|
|
|
@ -624,70 +624,88 @@ public class UserServiceImpl implements IUserService { |
|
|
|
int insertNum = 0; |
|
|
|
int updateNum = 0; |
|
|
|
for (int i = 0; i < dataArr.size(); i++) { |
|
|
|
JSONObject jsonObject = dataArr.getJSONObject(i); |
|
|
|
// 通过登录名判断用户是否存在
|
|
|
|
try { |
|
|
|
JSONObject jsonObject = dataArr.getJSONObject(i); |
|
|
|
// 通过登录名判断用户是否存在
|
|
|
|
// checkLoginNameUnique(jsonObject.getString("username"));
|
|
|
|
if (StringUtils.isEmpty(jsonObject.getString("username"))) { continue; } |
|
|
|
if (StringUtils.isEmpty(jsonObject.getString("username"))) { |
|
|
|
continue; |
|
|
|
} |
|
|
|
|
|
|
|
try { |
|
|
|
// 返回每条拉取的成功情况
|
|
|
|
String taskId = jsonObject.getString("taskId"); |
|
|
|
String params = "{\"token\":\""+token+"\",[{\"taskId\":\""+taskId+"\",\"result\":\"SUCCESS\"}]}"; |
|
|
|
connect("/ebus/sfrzhqxglmk/sysDoneTacc", params); |
|
|
|
}catch (Exception e){ |
|
|
|
log.info("用户数据下拉完成异常,异常任务id:{}",jsonObject.getString("taskId")); |
|
|
|
e.printStackTrace(); |
|
|
|
} |
|
|
|
try { |
|
|
|
// 返回每条拉取的成功情况
|
|
|
|
String taskId = jsonObject.getString("taskId"); |
|
|
|
String params = "{\"token\":\"" + token + "\",[{\"taskId\":\"" + taskId + "\",\"result\":\"SUCCESS\"}]}"; |
|
|
|
connect("/ebus/sfrzhqxglmk/sysDoneTacc", params); |
|
|
|
} catch (Exception e) { |
|
|
|
log.info("用户数据下拉完成异常,异常任务id:{}", jsonObject.getString("taskId")); |
|
|
|
e.printStackTrace(); |
|
|
|
} |
|
|
|
|
|
|
|
User user = new User(); |
|
|
|
user.setDeptId(jsonObject.getString("organizationId")); |
|
|
|
user.setOrganizationId(jsonObject.getString("organizationId")); |
|
|
|
user.setStrUserId(jsonObject.getString("userId")); |
|
|
|
user.setSrzUserid(jsonObject.getString("srzUserId")); |
|
|
|
user.setFullname(jsonObject.getString("fullname")); |
|
|
|
user.setUserName(jsonObject.getString("fullname")); |
|
|
|
user.setTaskId(jsonObject.getString("taskId")); |
|
|
|
user.setSystemId(jsonObject.getString("systemId")); |
|
|
|
user.setLoginName(jsonObject.getString("username")); |
|
|
|
user.setEffectOn(jsonObject.getString("effectOn")); |
|
|
|
user.setIsDisabled(jsonObject.getString("isDisabled")); |
|
|
|
user.setIsDeleted(jsonObject.getString("isDeleted")); |
|
|
|
user.setCreateAt(jsonObject.getString("createAt")); |
|
|
|
user.setUpdateAt(jsonObject.getString("updateAt")); |
|
|
|
user.setGuid(jsonObject.getString("guid")); |
|
|
|
//手机号加密
|
|
|
|
String mobileNumber = |
|
|
|
IdCardCryptoUtil.symmetricEncryptIdCard(secretKey, jsonObject.getString("mobileNumber")); |
|
|
|
user.setMobileNumber(mobileNumber); |
|
|
|
|
|
|
|
user.setPhonenumber(mobileNumber); |
|
|
|
user.setEmail(jsonObject.getString("email")); |
|
|
|
user.setCertificateTypeId(jsonObject.getString("certificateTypeId")); |
|
|
|
user.setCertificateTypeIdCode(jsonObject.getString("certificateTypeIdCode")); |
|
|
|
//证件号加密
|
|
|
|
String certificateNumber = |
|
|
|
IdCardCryptoUtil.symmetricEncryptIdCard(secretKey, jsonObject.getString("certificateNumber")); |
|
|
|
user.setCertificateNumber(certificateNumber); |
|
|
|
user.setIsMappingPerson(jsonObject.getString("isMappingPerson")); |
|
|
|
//证件号加密
|
|
|
|
String units = |
|
|
|
IdCardCryptoUtil.symmetricEncryptIdCard(secretKey, jsonObject.getString("units")); |
|
|
|
user.setUnits(units); |
|
|
|
|
|
|
|
user.randomSalt(); |
|
|
|
//新增用户默认不删除标记
|
|
|
|
user.setDelFlag("0"); |
|
|
|
|
|
|
|
User uniqueUser = userMapper.selectUserByLoginName(jsonObject.getString("username")); |
|
|
|
if (null != uniqueUser && uniqueUser.getUserId() != null) { |
|
|
|
// 跟新数据库
|
|
|
|
user.setUserId(uniqueUser.getUserId()); |
|
|
|
int rowNum = userMapper.updateUser(user); |
|
|
|
updateNum += rowNum; |
|
|
|
} else { |
|
|
|
// 插入数据库
|
|
|
|
int rowNum = userMapper.insertUser(user); |
|
|
|
insertNum += rowNum; |
|
|
|
User user = new User(); |
|
|
|
user.setDeptId(jsonObject.getString("organizationId")); |
|
|
|
user.setOrganizationId(jsonObject.getString("organizationId")); |
|
|
|
user.setStrUserId(jsonObject.getString("userId")); |
|
|
|
user.setSrzUserid(jsonObject.getString("srzUserId")); |
|
|
|
user.setFullname(jsonObject.getString("fullname")); |
|
|
|
user.setUserName(jsonObject.getString("fullname")); |
|
|
|
user.setTaskId(jsonObject.getString("taskId")); |
|
|
|
user.setSystemId(jsonObject.getString("systemId")); |
|
|
|
user.setLoginName(jsonObject.getString("username")); |
|
|
|
user.setEffectOn(jsonObject.getString("effectOn")); |
|
|
|
user.setIsDisabled(jsonObject.getString("isDisabled")); |
|
|
|
user.setIsDeleted(jsonObject.getString("isDeleted")); |
|
|
|
user.setCreateAt(jsonObject.getString("createAt")); |
|
|
|
user.setUpdateAt(jsonObject.getString("updateAt")); |
|
|
|
user.setGuid(jsonObject.getString("guid")); |
|
|
|
//手机号加密
|
|
|
|
String mobileNumber = ""; |
|
|
|
try { |
|
|
|
mobileNumber = IdCardCryptoUtil.symmetricEncryptIdCard(secretKey, jsonObject.getString("mobileNumber")); |
|
|
|
} catch (Exception e) { |
|
|
|
mobileNumber = ""; |
|
|
|
} |
|
|
|
user.setMobileNumber(mobileNumber); |
|
|
|
|
|
|
|
user.setPhonenumber(mobileNumber); |
|
|
|
user.setEmail(jsonObject.getString("email")); |
|
|
|
user.setCertificateTypeId(jsonObject.getString("certificateTypeId")); |
|
|
|
user.setCertificateTypeIdCode(jsonObject.getString("certificateTypeIdCode")); |
|
|
|
//证件号加密
|
|
|
|
String certificateNumber = ""; |
|
|
|
try { |
|
|
|
certificateNumber = IdCardCryptoUtil.symmetricEncryptIdCard(secretKey, jsonObject.getString("certificateNumber")); |
|
|
|
} catch (Exception e) { |
|
|
|
certificateNumber = ""; |
|
|
|
} |
|
|
|
user.setCertificateNumber(certificateNumber); |
|
|
|
user.setIsMappingPerson(jsonObject.getString("isMappingPerson")); |
|
|
|
//证件号加密
|
|
|
|
String units = ""; |
|
|
|
try { |
|
|
|
units = IdCardCryptoUtil.symmetricEncryptIdCard(secretKey, jsonObject.getString("units")); |
|
|
|
} catch (Exception e) { |
|
|
|
units = ""; |
|
|
|
} |
|
|
|
user.setUnits(units); |
|
|
|
|
|
|
|
user.randomSalt(); |
|
|
|
//新增用户默认不删除标记
|
|
|
|
user.setDelFlag("0"); |
|
|
|
|
|
|
|
User uniqueUser = userMapper.selectUserByLoginName(jsonObject.getString("username")); |
|
|
|
if (null != uniqueUser && uniqueUser.getUserId() != null) { |
|
|
|
// 跟新数据库
|
|
|
|
user.setUserId(uniqueUser.getUserId()); |
|
|
|
int rowNum = userMapper.updateUser(user); |
|
|
|
updateNum += rowNum; |
|
|
|
} else { |
|
|
|
// 插入数据库
|
|
|
|
int rowNum = userMapper.insertUser(user); |
|
|
|
insertNum += rowNum; |
|
|
|
} |
|
|
|
} catch (Exception e) { |
|
|
|
continue; |
|
|
|
} |
|
|
|
} |
|
|
|
Map<String, Integer> resMap = new HashedMap(); |
|
|
|
|