|
@@ -618,7 +618,10 @@ public class TaskWorkNode {
|
|
|
JSONObject errJsonObject = new JSONObject();
|
|
|
errJsonObject.put("code", "exception");
|
|
|
errJsonObject.put("msg", e.getMessage());
|
|
|
+ errJsonObject.put("result", "false");
|
|
|
returnData = errJsonObject.toJSONString();
|
|
|
+ log.setStatus("0").setExeResult("0").setManual("1").setFeedback("节点" + taskNode.getId() + "逻辑出现异常:" + conMap.get("resultmsg") + ":" + e.getMessage());
|
|
|
+ autoNodeLogMapper.updateAllById(log);
|
|
|
logger.error("调用接口发生异常" + e.getMessage());
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
@@ -640,7 +643,7 @@ public class TaskWorkNode {
|
|
|
String code = retJson.getString("result").trim();
|
|
|
String concurrency = retJson.containsKey("concurrency") ? retJson.getString("concurrency").trim() : "false";
|
|
|
if (code.equals("true")) {
|
|
|
- log.setExeStatus("3").setEndTime(new Date()).setSendStatus("1").setExeResult("1").setFeedback("");
|
|
|
+ log.setExeStatus("2").setEndTime(new Date()).setSendStatus("1").setFeedback("");
|
|
|
//回调处理
|
|
|
// taskNode.setExeStatus("3").setEndTime(new Date()).setExeResult("1");
|
|
|
// taskNodeService.updateAllById(taskNode);
|
|
@@ -652,7 +655,7 @@ public class TaskWorkNode {
|
|
|
// 释放之前占用的资源 并发延迟带来的异常不释放锁定资源
|
|
|
if (concurrency.equals("false")) {
|
|
|
// begin modify by yejian on 20220520 for 解决资源抢占时机器人是空闲状态但是实际上面有料不能操作的时候请求指令接口返回失败后进入死循环问题
|
|
|
- log.setExeResult("0").setManual("0").setFeedback("设备资源和条件判断不通过");
|
|
|
+ log.setExeResult("0").setManual("0").setFeedback(log.getFeedback()==null?"设备资源和条件判断不通过" : log.getFeedback());
|
|
|
taskNodeService.freeLock(taskNode.getCompleteBatchNo());
|
|
|
logger.warn("{}设备资源不通过释放节点", taskNode.getCompleteBatchNo());
|
|
|
}
|