using System;
using System.Collections.Generic;
using System.Linq;
using System.Reflection;
using System.Text;
using System.Threading.Tasks;
using Aop.Api.Domain;
using DingTalk.Api.Request;
using JNPF.Common.Core.Manager;
using JNPF.Common.Extension;
using JNPF.Common.Filter;
using JNPF.Common.Security;
using JNPF.DependencyInjection;
using JNPF.DynamicApiController;
using JNPF.FriendlyException;
using JNPF.Logging;
using JNPF.Systems.Entitys.System;
using JNPF.Systems.Interfaces.System;
using JNPF.VisualDev;
using JNPF.VisualDev.Entitys.Dto.VisualDevModelData;
using Microsoft.AspNetCore.Mvc;
using Microsoft.ClearScript.JavaScript;
using Microsoft.Extensions.Logging;
using Newtonsoft.Json.Linq;
using SqlSugar;
using Tnb.BasicData.Entities;
using Tnb.EquipMgr.Entities;
using Tnb.ProductionMgr.Entities;
using Tnb.ProductionMgr.Entities.Entity;
using Tnb.QcMgr.Entities;
using Tnb.QcMgr.Entities.Dto;
using Tnb.QcMgr.Entities.Entity;
using Tnb.QcMgr.Entities.Enums;
using Tnb.WarehouseMgr;
using Tnb.WarehouseMgr.Entities;
using Tnb.WarehouseMgr.Entities.Consts;
using Tnb.WarehouseMgr.Entities.Dto;
using Tnb.WarehouseMgr.Entities.Enums;
using Tnb.WarehouseMgr.Interfaces;

namespace Tnb.QcMgr
{
    [ApiDescriptionSettings(Tag = ModuleConsts.Tag, Area = ModuleConsts.Area, Order = 800)]
    [Route("api/[area]/[controller]/[action]")]
    public class QcTempControlHService : BaseWareHouseService, IDynamicApiController, ITransient
    {
        private readonly ISqlSugarRepository<QcTempControlH> _repository;
        private readonly IUserManager _userManager;
        private readonly IWareHouseService _wareHouseService;
        private readonly IBillRullService _billRullService;
        private readonly ISqlSugarClient _db;
        public QcTempControlHService(ISqlSugarRepository<QcTempControlH> repository, IUserManager userManager, IWareHouseService wareHouseService,IBillRullService billRullService)
        {
            _db = repository.AsSugarClient();
            _userManager = userManager;
            _wareHouseService = wareHouseService;
            _billRullService = billRullService;
        }


        /// <summary>
        /// 获取质检暂控处理单
        /// </summary>
        /// <returns></returns>

        [HttpPost]
        public async Task<object> AllList(VisualDevModelListQueryInput input)
        {
            var bill_code = ""; //单据号
            var pro_task_code = ""; //生产任务单号
            var status = "";//状态
            if (!input.queryJson.IsNullOrWhiteSpace())
            {
                bill_code = JObject.Parse(input.queryJson).Value<string>("bill_code");
                pro_task_code = JObject.Parse(input.queryJson).Value<string>("pro_task_code");
                status = JObject.Parse(input.queryJson).Value<string>("status");
            }

            var result = await _db.Queryable<QcTempControlH>().LeftJoin<BasWarehouse>((a, b) => a.in_warehouse_id == b.id)
                .LeftJoin<BasWarehouse>((a, b, c) => a.out_warehouse_id == c.id)
                .WhereIF(!string.IsNullOrEmpty(bill_code), (a, b, c) => a.bill_code.Contains(bill_code))
                .WhereIF(!string.IsNullOrEmpty(pro_task_code), (a, b, c) => a.pro_task_code.Contains(pro_task_code))
                .WhereIF(!string.IsNullOrEmpty(status), (a, b, c) => a.status == status)
                .OrderByDescending((a, b, c) => a.create_time)
                .Select((a, b, c) => new QcTempControlHOutput()
                {
                    id = a.id,
                    bill_code = a.bill_code,
                    source_code = a.source_code,
                    pro_task_code = a.pro_task_code,
                    out_warehouse_id = a.out_warehouse_id,
                    out_warehouse_name = c.whname,
                    in_warehouse_id = a.in_warehouse_id,
                    in_warehouse_name = b.whname,
                    material_id = a.material_id,
                    material_code = a.material_code,
                    control_lx_qty = a.control_lx_qty,
                    control_qty = a.control_qty,
                    result = a.result,
                    loger_id = a.loger_id,
                    confirmer_id = a.confirmer_id,
                    status = a.status,
                    called_box_qty = a.called_box_qty,
                    called_qty = a.called_qty,
                    leave_call_box_qty = a.leave_call_box_qty,
                    leave_call_qty = a.leave_call_qty,

                    details = SqlFunc.Subqueryable<QcTempControlD>().Where(r => r.bill_id == a.id).OrderByDesc(r => r.create_time).ToList((x) => new QcTempControlDsOutput
                    {
                        id = x.id,
                        bill_id = x.bill_id,
                        carry_id = x.carry_id,
                        carry_code = x.carry_code,
                        warehouse_code = x.warehouse_code,
                        warehouse_id = x.warehouse_id,
                        location_code = x.location_code,
                        location_id = x.location_id,
                        qty = x.qty,
                        submiter = x.submiter,
                        maker_id = x.maker_id,
                    })

                }).ToPagedListAsync(input.currentPage, input.pageSize);

            return PageResult<QcTempControlHOutput>.SqlSugarPageResult(result);
        }


        /// <summary>
        /// 确认暂控料处理单结论
        /// </summary>
        /// <param name="dic"></param>
        /// <returns></returns>
        [HttpPost]
        public async Task<dynamic> ModifyResult(Dictionary<string, string> dic)
        {
            string id = dic["id"];
            string qcRes = dic["result"];

            try
            {
                var qcTempControlH = await _db.Queryable<QcTempControlH>().Where(r => r.id == id).FirstAsync();
                if(qcTempControlH==null)
                {
                    throw Oops.Bah("暂控处理单数据不存在");
                }
                await _db.Ado.BeginTranAsync();

                await _db.Updateable<QcTempControlH>().SetColumns(x => x.result == qcRes).SetColumns(x=>x.status==((int)EnumTempControlStatus.待下发).ToString()).Where(x => x.id == id).ExecuteCommandAsync();
                await _db.Updateable<QcTempControlD>().SetColumns(x => x.check_status == qcRes).Where(x => x.bill_id == qcTempControlH.bill_code).ExecuteCommandAsync();

                await _db.Ado.CommitTranAsync();
            }
            catch(Exception e)
            {
                await _db.Ado.RollbackTranAsync();
                Log.Error(e.Message, e);
                throw Oops.Bah(e.Message);
            }

            return "修改成功";
        }

        /// <summary>
        /// 下发暂控料处理单
        /// </summary>
        /// <param name="dic"></param>
        /// <returns></returns>
        [HttpPost]
        public async Task<string> QcTempControlIssued(Dictionary<string, string> dic)
        {
            string id = dic["id"];

            try
            {
                var qcTempControlH = await _db.Queryable<QcTempControlH>().Where(r => r.id == id).FirstAsync();
                if (qcTempControlH == null)
                {
                    throw Oops.Bah("暂控处理单数据不存在");
                }
                //所有暂控的料箱必须都进入中储仓才能进行下发
                var qcTempControlDs = await _db.Queryable<QcTempControlD>().Where(r => r.bill_id == qcTempControlH.id).ToListAsync();
                if (qcTempControlDs!=null && qcTempControlDs.Count > 0)
                {
                    var carrys = await _db.Queryable<WmsCarryCode>().Where(r => qcTempControlDs.Select(r => r.carry_id).Contains(r.carry_id)).ToListAsync();
                    var noInStockCarrys = carrys.Where(r => r.warehouse_id != WmsWareHouseConst.WAREHOUSE_ZC_ID);
                    if (noInStockCarrys.Any())
                    {
                        var carryCodes=string.Join(",", noInStockCarrys.Distinct().Select(r=>r.carry_code));
                        throw Oops.Bah($"{carryCodes}等料箱还没入中储仓，不能下发");
                    }
                }

                await _db.Ado.BeginTranAsync();

                await _db.Updateable<QcTempControlH>().SetColumns(x => x.status == ((int)EnumTempControlStatus.已下发).ToString()).Where(x => x.id == id).ExecuteCommandAsync();

                await _db.Ado.CommitTranAsync();
            }
            catch (Exception e)
            {
                await _db.Ado.RollbackTranAsync();
                Log.Error(e.Message, e);
                throw Oops.Bah(e.Message);
            }

            return "修改成功";
        }

        /// <summary>
        /// 获取质检单 for APP
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        public async Task<object> GetQcTempControlList(PageInputBase input)
        {
            Dictionary<string, object> queryJson = string.IsNullOrEmpty(input.queryJson) ? new Dictionary<string, object>() : input.queryJson.ToObject<Dictionary<string, object>>();
            string? bill_code = queryJson.ContainsKey("bill_code") ? queryJson["bill_code"].ToString() : "";
            string? status = queryJson.ContainsKey("status") ? queryJson["status"].ToString() : "";

            if (string.IsNullOrEmpty(input.sidx))
            {
                input.sidx = "create_time";
                input.sort = "desc";
            }

            var result = await _db.Queryable<QcTempControlH>().LeftJoin<BasWarehouse>((a, b) => a.in_warehouse_id == b.id)
                        .LeftJoin<BasWarehouse>((a, b, c) => a.out_warehouse_id == c.id)
                        .WhereIF(!string.IsNullOrEmpty(bill_code), (a, b, c) => a.bill_code.Contains(bill_code))
                        .WhereIF(!string.IsNullOrEmpty(status), (a, b, c) => a.status == status)
                        .OrderByDescending((a, b, c) => a.create_time)
                        .Select((a, b, c) => new QcTempControlHAppOutput()
                        {
                            id = a.id,
                            bill_code = a.bill_code,
                            source_code = a.source_code,
                            pro_task_code = a.pro_task_code,
                            out_warehouse_id = a.out_warehouse_id,
                            out_warehouse_name = c.whname,
                            in_warehouse_id = a.in_warehouse_id,
                            in_warehouse_name = b.whname,
                            material_id = a.material_id,
                            material_code = a.material_code,
                            control_lx_qty = a.control_lx_qty,
                            control_qty = a.control_qty,
                            result = a.result,
                            loger_id = a.loger_id,
                            confirmer_id = a.confirmer_id,
                            status = a.status,
                            called_box_qty = a.called_box_qty,
                            called_qty = a.called_qty,
                            leave_call_box_qty = a.leave_call_box_qty,
                            leave_call_qty = a.leave_call_qty,

                        }).ToPagedListAsync(input.currentPage, input.pageSize);

            return PageResult<QcTempControlHAppOutput>.SqlSugarPageResult(result);
        }

        /// <summary>
        /// PDA暂控料呼叫
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        public async Task<string> TempControlCall(QcTempControlCallInput input)
        {
            try
            {
                if (string.IsNullOrEmpty(input.id))
                    throw Oops.Bah("主键id不能为空");
                if (string.IsNullOrEmpty(input.destination_location_code))
                    throw Oops.Bah("目标库位不能为空");
                if (input.box_qty <= 0)
                    throw Oops.Bah("呼叫箱数不能小于1");

                var qcTempControlH = await _db.Queryable<QcTempControlH>().Where(r => r.id == input.id).FirstAsync();
                if (qcTempControlH == null)
                    throw Oops.Bah("暂控处理单数据不存在");

                var basLocation=await _db.Queryable<BasLocation>().Where(r=>r.location_code==input.destination_location_code).FirstAsync();
                if (basLocation == null)
                    throw Oops.Bah($"目标库位{input.destination_location_code}不存在");

                var qcTempControlDs = await _db.Queryable<QcTempControlD>().Where(r => r.bill_id == input.id && r.call_status == "未呼叫").Take(input.box_qty).ToListAsync();
                if (qcTempControlDs == null || qcTempControlDs.Count <= 0)
                    throw Oops.Bah("不存在未下发的料箱");

                await _db.Ado.BeginTranAsync();

                decimal callqty = 0;//当前呼叫物料总数量
                foreach(var item in qcTempControlDs)
                {
                    callqty += (string.IsNullOrEmpty(item.qty) ? 0 : Convert.ToDecimal(item.qty));

                    // 计算路径，插入预任务申请
                    WmsPointH sPoint = await _db.Queryable<WmsPointH>().FirstAsync(it => it.location_id ==item.location_id);
                    WmsPointH ePoint = await _db.Queryable<WmsPointH>().FirstAsync(it => it.location_id == basLocation.id);

                    if (sPoint == null)
                        throw Oops.Bah($"载具编号{item.carry_code}未找到起始点位");
                    if (ePoint == null)
                        throw Oops.Bah($"载具编号{item.carry_code}未找到终点点位");

                    List<WmsPointH> points = new List<WmsPointH>();
                    if (sPoint.area_code != ePoint.area_code)
                    {
                        points = await _wareHouseService.PathAlgorithms(sPoint.id, ePoint.id);
                        if (points.Count <= 2)
                        {
                            throw new AppFriendlyException($"sPoint {sPoint.point_code} ePoint{ePoint.point_code}该路径不存在", 500);
                        }
                    }
                    else
                    {
                        points.Add(sPoint);
                        points.Add(ePoint);
                    }
                    if (points.Count <= 0)
                        throw Oops.Bah("点位不存在");

                    List<WmsPretaskH> preTasks = points.Where(it => !it.location_id.IsNullOrEmpty()).GroupBy(g => g.area_code).Select(it =>
                    {
                        WmsPointH? sPoint = it.FirstOrDefault();
                        WmsPointH? ePoint = it.LastOrDefault();

                        WmsPretaskH preTask = new()
                        {
                            org_id = _userManager!.User.OrganizeId,
                            startlocation_id = sPoint?.location_id!,
                            startlocation_code = sPoint?.location_code!,
                            endlocation_id = ePoint?.location_id!,
                            endlocation_code = ePoint?.location_code!,
                            start_floor = sPoint?.floor.ToString(),
                            end_floor = ePoint?.floor.ToString(),
                            startpoint_id = sPoint?.id!,
                            startpoint_code = sPoint?.point_code!,
                            endpoint_id = ePoint?.id!,
                            endpoint_code = ePoint?.point_code!,
                            bill_code = _billRullService!.GetBillNumber(WmsWareHouseConst.WMS_PRETASK_H_ENCODE).GetAwaiter().GetResult(),
                            status = WmsWareHouseConst.PRETASK_BILL_STATUS_DXF_ID,
                            biz_type = WmsWareHouseConst.BIZTYPE_WMSTRANSFERINSTOCK_ID,
                            task_type = WmsWareHouseConst.WMS_PRETASK_TRANSFER_TYPE_ID
                        };
                        preTask.area_id = sPoint?.area_id!;
                        preTask.area_code = it.Key;
                        preTask.require_id = qcTempControlH.id;
                        preTask.require_code = qcTempControlH.bill_code;
                        preTask.create_id = _userManager.UserId;
                        preTask.create_time = DateTime.Now;
                        return preTask;
                    }).ToList();
                    bool isOk = await _wareHouseService.GenPreTask(preTasks, null!);
                    if (!isOk)
                        throw Oops.Bah($"载具编号{item.carry_code}生成预任务失败");

                }

                await _db.Updateable(qcTempControlDs).SetColumns(x=>x.call_status=="已呼叫").ExecuteCommandAsync();

                //已呼叫料箱数量
                var called_box_qty = qcTempControlDs.Count + (string.IsNullOrEmpty(qcTempControlH.called_box_qty) ? 0 : Convert.ToDecimal(qcTempControlH.called_box_qty));
                //已呼叫物料数量
                var called_qty = callqty + (string.IsNullOrEmpty(qcTempControlH.called_qty) ? 0 : Convert.ToDecimal(qcTempControlH.called_qty));
                //剩余呼叫料箱数量
                var leave_call_box_qty = (string.IsNullOrEmpty(qcTempControlH.control_lx_qty) ? 0 : Convert.ToDecimal(qcTempControlH.control_lx_qty)) - called_box_qty;
                //剩余呼叫数量
                var leave_call_qty = (string.IsNullOrEmpty(qcTempControlH.control_qty) ? 0 : Convert.ToDecimal(qcTempControlH.control_qty)) - called_qty;

                await _db.Updateable(qcTempControlH).SetColumns(x => x.called_box_qty == called_box_qty.ToString())
                    .SetColumns(x => x.called_qty == called_qty.ToString())
                    .SetColumns(x => x.leave_call_box_qty == leave_call_box_qty.ToString())
                    .SetColumns(x => x.leave_call_qty == leave_call_qty.ToString())
                    .SetColumns(x=>x.status==((int)EnumTempControlStatus.执行中).ToString())
                    .ExecuteCommandAsync();

                await _db.Ado.CommitTranAsync();
            }
            catch (Exception e)
            {
                await _db.Ado.RollbackTranAsync();
                Log.Error(e.Message, e);
                throw Oops.Bah(e.Message);
            }
            return "呼叫成功";
        }


        /// <summary>
        /// PDA扫描料箱获取暂控处理单详情
        /// </summary>
        /// <param name="dic"></param>
        /// <returns></returns>
        [HttpPost]

        public async Task<object> GetQcTempControlDetail(Dictionary<string,string> dic)
        {
            var id = dic["id"].ToString();
            var carryCode = dic["carryCode"].ToString();

            if (string.IsNullOrEmpty(carryCode))
                throw Oops.Bah("料箱号不能为空");

            var qcTempControlH = await _db.Queryable<QcTempControlH>().Where(r => r.id == id).FirstAsync();
            if (qcTempControlH == null)
                throw Oops.Bah("未找到暂控料处理单数据");

            var carry = await _db.Queryable<WmsCarryCode>().Where(r => r.carry_code == carryCode).FirstAsync();
            if (carry == null)
                throw Oops.Bah($"料箱号：{carryCode}不存在");

            var qcTempControlD = await _db.Queryable<QcTempControlD>().Where(r => r.bill_id == qcTempControlH.id && r.carry_id == carry.id).FirstAsync();
            if (qcTempControlD == null)
                throw Oops.Bah($"料箱号：{carryCode}不在此暂控料处理单的暂控料箱列表中");

            var material= await _db.Queryable<BasMaterial>().Where(r => r.id == qcTempControlH.material_id).FirstAsync();
            var result = new QcTempControlScanCodeOutput();
            result.id = qcTempControlD.id;
            result.material_code = material?.code;
            result.material_name = material?.name;
            result.container_no=material?.container_no;
            result.material_standard = material?.material_standard;
            result.material_specification = material?.material_specification;
            result.unit_code = material?.unit_id;
            result.code_qty = qcTempControlD.qty;
            return result;
        }

        /// <summary>
        /// 保存挑选合格数量
        /// </summary>
        /// <param name="dic"></param>
        /// <returns></returns>
        [HttpPost]

        public async Task<string> SaveQualifiedQty(Dictionary<string, string> dic)
        {
            try
            {
                var id = dic["id"].ToString();
                var qualifiedQty = dic["qualifiedQty"].ToString();
                if (string.IsNullOrEmpty(qualifiedQty))
                    throw Oops.Bah("合格数量不能为空");

                //先保存不合格数量，修改状态为让步接收，改变对应载具台账的检验状态为合格，并生成对应料箱的8号线入库任务
                var qcTempControlD = await _db.Queryable<QcTempControlD>().Where(r => r.id == id).FirstAsync();
                if (qcTempControlD == null)
                    throw Oops.Bah($"数据不存在");

                if (qcTempControlD.pick_status == "已挑选")
                    throw Oops.Bah("已挑选，不能重复挑选");

                var qctempControlH=await _db.Queryable<QcTempControlH>().Where(r=>r.id==qcTempControlD.bill_id).FirstAsync();
                //计算不合格数量
                var unQualifiedQty = (string.IsNullOrEmpty(qcTempControlD.qty) ? 0 : Convert.ToDecimal(qcTempControlD.qty)) - (Convert.ToDecimal(qualifiedQty));
                await _db.Ado.BeginTranAsync();
                //修改对应暂控子表的不合格数量和挑选状态
                await _db.Updateable<QcTempControlD>()
                    .SetColumns(r => r.qualified_qty == qualifiedQty)
                    .SetColumns(r=>r.unqualified_qty== unQualifiedQty.ToString())
                    .SetColumns(r => r.pick_status == "已挑选")
                    .SetColumns(r=>r.check_status=="让步接收")
                    .Where(r => r.id == qcTempControlD.id).ExecuteCommandAsync();
                //更新对应载具台账的检验状态为合格
                await _db.Updateable<WmsCarryH>().SetColumns(r => r.is_check == ((int)EnumCheckConclusion.合格).ToString()).Where(r => r.id == qcTempControlD.carry_id).ExecuteCommandAsync();
                //更新对应载具条码表的条码数量为挑选好的合格数量
                await _db.Updateable<WmsCarryCode>().SetColumns(r => r.codeqty == Convert.ToDecimal(qualifiedQty)).Where(r => r.carry_id == qcTempControlD.carry_id && r.material_id == qctempControlH.material_id).ExecuteCommandAsync();

                #region 生成8号线入库任务

                //入库取终点
                InStockStrategyQuery inStockStrategyInput = new() { warehouse_id = qcTempControlD.warehouse_id, Size = 1 };
                List<BasLocation> endLocations = await _wareHouseService.InStockStrategy(inStockStrategyInput);
                WmsPointH? sPoint = null;
                WmsPointH? ePoint = null;
                sPoint = await _db.Queryable<WmsPointH>().FirstAsync(it => it.location_id == qcTempControlD.warehouse_id);
                if (sPoint == null)
                    throw Oops.Bah($"起始库位不可用");
                if (endLocations?.Count > 0)
                {
                    WmsCarryH carry = await _db.Queryable<WmsCarryH>().SingleAsync(it => it.id == qcTempControlD.carry_id);
                    BasLocation loc = await _db.Queryable<BasLocation>().SingleAsync(it => it.id == endLocations[0].id);
                    bool isMatch = await IsCarryAndLocationMatchByCarryStd(carry, loc);
                    if (!isMatch)
                    {
                        throw new AppFriendlyException("库位与载具规格不匹配", 500);
                    }

                    ePoint = await _db.Queryable<WmsPointH>().FirstAsync(it => it.location_id == endLocations[0].id);
                }
                if (ePoint == null)
                    throw Oops.Bah("无可用的目标库位");

                List<WmsPointH> points = new List<WmsPointH>();
                if (sPoint.area_code != ePoint.area_code)
                {
                    points = await _wareHouseService.PathAlgorithms(sPoint.id, ePoint.id);
                    if (points.Count <= 2)
                    {
                        throw new AppFriendlyException($"sPoint {sPoint.point_code} ePoint{ePoint.point_code}该路径不存在", 500);
                    }
                }
                else
                {
                    points.Add(sPoint);
                    points.Add(ePoint);
                }

                //根据获取的路径点生成预任务,生成顺序必须预路径算法返回的起终点的顺序一致（预任务顺序）

                List<WmsPretaskH> preTasks = points.Where(it => !it.location_id.IsNullOrEmpty()).GroupBy(g => g.area_code).Select(it =>
                {
                    WmsPointH? sPoint = it.FirstOrDefault();
                    WmsPointH? ePoint = it.LastOrDefault();

                    WmsPretaskH preTask = new()
                    {
                        org_id = _userManager.User.OrganizeId,
                        startlocation_id = sPoint?.location_id!,
                        startlocation_code = sPoint?.location_code!,
                        endlocation_id = ePoint?.location_id!,
                        endlocation_code = ePoint?.location_code!,
                        start_floor = sPoint?.floor.ToString(),
                        end_floor = ePoint?.floor.ToString(),
                        startpoint_id = sPoint?.id!,
                        startpoint_code = sPoint?.point_code!,
                        endpoint_id = ePoint?.id!,
                        endpoint_code = ePoint?.point_code!,
                        bill_code = _billRullService.GetBillNumber(WmsWareHouseConst.WMS_PRETASK_H_ENCODE).GetAwaiter().GetResult(),
                        status = WmsWareHouseConst.PRETASK_BILL_STATUS_DXF_ID,
                        biz_type = WmsWareHouseConst.BIZTYPE_TEMPCONTROLINSTOCK_ID,
                        task_type = WmsWareHouseConst.WMS_PRETASK_INSTOCK_TYPE_ID,
                        carry_id = qcTempControlD.carry_id,
                        carry_code = qcTempControlD.carry_code,
                        area_id = sPoint?.area_id!,
                        area_code = it.Key,
                        require_id = qctempControlH?.id,
                        require_code = qctempControlH?.bill_code,
                        create_id = _userManager.UserId,
                        create_time = DateTime.Now,
                    };

                    return preTask;
                }).ToList();
                bool isOk = await _wareHouseService.GenPreTask(preTasks, null!);
                if (!isOk)
                    throw Oops.Bah($"生成暂控料入库预任务失败");

                await _db.Updateable<QcTempControlD>().SetColumns(r => r.pre_task_id == preTasks.FirstOrDefault().id).Where(r => r.id == id).ExecuteCommandAsync();
                #endregion

                await _db.Ado.CommitTranAsync();
            }
            catch(Exception e)
            {
                await _db.Ado.RollbackTranAsync();
                Log.Error(e.Message, e);
                throw Oops.Bah(e.Message);
            }
            return "保存成功";
        }

        /// <summary>
        /// 显示已挑选合格数量
        /// </summary>
        /// <param name="dic"></param>
        /// <returns></returns>
        [HttpPost]

        public async Task<dynamic> ShowPickQualifiedQty(Dictionary<string, string> dic)
        {
            try
            {
                var id = dic["id"].ToString();
                var qcTempControlH = await _db.Queryable<QcTempControlH>().Where(r => r.id == id).FirstAsync();
                if (qcTempControlH == null)
                    throw Oops.Bah($"数据不存在");

                var qcTempControlDs = await _db.Queryable<QcTempControlD>().Where(r => r.bill_id == id).ToListAsync();

                QcTempControlPickQualifiedQtyOutput result = new QcTempControlPickQualifiedQtyOutput();
                if (qcTempControlDs != null)
                {
                    result.temp_control_qty = qcTempControlH.control_qty;
                    result.qualified_qty = qcTempControlDs.Sum(r => (string.IsNullOrEmpty(r.qualified_qty) ? 0 : Convert.ToDecimal(r.qualified_qty))).ToString();
                    result.unQualified_qty = ((string.IsNullOrEmpty(qcTempControlH.control_qty) ? 0 : Convert.ToDecimal(qcTempControlH.control_qty)) - Convert.ToDecimal(result.qualified_qty)).ToString();
                }
                else
                {
                    result.temp_control_qty = qcTempControlH.control_qty;
                    result.qualified_qty = "0";
                    result.unQualified_qty = "0";
                }
                return result;
            }
            catch (Exception e)
            {
                Log.Error(e.Message, e);
                throw Oops.Bah(e.Message);
            }
        }



        /// <summary>
        /// 挑选不合格数量完成
        /// </summary>
        /// <param name="dic"></param>
        /// <returns></returns>
        [HttpPost]

        public async Task<string> SavePickComplete(Dictionary<string, string> dic)
        {
            try
            {
                var id = dic["id"].ToString();

                //保存暂控处理单状态为挑选完成之前，需要确保所有的8号线入库任务全部完成，挑选完成之后，对接bip(暂时不对接)，把不合格总数量传给BIP；
                //并且生成一个其它出库（从中储仓出到次品仓），其他入库（从中储仓入到次品仓）任务
                var qcTempControlH = await _db.Queryable<QcTempControlH>().Where(r => r.id == id).FirstAsync();
                if (qcTempControlH == null)
                    throw Oops.Bah($"数据不存在");
                //质检任务主表
                var qcCheckExecH = await _db.Queryable<QcCheckExecH>().Where(r => r.bill_code == qcTempControlH.source_code).FirstAsync();

                var qcTempControlDs = await _db.Queryable<QcTempControlD>().Where(r => r.bill_id == qcTempControlH.id).ToListAsync();
                //找到所有的预任务id
                var pre_task_ids = qcTempControlDs.Where(r => !string.IsNullOrEmpty(r.pre_task_id)).Select(r => r.pre_task_id).Distinct();

                //查找到未完成的任务
                var wmsDistasks = await _db.Queryable<WmsDistaskH>().Where(r => pre_task_ids.Contains(r.pretask_id) && r.status != WmsWareHouseConst.TASK_BILL_STATUS_COMPLE_ID).ToListAsync();
                if (wmsDistasks != null && wmsDistasks.Count > 0)
                    throw Oops.Bah($"还存在未完成的入库任务，挑选完成失败");

                //计算所有合格数量
                var qualifiedQty = qcTempControlDs.Sum(r => (string.IsNullOrEmpty(r.qualified_qty) ? 0 : Convert.ToDecimal(r.qualified_qty)));

                #region 生产报废记录

                //新增生产报废记录
                var prdTaskDefect = new PrdMoTaskDefectRecord();
                //生产工单
                var prdMo = await _db.Queryable<PrdMo>().LeftJoin<PrdMoTask>((a, b) => a.id == b.mo_id).Where((a, b) => b.mo_task_code == qcTempControlH.pro_task_code).FirstAsync();
                var prdMoTask = await _db.Queryable<PrdMoTask>().Where(r => r.mo_task_code == qcTempControlH.pro_task_code).FirstAsync();
                prdTaskDefect.mo_code=prdMo?.mo_code;
                prdTaskDefect.mo_task_id = prdMoTask?.id;
                prdTaskDefect.mo_task_code=qcTempControlH.pro_task_code;
                prdTaskDefect.mo_task_type = prdMo?.mo_type;

                var basMaterial = await _db.Queryable<BasMaterial>().Where(r => r.id == qcTempControlH.material_id).FirstAsync();
                prdTaskDefect.material_code = basMaterial?.code;
                prdTaskDefect.material_name=basMaterial?.name;
                prdTaskDefect.estimated_start_date = prdMoTask?.estimated_start_date;
                prdTaskDefect.estimated_end_date=prdMoTask?.estimated_end_date;
                prdTaskDefect.plan_qty = prdMoTask?.plan_qty;
                prdTaskDefect.scrap_qty = (string.IsNullOrEmpty(qcTempControlH.control_qty) ? 0 : Convert.ToDecimal(qcTempControlH.control_qty)) - qualifiedQty;//暂控数量-合格数量
                prdTaskDefect.status = prdMoTask?.mo_task_status;
                prdTaskDefect.eqp_code = prdMoTask == null ? "" : (await _db.Queryable<EqpEquipment>().FirstAsync(it => it.id == prdMoTask.eqp_id))?.code!;
                prdTaskDefect.mold_name = prdMoTask == null ? "" : (await _db.Queryable<ToolMolds>().FirstAsync(it => it.id == prdMoTask.mold_id))?.mold_name!;
                prdTaskDefect.create_time = DateTime.Now;
                prdTaskDefect.create_id = _userManager.UserId;

                await _db.Insertable(prdTaskDefect).ExecuteCommandAsync();
                //新增生产报废记录子表
                var prdMoTaskDefectRecordDs = new List<PrdMoTaskDefectRecordD>();
                foreach(var item in qcTempControlDs)
                {
                    var prdMoTaskDefectRecordD = new PrdMoTaskDefectRecordD
                    {
                        bill_id = prdTaskDefect.id,
                        source_id = item.id,
                        carry_id = item.carry_id,
                        carry_code = item.carry_code,
                        scrap_qty = ((string.IsNullOrEmpty(item.qty) ? 0 : Convert.ToDecimal(item.qty)) - (string.IsNullOrEmpty(item.qualified_qty) ? 0 : Convert.ToDecimal(item.qualified_qty))).ToString(),
                        submiter_id= item.submiter,
                        maker_id =item.maker_id,
                        make_time= prdTaskDefect.create_time
                    };
                    prdMoTaskDefectRecordDs.Add(prdMoTaskDefectRecordD);
                }

                await _db.Insertable(prdMoTaskDefectRecordDs).ExecuteCommandAsync();
                #endregion

                //载具台账变为空载具（载具状态：空闲、库位ID清空、检验状态：待检、子表数据清空）

                foreach(var item in qcTempControlDs)
                {
                    var wmsCarryH = await _db.Queryable<WmsCarryH>().Where(r => r.id == item.carry_id).FirstAsync();
                    wmsCarryH.carry_status = ((int)EnumCarryStatus.空闲).ToString();
                    wmsCarryH.is_check = ((int)EnumCheckConclusion.待检).ToString();
                    wmsCarryH.location_code = "";
                    wmsCarryH.location_id = "";
                    wmsCarryH.is_lock = 0;
                    await _db.Updateable(wmsCarryH).ExecuteCommandAsync();

                    await _db.Updateable<WmsCarryH>()
                        .SetColumns(r => r.carry_status == ((int)EnumCarryStatus.空闲).ToString())
                        .SetColumns(r => r.is_check == ((int)EnumCheckConclusion.待检).ToString())
                        .SetColumns(r => r.location_code == "")
                        .SetColumns(r => r.location_id == "")
                        .SetColumns(r => r.is_lock == 0)
                        .Where(r=>r.id==item.carry_id)
                        .ExecuteCommandAsync();

                    await _db.Deleteable<WmsCarryCode>().Where(r => r.carry_id == item.carry_id).ExecuteCommandAsync();
                }

                await _db.Ado.CommitTranAsync();
            }
            catch (Exception e)
            {
                await _db.Ado.RollbackTranAsync();
                Log.Error(e.Message, e);
                throw Oops.Bah(e.Message);
            }
            return "保存成功";
        }


    }
}