发送消息通知

api-module/src/test/java/com/tzld/piaoquan/api/ContentPlatformTest.java

@@ -2,9 +2,11 @@ package com.tzld.piaoquan.api;
 
 import com.aliyun.openservices.shade.com.google.common.collect.Sets;
 import com.tzld.piaoquan.api.dao.mapper.contentplatform.ContentPlatformAccountMapper;
+import com.tzld.piaoquan.api.dao.mapper.contentplatform.ContentPlatformIllegalMsgMapper;
 import com.tzld.piaoquan.api.job.contentplatform.ContentPlatformDatastatJob;
 import com.tzld.piaoquan.api.model.po.contentplatform.ContentPlatformAccount;
 import com.tzld.piaoquan.api.model.po.contentplatform.ContentPlatformAccountExample;
+import com.tzld.piaoquan.api.model.po.contentplatform.ContentPlatformIllegalMsg;
 import com.tzld.piaoquan.growth.common.model.bo.VideoDetail;
 import com.tzld.piaoquan.growth.common.service.MessageAttachmentService;
 import com.tzld.piaoquan.growth.common.utils.DateUtil;
@@ -30,6 +32,8 @@ public class ContentPlatformTest {
     MessageAttachmentService messageAttachmentService;
     @Autowired
     ContentPlatformAccountMapper accountMapper;
+    @Autowired
+    private ContentPlatformIllegalMsgMapper contentPlatformIllegalMsgMapper;
 
     @Test
     public void testSyncContentPlatformQwDatastatReplyTotalJob() {
@@ -89,4 +93,28 @@ public class ContentPlatformTest {
         return matcher.replaceAll("$1" + newValue);
     }
 
+    @Test
+    public void sendIllegalMsg() {
+        List<String> channels = Arrays.asList("yy","yygz","ls","xs","zqh","cy","qs","bh","jxyy","yqst","sw","sxzq","bz","gzdd","gzbb","gzxts","gzyhc","gzlq","wxm","hc","hzrf","ywlx","zc","hzqf","qd","zh","pj","szhx","zzws","llf","shx","lq","zzbf","xsy","ml","xmayd","wx","hnld","gzash","xf","jyxx","htlz","hzlcz","gzyd");
+        ContentPlatformAccountExample example = new ContentPlatformAccountExample();
+        example.createCriteria().andChannelIn(channels);
+        List<ContentPlatformAccount> accountList = accountMapper.selectByExample(example);
+        for (ContentPlatformAccount contentPlatformAccount : accountList) {
+            ContentPlatformIllegalMsg msg = new ContentPlatformIllegalMsg();
+            msg.setAccountId(contentPlatformAccount.getId());
+            msg.setStatus(0);
+            msg.setIllegalTitle("平台【本渠道裂变率】概念调整通知");
+            msg.setIllegalContent("尊敬的用户：\n" +
+                    "\n" +
+                    "为优化体验、规范信息传递，平台将公众号-自动回复的【本渠道裂变率】调整为【本渠道质量分】。新字段整合裂变、arpu等维度的效率数值，综合反映渠道质量表现。\n" +
+                    "\n" +
+                    "本次调整于2026年1月8日正式生效，不影响用户核心权益。如有疑问，可联系商务反馈。\n" +
+                    "\n" +
+                    "2026年1月8日");
+            msg.setCreateTimestamp(System.currentTimeMillis());
+            msg.setUpdateTimestamp(System.currentTimeMillis());
+            contentPlatformIllegalMsgMapper.insertSelective(msg);
+        }
+    }
+
 }