|
|
@@ -169,6 +169,8 @@ public class MessageServiceImpl extends BaseMybatisDao<MessageFromSystemMapper>
|
|
|
mp.setId(UUID.randomUUID().toString());
|
|
|
mp.setMessageId(mfs.getId());
|
|
|
mp.setConsumerId(cid);
|
|
|
+ mp.setCreateTime(createTime);
|
|
|
+ mp.setSendTime(createTime);
|
|
|
producerTarget.add(mp);
|
|
|
registrationId = messageFromSystemMapper.selectJPushAcc(cid);
|
|
|
if(StringUtils.isNotBlank(registrationId)){
|
|
|
@@ -195,6 +197,8 @@ public class MessageServiceImpl extends BaseMybatisDao<MessageFromSystemMapper>
|
|
|
mp.setId(UUID.randomUUID().toString());
|
|
|
mp.setMessageId(mfs.getId());
|
|
|
mp.setConsumerId(cid);
|
|
|
+ mp.setCreateTime(createTime);
|
|
|
+ mp.setSendTime(createTime);
|
|
|
producerTarget.add(mp);
|
|
|
registrationId = messageFromSystemMapper.selectJPushAcc(cid);
|
|
|
if(StringUtils.isNotBlank(registrationId)){
|
|
|
@@ -258,8 +262,9 @@ public class MessageServiceImpl extends BaseMybatisDao<MessageFromSystemMapper>
|
|
|
mp = new MessageProducer();
|
|
|
mp.setId(UUID.randomUUID().toString());
|
|
|
mp.setConsumerId(cid);
|
|
|
- mp.setCreateTime(createTime);
|
|
|
mp.setMessageId(messageId);
|
|
|
+ mp.setCreateTime(createTime);
|
|
|
+ mp.setSendTime(createTime);
|
|
|
producerTarget.add(mp);
|
|
|
registrationId = messageFromSystemMapper.selectJPushAcc(cid);
|
|
|
if(StringUtils.isNotBlank(registrationId)){
|