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/SiteVipRobServiceImpl.java | 130 +++++++++++++++++++++++++++++++++++++++++++
1 files changed, 130 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/nq/service/impl/SiteVipRobServiceImpl.java b/src/main/java/com/nq/service/impl/SiteVipRobServiceImpl.java
new file mode 100644
index 0000000..0ee8d2a
--- /dev/null
+++ b/src/main/java/com/nq/service/impl/SiteVipRobServiceImpl.java
@@ -0,0 +1,130 @@
+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.ServerResponse;
+import com.nq.dao.SiteVipRobMapper;
+import com.nq.dao.StockMapper;
+import com.nq.pojo.SiteVipRob;
+import com.nq.pojo.Stock;
+import com.nq.pojo.UserPurchaseApplication;
+import com.nq.service.ISiteVipRobService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.math.BigDecimal;
+import java.util.Date;
+import java.util.List;
+
+@Service("iSiteVipRobService")
+public class SiteVipRobServiceImpl extends ServiceImpl<SiteVipRobMapper, SiteVipRob> implements ISiteVipRobService {
+ private static final Logger log = LoggerFactory.getLogger(SiteVipRobServiceImpl.class);
+
+ @Autowired
+ SiteVipRobMapper siteVipRobMapper;
+ @Autowired
+ StockMapper stockMapper;
+
+ @Override
+ public ServerResponse insert(SiteVipRob siteVipRob) {
+ // 构造查询条件
+ LambdaQueryWrapper<SiteVipRob> wrapper = new LambdaQueryWrapper<>();
+ wrapper.eq(SiteVipRob::getStockCode, siteVipRob.getStockCode());
+ if(siteVipRob.getStockChg().compareTo(new BigDecimal(0)) < 0 || siteVipRob.getStockChg().compareTo(new BigDecimal(100)) >= 0){
+ return ServerResponse.createByErrorMsg("涨跌幅在0~100之间");
+ }
+ // 查询是否存在相同的股票代码设置
+ List<SiteVipRob> list = list(wrapper);
+ if (!list.isEmpty()) {
+ return ServerResponse.createByErrorMsg("该股票代码设置已存在");
+ }
+ Stock stock = stockMapper.findStockByCode(siteVipRob.getStockCode());
+ if(null == stock){
+ return ServerResponse.createByErrorMsg("股票代码不存在");
+ }
+ // 设置创建时间
+ siteVipRob.setCreateTime(new Date());
+
+ // 执行保存操作
+ if (save(siteVipRob)) {
+ return ServerResponse.createBySuccessMsg("添加成功");
+ } else {
+ return ServerResponse.createByErrorMsg("添加失败");
+ }
+ }
+
+
+ @Override
+ public ServerResponse modify(SiteVipRob siteVipRob) {
+ // 构造查询条件
+ LambdaQueryWrapper<SiteVipRob> wrapper = new LambdaQueryWrapper<>();
+ wrapper.eq(SiteVipRob::getStockCode, siteVipRob.getStockCode())
+ .ne(SiteVipRob::getId, siteVipRob.getId());
+ if(siteVipRob.getStockChg().compareTo(new BigDecimal(0)) < 0 || siteVipRob.getStockChg().compareTo(new BigDecimal(100)) >= 0){
+ return ServerResponse.createByErrorMsg("涨跌幅在0~100之间");
+ }
+ // 查询是否存在相同的股票代码设置
+ List<SiteVipRob> list = list(wrapper);
+ if (!list.isEmpty()) {
+ return ServerResponse.createByErrorMsg("该股票代码设置已存在");
+ }
+ Stock stock = stockMapper.findStockByCode(siteVipRob.getStockCode());
+ if(null == stock){
+ return ServerResponse.createByErrorMsg("股票代码不存在");
+ }
+ // 更新修改时间
+ siteVipRob.setUpdateTime(new Date());
+
+ // 执行更新操作
+ if (updateById(siteVipRob)) {
+ return ServerResponse.createBySuccessMsg("修改成功");
+ } else {
+ return ServerResponse.createByErrorMsg("修改失败");
+ }
+ }
+
+
+ @Override
+ public ServerResponse list(String keyword, Integer status, int pageNum, int pageSize) {
+ // 创建分页对象
+ Page<SiteVipRob> page = new Page<>(pageNum, pageSize);
+
+ // 构造查询条件
+ LambdaQueryWrapper<SiteVipRob> wrapper = new LambdaQueryWrapper<>();
+ wrapper.and(q -> q.like(SiteVipRob::getStockCode, keyword).or().like(SiteVipRob::getName, keyword));
+ if (status != null) {
+ wrapper.eq(SiteVipRob::getStatus, status);
+ }
+ wrapper.orderByDesc(SiteVipRob::getCreateTime);
+ // 执行分页查询
+ IPage<SiteVipRob> resultPage = page(page, wrapper);
+
+ // 返回分页结果
+ return ServerResponse.createBySuccess(resultPage);
+ }
+
+
+ @Override
+ public SiteVipRob getByStockCode(String stockCode) {
+ LambdaQueryWrapper<SiteVipRob> wrapper = new LambdaQueryWrapper<SiteVipRob>().eq(SiteVipRob::getStockCode, stockCode);
+ return siteVipRobMapper.selectOne(wrapper);
+ }
+
+ @Override
+ public ServerResponse updateStatus(Integer id,Integer status) {
+ SiteVipRob siteVipRob = siteVipRobMapper.selectById(id);
+ siteVipRob.setStatus(status);
+ siteVipRob.setUpdateTime(new Date());
+ // 执行更新操作
+ if (updateById(siteVipRob)) {
+ return ServerResponse.createBySuccessMsg("修改成功");
+ } else {
+ return ServerResponse.createByErrorMsg("修改失败");
+ }
+ }
+
+}
--
Gitblit v1.9.3