From 23c07b71a269f2540e5c09eb8d2002d9f20a857e Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Thu, 25 Apr 2024 16:07:43 +0800
Subject: [PATCH] 1
---
src/main/java/com/nq/service/impl/UserStockSubscribeServiceImpl.java | 33 ++++++++++++++++++++++++++++-----
1 files changed, 28 insertions(+), 5 deletions(-)
diff --git a/src/main/java/com/nq/service/impl/UserStockSubscribeServiceImpl.java b/src/main/java/com/nq/service/impl/UserStockSubscribeServiceImpl.java
index 725d646..9729dfb 100644
--- a/src/main/java/com/nq/service/impl/UserStockSubscribeServiceImpl.java
+++ b/src/main/java/com/nq/service/impl/UserStockSubscribeServiceImpl.java
@@ -6,6 +6,7 @@
import com.github.pagehelper.PageInfo;
import com.nq.common.ServerResponse;
import com.nq.dao.StockSubscribeMapper;
+import com.nq.dao.UserAssetsMapper;
import com.nq.dao.UserMapper;
import com.nq.dao.UserStockSubscribeMapper;
import com.nq.enums.EStockType;
@@ -18,6 +19,7 @@
import com.nq.utils.redis.JsonUtil;
import com.nq.utils.redis.RedisShardedPoolUtils;
import com.nq.utils.stock.BuyAndSellUtils;
+import com.sun.org.apache.bcel.internal.generic.RETURN;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
@@ -64,6 +66,10 @@
@Resource
IUserAssetsServices iUserAssetsServices;
+
+ @Autowired
+ UserAssetsMapper userAssetsMapper;
+
/**
* 用户新股申购
* @param model
@@ -81,7 +87,7 @@
StockSubscribe stockSubscribe = stockSubscribeMapper.selectOne(new QueryWrapper<StockSubscribe>().eq("code", model.getNewCode()));
//实名认证开关
SiteProduct siteProduct = iSiteProductService.getProductSetting();
- if (siteProduct.getRealNameDisplay() && (StringUtils.isBlank(user.getRealName()) || StringUtils.isBlank(user.getIdCard()))) {
+ if (siteProduct.getRealNameDisplay() && user.getIsActive() != 2) {
return ServerResponse.createByErrorMsg("订单失败，请先实名认证",request);
}
@@ -127,7 +133,7 @@
BigDecimal bound = new BigDecimal(model.getApplyNums()).multiply(stockSubscribe.getPrice());
BigDecimal useEnaAmount = iUserAssetsServices.getAvailableBalance(EStockType.IN.getCode(), user.getId());
if(useEnaAmount.compareTo(bound)<0){
- ServerResponse.createByErrorMsg("余额不足,配售失败",request);
+ return ServerResponse.createByErrorMsg("余额不足,配售失败",request);
}
model.setUserId(user.getId());
model.setNewName(stockSubscribe.getName());
@@ -164,9 +170,9 @@
* admin 新股申购-添加和修改
*/
@Override
+ @Transactional
public ServerResponse save(UserStockSubscribe model, HttpServletRequest request) {
int ret = 0;
-
if( model.getId() != null ){
if (model.getStatus() == 3||model.getStatus() == 2) {
model.setEndTime(DateTimeUtil.getCurrentDate());
@@ -176,10 +182,28 @@
return ServerResponse.createByErrorMsg("It's been converted");
}
StockSubscribe stockSubscribe = stockSubscribeMapper.selectOne(new QueryWrapper<>(new StockSubscribe()).eq("code", userStockSubscribe.getNewCode()));
+ if((model.getStatus() == 3 && model.getApplyNumber() == null) || (model.getStatus() == 3 && model.getApplyNumber() == 0) ){
+ return ServerResponse.createByErrorMsg("中签数量不能小于0");
+ }
if (model.getStatus() == 3 && model.getApplyNumber() != null){
if(stockSubscribe.getType() == 1){
model.setBond(stockSubscribe.getPrice().multiply(BigDecimal.valueOf(model.getApplyNumber())));
model.setDbMoney(model.getDbMoney());
+ //客户中签直接扣除客户账户可用资金
+ UserAssets userAssets = iUserAssetsServices.assetsByTypeAndUserId("IN", userStockSubscribe.getUserId());
+ if(null == userAssets){
+ return ServerResponse.createByErrorMsg("客户资金账户不存在");
+ }
+ BigDecimal decimal = userStockSubscribe.getBuyPrice().multiply(new BigDecimal(model.getApplyNumber()));//中签总价
+ BigDecimal availableBalance = userAssets.getAvailableBalance().subtract(decimal);//剩余可用余额
+ if(decimal.compareTo(userAssets.getAvailableBalance()) <= 0){
+ userAssets.setAvailableBalance(availableBalance);
+ }else{
+ BigDecimal amountToBeCovered = decimal.subtract(userAssets.getAvailableBalance());//待补金额
+ userAssets.setAvailableBalance(BigDecimal.ZERO);
+ userAssets.setAmountToBeCovered(userAssets.getAmountToBeCovered().add(amountToBeCovered));
+ }
+ userAssetsMapper.updateById(userAssets);
ret = userStockSubscribeMapper.update1(model);
}else{
if(model.getApplyNumber()>model.getApplyNums()){
@@ -278,7 +302,6 @@
return ServerResponse.createByErrorMsg("Operation failure");
}
-
/**
* 发送站内信
*/
@@ -395,7 +418,7 @@
return ServerResponse.createByErrorMsg("余额不足",request);
}
iUserAssetsServices.availablebalanceChange(EStockType.IN.getCode(),userStockSubscribe.getUserId(),
- EUserAssets.BUY,multiply,"","");
+ EUserAssets.BUY,multiply.negate(),"","");
userStockSubscribe.setDbMoney(BigDecimal.ZERO);
userStockSubscribeMapper.update1(userStockSubscribe);
return ServerResponse.createBySuccess();
--
Gitblit v1.9.3