diff --git a/src/main/java/com/ycwl/basic/service/task/impl/TaskTaskServiceImpl.java b/src/main/java/com/ycwl/basic/service/task/impl/TaskTaskServiceImpl.java index 7c4f3dbb..aad74d8a 100644 --- a/src/main/java/com/ycwl/basic/service/task/impl/TaskTaskServiceImpl.java +++ b/src/main/java/com/ycwl/basic/service/task/impl/TaskTaskServiceImpl.java @@ -641,6 +641,9 @@ public class TaskTaskServiceImpl implements TaskService { variables.put("scenicName", scenic.getName()); variables.put("faceId", item.getFaceId()); variables.put("videoId", item.getVideoId()); + variables.put("videoDeviceCount", videoTaskRepository.getTaskDeviceNum(taskId)); + variables.put("videoLensCount", videoTaskRepository.getTaskLensNum(taskId)); + variables.put("videoShotTime", DateUtil.format(videoTaskRepository.getTaskShotDate(taskId), "yyyy-MM-dd HH:mm")); variables.put("videoCreateTime", DateUtil.format(new Date(), "yyyy-MM-dd HH:mm")); WechatSubscribeNotifyTriggerRequest request = WechatSubscribeNotifyTriggerRequest.builder() diff --git a/src/main/java/com/ycwl/basic/task/DownloadNotificationTasker.java b/src/main/java/com/ycwl/basic/task/DownloadNotificationTasker.java index d631c947..2128c09d 100644 --- a/src/main/java/com/ycwl/basic/task/DownloadNotificationTasker.java +++ b/src/main/java/com/ycwl/basic/task/DownloadNotificationTasker.java @@ -14,11 +14,9 @@ import com.ycwl.basic.model.pc.mp.MpConfigEntity; import com.ycwl.basic.integration.common.manager.ScenicConfigManager; import com.ycwl.basic.model.pc.notify.req.WechatSubscribeNotifyTriggerRequest; import com.ycwl.basic.model.pc.notify.resp.WechatSubscribeNotifyTriggerResult; -import com.ycwl.basic.model.pc.scenic.entity.ScenicEntity; import com.ycwl.basic.model.pc.scenic.req.ScenicReqQuery; import com.ycwl.basic.repository.ScenicRepository; -import com.ycwl.basic.repository.TemplateRepository; -import com.ycwl.basic.integration.common.manager.ScenicConfigManager; +import com.ycwl.basic.repository.VideoTaskRepository; import com.ycwl.basic.service.notify.WechatSubscribeNotifyTriggerService; import com.ycwl.basic.utils.NotificationAuthUtils; import lombok.extern.slf4j.Slf4j; @@ -56,6 +54,8 @@ public class DownloadNotificationTasker { private ZtMessageProducerService ztMessageProducerService; @Autowired private NotificationAuthUtils notificationAuthUtils; + @Autowired + private VideoTaskRepository videoTaskRepository; @Scheduled(cron = "0 0 21 * * *") public void sendDownloadNotification() { @@ -81,6 +81,9 @@ public class DownloadNotificationTasker { variables.put("scenicName", scenic.getName()); variables.put("scenicId", scenic.getId()); variables.put("faceId", item.getFaceId()); + variables.put("videoDeviceCount", videoTaskRepository.getTaskDeviceNum(item.getTaskId())); + variables.put("videoLensCount", videoTaskRepository.getTaskLensNum(item.getTaskId())); + variables.put("videoShotTime", DateUtil.format(videoTaskRepository.getTaskShotDate(item.getTaskId()), "yyyy-MM-dd")); WechatSubscribeNotifyTriggerRequest request = WechatSubscribeNotifyTriggerRequest.builder() .scenicId(item.getScenicId()) .memberId(item.getMemberId()) @@ -122,7 +125,10 @@ public class DownloadNotificationTasker { variables.put("scenicName", scenic.getName()); variables.put("scenicId", scenic.getId()); variables.put("faceId", item.getFaceId()); - variables.put("expireDate", expireDate); + variables.put("expireDate", DateUtil.format(expireDate, "yyyy-MM-dd")); + variables.put("videoDeviceCount", videoTaskRepository.getTaskDeviceNum(item.getTaskId())); + variables.put("videoLensCount", videoTaskRepository.getTaskLensNum(item.getTaskId())); + variables.put("videoShotTime", DateUtil.format(videoTaskRepository.getTaskShotDate(item.getTaskId()), "yyyy-MM-dd HH:mm")); WechatSubscribeNotifyTriggerRequest request = WechatSubscribeNotifyTriggerRequest.builder() .scenicId(item.getScenicId()) .memberId(item.getMemberId()) @@ -182,6 +188,9 @@ public class DownloadNotificationTasker { variables.put("scenicName", scenic.getName()); variables.put("scenicId", scenic.getId()); variables.put("faceId", item.getFaceId()); + variables.put("videoDeviceCount", videoTaskRepository.getTaskDeviceNum(item.getTaskId())); + variables.put("videoLensCount", videoTaskRepository.getTaskLensNum(item.getTaskId())); + variables.put("videoShotTime", DateUtil.format(videoTaskRepository.getTaskShotDate(item.getTaskId()), "yyyy-MM-dd HH:mm")); WechatSubscribeNotifyTriggerRequest request = WechatSubscribeNotifyTriggerRequest.builder() .scenicId(item.getScenicId()) .memberId(item.getMemberId())