优化公众号费用通知

java110

2020-06-17 2f2aa321ebaca83a840198b04b7afc718d042c8c

 service-job/src/main/java/com/java110/job/quartz/TaskSystemQuartz.java

@@ -1,8 +1,17 @@
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;
import org.springframework.beans.factory.annotation.Autowired;

import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * @author
@@ -10,6 +19,12 @@
public abstract class TaskSystemQuartz {

    protected static final Logger logger = LoggerFactory.getLogger(TaskSystemQuartz.class);

    @Autowired
    private ITaskServiceDao taskServiceDaoImpl;

    @Autowired
    private ICommunityInnerServiceSMO communityInnerServiceSMOImpl;


    public void initTask() {
@@ -23,8 +38,15 @@
     */
    public void startTask(TaskDto taskDto) throws Exception {

        Map info = new HashMap();
        info.put("taskId", taskDto.getTaskId());
        List<Map> taskInfos = taskServiceDaoImpl.getTaskInfo(info);
        if (taskInfos == null || taskInfos.size() < 1) {
            return;
        }

        // 这么做是为了，单线程调用，防止多线程导致数据重复处理
        if (!"002".equals(taskDto.getState())) {
        if (!"002".equals(taskInfos.get(0).get("state"))) {
            return;
        }

@@ -77,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;
    }
}