diff --git a/com.actionsoft.apps.coe.pal.publisher/src/com/actionsoft/apps/coe/pal/publisher/extend/CreateOutputReportJob.java b/com.actionsoft.apps.coe.pal.publisher/src/com/actionsoft/apps/coe/pal/publisher/extend/CreateOutputReportJob.java deleted file mode 100644 index 220df5b8..00000000 --- a/com.actionsoft.apps.coe.pal.publisher/src/com/actionsoft/apps/coe/pal/publisher/extend/CreateOutputReportJob.java +++ /dev/null @@ -1,276 +0,0 @@ -package com.actionsoft.apps.coe.pal.publisher.extend; - -import java.util.ArrayList; -import java.util.List; - -import org.quartz.JobExecutionContext; -import org.quartz.JobExecutionException; - -import com.actionsoft.apps.coe.pal.pal.repository.PALRepositoryAPIManager; -import com.actionsoft.apps.coe.pal.pal.repository.PALRepositoryQueryAPIManager; -import com.actionsoft.apps.coe.pal.pal.repository.cache.PALRepositoryCache; -import com.actionsoft.apps.coe.pal.pal.repository.dao.CoeProcessLevelDaoFacotory; -import com.actionsoft.apps.coe.pal.pal.repository.dao.PALRepositoryPropertyDao; -import com.actionsoft.apps.coe.pal.pal.repository.model.PALRepositoryModel; -import com.actionsoft.apps.coe.pal.pal.repository.util.CoeProcessLevelUtil; -import com.actionsoft.bpms.bo.engine.BO; -import com.actionsoft.bpms.bpmn.engine.model.run.delegate.ProcessInstance; -import com.actionsoft.bpms.bpmn.engine.model.run.delegate.TaskInstance; -import com.actionsoft.bpms.commons.database.RowMap; -import com.actionsoft.bpms.schedule.IJob; -import com.actionsoft.bpms.server.UserContext; -import com.actionsoft.bpms.util.DBSql; -import com.actionsoft.bpms.util.UtilString; -import com.actionsoft.sdk.local.SDK; -import com.alibaba.fastjson.JSONArray; -import com.alibaba.fastjson.JSONObject; -/** - * 批量重新生成手册 - * @author Administrator - * - */ -@SuppressWarnings("all") -public class CreateOutputReportJob implements IJob { - @Override - public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException { - - String jobParameter = SDK.getJobAPI().getJobParameter(jobExecutionContext); - - - CARA1(); - /* - * System.err.println("本次共新增手册：" + createNum); System.err.println("本次共更新手册：" + - * updateNum); - */ - - } - - // 批量移动文件架构 - public void CARA3() { - System.err.println("开始移动文件=======>"); - String sql = "SELECT * FROM BO_EU_PAL_FRAMEWORK_TOOL where RESULT not like '%成功%'"; - List maps = DBSql.getMaps(sql); - for (RowMap rowMap : maps) { - String plName = rowMap.getString("PALNAME"); - String error = rowMap.getString("ERRORFRAMEWORK"); - String right = rowMap.getString("CORRECTFRAMEWORK"); - System.err.println("错误架构名=======>"+error); - System.err.println("正确架构名=======>"+right); - // 获取导入表的错误架构id - String sqlerror = "SELECT ID FROM App_Act_Coe_Pal_Repository WHERE PLNAME ='" + error + "'"; - String maperrorId = DBSql.getString(sqlerror); - - // 获取导入表的正确架构id - String sqlright = "SELECT ID FROM App_Act_Coe_Pal_Repository WHERE PLNAME ='" + right + "'"; - String maprightId = DBSql.getString(sqlright); - - // 获取文件id和父架构ID33 - String sqlS = "SELECT ID,PLPARENTID FROM App_Act_Coe_Pal_Repository WHERE PLNAME ='" + plName + "'"; - RowMap map = DBSql.getMap(sqlS); - String uuid = map.getString("ID"); - String prId = map.getString("PLPARENTID"); - // 获取文件库父架构名称 - String sqlT = "SELECT PLNAME FROM App_Act_Coe_Pal_Repository WHERE ID ='" + prId + "'"; - String prName = DBSql.getString(sqlT); - String prName3 = DBSql.getString(sqlT); - - String substring = right.substring(right.lastIndexOf(".") + 2); - // 判断是否是导入表的错误架构 - // - System.err.println("当前文件架构名=======>"+prName); - if (error.equals(prName)) { - String update = "UPDATE App_Act_Coe_Pal_Repository SET PLPARENTID = '" + maprightId + "' WHERE ID ='" - + uuid + "'"; - int update2 = DBSql.update(update); - PALRepositoryPropertyDao propertyDao = new PALRepositoryPropertyDao(); - - String name1 = right.substring(right.lastIndexOf(".") + 2).trim(); - // 设置三级架构名称 - propertyDao.updatePropertyByPropertyId(uuid, "Process_Architecture_L3", name1); - - // 设置二级架构名称 - String sql2 = "SELECT PLPARENTID FROM App_Act_Coe_Pal_Repository WHERE ID ='" + maprightId + "'"; - String prd2 = DBSql.getString(sql2); - String sqlp2 = "SELECT PLNAME,ID FROM App_Act_Coe_Pal_Repository WHERE ID ='" + prd2 + "'"; - RowMap map2 = DBSql.getMap(sqlp2); - if (map2 != null) { - String uuid2 = map2.getString("ID"); - String plName2 = map2.getString("PLNAME"); - String name2 = plName2.substring(plName2.lastIndexOf(".") + 2).trim(); - propertyDao.updatePropertyByPropertyId(uuid, "Process_Architecture_L2", name2); - - // 设置一级架构名称 - String sql1 = "SELECT PLPARENTID FROM App_Act_Coe_Pal_Repository WHERE ID ='" + uuid2 + "'"; - String prd1 = DBSql.getString(sql1); - String sqlp1 = "SELECT PLNAME,ID FROM App_Act_Coe_Pal_Repository WHERE ID ='" + prd1 + "'"; - RowMap map1 = DBSql.getMap(sqlp1); - - if (map1 != null) { - String uuid1 = map1.getString("ID"); - String plName1 = map1.getString("PLNAME"); - String name3 = plName1.substring(plName1.lastIndexOf(".") + 2).trim(); - propertyDao.updatePropertyByPropertyId(uuid, "Process_Architecture_L1", name3); - - } else { - propertyDao.updatePropertyByPropertyId(uuid, "Process_Architecture_L3", "/"); - propertyDao.updatePropertyByPropertyId(uuid, "Process_Architecture_L1", name2); - propertyDao.updatePropertyByPropertyId(uuid, "Process_Architecture_L2", name1); - } - - } else { - propertyDao.updatePropertyByPropertyId(uuid, "Process_Architecture_L2", "/"); - propertyDao.updatePropertyByPropertyId(uuid, "Process_Architecture_L3", "/"); - propertyDao.updatePropertyByPropertyId(uuid, "Process_Architecture_L1", name1); - - } - String result = "文件从【"+error+"】移动到【"+right+"】成功！"; - String updateSql = "UPDATE BO_EU_PAL_FRAMEWORK_TOOL SET RESULT = '"+result+"',PAID = '"+uuid+"' WHERE PALNAME = '"+plName+"'"; - DBSql.update(updateSql); - - }else { - String updateSql = "UPDATE BO_EU_PAL_FRAMEWORK_TOOL SET RESULT ='文件移动失败，架构不匹配！' WHERE PALNAME = '"+plName+"'"; - DBSql.update(updateSql); - } - } - - } - - public static String getQuantity(String regular){ - int index = 0; - for (int i = 0; i < regular.length(); i++) { - char c = regular.charAt(i); - if (Character.isDigit(c)) { - if (i == regular.length() - 1) { - index = i + 1; - } else { - index = i; - } - continue; - } else { - index = i; - break; - } - } - return regular.substring(0, index); - } - - - public void CARA2() { - String sql1 = "SELECT PUBLISHFILEID FROM BO_ACT_COE_PUBLISH_N WHERE PUBLISHDESC = '批量发布'"; - List maps = DBSql.getMaps(sql1); - for (RowMap rowMap : maps) { - String uuid = rowMap.getString("PUBLISHFILEID"); - String sql2 = "SELECT PUBLISHFILEID FROM BO_ACT_COE_PUBLISH_N WHERE PUBLISHFILEID = '"+uuid+"' AND PUBLISHDESC ='待删除'"; - String uuid2 = DBSql.getString(sql2); - if(UtilString.isNotEmpty(uuid2)) { - String sql = "DELETE FROM BO_ACT_COE_PUBLISH_N WHERE PUBLISHFILEID = '"+uuid+"' AND PUBLISHDESC ='待删除'"; - int update = DBSql.update(sql1); - System.out.println("删除N表=======>"+update); - String sqls = "SELECT PLVERSIONID FROM App_Act_Coe_Pal_Repository WHERE ID = '"+uuid+"'"; - String versionId = DBSql.getString(sqls); - String sqlt = "DELETE FROM app_act_coe_pal_publish_list WHERE PALREPOSITORYID = '"+versionId+"' "; - int update2 = DBSql.update(sqlt); - System.out.println("删除List表=======>"+update2); - } - } - - - } - //批量发布文件 - public void CARA1() { - int updateNum = 0; - int createNum = 0; - UserContext _uc = UserContext.fromUID("admin"); - ProcessInstance createProcessInstance = SDK.getProcessAPI().createProcessInstance("obj_7cb02971312c47febd508bdffa122614", "admin", "批量发布文件-"); - TaskInstance taskInst = SDK.getProcessAPI().start(createProcessInstance).fetchActiveTasks().get(0); - //String sql = "SELECT PLID,PLNAME FROM BO_EU_PAL_OUTPUTREPORT WHERE RESULT != '手册转换成功！'"; - String sql = "SELECT PLNAME FROM BO_EU_PAL_PLFB "; - BO bo = new BO(); - bo.set("OPTIONTYPE", "流程制度发布"); - bo.set("PROCESS_TITLE", "文件发布_批量发布"); - SDK.getBOAPI().create("BO_ACT_COE_PUBLISH", bo, createProcessInstance, _uc); - ArrayList boList = new ArrayList(); - BO subBo = null; - List maps = DBSql.getMaps(sql); - System.err.println("批量发布文件数量为："+maps.size()); - for (RowMap rowMap : maps) { - String plname = rowMap.getString("PLNAME"); - if(UtilString.isNotEmpty(plname)) { - PALRepositoryModel repositoryByName = getRepositoryByName("7d3ca852-a0bd-42e6-80b1-3dcea6f55083", plname); - //String sqls = "SELECT ID FROM APP_ACT_COE_PAL_REPOSITORY WHERE PLNAME = '"+plname+"'"; - //System.err.println("======sqls======="+sqls); - if(repositoryByName!=null) { - subBo = new BO(); - //String uuid = rowMap.getString("PLID"); - String uuid = repositoryByName.getId(); - subBo.set("PUBLISTHTYPE", "N"); - subBo.set("PUBLISHFILENAME", plname); - subBo.set("PUBLISHDESC", "批量发布"); - subBo.set("PUBLISHFILEID", uuid); - PALRepositoryModel model = PALRepositoryCache.getCache().get(uuid); - String sqly = "UPDATE BO_ACT_COE_PUBLISH_N SET PUBLISHDESC ='待删除' WHERE PUBLISHFILEID = '"+uuid+"'"; - DBSql.update(sqly); - String taskId = "N"; - try { - System.err.println("批量转换模型名称=========>"+rowMap.getString("PLNAME")); - taskId = createOutputReport(model, "7d3ca852-a0bd-42e6-80b1-3dcea6f55083", "admin","", uuid); - System.err.println("批量转换模型名称=========>"+rowMap.getString("PLNAME")+"===>"+taskId); - } catch (Exception e) { - } - subBo.set("TASKID", taskId); - boList.add(subBo); - - } - } - } - SDK.getBOAPI().create("BO_ACT_COE_PUBLISH_N", boList, createProcessInstance, _uc); - - - - } - - /** - * 创建手册 - * @param model - * @param wsId - * @param userId - * @param teamId - * @param uuid - * @return - */ - private String createOutputReport(PALRepositoryModel model, String wsId, String userId, String teamId, String uuid) { - String taskId = ""; - if (model.getMethodId().contains("process.")) { - taskId = PALRepositoryQueryAPIManager.getInstance().createOutputReportPr(wsId, userId, teamId, uuid); - JSONObject object = JSONObject.parseObject(taskId); - if ("ok".equals(object.getString("result"))) { - taskId = object.getJSONObject("data").getString("taskId"); - } - } else if ("data.form".equals(model.getMethodId())) { - taskId = PALRepositoryQueryAPIManager.getInstance().createOutputReportBd(wsId, userId, teamId, uuid); - JSONObject object = JSONObject.parseObject(taskId); - if ("ok".equals(object.getString("result"))) { - taskId = object.getJSONObject("data").getString("taskId"); - } - } else if ("control.policy".equals(model.getMethodId())) { - taskId = PALRepositoryQueryAPIManager.getInstance().createOutputReportZd(wsId, userId, teamId, uuid); - JSONObject object = JSONObject.parseObject(taskId); - if ("ok".equals(object.getString("result"))) { - taskId = object.getJSONObject("data").getString("taskId"); - } - } - return taskId; - } - - public static PALRepositoryModel getRepositoryByName(String wsId, String repositoryName) { - List palRepositoryModels = CoeProcessLevelDaoFacotory.createCoeProcessLevel().getAllCoeProcessLevelByWsId(wsId); - for (PALRepositoryModel palRepositoryModel : palRepositoryModels) { - - if (palRepositoryModel.getName().equals(repositoryName)&&palRepositoryModel.isUse()) { - return palRepositoryModel; - } - } - return null; - } - -} diff --git a/com.actionsoft.apps.coe.pal.publisher/src/com/actionsoft/apps/coe/pal/publisher/extend/CreateOutputReportJob2.java b/com.actionsoft.apps.coe.pal.publisher/src/com/actionsoft/apps/coe/pal/publisher/extend/CreateOutputReportJob2.java deleted file mode 100644 index ec7351dd..00000000 --- a/com.actionsoft.apps.coe.pal.publisher/src/com/actionsoft/apps/coe/pal/publisher/extend/CreateOutputReportJob2.java +++ /dev/null @@ -1,253 +0,0 @@ -package com.actionsoft.apps.coe.pal.publisher.extend; - -import java.util.List; - -import org.quartz.JobExecutionContext; -import org.quartz.JobExecutionException; - -import com.actionsoft.apps.coe.pal.pal.manage.publish.cache.PublishHistoryCache; -import com.actionsoft.apps.coe.pal.pal.manage.publish.cache.PublishUserGroupCache; -import com.actionsoft.apps.coe.pal.pal.manage.publish.cache.PublishUserGroupPermCache; -import com.actionsoft.apps.coe.pal.pal.manage.publish.cache.PublishUserGroupRoleCache; -import com.actionsoft.apps.coe.pal.pal.repository.cache.CoeProcessLevelCorrelateCache; -import com.actionsoft.apps.coe.pal.pal.repository.cache.PALRepositoryAttributeCache; -import com.actionsoft.apps.coe.pal.pal.repository.cache.PALRepositoryCache; -import com.actionsoft.apps.coe.pal.pal.repository.cache.PALRepositoryPropertyCache; -import com.actionsoft.apps.coe.pal.pal.repository.cache.PALRepositoryRemoveCache; -import com.actionsoft.apps.coe.pal.pal.repository.cache.PALRepositoryShapeAttributeCache; -import com.actionsoft.apps.coe.pal.pal.repository.cache.PALRepositoryShapeConfigCache; -import com.actionsoft.apps.coe.pal.pal.repository.designer.cache.CoeDesignerImageCache; -import com.actionsoft.apps.coe.pal.pal.repository.designer.cache.CoeDesignerShapeCache; -import com.actionsoft.apps.coe.pal.pal.repository.designer.cache.PALDesignerFileCache; -import com.actionsoft.apps.coe.pal.pal.repository.designer.cache.PALDesignerFileDragModelCache; -import com.actionsoft.apps.coe.pal.pal.repository.designer.manage.CoeDesignerAPIManager; -import com.actionsoft.apps.coe.pal.pal.repository.designer.model.BaseModel; -import com.actionsoft.apps.coe.pal.pal.repository.designer.relation.cache.DesignerShapeRelationCache; -import com.actionsoft.apps.coe.pal.pal.repository.model.PALRepositoryModel; -import com.actionsoft.apps.coe.pal.teamwork.cache.TeamMemberPermCache; -import com.actionsoft.apps.coe.pal.teamwork.cache.TeamPermCache; -import com.actionsoft.bpms.bo.engine.BO; -import com.actionsoft.bpms.commons.database.RowMap; -import com.actionsoft.bpms.schedule.IJob; -import com.actionsoft.bpms.server.UserContext; -import com.actionsoft.bpms.util.DBSql; -import com.actionsoft.bpms.util.UtilString; -import com.actionsoft.sdk.local.SDK; -import com.alibaba.fastjson.JSONObject; -import com.sun.org.apache.xalan.internal.xsltc.compiler.sym; -/** - * 空模型改为发布态文件发布状态 - * @author Administrator - * - */ -public class CreateOutputReportJob2 implements IJob { - @Override - public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException { - - count2(); - - } - - public void count2() { - int count = 0; - String sqls = "DELETE FROM BO_EU__PAL_NULL_L"; - DBSql.update(sqls); - String sql = "select ID from App_Act_Coe_Pal_Repository "; - // String sql = "select ID from App_Act_Coe_Pal_Repository where PLNAME = - // '测试文件测'"; - List maps = DBSql.getMaps(sql); - for (RowMap rowMap : maps) { - BO bo = new BO(); - String id = rowMap.getString("ID"); - PALRepositoryModel model = PALRepositoryCache.getCache().get(id); - if (model != null) { - bo.set("PLNAME", model.getName()); - PALRepositoryModel prmodel = PALRepositoryCache.getCache().get(model.getParentId()); - if (prmodel != null) { - bo.set("FRAMEWORK", prmodel.getName()); - } - bo.set("VERSION", model.getVersion()); - if(model.isPublish()) { - bo.set("ISPUBLISH","已发布"); - }else { - bo.set("ISPUBLISH","未发布"); - } - String methodId = model.getMethodId(); - if (methodId.contains("data")) { - bo.set("TYPE", "表单"); - }else if (methodId.contains("control.policy")) { - bo.set("TYPE", "制度"); - }else if (methodId.contains("process")) { - bo.set("TYPE", "流程"); - } - CoeDesignerAPIManager instance = CoeDesignerAPIManager.getInstance(); - if (instance != null) { - BaseModel defineModel = null; - try { - - defineModel = instance.getDefinition(id, 0); - } catch (Exception e) { - bo.set("ERRORTYPE", "1"); - count += SDK.getBOAPI().createDataBO("BO_EU_PAL_ERROR_FILE", bo, UserContext.fromUID("admin")); - } - - if (null == defineModel) { - bo.set("ERRORTYPE", "2"); - count += SDK.getBOAPI().createDataBO("BO_EU_PAL_ERROR_FILE", bo, UserContext.fromUID("admin")); - } else { - try { - String define = defineModel.getDefinition(); - JSONObject definition = JSONObject.parseObject(define); - } catch (Exception e) { - bo.set("ERRORTYPE", "错误文件"); - count += SDK.getBOAPI().createDataBO("BO_EU_PAL_ERROR_FILE", bo, UserContext.fromUID("admin")); - } - - } - - } - } - } - } - public void count1() { - int updateNum = 0; - int createNum = 0; - String sqls = "DELETE FROM BO_EU__PAL_NULL_L"; - DBSql.update(sqls); - String sqls2 = "DELETE FROM BO_EU_PAL_FILE_NULL_L"; - DBSql.update(sqls2); - // String sql = "select ID from App_Act_Coe_Pal_Repository where PUBLISHDATE < - // to_date('2022/10/5 9:46:18 ','yyyy-mm-dd hh24:mi:ss')"; - // String sql = "select ID from App_Act_Coe_Pal_Repository where PUBLISHDATE > - // '2022/7/5 9:46:18'"; - String sql = "select ID from App_Act_Coe_Pal_Repository "; - // String sql = "select ID from App_Act_Coe_Pal_Repository where PLNAME = - // '测试文件测'"; - List maps = DBSql.getMaps(sql); - for (RowMap rowMap : maps) { - String id = rowMap.getString("ID"); - PALRepositoryModel model = PALRepositoryCache.getCache().get(id); - // 查询对应绩效模型中数据模型进行填充数据 - - /* - * String s = "SELECT * FROM BO_ACT_BATCH_PUBLIS_N WHERE PLNAME = '" + - * model.getName() + "'"; if (UtilString.isNotEmpty(DBSql.getString(s))) { - * String updataSql = - * "UPDATE App_Act_Coe_Pal_Repository SET ISPUBLISH = 0 , PUBLISHDATE = null WHERE ID = '" - * + id + "'"; updateNum += DBSql.update(updataSql); - * System.err.println("刷新为设计的模型：" + model.getName()); - * - * } - */ - if (model != null) { - CoeDesignerAPIManager instance = CoeDesignerAPIManager.getInstance(); - if (instance != null) { - BaseModel defineModel = null; - try { - defineModel = instance.getDefinition(id, 0); - } catch (Exception e) { - System.out.println("有问题的模型=====>" + model.getName()); - } - if (null == defineModel) { - } else { - String define = defineModel.getDefinition(); - JSONObject definition = JSONObject.parseObject(define); - JSONObject elements = definition.getJSONObject("elements"); - if (elements.size() == 0) { - BO bo = new BO(); - BO bo2 = new BO(); - bo.set("PLNAME", model.getName()); - bo2.set("PLNAME", model.getName()); - PALRepositoryModel prmodel = PALRepositoryCache.getCache().get(model.getParentId()); - if (prmodel != null) { - bo.set("FRAMEWORK", prmodel.getName()); - bo2.set("FRAMEWORK", prmodel.getName()); - } - bo.set("VERSION", model.getVersion()); - bo2.set("VERSION", model.getVersion()); - if(model.isPublish()) { - bo.set("ISPUBLISH","已发布"); - bo2.set("ISPUBLISH","已发布"); - }else { - bo.set("ISPUBLISH","未发布"); - bo2.set("ISPUBLISH","未发布"); - } - String methodId = model.getMethodId(); - if (methodId.contains("data")) { - bo.set("TYPE", "表单"); - createNum += SDK.getBOAPI().createDataBO("BO_EU__PAL_NULL_L", bo, UserContext.fromUID("admin")); - String sqlt ="UPDATE BO_EU_PAL_FILE1 SET FILESTATE = 0 WHERE PLNAME = '"+model.getName()+"'"; - int a = DBSql.update(sqlt); - if(a!=0) { - bo2.set("TYPE", "表单"); - System.err.println("刷新为设计的模型：" +model.getName()); - updateNum += SDK.getBOAPI().createDataBO("BO_EU_PAL_FILE_NULL_L", bo2, UserContext.fromUID("admin")); - } - - } else if (methodId.contains("control.policy")) { - bo.set("TYPE", "制度"); - createNum += SDK.getBOAPI().createDataBO("BO_EU__PAL_NULL_L", bo, UserContext.fromUID("admin")); - String sqlt ="UPDATE BO_EU_PAL_FILE1 SET FILESTATE = 0 WHERE PLNAME = '"+model.getName()+"'"; - int a = DBSql.update(sqlt); - if(a!=0) { - bo2.set("TYPE", "制度"); - System.err.println("刷新为设计的模型：" +model.getName()); - updateNum += SDK.getBOAPI().createDataBO("BO_EU_PAL_FILE_NULL_L", bo2, UserContext.fromUID("admin")); - } - } else if (methodId.contains("process")) { - bo.set("TYPE", "流程"); - createNum += SDK.getBOAPI().createDataBO("BO_EU__PAL_NULL_L", bo, UserContext.fromUID("admin")); - String sqlt ="UPDATE BO_EU_PAL_FILE1 SET FILESTATE = 0 WHERE PLNAME = '"+model.getName()+"'"; - int a = DBSql.update(sqlt); - if(a!=0) { - bo2.set("TYPE", "流程"); - System.err.println("刷新为设计的模型：" +model.getName()); - updateNum += SDK.getBOAPI().createDataBO("BO_EU_PAL_FILE_NULL_L", bo2, UserContext.fromUID("admin")); - } - } - - - /* - * String updataSql = - * "UPDATE App_Act_Coe_Pal_Repository SET ISPUBLISH = 0 , PUBLISHDATE = null WHERE ID = '" - * + id + "'"; DBSql.update(updataSql); - */ - - - } - - } - } - - } - - } - - SDK.getLogAPI().consoleInfo("更新状态后刷新缓存开始===========>"); - TeamPermCache.getCache().reload(); - TeamMemberPermCache.getCache().reload(); - PublishHistoryCache.getCache().reload(); - PublishUserGroupCache.getCache().reload(); - PublishUserGroupPermCache.getCache().reload(); - PublishUserGroupRoleCache.getCache().reload(); - PALDesignerFileCache.getCache().reload(); - PALDesignerFileDragModelCache.getCache().reload(); - PALRepositoryCache.getCache().reload(); - PALRepositoryRemoveCache.getCache().reload(); - CoeDesignerShapeCache.getCache().reload(); - DesignerShapeRelationCache.getCache().reload(); - PALRepositoryPropertyCache.getCache().reload(); - PALRepositoryAttributeCache.getCache().reload(); - PALRepositoryShapeConfigCache.getCache().reload(); - PALRepositoryShapeAttributeCache.getCache().reload(); - CoeProcessLevelCorrelateCache.getCache().reload(); - CoeDesignerImageCache.getCache().reload(); - SDK.getLogAPI().consoleInfo("更新状态后刷新缓存结束===========>"); - - System.err.println("更新文件表数量：" + updateNum); - System.err.println("本次共查询到的模型：" + createNum); - } - - - -} diff --git a/com.actionsoft.apps.coe.pal.publisher/src/com/actionsoft/apps/coe/pal/publisher/extend/CreateProcessController.java b/com.actionsoft.apps.coe.pal.publisher/src/com/actionsoft/apps/coe/pal/publisher/extend/CreateProcessController.java deleted file mode 100644 index 6e2a8aa9..00000000 --- a/com.actionsoft.apps.coe.pal.publisher/src/com/actionsoft/apps/coe/pal/publisher/extend/CreateProcessController.java +++ /dev/null @@ -1,271 +0,0 @@ -package com.actionsoft.apps.coe.pal.publisher.extend; - -import java.text.SimpleDateFormat; -import java.util.ArrayList; -import java.util.Date; -import java.util.HashSet; -import java.util.List; -import java.util.Set; - -import com.actionsoft.apps.coe.pal.pal.repository.dao.PALRepositoryPropertyDao; -import com.actionsoft.bpms.bo.engine.BO; -import com.actionsoft.bpms.bpmn.engine.model.run.delegate.ProcessInstance; -import com.actionsoft.bpms.bpmn.engine.model.run.delegate.TaskInstance; -import com.actionsoft.bpms.commons.database.RowMap; -import com.actionsoft.bpms.commons.mvc.view.ResponseObject; -import com.actionsoft.bpms.server.UserContext; -import com.actionsoft.bpms.server.bind.annotation.Controller; -import com.actionsoft.bpms.server.bind.annotation.Mapping; -import com.actionsoft.bpms.util.DBSql; -import com.actionsoft.bpms.util.UUIDGener; -import com.actionsoft.bpms.util.UtilString; -import com.actionsoft.sdk.local.SDK; -import com.alibaba.fastjson.JSONObject; - -import bsh.util.Util; - -/* - * 新建流程 - */ -@Controller -public class CreateProcessController { - @Mapping("com.awspaas.user.apps.xitongfankui.createProcess") - public JSONObject CheckUser(String sid,String processDefId) { - JSONObject result = new JSONObject(); - UserContext uc = UserContext.fromSessionId(sid); - SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); - ProcessInstance processInst = SDK.getProcessAPI().createProcessInstance(processDefId, uc.getUID(), "流程管理平台问题反馈"+"-"+uc.getUserName()+"-"+df.format(new Date())); - TaskInstance taskInst = SDK.getProcessAPI().start(processInst).fetchActiveTasks().get(0); - String portalUrl = SDK.getPortalAPI().getPortalUrl(); - String url = portalUrl + "/r/w?sid=" + uc.getSessionId() - + "&cmd=CLIENT_BPM_FORM_MAIN_PAGE_OPEN&processInstId=" + processInst.getId() + "&taskInstId=" - + taskInst.getId() + "&openState=1&reloadedFile=1"; - result.put("url",url); - return result; - } - - - // 批量移动文件架构 - @Mapping("com.awspaas.user.apps.app.controller.movePalFile") - public ResponseObject move(String sid,String plname) { - ResponseObject ro = ResponseObject.newOkResponse(); - System.err.println("开始移动文件=======>"+plname); - String sql = "SELECT * FROM BO_EU_PAL_FRAMEWORK_TOOL WHERE RESULT NOT LIKE '%成功%' "; - if(UtilString.isNotEmpty(plname)) { - sql = "SELECT * FROM BO_EU_PAL_FRAMEWORK_TOOL WHERE PALNAME ='"+plname+"'"; - } - - List maps = DBSql.getMaps(sql); - System.err.println("maps===>"+maps); - if(maps.size()>0) { - for (RowMap rowMap : maps) { - String plName = rowMap.getString("PALNAME"); - String error = rowMap.getString("ERRORFRAMEWORK"); - String right = rowMap.getString("CORRECTFRAMEWORK"); - // 获取导入表的错误架构id - String sqlerror = "SELECT ID FROM App_Act_Coe_Pal_Repository WHERE PLNAME ='" + error + "'"; - String maperrorId = DBSql.getString(sqlerror); - - // 获取导入表的正确架构id - String sqlright = "SELECT ID FROM App_Act_Coe_Pal_Repository WHERE PLNAME ='" + right + "'"; - String maprightId = DBSql.getString(sqlright); - - // 获取文件id和父架构ID33 - String sqlS = "SELECT ID,PLPARENTID FROM App_Act_Coe_Pal_Repository WHERE PLNAME ='" + plName + "'"; - RowMap map = DBSql.getMap(sqlS); - String uuid = map.getString("ID"); - String prId = map.getString("PLPARENTID"); - // 获取文件库父架构名称 - String sqlT = "SELECT PLNAME FROM App_Act_Coe_Pal_Repository WHERE ID ='" + prId + "'"; - String prName = DBSql.getString(sqlT); - String prName3 = DBSql.getString(sqlT); - - String substring = right.substring(right.lastIndexOf(".") + 2); - // 判断是否是导入表的错误架构 - // - System.err.println("当前文件架构名=======>"+prName); - if (error.trim().equals(prName.trim())) { - String update = "UPDATE App_Act_Coe_Pal_Repository SET PLPARENTID = '" + maprightId + "' WHERE ID ='" - + uuid + "'"; - int update2 = DBSql.update(update); - PALRepositoryPropertyDao propertyDao = new PALRepositoryPropertyDao(); - - String name1 = right.substring(right.lastIndexOf(".") + 2).trim(); - // 设置三级架构名称 - propertyDao.updatePropertyByPropertyId(uuid, "Process_Architecture_L3", name1); - - // 设置二级架构名称 - String sql2 = "SELECT PLPARENTID FROM App_Act_Coe_Pal_Repository WHERE ID ='" + maprightId + "'"; - String prd2 = DBSql.getString(sql2); - String sqlp2 = "SELECT PLNAME,ID FROM App_Act_Coe_Pal_Repository WHERE ID ='" + prd2 + "'"; - RowMap map2 = DBSql.getMap(sqlp2); - if (map2 != null) { - String uuid2 = map2.getString("ID"); - String plName2 = map2.getString("PLNAME"); - String name2 = plName2.substring(plName2.lastIndexOf(".") + 2).trim(); - propertyDao.updatePropertyByPropertyId(uuid, "Process_Architecture_L2", name2); - - // 设置一级架构名称 - String sql1 = "SELECT PLPARENTID FROM App_Act_Coe_Pal_Repository WHERE ID ='" + uuid2 + "'"; - String prd1 = DBSql.getString(sql1); - String sqlp1 = "SELECT PLNAME,ID FROM App_Act_Coe_Pal_Repository WHERE ID ='" + prd1 + "'"; - RowMap map1 = DBSql.getMap(sqlp1); - - if (map1 != null) { - String uuid1 = map1.getString("ID"); - String plName1 = map1.getString("PLNAME"); - String name3 = plName1.substring(plName1.lastIndexOf(".") + 2).trim(); - propertyDao.updatePropertyByPropertyId(uuid, "Process_Architecture_L1", name3); - - } else { - propertyDao.updatePropertyByPropertyId(uuid, "Process_Architecture_L3", "/"); - propertyDao.updatePropertyByPropertyId(uuid, "Process_Architecture_L1", name2); - propertyDao.updatePropertyByPropertyId(uuid, "Process_Architecture_L2", name1); - } - - } else { - propertyDao.updatePropertyByPropertyId(uuid, "Process_Architecture_L2", "/"); - propertyDao.updatePropertyByPropertyId(uuid, "Process_Architecture_L3", "/"); - propertyDao.updatePropertyByPropertyId(uuid, "Process_Architecture_L1", name1); - - } - - ro.put("result", "ok"); - String result = "文件从【"+error+"】移动到【"+right+"】成功！"; - String updateSql = "UPDATE BO_EU_PAL_FRAMEWORK_TOOL SET RESULT = '"+result+"',PAID = '"+uuid+"' WHERE PALNAME = '"+plName+"'"; - DBSql.update(updateSql); - - }else { - ro.put("result", "error"); - String updateSql = "UPDATE BO_EU_PAL_FRAMEWORK_TOOL SET RESULT ='文件移动失败，架构不匹配！' WHERE PALNAME = '"+plName+"'"; - DBSql.update(updateSql); - } - } - } - return ro; - - } - - //批量导入权限 - @Mapping("com.awspaas.user.apps.xitongfankui.createPrem") - public JSONObject createPrem(String sid,String processDefId) { - JSONObject result = new JSONObject(); - UserContext uc = UserContext.fromSessionId(sid); - - - List list = SDK.getBOAPI().query("BO_ACT_PUBLISH_SCOPE_IMPORT").list(); - for (BO bos : list) { - String palName = bos.getString("PALNAME"); - String orgPerm = bos.getString("ORGPERM"); - String postPerm = bos.getString("POSTPERM"); - String levelPrem = bos.getString("LEVELPERM"); - String sendScope = bos.getString("SEND_SCOP"); - - StringBuffer orgSuccess = new StringBuffer(); - StringBuffer orgFail = new StringBuffer(); - - StringBuffer orgPermBuf = new StringBuffer(); - String[] orgPermArr = orgPerm.split("，"); - for (String str : orgPermArr) { - String dsql = "SELECT ID FROM ORGDEPARTMENT WHERE DEPARTMENTNAME = '"+str+"'"; - String depId = DBSql.getString(dsql); - if(UtilString.isNotEmpty(depId)) { - if(str.equals(orgPermArr[orgPermArr.length-1])) { - orgPermBuf.append(depId); - }else { - orgPermBuf.append(depId).append(","); - } - - }else { - orgFail.append(str).append(","); - } - } - bos.set("ORGFAIL", orgFail); - - StringBuffer postFail = new StringBuffer(); - StringBuffer postPermBuf = new StringBuffer(); - String[] postPermArr = postPerm.split("，"); - for (String str : postPermArr) { - String postNbrSql = "SELECT POSITION_NBR FROM BO_EU_ORG_POSTS WHERE DESCR = '"+str+"'"; - String postNbr = DBSql.getString(postNbrSql); - if(UtilString.isNotEmpty(postNbr)) { - if(str.equals(postPermArr[postPermArr.length-1])) { - postPermBuf.append(postNbr); - }else { - postPermBuf.append(postNbr).append(","); - } - - }else { - postFail.append(str).append(","); - } - } - bos.set("POSTFAIL", postFail); - StringBuffer levelFail = new StringBuffer(); - StringBuffer levelPremArrBuf = new StringBuffer(); - String[] levelPremArr = levelPrem.split("，"); - for (String str : levelPremArr) { - String levelSql = "SELECT RANKSUB_NO FROM BO_ACT_PAL_LEVEL_SUB WHERE RANKSUB_NAME = '"+str+"'"; - String leveNo = DBSql.getString(levelSql); - if(UtilString.isNotEmpty(leveNo)) { - if(str.equals(levelPremArr[levelPremArr.length-1])) { - levelPremArrBuf.append(str); - }else { - levelPremArrBuf.append(str).append(","); - } - }else { - levelFail.append(str).append(","); - } - } - bos.set("LEVELFAIL", postFail); - - if("1".equals(sendScope)||orgPermBuf.length()!=0||postPermBuf.length()!=0||levelPremArrBuf.length()!=0) { - List premlist = new ArrayList<>(); - String sqls = "SELECT * FROM APP_ACT_COE_PAL_REPOSITORY WHERE PLNAME = '"+palName+"'"; - List maps = DBSql.getMaps(sqls); - - Set removeIds = new HashSet<>(); - for (RowMap rowMap : maps) { - List delList = SDK.getBOAPI().query("BO_ACT_PUBLISH_PERM_SCOPE2").addQuery("PALVERSIONID=", rowMap.getString("PALVERSIONID")).list(); - if (delList != null && delList.size() > 0) { - for (BO del : delList) { - removeIds.add(del.getId()); - } - } - } - for (String removeId : removeIds) { - SDK.getBOAPI().remove("BO_ACT_PUBLISH_PERM_SCOPE2", removeId); - } - - - - for (RowMap rowMap : maps) { - - BO bo = new BO(); - bo.set("PERMID", UUIDGener.getUUID()); - bo.set("WSID", rowMap.getString("WSID")); - bo.set("PALVERSIONID", rowMap.getString("PLVERSIONID")); - bo.set("PALNAME", rowMap.getString("PLNAME")); - bo.set("PERMTYPE", sendScope); - bo.set("ORGPERM", orgPermBuf); - bo.set("POSTPERM", postPermBuf); - bo.set("LEVELPERM",levelPremArrBuf); - premlist.add(bo); - } - if (premlist.size() > 0) { - bos.set("RESULT", "导入成功！"); - SDK.getBOAPI().update("BO_ACT_PUBLISH_SCOPE_IMPORT", bos); - SDK.getBOAPI().createDataBO("BO_ACT_PUBLISH_PERM_SCOPE2", premlist, uc); - SDK.getLogAPI().consoleInfo("[发布范围权限信息保存至范围权限表]更新成功"); - } - - }else { - bos.set("RESULT", "导入失败！"); - SDK.getBOAPI().update("BO_ACT_PUBLISH_SCOPE_IMPORT", bos); - } - - - } - - return result; - } -} diff --git a/com.actionsoft.apps.coe.pal.publisher/src/com/actionsoft/apps/coe/pal/publisher/extend/PAlOnlinedocFileConvertJob.java b/com.actionsoft.apps.coe.pal.publisher/src/com/actionsoft/apps/coe/pal/publisher/extend/PAlOnlinedocFileConvertJob.java deleted file mode 100644 index 1607b9c0..00000000 --- a/com.actionsoft.apps.coe.pal.publisher/src/com/actionsoft/apps/coe/pal/publisher/extend/PAlOnlinedocFileConvertJob.java +++ /dev/null @@ -1,239 +0,0 @@ -package com.actionsoft.apps.coe.pal.publisher.extend; - -import java.io.File; -import java.util.HashMap; -import java.util.List; -import java.util.Map; - -import org.quartz.JobExecutionContext; -import org.quartz.JobExecutionException; - -import com.actionsoft.apps.coe.pal.pal.output.OutputAPIManager; -import com.actionsoft.apps.coe.pal.pal.output.dao.OutputTask; -import com.actionsoft.apps.coe.pal.pal.output.extend.OutputAppManager; -import com.actionsoft.apps.coe.pal.pal.output.extend.OutputAppProfile; -import com.actionsoft.apps.coe.pal.pal.output.model.OutputTaskModel; -import com.actionsoft.apps.coe.pal.pal.repository.cache.PALRepositoryCache; -import com.actionsoft.apps.coe.pal.pal.repository.model.PALRepositoryModel; -import com.actionsoft.apps.resource.AppContext; -import com.actionsoft.bpms.bo.engine.BO; -import com.actionsoft.bpms.commons.database.RowMap; -import com.actionsoft.bpms.commons.mvc.view.ResponseObject; -import com.actionsoft.bpms.schedule.IJob; -import com.actionsoft.bpms.server.SSOUtil; -import com.actionsoft.bpms.server.UserContext; -import com.actionsoft.bpms.server.fs.DCContext; -import com.actionsoft.bpms.server.fs.dc.DCProfileManager; -import com.actionsoft.bpms.util.DBSql; -import com.actionsoft.bpms.util.UtilFile; -import com.actionsoft.bpms.util.UtilString; -import com.actionsoft.sdk.local.SDK; -import com.actionsoft.sdk.local.api.AppAPI; -/** - * 模型附件去重 - * @author Administrator - * - */ -public class PAlOnlinedocFileConvertJob implements IJob { - private UserContext _uc; - - @Override - public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException { - System.err.println("文件转换开始====>"); - // String sql = "select * from app_act_coe_pal_publish_list "; - String sql = "select ID,PLNAME from App_Act_Coe_Pal_Repository where ISPUBLISH ='1'"; - SSOUtil ssoUtil = new SSOUtil(); - String portalUrl = SDK.getPortalAPI().getPortalUrl(); - String session = ssoUtil.registerClientSessionNoPassword("admin", "cn", portalUrl, "pc"); - UserContext fromSessionId = UserContext.fromSessionId(session); - List maps = DBSql.getMaps(sql); - // ExecutorService service = Executors.newFixedThreadPool(4); - for (RowMap rowMap : maps) { - String plId = rowMap.getString("ID"); - String palname = rowMap.getString("PLNAME"); - - String sqls = "select taskId from (select * from BO_ACT_COE_PUBLISH_N where PUBLISHFILEID = '" + plId - + "' order by CREATEDATE desc) where rownum = 1"; - String taskId = DBSql.getString(sqls); - String sqld = "SELECT BINDID FROM BO_ACT_COE_PUBLISH_N WHERE TASKID = '" + taskId + "'"; - String bindid = DBSql.getString(sqld); - if (!"7964be16-dc8b-41b1-a10a-bc8a84885074".equals(bindid)) { - try { - outputReportPreview(fromSessionId, session, taskId, plId); - } catch (Exception e) { - // TODO: handle exception - } - } - - /* - * service.execute(new Runnable() { - * - * @Override public void run() { } }); - */ - - } - System.err.println("文件转换结束====>"); - } - - public void outputReportPreview(UserContext _uc, String session, String taskId, String palId) { - String sqlt = "SELECT * FROM BO_EU_PAL_OUTPUTREPORT WHERE PLID = '" + palId + "' AND RESULT = '手册转换成功！'"; - //String sqlt = "SELECT * FROM BO_EU_PAL_OUTPUTREPORT WHERE PLID = '" + palId + "'"; - RowMap maps = DBSql.getMap(sqlt); - if (maps != null) { - return; - } - BO bo = new BO(); - String sql = "select * from App_Act_Coe_Pal_Repository where id = '" + palId + "' "; - RowMap map = DBSql.getMap(sql); - if (map != null) { - String ispulish = map.getString("ISPUBLISH"); - String palname = map.getString("PLNAME"); - String methodid = map.getString("PLMETHODID"); - String plparid = map.getString("PLPARENTID"); - if ("1".equals(ispulish)) { - //if ("control.policy".equals(methodid)) { - if("control.policy".equals(methodid)||"data.form".equals(methodid)||"process.epc".equals(methodid)||"process.flowchart".equals(methodid)){ - try { - bo.set("PLNAME", map.getString("PLNAME")); - bo.set("PLID", palId); - bo.set("TASKID", taskId); - PALRepositoryModel prmodel = PALRepositoryCache.getCache().get(plparid); - if (prmodel != null) { - bo.set("FRNAME", prmodel.getName()); - } - bo.set("PLVERSION", map.getString("PLVER")); - bo.set("PLMETHODID", map.getString("PLMETHODID")); - OutputTaskModel model = new OutputTask().getTaskReportById(taskId); - ResponseObject result = ResponseObject.newOkResponse(); - if (model != null) { - UtilFile file = OutputAPIManager.getInstance().getFilePath(model.getWsId(), taskId, - model.getProfileId()); - if (file.exists()) { - File[] fileList = file.listFiles(); - if (fileList.length > 0) { - File docFile = null; - for (File file2 : fileList) { - if (file2.isFile() && "doc".equals( - (file2.getName().substring(file2.getName().lastIndexOf(".") + 1)))) { - docFile = file2; - break; - } - } - if (docFile == null) { - bo.set("RESULT", "模型没有手册文件_1！"); - result = ResponseObject.newErrResponse("没有手册文件！"); - } - if (SDK.getAppAPI().isActive("com.actionsoft.apps.addons.onlinedoc")) { - OutputAppProfile appFile = OutputAppManager.getProfile(model.getProfileId()); - String sourceAppId = appFile.getAppContext().getId(); - String filename = docFile.getName(); - System.err.println("开始转换===>" + filename + "===>" + sourceAppId); - DCContext sourceDc = new DCContext(_uc, - DCProfileManager.getDCProfile(sourceAppId, "output"), sourceAppId, - model.getWsId(), taskId, filename); - /* - * Map aslpParams = new HashMap(); - * - * aslpParams.put("sid", _uc.getSessionId()); aslpParams.put("fileNameOriginal", - * filename); aslpParams.put("sourceDc", sourceDc); - * aslpParams.put("isShowDefaultToolbar", true); aslpParams.put("isShowBackbtn", - * false); aslpParams.put("isEncrypt", true); aslpParams.put("isCopy", true); - * aslpParams.put("isPrint", true); aslpParams.put("isDownload", true); AppAPI - * appAPI = SDK.getAppAPI(); ResponseObject responseObject = - * appAPI.callASLP(appAPI.getAppContext(sourceAppId), - * "aslp://com.actionsoft.apps.addons.onlinedoc/filePreview", aslpParams); - */ - - // 调用App - // aslp服务地址 - String aslp = "aslp://com.actionsoft.apps.addons.onlinedoc/fileConvert"; - // 参数定义列表 - HashMap params = new HashMap(); - // PDF转图片处理选项。- 0代表只在需要时做转换；- 1代表打开即检查是否已转换成图片，如未处理，强制转换。默认0,非必填 - params.put("isPDFCovertPNG", "0"); - // 原文件DC,必填 - params.put("sourceDc", sourceDc); - // 文档是否允许复制。true为允许复制，转换结果为PDF格式文件；false为不可复制，转换结果为PNG格式文件（注意参数值为false时转换时间稍长）,必填 - params.put("isCopy", true); - // sessionid,必填 - params.put("sid", session); - AppAPI appAPI = SDK.getAppAPI(); - // 调用转换服务.在预览之前提前进行转换，预览时直接打开转换后的文件 - String sourceId = "com.actionsoft.apps.coe.pal.publisher"; - AppContext appContext = appAPI.getAppContext(sourceId); - ResponseObject responseObject = appAPI.callASLP(appContext, aslp, params); - System.err.println("转换结果=======>" + responseObject); - if (responseObject != null) { - String results = responseObject.toString(); - if (UtilString.isNotEmpty(results)) { - if (results.contains("200")) { - bo.set("RESULT", "手册转换成功！"); - Map aslpParams = new HashMap(); - aslpParams.put("sid", _uc.getSessionId()); - aslpParams.put("fileNameOriginal", filename); - aslpParams.put("sourceDc", sourceDc); - aslpParams.put("isShowDefaultToolbar", true); - aslpParams.put("isShowBackbtn", false); - aslpParams.put("isEncrypt", true); - aslpParams.put("isCopy", true); - aslpParams.put("isPrint", true); - aslpParams.put("isDownload", true); - ResponseObject responseObjects = appAPI.callASLP( - appAPI.getAppContext(sourceAppId), - "aslp://com.actionsoft.apps.addons.onlinedoc/filePreview", - aslpParams); - - if (responseObjects != null) { - if (responseObjects.isOk()) { - String url = responseObjects.get("url").toString(); - bo.set("FILEURL", url.substring(url.indexOf("&cmd"))); - result = ResponseObject.newErrResponse("模型转换成功！"); - } else { - bo.set("FILEURL", "链接获取失败！"); - result = ResponseObject.newErrResponse("文档转换服务不可用，请联系管理员"); - } - } - } else { - bo.set("RESULT", "文件转换失败_1！"); - result = ResponseObject.newErrResponse("文档转换服务不可用，请联系管理员"); - } - } else { - bo.set("RESULT", "文件转换失败_2！"); - } - } else { - bo.set("RESULT", "文件转换失败_3！"); - } - - } else { - bo.set("RESULT", "文档转换服务不可用！"); - result = ResponseObject.newErrResponse("文档转换服务不可用，请联系管理员"); - } - } - } else { - bo.set("RESULT", "模型没有手册文件_2！"); - result = ResponseObject.newErrResponse("没有手册文件！"); - } - - } else { - bo.set("RESULT", "模型没有手册文件_3！"); - } - } catch (Exception e) { - bo.set("RESULT", "文件转换失败_4！"); - } finally { - String sqlT = "SELECT ID FROM BO_EU_PAL_OUTPUTREPORT WHERE PLID = '" + palId + "'"; - String Id = DBSql.getString(sqlT); - if (UtilString.isNotEmpty(Id)) { - bo.setId(Id); - SDK.getBOAPI().update("BO_EU_PAL_OUTPUTREPORT", bo); - } else { - SDK.getBOAPI().createDataBO("BO_EU_PAL_OUTPUTREPORT", bo, UserContext.fromUID("admin")); - } - } - } - - } - } - } - - -} diff --git a/com.actionsoft.apps.coe.pal.publisher/src/com/actionsoft/apps/coe/pal/publisher/extend/PublisherGetManagerController.java b/com.actionsoft.apps.coe.pal.publisher/src/com/actionsoft/apps/coe/pal/publisher/extend/PublisherGetManagerController.java deleted file mode 100644 index 225eea75..00000000 --- a/com.actionsoft.apps.coe.pal.publisher/src/com/actionsoft/apps/coe/pal/publisher/extend/PublisherGetManagerController.java +++ /dev/null @@ -1,52 +0,0 @@ -package com.actionsoft.apps.coe.pal.publisher.extend; - -import java.sql.Connection; - -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -import com.actionsoft.bpms.commons.database.RowMap; -import com.actionsoft.bpms.commons.mvc.view.ResponseObject; -import com.actionsoft.bpms.server.UserContext; -import com.actionsoft.bpms.server.bind.annotation.Controller; -import com.actionsoft.bpms.server.bind.annotation.Mapping; -import com.actionsoft.bpms.util.DBSql; -import com.actionsoft.sdk.local.SDK; -/** - * 表单加载前获取内部校对人和流程经理 - * @author lihongyu - * - */ -@Controller -public class PublisherGetManagerController { - private static Logger logger = LoggerFactory.getLogger(PublisherGetManagerController.class); - // 修改文件发布状态 - @Mapping("com.actionsoft.apps.coe.pal.publisher.PublisherGetManagerController") - public ResponseObject checkIsSend(String sid) { - ResponseObject ro = ResponseObject.newOkResponse(); - //根据部门名称 和单位 计算出 内部校对人 和流程经理 - UserContext me = UserContext.fromSessionId(sid); - String departmentId = me.getUserModel().getDepartmentId(); - String allpath = SDK.getORGAPI().getDepartmentById(departmentId).getPathNameOfCache(); - String[] patharr = allpath.split("/"); - StringBuffer sb = new StringBuffer(); - for (String str : patharr) { - sb.append("'").append(str).append("'").append(","); - } - String substring = sb.substring(0, sb.length()-1); - // 可以为boData中的字段进行赋值 - Connection open = DBSql.open(); - RowMap data = DBSql.getMap(open,"select DEAPRTMNUM,PROCESSMNUMBER from BO_ACT_PROCESSMANAGER where ORGDEPART in ("+substring+")"); - if(null==data) { - ro.put("result","error"); - }else { - ro.put("result","ok"); - ro.put("DEAPRTMNUM",data.getString("DEAPRTMNUM")); - ro.put("PROCESSMNUMBER",data.getString("PROCESSMNUMBER")); - } - return ro; - } - - - -} diff --git a/com.actionsoft.apps.coe.pal.publisher/src/com/actionsoft/apps/coe/pal/publisher/extend/SelectPremJob.java b/com.actionsoft.apps.coe.pal.publisher/src/com/actionsoft/apps/coe/pal/publisher/extend/SelectPremJob.java deleted file mode 100644 index abfd5ca1..00000000 --- a/com.actionsoft.apps.coe.pal.publisher/src/com/actionsoft/apps/coe/pal/publisher/extend/SelectPremJob.java +++ /dev/null @@ -1,90 +0,0 @@ -package com.actionsoft.apps.coe.pal.publisher.extend; - -import java.util.List; - -import org.quartz.JobExecutionContext; -import org.quartz.JobExecutionException; - -import com.actionsoft.apps.coe.pal.pal.repository.cache.PALRepositoryCache; -import com.actionsoft.apps.coe.pal.pal.repository.dao.CoeProcessLevelDaoFacotory; -import com.actionsoft.apps.coe.pal.pal.repository.model.PALRepositoryModel; -import com.actionsoft.bpms.bo.engine.BO; -import com.actionsoft.bpms.commons.database.RowMap; -import com.actionsoft.bpms.schedule.IJob; -import com.actionsoft.bpms.server.UserContext; -import com.actionsoft.bpms.util.DBSql; -import com.actionsoft.sdk.local.SDK; -/** - * 模型附件去重 - * @author Administrator - * - */ -public class SelectPremJob implements IJob { - @Override - public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException { - - List palRepositoryModels = CoeProcessLevelDaoFacotory.createCoeProcessLevel() - .getAllCoeProcessLevelByWsId("7d3ca852-a0bd-42e6-80b1-3dcea6f55083"); - for (PALRepositoryModel palRepositoryModel : palRepositoryModels) { - String methodId = palRepositoryModel.getMethodId(); - if (!palRepositoryModel.getName().contains("测试") && palRepositoryModel.isUse() - && ("process.epc".equals(methodId) || "control.policy".equals(methodId) - || "data.form".equals(methodId) || "process.flowchart".equals(methodId))) { - String versionId = palRepositoryModel.getVersionId(); - String sql = "SELECT * FROM BO_ACT_PUBLISH_PERM_SCOPE WHERE PALVERSIONID ='" + versionId + "'"; - RowMap map = DBSql.getMap(sql); - if (map == null) { - BO bo = new BO(); - bo.set("PALVERSIONID", versionId); - bo.set("PALNAME", palRepositoryModel.getName()); - int level = palRepositoryModel.getLevel(); - PALRepositoryModel prmodel = PALRepositoryCache.getCache().get(palRepositoryModel.getParentId()); - if (prmodel != null) { - String name = prmodel.getName(); - if (level == 2 || level == 5 || level == 6) { - if (name.contains("测试") || name.contains("练习")) { - continue; - } - } else if (level == 3) { - if (name.contains("测试") || name.contains("Test") || name.contains("培训")) { - continue; - } - } else if (level == 4) { - if (name.contains("测试") || name.contains("Test")) { - continue; - } - } - } - - if (prmodel != null) { - bo.set("FRNAME", prmodel.getName()); - } - bo.set("PALVERSIONID", versionId); - if ("process.epc".equals(methodId)) { - bo.set("FILETYPE", "流程模型"); - - } else if ("control.policy".equals(methodId)) { - bo.set("FILETYPE", "制度模型"); - - } else if ("data.form".equals(methodId)) { - bo.set("FILETYPE", "表单模型"); - - } else if ("process.flowchart".equals(methodId)) { - bo.set("FILETYPE", "泳道图模型"); - - } - if (palRepositoryModel.isPublish()) { - bo.set("IDPLUBSH", "已发布"); - } else { - bo.set("IDPLUBSH", "未发布"); - } - - SDK.getBOAPI().createDataBO("BO_EU_PUBLISH_SCOPE_IMPORT", bo, UserContext.fromUID("admin")); - } - - } - } - - } - -} diff --git a/com.actionsoft.apps.coe.pal.publisher/src/com/actionsoft/apps/coe/pal/publisher/extend/UpateFileStateController.java b/com.actionsoft.apps.coe.pal.publisher/src/com/actionsoft/apps/coe/pal/publisher/extend/UpateFileStateController.java deleted file mode 100644 index 048cb229..00000000 --- a/com.actionsoft.apps.coe.pal.publisher/src/com/actionsoft/apps/coe/pal/publisher/extend/UpateFileStateController.java +++ /dev/null @@ -1,121 +0,0 @@ -package com.actionsoft.apps.coe.pal.publisher.extend; - -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -import com.actionsoft.apps.coe.pal.pal.repository.PALRepositoryQueryAPIManager; -import com.actionsoft.apps.coe.pal.pal.repository.cache.PALRepositoryCache; -import com.actionsoft.apps.coe.pal.pal.repository.dao.PALRepository; -import com.actionsoft.apps.coe.pal.pal.repository.model.PALRepositoryModel; -import com.actionsoft.bpms.commons.mvc.view.ResponseObject; -import com.actionsoft.bpms.server.bind.annotation.Controller; -import com.actionsoft.bpms.server.bind.annotation.Mapping; -import com.actionsoft.bpms.util.DBSql; -import com.actionsoft.bpms.util.UtilString; -import com.actionsoft.sdk.local.SDK; -import com.alibaba.fastjson.JSONObject; -/** - * 修改文件状态 - * @author lihongyu - * - */ -@Controller -public class UpateFileStateController { - private static Logger logger = LoggerFactory.getLogger(UpateFileStateController.class); - - // 修改文件发布状态 - @Mapping("com.awspaas.user.apps.app.controller.updatePalFileState") - public ResponseObject checkIsSend(String sid, String plId, String state, String type) { - ResponseObject ro = ResponseObject.newOkResponse(); - int count = 0; - if ("1".equals(type)) { - String id = DBSql.getString("SELECT ID FROM APP_ACT_COE_PAL_PUBLISH_LIST WHERE PALREPOSITORYID='" + plId + "'"); - if (UtilString.isNotEmpty(id)) { - String updataSql = "UPDATE APP_ACT_COE_PAL_REPOSITORY SET ISPUBLISH = '" + state + "' WHERE ID = '" - + plId + "'"; - count += DBSql.update(updataSql); - String sqlt = "UPDATE BO_EU_PAL_FILE1 SET FILESTATE = '" + state + "' WHERE FILEID = '" + plId + "'"; - DBSql.update(sqlt); - - - PALRepositoryModel model = PALRepositoryCache.getCache().get(plId); - String taskId = createOutputReport(model, "7d3ca852-a0bd-42e6-80b1-3dcea6f55083", "admin", "", plId); - //刷新预览加载的表 - String sqlr = "UPDATE BO_EU_PAL_OUTPUTREPORT SET TASKID = '" + taskId + "' WHERE PLID = '" + plId + "'"; - DBSql.update(sqlr); - System.err.println("重新生成手册:" + model.getName() + "--->taskId" + taskId); - DBSql.update( - "UPDATE BO_ACT_COE_PUBLISH_N SET TASKID='" + taskId + "'WHERE PUBLISHFILEID ='" + plId + "'"); - count += DBSql.update("UPDATE APP_ACT_COE_PAL_PUBLISH_LIST SET TASKID='" + taskId - + "'WHERE PALREPOSITORYID='" + plId + "'"); - } else { - //SDK.getPALPublishAPI().publishPALRepository(publishInfo, publishList) - } - } else { - - PALRepository repositoryDao = new PALRepository(); - //修改流程文件的发布属性和发布时间 - repositoryDao.updatePublishStatusAndDate("N",plId, null, null); - - - String updataSql = "UPDATE APP_ACT_COE_PAL_REPOSITORY SET ISPUBLISH = '" + state + "' WHERE ID = '" + plId - + "'"; - count += DBSql.update(updataSql); - String sqlt = "UPDATE BO_EU_PAL_FILE1 SET FILESTATE = '" + state + "' WHERE FILEID = '" + plId + "'"; - DBSql.update(sqlt); - - } - if (count > 0) { - SDK.getLogAPI().consoleInfo("更新状态后刷新缓存开始===========>"); - PALRepositoryCache.getCache().reload(); - /* - * TeamPermCache.getCache().reload(); TeamMemberPermCache.getCache().reload(); - * PublishHistoryCache.getCache().reload(); - * PublishUserGroupCache.getCache().reload(); - * PublishUserGroupPermCache.getCache().reload(); - * PublishUserGroupRoleCache.getCache().reload(); - * PALDesignerFileCache.getCache().reload(); - * PALDesignerFileDragModelCache.getCache().reload(); - * PALRepositoryRemoveCache.getCache().reload(); - * CoeDesignerShapeCache.getCache().reload(); - * DesignerShapeRelationCache.getCache().reload(); - * PALRepositoryPropertyCache.getCache().reload(); - * PALRepositoryAttributeCache.getCache().reload(); - * PALRepositoryShapeConfigCache.getCache().reload(); - * PALRepositoryShapeAttributeCache.getCache().reload(); - * CoeProcessLevelCorrelateCache.getCache().reload(); - * CoeDesignerImageCache.getCache().reload(); - */ - SDK.getLogAPI().consoleInfo("更新状态后刷新缓存结束===========>"); - ro.put("result", "ok"); - } else { - ro.put("result", "error"); - } - return ro; - } - - private String createOutputReport(PALRepositoryModel model, String wsId, String userId, String teamId, String uuid) { - String taskId = ""; - if (model.getMethodId().contains("process.")) { - taskId = PALRepositoryQueryAPIManager.getInstance().createOutputReportPr(wsId, userId, teamId, uuid); - JSONObject object = JSONObject.parseObject(taskId); - if ("ok".equals(object.getString("result"))) { - taskId = object.getJSONObject("data").getString("taskId"); - } - } else if ("data.form".equals(model.getMethodId())) { - taskId = PALRepositoryQueryAPIManager.getInstance().createOutputReportBd(wsId, userId, teamId, uuid); - JSONObject object = JSONObject.parseObject(taskId); - if ("ok".equals(object.getString("result"))) { - taskId = object.getJSONObject("data").getString("taskId"); - } - } else if ("control.policy".equals(model.getMethodId())) { - taskId = PALRepositoryQueryAPIManager.getInstance().createOutputReportZd(wsId, userId, teamId, uuid); - JSONObject object = JSONObject.parseObject(taskId); - if ("ok".equals(object.getString("result"))) { - taskId = object.getJSONObject("data").getString("taskId"); - } - } - return taskId; - } - -} diff --git a/com.actionsoft.apps.coe.pal.publisher/src/com/actionsoft/apps/coe/pal/publisher/pubEvent/ProcessEndAfterEvent.java b/com.actionsoft.apps.coe.pal.publisher/src/com/actionsoft/apps/coe/pal/publisher/pubEvent/ProcessEndAfterEvent.java index a7e18dcc..fddaa82a 100644 --- a/com.actionsoft.apps.coe.pal.publisher/src/com/actionsoft/apps/coe/pal/publisher/pubEvent/ProcessEndAfterEvent.java +++ b/com.actionsoft.apps.coe.pal.publisher/src/com/actionsoft/apps/coe/pal/publisher/pubEvent/ProcessEndAfterEvent.java @@ -35,6 +35,7 @@ import com.actionsoft.bpms.bpmn.engine.core.delegate.ProcessExecutionContext; import com.actionsoft.bpms.bpmn.engine.listener.ExecuteListener; import com.actionsoft.bpms.bpmn.engine.listener.ExecuteListenerInterface; import com.actionsoft.bpms.bpmn.engine.model.run.delegate.ProcessInstance; +import com.actionsoft.bpms.bpmn.engine.model.run.delegate.TaskInstance; import com.actionsoft.bpms.commons.database.RowMap; import com.actionsoft.bpms.commons.login.constant.LoginConst; import com.actionsoft.bpms.commons.mvc.view.ResponseObject; @@ -233,6 +234,10 @@ public class ProcessEndAfterEvent extends ExecuteListener implements ExecuteList } } long endTimes = System.currentTimeMillis(); + //文件发布成功回执流程 + ProcessInstance processInst = SDK.getProcessAPI().createProcessInstance("obj_b4700f89a7a144c086d047de0cfe9531", "admin", bo_act_coe_publish1.getString("PROCESS_TITLE")+"成功发布回执单"); + TaskInstance taskInst = SDK.getProcessAPI().start(processInst).fetchActiveTasks().get(0); + SDK.getTaskAPI().completeTask(taskInst.getId(), "admin"); //存入日志 createReadLog(processExecutionContext, jsonObject, sendList, startTime,endTimes); System.err.println(instanceById.getTitle() + "推送OA待阅执行完毕====>" + "用时："+(endTimes-startTime)/1000/60+"分钟"); @@ -1021,7 +1026,7 @@ public class ProcessEndAfterEvent extends ExecuteListener implements ExecuteList bo_Read_log.set("STARTTIMES", startTime); bo_Read_log.set("ENDTIMES", endTimes); bo_Read_log.set("TIMECOUNT", (endTimes-startTime)/1000/60+"分钟"); - SDK.getBOAPI().createDataBO("BO_EU_PAL_READ_LOG", bo_Read_log, processExecutionContext.getUserContext()); + SDK.getBOAPI().createDataBO("BO_EU_PAL_PULBISH_SUCCESS", bo_Read_log, processExecutionContext.getUserContext()); }