|
|
@ -186,7 +186,7 @@ public class IcPartyActServiceImpl extends BaseServiceImpl<IcPartyActDao, IcPart |
|
|
|
icPartyActEntity.setIsPublish(origin.getIsPublish()); |
|
|
|
baseDao.updateById(icPartyActEntity); |
|
|
|
//已发布,在编辑的时候,需要发送消息
|
|
|
|
if(NumConstant.ONE_STR.equals(icPartyActEntity.getIsPublish())){ |
|
|
|
if(NumConstant.ONE_STR.equals(icPartyActEntity.getIsPublish())&&NumConstant.ONE_STR.equals(icPartyActEntity.getIsAutoInform())){ |
|
|
|
sendMsg=true; |
|
|
|
} |
|
|
|
}else{ |
|
|
@ -615,11 +615,13 @@ public class IcPartyActServiceImpl extends BaseServiceImpl<IcPartyActDao, IcPart |
|
|
|
icPartyActEntity.setUpdatedBy(userId); |
|
|
|
baseDao.updateById(icPartyActEntity); |
|
|
|
//发送消息
|
|
|
|
PartyMeetingMessageMQMsg msg = new PartyMeetingMessageMQMsg(); |
|
|
|
msg.setCustomerId(icPartyActEntity.getCustomerId()); |
|
|
|
msg.setIcPartyActId(icPartyActEntity.getId()); |
|
|
|
msg.setType("publish"); |
|
|
|
SendMqMsgUtil.build().openFeignClient(SpringContextUtils.getBean(EpmetMessageOpenFeignClient.class)).sendRocketMqMsg(SystemMessageType.PARTY_MEETING_MESSAGE, msg); |
|
|
|
if(NumConstant.ONE_STR.equals(icPartyActEntity.getIsAutoInform())){ |
|
|
|
PartyMeetingMessageMQMsg msg = new PartyMeetingMessageMQMsg(); |
|
|
|
msg.setCustomerId(icPartyActEntity.getCustomerId()); |
|
|
|
msg.setIcPartyActId(icPartyActEntity.getId()); |
|
|
|
msg.setType("publish"); |
|
|
|
SendMqMsgUtil.build().openFeignClient(SpringContextUtils.getBean(EpmetMessageOpenFeignClient.class)).sendRocketMqMsg(SystemMessageType.PARTY_MEETING_MESSAGE, msg); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
@ -661,6 +663,7 @@ public class IcPartyActServiceImpl extends BaseServiceImpl<IcPartyActDao, IcPart |
|
|
|
@Override |
|
|
|
public void noticePartyActAutoPublishTask() { |
|
|
|
//todo
|
|
|
|
|
|
|
|
return; |
|
|
|
} |
|
|
|
|
|
|
|