视频会员分账

SpringBatchServiceServer/src/main/java/com/zswl/cloud/springBtach/server/core/job/video/VideoDeliveryJob.java

@@ -52,6 +52,20 @@ public class VideoDeliveryJob {
 
                     JSONObject entries = JSONUtil.parseObj(goodsResultModel.getExtend());
                     String account = String.valueOf(entries.get("account"));
+
+
+                    VerificationModel verificationModel = new VerificationModel();
+                    verificationModel.setId(goodsResultModel.getId());
+                    verificationModel.setShopId(goodsResultModel.getShopId());
+                    verificationModel.setVerification(new JSONObject());
+                    ResultContent verification = orderService2.verification(verificationModel);
+                    if (!verification.getState().equals(ResultState.Success)){
+
+                        log.info("核销状态变更失败：{}",JSONUtil.toJsonStr(goodsResultModel));
+                        getResultContent().set(ResultContent.build(ResultState.Fail));
+                        return RepeatStatus.FINISHED;
+
+                    }
                     OrderDto orderDto = new OrderDto();
                     orderDto.setCommodityId(goodsResultModel.getGoodsId());
                     orderDto.setPhone(account);
@@ -65,19 +79,6 @@ public class VideoDeliveryJob {
                     JSONObject entries1 = JSONUtil.parseObj(extend);
                     entries1.set("response", resultContent.getContent());
                     orderService2.updateExtend(goodsResultModel.getId(), JSONUtil.toJsonStr(entries1));
-
-                    VerificationModel verificationModel = new VerificationModel();
-                    verificationModel.setId(goodsResultModel.getId());
-                    verificationModel.setShopId(null);
-                    verificationModel.setVerification(new JSONObject());
-                    ResultContent verification = orderService2.verification(verificationModel);
-                    if (!verification.getState().equals(ResultState.Success)){
-
-                        log.info("核销状态变更失败：{}",JSONUtil.toJsonStr(goodsResultModel));
-                        getResultContent().set(ResultContent.build(ResultState.Fail));
-                        return RepeatStatus.FINISHED;
-
-                    }
                     getResultContent().set(ResultContent.build(ResultState.Success));
                     return RepeatStatus.FINISHED;