楚江erp：台账报表相关接口开发

+package com.lframework.xingyun.sc.bo.ledger.receipt;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.math.BigDecimal;
+import java.util.List;
+
+/**
+ * <p>
+ * 应收款台账明细 QueryBo
+ * </p>
+ *
+ */
+@Data
+public class ReceiptLedgerReportBo {
+
+    /**
+     * 额度
+     */
+    @ApiModelProperty("额度")
+    private BigDecimal quota;
+
+    /**
+     * 结算期限
+     */
+    @ApiModelProperty("结算期限")
+    private String settleTerm;
+
+    /**
+     * 办事处ID
+     */
+    @ApiModelProperty("办事处ID")
+    private String deptId;
+
+    /**
+     * 办事处名称
+     */
+    @ApiModelProperty("办事处名称")
+    private String deptName;
+
+    /**
+     * 区域ID
+     */
+    @ApiModelProperty("区域ID")
+    private String region;
+
+    /**
+     * 区域名称
+     */
+    @ApiModelProperty("区域名称")
+    private String regionName;
+
+    /**
+     * 客户类型
+     */
+    @ApiModelProperty("客户类型")
+    private String customerType;
+
+    /**
+     * 客户简称ID
+     */
+    @ApiModelProperty("客户简称ID")
+    private String customerShortId;
+
+    /**
+     * 客户简称
+     */
+    @ApiModelProperty("客户简称")
+    private String customerShortName;
+
+    /**
+     * 报表明细
+     */
+    @ApiModelProperty("报表明细")
+    private List<ReceiptLedgerReportDetail> detailList;
+
+    /**
+     * 总欠款
+     */
+    @ApiModelProperty("总欠款")
+    private BigDecimal debtTotal;
+
+    /**
+     * 约定内总欠款
+     */
+    @ApiModelProperty("约定内总欠款")
+    private BigDecimal agreementTotal;
+
+    /**
+     * 一次协调总欠款
+     */
+    @ApiModelProperty("一次协调总欠款")
+    private BigDecimal firstCoordinateTotal;
+
+    /**
+     * 二次协调总欠款
+     */
+    @ApiModelProperty("二次协调总欠款")
+    private BigDecimal secondCoordinateTotal;
+
+    /**
+     * 清欠总欠款
+     */
+    @ApiModelProperty("清欠总欠款")
+    private BigDecimal clearDebtTotal;
+
+    /**
+     * 授信状态
+     */
+    @ApiModelProperty("授信状态")
+    private String creditStatus;
+
+    /**
+     * 授时状态
+     */
+    @ApiModelProperty("总欠款")
+    private String timingStatus;
+
+    /**
+     * 待交付订单总数
+     */
+    @ApiModelProperty("待交付订单总数")
+    private Integer waitDeliveredOrderTotal;
+}

+package com.lframework.xingyun.sc.bo.ledger.receipt;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.math.BigDecimal;
+
+/**
+ * <p>
+ * 应收款台账明细 QueryBo
+ * </p>
+ *
+ */
+@Data
+public class ReceiptLedgerReportDetail {
+
+    /**
+     * 客户ID
+     */
+    @ApiModelProperty("客户ID")
+    private String customerId;
+
+    /**
+     * 客户名称
+     */
+    @ApiModelProperty("客户名称")
+    private String customerName;
+
+    /**
+     * 总欠款
+     */
+    @ApiModelProperty("总欠款")
+    private BigDecimal debtTotal;
+
+    /**
+     * 约定内欠款
+     */
+    @ApiModelProperty("约定内欠款")
+    private BigDecimal agreement;
+
+    /**
+     * 一次协调欠款
+     */
+    @ApiModelProperty("一次协调欠款")
+    private BigDecimal firstCoordinate;
+
+    /**
+     * 二次协调欠款
+     */
+    @ApiModelProperty("二次协调欠款")
+    private BigDecimal secondCoordinate;
+
+    /**
+     * 清欠阶段欠款金额
+     */
+    @ApiModelProperty("清欠阶段欠款金额")
+    private BigDecimal clearDebt;
+
+    /**
+     * 授信状态
+     */
+    @ApiModelProperty("授信状态")
+    private String creditStatus;
+
+    /**
+     * 授时状态
+     */
+    @ApiModelProperty("授时状态")
+    private String timingStatus;
+
+    /**
+     * 待交付订单数量
+     */
+    @ApiModelProperty("授时状态")
+    private Integer waitDeliveredOrder;
+}

@@ -2,6 +2,7 @@ package com.lframework.xingyun.sc.controller.ledger;
 
 import com.lframework.xingyun.sc.bo.ledger.receipt.GetReceiptLedgerInfoBo;
 import com.lframework.xingyun.sc.bo.ledger.receipt.QueryReceiptLedgerInfoBo;
+import com.lframework.xingyun.sc.bo.ledger.receipt.ReceiptLedgerReportBo;
 import com.lframework.xingyun.sc.utils.CommonUtil;
 import com.lframework.xingyun.sc.vo.ledger.receipt.QueryReceiptLedgerInfoVo;
 import com.lframework.xingyun.sc.service.ledger.ReceiptLedgerInfoService;
@@ -129,4 +130,16 @@ public class ReceiptLedgerInfoController extends DefaultBaseController {
         receiptLedgerInfoService.deleteById(id);
         return InvokeResultBuilder.success();
     }
+
+
+    /**
+     * 台账报表
+     */
+    @ApiOperation("台账报表")
+    @HasPermission({"account-manage:ledger-detail:query"})
+    @GetMapping("/report")
+    public InvokeResult<PageResult<ReceiptLedgerReportBo>> report(@Valid QueryReceiptLedgerInfoVo vo) {
+        PageResult<ReceiptLedgerReportBo> pageResult = receiptLedgerInfoService.report(getPageIndex(vo), getPageSize(vo), vo);
+        return InvokeResultBuilder.success(pageResult);
+    }
 }

@@ -13,6 +13,8 @@ import com.lframework.xingyun.basedata.entity.Customer;
 import com.lframework.xingyun.basedata.entity.CustomerShort;
 import com.lframework.xingyun.basedata.service.customer.CustomerService;
 import com.lframework.xingyun.basedata.service.customer.CustomerShortService;
+import com.lframework.xingyun.sc.bo.ledger.receipt.ReceiptLedgerReportBo;
+import com.lframework.xingyun.sc.bo.ledger.receipt.ReceiptLedgerReportDetail;
 import com.lframework.xingyun.sc.entity.*;
 import com.lframework.starter.web.core.impl.BaseMpServiceImpl;
 import com.lframework.starter.web.core.utils.PageResultUtil;
@@ -149,7 +151,7 @@ public class ReceiptLedgerInfoServiceImpl extends BaseMpServiceImpl<ReceiptLedge
             throw new DefaultClientException("应收款台账明细不存在！");
         }
         // 获取欠款状态
-        String settlementStatus = getSettlementStatus(data.getEndAccountReceivable(), data.getProcessedDate());
+        String settlementStatus = getSettlementStatus(data.getEndAccountReceivable(), vo.getProcessedDate());
         LambdaUpdateWrapper<ReceiptLedgerInfo> updateWrapper = Wrappers.lambdaUpdate(ReceiptLedgerInfo.class)
                 .set(ReceiptLedgerInfo::getDescription, StringUtil.isBlank(vo.getDescription()) ? null : vo.getDescription())
                 .set(ReceiptLedgerInfo::getProcessedDate, vo.getProcessedDate() == null ? null : vo.getProcessedDate())
@@ -369,6 +371,107 @@ public class ReceiptLedgerInfoServiceImpl extends BaseMpServiceImpl<ReceiptLedge
         getBaseMapper().batchAdd(dataList);
     }
 
+    @Override
+    public PageResult<ReceiptLedgerReportBo> report(Integer pageIndex, Integer pageSize, QueryReceiptLedgerInfoVo vo) {
+        Assert.greaterThanZero(pageIndex);
+        Assert.greaterThanZero(pageSize);
+        // 开启分页
+        PageHelperUtil.startPage(pageIndex, pageSize);
+        List<ReceiptLedgerReportBo> dataList = getBaseMapper().report(vo);
+        PageResult<ReceiptLedgerReportBo> result = PageResultUtil.convert(new PageInfo<>(dataList));
+        if (CollectionUtils.isEmpty(dataList)) {
+            return result;
+        }
+        List<String> shortNames = dataList.stream().map(ReceiptLedgerReportBo::getCustomerShortName).distinct().collect(Collectors.toList());
+        // 只统计约定内、一次、二次协调、清欠阶段
+        List<String> debtStatusList = new ArrayList<>();
+        debtStatusList.add("AGREEMENT");
+        debtStatusList.add("FIRST_COORDINATE");
+        debtStatusList.add("SECOND_COORDINATE");
+        debtStatusList.add("CLEAR_DEBTS");
+        List<Map<String, Object>> debtAmountList = getBaseMapper().statisticsDeptByShortName(shortNames, debtStatusList);
+        if (CollectionUtils.isEmpty(debtAmountList)) {
+            return result;
+        }
+        // 根据简称分组
+        Map<String, List<Map<String, Object>>> debtMap = new HashMap<>();
+        for (Map<String, Object> map : debtAmountList) {
+            String shortName = (String) map.get("short_name");
+            List<Map<String, Object>> list = debtMap.computeIfAbsent(shortName, k -> new ArrayList<>());
+            list.add(map);
+        }
+        for (ReceiptLedgerReportBo report : dataList) {
+            String customerShortName = report.getCustomerShortName();
+            List<Map<String, Object>> list = debtMap.get(customerShortName);
+            if (CollectionUtils.isEmpty(list)) {
+                continue;
+            }
+            BigDecimal debtTotal = BigDecimal.ZERO;
+            BigDecimal agreementTotal = BigDecimal.ZERO;
+            BigDecimal firstCoordinateTotal = BigDecimal.ZERO;
+            BigDecimal secondCoordinateTotal = BigDecimal.ZERO;
+            BigDecimal clearDebtTotal = BigDecimal.ZERO;
+            Integer waitDeliveredOrderTotal = 0;
+            Map<String, ReceiptLedgerReportDetail> reportDetailMap = new HashMap<>();
+            for (Map<String, Object> map : list) {
+                String customerName = (String) map.get("name");
+                String debtStatus = (String) map.get("debt_status");
+                BigDecimal debtAmount = (BigDecimal) map.get("debt_amount");
+
+                ReceiptLedgerReportDetail reportDetail = reportDetailMap.get(customerName);
+                if (reportDetail == null) {
+                    reportDetail = new ReceiptLedgerReportDetail();
+                }
+                reportDetail.setCustomerName(customerName);
+                if ("AGREEMENT".equals(debtStatus)) {
+                    reportDetail.setAgreement(debtAmount);
+                    agreementTotal = agreementTotal.add(debtAmount);
+                } else if ("FIRST_COORDINATE".equals(debtStatus)) {
+                    reportDetail.setFirstCoordinate(debtAmount);
+                    firstCoordinateTotal = firstCoordinateTotal.add(debtAmount);
+                } else if ("SECOND_COORDINATE".equals(debtStatus)) {
+                    reportDetail.setSecondCoordinate(debtAmount);
+                    secondCoordinateTotal = secondCoordinateTotal.add(debtAmount);
+                } else if ("CLEAR_DEBTS".equals(debtStatus)) {
+                    reportDetail.setClearDebt(debtAmount);
+                    clearDebtTotal = clearDebtTotal.add(debtAmount);
+                }
+                debtTotal = debtTotal.add(debtAmount);
+
+                reportDetailMap.put(reportDetail.getCustomerName(), reportDetail);
+            }
+            List<ReceiptLedgerReportDetail> details = new ArrayList<>(reportDetailMap.values());
+            for (ReceiptLedgerReportDetail detail : details) {
+                BigDecimal total = getDebtTotal(detail);
+                detail.setDebtTotal(total);
+            }
+            report.setDetailList(details);
+
+            report.setDebtTotal(debtTotal);
+            report.setAgreementTotal(agreementTotal);
+            report.setFirstCoordinateTotal(firstCoordinateTotal);
+            report.setSecondCoordinateTotal(secondCoordinateTotal);
+            report.setClearDebtTotal(clearDebtTotal);
+            report.setWaitDeliveredOrderTotal(waitDeliveredOrderTotal);
+        }
+        return result;
+    }
+
+
+    /**
+     * 获取总欠款
+     *
+     * @param detail    报表明细数据
+     * @return          BigDecimal
+     */
+    private static BigDecimal getDebtTotal(ReceiptLedgerReportDetail detail) {
+        BigDecimal agreement = detail.getAgreement() == null ? BigDecimal.ZERO : detail.getAgreement();
+        BigDecimal firstCoordinate = detail.getFirstCoordinate() == null ? BigDecimal.ZERO : detail.getFirstCoordinate();
+        BigDecimal secondCoordinate = detail.getSecondCoordinate()== null ? BigDecimal.ZERO : detail.getSecondCoordinate();
+        BigDecimal clearDebt = detail.getClearDebt() == null ? BigDecimal.ZERO : detail.getClearDebt();
+
+        return agreement.add(firstCoordinate).add(secondCoordinate).add(clearDebt);
+    }
 
 
     /**

 package com.lframework.xingyun.sc.mappers;
 
+import com.lframework.xingyun.sc.bo.ledger.receipt.ReceiptLedgerReportBo;
 import com.lframework.xingyun.sc.entity.ReceiptLedgerInfo;
 import com.lframework.starter.web.core.mapper.BaseMapper;
 import com.lframework.xingyun.sc.vo.ledger.receipt.QueryReceiptLedgerInfoVo;
 import org.apache.ibatis.annotations.Param;
 
 import java.util.List;
+import java.util.Map;
 
 /**
  * <p>
@@ -30,4 +32,20 @@ public interface ReceiptLedgerInfoMapper extends BaseMapper<ReceiptLedgerInfo> {
      * @param dataList  数据实体
      */
     void batchAdd(List<ReceiptLedgerInfo> dataList);
+
+    /**
+     * 报表统计
+     *
+     * @param vo    查询条件
+     * @return      List<ReceiptLedgerReportBo>
+     */
+    List<ReceiptLedgerReportBo> report(@Param("vo") QueryReceiptLedgerInfoVo vo);
+
+    /**
+     * 根据客户简称统计欠款金额
+     *
+     * @param shortNames    客户简称
+     * @return              List<Map<String, BigDecimal>>
+     */
+    List<Map<String, Object>> statisticsDeptByShortName(@Param("shortNames") List<String> shortNames, @Param("debtStatusList") List<String> debtStatusList);
 }

 package com.lframework.xingyun.sc.service.ledger;
 
+import com.lframework.xingyun.sc.bo.ledger.receipt.ReceiptLedgerReportBo;
 import com.lframework.xingyun.sc.entity.ShipmentsOrderInfo;
 import com.lframework.xingyun.sc.vo.ledger.receipt.CreateReceiptLedgerInfoVo;
 import com.lframework.xingyun.sc.vo.ledger.receipt.QueryReceiptLedgerInfoVo;
@@ -80,4 +81,12 @@ public interface ReceiptLedgerInfoService extends BaseMpService<ReceiptLedgerInf
      * @param orderInfoList 发货单数据
      */
     void generateLedgerInfo(List<ShipmentsOrderInfo> orderInfoList);
+
+    /**
+     * 报表统计
+     *
+     * @param vo    查询条件
+     * @return      PageResult<ReceiptLedgerReportBo>
+     */
+    PageResult<ReceiptLedgerReportBo> report(Integer pageIndex, Integer pageSize, QueryReceiptLedgerInfoVo vo);
 }

@@ -192,4 +192,39 @@
             )
         </foreach>
     </insert>
+
+    <select id="report" resultType="com.lframework.xingyun.sc.bo.ledger.receipt.ReceiptLedgerReportBo">
+        select tb.short_name as customer_short_name,
+               tb.type,
+               tb.dept_id,
+               d.name as dept_name,
+               tb.region,
+               r.name as region_name,
+               max(cc.company_credit_limit) as quota
+        from base_data_customer_short tb
+        left join sys_dept d on tb.dept_id = d.id
+        left join sys_dept r on tb.region = r.id
+        left join customer_credit cc on tb.customer_id = cc.company_id
+        group by tb.short_name,tb.type,tb.dept_id,tb.region
+    </select>
+
+    <select id="statisticsDeptByShortName" resultType="java.util.Map">
+        select c.name,
+               cs.short_name,
+               tb.debt_status,
+               sum(tb.end_account_receivable) as debt_amount
+        from receipt_ledger_info tb
+        inner join base_data_customer_short cs on tb.customer_id = cs.customer_id
+        inner join base_data_customer c on tb.customer_id = c.id
+        where cs.short_name in
+        <foreach collection="shortNames" open="(" separator="," close=")" item="item">
+            #{item}
+        </foreach>
+        and tb.debt_status in
+        <foreach collection="debtStatusList" open="(" separator="," close=")" item="item">
+            #{item}
+        </foreach>
+        and tb.debt_status is not null
+        group by c.name,cs.short_name,tb.debt_status
+    </select>
 </mapper>