From a97c1206b36cc796bb6e1a8163d3ce9f0efda121 Mon Sep 17 00:00:00 2001
From: yinzuomei <576302893@qq.com>
Date: Mon, 22 Aug 2022 17:15:34 +0800
Subject: [PATCH] =?UTF-8?q?=E8=87=AA=E5=8A=A8=E5=8F=91=E5=B8=83=E6=97=B6?=
 =?UTF-8?q?=E9=97=B4=E7=9A=84=E5=89=8D3=E5=A4=A9=E6=8F=90=E9=86=92?=
 =?UTF-8?q?=EF=BC=9A=E6=82=A8=E6=9C=89=E4=B8=80=E4=B8=AA=E6=B4=BB=E5=8A=A8?=
 =?UTF-8?q?3=E5=A4=A9=E5=90=8E=E5=8D=B3=E5=B0=86=E8=87=AA=E5=8A=A8?=
 =?UTF-8?q?=E5=8F=91=E5=B8=83?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../modules/partyOrg/dao/IcPartyActDao.java   |  2 ++
 .../service/impl/IcPartyActServiceImpl.java   | 19 ++++++++++++++++---
 .../mapper/partyOrg/IcPartyActDao.xml         | 15 +++++++++++++++
 3 files changed, 33 insertions(+), 3 deletions(-)

diff --git a/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partyOrg/dao/IcPartyActDao.java b/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partyOrg/dao/IcPartyActDao.java
index 5426dfc9e4..e8b0f11dfc 100644
--- a/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partyOrg/dao/IcPartyActDao.java
+++ b/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);
 }
\ No newline at end of file
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 347f62a79d..a10b817418 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
@@ -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);
+        }
     }
 
 }
\ No newline at end of file
diff --git a/epmet-module/resi-partymember/resi-partymember-server/src/main/resources/mapper/partyOrg/IcPartyActDao.xml b/epmet-module/resi-partymember/resi-partymember-server/src/main/resources/mapper/partyOrg/IcPartyActDao.xml
index 414f5ca590..7ed122e31a 100644
--- a/epmet-module/resi-partymember/resi-partymember-server/src/main/resources/mapper/partyOrg/IcPartyActDao.xml
+++ b/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>
\ No newline at end of file