调整后端代码生成器

java110

2020-06-02 282ef35e35d510948d0818fc0ad8eeaf1926f875

调整后端代码生成器

 Api/src/main/java/com/java110/api/bmo/store/IStoreAttrBMO.java

File was renamed from Api/src/main/java/com/java110/api/bmo/storeAttr/IStoreAttrBMO.java
@@ -1,4 +1,4 @@
package com.java110.api.bmo.storeAttr;
package com.java110.api.bmo.store;

import com.alibaba.fastjson.JSONObject;
import com.java110.api.bmo.IApiBaseBMO;

 Api/src/main/java/com/java110/api/bmo/store/impl/StoreAttrBMOImpl.java

File was renamed from Api/src/main/java/com/java110/api/bmo/storeAttr/impl/StoreAttrBMOImpl.java
@@ -1,8 +1,8 @@
package com.java110.api.bmo.storeAttr.impl;
package com.java110.api.bmo.store.impl;

import com.alibaba.fastjson.JSONObject;
import com.java110.api.bmo.ApiBaseBMO;
import com.java110.api.bmo.storeAttr.IStoreAttrBMO;
import com.java110.api.bmo.store.IStoreAttrBMO;
import com.java110.core.context.DataFlowContext;
import com.java110.core.smo.storeAttr.IStoreAttrInnerServiceSMO;
import com.java110.dto.store.StoreAttrDto;

 Api/src/main/java/com/java110/api/bmo/task/ITaskAttrBMO.java

copy from Api/src/main/java/com/java110/api/bmo/storeAttr/IStoreAttrBMO.java
copy to Api/src/main/java/com/java110/api/bmo/task/ITaskAttrBMO.java
File was copied from Api/src/main/java/com/java110/api/bmo/storeAttr/IStoreAttrBMO.java
@@ -1,38 +1,38 @@
package com.java110.api.bmo.storeAttr;
package com.java110.api.bmo.task;

import com.alibaba.fastjson.JSONObject;
import com.java110.api.bmo.IApiBaseBMO;
import com.java110.core.context.DataFlowContext;

public interface IStoreAttrBMO extends IApiBaseBMO {
public interface ITaskAttrBMO extends IApiBaseBMO {


    /**
     * 添加商户属性
     *
     * 添加定时任务属性
     * @param paramInJson
     * @param dataFlowContext
     * @return
     */
    void addStoreAttr(JSONObject paramInJson, DataFlowContext dataFlowContext);
     void addTaskAttr(JSONObject paramInJson, DataFlowContext dataFlowContext);

    /**
     * 添加商户属性信息
     * 添加定时任务属性信息
     *
     * @param paramInJson     接口调用放传入入参
     * @param dataFlowContext 数据上下文
     * @return 订单服务能够接受的报文
     */
    void updateStoreAttr(JSONObject paramInJson, DataFlowContext dataFlowContext);
     void updateTaskAttr(JSONObject paramInJson, DataFlowContext dataFlowContext);

    /**
     * 删除商户属性
     * 删除定时任务属性
     *
     * @param paramInJson     接口调用放传入入参
     * @param dataFlowContext 数据上下文
     * @return 订单服务能够接受的报文
     */
    void deleteStoreAttr(JSONObject paramInJson, DataFlowContext dataFlowContext);
     void deleteTaskAttr(JSONObject paramInJson, DataFlowContext dataFlowContext);



}

 Api/src/main/java/com/java110/api/bmo/task/impl/TaskAttrBMOImpl.java

New file
@@ -0,0 +1,76 @@
package com.java110.api.bmo.task.impl;

import com.alibaba.fastjson.JSONObject;
import com.java110.api.bmo.ApiBaseBMO;
import com.java110.api.bmo.task.ITaskAttrBMO;
import com.java110.core.context.DataFlowContext;
import com.java110.core.smo.taskAttr.ITaskAttrInnerServiceSMO;
import com.java110.dto.taskAttr.TaskAttrDto;
import com.java110.po.taskAttr.TaskAttrPo;
import com.java110.utils.constant.BusinessTypeConstant;
import com.java110.utils.util.Assert;
import com.java110.utils.util.BeanConvertUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;

@Service("taskAttrBMOImpl")
public class TaskAttrBMOImpl extends ApiBaseBMO implements ITaskAttrBMO {

    @Autowired
    private ITaskAttrInnerServiceSMO taskAttrInnerServiceSMOImpl;

    /**
     * 添加小区信息
     *
     * @param paramInJson     接口调用放传入入参
     * @param dataFlowContext 数据上下文
     * @return 订单服务能够接受的报文
     */
    public void addTaskAttr(JSONObject paramInJson, DataFlowContext dataFlowContext) {

        paramInJson.put("attrId", "-1");
        TaskAttrPo taskAttrPo = BeanConvertUtil.covertBean(paramInJson, TaskAttrPo.class);
        super.insert(dataFlowContext, taskAttrPo, BusinessTypeConstant.BUSINESS_TYPE_SAVE_TASK_ATTR);
    }


    /**
     * 添加活动信息
     *
     * @param paramInJson     接口调用放传入入参
     * @param dataFlowContext 数据上下文
     * @return 订单服务能够接受的报文
     */
    public void updateTaskAttr(JSONObject paramInJson, DataFlowContext dataFlowContext) {

        TaskAttrDto taskAttrDto = new TaskAttrDto();
        taskAttrDto.setAttrId(paramInJson.getString("attrId"));
        taskAttrDto.setTaskId(paramInJson.getString("taskId"));
        List<TaskAttrDto> taskAttrDtos = taskAttrInnerServiceSMOImpl.queryTaskAttrs(taskAttrDto);

        Assert.listOnlyOne(taskAttrDtos, "未找到需要修改的活动 或多条数据");


        paramInJson.putAll(BeanConvertUtil.beanCovertMap(taskAttrDtos.get(0)));
        TaskAttrPo taskAttrPo = BeanConvertUtil.covertBean(paramInJson, TaskAttrPo.class);
        super.update(dataFlowContext, taskAttrPo, BusinessTypeConstant.BUSINESS_TYPE_UPDATE_TASK_ATTR);
    }



    /**
     * 添加小区信息
     *
     * @param paramInJson     接口调用放传入入参
     * @param dataFlowContext 数据上下文
     * @return 订单服务能够接受的报文
     */
    public void deleteTaskAttr(JSONObject paramInJson, DataFlowContext dataFlowContext) {

        TaskAttrPo taskAttrPo = BeanConvertUtil.covertBean(paramInJson, TaskAttrPo.class);
        super.update(dataFlowContext, taskAttrPo, BusinessTypeConstant.BUSINESS_TYPE_DELETE_TASK_ATTR);
    }

}

 Api/src/main/java/com/java110/api/bmo/task/impl/TaskBMOImpl.java

@@ -8,7 +8,6 @@
import com.java110.dto.task.TaskDto;
import com.java110.po.task.TaskPo;
import com.java110.utils.constant.BusinessTypeConstant;
import com.java110.utils.constant.CommonConstant;
import com.java110.utils.util.Assert;
import com.java110.utils.util.BeanConvertUtil;
import org.springframework.beans.factory.annotation.Autowired;
@@ -31,8 +30,9 @@
     */
    public void addTask(JSONObject paramInJson, DataFlowContext dataFlowContext) {

        paramInJson.put("taskId", "-1");
        // paramInJson.put("taskId", "-1");
        TaskPo taskPo = BeanConvertUtil.covertBean(paramInJson, TaskPo.class);
        taskPo.setTaskId("-1");
        super.insert(dataFlowContext, taskPo, BusinessTypeConstant.BUSINESS_TYPE_SAVE_TASK);
    }

@@ -58,7 +58,6 @@
        TaskPo taskPo = BeanConvertUtil.covertBean(paramInJson, TaskPo.class);
        super.update(dataFlowContext, taskPo, BusinessTypeConstant.BUSINESS_TYPE_UPDATE_TASK);
    }



    /**

 Api/src/main/java/com/java110/api/listener/store/DeleteStoreAttrListener.java

File was renamed from Api/src/main/java/com/java110/api/listener/storeAttr/DeleteStoreAttrListener.java
@@ -1,7 +1,7 @@
package com.java110.api.listener.storeAttr;
package com.java110.api.listener.store;

import com.alibaba.fastjson.JSONObject;
import com.java110.api.bmo.storeAttr.IStoreAttrBMO;
import com.java110.api.bmo.store.IStoreAttrBMO;
import com.java110.api.listener.AbstractServiceApiPlusListener;
import com.java110.core.annotation.Java110Listener;
import com.java110.core.context.DataFlowContext;

 Api/src/main/java/com/java110/api/listener/store/ListStoreAttrsListener.java

File was renamed from Api/src/main/java/com/java110/api/listener/storeAttr/ListStoreAttrsListener.java
@@ -1,4 +1,4 @@
package com.java110.api.listener.storeAttr;
package com.java110.api.listener.store;

import com.alibaba.fastjson.JSONObject;
import com.java110.api.listener.AbstractServiceApiListener;

 Api/src/main/java/com/java110/api/listener/store/SaveStoreAttrListener.java

File was renamed from Api/src/main/java/com/java110/api/listener/storeAttr/SaveStoreAttrListener.java
@@ -1,7 +1,7 @@
package com.java110.api.listener.storeAttr;
package com.java110.api.listener.store;

import com.alibaba.fastjson.JSONObject;
import com.java110.api.bmo.storeAttr.IStoreAttrBMO;
import com.java110.api.bmo.store.IStoreAttrBMO;
import com.java110.api.listener.AbstractServiceApiPlusListener;
import com.java110.core.annotation.Java110Listener;
import com.java110.core.context.DataFlowContext;
@@ -21,6 +21,7 @@
    @Autowired
    private IStoreAttrBMO storeAttrBMOImpl;


    @Override
    protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) {
        //Assert.hasKeyAndValue(reqJson, "xxx", "xxx");

 Api/src/main/java/com/java110/api/listener/store/UpdateStoreAttrListener.java

File was renamed from Api/src/main/java/com/java110/api/listener/storeAttr/UpdateStoreAttrListener.java
@@ -1,7 +1,7 @@
package com.java110.api.listener.storeAttr;
package com.java110.api.listener.store;

import com.alibaba.fastjson.JSONObject;
import com.java110.api.bmo.storeAttr.IStoreAttrBMO;
import com.java110.api.bmo.store.IStoreAttrBMO;
import com.java110.api.listener.AbstractServiceApiPlusListener;
import com.java110.core.annotation.Java110Listener;
import com.java110.core.context.DataFlowContext;

 JobService/src/main/java/com/java110/job/dao/ITaskAttrServiceDao.java

New file
@@ -0,0 +1,81 @@
package com.java110.job.dao;


import com.java110.utils.exception.DAOException;
import com.java110.entity.merchant.BoMerchant;
import com.java110.entity.merchant.BoMerchantAttr;
import com.java110.entity.merchant.Merchant;
import com.java110.entity.merchant.MerchantAttr;


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

/**
 * 定时任务属性组件内部之间使用，没有给外围系统提供服务能力
 * 定时任务属性服务接口类，要求全部以字符串传输，方便微服务化
 * 新建客户，修改客户，删除客户，查询客户等功能
 *
 * Created by wuxw on 2016/12/27.
 */
public interface ITaskAttrServiceDao {

    /**
     * 保存 定时任务属性信息
     * @param businessTaskAttrInfo 定时任务属性信息 封装
     * @throws DAOException 操作数据库异常
     */
    void saveBusinessTaskAttrInfo(Map businessTaskAttrInfo) throws DAOException;



    /**
     * 查询定时任务属性信息（business过程）
     * 根据bId 查询定时任务属性信息
     * @param info bId 信息
     * @return 定时任务属性信息
     * @throws DAOException DAO异常
     */
    List<Map> getBusinessTaskAttrInfo(Map info) throws DAOException;




    /**
     * 保存 定时任务属性信息 Business数据到 Instance中
     * @param info
     * @throws DAOException DAO异常
     */
    void saveTaskAttrInfoInstance(Map info) throws DAOException;




    /**
     * 查询定时任务属性信息（instance过程）
     * 根据bId 查询定时任务属性信息
     * @param info bId 信息
     * @return 定时任务属性信息
     * @throws DAOException DAO异常
     */
    List<Map> getTaskAttrInfo(Map info) throws DAOException;



    /**
     * 修改定时任务属性信息
     * @param info 修改信息
     * @throws DAOException DAO异常
     */
    void updateTaskAttrInfoInstance(Map info) throws DAOException;


    /**
     * 查询定时任务属性总数
     *
     * @param info 定时任务属性信息
     * @return 定时任务属性数量
     */
    int queryTaskAttrsCount(Map info);

}

 JobService/src/main/java/com/java110/job/dao/impl/TaskAttrServiceDaoImpl.java

New file
@@ -0,0 +1,130 @@
package com.java110.job.dao.impl;

import com.alibaba.fastjson.JSONObject;
import com.java110.utils.constant.ResponseConstant;
import com.java110.utils.exception.DAOException;
import com.java110.utils.util.DateUtil;
import com.java110.core.base.dao.BaseServiceDao;
import com.java110.job.dao.ITaskAttrServiceDao;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

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

/**
 * 定时任务属性服务 与数据库交互
 * Created by wuxw on 2017/4/5.
 */
@Service("taskAttrServiceDaoImpl")
//@Transactional
public class TaskAttrServiceDaoImpl extends BaseServiceDao implements ITaskAttrServiceDao {

    private static Logger logger = LoggerFactory.getLogger(TaskAttrServiceDaoImpl.class);

    /**
     * 定时任务属性信息封装
     * @param businessTaskAttrInfo 定时任务属性信息 封装
     * @throws DAOException DAO异常
     */
    @Override
    public void saveBusinessTaskAttrInfo(Map businessTaskAttrInfo) throws DAOException {
        businessTaskAttrInfo.put("month", DateUtil.getCurrentMonth());
        // 查询business_user 数据是否已经存在
        logger.debug("保存定时任务属性信息 入参 businessTaskAttrInfo : {}",businessTaskAttrInfo);
        int saveFlag = sqlSessionTemplate.insert("taskAttrServiceDaoImpl.saveBusinessTaskAttrInfo",businessTaskAttrInfo);

        if(saveFlag < 1){
            throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR,"保存定时任务属性数据失败："+ JSONObject.toJSONString(businessTaskAttrInfo));
        }
    }


    /**
     * 查询定时任务属性信息
     * @param info bId 信息
     * @return 定时任务属性信息
     * @throws DAOException DAO异常
     */
    @Override
    public List<Map> getBusinessTaskAttrInfo(Map info) throws DAOException {

        logger.debug("查询定时任务属性信息 入参 info : {}",info);

        List<Map> businessTaskAttrInfos = sqlSessionTemplate.selectList("taskAttrServiceDaoImpl.getBusinessTaskAttrInfo",info);

        return businessTaskAttrInfos;
    }



    /**
     * 保存定时任务属性信息 到 instance
     * @param info   bId 信息
     * @throws DAOException DAO异常
     */
    @Override
    public void saveTaskAttrInfoInstance(Map info) throws DAOException {
        logger.debug("保存定时任务属性信息Instance 入参 info : {}",info);

        int saveFlag = sqlSessionTemplate.insert("taskAttrServiceDaoImpl.saveTaskAttrInfoInstance",info);

        if(saveFlag < 1){
            throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR,"保存定时任务属性信息Instance数据失败："+ JSONObject.toJSONString(info));
        }
    }


    /**
     * 查询定时任务属性信息（instance）
     * @param info bId 信息
     * @return List<Map>
     * @throws DAOException DAO异常
     */
    @Override
    public List<Map> getTaskAttrInfo(Map info) throws DAOException {
        logger.debug("查询定时任务属性信息 入参 info : {}",info);

        List<Map> businessTaskAttrInfos = sqlSessionTemplate.selectList("taskAttrServiceDaoImpl.getTaskAttrInfo",info);

        return businessTaskAttrInfos;
    }


    /**
     * 修改定时任务属性信息
     * @param info 修改信息
     * @throws DAOException DAO异常
     */
    @Override
    public void updateTaskAttrInfoInstance(Map info) throws DAOException {
        logger.debug("修改定时任务属性信息Instance 入参 info : {}",info);

        int saveFlag = sqlSessionTemplate.update("taskAttrServiceDaoImpl.updateTaskAttrInfoInstance",info);

        if(saveFlag < 1){
            throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR,"修改定时任务属性信息Instance数据失败："+ JSONObject.toJSONString(info));
        }
    }

     /**
     * 查询定时任务属性数量
     * @param info 定时任务属性信息
     * @return 定时任务属性数量
     */
    @Override
    public int queryTaskAttrsCount(Map info) {
        logger.debug("查询定时任务属性数据 入参 info : {}",info);

        List<Map> businessTaskAttrInfos = sqlSessionTemplate.selectList("taskAttrServiceDaoImpl.queryTaskAttrsCount", info);
        if (businessTaskAttrInfos.size() < 1) {
            return 0;
        }

        return Integer.parseInt(businessTaskAttrInfos.get(0).get("count").toString());
    }


}

 JobService/src/main/java/com/java110/job/listener/taskAttr/AbstractTaskAttrBusinessServiceDataFlowListener.java

New file
@@ -0,0 +1,88 @@
package com.java110.job.listener.taskAttr;

import com.alibaba.fastjson.JSONObject;
import com.java110.core.event.service.AbstractBusinessServiceDataFlowListener;
import com.java110.entity.center.Business;
import com.java110.job.dao.ITaskAttrServiceDao;
import com.java110.utils.constant.ResponseConstant;
import com.java110.utils.constant.StatusConstant;
import com.java110.utils.exception.ListenerExecuteException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

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

/**
 * 定时任务属性 服务侦听 父类
 * Created by wuxw on 2018/7/4.
 */
public abstract class AbstractTaskAttrBusinessServiceDataFlowListener extends AbstractBusinessServiceDataFlowListener {
    private static Logger logger = LoggerFactory.getLogger(AbstractTaskAttrBusinessServiceDataFlowListener.class);


    /**
     * 获取 DAO工具类
     *
     * @return
     */
    public abstract ITaskAttrServiceDao getTaskAttrServiceDaoImpl();

    /**
     * 刷新 businessTaskAttrInfo 数据
     * 主要将 数据库 中字段和 接口传递字段建立关系
     *
     * @param businessTaskAttrInfo
     */
    protected void flushBusinessTaskAttrInfo(Map businessTaskAttrInfo, String statusCd) {
        businessTaskAttrInfo.put("newBId", businessTaskAttrInfo.get("b_id"));
        businessTaskAttrInfo.put("attrId", businessTaskAttrInfo.get("attr_id"));
        businessTaskAttrInfo.put("operate", businessTaskAttrInfo.get("operate"));
        businessTaskAttrInfo.put("createTime", businessTaskAttrInfo.get("create_time"));
        businessTaskAttrInfo.put("specCd", businessTaskAttrInfo.get("spec_cd"));
        businessTaskAttrInfo.put("value", businessTaskAttrInfo.get("value"));
        businessTaskAttrInfo.put("taskId", businessTaskAttrInfo.get("task_id"));
        businessTaskAttrInfo.remove("bId");
        businessTaskAttrInfo.put("statusCd", statusCd);
    }


    /**
     * 当修改数据时，查询instance表中的数据 自动保存删除数据到business中
     *
     * @param businessTaskAttr 定时任务属性信息
     */
    protected void autoSaveDelBusinessTaskAttr(Business business, JSONObject businessTaskAttr) {
//自动插入DEL
        Map info = new HashMap();
        info.put("attrId", businessTaskAttr.getString("attrId"));
        info.put("statusCd", StatusConstant.STATUS_CD_VALID);
        List<Map> currentTaskAttrInfos = getTaskAttrServiceDaoImpl().getTaskAttrInfo(info);
        if (currentTaskAttrInfos == null || currentTaskAttrInfos.size() != 1) {
            throw new ListenerExecuteException(ResponseConstant.RESULT_PARAM_ERROR, "未找到需要修改数据信息，入参错误或数据有问题，请检查" + info);
        }

        Map currentTaskAttrInfo = currentTaskAttrInfos.get(0);

        currentTaskAttrInfo.put("bId", business.getbId());

        currentTaskAttrInfo.put("attrId", currentTaskAttrInfo.get("attr_id"));
        currentTaskAttrInfo.put("operate", currentTaskAttrInfo.get("operate"));
        currentTaskAttrInfo.put("createTime", currentTaskAttrInfo.get("create_time"));
        currentTaskAttrInfo.put("specCd", currentTaskAttrInfo.get("spec_cd"));
        currentTaskAttrInfo.put("value", currentTaskAttrInfo.get("value"));
        currentTaskAttrInfo.put("taskId", currentTaskAttrInfo.get("task_id"));


        currentTaskAttrInfo.put("operate", StatusConstant.OPERATE_DEL);
        getTaskAttrServiceDaoImpl().saveBusinessTaskAttrInfo(currentTaskAttrInfo);
        for (Object key : currentTaskAttrInfo.keySet()) {
            if (businessTaskAttr.get(key) == null) {
                businessTaskAttr.put(key.toString(), currentTaskAttrInfo.get(key));
            }
        }
    }


}

 JobService/src/main/java/com/java110/job/listener/taskAttr/DeleteTaskAttrInfoListener.java

New file
@@ -0,0 +1,176 @@
package com.java110.job.listener.taskAttr;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.java110.po.taskAttr.TaskAttrPo;
import com.java110.utils.constant.BusinessTypeConstant;
import com.java110.utils.constant.ResponseConstant;
import com.java110.utils.constant.StatusConstant;
import com.java110.utils.exception.ListenerExecuteException;
import com.java110.utils.util.Assert;
import com.java110.core.annotation.Java110Listener;
import com.java110.core.context.DataFlowContext;
import com.java110.entity.center.Business;
import com.java110.job.dao.ITaskAttrServiceDao;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional;

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

/**
 * 删除定时任务属性信息 侦听
 *
 * 处理节点
 * 1、businessTaskAttr:{} 定时任务属性基本信息节点
 * 2、businessTaskAttrAttr:[{}] 定时任务属性属性信息节点
 * 3、businessTaskAttrPhoto:[{}] 定时任务属性照片信息节点
 * 4、businessTaskAttrCerdentials:[{}] 定时任务属性证件信息节点
 * 协议地址 ：https://github.com/java110/MicroCommunity/wiki/%E5%88%A0%E9%99%A4%E5%95%86%E6%88%B7%E4%BF%A1%E6%81%AF-%E5%8D%8F%E8%AE%AE
 * Created by wuxw on 2018/5/18.
 */
@Java110Listener("deleteTaskAttrInfoListener")
@Transactional
public class DeleteTaskAttrInfoListener extends AbstractTaskAttrBusinessServiceDataFlowListener {

    private final static Logger logger = LoggerFactory.getLogger(DeleteTaskAttrInfoListener.class);
    @Autowired
    ITaskAttrServiceDao taskAttrServiceDaoImpl;

    @Override
    public int getOrder() {
        return 3;
    }

    @Override
    public String getBusinessTypeCd() {
        return BusinessTypeConstant.BUSINESS_TYPE_DELETE_TASK_ATTR;
    }

    /**
     * 根据删除信息 查出Instance表中数据 保存至business表 （状态写DEL） 方便撤单时直接更新回去
     * @param dataFlowContext 数据对象
     * @param business 当前业务对象
     */
    @Override
    protected void doSaveBusiness(DataFlowContext dataFlowContext, Business business) {
        JSONObject data = business.getDatas();

        Assert.notEmpty(data,"没有datas 节点，或没有子节点需要处理");

            //处理 businessTaskAttr 节点
            if(data.containsKey(TaskAttrPo.class.getSimpleName())){
                Object _obj = data.get(TaskAttrPo.class.getSimpleName());
                JSONArray businessTaskAttrs = null;
                if(_obj instanceof JSONObject){
                    businessTaskAttrs = new JSONArray();
                    businessTaskAttrs.add(_obj);
                }else {
                    businessTaskAttrs = (JSONArray)_obj;
                }
                //JSONObject businessTaskAttr = data.getJSONObject(TaskAttrPo.class.getSimpleName());
                for (int _taskAttrIndex = 0; _taskAttrIndex < businessTaskAttrs.size();_taskAttrIndex++) {
                    JSONObject businessTaskAttr = businessTaskAttrs.getJSONObject(_taskAttrIndex);
                    doBusinessTaskAttr(business, businessTaskAttr);
                    if(_obj instanceof JSONObject) {
                        dataFlowContext.addParamOut("attrId", businessTaskAttr.getString("attrId"));
                    }
                }

        }


    }

    /**
     * 删除 instance数据
     * @param dataFlowContext 数据对象
     * @param business 当前业务对象
     */
    @Override
    protected void doBusinessToInstance(DataFlowContext dataFlowContext, Business business) {
        String bId = business.getbId();
        //Assert.hasLength(bId,"请求报文中没有包含 bId");

        //定时任务属性信息
        Map info = new HashMap();
        info.put("bId",business.getbId());
        info.put("operate",StatusConstant.OPERATE_DEL);

        //定时任务属性信息
        List<Map> businessTaskAttrInfos = taskAttrServiceDaoImpl.getBusinessTaskAttrInfo(info);
        if( businessTaskAttrInfos != null && businessTaskAttrInfos.size() >0) {
            for (int _taskAttrIndex = 0; _taskAttrIndex < businessTaskAttrInfos.size();_taskAttrIndex++) {
                Map businessTaskAttrInfo = businessTaskAttrInfos.get(_taskAttrIndex);
                flushBusinessTaskAttrInfo(businessTaskAttrInfo,StatusConstant.STATUS_CD_INVALID);
                taskAttrServiceDaoImpl.updateTaskAttrInfoInstance(businessTaskAttrInfo);
                dataFlowContext.addParamOut("attrId",businessTaskAttrInfo.get("attr_id"));
            }
        }

    }

    /**
     * 撤单
     * 从business表中查询到DEL的数据 将instance中的数据更新回来
     * @param dataFlowContext 数据对象
     * @param business 当前业务对象
     */
    @Override
    protected void doRecover(DataFlowContext dataFlowContext, Business business) {
        String bId = business.getbId();
        //Assert.hasLength(bId,"请求报文中没有包含 bId");
        Map info = new HashMap();
        info.put("bId",bId);
        info.put("statusCd",StatusConstant.STATUS_CD_INVALID);

        Map delInfo = new HashMap();
        delInfo.put("bId",business.getbId());
        delInfo.put("operate",StatusConstant.OPERATE_DEL);
        //定时任务属性信息
        List<Map> taskAttrInfo = taskAttrServiceDaoImpl.getTaskAttrInfo(info);
        if(taskAttrInfo != null && taskAttrInfo.size() > 0){

            //定时任务属性信息
            List<Map> businessTaskAttrInfos = taskAttrServiceDaoImpl.getBusinessTaskAttrInfo(delInfo);
            //除非程序出错了，这里不会为空
            if(businessTaskAttrInfos == null ||  businessTaskAttrInfos.size() == 0){
                throw new ListenerExecuteException(ResponseConstant.RESULT_CODE_INNER_ERROR,"撤单失败（taskAttr），程序内部异常,请检查！ "+delInfo);
            }
            for (int _taskAttrIndex = 0; _taskAttrIndex < businessTaskAttrInfos.size();_taskAttrIndex++) {
                Map businessTaskAttrInfo = businessTaskAttrInfos.get(_taskAttrIndex);
                flushBusinessTaskAttrInfo(businessTaskAttrInfo,StatusConstant.STATUS_CD_VALID);
                taskAttrServiceDaoImpl.updateTaskAttrInfoInstance(businessTaskAttrInfo);
            }
        }
    }



    /**
     * 处理 businessTaskAttr 节点
     * @param business 总的数据节点
     * @param businessTaskAttr 定时任务属性节点
     */
    private void doBusinessTaskAttr(Business business,JSONObject businessTaskAttr){

        Assert.jsonObjectHaveKey(businessTaskAttr,"attrId","businessTaskAttr 节点下没有包含 attrId 节点");

        if(businessTaskAttr.getString("attrId").startsWith("-")){
            throw new ListenerExecuteException(ResponseConstant.RESULT_PARAM_ERROR,"attrId 错误，不能自动生成（必须已经存在的attrId）"+businessTaskAttr);
        }
        //自动插入DEL
        autoSaveDelBusinessTaskAttr(business,businessTaskAttr);
    }
    @Override
    public ITaskAttrServiceDao getTaskAttrServiceDaoImpl() {
        return taskAttrServiceDaoImpl;
    }

    public void setTaskAttrServiceDaoImpl(ITaskAttrServiceDao taskAttrServiceDaoImpl) {
        this.taskAttrServiceDaoImpl = taskAttrServiceDaoImpl;
    }
}

 JobService/src/main/java/com/java110/job/listener/taskAttr/SaveTaskAttrInfoListener.java

New file
@@ -0,0 +1,181 @@
package com.java110.job.listener.taskAttr;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.java110.core.annotation.Java110Listener;
import com.java110.core.context.DataFlowContext;
import com.java110.core.factory.GenerateCodeFactory;
import com.java110.entity.center.Business;
import com.java110.job.dao.ITaskAttrServiceDao;
import com.java110.po.taskAttr.TaskAttrPo;
import com.java110.utils.constant.BusinessTypeConstant;
import com.java110.utils.constant.StatusConstant;
import com.java110.utils.util.Assert;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional;

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

/**
 * 保存 定时任务属性信息 侦听
 * Created by wuxw on 2018/5/18.
 */
@Java110Listener("saveTaskAttrInfoListener")
@Transactional
public class SaveTaskAttrInfoListener extends AbstractTaskAttrBusinessServiceDataFlowListener {

    private static Logger logger = LoggerFactory.getLogger(SaveTaskAttrInfoListener.class);

    @Autowired
    private ITaskAttrServiceDao taskAttrServiceDaoImpl;

    @Override
    public int getOrder() {
        return 0;
    }

    @Override
    public String getBusinessTypeCd() {
        return BusinessTypeConstant.BUSINESS_TYPE_SAVE_TASK_ATTR;
    }

    /**
     * 保存定时任务属性信息 business 表中
     *
     * @param dataFlowContext 数据对象
     * @param business        当前业务对象
     */
    @Override
    protected void doSaveBusiness(DataFlowContext dataFlowContext, Business business) {
        JSONObject data = business.getDatas();
        Assert.notEmpty(data, "没有datas 节点，或没有子节点需要处理");

        //处理 businessTaskAttr 节点
        if (data.containsKey(TaskAttrPo.class.getSimpleName())) {
            Object bObj = data.get(TaskAttrPo.class.getSimpleName());
            JSONArray businessTaskAttrs = null;
            if (bObj instanceof JSONObject) {
                businessTaskAttrs = new JSONArray();
                businessTaskAttrs.add(bObj);
            } else {
                businessTaskAttrs = (JSONArray) bObj;
            }
            //JSONObject businessTaskAttr = data.getJSONObject(TaskAttrPo.class.getSimpleName());
            for (int bTaskAttrIndex = 0; bTaskAttrIndex < businessTaskAttrs.size(); bTaskAttrIndex++) {
                JSONObject businessTaskAttr = businessTaskAttrs.getJSONObject(bTaskAttrIndex);
                doBusinessTaskAttr(business, businessTaskAttr);
                if (bObj instanceof JSONObject) {
                    dataFlowContext.addParamOut("attrId", businessTaskAttr.getString("attrId"));
                }
            }
        }
    }

    /**
     * business 数据转移到 instance
     *
     * @param dataFlowContext 数据对象
     * @param business        当前业务对象
     */
    @Override
    protected void doBusinessToInstance(DataFlowContext dataFlowContext, Business business) {
        JSONObject data = business.getDatas();

        Map info = new HashMap();
        info.put("bId", business.getbId());
        info.put("operate", StatusConstant.OPERATE_ADD);

        //定时任务属性信息
        List<Map> businessTaskAttrInfo = taskAttrServiceDaoImpl.getBusinessTaskAttrInfo(info);
        if (businessTaskAttrInfo != null && businessTaskAttrInfo.size() > 0) {
            reFreshShareColumn(info, businessTaskAttrInfo.get(0));
            taskAttrServiceDaoImpl.saveTaskAttrInfoInstance(info);
            if (businessTaskAttrInfo.size() == 1) {
                dataFlowContext.addParamOut("attrId", businessTaskAttrInfo.get(0).get("attr_id"));
            }
        }
    }


    /**
     * 刷 分片字段
     *
     * @param info         查询对象
     * @param businessInfo 小区ID
     */
    private void reFreshShareColumn(Map info, Map businessInfo) {

        if (info.containsKey("task_id")) {
            return;
        }

        if (!businessInfo.containsKey("taskId")) {
            return;
        }

        info.put("task_id", businessInfo.get("taskId"));
    }

    /**
     * 撤单
     *
     * @param dataFlowContext 数据对象
     * @param business        当前业务对象
     */
    @Override
    protected void doRecover(DataFlowContext dataFlowContext, Business business) {
        String bId = business.getbId();
        //Assert.hasLength(bId,"请求报文中没有包含 bId");
        Map info = new HashMap();
        info.put("bId", bId);
        info.put("statusCd", StatusConstant.STATUS_CD_VALID);
        Map paramIn = new HashMap();
        paramIn.put("bId", bId);
        paramIn.put("statusCd", StatusConstant.STATUS_CD_INVALID);
        //定时任务属性信息
        List<Map> taskAttrInfo = taskAttrServiceDaoImpl.getTaskAttrInfo(info);
        if (taskAttrInfo != null && taskAttrInfo.size() > 0) {
            reFreshShareColumn(paramIn, taskAttrInfo.get(0));
            taskAttrServiceDaoImpl.updateTaskAttrInfoInstance(paramIn);
        }
    }


    /**
     * 处理 businessTaskAttr 节点
     *
     * @param business         总的数据节点
     * @param businessTaskAttr 定时任务属性节点
     */
    private void doBusinessTaskAttr(Business business, JSONObject businessTaskAttr) {

        Assert.jsonObjectHaveKey(businessTaskAttr, "attrId", "businessTaskAttr 节点下没有包含 attrId 节点");

        if (businessTaskAttr.getString("attrId").startsWith("-")) {
            //刷新缓存
            //flushTaskAttrId(business.getDatas());

            businessTaskAttr.put("attrId", GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_attrId));

        }

        businessTaskAttr.put("bId", business.getbId());
        businessTaskAttr.put("operate", StatusConstant.OPERATE_ADD);
        //保存定时任务属性信息
        taskAttrServiceDaoImpl.saveBusinessTaskAttrInfo(businessTaskAttr);

    }

    @Override
    public ITaskAttrServiceDao getTaskAttrServiceDaoImpl() {
        return taskAttrServiceDaoImpl;
    }

    public void setTaskAttrServiceDaoImpl(ITaskAttrServiceDao taskAttrServiceDaoImpl) {
        this.taskAttrServiceDaoImpl = taskAttrServiceDaoImpl;
    }
}

 JobService/src/main/java/com/java110/job/listener/taskAttr/UpdateTaskAttrInfoListener.java

New file
@@ -0,0 +1,190 @@
package com.java110.job.listener.taskAttr;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.java110.core.annotation.Java110Listener;
import com.java110.core.context.DataFlowContext;
import com.java110.entity.center.Business;
import com.java110.job.dao.ITaskAttrServiceDao;
import com.java110.po.taskAttr.TaskAttrPo;
import com.java110.utils.constant.BusinessTypeConstant;
import com.java110.utils.constant.ResponseConstant;
import com.java110.utils.constant.StatusConstant;
import com.java110.utils.exception.ListenerExecuteException;
import com.java110.utils.util.Assert;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional;

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

/**
 * 修改定时任务属性信息 侦听
 * <p>
 * 处理节点
 * 1、businessTaskAttr:{} 定时任务属性基本信息节点
 * 2、businessTaskAttrAttr:[{}] 定时任务属性属性信息节点
 * 3、businessTaskAttrPhoto:[{}] 定时任务属性照片信息节点
 * 4、businessTaskAttrCerdentials:[{}] 定时任务属性证件信息节点
 * 协议地址 ：https://github.com/java110/MicroCommunity/wiki/%E4%BF%AE%E6%94%B9%E5%95%86%E6%88%B7%E4%BF%A1%E6%81%AF-%E5%8D%8F%E8%AE%AE
 * Created by wuxw on 2018/5/18.
 */
@Java110Listener("updateTaskAttrInfoListener")
@Transactional
public class UpdateTaskAttrInfoListener extends AbstractTaskAttrBusinessServiceDataFlowListener {

    private static Logger logger = LoggerFactory.getLogger(UpdateTaskAttrInfoListener.class);
    @Autowired
    private ITaskAttrServiceDao taskAttrServiceDaoImpl;

    @Override
    public int getOrder() {
        return 2;
    }

    @Override
    public String getBusinessTypeCd() {
        return BusinessTypeConstant.BUSINESS_TYPE_UPDATE_TASK_ATTR;
    }

    /**
     * business过程
     *
     * @param dataFlowContext 上下文对象
     * @param business        业务对象
     */
    @Override
    protected void doSaveBusiness(DataFlowContext dataFlowContext, Business business) {

        JSONObject data = business.getDatas();

        Assert.notEmpty(data, "没有datas 节点，或没有子节点需要处理");


        //处理 businessTaskAttr 节点
        if (data.containsKey(TaskAttrPo.class.getSimpleName())) {
            Object _obj = data.get(TaskAttrPo.class.getSimpleName());
            JSONArray businessTaskAttrs = null;
            if (_obj instanceof JSONObject) {
                businessTaskAttrs = new JSONArray();
                businessTaskAttrs.add(_obj);
            } else {
                businessTaskAttrs = (JSONArray) _obj;
            }
            //JSONObject businessTaskAttr = data.getJSONObject(TaskAttrPo.class.getSimpleName());
            for (int _taskAttrIndex = 0; _taskAttrIndex < businessTaskAttrs.size(); _taskAttrIndex++) {
                JSONObject businessTaskAttr = businessTaskAttrs.getJSONObject(_taskAttrIndex);
                doBusinessTaskAttr(business, businessTaskAttr);
                if (_obj instanceof JSONObject) {
                    dataFlowContext.addParamOut("attrId", businessTaskAttr.getString("attrId"));
                }
            }
        }
    }


    /**
     * business to instance 过程
     *
     * @param dataFlowContext 数据对象
     * @param business        当前业务对象
     */
    @Override
    protected void doBusinessToInstance(DataFlowContext dataFlowContext, Business business) {

        JSONObject data = business.getDatas();

        Map info = new HashMap();
        info.put("bId", business.getbId());
        info.put("operate", StatusConstant.OPERATE_ADD);

        //定时任务属性信息
        List<Map> businessTaskAttrInfos = taskAttrServiceDaoImpl.getBusinessTaskAttrInfo(info);
        if (businessTaskAttrInfos != null && businessTaskAttrInfos.size() > 0) {
            for (int _taskAttrIndex = 0; _taskAttrIndex < businessTaskAttrInfos.size(); _taskAttrIndex++) {
                Map businessTaskAttrInfo = businessTaskAttrInfos.get(_taskAttrIndex);
                flushBusinessTaskAttrInfo(businessTaskAttrInfo, StatusConstant.STATUS_CD_VALID);
                taskAttrServiceDaoImpl.updateTaskAttrInfoInstance(businessTaskAttrInfo);
                if (businessTaskAttrInfo.size() == 1) {
                    dataFlowContext.addParamOut("attrId", businessTaskAttrInfo.get("attr_id"));
                }
            }
        }

    }

    /**
     * 撤单
     *
     * @param dataFlowContext 数据对象
     * @param business        当前业务对象
     */
    @Override
    protected void doRecover(DataFlowContext dataFlowContext, Business business) {

        String bId = business.getbId();
        //Assert.hasLength(bId,"请求报文中没有包含 bId");
        Map info = new HashMap();
        info.put("bId", bId);
        info.put("statusCd", StatusConstant.STATUS_CD_VALID);
        Map delInfo = new HashMap();
        delInfo.put("bId", business.getbId());
        delInfo.put("operate", StatusConstant.OPERATE_DEL);
        //定时任务属性信息
        List<Map> taskAttrInfo = taskAttrServiceDaoImpl.getTaskAttrInfo(info);
        if (taskAttrInfo != null && taskAttrInfo.size() > 0) {

            //定时任务属性信息
            List<Map> businessTaskAttrInfos = taskAttrServiceDaoImpl.getBusinessTaskAttrInfo(delInfo);
            //除非程序出错了，这里不会为空
            if (businessTaskAttrInfos == null || businessTaskAttrInfos.size() == 0) {
                throw new ListenerExecuteException(ResponseConstant.RESULT_CODE_INNER_ERROR, "撤单失败（taskAttr），程序内部异常,请检查！ " + delInfo);
            }
            for (int _taskAttrIndex = 0; _taskAttrIndex < businessTaskAttrInfos.size(); _taskAttrIndex++) {
                Map businessTaskAttrInfo = businessTaskAttrInfos.get(_taskAttrIndex);
                flushBusinessTaskAttrInfo(businessTaskAttrInfo, StatusConstant.STATUS_CD_VALID);
                taskAttrServiceDaoImpl.updateTaskAttrInfoInstance(businessTaskAttrInfo);
            }
        }

    }


    /**
     * 处理 businessTaskAttr 节点
     *
     * @param business         总的数据节点
     * @param businessTaskAttr 定时任务属性节点
     */
    private void doBusinessTaskAttr(Business business, JSONObject businessTaskAttr) {

        Assert.jsonObjectHaveKey(businessTaskAttr, "attrId", "businessTaskAttr 节点下没有包含 attrId 节点");

        if (businessTaskAttr.getString("attrId").startsWith("-")) {
            throw new ListenerExecuteException(ResponseConstant.RESULT_PARAM_ERROR, "attrId 错误，不能自动生成（必须已经存在的attrId）" + businessTaskAttr);
        }
        //自动保存DEL
        autoSaveDelBusinessTaskAttr(business, businessTaskAttr);

        businessTaskAttr.put("bId", business.getbId());
        businessTaskAttr.put("operate", StatusConstant.OPERATE_ADD);
        //保存定时任务属性信息
        taskAttrServiceDaoImpl.saveBusinessTaskAttrInfo(businessTaskAttr);

    }


    @Override
    public ITaskAttrServiceDao getTaskAttrServiceDaoImpl() {
        return taskAttrServiceDaoImpl;
    }

    public void setTaskAttrServiceDaoImpl(ITaskAttrServiceDao taskAttrServiceDaoImpl) {
        this.taskAttrServiceDaoImpl = taskAttrServiceDaoImpl;
    }


}

 JobService/src/main/java/com/java110/job/smo/impl/TaskAttrInnerServiceSMOImpl.java

New file
@@ -0,0 +1,111 @@
package com.java110.job.smo.impl;


import com.java110.job.dao.ITaskAttrServiceDao;
import com.java110.core.smo.taskAttr.ITaskAttrInnerServiceSMO;
import com.java110.dto.taskAttr.TaskAttrDto;
import com.java110.utils.util.BeanConvertUtil;
import com.java110.core.base.smo.BaseServiceSMO;
import com.java110.dto.user.UserDto;
import com.java110.core.smo.user.IUserInnerServiceSMO;
import com.java110.dto.PageDto;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;

import java.util.ArrayList;
import java.util.List;

/**
 * @ClassName FloorInnerServiceSMOImpl
 * @Description 定时任务属性内部服务实现类
 * @Author wuxw
 * @Date 2019/4/24 9:20
 * @Version 1.0
 * add by wuxw 2019/4/24
 **/
@RestController
public class TaskAttrInnerServiceSMOImpl extends BaseServiceSMO implements ITaskAttrInnerServiceSMO {

    @Autowired
    private ITaskAttrServiceDao taskAttrServiceDaoImpl;

    @Autowired
    private IUserInnerServiceSMO userInnerServiceSMOImpl;

    @Override
    public List<TaskAttrDto> queryTaskAttrs(@RequestBody  TaskAttrDto taskAttrDto) {

        //校验是否传了 分页信息

        int page = taskAttrDto.getPage();

        if (page != PageDto.DEFAULT_PAGE) {
            taskAttrDto.setPage((page - 1) * taskAttrDto.getRow());
        }

        List<TaskAttrDto> taskAttrs = BeanConvertUtil.covertBeanList(taskAttrServiceDaoImpl.getTaskAttrInfo(BeanConvertUtil.beanCovertMap(taskAttrDto)), TaskAttrDto.class);

        if (taskAttrs == null || taskAttrs.size() == 0) {
            return taskAttrs;
        }

        String[] userIds = getUserIds(taskAttrs);
        //根据 userId 查询用户信息
        List<UserDto> users = userInnerServiceSMOImpl.getUserInfo(userIds);

        for (TaskAttrDto taskAttr : taskAttrs) {
            refreshTaskAttr(taskAttr, users);
        }
        return taskAttrs;
    }

    /**
     * 从用户列表中查询用户，将用户中的信息 刷新到 floor对象中
     *
     * @param taskAttr 小区定时任务属性信息
     * @param users 用户列表
     */
    private void refreshTaskAttr(TaskAttrDto taskAttr, List<UserDto> users) {
        for (UserDto user : users) {
            if (taskAttr.getAttrId().equals(user.getUserId())) {
                BeanConvertUtil.covertBean(user, taskAttr);
            }
        }
    }

    /**
     * 获取批量userId
     *
     * @param taskAttrs 小区楼信息
     * @return 批量userIds 信息
     */
     private String[] getUserIds(List<TaskAttrDto> taskAttrs) {
        List<String> userIds = new ArrayList<String>();
        for (TaskAttrDto taskAttr : taskAttrs) {
            userIds.add(taskAttr.getAttrId());
        }

        return userIds.toArray(new String[userIds.size()]);
    }

    @Override
    public int queryTaskAttrsCount(@RequestBody TaskAttrDto taskAttrDto) {
        return taskAttrServiceDaoImpl.queryTaskAttrsCount(BeanConvertUtil.beanCovertMap(taskAttrDto));    }

    public ITaskAttrServiceDao getTaskAttrServiceDaoImpl() {
        return taskAttrServiceDaoImpl;
    }

    public void setTaskAttrServiceDaoImpl(ITaskAttrServiceDao taskAttrServiceDaoImpl) {
        this.taskAttrServiceDaoImpl = taskAttrServiceDaoImpl;
    }

    public IUserInnerServiceSMO getUserInnerServiceSMOImpl() {
        return userInnerServiceSMOImpl;
    }

    public void setUserInnerServiceSMOImpl(IUserInnerServiceSMO userInnerServiceSMOImpl) {
        this.userInnerServiceSMOImpl = userInnerServiceSMOImpl;
    }
}

 docs/document/services/taskAttr/DeleteTaskAttrInfo.md

New file
@@ -0,0 +1,175 @@
package com.java110.job.listener.taskAttr;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.java110.utils.constant.BusinessTypeConstant;
import com.java110.utils.constant.ResponseConstant;
import com.java110.utils.constant.StatusConstant;
import com.java110.utils.exception.ListenerExecuteException;
import com.java110.utils.util.Assert;
import com.java110.core.annotation.Java110Listener;
import com.java110.core.context.DataFlowContext;
import com.java110.entity.center.Business;
import com.java110.job.dao.ITaskAttrServiceDao;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional;

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

/**
 * 删除定时任务属性信息 侦听
 *
 * 处理节点
 * 1、businessTaskAttr:{} 定时任务属性基本信息节点
 * 2、businessTaskAttrAttr:[{}] 定时任务属性属性信息节点
 * 3、businessTaskAttrPhoto:[{}] 定时任务属性照片信息节点
 * 4、businessTaskAttrCerdentials:[{}] 定时任务属性证件信息节点
 * 协议地址 ：https://github.com/java110/MicroCommunity/wiki/%E5%88%A0%E9%99%A4%E5%95%86%E6%88%B7%E4%BF%A1%E6%81%AF-%E5%8D%8F%E8%AE%AE
 * Created by wuxw on 2018/5/18.
 */
@Java110Listener("deleteTaskAttrInfoListener")
@Transactional
public class DeleteTaskAttrInfoListener extends AbstractTaskAttrBusinessServiceDataFlowListener {

    private final static Logger logger = LoggerFactory.getLogger(DeleteTaskAttrInfoListener.class);
    @Autowired
    ITaskAttrServiceDao taskAttrServiceDaoImpl;

    @Override
    public int getOrder() {
        return 3;
    }

    @Override
    public String getBusinessTypeCd() {
        return BusinessTypeConstant.BUSINESS_TYPE_DELETE_TASK_ATTR;
    }

    /**
     * 根据删除信息 查出Instance表中数据 保存至business表 （状态写DEL） 方便撤单时直接更新回去
     * @param dataFlowContext 数据对象
     * @param business 当前业务对象
     */
    @Override
    protected void doSaveBusiness(DataFlowContext dataFlowContext, Business business) {
        JSONObject data = business.getDatas();

        Assert.notEmpty(data,"没有datas 节点，或没有子节点需要处理");

            //处理 businessTaskAttr 节点
            if(data.containsKey(TaskAttrPo.class.getSimpleName())){
                Object _obj = data.get(TaskAttrPo.class.getSimpleName());
                JSONArray businessTaskAttrs = null;
                if(_obj instanceof JSONObject){
                    businessTaskAttrs = new JSONArray();
                    businessTaskAttrs.add(_obj);
                }else {
                    businessTaskAttrs = (JSONArray)_obj;
                }
                //JSONObject businessTaskAttr = data.getJSONObject(TaskAttrPo.class.getSimpleName());
                for (int _taskAttrIndex = 0; _taskAttrIndex < businessTaskAttrs.size();_taskAttrIndex++) {
                    JSONObject businessTaskAttr = businessTaskAttrs.getJSONObject(_taskAttrIndex);
                    doBusinessTaskAttr(business, businessTaskAttr);
                    if(_obj instanceof JSONObject) {
                        dataFlowContext.addParamOut("attrId", businessTaskAttr.getString("attrId"));
                    }
                }

        }


    }

    /**
     * 删除 instance数据
     * @param dataFlowContext 数据对象
     * @param business 当前业务对象
     */
    @Override
    protected void doBusinessToInstance(DataFlowContext dataFlowContext, Business business) {
        String bId = business.getbId();
        //Assert.hasLength(bId,"请求报文中没有包含 bId");

        //定时任务属性信息
        Map info = new HashMap();
        info.put("bId",business.getbId());
        info.put("operate",StatusConstant.OPERATE_DEL);

        //定时任务属性信息
        List<Map> businessTaskAttrInfos = taskAttrServiceDaoImpl.getBusinessTaskAttrInfo(info);
        if( businessTaskAttrInfos != null && businessTaskAttrInfos.size() >0) {
            for (int _taskAttrIndex = 0; _taskAttrIndex < businessTaskAttrInfos.size();_taskAttrIndex++) {
                Map businessTaskAttrInfo = businessTaskAttrInfos.get(_taskAttrIndex);
                flushBusinessTaskAttrInfo(businessTaskAttrInfo,StatusConstant.STATUS_CD_INVALID);
                taskAttrServiceDaoImpl.updateTaskAttrInfoInstance(businessTaskAttrInfo);
                dataFlowContext.addParamOut("attrId",businessTaskAttrInfo.get("attr_id"));
            }
        }

    }

    /**
     * 撤单
     * 从business表中查询到DEL的数据 将instance中的数据更新回来
     * @param dataFlowContext 数据对象
     * @param business 当前业务对象
     */
    @Override
    protected void doRecover(DataFlowContext dataFlowContext, Business business) {
        String bId = business.getbId();
        //Assert.hasLength(bId,"请求报文中没有包含 bId");
        Map info = new HashMap();
        info.put("bId",bId);
        info.put("statusCd",StatusConstant.STATUS_CD_INVALID);

        Map delInfo = new HashMap();
        delInfo.put("bId",business.getbId());
        delInfo.put("operate",StatusConstant.OPERATE_DEL);
        //定时任务属性信息
        List<Map> taskAttrInfo = taskAttrServiceDaoImpl.getTaskAttrInfo(info);
        if(taskAttrInfo != null && taskAttrInfo.size() > 0){

            //定时任务属性信息
            List<Map> businessTaskAttrInfos = taskAttrServiceDaoImpl.getBusinessTaskAttrInfo(delInfo);
            //除非程序出错了，这里不会为空
            if(businessTaskAttrInfos == null ||  businessTaskAttrInfos.size() == 0){
                throw new ListenerExecuteException(ResponseConstant.RESULT_CODE_INNER_ERROR,"撤单失败（taskAttr），程序内部异常,请检查！ "+delInfo);
            }
            for (int _taskAttrIndex = 0; _taskAttrIndex < businessTaskAttrInfos.size();_taskAttrIndex++) {
                Map businessTaskAttrInfo = businessTaskAttrInfos.get(_taskAttrIndex);
                flushBusinessTaskAttrInfo(businessTaskAttrInfo,StatusConstant.STATUS_CD_VALID);
                taskAttrServiceDaoImpl.updateTaskAttrInfoInstance(businessTaskAttrInfo);
            }
        }
    }



    /**
     * 处理 businessTaskAttr 节点
     * @param business 总的数据节点
     * @param businessTaskAttr 定时任务属性节点
     */
    private void doBusinessTaskAttr(Business business,JSONObject businessTaskAttr){

        Assert.jsonObjectHaveKey(businessTaskAttr,"attrId","businessTaskAttr 节点下没有包含 attrId 节点");

        if(businessTaskAttr.getString("attrId").startsWith("-")){
            throw new ListenerExecuteException(ResponseConstant.RESULT_PARAM_ERROR,"attrId 错误，不能自动生成（必须已经存在的attrId）"+businessTaskAttr);
        }
        //自动插入DEL
        autoSaveDelBusinessTaskAttr(business,businessTaskAttr);
    }
    @Override
    public ITaskAttrServiceDao getTaskAttrServiceDaoImpl() {
        return taskAttrServiceDaoImpl;
    }

    public void setTaskAttrServiceDaoImpl(ITaskAttrServiceDao taskAttrServiceDaoImpl) {
        this.taskAttrServiceDaoImpl = taskAttrServiceDaoImpl;
    }
}

 docs/document/services/taskAttr/SaveTaskAttrInfo.md

New file
@@ -0,0 +1,175 @@
package com.java110.job.listener.taskAttr;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.java110.utils.constant.BusinessTypeConstant;
import com.java110.utils.constant.StatusConstant;
import com.java110.utils.util.Assert;
import com.java110.job.dao.ITaskAttrServiceDao;
import com.java110.core.annotation.Java110Listener;
import com.java110.core.context.DataFlowContext;
import com.java110.core.factory.GenerateCodeFactory;
import com.java110.entity.center.Business;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional;

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

/**
 * 保存 定时任务属性信息 侦听
 * Created by wuxw on 2018/5/18.
 */
@Java110Listener("saveTaskAttrInfoListener")
@Transactional
public class SaveTaskAttrInfoListener extends AbstractTaskAttrBusinessServiceDataFlowListener{

    private static Logger logger = LoggerFactory.getLogger(SaveTaskAttrInfoListener.class);

    @Autowired
    private ITaskAttrServiceDao taskAttrServiceDaoImpl;

    @Override
    public int getOrder() {
        return 0;
    }

    @Override
    public String getBusinessTypeCd() {
        return BusinessTypeConstant.BUSINESS_TYPE_SAVE_TASK_ATTR;
    }

    /**
     * 保存定时任务属性信息 business 表中
     * @param dataFlowContext 数据对象
     * @param business 当前业务对象
     */
    @Override
    protected void doSaveBusiness(DataFlowContext dataFlowContext, Business business) {
        JSONObject data = business.getDatas();
        Assert.notEmpty(data,"没有datas 节点，或没有子节点需要处理");

        //处理 businessTaskAttr 节点
        if(data.containsKey(TaskAttrPo.class.getSimpleName())){
            Object bObj = data.get(TaskAttrPo.class.getSimpleName());
            JSONArray businessTaskAttrs = null;
            if(bObj instanceof JSONObject){
                businessTaskAttrs = new JSONArray();
                businessTaskAttrs.add(bObj);
            }else {
                businessTaskAttrs = (JSONArray)bObj;
            }
            //JSONObject businessTaskAttr = data.getJSONObject(TaskAttrPo.class.getSimpleName());
            for (int bTaskAttrIndex = 0; bTaskAttrIndex < businessTaskAttrs.size();bTaskAttrIndex++) {
                JSONObject businessTaskAttr = businessTaskAttrs.getJSONObject(bTaskAttrIndex);
                doBusinessTaskAttr(business, businessTaskAttr);
                if(bObj instanceof JSONObject) {
                    dataFlowContext.addParamOut("attrId", businessTaskAttr.getString("attrId"));
                }
            }
        }
    }

    /**
     * business 数据转移到 instance
     * @param dataFlowContext 数据对象
     * @param business 当前业务对象
     */
    @Override
    protected void doBusinessToInstance(DataFlowContext dataFlowContext, Business business) {
        JSONObject data = business.getDatas();

        Map info = new HashMap();
        info.put("bId",business.getbId());
        info.put("operate",StatusConstant.OPERATE_ADD);

        //定时任务属性信息
        List<Map> businessTaskAttrInfo = taskAttrServiceDaoImpl.getBusinessTaskAttrInfo(info);
        if( businessTaskAttrInfo != null && businessTaskAttrInfo.size() >0) {
            reFreshShareColumn(info, businessTaskAttrInfo.get(0));
            taskAttrServiceDaoImpl.saveTaskAttrInfoInstance(info);
            if(businessTaskAttrInfo.size() == 1) {
                dataFlowContext.addParamOut("attrId", businessTaskAttrInfo.get(0).get("attr_id"));
            }
        }
    }


    /**
     * 刷 分片字段
     *
     * @param info         查询对象
     * @param businessInfo 小区ID
     */
    private void reFreshShareColumn(Map info, Map businessInfo) {

        if (info.containsKey("task_id")) {
            return;
        }

        if (!businessInfo.containsKey("taskId")) {
            return;
        }

        info.put("task_id", businessInfo.get("taskId"));
    }
    /**
     * 撤单
     * @param dataFlowContext 数据对象
     * @param business 当前业务对象
     */
    @Override
    protected void doRecover(DataFlowContext dataFlowContext, Business business) {
        String bId = business.getbId();
        //Assert.hasLength(bId,"请求报文中没有包含 bId");
        Map info = new HashMap();
        info.put("bId",bId);
        info.put("statusCd",StatusConstant.STATUS_CD_VALID);
        Map paramIn = new HashMap();
        paramIn.put("bId",bId);
        paramIn.put("statusCd",StatusConstant.STATUS_CD_INVALID);
        //定时任务属性信息
        List<Map> taskAttrInfo = taskAttrServiceDaoImpl.getTaskAttrInfo(info);
        if(taskAttrInfo != null && taskAttrInfo.size() > 0){
            reFreshShareColumn(paramIn, taskAttrInfo.get(0));
            taskAttrServiceDaoImpl.updateTaskAttrInfoInstance(paramIn);
        }
    }



    /**
     * 处理 businessTaskAttr 节点
     * @param business 总的数据节点
     * @param businessTaskAttr 定时任务属性节点
     */
    private void doBusinessTaskAttr(Business business,JSONObject businessTaskAttr){

        Assert.jsonObjectHaveKey(businessTaskAttr,"attrId","businessTaskAttr 节点下没有包含 attrId 节点");

        if(businessTaskAttr.getString("attrId").startsWith("-")){
            //刷新缓存
            //flushTaskAttrId(business.getDatas());

            businessTaskAttr.put("attrId",GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_attrId));

        }

        businessTaskAttr.put("bId",business.getbId());
        businessTaskAttr.put("operate", StatusConstant.OPERATE_ADD);
        //保存定时任务属性信息
        taskAttrServiceDaoImpl.saveBusinessTaskAttrInfo(businessTaskAttr);

    }
    @Override
    public ITaskAttrServiceDao getTaskAttrServiceDaoImpl() {
        return taskAttrServiceDaoImpl;
    }

    public void setTaskAttrServiceDaoImpl(ITaskAttrServiceDao taskAttrServiceDaoImpl) {
        this.taskAttrServiceDaoImpl = taskAttrServiceDaoImpl;
    }
}

 docs/document/services/taskAttr/UpdateTaskAttrInfo.md

New file
@@ -0,0 +1,188 @@
package com.java110.job.listener.taskAttr;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.java110.utils.constant.BusinessTypeConstant;
import com.java110.utils.constant.ResponseConstant;
import com.java110.utils.constant.StatusConstant;
import com.java110.utils.exception.ListenerExecuteException;
import com.java110.utils.util.Assert;
import com.java110.core.annotation.Java110Listener;
import com.java110.core.context.DataFlowContext;
import com.java110.entity.center.Business;
import com.java110.job.dao.ITaskAttrServiceDao;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional;

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

/**
 * 修改定时任务属性信息 侦听
 *
 * 处理节点
 * 1、businessTaskAttr:{} 定时任务属性基本信息节点
 * 2、businessTaskAttrAttr:[{}] 定时任务属性属性信息节点
 * 3、businessTaskAttrPhoto:[{}] 定时任务属性照片信息节点
 * 4、businessTaskAttrCerdentials:[{}] 定时任务属性证件信息节点
 * 协议地址 ：https://github.com/java110/MicroCommunity/wiki/%E4%BF%AE%E6%94%B9%E5%95%86%E6%88%B7%E4%BF%A1%E6%81%AF-%E5%8D%8F%E8%AE%AE
 * Created by wuxw on 2018/5/18.
 */
@Java110Listener("updateTaskAttrInfoListener")
@Transactional
public class UpdateTaskAttrInfoListener extends AbstractTaskAttrBusinessServiceDataFlowListener {

    private static Logger logger = LoggerFactory.getLogger(UpdateTaskAttrInfoListener.class);
    @Autowired
    private ITaskAttrServiceDao taskAttrServiceDaoImpl;

    @Override
    public int getOrder() {
        return 2;
    }

    @Override
    public String getBusinessTypeCd() {
        return BusinessTypeConstant.BUSINESS_TYPE_UPDATE_TASK_ATTR;
    }

    /**
     * business过程
     * @param dataFlowContext 上下文对象
     * @param business 业务对象
     */
    @Override
    protected void doSaveBusiness(DataFlowContext dataFlowContext, Business business) {

        JSONObject data = business.getDatas();

        Assert.notEmpty(data,"没有datas 节点，或没有子节点需要处理");


            //处理 businessTaskAttr 节点
            if(data.containsKey(TaskAttrPo.class.getSimpleName())){
                Object _obj = data.get(TaskAttrPo.class.getSimpleName());
                JSONArray businessTaskAttrs = null;
                if(_obj instanceof JSONObject){
                    businessTaskAttrs = new JSONArray();
                    businessTaskAttrs.add(_obj);
                }else {
                    businessTaskAttrs = (JSONArray)_obj;
                }
                //JSONObject businessTaskAttr = data.getJSONObject(TaskAttrPo.class.getSimpleName());
                for (int _taskAttrIndex = 0; _taskAttrIndex < businessTaskAttrs.size();_taskAttrIndex++) {
                    JSONObject businessTaskAttr = businessTaskAttrs.getJSONObject(_taskAttrIndex);
                    doBusinessTaskAttr(business, businessTaskAttr);
                    if(_obj instanceof JSONObject) {
                        dataFlowContext.addParamOut("attrId", businessTaskAttr.getString("attrId"));
                    }
                }
            }
    }


    /**
     * business to instance 过程
     * @param dataFlowContext 数据对象
     * @param business 当前业务对象
     */
    @Override
    protected void doBusinessToInstance(DataFlowContext dataFlowContext, Business business) {

        JSONObject data = business.getDatas();

        Map info = new HashMap();
        info.put("bId",business.getbId());
        info.put("operate",StatusConstant.OPERATE_ADD);

        //定时任务属性信息
        List<Map> businessTaskAttrInfos = taskAttrServiceDaoImpl.getBusinessTaskAttrInfo(info);
        if( businessTaskAttrInfos != null && businessTaskAttrInfos.size() >0) {
            for (int _taskAttrIndex = 0; _taskAttrIndex < businessTaskAttrInfos.size();_taskAttrIndex++) {
                Map businessTaskAttrInfo = businessTaskAttrInfos.get(_taskAttrIndex);
                flushBusinessTaskAttrInfo(businessTaskAttrInfo,StatusConstant.STATUS_CD_VALID);
                taskAttrServiceDaoImpl.updateTaskAttrInfoInstance(businessTaskAttrInfo);
                if(businessTaskAttrInfo.size() == 1) {
                    dataFlowContext.addParamOut("attrId", businessTaskAttrInfo.get("attr_id"));
                }
            }
        }

    }

    /**
     * 撤单
     * @param dataFlowContext 数据对象
     * @param business 当前业务对象
     */
    @Override
    protected void doRecover(DataFlowContext dataFlowContext, Business business) {

        String bId = business.getbId();
        //Assert.hasLength(bId,"请求报文中没有包含 bId");
        Map info = new HashMap();
        info.put("bId",bId);
        info.put("statusCd",StatusConstant.STATUS_CD_VALID);
        Map delInfo = new HashMap();
        delInfo.put("bId",business.getbId());
        delInfo.put("operate",StatusConstant.OPERATE_DEL);
        //定时任务属性信息
        List<Map> taskAttrInfo = taskAttrServiceDaoImpl.getTaskAttrInfo(info);
        if(taskAttrInfo != null && taskAttrInfo.size() > 0){

            //定时任务属性信息
            List<Map> businessTaskAttrInfos = taskAttrServiceDaoImpl.getBusinessTaskAttrInfo(delInfo);
            //除非程序出错了，这里不会为空
            if(businessTaskAttrInfos == null || businessTaskAttrInfos.size() == 0){
                throw new ListenerExecuteException(ResponseConstant.RESULT_CODE_INNER_ERROR,"撤单失败（taskAttr），程序内部异常,请检查！ "+delInfo);
            }
            for (int _taskAttrIndex = 0; _taskAttrIndex < businessTaskAttrInfos.size();_taskAttrIndex++) {
                Map businessTaskAttrInfo = businessTaskAttrInfos.get(_taskAttrIndex);
                flushBusinessTaskAttrInfo(businessTaskAttrInfo,StatusConstant.STATUS_CD_VALID);
                taskAttrServiceDaoImpl.updateTaskAttrInfoInstance(businessTaskAttrInfo);
            }
        }

    }



    /**
     * 处理 businessTaskAttr 节点
     * @param business 总的数据节点
     * @param businessTaskAttr 定时任务属性节点
     */
    private void doBusinessTaskAttr(Business business,JSONObject businessTaskAttr){

        Assert.jsonObjectHaveKey(businessTaskAttr,"attrId","businessTaskAttr 节点下没有包含 attrId 节点");

        if(businessTaskAttr.getString("attrId").startsWith("-")){
            throw new ListenerExecuteException(ResponseConstant.RESULT_PARAM_ERROR,"attrId 错误，不能自动生成（必须已经存在的attrId）"+businessTaskAttr);
        }
        //自动保存DEL
        autoSaveDelBusinessTaskAttr(business,businessTaskAttr);

        businessTaskAttr.put("bId",business.getbId());
        businessTaskAttr.put("operate", StatusConstant.OPERATE_ADD);
        //保存定时任务属性信息
        taskAttrServiceDaoImpl.saveBusinessTaskAttrInfo(businessTaskAttr);

    }



    @Override
    public ITaskAttrServiceDao getTaskAttrServiceDaoImpl() {
        return taskAttrServiceDaoImpl;
    }

    public void setTaskAttrServiceDaoImpl(ITaskAttrServiceDao taskAttrServiceDaoImpl) {
        this.taskAttrServiceDaoImpl = taskAttrServiceDaoImpl;
    }



}

 java110-bean/src/main/java/com/java110/dto/taskAttr/TaskAttrDto.java

New file
@@ -0,0 +1,77 @@
package com.java110.dto.taskAttr;

import com.java110.dto.PageDto;

import java.io.Serializable;
import java.util.Date;

/**
 * @ClassName FloorDto
 * @Description 定时任务属性数据层封装
 * @Author wuxw
 * @Date 2019/4/24 8:52
 * @Version 1.0
 * add by wuxw 2019/4/24
 **/
public class TaskAttrDto extends PageDto implements Serializable {

    private String attrId;
    private String specCd;
    private String value;
    private String taskId;


    private Date createTime;

    private String statusCd = "0";


    public String getAttrId() {
        return attrId;
    }

    public void setAttrId(String attrId) {
        this.attrId = attrId;
    }

    public String getSpecCd() {
        return specCd;
    }

    public void setSpecCd(String specCd) {
        this.specCd = specCd;
    }

    public String getValue() {
        return value;
    }

    public void setValue(String value) {
        this.value = value;
    }

    public String getTaskId() {
        return taskId;
    }

    public void setTaskId(String taskId) {
        this.taskId = taskId;
    }


    public Date getCreateTime() {
        return createTime;
    }

    public void setCreateTime(Date createTime) {
        this.createTime = createTime;
    }

    public String getStatusCd() {
        return statusCd;
    }

    public void setStatusCd(String statusCd) {
        this.statusCd = statusCd;
    }
}

 java110-bean/src/main/java/com/java110/po/taskAttr/TaskAttrPo.java

New file
@@ -0,0 +1,45 @@
package com.java110.po.taskAttr;

import java.io.Serializable;

public class TaskAttrPo implements Serializable {

    private String attrId;
    private String specCd;
    private String value;
    private String taskId;

    public String getAttrId() {
        return attrId;
    }

    public void setAttrId(String attrId) {
        this.attrId = attrId;
    }

    public String getSpecCd() {
        return specCd;
    }

    public void setSpecCd(String specCd) {
        this.specCd = specCd;
    }

    public String getValue() {
        return value;
    }

    public void setValue(String value) {
        this.value = value;
    }

    public String getTaskId() {
        return taskId;
    }

    public void setTaskId(String taskId) {
        this.taskId = taskId;
    }


}

 java110-code-generator/src/main/resources/back/template_1.json

@@ -1,26 +1,25 @@
{
  "autoMove": true,
  "id": "taskId",
  "name": "task",
  "desc": "定时任务",
  "id": "attrId",
  "name": "taskAttr",
  "desc": "定时任务属性",
  "shareParam": "task_id",
  "shareColumn": "taskId",
  "shareName": "job",
  "newBusinessTypeCd": "BUSINESS_TYPE_SAVE_TASK",
  "updateBusinessTypeCd": "BUSINESS_TYPE_UPDATE_TASK",
  "deleteBusinessTypeCd": "BUSINESS_TYPE_DELETE_TASK",
  "newBusinessTypeCdValue": "560200030001",
  "updateBusinessTypeCdValue": "560200040001",
  "deleteBusinessTypeCdValue": "560200050001",
  "businessTableName": "business_task",
  "tableName": "task",
  "newBusinessTypeCd": "BUSINESS_TYPE_SAVE_TASK_ATTR",
  "updateBusinessTypeCd": "BUSINESS_TYPE_UPDATE_TASK_ATTR",
  "deleteBusinessTypeCd": "BUSINESS_TYPE_DELETE_TASK_ATTR",
  "newBusinessTypeCdValue": "560300030001",
  "updateBusinessTypeCdValue": "560300040001",
  "deleteBusinessTypeCdValue": "560300050001",
  "businessTableName": "business_task_attr",
  "tableName": "task_attr",
  "param": {
    "taskId": "task_id",
    "attrId": "attr_id",
    "bId": "b_id",
    "taskName": "task_name",
    "templateId": "template_id",
    "taskCron": "task_cron",
    "state": "state",
    "taskId": "task_id",
    "specCd": "spec_cd",
    "value": "value",
    "statusCd": "status_cd",
    "createTime": "create_time",
    "operate": "operate"
@@ -28,16 +27,16 @@
  "required": [
    {

      "code": "taskName",
      "msg": "任务名称不能为空"
      "code": "taskId",
      "msg": "任务不能为空"
    },
    {
      "code": "templateId",
      "msg": "模板不能为空"
      "code": "specCd",
      "msg": "任务属性不能为空"
    },
    {
      "code": "taskCron",
      "msg": "定时时间不能为空"
      "code": "value",
      "msg": "任务属性值不能为空"
    }
  ]
}

 java110-code-generator/src/main/resources/back/template_task.json

New file
@@ -0,0 +1,43 @@
{
  "autoMove": true,
  "id": "taskId",
  "name": "task",
  "desc": "定时任务",
  "shareParam": "task_id",
  "shareColumn": "taskId",
  "shareName": "job",
  "newBusinessTypeCd": "BUSINESS_TYPE_SAVE_TASK",
  "updateBusinessTypeCd": "BUSINESS_TYPE_UPDATE_TASK",
  "deleteBusinessTypeCd": "BUSINESS_TYPE_DELETE_TASK",
  "newBusinessTypeCdValue": "560200030001",
  "updateBusinessTypeCdValue": "560200040001",
  "deleteBusinessTypeCdValue": "560200050001",
  "businessTableName": "business_task",
  "tableName": "task",
  "param": {
    "taskId": "task_id",
    "bId": "b_id",
    "taskName": "task_name",
    "templateId": "template_id",
    "taskCron": "task_cron",
    "state": "state",
    "statusCd": "status_cd",
    "createTime": "create_time",
    "operate": "operate"
  },
  "required": [
    {

      "code": "taskName",
      "msg": "任务名称不能为空"
    },
    {
      "code": "templateId",
      "msg": "模板不能为空"
    },
    {
      "code": "taskCron",
      "msg": "定时时间不能为空"
    }
  ]
}

 java110-core/src/main/java/com/java110/core/smo/taskAttr/ITaskAttrInnerServiceSMO.java

New file
@@ -0,0 +1,42 @@
package com.java110.core.smo.taskAttr;

import com.java110.core.feign.FeignConfiguration;
import com.java110.dto.taskAttr.TaskAttrDto;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;

import java.util.List;

/**
 * @ClassName ITaskAttrInnerServiceSMO
 * @Description 定时任务属性接口类
 * @Author wuxw
 * @Date 2019/4/24 9:04
 * @Version 1.0
 * add by wuxw 2019/4/24
 **/
@FeignClient(name = "job-service", configuration = {FeignConfiguration.class})
@RequestMapping("/taskAttrApi")
public interface ITaskAttrInnerServiceSMO {

    /**
     * <p>查询小区楼信息</p>
     *
     *
     * @param taskAttrDto 数据对象分享
     * @return TaskAttrDto 对象数据
     */
    @RequestMapping(value = "/queryTaskAttrs", method = RequestMethod.POST)
    List<TaskAttrDto> queryTaskAttrs(@RequestBody TaskAttrDto taskAttrDto);

    /**
     * 查询<p>小区楼</p>总记录数
     *
     * @param taskAttrDto 数据对象分享
     * @return 小区下的小区楼记录数
     */
    @RequestMapping(value = "/queryTaskAttrsCount", method = RequestMethod.POST)
    int queryTaskAttrsCount(@RequestBody TaskAttrDto taskAttrDto);
}

 java110-db/src/main/resources/mapper/job/TaskAttrServiceDaoImplMapper.xml

New file
@@ -0,0 +1,172 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="taskAttrServiceDaoImpl">

    <!-- 保存定时任务属性信息 add by wuxw 2018-07-03 -->
       <insert id="saveBusinessTaskAttrInfo" parameterType="Map">
           insert into business_task_attr(
attr_id,operate,create_time,spec_cd,b_id,value,task_id
) values (
#{attrId},#{operate},#{createTime},#{specCd},#{bId},#{value},#{taskId}
)
       </insert>


       <!-- 查询定时任务属性信息（Business） add by wuxw 2018-07-03 -->
       <select id="getBusinessTaskAttrInfo" parameterType="Map" resultType="Map">
           select  t.attr_id,t.attr_id attrId,t.operate,t.create_time,t.create_time createTime,t.spec_cd,t.spec_cd specCd,t.b_id,t.b_id bId,t.value,t.task_id,t.task_id taskId 
from business_task_attr t 
where 1 =1 
<if test="attrId !=null and attrId != ''">
   and t.attr_id= #{attrId}
</if> 
<if test="operate !=null and operate != ''">
   and t.operate= #{operate}
</if> 
<if test="createTime !=null and createTime != ''">
   and t.create_time= #{createTime}
</if> 
<if test="specCd !=null and specCd != ''">
   and t.spec_cd= #{specCd}
</if> 
<if test="bId !=null and bId != ''">
   and t.b_id= #{bId}
</if> 
<if test="value !=null and value != ''">
   and t.value= #{value}
</if> 
<if test="taskId !=null and taskId != ''">
   and t.task_id= #{taskId}
</if> 

       </select>





    <!-- 保存定时任务属性信息至 instance表中 add by wuxw 2018-07-03 -->
    <insert id="saveTaskAttrInfoInstance" parameterType="Map">
        insert into task_attr(
attr_id,create_time,spec_cd,status_cd,b_id,value,task_id
) select t.attr_id,t.create_time,t.spec_cd,'0',t.b_id,t.value,t.task_id from business_task_attr t where 1=1
<if test="attrId !=null and attrId != ''">
   and t.attr_id= #{attrId}
</if> 
   and t.operate= 'ADD'
<if test="createTime !=null and createTime != ''">
   and t.create_time= #{createTime}
</if> 
<if test="specCd !=null and specCd != ''">
   and t.spec_cd= #{specCd}
</if> 
<if test="bId !=null and bId != ''">
   and t.b_id= #{bId}
</if> 
<if test="value !=null and value != ''">
   and t.value= #{value}
</if> 
<if test="taskId !=null and taskId != ''">
   and t.task_id= #{taskId}
</if> 

    </insert>



    <!-- 查询定时任务属性信息 add by wuxw 2018-07-03 -->
    <select id="getTaskAttrInfo" parameterType="Map" resultType="Map">
        select  t.attr_id,t.attr_id attrId,t.create_time,t.create_time createTime,t.spec_cd,t.spec_cd specCd,t.status_cd,t.status_cd statusCd,t.b_id,t.b_id bId,t.value,t.task_id,t.task_id taskId 
from task_attr t 
where 1 =1 
<if test="attrId !=null and attrId != ''">
   and t.attr_id= #{attrId}
</if> 
<if test="createTime !=null and createTime != ''">
   and t.create_time= #{createTime}
</if> 
<if test="specCd !=null and specCd != ''">
   and t.spec_cd= #{specCd}
</if> 
<if test="statusCd !=null and statusCd != ''">
   and t.status_cd= #{statusCd}
</if> 
<if test="bId !=null and bId != ''">
   and t.b_id= #{bId}
</if> 
<if test="value !=null and value != ''">
   and t.value= #{value}
</if> 
<if test="taskId !=null and taskId != ''">
   and t.task_id= #{taskId}
</if> 
order by t.create_time desc
<if test="page != -1 and page != null ">
   limit #{page}, #{row}
</if> 

    </select>




    <!-- 修改定时任务属性信息 add by wuxw 2018-07-03 -->
    <update id="updateTaskAttrInfoInstance" parameterType="Map">
        update  task_attr t set t.status_cd = #{statusCd}
<if test="newBId != null and newBId != ''">
,t.b_id = #{newBId}
</if> 
<if test="createTime !=null and createTime != ''">
, t.create_time= #{createTime}
</if> 
<if test="specCd !=null and specCd != ''">
, t.spec_cd= #{specCd}
</if> 
<if test="value !=null and value != ''">
, t.value= #{value}
</if> 
<if test="taskId !=null and taskId != ''">
, t.task_id= #{taskId}
</if> 
 where 1=1 <if test="attrId !=null and attrId != ''">
and t.attr_id= #{attrId}
</if> 
<if test="bId !=null and bId != ''">
and t.b_id= #{bId}
</if> 

    </update>

    <!-- 查询定时任务属性数量 add by wuxw 2018-07-03 -->
     <select id="queryTaskAttrsCount" parameterType="Map" resultType="Map">
        select  count(1) count 
from task_attr t 
where 1 =1 
<if test="attrId !=null and attrId != ''">
   and t.attr_id= #{attrId}
</if> 
<if test="createTime !=null and createTime != ''">
   and t.create_time= #{createTime}
</if> 
<if test="specCd !=null and specCd != ''">
   and t.spec_cd= #{specCd}
</if> 
<if test="statusCd !=null and statusCd != ''">
   and t.status_cd= #{statusCd}
</if> 
<if test="bId !=null and bId != ''">
   and t.b_id= #{bId}
</if> 
<if test="value !=null and value != ''">
   and t.value= #{value}
</if> 
<if test="taskId !=null and taskId != ''">
   and t.task_id= #{taskId}
</if> 


     </select>

</mapper>

 java110-utils/src/main/java/com/java110/utils/constant/BusinessTypeConstant.java

@@ -1016,22 +1016,40 @@
    public static final String BUSINESS_TYPE_DELETE_JUNK_REQUIREMENT="550200050001";

    /**
     *  保存旧货市场
     *  保存任务
     *  3保存
     */
    public static final String BUSINESS_TYPE_SAVE_TASK="560200030001";


    /**
     *  修改旧货市场
     *  修改任务
     *  3保存
     */
    public static final String BUSINESS_TYPE_UPDATE_TASK="560200040001";

    /**
     * 删除旧货市场
     * 删除任务
     */
    public static final String BUSINESS_TYPE_DELETE_TASK="560200050001";

    /**
     *  保存任务
     *  3保存
     */
    public static final String BUSINESS_TYPE_SAVE_TASK_ATTR="560300030001";


    /**
     *  修改任务
     *  3保存
     */
    public static final String BUSINESS_TYPE_UPDATE_TASK_ATTR="560300040001";

    /**
     * 删除任务
     */
    public static final String BUSINESS_TYPE_DELETE_TASK_ATTR="560300050001";


}