package shkd.repc.resm.formplugin;

import kd.bos.bill.AbstractBillPlugIn;
import kd.bos.dataentity.OperateOption;
import kd.bos.dataentity.entity.DynamicObject;
import kd.bos.dataentity.entity.DynamicObjectCollection;
import kd.bos.dataentity.utils.StringUtils;
import kd.bos.form.control.Control;
import kd.bos.logging.Log;
import kd.bos.logging.LogFactory;
import kd.bos.orm.query.QCP;
import kd.bos.orm.query.QFilter;
import kd.bos.servicehelper.BusinessDataServiceHelper;
import kd.bos.servicehelper.botp.BFTrackerServiceHelper;
import kd.bos.servicehelper.operation.SaveServiceHelper;
import kd.bos.servicehelper.org.OrgUnitServiceHelper;
import kd.bos.servicehelper.org.OrgViewType;
import kd.scm.bid.common.constant.entity.BidTemplateMangeEntity;
import kd.sdk.plugin.Plugin;

import java.math.BigDecimal;
import java.math.RoundingMode;
import java.util.ArrayList;
import java.util.EventObject;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;

/**
 * 自动设置考察任务考察对象
 */
public class AutomaticallySetObjectPlugin extends AbstractBillPlugIn implements Plugin {

    private static final Log logger = LogFactory.getLog(AutomaticallySetObjectPlugin.class);

    @Override
    public void afterBindData(EventObject e) {
        super.afterBindData(e);

        DynamicObject dataEntity = this.getModel().getDataEntity();
        DynamicObjectCollection entry = dataEntity.getDynamicObjectCollection("entry_evaldetail");

        if (entry == null || entry.isEmpty()) return;

        String object = entry.get(0).getString("entryevaluatorstr");

        // 状态暂存且分录考察人为空
        if ("A".equals(this.getModel().getValue("billstatus")) && "".equals(object)) {

            // 获取取值逻辑
            DynamicObject dataModel = BusinessDataServiceHelper.loadSingle("qeug_datamodel",
                    (new QFilter("qeug_projectsource", QCP.equals, "考察计划")).toArray());

            if (dataModel == null) return;

            String projectSource = dataModel.getString("qeug_projectsource");
            Long orgId;
            if ("考察计划".equals(projectSource)) {

                // 获取考察详情
                QFilter qFilter = new QFilter("plandetails.evaltask", QCP.equals, dataEntity.getPkValue());
                DynamicObject plane = BusinessDataServiceHelper.loadSingle("resm_investigationplan", qFilter.toArray());

                if (plane == null) return;

                DynamicObject project = plane.getDynamicObject("qeug_project");
                if (project == null) return;

                // 获取项目-所属组织
                QFilter qFilter1 = new QFilter("id", QCP.equals, project.get("id"));
                DynamicObject dynamicObject1 = BusinessDataServiceHelper.loadSingle("repmd_projectbill", qFilter1.toArray());
                if (dynamicObject1 == null) return;

                DynamicObject org = dynamicObject1.getDynamicObject("org");
                if (org == null) return;

                orgId = org.getLong("id");
                DynamicObjectCollection dataModelEntry = dataModel.getDynamicObjectCollection("entryentity");

                // 使用 Stream API 获取所有匹配的 role 对象
                List<DynamicObject> matchingRoles = dataModelEntry.stream()
                        .map(modelEntry -> modelEntry.getString("qeug_rolenumber"))
                        .filter(roleNumber -> roleNumber != null)
                        .map(roleNumber -> BusinessDataServiceHelper.loadSingle("wf_role", new QFilter("number", QCP.equals, roleNumber).toArray()))
                        .filter(roleDynamic -> roleDynamic != null)
                        .filter(roleDynamic -> roleDynamic.getDynamicObjectCollection("roleentry") != null && !roleDynamic.getDynamicObjectCollection("roleentry").isEmpty()) // 跳过 roleentry 为空的情况
                        .flatMap(roleDynamic -> roleDynamic.getDynamicObjectCollection("roleentry").stream())
                        .filter(role -> {
                            Long roleOrgId = role.getLong("org.id");
                            return roleOrgId != null && roleOrgId.compareTo(orgId) == 0; // 筛选符合条件的 role
                        })
                        .collect(Collectors.toList());
                // 如果有匹配项
                if (!((List<?>) matchingRoles).isEmpty()) {
                    creatExamData(matchingRoles, entry);
                } else {
                    findParentOrgMatch(entry, orgId, dataModelEntry);
                }
                SaveServiceHelper.saveOperate("resm_exam_task", new DynamicObject[]{dataEntity}, OperateOption.create());
            }
        }
        this.getView().updateView("entry_evaldetail");
    }


    /**
     * 递归查找上级组织
     *
     * @param entry          考察任务分录
     * @param orgId          当前工作流角色组织
     * @param dataModelEntry 取数模板
     */
    private void findParentOrgMatch(DynamicObjectCollection entry, Long orgId, DynamicObjectCollection dataModelEntry) {
        if (orgId == null) return;
        //取上级组织.
        List<Long> dptIds = new ArrayList<>();
        dptIds.add(orgId);
        Map<Long, Long> orgParentMap = OrgUnitServiceHelper.getDirectSuperiorOrg(OrgViewType.Admin, dptIds);
        if (orgParentMap != null) {
            Long parentId = orgParentMap.get(orgId);
            DynamicObject parentOrg = BusinessDataServiceHelper.loadSingle(parentId, "bos_adminorg");
            if (parentOrg != null) {
                orgId = parentOrg.getLong("id");
                // 使用 Stream API 获取所有匹配的 role 对象
                Long finalOrgId = orgId;
                List<DynamicObject> matchingRoles = dataModelEntry.stream()
                        .map(modelEntry -> modelEntry.getString("qeug_rolenumber"))
                        .filter(roleNumber -> roleNumber != null)
                        .map(roleNumber -> BusinessDataServiceHelper.loadSingle("wf_role", new QFilter("number", QCP.equals, roleNumber).toArray()))
                        .filter(roleDynamic -> roleDynamic != null)
                        .filter(roleDynamic -> roleDynamic.getDynamicObjectCollection("roleentry") != null && !roleDynamic.getDynamicObjectCollection("roleentry").isEmpty()) // 跳过 roleentry 为空的情况
                        .flatMap(roleDynamic -> roleDynamic.getDynamicObjectCollection("roleentry").stream())
                        .filter(role -> {
                            Long roleOrgId = role.getLong("org.id");
                            return roleOrgId != null && roleOrgId.compareTo(finalOrgId) == 0; // 筛选符合条件的 role
                        })
                        .collect(Collectors.toList());
                // 如果有匹配项，则返回；否则递归查找上级组织
                if (!matchingRoles.isEmpty()) {
                    creatExamData(matchingRoles, entry);
                } else {
                    findParentOrgMatch(entry, orgId, dataModelEntry); // 没有匹配项，递归调用上级组织
                }
            }
        }
    }

    /**
     * 生成考察人
     * @param matchingRoles 收集符合条件的人员
     * @param entry         考察任务分录
     */
    private void creatExamData(List<DynamicObject> matchingRoles, DynamicObjectCollection entry) {
        for (DynamicObject dynamicObject : entry) {
            StringBuilder objectText = new StringBuilder();
            DynamicObject examuator = BusinessDataServiceHelper.newDynamicObject("resm_examuator");
            String pkValue = dynamicObject.getString("id");
            examuator.set("evalentryid", pkValue);

            DynamicObjectCollection entryCollection = examuator.getDynamicObjectCollection("entry_evaluator");

            boolean isSingleRole = matchingRoles.size() == 1;

            for (int i = 0; i < matchingRoles.size(); i++) {
                DynamicObject matchingRole = matchingRoles.get(i);
                DynamicObject evaluator = entryCollection.addNew();
                evaluator.set("user", matchingRole.getLong("user.id"));
                evaluator.set("userposition", matchingRole.getLong("userposition.id"));

                String name = matchingRole.getString("user.name");
                BigDecimal weight = calculateWeight(matchingRoles.size(), i);
                String weightPercentage = formatWeight(weight);

                if (isSingleRole) {
                    objectText.append(name).append("（").append(weightPercentage).append("）");
                } else {
                    if (i > 0) objectText.append(";");
                    objectText.append(name).append("（").append(weightPercentage).append("）");
                }

                evaluator.set("weight", weight);
                evaluator.set("seq", i + 1);
            }
            dynamicObject.set("entryevaluatorstr", objectText);
            try {
                SaveServiceHelper.saveOperate("resm_examuator", new DynamicObject[]{examuator}, OperateOption.create());
            } catch (Exception ex) {
                logger.error("保存考察人数据失败", ex);
            }
        }
    }


    /**
     * 权重计算
     * @param totalRoles 人员列表
     * @param currentIndex 行数
     * @return 权重
     */
    private BigDecimal calculateWeight(int totalRoles, int currentIndex) {
        BigDecimal weight = new BigDecimal(1.0 / totalRoles).setScale(2, RoundingMode.HALF_UP);
        if (totalRoles % 2 == 1 && currentIndex == totalRoles - 1 && totalRoles != 1) {
            weight = weight.add(new BigDecimal(0.01));
        }
        return weight;
    }

    /**
     * 权重转百分比
     * @param weight 权重
     * @return 百分比字符串
     */
    private String formatWeight(BigDecimal weight) {
        return weight.multiply(new BigDecimal(100)).setScale(0, RoundingMode.HALF_UP) + "%";
    }



}