From 6e458db0e401e6f9ac5f37169d79af1a8b6aa0fc Mon Sep 17 00:00:00 2001
From: wuyu <wuyu@axzo.cn>
Date: Mon, 27 Nov 2023 13:42:40 +0800
Subject: [PATCH] =?UTF-8?q?+=E6=89=A7=E8=A1=8C=E4=BA=BA=E8=BF=87=E6=BB=A4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../impl/PendingMessageNewServiceImpl.java    |  2 +-
 .../mapper/PendingMessageRecordMapper.java    |  3 ++-
 .../mapper/PendingMessageRecordMapper.xml     | 27 +++++++++----------
 3 files changed, 15 insertions(+), 17 deletions(-)

diff --git a/inside-notices/src/main/java/cn/axzo/msg/center/message/service/impl/PendingMessageNewServiceImpl.java b/inside-notices/src/main/java/cn/axzo/msg/center/message/service/impl/PendingMessageNewServiceImpl.java
index d8e6ddca..5aca46c0 100644
--- a/inside-notices/src/main/java/cn/axzo/msg/center/message/service/impl/PendingMessageNewServiceImpl.java
+++ b/inside-notices/src/main/java/cn/axzo/msg/center/message/service/impl/PendingMessageNewServiceImpl.java
@@ -169,7 +169,7 @@ public class PendingMessageNewServiceImpl implements PendingMessageNewService {
     public List<PendingMessageResponse> getPendingMessageByAppWorker(PendingMessageFixedTemplatePageRequest request) {
         List<PendingMessageResponse> result = new ArrayList<>();
         PendingCalendarCodeDTO calendarCodeDTO = buildCalendarCodesDTO(calendarCodeConfig);
-        List<PendingMessageRecord> pendingMessageRecords = pendingMessageRecordMapper.queryByTemplateCodes(calendarCodeDTO,request.getWorkspaceId(),request.getSelectDate());
+        List<PendingMessageRecord> pendingMessageRecords = pendingMessageRecordMapper.queryByTemplateCodes(calendarCodeDTO,request.getWorkspaceId(),request.getSelectDate(),request.getPersonId());
         List<MessageTemplateDTO> messageTemplates = messageTemplateNewService.listByTemplateCodes(calendarCodeConfig.getCalendarAllCodes());
         result = pendingMessageRecords.stream()
                 .map(e -> convert(e, messageTemplates).toResponse(request.getTerminalType()))
diff --git a/msg-center-dal/src/main/java/cn/axzo/msg/center/dal/mapper/PendingMessageRecordMapper.java b/msg-center-dal/src/main/java/cn/axzo/msg/center/dal/mapper/PendingMessageRecordMapper.java
index fb52becc..374e2ce1 100644
--- a/msg-center-dal/src/main/java/cn/axzo/msg/center/dal/mapper/PendingMessageRecordMapper.java
+++ b/msg-center-dal/src/main/java/cn/axzo/msg/center/dal/mapper/PendingMessageRecordMapper.java
@@ -16,6 +16,7 @@ import java.util.List;
  * @version 1.0
  */
 public interface PendingMessageRecordMapper extends BaseMapper<PendingMessageRecord> {
-    List<PendingMessageRecord> queryByTemplateCodes(@Param("pendingCalendarCodeDTO") PendingCalendarCodeDTO pendingCalendarCodeDTO, @Param("workspaceId") Long workspaceId, @Param("selectDate") Date selectDate);
+    List<PendingMessageRecord> queryByTemplateCodes(@Param("pendingCalendarCodeDTO") PendingCalendarCodeDTO pendingCalendarCodeDTO, @Param("workspaceId") Long workspaceId,
+                                                    @Param("selectDate") Date selectDate, @Param("personId") Long personId);
 }
 
diff --git a/msg-center-dal/src/main/resources/mapper/PendingMessageRecordMapper.xml b/msg-center-dal/src/main/resources/mapper/PendingMessageRecordMapper.xml
index 02b314d6..9cc53856 100644
--- a/msg-center-dal/src/main/resources/mapper/PendingMessageRecordMapper.xml
+++ b/msg-center-dal/src/main/resources/mapper/PendingMessageRecordMapper.xml
@@ -9,30 +9,27 @@
     </sql>
 
     <select id="queryByTemplateCodes" resultType="cn.axzo.msg.center.domain.entity.PendingMessageRecord">
-        select * from (SELECT * FROM (SELECT * FROM pending_message_record WHERE org_id=326 AND DATE(create_at) <![CDATA[<]]> CURDATE() AND state IN('HAS_BEEN_SENT')
-        AND template_code IN('d1d4793c84e14d20ae1cbc399338efa3','367ba552bb374049a73e737ac3b8b08c') ORDER BY create_at ASC) old_pending_message
-        UNION ALL
-        SELECT * FROM(SELECT * FROM pending_message_record WHERE org_id=326 AND DATE(create_at) = CURDATE() AND state IN('HAS_BEEN_SENT','COMPLETED')
-        AND template_code IN('d1d4793c84e14d20ae1cbc399338efa3','367ba552bb374049a73e737ac3b8b08c') ORDER BY create_at DESC) new_pending_message
-        UNION ALL
-        SELECT * FROM(SELECT * FROM pending_message_record WHERE org_id=326 AND DATE(create_at) = CURDATE() AND state IN('HAS_BEEN_SENT','COMPLETED')
-        AND template_code IN('出厂打卡') ORDER BY create_at DESC) new_pending_message1
-        UNION ALL
-        SELECT * FROM(SELECT * FROM pending_message_record WHERE org_id=326 AND DATE(create_at) = CURDATE() AND state IN('HAS_BEEN_SENT','COMPLETED')
-        AND template_code IN('进场打卡') ORDER BY create_at DESC) new_pending_message2)aa
+        SELECT * FROM pending_message_record WHERE DATE(create_at) = DATE(#{selectDate})
+        AND template_code IN<foreach collection="pendingCalendarCodeDTO.constructionCodes" index="index" item="item" open="(" separator="," close=")">
+            #{item}
+        </foreach>
+        AND executor_id=#{personId}
+        ORDER BY create_at DESC
+
+
         <!--select * from (
-        SELECT * FROM (SELECT * FROM pending_message_record WHERE DATE(create_at) <![CDATA[<]]> #{selectDate} AND state IN('HAS_BEEN_SENT')
+        SELECT * FROM (SELECT * FROM pending_message_record WHERE DATE(create_at) <![CDATA[<]]> DATE(#{selectDate}) AND state IN('HAS_BEEN_SENT')
         AND template_code IN('d1d4793c84e14d20ae1cbc399338efa3','367ba552bb374049a73e737ac3b8b08c')
         <if test="workspaceId != null"> AND org_id=#{workspaceId} </if>
         ORDER BY create_at ASC) old_pending_message
         UNION ALL
-        SELECT * FROM(SELECT * FROM pending_message_record WHERE DATE(create_at) = #{selectDate}
+        SELECT * FROM(SELECT * FROM pending_message_record WHERE DATE(create_at) = DATE(#{selectDate})
         AND template_code IN('d1d4793c84e14d20ae1cbc399338efa3','367ba552bb374049a73e737ac3b8b08c') <if test="workspaceId != null"> AND org_id=#{workspaceId} </if>  ORDER BY create_at DESC) new_pending_message
         UNION ALL
-        SELECT * FROM(SELECT * FROM pending_message_record WHERE DATE(create_at) = #{selectDate} AND state IN('HAS_BEEN_SENT','COMPLETED')
+        SELECT * FROM(SELECT * FROM pending_message_record WHERE DATE(create_at) = DATE(#{selectDate}) AND state IN('HAS_BEEN_SENT','COMPLETED')
         AND template_code IN('出厂打卡') <if test="workspaceId != null"> AND org_id=#{workspaceId} </if>  ORDER BY create_at DESC) new_pending_message1
         UNION ALL
-        SELECT * FROM(SELECT * FROM pending_message_record WHERE DATE(create_at) = #{selectDate} AND state IN('HAS_BEEN_SENT','COMPLETED')
+        SELECT * FROM(SELECT * FROM pending_message_record WHERE DATE(create_at) = DATE(#{selectDate}) AND state IN('HAS_BEEN_SENT','COMPLETED')
         AND template_code IN('进场打卡') <if test="workspaceId != null"> AND org_id=#{workspaceId} </if>  ORDER BY create_at DESC) new_pending_message2
         )cc-->
     </select>