采购计划：内贸计划明细汇总

@@ -2242,3 +2242,53 @@ CREATE TABLE `procurement_plan_replenish_line`
     PRIMARY KEY (`id`),
     PRIMARY KEY (`id`),
     KEY                             `idx_pp_replenish_line_main` (`procurement_plan_replenish_id`)
     KEY                             `idx_pp_replenish_line_main` (`procurement_plan_replenish_id`)
 ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_bin COMMENT='采购计划补单明细表';
 ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_bin COMMENT='采购计划补单明细表';
+
+
+CREATE TABLE domestic_plan_summary
+(
+    id                        VARCHAR(32)    NOT NULL COMMENT '主键ID',
+    code                      VARCHAR(32)    NOT NULL COMMENT '编号',
+    summary_date              DATE           NOT NULL COMMENT '汇总生成日期',
+    total_quantity            DECIMAL(18, 4) NOT NULL DEFAULT 0 COMMENT '合计(数量合计 吨)',
+    weighted_avg_coordination DECIMAL(18, 6) NOT NULL DEFAULT 0 COMMENT '吨超协加权平均 Σ(吨超协*数量)/Σ数量',
+    create_by_id              VARCHAR(32)             DEFAULT NULL COMMENT '创建人ID',
+    create_by                 VARCHAR(64)             DEFAULT NULL COMMENT '创建人',
+    create_time               DATETIME       NOT NULL COMMENT '创建时间',
+    update_by_id              VARCHAR(32)             DEFAULT NULL COMMENT '修改人ID',
+    update_by                 VARCHAR(64)             DEFAULT NULL COMMENT '修改人',
+    update_time               DATETIME                DEFAULT NULL COMMENT '修改时间',
+    PRIMARY KEY (id),
+    UNIQUE KEY uk_dps_code (code),
+    KEY                       idx_dps_summary_date (summary_date)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_bin COMMENT='内贸计划明细汇总主表';
+
+CREATE TABLE domestic_plan_summary_detail
+(
+    id                    VARCHAR(32)    NOT NULL COMMENT '主键ID',
+    summary_id            VARCHAR(32)    NOT NULL COMMENT '汇总主表ID',
+    order_no              INT(11) NOT NULL DEFAULT 0 COMMENT '排序号(审核通过时间 + 明细行号 最终排序)',
+    plan_create_date      DATE           NOT NULL COMMENT '计划创建日期',
+    purchase_dept_id      VARCHAR(32)             DEFAULT NULL COMMENT '采购处ID',
+    supplier_name         VARCHAR(200)   NOT NULL COMMENT '客户名称(供应商简称)',
+    plan_id               VARCHAR(32)    NOT NULL COMMENT '原采购计划ID',
+    plan_code             VARCHAR(64)    NOT NULL COMMENT '订单编号(原计划单编号)',
+    product_id            VARCHAR(32)             DEFAULT NULL COMMENT '品种ID',
+    quantity              DECIMAL(18, 4) NOT NULL DEFAULT 0 COMMENT '数量(吨)',
+    actual_purchase_price DECIMAL(18, 4) NOT NULL DEFAULT 0 COMMENT '实际采购价(元/吨)',
+    shipping_cost         DECIMAL(18, 4) NOT NULL DEFAULT 0 COMMENT '运费(元/吨)',
+    price_with_shipping   DECIMAL(18, 4) NOT NULL DEFAULT 0 COMMENT '单价(含运) = 实际采购价 + 运费',
+    workshop_id           VARCHAR(32)             DEFAULT NULL COMMENT '分厂ID',
+    coordination_range    DECIMAL(18, 6) NOT NULL DEFAULT 0 COMMENT '吨超协(协调幅度)',
+    remark_flag           VARCHAR(64)             DEFAULT NULL COMMENT '备注标识 空/买断/补单/"买断 补单"(同时有)',
+    plan_line_id          VARCHAR(32)             DEFAULT NULL COMMENT '原计划明细行ID(便于追溯)',
+    approval_pass_Time    DATETIME                DEFAULT NULL COMMENT '审核时间',
+    create_by_id          VARCHAR(32)             DEFAULT NULL COMMENT '创建人ID',
+    create_by             VARCHAR(64)             DEFAULT NULL COMMENT '创建人',
+    create_time           DATETIME       NOT NULL COMMENT '创建时间',
+    update_by_id          VARCHAR(32)             DEFAULT NULL COMMENT '修改人ID',
+    update_by             VARCHAR(64)             DEFAULT NULL COMMENT '修改人',
+    update_time           DATETIME                DEFAULT NULL COMMENT '修改时间',
+    PRIMARY KEY (id),
+    KEY                   idx_dpsd_summary_id (summary_id),
+    KEY                   idx_dpsd_plan_id (plan_id)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_bin COMMENT='内贸计划明细汇总明细表';

+package com.lframework.xingyun.sc.bo.procurement;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.lframework.starter.common.constants.StringPool;
+import com.lframework.starter.web.core.bo.BaseBo;
+import com.lframework.xingyun.sc.procurement.entity.summary.DomesticPlanSummary;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import java.math.BigDecimal;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.util.List;
+
+@Data
+public class GetDomesticPlanSummaryBo extends BaseBo<DomesticPlanSummary> {
+
+  @ApiModelProperty("ID")
+  private String id;
+
+  @ApiModelProperty("汇总编号")
+  private String code;
+
+  @ApiModelProperty("汇总日期")
+  @JsonFormat(pattern = StringPool.DATE_PATTERN)
+  private LocalDate summaryDate;
+
+  @ApiModelProperty("总数量")
+  private BigDecimal totalQuantity;
+
+  @ApiModelProperty("加权平均协调幅度")
+  private BigDecimal weightedAvgCoordination;
+
+  @ApiModelProperty("明细信息")
+  private List<GetDomesticPlanSummaryDetailBo> details;
+
+  @ApiModelProperty("创建人")
+  private String createBy;
+
+  @ApiModelProperty("创建时间")
+  @JsonFormat(pattern = StringPool.DATE_TIME_PATTERN)
+  private LocalDateTime createTime;
+
+  public GetDomesticPlanSummaryBo() {
+  }
+
+  public GetDomesticPlanSummaryBo(DomesticPlanSummary dto) {
+    super(dto);
+  }
+
+  @Override
+  public BaseBo<DomesticPlanSummary> convert(DomesticPlanSummary dto) {
+    return super.convert(dto);
+  }
+}

+package com.lframework.xingyun.sc.bo.procurement;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.lframework.starter.common.constants.StringPool;
+import com.lframework.starter.web.core.bo.BaseBo;
+import com.lframework.xingyun.sc.procurement.entity.summary.DomesticPlanSummaryDetail;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import java.math.BigDecimal;
+import java.time.LocalDate;
+
+@Data
+public class GetDomesticPlanSummaryDetailBo extends BaseBo<DomesticPlanSummaryDetail> {
+
+  @ApiModelProperty("序号")
+  private Integer seq;
+
+  @ApiModelProperty("计划创建日期")
+  @JsonFormat(pattern = StringPool.DATE_PATTERN)
+  private LocalDate planCreateDate;
+
+  @ApiModelProperty("采购处")
+  private String purchaseDeptName;
+
+  @ApiModelProperty("客户名称")
+  private String supplierName;
+
+  @ApiModelProperty("订单编号")
+  private String planCode;
+
+  @ApiModelProperty("品种")
+  private String productName;
+
+  @ApiModelProperty("数量")
+  private BigDecimal quantity;
+
+  @ApiModelProperty("单价（含运）")
+  private BigDecimal priceWithShipping;
+
+  @ApiModelProperty("分厂")
+  private String workshopName;
+
+  @ApiModelProperty("吨超协(协调幅度)")
+  private BigDecimal coordinationRange;
+
+  @ApiModelProperty("与平均对比 吨超协 - 吨超协*数量加权核算/总数量 结果为正标红")
+  private BigDecimal compareWithAvg;
+
+  @ApiModelProperty("备注 有买断显示买断 有补单显示补单 同时有显示买断 补单")
+  private String remarkLabel;
+
+  public GetDomesticPlanSummaryDetailBo() {
+  }
+
+  public GetDomesticPlanSummaryDetailBo(DomesticPlanSummaryDetail dto) {
+    super(dto);
+  }
+
+  @Override
+  public BaseBo<DomesticPlanSummaryDetail> convert(DomesticPlanSummaryDetail dto) {
+    return super.convert(dto);
+  }
+}

+package com.lframework.xingyun.sc.procurement.controller.summary;
+
+import com.lframework.starter.common.constants.StringPool;
+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.xingyun.sc.bo.procurement.GetDomesticPlanSummaryBo;
+import com.lframework.xingyun.sc.procurement.entity.summary.DomesticPlanSummary;
+import com.lframework.xingyun.sc.procurement.service.summary.DomesticPlanSummaryService;
+import com.lframework.xingyun.sc.procurement.vo.summary.QueryDomesticPlanSummaryVo;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiOperation;
+import javax.validation.Valid;
+import javax.validation.constraints.NotBlank;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.format.annotation.DateTimeFormat;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.time.LocalDate;
+
+@Api(tags = "内贸计划明细汇总表管理")
+@Slf4j
+@Validated
+@RestController
+@RequestMapping("/procurement/plan/summary")
+public class DomesticPlanSummaryController extends DefaultBaseController {
+
+  @Autowired
+  private DomesticPlanSummaryService domesticPlanSummaryService;
+
+  @ApiOperation("分页查询内贸计划明细汇总表列表")
+  @HasPermission({"plan-manage:domestic-plan-summary:query"})
+  @GetMapping("/query")
+  public InvokeResult<PageResult<DomesticPlanSummary>> query(@Valid QueryDomesticPlanSummaryVo vo) {
+    PageResult<DomesticPlanSummary> result = domesticPlanSummaryService.query(getPageIndex(vo), getPageSize(vo), vo);
+    return InvokeResultBuilder.success(result);
+  }
+
+  @ApiOperation("查询内贸计划明细汇总表详情")
+  @ApiImplicitParam(value = "ID", name = "id", paramType = "path", required = true)
+  @HasPermission({"plan-manage:domestic-plan-summary:query","plan-manage:domestic-plan-summary:view"})
+  @GetMapping("")
+  public InvokeResult<GetDomesticPlanSummaryBo> findById(@NotBlank(message = "ID不能为空！") String id) {
+    GetDomesticPlanSummaryBo result = domesticPlanSummaryService.findDetail(id);
+    return InvokeResultBuilder.success(result);
+  }
+
+  @ApiOperation("触发生成内贸计划明细汇总表（补跑）")
+  @ApiImplicitParam(value = "生成日期(yyyy-MM-dd 默认当天)", name = "date", paramType = "query", required = false)
+  @HasPermission({"plan-manage:domestic-plan-summary:add"})
+  @PostMapping("/generate")
+  public InvokeResult<String> generate(
+      @RequestParam(required = false) @DateTimeFormat(pattern = StringPool.DATE_PATTERN) LocalDate date) {
+    String id = domesticPlanSummaryService.generateDailySummary(date);
+    return InvokeResultBuilder.success(id);
+  }
+
+  @Scheduled(cron = "0 0 1 * * ?")
+  @ApiOperation(hidden = true, value = "定时生成前一天的内贸计划明细汇总表 每天1点")
+  public void scheduledGenerateDailySummary() {
+    try {
+      log.info("[内贸计划明细汇总表] 定时任务开始执行...");
+      String id = domesticPlanSummaryService.generateDailySummary(LocalDate.now());
+      log.info("[内贸计划明细汇总表] 定时任务执行完毕，生成汇总表ID: {}", id);
+    } catch (Exception e) {
+      log.error("[内贸计划明细汇总表] 定时任务执行失败!", e);
+    }
+  }
+}

+package com.lframework.xingyun.sc.procurement.entity.summary;
+
+import com.baomidou.mybatisplus.annotation.FieldFill;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.lframework.starter.web.core.dto.BaseDto;
+import com.lframework.starter.web.core.entity.BaseEntity;
+import lombok.Data;
+import java.math.BigDecimal;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+
+@Data
+@TableName("domestic_plan_summary")
+public class DomesticPlanSummary extends BaseEntity implements BaseDto {
+
+  private static final long serialVersionUID = 1L;
+
+  /**
+   * 主键ID
+   */
+  private String id;
+
+  /**
+   * 编号 XT260001 (XT+年份后2位+4位流水 每年重置)
+   */
+  private String code;
+
+  /**
+   * 汇总生成日期(年月日)
+   */
+  private LocalDate summaryDate;
+
+  /**
+   * 合计(数量合计 吨)
+   */
+  private BigDecimal totalQuantity;
+
+  /**
+   * 吨超协加权平均 Σ(吨超协*数量)/Σ数量
+   */
+  private BigDecimal weightedAvgCoordination;
+
+  /**
+   * 创建人ID
+   */
+  @TableField(fill = FieldFill.INSERT)
+  private String createById;
+
+  /**
+   * 创建人
+   */
+  @TableField(fill = FieldFill.INSERT)
+  private String createBy;
+
+  /**
+   * 创建时间
+   */
+  @TableField(fill = FieldFill.INSERT)
+  private LocalDateTime createTime;
+
+  /**
+   * 修改人ID
+   */
+  @TableField(fill = FieldFill.INSERT_UPDATE)
+  private String updateById;
+
+  /**
+   * 修改人
+   */
+  @TableField(fill = FieldFill.INSERT_UPDATE)
+  private String updateBy;
+
+  /**
+   * 修改时间
+   */
+  @TableField(fill = FieldFill.INSERT_UPDATE)
+  private LocalDateTime updateTime;
+}

+package com.lframework.xingyun.sc.procurement.entity.summary;
+
+import com.baomidou.mybatisplus.annotation.FieldFill;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.lframework.starter.web.core.dto.BaseDto;
+import com.lframework.starter.web.core.entity.BaseEntity;
+import lombok.Data;
+import java.math.BigDecimal;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+
+@Data
+@TableName("domestic_plan_summary_detail")
+public class DomesticPlanSummaryDetail extends BaseEntity implements BaseDto {
+
+  private static final long serialVersionUID = 1L;
+
+  /**
+   * 主键ID
+   */
+  private String id;
+
+  /**
+   * 汇总主表ID
+   */
+  private String summaryId;
+
+  /**
+   * 排序号(审核通过时间 + 明细行号 最终排序)
+   */
+  private Integer orderNo;
+
+  /**
+   * 计划创建日期(年-月-日)
+   */
+  private LocalDate planCreateDate;
+
+  /**
+   * 采购处ID
+   */
+  private String purchaseDeptId;
+
+  /**
+   * 采购处名称(冗余)
+   */
+  @TableField(exist = false)
+  private String purchaseDeptName;
+
+  /**
+   * 客户名称(供应商简称)
+   */
+  private String supplierName;
+
+  /**
+   * 原采购计划ID
+   */
+  private String planId;
+
+  /**
+   * 订单编号(原计划单编号)
+   */
+  private String planCode;
+
+  /**
+   * 品种ID
+   */
+  private String productId;
+
+  /**
+   * 品种名称(冗余)
+   */
+  @TableField(exist = false)
+  private String productName;
+
+  /**
+   * 数量(吨)
+   */
+  private BigDecimal quantity;
+
+  /**
+   * 实际采购价(元/吨)
+   */
+  private BigDecimal actualPurchasePrice;
+
+  /**
+   * 运费(元/吨)
+   */
+  private BigDecimal shippingCost;
+
+  /**
+   * 单价(含运) = 实际采购价 + 运费
+   */
+  private BigDecimal priceWithShipping;
+
+  /**
+   * 分厂ID
+   */
+  private String workshopId;
+
+  /**
+   * 分厂名称(冗余)
+   */
+  @TableField(exist = false)
+  private String workshopName;
+
+  /**
+   * 吨超协(协调幅度)
+   */
+  private BigDecimal coordinationRange;
+
+  /**
+   * 备注标识 空/买断/补单/"买断 补单"(同时有)
+   */
+  private String remarkFlag;
+
+  /**
+   * 原计划明细行ID(便于追溯)
+   */
+  private String planLineId;
+
+  /**
+   * 原计划审核通过时间(用于全局排序)
+   */
+  private LocalDateTime approvalPassTime;
+
+  /**
+   * 创建人ID
+   */
+  @TableField(fill = FieldFill.INSERT)
+  private String createById;
+
+  /**
+   * 创建人
+   */
+  @TableField(fill = FieldFill.INSERT)
+  private String createBy;
+
+  /**
+   * 创建时间
+   */
+  @TableField(fill = FieldFill.INSERT)
+  private LocalDateTime createTime;
+
+  /**
+   * 修改人ID
+   */
+  @TableField(fill = FieldFill.INSERT_UPDATE)
+  private String updateById;
+
+  /**
+   * 修改人
+   */
+  @TableField(fill = FieldFill.INSERT_UPDATE)
+  private String updateBy;
+
+  /**
+   * 修改时间
+   */
+  @TableField(fill = FieldFill.INSERT_UPDATE)
+  private LocalDateTime updateTime;
+}

+package com.lframework.xingyun.sc.procurement.impl.summary;
+
+import com.lframework.starter.web.core.impl.BaseMpServiceImpl;
+import com.lframework.xingyun.sc.procurement.entity.summary.DomesticPlanSummaryDetail;
+import com.lframework.xingyun.sc.procurement.mappers.summary.DomesticPlanSummaryDetailMapper;
+import com.lframework.xingyun.sc.procurement.service.summary.DomesticPlanSummaryDetailService;
+import java.util.List;
+import org.springframework.stereotype.Service;
+
+@Service
+public class DomesticPlanSummaryDetailServiceImpl extends
+    BaseMpServiceImpl<DomesticPlanSummaryDetailMapper, DomesticPlanSummaryDetail> implements
+    DomesticPlanSummaryDetailService {
+
+  @Override
+  public List<DomesticPlanSummaryDetail> getBySummaryId(String summaryId) {
+    return getBaseMapper().getBySummaryId(summaryId);
+  }
+
+  @Override
+  public void deleteBySummaryId(String summaryId) {
+    getBaseMapper().deleteBySummaryId(summaryId);
+  }
+}

+package com.lframework.xingyun.sc.procurement.impl.summary;
+
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.github.pagehelper.PageInfo;
+import com.lframework.starter.common.utils.Assert;
+import com.lframework.starter.common.utils.CollectionUtil;
+import com.lframework.starter.common.utils.StringUtil;
+import com.lframework.starter.web.core.components.resp.PageResult;
+import com.lframework.starter.web.core.impl.BaseMpServiceImpl;
+import com.lframework.starter.web.core.utils.IdUtil;
+import com.lframework.starter.web.core.utils.PageHelperUtil;
+import com.lframework.starter.web.core.utils.PageResultUtil;
+import com.lframework.xingyun.sc.bo.procurement.GetDomesticPlanSummaryBo;
+import com.lframework.xingyun.sc.bo.procurement.GetDomesticPlanSummaryDetailBo;
+import com.lframework.xingyun.sc.procurement.entity.ProcurementBuyoutApply;
+import com.lframework.xingyun.sc.procurement.entity.replenish.ProcurementPlanReplenish;
+import com.lframework.xingyun.sc.procurement.entity.summary.DomesticPlanSummary;
+import com.lframework.xingyun.sc.procurement.entity.summary.DomesticPlanSummaryDetail;
+import com.lframework.xingyun.sc.procurement.mappers.summary.DomesticPlanSummaryDetailMapper;
+import com.lframework.xingyun.sc.procurement.mappers.summary.DomesticPlanSummaryMapper;
+import com.lframework.xingyun.sc.procurement.service.buyout.ProcurementBuyoutApplyService;
+import com.lframework.xingyun.sc.procurement.service.replenish.ProcurementPlanReplenishService;
+import com.lframework.xingyun.sc.procurement.service.summary.DomesticPlanSummaryDetailService;
+import com.lframework.xingyun.sc.procurement.service.summary.DomesticPlanSummaryService;
+import com.lframework.xingyun.sc.procurement.vo.summary.QueryDomesticPlanSummaryVo;
+import java.math.BigDecimal;
+import java.math.RoundingMode;
+import java.sql.Timestamp;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.List;
+import java.util.Map;
+import java.util.Objects;
+import java.util.Set;
+import java.util.stream.Collectors;
+import javax.annotation.Resource;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+@Service
+public class DomesticPlanSummaryServiceImpl extends
+    BaseMpServiceImpl<DomesticPlanSummaryMapper, DomesticPlanSummary> implements
+    DomesticPlanSummaryService {
+
+  @Resource
+  private DomesticPlanSummaryMapper domesticPlanSummaryMapper;
+  @Resource
+  private DomesticPlanSummaryDetailMapper domesticPlanSummaryDetailMapper;
+  @Resource
+  private DomesticPlanSummaryDetailService domesticPlanSummaryDetailService;
+  @Resource
+  private ProcurementBuyoutApplyService procurementBuyoutApplyService;
+  @Resource
+  private ProcurementPlanReplenishService procurementPlanReplenishService;
+
+  @Override
+  public PageResult<DomesticPlanSummary> query(Integer pageIndex, Integer pageSize,
+      QueryDomesticPlanSummaryVo vo) {
+    Assert.greaterThanZero(pageIndex);
+    Assert.greaterThanZero(pageSize);
+
+    PageHelperUtil.startPage(pageIndex, pageSize);
+    List<DomesticPlanSummary> datas = this.query(vo);
+    return PageResultUtil.convert(new PageInfo<>(datas));
+  }
+
+  @Override
+  public List<DomesticPlanSummary> query(QueryDomesticPlanSummaryVo vo) {
+    return domesticPlanSummaryMapper.query(vo);
+  }
+
+  @Override
+  public GetDomesticPlanSummaryBo findDetail(String id) {
+    if (StringUtil.isBlank(id)) {
+      throw new com.lframework.starter.common.exceptions.impl.InputErrorException("ID不能为空！");
+    }
+
+    DomesticPlanSummary entity = domesticPlanSummaryMapper.findById(id);
+    if (entity == null) {
+      throw new com.lframework.starter.common.exceptions.impl.DefaultClientException("汇总记录不存在！");
+    }
+
+    GetDomesticPlanSummaryBo bo = new GetDomesticPlanSummaryBo(entity);
+    bo.convert(entity);
+
+    List<DomesticPlanSummaryDetail> details = domesticPlanSummaryDetailService.getBySummaryId(id);
+    if (!CollectionUtil.isEmpty(details)) {
+      List<GetDomesticPlanSummaryDetailBo> detailBoList = new ArrayList<>();
+      for (int i = 0; i < details.size(); i++) {
+        GetDomesticPlanSummaryDetailBo dbo = new GetDomesticPlanSummaryDetailBo(details.get(i));
+        dbo.setSeq(i + 1);
+        BigDecimal cr = details.get(i).getCoordinationRange() != null
+            ? details.get(i).getCoordinationRange() : BigDecimal.ZERO;
+        BigDecimal avg =
+            entity.getWeightedAvgCoordination() != null ? entity.getWeightedAvgCoordination()
+                : BigDecimal.ZERO;
+        dbo.setCompareWithAvg(cr.subtract(avg));
+        dbo.setRemarkLabel(details.get(i).getRemarkFlag());
+        detailBoList.add(dbo);
+      }
+      bo.setDetails(detailBoList);
+    } else {
+      bo.setDetails(Collections.emptyList());
+    }
+
+    return bo;
+  }
+
+  @Override
+  @Transactional(rollbackFor = Exception.class)
+  public String generateDailySummary(LocalDate summaryDate) {
+    if (summaryDate == null) {
+      summaryDate = LocalDate.now();
+    }
+
+    long existCount = domesticPlanSummaryMapper.countBySummaryDate(summaryDate);
+    if (existCount > 0) {
+      DomesticPlanSummary exist = this.getOne(
+          Wrappers.lambdaQuery(DomesticPlanSummary.class)
+              .eq(DomesticPlanSummary::getSummaryDate, summaryDate));
+      return exist.getId();
+    }
+
+    LocalDate yesterday = summaryDate.minusDays(1);
+    LocalDateTime auditStart = yesterday.atStartOfDay();
+    LocalDateTime auditEnd = yesterday.atTime(23, 59, 59);
+
+    List<Map<String, Object>> rawLines =
+        domesticPlanSummaryDetailMapper.selectPlanLinesForYesterdaySummary(auditStart, auditEnd);
+    if (rawLines == null) {
+      return null;
+    }
+
+    Set<String> planIds = rawLines.stream()
+        .map(row -> (String) row.get("plan_id"))
+        .filter(Objects::nonNull)
+        .collect(Collectors.toSet());
+
+    Set<String> buyoutPlanIds = Collections.emptySet();
+    if (CollectionUtil.isNotEmpty(planIds)) {
+      buyoutPlanIds = procurementBuyoutApplyService.list(
+              Wrappers.lambdaQuery(ProcurementBuyoutApply.class)
+                  .in(ProcurementBuyoutApply::getProcurementPlanId, planIds)
+                  .select(ProcurementBuyoutApply::getProcurementPlanId))
+          .stream()
+          .map(ProcurementBuyoutApply::getProcurementPlanId)
+          .collect(Collectors.toSet());
+    }
+
+    Set<String> replenishPlanIds = Collections.emptySet();
+    if (CollectionUtil.isNotEmpty(planIds)) {
+      replenishPlanIds = procurementPlanReplenishService.list(
+              Wrappers.lambdaQuery(ProcurementPlanReplenish.class)
+                  .in(ProcurementPlanReplenish::getProcurementPlanId, planIds)
+                  .eq(ProcurementPlanReplenish::getApprovalStatus, "PASS")
+                  .select(ProcurementPlanReplenish::getProcurementPlanId))
+          .stream()
+          .map(ProcurementPlanReplenish::getProcurementPlanId)
+          .collect(Collectors.toSet());
+    }
+
+    DomesticPlanSummary summary = new DomesticPlanSummary();
+    summary.setId(IdUtil.getId());
+
+    String yearPart = String.format("%02d", summaryDate.getYear() % 100);
+    String prefix = "XT" + yearPart;
+    DomesticPlanSummary max = domesticPlanSummaryMapper.findMaxCodeByYearPrefix(prefix);
+    int seq = 1;
+    if (max != null && StringUtil.isNotBlank(max.getCode())) {
+      String numPart = max.getCode().substring(prefix.length());
+      seq = Integer.parseInt(numPart) + 1;
+    }
+    summary.setCode(prefix + String.format("%04d", seq));
+
+    summary.setSummaryDate(summaryDate);
+    summary.setTotalQuantity(BigDecimal.ZERO);
+    summary.setWeightedAvgCoordination(BigDecimal.ZERO);
+
+    List<DomesticPlanSummaryDetail> detailList = new ArrayList<>();
+    BigDecimal totalQty = BigDecimal.ZERO;
+    BigDecimal weightedSum = BigDecimal.ZERO;
+    int orderNo = 0;
+
+    for (Map<String, Object> row : rawLines) {
+      DomesticPlanSummaryDetail d = new DomesticPlanSummaryDetail();
+      d.setId(IdUtil.getId());
+      d.setSummaryId(summary.getId());
+      d.setOrderNo(++orderNo);
+
+      Object planCreateTime = row.get("plan_create_time");
+      if (planCreateTime != null) {
+        if (planCreateTime instanceof LocalDateTime) {
+          d.setPlanCreateDate(((LocalDateTime) planCreateTime).toLocalDate());
+        } else if (planCreateTime instanceof LocalDate) {
+          d.setPlanCreateDate((LocalDate) planCreateTime);
+        } else if (planCreateTime instanceof Timestamp) {
+          d.setPlanCreateDate(((Timestamp) planCreateTime).toLocalDateTime().toLocalDate());
+        }
+      }
+
+      d.setPurchaseDeptId((String) row.get("purchase_dept_id"));
+      d.setSupplierName(
+          row.get("supplier_name") != null ? (String) row.get("supplier_name") : "");
+      d.setPlanId((String) row.get("plan_id"));
+      d.setPlanCode((String) row.get("plan_code"));
+      d.setProductId((String) row.get("product_id"));
+
+      BigDecimal qty = toDecimal(row.get("quantity"));
+      d.setQuantity(qty);
+      BigDecimal actualPrice = toDecimal(row.get("actual_purchase_price"));
+      d.setActualPurchasePrice(actualPrice);
+      BigDecimal shippingCost = toDecimal(row.get("shipping_cost"));
+      d.setShippingCost(shippingCost);
+      d.setPriceWithShipping(actualPrice.add(shippingCost));
+      d.setWorkshopId((String) row.get("workshop_id"));
+      BigDecimal cr = toDecimal(row.get("coordination_range"));
+      d.setCoordinationRange(cr);
+      d.setCreateById("1");
+      d.setCreateBy("系统管理员");
+      d.setUpdateById("1");
+      d.setUpdateBy("系统管理员");
+
+      boolean hasBuyout = buyoutPlanIds.contains(d.getPlanId());
+      boolean hasReplenish = replenishPlanIds.contains(d.getPlanId());
+      if (hasBuyout && hasReplenish) {
+        d.setRemarkFlag("买断 补单");
+      } else if (hasBuyout) {
+        d.setRemarkFlag("买断");
+      } else if (hasReplenish) {
+        d.setRemarkFlag("补单");
+      } else {
+        d.setRemarkFlag(null);
+      }
+
+      d.setPlanLineId((String) row.get("plan_line_id"));
+      Object apt = row.get("approval_pass_time");
+      if (apt != null) {
+        if (apt instanceof LocalDateTime) {
+          d.setApprovalPassTime((LocalDateTime) apt);
+        } else if (apt instanceof Timestamp) {
+          d.setApprovalPassTime(((Timestamp) apt).toLocalDateTime());
+        }
+      }
+
+      detailList.add(d);
+      totalQty = totalQty.add(qty);
+      weightedSum = weightedSum.add(cr.multiply(qty));
+    }
+
+    summary.setTotalQuantity(totalQty);
+    if (totalQty.compareTo(BigDecimal.ZERO) > 0) {
+      BigDecimal weightedAvg = weightedSum.divide(totalQty, 6, RoundingMode.HALF_UP);
+      summary.setWeightedAvgCoordination(weightedAvg);
+    } else {
+      summary.setWeightedAvgCoordination(BigDecimal.ZERO);
+    }
+    summary.setCreateById("1");
+    summary.setCreateBy("系统管理员");
+    summary.setUpdateById("1");
+    summary.setUpdateBy("系统管理员");
+
+    this.save(summary);
+    if (!CollectionUtil.isEmpty(detailList)) {
+      domesticPlanSummaryDetailService.saveBatch(detailList);
+    }
+
+    return summary.getId();
+  }
+
+  private BigDecimal toDecimal(Object obj) {
+    if (obj == null) {
+      return BigDecimal.ZERO;
+    }
+    if (obj instanceof BigDecimal) {
+      return (BigDecimal) obj;
+    }
+    if (obj instanceof Number) {
+      return new BigDecimal(obj.toString());
+    }
+    if (obj instanceof String) {
+      String str = ((String) obj).trim();
+      if (StringUtil.isBlank(str)) {
+        return BigDecimal.ZERO;
+      }
+      return new BigDecimal(str);
+    }
+    return BigDecimal.ZERO;
+  }
+}

+package com.lframework.xingyun.sc.procurement.mappers.summary;
+
+import com.lframework.starter.web.core.mapper.BaseMapper;
+import com.lframework.xingyun.sc.procurement.entity.summary.DomesticPlanSummaryDetail;
+import java.time.LocalDateTime;
+import java.util.List;
+import java.util.Map;
+import org.apache.ibatis.annotations.Param;
+
+public interface DomesticPlanSummaryDetailMapper extends BaseMapper<DomesticPlanSummaryDetail> {
+
+  /**
+   * 根据汇总ID查询明细列表
+   *
+   * @param summaryId
+   * @return
+   */
+  List<DomesticPlanSummaryDetail> getBySummaryId(@Param("summaryId") String summaryId);
+
+  /**
+   * 根据汇总ID删除明细
+   *
+   * @param summaryId
+   */
+  void deleteBySummaryId(@Param("summaryId") String summaryId);
+
+  /**
+   * 查询前一天审核通过的计划明细用于汇总
+   *
+   * @param yesterdayStart
+   * @param yesterdayEnd
+   * @return
+   */
+  List<Map<String, Object>> selectPlanLinesForYesterdaySummary(
+      @Param("yesterdayStart") LocalDateTime yesterdayStart,
+      @Param("yesterdayEnd") LocalDateTime yesterdayEnd);
+}

+package com.lframework.xingyun.sc.procurement.mappers.summary;
+
+import com.lframework.starter.web.core.mapper.BaseMapper;
+import com.lframework.xingyun.sc.procurement.entity.summary.DomesticPlanSummary;
+import com.lframework.xingyun.sc.procurement.vo.summary.QueryDomesticPlanSummaryVo;
+import java.time.LocalDate;
+import java.util.List;
+import org.apache.ibatis.annotations.Param;
+
+public interface DomesticPlanSummaryMapper extends BaseMapper<DomesticPlanSummary> {
+
+  /**
+   * 查询列表
+   *
+   * @param vo
+   * @return
+   */
+  List<DomesticPlanSummary> query(@Param("vo") QueryDomesticPlanSummaryVo vo);
+
+  /**
+   * 根据ID查询
+   *
+   * @param id
+   * @return
+   */
+  DomesticPlanSummary findById(@Param("id") String id);
+
+  /**
+   * 根据汇总日期统计数量（幂等用）
+   *
+   * @param summaryDate
+   * @return
+   */
+  long countBySummaryDate(@Param("summaryDate") LocalDate summaryDate);
+
+  /**
+   * 根据年份前缀查找最大编码的记录
+   *
+   * @param prefix
+   * @return
+   */
+  DomesticPlanSummary findMaxCodeByYearPrefix(@Param("prefix") String prefix);
+}

+package com.lframework.xingyun.sc.procurement.service.summary;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.lframework.xingyun.sc.procurement.entity.summary.DomesticPlanSummaryDetail;
+import java.util.List;
+
+public interface DomesticPlanSummaryDetailService extends IService<DomesticPlanSummaryDetail> {
+
+  List<DomesticPlanSummaryDetail> getBySummaryId(String summaryId);
+
+  void deleteBySummaryId(String summaryId);
+}

+package com.lframework.xingyun.sc.procurement.service.summary;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.lframework.starter.web.core.components.resp.PageResult;
+import com.lframework.xingyun.sc.bo.procurement.GetDomesticPlanSummaryBo;
+import com.lframework.xingyun.sc.procurement.entity.summary.DomesticPlanSummary;
+import com.lframework.xingyun.sc.procurement.vo.summary.QueryDomesticPlanSummaryVo;
+import java.time.LocalDate;
+import java.util.List;
+
+public interface DomesticPlanSummaryService extends IService<DomesticPlanSummary> {
+
+  PageResult<DomesticPlanSummary> query(Integer pageIndex, Integer pageSize,
+      QueryDomesticPlanSummaryVo vo);
+
+  List<DomesticPlanSummary> query(QueryDomesticPlanSummaryVo vo);
+
+  GetDomesticPlanSummaryBo findDetail(String id);
+
+  String generateDailySummary(LocalDate summaryDate);
+}

+package com.lframework.xingyun.sc.procurement.vo.summary;
+
+import com.lframework.starter.web.core.vo.SortPageVo;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import java.time.LocalDate;
+import lombok.Data;
+
+@Data
+@ApiModel("查询内销计划汇总Vo")
+public class QueryDomesticPlanSummaryVo extends SortPageVo {
+
+  private static final long serialVersionUID = 1L;
+
+  @ApiModelProperty("汇总编号")
+  private String code;
+
+  @ApiModelProperty("汇总日期起始")
+  private LocalDate startDate;
+
+  @ApiModelProperty("汇总日期截止")
+  private LocalDate endDate;
+}

+<?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.procurement.mappers.summary.DomesticPlanSummaryDetailMapper">
+
+    <resultMap id="DomesticPlanSummaryDetail" type="com.lframework.xingyun.sc.procurement.entity.summary.DomesticPlanSummaryDetail">
+        <id column="id" property="id"/>
+        <result column="summary_id" property="summaryId"/>
+        <result column="order_no" property="orderNo"/>
+        <result column="plan_create_date" property="planCreateDate"/>
+        <result column="purchase_dept_id" property="purchaseDeptId"/>
+        <result column="purchase_dept_name" property="purchaseDeptName"/>
+        <result column="supplier_name" property="supplierName"/>
+        <result column="plan_id" property="planId"/>
+        <result column="plan_code" property="planCode"/>
+        <result column="product_id" property="productId"/>
+        <result column="product_name" property="productName"/>
+        <result column="quantity" property="quantity"/>
+        <result column="actual_purchase_price" property="actualPurchasePrice"/>
+        <result column="shipping_cost" property="shippingCost"/>
+        <result column="price_with_shipping" property="priceWithShipping"/>
+        <result column="workshop_id" property="workshopId"/>
+        <result column="workshop_name" property="workshopName"/>
+        <result column="coordination_range" property="coordinationRange"/>
+        <result column="remark_flag" property="remarkFlag"/>
+        <result column="plan_line_id" property="planLineId"/>
+        <result column="approval_pass_time" property="approvalPassTime"/>
+        <result column="create_by_id" property="createById"/>
+        <result column="create_by" property="createBy"/>
+        <result column="update_by_id" property="updateById"/>
+        <result column="update_by" property="updateBy"/>
+        <result column="create_time" property="createTime"/>
+        <result column="update_time" property="updateTime"/>
+    </resultMap>
+
+    <sql id="DomesticPlanSummaryDetail_sql">
+        SELECT
+            dpsd.id,
+            dpsd.summary_id,
+            dpsd.order_no,
+            dpsd.plan_create_date,
+            dpsd.purchase_dept_id,
+            sd.name AS purchase_dept_name,
+            dpsd.supplier_name,
+            dpsd.plan_id,
+            dpsd.plan_code,
+            dpsd.product_id,
+            br.product_name,
+            dpsd.quantity,
+            dpsd.actual_purchase_price,
+            dpsd.shipping_cost,
+            dpsd.price_with_shipping,
+            dpsd.workshop_id,
+            ws.name AS workshop_name,
+            dpsd.coordination_range,
+            dpsd.remark_flag,
+            dpsd.plan_line_id,
+            dpsd.approval_pass_time,
+            dpsd.create_by_id,
+            dpsd.create_by,
+            dpsd.update_by_id,
+            dpsd.update_by,
+            dpsd.create_time,
+            dpsd.update_time
+        FROM domestic_plan_summary_detail AS dpsd
+        LEFT JOIN base_data_breed_relationship br ON br.id = dpsd.product_id
+        LEFT JOIN base_data_workshop as ws on ws.id = dpsd.workshop_id
+        LEFT JOIN sys_dept sd ON sd.id = dpsd.purchase_dept_id
+    </sql>
+
+    <select id="getBySummaryId" resultMap="DomesticPlanSummaryDetail">
+        <include refid="DomesticPlanSummaryDetail_sql"/>
+        WHERE dpsd.summary_id = #{summaryId}
+        ORDER BY dpsd.order_no ASC
+    </select>
+
+    <delete id="deleteBySummaryId">
+        DELETE FROM domestic_plan_summary_detail WHERE summary_id = #{summaryId}
+    </delete>
+
+    <select id="selectPlanLinesForYesterdaySummary" resultType="java.util.HashMap">
+        SELECT
+            pp.id AS plan_id,
+            pp.code AS plan_code,
+            pp.create_time AS plan_create_time,
+            pp.purchase_department AS purchase_dept_id,
+            pdc.customer_short_name AS supplier_name,
+            pp.shipping_cost AS shipping_cost,
+            pp.approval_pass_time AS approval_pass_time,
+            ppl.id AS plan_line_id,
+            ppl.product_id AS product_id,
+            ppl.quantity AS quantity,
+            ppl.actual_purchase_price AS actual_purchase_price,
+            ppl.coordination_range AS coordination_range,
+            ppl.workshop_id AS workshop_id
+        FROM procurement_plan_line ppl
+        INNER JOIN procurement_plan pp ON ppl.procurement_plan_id = pp.id
+            AND pp.process_status = 'COMPLETED'
+            AND (pp.frozen = 0 OR pp.frozen IS NULL)
+            AND pp.deleted = 0
+            AND pp.approval_pass_time BETWEEN #{yesterdayStart} AND #{yesterdayEnd}
+        LEFT JOIN procurement_domestic_customer_credit pdc ON pdc.id = pp.supplier_id
+        ORDER BY pp.approval_pass_time ASC, ppl.id ASC
+    </select>
+</mapper>

+<?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.procurement.mappers.summary.DomesticPlanSummaryMapper">
+
+    <resultMap id="DomesticPlanSummary" type="com.lframework.xingyun.sc.procurement.entity.summary.DomesticPlanSummary">
+        <id column="id" property="id"/>
+        <result column="code" property="code"/>
+        <result column="summary_date" property="summaryDate"/>
+        <result column="total_quantity" property="totalQuantity"/>
+        <result column="weighted_avg_coordination" property="weightedAvgCoordination"/>
+        <result column="create_by_id" property="createById"/>
+        <result column="create_by" property="createBy"/>
+        <result column="create_time" property="createTime"/>
+        <result column="update_by_id" property="updateById"/>
+        <result column="update_by" property="updateBy"/>
+        <result column="update_time" property="updateTime"/>
+    </resultMap>
+
+    <sql id="DomesticPlanSummary_sql">
+        SELECT
+            dps.id,
+            dps.code,
+            dps.summary_date,
+            dps.total_quantity,
+            dps.weighted_avg_coordination,
+            dps.create_by_id,
+            dps.create_by,
+            dps.create_time,
+            dps.update_by_id,
+            dps.update_by,
+            dps.update_time
+        FROM domestic_plan_summary AS dps
+    </sql>
+
+    <select id="query" resultMap="DomesticPlanSummary">
+        <include refid="DomesticPlanSummary_sql"/>
+        <where>
+            <if test="vo.code != null and vo.code != ''">
+                AND dps.code LIKE CONCAT('%', #{vo.code}, '%')
+            </if>
+            <if test="vo.startDate != null">
+                AND dps.summary_date &gt;= #{vo.startDate}
+            </if>
+            <if test="vo.endDate != null">
+                AND dps.summary_date &lt;= #{vo.endDate}
+            </if>
+        </where>
+        ORDER BY dps.summary_date DESC, dps.code DESC
+    </select>
+
+    <select id="findById" resultMap="DomesticPlanSummary">
+        <include refid="DomesticPlanSummary_sql"/>
+        WHERE dps.id = #{id}
+    </select>
+
+    <select id="countBySummaryDate" resultType="long">
+        SELECT COUNT(1) FROM domestic_plan_summary WHERE summary_date = #{summaryDate}
+    </select>
+
+    <select id="findMaxCodeByYearPrefix" resultMap="DomesticPlanSummary">
+        SELECT * FROM domestic_plan_summary WHERE code LIKE CONCAT(#{prefix}, '%') ORDER BY code DESC LIMIT 1
+    </select>
+</mapper>