yuxueliang0813
/
shjh
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

1.OA待办事项 

--s
This commit is contained in:
weiyunlong 2025-02-25 19:08:30 +08:00
parent c304a7e581
commit 9d68d478f9
4 changed files with 387 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

51
main/java/shjh/jhzj7/fi/fi/plugin/workflow/closeTaskPagePlugin.java Normal file
View File

@ -0,0 +1,51 @@
package shjh.jhzj7.fi.fi.plugin.workflow;
import com.alibaba.fastjson.JSON;
import kd.bos.form.FormShowParameter;
import kd.bos.logging.Log;
import kd.bos.logging.LogFactory;
import kd.bos.mvc.form.FormView;
import kd.bos.workflow.taskcenter.plugin.validate.IApprovalSubPlugin;
import java.util.HashMap;
import java.util.Map;
/**
* 待办提交关闭页面
*/
public class closeTaskPagePlugin implements IApprovalSubPlugin {
private static final Log logger = LogFactory.getLog(closeTaskPagePlugin.class);
@Override
public boolean executeClosePageAfterSubmitTask(boolean isPCShow, Map<String, Object> customParams) {
logger.info("进入页面关闭方法");
boolean flag = false;
FormView view = (FormView) customParams.get("formView");
FormShowParameter parameter = view.getFormShowParameter();
logger.info("获取view对象成功");
if (parameter.getCustomParams().containsKey("apptype")) {
String apptype = parameter.getCustomParam("apptype");
if ("fanwei".equals(apptype)) {
if (isPCShow) {
try {
view.close();
} catch (Exception e) {
logger.info("发送指令时异常" + e.getMessage());
throw new RuntimeException(e);
}
flag = true;
} else {
HashMap<String, Object> map = new HashMap<>();
map.put("method", "closeWebView");
String mapString = JSON.toJSONString(map);
view.executeClientCommand("callAPPApi", map);
logger.info("准备发送指令" + mapString);
logger.info("准备关闭移动页面");
flag = true;
}
}
}
return flag;
}
}

151
main/java/shjh/jhzj7/fi/fi/plugin/workflow/todoZyTaskServiceHandler.java Normal file
View File

@ -0,0 +1,151 @@
package shjh.jhzj7.fi.fi.plugin.workflow;
import com.alibaba.fastjson.JSONObject;
import kd.bos.dataentity.entity.DynamicObject;
import kd.bos.logging.Log;
import kd.bos.logging.LogFactory;
import kd.bos.servicehelper.BusinessDataServiceHelper;
import kd.bos.workflow.engine.msg.AbstractMessageServiceHandler;
import kd.bos.workflow.engine.msg.ctx.MessageContext;
import kd.bos.workflow.engine.msg.info.MessageInfo;
import kd.bos.workflow.engine.msg.info.ToDoInfo;
import java.text.SimpleDateFormat;
import java.util.*;
import static kd.bd.assistant.plugin.basedata.WorkCalendarEditPlugin.SDF;
import static shjh.jhzj7.fi.fi.utils.OAUtils.thirdParty;
public class todoZyTaskServiceHandler extends AbstractMessageServiceHandler {
private static final Log logger = LogFactory.getLog(todoZyTaskServiceHandler.class);
@Override
public void createToDo(MessageContext messageContext, ToDoInfo toDoInfo) {
System.out.println("createToDo");
// 构建第三方数据映射
Map<String, Object> thirdPartyMap = buildThirdPartyMap(messageContext, toDoInfo, "0", "0");
//推送OA待办接口
thirdParty(thirdPartyMap);
System.out.println("createToDo");
}
@Override
public void dealToDo(MessageContext messageContext, ToDoInfo toDoInfo) {
//select * from t_wf_operationlog where fbillno = '测试:待办推送致远(1106-1915)'
//todo 待办推送第三方,节点审批通过或者驳回到某节点时都会进入(dealToDo)方法,代码如何判断该节点是驳回还是审批通过
System.out.println("dealToDo");
// 构建第三方数据映射 流程处理状态；0:待办,2：已办,4：办结 流程查看状态；0:未读,1：已读
Map<String, Object> thirdPartyMap = buildThirdPartyMap(messageContext, toDoInfo, "2", "1");
// 推送 OA 待办接口
thirdParty(thirdPartyMap);
System.out.println("dealToDo");
}
@Override
public void deleteToDo(MessageContext messageContext, ToDoInfo toDoInfo) {
System.out.println("deleteToDo");
// 构建第三方数据映射
Map<String, Object> thirdPartyMap = buildThirdPartyMap(messageContext, toDoInfo, "4", "1");
// 推送 OA 待办接口
thirdParty(thirdPartyMap);
System.out.println("deleteToDo");
}
@Override
public void sendMessage(MessageContext messageContext, MessageInfo message) {
System.out.println("sendMessage");
System.out.println("sendMessage");
}
/**
* 构建第三方数据映射
*
* @param messageContext 消息上下文
* @param toDoInfo 待办信息
* @param isRemark 流程处理状态
* @param viewType 流程查看状态
* @return 第三方数据映射
*/
private Map<String, Object> buildThirdPartyMap(MessageContext messageContext, ToDoInfo toDoInfo, String isRemark, String viewType) {
// 获取流程实例ID
Long processInstanceId = messageContext.getProcessInstanceId();
// 获取任务步骤
Long executionId = messageContext.getExecutionId(); // 节点ID
// 获取当前任务ID
Long taskId = messageContext.getTaskId();
// 获取单据编码
String billNo = messageContext.getBillNo();
// 获取审批人集合
List<DynamicObject> approvers = new ArrayList<>();
List<Long> userIds = toDoInfo.getUserIds(); // 审批人ID集合
List<DynamicObject> approversLists = getApprovers(userIds, approvers);
// 获取任务标题
Map<String, Object> params = toDoInfo.getParams();
String subjectJson = (String) params.get("subject");
JSONObject subjectObj = JSONObject.parseObject(subjectJson);
String title = subjectObj.getString("zh_CN");
// 节点名称
String executionName = "";
DynamicObject execution = BusinessDataServiceHelper.loadSingle(executionId, "wf_execution");
if (execution != null) {
executionName = execution.getString("activityname");// 节点名称
}
// 获取Url
String url = toDoInfo.getUrl(); // 链接
String appurl = url + "&device=mob&ado=view";
// 获取任务创建人
Long startUserId = messageContext.getStartUserId(); // 审批实例发起人id
DynamicObject startUser = BusinessDataServiceHelper.loadSingle(startUserId, "bos_user");
String startNumber = "";
String startName = "";
if (null != startUser) {
startNumber = startUser.getString("number");
startName = startUser.getString("name");
}
// 待办创建时间（格式：yyyy-MM-dd HH:mm:ss）
Date createDate = messageContext.getCreateDate();
String createDateStr = SDF.format(createDate);
Map<String, Object> thirdPartyMap = new HashMap<>();
thirdPartyMap.put("syscode", "Kingdee");// 异构系统标识
thirdPartyMap.put("flowid", taskId);// 流程任务ID，流程数据的标识，可自定义
thirdPartyMap.put("requestname", title);// 标题
thirdPartyMap.put("approversLists", approversLists);// 审批人集合
thirdPartyMap.put("workflowname", "流程类型名称");// todo:流程类型名称
thirdPartyMap.put("nodename", executionName);// 步骤名称（节点名称）
thirdPartyMap.put("pcurl", url);// PC地址，第三方系统中流程处理界面的PC端地址
thirdPartyMap.put("appurl", appurl);// APP地址，第三方系统中流程处理界面的移动端地址
thirdPartyMap.put("isremark", isRemark);// 流程处理状态；0：待办 ，2：已办 ，4：办结。
thirdPartyMap.put("viewtype", viewType);// 流程查看状态；0：未读，1：已读。
thirdPartyMap.put("creator", startNumber);// 发起人
thirdPartyMap.put("createDateStr", createDateStr);// 创建日期时间，格式：yyyy-MM-dd HH:mm:ss
thirdPartyMap.put("receivedatetime", createDateStr);// 接收日期时间，格式：yyyy-MM-dd HH:mm:ss
thirdPartyMap.put("billNo", billNo);// 单据编号
return thirdPartyMap;
}
/**
* 通过人员id获取人员信息
*
* @param userIds 人员id集合
* @param approvers 人员信息集合
*/
private List<DynamicObject> getApprovers(List<Long> userIds, List<DynamicObject> approvers) {
List<Long> distinctUserIds = new ArrayList<>();
for (Long userId : userIds) {
if (!distinctUserIds.contains(userId)) {
distinctUserIds.add(userId);
}
}
for (Long userId : distinctUserIds) {
DynamicObject user = BusinessDataServiceHelper.loadSingle(userId, "bos_user");
approvers.add(user);
}
return approvers;
}
}

180
main/java/shjh/jhzj7/fi/fi/utils/OAUtils.java Normal file
View File

@ -0,0 +1,180 @@
package shjh.jhzj7.fi.fi.utils;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import kd.bos.dataentity.entity.DynamicObject;
import kd.bos.logging.Log;
import kd.bos.logging.LogFactory;
import kd.bos.util.HttpClientUtils;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Objects;
/**
* 待办集成工具类-->泛微
*/
public class OAUtils {
public static final String oaUrl = "https://hipint-stg.jahwa.com.cn:6443/gateway/HIP_ReceiveToOA/1.0/receiveToOA";//测试环境
public static final String oaAPIKey = "207b5296-9866-4b4b-8146-1fea58b3c8c9";//测试环境APIKey
private static final Log logger = LogFactory.getLog(OAUtils.class);
private static final String Apimenthod = "OA待办接口";
// public static final String oaUrl = "https://hipint.jahwa.com.cn:6443/gateway/HIP_ReceiveToOA/1.0/receiveToOA";//正式环境
// public static final String oaAPIKey = "8281da80-b39b-48c4-83bd-f8e480740c6a";//测试环境APIKey
/**
* 金蝶系统推送OA待办新增
* @param thirdPartyMap 流程参数
* 接收流程数据：可接收待办、已办、归档的流程数据
* x-Gateway-APIKey: 207b5296-9866-4b4b-8146-1fea58b3c8c9（测试）
* 8281da80-b39b-48c4-83bd-f8e480740c6a（生产）
*/
public static void thirdParty(Map<String, Object> thirdPartyMap) {
// 构建请求头
Map<String, String> customerHeader = buildCustomerHeader(thirdPartyMap);
// 组装请求体
JSONObject pendingsBody = buildPendingsBody(thirdPartyMap);
// 发送请求并处理响应
processRequest(customerHeader, pendingsBody, thirdPartyMap);
}
/**
* 构建请求头
* @param thirdPartyMap 第三方数据映射
* @return 请求头映射
*/
private static Map<String, String> buildCustomerHeader(Map<String, Object> thirdPartyMap) {
Map<String, String> customerHeader = new HashMap<>();
customerHeader.put("Content-Type", "application/json;charset=UTF-8");//请求报文类型
customerHeader.put("x-Gateway-APIKey",oaAPIKey);//apiKey,由ESB提供
customerHeader.put("interfaceID", "TodoFlow");//todo:识别被调接口并进行路由
customerHeader.put("senderID", String.valueOf(thirdPartyMap.get("creator")));//定义的发送者.暂定工号
return customerHeader;
}
/**
* 组装请求体
* @param thirdPartyMap 第三方数据映射
* @return 请求体的 JSON 对象
*/
private static JSONObject buildPendingsBody(Map<String, Object> thirdPartyMap) {
//组装请求体
JSONObject pendingsBody = new JSONObject();
pendingsBody.put("rootContextID", "qqqqqq");//todo:唯一事务ID，采用UUID或其他强唯一性ID
pendingsBody.put("requestTime", String.valueOf(thirdPartyMap.get("createdatetime")));//请求时间,格式为yyyy-MM-dd HH:mm:ss.SSS
JSONArray data = new JSONArray();
//接收人信息
List<DynamicObject> approversLists = (List<DynamicObject>) thirdPartyMap.get("approversLists");
for (DynamicObject approver : approversLists) {
JSONObject jsonObject = new JSONObject();
jsonObject.put("syscode", String.valueOf(thirdPartyMap.get("syscode")));//异构系统标识
jsonObject.put("flowid", String.valueOf(thirdPartyMap.get("flowid")) + approver.getString("number"));//流程任务ID，流程数据的标识，可自定义
jsonObject.put("requestname", String.valueOf(thirdPartyMap.get("requestname")));//标题
jsonObject.put("workflowname", String.valueOf(thirdPartyMap.get("workflowname")));//todo:流程类型名称
jsonObject.put("nodename", String.valueOf(thirdPartyMap.get("nodename")));//步骤名称（节点名称）
jsonObject.put("pcurl", String.valueOf(thirdPartyMap.get("pcurl")));//PC地址，第三方系统中流程处理界面的PC端地址
jsonObject.put("appurl", String.valueOf(thirdPartyMap.get("appurl")));//APP地址，第三方系统中流程处理界面的移动端地址
jsonObject.put("isremark", String.valueOf(thirdPartyMap.get("isremark")));//流程处理状态；0：待办 ，2：已办 ，4：办结。
jsonObject.put("viewtype", String.valueOf(thirdPartyMap.get("viewtype")));//流程查看状态；0：未读，1：已读。
jsonObject.put("creator", String.valueOf(thirdPartyMap.get("creator")));//创建人，工号
jsonObject.put("createdatetime", String.valueOf(thirdPartyMap.get("createdatetime")));//创建日期时间，格式：yyyy-MM-dd HH:mm:ss
jsonObject.put("receiver", approver.getString("number"));//接收人，工号
jsonObject.put("receivedatetime", String.valueOf(thirdPartyMap.get("receivedatetime")));//接收日期时间，格式：yyyy-MM-dd HH:mm:ss
data.add(jsonObject);
}
pendingsBody.put("data", data);
return pendingsBody;
}
/**
* 发送请求并处理响应
*
* @param customerHeader 请求头
* @param pendingsBody 请求体
* @param thirdPartyMap 第三方数据映射
*/
private static void processRequest(Map<String, String> customerHeader, JSONObject pendingsBody, Map<String, Object> thirdPartyMap) {
String pendingPostjson = null;
JSONObject jsonObject = null;
try {
// 发送POST请求并获取响应
pendingPostjson = HttpClientUtils.postjson(OAUtils.oaUrl, customerHeader, pendingsBody.toJSONString());
jsonObject = parseResponse(pendingPostjson);
// 检查JSON对象是否为空
if (jsonObject != null && !jsonObject.isEmpty()) {
handleResponse(jsonObject, pendingsBody, thirdPartyMap);
}
} catch (Exception e) {
handleException(e, pendingsBody, thirdPartyMap, jsonObject);
}
}
/**
* 解析响应 JSON 字符串
* @param response 响应的 JSON 字符串
* @return 解析后的 JSON 对象
*/
private static JSONObject parseResponse(String response) {
try {
return JSONObject.parseObject(response);
} catch (Exception e) {
logger.error("解析响应 JSON 时出错: {}", e.getMessage());
return null;
}
}
/**
* 处理响应结果
* @param jsonObject 响应的 JSON 对象
* @param pendingsBody 请求体
* @param thirdPartyMap 第三方数据映射
*/
private static void handleResponse(JSONObject jsonObject, JSONObject pendingsBody, Map<String, Object> thirdPartyMap) {
JSONArray data1 = jsonObject.getJSONArray("data");
if (data1 == null || data1.isEmpty()) {
logger.info("推送OA消息失败！");
saveLog("待办:" + String.valueOf(thirdPartyMap.get("billno")), pendingsBody, jsonObject, false);
return;
}
JSONObject jsonobject = data1.getJSONObject(0);
String operResult = jsonobject.getString("operResult");
String logMessage = Objects.equals(operResult, "1") ? "金蝶系统推送OA消息成功！" : "金蝶系统推送OA消息失败！";
// 记录日志
logger.info(logMessage);
saveLog("待办:" + String.valueOf(thirdPartyMap.get("billno")), pendingsBody, jsonObject, true);
}
/**
* 处理异常情况
* @param e 捕获的异常
* @param pendingsBody 请求体
* @param thirdPartyMap 第三方数据映射
* @param jsonObject 响应的 JSON 对象
*/
private static void handleException(Exception e, JSONObject pendingsBody, Map<String, Object> thirdPartyMap, JSONObject jsonObject) {
// 记录异常信息
String errorMessage = String.format("待办接口异常：%s", e.getMessage());
logger.error(errorMessage);
saveLog("待办:" + String.valueOf(thirdPartyMap.get("billno")), pendingsBody, jsonObject, false);
throw new RuntimeException(e);
}
/**
* 保存日志
*
* @param billNo 账单号
* @param pendingsBody 请求体
* @param jsonObject 响应的 JSON 对象
* @param isSuccess 是否成功
*/
private static void saveLog(String billNo, JSONObject pendingsBody, JSONObject jsonObject, boolean isSuccess) {
JhzjUtils.saveLog(billNo, OAUtils.Apimenthod, pendingsBody.toJSONString(),
jsonObject != null ? jsonObject.toJSONString() : "{}", isSuccess, "API");
}
}

5
main/java/shjh/jhzj7/fi/fi/webapi/ApplyAdjustBillControler.java
View File

@ -24,6 +24,7 @@ import kd.bos.orm.query.QCP;
import kd.bos.orm.query.QFilter;
import kd.bos.servicehelper.BusinessDataServiceHelper;
import kd.bos.servicehelper.operation.OperationServiceHelper;
import kd.bos.servicehelper.operation.SaveServiceHelper;
import shjh.jhzj7.fi.fi.utils.JhzjUtils;
import shjh.jhzj7.fi.fi.webapi.model.ApplyAdjustBillModel;
@ -50,6 +51,7 @@ public class ApplyAdjustBillControler {
@ApiPostMapping(value = apimenthod, desc = "应付付款调整单接口")
public CustomApiResult<ApiResult> applybill_adjust(@NotNull @Valid @ApiRequestBody(value = "入参json格式数据") ApplyAdjustBillModel applyAdjustbill) {
JSONObject json_body;
String jsonBodyString = null;
try {
@ -179,6 +181,9 @@ public class ApplyAdjustBillControler {
log.error("审核成功,费控调整单号:" + fkBillNum);
JhzjUtils.saveLog(fkBillNum, Apimenthod, jsonBodyString, null, true, "API");
return CustomApiResult.success(null);
}else {
// 调整金额大于分录未调整过的申请金额,反馈无法处理
return handleErrorAndReturn("同步失败, 调整单号:" + fkBillNum + "的调整金额大于分录未调整过的申请金额", fkBillNum, jsonBodyString);
}
}
else {