优化代码生成

java110-generator/src/main/java/com/java110/code/newBack/GeneratorApiListener.java

@@ -15,8 +15,15 @@ public class GeneratorApiListener extends BaseGenerator {
      */
     public void generator(Data data) throws Exception {
         genneratorPo(data);             //API DataVo对象
-        //genneratorIBmo(data);               //API  IBmo
-        //genneratorBmoImpl(data);            //Api BmoImpl
+        genneratorISaveBmo(data);               //API  IBmo
+        genneratorSaveBmoImpl(data);            //Api BmoImpl
+        genneratorIUpdateBmo(data);               //API  IBmo
+        genneratorUpdateBmoImpl(data);            //Api BmoImpl
+        genneratorIDeleteBmo(data);               //API  IBmo
+        genneratorDeleteBmoImpl(data);            //Api BmoImpl
+        genneratorIGetBmo(data);               //API  IBmo
+        genneratorGetBmoImpl(data);            //Api BmoImpl
+        genneratorApi(data);
     }
 
 
@@ -68,20 +75,20 @@ public class GeneratorApiListener extends BaseGenerator {
      *
      * @param data
      */
-    private void genneratorIBmo(Data data) throws Exception {
-        StringBuffer sb = readFile(GeneratorStart.class.getResource("/newTemplate/IBMO.java").getFile());
+    private void genneratorISaveBmo(Data data) throws Exception {
+        StringBuffer sb = readFile(GeneratorStart.class.getResource("/newTemplate/ISaveBMO.java").getFile());
         String fileContext = sb.toString();
 
         fileContext = super.replaceTemplateContext(fileContext, data);
 
         String writePath = this.getClass().getResource("/").getPath()
-                + "out/api/bmo/" + data.getName() + "/I" + toUpperCaseFirstOne(data.getName()) + "BMO.java";
+                + "out/back/bmo/" + data.getName() + "/ISave" + toUpperCaseFirstOne(data.getName()) + "BMO.java";
         System.out.printf("writePath: " + writePath);
         writeFile(writePath,
                 fileContext);
         //复制生成的文件到对应分区目录下
         if (data.isAutoMove()) {
-            FileUtilBase.copyfile(writePath, "service-api\\src\\main\\java\\com\\java110\\api\\bmo\\" + data.getName() + "/I" + toUpperCaseFirstOne(data.getName()) + "BMO.java");
+            FileUtilBase.copyfile(writePath, "service-"+data.getShareName()+"\\src\\main\\java\\com\\java110\\"+data.getShareName()+"\\bmo\\" + data.getName() + "/I" + toUpperCaseFirstOne(data.getName()) + "BMO.java");
         }
     }
 
@@ -90,8 +97,8 @@ public class GeneratorApiListener extends BaseGenerator {
      *
      * @param data
      */
-    private void genneratorBmoImpl(Data data) throws Exception {
-        StringBuffer sb = readFile(GeneratorStart.class.getResource("/template/BMOImpl.java").getFile());
+    private void genneratorSaveBmoImpl(Data data) throws Exception {
+        StringBuffer sb = readFile(GeneratorStart.class.getResource("/newTemplate/SaveBMOImpl.java").getFile());
         String fileContext = sb.toString();
         fileContext = fileContext.replace("@@shareName@@", data.getShareName())
                 .replace("@@ShareName@@", toUpperCaseFirstOne(data.getShareName()));
@@ -99,15 +106,191 @@ public class GeneratorApiListener extends BaseGenerator {
         fileContext = super.replaceTemplateContext(fileContext, data);
 
         String writePath = this.getClass().getResource("/").getPath()
-                + "out/api/bmo/" + data.getName() + "/impl/" + toUpperCaseFirstOne(data.getName()) + "BMOImpl.java";
+                + "out/back/bmo/" + data.getName() + "/impl/Save" + toUpperCaseFirstOne(data.getName()) + "BMOImpl.java";
         System.out.printf("writePath: " + writePath);
         writeFile(writePath,
                 fileContext);
         //复制生成的文件到对应分区目录下
         if (data.isAutoMove()) {
-            FileUtilBase.copyfile(writePath, "service-api\\src\\main\\java\\com\\java110\\api\\bmo\\" + data.getName() + "/impl/" + toUpperCaseFirstOne(data.getName()) + "BMOImpl.java");
+            FileUtilBase.copyfile(writePath, "service-"+data.getShareName()+"\\src\\main\\java\\com\\java110\\"+data.getShareName()+"\\bmo\\" + data.getName() + "/impl/" + toUpperCaseFirstOne(data.getName()) + "BMOImpl.java");
         }
     }
 
 
+    /**
+     * 生成API 侦听处理类
+     *
+     * @param data
+     */
+    private void genneratorIUpdateBmo(Data data) throws Exception {
+        StringBuffer sb = readFile(GeneratorStart.class.getResource("/newTemplate/IUpdateBMO.java").getFile());
+        String fileContext = sb.toString();
+
+        fileContext = super.replaceTemplateContext(fileContext, data);
+
+        String writePath = this.getClass().getResource("/").getPath()
+                + "out/back/bmo/" + data.getName() + "/IUpdate" + toUpperCaseFirstOne(data.getName()) + "BMO.java";
+        System.out.printf("writePath: " + writePath);
+        writeFile(writePath,
+                fileContext);
+        //复制生成的文件到对应分区目录下
+        if (data.isAutoMove()) {
+            FileUtilBase.copyfile(writePath, "service-"+data.getShareName()+"\\src\\main\\java\\com\\java110\\"+data.getShareName()+"\\bmo\\" + data.getName() + "/IUpdate" + toUpperCaseFirstOne(data.getName()) + "BMO.java");
+        }
+    }
+
+    /**
+     * 生成API 侦听处理类
+     *
+     * @param data
+     */
+    private void genneratorUpdateBmoImpl(Data data) throws Exception {
+        StringBuffer sb = readFile(GeneratorStart.class.getResource("/newTemplate/UpdateBMOImpl.java").getFile());
+        String fileContext = sb.toString();
+        fileContext = fileContext.replace("@@shareName@@", data.getShareName())
+                .replace("@@ShareName@@", toUpperCaseFirstOne(data.getShareName()));
+
+        fileContext = super.replaceTemplateContext(fileContext, data);
+
+        String writePath = this.getClass().getResource("/").getPath()
+                + "out/back/bmo/" + data.getName() + "/impl/Update" + toUpperCaseFirstOne(data.getName()) + "BMOImpl.java";
+        System.out.printf("writePath: " + writePath);
+        writeFile(writePath,
+                fileContext);
+        //复制生成的文件到对应分区目录下
+        if (data.isAutoMove()) {
+            FileUtilBase.copyfile(writePath, "service-"+data.getShareName()+"\\src\\main\\java\\com\\java110\\"+data.getShareName()+"\\bmo\\" + data.getName() + "/impl/Update" + toUpperCaseFirstOne(data.getName()) + "BMOImpl.java");
+        }
+    }
+
+    /**
+     * 生成API 侦听处理类
+     *
+     * @param data
+     */
+    private void genneratorIDeleteBmo(Data data) throws Exception {
+        StringBuffer sb = readFile(GeneratorStart.class.getResource("/newTemplate/IDeleteBMO.java").getFile());
+        String fileContext = sb.toString();
+
+        fileContext = super.replaceTemplateContext(fileContext, data);
+
+        String writePath = this.getClass().getResource("/").getPath()
+                + "out/back/bmo/" + data.getName() + "/IDelete" + toUpperCaseFirstOne(data.getName()) + "BMO.java";
+        System.out.printf("writePath: " + writePath);
+        writeFile(writePath,
+                fileContext);
+        //复制生成的文件到对应分区目录下
+        if (data.isAutoMove()) {
+            FileUtilBase.copyfile(writePath, "service-"+data.getShareName()+"\\src\\main\\java\\com\\java110\\"+data.getShareName()+"\\bmo\\" + data.getName() + "/IDelete" + toUpperCaseFirstOne(data.getName()) + "BMO.java");
+        }
+    }
+
+    /**
+     * 生成API 侦听处理类
+     *
+     * @param data
+     */
+    private void genneratorDeleteBmoImpl(Data data) throws Exception {
+        StringBuffer sb = readFile(GeneratorStart.class.getResource("/newTemplate/DeleteBMOImpl.java").getFile());
+        String fileContext = sb.toString();
+        fileContext = fileContext.replace("@@shareName@@", data.getShareName())
+                .replace("@@ShareName@@", toUpperCaseFirstOne(data.getShareName()));
+
+        fileContext = super.replaceTemplateContext(fileContext, data);
+
+        String writePath = this.getClass().getResource("/").getPath()
+                + "out/back/bmo/" + data.getName() + "/impl/Delete" + toUpperCaseFirstOne(data.getName()) + "BMOImpl.java";
+        System.out.printf("writePath: " + writePath);
+        writeFile(writePath,
+                fileContext);
+        //复制生成的文件到对应分区目录下
+        if (data.isAutoMove()) {
+            FileUtilBase.copyfile(writePath, "service-"+data.getShareName()+"\\src\\main\\java\\com\\java110\\"+data.getShareName()+"\\bmo\\" + data.getName() + "/impl/Delete" + toUpperCaseFirstOne(data.getName()) + "BMOImpl.java");
+        }
+    }
+
+    /**
+     * 生成API 侦听处理类
+     *
+     * @param data
+     */
+    private void genneratorIGetBmo(Data data) throws Exception {
+        StringBuffer sb = readFile(GeneratorStart.class.getResource("/newTemplate/IGetBMO.java").getFile());
+        String fileContext = sb.toString();
+
+        fileContext = super.replaceTemplateContext(fileContext, data);
+
+        String writePath = this.getClass().getResource("/").getPath()
+                + "out/back/bmo/" + data.getName() + "/IGet" + toUpperCaseFirstOne(data.getName()) + "BMO.java";
+        System.out.printf("writePath: " + writePath);
+        writeFile(writePath,
+                fileContext);
+        //复制生成的文件到对应分区目录下
+        if (data.isAutoMove()) {
+            FileUtilBase.copyfile(writePath, "service-"+data.getShareName()+"\\src\\main\\java\\com\\java110\\"+data.getShareName()+"\\bmo\\" + data.getName() + "/IGet" + toUpperCaseFirstOne(data.getName()) + "BMO.java");
+        }
+    }
+
+    /**
+     * 生成API 侦听处理类
+     *
+     * @param data
+     */
+    private void genneratorGetBmoImpl(Data data) throws Exception {
+        StringBuffer sb = readFile(GeneratorStart.class.getResource("/newTemplate/GetBMOImpl.java").getFile());
+        String fileContext = sb.toString();
+        fileContext = fileContext.replace("@@shareName@@", data.getShareName())
+                .replace("@@ShareName@@", toUpperCaseFirstOne(data.getShareName()));
+
+        fileContext = super.replaceTemplateContext(fileContext, data);
+
+        String writePath = this.getClass().getResource("/").getPath()
+                + "out/back/bmo/" + data.getName() + "/impl/Get" + toUpperCaseFirstOne(data.getName()) + "BMOImpl.java";
+        System.out.printf("writePath: " + writePath);
+        writeFile(writePath,
+                fileContext);
+        //复制生成的文件到对应分区目录下
+        if (data.isAutoMove()) {
+            FileUtilBase.copyfile(writePath, "service-"+data.getShareName()+"\\src\\main\\java\\com\\java110\\"+data.getShareName()+"\\bmo\\" + data.getName() + "/impl/Get" + toUpperCaseFirstOne(data.getName()) + "BMOImpl.java");
+        }
+    }
+
+    private void genneratorApi(Data data) throws Exception {
+        StringBuffer sb = readFile(GeneratorStart.class.getResource("/newTemplate/Api.java").getFile());
+        String fileContext = sb.toString();
+        fileContext = fileContext.replace("@@shareName@@", data.getShareName())
+                .replace("@@ShareName@@", toUpperCaseFirstOne(data.getShareName()));
+
+        fileContext = super.replaceTemplateContext(fileContext, data);
+        //替换保存
+        StringBuffer validateStr = new StringBuffer();
+        for (String key : data.getRequiredParam()) {
+            //JSONObject column = columns.getJSONObject(columnIndex);
+            validateStr.append("Assert.hasKeyAndValue(reqJson, \"" + key + "\", \"请求报文中未包含" + key + "\");\n");
+        }
+        fileContext = fileContext.replace("@@validateSaveTemplateColumns@@", validateStr.toString());
+
+        //替换 修改
+        validateStr.append("Assert.hasKeyAndValue(reqJson, \"" + data.getId() + "\", \"" + data.getId() + "不能为空\");\n");
+        fileContext = fileContext.replace("@@validateUpdateTemplateColumns@@", validateStr.toString());
+
+        validateStr = new StringBuffer();
+        validateStr.append("Assert.hasKeyAndValue(reqJson, \"" + data.getId() + "\", \"" + data.getId() + "不能为空\");\n");
+        fileContext = fileContext.replace("@@validateDeleteTemplateColumns@@", validateStr.toString());
+
+
+        String writePath = this.getClass().getResource("/").getPath()
+                + "out/back/api/" + toUpperCaseFirstOne(data.getName()) + "Api.java";
+        System.out.printf("writePath: " + writePath);
+        writeFile(writePath,
+                fileContext);
+        //复制生成的文件到对应分区目录下
+        if (data.isAutoMove()) {
+            FileUtilBase.copyfile(writePath, "service-"+data.getShareName()+"\\src\\main\\java\\com\\java110\\"+data.getShareName()+"\\" + toUpperCaseFirstOne(data.getName()) + "Api.java");
+        }
+    }
+
+
+
+
 }

java110-generator/src/main/resources/newBack/template_1.json

@@ -1,37 +1,27 @@
 {
-  "autoMove": true,
-  "id": "templateId",
-  "name": "wechatSmsTemplate",
-  "desc": "微信消息模板",
-  "shareParam": "communityId",
-  "shareColumn": "community_id",
+  "autoMove": false,
+  "id": "attrId",
+  "name": "storeAttr",
+  "desc": "商户属性ID",
+  "shareParam": "storeId",
+  "shareColumn": "store_id",
   "shareName": "store",
-  "tableName": "wechat_sms_template",
+  "tableName": "mall_store_attr",
   "param": {
-    "templateId": "template_id",
-    "wechatId": "wechat_id",
-    "smsTemplateId": "sms_template_id",
-    "templateType": "template_type",
-    "communityId": "community_id",
-    "remarks": "remarks",
+    "storeId": "store_id",
+    "attrId": "attr_id",
+    "specCd": "spec_cd",
+    "value": "value",
     "statusCd": "status_cd"
   },
   "required": [
     {
-      "code": "wechatId",
-      "msg": "微信ID不能为空"
+      "code": "storeId",
+      "msg": "商户ID不能为空"
     },
     {
-      "code": "smsTemplateId",
-      "msg": "模板ID不能为空"
-    },
-    {
-      "code": "templateType",
-      "msg": "模板类型不能为空"
-    },
-    {
-      "code": "communityId",
-      "msg": "小区ID不能为空"
+      "code": "specCd",
+      "msg": "商户规格不能为空"
     }
   ]
 }

java110-generator/src/main/resources/newBack/template_storeAttr.json

@@ -0,0 +1,54 @@
+{
+  "autoMove": false,
+  "id": "storeId",
+  "name": "storeAttr",
+  "desc": "商户ID",
+  "shareParam": "storeId",
+  "shareColumn": "store_id",
+  "shareName": "store",
+  "tableName": "mall_store",
+  "param": {
+    "storeId": "store_id",
+    "staffId": "staff_id",
+    "name": "name",
+    "address": "address",
+    "tel": "tel",
+    "storeTypeCd": "store_type_cd",
+    "nearbyLandmarks": "nearby_landmarks",
+    "mapX": "map_x",
+    "mapY": "map_y",
+    "statusCd": "status_cd"
+  },
+  "required": [
+    {
+      "code": "staffId",
+      "msg": "员工不能为空"
+    },
+    {
+      "code": "name",
+      "msg": "商户名称不能为空"
+    },
+    {
+      "code": "address",
+      "msg": "地址不能为空"
+    },
+    {
+      "code": "tel",
+      "msg": "电话不能为空"
+    },
+    {
+      "code": "storeTypeCd",
+      "msg": "商户类型不能为空"
+    }
+    ,
+    {
+      "code": "mapX",
+      "msg": "精度不能为空"
+    } ,
+    {
+      "code": "mapY",
+      "msg": "维度不能为空"
+    }
+  ]
+}
+

java110-generator/src/main/resources/newBack/template_user.json

@@ -0,0 +1,40 @@
+{
+  "autoMove": false,
+  "id": "userId",
+  "name": "user",
+  "desc": "用户",
+  "shareParam": "storeId",
+  "shareColumn": "store_id",
+  "shareName": "user",
+  "tableName": "mall_user",
+  "param": {
+    "userId": "user_id",
+    "name": "name",
+    "email": "email",
+    "address": "address",
+    "password": "password",
+    "age": "age",
+    "sex": "sex",
+    "tel": "tel",
+    "statusCd": "status_cd"
+  },
+  "required": [
+    {
+      "code": "name",
+      "msg": "用户名称不能为空"
+    },
+    {
+      "code": "password",
+      "msg": "密码不能为空"
+    },
+    {
+      "code": "tel",
+      "msg": "手机号不能为空"
+    },
+    {
+      "code": "communityId",
+      "msg": "小区ID不能为空"
+    }
+  ]
+}
+

java110-generator/src/main/resources/newBack/template_userAddress.json

@@ -0,0 +1,55 @@
+{
+  "autoMove": false,
+  "id": "userId",
+  "name": "userAddress",
+  "desc": "用户地址",
+  "shareParam": "storeId",
+  "shareColumn": "store_id",
+  "shareName": "cust",
+  "tableName": "mall_user_address",
+  "param": {
+    "addressId": "address_id",
+    "name": "name",
+    "phone": "phone",
+    "address": "address",
+    "provinceId": "province_id",
+    "cityId": "city_id",
+    "regionId": "region_id",
+    "detail": "detail",
+    "userId": "user_id",
+    "statusCd": "status_cd"
+  },
+  "required": [
+    {
+      "code": "name",
+      "msg": "用户名称不能为空"
+    },
+    {
+      "code": "phone",
+      "msg": "手机号不能为空"
+    },
+    {
+      "code": "address",
+      "msg": "地址不能为空"
+    },
+    {
+      "code": "provinceId",
+      "msg": "省份不能为空"
+    },
+    {
+      "code": "cityId",
+      "msg": "城市不能为空"
+    }
+    ,
+    {
+      "code": "regionId",
+      "msg": "区域不能为空"
+    }
+    ,
+    {
+      "code": "userId",
+      "msg": "用户不能为空"
+    }
+  ]
+}
+

java110-generator/src/main/resources/newBack/template_userAttr.json

@@ -0,0 +1,28 @@
+{
+  "autoMove": false,
+  "id": "attrId",
+  "name": "userAttr",
+  "desc": "用户属性ID",
+  "shareParam": "storeId",
+  "shareColumn": "store_id",
+  "shareName": "cust",
+  "tableName": "mall_user_attr",
+  "param": {
+    "userId": "user_id",
+    "attrId": "attr_id",
+    "specCd": "spec_cd",
+    "value": "value",
+    "statusCd": "status_cd"
+  },
+  "required": [
+    {
+      "code": "userId",
+      "msg": "用户ID不能为空"
+    },
+    {
+      "code": "specCd",
+      "msg": "用户规格不能为空"
+    }
+  ]
+}
+

java110-generator/src/main/resources/newBack/template_wechatSmsTemplate.json

@@ -0,0 +1,38 @@
+{
+  "autoMove": true,
+  "id": "templateId",
+  "name": "wechatSmsTemplate",
+  "desc": "微信消息模板",
+  "shareParam": "communityId",
+  "shareColumn": "community_id",
+  "shareName": "store",
+  "tableName": "wechat_sms_template",
+  "param": {
+    "templateId": "template_id",
+    "wechatId": "wechat_id",
+    "smsTemplateId": "sms_template_id",
+    "templateType": "template_type",
+    "communityId": "community_id",
+    "remarks": "remarks",
+    "statusCd": "status_cd"
+  },
+  "required": [
+    {
+      "code": "wechatId",
+      "msg": "微信ID不能为空"
+    },
+    {
+      "code": "smsTemplateId",
+      "msg": "模板ID不能为空"
+    },
+    {
+      "code": "templateType",
+      "msg": "模板类型不能为空"
+    },
+    {
+      "code": "communityId",
+      "msg": "小区ID不能为空"
+    }
+  ]
+}
+

java110-generator/src/main/resources/newTemplate/AbstractBusinessServiceDataFlowListener.txt

@@ -1,77 +0,0 @@
-package com.java110.@@shareName@@.listener.@@templateCode@@;
-
-import com.alibaba.fastjson.JSONObject;
-import com.java110.utils.constant.ResponseConstant;
-import com.java110.utils.constant.StatusConstant;
-import com.java110.utils.exception.ListenerExecuteException;
-import com.java110.entity.center.Business;
-import com.java110.event.service.AbstractBusinessServiceDataFlowListener;
-import com.java110.@@shareName@@.dao.IStoreServiceDao;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-
-/**
- *
- * 商户 服务侦听 父类
- * Created by wuxw on 2018/7/4.
- */
-public abstract class AbstractStoreBusinessServiceDataFlowListener extends AbstractBusinessServiceDataFlowListener{
-    private static Logger logger = LoggerFactory.getLogger(AbstractStoreBusinessServiceDataFlowListener.class);
-
-
-    /**
-     * 获取 DAO工具类
-     * @return
-     */
-    public abstract IStoreServiceDao getStoreServiceDaoImpl();
-
-    /**
-     * 刷新 businessStoreInfo 数据
-     * 主要将 数据库 中字段和 接口传递字段建立关系
-     * @param businessStoreInfo
-     */
-    protected void flushBusinessStoreInfo(Map businessStoreInfo,String statusCd){
-        businessStoreInfo.put("newBId", businessStoreInfo.get("b_id"));
-        $flushBusinessInfo$
-        businessStoreInfo.put("statusCd", statusCd);
-    }
-
-
-    /**
-     * 当修改数据时，查询instance表中的数据 自动保存删除数据到business中
-     * @param businessStore 商户信息
-     */
-    protected void autoSaveDelBusinessStore(Business business, JSONObject businessStore){
-//自动插入DEL
-        Map info = new HashMap();
-        info.put("storeId",businessStore.getString("storeId"));
-        info.put("statusCd",StatusConstant.STATUS_CD_VALID);
-        List<Map> currentStoreInfos = getStoreServiceDaoImpl().getStoreInfo(info);
-        if(currentStoreInfos == null || currentStoreInfos.size() != 1){
-            throw new ListenerExecuteException(ResponseConstant.RESULT_PARAM_ERROR,"未找到需要修改数据信息，入参错误或数据有问题，请检查"+info);
-        }
-
-        Map currentStoreInfo = currentStoreInfos.get(0);
-
-        currentStoreInfo.put("bId",business.getbId());
-
-        $autoSaveDelBusiness$
-
-        currentStoreInfo.put("operate",StatusConstant.OPERATE_DEL);
-        getStoreServiceDaoImpl().saveBusinessStoreInfo(currentStoreInfo);
-        for(Object key : currentStoreInfo.keySet()) {
-            if(businessStore.get(key) == null) {
-                businessStore.put(key.toString(), currentStoreInfo.get(key));
-            }
-        }
-    }
-
-
-
-
-
-}

java110-generator/src/main/resources/newTemplate/Api.java

@@ -0,0 +1,95 @@
+package com.java110.store.api;
+
+import com.java110.dto.Dto;.@@TemplateCode@@Dto;
+import com.java110.po.@@templateCode@@.@@TemplateCode@@Po;
+import com.java110.store.bmo.@@TemplateCode@@.IDelete@@TemplateCode@@BMO;
+import com.java110.store.bmo.@@TemplateCode@@.IGet@@TemplateCode@@BMO;
+import com.java110.store.bmo.@@TemplateCode@@.ISave@@TemplateCode@@BMO;
+import com.java110.store.bmo.@@TemplateCode@@.IUpdate@@TemplateCode@@BMO;
+import com.java110.utils.util.Assert;
+import com.java110.utils.util.BeanConvertUtil;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.*;
+
+@RestController
+@RequestMapping(value = "/@@templateCode@@")
+public class @@TemplateCode@@Api {
+
+    @Autowired
+    private ISave@@TemplateCode@@BMO save@@TemplateCode@@BMOImpl;
+    @Autowired
+    private IUpdate@@TemplateCode@@BMO update@@TemplateCode@@BMOImpl;
+    @Autowired
+    private IDelete@@TemplateCode@@BMO delete@@TemplateCode@@BMOImpl;
+
+    @Autowired
+    private IGet@@TemplateCode@@BMO get@@TemplateCode@@BMOImpl;
+
+    /**
+     * 微信保存消息模板
+     * @serviceCode /@@templateCode@@/save@@TemplateCode@@
+     * @path /app/@@templateCode@@/save@@TemplateCode@@
+     * @param reqJson
+     * @return
+     */
+    @RequestMapping(value = "/save@@TemplateCode@@", method = RequestMethod.POST)
+    public ResponseEntity<String> save@@TemplateCode@@(@RequestBody JSONObject reqJson) {
+
+        @@validateSaveTemplateColumns@@
+
+        @@TemplateCode@@Po @@templateCode@@Po = BeanConvertUtil.covertBean(reqJson, @@TemplateCode@@Po.class);
+        return save@@TemplateCode@@BMOImpl.save(@@templateCode@@Po);
+    }
+
+    /**
+     * 微信修改消息模板
+     * @serviceCode /@@templateCode@@/update@@TemplateCode@@
+     * @path /app/@@templateCode@@/update@@TemplateCode@@
+     * @param reqJson
+     * @return
+     */
+    @RequestMapping(value = "/update@@TemplateCode@@", method = RequestMethod.POST)
+    public ResponseEntity<String> update@@TemplateCode@@(@RequestBody JSONObject reqJson) {
+
+        @@validateUpdateTemplateColumns@@
+
+        @@TemplateCode@@Po @@templateCode@@Po = BeanConvertUtil.covertBean(reqJson, @@TemplateCode@@Po.class);
+        return update@@TemplateCode@@BMOImpl.update(@@templateCode@@Po);
+    }
+
+    /**
+     * 微信删除消息模板
+     * @serviceCode /@@templateCode@@/delete@@TemplateCode@@
+     * @path /app/@@templateCode@@/delete@@TemplateCode@@
+     * @param reqJson
+     * @return
+     */
+    @RequestMapping(value = "/delete@@TemplateCode@@", method = RequestMethod.POST)
+    public ResponseEntity<String> delete@@TemplateCode@@(@RequestBody JSONObject reqJson) {
+        Assert.hasKeyAndValue(reqJson, "communityId", "小区ID不能为空");
+
+        @@validateDeleteTemplateColumns@@
+
+        @@TemplateCode@@Po @@templateCode@@Po = BeanConvertUtil.covertBean(reqJson, @@TemplateCode@@Po.class);
+        return delete@@TemplateCode@@BMOImpl.delete(@@templateCode@@Po);
+    }
+
+    /**
+     * 微信删除消息模板
+     * @serviceCode /@@templateCode@@/query@@TemplateCode@@
+     * @path /app/@@templateCode@@/query@@TemplateCode@@
+     * @param communityId 小区ID
+     * @return
+     */
+    @RequestMapping(value = "/query@@TemplateCode@@", method = RequestMethod.GET)
+    public ResponseEntity<String> query@@TemplateCode@@(@RequestParam(value = "communityId") String communityId,
+                                                      @RequestParam(value = "page") int page,
+                                                      @RequestParam(value = "row") int row) {
+        @@TemplateCode@@Dto @@templateCode@@Dto = new @@TemplateCode@@Dto();
+        @@templateCode@@Dto.setPage(page);
+        @@templateCode@@Dto.setRow(row);
+        @@templateCode@@Dto.setCommunityId(communityId);
+        return get@@TemplateCode@@BMOImpl.get(@@templateCode@@Dto);
+    }
+}

java110-generator/src/main/resources/newTemplate/BMOImpl.java

@@ -1,66 +0,0 @@
-package com.java110.api.bmo.@@templateCode@@.impl;
-
-import com.alibaba.fastjson.JSONObject;
-import com.java110.api.bmo.ApiBaseBMO;
-import com.java110.api.bmo.@@templateCode@@.I@@TemplateCode@@BMO;
-import com.java110.core.context.DataFlowContext;
-import com.java110.intf.@@templateCode@@.I@@TemplateCode@@InnerServiceSMO;
-import com.java110.dto.@@templateCode@@.@@TemplateCode@@Dto;
-import com.java110.utils.constant.BusinessTypeConstant;
-import com.java110.utils.constant.CommonConstant;
-import com.java110.utils.util.Assert;
-import com.java110.utils.util.BeanConvertUtil;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Service;
-
-import java.util.List;
-
-@Service("@@templateCode@@BMOImpl")
-public class @@TemplateCode@@BMOImpl extends ApiBaseBMO implements I@@TemplateCode@@BMO {
-
-    @Autowired
-    private I@@TemplateCode@@InnerServiceSMO @@templateCode@@InnerServiceSMOImpl;
-
-    /**
-     * 添加小区信息
-     *
-     * @param paramInJson     接口调用放传入入参
-     * @param dataFlowContext 数据上下文
-     * @return 订单服务能够接受的报文
-     */
-    public void add@@TemplateCode@@(JSONObject paramInJson, DataFlowContext dataFlowContext) {
-
-        paramInJson.put("@@templateKey@@", "-1");
-        @@TemplateCode@@Po @@templateCode@@Po = BeanConvertUtil.covertBean(paramInJson, @@TemplateCode@@Po.class);
-        super.insert(dataFlowContext, @@templateCode@@Po, BusinessTypeConstant.BUSINESS_TYPE_SAVE_@@TEMPLATECODE@@);
-    }
-
-
-    /**
-     * 添加活动信息
-     *
-     * @param paramInJson     接口调用放传入入参
-     * @param dataFlowContext 数据上下文
-     * @return 订单服务能够接受的报文
-     */
-    public void update@@TemplateCode@@(JSONObject paramInJson, DataFlowContext dataFlowContext) {
-        @@TemplateCode@@Po @@templateCode@@Po = BeanConvertUtil.covertBean(paramInJson, @@TemplateCode@@Po.class);
-        super.update(dataFlowContext, @@templateCode@@Po, BusinessTypeConstant.BUSINESS_TYPE_UPDATE_@@TEMPLATECODE@@);
-    }
-
-
-
-    /**
-     * 添加小区信息
-     *
-     * @param paramInJson     接口调用放传入入参
-     * @param dataFlowContext 数据上下文
-     * @return 订单服务能够接受的报文
-     */
-    public void delete@@TemplateCode@@(JSONObject paramInJson, DataFlowContext dataFlowContext) {
-
-        @@TemplateCode@@Po @@templateCode@@Po = BeanConvertUtil.covertBean(paramInJson, @@TemplateCode@@Po.class);
-        super.update(dataFlowContext, @@templateCode@@Po, BusinessTypeConstant.BUSINESS_TYPE_DELETE_@@TEMPLATECODE@@);
-    }
-
-}

java110-generator/src/main/resources/newTemplate/DeleteBMOImpl.java

@@ -0,0 +1,48 @@
+package com.java110.api.bmo.@@templateCode@@.impl;
+
+import com.alibaba.fastjson.JSONObject;
+import com.java110.api.bmo.ApiBaseBMO;
+import com.java110.api.bmo.@@templateCode@@.I@@TemplateCode@@BMO;
+import com.java110.core.annotation.Java110Transactional;
+import com.java110.core.factory.GenerateCodeFactory;
+import com.java110.intf.store.IWechatSmsTemplateInnerServiceSMO;
+import com.java110.po.wechatSmsTemplate.WechatSmsTemplatePo;
+import com.java110.vo.ResultVo;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Service;
+import com.java110.core.context.DataFlowContext;
+import com.java110.intf.@@templateCode@@.I@@TemplateCode@@InnerServiceSMO;
+import com.java110.dto.@@templateCode@@.@@TemplateCode@@Dto;
+import com.java110.utils.constant.BusinessTypeConstant;
+import com.java110.utils.constant.CommonConstant;
+import com.java110.utils.util.Assert;
+import com.java110.utils.util.BeanConvertUtil;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service("delete@@TemplateCode@@BMOImpl")
+public class Delete@@TemplateCode@@BMOImpl implements IDelete@@TemplateCode@@BMO {
+
+    @Autowired
+    private I@@TemplateCode@@InnerServiceSMO @@templateCode@@InnerServiceSMOImpl;
+
+    /**
+     * @param @@templateCode@@Po 数据
+     * @return 订单服务能够接受的报文
+     */
+    @Java110Transactional
+    public ResponseEntity<String> delete(@@TemplateCode@@Po @@templateCode@@Po) {
+
+        int flag = @@templateCode@@InnerServiceSMOImpl.delete@@TemplateCode@@(@@templateCode@@Po);
+
+        if (flag > 0) {
+        return ResultVo.createResponseEntity(ResultVo.CODE_OK, "保存成功");
+        }
+
+        return ResultVo.createResponseEntity(ResultVo.CODE_ERROR, "保存失败");
+    }
+
+}

java110-generator/src/main/resources/newTemplate/DeleteInfoListener.txt

@@ -1,175 +0,0 @@
-package com.java110.@@shareName@@.listener.@@templateCode@@;
-
-import com.alibaba.fastjson.JSONArray;
-import com.alibaba.fastjson.JSONObject;
-import com.java110.utils.constant.BusinessTypeConstant;
-import com.java110.utils.constant.ResponseConstant;
-import com.java110.utils.constant.StatusConstant;
-import com.java110.utils.exception.ListenerExecuteException;
-import com.java110.utils.util.Assert;
-import com.java110.core.annotation.Java110Listener;
-import com.java110.core.context.DataFlowContext;
-import com.java110.entity.center.Business;
-import com.java110.@@shareName@@.dao.IStoreServiceDao;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.transaction.annotation.Transactional;
-
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-
-/**
- * 删除商户信息 侦听
- *
- * 处理节点
- * 1、businessStore:{} 商户基本信息节点
- * 2、businessStoreAttr:[{}] 商户属性信息节点
- * 3、businessStorePhoto:[{}] 商户照片信息节点
- * 4、businessStoreCerdentials:[{}] 商户证件信息节点
- * 协议地址 ：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("deleteStoreInfoListener")
-@Transactional
-public class DeleteStoreInfoListener extends AbstractStoreBusinessServiceDataFlowListener {
-
-    private final static Logger logger = LoggerFactory.getLogger(DeleteStoreInfoListener.class);
-    @Autowired
-    IStoreServiceDao storeServiceDaoImpl;
-
-    @Override
-    public int getOrder() {
-        return 3;
-    }
-
-    @Override
-    public String getBusinessTypeCd() {
-        return BusinessTypeConstant.BUSINESS_TYPE_DELETE_STORE_INFO;
-    }
-
-    /**
-     * 根据删除信息 查出Instance表中数据 保存至business表 （状态写DEL） 方便撤单时直接更新回去
-     * @param dataFlowContext 数据对象
-     * @param business 当前业务对象
-     */
-    @Override
-    protected void doSaveBusiness(DataFlowContext dataFlowContext, Business business) {
-        JSONObject data = business.getDatas();
-
-        Assert.notEmpty(data,"没有datas 节点，或没有子节点需要处理");
-
-            //处理 businessStore 节点
-            if(data.containsKey(StorePo.class.getSimpleName())){
-                Object _obj = data.get(StorePo.class.getSimpleName());
-                JSONArray businessStores = null;
-                if(_obj instanceof JSONObject){
-                    businessStores = new JSONArray();
-                    businessStores.add(_obj);
-                }else {
-                    businessStores = (JSONArray)_obj;
-                }
-                //JSONObject businessStore = data.getJSONObject(StorePo.class.getSimpleName());
-                for (int _storeIndex = 0; _storeIndex < businessStores.size();_storeIndex++) {
-                    JSONObject businessStore = businessStores.getJSONObject(_storeIndex);
-                    doBusinessStore(business, businessStore);
-                    if(_obj instanceof JSONObject) {
-                        dataFlowContext.addParamOut("storeId", businessStore.getString("storeId"));
-                    }
-                }
-
-        }
-
-
-    }
-
-    /**
-     * 删除 instance数据
-     * @param dataFlowContext 数据对象
-     * @param business 当前业务对象
-     */
-    @Override
-    protected void doBusinessToInstance(DataFlowContext dataFlowContext, Business business) {
-        String bId = business.getbId();
-        //Assert.hasLength(bId,"请求报文中没有包含 bId");
-
-        //商户信息
-        Map info = new HashMap();
-        info.put("bId",business.getbId());
-        info.put("operate",StatusConstant.OPERATE_DEL);
-
-        //商户信息
-        List<Map> businessStoreInfos = storeServiceDaoImpl.getBusinessStoreInfo(info);
-        if( businessStoreInfos != null && businessStoreInfos.size() >0) {
-            for (int _storeIndex = 0; _storeIndex < businessStoreInfos.size();_storeIndex++) {
-                Map businessStoreInfo = businessStoreInfos.get(_storeIndex);
-                flushBusinessStoreInfo(businessStoreInfo,StatusConstant.STATUS_CD_INVALID);
-                storeServiceDaoImpl.updateStoreInfoInstance(businessStoreInfo);
-                dataFlowContext.addParamOut("storeId",businessStoreInfo.get("store_id"));
-            }
-        }
-
-    }
-
-    /**
-     * 撤单
-     * 从business表中查询到DEL的数据 将instance中的数据更新回来
-     * @param dataFlowContext 数据对象
-     * @param business 当前业务对象
-     */
-    @Override
-    protected void doRecover(DataFlowContext dataFlowContext, Business business) {
-        String bId = business.getbId();
-        //Assert.hasLength(bId,"请求报文中没有包含 bId");
-        Map info = new HashMap();
-        info.put("bId",bId);
-        info.put("statusCd",StatusConstant.STATUS_CD_INVALID);
-
-        Map delInfo = new HashMap();
-        delInfo.put("bId",business.getbId());
-        delInfo.put("operate",StatusConstant.OPERATE_DEL);
-        //商户信息
-        List<Map> storeInfo = storeServiceDaoImpl.getStoreInfo(info);
-        if(storeInfo != null && storeInfo.size() > 0){
-
-            //商户信息
-            List<Map> businessStoreInfos = storeServiceDaoImpl.getBusinessStoreInfo(delInfo);
-            //除非程序出错了，这里不会为空
-            if(businessStoreInfos == null ||  businessStoreInfos.size() == 0){
-                throw new ListenerExecuteException(ResponseConstant.RESULT_CODE_INNER_ERROR,"撤单失败（store），程序内部异常,请检查！ "+delInfo);
-            }
-            for (int _storeIndex = 0; _storeIndex < businessStoreInfos.size();_storeIndex++) {
-                Map businessStoreInfo = businessStoreInfos.get(_storeIndex);
-                flushBusinessStoreInfo(businessStoreInfo,StatusConstant.STATUS_CD_VALID);
-                storeServiceDaoImpl.updateStoreInfoInstance(businessStoreInfo);
-            }
-        }
-    }
-
-
-
-    /**
-     * 处理 businessStore 节点
-     * @param business 总的数据节点
-     * @param businessStore 商户节点
-     */
-    private void doBusinessStore(Business business,JSONObject businessStore){
-
-        Assert.jsonObjectHaveKey(businessStore,"storeId","businessStore 节点下没有包含 storeId 节点");
-
-        if(businessStore.getString("storeId").startsWith("-")){
-            throw new ListenerExecuteException(ResponseConstant.RESULT_PARAM_ERROR,"storeId 错误，不能自动生成（必须已经存在的storeId）"+businessStore);
-        }
-        //自动插入DEL
-        autoSaveDelBusinessStore(business,businessStore);
-    }
-    @Override
-    public IStoreServiceDao getStoreServiceDaoImpl() {
-        return storeServiceDaoImpl;
-    }
-
-    public void setStoreServiceDaoImpl(IStoreServiceDao storeServiceDaoImpl) {
-        this.storeServiceDaoImpl = storeServiceDaoImpl;
-    }
-}

java110-generator/src/main/resources/newTemplate/DeleteListener.java

@@ -1,53 +0,0 @@
-package com.java110.api.listener.@@templateCode@@;
-
-import com.alibaba.fastjson.JSONArray;
-import com.alibaba.fastjson.JSONObject;
-import com.java110.api.bmo.@@templateCode@@.I@@TemplateCode@@BMO;
-import com.java110.api.listener.AbstractServiceApiListener;
-import com.java110.utils.constant.ServiceCode@@TemplateCode@@Constant;
-import com.java110.utils.util.Assert;
-import com.java110.core.context.DataFlowContext;
-import com.java110.entity.center.AppService;
-import com.java110.event.service.api.ServiceDataFlowEvent;
-import com.java110.utils.constant.CommonConstant;
-import com.java110.core.annotation.Java110Listener;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.http.HttpHeaders;
-import org.springframework.http.HttpMethod;
-import org.springframework.http.ResponseEntity;
-
-
-/**
- * 保存小区侦听
- * add by wuxw 2019-06-30
- */
-@Java110Listener("delete@@TemplateCode@@Listener")
-public class Delete@@TemplateCode@@Listener extends AbstractServiceApiPlusListener {
-
-    @Autowired
-    private I@@TemplateCode@@BMO @@templateCode@@BMOImpl;
-
-    @Override
-    protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) {
-        //Assert.hasKeyAndValue(reqJson, "xxx", "xxx");
-
-        @@validateTemplateColumns@@
-    }
-
-    @Override
-    protected void doSoService(ServiceDataFlowEvent event, DataFlowContext context, JSONObject reqJson) {
-
-        @@templateCode@@BMOImpl.delete@@TemplateCode@@(reqJson, context);
-    }
-
-    @Override
-    public String getServiceCode() {
-        return ServiceCode@@TemplateCode@@Constant.DELETE_@@TEMPLATECODE@@;
-    }
-
-    @Override
-    public HttpMethod getHttpMethod() {
-        return HttpMethod.POST;
-    }
-
-}

java110-generator/src/main/resources/newTemplate/GetBMOImpl.java

@@ -0,0 +1,57 @@
+package com.java110.api.bmo.@@templateCode@@.impl;
+
+import com.alibaba.fastjson.JSONObject;
+import com.java110.api.bmo.ApiBaseBMO;
+import com.java110.api.bmo.@@templateCode@@.I@@TemplateCode@@BMO;
+import com.java110.core.annotation.Java110Transactional;
+import com.java110.core.factory.GenerateCodeFactory;
+import com.java110.intf.store.IWechatSmsTemplateInnerServiceSMO;
+import com.java110.po.wechatSmsTemplate.WechatSmsTemplatePo;
+import com.java110.vo.ResultVo;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Service;
+import com.java110.core.context.DataFlowContext;
+import com.java110.intf.@@templateCode@@.I@@TemplateCode@@InnerServiceSMO;
+import com.java110.dto.@@templateCode@@.@@TemplateCode@@Dto;
+import com.java110.utils.constant.BusinessTypeConstant;
+import com.java110.utils.constant.CommonConstant;
+import com.java110.utils.util.Assert;
+import com.java110.utils.util.BeanConvertUtil;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service("get@@TemplateCode@@BMOImpl")
+public class Get@@TemplateCode@@BMOImpl implements IGet@@TemplateCode@@BMO {
+
+    @Autowired
+    private I@@TemplateCode@@InnerServiceSMO @@templateCode@@InnerServiceSMOImpl;
+
+    /**
+     *
+     *
+     * @param  @@templateCode@@Dto
+     * @return 订单服务能够接受的报文
+     */
+    public ResponseEntity<String> get(@@TemplateCode@@Dto @@templateCode@@Dto) {
+
+
+        int count = @@templateCode@@InnerServiceSMOImpl.query@@TemplateCode@@sCount(@@templateCode@@Dto);
+
+        List<@@TemplateCode@@Dto> @@templateCode@@Dtos = null;
+        if (count > 0) {
+            @@templateCode@@Dtos = @@templateCode@@InnerServiceSMOImpl.query@@TemplateCode@@s(@@templateCode@@Dto);
+        } else {
+            @@templateCode@@Dtos = new ArrayList<>();
+        }
+
+        ResultVo resultVo = new ResultVo((int) Math.ceil((double) count / (double) @@templateCode@@Dto.getRow()), count, @@templateCode@@Dtos);
+
+        ResponseEntity<String> responseEntity = new ResponseEntity<String>(resultVo.toString(), HttpStatus.OK);
+
+        return responseEntity;
+    }
+
+}

java110-generator/src/main/resources/newTemplate/IBMO.java

@@ -1,38 +0,0 @@
-package com.java110.api.bmo.@@templateCode@@;
-
-import com.alibaba.fastjson.JSONObject;
-import com.java110.api.bmo.IApiBaseBMO;
-import com.java110.core.context.DataFlowContext;
-
-public interface I@@TemplateCode@@BMO extends IApiBaseBMO {
-
-
-    /**
-     * 添加@@templateName@@
-     * @param paramInJson
-     * @param dataFlowContext
-     * @return
-     */
-     void add@@TemplateCode@@(JSONObject paramInJson, DataFlowContext dataFlowContext);
-
-    /**
-     * 添加@@templateName@@信息
-     *
-     * @param paramInJson     接口调用放传入入参
-     * @param dataFlowContext 数据上下文
-     * @return 订单服务能够接受的报文
-     */
-     void update@@TemplateCode@@(JSONObject paramInJson, DataFlowContext dataFlowContext);
-
-    /**
-     * 删除@@templateName@@
-     *
-     * @param paramInJson     接口调用放传入入参
-     * @param dataFlowContext 数据上下文
-     * @return 订单服务能够接受的报文
-     */
-     void delete@@TemplateCode@@(JSONObject paramInJson, DataFlowContext dataFlowContext);
-
-
-
-}

java110-generator/src/main/resources/newTemplate/IDeleteBMO.java

@@ -0,0 +1,16 @@
+package com.java110.api.bmo.@@templateCode@@;
+import org.springframework.http.ResponseEntity;
+
+public interface IDelete@@TemplateCode@@BMO {
+
+
+    /**
+     * 修改@@templateName@@
+     * add by wuxw
+     * @param @@templateCode@@Po
+     * @return
+     */
+    ResponseEntity<String> delete(@@TemplateCode@@Po @@templateCode@@Po);
+
+
+}

java110-generator/src/main/resources/newTemplate/IGetBMO.java

@@ -0,0 +1,15 @@
+package com.java110.api.bmo.@@templateCode@@;
+import org.springframework.http.ResponseEntity;
+public interface IGet@@TemplateCode@@BMO {
+
+
+    /**
+     * 查询@@templateName@@
+     * add by wuxw
+     * @param  @@templateCode@@Dto
+     * @return
+     */
+    ResponseEntity<String> get(@@TemplateCode@@Dto @@templateCode@@Dto);
+
+
+}

java110-generator/src/main/resources/newTemplate/ISaveBMO.java

@@ -0,0 +1,16 @@
+package com.java110.api.bmo.@@templateCode@@;
+
+import org.springframework.http.ResponseEntity;
+public interface ISave@@TemplateCode@@BMO {
+
+
+    /**
+     * 添加@@templateName@@
+     * add by wuxw
+     * @param @@templateCode@@Po
+     * @return
+     */
+    ResponseEntity<String> save(@@TemplateCode@@Po @@templateCode@@Po);
+
+
+}

java110-generator/src/main/resources/newTemplate/IUpdateBMO.java

@@ -0,0 +1,16 @@
+package com.java110.api.bmo.@@templateCode@@;
+import org.springframework.http.ResponseEntity;
+
+public interface IUpdate@@TemplateCode@@BMO {
+
+
+    /**
+     * 修改@@templateName@@
+     * add by wuxw
+     * @param @@templateCode@@Po
+     * @return
+     */
+    ResponseEntity<String> update(@@TemplateCode@@Po @@templateCode@@Po);
+
+
+}

java110-generator/src/main/resources/newTemplate/ListListener.java

@@ -1,82 +0,0 @@
-package com.java110.api.listener.@@templateCode@@;
-
-import com.alibaba.fastjson.JSONObject;
-import com.java110.api.listener.AbstractServiceApiListener;
-import com.java110.intf.@@templateCode@@.I@@TemplateCode@@InnerServiceSMO;
-import com.java110.utils.constant.ServiceCode@@TemplateCode@@Constant;
-import com.java110.utils.util.BeanConvertUtil;
-import com.java110.core.annotation.Java110Listener;
-import com.java110.core.context.DataFlowContext;
-import com.java110.dto.companyMain.CompanyMainDto;
-import com.java110.event.service.api.ServiceDataFlowEvent;
-import com.java110.vo.api.@@templateCode@@.Api@@TemplateCode@@DataVo;
-import com.java110.vo.api.@@templateCode@@.Api@@TemplateCode@@Vo;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.http.HttpMethod;
-import org.springframework.http.HttpStatus;
-import org.springframework.http.ResponseEntity;
-import java.util.ArrayList;
-import java.util.List;
-
-/**
- * 查询小区侦听类
- */
-@Java110Listener("list@@TemplateCode@@sListener")
-public class List@@TemplateCode@@sListener extends AbstractServiceApiListener {
-
-    @Autowired
-    private I@@TemplateCode@@InnerServiceSMO @@templateCode@@InnerServiceSMOImpl;
-
-    @Override
-    public String getServiceCode() {
-        return ServiceCode@@TemplateCode@@Constant.LIST_@@TEMPLATECODE@@S;
-    }
-
-    @Override
-    public HttpMethod getHttpMethod() {
-        return HttpMethod.GET;
-    }
-
-
-    @Override
-    public int getOrder() {
-        return DEFAULT_ORDER;
-    }
-
-
-    public I@@TemplateCode@@InnerServiceSMO get@@TemplateCode@@InnerServiceSMOImpl() {
-        return @@templateCode@@InnerServiceSMOImpl;
-    }
-
-    public void set@@TemplateCode@@InnerServiceSMOImpl(I@@TemplateCode@@InnerServiceSMO @@templateCode@@InnerServiceSMOImpl) {
-        this.@@templateCode@@InnerServiceSMOImpl = @@templateCode@@InnerServiceSMOImpl;
-    }
-
-    @Override
-    protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) {
-        super.validatePageInfo(reqJson);
-    }
-
-    @Override
-    protected void doSoService(ServiceDataFlowEvent event, DataFlowContext context, JSONObject reqJson) {
-
-        @@TemplateCode@@Dto @@templateCode@@Dto = BeanConvertUtil.covertBean(reqJson, @@TemplateCode@@Dto.class);
-
-        int count = @@templateCode@@InnerServiceSMOImpl.query@@TemplateCode@@sCount(@@templateCode@@Dto);
-
-        List<@@TemplateCode@@Dto> @@templateCode@@Dtos = null;
-
-        if (count > 0) {
-            @@templateCode@@Dtos = @@templateCode@@InnerServiceSMOImpl.query@@TemplateCode@@s(@@templateCode@@Dto);
-        } else {
-            @@templateCode@@Dtos = new ArrayList<>();
-        }
-
-        ResultVo resultVo = new ResultVo((int) Math.ceil((double) count / (double) reqJson.getInteger("row")), count, @@templateCode@@Dtos);
-
-        ResponseEntity<String> responseEntity = new ResponseEntity<String>(resultVo.toString(), HttpStatus.OK);
-
-        context.setResponseEntity(responseEntity);
-
-    }
-}

java110-generator/src/main/resources/newTemplate/SaveBMOImpl.java

@@ -0,0 +1,51 @@
+package com.java110.api.bmo.@@templateCode@@.impl;
+
+import com.alibaba.fastjson.JSONObject;
+import com.java110.api.bmo.ApiBaseBMO;
+import com.java110.api.bmo.@@templateCode@@.I@@TemplateCode@@BMO;
+import com.java110.core.annotation.Java110Transactional;
+import com.java110.core.factory.GenerateCodeFactory;
+import com.java110.intf.store.IWechatSmsTemplateInnerServiceSMO;
+import com.java110.po.wechatSmsTemplate.WechatSmsTemplatePo;
+import com.java110.vo.ResultVo;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Service;
+import com.java110.core.context.DataFlowContext;
+import com.java110.intf.@@templateCode@@.I@@TemplateCode@@InnerServiceSMO;
+import com.java110.dto.@@templateCode@@.@@TemplateCode@@Dto;
+import com.java110.utils.constant.BusinessTypeConstant;
+import com.java110.utils.constant.CommonConstant;
+import com.java110.utils.util.Assert;
+import com.java110.utils.util.BeanConvertUtil;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service("save@@TemplateCode@@BMOImpl")
+public class Save@@TemplateCode@@BMOImpl implements ISave@@TemplateCode@@BMO {
+
+    @Autowired
+    private I@@TemplateCode@@InnerServiceSMO @@templateCode@@InnerServiceSMOImpl;
+
+    /**
+     * 添加小区信息
+     *
+     * @param @@templateCode@@Po
+     * @return 订单服务能够接受的报文
+     */
+    @Java110Transactional
+    public ResponseEntity<String> save(@@TemplateCode@@Po @@templateCode@@Po) {
+
+        @@templateCode@@Po.set@@TemplateKey@@(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_@@templateKey@@));
+        int flag = @@templateCode@@InnerServiceSMOImpl.save@@TemplateCode@@(@@templateCode@@Po);
+
+        if (flag > 0) {
+        return ResultVo.createResponseEntity(ResultVo.CODE_OK, "保存成功");
+        }
+
+        return ResultVo.createResponseEntity(ResultVo.CODE_ERROR, "保存失败");
+    }
+
+}

java110-generator/src/main/resources/newTemplate/SaveListener.java

@@ -1,50 +0,0 @@
-package com.java110.api.listener.@@templateCode@@;
-
-import com.alibaba.fastjson.JSONArray;
-import com.alibaba.fastjson.JSONObject;
-import com.java110.api.bmo.@@templateCode@@.I@@TemplateCode@@BMO;
-import com.java110.api.listener.AbstractServiceApiListener;
-import com.java110.utils.constant.ServiceCode@@TemplateCode@@Constant;
-import com.java110.utils.util.Assert;
-import com.java110.core.context.DataFlowContext;
-import com.java110.entity.center.AppService;
-import com.java110.event.service.api.ServiceDataFlowEvent;
-import com.java110.utils.constant.CommonConstant;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.http.HttpHeaders;
-import org.springframework.http.HttpMethod;
-import org.springframework.http.ResponseEntity;
-import com.java110.core.annotation.Java110Listener;
-/**
- * 保存商户侦听
- * add by wuxw 2019-06-30
- */
-@Java110Listener("save@@TemplateCode@@Listener")
-public class Save@@TemplateCode@@Listener extends AbstractServiceApiPlusListener {
-
-    @Autowired
-    private I@@TemplateCode@@BMO @@templateCode@@BMOImpl;
-
-    @Override
-    protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) {
-        //Assert.hasKeyAndValue(reqJson, "xxx", "xxx");
-
-        @@validateTemplateColumns@@
-    }
-
-    @Override
-    protected void doSoService(ServiceDataFlowEvent event, DataFlowContext context, JSONObject reqJson) {
-        @@templateCode@@BMOImpl.add@@TemplateCode@@(reqJson, context);
-    }
-
-    @Override
-    public String getServiceCode() {
-        return ServiceCode@@TemplateCode@@Constant.ADD_@@TEMPLATECODE@@;
-    }
-
-    @Override
-    public HttpMethod getHttpMethod() {
-        return HttpMethod.POST;
-    }
-
-}

java110-generator/src/main/resources/newTemplate/SaveListener.txt

@@ -1,175 +0,0 @@
-package com.java110.@@shareName@@.listener.@@templateCode@@;
-
-import com.alibaba.fastjson.JSONArray;
-import com.alibaba.fastjson.JSONObject;
-import com.java110.utils.constant.BusinessTypeConstant;
-import com.java110.utils.constant.StatusConstant;
-import com.java110.utils.util.Assert;
-import com.java110.@@shareName@@.dao.IStoreServiceDao;
-import com.java110.core.annotation.Java110Listener;
-import com.java110.core.context.DataFlowContext;
-import com.java110.core.factory.GenerateCodeFactory;
-import com.java110.entity.center.Business;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.transaction.annotation.Transactional;
-
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-
-/**
- * 保存 商户信息 侦听
- * Created by wuxw on 2018/5/18.
- */
-@Java110Listener("saveStoreInfoListener")
-@Transactional
-public class SaveStoreInfoListener extends AbstractStoreBusinessServiceDataFlowListener{
-
-    private static Logger logger = LoggerFactory.getLogger(SaveStoreInfoListener.class);
-
-    @Autowired
-    private IStoreServiceDao storeServiceDaoImpl;
-
-    @Override
-    public int getOrder() {
-        return 0;
-    }
-
-    @Override
-    public String getBusinessTypeCd() {
-        return BusinessTypeConstant.BUSINESS_TYPE_SAVE_STORE_INFO;
-    }
-
-    /**
-     * 保存商户信息 business 表中
-     * @param dataFlowContext 数据对象
-     * @param business 当前业务对象
-     */
-    @Override
-    protected void doSaveBusiness(DataFlowContext dataFlowContext, Business business) {
-        JSONObject data = business.getDatas();
-        Assert.notEmpty(data,"没有datas 节点，或没有子节点需要处理");
-
-        //处理 businessStore 节点
-        if(data.containsKey(StorePo.class.getSimpleName())){
-            Object bObj = data.get(StorePo.class.getSimpleName());
-            JSONArray businessStores = null;
-            if(bObj instanceof JSONObject){
-                businessStores = new JSONArray();
-                businessStores.add(bObj);
-            }else {
-                businessStores = (JSONArray)bObj;
-            }
-            //JSONObject businessStore = data.getJSONObject(StorePo.class.getSimpleName());
-            for (int bStoreIndex = 0; bStoreIndex < businessStores.size();bStoreIndex++) {
-                JSONObject businessStore = businessStores.getJSONObject(bStoreIndex);
-                doBusinessStore(business, businessStore);
-                if(bObj instanceof JSONObject) {
-                    dataFlowContext.addParamOut("storeId", businessStore.getString("storeId"));
-                }
-            }
-        }
-    }
-
-    /**
-     * business 数据转移到 instance
-     * @param dataFlowContext 数据对象
-     * @param business 当前业务对象
-     */
-    @Override
-    protected void doBusinessToInstance(DataFlowContext dataFlowContext, Business business) {
-        JSONObject data = business.getDatas();
-
-        Map info = new HashMap();
-        info.put("bId",business.getbId());
-        info.put("operate",StatusConstant.OPERATE_ADD);
-
-        //商户信息
-        List<Map> businessStoreInfo = storeServiceDaoImpl.getBusinessStoreInfo(info);
-        if( businessStoreInfo != null && businessStoreInfo.size() >0) {
-            reFreshShareColumn(info, businessStoreInfo.get(0));
-            storeServiceDaoImpl.saveStoreInfoInstance(info);
-            if(businessStoreInfo.size() == 1) {
-                dataFlowContext.addParamOut("storeId", businessStoreInfo.get(0).get("store_id"));
-            }
-        }
-    }
-
-
-    /**
-     * 刷 分片字段
-     *
-     * @param info         查询对象
-     * @param businessInfo 小区ID
-     */
-    private void reFreshShareColumn(Map info, Map businessInfo) {
-
-        if (info.containsKey("shareId")) {
-            return;
-        }
-
-        if (!businessInfo.containsKey("stare_id")) {
-            return;
-        }
-
-        info.put("shareId", businessInfo.get("stare_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);
-        //商户信息
-        List<Map> storeInfo = storeServiceDaoImpl.getStoreInfo(info);
-        if(storeInfo != null && storeInfo.size() > 0){
-            reFreshShareColumn(paramIn, storeInfo.get(0));
-            storeServiceDaoImpl.updateStoreInfoInstance(paramIn);
-        }
-    }
-
-
-
-    /**
-     * 处理 businessStore 节点
-     * @param business 总的数据节点
-     * @param businessStore 商户节点
-     */
-    private void doBusinessStore(Business business,JSONObject businessStore){
-
-        Assert.jsonObjectHaveKey(businessStore,"storeId","businessStore 节点下没有包含 storeId 节点");
-
-        if(businessStore.getString("storeId").startsWith("-")){
-            //刷新缓存
-            //flushStoreId(business.getDatas());
-
-            businessStore.put("storeId",GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_storeId));
-
-        }
-
-        businessStore.put("bId",business.getbId());
-        businessStore.put("operate", StatusConstant.OPERATE_ADD);
-        //保存商户信息
-        storeServiceDaoImpl.saveBusinessStoreInfo(businessStore);
-
-    }
-    @Override
-    public IStoreServiceDao getStoreServiceDaoImpl() {
-        return storeServiceDaoImpl;
-    }
-
-    public void setStoreServiceDaoImpl(IStoreServiceDao storeServiceDaoImpl) {
-        this.storeServiceDaoImpl = storeServiceDaoImpl;
-    }
-}

java110-generator/src/main/resources/newTemplate/UpdateBMOImpl.java

@@ -0,0 +1,50 @@
+package com.java110.api.bmo.@@templateCode@@.impl;
+
+import com.alibaba.fastjson.JSONObject;
+import com.java110.api.bmo.ApiBaseBMO;
+import com.java110.api.bmo.@@templateCode@@.I@@TemplateCode@@BMO;
+import com.java110.core.annotation.Java110Transactional;
+import com.java110.core.factory.GenerateCodeFactory;
+import com.java110.intf.store.IWechatSmsTemplateInnerServiceSMO;
+import com.java110.po.wechatSmsTemplate.WechatSmsTemplatePo;
+import com.java110.vo.ResultVo;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Service;
+import com.java110.core.context.DataFlowContext;
+import com.java110.intf.@@templateCode@@.I@@TemplateCode@@InnerServiceSMO;
+import com.java110.dto.@@templateCode@@.@@TemplateCode@@Dto;
+import com.java110.utils.constant.BusinessTypeConstant;
+import com.java110.utils.constant.CommonConstant;
+import com.java110.utils.util.Assert;
+import com.java110.utils.util.BeanConvertUtil;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service("update@@TemplateCode@@BMOImpl")
+public class Update@@TemplateCode@@BMOImpl implements IUpdate@@TemplateCode@@BMO {
+
+    @Autowired
+    private I@@TemplateCode@@InnerServiceSMO @@templateCode@@InnerServiceSMOImpl;
+
+    /**
+     *
+     *
+     * @param @@templateCode@@Po
+     * @return 订单服务能够接受的报文
+     */
+    @Java110Transactional
+    public ResponseEntity<String> update(@@TemplateCode@@Po @@templateCode@@Po) {
+
+        int flag = @@templateCode@@InnerServiceSMOImpl.update@@TemplateCode@@(@@templateCode@@Po);
+
+        if (flag > 0) {
+        return ResultVo.createResponseEntity(ResultVo.CODE_OK, "保存成功");
+        }
+
+        return ResultVo.createResponseEntity(ResultVo.CODE_ERROR, "保存失败");
+    }
+
+}

java110-generator/src/main/resources/newTemplate/UpdateInfoListener.txt

@@ -1,188 +0,0 @@
-package com.java110.@@shareName@@.listener.@@templateCode@@;
-
-import com.alibaba.fastjson.JSONArray;
-import com.alibaba.fastjson.JSONObject;
-import com.java110.utils.constant.BusinessTypeConstant;
-import com.java110.utils.constant.ResponseConstant;
-import com.java110.utils.constant.StatusConstant;
-import com.java110.utils.exception.ListenerExecuteException;
-import com.java110.utils.util.Assert;
-import com.java110.core.annotation.Java110Listener;
-import com.java110.core.context.DataFlowContext;
-import com.java110.entity.center.Business;
-import com.java110.@@shareName@@.dao.IStoreServiceDao;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.transaction.annotation.Transactional;
-
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-
-/**
- * 修改商户信息 侦听
- *
- * 处理节点
- * 1、businessStore:{} 商户基本信息节点
- * 2、businessStoreAttr:[{}] 商户属性信息节点
- * 3、businessStorePhoto:[{}] 商户照片信息节点
- * 4、businessStoreCerdentials:[{}] 商户证件信息节点
- * 协议地址 ：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("updateStoreInfoListener")
-@Transactional
-public class UpdateStoreInfoListener extends AbstractStoreBusinessServiceDataFlowListener {
-
-    private static Logger logger = LoggerFactory.getLogger(UpdateStoreInfoListener.class);
-    @Autowired
-    private IStoreServiceDao storeServiceDaoImpl;
-
-    @Override
-    public int getOrder() {
-        return 2;
-    }
-
-    @Override
-    public String getBusinessTypeCd() {
-        return BusinessTypeConstant.BUSINESS_TYPE_UPDATE_STORE_INFO;
-    }
-
-    /**
-     * business过程
-     * @param dataFlowContext 上下文对象
-     * @param business 业务对象
-     */
-    @Override
-    protected void doSaveBusiness(DataFlowContext dataFlowContext, Business business) {
-
-        JSONObject data = business.getDatas();
-
-        Assert.notEmpty(data,"没有datas 节点，或没有子节点需要处理");
-
-
-            //处理 businessStore 节点
-            if(data.containsKey(StorePo.class.getSimpleName())){
-                Object _obj = data.get(StorePo.class.getSimpleName());
-                JSONArray businessStores = null;
-                if(_obj instanceof JSONObject){
-                    businessStores = new JSONArray();
-                    businessStores.add(_obj);
-                }else {
-                    businessStores = (JSONArray)_obj;
-                }
-                //JSONObject businessStore = data.getJSONObject(StorePo.class.getSimpleName());
-                for (int _storeIndex = 0; _storeIndex < businessStores.size();_storeIndex++) {
-                    JSONObject businessStore = businessStores.getJSONObject(_storeIndex);
-                    doBusinessStore(business, businessStore);
-                    if(_obj instanceof JSONObject) {
-                        dataFlowContext.addParamOut("storeId", businessStore.getString("storeId"));
-                    }
-                }
-            }
-    }
-
-
-    /**
-     * business to instance 过程
-     * @param dataFlowContext 数据对象
-     * @param business 当前业务对象
-     */
-    @Override
-    protected void doBusinessToInstance(DataFlowContext dataFlowContext, Business business) {
-
-        JSONObject data = business.getDatas();
-
-        Map info = new HashMap();
-        info.put("bId",business.getbId());
-        info.put("operate",StatusConstant.OPERATE_ADD);
-
-        //商户信息
-        List<Map> businessStoreInfos = storeServiceDaoImpl.getBusinessStoreInfo(info);
-        if( businessStoreInfos != null && businessStoreInfos.size() >0) {
-            for (int _storeIndex = 0; _storeIndex < businessStoreInfos.size();_storeIndex++) {
-                Map businessStoreInfo = businessStoreInfos.get(_storeIndex);
-                flushBusinessStoreInfo(businessStoreInfo,StatusConstant.STATUS_CD_VALID);
-                storeServiceDaoImpl.updateStoreInfoInstance(businessStoreInfo);
-                if(businessStoreInfo.size() == 1) {
-                    dataFlowContext.addParamOut("storeId", businessStoreInfo.get("store_id"));
-                }
-            }
-        }
-
-    }
-
-    /**
-     * 撤单
-     * @param dataFlowContext 数据对象
-     * @param business 当前业务对象
-     */
-    @Override
-    protected void doRecover(DataFlowContext dataFlowContext, Business business) {
-
-        String bId = business.getbId();
-        //Assert.hasLength(bId,"请求报文中没有包含 bId");
-        Map info = new HashMap();
-        info.put("bId",bId);
-        info.put("statusCd",StatusConstant.STATUS_CD_VALID);
-        Map delInfo = new HashMap();
-        delInfo.put("bId",business.getbId());
-        delInfo.put("operate",StatusConstant.OPERATE_DEL);
-        //商户信息
-        List<Map> storeInfo = storeServiceDaoImpl.getStoreInfo(info);
-        if(storeInfo != null && storeInfo.size() > 0){
-
-            //商户信息
-            List<Map> businessStoreInfos = storeServiceDaoImpl.getBusinessStoreInfo(delInfo);
-            //除非程序出错了，这里不会为空
-            if(businessStoreInfos == null || businessStoreInfos.size() == 0){
-                throw new ListenerExecuteException(ResponseConstant.RESULT_CODE_INNER_ERROR,"撤单失败（store），程序内部异常,请检查！ "+delInfo);
-            }
-            for (int _storeIndex = 0; _storeIndex < businessStoreInfos.size();_storeIndex++) {
-                Map businessStoreInfo = businessStoreInfos.get(_storeIndex);
-                flushBusinessStoreInfo(businessStoreInfo,StatusConstant.STATUS_CD_VALID);
-                storeServiceDaoImpl.updateStoreInfoInstance(businessStoreInfo);
-            }
-        }
-
-    }
-
-
-
-    /**
-     * 处理 businessStore 节点
-     * @param business 总的数据节点
-     * @param businessStore 商户节点
-     */
-    private void doBusinessStore(Business business,JSONObject businessStore){
-
-        Assert.jsonObjectHaveKey(businessStore,"storeId","businessStore 节点下没有包含 storeId 节点");
-
-        if(businessStore.getString("storeId").startsWith("-")){
-            throw new ListenerExecuteException(ResponseConstant.RESULT_PARAM_ERROR,"storeId 错误，不能自动生成（必须已经存在的storeId）"+businessStore);
-        }
-        //自动保存DEL
-        autoSaveDelBusinessStore(business,businessStore);
-
-        businessStore.put("bId",business.getbId());
-        businessStore.put("operate", StatusConstant.OPERATE_ADD);
-        //保存商户信息
-        storeServiceDaoImpl.saveBusinessStoreInfo(businessStore);
-
-    }
-
-
-
-    @Override
-    public IStoreServiceDao getStoreServiceDaoImpl() {
-        return storeServiceDaoImpl;
-    }
-
-    public void setStoreServiceDaoImpl(IStoreServiceDao storeServiceDaoImpl) {
-        this.storeServiceDaoImpl = storeServiceDaoImpl;
-    }
-
-
-
-}

java110-generator/src/main/resources/newTemplate/UpdateListener.java

@@ -1,48 +0,0 @@
-package com.java110.api.listener.@@templateCode@@;
-
-.I@@TemplateCode@@BMO;
-import com.java110.api.listener.AbstractServiceApiListener;
-import com.java110.utils.constant.CommonConstant;
-import com.java110.utils.constant.ServiceCode@@TemplateCode@@Constant;
-import com.java110.utils.util.Assert;
-import com.java110.core.annotation.Java110Listener;
-import com.java110.core.context.DataFlowContext;
-import com.java110.entity.center.AppService;
-import com.java110.event.service.api.ServiceDataFlowEvent;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.http.HttpHeaders;
-import org.springframework.http.HttpMethod;
-import org.springframework.http.ResponseEntity;
-
-/**
- * 保存@@templateName@@侦听
- * add by wuxw 2019-06-30
- */
-@Java110Listener("update@@TemplateCode@@Listener")
-public class Update@@TemplateCode@@Listener extends AbstractServiceApiPlusListener {
-
-    @Autowired
-    private I@@TemplateCode@@BMO @@templateCode@@BMOImpl;
-
-    @Override
-    protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) {
-
-        @@validateTemplateColumns@@
-    }
-
-    @Override
-    protected void doSoService(ServiceDataFlowEvent event, DataFlowContext context, JSONObject reqJson) {
-
-        @@templateCode@@BMOImpl.update@@TemplateCode@@(reqJson, context);
-    }
-
-    @Override
-    public String getServiceCode() {
-        return ServiceCode@@TemplateCode@@Constant.UPDATE_@@TEMPLATECODE@@;
-    }
-
-    @Override
-    public HttpMethod getHttpMethod() {
-        return HttpMethod.POST;
-    }
-}

java110-generator/src/main/resources/newTemplate/serviceDoc.txt

@@ -1,113 +0,0 @@
-
-
-**1\. 保存商户**
-###### 接口功能
-> API服务做保存商户时调用该接口
-
-###### URL
-> [http://store-service/storeApi/service](http://store-service/storeApi/service)
-
-###### 支持格式
-> JSON
-
-###### HTTP请求方式
-> POST
-
-###### 协议接口
-|父元素名称|参数名称|约束|类型|长度|描述|取值说明|
-| :-: | :-: | :-: | :-: | :-: | :-: | :-:|
-|-|orders|1|Object|-|订单节点|-|
-|-|business|1|Array|-|业务节点|-|
-
-###### orders
-|父元素名称|参数名称|约束|类型|长度|描述|取值说明|
-| :-: | :-: | :-: | :-: | :-: | :-: | :-: |
-|-|orders|1|Object|-|订单节点|-|
-|orders|appId|1|String|10|系统ID|由中心服务提供|
-|orders|transactionId|1|String|30|交互流水|appId+'00'+YYYYMMDD+10位序列|
-|orders|userId|1|String|30|用户ID|已有用户ID|
-|orders|orderTypeCd|1|String|4|订单类型|查看订单类型说明|
-|orders|requestTime|1|String|14|请求时间|YYYYMMDDhhmmss|
-|orders|remark|1|String|200|备注|备注|
-|orders|sign|?|String|64|签名|查看加密说明|
-|orders|attrs|?|Array|-|订单属性|-|
-|attrs|specCd|1|String|12|规格编码|由中心服务提供|
-|attrs|value|1|String|50|属性值|-|
-|orders|response|1|Object|-|返回结果节点|-|
-|response|code|1|String|4|返回状态|查看状态说明|
-|response|message|1|String|200|返回状态描述|-|
-
-###### business
-|父元素名称|参数名称|约束|类型|长度|描述|取值说明|
-| :-: | :-: | :-: | :-: | :-: | :-: | :-: |
-|-|business|?|Array|-|业务节点|-|
-|business|businessTypeCd|1|String|12|业务类型编码|500100030002|
-|business|datas|1|Object|-|数据节点|不同的服务下的节点不一样|
-|datas|businessStoreInfo|1|Object|-|小区成员|小区成员|
-$busienssInfo$
-
-###### 返回协议
-
-当http返回状态不为200 时请求处理失败 body内容为失败的原因
-
-当http返回状态为200时请求处理成功，body内容为返回内容，
-
-
-
-
-
-###### 举例
-> 地址：[http://store-service/storeApi/service](http://store-service/storeApi/service)
-
-``` javascript
-请求头信息：
-Content-Type:application/json
-
-请求报文：
-
-{
-  "orders": {
-    "appId": "外系统ID，分配得到",
-    "transactionId": "100000000020180409224736000001",
-    "userId": "用户ID",
-    "orderTypeCd": "订单类型,查询,受理",
-    "requestTime": "20180409224736",
-    "remark": "备注",
-    "sign": "这个服务是否要求MD5签名",
-    "businessType":"I",
-    "attrs": [{
-      "specCd": "配置的字段ID",
-      "value": "具体值"
-    }]
-  },
-  "business": {
-    "businessTypeCd": "$businessTypeCd$",
-    "bId":"1234567892",
-    "remark": "备注",
-    "datas": {
-      "businessStoreInfo": {
-        $businessInfoJson$
-      }
-    },
-    "attrs": [{
-      "specCd": "配置的字段ID",
-      "value": "具体值"
-    }]
-  }
-}
-
-返回报文：
- {
-	"orderTypeCd": "D",
-	"response": {
-		"code": "0000",
-		"message": "成功"
-	},
-	"responseTime": "20190418102004",
-	"bId": "202019041810750003",
-	"businessType": "B",
-	"transactionId": "3a5a411ec65a4c3f895935638aa1d2bc",
-	"dataFlowId": "44fde86d39ce46f4b4aab5f6b14f3947"
-}
-
-```