Explorar o código

课表发布消息推送调整

dzx hai 6 meses
pai
achega
df9b12330f

+ 4 - 1
src/main/java/com/xjrsoft/module/job/JianyuekbScheduleTask.java

@@ -57,6 +57,7 @@ import org.springframework.scheduling.annotation.Async;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
+import java.text.SimpleDateFormat;
 import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
@@ -290,6 +291,8 @@ public class JianyuekbScheduleTask {
         List<Map<String, Object>> userList1 = SqlRunnerAdapter.db().selectList(sql);
         userList.addAll(userList1);
 
+        LocalDateTime createDate = (LocalDateTime) receiveMsg.get("create_date");
+        String createDateStr = createDate.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
         for (Map<String, Object> user : userList) {
             try {
                 WeChatSendMessageDto weChatSendMessageDto = new WeChatSendMessageDto();
@@ -309,7 +312,7 @@ public class JianyuekbScheduleTask {
                 paramJson.put("thing6", thing6);
 
                 JSONObject time3 = new JSONObject();
-                time3.put("value", receiveMsg.get("create_date").toString());
+                time3.put("value", createDateStr);
                 paramJson.put("time3", time3);
 
                 weChatSendMessageDto.setContent(paramJson);

+ 1 - 1
src/main/resources/application.yml

@@ -5,7 +5,7 @@ server:
 spring:
   # 环 io境 dev|pre|prod
   profiles:
-    active: pre
+    active: dev
   # jackson时间格式化
   jackson:
     time-zone: GMT+8

+ 3 - 10
src/test/java/com/xjrsoft/module/job/AttenDanceWarnNoticeTaskTest.java

@@ -52,9 +52,6 @@ class AttenDanceWarnNoticeTaskTest {
     @Autowired
     private WeChatUtil weChatUtil;
 
-    @Autowired
-    private IWechatMessageLogService wechatMessageLogService;
-
     @Test
     public void RefreshConnectionPool() {
         String active = SpringUtil.getActiveProfile();
@@ -114,9 +111,9 @@ class AttenDanceWarnNoticeTaskTest {
         //判断所有当前时间下,哪几条规则需要进行提醒
         Map<Long, Integer> ruleDetailsJudgeMap = judgeExecuteNotice(now, ruleDetailsList, recentlyTime);
 
-        WechatMessageLog messageLog = new WechatMessageLog();
-        messageLog.setTemplateId(wechatTemplate);
-        messageLog.setSendTime(recentlyTime);
+//        WechatMessageLog messageLog = new WechatMessageLog();
+//        messageLog.setTemplateId(wechatTemplate);
+//        messageLog.setSendTime(recentlyTime);
 
         List<XjrUser> userList = getUserList(allTodyRule.keySet());
         for (XjrUser xjrUser : userList) {
@@ -160,10 +157,6 @@ class AttenDanceWarnNoticeTaskTest {
             weChatService.sendTemplateMessage(weChatSendMessageDto);
         }
 
-        messageLog.setCreateDate(new Date());
-        messageLog.setContent("消息推送人数:" + userList.size());
-        wechatMessageLogService.save(messageLog);
-
     }
 
     /**

+ 23 - 4
src/test/java/com/xjrsoft/xjrsoftboot/KbTest.java

@@ -2,29 +2,48 @@ package com.xjrsoft.xjrsoftboot;
 
 
 import cn.hutool.core.lang.Console;
+import cn.hutool.db.Entity;
 import cn.hutool.poi.excel.ExcelUtil;
 import cn.hutool.poi.excel.sax.handler.RowHandler;
+import com.xjrsoft.XjrSoftApplication;
+import com.xjrsoft.common.mybatis.SqlRunnerAdapter;
 import org.junit.jupiter.api.Test;
+import org.junit.runner.RunWith;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.junit4.SpringRunner;
 
 import java.io.BufferedReader;
 import java.io.File;
 import java.io.FileNotFoundException;
 import java.io.FileReader;
 import java.io.IOException;
+import java.text.SimpleDateFormat;
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
 import java.util.Arrays;
+import java.util.Date;
 import java.util.List;
+import java.util.Map;
 import java.util.Scanner;
 
 /**
  * @author dzx
  * @date 2023/12/8
  */
-public class KbTest {
+@RunWith(SpringRunner.class)
+@SpringBootTest(classes = XjrSoftApplication.class)
+class KbTest {
     @Test
     void test4(){
-        String[] split2 = {"1836067931570090015","1836067931570090028","1836067931570090033"};
-        List<String> split = Arrays.asList(split2);
-        System.out.println(split.toString().replace("[", "").replace("]", ""));
+        String tableName = "course_receive_msg";
+        Entity where = Entity.create(tableName);
+        where.set("id", "1927540722370154498");
+        Map<String, Object> receiveMsg = SqlRunnerAdapter.db().dynamicSelectOne(tableName, where);
+
+        LocalDateTime createDate = (LocalDateTime) receiveMsg.get("create_date");
+        String createDateStr = createDate.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
+
+        System.out.println(createDateStr);
     }
     public static void main(String[] args){
 //        String filePath = "C:\\Users\\建刚\\Desktop\\课表\\1数据_接口.H";