|
@ -198,7 +198,7 @@ public class FlowManager implements IFlowManage {
|
|
|
}
|
|
|
|
|
|
public SystemServiceFlowClass getFlowClassById(Integer id) throws Exception {
|
|
|
return flowClassDao.getEntity(SystemServiceFlowClass.class,id);
|
|
|
return flowClassDao.getEntity(SystemServiceFlowClass.class, id);
|
|
|
}
|
|
|
|
|
|
@Transactional
|
|
@ -379,6 +379,7 @@ public class FlowManager implements IFlowManage {
|
|
|
processClass.setFlowId(newFlow.getId());
|
|
|
processClass.setType(Constants.FLOW_TYPE_PROCESSOR);
|
|
|
flowClassDao.saveEntity(processClass);
|
|
|
sendUpdateMessage(newFlow.getCode(), processClass, Constants.FLOW_OP_ADD);
|
|
|
|
|
|
// copyProcessor(process.getClassPath(),proPath.toString(),process.getClassName());
|
|
|
}
|
|
@ -411,6 +412,7 @@ public class FlowManager implements IFlowManage {
|
|
|
newFlowClass.setFlowId(newFlow.getId());
|
|
|
newFlowClass.setType(Constants.FLOW_TYPE_ROUTE);
|
|
|
flowClassDao.saveEntity(newFlowClass);
|
|
|
sendUpdateMessage(newFlow.getCode(), newFlowClass, Constants.FLOW_OP_ADD);
|
|
|
|
|
|
// genNewRoutefile(flowTemp.getClassPath(),basePath.toString(),flowTemp.getClassName(),newClassName,newCron);
|
|
|
return newFlow.getId();
|
|
@ -432,8 +434,8 @@ public class FlowManager implements IFlowManage {
|
|
|
ObjectMapper objectMapper = new ObjectMapper();
|
|
|
List<SystemServiceFlowTemp> flowTempRouters = flowTempDao.getFlowTemps(flowTempId, Constants.FLOW_TYPE_ROUTE);
|
|
|
List<SystemServiceFlowClass> flowClassRouters = flowClassDao.getFlowClass(flowId, Constants.FLOW_TYPE_ROUTE);
|
|
|
SystemServiceFlow oldFlow = getFlowById(flowId);
|
|
|
|
|
|
// SystemServiceFlow oldFlow = getFlowById(flowId);
|
|
|
SystemServiceFlow flow = flowDao.getEntity(SystemServiceFlow.class,flowId);
|
|
|
//route模板文件记录是否存在。不存在就返回。
|
|
|
if (!flowTempRouters.isEmpty()){
|
|
|
SystemServiceFlowTemp flowTemp =flowTempRouters.get(0);
|
|
@ -458,6 +460,8 @@ public class FlowManager implements IFlowManage {
|
|
|
Map<String,Object> body = objectMapper.readValue(response.getBody(),Map.class);
|
|
|
boolean succ = (boolean) body.get("successFlg");
|
|
|
if (succ){
|
|
|
//route文件生成成功,发送消息
|
|
|
sendUpdateMessage(flow.getCode(), flowClass, Constants.FLOW_OP_UPDATE);
|
|
|
return flowId;
|
|
|
}else {
|
|
|
return null;
|