From be633ddaa674725e8a6860b73a20f6690a3da4ec Mon Sep 17 00:00:00 2001
From: zhn <947514737@qq.com>
Date: Fri, 28 Oct 2022 15:06:25 +0800
Subject: [PATCH] =?UTF-8?q?=E6=96=87=E6=A1=A3=E8=AE=A2=E9=98=85--=E7=BC=96?=
 =?UTF-8?q?=E8=BE=91=E6=97=B6=E5=8F=91=E6=B6=88=E6=81=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../system/entity/SysAnnouncement.java        |  4 +
 .../mapper/xml/SysAnnouncementSendMapper.xml  |  6 +-
 .../system/model/AnnouncementSendModel.java   |  4 +
 .../BussDocumentLibraryEOServiceImpl.java     | 77 ++++++++++++++++---
 .../impl/DummyInventoryBaseEOServiceImpl.java | 34 +++++++-
 .../modules/warn/service/LawsWarnService.java |  8 +-
 .../modules/warn/service/TimedTaskWarn.java   |  8 +-
 7 files changed, 124 insertions(+), 17 deletions(-)

diff --git a/jero-boot/jero-boot-module-system/src/main/java/com/jero/modules/system/entity/SysAnnouncement.java b/jero-boot/jero-boot-module-system/src/main/java/com/jero/modules/system/entity/SysAnnouncement.java
index 4da6a9046..fac7280f7 100644
--- a/jero-boot/jero-boot-module-system/src/main/java/com/jero/modules/system/entity/SysAnnouncement.java
+++ b/jero-boot/jero-boot-module-system/src/main/java/com/jero/modules/system/entity/SysAnnouncement.java
@@ -157,4 +157,8 @@ public class SysAnnouncement implements Serializable {
      * 发起人
      */
     private java.lang.String initiator;
+
+    private java.lang.String msgContentCn;//消息的中文(不带标签)
+
+    private java.lang.String msgContentInfoCn;//消息的中文(带标签)
 }
diff --git a/jero-boot/jero-boot-module-system/src/main/java/com/jero/modules/system/mapper/xml/SysAnnouncementSendMapper.xml b/jero-boot/jero-boot-module-system/src/main/java/com/jero/modules/system/mapper/xml/SysAnnouncementSendMapper.xml
index eeaf3e484..e8572c2ad 100644
--- a/jero-boot/jero-boot-module-system/src/main/java/com/jero/modules/system/mapper/xml/SysAnnouncementSendMapper.xml
+++ b/jero-boot/jero-boot-module-system/src/main/java/com/jero/modules/system/mapper/xml/SysAnnouncementSendMapper.xml
@@ -18,6 +18,8 @@
 		<result column="open_page" property="openPage" jdbcType="VARCHAR"/>
 		<result column="document_id" property="documentId" jdbcType="VARCHAR"/>
 		<result column="initiator" property="initiator" jdbcType="VARCHAR"/>
+		<result column="msg_content_cn" property="msgContentCn" jdbcType="VARCHAR"/>
+		<result column="msg_content_info_cn" property="msgContentInfoCn" jdbcType="VARCHAR"/>
 	</resultMap>
 
 	<select id="queryByUserId" parameterType="String"  resultType="String">
@@ -43,7 +45,9 @@
 			sa.open_page as open_page,
 			sa.msg_abstract,
 			sa.document_id as document_id,
-		    sa.initiator as initiator
+		    sa.initiator as initiator,
+		    sa.msg_content_cn as msg_content_cn,
+		    sa.msg_content_info_cn as msg_content_info_cn
 	   from sys_announcement_send sas
 	   left join sys_announcement sa ON sas.annt_id = sa.id
 	   where sa.del_flag = '0'
diff --git a/jero-boot/jero-boot-module-system/src/main/java/com/jero/modules/system/model/AnnouncementSendModel.java b/jero-boot/jero-boot-module-system/src/main/java/com/jero/modules/system/model/AnnouncementSendModel.java
index c06ddda74..97ceb8071 100644
--- a/jero-boot/jero-boot-module-system/src/main/java/com/jero/modules/system/model/AnnouncementSendModel.java
+++ b/jero-boot/jero-boot-module-system/src/main/java/com/jero/modules/system/model/AnnouncementSendModel.java
@@ -87,4 +87,8 @@ public class AnnouncementSendModel implements Serializable {
 	 */
 	private java.lang.String initiator;
 
+	private java.lang.String msgContentCn;//消息的中文(不带标签)
+
+	private java.lang.String msgContentInfoCn;//消息的中文(带标签)
+
 }
diff --git a/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/document/service/impl/BussDocumentLibraryEOServiceImpl.java b/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/document/service/impl/BussDocumentLibraryEOServiceImpl.java
index 4353c9894..6e4f72a1d 100644
--- a/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/document/service/impl/BussDocumentLibraryEOServiceImpl.java
+++ b/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/document/service/impl/BussDocumentLibraryEOServiceImpl.java
@@ -316,7 +316,14 @@ public class BussDocumentLibraryEOServiceImpl extends ServiceImpl<BussDocumentLi
             String contentInfo =content;
             String title = content;
             //封装消息的实体类
-            SysAnnouncement sysAnnouncement = getSysAnnouncement(userIdList, title, content, contentInfo,MessageTypeEnum.READ.getValue(),MessageTypeEnum.SYSTEMATIC_NOTIFICATION.getName());
+            SysAnnouncement sysAnnouncement = getSysAnnouncement(userIdList,
+                    title,
+                    content,
+                    contentInfo,
+                    MessageTypeEnum.READ.getValue(),
+                    MessageTypeEnum.SYSTEMATIC_NOTIFICATION.getName(),
+                    null,
+                    null);
             sysAnnouncementService.saveAnnouncement(sysAnnouncement);
             sendWebsocket(StringUtils.join(serialNumberList, ","), contentInfo);
         }
@@ -2202,7 +2209,14 @@ public class BussDocumentLibraryEOServiceImpl extends ServiceImpl<BussDocumentLi
                     + href +" has been updated.";
             String msgTitle = "The " + technologyTerritoryName + " technical field you subscribed to has been updated";
             //封装消息的实体类
-            SysAnnouncement sysAnnouncement = getSysAnnouncement(userIdList, msgTitle, content, contentInfo,MessageTypeEnum.READ.getValue(),MessageTypeEnum.SYSTEMATIC_NOTIFICATION.getName());
+            SysAnnouncement sysAnnouncement = getSysAnnouncement(userIdList,
+                    msgTitle,
+                    content,
+                    contentInfo,
+                    MessageTypeEnum.READ.getValue(),
+                    MessageTypeEnum.SYSTEMATIC_NOTIFICATION.getName(),
+                    null,
+                    null);
             sysAnnouncementService.saveAnnouncement(sysAnnouncement);
             sendWebsocket(idTemp, contentInfo);
             //飞书
@@ -3473,7 +3487,14 @@ public class BussDocumentLibraryEOServiceImpl extends ServiceImpl<BussDocumentLi
                 String contentInfo = "In the " + technologyTerritoryNameEn + " technical field you subscribed to," +sysUser.getUsername()+" changed the "+ href + " " + sbStr.toString();
                 String msgTitle = "The " + technologyTerritoryNameEn + " technical field you subscribed to has been updated";
                 // 封装消息的实体类
-                SysAnnouncement sysAnnouncement = getSysAnnouncement(userList, msgTitle, contentInfoFei, contentInfo,MessageTypeEnum.READ.getValue(),MessageTypeEnum.SYSTEMATIC_NOTIFICATION.getName());
+                SysAnnouncement sysAnnouncement = getSysAnnouncement(userList,
+                        msgTitle,
+                        contentInfoFei,
+                        contentInfo,
+                        MessageTypeEnum.READ.getValue(),
+                        MessageTypeEnum.SYSTEMATIC_NOTIFICATION.getName(),
+                        null,
+                        null);
                 sysAnnouncementService.saveAnnouncement(sysAnnouncement);
                 sendWebsocket((String) map.get("id"), contentInfo);
             }
@@ -3487,17 +3508,36 @@ public class BussDocumentLibraryEOServiceImpl extends ServiceImpl<BussDocumentLi
                     "&title=" + title +
                     "&serial_number=" + serialNumber + "'" + " target='_blank'>" + serialNumber + "</a>";
             String content = "";
-            if (StringUtils.isNotBlank(sbStr.toString())) {
+            if (StringUtils.isNotBlank(sbStr.toString()) && StringUtils.isNotBlank(sbStrCn)) {
                 //去掉a标签
                 sbStr = sbStr.replaceAll("<text class='highlight-class'>", "").replaceAll("</text>", "");
                 //您订阅的XXX已被修改
                 content = "In the "+category + " " + serialNumber+" you subscribed to, has been modified,Please pay attention to check.";
-                String contentInfo = "In the "+category + " " + href+" you subscribed to, "+sysUser.getUsername()+" changed the "+ href + " " + sbStr.toString();
+                //内容详情--英文(不带标签)
+                String contentInfoNo = "In the "+category + " " + serialNumber+" you subscribed to, "+ sbStr.toString();
+
+                //内容详情--英文(带标签)
+                String contentInfoYes = "In the "+category + " " + href+" you subscribed to, "+ sbStr.toString();
+
                 String msgTitle = serialNumber + " you subscribed to has been updated";
+                //内容详情-中文(不带标签)
+                String sbStrCnTemp = sbStrCn.replaceAll("<text class='highlight-class'>", "").replaceAll("</text>", "");
+                String contentCnNo = "您所订阅的"+categoryCn+serialNumber+","+sbStrCnTemp;
+
+                //内容详情--中文(带标签)
+                String contentInfoCnReplace = sbStrCn.replaceAll("<text class='highlight-class'>","").replaceAll("</text>","");
+                String contentInfoCnYes ="您所订阅的"+categoryCn+href+","+contentInfoCnReplace;;
                 //封装消息的实体类
-                SysAnnouncement sysAnnouncement = getSysAnnouncement(userIdListUpdate, msgTitle, content, contentInfo,MessageTypeEnum.READ.getValue(),MessageTypeEnum.SYSTEMATIC_NOTIFICATION.getName());
+                SysAnnouncement sysAnnouncement = getSysAnnouncement(userIdListUpdate,
+                        msgTitle,
+                        contentInfoNo,
+                        contentInfoYes,
+                        MessageTypeEnum.READ.getValue(),
+                        MessageTypeEnum.SYSTEMATIC_NOTIFICATION.getName(),
+                        contentCnNo,
+                        contentInfoCnYes);
                 sysAnnouncementService.saveAnnouncement(sysAnnouncement);
-                sendWebsocket((String) map.get("id"), contentInfo);
+                sendWebsocket((String) map.get("id"), contentInfoYes);
             }
             //订阅文档的飞书消息
             try {
@@ -3593,7 +3633,13 @@ public class BussDocumentLibraryEOServiceImpl extends ServiceImpl<BussDocumentLi
         String contentInfo = "New numbering implemented, please note update status of alternate numbering " + sbStr;
         String msgTitle = contentInfo;
         //封装消息的实体类
-        SysAnnouncement sysAnnouncement = getSysAnnouncement(userIdList, msgTitle, content, contentInfo,MessageTypeEnum.READ.getValue(),MessageTypeEnum.SYSTEMATIC_NOTIFICATION.getName());
+        SysAnnouncement sysAnnouncement = getSysAnnouncement(userIdList,
+                msgTitle,
+                content,
+                contentInfo,MessageTypeEnum.READ.getValue(),
+                MessageTypeEnum.SYSTEMATIC_NOTIFICATION.getName(),
+                null,
+                null);
         sysAnnouncementService.saveAnnouncement(sysAnnouncement);
         sendWebsocket(StringUtils.join(serialNumberListTemp, ","), contentInfo);
         //飞书
@@ -3621,7 +3667,9 @@ public class BussDocumentLibraryEOServiceImpl extends ServiceImpl<BussDocumentLi
                                               String content,
                                               String contentInfo,
                                               String messageType,
-                                              String initiator) {
+                                              String initiator,
+                                              String contentCn,
+                                              String contentInfoCn) {
         SysAnnouncement sysAnnouncement = new SysAnnouncement();
         sysAnnouncement.setInitiator(initiator);
         sysAnnouncement.setDelFlag("0");
@@ -3633,6 +3681,8 @@ public class BussDocumentLibraryEOServiceImpl extends ServiceImpl<BussDocumentLi
         sysAnnouncement.setTitile(title);
         sysAnnouncement.setMsgContent(content);
         sysAnnouncement.setMsgContentInfo(contentInfo);
+        sysAnnouncement.setMsgContentCn(contentCn);
+        sysAnnouncement.setMsgContentInfoCn(contentInfoCn);
         sysAnnouncement.setUserIds(StringUtils.join(userIdList, ","));
         return sysAnnouncement;
     }
@@ -5193,7 +5243,14 @@ public class BussDocumentLibraryEOServiceImpl extends ServiceImpl<BussDocumentLi
 //        String title = StringUtils.join(serialNumberList, ",") +  " has been pushed to you, please check";
 
         //封装消息的实体类
-        SysAnnouncement sysAnnouncement = getSysAnnouncement(userIdList, title, content, contentInfo,MessageTypeEnum.PUSH.getValue(),MessageTypeEnum.SYSTEMATIC_NOTIFICATION.getName());
+        SysAnnouncement sysAnnouncement = getSysAnnouncement(userIdList,
+                title,
+                content,
+                contentInfo,
+                MessageTypeEnum.PUSH.getValue(),
+                MessageTypeEnum.SYSTEMATIC_NOTIFICATION.getName(),
+                null,
+                null);
         sysAnnouncementService.saveAnnouncement(sysAnnouncement);
         sendWebsocket(StringUtils.join(thirdIdList, ","), contentInfo);
         //飞书
diff --git a/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/dummy/service/impl/DummyInventoryBaseEOServiceImpl.java b/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/dummy/service/impl/DummyInventoryBaseEOServiceImpl.java
index 69cd72ba6..9c7fbcbe0 100644
--- a/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/dummy/service/impl/DummyInventoryBaseEOServiceImpl.java
+++ b/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/dummy/service/impl/DummyInventoryBaseEOServiceImpl.java
@@ -442,7 +442,14 @@ public class DummyInventoryBaseEOServiceImpl extends ServiceImpl<DummyInventoryB
                                 if(userIdList.size() != 0){
                                     //封装消息的实体类
                                     String title = "The "+ baseEO.getName()+" virtual list you subscribed to has been updated.";
-                                    SysAnnouncement sysAnnouncement = bussDocumentLibraryEOService.getSysAnnouncement(userIdList, title, title, contentLog,MessageTypeEnum.READ.getValue(),MessageTypeEnum.SYSTEMATIC_NOTIFICATION.getName());
+                                    SysAnnouncement sysAnnouncement = bussDocumentLibraryEOService.getSysAnnouncement(userIdList,
+                                            title,
+                                            title,
+                                            contentLog,
+                                            MessageTypeEnum.READ.getValue(),
+                                            MessageTypeEnum.SYSTEMATIC_NOTIFICATION.getName(),
+                                            null,
+                                            null);
                                     sysAnnouncementService.saveAnnouncement(sysAnnouncement);
                                     bussDocumentLibraryEOService.sendWebsocket(dummyInventoryBaseEO.getId(), title);
                                 }
@@ -492,7 +499,13 @@ public class DummyInventoryBaseEOServiceImpl extends ServiceImpl<DummyInventoryB
                         String title = "The "+ baseEO.getName()+" virtual list you subscribed to has been withdrawn.";
                         //Please note that the XX virtual list you subscribed to has been withdrawn.
                         String contentLog = "Please note that the "+ baseEO.getName()+" virtual list you subscribed to has been withdrawn.";
-                        SysAnnouncement sysAnnouncement = bussDocumentLibraryEOService.getSysAnnouncement(userIdList, title, title, contentLog,MessageTypeEnum.READ.getValue(),MessageTypeEnum.SYSTEMATIC_NOTIFICATION.getName());
+                        SysAnnouncement sysAnnouncement = bussDocumentLibraryEOService.getSysAnnouncement(userIdList,
+                                title,
+                                title,
+                                contentLog,
+                                MessageTypeEnum.READ.getValue(),
+                                MessageTypeEnum.SYSTEMATIC_NOTIFICATION.getName(),
+                                null,null);
                         sysAnnouncementService.saveAnnouncement(sysAnnouncement);
                         bussDocumentLibraryEOService.sendWebsocket(dummyInventoryBaseEO.getId(), title);
                     }
@@ -1371,7 +1384,14 @@ public class DummyInventoryBaseEOServiceImpl extends ServiceImpl<DummyInventoryB
 
                     msgTitle = "The " + baseName + " virtual list you subscribed to has been updated";
                     //封装消息的实体类
-                    SysAnnouncement sysAnnouncement = bussDocumentLibraryEOService.getSysAnnouncement(userIdList, msgTitle, content, contentInfo,MessageTypeEnum.READ.getValue(),MessageTypeEnum.SYSTEMATIC_NOTIFICATION.getName());
+                    SysAnnouncement sysAnnouncement = bussDocumentLibraryEOService.getSysAnnouncement(userIdList,
+                            msgTitle,
+                            content,
+                            contentInfo,
+                            MessageTypeEnum.READ.getValue(),
+                            MessageTypeEnum.SYSTEMATIC_NOTIFICATION.getName(),
+                            null,
+                            null);
                     sysAnnouncementService.saveAnnouncement(sysAnnouncement);
                     bussDocumentLibraryEOService.sendWebsocket(idTemp, contentInfo);
                     //飞书
@@ -1385,7 +1405,13 @@ public class DummyInventoryBaseEOServiceImpl extends ServiceImpl<DummyInventoryB
                     contentInfo = "Please note that the "+baseName+" virtual list you subscribed to has been withdrawn.";
                     msgTitle = "The " + baseName + " virtual list you subscribed to has been withdrawn";
                     //封装消息的实体类
-                    SysAnnouncement sysAnnouncement = bussDocumentLibraryEOService.getSysAnnouncement(userIdList, msgTitle, content, contentInfo,MessageTypeEnum.READ.getValue(),MessageTypeEnum.SYSTEMATIC_NOTIFICATION.getName());
+                    SysAnnouncement sysAnnouncement = bussDocumentLibraryEOService.getSysAnnouncement(userIdList,
+                            msgTitle,
+                            content,
+                            contentInfo,
+                            MessageTypeEnum.READ.getValue(),
+                            MessageTypeEnum.SYSTEMATIC_NOTIFICATION.getName(),
+                            null,null);
                     sysAnnouncementService.saveAnnouncement(sysAnnouncement);
                     bussDocumentLibraryEOService.sendWebsocket(idTemp, contentInfo);
                     //飞书
diff --git a/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/warn/service/LawsWarnService.java b/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/warn/service/LawsWarnService.java
index 881946767..93e4cb4f6 100644
--- a/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/warn/service/LawsWarnService.java
+++ b/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/warn/service/LawsWarnService.java
@@ -421,7 +421,13 @@ public class LawsWarnService {
         String title = content;
 
         //封装消息的实体类
-        SysAnnouncement sysAnnouncement = bussDocumentLibraryEOService.getSysAnnouncement(userIdList, title, content, contentInfo,MessageTypeEnum.PUSH.getValue(),MessageTypeEnum.SYSTEMATIC_NOTIFICATION.getName());
+        SysAnnouncement sysAnnouncement = bussDocumentLibraryEOService.getSysAnnouncement(userIdList,
+                title,
+                content,
+                contentInfo,
+                MessageTypeEnum.PUSH.getValue(),
+                MessageTypeEnum.SYSTEMATIC_NOTIFICATION.getName(),
+                null,null);
         sysAnnouncementService.saveAnnouncement(sysAnnouncement);
         bussDocumentLibraryEOService.sendWebsocket(StringUtils.join(thirdIdList, ","), contentInfo);
         //飞书
diff --git a/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/warn/service/TimedTaskWarn.java b/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/warn/service/TimedTaskWarn.java
index 204629c96..f8cc2140e 100644
--- a/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/warn/service/TimedTaskWarn.java
+++ b/jero-boot/jero-boot-modules/src/main/java/com/jero/modules/warn/service/TimedTaskWarn.java
@@ -227,7 +227,13 @@ public class TimedTaskWarn implements Job {
     private void sendMessage(String title, String content,String contentInfo,String contentFeiShu, String url, List<String> userIdList, List<String> thirdIdList) {
         //站内消息
         //封装消息的实体类
-        SysAnnouncement sysAnnouncement = bussDocumentLibraryEOService.getSysAnnouncement(userIdList, title, content, contentInfo,MessageTypeEnum.WARN.getValue(),MessageTypeEnum.SYSTEMATIC_NOTIFICATION.getName());
+        SysAnnouncement sysAnnouncement = bussDocumentLibraryEOService.getSysAnnouncement(userIdList,
+                title,
+                content,
+                contentInfo,
+                MessageTypeEnum.WARN.getValue(),
+                MessageTypeEnum.SYSTEMATIC_NOTIFICATION.getName(),
+                null,null);
         sysAnnouncementService.saveAnnouncement(sysAnnouncement);
         bussDocumentLibraryEOService.sendWebsocket(StringUtils.join(userIdList, ","), content);