优化查询

java110-db/src/main/resources/mapper/fee/PayFeeConfigV1ServiceDaoImplMapper.xml

@@ -231,4 +231,31 @@
 
     </select>
 
+    <!-- 查询收费项目数量 add by wuxw 2018-07-03 -->
+    <select id="queryFeeObjsCount" parameterType="Map" resultType="Map">
+        select count(1) count
+        from pay_fee t
+        left join pay_fee_attrs pfa on t.fee_id = pfa.fee_id and pfa.status_cd = '0' and pfa.spec_cd = '390012'
+        left join pay_fee_attrs pfa1 on t.fee_id = pfa1.fee_id and pfa1.status_cd = '0' and pfa1.spec_cd = '390008'
+        left join pay_fee_attrs pfa2 on t.fee_id = pfa2.fee_id and pfa2.status_cd = '0' and pfa2.spec_cd = '390009'
+        where t.config_id = #{configId}
+        and t.community_id= #{communityId}
+    </select>
+
+    <!-- 查询收费项目信息 add by wuxw 2018-07-03 -->
+    <select id="queryFeeObjs" parameterType="Map" resultType="Map">
+        select t.fee_id feeId,t.payer_obj_type payerObjType,pfa.`value` payerObjName,pfa1.`value` ownerName,
+        pfa2.value ownerTel, t.create_time createTime
+        from pay_fee t
+        left join pay_fee_attrs pfa on t.fee_id = pfa.fee_id and pfa.status_cd = '0' and pfa.spec_cd = '390012'
+        left join pay_fee_attrs pfa1 on t.fee_id = pfa1.fee_id and pfa1.status_cd = '0' and pfa1.spec_cd = '390008'
+        left join pay_fee_attrs pfa2 on t.fee_id = pfa2.fee_id and pfa2.status_cd = '0' and pfa2.spec_cd = '390009'
+        where t.config_id = #{configId}
+        and t.community_id= #{communityId}
+        order by t.create_time desc
+        <if test="page != -1 and page != null ">
+            limit #{page}, #{row}
+        </if>
+    </select>
+
 </mapper>

java110-interface/src/main/java/com/java110/intf/fee/IPayFeeConfigV1InnerServiceSMO.java

@@ -17,6 +17,7 @@ package com.java110.intf.fee;
 
 import com.java110.config.feign.FeignConfiguration;
 import com.java110.dto.fee.FeeConfigDto;
+import com.java110.dto.fee.FeeDto;
 import com.java110.po.fee.PayFeeConfigPo;
 import org.springframework.cloud.openfeign.FeignClient;
 import org.springframework.web.bind.annotation.RequestBody;
@@ -64,4 +65,10 @@ public interface IPayFeeConfigV1InnerServiceSMO {
      */
     @RequestMapping(value = "/queryPayFeeConfigsCount", method = RequestMethod.POST)
     int queryPayFeeConfigsCount(@RequestBody FeeConfigDto payFeeConfigDto);
+
+    @RequestMapping(value = "/queryFeeObjsCount", method = RequestMethod.POST)
+    int queryFeeObjsCount(@RequestBody FeeConfigDto feeConfigDto);
+
+    @RequestMapping(value = "/queryFeeObjs", method = RequestMethod.POST)
+    List<FeeDto> queryFeeObjs(@RequestBody FeeConfigDto feeConfigDto);
 }

service-fee/src/main/java/com/java110/fee/cmd/feeConfig/ListConfigFeeObjsCmd.java

@@ -0,0 +1,65 @@
+package com.java110.fee.cmd.feeConfig;
+
+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.dto.PageDto;
+import com.java110.dto.fee.FeeConfigDto;
+import com.java110.dto.fee.FeeDto;
+import com.java110.intf.fee.IPayFeeConfigV1InnerServiceSMO;
+import com.java110.utils.exception.CmdException;
+import com.java110.utils.util.Assert;
+import com.java110.utils.util.BeanConvertUtil;
+import com.java110.utils.util.StringUtil;
+import com.java110.vo.ResultVo;
+import com.java110.vo.api.feeConfig.ApiFeeConfigDataVo;
+import com.java110.vo.api.feeConfig.ApiFeeConfigVo;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+
+import java.text.ParseException;
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * 查询 费用对象
+ */
+@Java110Cmd(serviceCode = "feeConfig.listConfigFeeObjs")
+public class ListConfigFeeObjsCmd extends Cmd {
+
+    @Autowired
+    private IPayFeeConfigV1InnerServiceSMO payFeeConfigV1InnerServiceSMOImpl;
+
+    @Override
+    public void validate(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException, ParseException {
+        Assert.hasKeyAndValue(reqJson, "communityId", "未包含小区");
+        Assert.hasKeyAndValue(reqJson, "configId", "未包含费用项");
+    }
+
+    @Override
+    public void doCmd(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException, ParseException {
+        FeeConfigDto feeConfigDto = BeanConvertUtil.covertBean(reqJson, FeeConfigDto.class);
+
+        int count = payFeeConfigV1InnerServiceSMOImpl.queryFeeObjsCount(feeConfigDto);
+
+        List<FeeDto> feeDtos = null;
+
+        if (count > 0) {
+            feeDtos = BeanConvertUtil.covertBeanList(payFeeConfigV1InnerServiceSMOImpl.queryFeeObjs(feeConfigDto), FeeDto.class);
+        } else {
+            feeDtos = new ArrayList<>();
+        }
+
+
+        ResponseEntity<String> responseEntity
+                = ResultVo.createResponseEntity(
+                (int) Math.ceil((double) count / (double) reqJson.getInteger("row")),
+                count,
+                feeDtos);
+
+        context.setResponseEntity(responseEntity);
+    }
+}

service-fee/src/main/java/com/java110/fee/dao/IPayFeeConfigV1ServiceDao.java

@@ -74,4 +74,7 @@ public interface IPayFeeConfigV1ServiceDao {
      */
     int queryPayFeeConfigsCount(Map info);
 
+    int queryFeeObjsCount(Map info);
+
+    List<Map> queryFeeObjs(Map info);
 }

service-fee/src/main/java/com/java110/fee/dao/impl/PayFeeConfigV1ServiceDaoImpl.java

@@ -108,5 +108,26 @@ public class PayFeeConfigV1ServiceDaoImpl extends BaseServiceDao implements IPay
         return Integer.parseInt(businessPayFeeConfigInfos.get(0).get("count").toString());
     }
 
+    @Override
+    public int queryFeeObjsCount(Map info) {
+        logger.debug("查询 queryFeeObjsCount 入参 info : {}",info);
+
+        List<Map> datas = sqlSessionTemplate.selectList("payFeeConfigV1ServiceDaoImpl.queryFeeObjsCount", info);
+        if (datas.size() < 1) {
+            return 0;
+        }
+
+        return Integer.parseInt(datas.get(0).get("count").toString());
+    }
+
+    @Override
+    public List<Map> queryFeeObjs(Map info) {
+        logger.debug("查询 queryFeeObjs 入参 info : {}",info);
+
+        List<Map> datas = sqlSessionTemplate.selectList("payFeeConfigV1ServiceDaoImpl.queryFeeObjs",info);
+
+        return datas;
+    }
+
 
 }

service-fee/src/main/java/com/java110/fee/smo/impl/PayFeeConfigV1InnerServiceSMOImpl.java

@@ -19,6 +19,7 @@ package com.java110.fee.smo.impl;
 import com.java110.core.base.smo.BaseServiceSMO;
 import com.java110.dto.PageDto;
 import com.java110.dto.fee.FeeConfigDto;
+import com.java110.dto.fee.FeeDto;
 import com.java110.fee.dao.IPayFeeConfigV1ServiceDao;
 import com.java110.intf.fee.IPayFeeConfigV1InnerServiceSMO;
 import com.java110.po.fee.PayFeeConfigPo;
@@ -86,4 +87,25 @@ public class PayFeeConfigV1InnerServiceSMOImpl extends BaseServiceSMO implements
         return payFeeConfigV1ServiceDaoImpl.queryPayFeeConfigsCount(BeanConvertUtil.beanCovertMap(payFeeConfigDto));
     }
 
+    @Override
+    public int queryFeeObjsCount(@RequestBody FeeConfigDto feeConfigDto) {
+        return payFeeConfigV1ServiceDaoImpl.queryFeeObjsCount(BeanConvertUtil.beanCovertMap(feeConfigDto));
+    }
+
+    @Override
+    public List<FeeDto> queryFeeObjs(@RequestBody FeeConfigDto feeConfigDto) {
+        //校验是否传了 分页信息
+
+        int page = feeConfigDto.getPage();
+
+        if (page != PageDto.DEFAULT_PAGE) {
+            feeConfigDto.setPage((page - 1) * feeConfigDto.getRow());
+        }
+
+        List<FeeDto> feeDtos = BeanConvertUtil.covertBeanList(
+                payFeeConfigV1ServiceDaoImpl.queryFeeObjs(BeanConvertUtil.beanCovertMap(feeConfigDto)), FeeDto.class);
+
+        return feeDtos;
+    }
+
 }