自动发布时间的前3天提醒：您有一个活动3天后即将自动发布

epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partyOrg/dao/IcPartyActDao.java

@@ -44,4 +44,6 @@ public interface IcPartyActDao extends BaseDao<IcPartyActEntity> {
     int deleteIcPartyAct(@Param("customerId") String customerId, @Param("userId")String userId, @Param("icPartyActId")String icPartyActId);
 
     List<IcPartyActListResultDTO> selectresiPartyActList(IcPartyActListFormDTO formDTO);
+
+    List<IcPartyActEntity> selectNeedRemindAutoPublishAct(String afterThreeDayDate);
 }

epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partyOrg/service/impl/IcPartyActServiceImpl.java

@@ -663,9 +663,22 @@ public class IcPartyActServiceImpl extends BaseServiceImpl<IcPartyActDao, IcPart
 
     @Override
     public void noticePartyActAutoPublishTask() {
-        //todo
-
-        return;
+        Date nowDate=new Date();
+        Date afterThreeDayDate=DateUtils.calDateBaseDay(nowDate,3);
+        // log.info("现在时间:"+DateUtils.format(nowDate,"yyyy-MM-dd HH:mm:ss")+";3天后="+DateUtils.format(afterThreeDayDate,"yyyy-MM-dd HH:mm:ss"));
+        //现在时间:2022-08-22 17:11:49;3天后=2022-08-25 17:11:49
+        //dateId:20220825
+        String dateId=DateUtils.format(afterThreeDayDate,DateUtils.DATE_PATTERN_YYYYMMDD);
+        List<IcPartyActEntity> list=baseDao.selectNeedRemindAutoPublishAct(dateId);
+        for(IcPartyActEntity act:list){
+            PartyMeetingMessageMQMsg msg = new PartyMeetingMessageMQMsg();
+            msg.setCustomerId(act.getCustomerId());
+            msg.setIcPartyActId(act.getId());
+            msg.setType("remind");
+            SendMqMsgUtil.build()
+                    .openFeignClient(SpringContextUtils.getBean(EpmetMessageOpenFeignClient.class))
+                    .sendRocketMqMsg(SystemMessageType.PARTY_MEETING_MESSAGE, msg);
+        }
     }
 
 }

epmet-module/resi-partymember/resi-partymember-server/src/main/resources/mapper/partyOrg/IcPartyActDao.xml

@@ -205,4 +205,19 @@
         where customerId=#{customerId}
         and id=#{icPartyActId}
     </update>
+
+    <select id="selectNeedRemindAutoPublishAct" parameterType="java.lang.String" resultType="com.epmet.modules.partyOrg.entity.IcPartyActEntity">
+        SELECT
+            a.ID,
+            a.CUSTOMER_ID,
+            a.PUBLISH_STAFF_ID,
+            a.AUTO_PUBLIC_TYPE,
+            a.AUTO_PUBLIC_TIME
+        FROM
+            ic_party_act a
+        WHERE
+            a.DEL_FLAG = '0'
+          AND a.IS_PUBLISH = '0'
+          AND DATE_FORMAT(a.AUTO_PUBLIC_TIME,'%Y%m%d') =#{afterThreeDayDate}
+    </select>
 </mapper>