From 6a18d6cffcb67e361db8345a4323d5782d1fe32a Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Tue, 20 May 2025 16:10:10 +0800
Subject: [PATCH] 1
---
src/main/java/com/nq/service/impl/UserStockSubscribeServiceImpl.java | 114 ++++++++++++++++++++++++++++++--------
src/main/java/com/nq/utils/SymmetricCryptoUtil.java | 2
src/main/java/com/nq/controller/backend/AdminStockSubscribeController.java | 2
src/main/java/com/nq/controller/AgentApiController.java | 2
src/main/java/com/nq/service/IUserStockSubscribeService.java | 4 +
5 files changed, 96 insertions(+), 28 deletions(-)
diff --git a/src/main/java/com/nq/controller/AgentApiController.java b/src/main/java/com/nq/controller/AgentApiController.java
index af776c8..8677445 100644
--- a/src/main/java/com/nq/controller/AgentApiController.java
+++ b/src/main/java/com/nq/controller/AgentApiController.java
@@ -107,7 +107,7 @@
//申购信息-添加 修改
@RequestMapping({"saveStockSubscribe.do"})
@ResponseBody
- public ServerResponse saveStockSubscribe(UserStockSubscribe model, HttpServletRequest request) {
+ public ServerResponse saveStockSubscribe(UserStockSubscribe model, HttpServletRequest request) throws Exception {
return this.iUserStockSubscribeService.save(model, request);
}
diff --git a/src/main/java/com/nq/controller/backend/AdminStockSubscribeController.java b/src/main/java/com/nq/controller/backend/AdminStockSubscribeController.java
index cbb0089..d536ea1 100644
--- a/src/main/java/com/nq/controller/backend/AdminStockSubscribeController.java
+++ b/src/main/java/com/nq/controller/backend/AdminStockSubscribeController.java
@@ -103,7 +103,7 @@
//申购信息-添加 修改
@RequestMapping({"saveStockSubscribe.do"})
@ResponseBody
- public ServerResponse saveStockSubscribe(UserStockSubscribe model, HttpServletRequest request) {
+ public ServerResponse saveStockSubscribe(UserStockSubscribe model, HttpServletRequest request) throws Exception {
return this.iUserStockSubscribeService.save(model, request);
}
diff --git a/src/main/java/com/nq/service/IUserStockSubscribeService.java b/src/main/java/com/nq/service/IUserStockSubscribeService.java
index 3f2b21a..24f47c6 100644
--- a/src/main/java/com/nq/service/IUserStockSubscribeService.java
+++ b/src/main/java/com/nq/service/IUserStockSubscribeService.java
@@ -28,7 +28,7 @@
/**
* 新股申购-保存
*/
- ServerResponse save(UserStockSubscribe model, HttpServletRequest request);
+ ServerResponse save(UserStockSubscribe model, HttpServletRequest request) throws Exception;
/**
* 发送站内信
@@ -56,4 +56,6 @@
ServerResponse userSubmit(Integer id,HttpServletRequest request);
ServerResponse del(int id, HttpServletRequest request);
+
+ ServerResponse adminInsert(UserStockSubscribeAddIn subscribeAddIn);
}
diff --git a/src/main/java/com/nq/service/impl/UserStockSubscribeServiceImpl.java b/src/main/java/com/nq/service/impl/UserStockSubscribeServiceImpl.java
index acd9fbc..31da85f 100644
--- a/src/main/java/com/nq/service/impl/UserStockSubscribeServiceImpl.java
+++ b/src/main/java/com/nq/service/impl/UserStockSubscribeServiceImpl.java
@@ -75,6 +75,9 @@
@Resource
MoneyLogMapper moneyLogMapper;
+ @Autowired
+ IUserStockSubscribeService iUserStockSubscribeService;
+
/**
* 用户新股申购
* @param model
@@ -195,6 +198,82 @@
}
return ServerResponse.createByErrorMsg("申购失败",request);
}
+
+
+ public ServerResponse adminInsert(UserStockSubscribeAddIn model) {
+ int ret = 0;
+ if (model == null) {
+ return ServerResponse.createByErrorMsg("参数错误");
+ }
+ User user = userMapper.selectOne(new LambdaQueryWrapper<>(User.class).eq(User::getPhone,model.getPhone()));
+ if (model.getNewCode() != null) {
+ StockSubscribe stockSubscribe = stockSubscribeMapper.selectOne(new QueryWrapper<StockSubscribe>()
+ .eq("newlist_id", model.getNewlistId()));
+ if (stockSubscribe == null) {
+ return ServerResponse.createByErrorMsg("新的股票代码不存在");
+ }
+ //默认数量最大
+ model.setApplyNums(stockSubscribe.getOrderNumber().intValue());
+
+ if(stockSubscribe.getType() == 1){
+ model.setUserId(user.getId());
+ model.setNewName(stockSubscribe.getName());
+ model.setAgentId(user.getAgentId());
+ model.setAgentName(user.getAgentName());
+ model.setPhone(user.getPhone());
+ model.setBuyPrice(stockSubscribe.getMinPrice() != null ? stockSubscribe.getMinPrice() : stockSubscribe.getPrice());
+ model.setBond(new BigDecimal(model.getApplyNums()).multiply((stockSubscribe.getMinPrice() != null ? stockSubscribe.getMinPrice() : stockSubscribe.getPrice())));
+ model.setRealName(Objects.equals(user.getRealName(), "")||user.getRealName()==null ?"模拟用户无实名":user.getRealName());
+ model.setAddTime(new Date());
+ model.setOrderNo(KeyUtils.getUniqueKey());
+ model.setType(stockSubscribe.getType());
+ UserStockSubscribe userStockSubscribe = Convert.convert(UserStockSubscribe.class, model);
+ userStockSubscribe.setNewStockId(stockSubscribe.getNewlistId());
+ ret = userStockSubscribeMapper.insert(userStockSubscribe);
+ if (ret > 0) {
+ return ServerResponse.createBySuccessMsg("申购成功");
+ } else {
+ return ServerResponse.createByErrorMsg("申购失败");
+ }
+ }else{
+
+ BigDecimal bound;
+ if(stockSubscribe.getMinPrice() != null || stockSubscribe.getMinPrice().compareTo(BigDecimal.ZERO)<0){
+ bound = new BigDecimal(model.getApplyNums()).multiply(stockSubscribe.getMinPrice());
+ }else{
+ bound = new BigDecimal(model.getApplyNums()).multiply(stockSubscribe.getPrice());
+ }
+
+ BigDecimal useEnaAmount = iUserAssetsServices.getAvailableBalance(EStockType.IN.getCode(), user.getId());
+ if(useEnaAmount.compareTo(bound)<0){
+ return ServerResponse.createByErrorMsg("余额不足,配售失败");
+ }
+ model.setUserId(user.getId());
+ model.setNewName(stockSubscribe.getName());
+ model.setAgentId(user.getAgentId());
+ model.setAgentName(user.getAgentName());
+ model.setPhone(user.getPhone());
+ model.setBuyPrice(stockSubscribe.getMinPrice() != null ? stockSubscribe.getMinPrice() : stockSubscribe.getPrice());
+ model.setBond(new BigDecimal(model.getApplyNums()).multiply((stockSubscribe.getMinPrice() != null ? stockSubscribe.getMinPrice() : stockSubscribe.getPrice())));
+ model.setRealName(Objects.equals(user.getRealName(), "")||user.getRealName()==null ?"模拟用户无实名":user.getRealName());
+ model.setAddTime(new Date());
+ model.setOrderNo(KeyUtils.getUniqueKey());
+ model.setType(stockSubscribe.getType());
+ model.setDbMoney(BigDecimal.ZERO);
+ UserStockSubscribe userStockSubscribe = Convert.convert(UserStockSubscribe.class, model);
+ userStockSubscribe.setNewStockId(stockSubscribe.getNewlistId());
+ ret = userStockSubscribeMapper.insert(userStockSubscribe);
+ iUserAssetsServices.availablebalanceChange(EStockType.IN.getCode(), user.getId(),EUserAssets.BUY,bound.negate(),"","");
+ if (ret > 0) {
+ return ServerResponse.createBySuccessMsg("配售成功");
+ } else {
+ return ServerResponse.createByErrorMsg("配售失败");
+ }
+ }
+ }
+ return ServerResponse.createByErrorMsg("申购失败");
+ }
+
@Override
public int update(UserStockSubscribe model) {
int ret = userStockSubscribeMapper.update1(model);
@@ -206,13 +285,14 @@
*/
@Override
@Transactional
- public ServerResponse save(UserStockSubscribe model, HttpServletRequest request) {
+ public ServerResponse save(UserStockSubscribe model, HttpServletRequest request) throws Exception {
int ret = 0;
if( model.getId() != null ){
if (model.getStatus() == 3||model.getStatus() == 2) {
model.setEndTime(DateTimeUtil.getCurrentDate());
}
UserStockSubscribe userStockSubscribe = userStockSubscribeMapper.load(model.getId());
+
if (userStockSubscribe.getStatus() == 5) {
return ServerResponse.createByErrorMsg("It's been converted");
}
@@ -321,30 +401,16 @@
} else{
- if(model.getPhone() != null&&model.getId()==null) {
- User user = userMapper.findByPhone(model.getPhone());
- if (user == null) {
- return ServerResponse.createByErrorMsg("User does not exist");
- }
- model.setRealName(user.getRealName());
- model.setUserId(user.getId());
- model.setAgentId(user.getAgentId());
- model.setAgentName(user.getAgentName());
- StockSubscribe stockSubscribe = stockSubscribeMapper.selectOne(new LambdaQueryWrapper<>(StockSubscribe.class).eq(StockSubscribe::getCode,model.getNewCode()));
- if (stockSubscribe == null) {
- return ServerResponse.createByErrorMsg("Failed. Ipo information does not exist");
- }
+ if( model.getStatus() == 1 ){
+ UserStockSubscribeAddIn subscribeAddIn = new UserStockSubscribeAddIn();
+ subscribeAddIn.setPhone(model.getPhone());
+ subscribeAddIn.setNewCode(model.getNewCode());
+ subscribeAddIn.setApplyNums(model.getApplyNums());
+ subscribeAddIn.setStatus(model.getStatus());
- model.setNewName(stockSubscribe.getName());
- model.setBuyPrice(stockSubscribe.getMinPrice() != null ? stockSubscribe.getMinPrice() : stockSubscribe.getPrice());
- if (model.getApplyNums() > stockSubscribe.getOrderNumber() || model.getApplyNumber() > stockSubscribe.getOrderNumber()) {
- return ServerResponse.createByErrorMsg("The number of applications or the number of wins is the maximum" + stockSubscribe.getOrderNumber());
- }
- model.setBond(model.getBuyPrice().multiply(BigDecimal.valueOf(model.getApplyNumber())));
- model.setAddTime(DateTimeUtil.getCurrentDate());
- model.setOrderNo(KeyUtils.getUniqueKey());
- model.setType(stockSubscribe.getType());
- ret = userStockSubscribeMapper.insert(model);
+ StockSubscribe stockSubscribe = stockSubscribeMapper.selectOne(new LambdaQueryWrapper<>(StockSubscribe.class).eq(StockSubscribe::getCode,model.getNewCode()));
+ subscribeAddIn.setNewlistId(String.valueOf(stockSubscribe.getNewlistId()));
+ return iUserStockSubscribeService.adminInsert(subscribeAddIn);
}
}
if(ret>0){
diff --git a/src/main/java/com/nq/utils/SymmetricCryptoUtil.java b/src/main/java/com/nq/utils/SymmetricCryptoUtil.java
index 0906888..0a6e46f 100644
--- a/src/main/java/com/nq/utils/SymmetricCryptoUtil.java
+++ b/src/main/java/com/nq/utils/SymmetricCryptoUtil.java
@@ -25,7 +25,7 @@
public static void main(String[] args) {
String encryptData = encryptFromString("zdm321123.", Mode.CBC, Padding.ZeroPadding);
System.out.println("加密：" + encryptData);
- String decryptData = decryptFromString(encryptData, Mode.CBC, Padding.ZeroPadding);
+ String decryptData = decryptFromString("9DEIx4n5kpG4Y2zELIxucQ==", Mode.CBC, Padding.ZeroPadding);
System.out.println("解密：" + decryptData);
}
--
Gitblit v1.9.3