增加定时刷新发票回转数据

win-module-wms/win-module-wms-biz/src/main/java/com/win/module/wms/job/SupplierinvoiceSyncOneJob.java

@@ -0,0 +1,26 @@
+package com.win.module.wms.job;
+
+import com.win.framework.quartz.core.handler.JobHandler;
+import com.win.framework.tenant.core.context.TenantContextHolder;
+import com.win.module.wms.service.supplierinvoiceRequest.SupplierinvoiceRequestMainService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+
+@Component
+@Slf4j
+public class SupplierinvoiceSyncOneJob implements JobHandler {
+
+    @Resource
+    private SupplierinvoiceRequestMainService supplierinvoiceRequestMainService;
+
+    @Override
+    public String execute(String param) throws Exception {
+        log.info("【刷新发票回转数据】----开始");
+        TenantContextHolder.setTenantId(1l);
+        supplierinvoiceRequestMainService.updateSupplierinvoineData(1l);
+        log.info("【刷新发票回转数据】----结束");
+        return "刷新发票回转数据";
+    }
+}

win-module-wms/win-module-wms-biz/src/main/java/com/win/module/wms/job/SupplierinvoiceSyncThreeJob.java

@@ -0,0 +1,26 @@
+package com.win.module.wms.job;
+
+import com.win.framework.quartz.core.handler.JobHandler;
+import com.win.framework.tenant.core.context.TenantContextHolder;
+import com.win.module.wms.service.supplierinvoiceRequest.SupplierinvoiceRequestMainService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+
+@Component
+@Slf4j
+public class SupplierinvoiceSyncThreeJob implements JobHandler {
+
+    @Resource
+    private SupplierinvoiceRequestMainService supplierinvoiceRequestMainService;
+
+    @Override
+    public String execute(String param) throws Exception {
+        log.info("【刷新发票回转数据】----开始");
+        TenantContextHolder.setTenantId(3l);
+        supplierinvoiceRequestMainService.updateSupplierinvoineData(3l);
+        log.info("【刷新发票回转数据】----结束");
+        return "刷新发票回转数据";
+    }
+}

win-module-wms/win-module-wms-biz/src/main/java/com/win/module/wms/job/SupplierinvoiceSyncTwoJob.java

@@ -0,0 +1,26 @@
+package com.win.module.wms.job;
+
+import com.win.framework.quartz.core.handler.JobHandler;
+import com.win.framework.tenant.core.context.TenantContextHolder;
+import com.win.module.wms.service.supplierinvoiceRequest.SupplierinvoiceRequestMainService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+
+@Component
+@Slf4j
+public class SupplierinvoiceSyncTwoJob implements JobHandler {
+
+    @Resource
+    private SupplierinvoiceRequestMainService supplierinvoiceRequestMainService;
+
+    @Override
+    public String execute(String param) throws Exception {
+        log.info("【刷新发票回转数据】----开始");
+        TenantContextHolder.setTenantId(2l);
+        supplierinvoiceRequestMainService.updateSupplierinvoineData(2l);
+        log.info("【刷新发票回转数据】----结束");
+        return "刷新发票回转数据";
+    }
+}

win-module-wms/win-module-wms-biz/src/main/java/com/win/module/wms/service/supplierinvoiceRequest/SupplierinvoiceRequestMainService.java

@@ -182,4 +182,6 @@ public interface SupplierinvoiceRequestMainService {
     BigDecimal computeById(Long id, BigDecimal taxRate);
 
     PageResult<SupplierinvoiceRequestMainPrintVO> listSupplierInvoiceRequestMain(String ids, Integer pageNo, Integer pageSize);
+
+    void updateSupplierinvoineData(long l);
 }

win-module-wms/win-module-wms-biz/src/main/java/com/win/module/wms/service/supplierinvoiceRequest/SupplierinvoiceRequestMainServiceImpl.java

@@ -1356,4 +1356,31 @@ public class SupplierinvoiceRequestMainServiceImpl implements SupplierinvoiceReq
         }
         return new PageResult<>(voList, data.getTotal());
     }
+
+    @Transactional
+    @Override
+    public void updateSupplierinvoineData(long tenantId) {
+        LambdaQueryWrapperX<SupplierinvoiceRequestMainDO> supplierinvoiceRequestMainDOLambdaQueryWrapperX = new LambdaQueryWrapperX<>();
+        supplierinvoiceRequestMainDOLambdaQueryWrapperX.eq(SupplierinvoiceRequestMainDO::getStatus,"12");
+        List<SupplierinvoiceRequestMainDO> supplierinvoiceRequestMainDOS = supplierinvoiceRequestMainMapper.selectList(supplierinvoiceRequestMainDOLambdaQueryWrapperX);
+        Set<String> numberSet = new HashSet<>();
+        for(SupplierinvoiceRequestMainDO supplierinvoiceRequestMainDO:supplierinvoiceRequestMainDOS){
+            numberSet.add(supplierinvoiceRequestMainDO.getNumber());
+        }
+        if(numberSet.size() > 0){
+            LambdaQueryWrapperX<SupplierinvoiceRequestDetailDO> supplierinvoiceRequestDetailDOLambdaQueryWrapperX = new LambdaQueryWrapperX<>();
+            supplierinvoiceRequestDetailDOLambdaQueryWrapperX.in(SupplierinvoiceRequestDetailDO::getNumber,new ArrayList<>(numberSet));
+            List<SupplierinvoiceRequestDetailDO> supplierinvoiceRequestDetailDOS = supplierinvoiceRequestDetailMapper.selectList(supplierinvoiceRequestDetailDOLambdaQueryWrapperX);
+            Set<String> recvBillNumSet = new HashSet<>();
+            for(SupplierinvoiceRequestDetailDO supplierinvoiceRequestDetailDO:supplierinvoiceRequestDetailDOS){
+                recvBillNumSet.add(supplierinvoiceRequestDetailDO.getRecvBillNum());
+            }
+            if(recvBillNumSet.size() > 0){
+                LambdaQueryWrapperX<SupplierinvoiceInvoicedDO> supplierinvoiceInvoicedDOLambdaQueryWrapperX = new LambdaQueryWrapperX<>();
+                supplierinvoiceInvoicedDOLambdaQueryWrapperX.in(SupplierinvoiceInvoicedDO::getRecvBillNum,new ArrayList<>(recvBillNumSet));
+                List<SupplierinvoiceInvoicedDO> supplierinvoiceInvoicedDOS = supplierinvoiceInvoicedMapper.selectList(supplierinvoiceInvoicedDOLambdaQueryWrapperX);
+                supplierinvoiceInvoicedService.handleData(supplierinvoiceInvoicedDOS);
+            }
+        }
+    }
 }

win-module-wms/win-module-wms-biz/src/main/java/com/win/module/wms/service/supplierinvoiceinvoiced/SupplierinvoiceInvoicedServiceImpl.java

@@ -352,7 +352,7 @@ public class SupplierinvoiceInvoicedServiceImpl implements SupplierinvoiceInvoic
     }
 
 
-
+    @Transactional
     @Override
     public void handleData(List<SupplierinvoiceInvoicedDO> list) {
         Set<String> recvBillNumSet = new HashSet<>();