From 4601316438d6cce2c8bbd6bd4a20de2378da6b21 Mon Sep 17 00:00:00 2001
From: hyingbo <1363390067@qq.com>
Date: 星期三, 04 六月 2025 18:06:21 +0800
Subject: [PATCH] 我的消息添加状态筛选

---
 lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/system/service/impl/SysAnnouncementSendServiceImpl.java |   41 ++++++++++++++++++++++++++++++++++++++++-
 1 files changed, 40 insertions(+), 1 deletions(-)

diff --git a/lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/system/service/impl/SysAnnouncementSendServiceImpl.java b/lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/system/service/impl/SysAnnouncementSendServiceImpl.java
index 941b114..683394e 100644
--- a/lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/system/service/impl/SysAnnouncementSendServiceImpl.java
+++ b/lxzn-module-system/lxzn-system-biz/src/main/java/org/jeecg/modules/system/service/impl/SysAnnouncementSendServiceImpl.java
@@ -1,13 +1,18 @@
 package org.jeecg.modules.system.service.impl;
 
-import java.util.List;
+import java.util.*;
+import java.util.stream.Collectors;
 
 import javax.annotation.Resource;
 
+import org.apache.commons.compress.utils.Lists;
+import org.apache.commons.lang3.StringUtils;
+import org.jeecg.common.constant.CommonConstant;
 import org.jeecg.modules.system.entity.SysAnnouncementSend;
 import org.jeecg.modules.system.mapper.SysAnnouncementSendMapper;
 import org.jeecg.modules.system.model.AnnouncementSendModel;
 import org.jeecg.modules.system.service.ISysAnnouncementSendService;
+import org.jeecg.modules.system.vo.OptionsVo;
 import org.springframework.stereotype.Service;
 
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
@@ -33,6 +38,16 @@
 	@Override
 	public Page<AnnouncementSendModel> getMyAnnouncementSendPage(Page<AnnouncementSendModel> page,
 			AnnouncementSendModel announcementSendModel) {
+
+		List<String> msgCategory = Lists.newArrayList();
+		if ("绯荤粺娑堟伅".equals(announcementSendModel.getMsgCategory())) {
+			msgCategory.addAll(Arrays.asList("绯荤粺娑堟伅", "2"));
+		}else if ("閫氱煡鍏憡".equals(announcementSendModel.getMsgCategory())) {
+			msgCategory.addAll(Arrays.asList("閫氱煡鍏憡", "1"));
+		}else if (StringUtils.isNotBlank(announcementSendModel.getMsgCategory())){
+			msgCategory.addAll(Arrays.asList(announcementSendModel.getMsgCategory()));
+		}
+		announcementSendModel.setMsgCategoryList(msgCategory);
 		 return page.setRecords(sysAnnouncementSendMapper.getMyAnnouncementSendList(page, announcementSendModel));
 	}
 
@@ -46,4 +61,28 @@
 		return baseMapper.getPrimaryInfo(userId,msgCategoryList);
 	}
 
+	@Override
+	public List<OptionsVo> getMessageType() {
+		Set<OptionsVo> result = new HashSet<>();
+        List<String> messageTypeList = this.baseMapper.getMessageType();
+        if (messageTypeList != null && !messageTypeList.isEmpty()) {
+            for (String messageType : messageTypeList) {
+				OptionsVo optionsVo = new OptionsVo();
+				String label = messageType;
+				String value = messageType;
+				if (CommonConstant.MSG_CATEGORY_2.equals(messageType)) {
+					label = "绯荤粺娑堟伅";
+					value = "绯荤粺娑堟伅";
+				} else if (CommonConstant.MSG_CATEGORY_1.equals(messageType)) {
+					label = "閫氱煡鍏憡";
+					value = "閫氱煡鍏憡";
+				}
+				optionsVo.setLabel(label);
+				optionsVo.setValue(value);
+                result.add(optionsVo);
+            }
+        }
+        return new ArrayList<>(result);
+	}
+
 }

--
Gitblit v1.9.3