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

首节已办发送

This commit is contained in:
fang 2025-07-02 17:49:27 +08:00
parent 1868403f3b
commit 9febd25018
1 changed files with 30 additions and 49 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -72,7 +72,7 @@ public class BacklogServiceHandle extends AbstractServiceHandler {
// 发送首节的已办 // 发送首节的已办
sendToDo(ctx); sendToDo(ctx);
} catch (Exception e) { } catch (Exception e) {
logger.info("获得缓存失败，发送首节的已办失败:" + e.getMessage()); logger.info("###获得缓存失败，发送首节的已办失败:" + e.getMessage()+"ctx.getBusinessKey："+ctx.getBusinessKey());
} }
} }
/* //几个待办 /* //几个待办
@ -135,6 +135,7 @@ public class BacklogServiceHandle extends AbstractServiceHandler {
* @param ctx 信息 * @param ctx 信息
*/ */
private void sendToDo(MessageContext ctx) { private void sendToDo(MessageContext ctx) {
logger.info("###进入首节已办推送方法");
String accountId = System.getProperty("backlog-accountid"); String accountId = System.getProperty("backlog-accountid");
Object shkd_type = SystemParamServiceHelper.getPublicParameter("shkd_type"); Object shkd_type = SystemParamServiceHelper.getPublicParameter("shkd_type");
StringBuilder cwbSql1 = new StringBuilder(); StringBuilder cwbSql1 = new StringBuilder();
@ -217,9 +218,11 @@ public class BacklogServiceHandle extends AbstractServiceHandler {
cwbSql1.append(" and b.FDELETEREASON ='first_usertask_skip"); cwbSql1.append(" and b.FDELETEREASON ='first_usertask_skip");
cwbSql1.append(" and b.FENDTIME is not null and d.FENDTIME is not null"); cwbSql1.append(" and b.FENDTIME is not null and d.FENDTIME is not null");
cwbSql1.append(" ORDER BY b.FMODIFYDATE,b.FID"); cwbSql1.append(" ORDER BY b.FMODIFYDATE,b.FID");
logger.info("###开始第一个节点已办数据拼接结束");
logger.info("###查询首节节点数据-开始");
DataSet cwbAmount1 = DB.queryDataSet(this.getClass().getName(), DBRoute.of("sys"), cwbSql1.toString(), new Object[]{ctx.getBusinessKey()}); DataSet cwbAmount1 = DB.queryDataSet(this.getClass().getName(), DBRoute.of("sys"), cwbSql1.toString(), new Object[]{ctx.getBusinessKey()});
Iterator<Row> iterator = cwbAmount1.iterator(); Iterator<Row> iterator = cwbAmount1.iterator();
logger.info("开始第一个节点已办数据拼接"); logger.info("###查询首节节点数据-结束");
try { try {
while (iterator.hasNext()) { while (iterator.hasNext()) {
Row next = iterator.next(); Row next = iterator.next();
@ -288,62 +291,40 @@ public class BacklogServiceHandle extends AbstractServiceHandler {
Object shkd_cache = SystemParamServiceHelper.getPublicParameter("shkd_cache"); Object shkd_cache = SystemParamServiceHelper.getPublicParameter("shkd_cache");
Integer z = 0; Integer z = 0;
if (Objects.equals(shkd_type, "0")) { if (Objects.equals(shkd_type, "0")) {
//旧 eoss 环境 //旧 eoss 环境 待办
boolean b = 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(), userName, next.getString("fbillno"));
if(ObjectUtils.isEmpty(shkd_cache)){ //旧 eoss 环境 已办
DealToDoHandler.get_DealToDoHandler().sendDealToDo(next.getLong("fid"), userName, next.getString("fbillno"));
if (ObjectUtils.isEmpty(shkd_cache)) {
z = 604800; z = 604800;
}else{ } else {
z = Integer.valueOf(shkd_cache.toString()); z = Integer.valueOf(shkd_cache.toString());
} }
cache.put(ctx.getBusinessKey(),String.valueOf(b),z); cache.put(ctx.getBusinessKey(), "true", z);
} else if (Objects.equals(shkd_type, "1")) { } else if (Objects.equals(shkd_type, "1")) {
//新 eoss 环境 //新 eoss 环境 待办
boolean b = CreateToDoHandler.get_CreateToDoHandler().sendCreateToDoNew(form.toString(), title, next.getLong("fid").toString(), userName, next.getString("fbillno"));
if(ObjectUtils.isEmpty(shkd_cache)){
z = 604800;
}else{
z = Integer.valueOf(shkd_cache.toString());
}
cache.put(ctx.getBusinessKey(),String.valueOf(b),z);
} else if (Objects.equals(shkd_type, "2")) {
//二套环境
boolean b = CreateToDoHandler.get_CreateToDoHandler().sendCreateToDo(form.toString(), title, next.getLong("fid").toString(), userName, next.getString("fbillno"));
CreateToDoHandler.get_CreateToDoHandler().sendCreateToDoNew(form.toString(), title, next.getLong("fid").toString(), userName, next.getString("fbillno")); CreateToDoHandler.get_CreateToDoHandler().sendCreateToDoNew(form.toString(), title, next.getLong("fid").toString(), userName, next.getString("fbillno"));
if(ObjectUtils.isEmpty(shkd_cache)){ //新 eoss 环境 已办
z = 604800;
}else{
z = Integer.valueOf(shkd_cache.toString());
}
cache.put(ctx.getBusinessKey(),String.valueOf(b),z);
}
if (Objects.equals(shkd_type, "0")) {
//旧 eoss 环境
boolean b = DealToDoHandler.get_DealToDoHandler().sendDealToDo(next.getLong("fid"), userName, next.getString("fbillno"));
if(ObjectUtils.isEmpty(shkd_cache)){
z = 604800;
}else{
z = Integer.valueOf(shkd_cache.toString());
}
cache.put(ctx.getBusinessKey(),String.valueOf(b),z);
} else if (Objects.equals(shkd_type, "1")) {
//新 eoss 环境
boolean b = DealToDoHandler.get_DealToDoHandler().sendDealToDoNew(next.getLong("fid"), userName, next.getString("fbillno"));
if(ObjectUtils.isEmpty(shkd_cache)){
z = 604800;
}else{
z = Integer.valueOf(shkd_cache.toString());
}
cache.put(ctx.getBusinessKey(),String.valueOf(b),z);
} else if (Objects.equals(shkd_type, "2")) {
//二套环境
boolean b = DealToDoHandler.get_DealToDoHandler().sendDealToDo(next.getLong("fid"), userName, next.getString("fbillno"));
DealToDoHandler.get_DealToDoHandler().sendDealToDoNew(next.getLong("fid"), userName, next.getString("fbillno")); DealToDoHandler.get_DealToDoHandler().sendDealToDoNew(next.getLong("fid"), userName, next.getString("fbillno"));
if(ObjectUtils.isEmpty(shkd_cache)){ if (ObjectUtils.isEmpty(shkd_cache)) {
z = 604800; z = 604800;
}else{ } else {
z = Integer.valueOf(shkd_cache.toString()); z = Integer.valueOf(shkd_cache.toString());
} }
cache.put(ctx.getBusinessKey(),String.valueOf(b),z); cache.put(ctx.getBusinessKey(), "true", z);
} else if (Objects.equals(shkd_type, "2")) {
//二套环境 待办
CreateToDoHandler.get_CreateToDoHandler().sendCreateToDo(form.toString(), title, next.getLong("fid").toString(), userName, next.getString("fbillno"));
CreateToDoHandler.get_CreateToDoHandler().sendCreateToDoNew(form.toString(), title, next.getLong("fid").toString(), userName, next.getString("fbillno"));
//二套环境 已办
DealToDoHandler.get_DealToDoHandler().sendDealToDo(next.getLong("fid"), userName, next.getString("fbillno"));
DealToDoHandler.get_DealToDoHandler().sendDealToDoNew(next.getLong("fid"), userName, next.getString("fbillno"));
if (ObjectUtils.isEmpty(shkd_cache)) {
z = 604800;
} else {
z = Integer.valueOf(shkd_cache.toString());
}
cache.put(ctx.getBusinessKey(), "true", z);
} }
} }
} catch (Exception e) { } catch (Exception e) {