加入模板添加功能

Api/src/main/java/com/java110/api/listener/community/SaveCommunityListener.java

@@ -0,0 +1,91 @@
+package com.java110.api.listener.community;
+
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.java110.api.listener.AbstractServiceApiListener;
+import com.java110.common.constant.*;
+import com.java110.common.exception.ListenerExecuteException;
+import com.java110.common.util.Assert;
+import com.java110.core.context.DataFlowContext;
+import com.java110.dto.FeeConfigDto;
+import com.java110.dto.FeeDto;
+import com.java110.dto.RoomDto;
+import com.java110.entity.center.AppService;
+import com.java110.event.service.api.ServiceDataFlowEvent;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpMethod;
+import org.springframework.http.ResponseEntity;
+
+import java.util.List;
+
+/**
+ * 保存小区侦听
+ * add by wuxw 2019-06-30
+ */
+public class SaveCommunityListener extends AbstractServiceApiListener {
+    @Override
+    protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) {
+        Assert.hasKeyAndValue(reqJson, "xxx", "xxx");
+    }
+
+    @Override
+    protected void doSoService(ServiceDataFlowEvent event, DataFlowContext context, JSONObject reqJson) {
+
+        HttpHeaders header = new HttpHeaders();
+        context.getRequestCurrentHeaders().put(CommonConstant.HTTP_ORDER_TYPE_CD, "D");
+        JSONArray businesses = new JSONArray();
+
+        AppService service = event.getAppService();
+
+        //添加单元信息
+        businesses.add(addCommunity(reqJson, context));
+
+        JSONObject paramInObj = super.restToCenterProtocol(businesses, context.getRequestCurrentHeaders());
+
+        //将 rest header 信息传递到下层服务中去
+        super.freshHttpHeader(header, context.getRequestCurrentHeaders());
+
+        ResponseEntity<String> responseEntity = this.callService(context, service.getServiceCode(), paramInObj);
+
+        context.setResponseEntity(responseEntity);
+    }
+
+    @Override
+    public String getServiceCode() {
+        return ServiceCodeConstant.SERVICE_CODE_SAVE_COMMUNITY;
+    }
+
+    @Override
+    public HttpMethod getHttpMethod() {
+        return HttpMethod.POST;
+    }
+
+    @Override
+    public int getOrder() {
+        return DEFAULT_ORDER;
+    }
+
+
+    /**
+     * 添加小区信息
+     *
+     * @param paramInJson     接口调用放传入入参
+     * @param dataFlowContext 数据上下文
+     * @return 订单服务能够接受的报文
+     */
+    private JSONObject addCommunity(JSONObject paramInJson, DataFlowContext dataFlowContext) {
+
+
+        JSONObject business = JSONObject.parseObject("{\"datas\":{}}");
+        business.put(CommonConstant.HTTP_BUSINESS_TYPE_CD, BusinessTypeConstant.BUSINESS_TYPE_SAVE_COMMUNITY_INFO);
+        business.put(CommonConstant.HTTP_SEQ, DEFAULT_SEQ);
+        business.put(CommonConstant.HTTP_INVOKE_MODEL, CommonConstant.HTTP_INVOKE_MODEL_S);
+        JSONObject businessCommunity = new JSONObject();
+        businessCommunity.putAll(paramInJson);
+        businessCommunity.put("communityId", "-1");
+        //计算 应收金额
+        business.getJSONObject(CommonConstant.HTTP_BUSINESS_DATAS).put("businessFeeDetail", businessCommunity);
+        return business;
+    }
+
+}

WebService/src/main/java/com/java110/web/components/community/AddCommunityComponent.java

@@ -0,0 +1,34 @@
+package com.java110.web.components.community;
+
+import com.java110.core.context.IPageData;
+import com.java110.web.smo.community.IAddCommunitySMO;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Component;
+
+/**
+ * 添加小区组件
+ */
+@Component("addCommunity")
+public class AddCommunityComponent {
+
+    @Autowired
+    private IAddCommunitySMO addCommunitySMOImpl;
+
+    /**
+     * 添加小区数据
+     * @param pd 页面数据封装
+     * @return ResponseEntity 对象
+     */
+    public ResponseEntity<String> save(IPageData pd){
+        return addCommunitySMOImpl.saveCommunity(pd);
+    }
+
+    public IAddCommunitySMO getAddCommunitySMOImpl() {
+        return addCommunitySMOImpl;
+    }
+
+    public void setAddCommunitySMOImpl(IAddCommunitySMO addCommunitySMOImpl) {
+        this.addCommunitySMOImpl = addCommunitySMOImpl;
+    }
+}

WebService/src/main/java/com/java110/web/smo/community/IAddCommunitySMO.java

@@ -0,0 +1,19 @@
+package com.java110.web.smo.community;
+
+import com.java110.core.context.IPageData;
+import org.springframework.http.ResponseEntity;
+
+/**
+ * 添加小区接口
+ *
+ * add by wuxw 2019-06-30
+ */
+public interface IAddCommunitySMO {
+
+    /**
+     * 添加小区
+     * @param pd 页面数据封装
+     * @return ResponseEntity 对象
+     */
+    ResponseEntity<String> saveCommunity(IPageData pd);
+}

WebService/src/main/java/com/java110/web/smo/community/impl/AddCommunitySMOImpl.java

@@ -0,0 +1,61 @@
+package com.java110.web.smo.community.impl;
+
+import com.alibaba.fastjson.JSONObject;
+import com.java110.common.constant.PrivilegeCodeConstant;
+import com.java110.common.constant.ServiceConstant;
+import com.java110.common.util.Assert;
+import com.java110.core.client.RestTemplate;
+import com.java110.core.context.IPageData;
+import com.java110.web.core.AbstractComponentSMO;
+import com.java110.web.smo.community.IAddCommunitySMO;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpMethod;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Service;
+
+/**
+ * 添加小区服务实现类
+ * add by wuxw 2019-06-30
+ */
+@Service("addCommunitySMOImpl")
+public class AddCommunitySMOImpl extends AbstractComponentSMO implements IAddCommunitySMO {
+
+    @Autowired
+    private RestTemplate restTemplate;
+
+    @Override
+    protected void validate(IPageData pd, JSONObject paramIn) {
+
+        //super.validatePageInfo(pd);
+
+        Assert.hasKeyAndValue(paramIn, "xxx", "xxx");
+
+
+        super.checkUserHasPrivilege(pd, restTemplate, PrivilegeCodeConstant.AGENT_HAS_LIST_COMMUNITY);
+
+    }
+
+    @Override
+    protected ResponseEntity<String> doBusinessProcess(IPageData pd, JSONObject paramIn) {
+        ResponseEntity<String> responseEntity = null;
+        super.validateStoreStaffCommunityRelationship(pd, restTemplate);
+
+        responseEntity = this.callCenterService(restTemplate, pd, paramIn.toJSONString(),
+                ServiceConstant.SERVICE_API_URL + "/api/community.saveCommunity",
+                HttpMethod.POST);
+        return responseEntity;
+    }
+
+    @Override
+    public ResponseEntity<String> saveCommunity(IPageData pd) {
+        return super.businessProcess(pd);
+    }
+
+    public RestTemplate getRestTemplate() {
+        return restTemplate;
+    }
+
+    public void setRestTemplate(RestTemplate restTemplate) {
+        this.restTemplate = restTemplate;
+    }
+}

java110-code-generator/src/main/resources/web/add/AddComponent.java

@@ -0,0 +1,35 @@
+package com.java110.web.components.@@templateCode@@;
+
+import com.java110.core.context.IPageData;
+import com.java110.web.smo.I@@TemplateCode@@ServiceSMO;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Component;
+
+/**
+ * 添加@@templateName@@组件
+ */
+@Component("add@@TemplateCode@@")
+public class Add@@TemplateCode@@Component {
+
+    @Autowired
+    private I@@TemplateCode@@ServiceSMO @@templateCode@@ServiceSMOImpl;
+
+    /**
+     * 查询@@templateName@@信息
+     * @param pd 页面封装对象 包含页面请求数据
+     * @return ResponseEntity对象返回给页面
+     */
+    public ResponseEntity<String> save(IPageData pd) {
+
+        return @@templateCode@@ServiceSMOImpl.save@@TemplateCode@@(pd);
+    }
+
+    public I@@TemplateCode@@ServiceSMO get@@TemplateCode@@ServiceSMOImpl() {
+        return @@templateCode@@ServiceSMOImpl;
+    }
+
+    public void set@@TemplateCode@@ServiceSMOImpl(I@@TemplateCode@@ServiceSMO @@templateCode@@ServiceSMOImpl) {
+        this.@@templateCode@@ServiceSMOImpl = @@templateCode@@ServiceSMOImpl;
+    }
+}

java110-code-generator/src/main/resources/web/add/AddSMOImpl.java

@@ -0,0 +1,62 @@
+package com.java110.web.smo.@@templateCode@@.impl;
+
+import com.alibaba.fastjson.JSONObject;
+import com.java110.common.constant.PrivilegeCodeConstant;
+import com.java110.common.constant.ServiceConstant;
+import com.java110.common.util.Assert;
+import com.java110.core.client.RestTemplate;
+import com.java110.core.context.IPageData;
+import com.java110.web.core.AbstractComponentSMO;
+import com.java110.web.smo.@@templateCode@@
+import org.springframework.stereotype.Service;.IAdd@@TemplateCode@@SMO;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpMethod;
+import org.springframework.http.ResponseEntity;
+
+/**
+ * 添加小区服务实现类
+ * add by wuxw 2019-06-30
+ */
+@Service("add@@TemplateCode@@SMOImpl")
+public class Add@@TemplateCode@@SMOImpl extends AbstractComponentSMO implements IAdd@@TemplateCode@@SMO {
+
+    @Autowired
+    private RestTemplate restTemplate;
+
+    @Override
+    protected void validate(IPageData pd, JSONObject paramIn) {
+
+        //super.validatePageInfo(pd);
+
+        //Assert.hasKeyAndValue(paramIn, "xxx", "xxx");
+        @@validateTemplateColumns@@
+
+
+        super.checkUserHasPrivilege(pd, restTemplate, PrivilegeCodeConstant.AGENT_HAS_LIST_@@TEMPLATECODE@@);
+
+    }
+
+    @Override
+    protected ResponseEntity<String> doBusinessProcess(IPageData pd, JSONObject paramIn) {
+        ResponseEntity<String> responseEntity = null;
+        super.validateStoreStaffCommunityRelationship(pd, restTemplate);
+
+        responseEntity = this.callCenterService(restTemplate, pd, paramIn.toJSONString(),
+                ServiceConstant.SERVICE_API_URL + "/api/@@templateCode@@.save@@TemplateCode@@",
+                HttpMethod.POST);
+        return responseEntity;
+    }
+
+    @Override
+    public ResponseEntity<String> save@@TemplateCode@@(IPageData pd) {
+        return super.businessProcess(pd);
+    }
+
+    public RestTemplate getRestTemplate() {
+        return restTemplate;
+    }
+
+    public void setRestTemplate(RestTemplate restTemplate) {
+        this.restTemplate = restTemplate;
+    }
+}

java110-code-generator/src/main/resources/web/add/IAddSMO.java

@@ -0,0 +1,19 @@
+package com.java110.web.smo.community;
+
+import com.java110.core.context.IPageData;
+import org.springframework.http.ResponseEntity;
+
+/**
+ * 添加@@templateName@@接口
+ *
+ * add by wuxw 2019-06-30
+ */
+public interface IAdd@@TemplateCode@@SMO {
+
+    /**
+     * 添加@@templateName@@
+     * @param pd 页面数据封装
+     * @return ResponseEntity 对象
+     */
+    ResponseEntity<String> save@@TemplateCode@@(IPageData pd);
+}

java110-code-generator/src/main/resources/web/add/SaveListener.java

@@ -0,0 +1,86 @@
+package com.java110.api.listener.@@templateCode@@;
+
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.java110.api.listener.AbstractServiceApiListener;
+import com.java110.common.util.Assert;
+import com.java110.core.context.DataFlowContext;
+import com.java110.entity.center.AppService;
+import com.java110.event.service.api.ServiceDataFlowEvent;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpMethod;
+import org.springframework.http.ResponseEntity;
+
+/**
+ * 保存小区侦听
+ * add by wuxw 2019-06-30
+ */
+public class SaveListener extends AbstractServiceApiListener {
+    @Override
+    protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) {
+        //Assert.hasKeyAndValue(reqJson, "xxx", "xxx");
+
+        @@validateTemplateColumns@@
+    }
+
+    @Override
+    protected void doSoService(ServiceDataFlowEvent event, DataFlowContext context, JSONObject reqJson) {
+
+        HttpHeaders header = new HttpHeaders();
+        context.getRequestCurrentHeaders().put(CommonConstant.HTTP_ORDER_TYPE_CD, "D");
+        JSONArray businesses = new JSONArray();
+
+        AppService service = event.getAppService();
+
+        //添加单元信息
+        businesses.add(add@@TemplateCode@@(reqJson, context));
+
+        JSONObject paramInObj = super.restToCenterProtocol(businesses, context.getRequestCurrentHeaders());
+
+        //将 rest header 信息传递到下层服务中去
+        super.freshHttpHeader(header, context.getRequestCurrentHeaders());
+
+        ResponseEntity<String> responseEntity = this.callService(context, service.getServiceCode(), paramInObj);
+
+        context.setResponseEntity(responseEntity);
+    }
+
+    @Override
+    public String getServiceCode() {
+        return ServiceCodeConstant.SERVICE_CODE_SAVE_@@TEMPLATECODE@@;
+    }
+
+    @Override
+    public HttpMethod getHttpMethod() {
+        return HttpMethod.POST;
+    }
+
+    @Override
+    public int getOrder() {
+        return DEFAULT_ORDER;
+    }
+
+
+    /**
+     * 添加小区信息
+     *
+     * @param paramInJson     接口调用放传入入参
+     * @param dataFlowContext 数据上下文
+     * @return 订单服务能够接受的报文
+     */
+    private JSONObject add@@TemplateCode@@(JSONObject paramInJson, DataFlowContext dataFlowContext) {
+
+
+        JSONObject business = JSONObject.parseObject("{\"datas\":{}}");
+        business.put(CommonConstant.HTTP_BUSINESS_TYPE_CD, BusinessTypeConstant.BUSINESS_TYPE_SAVE_@@TEMPLATECODE@@_INFO);
+        business.put(CommonConstant.HTTP_SEQ, DEFAULT_SEQ);
+        business.put(CommonConstant.HTTP_INVOKE_MODEL, CommonConstant.HTTP_INVOKE_MODEL_S);
+        JSONObject business@@TemplateCode@@ = new JSONObject();
+        business@@TemplateCode@@.putAll(paramInJson);
+        business@@TemplateCode@@.put("@@templateKey@@", "-1");
+        //计算 应收金额
+        business.getJSONObject(CommonConstant.HTTP_BUSINESS_DATAS).put("business@@TemplateCode@@", business@@TemplateCode@@);
+        return business;
+    }
+
+}

java110-code-generator/src/main/resources/web/add/add.html

@@ -0,0 +1,33 @@
+<div id = "add@@TemplateCode@@Model" class="modal fade" tabindex="-1" role="dialog" aria-labelledby="exampleModalLabel" aria-hidden="true" >
+    <div class="modal-dialog modal-lg">
+        <div class="modal-content">
+            <div class="modal-body">
+                <h3 class="m-t-none m-b ">添加@@templateName@@</h3>
+                <div class="ibox-content">
+                    <div>
+                        <div>
+                            <!--<div class="form-group row">
+                                <label class="col-sm-2 col-form-label">楼名称</label>
+                                <div class="col-sm-10"><input v-model="addFloorInfo.name" type="text" placeholder="必填，请填写名称" class="form-control"></div>
+                            </div>
+                            <div class="form-group row">
+                                <label class="col-sm-2 col-form-label">楼编号</label>
+                                <div class="col-sm-10"><input v-model="addFloorInfo.floorNum" type="email" placeholder="必填，请填写编号" class="form-control"></div>
+                            </div>
+                            <div class="form-group row">
+                                <label class="col-sm-2 col-form-label">备注</label>
+                                <div class="col-sm-10"><input v-model="addFloorInfo.remark" type="tel" placeholder="可填，请填写备注" class="form-control"></div>
+                            </div>-->
+
+                            @@addTemplateColumns@@
+                            <div class="ibox-content">
+                                <button class="btn btn-primary float-right" type="button" v-on:click="save@@TemplateCode@@Info()" ><i class="fa fa-check"></i>&nbsp;保存</button>
+                                <button type="button" class="btn btn-warning float-right" style="margin-right:20px;" data-dismiss="modal">取消</button>
+                            </div>
+                        </div>
+                    </div>
+                </div>
+            </div>
+        </div>
+    </div>
+</div>

java110-code-generator/src/main/resources/web/add/add.js

@@ -0,0 +1,81 @@
+(function(vc){
+
+    vc.extends({
+        data:{
+            add@@TemplateCode@@Info:{
+                @@templateCodeColumns@@
+            }
+        },
+         _initMethod:function(){
+
+         },
+         _initEvent:function(){
+            vc.on('add@@TemplateCode@@','openAdd@@TemplateCode@@Modal',function(){
+                $('#add@@TemplateCode@@Model').modal('show');
+            });
+        },
+        methods:{
+            add@@TemplateCode@@Validate(){
+                return vc.validate.validate({
+                    add@@TemplateCode@@Info:vc.component.add@@TemplateCode@@Info
+                },{
+                    'add@@TemplateCode@@Info.name':[
+                        {
+                            limit:"required",
+                            param:"",
+                            errInfo:"楼名称不能为空"
+                        },
+                        {
+                            limit:"maxin",
+                            param:"2,10",
+                            errInfo:"楼名称长度必须在2位至10位"
+                        },
+                    ]
+
+                });
+            },
+            save@@TemplateCode@@Info:function(){
+                if(!vc.component.add@@TemplateCode@@Validate()){
+                    vc.message(vc.validate.errInfo);
+
+                    return ;
+                }
+
+                vc.component.add@@TemplateCode@@Info.communityId = vc.getCurrentCommunity().communityId;
+
+                vc.http.post(
+                    'add@@TemplateCode@@',
+                    'save',
+                    JSON.stringify(vc.component.add@@TemplateCode@@Info),
+                    {
+                        emulateJSON:true
+                     },
+                     function(json,res){
+                        //vm.menus = vm.refreshMenuActive(JSON.parse(json),0);
+                        if(res.status == 200){
+                            //关闭model
+                            $('#add@@TemplateCode@@Model').modal('hide');
+                            vc.component.clearAdd@@TemplateCode@@Info();
+                            vc.emit('@@templateCode@@Manage','list@@TemplateCode@@',{});
+
+                            return ;
+                        }
+                        vc.message(json);
+
+                     },
+                     function(errInfo,error){
+                        console.log('请求失败处理');
+
+                        vc.message(errInfo);
+
+                     });
+            },
+            clearAdd@@TemplateCode@@Info:function(){
+                vc.component.add@@TemplateCode@@Info = {
+                                            @@templateCodeColumns@@
+                                        };
+            }
+        }
+    });
+
+})(window.vc);

java110-common/src/main/java/com/java110/common/constant/ServiceCodeConstant.java

@@ -486,4 +486,9 @@ public class ServiceCodeConstant {
      */
     public static final String SERVICE_CODE_LIST_COMMUNITYS = "community.listCommunitys";
 
+    /**
+     * 保存小区
+     */
+    public static final String SERVICE_CODE_SAVE_COMMUNITY = "community.saveCommunity";
+
 }