OA待阅发布代码提交
This commit is contained in:
parent
348cc955d3
commit
ca72061bb4
Binary file not shown.
@ -2559,7 +2559,7 @@ public class ProcessPublishWeb extends ActionWeb {
|
||||
String name = parseObject.getString("name");
|
||||
if (!"流程制度".equals(name)) {
|
||||
String versionId = parseObject.getString("versionId");
|
||||
String sql = "SELECT PLNAME FROM APP_ACT_COE_PAL_REPOSITORY WHERE PLVERSIONID = '" + versionId + "' and ISPUBLISH = '0' and ISSTOP = '0' ";
|
||||
String sql = "SELECT PLNAME FROM APP_ACT_COE_PAL_REPOSITORY WHERE PLVERSIONID = '" + versionId + "' and ISPUBLISH = '0' and ISSTOP = '0' order by plver ";
|
||||
String newName = DBSql.getString(sql);
|
||||
parseObject.replace("name", newName);
|
||||
parseObject.replace("isParent", "false");
|
||||
|
||||
@ -114,6 +114,18 @@ public class ProcessEndAfterEvent_new extends ExecuteListener implements Execute
|
||||
e.printStackTrace();
|
||||
}
|
||||
|
||||
|
||||
//发送消息通知
|
||||
List<BO> readCountBO=SDK.getBOAPI().query("BO_EU_READ_COUNT").addQuery("PROCESSID=",ext.getProcessInstance().getId()).addQuery("RESULT=","待处理").list();
|
||||
if(readCountBO.size()>0){
|
||||
SDK.getNotificationAPI().sendMessage("admin", "admin", "文件名称:"+ext.getProcessInstance().getTitle()+"文件有失败记录，请及时处理！！！");
|
||||
}
|
||||
|
||||
|
||||
//更新任务状态
|
||||
int r1 = DBSql.update("UPDATE BO_ACT_EXECUTIVE_TASK SET ISTASKEND='2' WHERE TASKID ='" + ext.getProcessInstance().getId() + "'");
|
||||
|
||||
|
||||
}
|
||||
|
||||
public void ProcessData(ProcessExecutionContext processExecutionContext,Connection open) throws Exception {
|
||||
@ -551,30 +563,29 @@ public class ProcessEndAfterEvent_new extends ExecuteListener implements Execute
|
||||
/**
|
||||
* 创建索引
|
||||
* @param processExecutionContext 流程实例
|
||||
* @param index 索引名称 (随便填写,aslp那边已经有固定的)
|
||||
* @param type 类型(随便填写,aslp中也是有固定的)
|
||||
* @param documentPath dc全路径
|
||||
* @param fileNames 文件名称
|
||||
* @param contents 索引内容
|
||||
* @return
|
||||
*/
|
||||
public void createIndexByFile(ProcessExecutionContext processExecutionContext,String index,String type,String documentPath,JSONObject fileNames) {
|
||||
|
||||
public boolean createIndexesByContent(ProcessExecutionContext processExecutionContext,JSONArray contents) {
|
||||
// 调用App
|
||||
String sourceAppId = processExecutionContext.getProcessInstance().getAppId();
|
||||
String sourceAppId =processExecutionContext.getProcessInstance().getAppId() ;
|
||||
// aslp服务地址
|
||||
String aslp = "aslp://com.actionsoft.apps.addons.es/createIndexByFile";
|
||||
String aslp = "aslp://com.actionsoft.apps.addons.es/createIndexesByContent";
|
||||
// 参数定义列表
|
||||
Map params = new HashMap<String, Object>();
|
||||
//索引内容(JSONArray格式, JSONArray中包含JSONObject, JSONObject的内容同创建单个索引),必填
|
||||
params.put("contents", contents);
|
||||
//索引名称(文档在哪存放),必填
|
||||
params.put("index", index);
|
||||
params.put("index", "com.actionsoft.apps.kms_kmsdoc_card");
|
||||
//类型(索引中对数据进行逻辑分区。不同 type的文档可能有不同的字段，但最好能够非常相似,比如：存储所有产品到索引products中，但是你有许多不同的产品类别，这些产品共享一种相同的（或非常相似）的模式：他们有一个标题、描述、产品代码和价格。他们只是正好属于“产品”下的一些子类。用type表示不同的类别),必填
|
||||
params.put("type", type);
|
||||
//要入库的文件全路径,必填
|
||||
params.put("documentPath", documentPath);
|
||||
//文件实际名称， jsonObject,非必填
|
||||
params.put("fileNames", fileNames);
|
||||
params.put("type", "kmsdoc_card");
|
||||
AppAPI appAPI = SDK.getAppAPI();
|
||||
//入库操作，从文件创建内容索引
|
||||
//入库操作，创建内容索引(多个)
|
||||
ResponseObject ro = appAPI.callASLP(appAPI.getAppContext(sourceAppId), aslp, params);
|
||||
System.out.println("ro===================="+ro);
|
||||
|
||||
System.out.println("ro==================="+ro);
|
||||
return ro.isOk();
|
||||
}
|
||||
|
||||
/**
|
||||
@ -659,15 +670,6 @@ public class ProcessEndAfterEvent_new extends ExecuteListener implements Execute
|
||||
|
||||
|
||||
|
||||
//发送消息通知
|
||||
List<BO> readCountBO=SDK.getBOAPI().query("BO_EU_READ_COUNT").addQuery("PROCESSID=",processExecutionContext.getProcessInstance().getId()).addQuery("RESULT=","待处理").list();
|
||||
if(readCountBO.size()>0){
|
||||
SDK.getNotificationAPI().sendMessage("admin", "admin", "文件名称:"+processExecutionContext.getProcessInstance().getTitle()+"文件有失败记录，请及时处理！！！");
|
||||
}
|
||||
|
||||
//更新任务状态
|
||||
int r1 = DBSql.update("UPDATE BO_ACT_EXECUTIVE_TASK SET ISTASKEND='2' WHERE TASKID ='" + processExecutionContext.getProcessInstance().getId() + "'");
|
||||
|
||||
|
||||
} catch (Exception e) {
|
||||
System.out.println("等待中断异常");
|
||||
@ -760,7 +762,16 @@ public class ProcessEndAfterEvent_new extends ExecuteListener implements Execute
|
||||
//创建文件
|
||||
ResponseObject ro = appAPI.callASLP(appAPI.getAppContext(sourceAppId), aslp, params);
|
||||
System.out.println("流程手册的存入=================" + ro);
|
||||
createIndexByFile(processExecutionContext, dcContext.getFileName(),"process",dcContext.getFilePath(),new JSONObject());
|
||||
|
||||
JSONArray coontest = new JSONArray(new LinkedList<>());
|
||||
JSONObject jsonObject = new JSONObject(new LinkedHashMap<>());
|
||||
jsonObject.put("documentId", cardId);
|
||||
jsonObject.put("content", "");//信息附件
|
||||
jsonObject.put("abstract", dcContext);//信息摘要
|
||||
jsonObject.put("title", dcContext.getFileName().substring(0,dcContext.getFileName().indexOf(".")));//信息标题
|
||||
coontest.add(jsonObject);
|
||||
//createIndexesByContent(processExecutionContext,coontest);
|
||||
|
||||
}
|
||||
}
|
||||
|
||||
@ -799,7 +810,16 @@ public class ProcessEndAfterEvent_new extends ExecuteListener implements Execute
|
||||
paramss.put("dc", dcContexts);
|
||||
AppAPI appAPIs = SDK.getAppAPI();
|
||||
ResponseObject ros = appAPIs.callASLP(appAPIs.getAppContext(sourceAppId), aslp, paramss);
|
||||
//createIndexByFile(processExecutionContext, dcContexts.getFileName(),"process",dcContexts.getFilePath(),new JSONObject());
|
||||
|
||||
JSONArray coontest = new JSONArray(new LinkedList<>());
|
||||
JSONObject jsonObject = new JSONObject(new LinkedHashMap<>());
|
||||
jsonObject.put("documentId", cardId);
|
||||
jsonObject.put("content", "");//信息附件
|
||||
jsonObject.put("abstract", dcContexts);//信息摘要
|
||||
jsonObject.put("title", dcContexts.getFileName().substring(0,dcContexts.getFileName().indexOf(".")));//信息标题
|
||||
coontest.add(jsonObject);
|
||||
//createIndexesByContent(processExecutionContext,coontest);
|
||||
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -2097,7 +2117,7 @@ public class ProcessEndAfterEvent_new extends ExecuteListener implements Execute
|
||||
jsonObject_ehsq.put("releasescope", "内蒙古伊利实业集团股份有限公司");
|
||||
} else {
|
||||
|
||||
String departname = "";
|
||||
/*String departname = "";
|
||||
String orgperm = bo1.getString("ORGPERM");
|
||||
String dleass = "";
|
||||
String[] deptSplit = orgperm.split(",");
|
||||
@ -2114,9 +2134,10 @@ public class ProcessEndAfterEvent_new extends ExecuteListener implements Execute
|
||||
if(UtilString.isNotEmpty(departname)&&departname.length()>500) {
|
||||
String substring = departname.substring(0, 500);
|
||||
departname = substring.substring(0,substring.lastIndexOf(";"));
|
||||
}
|
||||
jsonObject_ehsq.put("releasescope", departname);
|
||||
}*/
|
||||
//jsonObject_ehsq.put("releasescope", departname);
|
||||
|
||||
jsonObject_ehsq.put("releasescope", byProcess.getString("IS_THE_UNIT"));
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
Loading…
Reference in New Issue
Block a user