|
@@ -20,8 +20,6 @@ import com.fjhx.flow.enums.HandleObjectTypeEnum;
|
|
import com.fjhx.flow.enums.HandleTypeEnum;
|
|
import com.fjhx.flow.enums.HandleTypeEnum;
|
|
import com.fjhx.flow.enums.NodeTypeEnum;
|
|
import com.fjhx.flow.enums.NodeTypeEnum;
|
|
import com.fjhx.flow.service.flow.*;
|
|
import com.fjhx.flow.service.flow.*;
|
|
-import com.fjhx.socket.core.PushTypeEnum;
|
|
|
|
-import com.fjhx.socket.core.WebSocketPush;
|
|
|
|
import com.googlecode.aviator.AviatorEvaluator;
|
|
import com.googlecode.aviator.AviatorEvaluator;
|
|
import com.googlecode.aviator.Expression;
|
|
import com.googlecode.aviator.Expression;
|
|
import com.ruoyi.common.constant.StatusConstant;
|
|
import com.ruoyi.common.constant.StatusConstant;
|
|
@@ -193,7 +191,7 @@ public class FlowProcessServiceImpl implements FlowProcessService {
|
|
ObsFileUtil.saveFile(dto.getFileList(), startExampleDetail.getId());
|
|
ObsFileUtil.saveFile(dto.getFileList(), startExampleDetail.getId());
|
|
|
|
|
|
// 推送
|
|
// 推送
|
|
- pushInitiateMessage(flowId, flowDefinition, nextNodeType, flowExample);
|
|
|
|
|
|
+ // pushInitiateMessage(flowId, flowDefinition, nextNodeType, flowExample);
|
|
|
|
|
|
// 清空ThreadLocal
|
|
// 清空ThreadLocal
|
|
FlowThreadLocalUtil.remove();
|
|
FlowThreadLocalUtil.remove();
|
|
@@ -269,7 +267,7 @@ public class FlowProcessServiceImpl implements FlowProcessService {
|
|
editExample(context);
|
|
editExample(context);
|
|
|
|
|
|
// 消息推送
|
|
// 消息推送
|
|
- pushJumpMessage(context);
|
|
|
|
|
|
+// pushJumpMessage(context);
|
|
|
|
|
|
// 清空ThreadLocal
|
|
// 清空ThreadLocal
|
|
FlowThreadLocalUtil.remove();
|
|
FlowThreadLocalUtil.remove();
|
|
@@ -606,7 +604,7 @@ public class FlowProcessServiceImpl implements FlowProcessService {
|
|
|
|
|
|
// 如果不为分支
|
|
// 如果不为分支
|
|
else {
|
|
else {
|
|
- if (nextNodeList == null || nextNodeList.size() == 0) {
|
|
|
|
|
|
+ if (nextNodeList == null || nextNodeList.isEmpty()) {
|
|
throw new ServiceException("流程定义错误:用户节点未找到跳转节点");
|
|
throw new ServiceException("流程定义错误:用户节点未找到跳转节点");
|
|
}
|
|
}
|
|
if (nextNodeList.size() > 1) {
|
|
if (nextNodeList.size() > 1) {
|
|
@@ -678,7 +676,7 @@ public class FlowProcessServiceImpl implements FlowProcessService {
|
|
|
|
|
|
case POST:
|
|
case POST:
|
|
List<SysUser> postUserList = sysUserService.getListByPostId(handleObjectId);
|
|
List<SysUser> postUserList = sysUserService.getListByPostId(handleObjectId);
|
|
- if (postUserList.size() == 0) {
|
|
|
|
|
|
+ if (postUserList.isEmpty()) {
|
|
throw new ServiceException("流程节点处理人异常:节点处理岗位无用户");
|
|
throw new ServiceException("流程节点处理人异常:节点处理岗位无用户");
|
|
}
|
|
}
|
|
if (postUserList.size() == 1) {
|
|
if (postUserList.size() == 1) {
|
|
@@ -692,7 +690,7 @@ public class FlowProcessServiceImpl implements FlowProcessService {
|
|
|
|
|
|
case ROLE:
|
|
case ROLE:
|
|
List<SysUser> roleUserList = sysUserService.getListByRoleId(handleObjectId);
|
|
List<SysUser> roleUserList = sysUserService.getListByRoleId(handleObjectId);
|
|
- if (roleUserList.size() == 0) {
|
|
|
|
|
|
+ if (roleUserList.isEmpty()) {
|
|
throw new ServiceException("流程节点处理人异常:节点处理角色无用户");
|
|
throw new ServiceException("流程节点处理人异常:节点处理角色无用户");
|
|
}
|
|
}
|
|
if (roleUserList.size() == 1) {
|
|
if (roleUserList.size() == 1) {
|
|
@@ -731,7 +729,7 @@ public class FlowProcessServiceImpl implements FlowProcessService {
|
|
title = "您有一条新的待审批事项,请及时处理。";
|
|
title = "您有一条新的待审批事项,请及时处理。";
|
|
}
|
|
}
|
|
|
|
|
|
- WebSocketPush.byUser(PushTypeEnum.MESSAGE, pushUserId, title, 0, businessData);
|
|
|
|
|
|
+ // WebSocketPush.byUser(PushTypeEnum.MESSAGE, pushUserId, title, 0, businessData);
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|
|
@@ -816,7 +814,7 @@ public class FlowProcessServiceImpl implements FlowProcessService {
|
|
throw new ServiceException("未知流程跳转类型");
|
|
throw new ServiceException("未知流程跳转类型");
|
|
}
|
|
}
|
|
|
|
|
|
- WebSocketPush.byUser(PushTypeEnum.MESSAGE, pushUserId, title, 0, businessData);
|
|
|
|
|
|
+ // WebSocketPush.byUser(PushTypeEnum.MESSAGE, pushUserId, title, 0, businessData);
|
|
}
|
|
}
|
|
|
|
|
|
// public static void main(String[] args) {
|
|
// public static void main(String[] args) {
|