优化查询

Your Name

2023-04-12 4010d71ed943786c23cf4c1efe54c387d75e6846

优化查询

 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 @@

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 @@
     */
    @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

New file
@@ -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 @@
     */
    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 @@
        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 @@
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 @@
        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;
    }

}