using DBUtility;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Net;
using System.Net.Http;
using System.Web.Http;
using WebAPI.Models;

namespace WebAPI.Controllers
{
    public class Gy_UnitConvertRateController : ApiController
    {
        public DBUtility.ClsPub.Enum_BillStatus BillStatus;
        const string ModCaption = "单位换算";
        public const string ModRightName = "Gy_UnitConvertRate";
        public const string ModRightNameDelete = ModRightName + "_Delete";  //删除
        public DataSet ds = new DataSet();
        private json objJsonResult = new json();
        SQLHelper.ClsCN oCn = new SQLHelper.ClsCN();
        Pub_Class.ClsXt_SystemParameter oSystemParameter = new Pub_Class.ClsXt_SystemParameter();


        #region 单位换算列表
        /// <summary>
        /// 获取单位换算列表信息
        /// </summary>
        /// <returns></returns>
        [Route("Gy_UnitConvertRateController/GetGy_UnitConvertRateList_Json")]
        [HttpGet]
        public object GetGy_UnitConvertRateList_Json(string sWhere, string HMaker, string OperationType)
        {
            try
            {
                //判断权限  1为直接列表模块打开  2为从其他模块跳转打开列表
                if (OperationType == "1")
                {
                    //判断权限
                    if (!DBUtility.ClsPub.Security_Log(ModRightName, 1, false, HMaker))
                    {
                        objJsonResult.code = "0";
                        objJsonResult.count = 0;
                        objJsonResult.Message = "您没有该模块权限,请与管理员联系！";
                        objJsonResult.data = null;
                        return objJsonResult;
                    }
                }

                //返回列表信息
                ds = oCn.RunProcReturn("select * from h_v_Gy_UnitConvertRateList where " + sWhere + " order by HItemID desc", "h_v_Gy_UnitConvertRateList");
                List<object> columnNameList = new List<object>();
                //添加列名
                foreach (DataColumn col in ds.Tables[0].Columns)
                {
                    Type dataType = col.DataType;
                    string ColmString = "{\"ColmCols\":\"" + col.ColumnName + "\",\"ColmType\":\"" + dataType.Name + "\"}";
                    columnNameList.Add(JsonConvert.DeserializeObject(ColmString));  //获取到DataColumn列对象的列名
                }
                objJsonResult.code = "0";
                objJsonResult.count = 1;
                objJsonResult.Message = "成功！";
                objJsonResult.data = ds.Tables[0];
                objJsonResult.list = columnNameList;
                return objJsonResult;
            }
            catch (Exception e)
            {
                objJsonResult.code = "0";
                objJsonResult.count = 0;
                objJsonResult.Message = "查询列表信息失败！" + e.ToString();
                objJsonResult.data = null;
                return objJsonResult;
            }
        }
        #endregion

        #region 单位换算删除
        /// <summary>
        /// 删除单位换算
        /// </summary>
        /// <returns></returns>
        [Route("Gy_UnitConvertRateController/GetGy_UnitConvertRate_Delete_Json")]
        [HttpGet]
        public object GetGy_UnitConvertRate_Delete_Json(Int64 HItemID, string HMaker)
        {
            try
            {
                //判断权限
                if (!DBUtility.ClsPub.Security_Log(ModRightNameDelete, 1, false, HMaker))
                {
                    objJsonResult.code = "0";
                    objJsonResult.count = 0;
                    objJsonResult.Message = "您没有该模块删除功能权限,请与管理员联系！";
                    objJsonResult.data = null;
                    return objJsonResult;
                }

                oCn.BeginTran();
                //判断存在性
                ds = oCn.RunProcReturn("select HNumber,HName from Gy_UnitConvertRate with(nolock) where HItemID= " + HItemID.ToString(), "Gy_UnitConvertRate");
                if (ds == null || ds.Tables[0].Rows.Count == 0)
                {
                    oCn.RollBack();
                    objJsonResult.code = "0";
                    objJsonResult.count = 0;
                    objJsonResult.Message = "未查询到该单位换算，请刷新数据后重新选择！";
                    objJsonResult.data = null;
                    return objJsonResult;
                }
                else
                {
                    oCn.RunProc("Delete from Gy_UnitConvertRate where HItemID= " + HItemID.ToString(), ref DBUtility.ClsPub.sExeReturnInfo);
                    //写入日志
                    DBUtility.ClsPub.Add_Log("", "删除单位换算，代码：" + DBUtility.ClsPub.isStrNull(ds.Tables[0].Rows[0]["HNumber"]) + ",名称：" + DBUtility.ClsPub.isStrNull(ds.Tables[0].Rows[0]["HName"]), HMaker);
                    oCn.Commit();
                    objJsonResult.code = "0";
                    objJsonResult.count = 1;
                    objJsonResult.Message = "删除单位换算成功！";
                    objJsonResult.data = null;
                    return objJsonResult;
                }
            }
            catch (Exception e)
            {
                oCn.RollBack();
                objJsonResult.code = "0";
                objJsonResult.count = 0;
                objJsonResult.Message = "删除单位换算失败！" + e.ToString();
                objJsonResult.data = null;
                return objJsonResult;
            }
        }
        #endregion

        #region 单位换算批量同步
        /// <summary>
        /// 从金蝶云批量同步单位换算至本地表
        /// </summary>
        [Route("Gy_UnitConvertRateController/GetGy_UnitConvertRate_BatchSync_Json")]
        [HttpGet]
        public object GetGy_UnitConvertRate_BatchSync_Json()
        {
            try
            {
                //获取系统参数
                string sErrMsg = "";
                if (oSystemParameter.ShowBill(ref sErrMsg) == true)
                {
                    //系统参数是否为私有云模式,N为公有云模式，Y为私有云模式
                    //私有云模式，通过调用存储过程进行同步
                    if (oSystemParameter.omodel.WMS_CloudMode.ToUpper() == "Y")
                    {
                        ds = oCn.RunProcReturn("exec h_p_IFCLD_ERPDataToLocal_UnitConvertRate", "h_p_IFCLD_ERPDataToLocal_UnitConvertRate");
                        objJsonResult.code = "0";
                        objJsonResult.count = 1;
                        objJsonResult.Message = "单位换算批量同步成功！";
                        objJsonResult.data = null;
                        return objJsonResult;
                    }
                    //公有云模式，通过调用WEBAPI方式进行同步
                    else if (oSystemParameter.omodel.WMS_CloudMode.ToUpper() == "N")
                    {
                        //判断金蝶云是否登录成功
                        var loginRet = InvokeHelper.Login();
                        var isSuccess = JObject.Parse(loginRet)["LoginResultType"].Value<int>();
                        //判断是否登录成功
                        if (isSuccess <= 0)
                        {
                            objJsonResult.code = "0";
                            objJsonResult.count = 0;
                            objJsonResult.Message = "批量同步失败，金蝶云登入不成功，请确认C盘配置文件所设置金蝶云对应网址、账套、登录用户、登录密码是否正确！";
                            objJsonResult.data = null;
                            return objJsonResult;
                        }

                        var json = new
                        {
                            FormId = "BD_UNITCONVERTRATE",
                            FieldKeys = "FUNITCONVERTRATEID,FBILLNO,FMATERIALID,FUSEORGID,FCREATEORGID,FFORBIDSTATUS" +
                            ",FCURRENTUNITID,FDESTUNITID,FCONVERTTYPE,FCONVERTNUMERATOR,FCONVERTDENOMINATOR" +
                            ",FCREATORID,FCREATEDATE,FMODIFIERID,FMODIFYDATE,FAPPROVERID,FAPPROVEDATE,FFORBIDDERID,FFORBIDDATE" +
                            ",FMATERIALID.FNUMBER",
                            FilterString = "",
                            OrderString = "",
                            TopRowCount = 0,
                            StartRow = 0,
                            Limit = 0
                        };
                        //查看 获取数据                    
                        var _result = InvokeHelper.Query("BD_UNITCONVERTRATE", JsonConvert.SerializeObject(json));

                        //反序列化
                        _result = _result.Replace("\"", "");
                        _result = _result.Replace("\n", "");
                        _result = _result.Replace(",[", "");
                        _result = _result.Replace("[", "");
                        string[] rows = _result.Split(new string[] { "]" }, StringSplitOptions.RemoveEmptyEntries); //以"]"分隔每一行并移除空行
                        string[,] arr = new string[rows.Length, rows[0].Split(',').Length]; //根据行和列数创建二维数组
                        for (int i = 0; i < rows.Length; i++) //遍历每一行
                        {
                            string[] cols = rows[i].Split(','); //以逗号分隔每一列
                            for (int j = 0; j < cols.Length; j++) //遍历每一列
                            {
                                arr[i, j] = cols[j]; //存入二维数组
                            }
                        }

                        oCn.BeginTran();
                        //清空单位换算表数据
                        oCn.RunProc("Delete from Gy_UnitConvertRate", ref DBUtility.ClsPub.sExeReturnInfo);

                        //输出二维数组
                        for (int i = 0; i < arr.GetLength(0); i++)
                        {
                            var subData = new
                            {
                                HItemID = DBUtility.ClsPub.isLong(arr[i, 0]),
                                HNumber = "",
                                HName = "",
                                HShortNumber = "",
                                HParentID = 0,
                                HLevel = 1,
                                HEndFlag = 1,
                                HStopflag = arr[i, 5].ToString() == "B" ? 1 : 0,
                                HRemark = "CLD-ERP导入",
                                HUseFlag = "已使用",
                                HUSEORGID = DBUtility.ClsPub.isLong(arr[i, 3]),
                                HCREATEORGID = DBUtility.ClsPub.isLong(arr[i, 4]),
                                HBILLNO = DBUtility.ClsPub.isStrNull(arr[i, 1]),
                                HMATERID = DBUtility.ClsPub.isLong(arr[i, 2]),
                                HCURRENTUNITID = DBUtility.ClsPub.isLong(arr[i, 6]),
                                HDESTUNITID = DBUtility.ClsPub.isLong(arr[i, 7]),
                                HCONVERTTYPE = DBUtility.ClsPub.isStrNull(arr[i, 8]),
                                HCONVERTNUMERATOR = DBUtility.ClsPub.isDoule(arr[i, 9]),
                                HCONVERTDENOMINATOR = DBUtility.ClsPub.isDoule(arr[i, 10]),
                                HFORBIDSTATUS = DBUtility.ClsPub.isStrNull(arr[i, 5]),
                                HUnitID = DBUtility.ClsPub.isLong(arr[i, 2] == "0" ? arr[i, 6] : "-1"),
                                HMakeEmp = DBUtility.ClsPub.isStrNull(arr[i, 11]),
                                HMakeTime = DBUtility.ClsPub.isDate(arr[i, 12]),
                                HCheckEmp = DBUtility.ClsPub.isStrNull(arr[i, 15]),
                                HCheckTime = DBUtility.ClsPub.isDate(arr[i, 16]),
                                HModifyEmp = DBUtility.ClsPub.isStrNull(arr[i, 13]),
                                HModifyTime = DBUtility.ClsPub.isDate(arr[i, 14]),
                                HStopEmp = DBUtility.ClsPub.isStrNull(arr[i, 17]),
                                HStopTime = DBUtility.ClsPub.isDate(arr[i, 18]),
                                HMaterNumber = DBUtility.ClsPub.isStrNull(arr[i, 19]),
                            };

                            //写入单位换算表数据
                            oCn.RunProc("set identity_insert Gy_UnitConvertRate on", ref DBUtility.ClsPub.sExeReturnInfo);
                            string sql = $@"Insert into Gy_UnitConvertRate 
                                    (HItemID,HNumber,HName,HShortNumber,HParentID,HLevel
                                    ,HEndFlag,HStopflag,HRemark,HUseFlag,HUSEORGID,HCREATEORGID
                                    ,HBILLNO,HMATERID,HCURRENTUNITID,HDESTUNITID,HCONVERTTYPE,HCONVERTNUMERATOR
                                    ,HCONVERTDENOMINATOR,HFORBIDSTATUS,HUnitID,HMaterNumber
                                    ,HMakeEmp,HMakeTime
                                    ,HCheckEmp,HCheckTime
                                    ,HModifyEmp,HModifyTime
                                    ,HStopEmp,HStopTime)
                                    Values({subData.HItemID},'{subData.HNumber}','{subData.HName}','{subData.HShortNumber}',{subData.HParentID},{subData.HLevel}
                                    ,{subData.HEndFlag},{subData.HStopflag},'{subData.HRemark}','{subData.HUseFlag}',{subData.HUSEORGID},{subData.HCREATEORGID}
                                    ,'{subData.HBILLNO}',{subData.HMATERID},{subData.HCURRENTUNITID},{subData.HDESTUNITID},{subData.HCONVERTTYPE},{subData.HCONVERTNUMERATOR}
                                    ,{subData.HCONVERTDENOMINATOR},'{subData.HFORBIDSTATUS}',{subData.HUnitID},'{subData.HMaterNumber}'
                                    ,'{subData.HMakeEmp}',case when '{subData.HMakeTime}' = '1900/1/1 0:00:00' then NULL else '{subData.HMakeTime}' end
                                    ,'{subData.HCheckEmp}',case when '{subData.HCheckTime}' = '1900/1/1 0:00:00' then NULL else '{subData.HCheckTime}' end
                                    ,'{subData.HModifyEmp}',case when '{subData.HModifyTime}' = '1900/1/1 0:00:00' then NULL else '{subData.HModifyTime}' end
                                    ,'{subData.HStopEmp}',case when '{subData.HStopTime}' = '1900/1/1 0:00:00' then NULL else '{subData.HStopTime}' end)";
                            oCn.RunProc(sql.Replace("\r\n", ""));
                            oCn.RunProc("set identity_insert Gy_UnitConvertRate off", ref DBUtility.ClsPub.sExeReturnInfo);
                        }
                        oCn.Commit();
                        objJsonResult.code = "0";
                        objJsonResult.count = 1;
                        objJsonResult.Message = "单位换算批量同步成功！";
                        objJsonResult.data = null;
                        return objJsonResult;
                    }
                    else
                    {
                        objJsonResult.code = "0";
                        objJsonResult.count = 1;
                        objJsonResult.Message = "不支持批量同步功能！";
                        objJsonResult.data = null;
                        return objJsonResult;
                    }
                }
                else
                {
                    objJsonResult.code = "0";
                    objJsonResult.count = 0;
                    objJsonResult.Message = "获取系统参数失败！ " + sErrMsg;
                    objJsonResult.data = null;
                    return objJsonResult;
                }
            }
            catch (Exception e)
            {
                objJsonResult.code = "0";
                objJsonResult.count = 0;
                objJsonResult.Message = "单位换算批量同步失败！" + e.ToString();
                objJsonResult.data = null;
                return objJsonResult;
            }
        }

        #endregion

    }
}