From 09d6fcc6d8d4c21ba967f24c58be4b47cacfc31c Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=8B=8F=E7=AB=B9=E7=BA=A2?= <zhuhong.su@coolcollege.cn>
Date: Mon, 9 Jun 2025 13:37:47 +0800
Subject: [PATCH] =?UTF-8?q?feat=EF=BC=9AfranchiseFeeDataHandler?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../controller/webb/PCTestController.java     | 46 +++++++++++++++++++
 1 file changed, 46 insertions(+)

diff --git a/coolstore-partner-web/src/main/java/com/cool/store/controller/webb/PCTestController.java b/coolstore-partner-web/src/main/java/com/cool/store/controller/webb/PCTestController.java
index ba9cbfe23..95edd4456 100644
--- a/coolstore-partner-web/src/main/java/com/cool/store/controller/webb/PCTestController.java
+++ b/coolstore-partner-web/src/main/java/com/cool/store/controller/webb/PCTestController.java
@@ -9,6 +9,7 @@ import com.cool.store.entity.*;
 import com.cool.store.enums.DownSystemTypeEnum;
 import com.cool.store.enums.MessageEnum;
 import com.cool.store.enums.SMSMsgEnum;
+import com.cool.store.enums.point.ShopSubStageStatusEnum;
 import com.cool.store.job.XxlJobHandler;
 import com.cool.store.mapper.FranchiseFeeMapper;
 import com.cool.store.mapper.LineInfoMapper;
@@ -42,6 +43,7 @@ import org.springframework.web.bind.annotation.*;
 import javax.annotation.Resource;
 import javax.validation.Valid;
 import java.util.*;
+import java.util.stream.Collectors;
 
 @Slf4j
 @RestController
@@ -358,4 +360,48 @@ public class PCTestController {
         return ResponseResult.success(Boolean.TRUE);
     }
 
+    @Resource
+    ShopStageInfoDAO shopStageInfoDAO;
+
+    @GetMapping("/franchiseFeeDataHandler")
+    @ApiOperation("加盟费数据处理")
+    public ResponseResult<Boolean> franchiseFeeDataHandler(){
+        //查询所有的待加盟商缴费 推送账单
+        List<ShopStageInfoDO> shopList = shopStageInfoDAO.getShopIdListByStageStatus(ShopSubStageStatusEnum.SHOP_SUB_STAGE_STATUS_71.getShopSubStageStatus());
+        log.info("----------开始推送账单数据---------");
+        shopList.forEach(x->{
+            try {
+                FranchiseFeeDO franchiseFeeDO = franchiseFeeMapper.selectByShopId(x.getShopId());
+                ShopInfoDO shopInfoDO = shopInfoMapper.selectByPrimaryKey(x.getShopId());
+                LineInfoDO lineInfoDO = lineInfoDAO.getLineInfo(shopInfoDO.getLineId());
+                PushFranchiseFeeRequest feeRequest = new PushFranchiseFeeRequest(shopInfoDO.getId(), lineInfoDO.getUsername(), franchiseFeeDO);
+                pushService.pushFranchiseFeeToXGJ(feeRequest);
+            } catch (Exception e) {
+                log.error("推送数据失败  shopId {},异常信息：{}",x,e.getMessage());
+            }
+        });
+        log.info("----------推送账单数据结束---------");
+        //对账中
+        log.info("----------开始推送账单与收款单数据---------");
+        List<ShopStageInfoDO> shopList2 = shopStageInfoDAO.getShopIdListByStageStatus(ShopSubStageStatusEnum.SHOP_SUB_STAGE_STATUS_72.getShopSubStageStatus());
+        shopList2.forEach(x->{
+            //先推送账单
+            try {
+                FranchiseFeeDO franchiseFeeDO = franchiseFeeMapper.selectByShopId(x.getShopId());
+                ShopInfoDO shopInfoDO = shopInfoMapper.selectByPrimaryKey(x.getShopId());
+                LineInfoDO lineInfoDO = lineInfoDAO.getLineInfo(shopInfoDO.getLineId());
+                PushFranchiseFeeRequest feeRequest = new PushFranchiseFeeRequest(shopInfoDO.getId(), lineInfoDO.getUsername(), franchiseFeeDO);
+                pushService.pushFranchiseFeeToXGJ(feeRequest);
+                List<LinePayDO> franchiseFeePayInfoByShopId = linePayDAO.getFranchiseFeePayInfoByShopId(x.getShopId());
+                franchiseFeePayInfoByShopId.forEach(y->{
+                    linePayService.pushPayInfo(x.getShopId(),y);
+                });
+            } catch (Exception e) {
+                log.error("推送数据失败  shopId {},异常信息：{}",x,e.getMessage());
+            }
+        });
+        log.info("----------账单与收款单数据推送完成---------");
+        return ResponseResult.success(Boolean.TRUE);
+    }
+
 }