From 0dd4d58348ea76cb24bbe3b862fec6ebbd35b78a Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Fri, 23 Jan 2026 12:40:00 +0800
Subject: [PATCH] 1
---
src/main/java/com/nq/service/impl/UserPositionServiceImpl.java | 460 ++++++++++++++++++++++++++++++++++++++++++++++++++-------
1 files changed, 400 insertions(+), 60 deletions(-)
diff --git a/src/main/java/com/nq/service/impl/UserPositionServiceImpl.java b/src/main/java/com/nq/service/impl/UserPositionServiceImpl.java
index 61f7920..8919907 100644
--- a/src/main/java/com/nq/service/impl/UserPositionServiceImpl.java
+++ b/src/main/java/com/nq/service/impl/UserPositionServiceImpl.java
@@ -104,6 +104,10 @@
CurrencyUtils currencyUtils;
@Autowired
StockDzMapper stockDzMapper;
+ @Autowired
+ StockVipMapper stockVipMapper;
+ @Autowired
+ FundFlowMapper fundFlowMapper;
@Transactional
@@ -777,6 +781,8 @@
BigDecimal reckon_all = user_all_amt.add(all_profit);
//修改用戶可用余額=當前可用余額+總盈虧+買入總金額+追加保證金
BigDecimal reckon_enable = user_enable_amt.add(all_profit).add(freez_amt).add(userPosition.getMarginAdd());
+ //锁定提现金额
+ BigDecimal lockAmount = reckon_enable.subtract(user_enable_amt);
log.info("用戶平倉後的總資金 = {} , 可用資金 = {}", reckon_all, reckon_enable);
user.setUserAmt(reckon_all);
@@ -788,6 +794,18 @@
log.error("用戶平倉】修改用戶金額出錯");
throw new Exception("用戶平倉】修改用戶金額出錯");
}
+ if (lockAmount.compareTo(BigDecimal.ZERO) > 0) {
+ Date date = new Date();
+ FundFlow fundFlow = new FundFlow();
+ fundFlow.setUserId(userPosition.getUserId());
+ fundFlow.setAmount(lockAmount);
+ fundFlow.setUsedAmount(BigDecimal.ZERO);
+ fundFlow.setWithdrawDate(DateTimeUtil.addDayAndGetZeroTime(date, 1));
+ fundFlow.setStatus(0);
+ fundFlow.setCreateTime(date);
+ fundFlowMapper.insert(fundFlow);
+ }
+
UserCashDetail ucd = new UserCashDetail();
ucd.setPositionId(userPosition.getId());
@@ -1983,6 +2001,10 @@
userPosition.setStockCode(userStockSubscribe.getNewCode());
userPosition.setStockName(userStockSubscribe.getNewName());
userPosition.setStockGid(stockSubscribe.getStockType() + userStockSubscribe.getNewCode());
+ Stock stock = stockMapper.selectOne(new QueryWrapper<Stock>().eq("stock_code", userStockSubscribe.getNewCode()));
+ if (stock != null) {
+ userPosition.setStockGid(stock.getStockGid());
+ }
userPosition.setBuyOrderId(GeneratePosition.getPositionId());
userPosition.setBuyOrderTime(new Date());
@@ -2089,70 +2111,73 @@
@Transactional
public ServerResponse buyDz(String stockCode, String password, Integer num, HttpServletRequest request) throws Exception {
- /*實名認證開關開啟*/
+ /*实名认证开关开启*/
SiteProduct siteProduct = iSiteProductService.getProductSetting();
User user = this.iUserService.getCurrentRefreshUser(request);
if (siteProduct.getRealNameDisplay() && (StringUtils.isBlank(user.getRealName()) || StringUtils.isBlank(user.getIdCard()))) {
- return ServerResponse.createByErrorMsg("下單失敗，請先實名認證");
+ return ServerResponse.createByErrorMsg("下单失败，请先实名认证");
}
BigDecimal user_enable_amt = user.getEnableAmt();
BigDecimal user_enable_withdraw_amt = user.getEnaleWithdrawAmt();
- log.info("用戶 {} 下單，股票code = {} ，數量 = {}", new Object[]{user
+ log.info("用户 {} 下单，股票code = {} ，数量 = {}", new Object[]{user
.getId(), stockCode, num});
if (siteProduct.getRealNameDisplay() && user.getIsLock().intValue() == 1) {
- return ServerResponse.createByErrorMsg("下單失敗，賬戶已被鎖定");
+ return ServerResponse.createByErrorMsg("下单失败，账户已被锁定");
}
SiteSetting siteSetting = this.iSiteSettingService.getSiteSetting();
if (siteSetting == null) {
- log.error("下單出錯，網站設置表不存在");
- return ServerResponse.createByErrorMsg("下單失敗，系統設置錯誤");
+ log.error("下单出错，网站设置表不存在");
+ return ServerResponse.createByErrorMsg("下单失败，系统设置错误");
}
StockDz stockDz = null;
- stockDz = this.stockDzMapper.selectOne(new QueryWrapper<StockDz>().eq("stock_code", stockCode));
- String am_begin = siteSetting.getTransAmBeginhk();
- String am_end = siteSetting.getTransAmEndhk();
- String pm_begin = siteSetting.getTransPmBeginhk();
- String pm_end = siteSetting.getTransPmEndhk();
- boolean am_flag = BuyAndSellUtils.isTransTime(am_begin, am_end);
- boolean pm_flag = BuyAndSellUtils.isTransTime(pm_begin, pm_end);
- log.info("是否在大宗交易時間 = {}", Boolean.valueOf(pm_flag));
+ stockDz = this.stockDzMapper.selectOne(new QueryWrapper<StockDz>().eq("stock_gid", stockCode));
+// String am_begin = siteSetting.getTransAmBeginhk();
+// String am_end = siteSetting.getTransAmEndhk();
+// String pm_begin = siteSetting.getTransPmBeginhk();
+// String pm_end = siteSetting.getTransPmEndhk();
+// boolean am_flag = BuyAndSellUtils.isTransTime(am_begin, am_end);
+// boolean pm_flag = BuyAndSellUtils.isTransTime(pm_begin, pm_end);
+// log.info("是否在大宗交易时间 = {}", Boolean.valueOf(pm_flag));
//15-15:30
// if (!pm_flag) {
-// return ServerResponse.createByErrorMsg("下單失敗，不在交易時段內");
+// return ServerResponse.createByErrorMsg("下单失败，不在交易时段内");
// }
+ if(stockDz.getStartTime().getTime() > new Date().getTime() || stockDz.getEndTime().getTime() < new Date().getTime()){
+ return ServerResponse.createByErrorMsg("不在交易时间之内");
+ }
if (siteProduct.getHolidayDisplay()) {
- return ServerResponse.createByErrorMsg("周末或節假日不能交易！");
+ return ServerResponse.createByErrorMsg("周末或节假日不能交易！");
}
if (!Objects.equals(stockDz.getPassword(), password)) {
- return ServerResponse.createByErrorMsg("下單失敗，密鑰錯誤");
+ return ServerResponse.createByErrorMsg("下单失败，密钥错误");
}
if (stockDz.getIsLock().intValue() != 0) {
- return ServerResponse.createByErrorMsg("下單失敗，當前股票不能交易");
+ return ServerResponse.createByErrorMsg("下单失败，当前股票不能交易");
}
List dbPosition = findPositionByStockCodeAndTimes(siteSetting.getBuySameTimes().intValue(), stockDz.getStockCode(), user.getId());
if (dbPosition.size() >= siteSetting.getBuySameNums().intValue()) {
- return ServerResponse.createByErrorMsg("頻繁交易," + siteSetting.getBuySameTimes() + "分鐘內同一股票持倉不得超過" + siteSetting
- .getBuySameNums() + "條");
+ return ServerResponse.createByErrorMsg("频繁交易," + siteSetting.getBuySameTimes() + "分钟内同一股票持仓不得超过" + siteSetting
+ .getBuySameNums() + "条");
}
Integer transNum = findPositionNumByTimes(siteSetting.getBuyNumTimes().intValue(), user.getId());
if (transNum.intValue() / 100 >= siteSetting.getBuyNumLots().intValue()) {
- return ServerResponse.createByErrorMsg("頻繁交易," + siteSetting
- .getBuyNumTimes() + "分鐘內不能超過" + siteSetting.getBuyNumLots() + "手");
+ return ServerResponse.createByErrorMsg("频繁交易," + siteSetting
+ .getBuyNumTimes() + "分钟内不能超过" + siteSetting.getBuyNumLots() + "手");
}
if (num < stockDz.getStockNum().intValue()) {
- return ServerResponse.createByErrorMsg("下單失敗，購買數量最小為" + stockDz.getStockNum() + "股");
+ return ServerResponse.createByErrorMsg("下单失败，购买数量最小为" + stockDz.getStockNum() + "股");
}
if (num > siteSetting.getBuyMaxNum()) {
- return ServerResponse.createByErrorMsg("下單失敗，購買數量大於" + siteSetting.getBuyMaxNum() + "股");
+ return ServerResponse.createByErrorMsg("下单失败，购买数量大于" + siteSetting.getBuyMaxNum() + "股");
}
BigDecimal now_price;
StockListVO stockListVO = new StockListVO();
- //價格處理
+ //价格处理
stockListVO = SinaStockApi.assembleLideStockListVO(LiDeDataUtils.getStock(stockDz.getStockCode()));
if (ObjectUtils.isEmpty(stockListVO)) {
stockListVO = SinaStockApi.assembleStockListVO(SinaStockApi.getSinaStock(stockDz.getStockGid()));
@@ -2160,7 +2185,7 @@
now_price = new BigDecimal(stockListVO.getNowPrice()).multiply(stockDz.getDiscount());
if (now_price.compareTo(new BigDecimal("0")) == 0) {
- return ServerResponse.createByErrorMsg("報價0，請稍後再試");
+ return ServerResponse.createByErrorMsg("报价0，请稍后再试");
}
@@ -2171,14 +2196,14 @@
if (stockDz.getStockPlate() != null) {
maxRisePercent = new BigDecimal("0.2");
- log.info("【科創股票】");
+ log.info("【科创股票】");
} else {
maxRisePercent = new BigDecimal("0.1");
log.info("【普通A股】");
}
if (stockListVO.getName().startsWith("ST") || stockListVO.getName().endsWith("退")) {
- return ServerResponse.createByErrorMsg("ST和已退市的股票不能入倉");
+ return ServerResponse.createByErrorMsg("ST和已退市的股票不能入仓");
}
BigDecimal zsPrice = new BigDecimal(stockListVO.getPreclose_px());
@@ -2189,7 +2214,7 @@
BigDecimal ztRate = chaPrice.multiply(new BigDecimal("100")).divide(zsPrice, 2, 4);
- log.info("當前漲跌幅 = {} % , 漲停幅度 = {} %", Double.valueOf(stock_crease), ztRate);
+ log.info("当前涨跌幅 = {} % , 涨停幅度 = {} %", Double.valueOf(stock_crease), ztRate);
if (stockDz.getStockPlate() == null || StringUtils.isEmpty(stockDz.getStockPlate())) {
@@ -2197,12 +2222,12 @@
int maxcrease = siteSetting.getCreaseMaxPercent().intValue();
if (stock_crease > 0.0D &&
stock_crease >= maxcrease) {
- return ServerResponse.createByErrorMsg("下單失敗，股票當前漲幅:" + stock_crease + ",大於最大漲幅:" + maxcrease);
+ return ServerResponse.createByErrorMsg("下单失败，股票当前涨幅:" + stock_crease + ",大于最大涨幅:" + maxcrease);
}
if (stock_crease < 0.0D &&
-stock_crease > maxcrease) {
- return ServerResponse.createByErrorMsg("下單失敗，股票當前跌幅:" + stock_crease + ",大於最大跌幅:" + maxcrease);
+ return ServerResponse.createByErrorMsg("下单失败，股票当前跌幅:" + stock_crease + ",大于最大跌幅:" + maxcrease);
}
@@ -2211,24 +2236,24 @@
int maxcrease = siteSetting.getCyCreaseMaxPercent().intValue();
if (stock_crease > 0.0D &&
stock_crease >= maxcrease) {
- return ServerResponse.createByErrorMsg("下單失敗，創業股當前漲幅:" + stock_crease + ",大於最大漲幅:" + maxcrease);
+ return ServerResponse.createByErrorMsg("下单失败，创业股当前涨幅:" + stock_crease + ",大于最大涨幅:" + maxcrease);
}
if (stock_crease < 0.0D &&
-stock_crease > maxcrease) {
- return ServerResponse.createByErrorMsg("下單失敗，創業股當前跌幅:" + stock_crease + ",大於最大跌幅:" + maxcrease);
+ return ServerResponse.createByErrorMsg("下单失败，创业股当前跌幅:" + stock_crease + ",大于最大跌幅:" + maxcrease);
}
} else {
int maxcrease = siteSetting.getKcCreaseMaxPercent().intValue();
if (stock_crease > 0.0D &&
stock_crease >= maxcrease) {
- return ServerResponse.createByErrorMsg("下單失敗，科創股當前漲幅:" + stock_crease + ",大於最大漲幅:" + maxcrease);
+ return ServerResponse.createByErrorMsg("下单失败，科创股当前涨幅:" + stock_crease + ",大于最大涨幅:" + maxcrease);
}
if (stock_crease < 0.0D &&
-stock_crease > maxcrease) {
- return ServerResponse.createByErrorMsg("下單失敗，科創股當前跌幅:" + stock_crease + ",大於最大跌幅:" + maxcrease);
+ return ServerResponse.createByErrorMsg("下单失败，科创股当前跌幅:" + stock_crease + ",大于最大跌幅:" + maxcrease);
}
}
@@ -2238,11 +2263,11 @@
return serverResponse;
}
BigDecimal daysRate = (BigDecimal) serverResponse.getData();
- log.info("股票 {} ， {} 天內 漲幅 {} , 設置的漲幅 = {}", new Object[]{stockDz.getStockCode(), siteSetting
+ log.info("股票 {} ， {} 天内 涨幅 {} , 设置的涨幅 = {}", new Object[]{stockDz.getStockCode(), siteSetting
.getStockDays(), daysRate, siteSetting.getStockRate()});
if (daysRate != null && siteSetting.getStockRate().compareTo(daysRate) == -1) {
- return serverResponse.createByErrorMsg(siteSetting.getStockDays() + "天內漲幅超過 " + siteSetting
+ return serverResponse.createByErrorMsg(siteSetting.getStockDays() + "天内涨幅超过 " + siteSetting
.getStockRate() + "不能交易");
}
@@ -2257,7 +2282,7 @@
int compareInt = buy_amt_autual.compareTo(new BigDecimal(siteSetting.getBuyMinAmt().intValue()));
if (compareInt == -1) {
- return ServerResponse.createByErrorMsg("下單失敗，購買金額小於" + siteSetting
+ return ServerResponse.createByErrorMsg("下单失败，购买金额小于" + siteSetting
.getBuyMinAmt() + "元");
}
@@ -2265,16 +2290,16 @@
BigDecimal max_buy_amt = user_enable_amt.multiply(siteSetting.getBuyMaxAmtPercent());
int compareCwInt = buy_amt_autual.compareTo(max_buy_amt);
if (compareCwInt == 1) {
- return ServerResponse.createByErrorMsg("下單失敗，不能超過可用資金的" + siteSetting
+ return ServerResponse.createByErrorMsg("下单失败，不能超过可用资金的" + siteSetting
.getBuyMaxAmtPercent().multiply(new BigDecimal("100")) + "%");
}
int compareUserAmtInt = user_enable_amt.compareTo(buy_amt_autual);
- log.info("用戶可用金額 = {} 實際購買金額 = {}", user_enable_amt, buy_amt_autual);
- log.info("比較 用戶金額 和 實際 購買金額 = {}", Integer.valueOf(compareUserAmtInt));
+ log.info("用户可用金额 = {} 实际购买金额 = {}", user_enable_amt, buy_amt_autual);
+ log.info("比较 用户金额 和 实际 购买金额 = {}", Integer.valueOf(compareUserAmtInt));
if (compareUserAmtInt == -1) {
- return ServerResponse.createByErrorMsg("下單失敗，融資可用金額小於" + buy_amt_autual + "元");
+ return ServerResponse.createByErrorMsg("下单失败，融资可用金额小于" + buy_amt_autual + "元");
}
// if (user.getUserIndexAmt().compareTo(new BigDecimal("0")) == -1) {
@@ -2294,7 +2319,7 @@
userPosition.setBuyOrderId(GeneratePosition.getPositionId());
userPosition.setBuyOrderTime(new Date());
userPosition.setBuyOrderPrice(now_price);
- userPosition.setOrderDirection("買漲");
+ userPosition.setOrderDirection("买涨");
userPosition.setOrderNum(num);
if (stockDz.getStockPlate() != null) {
userPosition.setStockPlate(stockDz.getStockPlate());
@@ -2303,7 +2328,7 @@
userPosition.setOrderLever(1);
userPosition.setOrderTotalPrice(buy_amt);
- //遞延費特殊處理
+ //递延费特殊处理
BigDecimal stayFee = userPosition.getOrderTotalPrice().multiply(siteSetting.getStayFee());
BigDecimal allStayFee = stayFee.multiply(new BigDecimal(1));
userPosition.setOrderStayFee(allStayFee);
@@ -2311,21 +2336,21 @@
BigDecimal buy_fee_amt = buy_amt.multiply(siteSetting.getBuyFee()).setScale(2, 4);
- log.info("用戶購買手續費（配資後總資金 * 百分比） = {}", buy_fee_amt);
+ log.info("用户购买手续费（配资后总资金 * 百分比） = {}", buy_fee_amt);
userPosition.setOrderFee(buy_fee_amt);
BigDecimal buy_yhs_amt = buy_amt.multiply(siteSetting.getDutyFee()).setScale(2, 4);
- log.info("用戶購買印花稅（配資後總資金 * 百分比） = {}", buy_yhs_amt);
+ log.info("用户购买印花税（配资后总资金 * 百分比） = {}", buy_yhs_amt);
userPosition.setOrderSpread(buy_yhs_amt);
SiteSpread siteSpread = iSiteSpreadService.findSpreadRateOne(new BigDecimal(stock_crease), buy_amt, stockDz.getStockCode(), now_price);
BigDecimal spread_rate_amt = new BigDecimal("0");
if (siteSpread != null) {
spread_rate_amt = buy_amt.multiply(siteSpread.getSpreadRate()).setScale(2, 4);
- log.info("用戶購買點差費（配資後總資金 * 百分比{}） = {}", siteSpread.getSpreadRate(), spread_rate_amt);
+ log.info("用户购买点差费（配资后总资金 * 百分比{}） = {}", siteSpread.getSpreadRate(), spread_rate_amt);
} else {
- log.info("用戶購買點差費（配資後總資金 * 百分比{}） = {}", "設置異常", spread_rate_amt);
+ log.info("用户购买点差费（配资后总资金 * 百分比{}） = {}", "设置异常", spread_rate_amt);
}
userPosition.setSpreadRatePrice(spread_rate_amt);
@@ -2347,14 +2372,14 @@
this.userPositionMapper.insert(userPosition);
insertPositionCount = userPosition.getId();
if (insertPositionCount > 0) {
- //修改用戶可用余額= 當前余額-下單金額-買入手續費-印花稅-點差費
+ //修改用户可用余额= 当前余额-下单金额-买入手续费-印花税-点差费
//BigDecimal reckon_enable = user_enable_amt.subtract(buy_amt_autual).subtract(buy_fee_amt).subtract(buy_yhs_amt).subtract(spread_rate_amt);
- //修改用戶可用余額= 當前余額-下單總金額
+ //修改用户可用余额= 当前余额-下单总金额
BigDecimal reckon_enable = user_enable_amt.subtract(buy_amt_autual);
- //修改用戶可取余額=當前可取余額-下單總金額
+ //修改用户可取余额=当前可取余额-下单总金额
int compareUserWithdrawAmtInt = user_enable_withdraw_amt.compareTo(buy_amt_autual);
if (compareUserWithdrawAmtInt == -1) {
- //若可取余額小於下單總額，但是可用余額充足，令可取余額為0
+ //若可取余额小于下单总额，但是可用余额充足，令可取余额为0
user.setEnaleWithdrawAmt(BigDecimal.ZERO);
} else {
user_enable_withdraw_amt = user_enable_withdraw_amt.subtract(buy_amt_autual);
@@ -2363,20 +2388,335 @@
user.setEnableAmt(reckon_enable);
int updateUserCount = this.userMapper.updateByPrimaryKeySelective(user);
if (updateUserCount > 0) {
- log.info("【用戶交易下單】修改用戶金額成功");
+ log.info("【用户交易下单】修改用户金额成功");
} else {
- log.error("用戶交易下單】修改用戶金額出錯");
- throw new Exception("用戶交易下單】修改用戶金額出錯");
+ log.error("用户交易下单】修改用户金额出错");
+ throw new Exception("用户交易下单】修改用户金额出错");
}
- //核算代理收入-入倉手續費
+ //核算代理收入-入仓手续费
iAgentAgencyFeeService.AgencyFeeIncome(1, userPosition.getPositionSn());
- log.info("【用戶交易下單】保存持倉記錄成功");
+ log.info("【用户交易下单】保存持仓记录成功");
} else {
- log.error("用戶交易下單】保存持倉記錄出錯");
- throw new Exception("用戶交易下單】保存持倉記錄出錯");
+ log.error("用户交易下单】保存持仓记录出错");
+ throw new Exception("用户交易下单】保存持仓记录出错");
}
- return ServerResponse.createBySuccess("大宗交易下單成功");
+ return ServerResponse.createBySuccess("大宗交易下单成功");
+ }
+
+ @Override
+ public ServerResponse buyStockVipList(HttpServletRequest request) {
+ User user = this.iUserService.getCurrentRefreshUser(request);
+ if (user == null) {
+ return null;
+ }
+ List<UserPosition> vipList = userPositionMapper.selectList(new QueryWrapper<UserPosition>().eq("user_id", user.getId()).eq("position_type", 4).orderByDesc("buy_order_time"));
+ return ServerResponse.createBySuccess(vipList);
+
+ }
+
+ /**
+ * VIP下單
+ *
+ * @param stockCode
+ * @param password
+ * @param num
+ * @param request
+ * @return
+ */
+ @Transactional
+ public ServerResponse buyVip(String stockCode, String password, Integer num, HttpServletRequest request) throws Exception {
+
+ /*實名認證開關開啟*/
+ SiteProduct siteProduct = iSiteProductService.getProductSetting();
+ User user = this.iUserService.getCurrentRefreshUser(request);
+ if (siteProduct.getRealNameDisplay() && (StringUtils.isBlank(user.getRealName()) || StringUtils.isBlank(user.getIdCard()))) {
+ return ServerResponse.createByErrorMsg("下單失敗，請先實名認證");
+ }
+ BigDecimal user_enable_amt = user.getEnableAmt();
+ BigDecimal user_enable_withdraw_amt = user.getEnaleWithdrawAmt();
+ log.info("用戶 {} 下單，股票code = {} ，數量 = {}", new Object[]{user
+ .getId(), stockCode, num});
+ if (siteProduct.getRealNameDisplay() && user.getIsLock().intValue() == 1) {
+ return ServerResponse.createByErrorMsg("下單失敗，賬戶已被鎖定");
+ }
+
+ SiteSetting siteSetting = this.iSiteSettingService.getSiteSetting();
+ if (siteSetting == null) {
+ log.error("下單出錯，網站設置表不存在");
+ return ServerResponse.createByErrorMsg("下單失敗，系統設置錯誤");
+ }
+ StockVip stockVip = null;
+ stockVip = this.stockVipMapper.selectOne(new QueryWrapper<StockVip>().eq("stock_gid", stockCode));
+// String am_begin = siteSetting.getTransAmBeginhk();
+// String am_end = siteSetting.getTransAmEndhk();
+// String pm_begin = siteSetting.getTransPmBeginhk();
+// String pm_end = siteSetting.getTransPmEndhk();
+// boolean am_flag = BuyAndSellUtils.isTransTime(am_begin, am_end);
+// boolean pm_flag = BuyAndSellUtils.isTransTime(pm_begin, pm_end);
+// log.info("是否在VIP交易时间 = {}", Boolean.valueOf(pm_flag));
+// if (!pm_flag) {
+// return ServerResponse.createByErrorMsg("下单失败，不在交易时段内");
+// }
+ if(stockVip.getStartTime().getTime() > new Date().getTime() || stockVip.getEndTime().getTime() < new Date().getTime()){
+ return ServerResponse.createByErrorMsg("不在交易时间之内");
+ }
+ if (siteProduct.getHolidayDisplay()) {
+ return ServerResponse.createByErrorMsg("周末或节假日不能交易！");
+ }
+ if (!Objects.equals(stockVip.getPassword(), password)) {
+ return ServerResponse.createByErrorMsg("下单失败，密钥错误");
+ }
+
+ if (stockVip.getIsLock().intValue() != 0) {
+ return ServerResponse.createByErrorMsg("下单失败，当前股票不能交易");
+ }
+
+ List dbPosition = findPositionByStockCodeAndTimes(siteSetting.getBuySameTimes().intValue(), stockVip.getStockCode(), user.getId());
+ if (dbPosition.size() >= siteSetting.getBuySameNums().intValue()) {
+ return ServerResponse.createByErrorMsg("频繁交易," + siteSetting.getBuySameTimes() + "分钟内同一股票持仓不得超过" + siteSetting
+ .getBuySameNums() + "条");
+ }
+
+ Integer transNum = findPositionNumByTimes(siteSetting.getBuyNumTimes().intValue(), user.getId());
+ if (transNum.intValue() / 100 >= siteSetting.getBuyNumLots().intValue()) {
+ return ServerResponse.createByErrorMsg("频繁交易," + siteSetting
+ .getBuyNumTimes() + "分钟内不能超过" + siteSetting.getBuyNumLots() + "手");
+ }
+
+ if (num < stockVip.getStockNum().intValue()) {
+ return ServerResponse.createByErrorMsg("下单失败，购买数量最小为" + stockVip.getStockNum() + "股");
+ }
+ if (num > siteSetting.getBuyMaxNum()) {
+ return ServerResponse.createByErrorMsg("下单失败，购买数量大于" + siteSetting.getBuyMaxNum() + "股");
+ }
+ BigDecimal now_price;
+ StockListVO stockListVO = new StockListVO();
+ //价格处理
+ stockListVO = SinaStockApi.assembleLideStockListVO(LiDeDataUtils.getStock(stockVip.getStockCode()));
+ if (ObjectUtils.isEmpty(stockListVO)) {
+ stockListVO = SinaStockApi.assembleStockListVO(SinaStockApi.getSinaStock(stockVip.getStockGid()));
+ }
+ now_price = new BigDecimal(stockListVO.getNowPrice()).multiply(stockVip.getDiscount());
+
+ if (now_price.compareTo(new BigDecimal("0")) == 0) {
+ return ServerResponse.createByErrorMsg("报价0，请稍后再试");
+ }
+
+
+ double stock_crease = stockListVO.getHcrate().doubleValue();
+
+
+ BigDecimal maxRisePercent = new BigDecimal("0");
+ if (stockVip.getStockPlate() != null) {
+
+ maxRisePercent = new BigDecimal("0.2");
+ log.info("【科创股票】");
+ } else {
+ maxRisePercent = new BigDecimal("0.1");
+ log.info("【普通A股】");
+ }
+
+ if (stockListVO.getName().startsWith("ST") || stockListVO.getName().endsWith("退")) {
+ return ServerResponse.createByErrorMsg("ST和已退市的股票不能入仓");
+ }
+
+ BigDecimal zsPrice = new BigDecimal(stockListVO.getPreclose_px());
+
+ BigDecimal ztPrice = zsPrice.multiply(maxRisePercent).add(zsPrice);
+ ztPrice = ztPrice.setScale(2, 4);
+ BigDecimal chaPrice = ztPrice.subtract(zsPrice);
+
+ BigDecimal ztRate = chaPrice.multiply(new BigDecimal("100")).divide(zsPrice, 2, 4);
+
+ log.info("当前涨跌幅 = {} % , 涨停幅度 = {} %", Double.valueOf(stock_crease), ztRate);
+
+
+ if (stockVip.getStockPlate() == null || StringUtils.isEmpty(stockVip.getStockPlate())) {
+
+ int maxcrease = siteSetting.getCreaseMaxPercent().intValue();
+ if (stock_crease > 0.0D &&
+ stock_crease >= maxcrease) {
+ return ServerResponse.createByErrorMsg("下单失败，股票当前涨幅:" + stock_crease + ",大于最大涨幅:" + maxcrease);
+ }
+
+ if (stock_crease < 0.0D &&
+ -stock_crease > maxcrease) {
+ return ServerResponse.createByErrorMsg("下单失败，股票当前跌幅:" + stock_crease + ",大于最大跌幅:" + maxcrease);
+
+ }
+
+ } else if ("創業".equals(stockVip.getStockPlate())) {
+
+ int maxcrease = siteSetting.getCyCreaseMaxPercent().intValue();
+ if (stock_crease > 0.0D &&
+ stock_crease >= maxcrease) {
+ return ServerResponse.createByErrorMsg("下单失败，创业股当前涨幅:" + stock_crease + ",大于最大涨幅:" + maxcrease);
+ }
+
+ if (stock_crease < 0.0D &&
+ -stock_crease > maxcrease) {
+ return ServerResponse.createByErrorMsg("下单失败，创业股当前跌幅:" + stock_crease + ",大于最大跌幅:" + maxcrease);
+ }
+ } else {
+
+ int maxcrease = siteSetting.getKcCreaseMaxPercent().intValue();
+ if (stock_crease > 0.0D &&
+ stock_crease >= maxcrease) {
+ return ServerResponse.createByErrorMsg("下单失败，科创股当前涨幅:" + stock_crease + ",大于最大涨幅:" + maxcrease);
+ }
+
+ if (stock_crease < 0.0D &&
+ -stock_crease > maxcrease) {
+ return ServerResponse.createByErrorMsg("下单失败，科创股当前跌幅:" + stock_crease + ",大于最大跌幅:" + maxcrease);
+ }
+ }
+
+
+ ServerResponse serverResponse = this.iStockService.selectRateByDaysAndStockCode(stockVip.getStockCode(), siteSetting.getStockDays().intValue());
+ if (!serverResponse.isSuccess()) {
+ return serverResponse;
+ }
+ BigDecimal daysRate = (BigDecimal) serverResponse.getData();
+ log.info("股票 {} ， {} 天内 涨幅 {} , 设置的涨幅 = {}", new Object[]{stockVip.getStockCode(), siteSetting
+ .getStockDays(), daysRate, siteSetting.getStockRate()});
+
+ if (daysRate != null && siteSetting.getStockRate().compareTo(daysRate) == -1) {
+ return serverResponse.createByErrorMsg(siteSetting.getStockDays() + "天内涨幅超过 " + siteSetting
+ .getStockRate() + "不能交易");
+ }
+
+
+ //BigDecimal buy_amt = now_price.multiply(new BigDecimal(buyNum.intValue())).divide(new BigDecimal(lever.intValue())).setScale(2, 4);
+ BigDecimal buy_amt = now_price.multiply(new BigDecimal(num.intValue()));
+
+
+ //BigDecimal buy_amt_autual = now_price.multiply(new BigDecimal(buyNum.intValue())).divide(new BigDecimal(lever.intValue()), 2, 4);
+ BigDecimal buy_amt_autual = buy_amt.divide(new BigDecimal(1), 2, 4);
+
+
+ int compareInt = buy_amt_autual.compareTo(new BigDecimal(siteSetting.getBuyMinAmt().intValue()));
+ if (compareInt == -1) {
+ return ServerResponse.createByErrorMsg("下单失败，购买金额小于" + siteSetting
+ .getBuyMinAmt() + "元");
+ }
+
+
+ BigDecimal max_buy_amt = user_enable_amt.multiply(siteSetting.getBuyMaxAmtPercent());
+ int compareCwInt = buy_amt_autual.compareTo(max_buy_amt);
+ if (compareCwInt == 1) {
+ return ServerResponse.createByErrorMsg("下单失败，不能超过可用资金的" + siteSetting
+ .getBuyMaxAmtPercent().multiply(new BigDecimal("100")) + "%");
+ }
+
+
+ int compareUserAmtInt = user_enable_amt.compareTo(buy_amt_autual);
+ log.info("用户可用金额 = {} 实际购买金额 = {}", user_enable_amt, buy_amt_autual);
+ log.info("比较 用户金额 和 实际 购买金额 = {}", Integer.valueOf(compareUserAmtInt));
+ if (compareUserAmtInt == -1) {
+ return ServerResponse.createByErrorMsg("下单失败，融资可用金额小于" + buy_amt_autual + "元");
+ }
+
+// if (user.getUserIndexAmt().compareTo(new BigDecimal("0")) == -1) {
+// return ServerResponse.createByErrorMsg("失敗，指數總資金小於0");
+// }
+//
+ UserPosition userPosition = new UserPosition();
+ userPosition.setPositionType(4);
+ userPosition.setPositionSn(KeyUtils.getUniqueKey());
+ userPosition.setUserId(user.getId());
+ userPosition.setNickName(user.getRealName());
+ userPosition.setAgentId(user.getAgentId());
+ userPosition.setStockCode(stockVip.getStockCode());
+ userPosition.setStockName(stockVip.getStockName());
+ userPosition.setStockGid(stockVip.getStockGid());
+ userPosition.setStockSpell(GetPyByChinese.converterToFirstSpell(stockVip.getStockName()));
+ userPosition.setBuyOrderId(GeneratePosition.getPositionId());
+ userPosition.setBuyOrderTime(new Date());
+ userPosition.setBuyOrderPrice(now_price);
+ userPosition.setOrderDirection("买涨");
+ userPosition.setOrderNum(num);
+ if (stockVip.getStockPlate() != null) {
+ userPosition.setStockPlate(stockVip.getStockPlate());
+ }
+ userPosition.setIsLock(Integer.valueOf(0));
+ userPosition.setOrderLever(1);
+ userPosition.setOrderTotalPrice(buy_amt);
+
+ //递延费特殊处理
+ BigDecimal stayFee = userPosition.getOrderTotalPrice().multiply(siteSetting.getStayFee());
+ BigDecimal allStayFee = stayFee.multiply(new BigDecimal(1));
+ userPosition.setOrderStayFee(allStayFee);
+ userPosition.setOrderStayDays(1);
+
+
+ BigDecimal buy_fee_amt = buy_amt.multiply(siteSetting.getBuyFee()).setScale(2, 4);
+ log.info("用户购买手续费（配资后总资金 * 百分比） = {}", buy_fee_amt);
+ userPosition.setOrderFee(buy_fee_amt);
+
+
+ BigDecimal buy_yhs_amt = buy_amt.multiply(siteSetting.getDutyFee()).setScale(2, 4);
+ log.info("用户购买印花税（配资后总资金 * 百分比） = {}", buy_yhs_amt);
+ userPosition.setOrderSpread(buy_yhs_amt);
+
+ SiteSpread siteSpread = iSiteSpreadService.findSpreadRateOne(new BigDecimal(stock_crease), buy_amt, stockVip.getStockCode(), now_price);
+ BigDecimal spread_rate_amt = new BigDecimal("0");
+ if (siteSpread != null) {
+ spread_rate_amt = buy_amt.multiply(siteSpread.getSpreadRate()).setScale(2, 4);
+ log.info("用户购买点差费（配资后总资金 * 百分比{}） = {}", siteSpread.getSpreadRate(), spread_rate_amt);
+ } else {
+ log.info("用户购买点差费（配资后总资金 * 百分比{}） = {}", "设置异常", spread_rate_amt);
+ }
+
+ userPosition.setSpreadRatePrice(spread_rate_amt);
+
+
+ BigDecimal profit_and_lose = new BigDecimal("0");
+ userPosition.setProfitAndLose(profit_and_lose);
+
+
+ BigDecimal all_profit_and_lose = profit_and_lose.subtract(buy_fee_amt).subtract(buy_yhs_amt).subtract(spread_rate_amt);
+ userPosition.setAllProfitAndLose(all_profit_and_lose);
+
+ userPosition.setOrderStayDays(Integer.valueOf(0));
+ userPosition.setOrderStayFee(new BigDecimal("0"));
+
+ log.info("--------------购买逻辑股票数据 buyVip stock------" + new Gson().toJson(userPosition));
+
+ int insertPositionCount = 0;
+ this.userPositionMapper.insert(userPosition);
+ insertPositionCount = userPosition.getId();
+ if (insertPositionCount > 0) {
+ //修改用户可用余额= 当前余额-下单金额-买入手续费-印花税-点差费
+ //BigDecimal reckon_enable = user_enable_amt.subtract(buy_amt_autual).subtract(buy_fee_amt).subtract(buy_yhs_amt).subtract(spread_rate_amt);
+ //修改用户可用余额= 当前余额-下单总金额
+ BigDecimal reckon_enable = user_enable_amt.subtract(buy_amt_autual);
+ //修改用户可取余额=当前可取余额-下单总金额
+ int compareUserWithdrawAmtInt = user_enable_withdraw_amt.compareTo(buy_amt_autual);
+ if (compareUserWithdrawAmtInt == -1) {
+ //若可取余额小于下单总额，但是可用余额充足，令可取余额为0
+ user.setEnaleWithdrawAmt(BigDecimal.ZERO);
+ } else {
+ user_enable_withdraw_amt = user_enable_withdraw_amt.subtract(buy_amt_autual);
+ user.setEnaleWithdrawAmt(user_enable_withdraw_amt);
+ }
+ user.setEnableAmt(reckon_enable);
+ int updateUserCount = this.userMapper.updateByPrimaryKeySelective(user);
+ if (updateUserCount > 0) {
+ log.info("【用户交易下单】修改用户金额成功");
+ } else {
+ log.error("用户交易下单】修改用户金额出错");
+ throw new Exception("用户交易下单】修改用户金额出错");
+ }
+ //核算代理收入-入仓手续费
+ iAgentAgencyFeeService.AgencyFeeIncome(1, userPosition.getPositionSn());
+ log.info("【用户交易下单】保存持仓记录成功");
+ } else {
+ log.error("用户交易下单】保存持仓记录出错");
+ throw new Exception("用户交易下单】保存持仓记录出错");
+ }
+
+ return ServerResponse.createBySuccess("VIP交易下单成功");
}
/**
--
Gitblit v1.9.3