Commit 80d875f1 authored by wujiang's avatar wujiang

修改同步用户

parent 33480e11
...@@ -57,20 +57,15 @@ public class PlatformModifyPasswordistener { ...@@ -57,20 +57,15 @@ public class PlatformModifyPasswordistener {
personAccountFed.setSecondaryPassword((String) jsonObject.get("rePassword")); personAccountFed.setSecondaryPassword((String) jsonObject.get("rePassword"));
personAccountFedMapper.updateById(personAccountFed); personAccountFedMapper.updateById(personAccountFed);
} }
//发消息通知集成方修改 //发消息通知集成方修改
Map<String, Object> data=new HashMap<>(); if(personAccount!=null)
FeignClientResult<AgencyUserModel> amosUser = Privilege.agencyUserClient.queryByUserId(personAccount.getPuserId()); {
AgencyUserModel user = new AgencyUserModel(); Map<String, Object> data=new HashMap<>();
if (!ObjectUtils.isEmpty(amosUser)) { data.put("SEQUENCE_NBR",jsonObject.get("sequenceNbr"));
if (amosUser.getStatus() == 200) { ProduceMsg produceMsg= new ProduceMsg(data, "UPDATE",personAccount.getPuserId());
user = amosUser.getResult(); querueProduce.produceMsg(JSON.toJSONString(produceMsg));
} else {
throw new RuntimeException(amosUser.getMessage());
}
} }
data.put("SEQUENCE_NBR",user.getSequenceNbr());
ProduceMsg produceMsg= new ProduceMsg(data, "UPDATE",personAccount.getPuserId());
querueProduce.produceMsg(JSON.toJSONString(produceMsg));
message.acknowledge(); message.acknowledge();
log.info("--------------------消息消费成功 {}", jsonObject); log.info("--------------------消息消费成功 {}", jsonObject);
} catch (Exception e) { } catch (Exception e) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment