|
|
|
@ -75,33 +75,40 @@ public class SrzUserServiceImpl implements ISrzUserService |
|
|
|
int insertNum = 0; |
|
|
|
int updateNum = 0; |
|
|
|
for (int i = 0; i < dataArr.size(); i++) { |
|
|
|
JSONObject jsonObject = dataArr.getJSONObject(i); |
|
|
|
if (StringUtils.isEmpty(jsonObject.getString("userId"))) { continue; } |
|
|
|
try { |
|
|
|
// 返回每条拉取的成功情况
|
|
|
|
String taskId = jsonObject.getString("taskId"); |
|
|
|
String params = "{\"token\":\"" + token + "\",\"data\":[{\"taskId\":\"" + taskId + "\",\"result\":\"SUCCESS\"}]}"; |
|
|
|
String doneStr = connect("/ebus/sfrzhqxglmk/sysDoneTacc", params); |
|
|
|
JSONObject doneObj = JSONObject.parseObject(doneStr); |
|
|
|
String done = doneObj.getString("success"); |
|
|
|
log.info("用户拉取完成结果 ========> {} ：{}", taskId, done); |
|
|
|
JSONObject jsonObject = dataArr.getJSONObject(i); |
|
|
|
if (StringUtils.isEmpty(jsonObject.getString("userId"))) { |
|
|
|
continue; |
|
|
|
} |
|
|
|
try { |
|
|
|
// 返回每条拉取的成功情况
|
|
|
|
String taskId = jsonObject.getString("taskId"); |
|
|
|
String params = "{\"token\":\"" + token + "\",\"data\":[{\"taskId\":\"" + taskId + "\",\"result\":\"SUCCESS\"}]}"; |
|
|
|
String doneStr = connect("/ebus/sfrzhqxglmk/sysDoneTacc", params); |
|
|
|
JSONObject doneObj = JSONObject.parseObject(doneStr); |
|
|
|
String done = doneObj.getString("success"); |
|
|
|
log.info("用户拉取完成结果 ========> {} ：{}", taskId, done); |
|
|
|
} catch (Exception e) { |
|
|
|
log.info("用户数据下拉完成异常，异常任务id：{}", jsonObject.getString("taskId")); |
|
|
|
e.printStackTrace(); |
|
|
|
} |
|
|
|
SrzUser srzUser = JSONObject.parseObject(jsonObject.toString(), SrzUser.class); |
|
|
|
if (srzUser == null) continue; |
|
|
|
|
|
|
|
SrzUser temp = srzUserMapper.selectUserByPrimaryKey(srzUser.getUserId()); |
|
|
|
srzUser.setNeedUpdate(0); |
|
|
|
// if (null != temp && temp.getOrganizationId() != null) {
|
|
|
|
if (null != temp) { |
|
|
|
// 跟新数据库
|
|
|
|
int rowNum = srzUserMapper.updateUser(srzUser); |
|
|
|
updateNum += rowNum; |
|
|
|
} else { |
|
|
|
// 插入数据库
|
|
|
|
int rowNum = srzUserMapper.insertUser(srzUser); |
|
|
|
insertNum += rowNum; |
|
|
|
} |
|
|
|
} catch (Exception e) { |
|
|
|
log.info("用户数据下拉完成异常，异常任务id：{}", jsonObject.getString("taskId")); |
|
|
|
e.printStackTrace(); |
|
|
|
} |
|
|
|
SrzUser srzUser=JSONObject.parseObject(jsonObject.toString(),SrzUser.class); |
|
|
|
if(srzUser==null)continue; |
|
|
|
|
|
|
|
SrzUser temp = srzUserMapper.selectUserByPrimaryKey(srzUser.getUserId()); |
|
|
|
srzUser.setNeedUpdate(0); |
|
|
|
if (null != temp && temp.getOrganizationId() != null) { |
|
|
|
// 跟新数据库
|
|
|
|
int rowNum = srzUserMapper.updateUser(srzUser); |
|
|
|
updateNum += rowNum; |
|
|
|
} else { |
|
|
|
// 插入数据库
|
|
|
|
int rowNum = srzUserMapper.insertUser(srzUser); |
|
|
|
insertNum += rowNum; |
|
|
|
log.info("用户数据同步异常. 暂不处理继续拉去"); |
|
|
|
} |
|
|
|
} |
|
|
|
Map<String, Integer> resMap = new HashedMap(); |
|
|
|
|
