定时任务回传问题调试

周鸿
1 parent 3d824c02
Showing 2 changed files with 28 additions and 22 deletions
src/main/java/com/huaheng/api/erp/service/TaskReturnServiceImpl.java
src/main/java/com/huaheng/pc/monitor/job/task/RyTask.java
@@ -156,9 +156,9 @@ public class TaskReturnServiceImpl implements TaskReturnService {
         String str = gson.toJson(erpInfo);
         String execute = null;
         try {
-            log.info("__1_____________成品入库回传erp__________start____________________________"+str);
+            //log.info("__1_____________成品入库回传erp__________start____________________________"+str);
             execute = InvokeHelper.Execute("Kingdee.JY.QR.WebApi.ServicesStub.Api.KDService.Interface", str);
-            log.info("****2***********成品入库回传erp************ end **************************");
+            //log.info("****2***********成品入库回传erp************ end **************************");
         } catch (Exception e) {
             e.printStackTrace();
         }
@@ -176,7 +176,7 @@ public class TaskReturnServiceImpl implements TaskReturnService {
         apiLog.setResponseBody(responseBody);
         apiLogService.save(apiLog);
         ERPAjaxResult<ErpInfoId> erpAjaxResult = gson.fromJson(execute, ERPAjaxResult.class);
-        log.info("____3___________成品入库回传erp__________result____________________________"+erpAjaxResult.isResult());
+        //log.info("____3___________成品入库回传erp__________result____________________________"+erpAjaxResult.isResult());
         if (erpAjaxResult.isResult()) {
             barCodeHeader.setLocked(3);//回传成功
             barCodeHeaderService.updateById(barCodeHeader);
@@ -3,6 +3,7 @@ package com.huaheng.pc.monitor.job.task;
  
 import com.alibaba.fastjson.JSON;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.huaheng.api.erp.service.TaskReturnServiceImpl;
 import com.huaheng.common.support.Convert;
 import com.huaheng.common.utils.Wrappers;
 import com.google.gson.Gson;
@@ -67,11 +68,15 @@ import com.huaheng.pc.task.taskHeader.service.TaskHeaderService;
 import com.huaheng.pc.task.taskHeader.service.WorkTaskService;
  
 import org.apache.commons.collections.MapUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.stereotype.Component;
  
 import javax.annotation.Resource;
  
 import java.math.BigDecimal;
+import java.time.Duration;
+import java.time.LocalDateTime;
 import java.util.*;
  
 /**
@@ -81,6 +86,8 @@ import java.util.*;
  */
 @Component("RyTask")
 public class RyTask extends BaseController {
+
+    private static final Logger log = LoggerFactory.getLogger(RyTask.class);
     @Resource
     private AddressService addressService;
     @Resource
@@ -262,6 +269,21 @@ public class RyTask extends BaseController {
      * 3.Fbillno生产订单单据编码
      */
     public void proReceiptReturn(String params) {
+        LocalDateTime beginTime = LocalDateTime.now();
+        log.info("-===========开始=============");
+        AjaxResult ajaxResult = handleMultiProcess(new MultiProcessListener() {
+            @Override
+            public AjaxResult doProcess() {
+                AjaxResult ajaxResult =proReceiptReturnTo();
+                return  ajaxResult;
+            }
+        });
+        Long timeConsuming = Duration.between(beginTime ,LocalDateTime.now()).toMillis();
+        log.info("===========结束=========="+timeConsuming);
+
+    }
+
+    public AjaxResult proReceiptReturnTo(){
         List<BarCodeHeader> barCodeHeaderList = barCodeHeaderService.list(new LambdaQueryWrapper<BarCodeHeader>()
                 .lt(BarCodeHeader::getPushErrorCount, 3)
                 .in(BarCodeHeader::getLocked, 2, 4)
@@ -295,28 +317,12 @@ public class RyTask extends BaseController {
             datas.setFProductType(barCodeHeader.getProType());
             datas.setFbillno(barCodeHeader.getFbillno());
  
-            AjaxResult ajaxResult = handleMultiProcess(new MultiProcessListener() {
-                @Override
-                public AjaxResult doProcess() {
-                    AjaxResult ajaxResult = taskReturnService.sendTaskReturnId(datas,barCodeHeader);
-                    return  ajaxResult;
-                }
-            });
-           // AjaxResult ajaxResult = taskReturnService.sendTaskReturnId(datas);
-           /* if (ajaxResult.getCode() != 200) {
-                //回传失败，修改回传次数
-                Integer pushErrorCount = barCodeHeader.getPushErrorCount() == null ? 0 : barCodeHeader.getPushErrorCount();
-                barCodeHeader.setPushErrorCount(pushErrorCount + 1);
-                barCodeHeader.setLocked(4);//回传失败
-                barCodeHeaderService.updateById(barCodeHeader);
-            } else {
-                barCodeHeader.setLocked(3);//回传成功
-            }
-            barCodeHeaderService.updateById(barCodeHeader);*/
+            AjaxResult ajaxResult = taskReturnService.sendTaskReturnId(datas,barCodeHeader);
+
         }
+        return AjaxResult.success();
     }
  
-
     /**
      * 拆解电池包，电池类原料出库完成，回传给MES，带生产订单号和电池包号、原料批号、重量
      */