package com.yihu.hos.system.service; import com.yihu.hos.common.constants.ContextAttributes; import com.yihu.hos.config.BeanConfig; import com.yihu.hos.core.datatype.ClassFileUtil; import com.yihu.hos.core.encrypt.DES; import com.yihu.hos.core.file.FileUtil; import com.yihu.hos.interceptor.LocalContext; import com.yihu.hos.services.ServiceFlowEventService; import com.yihu.hos.system.dao.FlowClassDao; import com.yihu.hos.system.dao.FlowDao; import com.yihu.hos.system.dao.FlowTempDao; import com.yihu.hos.system.model.SystemServiceFlow; import com.yihu.hos.system.model.SystemServiceFlowClass; import com.yihu.hos.system.model.SystemServiceFlowTemp; import com.yihu.hos.web.framework.constant.ServiceFlowConstant; import com.yihu.hos.web.framework.model.ActionResult; import com.yihu.hos.web.framework.model.DictItem; import com.yihu.hos.web.framework.model.Result; import com.yihu.hos.web.framework.model.bo.ServiceFlow; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; import java.io.File; import java.nio.charset.StandardCharsets; import java.util.ArrayList; import java.util.Date; import java.util.List; import java.util.Map; /** * 系统流程管理业务类 * * @author HZY * @vsrsion 1.0 * Created at 2016/8/19. */ @Service("flowManager") public class FlowManager { public static final String BEAN_ID = "flowManager"; @Autowired ServiceFlowEventService serviceFlowEventService; @Autowired private BeanConfig beanConfig; @Resource(name = "flowDao") private FlowDao flowDao; @Resource(name = FlowClassDao.BEAN_ID) private FlowClassDao flowClassDao; @Resource(name = FlowTempDao.BEAN_ID) private FlowTempDao flowTempDao; /** * 生成Route流程的java文件 * * @param routeId 流程Id * @param className 模板类名 * @param tempFilePath 模板文件路径 * @param newCron cron表达式 * @return */ public String genRouteJavaFile(String routeId, String className, String tempFilePath, String newCron) { try { String newFileName = className + routeId + ".java"; String newFilePath = "/temp/" + newFileName; byte[] content = ClassFileUtil.down(tempFilePath); if (content == null) { return null; } String text = new String(content, StandardCharsets.UTF_8); if (text.contains("?cron=")) { String oldStr = text.substring(text.indexOf("?cron=") + 6); String cron = oldStr.substring(0, oldStr.indexOf("\"")); text = text.replace(cron, newCron); } //修改java类名 if (text.contains(className)) { text = text.replace(className, className + routeId);//新类名规则=旧类名+routeId } //修改routeId；模板规则 routeId("routeId") text = text.replace("routeId(\"routeId\")", "routeId(\"" + routeId + "\")"); boolean succ = FileUtil.writeFile(newFilePath, text, "UTF-8"); if (succ) { newFileName = ClassFileUtil.uploadFile(beanConfig.getFsUrl(), new File(newFilePath + newFileName), newFileName); } else { return null; } return newFileName; } catch (Exception e) { System.out.println("修改Route的java文件操作出错"); e.printStackTrace(); } return null; } /** * 生成processor的java文件 * * @param jobId 任务Id * @param routeId 流程Code * @param tempFilePath 模板文件名 * @param className 模板类名 * @return */ public String genProcessorJavaFile(String jobId, String routeId, String tempFilePath, String className) { try { String newFileName = className + routeId + ".java"; String newFilePath = "/temp/" + className; byte[] content = ClassFileUtil.down(tempFilePath); if (content == null) { return null; } String text = new String(content, StandardCharsets.UTF_8); text = text.replace("jobId=jobId", "jobId=" + jobId); boolean succ = FileUtil.writeFile(newFilePath, text, "UTF-8"); //TODO 上传到GridFS if (succ) { newFileName = ClassFileUtil.uploadFile(beanConfig.getFsUrl(), new File(newFilePath + newFileName), newFileName); return newFileName; } } catch (Exception e) { System.out.println("生成processor的java文件操作出错"); e.printStackTrace(); } return null; } public Result getFlowList(Map params) throws Exception { return flowDao.getFlowList(params); } /** * @return List 返回所有可运行流程 * @throws Exception ... */ public List getServiceFlowList() throws Exception { List serviceFlowList = new ArrayList<>(); List classFlowList = flowDao.getFlowList(ServiceFlowConstant.CLASS); for (SystemServiceFlow systemServiceFlow : classFlowList) { String tenant = LocalContext.getContext().getAttachment(ContextAttributes.TENANT_NAME); ServiceFlow serviceFlow = new ServiceFlow(); serviceFlow.setRouteCode(systemServiceFlow.getCode()); serviceFlow.setFlowType(systemServiceFlow.getFileType()); serviceFlow.setTenant(tenant); List classList = flowClassDao.getFlowClassByFlowId(systemServiceFlow.getId()); ArrayList handleFileList = new ArrayList<>(); for (SystemServiceFlowClass flowClass : classList) { ServiceFlow.HandleFile handleFile = new ServiceFlow.HandleFile(); handleFile.setFileType(ServiceFlowConstant.CLASS); handleFile.setClassName(flowClass.getClassName()); handleFile.setPackageName(flowClass.getPackageName()); handleFile.setFilePath(flowClass.getClassPath()); handleFile.setUsage(flowClass.getType()); handleFile.setRouteCode(serviceFlow.getRouteCode()); handleFileList.add(handleFile); } serviceFlow.setHandleFiles(handleFileList); serviceFlowList.add(serviceFlow); } return serviceFlowList; } /* =================================== flowClass 部分================================================*/ public SystemServiceFlow getFlowById(Integer id) throws Exception { return flowDao.getEntity(SystemServiceFlow.class, id); } @Transactional public Result addFlow(SystemServiceFlow obj) throws Exception { obj.setCreateDate(new Date()); flowDao.saveEntity(obj); if (ServiceFlowConstant.CLASS.equals(obj.getFileType())) { List flowClassList = obj.getFlowClassArray(); ServiceFlow serviceFlow = new ServiceFlow(); serviceFlow.setRouteCode(obj.getCode()); serviceFlow.setFlowType(ServiceFlowConstant.CLASS); for (SystemServiceFlowClass flowClass : flowClassList) { flowClass.setFlowId(obj.getId()); flowDao.saveEntity(flowClass); ServiceFlow.HandleFile handleFile = new ServiceFlow.HandleFile(); handleFile.setRouteCode(obj.getCode()); handleFile.setFileType(ServiceFlowConstant.CLASS); handleFile.setPackageName(flowClass.getPackageName()); handleFile.setClassName(flowClass.getClassName()); handleFile.setFilePath(flowClass.getClassPath()); handleFile.setUsage(flowClass.getType()); serviceFlow.addHandleFile(handleFile); } serviceFlowEventService.serviceFlowAdded(serviceFlow); } else if (ServiceFlowConstant.JAVA.equals(obj.getFileType())) { List flowTempList = obj.getFlowTempArray(); for (SystemServiceFlowTemp flowTemp : flowTempList) { flowTemp.setFlowId(obj.getId()); flowDao.saveEntity(flowTemp); } } return Result.success("保存成功"); } @Transactional public Result updateFlow(SystemServiceFlow obj) throws Exception { ServiceFlow serviceFlow = new ServiceFlow(); SystemServiceFlow flow = flowDao.getEntity(SystemServiceFlow.class, obj.getId()); flow.setCode(obj.getCode()); flow.setName(obj.getName()); flow.setPath(obj.getPath()); flow.setChart(obj.getChart()); flow.setValid(obj.getValid()); flow.setFileType(obj.getFileType()); if (ServiceFlowConstant.JAVA.equals(flow.getFileType())) { List flowTempList = obj.getFlowTempArray(); boolean succ = flowTempDao.deleteFlowTempByFlowId(obj.getId()); if (succ) { for (SystemServiceFlowTemp flowTemp : flowTempList) { flowTempDao.saveEntity(flowTemp); } } } else if (ServiceFlowConstant.CLASS.equals(flow.getFileType())) { List classIds = flowClassDao.getFlowClassIds(obj.getId());//原flowclass集合 List flowClassList = obj.getFlowClassArray(); SystemServiceFlowClass flowClassRoute = null; serviceFlow.setRouteCode(obj.getCode()); serviceFlow.setFlowType(ServiceFlowConstant.CLASS); for (SystemServiceFlowClass flowClass : flowClassList) { if (flowClass.getId() != null) { classIds.remove(flowClass.getId()); flowClassDao.updateEntity(flowClass); } else { if (!flowClass.getType().equals(ServiceFlowConstant.FLOW_TYPE_ROUTE)) { flowClassDao.saveEntity(flowClass); } } ServiceFlow.HandleFile handleFile = new ServiceFlow.HandleFile(); handleFile.setRouteCode(obj.getCode()); handleFile.setFileType(ServiceFlowConstant.CLASS); handleFile.setPackageName(flowClass.getPackageName()); handleFile.setClassName(flowClass.getClassName()); handleFile.setFilePath(flowClass.getClassPath()); handleFile.setUsage(flowClass.getType()); serviceFlow.addHandleFile(handleFile); } serviceFlowEventService.serviceFlowModifiedAdd(serviceFlow); //删除判断 if (classIds != null && classIds.size() > 0) { for (Integer id : classIds) { SystemServiceFlowClass flowClass = getFlowClassById(id); flowClassDao.deleteEntity(flowClass); if (flowClass.getType().equals(ServiceFlowConstant.FLOW_TYPE_ROUTE)) { flowClassRoute = flowClass; flowClassRoute.setIsUpdate("1"); } } } } flowDao.updateEntity(flow); return Result.success("更新成功"); } @Transactional public Result deleteFlow(Integer id) throws Exception { SystemServiceFlow flow = flowDao.getEntity(SystemServiceFlow.class, id); if (flow == null) { return Result.error("删除流程失败"); } ArrayList handleFiles = new ArrayList<>(); List flowClassList = flowClassDao.getFlowClassByFlowId(id); if (ServiceFlowConstant.JAVA.equals(flow.getFileType())) { flowTempDao.deleteFlowTempByFlowId(id); } else { ServiceFlow serviceFlow = new ServiceFlow(); serviceFlow.setRouteCode(flow.getCode()); serviceFlow.setFlowType(ServiceFlowConstant.CLASS); for (SystemServiceFlowClass flowClass : flowClassList) { ServiceFlow.HandleFile handleFile = new ServiceFlow.HandleFile(); handleFile.setRouteCode(flow.getCode()); handleFile.setFileType(ServiceFlowConstant.JAVA); handleFile.setPackageName(flowClass.getPackageName()); handleFile.setClassName(flowClass.getClassName()); handleFile.setFilePath(flowClass.getClassPath()); handleFile.setUsage(flowClass.getType()); handleFiles.add(handleFile); flowClassDao.deleteEntity(flowClass); } serviceFlow.setHandleFiles(handleFiles); serviceFlowEventService.serviceFlowDelete(serviceFlow); } flowDao.deleteEntity(flow); return Result.success("删除流程成功"); } public Result getFlowClassList(Map params) throws Exception { return null; } public List getFlowClassByFlowId(Integer flowId) throws Exception { return flowClassDao.getFlowClassByFlowId(flowId); } public SystemServiceFlowClass getFlowClassById(Integer id) throws Exception { return flowClassDao.getEntity(SystemServiceFlowClass.class, id); } @Transactional public Result addFlowClass(SystemServiceFlowClass obj) throws Exception { flowDao.saveEntity(obj); return Result.success("保存成功"); } @Transactional public Result updateFlowClass(SystemServiceFlowClass obj) throws Exception { return null; } @Transactional public boolean deleteFlowClassByFlowId(Integer flowId) { boolean succ = flowClassDao.deleteFlowClassByFlowId(flowId); return succ; } public List getFlowTempByFlowId(Integer id) throws Exception { return flowTempDao.getFlowTempByFlowId(id); } //TODO public boolean genFlewByflowTempId(Integer flowTempId) throws Exception { SystemServiceFlow flow = getFlowById(flowTempId); //生成新的route类 //添加新processor记录 return false; } /** * 发送MQ消息-更新路由 * * @param flowCode 服务流程Code标识 * @param flowClass * @param operate */ public void sendUpdateMessage(String flowCode, SystemServiceFlowClass flowClass, String operate) { if ("1".equals(flowClass.getIsUpdate())) { ServiceFlow serviceFlow = new ServiceFlow(); serviceFlow.setRouteCode(flowCode); serviceFlow.setFlowType(ServiceFlowConstant.CLASS); ServiceFlow.HandleFile handleFile = new ServiceFlow.HandleFile(); handleFile.setRouteCode(flowCode); handleFile.setFileType(ServiceFlowConstant.CLASS); handleFile.setPackageName(flowClass.getPackageName()); handleFile.setClassName(flowClass.getClassName()); handleFile.setFilePath(flowClass.getClassPath()); handleFile.setUsage(flowClass.getType()); serviceFlow.addHandleFile(handleFile); switch (operate) { case ServiceFlowConstant.FLOW_OP_ADD: case ServiceFlowConstant.FLOW_OP_UPDATE: serviceFlowEventService.serviceFlowModifiedAdd(serviceFlow); break; case ServiceFlowConstant.FLOW_OP_DELETE: serviceFlowEventService.serviceFlowModifiedReduce(serviceFlow); break; default: break; } } } /** * 获取流程列表 * * @param type 流程的文件类型 * @return * @throws Exception */ public ActionResult getFlowList(String type) throws Exception { List flowList = flowDao.getFlowList(type); ActionResult re = new ActionResult(); if (flowList != null && flowList.size() > 0) { List dictList = new ArrayList<>(); for (SystemServiceFlow item : flowList) { DictItem dict = new DictItem(); dict.setCode(item.getId().toString()); dict.setValue(item.getName()); dict.setExtend(""); dictList.add(dict); } re.setData(dictList); } return re; } /** * 发送消息到broker，生成camel相关文件 * * @param flowTempId * @param newCron * @throws Exception */ public Integer genCamelFile(String jobId, Integer flowTempId, String newCron) throws Exception { Long timestamp = System.currentTimeMillis(); //发送生成processor文件的消息 Integer newFlowId = sendAddProcessor(jobId, flowTempId, timestamp); if (newFlowId != null) { //发送生成route文件的消息 newFlowId = sendAddRoute(flowTempId, newFlowId, newCron); if (newFlowId != null) { return newFlowId; } else { System.out.println("生成route文件失败"); return null; } } else { System.out.println("生成processor文件失败"); return null; } } /** * 修改任务，修改camel相关文件 * * @param flowId 流程ID * @param newCron 新cron * @return * @throws Exception */ public Integer updateCamelFile(String jobId, Integer flowTempId, Integer flowId, String newCron) throws Exception { /* 修改route文件无需重新生成flowClass记录，文件名根据className+routeId 生成；*/ List flowTempRouters = flowTempDao.getFlowTemps(flowTempId, ServiceFlowConstant.FLOW_TYPE_ROUTE); List flowTempProces = flowTempDao.getFlowTemps(flowTempId, ServiceFlowConstant.FLOW_TYPE_PROCESSOR); SystemServiceFlow flow = flowDao.getEntity(SystemServiceFlow.class, flowId); //route模板文件记录是否存在。不存在就返回。 if (!flowTempRouters.isEmpty()) { SystemServiceFlowTemp flowTemp = flowTempRouters.get(0); ArrayList handleFiles = new ArrayList<>(); ServiceFlow serviceFlow = new ServiceFlow(); //新增processor记录 for (SystemServiceFlowTemp process : flowTempProces) { String newPath = genProcessorJavaFile(jobId, flow.getCode(), process.getClassPath(), process.getClassName()); if (newPath != null) { //发送消息 serviceFlow.setRouteCode(flow.getCode()); serviceFlow.setFlowType(ServiceFlowConstant.CLASS); ServiceFlow.HandleFile handleFile = new ServiceFlow.HandleFile(); handleFile.setRouteCode(flow.getCode()); handleFile.setFileType(ServiceFlowConstant.JAVA); handleFile.setPackageName(process.getPackageName()); handleFile.setClassName(process.getClassName()); handleFile.setFilePath(newPath); handleFile.setUsage(ServiceFlowConstant.FLOW_TYPE_PROCESSOR); handleFiles.add(handleFile); serviceFlow.setHandleFiles(handleFiles); } else { System.out.println("生成processor的java文件过程出错"); return null; } } //生成新的route文件 String newPath = genRouteJavaFile(flow.getCode(), flowTemp.getClassName(), flowTemp.getClassPath(), newCron); serviceFlow.setRouteCode(flow.getCode()); serviceFlow.setFlowType(ServiceFlowConstant.JAVA); ServiceFlow.HandleFile handleFile = new ServiceFlow.HandleFile(); handleFile.setRouteCode(flow.getCode()); handleFile.setFileType(ServiceFlowConstant.JAVA); handleFile.setPackageName(flowTemp.getPackageName()); handleFile.setClassName(flowTemp.getClassName() + flow.getCode()); handleFile.setFilePath(newPath); handleFile.setUsage(ServiceFlowConstant.FLOW_TYPE_ROUTE); handleFiles.add(handleFile); serviceFlow.setHandleFiles(handleFiles); serviceFlowEventService.serviceFlowModifiedAdd(serviceFlow); return flowId; } return null; } /* ********************* 发送消息方式生成文件 ********************************/ public Integer sendAddRoute(Integer tempId, Integer flowId, String newCron) throws Exception { List flowTempRouters = flowTempDao.getFlowTemps(tempId, ServiceFlowConstant.FLOW_TYPE_ROUTE); SystemServiceFlow newFlow = getFlowById(flowId); //route模板文件记录是否存在。不存在就返回。 if (!flowTempRouters.isEmpty()) { SystemServiceFlowTemp flowTemp = flowTempRouters.get(0); StringBuilder basePath = new StringBuilder(); ; if (flowTemp.getPackageName() != null) { String packagePath[] = flowTemp.getPackageName().split("\\."); for (int i = 0; i < packagePath.length; i++) { basePath.append(packagePath[i]).append("/"); } } //新增processor记录 String newPath = genRouteJavaFile(newFlow.getCode(), flowTemp.getClassName(), flowTemp.getClassPath(), newCron); SystemServiceFlowClass newFlowClass = new SystemServiceFlowClass(); newFlowClass.setPackageName(flowTemp.getPackageName()); newFlowClass.setClassName(flowTemp.getClassName() + newFlow.getCode()); newFlowClass.setClassPath(flowTemp.getClassPath()); newFlowClass.setFlowId(newFlow.getId()); newFlowClass.setType(ServiceFlowConstant.FLOW_TYPE_ROUTE); flowClassDao.saveEntity(newFlowClass); newFlowClass.setIsUpdate("1"); if (newPath != null) { ServiceFlow serviceFlow = new ServiceFlow(); serviceFlow.setRouteCode(newFlow.getCode()); serviceFlow.setFlowType(ServiceFlowConstant.CLASS); ServiceFlow.HandleFile handleFile = new ServiceFlow.HandleFile(); handleFile.setRouteCode(newFlow.getCode()); handleFile.setFileType(ServiceFlowConstant.JAVA); handleFile.setPackageName(flowTemp.getPackageName()); handleFile.setClassName(flowTemp.getClassName() + newFlow.getCode()); handleFile.setFilePath(newPath); handleFile.setUsage(ServiceFlowConstant.FLOW_TYPE_ROUTE); ArrayList handleFiles = new ArrayList<>(); handleFiles.add(handleFile); serviceFlow.setHandleFiles(handleFiles); serviceFlowEventService.serviceFlowModifiedAdd(serviceFlow); return newFlow.getId(); } else { System.out.println("生成route的java文件过程出错"); return null; } } return null; } public Integer sendAddRoute(String code, String name, String javaName, String packageName, String fileInfo) throws Exception { String fileName = javaName + ".java"; String filePath = this.getClass().getProtectionDomain().getClassLoader().getResource("").getPath() + "temp/" + fileName; boolean succ = FileUtil.writeFile(filePath, fileInfo, "UTF-8"); String path = ""; if (succ) { path = ClassFileUtil.uploadFile(beanConfig.getFsUrl(), new File(filePath), fileName); } else { return null; } if (fileName != null) { SystemServiceFlow systemServiceFlow = new SystemServiceFlow(); systemServiceFlow.setName(name); systemServiceFlow.setCode(code); systemServiceFlow.setCreateDate(new Date()); systemServiceFlow.setValid(1); systemServiceFlow.setFileType(ServiceFlowConstant.JAVA); flowDao.saveEntity(systemServiceFlow); ServiceFlow serviceFlow = new ServiceFlow(); serviceFlow.setRouteCode(code); serviceFlow.setFlowType(ServiceFlowConstant.CLASS); ServiceFlow.HandleFile handleFile = new ServiceFlow.HandleFile(); handleFile.setRouteCode(code); handleFile.setFileType(ServiceFlowConstant.JAVA); handleFile.setPackageName(packageName); handleFile.setClassName(javaName); handleFile.setFilePath(path); handleFile.setUsage(ServiceFlowConstant.FLOW_TYPE_ROUTE); ArrayList handleFiles = new ArrayList<>(); handleFiles.add(handleFile); serviceFlow.setHandleFiles(handleFiles); serviceFlowEventService.serviceFlowAdded(serviceFlow); SystemServiceFlowClass flowClass = new SystemServiceFlowClass(); flowClass.setPackageName(packageName); flowClass.setClassName(javaName); flowClass.setClassPath(path); flowClass.setFlowId(systemServiceFlow.getId()); flowClass.setType(ServiceFlowConstant.FLOW_TYPE_ROUTE); flowClass.setIsUpdate("1"); flowClassDao.saveEntity(flowClass); return systemServiceFlow.getId(); } else { System.out.println("生成route的java文件过程出错"); return null; } } public Integer sendAddProcessor(String jobId, Integer flowId, Long timestamp) throws Exception { List flowTempRouters = flowTempDao.getFlowTemps(flowId, ServiceFlowConstant.FLOW_TYPE_ROUTE); List flowTempProces = flowTempDao.getFlowTemps(flowId, ServiceFlowConstant.FLOW_TYPE_PROCESSOR); SystemServiceFlow oldFlow = getFlowById(flowId); //route模板文件记录是否存在。不存在就返回。 if (!flowTempRouters.isEmpty()) { //成功生成文件后，添加flow和flowclass记录 SystemServiceFlow newFlow = new SystemServiceFlow(); newFlow.setName(oldFlow.getName() + timestamp); newFlow.setCode(oldFlow.getCode() + timestamp); newFlow.setChart(oldFlow.getChart()); newFlow.setValid(1); newFlow.setCreateDate(new Date()); newFlow.setFileType(ServiceFlowConstant.CLASS); flowDao.saveEntity(newFlow); ArrayList handleFiles = new ArrayList<>(); //新增processor记录 for (SystemServiceFlowTemp process : flowTempProces) { StringBuilder proPath = new StringBuilder(); if (process.getPackageName() != null) { //生成“/"分割的包名 String packagePath[] = process.getPackageName().split("\\."); for (int i = 0; i < packagePath.length; i++) { proPath.append(packagePath[i]).append("/"); } } String newPath = genProcessorJavaFile(jobId, newFlow.getCode(), process.getClassPath(), process.getClassName()); SystemServiceFlowClass processClass = new SystemServiceFlowClass(); processClass.setPackageName(process.getPackageName()); processClass.setClassName(process.getClassName()); processClass.setClassPath(processClass.getClassPath()); processClass.setFlowId(newFlow.getId()); processClass.setType(ServiceFlowConstant.FLOW_TYPE_PROCESSOR); processClass.setIsUpdate("1"); if (newPath != null) { //发送消息 ServiceFlow serviceFlow = new ServiceFlow(); serviceFlow.setRouteCode(newFlow.getCode()); serviceFlow.setFlowType(ServiceFlowConstant.CLASS); ServiceFlow.HandleFile handleFile = new ServiceFlow.HandleFile(); handleFile.setRouteCode(newFlow.getCode()); handleFile.setFileType(ServiceFlowConstant.JAVA); handleFile.setPackageName(processClass.getPackageName()); handleFile.setClassName(processClass.getClassName()); handleFile.setFilePath(newPath); handleFile.setUsage(ServiceFlowConstant.FLOW_TYPE_PROCESSOR); handleFiles.add(handleFile); serviceFlow.setHandleFiles(handleFiles); serviceFlowEventService.serviceFlowModifiedAdd(serviceFlow); flowClassDao.saveEntity(processClass); } else { System.out.println("生成processor的java文件过程出错"); return null; } } return newFlow.getId(); } return null; } /** * 服务启动/暂停 * * @param flowId 流程ID * @param oper 服务操作；1：启动；0：暂停 * @return * @throws Exception */ public boolean serviceOpenOrPause(Integer flowId, Integer oper) throws Exception { SystemServiceFlow flow = flowDao.getEntity(SystemServiceFlow.class, flowId); if (flow != null) { List flowClassList = flowClassDao.getFlowClassByFlowId(flowId); //route模板文件记录是否存在。不存在就返回。 ArrayList handleFiles = new ArrayList<>(); //新增processor记录 ServiceFlow serviceFlow = new ServiceFlow(); serviceFlow.setRouteCode(flow.getCode()); serviceFlow.setFlowType(ServiceFlowConstant.CLASS); for (SystemServiceFlowClass flowClass : flowClassList) { // String deName = DES.decrypt(flowClass.getClassPath(), DES.COMMON_PASSWORD);//吉阿米果的文件名 //发送消息 ServiceFlow.HandleFile handleFile = new ServiceFlow.HandleFile(); handleFile.setRouteCode(flow.getCode()); handleFile.setFileType(ServiceFlowConstant.CLASS); handleFile.setPackageName(flowClass.getPackageName()); handleFile.setClassName(flowClass.getClassName()); handleFile.setFilePath(flowClass.getClassPath()); handleFile.setUsage(ServiceFlowConstant.FLOW_TYPE_PROCESSOR); handleFiles.add(handleFile); } serviceFlow.setHandleFiles(handleFiles); if (1 == oper) { serviceFlowEventService.serviceFlowStarted(serviceFlow); } else if (0 == oper) { serviceFlowEventService.serviceFlowStopped(serviceFlow); } else { return false; } return true; } else { return false; } } }