|
|
|
@ -368,7 +368,7 @@ public class PersonTestingServiceImpl extends BaseServiceImpl<PersonTestingDao, |
|
|
|
private void sendMqMessage(PersonTestingDTO dto) { |
|
|
|
PersonTestingModifyDTO modifyDTO = ConvertUtils.sourceToTarget(dto, PersonTestingModifyDTO.class); |
|
|
|
personTestingModifyProducer.sendMessage(RocketMqConstant.MQ_TOPIC_VACCINE, RocketMqConstant.MQ_TAG_VACCINE, |
|
|
|
dto.getIdcard(), JSONObject.toJSONString(modifyDTO)); |
|
|
|
"vaccine-testing", JSONObject.toJSONString(modifyDTO)); |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|