优化更新已收取金额

src/main/java/com/qtzl/alterSales/manager/service/AflPaccountRefundCountService.java

 package com.qtzl.alterSales.manager.service;
 
 import cn.com.taiji.common.manager.net.http.ServiceHandleException;
+import com.qtzl.alterSales.dao.entity.primary.FssPaccountPay;
 import com.qtzl.alterSales.manager.model.protocol.sales.AflPaccountRefundCountFindPageViewRequest;
 import org.slf4j.Logger;
 
 public interface AflPaccountRefundCountService {
     String export(AflPaccountRefundCountFindPageViewRequest request, Logger logger) throws ServiceHandleException;
 
-    void saveFind(String payId);
+    void saveFind(FssPaccountPay fssPaccountPay);
 }

src/main/java/com/qtzl/alterSales/manager/service/AflPaccountRefundCountServiceImpl.java

 package com.qtzl.alterSales.manager.service;
 
 import cn.com.taiji.common.manager.net.http.ServiceHandleException;
+import com.alibaba.fastjson2.JSON;
 import com.google.common.collect.Lists;
 import com.qtzl.alterSales.dao.entity.primary.AflAgencyMchRel;
 import com.qtzl.alterSales.dao.entity.primary.FssPaccountPay;
     }
 
     @Override
-    public void saveFind(String payId) {
-        log.info("请求查询流水信息请求参数,payId={}",payId);
-        if (StringUtils.isEmpty(payId)){
-            log.error("请求查询流水信息请求参数为空");
+    public void saveFind(FssPaccountPay fssPaccountPay) {
+
+        if (fssPaccountPay==null){
+            log.error("流水信息为空");
             return;
         }
-        FssPaccountPay fssPaccountPay = fssPaccountPayRepo.findByPayId(payId);
-        if (fssPaccountPay==null){
-            log.error("未查询到流水信息,payId ={}",payId);
+        log.info("请求查询流水信息请求参数,payId={}", JSON.toJSONString(fssPaccountPay));
+        if (StringUtils.isEmpty(fssPaccountPay.getPayId())){
+            log.error("请求查询流水信息请求参数payId为空");
             return;
         }
         if (fssPaccountPay.getStatus()==null ||fssPaccountPay.getStatus().equals(1)){
-            log.error("查询到流水信息状态为已补缴或状态为空,payId ={},status={}",payId,fssPaccountPay.getStatus());
+            log.error("查询到流水信息状态为已补缴或状态为空,payId ={},status={}",fssPaccountPay.getPayId(),fssPaccountPay.getStatus());
             return;
         }
         if (StringUtils.isEmpty(fssPaccountPay.getAgentId())||fssPaccountPay.getInserttime()==null||fssPaccountPay.getReceiptAmt()==null){
-            log.error("查询到流水信息渠道id不存在或者插入时间为空或金额为空,payId ={}",payId);
+            log.error("查询到流水信息渠道id不存在或者插入时间为空或金额为空,payId ={}",fssPaccountPay.getPayId());
             return;
         }
         String format =null;
         try {
              format = DateTimeFormatter.ofPattern("yyyyMMdd").format(fssPaccountPay.getInserttime());
         } catch (Exception e) {
-            log.error("查询到流水信息插入时间转换有误,payId ={}",payId);
+            log.error("查询到流水信息插入时间转换有误,payId ={}",fssPaccountPay.getPayId());
             return;
         }
         if (StringUtils.isEmpty(format)){
-            log.error("查询到流水信息时间日期为空,payId ={}",payId);
+            log.error("查询到流水信息时间日期为空,payId ={}",fssPaccountPay.getPayId());
             return;
         }
 
             log.error("未查询到部中心原始流水统计信息,AgentId ={},accountDate={}",fssPaccountPay.getAgentId(),format);
             return;
         }
-        Long collectMoney =0l;
+        Long collectMoney =0L;
         if (aflPaccountRefundCount.getCollectMoney()!=null){
             collectMoney = aflPaccountRefundCount.getCollectMoney();
         }

src/main/java/com/qtzl/alterSales/manager/service/AflSupplementaryPayOrderServiceImpl.java

         supplementaryPayOrder.setSupplementaryTime(successTime);
         supplementaryPayOrder.setSupplementaryNotifyTime(LocalDateTime.now());
         supplementaryPayOrder.setState(SupplementartPayOrderStateEnum.SUCCESS);
-
+        //进行统计累加已收款金额
+        try {
+            aflPaccountRefundCountService.saveFind(fssPaccountPay);
+        } catch (Exception e) {
+            log.error("进行统计累加已收款金额失败... payId:{}", request.getPayId());
+            e.printStackTrace();
+        }
         fssPaccountPay.setStatus(1);
         fssPaccountPay.setMsg("请款成功");
         fssPaccountPay.setWxPayStatus(1);
         // 进行是否需要进行返白操作
         userStateHandler(fssPaccountPay, request.getPayId());
         //
-        //进行统计累加已收款金额
-        try {
-            aflPaccountRefundCountService.saveFind(request.getPayId());
-        } catch (Exception e) {
-            log.error("进行统计累加已收款金额失败... payId:{}", request.getPayId());
-            e.printStackTrace();
-        }
+
 
         supplementaryPayOrderRepo.save(supplementaryPayOrder);
         accountPayRepo.save(fssPaccountPay);

src/main/java/com/qtzl/alterSales/manager/service/ChoiceBillsOperationServiceImpl.java

             return;
         }
         accountPayList.forEach(pay -> {
+            try {
+                aflPaccountRefundCountService.saveFind(pay);
+            } catch (Exception e) {
+                e.printStackTrace();
+                log.error("进行统计累加已收款金额失败... payId:{}", pay.getPayId());
+            }
             pay.setStatus(1);
             pay.setMsg("请款成功");
             pay.setWxPayStatus(1);
             pay.setWxOrderId(payOrder.getOrderNo());
             //
             //进行统计累加已收款金额
-            try {
-                aflPaccountRefundCountService.saveFind(pay.getPayId());
-            } catch (Exception e) {
-                e.printStackTrace();
-                log.error("进行统计累加已收款金额失败... payId:{}", pay.getPayId());
-            }
+
             supplementaryPayOrderService.paySuccessNotify(pay.getPayId(), payTime, payOrder.getOrderNo());
         });
         accountPayRepo.saveAll(accountPayList);