报表：各办事处月度统计梳理

+package com.lframework.xingyun.sc.bo.statistics.shipmentQuantity;
+
+import com.lframework.xingyun.sc.dto.statistics.ShipmentQuantityStatisticsDto;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.math.BigDecimal;
+import java.time.LocalDate;
+
+@Data
+public class QueryShipmentQuantityStatisticsBo {
+
+    public QueryShipmentQuantityStatisticsBo(ShipmentQuantityStatisticsDto dto) {
+        this.shipmentDate = dto.getShipmentDate();
+        this.deptName = dto.getDeptName();
+        this.workshopName = dto.getWorkshopName();
+        this.shipmentQuantity = dto.getShipmentQuantity();
+    }
+
+    @ApiModelProperty("发货日期")
+    private LocalDate shipmentDate;
+
+    @ApiModelProperty("办事处")
+    private String deptName;
+
+    @ApiModelProperty("分厂")
+    private String workshopName;
+
+    @ApiModelProperty("发货数量")
+    private BigDecimal shipmentQuantity;
+}

+package com.lframework.xingyun.sc.controller.statistics;
+
+import com.lframework.starter.mq.core.utils.ExportTaskUtil;
+import com.lframework.starter.web.core.annotations.security.HasPermission;
+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.starter.web.core.utils.PageResultUtil;
+import com.lframework.xingyun.sc.bo.statistics.shipmentQuantity.QueryShipmentQuantityStatisticsBo;
+import com.lframework.xingyun.sc.dto.statistics.ShipmentQuantityStatisticsDto;
+import com.lframework.xingyun.sc.enums.ExportType;
+import com.lframework.xingyun.sc.excel.statistics.ShipmentQuantityStatisticsExportTaskWorker;
+import com.lframework.xingyun.sc.service.statistics.ShipmentQuantityStatisticsService;
+import com.lframework.xingyun.sc.vo.statistics.shipmentQuantity.QueryShipmentQuantityStatisticsVo;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.http.MediaType;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.annotation.Resource;
+import javax.validation.Valid;
+import java.util.List;
+import java.util.stream.Collectors;
+
+@Api(tags = "发货数量统计")
+@Validated
+@RestController
+@RequestMapping("/statistics/shipmentQuantity")
+public class ShipmentQuantityStatisticsController extends DefaultBaseController {
+
+    @Resource
+    private ShipmentQuantityStatisticsService shipmentQuantityStatisticsService;
+
+    @ApiOperation("查询列表")
+    @HasPermission({"statistical-report:dept-order-detail:query"})
+    @GetMapping("/query")
+    public InvokeResult<PageResult<QueryShipmentQuantityStatisticsBo>> query(@Valid QueryShipmentQuantityStatisticsVo vo) {
+
+        PageResult<ShipmentQuantityStatisticsDto> pageResult = shipmentQuantityStatisticsService.query(getPageIndex(vo), getPageSize(vo), vo);
+        List<QueryShipmentQuantityStatisticsBo> results = null;
+        if (pageResult.getDatas() != null && !pageResult.getDatas().isEmpty()) {
+            results = pageResult.getDatas().stream().map(QueryShipmentQuantityStatisticsBo::new).collect(Collectors.toList());
+        }
+        return InvokeResultBuilder.success(PageResultUtil.rebuild(pageResult, results));
+    }
+
+    @ApiOperation("发货数量统计导出")
+    @HasPermission({"statistical-report:dept-order-detail:export"})
+    @PostMapping(value = "/export", consumes = MediaType.APPLICATION_JSON_VALUE)
+    public InvokeResult<Void> exportJson(@Valid @RequestBody QueryShipmentQuantityStatisticsVo vo) {
+        vo.setExportType(ExportType.SHIPMENT_QUANTITY_REPORT.getCode());
+        ExportTaskUtil.exportTask("发货数量统计报表", ShipmentQuantityStatisticsExportTaskWorker.class, vo);
+        return InvokeResultBuilder.success();
+    }
+
+}

+package com.lframework.xingyun.sc.dto.statistics;
+
+import lombok.Data;
+
+import java.time.LocalDate;
+
+@Data
+public class ShipmentQuantityStatisticsDateRangeDto {
+
+    private LocalDate startDate;
+
+    private LocalDate endDate;
+}

+package com.lframework.xingyun.sc.dto.statistics;
+
+import lombok.Data;
+
+import java.math.BigDecimal;
+import java.time.LocalDate;
+
+@Data
+public class ShipmentQuantityStatisticsDto {
+
+    private LocalDate shipmentDate;
+
+    private String deptId;
+
+    private String deptCode;
+
+    private String deptName;
+
+    private String workshopId;
+
+    private String workshopCode;
+
+    private String workshopName;
+
+    private BigDecimal shipmentQuantity;
+}

+package com.lframework.xingyun.sc.dto.statistics;
+
+import lombok.Data;
+
+import java.math.BigDecimal;
+import java.time.LocalDate;
+
+@Data
+public class ShipmentQuantityStatisticsInvalidDto {
+
+    private String orderId;
+
+    private String orderNo;
+
+    private String lineId;
+
+    private LocalDate shipmentDate;
+
+    private String deptId;
+
+    private String workshopId;
+
+    private BigDecimal quantity;
+}

@@ -11,6 +11,7 @@ public enum ExportType implements BaseEnum<String> {
     CONTRACT_FRAMEWORK("CONTRACT_FRAMEWORK", "合同框架"),
     RECEIVABLE_LEDGER_REPORT("RECEIVABLE_LEDGER_REPORT", "应收款台账报表"),
     SHIPMENT_DETAIL_REPORT("SHIPMENT_DETAIL_REPORT", "发货明细报表"),
+    SHIPMENT_QUANTITY_REPORT("SHIPMENT_QUANTITY_REPORT", "发货数量统计报表"),
     ORDER_DETAIL_REPORT("ORDER_DETAIL_REPORT", "订单明细报表"),
     ORDER_EXPORT_ZIP("ORDER_EXPORT_ZIP", "订货单信息"),
     QUALITY_ORDER_DETAIL_REPORT("QUALITY_ORDER_DETAIL_REPORT", "品质科订单明细报表"),

+package com.lframework.xingyun.sc.excel.statistics;
+
+import com.lframework.starter.common.utils.CollectionUtil;
+import com.lframework.starter.mq.core.components.export.ExportTaskWorker;
+import com.lframework.starter.web.core.components.resp.PageResult;
+import com.lframework.starter.web.core.utils.ApplicationUtil;
+import com.lframework.starter.web.core.utils.JsonUtil;
+import com.lframework.starter.web.core.utils.PageResultUtil;
+import com.lframework.xingyun.sc.bo.statistics.shipmentQuantity.QueryShipmentQuantityStatisticsBo;
+import com.lframework.xingyun.sc.dto.statistics.ShipmentQuantityStatisticsDto;
+import com.lframework.xingyun.sc.service.statistics.ShipmentQuantityStatisticsService;
+import com.lframework.xingyun.sc.vo.statistics.shipmentQuantity.QueryShipmentQuantityStatisticsVo;
+
+import java.time.ZoneId;
+import java.util.Date;
+import java.util.List;
+import java.util.stream.Collectors;
+
+public class ShipmentQuantityStatisticsExportTaskWorker implements
+        ExportTaskWorker<QueryShipmentQuantityStatisticsVo, QueryShipmentQuantityStatisticsBo, ShipmentQuantityStatisticsModel> {
+
+    @Override
+    public QueryShipmentQuantityStatisticsVo parseParams(String json) {
+        return JsonUtil.parseObject(json, QueryShipmentQuantityStatisticsVo.class);
+    }
+
+    @Override
+    public PageResult<QueryShipmentQuantityStatisticsBo> getDataList(int pageIndex, int pageSize,
+                                                                    QueryShipmentQuantityStatisticsVo params) {
+        ShipmentQuantityStatisticsService shipmentQuantityStatisticsService = ApplicationUtil.getBean(ShipmentQuantityStatisticsService.class);
+        PageResult<ShipmentQuantityStatisticsDto> pageResult = shipmentQuantityStatisticsService.query(pageIndex, pageSize, params);
+        List<QueryShipmentQuantityStatisticsBo> results = null;
+        if (!CollectionUtil.isEmpty(pageResult.getDatas())) {
+            results = pageResult.getDatas().stream().map(QueryShipmentQuantityStatisticsBo::new).collect(Collectors.toList());
+        }
+        return PageResultUtil.rebuild(pageResult, results);
+    }
+
+    @Override
+    public ShipmentQuantityStatisticsModel exportData(QueryShipmentQuantityStatisticsBo data) {
+        ShipmentQuantityStatisticsModel model = new ShipmentQuantityStatisticsModel();
+        if (data.getShipmentDate() != null) {
+            model.setShipmentDate(Date.from(data.getShipmentDate().atStartOfDay(ZoneId.systemDefault()).toInstant()));
+        }
+        model.setDeptName(data.getDeptName());
+        model.setWorkshopName(data.getWorkshopName());
+        model.setShipmentQuantity(data.getShipmentQuantity());
+        return model;
+    }
+
+    @Override
+    public Class<ShipmentQuantityStatisticsModel> getModelClass() {
+        return ShipmentQuantityStatisticsModel.class;
+    }
+}
+

+package com.lframework.xingyun.sc.excel.statistics;
+
+import com.alibaba.excel.annotation.ExcelProperty;
+import com.alibaba.excel.annotation.format.DateTimeFormat;
+import com.alibaba.excel.annotation.format.NumberFormat;
+import com.lframework.starter.web.core.components.excel.ExcelModel;
+import lombok.Data;
+
+import java.math.BigDecimal;
+import java.util.Date;
+
+@Data
+public class ShipmentQuantityStatisticsModel implements ExcelModel {
+
+    @ExcelProperty(value = "日期", index = 0)
+    @DateTimeFormat("yyyy-MM-dd")
+    private Date shipmentDate;
+
+    @ExcelProperty(value = "办事处", index = 1)
+    private String deptName;
+
+    @ExcelProperty(value = "分厂", index = 2)
+    private String workshopName;
+
+    @ExcelProperty(value = "发货数量", index = 3)
+    private BigDecimal shipmentQuantity;
+}

+package com.lframework.xingyun.sc.impl.statistics;
+
+import com.github.pagehelper.Page;
+import com.github.pagehelper.PageInfo;
+import com.lframework.starter.common.utils.Assert;
+import com.lframework.starter.common.utils.CollectionUtil;
+import com.lframework.starter.web.core.components.resp.PageResult;
+import com.lframework.starter.web.core.utils.PageResultUtil;
+import com.lframework.xingyun.sc.dto.statistics.ShipmentQuantityStatisticsDateRangeDto;
+import com.lframework.xingyun.sc.dto.statistics.ShipmentQuantityStatisticsDto;
+import com.lframework.xingyun.sc.dto.statistics.ShipmentQuantityStatisticsInvalidDto;
+import com.lframework.xingyun.sc.mappers.ShipmentQuantityStatisticsMapper;
+import com.lframework.xingyun.sc.service.statistics.ShipmentQuantityStatisticsService;
+import com.lframework.xingyun.sc.vo.statistics.shipmentQuantity.QueryShipmentQuantityStatisticsVo;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.math.BigDecimal;
+import java.time.LocalDate;
+import java.time.format.DateTimeFormatter;
+import java.util.ArrayList;
+import java.util.Comparator;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+@Slf4j
+@Service
+public class ShipmentQuantityStatisticsServiceImpl implements ShipmentQuantityStatisticsService {
+
+    private static final DateTimeFormatter DATE_FORMATTER = DateTimeFormatter.ofPattern("yyyy-MM-dd");
+
+    @Resource
+    private ShipmentQuantityStatisticsMapper shipmentQuantityStatisticsMapper;
+
+    @Override
+    public PageResult<ShipmentQuantityStatisticsDto> query(Integer pageIndex, Integer pageSize,
+                                                          QueryShipmentQuantityStatisticsVo vo) {
+
+        Assert.greaterThanZero(pageIndex);
+        Assert.greaterThanZero(pageSize);
+
+        logInvalid(vo);
+
+        List<ShipmentQuantityStatisticsDto> fullList = buildFilledList(vo);
+        long total = fullList.size();
+
+        int fromIndex = (pageIndex - 1) * pageSize;
+        List<ShipmentQuantityStatisticsDto> pageDatas;
+        if (fromIndex >= total) {
+            pageDatas = new ArrayList<>();
+        } else {
+            int toIndex = (int) Math.min(fromIndex + pageSize, total);
+            pageDatas = fullList.subList(fromIndex, toIndex);
+        }
+
+        Page<ShipmentQuantityStatisticsDto> page = new Page<>(pageIndex, pageSize);
+        page.setTotal(total);
+        page.addAll(pageDatas);
+        return PageResultUtil.convert(new PageInfo<>(page));
+    }
+
+    @Override
+    public List<ShipmentQuantityStatisticsDto> query(QueryShipmentQuantityStatisticsVo vo) {
+        logInvalid(vo);
+        return buildFilledList(vo);
+    }
+
+    private void logInvalid(QueryShipmentQuantityStatisticsVo vo) {
+        List<ShipmentQuantityStatisticsInvalidDto> invalidList = shipmentQuantityStatisticsMapper.queryInvalid(vo);
+        if (CollectionUtil.isEmpty(invalidList)) {
+            return;
+        }
+
+        String invalidMsg = invalidList.stream()
+                .map(this::formatInvalid)
+                .collect(Collectors.joining("; "));
+        log.error("发货数量统计：检测到核心字段缺失的异常记录，已拦截不参与统计。{}", invalidMsg);
+    }
+
+    private String formatInvalid(ShipmentQuantityStatisticsInvalidDto dto) {
+        StringBuilder sb = new StringBuilder();
+        sb.append("orderNo=").append(dto.getOrderNo())
+                .append(", lineId=").append(dto.getLineId());
+        sb.append(", missing=");
+        boolean has = false;
+        if (dto.getShipmentDate() == null) {
+            sb.append("shipmentDate");
+            has = true;
+        }
+        if (dto.getDeptId() == null || dto.getDeptId().isEmpty()) {
+            if (has) sb.append("|");
+            sb.append("dept");
+            has = true;
+        }
+        if (dto.getWorkshopId() == null || dto.getWorkshopId().isEmpty()) {
+            if (has) sb.append("|");
+            sb.append("workshop");
+            has = true;
+        }
+        if (dto.getQuantity() == null) {
+            if (has) sb.append("|");
+            sb.append("quantity");
+        }
+        return sb.toString();
+    }
+
+    private List<ShipmentQuantityStatisticsDto> buildFilledList(QueryShipmentQuantityStatisticsVo vo) {
+        ShipmentQuantityStatisticsDateRangeDto dateRange = shipmentQuantityStatisticsMapper.queryDateRange(vo);
+        if (dateRange == null || dateRange.getStartDate() == null || dateRange.getEndDate() == null) {
+            return new ArrayList<>();
+        }
+
+        LocalDate startDate = parseOrDefault(vo.getShipmentDateStart(), dateRange.getStartDate());
+        LocalDate endDateDefault = dateRange.getEndDate();
+        LocalDate today = LocalDate.now();
+        if (endDateDefault.isBefore(today)) {
+            endDateDefault = today;
+        }
+        LocalDate endDate = parseOrDefault(vo.getShipmentDateEnd(), endDateDefault);
+        if (startDate == null || endDate == null || endDate.isBefore(startDate)) {
+            return new ArrayList<>();
+        }
+
+        QueryShipmentQuantityStatisticsVo queryVo = new QueryShipmentQuantityStatisticsVo();
+        queryVo.setDeptId(vo.getDeptId());
+        queryVo.setWorkshopId(vo.getWorkshopId());
+        queryVo.setShipmentDateStart(startDate.format(DATE_FORMATTER));
+        queryVo.setShipmentDateEnd(endDate.format(DATE_FORMATTER));
+
+        List<ShipmentQuantityStatisticsDto> aggList = shipmentQuantityStatisticsMapper.query(queryVo);
+        List<ShipmentQuantityStatisticsDto> deptList;
+        if (StringUtils.isNotBlank(vo.getDeptId())) {
+            ShipmentQuantityStatisticsDto dept = shipmentQuantityStatisticsMapper.queryDeptDimById(vo.getDeptId());
+            deptList = new ArrayList<>();
+            if (dept != null) {
+                deptList.add(dept);
+            }
+        } else {
+            List<String> deptCodes = new ArrayList<>();
+            deptCodes.add("BF");
+            deptCodes.add("CZ");
+            deptCodes.add("DG");
+            deptCodes.add("FS");
+            deptCodes.add("NB");
+            deptCodes.add("SZ");
+            deptCodes.add("WZ");
+            deptCodes.add("ZT");
+            deptCodes.add("WM");
+            deptList = shipmentQuantityStatisticsMapper.queryDeptDimByCodes(deptCodes);
+            if (deptList == null) {
+                deptList = new ArrayList<>();
+            }
+        }
+
+        if (CollectionUtil.isEmpty(deptList)) {
+            return new ArrayList<>();
+        }
+
+        List<ShipmentQuantityStatisticsDto> workshopList;
+        if (StringUtils.isNotBlank(vo.getWorkshopId())) {
+            ShipmentQuantityStatisticsDto workshop = shipmentQuantityStatisticsMapper.queryWorkshopDimById(vo.getWorkshopId());
+            workshopList = new ArrayList<>();
+            if (workshop != null) {
+                workshopList.add(workshop);
+            }
+        } else {
+            List<String> workshopCodes = new ArrayList<>();
+            workshopCodes.add("yfc");
+            workshopCodes.add("efc");
+            workshopCodes.add("sfc");
+            workshopCodes.add("ztfc");
+            workshopList = shipmentQuantityStatisticsMapper.queryWorkshopDimByCodes(workshopCodes);
+            if (workshopList == null) {
+                workshopList = new ArrayList<>();
+            }
+        }
+
+        if (CollectionUtil.isEmpty(workshopList)) {
+            return new ArrayList<>();
+        }
+
+        if (CollectionUtil.isEmpty(aggList)) {
+            aggList = new ArrayList<>();
+        }
+
+        Map<String, BigDecimal> quantityMap = aggList.stream()
+                .filter(d -> d.getShipmentDate() != null)
+                .filter(d -> StringUtils.isNotBlank(d.getDeptId()))
+                .filter(d -> StringUtils.isNotBlank(d.getWorkshopId()))
+                .collect(Collectors.toMap(
+                        d -> buildKey(d.getShipmentDate(), d.getDeptId(), d.getWorkshopId()),
+                        d -> d.getShipmentQuantity() == null ? BigDecimal.ZERO : d.getShipmentQuantity(),
+                        BigDecimal::add
+                ));
+
+        List<ShipmentQuantityStatisticsDto> results = new ArrayList<>();
+        for (LocalDate date = endDate; !date.isBefore(startDate); date = date.minusDays(1)) {
+            for (ShipmentQuantityStatisticsDto w : workshopList) {
+                for (ShipmentQuantityStatisticsDto dept : deptList) {
+                    ShipmentQuantityStatisticsDto row = new ShipmentQuantityStatisticsDto();
+                    row.setShipmentDate(date);
+                    row.setDeptId(dept.getDeptId());
+                    row.setDeptName(dept.getDeptName());
+                    row.setWorkshopId(w.getWorkshopId());
+                    row.setWorkshopCode(w.getWorkshopCode());
+                    row.setWorkshopName(w.getWorkshopName());
+                    BigDecimal qty = quantityMap.get(buildKey(date, dept.getDeptId(), w.getWorkshopId()));
+                    row.setShipmentQuantity(qty == null ? BigDecimal.ZERO : qty);
+                    results.add(row);
+                }
+            }
+        }
+
+        return results;
+    }
+
+    private static String buildKey(LocalDate date, String deptId, String workshopId) {
+        return date + "|" + deptId + "|" + workshopId;
+    }
+
+    private static LocalDate parseOrDefault(String dateStr, LocalDate defaultValue) {
+        if (StringUtils.isBlank(dateStr)) {
+            return defaultValue;
+        }
+        try {
+            return LocalDate.parse(dateStr, DATE_FORMATTER);
+        } catch (Exception e) {
+            return defaultValue;
+        }
+    }
+}

+package com.lframework.xingyun.sc.mappers;
+
+import com.lframework.starter.web.core.annotations.permission.DataPermission;
+import com.lframework.starter.web.core.annotations.permission.DataPermissions;
+import com.lframework.starter.web.inner.components.permission.OrderDataPermissionDataPermissionType;
+import com.lframework.xingyun.sc.dto.statistics.ShipmentQuantityStatisticsDateRangeDto;
+import com.lframework.xingyun.sc.dto.statistics.ShipmentQuantityStatisticsDto;
+import com.lframework.xingyun.sc.dto.statistics.ShipmentQuantityStatisticsInvalidDto;
+import com.lframework.xingyun.sc.vo.statistics.shipmentQuantity.QueryShipmentQuantityStatisticsVo;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+
+public interface ShipmentQuantityStatisticsMapper {
+    /**
+     * 查询列表
+     * 开启权限控制
+     *
+     * @param vo    查询条件
+     * @return      List<ShipmentQuantityStatisticsDto>
+     */
+    @DataPermissions(type = OrderDataPermissionDataPermissionType.class, value = {
+            @DataPermission(template = "order", alias = "t")
+    })
+    List<ShipmentQuantityStatisticsDto> query(@Param("vo") QueryShipmentQuantityStatisticsVo vo);
+
+    @DataPermissions(type = OrderDataPermissionDataPermissionType.class, value = {
+            @DataPermission(template = "order", alias = "t")
+    })
+    ShipmentQuantityStatisticsDateRangeDto queryDateRange(@Param("vo") QueryShipmentQuantityStatisticsVo vo);
+
+    List<ShipmentQuantityStatisticsDto> queryDeptDimByCodes(@Param("codes") List<String> codes);
+
+    ShipmentQuantityStatisticsDto queryDeptDimById(@Param("deptId") String deptId);
+
+    List<ShipmentQuantityStatisticsDto> queryWorkshopDimByCodes(@Param("codes") List<String> codes);
+
+    ShipmentQuantityStatisticsDto queryWorkshopDimById(@Param("workshopId") String workshopId);
+
+    List<ShipmentQuantityStatisticsInvalidDto> queryInvalid(@Param("vo") QueryShipmentQuantityStatisticsVo vo);
+}

+package com.lframework.xingyun.sc.service.statistics;
+
+import com.lframework.starter.web.core.components.resp.PageResult;
+import com.lframework.xingyun.sc.dto.statistics.ShipmentQuantityStatisticsDto;
+import com.lframework.xingyun.sc.vo.statistics.shipmentQuantity.QueryShipmentQuantityStatisticsVo;
+
+import java.util.List;
+
+public interface ShipmentQuantityStatisticsService {
+
+    PageResult<ShipmentQuantityStatisticsDto> query(Integer pageIndex, Integer pageSize, QueryShipmentQuantityStatisticsVo vo);
+
+    List<ShipmentQuantityStatisticsDto> query(QueryShipmentQuantityStatisticsVo vo);
+}

+package com.lframework.xingyun.sc.vo.statistics.shipmentQuantity;
+
+import com.lframework.starter.web.core.vo.BaseVo;
+import com.lframework.starter.web.core.vo.PageVo;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.io.Serializable;
+
+@Data
+public class QueryShipmentQuantityStatisticsVo extends PageVo implements BaseVo, Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @ApiModelProperty("发货日期开始")
+    private String shipmentDateStart;
+
+    @ApiModelProperty("发货日期结束")
+    private String shipmentDateEnd;
+
+    @ApiModelProperty("办事处ID")
+    private String deptId;
+
+    @ApiModelProperty("生产厂ID")
+    private String workshopId;
+
+    @ApiModelProperty("导出类型")
+    private String exportType;
+}

+<?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="com.lframework.xingyun.sc.mappers.ShipmentQuantityStatisticsMapper">
+
+    <resultMap id="ShipmentQuantityStatisticsDto" type="com.lframework.xingyun.sc.dto.statistics.ShipmentQuantityStatisticsDto">
+        <result column="shipment_date" property="shipmentDate"/>
+        <result column="dept_id" property="deptId"/>
+        <result column="dept_code" property="deptCode"/>
+        <result column="dept_name" property="deptName"/>
+        <result column="workshop_id" property="workshopId"/>
+        <result column="workshop_code" property="workshopCode"/>
+        <result column="workshop_name" property="workshopName"/>
+        <result column="shipment_quantity" property="shipmentQuantity"/>
+    </resultMap>
+
+    <resultMap id="ShipmentQuantityStatisticsDateRangeDto" type="com.lframework.xingyun.sc.dto.statistics.ShipmentQuantityStatisticsDateRangeDto">
+        <result column="start_date" property="startDate"/>
+        <result column="end_date" property="endDate"/>
+    </resultMap>
+
+    <resultMap id="ShipmentQuantityStatisticsInvalidDto" type="com.lframework.xingyun.sc.dto.statistics.ShipmentQuantityStatisticsInvalidDto">
+        <result column="order_id" property="orderId"/>
+        <result column="order_no" property="orderNo"/>
+        <result column="line_id" property="lineId"/>
+        <result column="shipment_date" property="shipmentDate"/>
+        <result column="dept_id" property="deptId"/>
+        <result column="workshop_id" property="workshopId"/>
+        <result column="quantity" property="quantity"/>
+    </resultMap>
+
+    <sql id="ShipmentQuantityStatistics_base_where">
+        o.type = 'PRODUCTION'
+        AND o.examine_status = 'PASS'
+        AND (o.status IS NULL OR o.status != 'CANCEL')
+        AND (ol.del_flag IS NULL OR ol.del_flag = 0)
+    </sql>
+
+    <select id="query" resultMap="ShipmentQuantityStatisticsDto">
+            SELECT
+                t.shipment_date,
+                t.dept_id,
+                t.dept_code,
+                t.dept_code,
+                t.dept_name,
+                t.workshop_id,
+                t.workshop_code,
+                t.shipment_quantity
+            FROM (
+                SELECT
+                    ol.delivery_date AS shipment_date,
+                    o.dept_id AS dept_id,
+                    sd.code AS dept_code,
+                    sd.name AS dept_name,
+                    o.workshop_id AS workshop_id,
+                    ws.code AS workshop_code,
+                    ws.name AS workshop_name,
+                    SUM(ol.quantity) AS shipment_quantity
+                FROM tbl_purchase_order_line ol
+                INNER JOIN purchase_order_info o ON o.id = ol.purchase_order_id
+                LEFT JOIN sys_dept sd ON sd.id = o.dept_id
+                LEFT JOIN base_data_workshop ws ON ws.id = o.workshop_id
+                WHERE
+                    <include refid="ShipmentQuantityStatistics_base_where"/>
+                    AND ol.delivery_date IS NOT NULL
+                    AND o.dept_id IS NOT NULL AND o.dept_id != ''
+                    AND o.workshop_id IS NOT NULL AND o.workshop_id != ''
+                    AND ol.quantity IS NOT NULL
+                    <if test="vo.shipmentDateStart != null and vo.shipmentDateStart != ''">
+                        AND ol.delivery_date <![CDATA[>=]]> #{vo.shipmentDateStart}
+                    </if>
+                    <if test="vo.shipmentDateEnd != null and vo.shipmentDateEnd != ''">
+                        AND ol.delivery_date <![CDATA[<=]]> #{vo.shipmentDateEnd}
+                    </if>
+                    <if test="vo.deptId != null and vo.deptId != ''">
+                        AND o.dept_id = #{vo.deptId}
+                    </if>
+                    <if test="vo.workshopId != null and vo.workshopId != ''">
+                        AND o.workshop_id = #{vo.workshopId}
+                    </if>
+                GROUP BY ol.delivery_date, o.dept_id, o.workshop_id
+            ) t
+        ORDER BY
+            t.shipment_date DESC,
+            CASE t.workshop_code
+                WHEN 'yfc' THEN 1
+                WHEN 'efc' THEN 2
+                WHEN 'sfc' THEN 3
+                WHEN 'ztfc' THEN 4
+                ELSE 99
+            END,
+            t.dept_name
+    </select>
+
+    <select id="queryDateRange" resultMap="ShipmentQuantityStatisticsDateRangeDto">
+        SELECT
+            MIN(t.shipment_date) AS start_date,
+            MAX(t.shipment_date) AS end_date
+        FROM (
+            SELECT
+                ol.delivery_date AS shipment_date,
+                o.dept_id AS dept_id,
+                o.workshop_id AS workshop_id
+            FROM tbl_purchase_order_line ol
+            INNER JOIN purchase_order_info o ON o.id = ol.purchase_order_id
+            WHERE
+                <include refid="ShipmentQuantityStatistics_base_where"/>
+                AND ol.delivery_date IS NOT NULL
+                AND o.dept_id IS NOT NULL AND o.dept_id != ''
+                AND o.workshop_id IS NOT NULL AND o.workshop_id != ''
+                AND ol.quantity IS NOT NULL
+                <if test="vo.deptId != null and vo.deptId != ''">
+                    AND o.dept_id = #{vo.deptId}
+                </if>
+                <if test="vo.workshopId != null and vo.workshopId != ''">
+                    AND o.workshop_id = #{vo.workshopId}
+                </if>
+        ) t
+    </select>
+
+    <select id="queryDeptDimByCodes" resultMap="ShipmentQuantityStatisticsDto">
+        SELECT
+            d.id AS dept_id,
+            d.code AS dept_code,
+            d.name AS dept_name
+        FROM sys_dept d
+        WHERE d.code IN
+        <foreach collection="codes" item="code" open="(" close=")" separator=",">
+            #{code}
+        </foreach>
+        ORDER BY
+            CASE d.code
+                WHEN 'BF' THEN 1
+                WHEN 'CZ' THEN 2
+                WHEN 'DG' THEN 3
+                WHEN 'FS' THEN 4
+                WHEN 'NB' THEN 5
+                WHEN 'SZ' THEN 6
+                WHEN 'WZ' THEN 7
+                WHEN 'ZT' THEN 8
+                WHEN 'WM' THEN 9
+                ELSE 99
+            END,
+            d.name
+    </select>
+
+    <select id="queryDeptDimById" resultMap="ShipmentQuantityStatisticsDto">
+        SELECT
+            d.id AS dept_id,
+            d.code AS dept_code,
+            d.name AS dept_name
+        FROM sys_dept d
+        WHERE d.id = #{deptId}
+    </select>
+
+    <select id="queryWorkshopDimByCodes" resultMap="ShipmentQuantityStatisticsDto">
+        SELECT
+            w.id AS workshop_id,
+            w.code AS workshop_code,
+            w.name AS workshop_name
+        FROM base_data_workshop w
+        WHERE w.code IN
+        <foreach collection="codes" item="code" open="(" close=")" separator=",">
+            #{code}
+        </foreach>
+        ORDER BY
+            CASE w.code
+                WHEN 'yfc' THEN 1
+                WHEN 'efc' THEN 2
+                WHEN 'sfc' THEN 3
+                WHEN 'ztfc' THEN 4
+                ELSE 99
+            END,
+            w.name
+    </select>
+
+    <select id="queryWorkshopDimById" resultMap="ShipmentQuantityStatisticsDto">
+        SELECT
+            w.id AS workshop_id,
+            w.code AS workshop_code,
+            w.name AS workshop_name
+        FROM base_data_workshop w
+        WHERE w.id = #{workshopId}
+    </select>
+
+    <select id="queryInvalid" resultMap="ShipmentQuantityStatisticsInvalidDto">
+        SELECT
+            t.order_id,
+            t.order_no,
+            t.line_id,
+            t.shipment_date,
+            t.dept_id,
+            t.workshop_id,
+            t.quantity
+        FROM (
+            SELECT
+                o.id AS order_id,
+                o.order_no AS order_no,
+                ol.id AS line_id,
+                ol.delivery_date AS shipment_date,
+                o.dept_id AS dept_id,
+                o.workshop_id AS workshop_id,
+                ol.quantity AS quantity,
+                o.create_time AS create_time
+            FROM tbl_purchase_order_line ol
+            INNER JOIN purchase_order_info o ON o.id = ol.purchase_order_id
+            WHERE
+                <include refid="ShipmentQuantityStatistics_base_where"/>
+                AND (
+                    ol.delivery_date IS NULL
+                    OR o.dept_id IS NULL OR o.dept_id = ''
+                    OR o.workshop_id IS NULL OR o.workshop_id = ''
+                    OR ol.quantity IS NULL
+                )
+                <if test="vo.shipmentDateStart != null and vo.shipmentDateStart != ''">
+                    AND (ol.delivery_date IS NULL OR ol.delivery_date <![CDATA[>=]]> #{vo.shipmentDateStart})
+                </if>
+                <if test="vo.shipmentDateEnd != null and vo.shipmentDateEnd != ''">
+                    AND (ol.delivery_date IS NULL OR ol.delivery_date <![CDATA[<=]]> #{vo.shipmentDateEnd})
+                </if>
+                <if test="vo.deptId != null and vo.deptId != ''">
+                    AND o.dept_id = #{vo.deptId}
+                </if>
+                <if test="vo.workshopId != null and vo.workshopId != ''">
+                    AND o.workshop_id = #{vo.workshopId}
+                </if>
+        ) t
+        ORDER BY t.create_time DESC
+        LIMIT 200
+    </select>
+</mapper>