功能修改

src/main/java/com/neotel/smfcore/custom/lizhen/LizhenApi.java

@@ -345,21 +345,24 @@ public class LizhenApi extends DefaultSmfApiListener {
      */
     @Override
     public void outTaskStatusChange(String outNotifyUrl, DataLog task) {
-        Storage storage = dataCache.getStorage(task.getCid());
-        Map<String, Object> paramMap = new HashMap<>();
-        paramMap.put("machineid", storage.getMachineId());
-        paramMap.put("reelno", task.getBarcode());
-        paramMap.put("line", task.getLine());
-        paramMap.put("partno", task.getPartNumber());
-        paramMap.put("qty", task.getNum());
-        paramMap.put("issuetime", task.getUpdateDate());
-        log.info("出库通知入参为:" + JSON.toJSONString(paramMap));
-        try {
-            String result = HttpHelper.postJson(outNotifyUrl, paramMap);
-            log.info(task.getBarcode() + "出入库通知返回结果为:" + result);
-        } catch (ApiException e) {
-            e.printStackTrace();
-            log.error(task.getBarcode() + "出入库通知异常:" + e.getMessage());
+
+        if (task.isFinished()) {
+            Storage storage = dataCache.getStorage(task.getCid());
+            Map<String, Object> paramMap = new HashMap<>();
+            paramMap.put("machineid", storage.getMachineId());
+            paramMap.put("reelno", task.getBarcode());
+            paramMap.put("line", task.getLine());
+            paramMap.put("partno", task.getPartNumber());
+            paramMap.put("qty", task.getNum());
+            paramMap.put("issuetime", task.getUpdateDate());
+            log.info("出库通知入参为:" + JSON.toJSONString(paramMap));
+            try {
+                String result = HttpHelper.postJson(outNotifyUrl, paramMap);
+                log.info(task.getBarcode() + "出入库通知返回结果为:" + result);
+            } catch (ApiException e) {
+                e.printStackTrace();
+                log.error(task.getBarcode() + "出入库通知异常:" + e.getMessage());
+            }
         }
     }