From 2f2aa321ebaca83a840198b04b7afc718d042c8c Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期三, 17 六月 2020 16:03:20 +0800
Subject: [PATCH] 优化公众号费用通知
---
service-job/src/main/java/com/java110/job/quartz/TaskSystemQuartz.java | 35 +++++++++++++++++++++++++++++++++++
1 files changed, 35 insertions(+), 0 deletions(-)
diff --git a/service-job/src/main/java/com/java110/job/quartz/TaskSystemQuartz.java b/service-job/src/main/java/com/java110/job/quartz/TaskSystemQuartz.java
index b367952..9b7e6cf 100644
--- a/service-job/src/main/java/com/java110/job/quartz/TaskSystemQuartz.java
+++ b/service-job/src/main/java/com/java110/job/quartz/TaskSystemQuartz.java
@@ -1,6 +1,9 @@
package com.java110.job.quartz;
+import com.java110.core.smo.community.ICommunityInnerServiceSMO;
+import com.java110.dto.community.CommunityDto;
import com.java110.dto.task.TaskDto;
+import com.java110.dto.taskAttr.TaskAttrDto;
import com.java110.job.dao.ITaskServiceDao;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -19,6 +22,9 @@
@Autowired
private ITaskServiceDao taskServiceDaoImpl;
+
+ @Autowired
+ private ICommunityInnerServiceSMO communityInnerServiceSMOImpl;
public void initTask() {
@@ -93,4 +99,33 @@
protected void after(TaskDto taskDto) {
}
+
+ /**
+ * 鏌ヨ灏忓尯淇℃伅
+ *
+ * @return
+ */
+ protected List<CommunityDto> getAllCommunity() {
+ CommunityDto communityDto = new CommunityDto();
+ communityDto.setState("1100"); //瀹℃牳杩囩殑灏忓尯
+ List<CommunityDto> communityDtos = communityInnerServiceSMOImpl.queryCommunitys(communityDto);
+ return communityDtos;
+ }
+
+ /**
+ * 鑾峰彇褰撳墠灞炴��
+ * @param taskDto
+ * @param specCd
+ * @return
+ */
+ protected TaskAttrDto getCurTaskAttr(TaskDto taskDto, String specCd) {
+ List<TaskAttrDto> taskAttrDtos = taskDto.getTaskAttr();
+ for (TaskAttrDto taskAttrDto : taskAttrDtos) {
+ if (specCd.equals(taskAttrDto.getSpecCd())) {
+ return taskAttrDto;
+ }
+ }
+
+ return null;
+ }
}
--
Gitblit v1.8.0