From 596e774d35f81bcfa740cf220cd13643bbad7a71 Mon Sep 17 00:00:00 2001 From: wenlukang1 Date: Wed, 2 Jul 2025 19:12:59 +0800 Subject: [PATCH] =?UTF-8?q?=E5=BE=85=E5=8A=9Ebug=E4=BF=AE=E5=A4=8D1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../servicehandler/BacklogServiceHandle.java | 178 +++--------------- 1 file changed, 22 insertions(+), 156 deletions(-) diff --git a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice/servicehandler/BacklogServiceHandle.java b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice/servicehandler/BacklogServiceHandle.java index be0b65c..46ce880 100644 --- a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice/servicehandler/BacklogServiceHandle.java +++ b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice/servicehandler/BacklogServiceHandle.java @@ -71,69 +71,13 @@ public class BacklogServiceHandle extends AbstractServiceHandler { if(contains){ return; } - /*String s = cache.get(ctx.getBusinessKey()); - if (Objects.equals(s, "true")) { - return; - }*/ // 发送首节的已办 sendToDo(ctx); } catch (Exception e) { logger.info("###获得缓存失败，发送首节的已办失败:" + e.getMessage()+" ctx:"+ctx.toString()+" ctx.getBusinessKey："+ctx.getBusinessKey()); } } - /* //几个待办 - List userIds = todoInfo.getUserIds(); - DynamicObjectCollection query = QueryServiceHelper.query("bos_user", "id,name,number" + - ",phone,username", new QFilter[]{new QFilter("id", "in", userIds)}); - DynamicObject dynamicObject = QueryServiceHelper.queryOne("wf_hitaskinst", "billno,startname,id,name", - new QFilter[]{new QFilter("id", "=", todoInfo.getTaskId())}); - logger.info("####待办taskid:"+todoInfo.getTaskId()); - for (DynamicObject query_one : query) { - String userName; - try { - userName = AesUtils.aesEncryptString(query_one.getString("username")); - logger.info("AES加密后user："+userName); - }catch (Exception e){ - logger.info("####AES加密出现异常，请联系运维人员排查！"); - ErrorCode errorCode = new ErrorCode("error_code", "AES加密出现异常，请联系运维人员排查！"); - throw new KDException(errorCode, e); - } - StringBuilder form = new StringBuilder(); - form.append("{"); - form.append("\"title\":"); - form.append("\"").append(todoInfo.getTitle()).append("\","); - form.append("\"bName\":"); - form.append("\"").append("司库").append("\","); - form.append("\"bussinessCode\":"); - form.append("\"").append("EOSS").append("\","); - form.append("\"urGency\":"); - form.append("\"0\","); - form.append("\"currentStepName\":"); - form.append("\"").append(dynamicObject.getString("name")).append("\","); - form.append("\"sendUserName\":"); - form.append("\"").append(dynamicObject.getString("startname")).append("\","); - form.append("\"receiveUsersysName\":"); - form.append("\"").append(query_one.getString("username")).append("\","); - form.append("\"receiveUserId\":"); - form.append("\"").append(query_one.getString("username")).append("\","); - form.append("\"handleUrl\":"); - Map taskInfo = GetUrlUtils.getTaskInfo(todoInfo.getTaskId()); - String url = GetUrlUtils.buildTaskUrl(taskInfo); - form.append("\"").append(url).append("&userName=").append(userName).append("\","); - form.append("\"appHandleUrl\":"); - form.append("\"").append(url).append("&userName=").append(userName).append("\","); - form.append("\"appName\":"); - form.append("\"").append(ctx.getEntityName()).append("\","); - form.append("\"pendingId\":"); - form.append("\"").append(todoInfo.getTaskId()).append("\","); - form.append("\"pendingAttr\":"); - form.append("\"0\""); - form.append("}"); - logger.info("###待办拼接请求体："+form); - CreateToDoHandler.get_CreateToDoHandler().sendCreateToDo(form.toString(),todoInfo.getTitle(), - todoInfo.getTaskId().toString(),query_one.getString("username"),dynamicObject.getString("billno")); - } - logger.info("###结束待办_createToDo");*/ + } /*** @@ -235,15 +179,7 @@ public class BacklogServiceHandle extends AbstractServiceHandler { //接收人手机号 DynamicObject dynamicObject = QueryServiceHelper.queryOne("bos_user", "number,name," + "phone,username", new QFilter[]{new QFilter("id", "=", next.getString("freceiveuserid"))}); - String userName1 = dynamicObject.getString("username"); - String userName; - try { - userName = AesUtils.aesEncryptString(dynamicObject.getString("username")); - logger.info("AES加密后user：" + userName); - } catch (Exception e) { - ErrorCode errorCode = new ErrorCode("error_code", "AES加密出现异常，请联系运维人员排查！"); - throw new KDException(errorCode, e); - } + String userName = dynamicObject.getString("username"); //判断是否移动端 boolean allowMobApprove = allowMobApprove(next.get("fid")); if (allowMobApprove) { @@ -274,28 +210,28 @@ public class BacklogServiceHandle extends AbstractServiceHandler { form.append("\"sendUserName\":"); form.append("\"").append(next.getString("fstartname")).append("\","); form.append("\"receiveUsersysName\":"); - form.append("\"").append(userName1).append("\","); + form.append("\"").append(userName).append("\","); form.append("\"receiveUserId\":"); - form.append("\"").append(userName1).append("\","); + form.append("\"").append(userName).append("\","); form.append("\"handleUrl\":"); - form.append("\"").append(pcUrl).append("&userName=").append(userName).append("\","); + form.append("\"").append(pcUrl).append("\","); form.append("\"appHandleUrl\":"); - form.append("\"").append(pcUrl).append("&userName=").append(userName).append("\","); + form.append("\"").append(pcUrl).append("\","); // appUrl移动端查看模式 form.append("\"appViewUrl\":"); - form.append("\"").append(pcUrl).append("&userName=").append(userName).append("&ado=view").append("\","); + form.append("\"").append(pcUrl).append("&ado=view").append("\","); form.append("\"appName\":"); form.append("\"").append(next.getString("fentityname")).append("\","); //pc端查看模式 form.append("\"viewUrl\":"); - form.append("\"").append(pcUrl).append("&userName=").append(userName).append("&ado=view").append("\","); + form.append("\"").append(pcUrl).append("&ado=view").append("\","); form.append("\"pendingId\":"); form.append("\"").append(next.getLong("fid")).append("\","); form.append("\"pendingAttr\":"); form.append("\"0\""); form.append("}"); Object shkd_cache = SystemParamServiceHelper.getPublicParameter("shkd_cache"); - Integer z = 0; + int z = 0; if (Objects.equals(shkd_type, "0")) { //旧 eoss 环境 待办 CreateToDoHandler.get_CreateToDoHandler().sendCreateToDo(form.toString(), title, next.getLong("fid").toString(), userName, next.getString("fbillno")); @@ -304,7 +240,7 @@ public class BacklogServiceHandle extends AbstractServiceHandler { if (ObjectUtils.isEmpty(shkd_cache)) { z = 604800; } else { - z = Integer.valueOf(shkd_cache.toString()); + z = Integer.parseInt(shkd_cache.toString()); } cache.put(ctx.getBusinessKey(), "true", z); } else if (Objects.equals(shkd_type, "1")) { @@ -315,7 +251,7 @@ public class BacklogServiceHandle extends AbstractServiceHandler { if (ObjectUtils.isEmpty(shkd_cache)) { z = 604800; } else { - z = Integer.valueOf(shkd_cache.toString()); + z = Integer.parseInt(shkd_cache.toString()); } cache.put(ctx.getBusinessKey(), "true", z); } else if (Objects.equals(shkd_type, "2")) { @@ -328,7 +264,7 @@ public class BacklogServiceHandle extends AbstractServiceHandler { if (ObjectUtils.isEmpty(shkd_cache)) { z = 604800; } else { - z = Integer.valueOf(shkd_cache.toString()); + z = Integer.parseInt(shkd_cache.toString()); } cache.put(ctx.getBusinessKey(), "true", z); } @@ -381,21 +317,6 @@ public class BacklogServiceHandle extends AbstractServiceHandler { getDeleteNew(ctx, info); getDeleteFormal(ctx, info); } - /* List userIds = info.getUserIds(); - DynamicObjectCollection query = QueryServiceHelper.query("bos_user", "id,name,phone,username", new QFilter[]{new QFilter("id", "in", userIds)}); - DynamicObject dynamicObject = QueryServiceHelper.queryOne("wf_hitaskinst", "billno", - new QFilter[]{new QFilter("id", "=", info.getTaskId())}); - //业务id - Long taskId = ctx.getTaskId(); - logger.info("####撤销taskid:"+info.getTaskId()); - for (DynamicObject queryOne : query) { - if(dynamicObject != null){ - deleteToDoHandler.get_deleteToDoHandler().sendDeleteToDo(taskId,queryOne.getString("username"),dynamicObject.getString("billno")); - }else{ - deleteToDoHandler.get_deleteToDoHandler().sendDeleteToDo(taskId,queryOne.getString("username"),""); - - } - }*/ logger.info("###结束撤销_deleteToDo"); } } @@ -412,15 +333,6 @@ public class BacklogServiceHandle extends AbstractServiceHandler { new QFilter[]{new QFilter("id", "=", todoInfo.getTaskId())}); logger.info("####待办taskid:" + todoInfo.getTaskId()); for (DynamicObject query_one : query) { - String userName; - try { - userName = AesUtils.aesEncryptString(query_one.getString("username")); - logger.info("AES加密后user：" + userName); - } catch (Exception e) { - logger.info("####AES加密出现异常，请联系运维人员排查！"); - ErrorCode errorCode = new ErrorCode("error_code", "AES加密出现异常，请联系运维人员排查！"); - throw new KDException(errorCode, e); - } StringBuilder form = new StringBuilder(); // BacklogMessage backlogMessage = new BacklogMessage(); form.append("{"); @@ -443,58 +355,22 @@ public class BacklogServiceHandle extends AbstractServiceHandler { form.append("\"handleUrl\":"); Map taskInfo = GetUrlUtils.getTaskInfo(todoInfo.getTaskId()); String url = GetUrlUtils.buildTaskUrl(taskInfo); - form.append("\"").append(url).append("&userName=").append(userName).append("\","); + form.append("\"").append(url).append("\","); form.append("\"appHandleUrl\":"); - form.append("\"").append(url).append("&userName=").append(userName).append("\","); + form.append("\"").append(url).append("\","); // appUrl移动端查看模式 form.append("\"appViewUrl\":"); - form.append("\"").append(url).append("&userName=").append(userName).append("&ado=view").append("\","); + form.append("\"").append(url).append("&ado=view").append("\","); form.append("\"appName\":"); form.append("\"").append(ctx.getEntityName()).append("\","); //pc端查看模式 form.append("\"viewUrl\":"); - form.append("\"").append(url).append("&userName=").append(userName).append("&ado=view").append("\","); + form.append("\"").append(url).append("&ado=view").append("\","); form.append("\"pendingId\":"); form.append("\"").append(todoInfo.getTaskId()).append("\","); form.append("\"pendingAttr\":"); form.append("\"0\""); form.append("}"); - /* //业务类型名称 - backlogMessage.setbName("业务类型名称"); - // 紧急程度 - backlogMessage.setUrGency("0"); - //当前节点名称 - backlogMessage.setCurrentStepName(dynamicObject.getString("name")); - //上步骤名称 - backlogMessage.setPreStepName(""); - // startname发起人名称 - backlogMessage.setSendUserName(dynamicObject.getString("startname")); - //接收人用户名 - backlogMessage.setReceiveUserId(query_one.getString("username")); - //标题 - backlogMessage.setTitle(todoInfo.getTitle()); - //PC地址 - backlogMessage.setHandleUrl(todoInfo.getUrl()); - //PC地址查看 - backlogMessage.setViewUrl(todoInfo.getUrl()+"&ado=view"); - //app地址 - backlogMessage.setAppHandleUrl(todoInfo.getUrl()); - //App应用名称 - backlogMessage.setAppName(""); - //app地址查看 - backlogMessage.setAppViewUrl(todoInfo.getUrl()+"&ado=view"); - //业务id - backlogMessage.setPendingId(String.valueOf(todoInfo.getTaskId())); - // 业务编码 - backlogMessage.setBussinessCode(dynamicObject.getString("billno")); - //属性 - backlogMessage.setPendingAttr("0"); - //notifyMsg 通知消息 - backlogMessage.setNotifyMsg(""); - //notifyMethod 通知方式 - backlogMessage.setNotifyMethod(""); - //业务自定义数据 - backlogMessage.setJsonData("");*/ logger.info("###待办拼接请求体：" + form); CreateToDoHandler.get_CreateToDoHandler().sendCreateToDo(form.toString(), todoInfo.getTitle(), todoInfo.getTaskId().toString(), query_one.getString("username"), dynamicObject.getString("billno")); @@ -511,19 +387,9 @@ public class BacklogServiceHandle extends AbstractServiceHandler { ",phone,username", new QFilter[]{new QFilter("id", "in", userIds)}); DynamicObject dynamicObject = QueryServiceHelper.queryOne("wf_hitaskinst", "billno,subject,startname,id,name", new QFilter[]{new QFilter("id", "=", todoInfo.getTaskId())}); - logger.info("####待办taskid:" + todoInfo.getTaskId()); + logger.info("####新EOSS待办taskid:" + todoInfo.getTaskId()); for (DynamicObject query_one : query) { - String userName; - try { - userName = AesUtils.aesEncryptString(query_one.getString("username")); - logger.info("AES加密后user：" + userName); - } catch (Exception e) { - logger.info("####AES加密出现异常，请联系运维人员排查！"); - ErrorCode errorCode = new ErrorCode("error_code", "AES加密出现异常，请联系运维人员排查！"); - throw new KDException(errorCode, e); - } StringBuilder form = new StringBuilder(); - // BacklogMessage backlogMessage = new BacklogMessage(); form.append("{"); form.append("\"title\":"); form.append("\"").append(dynamicObject.getString("subject")).append("\","); @@ -544,24 +410,24 @@ public class BacklogServiceHandle extends AbstractServiceHandler { form.append("\"handleUrl\":"); Map taskInfo = GetUrlUtils.getTaskInfo(todoInfo.getTaskId()); String url = GetUrlUtils.buildTaskUrl(taskInfo); - form.append("\"").append(url).append("&isNew=true&userName=").append(userName).append("\","); + form.append("\"").append(url).append("&isNew=true").append("\","); form.append("\"appHandleUrl\":"); - form.append("\"").append(url).append("&isNew=true&userName=").append(userName).append("\","); + form.append("\"").append(url).append("&isNew=true").append("\","); // appUrl移动端查看模式 form.append("\"appViewUrl\":"); - form.append("\"").append(url).append("&isNew=true&userName=").append(userName).append("&ado=view").append("\","); + form.append("\"").append(url).append("&isNew=true").append("&ado=view").append("\","); form.append("\"appName\":"); form.append("\"").append(ctx.getEntityName()).append("\","); //pc端查看模式 form.append("\"viewUrl\":"); - form.append("\"").append(url).append("&isNew=true&userName=").append(userName).append("&ado=view").append("\","); + form.append("\"").append(url).append("&isNew=true").append("&ado=view").append("\","); form.append("\"pendingId\":"); form.append("\"").append(todoInfo.getTaskId()).append("\","); form.append("\"pendingAttr\":"); form.append("\"0\""); form.append("}"); - logger.info("###待办拼接请求体：" + form); + logger.info("###推送新EOSS待办拼接请求体：" + form); CreateToDoHandler.get_CreateToDoHandler().sendCreateToDoNew(form.toString(), todoInfo.getTitle(), todoInfo.getTaskId().toString(), query_one.getString("username"), dynamicObject.getString("billno")); }