From 7f9f8bd9a6d94a9c7e149426e98dd645a9a24ed3 Mon Sep 17 00:00:00 2001 From: Mr-wang Date: Wed, 18 Oct 2023 15:10:35 +0800 Subject: [PATCH] =?UTF-8?q?=E6=89=B9=E9=87=8F=E5=88=B7=E6=96=B0Sys=5Fac?= =?UTF-8?q?=E8=A1=A8=E6=95=B0=E6=8D=AE=E4=BB=A5=E5=8F=8A=E6=A0=B9=E6=8D=AE?= =?UTF-8?q?=E5=8F=91=E5=B8=83=E6=B5=81=E7=A8=8B=E4=B8=AD=E7=9A=84=E8=A1=A8?= =?UTF-8?q?=E5=8D=95=E6=95=B0=E6=8D=AE,=E6=89=B9=E9=87=8F=E5=B0=86?= =?UTF-8?q?=E9=83=A8=E9=97=A8=E4=BF=AE=E6=94=B9=E4=B8=BA=E5=85=AC=E5=8F=B8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../awspaas/user/bpa/job/UpdateKnowJobs.java | 72 +++++++++++++++++++ .../awspaas/user/bpa/job/UpdateSysAcJob.java | 38 ++++++++++ 2 files changed, 110 insertions(+) create mode 100644 com.awspaas.user.bpa/src/com/awspaas/user/bpa/job/UpdateKnowJobs.java create mode 100644 com.awspaas.user.bpa/src/com/awspaas/user/bpa/job/UpdateSysAcJob.java 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 new file mode 100644 index 00000000..ee2b0dcd --- /dev/null +++ b/com.awspaas.user.bpa/src/com/awspaas/user/bpa/job/UpdateKnowJobs.java @@ -0,0 +1,72 @@ +package com.awspaas.user.bpa.job; + +import com.actionsoft.bpms.bo.engine.BO; +import com.actionsoft.bpms.bpmn.engine.core.delegate.ProcessExecutionContext; +import com.actionsoft.bpms.bpmn.engine.model.run.delegate.ProcessInstance; +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.UserContext; +import com.actionsoft.bpms.util.DBSql; +import com.actionsoft.sdk.local.SDK; +import com.actionsoft.sdk.local.api.AppAPI; +import com.alibaba.fastjson.JSONArray; +import com.alibaba.fastjson.JSONObject; +import org.quartz.JobExecutionContext; +import org.quartz.JobExecutionException; + +import java.sql.Connection; +import java.util.HashMap; +import java.util.List; +import java.util.Map; + +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(); + 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); + } + } + } + } + + public boolean AddKnwlAC(JSONArray jsonArray, String sid, + String knwlId) { + + // 调用App + String sourceAppId = "com.awspaas.user.apps.new_performance_indicator_library"; + // aslp服务地址 + String aslp = "aslp://com.actionsoft.apps.kms/AddKnwlAC"; + // 参数定义列表 + Map params = new HashMap(); + // [{"assignmentType":"department","assignmentId":"62196ff9-a26d-4be5-9480-3ef680886f63"},{"assignmentType":"user","assignmentId":"user1"}],必填 + params.put("acList", jsonArray); + // sid，如果为空，则需要传createUser参数,非必填 + params.put("sid", sid); + // 知识ID,必填 + params.put("knwlId", knwlId); + AppAPI appAPI = SDK.getAppAPI(); + // 给知识授权 + ResponseObject ro = appAPI.callASLP(appAPI.getAppContext(sourceAppId), aslp, params); + SDK.getLogAPI().consoleInfo("是否授权成功>>>>>>>>>>>>>>>"+ro.isOk()); + return ro.isOk(); + } +} diff --git a/com.awspaas.user.bpa/src/com/awspaas/user/bpa/job/UpdateSysAcJob.java b/com.awspaas.user.bpa/src/com/awspaas/user/bpa/job/UpdateSysAcJob.java new file mode 100644 index 00000000..c8a6386b --- /dev/null +++ b/com.awspaas.user.bpa/src/com/awspaas/user/bpa/job/UpdateSysAcJob.java @@ -0,0 +1,38 @@ +package com.awspaas.user.bpa.job; + +import com.actionsoft.bpms.commons.database.RowMap; +import com.actionsoft.bpms.schedule.IJob; +import com.actionsoft.bpms.util.DBSql; +import org.quartz.JobExecutionContext; +import org.quartz.JobExecutionException; + +import java.util.List; + +public class UpdateSysAcJob implements IJob { + @Override + public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException { + List maps = DBSql.getMaps("select distinct RESOURCEID from sys_ac where RESOURCETYPE = 'kms.card'"); + List maps1 = DBSql.getMaps("select distinct ID from app_act_kms_card"); + boolean flag = false; + String flag_id = ""; + for (RowMap rowMap:maps1) { + String id = rowMap.getString("ID"); + for (RowMap rowMap1: + maps) { + String id1 = rowMap1.getString("ID"); + flag_id = id1; + if (id1.equals(id)){ + flag = true; + break; + } + } + if (flag == true){ + continue; + } + if (flag == false){ + DBSql.update("delete from sys_ac where RESOURCETYPE = 'kms.card' and RESOURCEID = '"+flag_id+"'"); + } + } + } + +}