using System;
using HH.WCS.Mobox3.RiDong.dto;
using HH.WCS.Mobox3.RiDong.generalMethod;
using HH.WCS.Mobox3.RiDong.models;
using HH.WCS.Mobox3.RiDong.util;
using HH.WCS.Mobox3.RiDong.wms;

namespace HH.WCS.Mobox3.RiDong.apiMethod;

/// <summary>
/// 综合性方法类
/// </summary>
public static class SynthesizeService
{
    /// <summary>
    /// 创建作业
    /// <remarks>存在中转货位（入库、出库、盘点入、盘点出）</remarks>
    /// </summary>
    /// <param name="input">作业模型</param>
    /// <returns></returns>
    public static ApiModel.SimpleResult AddOperation(OperationDto input)
    {
        var result = new ApiModel.SimpleResult();

        int group = 0;

        // 查询当前使用的容器
        var container = AdoSqlMethod<Container>.QueryFirst(p => p.S_CODE == input.cntrCode);

        // 判断当前容器是否存在
        if (container == null)
        {
            result.resultCode = -1;
            result.resultMsg = "当前容器不存在";
            Console.WriteLine("当前容器不存在");
            return result;
        }

        LogHelper.Info($"托盘{input.cntrCode}生成任务，该托盘的类型为{container.S_TYPE}");

        // 判断当前托盘是否有未完成的任务
        if (AdoSqlMethod<Operation>.QueryCount(p => p.S_CNTR_CODE == input.cntrCode && p.N_B_STATE < 2) > 0)
        {
            result.resultCode = -1;
            result.resultMsg = "当前容器已存在任务，请勿重复下发任务";
            Console.WriteLine("当前容器已存在任务，请勿重复下发任务");
            return result;
        }

        // 如果是入库，则需要计算入库的货位数据
        if (input.taskType == 1 || input.taskType == 3)
        {
            // 判断是否有容器货位表
            if (AdoSqlMethod<LocCntrRel>.QueryCount(p => p.S_CNTR_CODE == input.cntrCode) > 0)
            {
                result.resultCode = -1;
                result.resultMsg = "当前容器已在立库，请勿重复下发任务";
                Console.WriteLine("当前容器已在立库，请勿重复下发任务");
                return result;
            }

            // 根据容器类型以及容器对应的库区找到对应的货位信息
            var location = LocationMethod.QueryStereoscopicStorehouseLocation(container.S_TYPE);

            if (location == null)
            {
                result.resultCode = -1;
                result.resultMsg = "无可用货位";
                Console.WriteLine("无可用货位");
                return result;
            }

            // 重新计算终点、赋值
            input.endLocation = location.S_CODE;
            group = location.N_ROADWAY;
        }
        else
        {
            var location = AdoSqlMethod<Location>.QueryFirst(p=>p.S_CODE == input.startLocation);
            group = location.N_ROADWAY;
        }

        // 获取中转货位
        var queryRandomLocation = LocationMethod.QueryLocation(input);

        // 为空
        if (queryRandomLocation == null)
        {
            result.resultCode = -1;
            result.resultMsg = "输送线中转接驳位获取失败，请检查是否配置";
            Console.WriteLine("输送线中转接驳位获取失败，请检查是否配置");
            return result;
        }

        // 创建任务，不需要进行货位管控
        var operation = new Operation
        {
            // 任务号
            S_CODE = HelperMethod.GenerateTaskNo("作业号", "OP"),
            // 任务类型
            N_TYPE = input.taskType,
            // 任务类型
            S_TYPE = Operation.GetTypeStr(input.taskType),
            // 起点货位
            S_START_LOC = input.startLocation,
            // 起点库区编码
            S_START_AREA = Operation.GetArea(input.startLocation),
            // 拓展字段（中转货位）
            S_EXT_ATTR1 = queryRandomLocation.S_CODE,
            // 终点货位
            S_END_LOC = input.endLocation,
            // 终点库区编码
            S_END_AREA = Operation.GetArea(input.endLocation),
            // 容器编码
            S_CNTR_CODE = input.cntrCode,
            // 作业定义名称
            S_OP_DEF_NAME = Operation.GetTypeStr(input.taskType),
            // 盘点单号
            S_COUNT_NO = input.odd,
            // 拓展字段（任务组）
            S_EXT_ATTR2 = Operation.GetGroup(group),
            // 巷道
            N_ROADWAY = group
        };

        // 实现事务
        var sqlSugarClient = AdoSqlMethod<object>.QuerySqlSugarClient();

        try
        {
            sqlSugarClient.BeginTran();
            if (AdoSqlMethod<Operation>.AddFirstTran(sqlSugarClient, operation))
            {
                if (operation.N_TYPE == 1 || operation.N_TYPE == 3)
                {
                    // 货位需要上锁
                    LocationHelper.LockLoc(operation.S_END_LOC, 1);
                }
                else if (operation.N_TYPE == 4)
                {
                    // 货位需要上锁
                    LocationHelper.LockLoc(operation.S_START_LOC, 2);

                    container.C_ENABLE = 'N';
                    container.N_LOCK_STATE = 4;
                    AdoSqlMethod<Container>.UpdateFirst(container, p => new { p.C_ENABLE, p.N_LOCK_STATE });
                }
                else
                {
                    // 货位需要上锁
                    LocationHelper.LockLoc(operation.S_START_LOC, 2);

                    container.C_ENABLE = 'N';
                    AdoSqlMethod<Container>.UpdateFirst(container, p => new { p.C_ENABLE });
                }

                result.resultCode = 0;
                result.resultMsg = "作业创建成功";
            }
            else
            {
                result.resultCode = -1;
                result.resultMsg = "作业创建失败";
            }

            sqlSugarClient.CommitTran();

            return result;
        }
        catch (Exception e)
        {
            sqlSugarClient.RollbackTran();
            Console.WriteLine(e);
            throw;
        }
    }
}