From 2f3fefaf863f9a9f18787622d1dc007578e34c55 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E7=99=BD=E7=BE=8E=E5=B9=B3?= <1102247926@qq.com> Date: Fri, 1 Aug 2025 11:08:41 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BA=BA=E5=91=98=E6=B6=88=E8=B4=B9=E7=A7=AF?= =?UTF-8?q?=E5=88=86=E6=A0=B8=E9=AA=8C?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .idea/CopilotChatHistory.xml | 15 +++++++ .../java/com/nmgs/entity/IntegralCheck.java | 2 + .../mapper/bak/IntegralCheckBakMapper.java | 12 ++++++ .../service/impl/SolveCheckServiceImpl.java | 39 +++++++++++++++++++ .../com/nmgs/task/ConsumeIntegralCheck.java | 26 +++++++------ 5 files changed, 82 insertions(+), 12 deletions(-) create mode 100644 .idea/CopilotChatHistory.xml create mode 100644 src/main/java/com/nmgs/mapper/bak/IntegralCheckBakMapper.java create mode 100644 src/main/java/com/nmgs/service/impl/SolveCheckServiceImpl.java diff --git a/.idea/CopilotChatHistory.xml b/.idea/CopilotChatHistory.xml new file mode 100644 index 0000000..9cd6c86 --- /dev/null +++ b/.idea/CopilotChatHistory.xml @@ -0,0 +1,15 @@ + + + + + + \ No newline at end of file diff --git a/src/main/java/com/nmgs/entity/IntegralCheck.java b/src/main/java/com/nmgs/entity/IntegralCheck.java index f6a816e..c569a7a 100644 --- a/src/main/java/com/nmgs/entity/IntegralCheck.java +++ b/src/main/java/com/nmgs/entity/IntegralCheck.java @@ -50,4 +50,6 @@ public class IntegralCheck { private BigDecimal cpintegrationadd; @TableField(value = "RESTTEGRALTIONADD") private BigDecimal resttegraltionadd; + @TableField(value = "OPERTOR") + private String opertor; } diff --git a/src/main/java/com/nmgs/mapper/bak/IntegralCheckBakMapper.java b/src/main/java/com/nmgs/mapper/bak/IntegralCheckBakMapper.java new file mode 100644 index 0000000..867d2f9 --- /dev/null +++ b/src/main/java/com/nmgs/mapper/bak/IntegralCheckBakMapper.java @@ -0,0 +1,12 @@ +package com.nmgs.mapper.bak; + + +import com.github.jeffreyning.mybatisplus.base.MppBaseMapper; +import com.nmgs.entity.IntegralCheck; +import org.apache.ibatis.annotations.Mapper; + +@Mapper +public interface IntegralCheckBakMapper extends MppBaseMapper { + + +} diff --git a/src/main/java/com/nmgs/service/impl/SolveCheckServiceImpl.java b/src/main/java/com/nmgs/service/impl/SolveCheckServiceImpl.java new file mode 100644 index 0000000..e04e29a --- /dev/null +++ b/src/main/java/com/nmgs/service/impl/SolveCheckServiceImpl.java @@ -0,0 +1,39 @@ +package com.nmgs.service.impl; + +import com.nmgs.entity.IntegralCheck; +import com.nmgs.mapper.bak.IntegralCheckBakMapper; +import com.nmgs.mapper.petrol.IntegralCheckMapper; +import com.nmgs.util.PropertiesUtil; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; + +import java.util.List; + +@Service +public class SolveCheckServiceImpl { + + public IntegralCheckMapper integralCheckMapper; + @Autowired + public void setIntegralCheckMapper(IntegralCheckMapper integralCheckMapper) { + this.integralCheckMapper = integralCheckMapper; + } + + public IntegralCheckBakMapper integralCheckBakMapper; + @Autowired + public void setIntegralCheckBakMapper(IntegralCheckBakMapper integralCheckBakMapper) { + this.integralCheckBakMapper = integralCheckBakMapper; + } + @Transactional(timeout = 1800) + public void solveCheck(List list){ + int i=1; + for(IntegralCheck integralCheck:list){ + i++; + integralCheckMapper.insert(integralCheck); + if(PropertiesUtil.getValue("IsBak").equals("1")){ + integralCheckBakMapper.insert(integralCheck); + } + System.out.println("次数===" + i); + } + } +} diff --git a/src/main/java/com/nmgs/task/ConsumeIntegralCheck.java b/src/main/java/com/nmgs/task/ConsumeIntegralCheck.java index b14abc6..157e721 100644 --- a/src/main/java/com/nmgs/task/ConsumeIntegralCheck.java +++ b/src/main/java/com/nmgs/task/ConsumeIntegralCheck.java @@ -3,9 +3,9 @@ package com.nmgs.task; import com.nmgs.entity.IntegralCheck; import com.nmgs.entity.IntegrationList; import com.nmgs.entity.User; -import com.nmgs.mapper.petrol.IntegralCheckMapper; import com.nmgs.mapper.petrol.IntegrationListMapper; import com.nmgs.mapper.petrol.UserMapper; +import com.nmgs.service.impl.SolveCheckServiceImpl; import com.nmgs.util.PropertiesUtil; import com.nmgs.util.PubTools; import lombok.extern.slf4j.Slf4j; @@ -13,10 +13,10 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.scheduling.annotation.Async; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; -import org.springframework.transaction.annotation.Transactional; import java.math.BigDecimal; import java.text.SimpleDateFormat; +import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; @@ -41,17 +41,16 @@ public class ConsumeIntegralCheck { public void setIntegrationListMapper(IntegrationListMapper integrationListMapper) { this.integrationListMapper = integrationListMapper; } - public IntegralCheckMapper integralCheckMapper; + + public SolveCheckServiceImpl solveCheckService; @Autowired - public void setIntegralCheckMapper(IntegralCheckMapper integralCheckMapper) { - this.integralCheckMapper = integralCheckMapper; + public void setSolveCheckService(SolveCheckServiceImpl solveCheckService) { + this.solveCheckService = solveCheckService; } - @Scheduled(cron = " 0 0 1 * * ? ")//每日1点执行一次 - @Transactional(timeout = 100) + @Scheduled(cron = " 0 0 11 * * ? ")//每日9点执行一次 public void check() { try { - SimpleDateFormat df=new SimpleDateFormat("yyyy-MM-dd"); //1、查询昨日积分有变动的人员 Map params=new HashMap(); @@ -60,10 +59,10 @@ public class ConsumeIntegralCheck { params.put("DBTYPE", PropertiesUtil.getValue("DBType")); List selectforlist = usermapper.getUserByInteralList(params); System.out.println("总人次数===" + selectforlist.size()); + List list=new ArrayList<>(); for (int i = 0; i < selectforlist.size(); i++) { User userIdO = selectforlist.get(i); int userId = userIdO.getId(); - IntegralCheck integralCheck=new IntegralCheck(); integralCheck.setUserId(userId); integralCheck.setOpenid(userIdO.getOpenId()); @@ -127,7 +126,6 @@ public class ConsumeIntegralCheck { String PAYTYPE = integrationList2.getPayType(); BigDecimal payIntegraltion = integrationList2.getPayIntegration(); RESTINTEGRALTIONDECODE=RESTINTEGRALTIONDECODE.subtract(payIntegraltion); - boolean updateCan = false; if ("FC".equals(PAYTYPE) || "FS".equals(PAYTYPE) || "FCA".equals(PAYTYPE)) {//商超及餐饮预约 CPENABLEINTEGRATIONDECODE = CPENABLEINTEGRATIONDECODE.subtract(payIntegraltion); @@ -153,12 +151,16 @@ public class ConsumeIntegralCheck { integralCheck.setOgintegrationdecode(OGENABLEINTEGRATIONDECODE); integralCheck.setCpintegrationdecode(CPENABLEINTEGRATIONDECODE); integralCheck.setRestintegraltiondecode(RESTINTEGRALTIONDECODE); - integralCheckMapper.insert(integralCheck); - System.out.println("次数===" + i); + integralCheck.setOpertor("BMP"); + list.add(integralCheck); + System.out.println("处理完数据次数===" + i); } + solveCheckService.solveCheck(list); } catch (Exception e) { + System.out.println("接口异常了："+e.getMessage()); e.printStackTrace(); } } + }