diff --git a/com.awspaas.user.bpa/src/com/awspaas/user/bpa/job/UpdateKnowJobs.java b/com.awspaas.user.bpa/src/com/awspaas/user/bpa/job/UpdateKnowJobs.java index f714ef00..2b71e5ed 100644 --- a/com.awspaas.user.bpa/src/com/awspaas/user/bpa/job/UpdateKnowJobs.java +++ b/com.awspaas.user.bpa/src/com/awspaas/user/bpa/job/UpdateKnowJobs.java @@ -24,47 +24,52 @@ public class UpdateKnowJobs implements IJob { @Override public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException { Connection open = DBSql.open(); - List list = SDK.getBOAPI().query("BO_ACT_COE_PUBLISH", true).addQuery("SEND_SCOP=", "1").addQuery("SEND_SCOPE_ORG IS NULL", null).list(); + List list = SDK.getBOAPI().query("BO_ACT_COE_PUBLISH", true).addQuery("ISEND=","1").addQuery("SEND_SCOP=", "1").addQuery("SEND_SCOPE_ORG IS NULL", null).list(); for (BO bo:list) { String bindid = bo.getString("BINDID"); - List bo_act_coe_publish_n = SDK.getBOAPI().query("BO_ACT_COE_PUBLISH_N", true).addQuery("BINDID = ", bindid).list(); - for (BO bo1:bo_act_coe_publish_n) { - String publishfileid = bo1.getString("PUBLISHFILEID"); - RowMap map = DBSql.getMap("select * from APP_ACT_COE_PAL_REPOSITORY where ID = '" + publishfileid + "' AND ISPUBLISH = '1' AND ISSTOP='0'"); - String ext4 = map.getString("EXT4"); - RowMap map1 = DBSql.getMap("select * from app_act_kms_card where ID = '" + ext4 + "'"); - if (map1!=null){ - int update = DBSql.update("delete from sys_ac where RESOURCEID = '" + ext4 + "' AND RESOURCETYPE = 'kms.card'"); - SDK.getLogAPI().consoleInfo("删除ac授权文件>>>>>>>>>>"+update); - JSONArray jsonArray1 = new JSONArray(); - JSONObject jsonObjecta = new JSONObject(); - jsonObjecta.put("assignmentType", "company"); - jsonObjecta.put("assignmentId", "8911e732-b42a-4556-853f-ad32761bcbee"); - jsonArray1.add(jsonObjecta); - UserContext userContext = UserContext.fromUID("admin"); - AddKnwlAC(jsonArray1,userContext.getSessionId(),ext4); - } - } + ProcessInstance instanceById = SDK.getProcessAPI().getInstanceById(bindid); + boolean end = instanceById.isEnd(); + if (end) { - List bo_act_coe_publish_c = SDK.getBOAPI().query("BO_ACT_COE_PUBLISH_C", true).addQuery("BINDID = ", bindid).list(); - for (BO bo1:bo_act_coe_publish_c) { - String publishfileid = bo1.getString("CHANGEDFILEIDNEW"); - RowMap map = DBSql.getMap("select * from APP_ACT_COE_PAL_REPOSITORY where ID = '" + publishfileid + "' AND ISPUBLISH = '1' AND ISSTOP='0'"); - String ext4 = map.getString("EXT4"); - RowMap map1 = DBSql.getMap("select * from app_act_kms_card where ID = '" + ext4 + "'"); - if (map1!=null){ - int update = DBSql.update("delete from sys_ac where RESOURCEID = '" + ext4 + "' AND RESOURCETYPE = 'kms.card'"); - SDK.getLogAPI().consoleInfo("删除ac授权文件>>>>>>>>>>"+update); - JSONArray jsonArray1 = new JSONArray(); - JSONObject jsonObjecta = new JSONObject(); - jsonObjecta.put("assignmentType", "company"); - jsonObjecta.put("assignmentId", "8911e732-b42a-4556-853f-ad32761bcbee"); - jsonArray1.add(jsonObjecta); - UserContext userContext = UserContext.fromUID("admin"); - AddKnwlAC(jsonArray1,userContext.getSessionId(),ext4); + List bo_act_coe_publish_n = SDK.getBOAPI().query("BO_ACT_COE_PUBLISH_N", true).addQuery("BINDID = ", bindid).list(); + for (BO bo1 : bo_act_coe_publish_n) { + String publishfileid = bo1.getString("PUBLISHFILEID"); + RowMap map = DBSql.getMap("select * from APP_ACT_COE_PAL_REPOSITORY where ID = '" + publishfileid + "' AND ISPUBLISH = '1' AND ISSTOP='0'"); + String ext4 = map.getString("EXT4"); + RowMap map1 = DBSql.getMap("select * from app_act_kms_card where ID = '" + ext4 + "'"); + if (map1 != null) { + int update = DBSql.update("delete from sys_ac where RESOURCEID = '" + ext4 + "' AND RESOURCETYPE = 'kms.card'"); + SDK.getLogAPI().consoleInfo("删除ac授权文件>>>>>>>>>>" + update); + JSONArray jsonArray1 = new JSONArray(); + JSONObject jsonObjecta = new JSONObject(); + jsonObjecta.put("assignmentType", "company"); + jsonObjecta.put("assignmentId", "8911e732-b42a-4556-853f-ad32761bcbee"); + jsonArray1.add(jsonObjecta); + UserContext userContext = UserContext.fromUID("admin"); + AddKnwlAC(jsonArray1, userContext.getSessionId(), ext4); + } } - } + List bo_act_coe_publish_c = SDK.getBOAPI().query("BO_ACT_COE_PUBLISH_C", true).addQuery("BINDID = ", bindid).list(); + for (BO bo1 : bo_act_coe_publish_c) { + String publishfileid = bo1.getString("CHANGEDFILEIDNEW"); + RowMap map = DBSql.getMap("select * from APP_ACT_COE_PAL_REPOSITORY where ID = '" + publishfileid + "' AND ISPUBLISH = '1' AND ISSTOP='0'"); + String ext4 = map.getString("EXT4"); + RowMap map1 = DBSql.getMap("select * from app_act_kms_card where ID = '" + ext4 + "'"); + if (map1 != null) { + int update = DBSql.update("delete from sys_ac where RESOURCEID = '" + ext4 + "' AND RESOURCETYPE = 'kms.card'"); + SDK.getLogAPI().consoleInfo("删除ac授权文件>>>>>>>>>>" + update); + JSONArray jsonArray1 = new JSONArray(); + JSONObject jsonObjecta = new JSONObject(); + jsonObjecta.put("assignmentType", "company"); + jsonObjecta.put("assignmentId", "8911e732-b42a-4556-853f-ad32761bcbee"); + jsonArray1.add(jsonObjecta); + UserContext userContext = UserContext.fromUID("admin"); + AddKnwlAC(jsonArray1, userContext.getSessionId(), ext4); + } + } + + } } }