|
@@ -1,5 +1,6 @@
|
|
|
package com.malk.tuosi.event;
|
|
package com.malk.tuosi.event;
|
|
|
|
|
|
|
|
|
|
+import cn.hutool.core.map.MapUtil;
|
|
|
import com.alibaba.fastjson.JSONObject;
|
|
import com.alibaba.fastjson.JSONObject;
|
|
|
import com.malk.delegate.TBEvent;
|
|
import com.malk.delegate.TBEvent;
|
|
|
import com.malk.server.common.McException;
|
|
import com.malk.server.common.McException;
|
|
@@ -41,14 +42,14 @@ public class McTbEventImpl implements TBEvent {
|
|
|
// }
|
|
// }
|
|
|
log.info("XXXXXX 进入节点更新流程,节点ID:{},状态:{},任务ID:{}",nodeId,status,taskId);
|
|
log.info("XXXXXX 进入节点更新流程,节点ID:{},状态:{},任务ID:{}",nodeId,status,taskId);
|
|
|
if(status.equals("finish")){
|
|
if(status.equals("finish")){
|
|
|
- try {
|
|
|
|
|
- Thread.sleep(3000);
|
|
|
|
|
- }catch (InterruptedException e){
|
|
|
|
|
- e.printStackTrace();
|
|
|
|
|
- }
|
|
|
|
|
List<Map> list=tbClient.queryNodeList(taskId);
|
|
List<Map> list=tbClient.queryNodeList(taskId);
|
|
|
Map node = _getNodeDetail(list,nodeId);
|
|
Map node = _getNodeDetail(list,nodeId);
|
|
|
if(String.valueOf(node.get("name")).contains("接单")){
|
|
if(String.valueOf(node.get("name")).contains("接单")){
|
|
|
|
|
+ try {
|
|
|
|
|
+ Thread.sleep(3000);
|
|
|
|
|
+ }catch (InterruptedException e){
|
|
|
|
|
+ e.printStackTrace();
|
|
|
|
|
+ }
|
|
|
List<String> assigneeIds = UtilMap.getList(node,"assigneeIds");
|
|
List<String> assigneeIds = UtilMap.getList(node,"assigneeIds");
|
|
|
String startDate = UtilMap.getString(node,"startDate");
|
|
String startDate = UtilMap.getString(node,"startDate");
|
|
|
String dueDate = UtilMap.getString(node,"dueDate");
|
|
String dueDate = UtilMap.getString(node,"dueDate");
|
|
@@ -76,6 +77,25 @@ public class McTbEventImpl implements TBEvent {
|
|
|
nextNode(taskId,list,nodeId,creatorId);
|
|
nextNode(taskId,list,nodeId,creatorId);
|
|
|
// }
|
|
// }
|
|
|
}
|
|
}
|
|
|
|
|
+ }else if(event.equals("v3.task.node.dueDate.update") || event.equals("v3.task.node.startDate.update")){
|
|
|
|
|
+ JSONObject data = eventJson.getJSONObject("data");
|
|
|
|
|
+ String taskId = data.getString("taskId");
|
|
|
|
|
+ String nodeId = data.getString("nodeId");
|
|
|
|
|
+ String creatorId = "61a8c27a143030d9110a66d4";
|
|
|
|
|
+ List<Map> list=tbClient.queryNodeList(taskId);
|
|
|
|
|
+ Map node = _getNodeDetail(list,nodeId);
|
|
|
|
|
+ if(String.valueOf(node.get("name")).equals("设计接单")){
|
|
|
|
|
+ try {
|
|
|
|
|
+ Thread.sleep(3000);
|
|
|
|
|
+ }catch (InterruptedException e){
|
|
|
|
|
+ e.printStackTrace();
|
|
|
|
|
+ }
|
|
|
|
|
+ boolean isDue = event.equals("v3.task.node.dueDate.update");
|
|
|
|
|
+ String date = data.getString(isDue?"dueDate":"startDate");
|
|
|
|
|
+ String key = isDue?"设计截止时间":"设计开始时间";
|
|
|
|
|
+ log.info("XXXXXX 设计接单时间变更,更新任务{}:{}-{}",key,taskId,date);
|
|
|
|
|
+ tbClient.updateTaskCustomField(taskId,creatorId, UtilMap.map("customfieldName, value",key,Arrays.asList(new JSONObject().fluentPut("title",date))));
|
|
|
|
|
+ }
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
|