采购计划：采购吨超协汇总消息提醒供应管理科计划管理员

 package com.lframework.xingyun.sc.procurement.controller.summary;
 
 import com.lframework.starter.common.constants.StringPool;
+import com.lframework.starter.common.utils.CollectionUtil;
 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.inner.service.system.SysUserRoleService;
 import com.lframework.xingyun.sc.bo.procurement.GetDomesticPlanSummaryBo;
+import com.lframework.xingyun.sc.handlers.MessageHandler;
 import com.lframework.xingyun.sc.procurement.entity.summary.DomesticPlanSummary;
+import com.lframework.xingyun.sc.procurement.service.plan.ProcurementPlanService;
 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 java.time.LocalDate;
+import java.time.format.DateTimeFormatter;
+import java.util.Collections;
+import java.util.List;
+import java.util.Map;
+import javax.annotation.Resource;
 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
@@ -36,8 +42,14 @@ import java.time.LocalDate;
 @RequestMapping("/procurement/plan/summary")
 public class DomesticPlanSummaryController extends DefaultBaseController {
 
-  @Autowired
+  @Resource
   private DomesticPlanSummaryService domesticPlanSummaryService;
+  @Resource
+  private ProcurementPlanService procurementPlanService;
+  @Resource
+  private SysUserRoleService sysUserRoleService;
+  @Resource
+  private MessageHandler messageHandler;
 
   @ApiOperation("分页查询内贸计划明细汇总表列表")
   @HasPermission({"plan-manage:detail-form:query"})
@@ -77,4 +89,37 @@ public class DomesticPlanSummaryController extends DefaultBaseController {
       log.error("[内贸计划明细汇总表] 定时任务执行失败!", e);
     }
   }
+
+  @Scheduled(cron = "0 0 0 * * ?")
+  @ApiOperation(hidden = true, value = "每天凌晨12点提醒供应管理科计划管理员：昨天创建的采购计划总数/完成数/流程中数")
+  public void scheduledNotifyYesterdayPlanAdmin() {
+    try {
+      log.info("[采购计划统计提醒] 定时任务开始执行 凌晨12点...");
+      LocalDate yesterday = LocalDate.now().minusDays(1);
+      Map<String, Long> stat = procurementPlanService.countCreatedPlansByDate(yesterday);
+      long total = stat.getOrDefault("totalCount", 0L);
+      long completed = stat.getOrDefault("completedCount", 0L);
+      long inProgress = stat.getOrDefault("inProgressCount", 0L);
+
+      // 组装消息
+      String dateStr = yesterday.format(DateTimeFormatter.ofPattern(StringPool.DATE_PATTERN));
+      String title = String.format("%s 采购计划创建统计提醒", dateStr);
+      String content = String.format(
+              "【采购计划统计提醒】%s 创建的采购计划共 %d 单，流程已完成(COMPLETED) %d 单，流程中 %d 单。请相关计划管理员及时跟进处理！",
+              dateStr, total, completed, inProgress);
+      String bizKey = "PROCUREMENT_PLAN_STAT_" + dateStr;
+
+      // 发送给供应管理科计划管理员
+      List<String> userIds = sysUserRoleService.listUserIdByRoleCodes(Collections.singletonList("gyglkjhgly"));
+      if (CollectionUtil.isEmpty(userIds)) {
+        log.warn("[采购计划统计提醒] 供应管理科计划管理员 下无用户，跳过消息发送！");
+        return;
+      }
+      messageHandler.sendMsg(userIds, title, content, bizKey, null);
+      log.info("[采购计划统计提醒] 消息发送完成 接收人{}个 总数{}完成{}流程中{}",
+              userIds.size(), total, completed, inProgress);
+    } catch (Exception e) {
+      log.error("[采购计划统计提醒] 定时任务执行失败!", e);
+    }
+  }
 }

@@ -791,4 +791,32 @@ public class ProcurementPlanServiceImpl extends BaseMpServiceImpl<ProcurementPla
       data.setShowExamine(hasTodo && CustomerDevelopStatus.AUDIT.name().equals(data.getApprovalStatus()));
     }
   }
+
+  @Override
+  public Map<String, Long> countCreatedPlansByDate(LocalDate date) {
+    if (date == null) {
+      date = LocalDate.now();
+    }
+    LocalDateTime start = date.atStartOfDay();
+    LocalDateTime end = date.atTime(23, 59, 59);
+    // 1. 总数：create_time 在昨天范围 + deleted=0（非归档）
+    long totalCount = this.count(Wrappers.lambdaQuery(ProcurementPlan.class)
+            .ge(ProcurementPlan::getCreateTime, start)
+            .le(ProcurementPlan::getCreateTime, end)
+            .eq(ProcurementPlan::getFrozen, false)
+            .and(w -> w.isNull(ProcurementPlan::getDeleted).or().eq(ProcurementPlan::getDeleted, false)));
+    // 2. 已完成：流程 COMPLETED
+    long completedCount = this.count(Wrappers.lambdaQuery(ProcurementPlan.class)
+            .ge(ProcurementPlan::getCreateTime, start)
+            .le(ProcurementPlan::getCreateTime, end)
+            .eq(ProcurementPlan::getFrozen, false)
+            .and(w -> w.isNull(ProcurementPlan::getDeleted).or().eq(ProcurementPlan::getDeleted, false))
+            .eq(ProcurementPlan::getProcessStatus, "COMPLETED"));
+    long inProgressCount = Math.max(totalCount - completedCount, 0L);
+    Map<String, Long> result = new HashMap<>();
+    result.put("totalCount", totalCount);
+    result.put("completedCount", completedCount);
+    result.put("inProgressCount", inProgressCount);
+    return result;
+  }
 }

@@ -152,4 +152,13 @@ public interface ProcurementPlanService extends BaseMpService<ProcurementPlan> {
    * @param id 采购计划ID（可以是主计划或子计划ID）
    */
   void abort(String id);
+
+  /**
+   * 统计指定日期创建的采购计划数量（按天0点~23:59:59，deleted=0 非归档/删除 非冻结的）
+   * 返回 Map: totalCount=总数；completedCount=流程状态COMPLETED数；inProgressCount=流程中非COMPLETED数
+   *
+   * @param date
+   * @return
+   */
+  java.util.Map<String, Long> countCreatedPlansByDate(java.time.LocalDate date);
 }