采购：业务员报价看板-当日成交按区域、品种维度统计

@@ -6,6 +6,8 @@ import com.lframework.starter.web.core.components.resp.InvokeResult;
 import com.lframework.starter.web.core.components.resp.InvokeResultBuilder;
 import com.lframework.starter.web.core.components.resp.PageResult;
 import com.lframework.starter.web.core.controller.DefaultBaseController;
+import com.lframework.xingyun.sc.procurement.dto.quotation.SalesmanQuotationDealProductSummaryDto;
+import com.lframework.xingyun.sc.procurement.dto.quotation.SalesmanQuotationDealRegionSummaryDto;
 import com.lframework.xingyun.sc.procurement.entity.SalesmanQuotation;
 import com.lframework.xingyun.sc.procurement.entity.SalesmanQuotationLine;
 import com.lframework.xingyun.sc.procurement.service.quotation.SalesmanQuotationLineService;
@@ -146,4 +148,20 @@ public class SalesmanQuotationController extends DefaultBaseController {
         List<SalesmanQuotationLine> salesmanQuotationLineList = salesmanQuotationLineService.queryCurrentDayList(today, "DEAL_CLOSED");
         return InvokeResultBuilder.success(salesmanQuotationLineList);
     }
+
+    @ApiOperation("当日已成交按区域汇总")
+    @GetMapping("/statistics/dealClosed/region")
+    public InvokeResult<List<SalesmanQuotationDealRegionSummaryDto>> statDealClosedByRegion() {
+        LocalDate today = LocalDate.now();
+        return InvokeResultBuilder.success(
+                salesmanQuotationLineService.statCurrentDayDealClosedByRegion(today));
+    }
+
+    @ApiOperation("当日已成交按品种汇总")
+    @GetMapping("/statistics/dealClosed/product")
+    public InvokeResult<List<SalesmanQuotationDealProductSummaryDto>> statDealClosedByProduct() {
+        LocalDate today = LocalDate.now();
+        return InvokeResultBuilder.success(
+                salesmanQuotationLineService.statCurrentDayDealClosedByProduct(today));
+    }
 }

+package com.lframework.xingyun.sc.procurement.dto.quotation;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+import lombok.Data;
+
+@Data
+public class SalesmanQuotationDealProductSummaryDto implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    private String productId;
+
+    private String productName;
+
+    private BigDecimal quantity;
+
+    private BigDecimal price;
+}
+

+package com.lframework.xingyun.sc.procurement.dto.quotation;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+import lombok.Data;
+
+@Data
+public class SalesmanQuotationDealRegionSummaryDto implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    private String regionId;
+
+    private String regionName;
+
+    private BigDecimal quantity;
+}
+

@@ -9,6 +9,8 @@ import com.lframework.starter.web.core.impl.BaseMpServiceImpl;
 import com.lframework.starter.web.core.utils.IdUtil;
 import com.lframework.starter.web.core.utils.OpLogUtil;
 import com.lframework.starter.web.inner.components.oplog.OtherOpLogType;
+import com.lframework.xingyun.sc.procurement.dto.quotation.SalesmanQuotationDealProductSummaryDto;
+import com.lframework.xingyun.sc.procurement.dto.quotation.SalesmanQuotationDealRegionSummaryDto;
 import com.lframework.xingyun.sc.procurement.entity.SalesmanQuotationLine;
 import com.lframework.xingyun.sc.procurement.mappers.quotation.SalesmanQuotationLineMapper;
 import com.lframework.xingyun.sc.procurement.service.quotation.SalesmanQuotationLineService;
@@ -53,6 +55,28 @@ public class SalesmanQuotationLineServiceImpl
     }
 
     /**
+     * 查询当日业务报价成交区域汇总
+     *
+     * @param day 日期
+     * @return 业务员报价区域汇总列表
+     */
+    @Override
+    public List<SalesmanQuotationDealRegionSummaryDto> statCurrentDayDealClosedByRegion(LocalDate day) {
+        return getBaseMapper().statCurrentDayDealClosedByRegion(day);
+    }
+
+    /**
+     * 查询当日业务报价成交品种汇总
+     *
+     * @param day 日期
+     * @return 业务员报价品种汇总列表
+     */
+    @Override
+    public List<SalesmanQuotationDealProductSummaryDto> statCurrentDayDealClosedByProduct(LocalDate day) {
+        return getBaseMapper().statCurrentDayDealClosedByProduct(day);
+    }
+
+    /**
      * 根据ID查询
      *
      * @param id 主键ID

 package com.lframework.xingyun.sc.procurement.mappers.quotation;
 
 import com.lframework.starter.web.core.mapper.BaseMapper;
+import com.lframework.xingyun.sc.procurement.dto.quotation.SalesmanQuotationDealProductSummaryDto;
+import com.lframework.xingyun.sc.procurement.dto.quotation.SalesmanQuotationDealRegionSummaryDto;
 import com.lframework.xingyun.sc.procurement.entity.SalesmanQuotationLine;
 import com.lframework.xingyun.sc.procurement.vo.quotation.QuerySalesmanQuotationLineVo;
 import java.time.LocalDate;
@@ -27,4 +29,20 @@ public interface SalesmanQuotationLineMapper extends BaseMapper<SalesmanQuotatio
      * @return 业务员报价明细表列表
      */
     List<SalesmanQuotationLine> queryCurrentDayList(@Param("day") LocalDate day, @Param("status") String status);
+
+    /**
+     * 查询当日业务报价成交区域汇总
+     *
+     * @param day 日期
+     * @return 业务员报价区域汇总列表
+     */
+    List<SalesmanQuotationDealRegionSummaryDto> statCurrentDayDealClosedByRegion(@Param("day") LocalDate day);
+
+    /**
+     * 查询当日业务报价成交品种汇总
+     *
+     * @param day 日期
+     * @return 业务员报价品种汇总列表
+     */
+    List<SalesmanQuotationDealProductSummaryDto> statCurrentDayDealClosedByProduct(@Param("day") LocalDate day);
 }

 package com.lframework.xingyun.sc.procurement.service.quotation;
 
 import com.lframework.starter.web.core.service.BaseMpService;
+import com.lframework.xingyun.sc.procurement.dto.quotation.SalesmanQuotationDealProductSummaryDto;
+import com.lframework.xingyun.sc.procurement.dto.quotation.SalesmanQuotationDealRegionSummaryDto;
 import com.lframework.xingyun.sc.procurement.entity.SalesmanQuotationLine;
 import com.lframework.xingyun.sc.procurement.vo.quotation.CreateSalesmanQuotationLineVo;
 import com.lframework.xingyun.sc.procurement.vo.quotation.QuerySalesmanQuotationLineVo;
@@ -30,6 +32,22 @@ public interface SalesmanQuotationLineService extends BaseMpService<SalesmanQuot
     List<SalesmanQuotationLine> queryCurrentDayList(LocalDate day, String status);
 
     /**
+     * 查询当日业务报价成交区域汇总
+     *
+     * @param day 日期
+     * @return 业务员报价区域汇总列表
+     */
+    List<SalesmanQuotationDealRegionSummaryDto> statCurrentDayDealClosedByRegion(LocalDate day);
+
+    /**
+     * 查询当日业务报价成交品种汇总
+     *
+     * @param day 日期
+     * @return 业务员报价品种汇总列表
+     */
+    List<SalesmanQuotationDealProductSummaryDto> statCurrentDayDealClosedByProduct(LocalDate day);
+
+    /**
      * 根据ID查询
      *
      * @param id 主键ID

@@ -94,4 +94,39 @@
         </where>
         ORDER BY tb.create_time DESC, tb.quotation_id DESC
     </select>
+
+    <select id="statCurrentDayDealClosedByRegion"
+            resultType="com.lframework.xingyun.sc.procurement.dto.quotation.SalesmanQuotationDealRegionSummaryDto">
+        SELECT
+            sq.region AS regionId,
+            sd1.name AS regionName,
+            SUM(tb.quantity) AS quantity
+        FROM procurement_salesman_quotation_line tb
+        INNER JOIN procurement_salesman_quotation sq ON sq.id = tb.quotation_id
+        LEFT JOIN sys_dept sd1 ON sd1.id = sq.region
+        <where>
+            DATE(sq.create_time) = #{day}
+            AND sq.status = 'DEAL_CLOSED'
+        </where>
+        GROUP BY sq.region, sd1.name
+        ORDER BY quantity DESC
+    </select>
+
+    <select id="statCurrentDayDealClosedByProduct"
+            resultType="com.lframework.xingyun.sc.procurement.dto.quotation.SalesmanQuotationDealProductSummaryDto">
+        SELECT
+            tb.product_id AS productId,
+            br.product_name AS productName,
+            SUM(tb.quantity) AS quantity,
+            (SUM(tb.quantity * tb.purchase_price) / NULLIF(SUM(tb.quantity), 0)) AS price
+        FROM procurement_salesman_quotation_line tb
+        INNER JOIN procurement_salesman_quotation sq ON sq.id = tb.quotation_id
+        LEFT JOIN base_data_breed_relationship br ON br.id = tb.product_id
+        <where>
+            DATE(sq.create_time) = #{day}
+            AND sq.status = 'DEAL_CLOSED'
+        </where>
+        GROUP BY tb.product_id, br.product_name
+        ORDER BY quantity DESC
+    </select>
 </mapper>