From c0e90a93b4f7b7e02874e6a122b5268a4ee046a3 Mon Sep 17 00:00:00 2001
From: yinzuomei <576302893@qq.com>
Date: Wed, 31 Aug 2022 12:42:14 +0800
Subject: [PATCH] log

---
 .../service/impl/IcPartyActServiceImpl.java   | 38 ++++++++++---------
 1 file changed, 21 insertions(+), 17 deletions(-)

diff --git a/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partyOrg/service/impl/IcPartyActServiceImpl.java b/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partyOrg/service/impl/IcPartyActServiceImpl.java
index c59e7bdc2b..a6eb03c9de 100644
--- a/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partyOrg/service/impl/IcPartyActServiceImpl.java
+++ b/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partyOrg/service/impl/IcPartyActServiceImpl.java
@@ -734,23 +734,27 @@ public class IcPartyActServiceImpl extends BaseServiceImpl<IcPartyActDao, IcPart
      */
     @Override
     public void autoPublishIcPartyAct() {
-        Date nowDate=new Date();
-        String dateId=DateUtils.format(nowDate,DateUtils.DATE_PATTERN_YYYYMMDDHHMM);
-        log.info("自动发布活动开始，dateId="+dateId+"sql入参："+dateId.substring(0,dateId.length()-1));
-        List<IcPartyActEntity> list=baseDao.selectNoPublishList(dateId.substring(0,dateId.length()-1));
-        for(IcPartyActEntity act:list){
-            //置为已发布
-            act.setIsPublish(NumConstant.ONE_STR);
-            baseDao.updateById(act);
-            //选择了自动通知参加人员的，需要发送消息
-            if(NumConstant.ONE_STR.equals(act.getIsAutoInform())){
-                PartyMeetingMessageMQMsg msg = new PartyMeetingMessageMQMsg();
-                msg.setCustomerId(act.getCustomerId());
-                msg.setIcPartyActId(act.getId());
-                msg.setType("publish");
-                SendMqMsgUtil.build()
-                        .openFeignClient(SpringContextUtils.getBean(EpmetMessageOpenFeignClient.class))
-                        .sendRocketMqMsg(SystemMessageType.PARTY_MEETING_MESSAGE, msg);
+        Date nowDate = new Date();
+        String dateId = DateUtils.format(nowDate, DateUtils.DATE_PATTERN_YYYYMMDDHHMM);
+        String min = dateId.substring(0, dateId.length() - 1);
+        log.info("自动发布活动开始，当前时间dateId=" + dateId + ";sql入参：" + min);
+        List<IcPartyActEntity> list = baseDao.selectNoPublishList(min);
+        if (CollectionUtils.isNotEmpty(list)) {
+            log.info("自动发布" + list.size() + "个活动");
+            for (IcPartyActEntity act : list) {
+                // 置为已发布
+                act.setIsPublish(NumConstant.ONE_STR);
+                baseDao.updateById(act);
+                // 选择了自动通知参加人员的，需要发送消息
+                if (NumConstant.ONE_STR.equals(act.getIsAutoInform())) {
+                    PartyMeetingMessageMQMsg msg = new PartyMeetingMessageMQMsg();
+                    msg.setCustomerId(act.getCustomerId());
+                    msg.setIcPartyActId(act.getId());
+                    msg.setType("publish");
+                    SendMqMsgUtil.build()
+                            .openFeignClient(SpringContextUtils.getBean(EpmetMessageOpenFeignClient.class))
+                            .sendRocketMqMsg(SystemMessageType.PARTY_MEETING_MESSAGE, msg);
+                }
             }
         }
     }