优化store 启动问题

java110-db/src/main/resources/mapper/user/JunkRequirementV1ServiceDaoImplMapper.xml

@@ -0,0 +1,151 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper
+        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="junkRequirementV1ServiceDaoImpl">
+
+
+
+
+
+    <!-- 保存需求信息 add by wuxw 2018-07-03 -->
+    <insert id="saveJunkRequirementInfo" parameterType="Map">
+        insert into junk_requirement(
+reference_price,type_cd,publish_user_name,publish_user_link,context,publish_user_id,junk_requirement_id,state,classification,community_id
+) values (
+#{referencePrice},#{typeCd},#{publishUserName},#{publishUserLink},#{context},#{publishUserId},#{junkRequirementId},#{state},#{classification},#{communityId}
+)
+    </insert>
+
+
+
+    <!-- 查询需求信息 add by wuxw 2018-07-03 -->
+    <select id="getJunkRequirementInfo" parameterType="Map" resultType="Map">
+        select  t.reference_price,t.reference_price referencePrice,t.type_cd,t.type_cd typeCd,t.publish_user_name,t.publish_user_name publishUserName,t.publish_user_link,t.publish_user_link publishUserLink,t.context,t.publish_user_id,t.publish_user_id publishUserId,t.status_cd,t.status_cd statusCd,t.junk_requirement_id,t.junk_requirement_id junkRequirementId,t.state,t.classification,t.community_id,t.community_id communityId 
+from junk_requirement t 
+where 1 =1 
+<if test="referencePrice !=null and referencePrice != ''">
+   and t.reference_price= #{referencePrice}
+</if> 
+<if test="typeCd !=null and typeCd != ''">
+   and t.type_cd= #{typeCd}
+</if> 
+<if test="publishUserName !=null and publishUserName != ''">
+   and t.publish_user_name= #{publishUserName}
+</if> 
+<if test="publishUserLink !=null and publishUserLink != ''">
+   and t.publish_user_link= #{publishUserLink}
+</if> 
+<if test="context !=null and context != ''">
+   and t.context= #{context}
+</if> 
+<if test="publishUserId !=null and publishUserId != ''">
+   and t.publish_user_id= #{publishUserId}
+</if> 
+<if test="statusCd !=null and statusCd != ''">
+   and t.status_cd= #{statusCd}
+</if> 
+<if test="junkRequirementId !=null and junkRequirementId != ''">
+   and t.junk_requirement_id= #{junkRequirementId}
+</if> 
+<if test="state !=null and state != ''">
+   and t.state= #{state}
+</if> 
+<if test="classification !=null and classification != ''">
+   and t.classification= #{classification}
+</if> 
+<if test="communityId !=null and communityId != ''">
+   and t.community_id= #{communityId}
+</if> 
+order by t.create_time desc
+<if test="page != -1 and page != null ">
+   limit #{page}, #{row}
+</if> 
+
+    </select>
+
+
+
+
+    <!-- 修改需求信息 add by wuxw 2018-07-03 -->
+    <update id="updateJunkRequirementInfo" parameterType="Map">
+        update  junk_requirement t set t.status_cd = #{statusCd}
+<if test="newBId != null and newBId != ''">
+,t.b_id = #{newBId}
+</if> 
+<if test="referencePrice !=null and referencePrice != ''">
+, t.reference_price= #{referencePrice}
+</if> 
+<if test="typeCd !=null and typeCd != ''">
+, t.type_cd= #{typeCd}
+</if> 
+<if test="publishUserName !=null and publishUserName != ''">
+, t.publish_user_name= #{publishUserName}
+</if> 
+<if test="publishUserLink !=null and publishUserLink != ''">
+, t.publish_user_link= #{publishUserLink}
+</if> 
+<if test="context !=null and context != ''">
+, t.context= #{context}
+</if> 
+<if test="publishUserId !=null and publishUserId != ''">
+, t.publish_user_id= #{publishUserId}
+</if> 
+<if test="state !=null and state != ''">
+, t.state= #{state}
+</if> 
+<if test="classification !=null and classification != ''">
+, t.classification= #{classification}
+</if> 
+<if test="communityId !=null and communityId != ''">
+, t.community_id= #{communityId}
+</if> 
+ where 1=1 <if test="junkRequirementId !=null and junkRequirementId != ''">
+and t.junk_requirement_id= #{junkRequirementId}
+</if> 
+
+    </update>
+
+    <!-- 查询需求数量 add by wuxw 2018-07-03 -->
+     <select id="queryJunkRequirementsCount" parameterType="Map" resultType="Map">
+        select  count(1) count 
+from junk_requirement t 
+where 1 =1 
+<if test="referencePrice !=null and referencePrice != ''">
+   and t.reference_price= #{referencePrice}
+</if> 
+<if test="typeCd !=null and typeCd != ''">
+   and t.type_cd= #{typeCd}
+</if> 
+<if test="publishUserName !=null and publishUserName != ''">
+   and t.publish_user_name= #{publishUserName}
+</if> 
+<if test="publishUserLink !=null and publishUserLink != ''">
+   and t.publish_user_link= #{publishUserLink}
+</if> 
+<if test="context !=null and context != ''">
+   and t.context= #{context}
+</if> 
+<if test="publishUserId !=null and publishUserId != ''">
+   and t.publish_user_id= #{publishUserId}
+</if> 
+<if test="statusCd !=null and statusCd != ''">
+   and t.status_cd= #{statusCd}
+</if> 
+<if test="junkRequirementId !=null and junkRequirementId != ''">
+   and t.junk_requirement_id= #{junkRequirementId}
+</if> 
+<if test="state !=null and state != ''">
+   and t.state= #{state}
+</if> 
+<if test="classification !=null and classification != ''">
+   and t.classification= #{classification}
+</if> 
+<if test="communityId !=null and communityId != ''">
+   and t.community_id= #{communityId}
+</if> 
+
+
+     </select>
+
+</mapper>

java110-interface/src/main/java/com/java110/intf/user/IJunkRequirementV1InnerServiceSMO.java

@@ -0,0 +1,68 @@
+/*
+ * Copyright 2017-2020 吴学文 and java110 team.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.java110.intf.user;
+
+import com.java110.config.feign.FeignConfiguration;
+import com.java110.dto.junkRequirement.JunkRequirementDto;
+import com.java110.po.junkRequirement.JunkRequirementPo;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+
+import java.util.List;
+
+/**
+ * 类表述： 服务之前调用的接口类，不对外提供接口能力 只用于接口建调用
+ * add by 吴学文 at 2022-08-08 08:53:50 mail: 928255095@qq.com
+ * open source address: https://gitee.com/wuxw7/MicroCommunity
+ * 官网：http://www.homecommunity.cn
+ * 温馨提示：如果您对此文件进行修改 请不要删除原有作者及注释信息，请补充您的 修改的原因以及联系邮箱如下
+ * // modify by 张三 at 2021-09-12 第10行在某种场景下存在某种bug 需要修复，注释10至20行 加入 20行至30行
+ */
+@FeignClient(name = "user-service", configuration = {FeignConfiguration.class})
+@RequestMapping("/junkRequirementV1Api")
+public interface IJunkRequirementV1InnerServiceSMO {
+
+
+    @RequestMapping(value = "/saveJunkRequirement", method = RequestMethod.POST)
+    public int saveJunkRequirement(@RequestBody  JunkRequirementPo junkRequirementPo);
+
+    @RequestMapping(value = "/updateJunkRequirement", method = RequestMethod.POST)
+    public int updateJunkRequirement(@RequestBody  JunkRequirementPo junkRequirementPo);
+
+    @RequestMapping(value = "/deleteJunkRequirement", method = RequestMethod.POST)
+    public int deleteJunkRequirement(@RequestBody  JunkRequirementPo junkRequirementPo);
+
+    /**
+     * <p>查询小区楼信息</p>
+     *
+     *
+     * @param junkRequirementDto 数据对象分享
+     * @return JunkRequirementDto 对象数据
+     */
+    @RequestMapping(value = "/queryJunkRequirements", method = RequestMethod.POST)
+    List<JunkRequirementDto> queryJunkRequirements(@RequestBody JunkRequirementDto junkRequirementDto);
+
+    /**
+     * 查询<p>小区楼</p>总记录数
+     *
+     * @param junkRequirementDto 数据对象分享
+     * @return 小区下的小区楼记录数
+     */
+    @RequestMapping(value = "/queryJunkRequirementsCount", method = RequestMethod.POST)
+    int queryJunkRequirementsCount(@RequestBody JunkRequirementDto junkRequirementDto);
+}

service-api/src/main/java/com/java110/api/listener/junkRequirement/DeleteJunkRequirementListener.java

@@ -1,53 +0,0 @@
-package com.java110.api.listener.junkRequirement;
-
-import com.alibaba.fastjson.JSONObject;
-import com.java110.api.bmo.junkRequirement.IJunkRequirementBMO;
-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.utils.constant.ServiceCodeJunkRequirementConstant;
-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("deleteJunkRequirementListener")
-public class DeleteJunkRequirementListener extends AbstractServiceApiPlusListener {
-
-    @Autowired
-    private IJunkRequirementBMO junkRequirementBMOImpl;
-
-    @Override
-    protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) {
-        //Assert.hasKeyAndValue(reqJson, "xxx", "xxx");
-
-        Assert.hasKeyAndValue(reqJson, "junkRequirementId", "junkRequirementId不能为空");
-
-    }
-
-    @Override
-    protected void doSoService(ServiceDataFlowEvent event, DataFlowContext context, JSONObject reqJson) {
-
-        junkRequirementBMOImpl.deleteJunkRequirement(reqJson, context);
-    }
-
-    @Override
-    public String getServiceCode() {
-        return ServiceCodeJunkRequirementConstant.DELETE_JUNKREQUIREMENT;
-    }
-
-    @Override
-    public HttpMethod getHttpMethod() {
-        return HttpMethod.POST;
-    }
-
-    @Override
-    public int getOrder() {
-        return DEFAULT_ORDER;
-    }
-
-}

service-api/src/main/java/com/java110/api/listener/junkRequirement/SaveJunkRequirementListener.java

@@ -1,96 +0,0 @@
-package com.java110.api.listener.junkRequirement;
-
-import com.alibaba.fastjson.JSONArray;
-import com.alibaba.fastjson.JSONObject;
-import com.java110.api.bmo.junkRequirement.IJunkRequirementBMO;
-import com.java110.api.listener.AbstractServiceApiPlusListener;
-import com.java110.core.annotation.Java110Listener;
-import com.java110.core.context.DataFlowContext;
-import com.java110.core.factory.GenerateCodeFactory;
-import com.java110.intf.common.IFileInnerServiceSMO;
-import com.java110.dto.file.FileDto;
-import com.java110.core.event.service.api.ServiceDataFlowEvent;
-import com.java110.utils.constant.ServiceCodeJunkRequirementConstant;
-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("saveJunkRequirementListener")
-public class SaveJunkRequirementListener extends AbstractServiceApiPlusListener {
-
-    @Autowired
-    private IJunkRequirementBMO junkRequirementBMOImpl;
-
-    @Autowired
-    private IFileInnerServiceSMO fileInnerServiceSMOImpl;
-
-    @Override
-    protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) {
-        //Assert.hasKeyAndValue(reqJson, "xxx", "xxx");
-
-        Assert.hasKeyAndValue(reqJson, "typeCd", "请求报文中未包含typeCd");
-        Assert.hasKeyAndValue(reqJson, "classification", "请求报文中未包含classification");
-        Assert.hasKeyAndValue(reqJson, "communityId", "请求报文中未包含communityId");
-        Assert.hasKeyAndValue(reqJson, "context", "请求报文中未包含context");
-        Assert.hasKeyAndValue(reqJson, "referencePrice", "请求报文中未包含referencePrice");
-        Assert.hasKeyAndValue(reqJson, "publishUserId", "请求报文中未包含publishUserId");
-        Assert.hasKeyAndValue(reqJson, "publishUserName", "请求报文中未包含publishUserName");
-        Assert.hasKeyAndValue(reqJson, "publishUserLink", "请求报文中未包含publishUserLink");
-
-    }
-
-    @Override
-    protected void doSoService(ServiceDataFlowEvent event, DataFlowContext context, JSONObject reqJson) {
-
-
-        //reqJson.put("state", "12001");
-        reqJson.put("state", "13001");
-        String junkRequirementId = GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_junkRequirementId);
-        reqJson.put("junkRequirementId", junkRequirementId);
-
-        if (reqJson.containsKey("photos")) {
-            dealPhotos(reqJson, context);
-        }
-
-        junkRequirementBMOImpl.addJunkRequirement(reqJson, context);
-    }
-
-    private void dealPhotos(JSONObject reqJson, DataFlowContext context) {
-        JSONArray photos = reqJson.getJSONArray("photos");
-        JSONObject photo = null;
-        for (int photoIndex = 0; photoIndex < photos.size(); photoIndex++) {
-            photo = photos.getJSONObject(photoIndex);
-            FileDto fileDto = new FileDto();
-            fileDto.setFileId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_file_id));
-            fileDto.setFileName(fileDto.getFileId());
-            fileDto.setContext(photo.getString("photo"));
-            fileDto.setSuffix("jpeg");
-            fileDto.setCommunityId(reqJson.getString("communityId"));
-            String fileName = fileInnerServiceSMOImpl.saveFile(fileDto);
-            reqJson.put("photoId", fileDto.getFileId());
-            reqJson.put("fileSaveName", fileName);
-
-            junkRequirementBMOImpl.addPhoto(reqJson, context);
-        }
-    }
-
-    @Override
-    public String getServiceCode() {
-        return ServiceCodeJunkRequirementConstant.ADD_JUNKREQUIREMENT;
-    }
-
-    @Override
-    public HttpMethod getHttpMethod() {
-        return HttpMethod.POST;
-    }
-
-    @Override
-    public int getOrder() {
-        return DEFAULT_ORDER;
-    }
-
-}

service-api/src/main/java/com/java110/api/listener/payFeeDetailDiscount/DeletePayFeeDetailDiscountListener.java

@@ -1,49 +0,0 @@
-package com.java110.api.listener.payFeeDetailDiscount;
-
-import com.alibaba.fastjson.JSONObject;
-import com.java110.api.bmo.payFeeDetailDiscount.IPayFeeDetailDiscountBMO;
-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.utils.constant.ServiceCodePayFeeDetailDiscountConstant;
-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("deletePayFeeDetailDiscountListener")
-public class DeletePayFeeDetailDiscountListener extends AbstractServiceApiPlusListener {
-
-    @Autowired
-    private IPayFeeDetailDiscountBMO payFeeDetailDiscountBMOImpl;
-
-    @Override
-    protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) {
-        //Assert.hasKeyAndValue(reqJson, "xxx", "xxx");
-
-        Assert.hasKeyAndValue(reqJson, "detailDiscountId", "detailDiscountId不能为空");
-
-    }
-
-    @Override
-    protected void doSoService(ServiceDataFlowEvent event, DataFlowContext context, JSONObject reqJson) {
-
-        payFeeDetailDiscountBMOImpl.deletePayFeeDetailDiscount(reqJson, context);
-    }
-
-    @Override
-    public String getServiceCode() {
-        return ServiceCodePayFeeDetailDiscountConstant.DELETE_PAYFEEDETAILDISCOUNT;
-    }
-
-    @Override
-    public HttpMethod getHttpMethod() {
-        return HttpMethod.POST;
-    }
-
-}

service-api/src/main/java/com/java110/api/listener/payFeeDetailDiscount/ListPayFeeDetailDiscountsListener.java

@@ -1,82 +0,0 @@
-package com.java110.api.listener.payFeeDetailDiscount;
-
-import com.alibaba.fastjson.JSONObject;
-import com.java110.api.listener.AbstractServiceApiListener;
-import com.java110.core.annotation.Java110Listener;
-import com.java110.core.context.DataFlowContext;
-import com.java110.core.event.service.api.ServiceDataFlowEvent;
-import com.java110.intf.fee.IPayFeeDetailDiscountInnerServiceSMO;
-import com.java110.dto.payFeeDetailDiscount.PayFeeDetailDiscountDto;
-import com.java110.utils.constant.ServiceCodePayFeeDetailDiscountConstant;
-import com.java110.utils.util.BeanConvertUtil;
-import com.java110.vo.ResultVo;
-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("listPayFeeDetailDiscountsListener")
-public class ListPayFeeDetailDiscountsListener extends AbstractServiceApiListener {
-
-    @Autowired
-    private IPayFeeDetailDiscountInnerServiceSMO payFeeDetailDiscountInnerServiceSMOImpl;
-
-    @Override
-    public String getServiceCode() {
-        return ServiceCodePayFeeDetailDiscountConstant.LIST_PAYFEEDETAILDISCOUNTS;
-    }
-
-    @Override
-    public HttpMethod getHttpMethod() {
-        return HttpMethod.GET;
-    }
-
-
-    @Override
-    public int getOrder() {
-        return DEFAULT_ORDER;
-    }
-
-
-    public IPayFeeDetailDiscountInnerServiceSMO getPayFeeDetailDiscountInnerServiceSMOImpl() {
-        return payFeeDetailDiscountInnerServiceSMOImpl;
-    }
-
-    public void setPayFeeDetailDiscountInnerServiceSMOImpl(IPayFeeDetailDiscountInnerServiceSMO payFeeDetailDiscountInnerServiceSMOImpl) {
-        this.payFeeDetailDiscountInnerServiceSMOImpl = payFeeDetailDiscountInnerServiceSMOImpl;
-    }
-
-    @Override
-    protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) {
-        super.validatePageInfo(reqJson);
-    }
-
-    @Override
-    protected void doSoService(ServiceDataFlowEvent event, DataFlowContext context, JSONObject reqJson) {
-
-        PayFeeDetailDiscountDto payFeeDetailDiscountDto = BeanConvertUtil.covertBean(reqJson, PayFeeDetailDiscountDto.class);
-
-        int count = payFeeDetailDiscountInnerServiceSMOImpl.queryPayFeeDetailDiscountsCount(payFeeDetailDiscountDto);
-
-        List<PayFeeDetailDiscountDto> payFeeDetailDiscountDtos = null;
-
-        if (count > 0) {
-            payFeeDetailDiscountDtos = payFeeDetailDiscountInnerServiceSMOImpl.queryPayFeeDetailDiscounts(payFeeDetailDiscountDto);
-        } else {
-            payFeeDetailDiscountDtos = new ArrayList<>();
-        }
-
-        ResultVo resultVo = new ResultVo((int) Math.ceil((double) count / (double) reqJson.getInteger("row")), count, payFeeDetailDiscountDtos);
-
-        ResponseEntity<String> responseEntity = new ResponseEntity<String>(resultVo.toString(), HttpStatus.OK);
-
-        context.setResponseEntity(responseEntity);
-
-    }
-}

service-api/src/main/java/com/java110/api/listener/payFeeDetailDiscount/UpdatePayFeeDetailDiscountListener.java

@@ -1,49 +0,0 @@
-package com.java110.api.listener.payFeeDetailDiscount;
-
-import com.alibaba.fastjson.JSONObject;
-import com.java110.api.bmo.payFeeDetailDiscount.IPayFeeDetailDiscountBMO;
-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.utils.constant.ServiceCodePayFeeDetailDiscountConstant;
-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("updatePayFeeDetailDiscountListener")
-public class UpdatePayFeeDetailDiscountListener extends AbstractServiceApiPlusListener {
-
-    @Autowired
-    private IPayFeeDetailDiscountBMO payFeeDetailDiscountBMOImpl;
-
-    @Override
-    protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) {
-
-        Assert.hasKeyAndValue(reqJson, "detailDiscountId", "detailDiscountId不能为空");
-        Assert.hasKeyAndValue(reqJson, "detailId", "请求报文中未包含detailId");
-        Assert.hasKeyAndValue(reqJson, "feeId", "请求报文中未包含feeId");
-        Assert.hasKeyAndValue(reqJson, "discountId", "请求报文中未包含discountId");
-
-    }
-
-    @Override
-    protected void doSoService(ServiceDataFlowEvent event, DataFlowContext context, JSONObject reqJson) {
-
-        payFeeDetailDiscountBMOImpl.updatePayFeeDetailDiscount(reqJson, context);
-    }
-
-    @Override
-    public String getServiceCode() {
-        return ServiceCodePayFeeDetailDiscountConstant.UPDATE_PAYFEEDETAILDISCOUNT;
-    }
-
-    @Override
-    public HttpMethod getHttpMethod() {
-        return HttpMethod.POST;
-    }
-}

service-store/src/main/java/com/java110/store/StoreServiceApplicationStart.java

@@ -59,6 +59,7 @@ import java.nio.charset.Charset;
         "com.java110.intf.fee",
         "com.java110.intf.user",
         "com.java110.intf.common",
+        "com.java110.intf.acct",
         "com.java110.intf.order"
 })
 public class StoreServiceApplicationStart {

service-user/src/main/java/com/java110/user/cmd/junkRequirement/DeleteJunkRequirementCmd.java

@@ -0,0 +1,71 @@
+/*
+ * Copyright 2017-2020 吴学文 and java110 team.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.java110.user.cmd.junkRequirement;
+
+import com.alibaba.fastjson.JSONObject;
+import com.java110.core.annotation.Java110Cmd;
+import com.java110.core.annotation.Java110Transactional;
+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.intf.user.IJunkRequirementV1InnerServiceSMO;
+import com.java110.po.junkRequirement.JunkRequirementPo;
+import com.java110.utils.exception.CmdException;
+import com.java110.utils.util.Assert;
+import com.java110.utils.util.BeanConvertUtil;
+import com.java110.vo.ResultVo;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+/**
+ * 类表述：删除
+ * 服务编码：junkRequirement.deleteJunkRequirement
+ * 请求路劲：/app/junkRequirement.DeleteJunkRequirement
+ * add by 吴学文 at 2022-08-08 08:53:50 mail: 928255095@qq.com
+ * open source address: https://gitee.com/wuxw7/MicroCommunity
+ * 官网：http://www.homecommunity.cn
+ * 温馨提示：如果您对此文件进行修改 请不要删除原有作者及注释信息，请补充您的 修改的原因以及联系邮箱如下
+ * // modify by 张三 at 2021-09-12 第10行在某种场景下存在某种bug 需要修复，注释10至20行 加入 20行至30行
+ */
+@Java110Cmd(serviceCode = "junkRequirement.deleteJunkRequirement")
+public class DeleteJunkRequirementCmd extends Cmd {
+  private static Logger logger = LoggerFactory.getLogger(DeleteJunkRequirementCmd.class);
+
+    @Autowired
+    private IJunkRequirementV1InnerServiceSMO junkRequirementV1InnerServiceSMOImpl;
+
+    @Override
+    public void validate(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) {
+        Assert.hasKeyAndValue(reqJson, "junkRequirementId", "junkRequirementId不能为空");
+Assert.hasKeyAndValue(reqJson, "communityId", "communityId不能为空");
+
+    }
+
+    @Override
+    @Java110Transactional
+    public void doCmd(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException {
+
+       JunkRequirementPo junkRequirementPo = BeanConvertUtil.covertBean(reqJson, JunkRequirementPo.class);
+        int flag = junkRequirementV1InnerServiceSMOImpl.deleteJunkRequirement(junkRequirementPo);
+
+        if (flag < 1) {
+            throw new CmdException("删除数据失败");
+        }
+
+        cmdDataFlowContext.setResponseEntity(ResultVo.success());
+    }
+}

service-api/src/main/java/com/java110/api/listener/junkRequirement/ListJunkRequirementsListener.java

@@ -1,35 +1,62 @@
-package com.java110.api.listener.junkRequirement;
+/*
+ * Copyright 2017-2020 吴学文 and java110 team.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.java110.user.cmd.junkRequirement;
 
 import com.alibaba.fastjson.JSONObject;
-import com.java110.api.listener.AbstractServiceApiListener;
-import com.java110.core.annotation.Java110Listener;
-import com.java110.core.context.DataFlowContext;
+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.dto.file.FileRelDto;
+import com.java110.dto.owner.OwnerAppUserDto;
 import com.java110.intf.common.IFileRelInnerServiceSMO;
 import com.java110.intf.user.IJunkRequirementInnerServiceSMO;
+import com.java110.intf.user.IJunkRequirementV1InnerServiceSMO;
 import com.java110.intf.user.IOwnerAppUserInnerServiceSMO;
-import com.java110.dto.file.FileRelDto;
-import com.java110.dto.junkRequirement.JunkRequirementDto;
-import com.java110.dto.owner.OwnerAppUserDto;
-import com.java110.core.event.service.api.ServiceDataFlowEvent;
-import com.java110.utils.constant.ServiceCodeJunkRequirementConstant;
+import com.java110.utils.exception.CmdException;
 import com.java110.utils.util.BeanConvertUtil;
 import com.java110.vo.api.junkRequirement.ApiJunkRequirementDataVo;
 import com.java110.vo.api.junkRequirement.ApiJunkRequirementVo;
 import com.java110.vo.api.junkRequirement.PhotoVo;
 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 com.java110.dto.junkRequirement.JunkRequirementDto;
 import java.util.List;
+import java.util.ArrayList;
+import org.springframework.http.ResponseEntity;
+import org.springframework.http.HttpStatus;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 
 /**
- * 查询小区侦听类
+ * 类表述：查询
+ * 服务编码：junkRequirement.listJunkRequirement
+ * 请求路劲：/app/junkRequirement.ListJunkRequirement
+ * add by 吴学文 at 2022-08-08 08:53:50 mail: 928255095@qq.com
+ * open source address: https://gitee.com/wuxw7/MicroCommunity
+ * 官网：http://www.homecommunity.cn
+ * 温馨提示：如果您对此文件进行修改 请不要删除原有作者及注释信息，请补充您的 修改的原因以及联系邮箱如下
+ * // modify by 张三 at 2021-09-12 第10行在某种场景下存在某种bug 需要修复，注释10至20行 加入 20行至30行
  */
-@Java110Listener("listJunkRequirementsListener")
-public class ListJunkRequirementsListener extends AbstractServiceApiListener {
+@Java110Cmd(serviceCode = "junkRequirement.listJunkRequirements")
+public class ListJunkRequirementsCmd extends Cmd {
+
+  private static Logger logger = LoggerFactory.getLogger(ListJunkRequirementsCmd.class);
+    @Autowired
+    private IJunkRequirementV1InnerServiceSMO junkRequirementV1InnerServiceSMOImpl;
 
     @Autowired
     private IJunkRequirementInnerServiceSMO junkRequirementInnerServiceSMOImpl;
@@ -40,38 +67,12 @@ public class ListJunkRequirementsListener extends AbstractServiceApiListener {
     private IOwnerAppUserInnerServiceSMO ownerAppUserInnerServiceSMOImpl;
 
     @Override
-    public String getServiceCode() {
-        return ServiceCodeJunkRequirementConstant.LIST_JUNKREQUIREMENTS;
-    }
-
-
-    @Override
-    public HttpMethod getHttpMethod() {
-        return HttpMethod.GET;
-    }
-
-
-    @Override
-    public int getOrder() {
-        return DEFAULT_ORDER;
-    }
-
-
-    public IJunkRequirementInnerServiceSMO getJunkRequirementInnerServiceSMOImpl() {
-        return junkRequirementInnerServiceSMOImpl;
-    }
-
-    public void setJunkRequirementInnerServiceSMOImpl(IJunkRequirementInnerServiceSMO junkRequirementInnerServiceSMOImpl) {
-        this.junkRequirementInnerServiceSMOImpl = junkRequirementInnerServiceSMOImpl;
-    }
-
-    @Override
-    protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) {
+    public void validate(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) {
         super.validatePageInfo(reqJson);
     }
 
     @Override
-    protected void doSoService(ServiceDataFlowEvent event, DataFlowContext context, JSONObject reqJson) {
+    public void doCmd(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException {
 
         JunkRequirementDto junkRequirementDto = BeanConvertUtil.covertBean(reqJson, JunkRequirementDto.class);
 
@@ -94,7 +95,7 @@ public class ListJunkRequirementsListener extends AbstractServiceApiListener {
 
         ResponseEntity<String> responseEntity = new ResponseEntity<String>(JSONObject.toJSONString(apiJunkRequirementVo), HttpStatus.OK);
 
-        context.setResponseEntity(responseEntity);
+        cmdDataFlowContext.setResponseEntity(responseEntity);
 
     }
 

service-user/src/main/java/com/java110/user/cmd/junkRequirement/SaveJunkRequirementCmd.java

@@ -0,0 +1,135 @@
+/*
+ * Copyright 2017-2020 吴学文 and java110 team.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.java110.user.cmd.junkRequirement;
+
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.java110.core.annotation.Java110Cmd;
+import com.java110.core.annotation.Java110Transactional;
+import com.java110.core.context.DataFlowContext;
+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.file.FileDto;
+import com.java110.intf.common.IFileInnerServiceSMO;
+import com.java110.intf.common.IFileRelInnerServiceSMO;
+import com.java110.intf.user.IJunkRequirementV1InnerServiceSMO;
+import com.java110.po.file.FileRelPo;
+import com.java110.po.junkRequirement.JunkRequirementPo;
+import com.java110.utils.exception.CmdException;
+import com.java110.utils.util.Assert;
+import com.java110.utils.util.BeanConvertUtil;
+import com.java110.vo.ResultVo;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * 类表述：保存
+ * 服务编码：junkRequirement.saveJunkRequirement
+ * 请求路劲：/app/junkRequirement.SaveJunkRequirement
+ * add by 吴学文 at 2022-08-08 08:53:50 mail: 928255095@qq.com
+ * open source address: https://gitee.com/wuxw7/MicroCommunity
+ * 官网：http://www.homecommunity.cn
+ * 温馨提示：如果您对此文件进行修改 请不要删除原有作者及注释信息，请补充您的 修改的原因以及联系邮箱如下
+ * // modify by 张三 at 2021-09-12 第10行在某种场景下存在某种bug 需要修复，注释10至20行 加入 20行至30行
+ */
+@Java110Cmd(serviceCode = "junkRequirement.saveJunkRequirement")
+public class SaveJunkRequirementCmd extends Cmd {
+
+    private static Logger logger = LoggerFactory.getLogger(SaveJunkRequirementCmd.class);
+
+    public static final String CODE_PREFIX_ID = "10";
+
+    @Autowired
+    private IJunkRequirementV1InnerServiceSMO junkRequirementV1InnerServiceSMOImpl;
+
+    @Autowired
+    private IFileRelInnerServiceSMO fileRelInnerServiceSMOImpl;
+
+    @Autowired
+    private IFileInnerServiceSMO fileInnerServiceSMOImpl;
+
+
+    @Override
+    public void validate(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) {
+        Assert.hasKeyAndValue(reqJson, "typeCd", "请求报文中未包含typeCd");
+        Assert.hasKeyAndValue(reqJson, "classification", "请求报文中未包含classification");
+        Assert.hasKeyAndValue(reqJson, "communityId", "请求报文中未包含communityId");
+        Assert.hasKeyAndValue(reqJson, "context", "请求报文中未包含context");
+        Assert.hasKeyAndValue(reqJson, "referencePrice", "请求报文中未包含referencePrice");
+        Assert.hasKeyAndValue(reqJson, "publishUserId", "请求报文中未包含publishUserId");
+        Assert.hasKeyAndValue(reqJson, "publishUserName", "请求报文中未包含publishUserName");
+        Assert.hasKeyAndValue(reqJson, "publishUserLink", "请求报文中未包含publishUserLink");
+
+    }
+
+    @Override
+    @Java110Transactional
+    public void doCmd(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException {
+        //reqJson.put("state", "12001");
+        reqJson.put("state", "13001");
+        String junkRequirementId = GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_junkRequirementId);
+        reqJson.put("junkRequirementId", junkRequirementId);
+
+        if (reqJson.containsKey("photos")) {
+            dealPhotos(reqJson);
+        }
+
+       JunkRequirementPo junkRequirementPo = BeanConvertUtil.covertBean(reqJson, JunkRequirementPo.class);
+        junkRequirementPo.setJunkRequirementId(GenerateCodeFactory.getGeneratorId(CODE_PREFIX_ID));
+        int flag = junkRequirementV1InnerServiceSMOImpl.saveJunkRequirement(junkRequirementPo);
+
+        if (flag < 1) {
+            throw new CmdException("保存数据失败");
+        }
+
+        cmdDataFlowContext.setResponseEntity(ResultVo.success());
+    }
+
+    private void dealPhotos(JSONObject reqJson) {
+        JSONArray photos = reqJson.getJSONArray("photos");
+        JSONObject photo = null;
+        int flag = 0;
+        for (int photoIndex = 0; photoIndex < photos.size(); photoIndex++) {
+            photo = photos.getJSONObject(photoIndex);
+            FileDto fileDto = new FileDto();
+            fileDto.setFileId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_file_id));
+            fileDto.setFileName(fileDto.getFileId());
+            fileDto.setContext(photo.getString("photo"));
+            fileDto.setSuffix("jpeg");
+            fileDto.setCommunityId(reqJson.getString("communityId"));
+            String fileName = fileInnerServiceSMOImpl.saveFile(fileDto);
+            reqJson.put("photoId", fileDto.getFileId());
+            reqJson.put("fileSaveName", fileName);
+
+            JSONObject businessUnit = new JSONObject();
+            businessUnit.put("fileRelId", GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_fileRelId));
+            businessUnit.put("relTypeCd", "80000");
+            businessUnit.put("saveWay", "ftp");
+            businessUnit.put("objId", reqJson.getString("junkRequirementId"));
+            businessUnit.put("fileRealName", reqJson.getString("photoId"));
+            businessUnit.put("fileSaveName", reqJson.getString("fileSaveName"));
+            FileRelPo fileRelPo = BeanConvertUtil.covertBean(businessUnit, FileRelPo.class);
+
+            flag = fileRelInnerServiceSMOImpl.saveFileRel(fileRelPo);
+            if(flag <1){
+                throw new CmdException("报错图片异常");
+            }
+        }
+    }
+}

service-user/src/main/java/com/java110/user/cmd/junkRequirement/UpdateJunkRequirementCmd.java

@@ -0,0 +1,99 @@
+/*
+ * Copyright 2017-2020 吴学文 and java110 team.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.java110.user.cmd.junkRequirement;
+
+import com.alibaba.fastjson.JSONObject;
+import com.java110.core.annotation.Java110Cmd;
+import com.java110.core.annotation.Java110Transactional;
+import com.java110.core.context.ICmdDataFlowContext;
+import com.java110.core.event.cmd.Cmd;
+import com.java110.core.event.cmd.CmdEvent;
+import com.java110.dto.junkRequirement.JunkRequirementDto;
+import com.java110.intf.user.IJunkRequirementInnerServiceSMO;
+import com.java110.intf.user.IJunkRequirementV1InnerServiceSMO;
+import com.java110.po.junkRequirement.JunkRequirementPo;
+import com.java110.utils.exception.CmdException;
+import com.java110.utils.util.Assert;
+import com.java110.utils.util.BeanConvertUtil;
+import com.java110.vo.ResultVo;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import java.util.List;
+
+
+/**
+ * 类表述：更新
+ * 服务编码：junkRequirement.updateJunkRequirement
+ * 请求路劲：/app/junkRequirement.UpdateJunkRequirement
+ * add by 吴学文 at 2022-08-08 08:53:50 mail: 928255095@qq.com
+ * open source address: https://gitee.com/wuxw7/MicroCommunity
+ * 官网：http://www.homecommunity.cn
+ * 温馨提示：如果您对此文件进行修改 请不要删除原有作者及注释信息，请补充您的 修改的原因以及联系邮箱如下
+ * // modify by 张三 at 2021-09-12 第10行在某种场景下存在某种bug 需要修复，注释10至20行 加入 20行至30行
+ */
+@Java110Cmd(serviceCode = "junkRequirement.updateJunkRequirement")
+public class UpdateJunkRequirementCmd extends Cmd {
+
+    private static Logger logger = LoggerFactory.getLogger(UpdateJunkRequirementCmd.class);
+
+
+    @Autowired
+    private IJunkRequirementV1InnerServiceSMO junkRequirementV1InnerServiceSMOImpl;
+
+    @Autowired
+    private IJunkRequirementInnerServiceSMO junkRequirementInnerServiceSMOImpl;
+
+    @Override
+    public void validate(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) {
+        Assert.hasKeyAndValue(reqJson, "junkRequirementId", "junkRequirementId不能为空");
+//        Assert.hasKeyAndValue(reqJson, "typeCd", "请求报文中未包含typeCd");
+//        Assert.hasKeyAndValue(reqJson, "classification", "请求报文中未包含classification");
+//        Assert.hasKeyAndValue(reqJson, "communityId", "请求报文中未包含communityId");
+//        Assert.hasKeyAndValue(reqJson, "context", "请求报文中未包含context");
+//        Assert.hasKeyAndValue(reqJson, "referencePrice", "请求报文中未包含referencePrice");
+//        Assert.hasKeyAndValue(reqJson, "publishUserId", "请求报文中未包含publishUserId");
+//        Assert.hasKeyAndValue(reqJson, "publishUserName", "请求报文中未包含publishUserName");
+//        Assert.hasKeyAndValue(reqJson, "publishUserLink", "请求报文中未包含publishUserLink");
+        Assert.hasKeyAndValue(reqJson, "state", "请求报文中未包含state");
+
+    }
+
+    @Override
+    @Java110Transactional
+    public void doCmd(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException {
+        JunkRequirementDto junkRequirementDto = new JunkRequirementDto();
+        junkRequirementDto.setJunkRequirementId(reqJson.getString("junkRequirementId"));
+//        junkRequirementDto.setCommunityId(paramInJson.getString("communityId"));
+        List<JunkRequirementDto> junkRequirementDtos = junkRequirementInnerServiceSMOImpl.queryJunkRequirements(junkRequirementDto);
+
+        Assert.listOnlyOne(junkRequirementDtos, "未找到需要修改的活动 或多条数据");
+
+        JSONObject businessJunkRequirement = new JSONObject();
+        businessJunkRequirement.putAll(BeanConvertUtil.beanCovertMap(junkRequirementDtos.get(0)));
+        businessJunkRequirement.putAll(reqJson);
+        JunkRequirementPo junkRequirementPo = BeanConvertUtil.covertBean(businessJunkRequirement, JunkRequirementPo.class);
+
+        int flag = junkRequirementV1InnerServiceSMOImpl.updateJunkRequirement(junkRequirementPo);
+
+        if (flag < 1) {
+            throw new CmdException("更新数据失败");
+        }
+
+        cmdDataFlowContext.setResponseEntity(ResultVo.success());
+    }
+}

service-user/src/main/java/com/java110/user/dao/IJunkRequirementV1ServiceDao.java

@@ -0,0 +1,77 @@
+/*
+ * Copyright 2017-2020 吴学文 and java110 team.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.java110.user.dao;
+
+
+import com.java110.utils.exception.DAOException;
+import com.java110.entity.merchant.BoMerchant;
+import com.java110.entity.merchant.BoMerchantAttr;
+import com.java110.entity.merchant.Merchant;
+import com.java110.entity.merchant.MerchantAttr;
+
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 类表述：
+ * add by 吴学文 at 2022-08-08 08:53:50 mail: 928255095@qq.com
+ * open source address: https://gitee.com/wuxw7/MicroCommunity
+ * 官网：http://www.homecommunity.cn
+ * 温馨提示：如果您对此文件进行修改 请不要删除原有作者及注释信息，请补充您的 修改的原因以及联系邮箱如下
+ * // modify by 张三 at 2021-09-12 第10行在某种场景下存在某种bug 需要修复，注释10至20行 加入 20行至30行
+ */
+public interface IJunkRequirementV1ServiceDao {
+
+
+    /**
+     * 保存 需求信息
+     * @param info
+     * @throws DAOException DAO异常
+     */
+    int saveJunkRequirementInfo(Map info) throws DAOException;
+
+
+
+
+    /**
+     * 查询需求信息（instance过程）
+     * 根据bId 查询需求信息
+     * @param info bId 信息
+     * @return 需求信息
+     * @throws DAOException DAO异常
+     */
+    List<Map> getJunkRequirementInfo(Map info) throws DAOException;
+
+
+
+    /**
+     * 修改需求信息
+     * @param info 修改信息
+     * @throws DAOException DAO异常
+     */
+    int updateJunkRequirementInfo(Map info) throws DAOException;
+
+
+    /**
+     * 查询需求总数
+     *
+     * @param info 需求信息
+     * @return 需求数量
+     */
+    int queryJunkRequirementsCount(Map info);
+
+}

service-user/src/main/java/com/java110/user/dao/impl/JunkRequirementV1ServiceDaoImpl.java

@@ -0,0 +1,112 @@
+/*
+ * Copyright 2017-2020 吴学文 and java110 team.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.java110.user.dao.impl;
+
+import com.alibaba.fastjson.JSONObject;
+import com.java110.utils.constant.ResponseConstant;
+import com.java110.utils.exception.DAOException;
+import com.java110.utils.util.DateUtil;
+import com.java110.core.base.dao.BaseServiceDao;
+import com.java110.user.dao.IJunkRequirementV1ServiceDao;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 类表述：
+ * add by 吴学文 at 2022-08-08 08:53:50 mail: 928255095@qq.com
+ * open source address: https://gitee.com/wuxw7/MicroCommunity
+ * 官网：http://www.homecommunity.cn
+ * 温馨提示：如果您对此文件进行修改 请不要删除原有作者及注释信息，请补充您的 修改的原因以及联系邮箱如下
+ * // modify by 张三 at 2021-09-12 第10行在某种场景下存在某种bug 需要修复，注释10至20行 加入 20行至30行
+ */
+@Service("junkRequirementV1ServiceDaoImpl")
+public class JunkRequirementV1ServiceDaoImpl extends BaseServiceDao implements IJunkRequirementV1ServiceDao {
+
+    private static Logger logger = LoggerFactory.getLogger(JunkRequirementV1ServiceDaoImpl.class);
+
+
+
+
+
+    /**
+     * 保存需求信息 到 instance
+     * @param info   bId 信息
+     * @throws DAOException DAO异常
+     */
+    @Override
+    public int saveJunkRequirementInfo(Map info) throws DAOException {
+        logger.debug("保存 saveJunkRequirementInfo 入参 info : {}",info);
+
+        int saveFlag = sqlSessionTemplate.insert("junkRequirementV1ServiceDaoImpl.saveJunkRequirementInfo",info);
+
+        return saveFlag;
+    }
+
+
+    /**
+     * 查询需求信息（instance）
+     * @param info bId 信息
+     * @return List<Map>
+     * @throws DAOException DAO异常
+     */
+    @Override
+    public List<Map> getJunkRequirementInfo(Map info) throws DAOException {
+        logger.debug("查询 getJunkRequirementInfo 入参 info : {}",info);
+
+        List<Map> businessJunkRequirementInfos = sqlSessionTemplate.selectList("junkRequirementV1ServiceDaoImpl.getJunkRequirementInfo",info);
+
+        return businessJunkRequirementInfos;
+    }
+
+
+    /**
+     * 修改需求信息
+     * @param info 修改信息
+     * @throws DAOException DAO异常
+     */
+    @Override
+    public int updateJunkRequirementInfo(Map info) throws DAOException {
+        logger.debug("修改 updateJunkRequirementInfo 入参 info : {}",info);
+
+        int saveFlag = sqlSessionTemplate.update("junkRequirementV1ServiceDaoImpl.updateJunkRequirementInfo",info);
+
+        return saveFlag;
+    }
+
+     /**
+     * 查询需求数量
+     * @param info 需求信息
+     * @return 需求数量
+     */
+    @Override
+    public int queryJunkRequirementsCount(Map info) {
+        logger.debug("查询 queryJunkRequirementsCount 入参 info : {}",info);
+
+        List<Map> businessJunkRequirementInfos = sqlSessionTemplate.selectList("junkRequirementV1ServiceDaoImpl.queryJunkRequirementsCount", info);
+        if (businessJunkRequirementInfos.size() < 1) {
+            return 0;
+        }
+
+        return Integer.parseInt(businessJunkRequirementInfos.get(0).get("count").toString());
+    }
+
+
+}

service-user/src/main/java/com/java110/user/smo/impl/JunkRequirementV1InnerServiceSMOImpl.java

@@ -0,0 +1,89 @@
+/*
+ * Copyright 2017-2020 吴学文 and java110 team.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.java110.user.smo.impl;
+
+
+import com.java110.user.dao.IJunkRequirementV1ServiceDao;
+import com.java110.intf.user.IJunkRequirementV1InnerServiceSMO;
+import com.java110.dto.junkRequirement.JunkRequirementDto;
+import com.java110.po.junkRequirement.JunkRequirementPo;
+import com.java110.utils.util.BeanConvertUtil;
+import com.java110.core.base.smo.BaseServiceSMO;
+import com.java110.dto.user.UserDto;
+import com.java110.dto.PageDto;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * 类表述： 服务之前调用的接口实现类，不对外提供接口能力 只用于接口建调用
+ * add by 吴学文 at 2022-08-08 08:53:50 mail: 928255095@qq.com
+ * open source address: https://gitee.com/wuxw7/MicroCommunity
+ * 官网：http://www.homecommunity.cn
+ * 温馨提示：如果您对此文件进行修改 请不要删除原有作者及注释信息，请补充您的 修改的原因以及联系邮箱如下
+ * // modify by 张三 at 2021-09-12 第10行在某种场景下存在某种bug 需要修复，注释10至20行 加入 20行至30行
+ */
+@RestController
+public class JunkRequirementV1InnerServiceSMOImpl extends BaseServiceSMO implements IJunkRequirementV1InnerServiceSMO {
+
+    @Autowired
+    private IJunkRequirementV1ServiceDao junkRequirementV1ServiceDaoImpl;
+
+
+    @Override
+    public int saveJunkRequirement(@RequestBody  JunkRequirementPo junkRequirementPo) {
+        int saveFlag = junkRequirementV1ServiceDaoImpl.saveJunkRequirementInfo(BeanConvertUtil.beanCovertMap(junkRequirementPo));
+        return saveFlag;
+    }
+
+     @Override
+    public int updateJunkRequirement(@RequestBody  JunkRequirementPo junkRequirementPo) {
+        int saveFlag = junkRequirementV1ServiceDaoImpl.updateJunkRequirementInfo(BeanConvertUtil.beanCovertMap(junkRequirementPo));
+        return saveFlag;
+    }
+
+     @Override
+    public int deleteJunkRequirement(@RequestBody  JunkRequirementPo junkRequirementPo) {
+       junkRequirementPo.setStatusCd("1");
+       int saveFlag = junkRequirementV1ServiceDaoImpl.updateJunkRequirementInfo(BeanConvertUtil.beanCovertMap(junkRequirementPo));
+       return saveFlag;
+    }
+
+    @Override
+    public List<JunkRequirementDto> queryJunkRequirements(@RequestBody  JunkRequirementDto junkRequirementDto) {
+
+        //校验是否传了 分页信息
+
+        int page = junkRequirementDto.getPage();
+
+        if (page != PageDto.DEFAULT_PAGE) {
+            junkRequirementDto.setPage((page - 1) * junkRequirementDto.getRow());
+        }
+
+        List<JunkRequirementDto> junkRequirements = BeanConvertUtil.covertBeanList(junkRequirementV1ServiceDaoImpl.getJunkRequirementInfo(BeanConvertUtil.beanCovertMap(junkRequirementDto)), JunkRequirementDto.class);
+
+        return junkRequirements;
+    }
+
+
+    @Override
+    public int queryJunkRequirementsCount(@RequestBody JunkRequirementDto junkRequirementDto) {
+        return junkRequirementV1ServiceDaoImpl.queryJunkRequirementsCount(BeanConvertUtil.beanCovertMap(junkRequirementDto));    }
+
+}