guoyuepeng
/
qa-prevention-gwj
1
0
Fork 3
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

学院定位

xuyifeng-0724-人员中台对接-dev
liujun 2024-06-27 15:59:25 +08:00
parent 213d2fa16f
commit f83f0ff3ee
6 changed files with 24 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/com/zcloud/flow/util/SendMessageUtil.java → src/main/java/com/zcloud/flow/util/GJSendMessageUtil.java
View File

@ -17,7 +17,7 @@ import java.util.*;
*/ */
@Component @Component
public class SendMessageUtil { public class GJSendMessageUtil {
/** /**
* 工匠学苑 服务地址(测试环境) * 工匠学苑 服务地址(测试环境)

8
src/main/java/com/zcloud/flow/xgf/GuFen/GuFenSupervise.java
View File

@ -3,7 +3,7 @@ package com.zcloud.flow.xgf.GuFen;
import com.yomahub.liteflow.annotation.LiteflowComponent; import com.yomahub.liteflow.annotation.LiteflowComponent;
import com.yomahub.liteflow.core.NodeComponent; import com.yomahub.liteflow.core.NodeComponent;
import com.zcloud.entity.PageData; import com.zcloud.entity.PageData;
import com.zcloud.flow.util.SendMessageUtil; import com.zcloud.flow.util.GJSendMessageUtil;
import com.zcloud.flow.util.dto.UserDTO; import com.zcloud.flow.util.dto.UserDTO;
import com.zcloud.mapper.datasource.xgf.XgfFlowsMapper; import com.zcloud.mapper.datasource.xgf.XgfFlowsMapper;
import com.zcloud.mapper.datasource.xgf.XgfUserDetailsMapper; import com.zcloud.mapper.datasource.xgf.XgfUserDetailsMapper;
@ -33,7 +33,7 @@ public class GuFenSupervise extends NodeComponent {
@Resource @Resource
private XgfUserDetailsMapper xgfUserDetailsMapper; private XgfUserDetailsMapper xgfUserDetailsMapper;
@Resource @Resource
private SendMessageUtil sendMessageUtil; private GJSendMessageUtil gjSendMessageUtil;
@Override @Override
public boolean isAccess() { public boolean isAccess() {
@ -97,7 +97,7 @@ public class GuFenSupervise extends NodeComponent {
// created by liu jun 2024-06-26 工匠学院对接 // created by liu jun 2024-06-26 工匠学院对接
condition.clear(); condition.clear();
condition.put("XGF_USER_ID", flows.getString("FLOWS_ID")); condition.put("XGF_USER_DETAILS_ID", flows.getString("FLOWS_ID"));
PageData entityInfo = xgfUserDetailsMapper.findById(condition); PageData entityInfo = xgfUserDetailsMapper.findById(condition);
UserDTO userDTO = UserDTO.builder() UserDTO userDTO = UserDTO.builder()
.userName(entity.getString("USERNAME")) .userName(entity.getString("USERNAME"))
@ -110,7 +110,7 @@ public class GuFenSupervise extends NodeComponent {
.build(); .build();
List<UserDTO> list = new ArrayList<UserDTO>(); List<UserDTO> list = new ArrayList<UserDTO>();
list.add(userDTO); list.add(userDTO);
sendMessageUtil.sendMessage(list); gjSendMessageUtil.sendMessage(list);
// 保存操作记录 // 保存操作记录
xgfUserService.saveLog(info, info.getSTATUS(), "1"); xgfUserService.saveLog(info, info.getSTATUS(), "1");
} }

9
src/main/java/com/zcloud/flow/xgf/GuFen/GuFenWeiTuoSupervise.java
View File

@ -3,7 +3,7 @@ package com.zcloud.flow.xgf.GuFen;
import com.yomahub.liteflow.annotation.LiteflowComponent; import com.yomahub.liteflow.annotation.LiteflowComponent;
import com.yomahub.liteflow.core.NodeComponent; import com.yomahub.liteflow.core.NodeComponent;
import com.zcloud.entity.PageData; import com.zcloud.entity.PageData;
import com.zcloud.flow.util.SendMessageUtil; import com.zcloud.flow.util.GJSendMessageUtil;
import com.zcloud.flow.util.dto.UserDTO; import com.zcloud.flow.util.dto.UserDTO;
import com.zcloud.mapper.datasource.bus.CorpInfoMapper; import com.zcloud.mapper.datasource.bus.CorpInfoMapper;
import com.zcloud.mapper.datasource.xgf.XgfFlowsMapper; import com.zcloud.mapper.datasource.xgf.XgfFlowsMapper;
@ -38,10 +38,11 @@ public class GuFenWeiTuoSupervise extends NodeComponent {
@Resource @Resource
private XgfUserDetailsMapper xgfUserDetailsMapper; private XgfUserDetailsMapper xgfUserDetailsMapper;
@Resource @Resource
private SendMessageUtil sendMessageUtil; private GJSendMessageUtil gjSendMessageUtil;
@Override @Override
public boolean isAccess() { public boolean isAccess() {
System.out.println("2???????");
XgfFlowDto info = this.getRequestData(); XgfFlowDto info = this.getRequestData();
// 如果指针没有数据，赋值后自动结束 // 如果指针没有数据，赋值后自动结束
if (StringUtils.isBlank(info.getIterator())) { if (StringUtils.isBlank(info.getIterator())) {
@ -98,7 +99,7 @@ public class GuFenWeiTuoSupervise extends NodeComponent {
// created by liu jun 2024-06-26 工匠学院对接 // created by liu jun 2024-06-26 工匠学院对接
condition.clear(); condition.clear();
condition.put("XGF_USER_ID", flows.getString("FLOWS_ID")); condition.put("XGF_USER_DETAILS_ID", flows.getString("FLOWS_ID"));
PageData entityInfo = xgfUserDetailsMapper.findById(condition); PageData entityInfo = xgfUserDetailsMapper.findById(condition);
UserDTO userDTO = UserDTO.builder() UserDTO userDTO = UserDTO.builder()
.userName(entity.getString("USERNAME")) .userName(entity.getString("USERNAME"))
@ -111,7 +112,7 @@ public class GuFenWeiTuoSupervise extends NodeComponent {
.build(); .build();
List<UserDTO> list = new ArrayList<UserDTO>(); List<UserDTO> list = new ArrayList<UserDTO>();
list.add(userDTO); list.add(userDTO);
sendMessageUtil.sendMessage(list); gjSendMessageUtil.sendMessage(list);
// 保存操作记录 // 保存操作记录
xgfUserService.saveLog(info, info.getSTATUS(), "1"); xgfUserService.saveLog(info, info.getSTATUS(), "1");

9
src/main/java/com/zcloud/flow/xgf/JiTuan/JiTuanSupervise.java
View File

@ -3,7 +3,8 @@ package com.zcloud.flow.xgf.JiTuan;
import com.yomahub.liteflow.annotation.LiteflowComponent; import com.yomahub.liteflow.annotation.LiteflowComponent;
import com.yomahub.liteflow.core.NodeComponent; import com.yomahub.liteflow.core.NodeComponent;
import com.zcloud.entity.PageData; import com.zcloud.entity.PageData;
import com.zcloud.flow.util.SendMessageUtil; import com.zcloud.flow.util.GJSendMessageUtil;
import com.zcloud.flow.util.GJSendMessageUtil;
import com.zcloud.flow.util.dto.UserDTO; import com.zcloud.flow.util.dto.UserDTO;
import com.zcloud.flow.xgf.util.XgfFlowDto; import com.zcloud.flow.xgf.util.XgfFlowDto;
import com.zcloud.mapper.datasource.xgf.XgfFlowsMapper; import com.zcloud.mapper.datasource.xgf.XgfFlowsMapper;
@ -32,7 +33,7 @@ public class JiTuanSupervise extends NodeComponent {
@Resource @Resource
private XgfUserDetailsMapper xgfUserDetailsMapper; private XgfUserDetailsMapper xgfUserDetailsMapper;
@Resource @Resource
private SendMessageUtil sendMessageUtil; private GJSendMessageUtil gjSendMessageUtil;
@Override @Override
public boolean isAccess() { public boolean isAccess() {
@ -96,7 +97,7 @@ public class JiTuanSupervise extends NodeComponent {
xgfUserMapper.edit(entity); xgfUserMapper.edit(entity);
// created by liu jun 2024-06-26 工匠学院对接 // created by liu jun 2024-06-26 工匠学院对接
condition.clear(); condition.clear();
condition.put("XGF_USER_ID", flows.getString("FLOWS_ID")); condition.put("XGF_USER_DETAILS_ID", flows.getString("FLOWS_ID"));
PageData entityInfo = xgfUserDetailsMapper.findById(condition); PageData entityInfo = xgfUserDetailsMapper.findById(condition);
UserDTO userDTO = UserDTO.builder() UserDTO userDTO = UserDTO.builder()
.userName(entity.getString("USERNAME")) .userName(entity.getString("USERNAME"))
@ -109,7 +110,7 @@ public class JiTuanSupervise extends NodeComponent {
.build(); .build();
List<UserDTO> list = new ArrayList<UserDTO>(); List<UserDTO> list = new ArrayList<UserDTO>();
list.add(userDTO); list.add(userDTO);
sendMessageUtil.sendMessage(list); gjSendMessageUtil.sendMessage(list);
// 保存操作记录 // 保存操作记录
xgfUserService.saveLog(info, info.getSTATUS(), "1"); xgfUserService.saveLog(info, info.getSTATUS(), "1");
} }

8
src/main/java/com/zcloud/flow/xgf/JiTuan/JiTuanWeiTuoSupervise.java
View File

@ -3,7 +3,7 @@ package com.zcloud.flow.xgf.JiTuan;
import com.yomahub.liteflow.annotation.LiteflowComponent; import com.yomahub.liteflow.annotation.LiteflowComponent;
import com.yomahub.liteflow.core.NodeComponent; import com.yomahub.liteflow.core.NodeComponent;
import com.zcloud.entity.PageData; import com.zcloud.entity.PageData;
import com.zcloud.flow.util.SendMessageUtil; import com.zcloud.flow.util.GJSendMessageUtil;
import com.zcloud.flow.util.dto.UserDTO; import com.zcloud.flow.util.dto.UserDTO;
import com.zcloud.flow.xgf.util.XgfFlowDto; import com.zcloud.flow.xgf.util.XgfFlowDto;
import com.zcloud.mapper.datasource.bus.CorpInfoMapper; import com.zcloud.mapper.datasource.bus.CorpInfoMapper;
@ -37,7 +37,7 @@ public class JiTuanWeiTuoSupervise extends NodeComponent {
@Resource @Resource
private XgfUserDetailsMapper xgfUserDetailsMapper; private XgfUserDetailsMapper xgfUserDetailsMapper;
@Resource @Resource
private SendMessageUtil sendMessageUtil; private GJSendMessageUtil gjSendMessageUtil;
@Override @Override
public boolean isAccess() { public boolean isAccess() {
@ -98,7 +98,7 @@ public class JiTuanWeiTuoSupervise extends NodeComponent {
// created by liu jun 2024-06-26 工匠学院对接 // created by liu jun 2024-06-26 工匠学院对接
condition.clear(); condition.clear();
condition.put("XGF_USER_ID", flows.getString("FLOWS_ID")); condition.put("XGF_USER_DETAILS_ID", flows.getString("FLOWS_ID"));
PageData entityInfo = xgfUserDetailsMapper.findById(condition); PageData entityInfo = xgfUserDetailsMapper.findById(condition);
UserDTO userDTO = UserDTO.builder() UserDTO userDTO = UserDTO.builder()
.userName(entity.getString("USERNAME")) .userName(entity.getString("USERNAME"))
@ -111,7 +111,7 @@ public class JiTuanWeiTuoSupervise extends NodeComponent {
.build(); .build();
List<UserDTO> list = new ArrayList<UserDTO>(); List<UserDTO> list = new ArrayList<UserDTO>();
list.add(userDTO); list.add(userDTO);
sendMessageUtil.sendMessage(list); gjSendMessageUtil.sendMessage(list);
// 保存操作记录 // 保存操作记录
xgfUserService.saveLog(info, info.getSTATUS(), "1"); xgfUserService.saveLog(info, info.getSTATUS(), "1");
} }

11
src/main/java/com/zcloud/flow/xgf/YiBan/YiBanSupervise.java
View File

@ -3,7 +3,7 @@ package com.zcloud.flow.xgf.YiBan;
import com.yomahub.liteflow.annotation.LiteflowComponent; import com.yomahub.liteflow.annotation.LiteflowComponent;
import com.yomahub.liteflow.core.NodeComponent; import com.yomahub.liteflow.core.NodeComponent;
import com.zcloud.entity.PageData; import com.zcloud.entity.PageData;
import com.zcloud.flow.util.SendMessageUtil; import com.zcloud.flow.util.GJSendMessageUtil;
import com.zcloud.flow.util.dto.UserDTO; import com.zcloud.flow.util.dto.UserDTO;
import com.zcloud.mapper.datasource.bus.CorpInfoMapper; import com.zcloud.mapper.datasource.bus.CorpInfoMapper;
import com.zcloud.mapper.datasource.xgf.XgfFlowsMapper; import com.zcloud.mapper.datasource.xgf.XgfFlowsMapper;
@ -17,11 +17,10 @@ import org.apache.commons.lang3.StringUtils;
import javax.annotation.Resource; import javax.annotation.Resource;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collections;
import java.util.List; import java.util.List;
@LiteflowComponent("YiBanSupervise") @LiteflowComponent("YiBanSupervise")
@SuppressWarnings("all")
public class YiBanSupervise extends NodeComponent { public class YiBanSupervise extends NodeComponent {
@Resource @Resource
@ -36,7 +35,7 @@ public class YiBanSupervise extends NodeComponent {
@Resource @Resource
private XgfUserDetailsMapper xgfUserDetailsMapper; private XgfUserDetailsMapper xgfUserDetailsMapper;
@Resource @Resource
private SendMessageUtil sendMessageUtil; private GJSendMessageUtil gjSendMessageUtil;
@Resource @Resource
private CorpInfoMapper corpInfoMapper; private CorpInfoMapper corpInfoMapper;
@ -131,7 +130,7 @@ public class YiBanSupervise extends NodeComponent {
xgfUserMapper.edit(entity); xgfUserMapper.edit(entity);
// created by liu jun 2024-06-26 工匠学院对接 // created by liu jun 2024-06-26 工匠学院对接
condition.clear(); condition.clear();
condition.put("XGF_USER_ID", flows.getString("FLOWS_ID")); condition.put("XGF_USER_DETAILS_ID", flows.getString("FLOWS_ID"));
PageData entityInfo = xgfUserDetailsMapper.findById(condition); PageData entityInfo = xgfUserDetailsMapper.findById(condition);
UserDTO userDTO = UserDTO.builder() UserDTO userDTO = UserDTO.builder()
.userName(entity.getString("USERNAME")) .userName(entity.getString("USERNAME"))
@ -144,7 +143,7 @@ public class YiBanSupervise extends NodeComponent {
.build(); .build();
List<UserDTO> list = new ArrayList<UserDTO>(); List<UserDTO> list = new ArrayList<UserDTO>();
list.add(userDTO); list.add(userDTO);
sendMessageUtil.sendMessage(list); gjSendMessageUtil.sendMessage(list);
// 保存操作记录 // 保存操作记录
xgfUserService.saveLog(info, info.getSTATUS(), "1"); xgfUserService.saveLog(info, info.getSTATUS(), "1");
} }