推送

tr-modules/tr-module-smartFollowUp/src/main/java/cn/tr/module/smart/common/service/impl/BizMpPublishTaskServiceImpl.java

@@ -124,8 +124,8 @@ public class BizMpPublishTaskServiceImpl implements IBizMpPublishTaskService {
      * @param task 任务对象
      */
     private void sendDelayMessage(BizMpPublishTaskPO task) {
-        // 计算延迟时间（毫秒）
-        long delayTime = TimeUnit.HOURS.toMillis(task.getInterval());
+        // 计算延迟时间（毫秒）todo
+        long delayTime = TimeUnit.SECONDS.toMillis(task.getInterval());
         // 发送延迟消息
         rabbitTemplate.convertAndSend(
                 RabbitMQConstant.TOPIC_EXCHANGE_MP_NAME,

tr-test/src/test/java/cn/tr/module/excel/MpPubTest.java

@@ -3,6 +3,7 @@ package cn.tr.module.excel;
 import cn.tr.core.strategy.LoginUserStrategy;
 import cn.tr.module.smart.common.enums.MpPublishTaskTypeEnums;
 import cn.tr.module.smart.common.repository.BizClinicRoomRepository;
+import cn.tr.module.smart.common.service.IBizMpPublishTaskService;
 import cn.tr.module.smart.wx.config.WxTemplateSendHelper;
 import cn.tr.module.smart.wx.dto.BizMpPublishInfoDTO;
 import cn.tr.module.smart.wx.handler.sender.BizMpBindSuccessTemplateDTO;
@@ -27,6 +28,7 @@ import org.springframework.context.annotation.Import;
 import org.springframework.test.context.ActiveProfiles;
 
 import java.io.Serializable;
+import java.util.Date;
 import java.util.concurrent.atomic.AtomicInteger;
 
 /**
@@ -44,17 +46,11 @@ public class MpPubTest {
     private BizClinicRoomRepository clinicRoomRepository;
 
 
-
+    @Autowired
+    private IBizMpPublishTaskService taskService;
 
     @Test
     public void pub() throws WxErrorException {
-        UserLoginInfoBO userLoginInfoBO = new UserLoginInfoBO();
-        userLoginInfoBO.setUserId("1");
-        userLoginInfoBO.setTenantId("1");
-        LoginUserContextHolder.setUser(userLoginInfoBO);
-        BizMpPublishInfoDTO bizMpPublishInfoDTO = clinicRoomRepository.selectMpPushTaskInfoById("1960865259339866113");
-        bizMpPublishInfoDTO.setOpenId("oxozA7cryCvf19x6AMW46DSrnp3Y");
-        wxTemplateSendHelper.sendMsg(bizMpPublishInfoDTO, MpPublishTaskTypeEnums.ASSESSMENT.getType());
-        wxTemplateSendHelper.sendMsg(bizMpPublishInfoDTO, MpPublishTaskTypeEnums.AFTER_QUESTION.getType());
+        taskService.createAssessmentTask("1964900545652805633",new Date());
     }
 }