wenlukang1
/
CTSK_DEV
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

待办代码回滚1

This commit is contained in:
wenlukang1 2025-07-04 15:37:01 +08:00
parent 77a779b0f9
commit 1d89074c3a
1 changed files with 53 additions and 35 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

88
sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice/servicehandler/BacklogServiceHandle.java
View File

@ -33,17 +33,15 @@ import java.util.Objects;
import static shkd.sys.sys.midservice.utils.MobApproveListServiceHelper.allowMobApprove; import static shkd.sys.sys.midservice.utils.MobApproveListServiceHelper.allowMobApprove;
/** /**
* @Description:
* @Author: FangShiXiao * @Author: FangShiXiao
* @Date: 2024/11/5 14:07 * @Date: 2024/11/5 14:07
* @Version: 1.0
* @Ability
*/ */
public class BacklogServiceHandle extends AbstractServiceHandler { public class BacklogServiceHandle extends AbstractServiceHandler {
public static final String TYPE = "todo";
private static final Log logger = LogFactory.getLog(BacklogServiceHandle.class); private static final Log logger = LogFactory.getLog(BacklogServiceHandle.class);
private static final Object shkd_type =SystemParamServiceHelper.getPublicParameter("shkd_type");
private static final DistributeSessionlessCache cache = CacheFactory.getCommonCacheFactory().getDistributeSessionlessCache(); private static final DistributeSessionlessCache cache = CacheFactory.getCommonCacheFactory().getDistributeSessionlessCache();
public void createToDo(MessageContext ctx, ToDoInfo todoInfo) { public void createToDo(MessageContext ctx, ToDoInfo todoInfo) {
@ -51,7 +49,6 @@ public class BacklogServiceHandle extends AbstractServiceHandler {
boolean b = allowMobApprove(ctx, todoInfo); boolean b = allowMobApprove(ctx, todoInfo);
logger.info("###推送结果为:" + b + "(true为不推送，false为推送)"); logger.info("###推送结果为:" + b + "(true为不推送，false为推送)");
if (!b) { if (!b) {
Object shkd_type = SystemParamServiceHelper.getPublicParameter("shkd_type");
logger.info("###shkd_type参数为"+shkd_type); logger.info("###shkd_type参数为"+shkd_type);
if (Objects.equals(shkd_type, "0")) { if (Objects.equals(shkd_type, "0")) {
//旧 eoss 环境 //旧 eoss 环境
@ -74,7 +71,7 @@ public class BacklogServiceHandle extends AbstractServiceHandler {
// 发送首节的已办 // 发送首节的已办
sendToDo(ctx); sendToDo(ctx);
} catch (Exception e) { } catch (Exception e) {
logger.info("###获得缓存失败，发送首节的已办失败:" + e.getMessage()+" ctx:"+ctx.toString()+" ctx.getBusinessKey："+ctx.getBusinessKey()); logger.info("###获得缓存失败，发送首节的已办失败:" + e.getMessage()+" ctx:"+ctx+" ctx.getBusinessKey："+ctx.getBusinessKey());
} }
} }
@ -87,7 +84,6 @@ public class BacklogServiceHandle extends AbstractServiceHandler {
private void sendToDo(MessageContext ctx) { private void sendToDo(MessageContext ctx) {
logger.info("###进入首节已办推送方法"); logger.info("###进入首节已办推送方法");
String accountId = System.getProperty("backlog-accountid"); String accountId = System.getProperty("backlog-accountid");
Object shkd_type = SystemParamServiceHelper.getPublicParameter("shkd_type");
StringBuilder cwbSql1 = new StringBuilder(); StringBuilder cwbSql1 = new StringBuilder();
cwbSql1.append("SELECT "); cwbSql1.append("SELECT ");
cwbSql1.append("b.FID,"); cwbSql1.append("b.FID,");
@ -179,7 +175,15 @@ public class BacklogServiceHandle extends AbstractServiceHandler {
//接收人手机号 //接收人手机号
DynamicObject dynamicObject = QueryServiceHelper.queryOne("bos_user", "number,name," + DynamicObject dynamicObject = QueryServiceHelper.queryOne("bos_user", "number,name," +
"phone,username", new QFilter[]{new QFilter("id", "=", next.getString("freceiveuserid"))}); "phone,username", new QFilter[]{new QFilter("id", "=", next.getString("freceiveuserid"))});
String userName = dynamicObject.getString("username"); 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);
}
//判断是否移动端 //判断是否移动端
boolean allowMobApprove = allowMobApprove(next.get("fid")); boolean allowMobApprove = allowMobApprove(next.get("fid"));
if (allowMobApprove) { if (allowMobApprove) {
@ -210,21 +214,21 @@ public class BacklogServiceHandle extends AbstractServiceHandler {
form.append("\"sendUserName\":"); form.append("\"sendUserName\":");
form.append("\"").append(next.getString("fstartname")).append("\","); form.append("\"").append(next.getString("fstartname")).append("\",");
form.append("\"receiveUsersysName\":"); form.append("\"receiveUsersysName\":");
form.append("\"").append(userName).append("\","); form.append("\"").append(userName1).append("\",");
form.append("\"receiveUserId\":"); form.append("\"receiveUserId\":");
form.append("\"").append(userName).append("\","); form.append("\"").append(userName1).append("\",");
form.append("\"handleUrl\":"); form.append("\"handleUrl\":");
form.append("\"").append(pcUrl).append("\","); form.append("\"").append(pcUrl).append("&userName=").append(userName).append("\",");
form.append("\"appHandleUrl\":"); form.append("\"appHandleUrl\":");
form.append("\"").append(pcUrl).append("\","); form.append("\"").append(pcUrl).append("&userName=").append(userName).append("\",");
// appUrl移动端查看模式 // appUrl移动端查看模式
form.append("\"appViewUrl\":"); form.append("\"appViewUrl\":");
form.append("\"").append(pcUrl).append("&ado=view").append("\","); form.append("\"").append(pcUrl).append("&ado=view&userName=").append(userName).append("\",");
form.append("\"appName\":"); form.append("\"appName\":");
form.append("\"").append(next.getString("fentityname")).append("\","); form.append("\"").append(next.getString("fentityname")).append("\",");
//pc端查看模式 //pc端查看模式
form.append("\"viewUrl\":"); form.append("\"viewUrl\":");
form.append("\"").append(pcUrl).append("&ado=view").append("\","); form.append("\"").append(pcUrl).append("&ado=view&userName=").append(userName).append("\",");
form.append("\"pendingId\":"); form.append("\"pendingId\":");
form.append("\"").append(next.getLong("fid")).append("\","); form.append("\"").append(next.getLong("fid")).append("\",");
form.append("\"pendingAttr\":"); form.append("\"pendingAttr\":");
@ -234,9 +238,9 @@ public class BacklogServiceHandle extends AbstractServiceHandler {
int z = 0; int z = 0;
if (Objects.equals(shkd_type, "0")) { if (Objects.equals(shkd_type, "0")) {
//旧 eoss 环境 待办 //旧 eoss 环境 待办
CreateToDoHandler.get_CreateToDoHandler().sendCreateToDo(form.toString(), title, next.getLong("fid").toString(), userName, next.getString("fbillno")); CreateToDoHandler.get_CreateToDoHandler().sendCreateToDo(form.toString(), title, next.getLong("fid").toString(), userName1, next.getString("fbillno"));
//旧 eoss 环境 已办 //旧 eoss 环境 已办
DealToDoHandler.get_DealToDoHandler().sendDealToDo(next.getLong("fid"), userName, next.getString("fbillno")); DealToDoHandler.get_DealToDoHandler().sendDealToDo(next.getLong("fid"), userName1, next.getString("fbillno"));
if (ObjectUtils.isEmpty(shkd_cache)) { if (ObjectUtils.isEmpty(shkd_cache)) {
z = 604800; z = 604800;
} else { } else {
@ -246,9 +250,9 @@ public class BacklogServiceHandle extends AbstractServiceHandler {
} else if (Objects.equals(shkd_type, "1")) { } else if (Objects.equals(shkd_type, "1")) {
String replace = form.toString().replace("&ado=view", "&ado=view&isNew=true"); String replace = form.toString().replace("&ado=view", "&ado=view&isNew=true");
//新 eoss 环境 待办 //新 eoss 环境 待办
CreateToDoHandler.get_CreateToDoHandler().sendCreateToDoNew(replace, title, next.getLong("fid").toString(), userName, next.getString("fbillno")); CreateToDoHandler.get_CreateToDoHandler().sendCreateToDoNew(replace, title, next.getLong("fid").toString(), userName1, next.getString("fbillno"));
//新 eoss 环境 已办 //新 eoss 环境 已办
DealToDoHandler.get_DealToDoHandler().sendDealToDoNew(next.getLong("fid"), userName, next.getString("fbillno")); DealToDoHandler.get_DealToDoHandler().sendDealToDoNew(next.getLong("fid"), userName1, next.getString("fbillno"));
if (ObjectUtils.isEmpty(shkd_cache)) { if (ObjectUtils.isEmpty(shkd_cache)) {
z = 604800; z = 604800;
} else { } else {
@ -258,11 +262,11 @@ public class BacklogServiceHandle extends AbstractServiceHandler {
} else if (Objects.equals(shkd_type, "2")) { } else if (Objects.equals(shkd_type, "2")) {
String replace = form.toString().replace("&ado=view", "&ado=view&isNew=true"); String replace = form.toString().replace("&ado=view", "&ado=view&isNew=true");
//二套环境 待办 //二套环境 待办
CreateToDoHandler.get_CreateToDoHandler().sendCreateToDo(form.toString(), title, next.getLong("fid").toString(), userName, next.getString("fbillno")); CreateToDoHandler.get_CreateToDoHandler().sendCreateToDo(form.toString(), title, next.getLong("fid").toString(), userName1, next.getString("fbillno"));
CreateToDoHandler.get_CreateToDoHandler().sendCreateToDoNew(replace, title, next.getLong("fid").toString(), userName, next.getString("fbillno")); CreateToDoHandler.get_CreateToDoHandler().sendCreateToDoNew(replace, title, next.getLong("fid").toString(), userName1, next.getString("fbillno"));
//二套环境 已办 //二套环境 已办
DealToDoHandler.get_DealToDoHandler().sendDealToDo(next.getLong("fid"), userName, next.getString("fbillno")); DealToDoHandler.get_DealToDoHandler().sendDealToDo(next.getLong("fid"), userName1, next.getString("fbillno"));
DealToDoHandler.get_DealToDoHandler().sendDealToDoNew(next.getLong("fid"), userName, next.getString("fbillno")); DealToDoHandler.get_DealToDoHandler().sendDealToDoNew(next.getLong("fid"), userName1, next.getString("fbillno"));
if (ObjectUtils.isEmpty(shkd_cache)) { if (ObjectUtils.isEmpty(shkd_cache)) {
z = 604800; z = 604800;
} else { } else {
@ -283,7 +287,6 @@ public class BacklogServiceHandle extends AbstractServiceHandler {
boolean b = allowMobApprove(ctx, info); boolean b = allowMobApprove(ctx, info);
logger.info("###推送结果为:" + b + "(true为不推送，false为推送)"); logger.info("###推送结果为:" + b + "(true为不推送，false为推送)");
if (!b) { if (!b) {
Object shkd_type = SystemParamServiceHelper.getPublicParameter("shkd_type");
logger.info("###shkd_type参数为"+shkd_type); logger.info("###shkd_type参数为"+shkd_type);
if (Objects.equals(shkd_type, "0")) { if (Objects.equals(shkd_type, "0")) {
//旧 eoss 环境 //旧 eoss 环境
@ -306,7 +309,6 @@ public class BacklogServiceHandle extends AbstractServiceHandler {
boolean b = allowMobApprove(ctx, info); boolean b = allowMobApprove(ctx, info);
logger.info("###推送结果为:" + b + "(true为不推送，false为推送)"); logger.info("###推送结果为:" + b + "(true为不推送，false为推送)");
if (!b) { if (!b) {
Object shkd_type = SystemParamServiceHelper.getPublicParameter("shkd_type");
logger.info("###shkd_type参数为"+shkd_type); logger.info("###shkd_type参数为"+shkd_type);
if (Objects.equals(shkd_type, "0")) { if (Objects.equals(shkd_type, "0")) {
//旧 eoss 环境 //旧 eoss 环境
@ -335,8 +337,16 @@ public class BacklogServiceHandle extends AbstractServiceHandler {
new QFilter[]{new QFilter("id", "=", todoInfo.getTaskId())}); new QFilter[]{new QFilter("id", "=", todoInfo.getTaskId())});
logger.info("####待办taskid:" + todoInfo.getTaskId()); logger.info("####待办taskid:" + todoInfo.getTaskId());
for (DynamicObject query_one : query) { 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(); StringBuilder form = new StringBuilder();
// BacklogMessage backlogMessage = new BacklogMessage();
form.append("{"); form.append("{");
form.append("\"title\":"); form.append("\"title\":");
form.append("\"").append(dynamicObject.getString("subject")).append("\","); form.append("\"").append(dynamicObject.getString("subject")).append("\",");
@ -357,17 +367,17 @@ public class BacklogServiceHandle extends AbstractServiceHandler {
form.append("\"handleUrl\":"); form.append("\"handleUrl\":");
Map<String, Object> taskInfo = GetUrlUtils.getTaskInfo(todoInfo.getTaskId()); Map<String, Object> taskInfo = GetUrlUtils.getTaskInfo(todoInfo.getTaskId());
String url = GetUrlUtils.buildTaskUrl(taskInfo); String url = GetUrlUtils.buildTaskUrl(taskInfo);
form.append("\"").append(url).append("\","); form.append("\"").append(url).append("&userName=").append(userName).append("\",");
form.append("\"appHandleUrl\":"); form.append("\"appHandleUrl\":");
form.append("\"").append(url).append("\","); form.append("\"").append(url).append("&userName=").append(userName).append("\",");
// appUrl移动端查看模式 // appUrl移动端查看模式
form.append("\"appViewUrl\":"); form.append("\"appViewUrl\":");
form.append("\"").append(url).append("&ado=view").append("\","); form.append("\"").append(url).append("&userName=").append(userName).append("&ado=view").append("\",");
form.append("\"appName\":"); form.append("\"appName\":");
form.append("\"").append(ctx.getEntityName()).append("\","); form.append("\"").append(ctx.getEntityName()).append("\",");
//pc端查看模式 //pc端查看模式
form.append("\"viewUrl\":"); form.append("\"viewUrl\":");
form.append("\"").append(url).append("&ado=view").append("\","); form.append("\"").append(url).append("&userName=").append(userName).append("&ado=view").append("\",");
form.append("\"pendingId\":"); form.append("\"pendingId\":");
form.append("\"").append(todoInfo.getTaskId()).append("\","); form.append("\"").append(todoInfo.getTaskId()).append("\",");
form.append("\"pendingAttr\":"); form.append("\"pendingAttr\":");
@ -391,6 +401,15 @@ public class BacklogServiceHandle extends AbstractServiceHandler {
new QFilter[]{new QFilter("id", "=", todoInfo.getTaskId())}); new QFilter[]{new QFilter("id", "=", todoInfo.getTaskId())});
logger.info("####新EOSS待办taskid:" + todoInfo.getTaskId()); logger.info("####新EOSS待办taskid:" + todoInfo.getTaskId());
for (DynamicObject query_one : query) { 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(); StringBuilder form = new StringBuilder();
form.append("{"); form.append("{");
form.append("\"title\":"); form.append("\"title\":");
@ -412,18 +431,17 @@ public class BacklogServiceHandle extends AbstractServiceHandler {
form.append("\"handleUrl\":"); form.append("\"handleUrl\":");
Map<String, Object> taskInfo = GetUrlUtils.getTaskInfo(todoInfo.getTaskId()); Map<String, Object> taskInfo = GetUrlUtils.getTaskInfo(todoInfo.getTaskId());
String url = GetUrlUtils.buildTaskUrl(taskInfo); String url = GetUrlUtils.buildTaskUrl(taskInfo);
form.append("\"").append(url).append("&isNew=true").append("\","); form.append("\"").append(url).append("&userName=").append(userName).append("\",");
form.append("\"appHandleUrl\":"); form.append("\"appHandleUrl\":");
form.append("\"").append(url).append("&isNew=true").append("\","); form.append("\"").append(url).append("&userName=").append(userName).append("\",");
// appUrl移动端查看模式 // appUrl移动端查看模式
form.append("\"appViewUrl\":"); form.append("\"appViewUrl\":");
form.append("\"").append(url).append("&isNew=true").append("&ado=view").append("\","); form.append("\"").append(url).append("&userName=").append(userName).append("&ado=view").append("\",");
form.append("\"appName\":"); form.append("\"appName\":");
form.append("\"").append(ctx.getEntityName()).append("\","); form.append("\"").append(ctx.getEntityName()).append("\",");
//pc端查看模式 //pc端查看模式
form.append("\"viewUrl\":"); form.append("\"viewUrl\":");
form.append("\"").append(url).append("&isNew=true").append("&ado=view").append("\","); form.append("\"").append(url).append("&userName=").append(userName).append("&ado=view").append("\",");
form.append("\"pendingId\":"); form.append("\"pendingId\":");
form.append("\"").append(todoInfo.getTaskId()).append("\","); form.append("\"").append(todoInfo.getTaskId()).append("\",");
form.append("\"pendingAttr\":"); form.append("\"pendingAttr\":");