核销调整

src/main/java/com/qs/serve/common/config/MyBatisConfig.java

@@ -45,7 +45,8 @@ public class MyBatisConfig {
                 "sys_tenant",
                 "wx_app",
                 "sys_menu",
-                "sys_menu_permit"
+                "sys_menu_permit",
+                "sys_request_log"
         };
         SysTenantHandler sysTenantHandler = new SysTenantHandler(ignoreTable);
         return new TenantLineInnerInterceptor(sysTenantHandler);

src/main/java/com/qs/serve/modules/vtb/controller/VtbVerificationController.java

@@ -454,7 +454,31 @@ public class VtbVerificationController {
      */
     @GetMapping("successCommit")
     public R<?> successCommit(Long verificationId){
-        vtbVerificationService.successCommit(verificationId);
+        vtbVerificationService.successCommit(verificationId,false);
+        return R.ok();
+    }
+
+
+    /**
+     * 成功提交回调
+     * @return
+     */
+    //@GetMapping("successCommit2")
+    public R<?> successCommit2(){
+        //错误的
+        Long[] costIds = new Long[]{
+                264884L,
+                22010L
+        };
+        List<Long> costIds2 = Arrays.asList(costIds);
+
+        LambdaQueryWrapper<VtbVerification> lqw = new LambdaQueryWrapper<>();
+        lqw.in(VtbVerification::getCostApplyId,costIds2);
+        lqw.select(VtbVerification::getId);
+        List<VtbVerification> vtbVerificationList = vtbVerificationService.list(lqw);
+        for (VtbVerification verification : vtbVerificationList) {
+            vtbVerificationService.successCommit(verification.getId(),false);
+        }
         return R.ok();
     }
 

src/main/java/com/qs/serve/modules/vtb/service/VtbVerificationService.java

@@ -76,6 +76,8 @@ public interface VtbVerificationService extends IService<VtbVerification> {
      */
     void successCommit(Long verificationId);
 
+    void successCommit(Long verificationId,boolean toPay);
+
     /**
      * 检测释放正在核销
      * @param activityId

src/main/java/com/qs/serve/modules/vtb/service/impl/VtbVerificationServiceImpl.java

@@ -1144,8 +1144,7 @@ public class VtbVerificationServiceImpl extends ServiceImpl<VtbVerificationMappe
     }
 
     @Override
-    @Transactional(rollbackFor = Exception.class)
-    public void successCommit(Long verificationId) {
+    public void successCommit(Long verificationId, boolean toPay) {
         log.info("活动核销提交成功。verificationId：{}",verificationId);
         VtbVerification verification = this.getById(verificationId);
         boolean checkZero = verification.getAmount().compareTo(BigDecimal.ZERO)==0;
@@ -1184,6 +1183,10 @@ public class VtbVerificationServiceImpl extends ServiceImpl<VtbVerificationMappe
             Long subjectId = verificationSubject.getSubjectId();
             BigDecimal usedAmount = verificationSubject.getUsedAmount();
             List<TbsActivityCenterGoods> activityCenterGoodsOfSubject = centerGoodsMapBySubject.get(subjectId);
+            if(!toPay&&activityCenterGoodsOfSubject==null){
+                log.warn("活动核销档案有异常。verificationId：{}",verificationId);
+                return;
+            }
             Map<String,List<TbsActivityCenterGoods>> activityGoodsOfSubjectCenter = activityCenterGoodsOfSubject.stream()
                     .collect(Collectors.groupingBy(obj->obj.getCenterType()+":"+obj.getCenterId()));
 
@@ -1225,7 +1228,8 @@ public class VtbVerificationServiceImpl extends ServiceImpl<VtbVerificationMappe
             supplier.setCode(activity.getSupplierCode());
             supplier.setName(activity.getSupplierName());
             //协议类的核销，不需要调用支付接口
-            if(!costApply.getContractFlag().equals(1)){
+            if(!costApply.getContractFlag().equals(1)&&toPay){
+                log.warn("核销去支付：{}",verification.getVerificationCode());
                 String COST_TO_PAY_API = projectApisProperties.getCostToPay();
                 String json = ThirtyVerificationUtil.buildJson(supplier, subject, verification.getAmount()
                         , activity.getActTitle(),activity.getActStartDate().atStartOfDay(),activity.getActEndDate().atTime(23,59,59), verification);
@@ -1302,7 +1306,12 @@ public class VtbVerificationServiceImpl extends ServiceImpl<VtbVerificationMappe
             }
         }
         costApplyService.updateById(updCost);
+    }
 
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void successCommit(Long verificationId) {
+        this.successCommit(verificationId,true);
     }
 
     /**