using System;

using HH.WCS.Mobox3.AnGang.AppStart;
using HH.WCS.Mobox3.AnGang.Consts;
using HH.WCS.Mobox3.AnGang.Helper;
using HH.WCS.Mobox3.AnGang.Helpers;
using HH.WCS.Mobox3.AnGang.Models;

using Newtonsoft.Json;

using static HH.WCS.Mobox3.AnGang.Dtos.Request.ErpRequest;
using static HH.WCS.Mobox3.AnGang.Dtos.Request.MoboxRequest;
using static HH.WCS.Mobox3.AnGang.Dtos.Response.MoboxResponse;

namespace HH.WCS.Mobox3.AnGang.Services {
    public class MoboxService {

        /// <summary>
        /// 产品入库(PDA)
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        internal static SimpleResult Inbound(InboundInfo model) {
            LogHelper.Info("触发API：产品入库(PDA)" + JsonConvert.SerializeObject(model), "API");
            var db = DbHelper.GetDbClient();
            var startLoc = new TN_Location();
            //var endLoc = new TN_Location();

            try {
                // 起点位置必须：为空、无锁、启用、属于收发区域
                startLoc = db.Queryable<TN_Location>().
                    First(a => a.S_CODE == model.startLoc && a.N_CURRENT_NUM == 0 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "无" && a.C_ENABLE == "Y" && a.S_SHELF_CODE == AreaCode.收发货位区);

                if (startLoc == null) {
                    return BuildSimpleResult(1, $"起点位置{model.startLoc}不存在！");
                }

                //if (!LocationHelper.IsStartLocationTransferOk(model.startLoc, 
                //    a => a.S_SHELF_CODE == Settings.Areas[0], 
                //    out startLoc)) {
                //    return BuildSimpleResult(1, $"起点位置{model.startLoc}不存在！");
                //}

                // 容器 ID 和 物料 ID 未指定，由系统直接生成
                var cntID = Guid.NewGuid().ToString("D");
                var CgId = Guid.NewGuid().ToString("D");

                // 初始是没有绑定信息的，先将起点位置与容器绑定，容器与物料绑定
                var cntLoc = new TN_Loc_Container() {
                    S_LOC_CODE = startLoc.S_CODE,
                    S_CNTR_CODE = cntID,
                };
                var cgCnt = new TN_CG_Detail() {
                    S_ITEM_CODE = CgId,
                    S_CNTR_CODE = cntID,
                };

                var endArea = ""; // 默认终点区域为空

                // 指定货位排号（不能为空、空字符串或空格）
                if (model.endShelf != null && model.endShelf.Trim() != "") {
                    endArea = model.endShelf;
                    // 没有在配置文件找到这个货架号
                    if (!Settings.AreaMap[AreaName.货架区].Contains(endArea)) {
                        return BuildSimpleResult(2, $"货架号 {model.endShelf} 不存在");
                    }
                }

                // 无论是否选择终点货架，都等到称重之后再计算终点货位
                using (var trans = db.Ado.UseTran()) {
                    if (db.Insertable<TN_Loc_Container>(cntLoc).ExecuteCommand() > 0
                        && db.Insertable<TN_CG_Detail>(cgCnt).ExecuteCommand() > 0) {
                        //创建产品入库任务：创建搬送任务，起点终点容器
                        if (WCSHelper.CreateTaskWithArea(startLoc.S_CODE, endArea, "产品入库(PDA)", 3, cntID)) {
                            //如果操作TN_Location会造成死锁
                            LocationHelper.LockLoc(startLoc.S_CODE, 2);//起点出库锁，
                            //LocationHelper.LockLoc(endLoc.S_CODE, 1);//终点入库锁

                            trans.CommitTran();

                            return BuildSimpleResult(0, $"生成 产品入库(PDA) 成功，容器号 {cntID} ，起点 {startLoc.S_CODE} ，终点货架 {endArea} ，终点货位未指定");
                        }
                        else {
                            trans.RollbackTran();

                            return BuildSimpleResult(5, $"生成 产品入库(PDA) 失败，容器号 {cntID} ，起点 {startLoc.S_CODE} ，终点货架 {endArea} ，终点货位未指定");
                        }
                    }
                    else {
                        return BuildSimpleResult(6, $"插入表数据失败");
                    }
                }
            }
            catch (Exception ex) {
                return BuildSimpleResult(1, $"发生了异常：{ex.Message}");
            }
        }

        /// <summary>
        /// PDA选择终点货位
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        internal static SimpleResult SelectLocation(SelectLocationInfo model) {
            LogHelper.Info("触发API：PDA选择终点货位" + JsonConvert.SerializeObject(model), "API");
            var db = DbHelper.GetDbClient();

            try {
                // 任务号存在：终点货架和终点位置为空，且任务为产品入库(PDA)
                //var task = db.Queryable<TN_Task>().First(a => a.S_CODE == model.taskNo && a.S_END_AREA == "" && a.S_END_LOC == "" && a.S_TYPE == "产品入库(PDA)");
                var task = db.Queryable<TN_Task>().First(a => a.S_EQ_NO == model.forklift_no && a.S_END_AREA == "" && a.S_END_LOC == "" && a.S_TYPE == "产品入库(PDA)");
                
                if (task == null) {
                    //return BuildSimpleResult(2, $"任务号 {model.taskNo} 不存在，或不满足终点货架为空、终点位置为空且为 产品入库(PDA) 任务");
                    return BuildSimpleResult(2, $"小车 '{model.forklift_no}' 当前不存在任务，或不满足终点货架为空、终点位置为空且为 产品入库(PDA) 任务");
                }

                var endLoc = new TN_Location();
                if (task.F_WEIGHT > 1500) {
                    // 重量超过1.5t，需要选择1-3层货架
                    endLoc = db.Queryable<TN_Location>().First(
                        a => a.S_CODE == model.endLoc && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "无" && a.C_ENABLE == "Y" && a.N_CURRENT_NUM == 0 && a.N_HEIGHT <= 3);
                }
                else {
                    endLoc = db.Queryable<TN_Location>().First(
                        a => a.S_CODE == model.endLoc && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "无" && a.C_ENABLE == "Y" && a.N_CURRENT_NUM == 0);
                }

                // 没有符合条件的货位
                if (endLoc == null) {
                    return BuildSimpleResult(3, $"货位{model.endLoc}不满足要求：不存在或不满足称重放置要求");
                }

                // 修改任务终点为PDA指定终点
                task.S_END_LOC = endLoc.S_CODE;
                task.S_END_AREA = endLoc.S_SHELF_CODE;

                using (var trans = db.Ado.UseTran()) {
                    if (db.Updateable<TN_Task>(task).ExecuteCommand() > 0) {
                        LocationHelper.LockLoc(endLoc.S_CODE, 1);//终点入库锁
                        trans.CommitTran();

                        return BuildSimpleResult(0, $"任务{task.S_CODE}修改成功，修改终点位置为{endLoc.S_CODE}");
                    }
                    else {
                        trans.RollbackTran();

                        return BuildSimpleResult(4, $"任务{task.S_CODE}修改失败，修改终点位置为{endLoc.S_CODE}");
                    }
                }
            }
            catch (Exception ex) {
                return BuildSimpleResult(1, $"发生了异常：{ex.Message}");
            }
        }

        /// <summary>
        /// 产品部分出库(WMS)
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        internal static SimpleResult PartOutbound(PartOutboundInfo model) {
            LogHelper.Info("触发API：产品部分出库(WMS)" + JsonConvert.SerializeObject(model), "API");
            var db = DbHelper.GetDbClient();

            try {
                // 起点位置：货架（有货、没有锁、已启用）
                var startLoc = db.Queryable<TN_Location>().First(a => a.S_CODE == model.startLoc && a.N_CURRENT_NUM == 1 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "无" && a.C_ENABLE == "Y");

                if (startLoc == null) {
                    return BuildSimpleResult(2, $"起点位置 {model.startLoc} 不存在或不具备取货要求");
                }

                var locCtnrRel = db.Queryable<TN_Loc_Container>().First(a => a.S_LOC_CODE == model.startLoc);

                if (locCtnrRel == null) {
                    return BuildSimpleResult(3, $"起点位置 {model.startLoc} 没有绑定容器，无可出库的物料");
                }

                var endLoc = db.Queryable<TN_Location>().First(a => a.S_CODE == model.endLoc && a.N_CURRENT_NUM == 0 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "无" && a.C_ENABLE == "Y" && a.S_AREA_CODE == AreaCode.收发货位区);

                if (endLoc == null) {
                    return BuildSimpleResult(4, $"终点位置 {model.endLoc} 不具备放货条件");
                }

                using (var trans = db.Ado.UseTran()) {
                    // 解绑：起点货位与待搬运容器（不需要手动deleteable操作，内部会自动操作的）
                    if (WCSHelper.CreateTask(startLoc.S_CODE, endLoc.S_CODE, "产品部分出库(WMS)", 3, locCtnrRel.S_CNTR_CODE))//创建搬送任务，起点终点容器
                        {//如果操作TN_Location会造成死锁
                        LocationHelper.LockLoc(startLoc.S_CODE, 2);//起点出库锁，
                        LocationHelper.LockLoc(endLoc.S_CODE, 1);//终点入库锁

                        trans.CommitTran();
                        return BuildSimpleResult(0, $"生成 产品出库(WMS) 成功，容器号{locCtnrRel.S_CNTR_CODE}，起点{startLoc.S_CODE}，终点{endLoc.S_CODE}");
                    }
                    else {
                        trans.RollbackTran();
                        return BuildSimpleResult(5, $"生成 产品出库(WMS) 失败，容器号{locCtnrRel.S_CNTR_CODE}，起点{startLoc.S_CODE}，终点{endLoc.S_CODE}");
                    }
                }
            }
            catch (Exception ex) {
                return BuildSimpleResult(1, $"发生了异常：{ex.Message}");
            }
        }

        /// <summary>
        /// 产品部分回库(WMS)
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        internal static SimpleResult PartInbound(PartInboundInfo model) {
            LogHelper.Info("触发API：产品部分回库(WMS)" + JsonConvert.SerializeObject(model), "API");
            var db = DbHelper.GetDbClient();

            try {
                // 起点位置：取放货区（有货物、没有锁、已启用）
                var startLoc = db.Queryable<TN_Location>().First(a => a.S_CODE == model.startLoc && a.N_CURRENT_NUM == 1 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "无" && a.C_ENABLE == "Y" && a.S_AREA_CODE == AreaCode.收发货位区);
                if (startLoc == null) {
                    return BuildSimpleResult(2, $"起点位置 {model.startLoc} 不符合回库条件");
                }

                var locCtnrRel = db.Queryable<TN_Loc_Container>().First(a => a.S_LOC_CODE == model.startLoc);
                if (locCtnrRel == null) {
                    return BuildSimpleResult(3, $"起点位置 {model.startLoc} 没有绑定容器，无可回库的物料");
                }

                // 终点位置：货架（没有货物，没有锁）
                var endLoc = db.Queryable<TN_Location>().First(a => a.S_CODE == model.endLoc && a.N_CURRENT_NUM == 0 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "无" && a.C_ENABLE == "Y");
                if (endLoc == null) {
                    return BuildSimpleResult(4, $"终点位置 {model.endLoc} 不具备放货条件");
                }

                using (var trans = db.Ado.UseTran()) {
                    // 解绑：起点货位与待搬运容器（不需要手动deleteable操作，内部会自动操作的）
                    if (WCSHelper.CreateTask(startLoc.S_CODE, endLoc.S_CODE, "产品部分入库(WMS)", 3, locCtnrRel.S_CNTR_CODE))//创建搬送任务，起点终点容器
                        {//如果操作TN_Location会造成死锁
                        LocationHelper.LockLoc(startLoc.S_CODE, 2);//起点出库锁，
                        LocationHelper.LockLoc(endLoc.S_CODE, 1);//终点入库锁

                        trans.CommitTran();
                        return BuildSimpleResult(0, $"生成 产品部分回库(WMS) 成功，容器号{locCtnrRel.S_CNTR_CODE}，起点{startLoc.S_CODE}，终点{endLoc.S_CODE}");
                    }
                    else {
                        trans.RollbackTran();
                        return BuildSimpleResult(5, $"生成 产品部分回库(WMS) 成功，容器号{locCtnrRel.S_CNTR_CODE}，起点{startLoc.S_CODE}，终点{endLoc.S_CODE}");
                    }
                }
            }
            catch (Exception ex) {
                return BuildSimpleResult(1, $"发生了异常：{ex.Message}");
            }
        }

        /// <summary>
        /// 盘点理货出库(WMS)
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        internal static SimpleResult CheckOutbound(CheckOutboundInfo model) {
            LogHelper.Info("触发API：盘点理货出库(WMS)" + JsonConvert.SerializeObject(model), "API");
            var db = DbHelper.GetDbClient();

            try {
                // 起点位置：取放货区（有货物、没有锁、已启用）
                var startLoc = db.Queryable<TN_Location>().First(a => a.S_CODE == model.startLoc && a.N_CURRENT_NUM == 1 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "无" && a.C_ENABLE == "Y" && a.S_AREA_CODE == AreaCode.收发货位区);
                if (startLoc == null) {
                    return BuildSimpleResult(2, $"起点位置 {model.startLoc} 不符合出库条件");
                }

                var locCtnrRel = db.Queryable<TN_Loc_Container>().First(a => a.S_LOC_CODE == model.startLoc);
                if (locCtnrRel == null) {
                    return BuildSimpleResult(3, $"起点位置 {model.startLoc} 没有绑定容器，无可回库的物料");
                }

                // 终点位置：货架（没有货物，没有锁）
                var endLoc = db.Queryable<TN_Location>().First(a => a.S_CODE == model.endLoc && a.N_CURRENT_NUM == 0 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "无" && a.C_ENABLE == "Y");
                if (endLoc == null) {
                    return BuildSimpleResult(4, $"终点位置 {model.endLoc} 不具备放货条件");
                }

                using (var trans = db.Ado.UseTran()) {
                    // 解绑：起点货位与待搬运容器（不需要手动deleteable操作，内部会自动操作的）
                    if (WCSHelper.CreateTask(startLoc.S_CODE, endLoc.S_CODE, "盘点理货出库(WMS)", 3, locCtnrRel.S_CNTR_CODE))//创建搬送任务，起点终点容器
                        {//如果操作TN_Location会造成死锁
                        LocationHelper.LockLoc(startLoc.S_CODE, 2);//起点出库锁，
                        LocationHelper.LockLoc(endLoc.S_CODE, 1);//终点入库锁

                        trans.CommitTran();
                        return BuildSimpleResult(0, $"生成 盘点理货出库(WMS) 成功，容器号{locCtnrRel.S_CNTR_CODE}，起点{startLoc.S_CODE}，终点{endLoc.S_CODE}");
                    }
                    else {
                        trans.RollbackTran();
                        return BuildSimpleResult(5, $"生成 盘点理货出库(WMS) 成功，容器号{locCtnrRel.S_CNTR_CODE}，起点{startLoc.S_CODE}，终点{endLoc.S_CODE}");
                    }
                }
            }
            catch (Exception ex) {
                return BuildSimpleResult(1, $"发生了异常：{ex.Message}");
            }
        }

        /// <summary>
        /// 盘点理货回库(WMS)
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        internal static SimpleResult CheckInbound(CheckInboundInfo model) {
            LogHelper.Info("触发API：盘点理货回库(WMS)" + JsonConvert.SerializeObject(model), "API");
            var db = DbHelper.GetDbClient();

            try {
                // 起点位置：取放货区（有货物、没有锁、已启用）
                var startLoc = db.Queryable<TN_Location>().First(a => a.S_CODE == model.startLoc && a.N_CURRENT_NUM == 1 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "无" && a.C_ENABLE == "Y" && a.S_AREA_CODE == AreaCode.收发货位区);
                if (startLoc == null) {
                    return BuildSimpleResult(2, $"起点位置 {model.startLoc} 不符合回库条件");
                }

                var locCtnrRel = db.Queryable<TN_Loc_Container>().First(a => a.S_LOC_CODE == model.startLoc);
                if (locCtnrRel == null) {
                    return BuildSimpleResult(3, $"起点位置 {model.startLoc} 没有绑定容器，无可回库的物料");
                }

                // 终点位置：货架（没有货物，没有锁）
                var endLoc = db.Queryable<TN_Location>().First(a => a.S_CODE == model.endLoc && a.N_CURRENT_NUM == 0 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "无" && a.C_ENABLE == "Y");
                if (endLoc == null) {
                    return BuildSimpleResult(4, $"终点位置 {model.endLoc} 不具备放货条件");
                }

                using (var trans = db.Ado.UseTran()) {
                    // 解绑：起点货位与待搬运容器（不需要手动deleteable操作，内部会自动操作的）
                    if (WCSHelper.CreateTask(startLoc.S_CODE, endLoc.S_CODE, "盘点理货回库(WMS)", 3, locCtnrRel.S_CNTR_CODE))//创建搬送任务，起点终点容器
                        {//如果操作TN_Location会造成死锁
                        LocationHelper.LockLoc(startLoc.S_CODE, 2);//起点出库锁，
                        LocationHelper.LockLoc(endLoc.S_CODE, 1);//终点入库锁

                        trans.CommitTran();
                        return BuildSimpleResult(0, $"生成 盘点理货回库(WMS) 成功，容器号{locCtnrRel.S_CNTR_CODE}，起点{startLoc.S_CODE}，终点{endLoc.S_CODE}");
                    }
                    else {
                        trans.RollbackTran();
                        return BuildSimpleResult(5, $"生成 盘点理货回库(WMS) 成功，容器号{locCtnrRel.S_CNTR_CODE}，起点{startLoc.S_CODE}，终点{endLoc.S_CODE}");
                    }
                }
            }
            catch (Exception ex) {
                return BuildSimpleResult(1, $"发生了异常：{ex.Message}");
            }
        }
    }
}