using log4net;
using System;
using System.Collections;
using System.Collections.Generic;
using UFIDA.U8.Framework.Api.ControlObject.Common;
using UFIDA.U8.Framework.Api.ControlObject.Json;
using UFIDA.U8.Framework.Api.ControlObject.Models;
using UFSoft.U8.Framework.ContextSrv;
using UFSoft.U8.U8M.BFDispatcher;
using UFSoft.U8.U8M.Common;
using UFSoft.U8.U8M.DAC;
using UFSoft.U8.U8M.DOSchema.SF;
// ReSharper disable IdentifierTypo
// ReSharper disable InconsistentNaming
// ReSharper disable StringLiteralTypo

namespace UFIDA.U8.Framework.Api.ControlObject.U8M
{
    public class MoRoutingBill
    {

        protected readonly ILog logInfo = LogManager.GetLogger("logInfo");

        private MoRoutingBillDs GetEmptyDs(string cCardNum)
        {
            var ds = SFExecutor.BFMoRoutingBill_LoadData("LoadFirst", 0, "", cCardNum, new DefaultContextContainer());

            #region 清除数据集里的数据

            if (ds.Tables.Contains("fc_MoRoutingBilldetail_ExtraDefine"))
            {
                ds.Tables["fc_MoRoutingBilldetail_ExtraDefine"].Clear();
            }
            if (ds.Tables.Contains("fc_MoRoutingBill_ExtraDefine"))
            {
                ds.Tables["fc_MoRoutingBill_ExtraDefine"].Clear();
            }

            ds.MoRoutingBillRes.Clear();
            ds.MoRoutingBillDetail.Clear();
            ds.MoRoutingBill.Clear();

            #endregion

            return ds;
        }

        private MoRoutingBillDs GetVoucherDs(string cCardNum, AutoDocNoGenerateParam docNoParam, Dictionary<string, object> input)
        {

            var ds = GetEmptyDs(cCardNum);

            var head = ds.MoRoutingBill.NewMoRoutingBillRow();

            ds.MoRoutingBill.AddMoRoutingBillRow(head);

            var docNo = U8MCommonExecutor.BFVoucher_GetVoucherID(cCardNum, docNoParam.Paramaters, false, new DefaultContextContainer());

            var be = new UFSoft.U8.SF.BE.MoRoutingBill(ds);

            be.cVouchType = cCardNum;
            be.cVouchCode = "";

            var beHead = new BEHelper(be);

            beHead.SetValue(input);

            if (string.IsNullOrWhiteSpace(be.cVouchCode))
            {
                be.cVouchCode = docNo;
            }

            var bodys = input["body"] as List<Dictionary<string, object>> ?? $"{input["body"]}".ToObject<List<Dictionary<string, object>>>();

            for (var i = 0; i < bodys.Count; i++)
            {
                var body = bodys[i];
                var detail = be.MoRoutingBillDetails[i];

                var beBody = new BEHelper(detail);

                beBody.SetValue(body);
            }


            return (MoRoutingBillDs)be.DataObject;
        }

        public BaseResult<dynamic> Save(string cCardNum, Dictionary<string, object> input)
        {
            try
            {
                var docNoParam = new AutoDocNoGenerateParam(EnumAutoDocNoType.HandAuto, cCardNum)
                {
                    IsCurrentDocNoByHand = false
                };

                var ds = GetVoucherDs(cCardNum, docNoParam, input);

                if (ds == null)
                {
                    throw new Exception("未能构建数据集");
                }

                //var context = new DefaultContextContainer();
                //context.context["taskid"] = taskId;

                var id = SFExecutor.BFMoRoutingBill_MoRoutingBillSave(ds, docNoParam, new DefaultContextContainer());

                return new BaseResult<dynamic>() { bSuccess = true, message = "新增成功", result = id };
            }
            catch (Exception ex)
            {
                logInfo.Error(ex.Message, ex);

                return new BaseResult<dynamic>() { bSuccess = false, message = "新增失败", result = ex.Message };

            }

        }

        public BaseResult<dynamic> Delete(string cCardNum, List<string> inputs)
        {
            try
            {
                if (inputs == null || inputs.Count <= 0)
                    throw new Exception("没有需要删除的数据");

                var dataReader = SimpleDACObject.ExecuteReader($"SELECT MID FROM dbo.fc_MoRoutingBill WHERE cVouchCode IN ('{string.Join("','", inputs)}') AND cVouchType='{cCardNum}'");

                var newInput = new List<int>();

                while (dataReader.Read())
                {
                    newInput.Add(int.Parse($"{dataReader[0]}"));
                }

                return Delete(newInput);
            }
            catch (Exception ex)
            {
                logInfo.Error(ex.Message, ex);

                return new BaseResult<dynamic>() { bSuccess = false, message = "删除失败", result = ex.Message };
            }
        }

        public BaseResult<dynamic> Delete(List<int> inputs)
        {
            try
            {
                if (inputs == null || inputs.Count <= 0)
                    throw new Exception("没有需要删除的数据");

                var ht = new Hashtable();

                foreach (var input in inputs)
                {
                    ht.Add(input, input);
                }

                var id = SFExecutor.BFMoRoutingBill_MoRoutingBillBatchDelete(ht, new DefaultContextContainer());

                return new BaseResult<dynamic>() { bSuccess = true, message = "删除成功", result = id };
            }
            catch (Exception ex)
            {
                logInfo.Error(ex.Message, ex);

                return new BaseResult<dynamic>() { bSuccess = false, message = "删除失败", result = ex.Message };

            }

        }

        public BaseResult<dynamic> Verify(string cCardNum, List<string> inputs)
        {
            try
            {
                if (inputs == null || inputs.Count <= 0)
                    throw new Exception("没有需要审核的数据");

                var dataReader = SimpleDACObject.ExecuteReader($"SELECT MID FROM dbo.fc_MoRoutingBill WHERE cVouchCode IN ('{string.Join("','", inputs)}') AND cVouchType='{cCardNum}'");

                var newInput = new List<int>();

                while (dataReader.Read())
                {
                    newInput.Add(int.Parse($"{dataReader[0]}"));
                }

                return Verify(newInput);
            }
            catch (Exception ex)
            {
                logInfo.Error(ex.Message, ex);

                return new BaseResult<dynamic>() { bSuccess = false, message = "审核失败", result = ex.Message };
            }
        }

        public BaseResult<dynamic> Verify(List<int> inputs)
        {
            try
            {
                if (inputs == null || inputs.Count <= 0)
                    throw new Exception("没有需要审核的数据");

                var ht = new Dictionary<int, string>();

                foreach (var input in inputs)
                {
                    ht.Add(input, $"{input}");
                }

                var id = SFExecutor.BFMoRoutingBill_Verify(ht, new DefaultContextContainer());

                return new BaseResult<dynamic>() { bSuccess = true, message = "审核成功", result = id };
            }
            catch (Exception ex)
            {
                logInfo.Error(ex.Message, ex);

                return new BaseResult<dynamic>() { bSuccess = false, message = "审核失败", result = ex.Message };

            }

        }

        public BaseResult<dynamic> UnVerify(string cCardNum, List<string> inputs)
        {
            try
            {
                if (inputs == null || inputs.Count <= 0)
                    throw new Exception("没有需要弃审的数据");

                var dataReader = SimpleDACObject.ExecuteReader($"SELECT MID FROM dbo.fc_MoRoutingBill WHERE cVouchCode IN ('{string.Join("','", inputs)}') AND cVouchType='{cCardNum}'");

                var newInput = new List<int>();

                while (dataReader.Read())
                {
                    newInput.Add(int.Parse($"{dataReader[0]}"));
                }

                return UnVerify(newInput);
            }
            catch (Exception ex)
            {
                logInfo.Error(ex.Message, ex);

                return new BaseResult<dynamic>() { bSuccess = false, message = "弃审失败", result = ex.Message };
            }
        }

        public BaseResult<dynamic> UnVerify(List<int> inputs)
        {
            try
            {
                if (inputs == null || inputs.Count <= 0)
                    throw new Exception("没有需要弃审的数据");

                var ht = new Dictionary<int, string>();

                foreach (var input in inputs)
                {
                    ht.Add(input, $"{input}");
                }

                var id = SFExecutor.BFMoRoutingBill_UnVerify(ht, new DefaultContextContainer());

                return new BaseResult<dynamic>() { bSuccess = true, message = "弃审成功", result = id };
            }
            catch (Exception ex)
            {
                logInfo.Error(ex.Message, ex);

                return new BaseResult<dynamic>() { bSuccess = false, message = "弃审失败", result = ex.Message };

            }

        }

    }
}