报表：各行业月度统计梳理

+package com.lframework.xingyun.sc.bo.statistics.shipmentQuantityIndustry;
+
+import com.lframework.xingyun.sc.dto.statistics.ShipmentQuantityIndustryStatisticsDto;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.math.BigDecimal;
+import java.time.LocalDate;
+
+@Data
+public class QueryShipmentQuantityIndustryStatisticsBo {
+
+    public QueryShipmentQuantityIndustryStatisticsBo(ShipmentQuantityIndustryStatisticsDto dto) {
+        this.shipmentDate = dto.getShipmentDate();
+        this.industry = dto.getIndustry();
+        this.workshopName = dto.getWorkshopName();
+        this.shipmentQuantity = dto.getShipmentQuantity();
+    }
+
+    @ApiModelProperty("发货日期")
+    private LocalDate shipmentDate;
+
+    @ApiModelProperty("行业")
+    private String industry;
+
+    @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.shipmentQuantityIndustry.QueryShipmentQuantityIndustryStatisticsBo;
+import com.lframework.xingyun.sc.dto.statistics.ShipmentQuantityIndustryStatisticsDto;
+import com.lframework.xingyun.sc.enums.ExportType;
+import com.lframework.xingyun.sc.excel.statistics.ShipmentQuantityIndustryStatisticsExportTaskWorker;
+import com.lframework.xingyun.sc.service.statistics.ShipmentQuantityIndustryStatisticsService;
+import com.lframework.xingyun.sc.vo.statistics.shipmentQuantityIndustry.QueryShipmentQuantityIndustryStatisticsVo;
+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/shipmentQuantityIndustry")
+public class ShipmentQuantityIndustryStatisticsController extends DefaultBaseController {
+
+    @Resource
+    private ShipmentQuantityIndustryStatisticsService shipmentQuantityIndustryStatisticsService;
+
+    @ApiOperation("查询列表")
+    @HasPermission({"statistical-report:industry-order-detail:query"})
+    @GetMapping("/query")
+    public InvokeResult<PageResult<QueryShipmentQuantityIndustryStatisticsBo>> query(@Valid QueryShipmentQuantityIndustryStatisticsVo vo) {
+
+        PageResult<ShipmentQuantityIndustryStatisticsDto> pageResult =
+                shipmentQuantityIndustryStatisticsService.query(getPageIndex(vo), getPageSize(vo), vo);
+        List<QueryShipmentQuantityIndustryStatisticsBo> results = null;
+        if (pageResult.getDatas() != null && !pageResult.getDatas().isEmpty()) {
+            results = pageResult.getDatas().stream().map(QueryShipmentQuantityIndustryStatisticsBo::new).collect(Collectors.toList());
+        }
+        return InvokeResultBuilder.success(PageResultUtil.rebuild(pageResult, results));
+    }
+
+    @ApiOperation("各行业月度统计梳理导出")
+    @HasPermission({"statistical-report:industry-order-detail:export"})
+    @PostMapping(value = "/export", consumes = MediaType.APPLICATION_JSON_VALUE)
+    public InvokeResult<Void> exportJson(@Valid @RequestBody QueryShipmentQuantityIndustryStatisticsVo vo) {
+        vo.setExportType(ExportType.SHIPMENT_QUANTITY_INDUSTRY_REPORT.getCode());
+        ExportTaskUtil.exportTask("各行业月度统计梳理", ShipmentQuantityIndustryStatisticsExportTaskWorker.class, vo);
+        return InvokeResultBuilder.success();
+    }
+}

@@ -28,7 +28,7 @@ import javax.validation.Valid;
 import java.util.List;
 import java.util.stream.Collectors;
 
-@Api(tags = "发货数量统计")
+@Api(tags = "各办事处月度统计梳理")
 @Validated
 @RestController
 @RequestMapping("/statistics/shipmentQuantity")
@@ -50,12 +50,12 @@ public class ShipmentQuantityStatisticsController extends DefaultBaseController
         return InvokeResultBuilder.success(PageResultUtil.rebuild(pageResult, results));
     }
 
-    @ApiOperation("发货数量统计导出")
+    @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);
+        ExportTaskUtil.exportTask("各办事处月度统计梳理", ShipmentQuantityStatisticsExportTaskWorker.class, vo);
         return InvokeResultBuilder.success();
     }
 

+package com.lframework.xingyun.sc.dto.statistics;
+
+import lombok.Data;
+
+import java.math.BigDecimal;
+import java.time.LocalDate;
+
+@Data
+public class ShipmentQuantityIndustryStatisticsDto {
+
+    private LocalDate shipmentDate;
+
+    private String industry;
+
+    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 ShipmentQuantityIndustryStatisticsInvalidDto {
+
+    private String orderId;
+
+    private String orderNo;
+
+    private String lineId;
+
+    private LocalDate shipmentDate;
+
+    private String industry;
+
+    private String workshopId;
+
+    private BigDecimal quantity;
+}

@@ -11,7 +11,8 @@ 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", "发货数量统计报表"),
+    SHIPMENT_QUANTITY_REPORT("SHIPMENT_QUANTITY_REPORT", "各办事处月度统计梳理"),
+    SHIPMENT_QUANTITY_INDUSTRY_REPORT("SHIPMENT_QUANTITY_INDUSTRY_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.shipmentQuantityIndustry.QueryShipmentQuantityIndustryStatisticsBo;
+import com.lframework.xingyun.sc.dto.statistics.ShipmentQuantityIndustryStatisticsDto;
+import com.lframework.xingyun.sc.service.statistics.ShipmentQuantityIndustryStatisticsService;
+import com.lframework.xingyun.sc.vo.statistics.shipmentQuantityIndustry.QueryShipmentQuantityIndustryStatisticsVo;
+
+import java.time.ZoneId;
+import java.util.Date;
+import java.util.List;
+import java.util.stream.Collectors;
+
+public class ShipmentQuantityIndustryStatisticsExportTaskWorker implements
+        ExportTaskWorker<QueryShipmentQuantityIndustryStatisticsVo, QueryShipmentQuantityIndustryStatisticsBo, ShipmentQuantityIndustryStatisticsModel> {
+
+    @Override
+    public QueryShipmentQuantityIndustryStatisticsVo parseParams(String json) {
+        return JsonUtil.parseObject(json, QueryShipmentQuantityIndustryStatisticsVo.class);
+    }
+
+    @Override
+    public PageResult<QueryShipmentQuantityIndustryStatisticsBo> getDataList(int pageIndex, int pageSize,
+                                                                            QueryShipmentQuantityIndustryStatisticsVo params) {
+        ShipmentQuantityIndustryStatisticsService service = ApplicationUtil.getBean(ShipmentQuantityIndustryStatisticsService.class);
+        PageResult<ShipmentQuantityIndustryStatisticsDto> pageResult = service.query(pageIndex, pageSize, params);
+        List<QueryShipmentQuantityIndustryStatisticsBo> results = null;
+        if (!CollectionUtil.isEmpty(pageResult.getDatas())) {
+            results = pageResult.getDatas().stream().map(QueryShipmentQuantityIndustryStatisticsBo::new).collect(Collectors.toList());
+        }
+        return PageResultUtil.rebuild(pageResult, results);
+    }
+
+    @Override
+    public ShipmentQuantityIndustryStatisticsModel exportData(QueryShipmentQuantityIndustryStatisticsBo data) {
+        ShipmentQuantityIndustryStatisticsModel model = new ShipmentQuantityIndustryStatisticsModel();
+        if (data.getShipmentDate() != null) {
+            model.setShipmentDate(Date.from(data.getShipmentDate().atStartOfDay(ZoneId.systemDefault()).toInstant()));
+        }
+        model.setIndustry(data.getIndustry());
+        model.setWorkshopName(data.getWorkshopName());
+        model.setShipmentQuantity(data.getShipmentQuantity());
+        return model;
+    }
+
+    @Override
+    public Class<ShipmentQuantityIndustryStatisticsModel> getModelClass() {
+        return ShipmentQuantityIndustryStatisticsModel.class;
+    }
+}

+package com.lframework.xingyun.sc.excel.statistics;
+
+import com.alibaba.excel.annotation.ExcelProperty;
+import com.alibaba.excel.annotation.format.DateTimeFormat;
+import com.lframework.starter.web.core.components.excel.ExcelModel;
+import lombok.Data;
+
+import java.math.BigDecimal;
+import java.util.Date;
+
+@Data
+public class ShipmentQuantityIndustryStatisticsModel implements ExcelModel {
+
+    @ExcelProperty(value = "日期", index = 0)
+    @DateTimeFormat("yyyy/MM/dd")
+    private Date shipmentDate;
+
+    @ExcelProperty(value = "行业", index = 1)
+    private String industry;
+
+    @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.ShipmentQuantityIndustryStatisticsDto;
+import com.lframework.xingyun.sc.dto.statistics.ShipmentQuantityIndustryStatisticsInvalidDto;
+import com.lframework.xingyun.sc.dto.statistics.ShipmentQuantityStatisticsDateRangeDto;
+import com.lframework.xingyun.sc.mappers.ShipmentQuantityIndustryStatisticsMapper;
+import com.lframework.xingyun.sc.service.statistics.ShipmentQuantityIndustryStatisticsService;
+import com.lframework.xingyun.sc.vo.statistics.shipmentQuantityIndustry.QueryShipmentQuantityIndustryStatisticsVo;
+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.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+@Slf4j
+@Service
+public class ShipmentQuantityIndustryStatisticsServiceImpl implements ShipmentQuantityIndustryStatisticsService {
+
+    private static final DateTimeFormatter DATE_FORMATTER = DateTimeFormatter.ofPattern("yyyy-MM-dd");
+
+    @Resource
+    private ShipmentQuantityIndustryStatisticsMapper shipmentQuantityIndustryStatisticsMapper;
+
+    @Override
+    public PageResult<ShipmentQuantityIndustryStatisticsDto> query(Integer pageIndex, Integer pageSize,
+                                                                  QueryShipmentQuantityIndustryStatisticsVo vo) {
+
+        Assert.greaterThanZero(pageIndex);
+        Assert.greaterThanZero(pageSize);
+
+        logInvalid(vo);
+
+        List<ShipmentQuantityIndustryStatisticsDto> fullList = buildFilledList(vo);
+        long total = fullList.size();
+
+        int fromIndex = (pageIndex - 1) * pageSize;
+        List<ShipmentQuantityIndustryStatisticsDto> pageDatas;
+        if (fromIndex >= total) {
+            pageDatas = new ArrayList<>();
+        } else {
+            int toIndex = (int) Math.min(fromIndex + pageSize, total);
+            pageDatas = fullList.subList(fromIndex, toIndex);
+        }
+
+        Page<ShipmentQuantityIndustryStatisticsDto> page = new Page<>(pageIndex, pageSize);
+        page.setTotal(total);
+        page.addAll(pageDatas);
+        return PageResultUtil.convert(new PageInfo<>(page));
+    }
+
+    @Override
+    public List<ShipmentQuantityIndustryStatisticsDto> query(QueryShipmentQuantityIndustryStatisticsVo vo) {
+        logInvalid(vo);
+        return buildFilledList(vo);
+    }
+
+    private void logInvalid(QueryShipmentQuantityIndustryStatisticsVo vo) {
+        List<ShipmentQuantityIndustryStatisticsInvalidDto> invalidList = shipmentQuantityIndustryStatisticsMapper.queryInvalid(vo);
+        if (CollectionUtil.isEmpty(invalidList)) {
+            return;
+        }
+
+        String invalidMsg = invalidList.stream()
+                .map(this::formatInvalid)
+                .collect(Collectors.joining("; "));
+        log.error("发货数量统计(行业)：检测到核心字段缺失的异常记录，已拦截不参与统计。{}", invalidMsg);
+    }
+
+    private String formatInvalid(ShipmentQuantityIndustryStatisticsInvalidDto 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.getIndustry() == null || dto.getIndustry().isEmpty()) {
+            if (has) sb.append("|");
+            sb.append("industry");
+            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<ShipmentQuantityIndustryStatisticsDto> buildFilledList(QueryShipmentQuantityIndustryStatisticsVo vo) {
+        ShipmentQuantityStatisticsDateRangeDto dateRange = shipmentQuantityIndustryStatisticsMapper.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<>();
+        }
+
+        QueryShipmentQuantityIndustryStatisticsVo queryVo = new QueryShipmentQuantityIndustryStatisticsVo();
+        queryVo.setIndustry(vo.getIndustry());
+        queryVo.setWorkshopId(vo.getWorkshopId());
+        queryVo.setShipmentDateStart(startDate.format(DATE_FORMATTER));
+        queryVo.setShipmentDateEnd(endDate.format(DATE_FORMATTER));
+
+        List<ShipmentQuantityIndustryStatisticsDto> aggList = shipmentQuantityIndustryStatisticsMapper.query(queryVo);
+
+        List<String> industryList;
+        industryList = shipmentQuantityIndustryStatisticsMapper.queryIndustryDim(queryVo);
+        if (industryList == null) {
+            industryList = new ArrayList<>();
+        }
+
+        if (CollectionUtil.isEmpty(industryList)) {
+            return new ArrayList<>();
+        }
+
+        List<ShipmentQuantityIndustryStatisticsDto> workshopList;
+        if (StringUtils.isNotBlank(vo.getWorkshopId())) {
+            ShipmentQuantityIndustryStatisticsDto workshop = shipmentQuantityIndustryStatisticsMapper.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 = shipmentQuantityIndustryStatisticsMapper.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 = new HashMap<>();
+        for (ShipmentQuantityIndustryStatisticsDto d : aggList) {
+            if (d.getShipmentDate() == null) {
+                continue;
+            }
+            if (StringUtils.isBlank(d.getIndustry()) || StringUtils.isBlank(d.getWorkshopId())) {
+                continue;
+            }
+            BigDecimal qty = d.getShipmentQuantity() == null ? BigDecimal.ZERO : d.getShipmentQuantity();
+            String key = buildKey(d.getShipmentDate(), d.getIndustry(), d.getWorkshopId());
+            quantityMap.merge(key, qty, BigDecimal::add);
+        }
+
+        List<ShipmentQuantityIndustryStatisticsDto> results = new ArrayList<>();
+        for (LocalDate date = endDate; !date.isBefore(startDate); date = date.minusDays(1)) {
+            for (ShipmentQuantityIndustryStatisticsDto w : workshopList) {
+                for (String industry : industryList) {
+                    ShipmentQuantityIndustryStatisticsDto row = new ShipmentQuantityIndustryStatisticsDto();
+                    row.setShipmentDate(date);
+                    row.setIndustry(industry);
+                    row.setWorkshopId(w.getWorkshopId());
+                    row.setWorkshopCode(w.getWorkshopCode());
+                    row.setWorkshopName(w.getWorkshopName());
+                    BigDecimal qty = quantityMap.get(buildKey(date, industry, w.getWorkshopId()));
+                    row.setShipmentQuantity(qty == null ? BigDecimal.ZERO : qty);
+                    results.add(row);
+                }
+            }
+        }
+
+        return results;
+    }
+
+    private static String buildKey(LocalDate date, String industry, String workshopId) {
+        return date + "|" + industry + "|" + 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.ShipmentQuantityIndustryStatisticsDto;
+import com.lframework.xingyun.sc.dto.statistics.ShipmentQuantityIndustryStatisticsInvalidDto;
+import com.lframework.xingyun.sc.dto.statistics.ShipmentQuantityStatisticsDateRangeDto;
+import com.lframework.xingyun.sc.vo.statistics.shipmentQuantityIndustry.QueryShipmentQuantityIndustryStatisticsVo;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+
+public interface ShipmentQuantityIndustryStatisticsMapper {
+
+    @DataPermissions(type = OrderDataPermissionDataPermissionType.class, value = {
+            @DataPermission(template = "order", alias = "t")
+    })
+    List<ShipmentQuantityIndustryStatisticsDto> query(@Param("vo") QueryShipmentQuantityIndustryStatisticsVo vo);
+
+    @DataPermissions(type = OrderDataPermissionDataPermissionType.class, value = {
+            @DataPermission(template = "order", alias = "t")
+    })
+    ShipmentQuantityStatisticsDateRangeDto queryDateRange(@Param("vo") QueryShipmentQuantityIndustryStatisticsVo vo);
+
+    List<String> queryIndustryDim(@Param("vo") QueryShipmentQuantityIndustryStatisticsVo vo);
+
+    ShipmentQuantityIndustryStatisticsDto queryWorkshopDimById(@Param("workshopId") String workshopId);
+
+    List<ShipmentQuantityIndustryStatisticsDto> queryWorkshopDimByCodes(@Param("codes") List<String> codes);
+
+    List<ShipmentQuantityIndustryStatisticsInvalidDto> queryInvalid(@Param("vo") QueryShipmentQuantityIndustryStatisticsVo vo);
+}

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

+package com.lframework.xingyun.sc.vo.statistics.shipmentQuantityIndustry;
+
+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 QueryShipmentQuantityIndustryStatisticsVo extends PageVo implements BaseVo, Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @ApiModelProperty("发货日期开始")
+    private String shipmentDateStart;
+
+    @ApiModelProperty("发货日期结束")
+    private String shipmentDateEnd;
+
+    @ApiModelProperty("行业")
+    private String industry;
+
+    @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.ShipmentQuantityIndustryStatisticsMapper">
+
+    <resultMap id="ShipmentQuantityIndustryStatisticsDto" type="com.lframework.xingyun.sc.dto.statistics.ShipmentQuantityIndustryStatisticsDto">
+        <result column="shipment_date" property="shipmentDate"/>
+        <result column="industry" property="industry"/>
+        <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="ShipmentQuantityIndustryStatisticsInvalidDto" type="com.lframework.xingyun.sc.dto.statistics.ShipmentQuantityIndustryStatisticsInvalidDto">
+        <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="industry" property="industry"/>
+        <result column="workshop_id" property="workshopId"/>
+        <result column="quantity" property="quantity"/>
+    </resultMap>
+
+    <sql id="ShipmentQuantityIndustryStatistics_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="ShipmentQuantityIndustryStatisticsDto">
+        SELECT
+            t.shipment_date,
+            t.industry,
+            t.workshop_id,
+            t.workshop_code,
+            t.shipment_quantity
+        FROM (
+            SELECT
+                ol.delivery_date AS shipment_date,
+                ol.industry AS industry,
+                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 base_data_workshop ws ON ws.id = o.workshop_id
+            WHERE
+                <include refid="ShipmentQuantityIndustryStatistics_base_where"/>
+                AND ol.delivery_date IS NOT NULL
+                AND ol.industry IS NOT NULL AND ol.industry != ''
+                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.industry != null and vo.industry != ''">
+                    AND ol.industry LIKE CONCAT('%', #{vo.industry}, '%')
+                </if>
+                <if test="vo.workshopId != null and vo.workshopId != ''">
+                    AND o.workshop_id = #{vo.workshopId}
+                </if>
+            GROUP BY ol.delivery_date, ol.industry, 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.industry
+    </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
+            FROM tbl_purchase_order_line ol
+            INNER JOIN purchase_order_info o ON o.id = ol.purchase_order_id
+            WHERE
+                <include refid="ShipmentQuantityIndustryStatistics_base_where"/>
+                AND ol.delivery_date IS NOT NULL
+                AND ol.industry IS NOT NULL AND ol.industry != ''
+                AND o.workshop_id IS NOT NULL AND o.workshop_id != ''
+                AND ol.quantity IS NOT NULL
+                <if test="vo.industry != null and vo.industry != ''">
+                    AND ol.industry LIKE CONCAT('%', #{vo.industry}, '%')
+                </if>
+                <if test="vo.workshopId != null and vo.workshopId != ''">
+                    AND o.workshop_id = #{vo.workshopId}
+                </if>
+        ) t
+    </select>
+
+    <select id="queryIndustryDim" resultType="java.lang.String">
+        SELECT DISTINCT
+            ol.industry AS industry
+        FROM tbl_purchase_order_line ol
+        INNER JOIN purchase_order_info o ON o.id = ol.purchase_order_id
+        WHERE
+            <include refid="ShipmentQuantityIndustryStatistics_base_where"/>
+            AND ol.delivery_date IS NOT NULL
+            AND ol.industry IS NOT NULL AND ol.industry != ''
+            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.industry != null and vo.industry != ''">
+                AND ol.industry LIKE CONCAT('%', #{vo.industry}, '%')
+            </if>
+            <if test="vo.workshopId != null and vo.workshopId != ''">
+                AND o.workshop_id = #{vo.workshopId}
+            </if>
+        ORDER BY ol.industry
+    </select>
+
+    <select id="queryWorkshopDimByCodes" resultMap="ShipmentQuantityIndustryStatisticsDto">
+        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="ShipmentQuantityIndustryStatisticsDto">
+        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="ShipmentQuantityIndustryStatisticsInvalidDto">
+        SELECT
+            t.order_id,
+            t.order_no,
+            t.line_id,
+            t.shipment_date,
+            t.industry,
+            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,
+                ol.industry AS industry,
+                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="ShipmentQuantityIndustryStatistics_base_where"/>
+                AND (
+                    ol.delivery_date IS NULL
+                    OR ol.industry IS NULL OR ol.industry = ''
+                    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.industry != null and vo.industry != ''">
+                    AND ol.industry LIKE CONCAT('%', #{vo.industry}, '%')
+                </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>