有道代码

service-api/src/main/java/com/java110/api/listener/resourceStoreType/DeleteResourceStoreTypeListener.java

@@ -1,45 +0,0 @@
-package com.java110.api.listener.resourceStoreType;
-
-import com.alibaba.fastjson.JSONObject;
-import com.java110.api.bmo.resourceStoreType.IResourceStoreTypeBMO;
-import com.java110.api.listener.AbstractServiceApiPlusListener;
-import com.java110.core.event.service.api.ServiceDataFlowEvent;
-import com.java110.utils.constant.ServiceCodeResourceStoreTypeConstant;
-import com.java110.utils.util.Assert;
-import com.java110.core.context.DataFlowContext;
-import com.java110.core.annotation.Java110Listener;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.http.HttpMethod;
-
-/**
- * 保存小区侦听
- * add by wuxw 2019-06-30
- */
-@Java110Listener("deleteResourceStoreTypeListener")
-public class DeleteResourceStoreTypeListener extends AbstractServiceApiPlusListener {
-
-    @Autowired
-    private IResourceStoreTypeBMO resourceStoreTypeBMOImpl;
-
-    @Override
-    protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) {
-        //Assert.hasKeyAndValue(reqJson, "xxx", "xxx");
-        Assert.hasKeyAndValue(reqJson, "rstId", "rstId不能为空");
-    }
-
-    @Override
-    protected void doSoService(ServiceDataFlowEvent event, DataFlowContext context, JSONObject reqJson) {
-        resourceStoreTypeBMOImpl.deleteResourceStoreType(reqJson, context);
-    }
-
-    @Override
-    public String getServiceCode() {
-        return ServiceCodeResourceStoreTypeConstant.DELETE_RESOURCESTORETYPE;
-    }
-
-    @Override
-    public HttpMethod getHttpMethod() {
-        return HttpMethod.POST;
-    }
-
-}

service-api/src/main/java/com/java110/api/listener/resourceStoreType/SaveResourceStoreTypeListener.java

@@ -1,66 +0,0 @@
-package com.java110.api.listener.resourceStoreType;
-
-import com.alibaba.fastjson.JSONObject;
-import com.java110.api.bmo.resourceStoreType.IResourceStoreTypeBMO;
-import com.java110.api.listener.AbstractServiceApiPlusListener;
-import com.java110.core.annotation.Java110Listener;
-import com.java110.core.context.DataFlowContext;
-import com.java110.core.event.service.api.ServiceDataFlowEvent;
-import com.java110.dto.resourceStoreType.ResourceStoreTypeDto;
-import com.java110.intf.store.IResourceStoreTypeV1InnerServiceSMO;
-import com.java110.utils.constant.ServiceCodeResourceStoreTypeConstant;
-import com.java110.utils.util.Assert;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.http.HttpMethod;
-
-/**
- * 保存商户侦听
- * add by wuxw 2019-06-30
- */
-@Java110Listener("saveResourceStoreTypeListener")
-public class SaveResourceStoreTypeListener extends AbstractServiceApiPlusListener {
-
-    @Autowired
-    private IResourceStoreTypeBMO resourceStoreTypeBMOImpl;
-
-    @Autowired
-    private IResourceStoreTypeV1InnerServiceSMO resourceStoreTypeV1InnerServiceSMOImpl;
-
-    @Override
-    protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) {
-        //Assert.hasKeyAndValue(reqJson, "xxx", "xxx");
-        Assert.hasKeyAndValue(reqJson, "name", "请求报文中未包含name");
-        //Assert.hasKeyAndValue(reqJson, "storeId", "请求报文中未包含storeId");
-
-        if (!reqJson.containsKey("storeId")) {
-            String storeId = event.getDataFlowContext().getRequestCurrentHeaders().get("store-id");
-            reqJson.put("storeId", storeId);
-        }
-        Assert.hasKeyAndValue(reqJson, "storeId", "请求报文中未包含storeId");
-        ResourceStoreTypeDto resourceStoreTypeDto = new ResourceStoreTypeDto();
-        resourceStoreTypeDto.setStoreId(reqJson.getString("storeId"));
-        resourceStoreTypeDto.setName(reqJson.getString("name"));
-        int flag = resourceStoreTypeV1InnerServiceSMOImpl.queryResourceStoreTypesCount(resourceStoreTypeDto);
-
-        if(flag > 0){
-            throw new IllegalArgumentException("类型名称已存在");
-        }
-
-    }
-
-    @Override
-    protected void doSoService(ServiceDataFlowEvent event, DataFlowContext context, JSONObject reqJson) {
-        resourceStoreTypeBMOImpl.addResourceStoreType(reqJson, context);
-    }
-
-    @Override
-    public String getServiceCode() {
-        return ServiceCodeResourceStoreTypeConstant.ADD_RESOURCESTORETYPE;
-    }
-
-    @Override
-    public HttpMethod getHttpMethod() {
-        return HttpMethod.POST;
-    }
-
-}

service-api/src/main/java/com/java110/api/listener/resourceStoreType/UpdateResourceStoreTypeListener.java

@@ -1,49 +0,0 @@
-package com.java110.api.listener.resourceStoreType;
-
-import com.alibaba.fastjson.JSONObject;
-import com.java110.api.bmo.resourceStoreType.IResourceStoreTypeBMO;
-import com.java110.api.listener.AbstractServiceApiPlusListener;
-import com.java110.core.event.service.api.ServiceDataFlowEvent;
-import com.java110.utils.constant.ServiceCodeResourceStoreTypeConstant;
-import com.java110.utils.util.Assert;
-import com.java110.core.annotation.Java110Listener;
-import com.java110.core.context.DataFlowContext;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.http.HttpMethod;
-
-/**
- * 保存物品类型侦听
- * add by wuxw 2019-06-30
- */
-@Java110Listener("updateResourceStoreTypeListener")
-public class UpdateResourceStoreTypeListener extends AbstractServiceApiPlusListener {
-
-    @Autowired
-    private IResourceStoreTypeBMO resourceStoreTypeBMOImpl;
-
-    @Override
-    protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) {
-        Assert.hasKeyAndValue(reqJson, "rstId", "请求报文中未包含rstId");
-        Assert.hasKeyAndValue(reqJson, "name", "请求报文中未包含name");
-        if (!reqJson.containsKey("storeId")) {
-            String storeId = event.getDataFlowContext().getRequestCurrentHeaders().get("store-id");
-            reqJson.put("storeId", storeId);
-        }
-        Assert.hasKeyAndValue(reqJson, "storeId", "请求报文中未包含storeId");
-    }
-
-    @Override
-    protected void doSoService(ServiceDataFlowEvent event, DataFlowContext context, JSONObject reqJson) {
-        resourceStoreTypeBMOImpl.updateResourceStoreType(reqJson, context);
-    }
-
-    @Override
-    public String getServiceCode() {
-        return ServiceCodeResourceStoreTypeConstant.UPDATE_RESOURCESTORETYPE;
-    }
-
-    @Override
-    public HttpMethod getHttpMethod() {
-        return HttpMethod.POST;
-    }
-}

service-store/src/main/java/com/java110/store/cmd/resourceStoreType/DeleteResourceStoreTypeCmd.java

@@ -0,0 +1,49 @@
+package com.java110.store.cmd.resourceStoreType;
+
+import com.alibaba.fastjson.JSONObject;
+import com.java110.core.annotation.Java110Cmd;
+import com.java110.core.context.ICmdDataFlowContext;
+import com.java110.core.event.cmd.Cmd;
+import com.java110.core.event.cmd.CmdEvent;
+import com.java110.intf.community.IResourceStoreServiceSMO;
+import com.java110.intf.store.IResourceStoreTypeV1InnerServiceSMO;
+import com.java110.po.purchase.ResourceStorePo;
+import com.java110.po.resourceStoreType.ResourceStoreTypePo;
+import com.java110.utils.exception.CmdException;
+import com.java110.utils.util.Assert;
+import com.java110.utils.util.BeanConvertUtil;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import java.text.ParseException;
+import java.util.List;
+
+@Java110Cmd(serviceCode = "resourceStoreType.deleteResourceStoreType")
+public class DeleteResourceStoreTypeCmd extends Cmd {
+
+    @Autowired
+    private IResourceStoreServiceSMO resourceStoreServiceSMOImpl;
+
+    @Autowired
+    private IResourceStoreTypeV1InnerServiceSMO resourceStoreTypeV1InnerServiceSMOImpl;
+
+    @Override
+    public void validate(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException {
+        Assert.hasKeyAndValue(reqJson, "rstId", "rstId不能为空");
+    }
+
+    @Override
+    public void doCmd(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException, ParseException {
+        ResourceStorePo resourceStorePo = new ResourceStorePo();
+        resourceStorePo.setRstId(reqJson.getString("rstId"));
+        //根据类型id物品信息表
+        List<ResourceStorePo> resourceStores = resourceStoreServiceSMOImpl.getResourceStores(resourceStorePo);
+        Assert.listIsNull(resourceStores, "物品信息中该类型正在使用，不能删除！");
+        ResourceStoreTypePo resourceStoreTypePo = BeanConvertUtil.covertBean(reqJson, ResourceStoreTypePo.class);
+
+        int flag = resourceStoreTypeV1InnerServiceSMOImpl.deleteResourceStoreType(resourceStoreTypePo);
+
+        if (flag < 1) {
+            throw new CmdException("删除失败");
+        }
+    }
+}

service-store/src/main/java/com/java110/store/cmd/resourceStoreType/SaveResourceStoreTypeCmd.java

@@ -0,0 +1,59 @@
+package com.java110.store.cmd.resourceStoreType;
+
+import com.alibaba.fastjson.JSONObject;
+import com.java110.core.annotation.Java110Cmd;
+import com.java110.core.context.ICmdDataFlowContext;
+import com.java110.core.event.cmd.Cmd;
+import com.java110.core.event.cmd.CmdEvent;
+import com.java110.core.factory.GenerateCodeFactory;
+import com.java110.dto.resourceStoreType.ResourceStoreTypeDto;
+import com.java110.intf.store.IResourceStoreTypeV1InnerServiceSMO;
+import com.java110.po.resourceStoreType.ResourceStoreTypePo;
+import com.java110.utils.exception.CmdException;
+import com.java110.utils.util.Assert;
+import com.java110.utils.util.BeanConvertUtil;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import java.text.ParseException;
+import java.util.Date;
+
+@Java110Cmd(serviceCode = "resourceStoreType.saveResourceStoreType")
+public class SaveResourceStoreTypeCmd extends Cmd {
+
+    @Autowired
+    private IResourceStoreTypeV1InnerServiceSMO resourceStoreTypeV1InnerServiceSMOImpl;
+
+    @Override
+    public void validate(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException {
+//Assert.hasKeyAndValue(reqJson, "xxx", "xxx");
+        Assert.hasKeyAndValue(reqJson, "name", "请求报文中未包含name");
+        //Assert.hasKeyAndValue(reqJson, "storeId", "请求报文中未包含storeId");
+
+        if (!reqJson.containsKey("storeId")) {
+            String storeId = context.getReqHeaders().get("store-id");
+            reqJson.put("storeId", storeId);
+        }
+        Assert.hasKeyAndValue(reqJson, "storeId", "请求报文中未包含storeId");
+        ResourceStoreTypeDto resourceStoreTypeDto = new ResourceStoreTypeDto();
+        resourceStoreTypeDto.setStoreId(reqJson.getString("storeId"));
+        resourceStoreTypeDto.setName(reqJson.getString("name"));
+        int flag = resourceStoreTypeV1InnerServiceSMOImpl.queryResourceStoreTypesCount(resourceStoreTypeDto);
+
+        if (flag > 0) {
+            throw new IllegalArgumentException("类型名称已存在");
+        }
+    }
+
+    @Override
+    public void doCmd(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException, ParseException {
+        reqJson.put("rstId", GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_rstId));
+        reqJson.put("createTime", new Date());
+        ResourceStoreTypePo resourceStoreTypePo = BeanConvertUtil.covertBean(reqJson, ResourceStoreTypePo.class);
+        int flag = resourceStoreTypeV1InnerServiceSMOImpl.saveResourceStoreType(resourceStoreTypePo);
+
+        if (flag < 1) {
+            throw new IllegalArgumentException("保存类型失败");
+        }
+
+    }
+}

service-store/src/main/java/com/java110/store/cmd/resourceStoreType/UpdateResourceStoreTypeCmd.java

@@ -0,0 +1,42 @@
+package com.java110.store.cmd.resourceStoreType;
+
+import com.alibaba.fastjson.JSONObject;
+import com.java110.core.annotation.Java110Cmd;
+import com.java110.core.context.ICmdDataFlowContext;
+import com.java110.core.event.cmd.Cmd;
+import com.java110.core.event.cmd.CmdEvent;
+import com.java110.intf.store.IResourceStoreTypeV1InnerServiceSMO;
+import com.java110.po.resourceStoreType.ResourceStoreTypePo;
+import com.java110.utils.exception.CmdException;
+import com.java110.utils.util.Assert;
+import com.java110.utils.util.BeanConvertUtil;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import java.text.ParseException;
+
+@Java110Cmd(serviceCode = "resourceStoreType.updateResourceStoreType")
+public class UpdateResourceStoreTypeCmd extends Cmd {
+
+    @Autowired
+    private IResourceStoreTypeV1InnerServiceSMO resourceStoreTypeV1InnerServiceSMOImpl;
+
+    @Override
+    public void validate(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException {
+        Assert.hasKeyAndValue(reqJson, "rstId", "请求报文中未包含rstId");
+        Assert.hasKeyAndValue(reqJson, "name", "请求报文中未包含name");
+        if (!reqJson.containsKey("storeId")) {
+            String storeId = context.getReqHeaders().get("store-id");
+            reqJson.put("storeId", storeId);
+        }
+        Assert.hasKeyAndValue(reqJson, "storeId", "请求报文中未包含storeId");
+    }
+
+    @Override
+    public void doCmd(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException, ParseException {
+        ResourceStoreTypePo resourceStoreTypePo = BeanConvertUtil.covertBean(reqJson, ResourceStoreTypePo.class);
+        int flag = resourceStoreTypeV1InnerServiceSMOImpl.saveResourceStoreType(resourceStoreTypePo);
+        if (flag < 1) {
+            throw new IllegalArgumentException("保存类型失败");
+        }
+    }
+}