新增了服务管理查询

Api/src/main/java/com/java110/api/listener/businesstype/QueryBusinessTypeConfigListener.java

@@ -8,8 +8,10 @@ import com.java110.common.util.Assert;
 import com.java110.common.util.BeanConvertUtil;
 import com.java110.core.annotation.Java110Listener;
 import com.java110.core.context.DataFlowContext;
-import com.java110.core.smo.businessytpe.IC_business_typeInnerServiceSMO;
-import com.java110.dto.businesstypecd.C_business_typeDto;
+import com.java110.core.smo.businesstype.ICbusinesstypeInnerServiceSMO;
+import com.java110.core.smo.demo.IDemoInnerServiceSMO;
+import com.java110.dto.businesstype.CbusinesstypeDto;
+import com.java110.dto.demo.DemoDto;
 import com.java110.event.service.api.ServiceDataFlowEvent;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.http.HttpMethod;
@@ -26,11 +28,11 @@ import java.util.List;
  * @Version 1.0
  * add by wuxw 2019/4/24
  **/
-@Java110Listener("queryBusinessTypeConfig")
+@Java110Listener("businessTypeDemoConfig")
 public class QueryBusinessTypeConfigListener extends AbstractServiceApiDataFlowListener {
 
     @Autowired
-    private IC_business_typeInnerServiceSMO ic_business_typeInnerServiceSMOImpl;
+    private ICbusinesstypeInnerServiceSMO iCbusinesstypeInnerServiceSMOImpl;
 
     @Override
     public String getServiceCode() {
@@ -52,10 +54,10 @@ public class QueryBusinessTypeConfigListener extends AbstractServiceApiDataFlowL
         DataFlowContext dataFlowContext = event.getDataFlowContext();
         //获取请求数据
         JSONObject reqJson = dataFlowContext.getReqJson();
-        validateDemoConfigData(reqJson);
+        //validateDemoConfigData(reqJson);
 
-        List<C_business_typeDto> C_business_typeDto = ic_business_typeInnerServiceSMOImpl.queryC_business_types(BeanConvertUtil.covertBean(reqJson, C_business_typeDto.class));
-        ResponseEntity<String> responseEntity = new ResponseEntity<String>(JSONObject.toJSONString(C_business_typeDto), HttpStatus.OK);
+        List<CbusinesstypeDto> cbusinesstypeDto = iCbusinesstypeInnerServiceSMOImpl.queryCbusinesstypes(BeanConvertUtil.covertBean(reqJson, CbusinesstypeDto.class));
+        ResponseEntity<String> responseEntity = new ResponseEntity<String>(JSONObject.toJSONString(cbusinesstypeDto), HttpStatus.OK);
 
         dataFlowContext.setResponseEntity(responseEntity);
     }
@@ -66,7 +68,9 @@ public class QueryBusinessTypeConfigListener extends AbstractServiceApiDataFlowL
      * @param reqJson 包含查询条件
      */
     private void validateDemoConfigData(JSONObject reqJson) {
-       System.out.println("校验已经通过");
+        Assert.jsonObjectHaveKey(reqJson, "demoName", "请求中未包含demoName信息");
+        Assert.jsonObjectHaveKey(reqJson, "demoValue", "请求中未包含demoValue信息");
+
 
     }
 
@@ -75,11 +79,11 @@ public class QueryBusinessTypeConfigListener extends AbstractServiceApiDataFlowL
         return super.DEFAULT_ORDER;
     }
 
-    public IC_business_typeInnerServiceSMO getIc_business_typeInnerServiceSMOImpl() {
-        return ic_business_typeInnerServiceSMOImpl;
+    public ICbusinesstypeInnerServiceSMO getiCbusinesstypeInnerServiceSMOImpl() {
+        return iCbusinesstypeInnerServiceSMOImpl;
     }
 
-    public void setIc_business_typeInnerServiceSMOImpl(IC_business_typeInnerServiceSMO ic_business_typeInnerServiceSMOImpl) {
-        this.ic_business_typeInnerServiceSMOImpl = ic_business_typeInnerServiceSMOImpl;
+    public void setiCbusinesstypeInnerServiceSMOImpl(ICbusinesstypeInnerServiceSMO iCbusinesstypeInnerServiceSMOImpl) {
+        this.iCbusinesstypeInnerServiceSMOImpl = iCbusinesstypeInnerServiceSMOImpl;
     }
 }

StoreService/src/main/java/com/java110/store/dao/IC_business_typeServiceDao.java

@@ -1,81 +0,0 @@
-package com.java110.store.dao;
-
-
-import com.java110.common.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;
-
-/**
- * BusinessType组件内部之间使用，没有给外围系统提供服务能力
- * BusinessType服务接口类，要求全部以字符串传输，方便微服务化
- * 新建客户，修改客户，删除客户，查询客户等功能
- *
- * Created by wuxw on 2016/12/27.
- */
-public interface IC_business_typeServiceDao {
-
-    /**
-     * 保存 BusinessType信息
-     * @param businessC_business_typeInfo BusinessType信息 封装
-     * @throws DAOException 操作数据库异常
-     */
-    void saveBusinessC_business_typeInfo(Map businessC_business_typeInfo) throws DAOException;
-
-
-
-    /**
-     * 查询BusinessType信息（business过程）
-     * 根据bId 查询BusinessType信息
-     * @param info bId 信息
-     * @return BusinessType信息
-     * @throws DAOException DAO异常
-     */
-    List<Map> getBusinessC_business_typeInfo(Map info) throws DAOException;
-
-
-
-
-    /**
-     * 保存 BusinessType信息 Business数据到 Instance中
-     * @param info
-     * @throws DAOException DAO异常
-     */
-    void saveC_business_typeInfoInstance(Map info) throws DAOException;
-
-
-
-
-    /**
-     * 查询BusinessType信息（instance过程）
-     * 根据bId 查询BusinessType信息
-     * @param info bId 信息
-     * @return BusinessType信息
-     * @throws DAOException DAO异常
-     */
-    List<Map> getC_business_typeInfo(Map info) throws DAOException;
-
-
-
-    /**
-     * 修改BusinessType信息
-     * @param info 修改信息
-     * @throws DAOException DAO异常
-     */
-    void updateC_business_typeInfoInstance(Map info) throws DAOException;
-
-
-    /**
-     * 查询BusinessType总数
-     *
-     * @param info BusinessType信息
-     * @return BusinessType数量
-     */
-    int queryC_business_typesCount(Map info);
-
-}

StoreService/src/main/java/com/java110/store/dao/ICbusinesstypeServiceDao.java

@@ -0,0 +1,81 @@
+package com.java110.store.dao;
+
+
+import com.java110.common.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;
+
+/**
+ * cbusinesstype组件内部之间使用，没有给外围系统提供服务能力
+ * cbusinesstype服务接口类，要求全部以字符串传输，方便微服务化
+ * 新建客户，修改客户，删除客户，查询客户等功能
+ *
+ * Created by wuxw on 2016/12/27.
+ */
+public interface ICbusinesstypeServiceDao {
+
+    /**
+     * 保存 cbusinesstype信息
+     * @param businessCbusinesstypeInfo cbusinesstype信息 封装
+     * @throws DAOException 操作数据库异常
+     */
+    void saveBusinessCbusinesstypeInfo(Map businessCbusinesstypeInfo) throws DAOException;
+
+
+
+    /**
+     * 查询cbusinesstype信息（business过程）
+     * 根据bId 查询cbusinesstype信息
+     * @param info bId 信息
+     * @return cbusinesstype信息
+     * @throws DAOException DAO异常
+     */
+    List<Map> getBusinessCbusinesstypeInfo(Map info) throws DAOException;
+
+
+
+
+    /**
+     * 保存 cbusinesstype信息 Business数据到 Instance中
+     * @param info
+     * @throws DAOException DAO异常
+     */
+    void saveCbusinesstypeInfoInstance(Map info) throws DAOException;
+
+
+
+
+    /**
+     * 查询cbusinesstype信息（instance过程）
+     * 根据bId 查询cbusinesstype信息
+     * @param info bId 信息
+     * @return cbusinesstype信息
+     * @throws DAOException DAO异常
+     */
+    List<Map> getCbusinesstypeInfo(Map info) throws DAOException;
+
+
+
+    /**
+     * 修改cbusinesstype信息
+     * @param info 修改信息
+     * @throws DAOException DAO异常
+     */
+    void updateCbusinesstypeInfoInstance(Map info) throws DAOException;
+
+
+    /**
+     * 查询cbusinesstype总数
+     *
+     * @param info cbusinesstype信息
+     * @return cbusinesstype数量
+     */
+    int queryCbusinesstypesCount(Map info);
+
+}

StoreService/src/main/java/com/java110/store/dao/businesstype/CbusinesstypeServiceDaoImpl.java

@@ -0,0 +1,130 @@
+package com.java110.store.dao.businesstype;
+
+import com.alibaba.fastjson.JSONObject;
+import com.java110.common.constant.ResponseConstant;
+import com.java110.common.exception.DAOException;
+import com.java110.common.util.DateUtil;
+import com.java110.core.base.dao.BaseServiceDao;
+import com.java110.store.dao.ICbusinesstypeServiceDao;
+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;
+
+/**
+ * cbusinesstype服务 与数据库交互
+ * Created by wuxw on 2017/4/5.
+ */
+@Service("cbusinesstypeServiceDaoImpl")
+//@Transactional
+public class CbusinesstypeServiceDaoImpl extends BaseServiceDao implements ICbusinesstypeServiceDao {
+
+    private static Logger logger = LoggerFactory.getLogger(CbusinesstypeServiceDaoImpl.class);
+
+    /**
+     * cbusinesstype信息封装
+     * @param businessCbusinesstypeInfo cbusinesstype信息 封装
+     * @throws DAOException DAO异常
+     */
+    @Override
+    public void saveBusinessCbusinesstypeInfo(Map businessCbusinesstypeInfo) throws DAOException {
+        businessCbusinesstypeInfo.put("month", DateUtil.getCurrentMonth());
+        // 查询business_user 数据是否已经存在
+        logger.debug("保存cbusinesstype信息 入参 businessCbusinesstypeInfo : {}",businessCbusinesstypeInfo);
+        int saveFlag = sqlSessionTemplate.insert("cbusinesstypeServiceDaoImpl.saveBusinessCbusinesstypeInfo",businessCbusinesstypeInfo);
+
+        if(saveFlag < 1){
+            throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR,"保存cbusinesstype数据失败："+ JSONObject.toJSONString(businessCbusinesstypeInfo));
+        }
+    }
+
+
+    /**
+     * 查询cbusinesstype信息
+     * @param info bId 信息
+     * @return cbusinesstype信息
+     * @throws DAOException DAO异常
+     */
+    @Override
+    public List<Map> getBusinessCbusinesstypeInfo(Map info) throws DAOException {
+
+        logger.debug("查询cbusinesstype信息 入参 info : {}",info);
+
+        List<Map> businessCbusinesstypeInfos = sqlSessionTemplate.selectList("cbusinesstypeServiceDaoImpl.getBusinessCbusinesstypeInfo",info);
+
+        return businessCbusinesstypeInfos;
+    }
+
+
+
+    /**
+     * 保存cbusinesstype信息 到 instance
+     * @param info   bId 信息
+     * @throws DAOException DAO异常
+     */
+    @Override
+    public void saveCbusinesstypeInfoInstance(Map info) throws DAOException {
+        logger.debug("保存cbusinesstype信息Instance 入参 info : {}",info);
+
+        int saveFlag = sqlSessionTemplate.insert("cbusinesstypeServiceDaoImpl.saveCbusinesstypeInfoInstance",info);
+
+        if(saveFlag < 1){
+            throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR,"保存cbusinesstype信息Instance数据失败："+ JSONObject.toJSONString(info));
+        }
+    }
+
+
+    /**
+     * 查询cbusinesstype信息（instance）
+     * @param info bId 信息
+     * @return List<Map>
+     * @throws DAOException DAO异常
+     */
+    @Override
+    public List<Map> getCbusinesstypeInfo(Map info) throws DAOException {
+        logger.debug("查询cbusinesstype信息 入参 info : {}",info);
+
+        List<Map> businessCbusinesstypeInfos = sqlSessionTemplate.selectList("cbusinesstypeServiceDaoImpl.getCbusinesstypeInfo",info);
+
+        return businessCbusinesstypeInfos;
+    }
+
+
+    /**
+     * 修改cbusinesstype信息
+     * @param info 修改信息
+     * @throws DAOException DAO异常
+     */
+    @Override
+    public void updateCbusinesstypeInfoInstance(Map info) throws DAOException {
+        logger.debug("修改cbusinesstype信息Instance 入参 info : {}",info);
+
+        int saveFlag = sqlSessionTemplate.update("cbusinesstypeServiceDaoImpl.updateCbusinesstypeInfoInstance",info);
+
+        if(saveFlag < 1){
+            throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR,"修改cbusinesstype信息Instance数据失败："+ JSONObject.toJSONString(info));
+        }
+    }
+
+     /**
+     * 查询cbusinesstype数量
+     * @param info cbusinesstype信息
+     * @return cbusinesstype数量
+     */
+    @Override
+    public int queryCbusinesstypesCount(Map info) {
+        logger.debug("查询cbusinesstype数据 入参 info : {}",info);
+
+        List<Map> businessCbusinesstypeInfos = sqlSessionTemplate.selectList("cbusinesstypeServiceDaoImpl.queryCbusinesstypesCount", info);
+        if (businessCbusinesstypeInfos.size() < 1) {
+            return 0;
+        }
+
+        return Integer.parseInt(businessCbusinesstypeInfos.get(0).get("count").toString());
+    }
+
+
+}

StoreService/src/main/java/com/java110/store/dao/impl/businesstype/C_business_typeServiceDaoImpl.java

@@ -1,129 +0,0 @@
-package com.java110.store.dao.impl.businesstype;
-
-import com.alibaba.fastjson.JSONObject;
-import com.java110.common.constant.ResponseConstant;
-import com.java110.common.exception.DAOException;
-import com.java110.common.util.DateUtil;
-import com.java110.core.base.dao.BaseServiceDao;
-import com.java110.store.dao.IC_business_typeServiceDao;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.stereotype.Service;
-
-import java.util.List;
-import java.util.Map;
-
-/**
- * BusinessType服务 与数据库交互
- * Created by wuxw on 2017/4/5.
- */
-@Service("c_business_typeServiceDaoImpl")
-//@Transactional
-public class C_business_typeServiceDaoImpl extends BaseServiceDao implements IC_business_typeServiceDao {
-
-    private static Logger logger = LoggerFactory.getLogger(C_business_typeServiceDaoImpl.class);
-
-    /**
-     * BusinessType信息封装
-     * @param businessC_business_typeInfo BusinessType信息 封装
-     * @throws DAOException DAO异常
-     */
-    @Override
-    public void saveBusinessC_business_typeInfo(Map businessC_business_typeInfo) throws DAOException {
-        businessC_business_typeInfo.put("month", DateUtil.getCurrentMonth());
-        // 查询business_user 数据是否已经存在
-        logger.debug("保存BusinessType信息 入参 businessC_business_typeInfo : {}",businessC_business_typeInfo);
-        int saveFlag = sqlSessionTemplate.insert("c_business_typeServiceDaoImpl.saveBusinessC_business_typeInfo",businessC_business_typeInfo);
-
-        if(saveFlag < 1){
-            throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR,"保存BusinessType数据失败："+ JSONObject.toJSONString(businessC_business_typeInfo));
-        }
-    }
-
-
-    /**
-     * 查询BusinessType信息
-     * @param info bId 信息
-     * @return BusinessType信息
-     * @throws DAOException DAO异常
-     */
-    @Override
-    public List<Map> getBusinessC_business_typeInfo(Map info) throws DAOException {
-
-        logger.debug("查询BusinessType信息 入参 info : {}",info);
-
-        List<Map> businessC_business_typeInfos = sqlSessionTemplate.selectList("c_business_typeServiceDaoImpl.getBusinessC_business_typeInfo",info);
-
-        return businessC_business_typeInfos;
-    }
-
-
-
-    /**
-     * 保存BusinessType信息 到 instance
-     * @param info   bId 信息
-     * @throws DAOException DAO异常
-     */
-    @Override
-    public void saveC_business_typeInfoInstance(Map info) throws DAOException {
-        logger.debug("保存BusinessType信息Instance 入参 info : {}",info);
-
-        int saveFlag = sqlSessionTemplate.insert("c_business_typeServiceDaoImpl.saveC_business_typeInfoInstance",info);
-
-        if(saveFlag < 1){
-            throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR,"保存BusinessType信息Instance数据失败："+ JSONObject.toJSONString(info));
-        }
-    }
-
-
-    /**
-     * 查询BusinessType信息（instance）
-     * @param info bId 信息
-     * @return List<Map>
-     * @throws DAOException DAO异常
-     */
-    @Override
-    public List<Map> getC_business_typeInfo(Map info) throws DAOException {
-        logger.debug("查询BusinessType信息 入参 info : {}",info);
-
-        List<Map> businessC_business_typeInfos = sqlSessionTemplate.selectList("c_business_typeServiceDaoImpl.getC_business_typeInfo",info);
-
-        return businessC_business_typeInfos;
-    }
-
-
-    /**
-     * 修改BusinessType信息
-     * @param info 修改信息
-     * @throws DAOException DAO异常
-     */
-    @Override
-    public void updateC_business_typeInfoInstance(Map info) throws DAOException {
-        logger.debug("修改BusinessType信息Instance 入参 info : {}",info);
-
-        int saveFlag = sqlSessionTemplate.update("c_business_typeServiceDaoImpl.updateC_business_typeInfoInstance",info);
-
-        if(saveFlag < 1){
-            throw new DAOException(ResponseConstant.RESULT_PARAM_ERROR,"修改BusinessType信息Instance数据失败："+ JSONObject.toJSONString(info));
-        }
-    }
-
-     /**
-     * 查询BusinessType数量
-     * @param info BusinessType信息
-     * @return BusinessType数量
-     */
-    @Override
-    public int queryC_business_typesCount(Map info) {
-        logger.debug("查询BusinessType数据 入参 info : {}",info);
-
-        List<Map> businessC_business_typeInfos = sqlSessionTemplate.selectList("c_business_typeServiceDaoImpl.queryC_business_typesCount", info);
-        if (businessC_business_typeInfos.size() < 1) {
-            return 0;
-        }
-
-        return Integer.parseInt(businessC_business_typeInfos.get(0).get("count").toString());
-    }
-
-
-}

StoreService/src/main/java/com/java110/store/listener/businesstype/AbstractCbusinesstypeBusinessServiceDataFlowListener.java

@@ -0,0 +1,81 @@
+package com.java110.store.listener.businesstype;
+
+import com.alibaba.fastjson.JSONObject;
+import com.java110.common.constant.ResponseConstant;
+import com.java110.common.constant.StatusConstant;
+import com.java110.common.exception.ListenerExecuteException;
+import com.java110.core.factory.GenerateCodeFactory;
+import com.java110.entity.center.Business;
+import com.java110.event.service.AbstractBusinessServiceDataFlowListener;
+import com.java110.cbusinesstype.dao.ICbusinesstypeServiceDao;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ *
+ * cbusinesstype 服务侦听 父类
+ * Created by wuxw on 2018/7/4.
+ */
+public abstract class AbstractCbusinesstypeBusinessServiceDataFlowListener extends AbstractBusinessServiceDataFlowListener{
+    private static Logger logger = LoggerFactory.getLogger(AbstractCbusinesstypeBusinessServiceDataFlowListener.class);
+
+
+    /**
+     * 获取 DAO工具类
+     * @return
+     */
+    public abstract ICbusinesstypeServiceDao getCbusinesstypeServiceDaoImpl();
+
+    /**
+     * 刷新 businessCbusinesstypeInfo 数据
+     * 主要将 数据库 中字段和 接口传递字段建立关系
+     * @param businessCbusinesstypeInfo
+     */
+    protected void flushBusinessCbusinesstypeInfo(Map businessCbusinesstypeInfo,String statusCd){
+        businessCbusinesstypeInfo.put("newBId", businessCbusinesstypeInfo.get("b_id"));
+        businessCbusinesstypeInfo.put("businessTypeCd",businessCbusinesstypeInfo.get("business_type_cd"));
+businessCbusinesstypeInfo.put("name",businessCbusinesstypeInfo.get("name"));
+businessCbusinesstypeInfo.put("description",businessCbusinesstypeInfo.get("description"));
+businessCbusinesstypeInfo.put("id",businessCbusinesstypeInfo.get("id"));
+businessCbusinesstypeInfo.remove("bId");
+        businessCbusinesstypeInfo.put("statusCd", statusCd);
+    }
+
+
+    /**
+     * 当修改数据时，查询instance表中的数据 自动保存删除数据到business中
+     * @param businessCbusinesstype cbusinesstype信息
+     */
+    protected void autoSaveDelBusinessCbusinesstype(Business business, JSONObject businessCbusinesstype){
+//自动插入DEL
+        Map info = new HashMap();
+        info.put("id",businessCbusinesstype.getString("id"));
+        info.put("statusCd",StatusConstant.STATUS_CD_VALID);
+        List<Map> currentCbusinesstypeInfos = getCbusinesstypeServiceDaoImpl().getCbusinesstypeInfo(info);
+        if(currentCbusinesstypeInfos == null || currentCbusinesstypeInfos.size() != 1){
+            throw new ListenerExecuteException(ResponseConstant.RESULT_PARAM_ERROR,"未找到需要修改数据信息，入参错误或数据有问题，请检查"+info);
+        }
+
+        Map currentCbusinesstypeInfo = currentCbusinesstypeInfos.get(0);
+
+        currentCbusinesstypeInfo.put("bId",business.getbId());
+
+        currentCbusinesstypeInfo.put("businessTypeCd",currentCbusinesstypeInfo.get("business_type_cd"));
+currentCbusinesstypeInfo.put("name",currentCbusinesstypeInfo.get("name"));
+currentCbusinesstypeInfo.put("description",currentCbusinesstypeInfo.get("description"));
+currentCbusinesstypeInfo.put("id",currentCbusinesstypeInfo.get("id"));
+
+
+        currentCbusinesstypeInfo.put("operate",StatusConstant.OPERATE_DEL);
+        getCbusinesstypeServiceDaoImpl().saveBusinessCbusinesstypeInfo(currentCbusinesstypeInfo);
+    }
+
+
+
+
+
+}

StoreService/src/main/java/com/java110/store/listener/businesstype/DeleteCbusinesstypeInfoListener.java

@@ -0,0 +1,177 @@
+package com.java110.store.listener.businesstype;
+
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.java110.common.constant.BusinessTypeConstant;
+import com.java110.common.constant.ResponseConstant;
+import com.java110.common.constant.StatusConstant;
+import com.java110.common.exception.ListenerExecuteException;
+import com.java110.common.util.Assert;
+import com.java110.core.annotation.Java110Listener;
+import com.java110.core.context.DataFlowContext;
+import com.java110.entity.center.Business;
+import com.java110.cbusinesstype.dao.ICbusinesstypeServiceDao;
+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;
+
+/**
+ * 删除cbusinesstype信息 侦听
+ *
+ * 处理节点
+ * 1、businessCbusinesstype:{} cbusinesstype基本信息节点
+ * 2、businessCbusinesstypeAttr:[{}] cbusinesstype属性信息节点
+ * 3、businessCbusinesstypePhoto:[{}] cbusinesstype照片信息节点
+ * 4、businessCbusinesstypeCerdentials:[{}] cbusinesstype证件信息节点
+ * 协议地址 ：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("deleteCbusinesstypeInfoListener")
+@Transactional
+public class DeleteCbusinesstypeInfoListener extends AbstractCbusinesstypeBusinessServiceDataFlowListener {
+
+    private final static Logger logger = LoggerFactory.getLogger(DeleteCbusinesstypeInfoListener.class);
+    @Autowired
+    ICbusinesstypeServiceDao cbusinesstypeServiceDaoImpl;
+
+    @Override
+    public int getOrder() {
+        return 3;
+    }
+
+    @Override
+    public String getBusinessTypeCd() {
+        return BusinessTypeConstant.BUSINESS_TYPE_DELETE_BUSINESSTYPE_INFO;
+    }
+
+    /**
+     * 根据删除信息 查出Instance表中数据 保存至business表 （状态写DEL） 方便撤单时直接更新回去
+     * @param dataFlowContext 数据对象
+     * @param business 当前业务对象
+     */
+    @Override
+    protected void doSaveBusiness(DataFlowContext dataFlowContext, Business business) {
+        JSONObject data = business.getDatas();
+
+        Assert.notEmpty(data,"没有datas 节点，或没有子节点需要处理");
+
+        //处理 businessCbusinesstype 节点
+        if(data.containsKey("businessCbusinesstype")){
+            //处理 businessCbusinesstype 节点
+            if(data.containsKey("businessCbusinesstype")){
+                Object _obj = data.get("businessCbusinesstype");
+                JSONArray businessCbusinesstypes = null;
+                if(_obj instanceof JSONObject){
+                    businessCbusinesstypes = new JSONArray();
+                    businessCbusinesstypes.add(_obj);
+                }else {
+                    businessCbusinesstypes = (JSONArray)_obj;
+                }
+                //JSONObject businessCbusinesstype = data.getJSONObject("businessCbusinesstype");
+                for (int _cbusinesstypeIndex = 0; _cbusinesstypeIndex < businessCbusinesstypes.size();_cbusinesstypeIndex++) {
+                    JSONObject businessCbusinesstype = businessCbusinesstypes.getJSONObject(_cbusinesstypeIndex);
+                    doBusinessCbusinesstype(business, businessCbusinesstype);
+                    if(_obj instanceof JSONObject) {
+                        dataFlowContext.addParamOut("id", businessCbusinesstype.getString("id"));
+                    }
+                }
+            }
+        }
+
+
+    }
+
+    /**
+     * 删除 instance数据
+     * @param dataFlowContext 数据对象
+     * @param business 当前业务对象
+     */
+    @Override
+    protected void doBusinessToInstance(DataFlowContext dataFlowContext, Business business) {
+        String bId = business.getbId();
+        //Assert.hasLength(bId,"请求报文中没有包含 bId");
+
+        //cbusinesstype信息
+        Map info = new HashMap();
+        info.put("bId",business.getbId());
+        info.put("operate",StatusConstant.OPERATE_DEL);
+
+        //cbusinesstype信息
+        List<Map> businessCbusinesstypeInfos = cbusinesstypeServiceDaoImpl.getBusinessCbusinesstypeInfo(info);
+        if( businessCbusinesstypeInfos != null && businessCbusinesstypeInfos.size() >0) {
+            for (int _cbusinesstypeIndex = 0; _cbusinesstypeIndex < businessCbusinesstypeInfos.size();_cbusinesstypeIndex++) {
+                Map businessCbusinesstypeInfo = businessCbusinesstypeInfos.get(_cbusinesstypeIndex);
+                flushBusinessCbusinesstypeInfo(businessCbusinesstypeInfo,StatusConstant.STATUS_CD_INVALID);
+                cbusinesstypeServiceDaoImpl.updateCbusinesstypeInfoInstance(businessCbusinesstypeInfo);
+                dataFlowContext.addParamOut("id",businessCbusinesstypeInfo.get("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);
+        //cbusinesstype信息
+        List<Map> cbusinesstypeInfo = cbusinesstypeServiceDaoImpl.getCbusinesstypeInfo(info);
+        if(cbusinesstypeInfo != null && cbusinesstypeInfo.size() > 0){
+
+            //cbusinesstype信息
+            List<Map> businessCbusinesstypeInfos = cbusinesstypeServiceDaoImpl.getBusinessCbusinesstypeInfo(delInfo);
+            //除非程序出错了，这里不会为空
+            if(businessCbusinesstypeInfos == null ||  businessCbusinesstypeInfos.size() == 0){
+                throw new ListenerExecuteException(ResponseConstant.RESULT_CODE_INNER_ERROR,"撤单失败（cbusinesstype），程序内部异常,请检查！ "+delInfo);
+            }
+            for (int _cbusinesstypeIndex = 0; _cbusinesstypeIndex < businessCbusinesstypeInfos.size();_cbusinesstypeIndex++) {
+                Map businessCbusinesstypeInfo = businessCbusinesstypeInfos.get(_cbusinesstypeIndex);
+                flushBusinessCbusinesstypeInfo(businessCbusinesstypeInfo,StatusConstant.STATUS_CD_VALID);
+                cbusinesstypeServiceDaoImpl.updateCbusinesstypeInfoInstance(businessCbusinesstypeInfo);
+            }
+        }
+    }
+
+
+
+    /**
+     * 处理 businessCbusinesstype 节点
+     * @param business 总的数据节点
+     * @param businessCbusinesstype cbusinesstype节点
+     */
+    private void doBusinessCbusinesstype(Business business,JSONObject businessCbusinesstype){
+
+        Assert.jsonObjectHaveKey(businessCbusinesstype,"id","businessCbusinesstype 节点下没有包含 id 节点");
+
+        if(businessCbusinesstype.getString("id").startsWith("-")){
+            throw new ListenerExecuteException(ResponseConstant.RESULT_PARAM_ERROR,"id 错误，不能自动生成（必须已经存在的id）"+businessCbusinesstype);
+        }
+        //自动插入DEL
+        autoSaveDelBusinessCbusinesstype(business,businessCbusinesstype);
+    }
+
+    public ICbusinesstypeServiceDao getCbusinesstypeServiceDaoImpl() {
+        return cbusinesstypeServiceDaoImpl;
+    }
+
+    public void setCbusinesstypeServiceDaoImpl(ICbusinesstypeServiceDao cbusinesstypeServiceDaoImpl) {
+        this.cbusinesstypeServiceDaoImpl = cbusinesstypeServiceDaoImpl;
+    }
+}

StoreService/src/main/java/com/java110/store/listener/businesstype/SaveCbusinesstypeInfoListener.java

@@ -0,0 +1,175 @@
+package com.java110.store.listener.businesstype;
+
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.java110.common.constant.BusinessTypeConstant;
+import com.java110.common.constant.StatusConstant;
+import com.java110.common.util.Assert;
+import com.java110.community.dao.ICbusinesstypeServiceDao;
+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;
+
+/**
+ * 保存 cbusinesstype信息 侦听
+ * Created by wuxw on 2018/5/18.
+ */
+@Java110Listener("saveCbusinesstypeInfoListener")
+@Transactional
+public class SaveCbusinesstypeInfoListener extends AbstractCbusinesstypeBusinessServiceDataFlowListener{
+
+    private static Logger logger = LoggerFactory.getLogger(SaveCbusinesstypeInfoListener.class);
+
+    @Autowired
+    private ICbusinesstypeServiceDao cbusinesstypeServiceDaoImpl;
+
+    @Override
+    public int getOrder() {
+        return 0;
+    }
+
+    @Override
+    public String getBusinessTypeCd() {
+        return BusinessTypeConstant.BUSINESS_TYPE_SAVE_BUSINESSTYPE_INFO;
+    }
+
+    /**
+     * 保存cbusinesstype信息 business 表中
+     * @param dataFlowContext 数据对象
+     * @param business 当前业务对象
+     */
+    @Override
+    protected void doSaveBusiness(DataFlowContext dataFlowContext, Business business) {
+        JSONObject data = business.getDatas();
+        Assert.notEmpty(data,"没有datas 节点，或没有子节点需要处理");
+
+        //处理 businessCbusinesstype 节点
+        if(data.containsKey("businessCbusinesstype")){
+            Object bObj = data.get("businessCbusinesstype");
+            JSONArray businessCbusinesstypes = null;
+            if(bObj instanceof JSONObject){
+                businessCbusinesstypes = new JSONArray();
+                businessCbusinesstypes.add(bObj);
+            }else {
+                businessCbusinesstypes = (JSONArray)bObj;
+            }
+            //JSONObject businessCbusinesstype = data.getJSONObject("businessCbusinesstype");
+            for (int bCbusinesstypeIndex = 0; bCbusinesstypeIndex < businessCbusinesstypes.size();bCbusinesstypeIndex++) {
+                JSONObject businessCbusinesstype = businessCbusinesstypes.getJSONObject(bCbusinesstypeIndex);
+                doBusinessCbusinesstype(business, businessCbusinesstype);
+                if(bObj instanceof JSONObject) {
+                    dataFlowContext.addParamOut("id", businessCbusinesstype.getString("id"));
+                }
+            }
+        }
+    }
+
+    /**
+     * 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);
+
+        //cbusinesstype信息
+        List<Map> businessCbusinesstypeInfo = cbusinesstypeServiceDaoImpl.getBusinessCbusinesstypeInfo(info);
+        if( businessCbusinesstypeInfo != null && businessCbusinesstypeInfo.size() >0) {
+            reFreshShareColumn(info, businessCbusinesstypeInfo.get(0));
+            cbusinesstypeServiceDaoImpl.saveCbusinesstypeInfoInstance(info);
+            if(businessCbusinesstypeInfo.size() == 1) {
+                dataFlowContext.addParamOut("id", businessCbusinesstypeInfo.get(0).get("id"));
+            }
+        }
+    }
+
+
+    /**
+     * 刷 分片字段
+     *
+     * @param info         查询对象
+     * @param businessInfo 小区ID
+     */
+    private void reFreshShareColumn(Map info, Map businessInfo) {
+
+        if (info.containsKey("id")) {
+            return;
+        }
+
+        if (!businessInfo.containsKey("id")) {
+            return;
+        }
+
+        info.put("id", businessInfo.get("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 paramIn = new HashMap();
+        paramIn.put("bId",bId);
+        paramIn.put("statusCd",StatusConstant.STATUS_CD_INVALID);
+        //cbusinesstype信息
+        List<Map> cbusinesstypeInfo = cbusinesstypeServiceDaoImpl.getCbusinesstypeInfo(info);
+        if(cbusinesstypeInfo != null && cbusinesstypeInfo.size() > 0){
+            reFreshShareColumn(paramIn, cbusinesstypeInfo.get(0));
+            cbusinesstypeServiceDaoImpl.updateCbusinesstypeInfoInstance(paramIn);
+        }
+    }
+
+
+
+    /**
+     * 处理 businessCbusinesstype 节点
+     * @param business 总的数据节点
+     * @param businessCbusinesstype cbusinesstype节点
+     */
+    private void doBusinessCbusinesstype(Business business,JSONObject businessCbusinesstype){
+
+        Assert.jsonObjectHaveKey(businessCbusinesstype,"id","businessCbusinesstype 节点下没有包含 id 节点");
+
+        if(businessCbusinesstype.getString("id").startsWith("-")){
+            //刷新缓存
+            //flushCbusinesstypeId(business.getDatas());
+
+            businessCbusinesstype.put("id",GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_id));
+
+        }
+
+        businessCbusinesstype.put("bId",business.getbId());
+        businessCbusinesstype.put("operate", StatusConstant.OPERATE_ADD);
+        //保存cbusinesstype信息
+        cbusinesstypeServiceDaoImpl.saveBusinessCbusinesstypeInfo(businessCbusinesstype);
+
+    }
+
+    public ICbusinesstypeServiceDao getCbusinesstypeServiceDaoImpl() {
+        return cbusinesstypeServiceDaoImpl;
+    }
+
+    public void setCbusinesstypeServiceDaoImpl(ICbusinesstypeServiceDao cbusinesstypeServiceDaoImpl) {
+        this.cbusinesstypeServiceDaoImpl = cbusinesstypeServiceDaoImpl;
+    }
+}

StoreService/src/main/java/com/java110/store/listener/businesstype/UpdateCbusinesstypeInfoListener.java

@@ -0,0 +1,190 @@
+package com.java110.store.listener.businesstype;
+
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.java110.common.constant.BusinessTypeConstant;
+import com.java110.common.constant.ResponseConstant;
+import com.java110.common.constant.StatusConstant;
+import com.java110.common.exception.ListenerExecuteException;
+import com.java110.common.util.Assert;
+import com.java110.core.annotation.Java110Listener;
+import com.java110.core.context.DataFlowContext;
+import com.java110.entity.center.Business;
+import com.java110.cbusinesstype.dao.ICbusinesstypeServiceDao;
+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;
+
+/**
+ * 修改cbusinesstype信息 侦听
+ *
+ * 处理节点
+ * 1、businessCbusinesstype:{} cbusinesstype基本信息节点
+ * 2、businessCbusinesstypeAttr:[{}] cbusinesstype属性信息节点
+ * 3、businessCbusinesstypePhoto:[{}] cbusinesstype照片信息节点
+ * 4、businessCbusinesstypeCerdentials:[{}] cbusinesstype证件信息节点
+ * 协议地址 ：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("updateCbusinesstypeInfoListener")
+@Transactional
+public class UpdateCbusinesstypeInfoListener extends AbstractCbusinesstypeBusinessServiceDataFlowListener {
+
+    private static Logger logger = LoggerFactory.getLogger(UpdateCbusinesstypeInfoListener.class);
+    @Autowired
+    private ICbusinesstypeServiceDao cbusinesstypeServiceDaoImpl;
+
+    @Override
+    public int getOrder() {
+        return 2;
+    }
+
+    @Override
+    public String getBusinessTypeCd() {
+        return BusinessTypeConstant.BUSINESS_TYPE_UPDATE_BUSINESSTYPE_INFO;
+    }
+
+    /**
+     * business过程
+     * @param dataFlowContext 上下文对象
+     * @param business 业务对象
+     */
+    @Override
+    protected void doSaveBusiness(DataFlowContext dataFlowContext, Business business) {
+
+        JSONObject data = business.getDatas();
+
+        Assert.notEmpty(data,"没有datas 节点，或没有子节点需要处理");
+
+        //处理 businessCbusinesstype 节点
+        if(data.containsKey("businessCbusinesstype")){
+            //处理 businessCbusinesstype 节点
+            if(data.containsKey("businessCbusinesstype")){
+                Object _obj = data.get("businessCbusinesstype");
+                JSONArray businessCbusinesstypes = null;
+                if(_obj instanceof JSONObject){
+                    businessCbusinesstypes = new JSONArray();
+                    businessCbusinesstypes.add(_obj);
+                }else {
+                    businessCbusinesstypes = (JSONArray)_obj;
+                }
+                //JSONObject businessCbusinesstype = data.getJSONObject("businessCbusinesstype");
+                for (int _cbusinesstypeIndex = 0; _cbusinesstypeIndex < businessCbusinesstypes.size();_cbusinesstypeIndex++) {
+                    JSONObject businessCbusinesstype = businessCbusinesstypes.getJSONObject(_cbusinesstypeIndex);
+                    doBusinessCbusinesstype(business, businessCbusinesstype);
+                    if(_obj instanceof JSONObject) {
+                        dataFlowContext.addParamOut("id", businessCbusinesstype.getString("id"));
+                    }
+                }
+            }
+        }
+    }
+
+
+    /**
+     * 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);
+
+        //cbusinesstype信息
+        List<Map> businessCbusinesstypeInfos = cbusinesstypeServiceDaoImpl.getBusinessCbusinesstypeInfo(info);
+        if( businessCbusinesstypeInfos != null && businessCbusinesstypeInfos.size() >0) {
+            for (int _cbusinesstypeIndex = 0; _cbusinesstypeIndex < businessCbusinesstypeInfos.size();_cbusinesstypeIndex++) {
+                Map businessCbusinesstypeInfo = businessCbusinesstypeInfos.get(_cbusinesstypeIndex);
+                flushBusinessCbusinesstypeInfo(businessCbusinesstypeInfo,StatusConstant.STATUS_CD_VALID);
+                cbusinesstypeServiceDaoImpl.updateCbusinesstypeInfoInstance(businessCbusinesstypeInfo);
+                if(businessCbusinesstypeInfo.size() == 1) {
+                    dataFlowContext.addParamOut("id", businessCbusinesstypeInfo.get("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);
+        //cbusinesstype信息
+        List<Map> cbusinesstypeInfo = cbusinesstypeServiceDaoImpl.getCbusinesstypeInfo(info);
+        if(cbusinesstypeInfo != null && cbusinesstypeInfo.size() > 0){
+
+            //cbusinesstype信息
+            List<Map> businessCbusinesstypeInfos = cbusinesstypeServiceDaoImpl.getBusinessCbusinesstypeInfo(delInfo);
+            //除非程序出错了，这里不会为空
+            if(businessCbusinesstypeInfos == null || businessCbusinesstypeInfos.size() == 0){
+                throw new ListenerExecuteException(ResponseConstant.RESULT_CODE_INNER_ERROR,"撤单失败（cbusinesstype），程序内部异常,请检查！ "+delInfo);
+            }
+            for (int _cbusinesstypeIndex = 0; _cbusinesstypeIndex < businessCbusinesstypeInfos.size();_cbusinesstypeIndex++) {
+                Map businessCbusinesstypeInfo = businessCbusinesstypeInfos.get(_cbusinesstypeIndex);
+                flushBusinessCbusinesstypeInfo(businessCbusinesstypeInfo,StatusConstant.STATUS_CD_VALID);
+                cbusinesstypeServiceDaoImpl.updateCbusinesstypeInfoInstance(businessCbusinesstypeInfo);
+            }
+        }
+
+    }
+
+
+
+    /**
+     * 处理 businessCbusinesstype 节点
+     * @param business 总的数据节点
+     * @param businessCbusinesstype cbusinesstype节点
+     */
+    private void doBusinessCbusinesstype(Business business,JSONObject businessCbusinesstype){
+
+        Assert.jsonObjectHaveKey(businessCbusinesstype,"id","businessCbusinesstype 节点下没有包含 id 节点");
+
+        if(businessCbusinesstype.getString("id").startsWith("-")){
+            throw new ListenerExecuteException(ResponseConstant.RESULT_PARAM_ERROR,"id 错误，不能自动生成（必须已经存在的id）"+businessCbusinesstype);
+        }
+        //自动保存DEL
+        autoSaveDelBusinessCbusinesstype(business,businessCbusinesstype);
+
+        businessCbusinesstype.put("bId",business.getbId());
+        businessCbusinesstype.put("operate", StatusConstant.OPERATE_ADD);
+        //保存cbusinesstype信息
+        cbusinesstypeServiceDaoImpl.saveBusinessCbusinesstypeInfo(businessCbusinesstype);
+
+    }
+
+
+
+
+    public ICbusinesstypeServiceDao getCbusinesstypeServiceDaoImpl() {
+        return cbusinesstypeServiceDaoImpl;
+    }
+
+    public void setCbusinesstypeServiceDaoImpl(ICbusinesstypeServiceDao cbusinesstypeServiceDaoImpl) {
+        this.cbusinesstypeServiceDaoImpl = cbusinesstypeServiceDaoImpl;
+    }
+
+
+
+}

StoreService/src/main/java/com/java110/store/listener/businesstypecd/AbstractC_business_typeBusinessServiceDataFlowListener.java

@@ -1,84 +0,0 @@
-package com.java110.store.listener.businesstypecd;
-
-import com.alibaba.fastjson.JSONObject;
-import com.java110.common.constant.ResponseConstant;
-import com.java110.common.constant.StatusConstant;
-import com.java110.common.exception.ListenerExecuteException;
-import com.java110.entity.center.Business;
-import com.java110.event.service.AbstractBusinessServiceDataFlowListener;
-import com.java110.store.dao.IC_business_typeServiceDao;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-
-/**
- *
- * BusinessType 服务侦听 父类
- * Created by wuxw on 2018/7/4.
- */
-public abstract class AbstractC_business_typeBusinessServiceDataFlowListener extends AbstractBusinessServiceDataFlowListener{
-    private static Logger logger = LoggerFactory.getLogger(AbstractC_business_typeBusinessServiceDataFlowListener.class);
-
-
-    /**
-     * 获取 DAO工具类
-     * @return
-     */
-    public abstract IC_business_typeServiceDao getC_business_typeServiceDaoImpl();
-
-    /**
-     * 刷新 businessC_business_typeInfo 数据
-     * 主要将 数据库 中字段和 接口传递字段建立关系
-     * @param businessC_business_typeInfo
-     */
-    protected void flushBusinessC_business_typeInfo(Map businessC_business_typeInfo,String statusCd){
-        businessC_business_typeInfo.put("newBId", businessC_business_typeInfo.get("b_id"));
-        businessC_business_typeInfo.put("businessTypeCd",businessC_business_typeInfo.get("business_type_cd"));
-businessC_business_typeInfo.put("operate",businessC_business_typeInfo.get("operate"));
-businessC_business_typeInfo.put("name",businessC_business_typeInfo.get("name"));
-businessC_business_typeInfo.put("description",businessC_business_typeInfo.get("description"));
-businessC_business_typeInfo.put("id",businessC_business_typeInfo.get("id"));
-businessC_business_typeInfo.put("userId",businessC_business_typeInfo.get("user_id"));
-businessC_business_typeInfo.remove("bId");
-        businessC_business_typeInfo.put("statusCd", statusCd);
-    }
-
-
-    /**
-     * 当修改数据时，查询instance表中的数据 自动保存删除数据到business中
-     * @param businessC_business_type BusinessType信息
-     */
-    protected void autoSaveDelBusinessC_business_type(Business business, JSONObject businessC_business_type){
-//自动插入DEL
-        Map info = new HashMap();
-        info.put("id",businessC_business_type.getString("id"));
-        info.put("statusCd",StatusConstant.STATUS_CD_VALID);
-        List<Map> currentC_business_typeInfos = getC_business_typeServiceDaoImpl().getC_business_typeInfo(info);
-        if(currentC_business_typeInfos == null || currentC_business_typeInfos.size() != 1){
-            throw new ListenerExecuteException(ResponseConstant.RESULT_PARAM_ERROR,"未找到需要修改数据信息，入参错误或数据有问题，请检查"+info);
-        }
-
-        Map currentC_business_typeInfo = currentC_business_typeInfos.get(0);
-
-        currentC_business_typeInfo.put("bId",business.getbId());
-
-        currentC_business_typeInfo.put("businessTypeCd",currentC_business_typeInfo.get("business_type_cd"));
-currentC_business_typeInfo.put("operate",currentC_business_typeInfo.get("operate"));
-currentC_business_typeInfo.put("name",currentC_business_typeInfo.get("name"));
-currentC_business_typeInfo.put("description",currentC_business_typeInfo.get("description"));
-currentC_business_typeInfo.put("id",currentC_business_typeInfo.get("id"));
-currentC_business_typeInfo.put("userId",currentC_business_typeInfo.get("user_id"));
-
-
-        currentC_business_typeInfo.put("operate",StatusConstant.OPERATE_DEL);
-        getC_business_typeServiceDaoImpl().saveBusinessC_business_typeInfo(currentC_business_typeInfo);
-    }
-
-
-
-
-
-}

StoreService/src/main/java/com/java110/store/listener/businesstypecd/DeleteC_business_typeInfoListener.java

@@ -1,177 +0,0 @@
-package com.java110.store.listener.businesstypecd;
-
-import com.alibaba.fastjson.JSONArray;
-import com.alibaba.fastjson.JSONObject;
-import com.java110.common.constant.BusinessTypeConstant;
-import com.java110.common.constant.ResponseConstant;
-import com.java110.common.constant.StatusConstant;
-import com.java110.common.exception.ListenerExecuteException;
-import com.java110.common.util.Assert;
-import com.java110.core.annotation.Java110Listener;
-import com.java110.core.context.DataFlowContext;
-import com.java110.entity.center.Business;
-import com.java110.store.dao.IC_business_typeServiceDao;
-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;
-
-/**
- * 删除BusinessType信息 侦听
- *
- * 处理节点
- * 1、businessC_business_type:{} BusinessType基本信息节点
- * 2、businessC_business_typeAttr:[{}] BusinessType属性信息节点
- * 3、businessC_business_typePhoto:[{}] BusinessType照片信息节点
- * 4、businessC_business_typeCerdentials:[{}] BusinessType证件信息节点
- * 协议地址 ：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("deleteC_business_typeInfoListener")
-@Transactional
-public class DeleteC_business_typeInfoListener extends AbstractC_business_typeBusinessServiceDataFlowListener {
-
-    private final static Logger logger = LoggerFactory.getLogger(DeleteC_business_typeInfoListener.class);
-    @Autowired
-    IC_business_typeServiceDao c_business_typeServiceDaoImpl;
-
-    @Override
-    public int getOrder() {
-        return 3;
-    }
-
-    @Override
-    public String getBusinessTypeCd() {
-        return BusinessTypeConstant.BUSINESS_TYPE_DELETE_BUSINESSTYPE_INFO;
-    }
-
-    /**
-     * 根据删除信息 查出Instance表中数据 保存至business表 （状态写DEL） 方便撤单时直接更新回去
-     * @param dataFlowContext 数据对象
-     * @param business 当前业务对象
-     */
-    @Override
-    protected void doSaveBusiness(DataFlowContext dataFlowContext, Business business) {
-        JSONObject data = business.getDatas();
-
-        Assert.notEmpty(data,"没有datas 节点，或没有子节点需要处理");
-
-        //处理 businessC_business_type 节点
-        if(data.containsKey("businessC_business_type")){
-            //处理 businessC_business_type 节点
-            if(data.containsKey("businessC_business_type")){
-                Object _obj = data.get("businessC_business_type");
-                JSONArray businessC_business_types = null;
-                if(_obj instanceof JSONObject){
-                    businessC_business_types = new JSONArray();
-                    businessC_business_types.add(_obj);
-                }else {
-                    businessC_business_types = (JSONArray)_obj;
-                }
-                //JSONObject businessC_business_type = data.getJSONObject("businessC_business_type");
-                for (int _c_business_typeIndex = 0; _c_business_typeIndex < businessC_business_types.size();_c_business_typeIndex++) {
-                    JSONObject businessC_business_type = businessC_business_types.getJSONObject(_c_business_typeIndex);
-                    doBusinessC_business_type(business, businessC_business_type);
-                    if(_obj instanceof JSONObject) {
-                        dataFlowContext.addParamOut("id", businessC_business_type.getString("id"));
-                    }
-                }
-            }
-        }
-
-
-    }
-
-    /**
-     * 删除 instance数据
-     * @param dataFlowContext 数据对象
-     * @param business 当前业务对象
-     */
-    @Override
-    protected void doBusinessToInstance(DataFlowContext dataFlowContext, Business business) {
-        String bId = business.getbId();
-        //Assert.hasLength(bId,"请求报文中没有包含 bId");
-
-        //BusinessType信息
-        Map info = new HashMap();
-        info.put("bId",business.getbId());
-        info.put("operate",StatusConstant.OPERATE_DEL);
-
-        //BusinessType信息
-        List<Map> businessC_business_typeInfos = c_business_typeServiceDaoImpl.getBusinessC_business_typeInfo(info);
-        if( businessC_business_typeInfos != null && businessC_business_typeInfos.size() >0) {
-            for (int _c_business_typeIndex = 0; _c_business_typeIndex < businessC_business_typeInfos.size();_c_business_typeIndex++) {
-                Map businessC_business_typeInfo = businessC_business_typeInfos.get(_c_business_typeIndex);
-                flushBusinessC_business_typeInfo(businessC_business_typeInfo,StatusConstant.STATUS_CD_INVALID);
-                c_business_typeServiceDaoImpl.updateC_business_typeInfoInstance(businessC_business_typeInfo);
-                dataFlowContext.addParamOut("id",businessC_business_typeInfo.get("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);
-        //BusinessType信息
-        List<Map> c_business_typeInfo = c_business_typeServiceDaoImpl.getC_business_typeInfo(info);
-        if(c_business_typeInfo != null && c_business_typeInfo.size() > 0){
-
-            //BusinessType信息
-            List<Map> businessC_business_typeInfos = c_business_typeServiceDaoImpl.getBusinessC_business_typeInfo(delInfo);
-            //除非程序出错了，这里不会为空
-            if(businessC_business_typeInfos == null ||  businessC_business_typeInfos.size() == 0){
-                throw new ListenerExecuteException(ResponseConstant.RESULT_CODE_INNER_ERROR,"撤单失败（c_business_type），程序内部异常,请检查！ "+delInfo);
-            }
-            for (int _c_business_typeIndex = 0; _c_business_typeIndex < businessC_business_typeInfos.size();_c_business_typeIndex++) {
-                Map businessC_business_typeInfo = businessC_business_typeInfos.get(_c_business_typeIndex);
-                flushBusinessC_business_typeInfo(businessC_business_typeInfo,StatusConstant.STATUS_CD_VALID);
-                c_business_typeServiceDaoImpl.updateC_business_typeInfoInstance(businessC_business_typeInfo);
-            }
-        }
-    }
-
-
-
-    /**
-     * 处理 businessC_business_type 节点
-     * @param business 总的数据节点
-     * @param businessC_business_type BusinessType节点
-     */
-    private void doBusinessC_business_type(Business business,JSONObject businessC_business_type){
-
-        Assert.jsonObjectHaveKey(businessC_business_type,"id","businessC_business_type 节点下没有包含 id 节点");
-
-        if(businessC_business_type.getString("id").startsWith("-")){
-            throw new ListenerExecuteException(ResponseConstant.RESULT_PARAM_ERROR,"id 错误，不能自动生成（必须已经存在的id）"+businessC_business_type);
-        }
-        //自动插入DEL
-        autoSaveDelBusinessC_business_type(business,businessC_business_type);
-    }
-
-    public IC_business_typeServiceDao getC_business_typeServiceDaoImpl() {
-        return c_business_typeServiceDaoImpl;
-    }
-
-    public void setC_business_typeServiceDaoImpl(IC_business_typeServiceDao c_business_typeServiceDaoImpl) {
-        this.c_business_typeServiceDaoImpl = c_business_typeServiceDaoImpl;
-    }
-}

StoreService/src/main/java/com/java110/store/listener/businesstypecd/SaveC_business_typeInfoListener.java

@@ -1,175 +0,0 @@
-package com.java110.store.listener.businesstypecd;
-
-import com.alibaba.fastjson.JSONArray;
-import com.alibaba.fastjson.JSONObject;
-import com.java110.common.constant.BusinessTypeConstant;
-import com.java110.common.constant.StatusConstant;
-import com.java110.common.util.Assert;
-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.store.dao.IC_business_typeServiceDao;
-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;
-
-/**
- * 保存 BusinessType信息 侦听
- * Created by wuxw on 2018/5/18.
- */
-@Java110Listener("saveC_business_typeInfoListener")
-@Transactional
-public class SaveC_business_typeInfoListener extends AbstractC_business_typeBusinessServiceDataFlowListener{
-
-    private static Logger logger = LoggerFactory.getLogger(SaveC_business_typeInfoListener.class);
-
-    @Autowired
-    private IC_business_typeServiceDao c_business_typeServiceDaoImpl;
-
-    @Override
-    public int getOrder() {
-        return 0;
-    }
-
-    @Override
-    public String getBusinessTypeCd() {
-        return BusinessTypeConstant.BUSINESS_TYPE_SAVE_BUSINESSTYPE_INFO;
-    }
-
-    /**
-     * 保存BusinessType信息 business 表中
-     * @param dataFlowContext 数据对象
-     * @param business 当前业务对象
-     */
-    @Override
-    protected void doSaveBusiness(DataFlowContext dataFlowContext, Business business) {
-        JSONObject data = business.getDatas();
-        Assert.notEmpty(data,"没有datas 节点，或没有子节点需要处理");
-
-        //处理 businessC_business_type 节点
-        if(data.containsKey("businessC_business_type")){
-            Object bObj = data.get("businessC_business_type");
-            JSONArray businessC_business_types = null;
-            if(bObj instanceof JSONObject){
-                businessC_business_types = new JSONArray();
-                businessC_business_types.add(bObj);
-            }else {
-                businessC_business_types = (JSONArray)bObj;
-            }
-            //JSONObject businessC_business_type = data.getJSONObject("businessC_business_type");
-            for (int bC_business_typeIndex = 0; bC_business_typeIndex < businessC_business_types.size();bC_business_typeIndex++) {
-                JSONObject businessC_business_type = businessC_business_types.getJSONObject(bC_business_typeIndex);
-                doBusinessC_business_type(business, businessC_business_type);
-                if(bObj instanceof JSONObject) {
-                    dataFlowContext.addParamOut("id", businessC_business_type.getString("id"));
-                }
-            }
-        }
-    }
-
-    /**
-     * 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);
-
-        //BusinessType信息
-        List<Map> businessC_business_typeInfo = c_business_typeServiceDaoImpl.getBusinessC_business_typeInfo(info);
-        if( businessC_business_typeInfo != null && businessC_business_typeInfo.size() >0) {
-            reFreshShareColumn(info, businessC_business_typeInfo.get(0));
-            c_business_typeServiceDaoImpl.saveC_business_typeInfoInstance(info);
-            if(businessC_business_typeInfo.size() == 1) {
-                dataFlowContext.addParamOut("id", businessC_business_typeInfo.get(0).get("id"));
-            }
-        }
-    }
-
-
-    /**
-     * 刷 分片字段
-     *
-     * @param info         查询对象
-     * @param businessInfo 小区ID
-     */
-    private void reFreshShareColumn(Map info, Map businessInfo) {
-
-        if (info.containsKey("id")) {
-            return;
-        }
-
-        if (!businessInfo.containsKey("id")) {
-            return;
-        }
-
-        info.put("id", businessInfo.get("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 paramIn = new HashMap();
-        paramIn.put("bId",bId);
-        paramIn.put("statusCd",StatusConstant.STATUS_CD_INVALID);
-        //BusinessType信息
-        List<Map> c_business_typeInfo = c_business_typeServiceDaoImpl.getC_business_typeInfo(info);
-        if(c_business_typeInfo != null && c_business_typeInfo.size() > 0){
-            reFreshShareColumn(paramIn, c_business_typeInfo.get(0));
-            c_business_typeServiceDaoImpl.updateC_business_typeInfoInstance(paramIn);
-        }
-    }
-
-
-
-    /**
-     * 处理 businessC_business_type 节点
-     * @param business 总的数据节点
-     * @param businessC_business_type BusinessType节点
-     */
-    private void doBusinessC_business_type(Business business,JSONObject businessC_business_type){
-
-        Assert.jsonObjectHaveKey(businessC_business_type,"id","businessC_business_type 节点下没有包含 id 节点");
-
-        if(businessC_business_type.getString("id").startsWith("-")){
-            //刷新缓存
-            //flushC_business_typeId(business.getDatas());
-
-            businessC_business_type.put("id",GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_id));
-
-        }
-
-        businessC_business_type.put("bId",business.getbId());
-        businessC_business_type.put("operate", StatusConstant.OPERATE_ADD);
-        //保存BusinessType信息
-        c_business_typeServiceDaoImpl.saveBusinessC_business_typeInfo(businessC_business_type);
-
-    }
-
-    public IC_business_typeServiceDao getC_business_typeServiceDaoImpl() {
-        return c_business_typeServiceDaoImpl;
-    }
-
-    public void setC_business_typeServiceDaoImpl(IC_business_typeServiceDao c_business_typeServiceDaoImpl) {
-        this.c_business_typeServiceDaoImpl = c_business_typeServiceDaoImpl;
-    }
-}

StoreService/src/main/java/com/java110/store/listener/businesstypecd/UpdateC_business_typeInfoListener.java

@@ -1,190 +0,0 @@
-package com.java110.store.listener.businesstypecd;
-
-import com.alibaba.fastjson.JSONArray;
-import com.alibaba.fastjson.JSONObject;
-import com.java110.common.constant.BusinessTypeConstant;
-import com.java110.common.constant.ResponseConstant;
-import com.java110.common.constant.StatusConstant;
-import com.java110.common.exception.ListenerExecuteException;
-import com.java110.common.util.Assert;
-import com.java110.core.annotation.Java110Listener;
-import com.java110.core.context.DataFlowContext;
-import com.java110.entity.center.Business;
-import com.java110.store.dao.IC_business_typeServiceDao;
-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;
-
-/**
- * 修改BusinessType信息 侦听
- *
- * 处理节点
- * 1、businessC_business_type:{} BusinessType基本信息节点
- * 2、businessC_business_typeAttr:[{}] BusinessType属性信息节点
- * 3、businessC_business_typePhoto:[{}] BusinessType照片信息节点
- * 4、businessC_business_typeCerdentials:[{}] BusinessType证件信息节点
- * 协议地址 ：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("updateC_business_typeInfoListener")
-@Transactional
-public class UpdateC_business_typeInfoListener extends AbstractC_business_typeBusinessServiceDataFlowListener {
-
-    private static Logger logger = LoggerFactory.getLogger(UpdateC_business_typeInfoListener.class);
-    @Autowired
-    private IC_business_typeServiceDao c_business_typeServiceDaoImpl;
-
-    @Override
-    public int getOrder() {
-        return 2;
-    }
-
-    @Override
-    public String getBusinessTypeCd() {
-        return BusinessTypeConstant.BUSINESS_TYPE_UPDATE_BUSINESSTYPE_INFO;
-    }
-
-    /**
-     * business过程
-     * @param dataFlowContext 上下文对象
-     * @param business 业务对象
-     */
-    @Override
-    protected void doSaveBusiness(DataFlowContext dataFlowContext, Business business) {
-
-        JSONObject data = business.getDatas();
-
-        Assert.notEmpty(data,"没有datas 节点，或没有子节点需要处理");
-
-        //处理 businessC_business_type 节点
-        if(data.containsKey("businessC_business_type")){
-            //处理 businessC_business_type 节点
-            if(data.containsKey("businessC_business_type")){
-                Object _obj = data.get("businessC_business_type");
-                JSONArray businessC_business_types = null;
-                if(_obj instanceof JSONObject){
-                    businessC_business_types = new JSONArray();
-                    businessC_business_types.add(_obj);
-                }else {
-                    businessC_business_types = (JSONArray)_obj;
-                }
-                //JSONObject businessC_business_type = data.getJSONObject("businessC_business_type");
-                for (int _c_business_typeIndex = 0; _c_business_typeIndex < businessC_business_types.size();_c_business_typeIndex++) {
-                    JSONObject businessC_business_type = businessC_business_types.getJSONObject(_c_business_typeIndex);
-                    doBusinessC_business_type(business, businessC_business_type);
-                    if(_obj instanceof JSONObject) {
-                        dataFlowContext.addParamOut("id", businessC_business_type.getString("id"));
-                    }
-                }
-            }
-        }
-    }
-
-
-    /**
-     * 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);
-
-        //BusinessType信息
-        List<Map> businessC_business_typeInfos = c_business_typeServiceDaoImpl.getBusinessC_business_typeInfo(info);
-        if( businessC_business_typeInfos != null && businessC_business_typeInfos.size() >0) {
-            for (int _c_business_typeIndex = 0; _c_business_typeIndex < businessC_business_typeInfos.size();_c_business_typeIndex++) {
-                Map businessC_business_typeInfo = businessC_business_typeInfos.get(_c_business_typeIndex);
-                flushBusinessC_business_typeInfo(businessC_business_typeInfo,StatusConstant.STATUS_CD_VALID);
-                c_business_typeServiceDaoImpl.updateC_business_typeInfoInstance(businessC_business_typeInfo);
-                if(businessC_business_typeInfo.size() == 1) {
-                    dataFlowContext.addParamOut("id", businessC_business_typeInfo.get("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);
-        //BusinessType信息
-        List<Map> c_business_typeInfo = c_business_typeServiceDaoImpl.getC_business_typeInfo(info);
-        if(c_business_typeInfo != null && c_business_typeInfo.size() > 0){
-
-            //BusinessType信息
-            List<Map> businessC_business_typeInfos = c_business_typeServiceDaoImpl.getBusinessC_business_typeInfo(delInfo);
-            //除非程序出错了，这里不会为空
-            if(businessC_business_typeInfos == null || businessC_business_typeInfos.size() == 0){
-                throw new ListenerExecuteException(ResponseConstant.RESULT_CODE_INNER_ERROR,"撤单失败（c_business_type），程序内部异常,请检查！ "+delInfo);
-            }
-            for (int _c_business_typeIndex = 0; _c_business_typeIndex < businessC_business_typeInfos.size();_c_business_typeIndex++) {
-                Map businessC_business_typeInfo = businessC_business_typeInfos.get(_c_business_typeIndex);
-                flushBusinessC_business_typeInfo(businessC_business_typeInfo,StatusConstant.STATUS_CD_VALID);
-                c_business_typeServiceDaoImpl.updateC_business_typeInfoInstance(businessC_business_typeInfo);
-            }
-        }
-
-    }
-
-
-
-    /**
-     * 处理 businessC_business_type 节点
-     * @param business 总的数据节点
-     * @param businessC_business_type BusinessType节点
-     */
-    private void doBusinessC_business_type(Business business,JSONObject businessC_business_type){
-
-        Assert.jsonObjectHaveKey(businessC_business_type,"id","businessC_business_type 节点下没有包含 id 节点");
-
-        if(businessC_business_type.getString("id").startsWith("-")){
-            throw new ListenerExecuteException(ResponseConstant.RESULT_PARAM_ERROR,"id 错误，不能自动生成（必须已经存在的id）"+businessC_business_type);
-        }
-        //自动保存DEL
-        autoSaveDelBusinessC_business_type(business,businessC_business_type);
-
-        businessC_business_type.put("bId",business.getbId());
-        businessC_business_type.put("operate", StatusConstant.OPERATE_ADD);
-        //保存BusinessType信息
-        c_business_typeServiceDaoImpl.saveBusinessC_business_typeInfo(businessC_business_type);
-
-    }
-
-
-
-
-    public IC_business_typeServiceDao getC_business_typeServiceDaoImpl() {
-        return c_business_typeServiceDaoImpl;
-    }
-
-    public void setC_business_typeServiceDaoImpl(IC_business_typeServiceDao c_business_typeServiceDaoImpl) {
-        this.c_business_typeServiceDaoImpl = c_business_typeServiceDaoImpl;
-    }
-
-
-
-}

StoreService/src/main/java/com/java110/store/smo/impl/businesstype/C_business_typeInnerServiceSMOImpl.java

@@ -1,112 +0,0 @@
-package com.java110.store.smo.impl.businesstype;
-
-
-import com.java110.common.util.BeanConvertUtil;
-import com.java110.core.base.smo.BaseServiceSMO;
-import com.java110.core.smo.businessytpe.IC_business_typeInnerServiceSMO;
-import com.java110.core.smo.user.IUserInnerServiceSMO;
-import com.java110.dto.PageDto;
-import com.java110.dto.UserDto;
-import com.java110.dto.businesstypecd.C_business_typeDto;
-import com.java110.store.dao.IC_business_typeServiceDao;
-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 BusinessType内部服务实现类
- * @Author wuxw
- * @Date 2019/4/24 9:20
- * @Version 1.0
- * add by wuxw 2019/4/24
- **/
-@RestController
-public class C_business_typeInnerServiceSMOImpl extends BaseServiceSMO implements IC_business_typeInnerServiceSMO {
-
-    @Autowired
-    private IC_business_typeServiceDao c_business_typeServiceDaoImpl;
-
-    @Autowired
-    private IUserInnerServiceSMO userInnerServiceSMOImpl;
-
-    @Override
-    public List<C_business_typeDto> queryC_business_types(@RequestBody  C_business_typeDto c_business_typeDto) {
-
-        //校验是否传了 分页信息
-
-        int page = c_business_typeDto.getPage();
-
-        if (page != PageDto.DEFAULT_PAGE) {
-            c_business_typeDto.setPage((page - 1) * c_business_typeDto.getRow());
-            c_business_typeDto.setRow(page * c_business_typeDto.getRow());
-        }
-
-        List<C_business_typeDto> c_business_types = BeanConvertUtil.covertBeanList(c_business_typeServiceDaoImpl.getC_business_typeInfo(BeanConvertUtil.beanCovertMap(c_business_typeDto)), C_business_typeDto.class);
-
-        if (c_business_types == null || c_business_types.size() == 0) {
-            return c_business_types;
-        }
-
-        String[] userIds = getUserIds(c_business_types);
-        //根据 userId 查询用户信息
-        List<UserDto> users = userInnerServiceSMOImpl.getUserInfo(userIds);
-
-        for (C_business_typeDto c_business_type : c_business_types) {
-            refreshC_business_type(c_business_type, users);
-        }
-        return c_business_types;
-    }
-
-    /**
-     * 从用户列表中查询用户，将用户中的信息 刷新到 floor对象中
-     *
-     * @param c_business_type 小区BusinessType信息
-     * @param users 用户列表
-     */
-    private void refreshC_business_type(C_business_typeDto c_business_type, List<UserDto> users) {
-        for (UserDto user : users) {
-            if (c_business_type.getUserId().equals(user.getUserId())) {
-                BeanConvertUtil.covertBean(user, c_business_type);
-            }
-        }
-    }
-
-    /**
-     * 获取批量userId
-     *
-     * @param c_business_types 小区楼信息
-     * @return 批量userIds 信息
-     */
-    private String[] getUserIds(List<C_business_typeDto> c_business_types) {
-        List<String> userIds = new ArrayList<String>();
-        for (C_business_typeDto c_business_type : c_business_types) {
-            userIds.add(c_business_type.getUserId());
-        }
-
-        return userIds.toArray(new String[userIds.size()]);
-    }
-
-    @Override
-    public int queryC_business_typesCount(@RequestBody C_business_typeDto c_business_typeDto) {
-        return c_business_typeServiceDaoImpl.queryC_business_typesCount(BeanConvertUtil.beanCovertMap(c_business_typeDto));    }
-
-    public IC_business_typeServiceDao getC_business_typeServiceDaoImpl() {
-        return c_business_typeServiceDaoImpl;
-    }
-
-    public void setC_business_typeServiceDaoImpl(IC_business_typeServiceDao c_business_typeServiceDaoImpl) {
-        this.c_business_typeServiceDaoImpl = c_business_typeServiceDaoImpl;
-    }
-
-    public IUserInnerServiceSMO getUserInnerServiceSMOImpl() {
-        return userInnerServiceSMOImpl;
-    }
-
-    public void setUserInnerServiceSMOImpl(IUserInnerServiceSMO userInnerServiceSMOImpl) {
-        this.userInnerServiceSMOImpl = userInnerServiceSMOImpl;
-    }
-}

StoreService/src/main/java/com/java110/store/smo/impl/businesstype/CbusinesstypeInnerServiceSMOImpl.java

@@ -0,0 +1,112 @@
+package com.java110.store.smo.impl.businesstype;
+
+
+import com.java110.common.util.BeanConvertUtil;
+import com.java110.core.base.smo.BaseServiceSMO;
+import com.java110.core.smo.businesstype.ICbusinesstypeInnerServiceSMO;
+import com.java110.core.smo.user.IUserInnerServiceSMO;
+import com.java110.dto.PageDto;
+import com.java110.dto.UserDto;
+import com.java110.dto.businesstype.CbusinesstypeDto;
+import com.java110.store.dao.ICbusinesstypeServiceDao;
+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 cbusinesstype内部服务实现类
+ * @Author wuxw
+ * @Date 2019/4/24 9:20
+ * @Version 1.0
+ * add by wuxw 2019/4/24
+ **/
+@RestController
+public class CbusinesstypeInnerServiceSMOImpl extends BaseServiceSMO implements ICbusinesstypeInnerServiceSMO {
+
+    @Autowired
+    private ICbusinesstypeServiceDao cbusinesstypeServiceDaoImpl;
+
+    @Autowired
+    private IUserInnerServiceSMO userInnerServiceSMOImpl;
+
+    @Override
+    public List<CbusinesstypeDto> queryCbusinesstypes(@RequestBody  CbusinesstypeDto cbusinesstypeDto) {
+
+        //校验是否传了 分页信息
+
+        int page = cbusinesstypeDto.getPage();
+
+        if (page != PageDto.DEFAULT_PAGE) {
+            cbusinesstypeDto.setPage((page - 1) * cbusinesstypeDto.getRow());
+            cbusinesstypeDto.setRow(page * cbusinesstypeDto.getRow());
+        }
+
+        List<CbusinesstypeDto> cbusinesstypes = BeanConvertUtil.covertBeanList(cbusinesstypeServiceDaoImpl.getCbusinesstypeInfo(BeanConvertUtil.beanCovertMap(cbusinesstypeDto)), CbusinesstypeDto.class);
+
+        if (cbusinesstypes == null || cbusinesstypes.size() == 0) {
+            return cbusinesstypes;
+        }
+
+        String[] userIds = getUserIds(cbusinesstypes);
+        //根据 userId 查询用户信息
+        List<UserDto> users = userInnerServiceSMOImpl.getUserInfo(userIds);
+
+        for (CbusinesstypeDto cbusinesstype : cbusinesstypes) {
+            refreshCbusinesstype(cbusinesstype, users);
+        }
+        return cbusinesstypes;
+    }
+
+    /**
+     * 从用户列表中查询用户，将用户中的信息 刷新到 floor对象中
+     *
+     * @param cbusinesstype 小区cbusinesstype信息
+     * @param users 用户列表
+     */
+    private void refreshCbusinesstype(CbusinesstypeDto cbusinesstype, List<UserDto> users) {
+        for (UserDto user : users) {
+            if (cbusinesstype.getUserId().equals(user.getUserId())) {
+                BeanConvertUtil.covertBean(user, cbusinesstype);
+            }
+        }
+    }
+
+    /**
+     * 获取批量userId
+     *
+     * @param cbusinesstypes 小区楼信息
+     * @return 批量userIds 信息
+     */
+    private String[] getUserIds(List<CbusinesstypeDto> cbusinesstypes) {
+        List<String> userIds = new ArrayList<String>();
+        for (CbusinesstypeDto cbusinesstype : cbusinesstypes) {
+            userIds.add(cbusinesstype.getUserId());
+        }
+
+        return userIds.toArray(new String[userIds.size()]);
+    }
+
+    @Override
+    public int queryCbusinesstypesCount(@RequestBody CbusinesstypeDto cbusinesstypeDto) {
+        return cbusinesstypeServiceDaoImpl.queryCbusinesstypesCount(BeanConvertUtil.beanCovertMap(cbusinesstypeDto));    }
+
+    public ICbusinesstypeServiceDao getCbusinesstypeServiceDaoImpl() {
+        return cbusinesstypeServiceDaoImpl;
+    }
+
+    public void setCbusinesstypeServiceDaoImpl(ICbusinesstypeServiceDao cbusinesstypeServiceDaoImpl) {
+        this.cbusinesstypeServiceDaoImpl = cbusinesstypeServiceDaoImpl;
+    }
+
+    public IUserInnerServiceSMO getUserInnerServiceSMOImpl() {
+        return userInnerServiceSMOImpl;
+    }
+
+    public void setUserInnerServiceSMOImpl(IUserInnerServiceSMO userInnerServiceSMOImpl) {
+        this.userInnerServiceSMOImpl = userInnerServiceSMOImpl;
+    }
+}

WebService/src/main/java/com/java110/web/components/businessType/ListBusinessTypeComponent.java

@@ -1,7 +1,9 @@
-package com.java110.web.components.businessType;
+package com.java110.web.components.businesstype;
 
 import com.java110.core.context.IPageData;
-import com.java110.web.smo.IBusinessTypeServiceSMO;
+import com.java110.core.smo.businesstype.ICbusinesstypeInnerServiceSMO;
+import com.java110.web.smo.ICbusinessTypeServiceSMO;
+import com.java110.web.smo.IDemoServiceSMO;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.http.ResponseEntity;
 import org.springframework.stereotype.Component;
@@ -9,7 +11,7 @@ import org.springframework.stereotype.Component;
 @Component("listBusinessType")
 public class ListBusinessTypeComponent {
     @Autowired
-    private IBusinessTypeServiceSMO businessTypeServiceSMOImpl;
+    private ICbusinessTypeServiceSMO iCbusinessTypeServiceSMOImpl;
 
     /**
      * 查询小区楼信息
@@ -19,7 +21,7 @@ public class ListBusinessTypeComponent {
      */
     public ResponseEntity<String> list(IPageData pd) {
 
-        return businessTypeServiceSMOImpl.listBusinessType(pd);
+        return iCbusinessTypeServiceSMOImpl.listBusinessType(pd);
     }
 
 

WebService/src/main/java/com/java110/web/smo/IBusinessTypeServiceSMO.java

@@ -6,7 +6,7 @@ import org.springframework.http.ResponseEntity;
 /**
  * 用例接口
  */
-public interface IBusinessTypeServiceSMO {
+public interface ICbusinessTypeServiceSMO {
 
     /**
      * 查询用例信息

WebService/src/main/java/com/java110/web/smo/impl/BusinessTypeServiceSMOImpl.java

@@ -8,7 +8,8 @@ import com.java110.common.exception.SMOException;
 import com.java110.common.util.Assert;
 import com.java110.core.context.IPageData;
 import com.java110.web.core.BaseComponentSMO;
-import com.java110.web.smo.IBusinessTypeServiceSMO;
+import com.java110.web.smo.ICbusinessTypeServiceSMO;
+import com.java110.web.smo.IDemoServiceSMO;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -24,8 +25,8 @@ import org.springframework.web.client.RestTemplate;
  * add by wuxw 2019-04-22
  */
 
-@Service("businessTypeServiceSMO")
-public class BusinessTypeServiceSMOImpl extends BaseComponentSMO implements IBusinessTypeServiceSMO {
+@Service("businessTypeServiceSMOImpl")
+public class BusinessTypeServiceSMOImpl extends BaseComponentSMO implements ICbusinessTypeServiceSMO {
 
     private static Logger logger = LoggerFactory.getLogger(BusinessTypeServiceSMOImpl.class);
 
@@ -42,7 +43,7 @@ public class BusinessTypeServiceSMOImpl extends BaseComponentSMO implements IBus
     @Override
     public ResponseEntity<String> listBusinessType(IPageData pd) {
 
-        validateListDemo(pd);
+        validateListBusinessType(pd);
 
         JSONObject paramIn = JSONObject.parseObject(pd.getReqData());
         int page = Integer.parseInt(paramIn.getString("page"));
@@ -59,20 +60,21 @@ public class BusinessTypeServiceSMOImpl extends BaseComponentSMO implements IBus
         Assert.jsonObjectHaveKey(responseEntity.getBody().toString(), "storeId", "根据用户ID查询商户ID失败，未包含storeId节点");
         Assert.jsonObjectHaveKey(responseEntity.getBody().toString(), "storeTypeCd", "根据用户ID查询商户类型失败，未包含storeTypeCd节点");
 
-       /* String storeId = JSONObject.parseObject(responseEntity.getBody().toString()).getString("storeId");
-        String storeTypeCd = JSONObject.parseObject(responseEntity.getBody().toString()).getString("storeTypeCd");*/
+        String storeId = JSONObject.parseObject(responseEntity.getBody().toString()).getString("storeId");
+        String storeTypeCd = JSONObject.parseObject(responseEntity.getBody().toString()).getString("storeTypeCd");
         //数据校验是否 商户是否入驻该小区
        // super.checkStoreEnterCommunity(pd, storeId, storeTypeCd, communityId, restTemplate);
-        String apiUrl = ServiceConstant.SERVICE_API_URL + "/api/business.queryBusinessTypeConfig" + mapToUrlParam(paramIn);
+        String apiUrl = ServiceConstant.SERVICE_API_URL + "/api/buiness.businessTypeDemoConfig" + mapToUrlParam(paramIn);
 
 
         responseEntity = this.callCenterService(restTemplate, pd, "",
                 apiUrl,
                 HttpMethod.GET);
-        System.out.println("我就看看获取到的数据"+responseEntity.toString());
+
         return responseEntity;
     }
 
+
     @Override
     public ResponseEntity<String> saveBusinessType(IPageData pd) {
 
@@ -223,7 +225,7 @@ public class BusinessTypeServiceSMOImpl extends BaseComponentSMO implements IBus
      *
      * @param pd 页面封装对象
      */
-    private void validateListDemo(IPageData pd) {
+    private void validateListBusinessType(IPageData pd) {
         Assert.jsonObjectHaveKey(pd.getReqData(), "page", "请求报文中未包含page节点");
         Assert.jsonObjectHaveKey(pd.getReqData(), "row", "请求报文中未包含row节点");
         JSONObject paramIn = JSONObject.parseObject(pd.getReqData());
@@ -239,6 +241,27 @@ public class BusinessTypeServiceSMOImpl extends BaseComponentSMO implements IBus
     }
 
 
+
+    /**
+     * 校验查询小区楼信息
+     *
+     * @param pd 页面封装对象
+     */
+    private void validateListDemoStudy(IPageData pd) {
+        Assert.jsonObjectHaveKey(pd.getReqData(), "page", "请求报文中未包含page节点");
+        Assert.jsonObjectHaveKey(pd.getReqData(), "row", "请求报文中未包含row节点");
+        JSONObject paramIn = JSONObject.parseObject(pd.getReqData());
+        Assert.isInteger(paramIn.getString("page"), "page不是数字");
+        Assert.isInteger(paramIn.getString("row"), "rows不是数字");
+        int row = Integer.parseInt(paramIn.getString("row"));
+
+
+        if (row > MAX_ROW) {
+            throw new SMOException(ResponseConstant.RESULT_CODE_ERROR, "row 数量不能大于50");
+        }
+
+    }
+
     public RestTemplate getRestTemplate() {
         return restTemplate;
     }

WebService/src/main/resources/components/list_business_type/listBusinessType.html

@@ -25,18 +25,18 @@
                         </tr>
                         </thead>
                         <tbody>
-                        <tr v-for="BusTypes in BusinessType.BusType">
+                        <tr v-for="BusTypes in listBusinessTypeInfo.BusinessType">
                             <td>
-                                {{BusTypes.ID}}
+                                {{BusTypes.id}}
                             </td>
                             <td>
-                                {{BusTypes.BusinessTypecD}}
+                                {{BusTypes.businessTypeCd}}
                             </td>
                             <td>
-                                {{BusTypes.Name}}
+                                {{BusTypes.name}}
                             </td>
                             <td>
-                                {{BusTypes.Description}}
+                                {{BusTypes.description}}
                             </td>
                             <td class="text-right">
                                 <div class="btn-group">

WebService/src/main/resources/components/list_business_type/listBusinessType.js

@@ -36,9 +36,7 @@
                              function(json,res){
                                 var listBusinessTypeData =JSON.parse(json);
 
-                                vc.component.listBusinessTypeInfo.total = listBusinessTypeData.total;
-                                vc.component.listBusinessTypeInfo.records = listBusinessTypeData.records;
-                                vc.component.listBusinessTypeInfo.BusinessType = listBusinessTypeData.BusinessType;
+                                vc.component.listBusinessTypeInfo.BusinessType = listBusinessTypeData;
 
                                 vc.emit('pagination','init',{
                                     total:vc.component.listBusinessTypeInfo.records,

docs/services/businessType/DeleteC_business_typeInfo.md

@@ -1,11 +1,11 @@
 
 
-**1\. 删除BusinessType**
+**1\. 删除cbusinesstype**
 ###### 接口功能
-> API服务做删除BusinessType时调用该接口
+> API服务做删除cbusinesstype时调用该接口
 
 ###### URL
-> [http://c_business_type-service/c_business_typeApi/service](http://c_business_type-service/c_business_typeApi/service)
+> [http://cbusinesstype-service/cbusinesstypeApi/service](http://cbusinesstype-service/cbusinesstypeApi/service)
 
 ###### 支持格式
 > JSON
@@ -43,8 +43,8 @@
 |-|business|?|Array|-|业务节点|-|
 |business|businessTypeCd|1|String|12|业务类型编码|500100030002|
 |business|datas|1|Object|-|数据节点|不同的服务下的节点不一样|
-|datas|businessC_business_typeInfo|1|Object|-|小区成员|小区成员|
-|businessC_business_typeInfo|id|1|String|30|-|-|
+|datas|businessCbusinesstypeInfo|1|Object|-|小区成员|小区成员|
+|businessCbusinesstypeInfo|id|1|String|30|-|-|
 
 
 ###### 返回协议
@@ -58,7 +58,7 @@
 
 
 ###### 举例
-> 地址：[http://c_business_type-service/c_business_typeApi/service](http://c_business_type-service/c_business_typeApi/service)
+> 地址：[http://cbusinesstype-service/cbusinesstypeApi/service](http://cbusinesstype-service/cbusinesstypeApi/service)
 
 ``` javascript
 请求头信息：
@@ -82,11 +82,11 @@ Content-Type:application/json
     }]
   },
   "business": {
-    "businessTypeCd": "900100050002",
+    "businessTypeCd": "900100050005",
     "bId":"1234567892",
     "remark": "备注",
     "datas": {
-      "businessC_business_typeInfo": {
+      "businessCbusinesstypeInfo": {
                 "id":"填写存在的值"
       }
     },

docs/services/businessType/SaveC_business_typeInfo.md

@@ -1,11 +1,11 @@
 
 
-**1\. 保存BusinessType**
+**1\. 保存cbusinesstype**
 ###### 接口功能
-> API服务做保存BusinessType时调用该接口
+> API服务做保存cbusinesstype时调用该接口
 
 ###### URL
-> [http://c_business_type-service/c_business_typeApi/service](http://c_business_type-service/c_business_typeApi/service)
+> [http://cbusinesstype-service/cbusinesstypeApi/service](http://cbusinesstype-service/cbusinesstypeApi/service)
 
 ###### 支持格式
 > JSON
@@ -43,12 +43,11 @@
 |-|business|?|Array|-|业务节点|-|
 |business|businessTypeCd|1|String|12|业务类型编码|500100030002|
 |business|datas|1|Object|-|数据节点|不同的服务下的节点不一样|
-|datas|businessC_business_typeInfo|1|Object|-|小区成员|小区成员|
-|businessC_business_typeInfo|businessTypeCd|1|String|30|-|-|
-|businessC_business_typeInfo|name|1|String|30|-|-|
-|businessC_business_typeInfo|description|1|String|30|-|-|
-|businessC_business_typeInfo|id|1|String|30|-|-|
-|businessC_business_typeInfo|userId|1|String|30|-|-|
+|datas|businessCbusinesstypeInfo|1|Object|-|小区成员|小区成员|
+|businessCbusinesstypeInfo|businessTypeCd|1|String|30|-|-|
+|businessCbusinesstypeInfo|name|1|String|30|-|-|
+|businessCbusinesstypeInfo|description|1|String|30|-|-|
+|businessCbusinesstypeInfo|id|1|String|30|-|-|
 
 
 ###### 返回协议
@@ -62,7 +61,7 @@
 
 
 ###### 举例
-> 地址：[http://c_business_type-service/c_business_typeApi/service](http://c_business_type-service/c_business_typeApi/service)
+> 地址：[http://cbusinesstype-service/cbusinesstypeApi/service](http://cbusinesstype-service/cbusinesstypeApi/service)
 
 ``` javascript
 请求头信息：
@@ -86,16 +85,15 @@ Content-Type:application/json
     }]
   },
   "business": {
-    "businessTypeCd": "900100030002",
+    "businessTypeCd": "900100030005",
     "bId":"1234567892",
     "remark": "备注",
     "datas": {
-      "businessC_business_typeInfo": {
+      "businessCbusinesstypeInfo": {
                 "businessTypeCd":"填写具体值",
         "name":"填写具体值",
         "description":"填写具体值",
-        "id":"填写具体值",
-        "userId":"填写具体值"
+        "id":"填写具体值"
       }
     },
     "attrs": [{

docs/services/businessType/UpdateC_business_typeInfo.md

@@ -1,11 +1,11 @@
 
 
-**1\. 修改BusinessType**
+**1\. 修改cbusinesstype**
 ###### 接口功能
-> API服务做修改BusinessType时调用该接口
+> API服务做修改cbusinesstype时调用该接口
 
 ###### URL
-> [http://c_business_type-service/c_business_typeApi/service](http://c_business_type-service/c_business_typeApi/service)
+> [http://cbusinesstype-service/cbusinesstypeApi/service](http://cbusinesstype-service/cbusinesstypeApi/service)
 
 ###### 支持格式
 > JSON
@@ -43,12 +43,11 @@
 |-|business|?|Array|-|业务节点|-|
 |business|businessTypeCd|1|String|12|业务类型编码|500100030002|
 |business|datas|1|Object|-|数据节点|不同的服务下的节点不一样|
-|datas|businessC_business_typeInfo|1|Object|-|小区成员|小区成员|
-|businessC_business_typeInfo|businessTypeCd|1|String|30|-|-|
-|businessC_business_typeInfo|name|1|String|30|-|-|
-|businessC_business_typeInfo|description|1|String|30|-|-|
-|businessC_business_typeInfo|id|1|String|30|-|-|
-|businessC_business_typeInfo|userId|1|String|30|-|-|
+|datas|businessCbusinesstypeInfo|1|Object|-|小区成员|小区成员|
+|businessCbusinesstypeInfo|businessTypeCd|1|String|30|-|-|
+|businessCbusinesstypeInfo|name|1|String|30|-|-|
+|businessCbusinesstypeInfo|description|1|String|30|-|-|
+|businessCbusinesstypeInfo|id|1|String|30|-|-|
 
 
 ###### 返回协议
@@ -62,7 +61,7 @@
 
 
 ###### 举例
-> 地址：[http://c_business_type-service/c_business_typeApi/service](http://c_business_type-service/c_business_typeApi/service)
+> 地址：[http://cbusinesstype-service/cbusinesstypeApi/service](http://cbusinesstype-service/cbusinesstypeApi/service)
 
 ``` javascript
 请求头信息：
@@ -86,16 +85,15 @@ Content-Type:application/json
     }]
   },
   "business": {
-    "businessTypeCd": "900100040002",
+    "businessTypeCd": "900100040005",
     "bId":"1234567892",
     "remark": "备注",
     "datas": {
-      "businessC_business_typeInfo": {
+      "businessCbusinesstypeInfo": {
                 "businessTypeCd":"填写具体值",
         "name":"填写具体值",
         "description":"填写具体值",
-        "id":"填写具体值",
-        "userId":"填写具体值"
+        "id":"填写具体值"
       }
     },
     "attrs": [{

java110-bean/src/main/java/com/java110/dto/businesstypecd/C_business_typeDto.java

@@ -1,4 +1,4 @@
-package com.java110.dto.businesstypecd;
+package com.java110.dto.businesstype;
 
 import com.java110.dto.PageDto;
 
@@ -7,13 +7,13 @@ import java.util.Date;
 
 /**
  * @ClassName FloorDto
- * @Description BusinessType数据层封装
+ * @Description cbusinesstype数据层封装
  * @Author wuxw
  * @Date 2019/4/24 8:52
  * @Version 1.0
  * add by wuxw 2019/4/24
  **/
-public class C_business_typeDto extends PageDto implements Serializable {
+public class CbusinesstypeDto extends PageDto implements Serializable {
 
     private String businessTypeCd;
 private String name;
@@ -51,12 +51,6 @@ public String getId() {
 public void setId(String id) {
         this.id = id;
     }
-public String getUserId() {
-        return userId;
-    }
-public void setUserId(String userId) {
-        this.userId = userId;
-    }
 
 
     public Date getCreateTime() {
@@ -74,4 +68,12 @@ public void setUserId(String userId) {
     public void setStatusCd(String statusCd) {
         this.statusCd = statusCd;
     }
+
+    public String getUserId() {
+        return userId;
+    }
+
+    public void setUserId(String userId) {
+        this.userId = userId;
+    }
 }

java110-code-generator/src/main/java/com/java110/BusinessTypeGeneratorApplication.java

@@ -24,14 +24,14 @@ public class BusinessTypeGeneratorApplication {
     public static void main(String[] args) {
         Data data = new Data();
         data.setId("id");//主键ID
-        data.setName("c_business_type");//表名
-        data.setDesc("BusinessType");//中文表名
+        data.setName("cbusinesstype");//表名
+        data.setDesc("cbusinesstype");//中文表名
         data.setNewBusinessTypeCd("BUSINESS_TYPE_SAVE_BUSINESSTYPE_INFO"); //业务类型
         data.setUpdateBusinessTypeCd("BUSINESS_TYPE_UPDATE_BUSINESSTYPE_INFO");//修改业务类型
         data.setDeleteBusinessTypeCd("BUSINESS_TYPE_DELETE_BUSINESSTYPE_INFO");//删除业务类型
-        data.setNewBusinessTypeCdValue("900100030002");//业务类型编码
-        data.setUpdateBusinessTypeCdValue("900100040002");//修修改业务类型编码
-        data.setDeleteBusinessTypeCdValue("900100050002");//删除业务类型编码
+        data.setNewBusinessTypeCdValue("900100030005");//业务类型编码
+        data.setUpdateBusinessTypeCdValue("900100040005");//修修改业务类型编码
+        data.setDeleteBusinessTypeCdValue("900100050005");//删除业务类型编码
         data.setBusinessTableName("business_bus");//表模型过程表名称
         data.setTableName("c_business_type");//表模型实列表名称
         data.setShareParam("id");
@@ -42,8 +42,6 @@ public class BusinessTypeGeneratorApplication {
         param.put("businessTypeCd", "business_type_cd");
         param.put("name", "name");
         param.put("description", "description");
-        param.put("userId", "user_id");
-        param.put("operate", "operate");
         /**表模型字段绑定end  创建时间CREATE_DATE不需要绑定系统默认自带**/
         data.setParams(param);
         GeneratorSaveInfoListener generatorSaveInfoListener = new GeneratorSaveInfoListener();

java110-core/src/main/java/com/java110/core/smo/businesstype/ICbusinesstypeInnerServiceSMO.java

@@ -0,0 +1,42 @@
+package com.java110.core.smo.businesstype;
+
+import com.java110.core.feign.FeignConfiguration;
+import com.java110.dto.businesstype.CbusinesstypeDto;
+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 ICbusinesstypeInnerServiceSMO
+ * @Description cbusinesstype接口类
+ * @Author wuxw
+ * @Date 2019/4/24 9:04
+ * @Version 1.0
+ * add by wuxw 2019/4/24
+ **/
+@FeignClient(name = "community-service", configuration = {FeignConfiguration.class})
+@RequestMapping("/cbusinesstypeApi")
+public interface ICbusinesstypeInnerServiceSMO {
+
+    /**
+     * <p>查询小区楼信息</p>
+     *
+     *
+     * @param cbusinesstypeDto 数据对象分享
+     * @return CbusinesstypeDto 对象数据
+     */
+    @RequestMapping(value = "/queryCbusinesstypes", method = RequestMethod.POST)
+    List<CbusinesstypeDto> queryCbusinesstypes(@RequestBody CbusinesstypeDto cbusinesstypeDto);
+
+    /**
+     * 查询<p>小区楼</p>总记录数
+     *
+     * @param cbusinesstypeDto 数据对象分享
+     * @return 小区下的小区楼记录数
+     */
+    @RequestMapping(value = "/queryCbusinesstypesCount", method = RequestMethod.POST)
+    int queryCbusinesstypesCount(@RequestBody CbusinesstypeDto cbusinesstypeDto);
+}

java110-core/src/main/java/com/java110/core/smo/businessytpe/IC_business_typeInnerServiceSMO.java

@@ -1,41 +0,0 @@
-package com.java110.core.smo.businessytpe;
-
-import com.java110.core.feign.FeignConfiguration;
-import com.java110.dto.businesstypecd.C_business_typeDto;
-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 IC_business_typeInnerServiceSMO
- * @Description BusinessType接口类
- * @Author wuxw
- * @Date 2019/4/24 9:04
- * @Version 1.0
- * add by wuxw 2019/4/24
- **/
-@FeignClient(name = "store-service", configuration = {FeignConfiguration.class})
-@RequestMapping("/c_business_typeApi")
-public interface IC_business_typeInnerServiceSMO {
-    /**
-     * <p>查询小区楼信息</p>
-     *
-     *
-     * @param c_business_typeDto 数据对象分享
-     * @return C_business_typeDto 对象数据
-     */
-    @RequestMapping(value = "/queryC_business_types", method = RequestMethod.POST)
-    List<C_business_typeDto> queryC_business_types(@RequestBody C_business_typeDto c_business_typeDto);
-
-    /**
-     * 查询<p>小区楼</p>总记录数
-     *
-     * @param c_business_typeDto 数据对象分享
-     * @return 小区下的小区楼记录数
-     */
-    @RequestMapping(value = "/queryC_business_typesCount", method = RequestMethod.POST)
-    int queryC_business_typesCount(@RequestBody C_business_typeDto c_business_typeDto);
-}

java110-db/src/main/resources/mapper/businesstye/C_business_typeServiceDaoImplMapper.xml

@@ -2,29 +2,26 @@
 <!DOCTYPE mapper
         PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="c_business_typeServiceDaoImpl">
+<mapper namespace="cbusinesstypeServiceDaoImpl">
 
-    <!-- 保存BusinessType信息 add by wuxw 2018-07-03 -->
-       <insert id="saveBusinessC_business_typeInfo" parameterType="Map">
+    <!-- 保存cbusinesstype信息 add by wuxw 2018-07-03 -->
+       <insert id="saveBusinessCbusinesstypeInfo" parameterType="Map">
            insert into business_bus(
-business_type_cd,operate,name,description,id,user_id
+business_type_cd,name,description,id
 ) values (
-#{businessTypeCd},#{operate},#{name},#{description},#{id},#{userId}
+#{businessTypeCd},#{name},#{description},#{id}
 )
        </insert>
 
 
-       <!-- 查询BusinessType信息（Business） add by wuxw 2018-07-03 -->
-       <select id="getBusinessC_business_typeInfo" parameterType="Map" resultType="Map">
-           select  t.business_type_cd,t.business_type_cd businessTypeCd,t.operate,t.name,t.description,t.id,t.user_id,t.user_id userId 
+       <!-- 查询cbusinesstype信息（Business） add by wuxw 2018-07-03 -->
+       <select id="getBusinessCbusinesstypeInfo" parameterType="Map" resultType="Map">
+           select  t.business_type_cd,t.business_type_cd businessTypeCd,t.name,t.description,t.id 
 from business_bus t 
 where 1 =1 
 <if test="businessTypeCd !=null and businessTypeCd != ''">
    and t.business_type_cd= #{businessTypeCd}
 </if> 
-<if test="operate !=null and operate != ''">
-   and t.operate= #{operate}
-</if> 
 <if test="name !=null and name != ''">
    and t.name= #{name}
 </if> 
@@ -34,9 +31,6 @@ where 1 =1
 <if test="id !=null and id != ''">
    and t.id= #{id}
 </if> 
-<if test="userId !=null and userId != ''">
-   and t.user_id= #{userId}
-</if> 
 
        </select>
 
@@ -44,15 +38,14 @@ where 1 =1
 
 
 
-    <!-- 保存BusinessType信息至 instance表中 add by wuxw 2018-07-03 -->
-    <insert id="saveC_business_typeInfoInstance" parameterType="Map">
+    <!-- 保存cbusinesstype信息至 instance表中 add by wuxw 2018-07-03 -->
+    <insert id="saveCbusinesstypeInfoInstance" parameterType="Map">
         insert into c_business_type(
-business_type_cd,name,description,id,user_id
-) select t.business_type_cd,t.name,t.description,t.id,t.user_id from business_bus t where 1=1
+business_type_cd,name,description,id
+) select t.business_type_cd,t.name,t.description,t.id from business_bus t where 1=1
 <if test="businessTypeCd !=null and businessTypeCd != ''">
    and t.business_type_cd= #{businessTypeCd}
 </if> 
-   and t.operate= 'ADD'
 <if test="name !=null and name != ''">
    and t.name= #{name}
 </if> 
@@ -62,17 +55,14 @@ business_type_cd,name,description,id,user_id
 <if test="id !=null and id != ''">
    and t.id= #{id}
 </if> 
-<if test="userId !=null and userId != ''">
-   and t.user_id= #{userId}
-</if> 
 
     </insert>
 
 
 
-    <!-- 查询BusinessType信息 add by wuxw 2018-07-03 -->
-    <select id="getC_business_typeInfo" parameterType="Map" resultType="Map">
-        select  t.business_type_cd,t.business_type_cd businessTypeCd,t.name,t.description,t.id
+    <!-- 查询cbusinesstype信息 add by wuxw 2018-07-03 -->
+    <select id="getCbusinesstypeInfo" parameterType="Map" resultType="Map">
+        select  t.business_type_cd,t.business_type_cd businessTypeCd,t.name,t.description,t.id 
 from c_business_type t 
 where 1 =1 
 <if test="businessTypeCd !=null and businessTypeCd != ''">
@@ -86,7 +76,7 @@ where 1 =1
 </if> 
 <if test="id !=null and id != ''">
    and t.id= #{id}
-</if>
+</if> 
 <if test="page != -1 and page != null ">
    limit #{page}, #{row}
 </if> 
@@ -96,8 +86,8 @@ where 1 =1
 
 
 
-    <!-- 修改BusinessType信息 add by wuxw 2018-07-03 -->
-    <update id="updateC_business_typeInfoInstance" parameterType="Map">
+    <!-- 修改cbusinesstype信息 add by wuxw 2018-07-03 -->
+    <update id="updateCbusinesstypeInfoInstance" parameterType="Map">
         update  c_business_type t set t.status_cd = #{statusCd}
 <if test="newBId != null and newBId != ''">
 ,t.b_id = #{newBId}
@@ -110,9 +100,6 @@ where 1 =1
 </if> 
 <if test="description !=null and description != ''">
 , t.description= #{description}
-</if> 
-<if test="userId !=null and userId != ''">
-, t.user_id= #{userId}
 </if> 
  where 1=1 <if test="id !=null and id != ''">
 and t.id= #{id}
@@ -120,8 +107,8 @@ and t.id= #{id}
 
     </update>
 
-    <!-- 查询BusinessType数量 add by wuxw 2018-07-03 -->
-     <select id="queryC_business_typesCount" parameterType="Map" resultType="Map">
+    <!-- 查询cbusinesstype数量 add by wuxw 2018-07-03 -->
+     <select id="queryCbusinesstypesCount" parameterType="Map" resultType="Map">
         select  count(1) count 
 from c_business_type t 
 where 1 =1 
@@ -137,9 +124,6 @@ where 1 =1
 <if test="id !=null and id != ''">
    and t.id= #{id}
 </if> 
-<if test="userId !=null and userId != ''">
-   and t.user_id= #{userId}
-</if> 
 
 
      </select>