|
@ -380,6 +380,7 @@ public class FlowManager implements IFlowManage {
|
|
|
processClass.setFlowId(newFlow.getId());
|
|
|
processClass.setType(Constants.FLOW_TYPE_PROCESSOR);
|
|
|
flowClassDao.saveEntity(processClass);
|
|
|
processClass.setIsUpdate("1");
|
|
|
sendUpdateMessage(newFlow.getCode(), processClass, Constants.FLOW_OP_ADD);
|
|
|
|
|
|
// copyProcessor(process.getClassPath(),proPath.toString(),process.getClassName());
|
|
@ -413,6 +414,7 @@ public class FlowManager implements IFlowManage {
|
|
|
newFlowClass.setFlowId(newFlow.getId());
|
|
|
newFlowClass.setType(Constants.FLOW_TYPE_ROUTE);
|
|
|
flowClassDao.saveEntity(newFlowClass);
|
|
|
newFlowClass.setIsUpdate("1");
|
|
|
sendUpdateMessage(newFlow.getCode(), newFlowClass, Constants.FLOW_OP_ADD);
|
|
|
|
|
|
// genNewRoutefile(flowTemp.getClassPath(),basePath.toString(),flowTemp.getClassName(),newClassName,newCron);
|
|
@ -451,6 +453,7 @@ public class FlowManager implements IFlowManage {
|
|
|
}
|
|
|
|
|
|
Map<String,String> params = new HashMap<>();
|
|
|
params.put("type",Constants.FLOW_TYPE_ROUTE);
|
|
|
params.put("filePath", flowTemp.getClassPath());
|
|
|
params.put("packageName", basePath.toString());
|
|
|
params.put("oldClassName", flowTemp.getClassName());
|
|
@ -462,6 +465,7 @@ public class FlowManager implements IFlowManage {
|
|
|
boolean succ = (boolean) body.get("successFlg");
|
|
|
if (succ){
|
|
|
//route文件生成成功,发送消息
|
|
|
flowClass.setIsUpdate("1");
|
|
|
sendUpdateMessage(flow.getCode(), flowClass, Constants.FLOW_OP_UPDATE);
|
|
|
return flowId;
|
|
|
}else {
|