package com.ruoyi.projectManagement.service;

import com.fasterxml.jackson.core.type.TypeReference;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.ruoyi.common.exception.ServiceException;
import com.ruoyi.common.utils.SecurityUtils;
import com.ruoyi.projectManagement.dto.ProjectWorkflowDtos;
import lombok.RequiredArgsConstructor;
import org.springframework.jdbc.core.namedparam.MapSqlParameterSource;
import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate;
import org.springframework.jdbc.support.GeneratedKeyHolder;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.math.BigDecimal;
import java.math.RoundingMode;
import java.time.LocalDate;
import java.util.ArrayList;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import java.util.Objects;

@Service
@RequiredArgsConstructor
public class ProjectWorkflowService {
    private static final TypeReference<List<Map<String, Object>>> FILE_LIST_TYPE = new TypeReference<>() { };
    private static final List<String> PHASE_CODES = List.of("INITIATION", "DEVELOPMENT", "APPLICATION", "RESULT", "ACCEPTANCE");
    private static final List<String> PHASE_NAMES = List.of("立项", "开发", "申报", "申报结果", "验收");

    private final NamedParameterJdbcTemplate jdbc;
    private final ObjectMapper objectMapper;

    public Map<String, Object> getWorkbench(Long projectId) {
        requireProject(projectId);
        List<Map<String, Object>> modules = query("""
                select m.id, m.project_id as projectId, m.module_name as moduleName,
                       m.planned_start_date as plannedStartDate, m.summary,
                       m.project_weight as projectWeight, m.current_progress as currentProgress,
                       (select count(*) from project_management_progress_report r where r.module_id=m.id and r.is_deleted=0) as reportCount,
                       m.create_time as createTime, m.update_time as updateTime
                from project_management_module m
                where m.project_id=:projectId and m.is_deleted=0 order by m.id
                """, Map.of("projectId", projectId));
        for (Map<String, Object> module : modules) {
            Long moduleId = asLong(module.get("id"));
            module.put("members", query("""
                    select id, module_id as moduleId, user_id as userId, user_name as userName,
                           module_share as moduleShare
                    from project_management_module_member
                    where module_id=:moduleId and is_deleted=0 order by id
                    """, Map.of("moduleId", moduleId)));
        }

        List<Map<String, Object>> followUps = query("""
                select id, project_id as projectId, follow_date as followDate, detail,
                       attachments, create_user_id as createUserId, create_user_name as createUserName,
                       create_time as createTime
                from project_management_follow_up
                where project_id=:projectId and is_deleted=0 order by follow_date desc,id desc
                """, Map.of("projectId", projectId));
        parseAttachments(followUps);

        List<Map<String, Object>> reports = query("""
                select r.id, r.project_id as projectId, r.module_id as moduleId,
                       m.module_name as moduleName, r.reporter_ids as reporterIds,
                       r.reporter_names as reporterNames, r.progress, r.report_date as reportDate,
                       r.reporter_shares as reporterShares, r.remark, r.attachments, r.create_time as createTime
                from project_management_progress_report r
                left join project_management_module m on m.id=r.module_id
                where r.project_id=:projectId and r.is_deleted=0 order by r.report_date desc,r.id desc
                """, Map.of("projectId", projectId));
        parseAttachments(reports);
        for (Map<String, Object> row : reports) {
            row.put("reporterIdList", parseLongList(row.get("reporterIds")));
            row.put("reporterNameList", parseStringList(row.get("reporterNames")));
            row.put("reporterShareList", parseFileList(row.get("reporterShares")));
        }

        List<Map<String, Object>> materials = query("""
                select id, project_id as projectId, material_name as materialName,
                       material_type as materialType, remark, attachments,
                       create_user_name as createUserName, create_time as createTime
                from project_management_material
                where project_id=:projectId and is_deleted=0 order by id desc
                """, Map.of("projectId", projectId));
        parseAttachments(materials);

        Map<String, Object> result = new LinkedHashMap<>();
        result.put("modules", modules);
        result.put("followUps", followUps);
        result.put("reports", reports);
        result.put("materials", materials);
        result.put("sourceBusiness", getSourceBusiness(projectId));
        result.put("memberStatistics", memberStatistics(projectId));
        result.put("followWindow", getFollowWindow(projectId));
        return result;
    }

    @Transactional(rollbackFor = Exception.class)
    public void startProject(Long projectId) {
        requireProject(projectId);
        Integer basicReady = jdbc.queryForObject("""
                select count(*) from project_management_info
                where id=:projectId and is_delete=0 and project_classification is not null
                and project_classification<>'' and plan_start_time is not null and plan_end_time is not null
                and project_leader_id is not null and project_manager_ids is not null
                and json_length(project_manager_ids)>0 and follow_cycle is not null and follow_cycle<>''
                and project_executor_ids is not null and json_length(project_executor_ids)>0
                """, Map.of("projectId", projectId), Integer.class);
        if (basicReady == null || basicReady == 0) throw new ServiceException("请先完整填写项目基本情况");
        List<Map<String, Object>> modules = query("""
                select id,module_name as moduleName,planned_start_date as plannedStartDate,
                       summary,project_weight as projectWeight
                from project_management_module where project_id=:projectId and is_deleted=0
                """, Map.of("projectId", projectId));
        if (modules.isEmpty()) throw new ServiceException("项目开始前请至少添加一个项目模块");
        BigDecimal total = BigDecimal.ZERO;
        for (Map<String, Object> module : modules) {
            if (isBlank(Objects.toString(module.get("moduleName"), "")) || module.get("plannedStartDate") == null
                    || isBlank(Objects.toString(module.get("summary"), ""))) {
                throw new ServiceException("请完整填写每个模块的名称、预计开始时间和模块概要");
            }
            total = total.add(nvl((BigDecimal) module.get("projectWeight")));
            Long moduleId = asLong(module.get("id"));
            Integer memberCount = jdbc.queryForObject("""
                    select count(*) from project_management_module_member
                    where module_id=:moduleId and is_deleted=0
                    """, Map.of("moduleId", moduleId), Integer.class);
            if (memberCount == null || memberCount == 0) throw new ServiceException("每个模块至少选择一名执行人");
        }
        if (total.setScale(2, RoundingMode.HALF_UP).compareTo(BigDecimal.valueOf(100).setScale(2)) != 0) {
            throw new ServiceException("项目开始前，所有模块的项目工作量占比合计必须为100%");
        }
        jdbc.update("update project_management_info set current_phase='开发',update_time=now() where id=:projectId", Map.of("projectId", projectId));
    }

    @Transactional(rollbackFor = Exception.class)
    public void transitionStage(ProjectWorkflowDtos.StageTransitionRequest request) {
        requireProject(request.getProjectId());
        String current = jdbc.queryForObject("select current_phase from project_management_info where id=:id and is_delete=0",
                Map.of("id", request.getProjectId()), String.class);
        if ("立项".equals(current)) current = "开发";
        Map<String, String> nextStages = Map.of(
                "开发", "申报",
                "申报", "申报结果",
                "申报结果", "验收",
                "验收", "已完成"
        );
        String expected = nextStages.get(current);
        if (expected == null || !expected.equals(request.getTargetStage())) {
            throw new ServiceException("项目阶段只能按开发、申报、申报结果、验收、已完成的顺序推进");
        }
        if ("开发".equals(current)) {
            Integer unfinished = jdbc.queryForObject("""
                    select count(*) from project_management_module
                    where project_id=:projectId and is_deleted=0 and current_progress<100
                    """, Map.of("projectId", request.getProjectId()), Integer.class);
            if (unfinished != null && unfinished > 0) {
                throw new ServiceException("所有项目模块进度达到100%后才能进入申报阶段");
            }
        }
        jdbc.update("update project_management_info set current_phase=:stage,update_time=now() where id=:projectId",
                new MapSqlParameterSource().addValue("stage", expected).addValue("projectId", request.getProjectId()));
    }

    @Transactional(rollbackFor = Exception.class)
    public void updateProjectExecutors(ProjectWorkflowDtos.ProjectExecutorsRequest request) {
        requireProject(request.getProjectId());
        validateMembers(request.getExecutors());
        List<Map<String, Object>> rows = query("""
                select project_executor_ids as executorIds from project_management_info
                where id=:projectId and is_delete=0
                """, Map.of("projectId", request.getProjectId()));
        List<Long> oldIds = rows.isEmpty() ? List.of() : parseLongList(rows.getFirst().get("executorIds"));
        List<Long> newIds = request.getExecutors().stream().map(ProjectWorkflowDtos.MemberRequest::getUserId).toList();
        for (Long removedId : oldIds.stream().filter(id -> !newIds.contains(id)).toList()) {
            if (hasPositiveProjectShare(request.getProjectId(), removedId)) {
                throw new ServiceException("该项目执行人已有项目汇报工作占比，不能删除");
            }
        }
        jdbc.update("""
                update project_management_info set project_executor_ids=:ids,project_executor_names=:names,update_time=now()
                where id=:projectId and is_delete=0
                """, new MapSqlParameterSource().addValue("projectId", request.getProjectId())
                .addValue("ids", json(newIds))
                .addValue("names", json(request.getExecutors().stream().map(ProjectWorkflowDtos.MemberRequest::getUserName).toList())));
    }

    @Transactional(rollbackFor = Exception.class)
    public Long savePhase(ProjectWorkflowDtos.PhaseRequest request) {
        requireProject(request.getProjectId());
        ensurePhases(request.getProjectId());
        int index = PHASE_CODES.indexOf(Objects.toString(request.getPhaseCode(), ""));
        if (index < 0) throw new ServiceException("项目阶段不正确");
        String status = Objects.toString(request.getStatus(), "IN_PROGRESS").toUpperCase();
        if (!List.of("NOT_STARTED", "IN_PROGRESS", "COMPLETED").contains(status)) {
            throw new ServiceException("阶段状态不正确");
        }
        if (index > 0 && !"NOT_STARTED".equals(status)) {
            Integer previousDone = jdbc.queryForObject("""
                    select count(*) from project_management_phase
                    where project_id=:projectId and phase_code=:phaseCode and status='COMPLETED' and is_deleted=0
                    """, new MapSqlParameterSource().addValue("projectId", request.getProjectId())
                    .addValue("phaseCode", PHASE_CODES.get(index - 1)), Integer.class);
            if (previousDone == null || previousDone == 0) {
                throw new ServiceException("请先完成上一阶段“" + PHASE_NAMES.get(index - 1) + "”");
            }
        }
        MapSqlParameterSource p = new MapSqlParameterSource()
                .addValue("projectId", request.getProjectId()).addValue("phaseCode", request.getPhaseCode())
                .addValue("status", status).addValue("formData", jsonObject(request.getFormData()))
                .addValue("remark", request.getRemark()).addValue("attachments", json(request.getAttachments()))
                .addValue("userName", currentUserName());
        jdbc.update("""
                update project_management_phase set status=:status,form_data=:formData,remark=:remark,
                attachments=:attachments,completed_time=case when :status='COMPLETED' then now() else null end,
                update_user_name=:userName,update_time=now()
                where project_id=:projectId and phase_code=:phaseCode and is_deleted=0
                """, p);
        String currentPhase = "COMPLETED".equals(status) && index == PHASE_CODES.size() - 1
                ? "已完成" : PHASE_NAMES.get(index);
        jdbc.update("update project_management_info set current_phase=:phase,update_time=now() where id=:projectId",
                new MapSqlParameterSource().addValue("phase", currentPhase).addValue("projectId", request.getProjectId()));
        return jdbc.queryForObject("select id from project_management_phase where project_id=:projectId and phase_code=:phaseCode and is_deleted=0",
                p, Long.class);
    }

    @Transactional(rollbackFor = Exception.class)
    public Long saveModule(ProjectWorkflowDtos.ModuleSaveRequest request) {
        requireProject(request.getProjectId());
        if (isBlank(request.getModuleName())) {
            throw new ServiceException("请输入模块名称");
        }
        if (request.getPlannedStartDate() == null) throw new ServiceException("请选择模块预计开始时间");
        if (isBlank(request.getSummary())) throw new ServiceException("请输入模块概要");
        BigDecimal weight = percent(request.getProjectWeight(), "模块在项目中的工作量占比");
        BigDecimal otherWeight = jdbc.queryForObject("""
                select coalesce(sum(project_weight),0) from project_management_module
                where project_id=:projectId and is_deleted=0 and (:id is null or id<>:id)
                """, new MapSqlParameterSource().addValue("projectId", request.getProjectId()).addValue("id", request.getId()), BigDecimal.class);
        BigDecimal available = BigDecimal.valueOf(100).subtract(nvl(otherWeight));
        if (weight.compareTo(available) > 0) {
            throw new ServiceException("其他模块已占" + nvl(otherWeight).stripTrailingZeros().toPlainString()
                    + "%，当前模块最多可设置" + available.stripTrailingZeros().toPlainString() + "%");
        }
        validateMembers(request.getMembers());
        List<Long> projectExecutorIds = projectExecutorIds(request.getProjectId());
        if (request.getMembers().stream().anyMatch(member -> !projectExecutorIds.contains(member.getUserId()))) {
            throw new ServiceException("模块执行人必须先加入项目执行人");
        }

        if (request.getId() != null) {
            Integer reportCount = jdbc.queryForObject("select count(*) from project_management_progress_report where module_id=:id and is_deleted=0",
                    Map.of("id", request.getId()), Integer.class);
            if (reportCount != null && reportCount > 0) {
                Map<String, Object> old = query("""
                        select module_name as moduleName,planned_start_date as plannedStartDate,
                               summary,project_weight as projectWeight from project_management_module
                        where id=:id and project_id=:projectId and is_deleted=0
                        """, new MapSqlParameterSource().addValue("id", request.getId()).addValue("projectId", request.getProjectId())).stream()
                        .findFirst().orElseThrow(() -> new ServiceException("项目模块不存在"));
                boolean changed = !Objects.equals(Objects.toString(old.get("moduleName"), ""), request.getModuleName().trim())
                        || !Objects.equals(Objects.toString(old.get("plannedStartDate"), ""), Objects.toString(request.getPlannedStartDate(), ""))
                        || !Objects.equals(Objects.toString(old.get("summary"), ""), Objects.toString(request.getSummary(), ""))
                        || nvl((BigDecimal) old.get("projectWeight")).compareTo(weight) != 0;
                if (changed) throw new ServiceException("该模块已有进度汇报，模块基础信息和占比不能修改，仅可调整执行人");
            }
            List<Long> oldMemberIds = query("""
                    select user_id as userId from project_management_module_member
                    where module_id=:moduleId and is_deleted=0
                    """, Map.of("moduleId", request.getId())).stream().map(row -> asLong(row.get("userId"))).toList();
            List<Long> newMemberIds = request.getMembers().stream().map(ProjectWorkflowDtos.MemberRequest::getUserId).toList();
            for (Long removedId : oldMemberIds.stream().filter(id -> !newMemberIds.contains(id)).toList()) {
                if (hasPositiveModuleShare(request.getId(), removedId)) {
                    throw new ServiceException("该模块执行人已有本模块工作占比，不能删除");
                }
            }
        }

        Long moduleId = request.getId();
        MapSqlParameterSource params = new MapSqlParameterSource()
                .addValue("projectId", request.getProjectId())
                .addValue("moduleName", request.getModuleName().trim())
                .addValue("plannedStartDate", request.getPlannedStartDate())
                .addValue("summary", request.getSummary())
                .addValue("projectWeight", weight);
        if (moduleId == null) {
            GeneratedKeyHolder keyHolder = new GeneratedKeyHolder();
            jdbc.update("""
                    insert into project_management_module
                    (project_id,module_name,planned_start_date,summary,project_weight,current_progress,is_deleted,create_time,update_time)
                    values (:projectId,:moduleName,:plannedStartDate,:summary,:projectWeight,0,0,now(),now())
                    """, params, keyHolder, new String[]{"id"});
            moduleId = Objects.requireNonNull(keyHolder.getKey()).longValue();
        } else {
            params.addValue("id", moduleId);
            int rows = jdbc.update("""
                    update project_management_module set module_name=:moduleName,
                    planned_start_date=:plannedStartDate,summary=:summary,project_weight=:projectWeight,update_time=now()
                    where id=:id and project_id=:projectId and is_deleted=0
                    """, params);
            if (rows == 0) throw new ServiceException("项目模块不存在");
            jdbc.update("update project_management_module_member set is_deleted=1 where module_id=:id", Map.of("id", moduleId));
        }
        for (ProjectWorkflowDtos.MemberRequest member : request.getMembers()) {
            jdbc.update("""
                    insert into project_management_module_member
                    (module_id,user_id,user_name,module_share,is_deleted,create_time,update_time)
                    values (:moduleId,:userId,:userName,:moduleShare,0,now(),now())
                    """, new MapSqlParameterSource()
                    .addValue("moduleId", moduleId)
                    .addValue("userId", member.getUserId())
                    .addValue("userName", member.getUserName())
                    .addValue("moduleShare", BigDecimal.ZERO));
        }
        return moduleId;
    }

    @Transactional(rollbackFor = Exception.class)
    public void deleteModule(Long id) {
        int count = jdbc.queryForObject("select count(*) from project_management_progress_report where module_id=:id and is_deleted=0", Map.of("id", id), Integer.class);
        if (count > 0) throw new ServiceException("该模块已有进度汇报，不能删除");
        jdbc.update("update project_management_module set is_deleted=1,update_time=now() where id=:id", Map.of("id", id));
        jdbc.update("update project_management_module_member set is_deleted=1,update_time=now() where module_id=:id", Map.of("id", id));
    }

    @Transactional(rollbackFor = Exception.class)
    public Long saveFollowUp(ProjectWorkflowDtos.FollowUpRequest request) {
        requireProject(request.getProjectId());
        Long leaderId = jdbc.queryForObject("select project_leader_id from project_management_info where id=:id",
                Map.of("id", request.getProjectId()), Long.class);
        if (leaderId == null || !leaderId.equals(SecurityUtils.getUserId())) {
            throw new ServiceException("只有项目负责人可以填写项目跟进");
        }
        if (request.getFollowDate() == null || isBlank(request.getDetail())) {
            throw new ServiceException("请填写跟进日期和跟进详情");
        }
        validateFollowWindow(request.getProjectId(), request.getFollowDate(), request.getId());
        MapSqlParameterSource p = new MapSqlParameterSource()
                .addValue("id", request.getId()).addValue("projectId", request.getProjectId())
                .addValue("followDate", request.getFollowDate()).addValue("detail", request.getDetail())
                .addValue("attachments", json(request.getAttachments()))
                .addValue("userId", SecurityUtils.getUserId()).addValue("userName", currentUserName());
        if (request.getId() == null) {
            GeneratedKeyHolder keys = new GeneratedKeyHolder();
            jdbc.update("""
                    insert into project_management_follow_up
                    (project_id,follow_date,detail,attachments,create_user_id,create_user_name,is_deleted,create_time,update_time)
                    values (:projectId,:followDate,:detail,:attachments,:userId,:userName,0,now(),now())
                    """, p, keys, new String[]{"id"});
            return Objects.requireNonNull(keys.getKey()).longValue();
        }
        jdbc.update("""
                update project_management_follow_up set follow_date=:followDate,detail=:detail,
                attachments=:attachments,update_time=now() where id=:id and project_id=:projectId and is_deleted=0
                """, p);
        return request.getId();
    }

    @Transactional(rollbackFor = Exception.class)
    public Long saveReport(ProjectWorkflowDtos.ProgressReportRequest request) {
        requireProject(request.getProjectId());
        if (request.getModuleId() == null || request.getReportDate() == null) {
            throw new ServiceException("请选择项目模块和汇报时间");
        }
        BigDecimal progress = percent(request.getProgress(), "模块进度");
        BigDecimal current = jdbc.queryForObject("""
                select current_progress from project_management_module
                where id=:moduleId and project_id=:projectId and is_deleted=0
                """, new MapSqlParameterSource().addValue("moduleId", request.getModuleId()).addValue("projectId", request.getProjectId()), BigDecimal.class);
        if (current == null) throw new ServiceException("项目模块不存在");
        if (progress.compareTo(current) < 0) throw new ServiceException("本次进度不能低于模块当前进度");
        List<ProjectWorkflowDtos.MemberRequest> reporterShares = normalizeReporterShares(request);
        validateReporterShares(reporterShares);
        List<Long> moduleMemberIds = query("""
                select user_id as userId from project_management_module_member
                where module_id=:moduleId and is_deleted=0
                """, Map.of("moduleId", request.getModuleId())).stream().map(row -> asLong(row.get("userId"))).toList();
        if (!moduleMemberIds.contains(SecurityUtils.getUserId())) throw new ServiceException("只有该模块执行人可以提交进度汇报");
        if (reporterShares.stream().anyMatch(member -> !moduleMemberIds.contains(member.getUserId()))) {
            throw new ServiceException("汇报人员只能选择该模块执行人");
        }
        request.setReporterIds(reporterShares.stream().map(ProjectWorkflowDtos.MemberRequest::getUserId).toList());
        request.setReporterNames(reporterShares.stream().map(ProjectWorkflowDtos.MemberRequest::getUserName).toList());
        MapSqlParameterSource p = new MapSqlParameterSource()
                .addValue("id", request.getId()).addValue("projectId", request.getProjectId())
                .addValue("moduleId", request.getModuleId())
                .addValue("reporterIds", json(request.getReporterIds()))
                .addValue("reporterNames", json(request.getReporterNames()))
                .addValue("reporterShares", json(reporterShares))
                .addValue("progress", progress).addValue("reportDate", request.getReportDate())
                .addValue("remark", request.getRemark()).addValue("attachments", json(request.getAttachments()));
        Long reportId = request.getId();
        if (reportId == null) {
            GeneratedKeyHolder keys = new GeneratedKeyHolder();
            jdbc.update("""
                    insert into project_management_progress_report
                    (project_id,module_id,reporter_ids,reporter_names,reporter_shares,progress,report_date,remark,attachments,is_deleted,create_time,update_time)
                    values (:projectId,:moduleId,:reporterIds,:reporterNames,:reporterShares,:progress,:reportDate,:remark,:attachments,0,now(),now())
                    """, p, keys, new String[]{"id"});
            reportId = Objects.requireNonNull(keys.getKey()).longValue();
        } else {
            jdbc.update("""
                    update project_management_progress_report set module_id=:moduleId,reporter_ids=:reporterIds,
                    reporter_names=:reporterNames,reporter_shares=:reporterShares,progress=:progress,report_date=:reportDate,remark=:remark,
                    attachments=:attachments,update_time=now()
                    where id=:id and project_id=:projectId and is_deleted=0
                    """, p);
        }
        jdbc.update("update project_management_module set current_progress=:progress,update_time=now() where id=:moduleId",
                new MapSqlParameterSource().addValue("progress", progress).addValue("moduleId", request.getModuleId()));
        return reportId;
    }

    @Transactional(rollbackFor = Exception.class)
    public Long saveMaterial(ProjectWorkflowDtos.MaterialRequest request) {
        requireProject(request.getProjectId());
        if (isBlank(request.getMaterialName())) throw new ServiceException("请输入资料名称");
        MapSqlParameterSource p = new MapSqlParameterSource()
                .addValue("id", request.getId()).addValue("projectId", request.getProjectId())
                .addValue("materialName", request.getMaterialName()).addValue("materialType", request.getMaterialType())
                .addValue("remark", request.getRemark()).addValue("attachments", json(request.getAttachments()))
                .addValue("userId", SecurityUtils.getUserId()).addValue("userName", currentUserName());
        if (request.getId() == null) {
            GeneratedKeyHolder keys = new GeneratedKeyHolder();
            jdbc.update("""
                    insert into project_management_material
                    (project_id,material_name,material_type,remark,attachments,create_user_id,create_user_name,is_deleted,create_time,update_time)
                    values (:projectId,:materialName,:materialType,:remark,:attachments,:userId,:userName,0,now(),now())
                    """, p, keys, new String[]{"id"});
            return Objects.requireNonNull(keys.getKey()).longValue();
        }
        jdbc.update("""
                update project_management_material set material_name=:materialName,material_type=:materialType,
                remark=:remark,attachments=:attachments,update_time=now()
                where id=:id and project_id=:projectId and is_deleted=0
                """, p);
        return request.getId();
    }

    public void softDelete(String table, Long id) {
        if (!List.of("project_management_follow_up", "project_management_progress_report", "project_management_material", "government_policy_file").contains(table)) {
            throw new ServiceException("不支持的删除类型");
        }
        jdbc.getJdbcTemplate().update("update " + table + " set is_deleted=1,update_time=now() where id=?", id);
    }

    public List<Map<String, Object>> listCategories() {
        return query("""
                select id,parent_id as parentId,category_name as categoryName,sort,remark
                from project_management_category where is_deleted=0 order by sort,id
                """, Map.of());
    }

    @Transactional(rollbackFor = Exception.class)
    public Long saveCategory(ProjectWorkflowDtos.CategoryRequest request) {
        if (isBlank(request.getCategoryName())) throw new ServiceException("请输入分类名称");
        Long parentId = request.getParentId() == null ? 0L : request.getParentId();
        if (request.getId() != null && request.getId().equals(parentId)) throw new ServiceException("上级分类不能选择自己");
        MapSqlParameterSource p = new MapSqlParameterSource().addValue("id", request.getId())
                .addValue("parentId", parentId).addValue("categoryName", request.getCategoryName().trim())
                .addValue("sort", request.getSort() == null ? 0 : request.getSort()).addValue("remark", request.getRemark());
        if (request.getId() == null) {
            GeneratedKeyHolder keys = new GeneratedKeyHolder();
            jdbc.update("""
                    insert into project_management_category(parent_id,category_name,sort,remark,is_deleted,create_time,update_time)
                    values (:parentId,:categoryName,:sort,:remark,0,now(),now())
                    """, p, keys, new String[]{"id"});
            return Objects.requireNonNull(keys.getKey()).longValue();
        }
        jdbc.update("""
                update project_management_category set parent_id=:parentId,category_name=:categoryName,
                sort=:sort,remark=:remark,update_time=now() where id=:id and is_deleted=0
                """, p);
        return request.getId();
    }

    public void deleteCategory(Long id) {
        int children = jdbc.queryForObject("select count(*) from project_management_category where parent_id=:id and is_deleted=0", Map.of("id", id), Integer.class);
        if (children > 0) throw new ServiceException("请先删除下级分类");
        jdbc.update("update project_management_category set is_deleted=1,update_time=now() where id=:id", Map.of("id", id));
    }

    public List<Map<String, Object>> listPolicies(String keyword) {
        MapSqlParameterSource p = new MapSqlParameterSource().addValue("keyword", keyword == null ? "" : keyword.trim());
        List<Map<String, Object>> rows = query("""
                select id,policy_name as policyName,publish_date as publishDate,policy_url as policyUrl,
                       attachments,maintainer_name as maintainerName,remark,create_time as createTime
                from government_policy_file where is_deleted=0
                and (:keyword='' or policy_name like concat('%',:keyword,'%'))
                order by publish_date desc,id desc
                """, p);
        parseAttachments(rows);
        return rows;
    }

    @Transactional(rollbackFor = Exception.class)
    public Long savePolicy(ProjectWorkflowDtos.PolicyRequest request) {
        if (isBlank(request.getPolicyName())) throw new ServiceException("请输入政策名称");
        String maintainer = isBlank(request.getMaintainerName()) ? currentUserName() : request.getMaintainerName();
        MapSqlParameterSource p = new MapSqlParameterSource().addValue("id", request.getId())
                .addValue("policyName", request.getPolicyName()).addValue("publishDate", request.getPublishDate())
                .addValue("policyUrl", request.getPolicyUrl()).addValue("attachments", json(request.getAttachments()))
                .addValue("maintainer", maintainer).addValue("remark", request.getRemark());
        if (request.getId() == null) {
            GeneratedKeyHolder keys = new GeneratedKeyHolder();
            jdbc.update("""
                    insert into government_policy_file
                    (policy_name,publish_date,policy_url,attachments,maintainer_name,remark,is_deleted,create_time,update_time)
                    values (:policyName,:publishDate,:policyUrl,:attachments,:maintainer,:remark,0,now(),now())
                    """, p, keys, new String[]{"id"});
            return Objects.requireNonNull(keys.getKey()).longValue();
        }
        jdbc.update("""
                update government_policy_file set policy_name=:policyName,publish_date=:publishDate,
                policy_url=:policyUrl,attachments=:attachments,maintainer_name=:maintainer,
                remark=:remark,update_time=now() where id=:id and is_deleted=0
                """, p);
        return request.getId();
    }

    private List<Map<String, Object>> memberStatistics(Long projectId) {
        List<Map<String, Object>> reports = query("""
                select r.module_id as moduleId,r.progress,r.reporter_ids as reporterIds,
                       r.reporter_names as reporterNames,r.reporter_shares as reporterShares,
                       m.project_weight as projectWeight
                from project_management_progress_report r
                join project_management_module m on m.id=r.module_id and m.is_deleted=0
                where r.project_id=:projectId and r.is_deleted=0
                order by r.module_id,r.report_date,r.id
                """, Map.of("projectId", projectId));
        Map<Long, BigDecimal> previousProgress = new LinkedHashMap<>();
        Map<Long, Map<String, Object>> totals = new LinkedHashMap<>();
        for (Map<String, Object> report : reports) {
            Long moduleId = asLong(report.get("moduleId"));
            BigDecimal progress = nvl((BigDecimal) report.get("progress"));
            BigDecimal previous = previousProgress.getOrDefault(moduleId, BigDecimal.ZERO);
            BigDecimal delta = progress.subtract(previous).max(BigDecimal.ZERO);
            previousProgress.put(moduleId, progress.max(previous));
            List<Map<String, Object>> shares = parseFileList(report.get("reporterShares"));
            if (shares.isEmpty()) shares = equalReporterShares(report.get("reporterIds"), report.get("reporterNames"));
            BigDecimal moduleWeight = nvl((BigDecimal) report.get("projectWeight"));
            for (Map<String, Object> share : shares) {
                Long userId = asLong(share.get("userId"));
                if (userId == null) continue;
                String userName = Objects.toString(share.get("userName"), "");
                BigDecimal memberShare = new BigDecimal(Objects.toString(share.get("moduleShare"), "0"));
                BigDecimal contribution = moduleWeight.multiply(delta).multiply(memberShare)
                        .divide(BigDecimal.valueOf(10000), 2, RoundingMode.HALF_UP);
                Map<String, Object> total = totals.computeIfAbsent(userId, id -> {
                    Map<String, Object> item = new LinkedHashMap<>();
                    item.put("userId", id); item.put("userName", userName); item.put("value", BigDecimal.ZERO);
                    return item;
                });
                total.put("value", ((BigDecimal) total.get("value")).add(contribution));
            }
        }
        return totals.values().stream()
                .sorted((a, b) -> ((BigDecimal) b.get("value")).compareTo((BigDecimal) a.get("value")))
                .toList();
    }

    private Map<String, Object> getFollowWindow(Long projectId) {
        List<Map<String, Object>> projectRows = query("""
                select follow_cycle as followCycle,plan_start_time as planStartTime
                from project_management_info where id=:projectId and is_delete=0
                """, Map.of("projectId", projectId));
        if (projectRows.isEmpty()) return Map.of();
        String cycle = Objects.toString(projectRows.getFirst().get("followCycle"), "");
        LocalDate last = jdbc.query("""
                select follow_date from project_management_follow_up
                where project_id=:projectId and is_deleted=0 order by follow_date desc,id desc limit 1
                """, Map.of("projectId", projectId), rs -> rs.next() ? rs.getDate(1).toLocalDate() : null);
        Map<String, Object> result = new LinkedHashMap<>();
        result.put("cycle", cycle);
        result.put("lastFollowDate", last);
        LocalDate planStart = projectRows.getFirst().get("planStartTime") instanceof java.sql.Date date ? date.toLocalDate() : null;
        LocalDate base = last == null ? planStart : last;
        if (base != null) {
            LocalDate due = nextDue(base, cycle);
            result.put("dueDate", due);
            result.put("windowStart", due.minusDays(3));
            result.put("windowEnd", due.plusDays(3));
        }
        return result;
    }

    private void ensurePhases(Long projectId) {
        for (int i = 0; i < PHASE_CODES.size(); i++) {
            jdbc.update("""
                    insert into project_management_phase
                    (project_id,phase_code,phase_name,phase_order,status,is_deleted,create_time,update_time)
                    select :projectId,:phaseCode,:phaseName,:phaseOrder,'NOT_STARTED',0,now(),now()
                    where not exists(select 1 from project_management_phase
                      where project_id=:projectId and phase_code=:phaseCode and is_deleted=0)
                    """, new MapSqlParameterSource().addValue("projectId", projectId)
                    .addValue("phaseCode", PHASE_CODES.get(i)).addValue("phaseName", PHASE_NAMES.get(i))
                    .addValue("phaseOrder", i + 1));
        }
    }

    private Map<String, Object> getSourceBusiness(Long projectId) {
        List<Map<String, Object>> rows = query("""
                select sl.id,sl.project_name as projectName,sl.customer_id as customerId,
                       sl.customer_name as customerName,sl.salesman,sl.entry_date as entryDate,
                       sl.remarks,sl.attachment_materials as attachmentMaterials,
                       sl.business_approval_status as approvalStatus,
                       sl.business_approval_remark as approvalRemark
                from project_management_info p
                join sales_ledger sl on sl.id=p.source_business_id
                where p.id=:projectId and p.source_business_id is not null
                """, Map.of("projectId", projectId));
        if (rows.isEmpty()) return Map.of();
        Map<String, Object> row = rows.getFirst();
        row.put("attachmentList", parseFileList(row.get("attachmentMaterials")));
        return row;
    }

    private void validateFollowWindow(Long projectId, LocalDate followDate, Long excludeId) {
        MapSqlParameterSource p = new MapSqlParameterSource().addValue("projectId", projectId).addValue("excludeId", excludeId);
        LocalDate last = jdbc.query("""
                select follow_date from project_management_follow_up
                where project_id=:projectId and is_deleted=0 and (:excludeId is null or id<>:excludeId)
                order by follow_date desc,id desc limit 1
                """, p, rs -> rs.next() ? rs.getDate(1).toLocalDate() : null);
        String cycle = jdbc.queryForObject("select follow_cycle from project_management_info where id=:projectId", Map.of("projectId", projectId), String.class);
        LocalDate base = last;
        if (base == null) {
            base = jdbc.query("select plan_start_time from project_management_info where id=:projectId", Map.of("projectId", projectId),
                    rs -> rs.next() && rs.getDate(1) != null ? rs.getDate(1).toLocalDate() : null);
        }
        if (base == null) throw new ServiceException("请先填写项目预计开始时间");
        LocalDate due = nextDue(base, cycle);
        if (followDate.isBefore(due.minusDays(3)) || followDate.isAfter(due.plusDays(3))) {
            throw new ServiceException("本次跟进应在" + due.minusDays(3) + "至" + due.plusDays(3) + "之间填写");
        }
    }

    private LocalDate nextDue(LocalDate base, String cycle) {
        return switch (Objects.toString(cycle, "MONTH").toUpperCase()) {
            case "QUARTER", "季度", "每季度" -> base.plusMonths(3);
            case "YEAR", "年度", "每年" -> base.plusYears(1);
            default -> base.plusMonths(1);
        };
    }

    private void validateMembers(List<ProjectWorkflowDtos.MemberRequest> members) {
        if (members == null || members.isEmpty()) throw new ServiceException("请至少选择一名模块执行人");
        List<Long> ids = new ArrayList<>();
        for (ProjectWorkflowDtos.MemberRequest member : members) {
            if (member.getUserId() == null || isBlank(member.getUserName())) throw new ServiceException("模块执行人不能为空");
            if (ids.contains(member.getUserId())) throw new ServiceException("模块执行人不能重复");
            ids.add(member.getUserId());
        }
    }

    private List<Long> projectExecutorIds(Long projectId) {
        List<Map<String, Object>> rows = query("""
                select project_executor_ids as executorIds from project_management_info
                where id=:projectId and is_delete=0
                """, Map.of("projectId", projectId));
        return rows.isEmpty() ? List.of() : parseLongList(rows.getFirst().get("executorIds"));
    }

    private boolean hasPositiveProjectShare(Long projectId, Long userId) {
        return hasPositiveShare(query("""
                select reporter_ids as reporterIds,reporter_names as reporterNames,reporter_shares as reporterShares
                from project_management_progress_report where project_id=:projectId and is_deleted=0
                """, Map.of("projectId", projectId)), userId);
    }

    private boolean hasPositiveModuleShare(Long moduleId, Long userId) {
        return hasPositiveShare(query("""
                select reporter_ids as reporterIds,reporter_names as reporterNames,reporter_shares as reporterShares
                from project_management_progress_report where module_id=:moduleId and is_deleted=0
                """, Map.of("moduleId", moduleId)), userId);
    }

    private boolean hasPositiveShare(List<Map<String, Object>> reports, Long userId) {
        for (Map<String, Object> report : reports) {
            List<Map<String, Object>> shares = parseFileList(report.get("reporterShares"));
            if (shares.isEmpty()) shares = equalReporterShares(report.get("reporterIds"), report.get("reporterNames"));
            for (Map<String, Object> share : shares) {
                if (Objects.equals(asLong(share.get("userId")), userId)
                        && new BigDecimal(Objects.toString(share.get("moduleShare"), "0")).compareTo(BigDecimal.ZERO) > 0) {
                    return true;
                }
            }
        }
        return false;
    }

    private void validateReporterShares(List<ProjectWorkflowDtos.MemberRequest> members) {
        if (members == null || members.isEmpty()) throw new ServiceException("请至少选择一名汇报人");
        BigDecimal sum = BigDecimal.ZERO;
        List<Long> ids = new ArrayList<>();
        for (ProjectWorkflowDtos.MemberRequest member : members) {
            if (member.getUserId() == null || isBlank(member.getUserName())) throw new ServiceException("汇报人不能为空");
            if (ids.contains(member.getUserId())) throw new ServiceException("汇报人不能重复");
            ids.add(member.getUserId());
            sum = sum.add(percent(member.getModuleShare(), "本次汇报人员比重"));
        }
        if (sum.setScale(2, RoundingMode.HALF_UP).compareTo(BigDecimal.valueOf(100).setScale(2)) != 0) {
            throw new ServiceException("本次汇报人员比重合计必须为100%");
        }
    }

    private List<ProjectWorkflowDtos.MemberRequest> normalizeReporterShares(ProjectWorkflowDtos.ProgressReportRequest request) {
        if (request.getReporterShares() != null && !request.getReporterShares().isEmpty()) return request.getReporterShares();
        List<Long> ids = request.getReporterIds() == null ? List.of() : request.getReporterIds();
        List<String> names = request.getReporterNames() == null ? List.of() : request.getReporterNames();
        if (ids.isEmpty()) return new ArrayList<>();
        BigDecimal share = BigDecimal.valueOf(100).divide(BigDecimal.valueOf(ids.size()), 2, RoundingMode.DOWN);
        List<ProjectWorkflowDtos.MemberRequest> result = new ArrayList<>();
        for (int i = 0; i < ids.size(); i++) {
            ProjectWorkflowDtos.MemberRequest member = new ProjectWorkflowDtos.MemberRequest();
            member.setUserId(ids.get(i)); member.setUserName(i < names.size() ? names.get(i) : "");
            member.setModuleShare(i == ids.size() - 1 ? BigDecimal.valueOf(100).subtract(share.multiply(BigDecimal.valueOf(i))) : share);
            result.add(member);
        }
        return result;
    }

    private List<Map<String, Object>> equalReporterShares(Object rawIds, Object rawNames) {
        List<Long> ids = parseLongList(rawIds);
        List<String> names = parseStringList(rawNames);
        if (ids.isEmpty()) return new ArrayList<>();
        BigDecimal share = BigDecimal.valueOf(100).divide(BigDecimal.valueOf(ids.size()), 2, RoundingMode.DOWN);
        List<Map<String, Object>> result = new ArrayList<>();
        for (int i = 0; i < ids.size(); i++) {
            Map<String, Object> item = new LinkedHashMap<>();
            item.put("userId", ids.get(i)); item.put("userName", i < names.size() ? names.get(i) : "");
            item.put("moduleShare", i == ids.size() - 1 ? BigDecimal.valueOf(100).subtract(share.multiply(BigDecimal.valueOf(i))) : share);
            result.add(item);
        }
        return result;
    }

    private BigDecimal percent(BigDecimal value, String label) {
        BigDecimal val = nvl(value);
        if (val.compareTo(BigDecimal.ZERO) < 0 || val.compareTo(BigDecimal.valueOf(100)) > 0) {
            throw new ServiceException(label + "必须在0到100之间");
        }
        return val.setScale(2, RoundingMode.HALF_UP);
    }

    private void requireProject(Long projectId) {
        if (projectId == null) throw new ServiceException("项目不能为空");
        Integer count = jdbc.queryForObject("select count(*) from project_management_info where id=:id and is_delete=0", Map.of("id", projectId), Integer.class);
        if (count == null || count == 0) throw new ServiceException("项目不存在");
    }

    private List<Map<String, Object>> query(String sql, Map<String, ?> params) {
        return jdbc.queryForList(sql, params);
    }

    private List<Map<String, Object>> query(String sql, MapSqlParameterSource params) {
        return jdbc.queryForList(sql, params);
    }

    private void parseAttachments(List<Map<String, Object>> rows) {
        for (Map<String, Object> row : rows) row.put("attachmentList", parseFileList(row.get("attachments")));
    }

    private List<Map<String, Object>> parseFileList(Object raw) {
        if (raw == null || raw.toString().isBlank()) return new ArrayList<>();
        try {
            return objectMapper.readValue(raw.toString(), FILE_LIST_TYPE);
        } catch (Exception ignored) {
            return new ArrayList<>();
        }
    }

    private List<Long> parseLongList(Object raw) {
        if (raw == null || raw.toString().isBlank()) return new ArrayList<>();
        try {
            return objectMapper.readValue(raw.toString(), new TypeReference<>() { });
        } catch (Exception ignored) {
            return new ArrayList<>();
        }
    }

    private List<String> parseStringList(Object raw) {
        if (raw == null || raw.toString().isBlank()) return new ArrayList<>();
        try {
            return objectMapper.readValue(raw.toString(), new TypeReference<>() { });
        } catch (Exception ignored) {
            return new ArrayList<>();
        }
    }

    private Map<String, Object> parseObjectMap(Object raw) {
        if (raw == null || raw.toString().isBlank()) return new LinkedHashMap<>();
        try {
            return objectMapper.readValue(raw.toString(), new TypeReference<>() { });
        } catch (Exception ignored) {
            return new LinkedHashMap<>();
        }
    }

    private String json(Object value) {
        try {
            return objectMapper.writeValueAsString(value == null ? List.of() : value);
        } catch (Exception e) {
            throw new ServiceException("附件或人员数据格式不正确");
        }
    }

    private String jsonObject(Object value) {
        try {
            return objectMapper.writeValueAsString(value == null ? Map.of() : value);
        } catch (Exception e) {
            throw new ServiceException("阶段信息格式不正确");
        }
    }

    private String currentUserName() {
        return SecurityUtils.getLoginUser() == null ? "" : SecurityUtils.getLoginUser().getNickName();
    }

    private boolean isBlank(String value) {
        return value == null || value.trim().isEmpty();
    }

    private BigDecimal nvl(BigDecimal value) {
        return value == null ? BigDecimal.ZERO : value;
    }

    private Long asLong(Object value) {
        return value == null ? null : Long.valueOf(value.toString());
    }
}