|
@@ -3,6 +3,7 @@ package com.github.zuihou.business.mq;
|
|
|
import cn.hutool.core.collection.CollectionUtil;
|
|
|
import cn.hutool.json.JSONArray;
|
|
|
import cn.hutool.json.JSONUtil;
|
|
|
+import com.alibaba.fastjson.JSON;
|
|
|
import com.alibaba.fastjson.JSONObject;
|
|
|
import com.github.zuihou.authority.dto.priority.TaskNodePriorityDto;
|
|
|
import com.github.zuihou.authority.service.common.ParameterService;
|
|
@@ -1128,6 +1129,16 @@ public class TaskWorkNode {
|
|
|
// }else{
|
|
|
// msgUtil.redis_set("repeatCheckOnCount"+taskNode.getId(),repeatCheckOnCount,10, TimeUnit.MINUTES);
|
|
|
Map map = getCheckCon(taskNode, task, dataMap);
|
|
|
+
|
|
|
+ //判断起始点位是否相同,是的话,抛出异常,不允许执行
|
|
|
+ if(map.containsKey("fromStorge") && map.containsKey("toStorge")){
|
|
|
+ Storge fromStorge = (Storge)map.get("fromStorge");
|
|
|
+ Storge toStorge = (Storge)map.get("toStorge");
|
|
|
+ if(fromStorge.getStorgeTypeId() == toStorge.getStorgeTypeId()){
|
|
|
+ throw new BizException("起始点目的位置为同一类不允许下发任务");
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
return map;
|
|
|
// boolean b = (boolean) map.get("result");
|
|
|
// if (!b) {
|