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

[新增功能](hyx_2024-9-27_tongbu) 

人员信息同步
hyx_2024-9-27_tongbu
huangyuxuan 2024-10-12 08:56:20 +08:00
parent 6050e94b49
commit f741535420
3 changed files with 28 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
src/main/java/com/zcloud/controller/system/UsersController.java
View File

@ -778,7 +778,7 @@ public class UsersController extends BaseController {
} }
map.put("result", errInfo); map.put("result", errInfo);
map.put("code","0"); map.put("code","0");
// map.put("syncInfo", JSONUtil.toJsonStr(usersService.findById(pd))); map.put("syncInfo", JSONUtil.toJsonStr(usersService.findById(pd)));
return map; return map;
} }
@ -1032,7 +1032,7 @@ public class UsersController extends BaseController {
map.put("USER_ID",ID); map.put("USER_ID",ID);
map.put("result", errInfo); //返回结果 map.put("result", errInfo); //返回结果
map.put("code", "0"); map.put("code", "0");
// map.put("syncInfo", JSONUtil.toJsonStr(userinfo)); map.put("syncInfo", JSONUtil.toJsonStr(userinfo));
} else { } else {
map.put("result", "您输入的身份证号和用户名二次校验失败，请确认后重新申请"); //返回结果 map.put("result", "您输入的身份证号和用户名二次校验失败，请确认后重新申请"); //返回结果
} }
@ -1066,9 +1066,9 @@ public class UsersController extends BaseController {
for (Object key : set) { for (Object key : set) {
param.put(key.toString(),pd.getString(key.toString())); param.put(key.toString(),pd.getString(key.toString()));
} }
// String UserDto = JSON.toJSONString(param); String UserDto = JSON.toJSONString(param);
// String result = HttpClientUtilDoGet.sendHttpPost(tongBuUrl + "/docking/core/user/addOrUpdate", UserDto,param); String result = HttpClientUtilDoGet.sendHttpPost(tongBuUrl + "/docking/core/user/addOrUpdate", UserDto,param);
// returnMap = (Map<String, String>) JSON.parse(result); returnMap = (Map<String, String>) JSON.parse(result);
// TODO com.alibaba.fastjson.JSONException: syntax error, pos 1 暂时不用人员中台 // TODO com.alibaba.fastjson.JSONException: syntax error, pos 1 暂时不用人员中台
returnMap.put("result", "success"); returnMap.put("result", "success");
} }
@ -2503,12 +2503,23 @@ public class UsersController extends BaseController {
return doCheck(param.get("USERNAME"),param.get("CARD_NO"),param.get("USER_ID")); return doCheck(param.get("USERNAME"),param.get("CARD_NO"),param.get("USER_ID"));
} }
/**
* 检查人员中台用户是否存在
*
* @param USERNAME 用户名
* @param CARD_NO 身份证号
* @param USER_ID 用户id
* @return map
* @throws Exception
* @author water_xu
* @date 2024-9-29
*/
public Map<String, String> doCheck(String USERNAME, String CARD_NO, String USER_ID) throws Exception { public Map<String, String> doCheck(String USERNAME, String CARD_NO, String USER_ID) throws Exception {
// String result = HttpClientUtilDoGet.sendHttpGet(tongBuUrl + "/docking/core/user/getCheck"+"?USERNAME="+USERNAME+"&CARD_NO="+CARD_NO+"&USER_ID="+USER_ID); String result = HttpClientUtilDoGet.sendHttpGet(tongBuUrl + "/docking/core/user/getCheck"+"?USERNAME="+USERNAME+"&CARD_NO="+CARD_NO+"&USER_ID="+USER_ID);
// Map<String, String> returnMap = (Map<String, String>) JSON.parse(result); Map<String, String> returnMap = (Map<String, String>) JSON.parse(result);
// 人员中台暂时不用 // 人员中台暂时不用
Map<String, String> returnMap = new HashMap<>(); // Map<String, String> returnMap = new HashMap<>();
returnMap.put("result", "success"); // returnMap.put("result", "success");
return returnMap; return returnMap;
} }

4
src/main/java/com/zcloud/syncData/SyncDataAdviceAspect.java
View File

@ -25,8 +25,8 @@ import java.util.Map;
* 作者：water_xu * 作者：water_xu
* 官网：www.zcloudchina.com * 官网：www.zcloudchina.com
*/ */
//@Aspect @Aspect
//@Component @Component
@SuppressWarnings("all") @SuppressWarnings("all")
public class SyncDataAdviceAspect { public class SyncDataAdviceAspect {

10
src/main/java/com/zcloud/syncData/listener/SyncDataListener.java
View File

@ -85,10 +85,12 @@ public class SyncDataListener implements RocketMQListener<String> {
pd.putAll(tenCorpDto.getPd()); pd.putAll(tenCorpDto.getPd());
pd.put("CONSUMPTION_TIME", DateUtil.date2Str(new Date())); pd.put("CONSUMPTION_TIME", DateUtil.date2Str(new Date()));
pd.put("CONSUMPTION_TYPE","MqQyDataListener"); pd.put("CONSUMPTION_TYPE","MqQyDataListener");
if ("qy".equals(tenCorpDto.getMessage())){ //2024-10-08 黄宇轩修改，
// 在本端发的同步消息，不需要再次同步该数据 // 三端新增用户后，人员中台将用户信息同步到core_sync_user表
return; // if ("qy".equals(tenCorpDto.getMessage())){
} // // 在本端发的同步消息，不需要再次同步该数据
// return;
// }
try { try {
//拿到原路径 //拿到原路径
String url = pd.getString("url"); String url = pd.getString("url");