package com.fzzy.igds.app.v1.service.impl;

import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.fzzy.common.constant.RespCodeEnum;
import com.fzzy.igds.app.v1.constant.PhoneConstant;
import com.fzzy.igds.app.v1.data.AuthUser;
import com.fzzy.igds.app.v1.data.ParamOrder;
import com.fzzy.igds.app.v1.data.PhoneRequest;
import com.fzzy.igds.app.v1.data.PhoneResponse;
import com.fzzy.igds.app.v1.mapper.PhoneMapper;
import com.fzzy.igds.app.v1.service.PhoneService;
import com.fzzy.igds.app.v1.util.PhoneRespUtil;
import com.fzzy.igds.constant.Constant;
import com.fzzy.igds.data.BaseResp;
import com.fzzy.igds.utils.ContextUtil;
import com.fzzy.work.data.WorkNode;
import com.fzzy.work.data.WorkStatus;
import com.fzzy.work.domain.WorkOrder;
import com.fzzy.work.domain.WorkOrderConf;
import com.fzzy.work.domain.WorkOrderProcess;
import com.fzzy.work.mapper.WorkOrderMapper;
import com.fzzy.work.service.WorkOrderConfService;
import com.fzzy.work.service.WorkOrderProcessService;
import com.fzzy.work.service.WorkOrderService;
import com.ruoyi.common.core.domain.entity.SysUser;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.Date;

/**
 * @Author: YYC
 * @Description: 工单管理-工单审核
 * @DateTime: 2026-1-12 14:43
 **/
@Service
public class ServiceImpl5102 implements PhoneService {

    @Resource
    private WorkOrderService orderService;
    @Resource
    private WorkOrderConfService confService;
    @Resource
    private WorkOrderProcessService orderProcessService;


    @Override
    public String getInterfaceId() {
        return PhoneConstant.API_PHONE_5102;
    }

    @Override
    public PhoneResponse<Object> execute(PhoneRequest<JSONObject> req, AuthUser authUser) throws Exception {
        //转化对象
        ParamOrder param = JSONObject.parseObject(req.getData().toString(), ParamOrder.class);
        if (null == param) {
            return PhoneRespUtil.error(RespCodeEnum.CODE_1111, "参数有误，请重试！！");
        }
        //参数验证
        if (StringUtils.isEmpty(param.getDeptId())) {
            return PhoneRespUtil.error(RespCodeEnum.CODE_1111, "参数有误，请重试！！");
        }
        //获取工单
        WorkOrder work = orderService.selectById(param.getOrderId());
        if (null == work) return PhoneRespUtil.error(RespCodeEnum.CODE_1111, "当前工单已不存在");

        if (work.getStatus().equals(WorkStatus.STATUS_50.getCode())
                || work.getStatus().equals(WorkStatus.STATUS_60.getCode())) {
            return PhoneRespUtil.error(RespCodeEnum.CODE_1111, "当前工单已处理，请刷新页面重试！！");
        }
        WorkOrderProcess process = new WorkOrderProcess();
        BeanUtils.copyProperties(param, process);
        //判断是不是指定处理人
        if (StringUtils.isNotEmpty(work.getAssigneeId())) {
            if (!work.getAssigneeId().equals(authUser.getUsername())) {
                return PhoneRespUtil.error(RespCodeEnum.CODE_1111, "当前工单已分配其他人处理，请勿处理");
            }
        }

        String curNode = process.getNode();
        //获取处理人
        if (!curNode.equals(work.getNode())) {
            return PhoneRespUtil.error(RespCodeEnum.CODE_1111, "当前工单已被处理，请刷新页面重试！！");
        }

        //获取配置信息
        WorkOrderConf conf = confService.selectById(work.getConfId());
        if (null == conf) PhoneRespUtil.error(RespCodeEnum.CODE_1111, "当前工单未配置流程");


        //添加记录
        process.setId(ContextUtil.UUID());
        process.setCreateTime(new Date());
        process.setOrderId(work.getId());
        process.setAssigneeName(authUser.getCname());
        process.setAssigneeId(authUser.getUsername());

        WorkNode nextNode = this.getNextNode(work.getNode(), conf);

        //通过操作
        if ("pass".equals(param.getStatus())) {
            process.setAction("通过");
            process.setNode(work.getNode());
            //结束判断，如果是结束节点，则结束工单
            if (WorkNode.NODE_END.getCode().equals(nextNode.getCode())) {
                work.setStatus(WorkStatus.STATUS_50.getCode());
                work.setAssigneeName(process.getAssigneeName());
                work.setAssigneeId(process.getAssigneeId());
                work.setNode(nextNode.getCode());
                orderService.complete(work);
            } else {
                work.setNode(nextNode.getCode());
                work.setStatus(WorkStatus.STATUS_30.getCode());
                orderService.updateData(work);
            }

            //增加审批记录
            orderProcessService.addData(process, WorkNode.NODE_END.equals(nextNode));
            return PhoneRespUtil.success(RespCodeEnum.CODE_0000.getCode(), req);
        }

        //拒绝操作
        if ("refuse".equals(param.getStatus())) {
            process.setAction("拒绝");
            process.setNode(work.getNode());

            work.setStatus(WorkStatus.STATUS_60.getCode());

            orderService.complete(work);

            //增加审批记录
            orderProcessService.addData(process, true);

            return PhoneRespUtil.success(RespCodeEnum.CODE_0000.getCode(), req);
        }

        return PhoneRespUtil.success(RespCodeEnum.CODE_0000.getCode(), req);
    }


    /**
     * 根据当前节点获取下一个节点
     *
     * @param curNode
     * @param conf
     * @return
     */
    private WorkNode getNextNode(String curNode, WorkOrderConf conf) {

        if (null == conf) return WorkNode.NODE_END;

        if (WorkNode.NODE_START.getCode().equals(curNode)) {
            if (Constant.YN_Y.equals(conf.getNodeVal1())) return WorkNode.NODE1;
            if (Constant.YN_Y.equals(conf.getNodeVal2())) return WorkNode.NODE2;
            if (Constant.YN_Y.equals(conf.getNodeVal3())) return WorkNode.NODE3;
        }

        if (WorkNode.NODE1.getCode().equals(curNode)) {
            if (Constant.YN_Y.equals(conf.getNodeVal2())) return WorkNode.NODE2;
            if (Constant.YN_Y.equals(conf.getNodeVal3())) return WorkNode.NODE3;
        }

        if (WorkNode.NODE2.getCode().equals(curNode)) {
            if (Constant.YN_Y.equals(conf.getNodeVal3())) return WorkNode.NODE3;
        }

        return WorkNode.NODE_END;
    }
}