From 5afa861246ff643cc00a9db7d9128bb05f391c61 Mon Sep 17 00:00:00 2001 From: xiaohu <1901900812@qq.com> Date: Fri, 1 Aug 2025 22:46:28 +0800 Subject: [PATCH] //activity v.schedule --- .../WxVtwoActivityGrantExportTwoSchedule.java | 83 +++++++++++++++++++ .../WxVtwoActivityGrantOrderMapper.java | 2 + .../WxVtwoActivityGrantSettlementMapper.java | 1 + .../WxVtwoCashBackGrantAwardMapper.java | 1 + .../mapper/WxVtwoCashBackGrantMapper.java | 3 + .../mapper/WxVtwoCashBackGrantMapper.xml | 7 ++ 6 files changed, 97 insertions(+) create mode 100644 mallinkSchedule/src/main/java/com/iformall/schedule/WxVtwoActivityGrantExportTwoSchedule.java diff --git a/mallinkSchedule/src/main/java/com/iformall/schedule/WxVtwoActivityGrantExportTwoSchedule.java b/mallinkSchedule/src/main/java/com/iformall/schedule/WxVtwoActivityGrantExportTwoSchedule.java new file mode 100644 index 000000000..466c82405 --- /dev/null +++ b/mallinkSchedule/src/main/java/com/iformall/schedule/WxVtwoActivityGrantExportTwoSchedule.java @@ -0,0 +1,83 @@ +package com.iformall.schedule; + +import com.iformall.domain.po.*; +import com.iformall.enums.EnumYesOrNo; +import com.iformall.mapper.WxVtwoActivityGrantOrderMapper; +import com.iformall.mapper.WxVtwoActivityGrantSettlementMapper; +import com.iformall.mapper.WxVtwoCashBackGrantAwardMapper; +import com.iformall.mapper.WxVtwoCashBackGrantMapper; +import com.iformall.service.WxVtwoActivityGrantExportTwoService; +import com.iformall.service.WxVtwoActivityGrantSettlementService; +import com.iformall.service.WxVtwoActivityOrderService; +import com.iformall.service.WxVtwoCashBackGrantService; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +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 java.util.List; +import java.util.stream.Collectors; + +@Component +public class WxVtwoActivityGrantExportTwoSchedule { + + private final Logger logger = LoggerFactory.getLogger(this.getClass()); + + @Autowired + private WxVtwoCashBackGrantMapper wxVtwoCashBackGrantMapper; + + @Autowired + private WxVtwoActivityGrantSettlementMapper wxVtwoActivityGrantSettlementMapper; + + @Autowired + private WxVtwoActivityGrantOrderMapper wxVtwoActivityGrantOrderMapper; + + @Autowired + private WxVtwoActivityOrderService wxVtwoActivityOrderService; + + @Autowired + private WxVtwoCashBackGrantAwardMapper wxVtwoCashBackGrantAwardMapper; + + @Autowired + private WxVtwoActivityGrantExportTwoService wxVtwoActivityGrantExportTwoService; + + + + @Async + @Scheduled(cron = "0 0 */1 * * ?") // 每小时检查一次 + public void wxVtwoCashBackGrantSchedule() { + logger.info("*************************************************************************************"); + String tenantId = "789"; +// String tenantId = "1095"; + List todoList = wxVtwoCashBackGrantMapper.findTodoList(tenantId); + if(todoList != null && !todoList.isEmpty()) { + todoList.forEach(todo ->{ + WxVtwoActivityGrantOrder grantOrderQ = new WxVtwoActivityGrantOrder(); + grantOrderQ.updateTenantInfo(todo); + grantOrderQ.setGrantId(todo.getId()); + List grantOrderList = wxVtwoActivityGrantOrderMapper.findList(grantOrderQ); + List orderIds = grantOrderList.stream().map(WxVtwoActivityGrantOrder::getOrderId).collect(Collectors.toList()); + List filterIdList = grantOrderList.stream().filter(grantOrder -> grantOrder.getIsAmount().equals(EnumYesOrNo.YES.getCode())).map(WxVtwoActivityGrantOrder::getOrderId).collect(Collectors.toList()); + List grantOrder = wxVtwoActivityOrderService.findGrantOrder(todo, orderIds, filterIdList); + todo.setOrderList(grantOrder); + + WxVtwoCashBackGrantAward grantAwardQ = new WxVtwoCashBackGrantAward(); + grantAwardQ.updateTenantInfo(todo); + grantAwardQ.setGrantId(todo.getId()); + List grantAwardList = wxVtwoCashBackGrantAwardMapper.findList(grantAwardQ); + todo.setGrantAwardList(grantAwardList); + + WxVtwoActivityGrantSettlement grantSettlementQ = new WxVtwoActivityGrantSettlement(); + grantSettlementQ.updateTenantInfo(todo); + grantSettlementQ.setGrantId(todo.getId()); + List grantSettlementList = wxVtwoActivityGrantSettlementMapper.findList(grantSettlementQ); + wxVtwoActivityGrantExportTwoService.saveGrantExport(todo,grantSettlementList); + }); + } + } + + + +} \ No newline at end of file diff --git a/mallinkService/src/main/java/com/iformall/mapper/WxVtwoActivityGrantOrderMapper.java b/mallinkService/src/main/java/com/iformall/mapper/WxVtwoActivityGrantOrderMapper.java index 03c860fac..299957d26 100644 --- a/mallinkService/src/main/java/com/iformall/mapper/WxVtwoActivityGrantOrderMapper.java +++ b/mallinkService/src/main/java/com/iformall/mapper/WxVtwoActivityGrantOrderMapper.java @@ -20,6 +20,8 @@ public interface WxVtwoActivityGrantOrderMapper extends CommonMapper findOrderNoList(@Param("grantId")Long grantId, @Param("tenantId")String tenantId); List findOrderIdList(WxVtwoActivityGrantOrder grantOrderQ); + + List findList(WxVtwoActivityGrantOrder grantOrderQ); } diff --git a/mallinkService/src/main/java/com/iformall/mapper/WxVtwoActivityGrantSettlementMapper.java b/mallinkService/src/main/java/com/iformall/mapper/WxVtwoActivityGrantSettlementMapper.java index b9b40450d..38c929f33 100644 --- a/mallinkService/src/main/java/com/iformall/mapper/WxVtwoActivityGrantSettlementMapper.java +++ b/mallinkService/src/main/java/com/iformall/mapper/WxVtwoActivityGrantSettlementMapper.java @@ -29,6 +29,7 @@ public interface WxVtwoActivityGrantSettlementMapper extends CommonMapper activityAwardStatisticsChart(WxVtwoActivityGrantSettlement record); + List findList(WxVtwoActivityGrantSettlement record); } diff --git a/mallinkService/src/main/java/com/iformall/mapper/WxVtwoCashBackGrantAwardMapper.java b/mallinkService/src/main/java/com/iformall/mapper/WxVtwoCashBackGrantAwardMapper.java index a39eb038b..9aeb33e64 100644 --- a/mallinkService/src/main/java/com/iformall/mapper/WxVtwoCashBackGrantAwardMapper.java +++ b/mallinkService/src/main/java/com/iformall/mapper/WxVtwoCashBackGrantAwardMapper.java @@ -21,6 +21,7 @@ public interface WxVtwoCashBackGrantAwardMapper extends CommonMapper awardItemStatistics(WxVtwoCashBackGrantAward grantAward); + List findList(WxVtwoCashBackGrantAward grantAwardQ); } diff --git a/mallinkService/src/main/java/com/iformall/mapper/WxVtwoCashBackGrantMapper.java b/mallinkService/src/main/java/com/iformall/mapper/WxVtwoCashBackGrantMapper.java index 114164a9b..2fe8af4a1 100644 --- a/mallinkService/src/main/java/com/iformall/mapper/WxVtwoCashBackGrantMapper.java +++ b/mallinkService/src/main/java/com/iformall/mapper/WxVtwoCashBackGrantMapper.java @@ -4,6 +4,7 @@ import com.iformall.common.CommonMapper; import com.iformall.domain.po.WxVtwoCashBackGrant; import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.iformall.domain.vo.WxVtwoAwardStatistics; +import io.lettuce.core.dynamic.annotation.Param; import java.util.List; @@ -20,6 +21,8 @@ public interface WxVtwoCashBackGrantMapper extends CommonMapper activityAwardStatisticsChart(WxVtwoCashBackGrant wxVtwoCashBackGrant); List findList(WxVtwoCashBackGrant activityGrant); + + List findTodoList(@Param("tenantId")String tenantId); } diff --git a/mallinkService/src/main/resources/mapper/WxVtwoCashBackGrantMapper.xml b/mallinkService/src/main/resources/mapper/WxVtwoCashBackGrantMapper.xml index f9d5f23df..64bd10c76 100644 --- a/mallinkService/src/main/resources/mapper/WxVtwoCashBackGrantMapper.xml +++ b/mallinkService/src/main/resources/mapper/WxVtwoCashBackGrantMapper.xml @@ -114,4 +114,11 @@ group by xTime + +