待办代码回滚3

This commit is contained in:
wenlukang1 2025-07-06 16:31:37 +08:00
parent 78f7f84776
commit 37d00e3ec5
1 changed files with 11 additions and 4 deletions

View File

@ -40,16 +40,15 @@ public class BacklogServiceHandle extends AbstractServiceHandler {
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();
public void createToDo(MessageContext ctx, ToDoInfo todoInfo) {
logger.info("###创建待办_createToDo");
boolean b = allowMobApprove(ctx, todoInfo);
logger.info("###推送结果为:" + b + "(true为不推送false为推送)");
if (!b) {
Object shkd_type =SystemParamServiceHelper.getPublicParameter("shkd_type");
logger.info("###shkd_type参数为"+shkd_type);
if (!b) {
if (Objects.equals(shkd_type, "0")) {
// eoss 环境
getToDoFormal(ctx, todoInfo);
@ -64,6 +63,7 @@ public class BacklogServiceHandle extends AbstractServiceHandler {
logger.info("###结束待办_createToDo");
try {
//判断是否包含cache值
DistributeSessionlessCache cache = CacheFactory.getCommonCacheFactory().getDistributeSessionlessCache();
boolean contains = cache.contains(ctx.getBusinessKey());
if(contains){
return;
@ -236,6 +236,9 @@ public class BacklogServiceHandle extends AbstractServiceHandler {
form.append("}");
Object shkd_cache = SystemParamServiceHelper.getPublicParameter("shkd_cache");
int z = 0;
DistributeSessionlessCache cache = CacheFactory.getCommonCacheFactory().getDistributeSessionlessCache();
Object shkd_type =SystemParamServiceHelper.getPublicParameter("shkd_type");
logger.info("###shkd_type参数为"+shkd_type);
if (Objects.equals(shkd_type, "0")) {
// eoss 环境 待办
CreateToDoHandler.get_CreateToDoHandler().sendCreateToDo(form.toString(), title, next.getLong("fid").toString(), userName1, next.getString("fbillno"));
@ -286,6 +289,8 @@ public class BacklogServiceHandle extends AbstractServiceHandler {
logger.info("###创建已办_dealToDo");
boolean b = allowMobApprove(ctx, info);
logger.info("###推送结果为:" + b + "(true为不推送false为推送)");
Object shkd_type =SystemParamServiceHelper.getPublicParameter("shkd_type");
logger.info("###shkd_type参数为"+shkd_type);
if (!b) {
logger.info("###shkd_type参数为"+shkd_type);
if (Objects.equals(shkd_type, "0")) {
@ -308,6 +313,8 @@ public class BacklogServiceHandle extends AbstractServiceHandler {
logger.info("###创建撤销_deleteToDo");
boolean b = allowMobApprove(ctx, info);
logger.info("###推送结果为:" + b + "(true为不推送false为推送)");
Object shkd_type =SystemParamServiceHelper.getPublicParameter("shkd_type");
logger.info("###shkd_type参数为"+shkd_type);
if (!b) {
logger.info("###shkd_type参数为"+shkd_type);
if (Objects.equals(shkd_type, "0")) {