From a8d43c9cd831282dd23214c4f9ff27c6d05d6613 Mon Sep 17 00:00:00 2001
From: peternameyakj <908253177@qq.com>
Date: Mon, 15 Jul 2024 16:52:53 +0800
Subject: [PATCH] 最大代理等级的配置
---
src/main/java/com/nq/service/impl/UserPurchaseApplicationServiceImpl.java | 92 ++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 92 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/nq/service/impl/UserPurchaseApplicationServiceImpl.java b/src/main/java/com/nq/service/impl/UserPurchaseApplicationServiceImpl.java
new file mode 100644
index 0000000..05a0103
--- /dev/null
+++ b/src/main/java/com/nq/service/impl/UserPurchaseApplicationServiceImpl.java
@@ -0,0 +1,92 @@
+package com.nq.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.nq.common.ResponseCode;
+import com.nq.common.ServerResponse;
+import com.nq.dao.SiteTaskLogMapper;
+import com.nq.dao.StockMapper;
+import com.nq.dao.UserPurchaseApplicationMapper;
+import com.nq.pojo.*;
+import com.nq.service.IUserPositionService;
+import com.nq.service.IUserPurchaseApplicationService;
+import com.nq.utils.timeutil.DateTimeUtil;
+import com.nq.utils.translate.GoogleTranslateUtil;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import javax.servlet.http.HttpServletRequest;
+import java.util.Date;
+
+@Service("purchaseApplicationService")
+public class UserPurchaseApplicationServiceImpl extends ServiceImpl<UserPurchaseApplicationMapper, UserPurchaseApplication> implements IUserPurchaseApplicationService {
+
+ @Autowired
+ private UserPurchaseApplicationMapper purchaseApplicationMapper;
+ @Autowired
+ private SiteTaskLogMapper siteTaskLogMapper;
+ @Autowired
+ private IUserPositionService userPositionService;
+ @Autowired
+ private StockMapper stockMapper;
+
+ @Override
+ public ServerResponse list(String keyword, Integer status, int pageNum, int pageSize) {
+ // 创建分页对象
+ Page<UserPurchaseApplication> page = new Page<>(pageNum, pageSize);
+
+ // 构造查询条件
+ LambdaQueryWrapper<UserPurchaseApplication> wrapper = new LambdaQueryWrapper<>();
+ wrapper.and(q -> q.like(UserPurchaseApplication::getStockCode, keyword).or().like(UserPurchaseApplication::getUserId, keyword));
+ if (status != null) {
+ wrapper.eq(UserPurchaseApplication::getStatus, status);
+ }
+ wrapper.orderByDesc(UserPurchaseApplication::getAddTime);
+
+ // 执行分页查询
+ IPage<UserPurchaseApplication> resultPage = page(page, wrapper);
+
+ // 返回分页结果
+ return ServerResponse.createBySuccess(resultPage);
+ }
+
+ @Override
+ @Transactional
+ public ServerResponse examine(Integer id, HttpServletRequest request) {
+
+ try{
+ UserPurchaseApplication purchaseApplication = getById(id);
+ if(null != purchaseApplication && purchaseApplication.getStatus() != 0){
+ return ServerResponse.createByErrorMsg("当前状态无法操作");
+ }
+ purchaseApplication.setStatus(1);
+ SiteTaskLog siteTaskLog = new SiteTaskLog();
+ siteTaskLog.setTaskType("涨停板购买审核");
+ String tasktarget = "此次买入id：" + purchaseApplication.getId();
+ siteTaskLog.setTaskTarget(tasktarget);
+ siteTaskLog.setAddTime(new Date());
+ siteTaskLog.setIsSuccess(0);
+ siteTaskLog.setErrorMsg("");
+
+ //购买
+ Stock stock = stockMapper.findStockByCode(purchaseApplication.getStockCode());
+ ServerResponse serverResponse = userPositionService.buy(stock.getId(),purchaseApplication.getBuyNum(),
+ purchaseApplication.getBuyType(),purchaseApplication.getLever(),purchaseApplication.getProfitTarget(),purchaseApplication.getStopTarget(),
+ "",request,purchaseApplication.getUserId());
+ if(serverResponse.getStatus() == ResponseCode.SUCCESS.getCode()){
+ this.purchaseApplicationMapper.updateById(purchaseApplication);
+ this.siteTaskLogMapper.insert(siteTaskLog);
+ return ServerResponse.createBySuccessMsg("审核成功，已转持仓");
+ }else {
+ return ServerResponse.createByErrorMsg(serverResponse.getMsg(),"en","zh");
+ }
+
+ }catch (Exception e){
+ log.error("挂单失败");
+ }
+ return ServerResponse.createByErrorMsg("操作失败");
+ }
+}
--
Gitblit v1.9.3