using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using System;
using System.Collections.Generic;
using System.Data;
using System.Data.SqlClient;
using System.Linq;
using System.Net;
using System.Net.Http;
using System.Text.RegularExpressions;
using System.Web;
using System.Web.Http;
using WebAPI.Code;
using WebAPI.Models;
using WebAPI.Utility;
namespace WebAPI.Controllers
{
    public class MaterialHandingController : ApiController
    {
        // GET: MaterialHanding
        private JsonResult objJsonResult = new JsonResult();
        private json objjson = new json();
        SQLHelper.ClsCN oCN = new SQLHelper.ClsCN();
        DataSet ds;
        //获取系统参数
        Pub_Class.ClsXt_SystemParameter oSystemParameter = new Pub_Class.ClsXt_SystemParameter();
        [Route("MaterialHandingController/GetMaterialHandingList")]
        [HttpGet]
        public object GetMaterialHandingList(string sWhere, string user)
        {
            List<object> columnNameList = new List<object>();
            try
            {
                string VsWhere = sWhere;
                SQLHelper.ClsCN oCn = new SQLHelper.ClsCN();
                DataSet ds;
                //其他过滤
                //string sql = " where 1 = 1 " + sqlWhere;
                ////转换特殊字符
                //if (Common.SQLtoChange(sql, ref VsWhere, ref PcWhere) == false)
                //{
                //    objjson.code = "0";
                //    objjson.count = 0;
                //    objjson.Message = "转换特殊字符失败";
                //    objjson.data = null;
                //    return objjson;
                //}

                //获取返回数据
                ds = oCn.RunProcReturn("select * from h_v_Gy_UserMaterRelation where 1=1 " + sWhere, "h_v_Gy_UserMaterRelation");
                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列对象的列名
                }
                if (ds == null || ds.Tables[0].Rows.Count == 0)
                {
                    objjson.code = "0";
                    objjson.count = 0;
                    objjson.Message = "获取失败,没有相关数据";
                    objjson.data = null;
                    return objjson;
                }
                else
                {
                    objjson.code = "0";
                    objjson.count = 10000;
                    objjson.Message = "获取成功";
                    objjson.data = ds.Tables[0];
                    objjson.list = columnNameList;
                    return objjson;
                }
            }
            catch (Exception e)
            {
                objjson.code = "0";
                objjson.count = 0;
                objjson.Message = "获取失败" + e.ToString();
                objjson.data = null;
                return objjson;
            }
        }

        #region  启用

        [Route("MaterialHandingController/OpenMaterial")]
        [HttpGet]
        public object OpenMaterial(int HInterID, int IsUse, string CurUserName)
        {
            try
            {

                var ds = oCN.RunProcReturn("select * from Gy_UserMaterRelation where HItemID=" + HInterID, "Gy_UserMaterRelation");
                if (ds.Tables[0].Rows.Count > 0)
                {
                    IsUse = Convert.ToInt32(ds.Tables[0].Rows[0]["HUseFlag"]) ;
                    if (IsUse == 1)  //判断
                    {
                        if (ds.Tables[0].Rows[0]["HUpDater"].ToString() != "")
                        {
                            objJsonResult.code = "0";
                            objJsonResult.count = 0;
                            objJsonResult.Message = "单据已启用!不能再次启用！";
                            objJsonResult.data = null;
                            return objJsonResult;
                        }
                    }
                }
                else
                {
                    objJsonResult.code = "0";
                    objJsonResult.count = 0;
                    objJsonResult.Message = "单据不存在!";
                    objJsonResult.data = null;
                    return objJsonResult;
                }

                oCN.BeginTran();

                if (IsUse == 0)  //启用判断
                {

                    //禁用前控制=========================================      
                    string sql1 = "exec h_p_Gy_MaterPrice_BeforeStopCtrl " + HInterID + ",'" + CurUserName + "'";
                    ds = oCN.RunProcReturn(sql1, "h_p_Gy_MaterPrice_BeforeStopCtrl");
                    if (ds == null || ds.Tables.Count == 0 || ds.Tables[0].Rows.Count == 0)
                    {
                        objJsonResult.code = "0";
                        objJsonResult.count = 1;
                        objJsonResult.Message = "禁用失败!原因:禁用前判断失败，请与网络管理人员联系";
                        objJsonResult.data = null;
                        oCN.RollBack();
                        return objJsonResult;
                    }

                    if (ds.Tables[0].Rows[0]["HBack"].ToString() != "0")
                    {
                        objJsonResult.code = "0";
                        objJsonResult.count = 1;
                        objJsonResult.Message = "禁用失败!原因:" + ds.Tables[0].Rows[0]["HRemark"].ToString(); ;
                        objJsonResult.data = null;
                        oCN.RollBack();
                        return objJsonResult;
                    }
                    //================================================================================== 


                    oCN.RunProc("update Gy_UserMaterRelation set HUpDater='" + CurUserName + "',HUpDateDate=getdate(),HUseFlag=1 where HItemID=" + HInterID);


                    //禁用后控制=========================================      
                    string sql2 = "exec h_p_Gy_MaterPrice_AfterStopCtrl " + HInterID + ",'" + CurUserName + "'";
                    ds = oCN.RunProcReturn(sql2, "h_p_Gy_MaterPrice_AfterStopCtrl");
                    if (ds == null || ds.Tables.Count == 0 || ds.Tables[0].Rows.Count == 0)
                    {
                        objJsonResult.code = "0";
                        objJsonResult.count = 1;
                        objJsonResult.Message = "禁用失败!原因:禁用后判断失败，请与网络管理人员联系";
                        objJsonResult.data = null;
                        oCN.RollBack();
                        return objJsonResult;
                    }

                    if (ds.Tables[0].Rows[0]["HBack"].ToString() != "0")
                    {
                        objJsonResult.code = "0";
                        objJsonResult.count = 1;
                        objJsonResult.Message = "禁用失败!原因:" + ds.Tables[0].Rows[0]["HRemark"].ToString(); ;
                        objJsonResult.data = null;
                        oCN.RollBack();
                        return objJsonResult;
                    }
                    //================================================================================== 


                    objJsonResult.code = "1";
                    objJsonResult.count = 1;
                    objJsonResult.Message = "启用成功";
                    objJsonResult.data = null;
                }
                //if (IsStop == 1) //反禁用判断
                //{
                //    //反禁用前控制=========================================      
                //    string sql1 = "exec h_p_Gy_Gy_MaterPrice_BeforeUnStopCtrl " + HInterID + ",'" + CurUserName + "'";
                //    ds = oCN.RunProcReturn(sql1, "h_p_Gy_Gy_MaterPrice_BeforeUnStopCtrl");
                //    if (ds == null || ds.Tables.Count == 0 || ds.Tables[0].Rows.Count == 0)
                //    {
                //        objJsonResult.code = "0";
                //        objJsonResult.count = 1;
                //        objJsonResult.Message = "反禁用失败!原因:反禁用前判断失败，请与网络管理人员联系";
                //        objJsonResult.data = null;
                //        oCN.RollBack();
                //        return objJsonResult;
                //    }

                //    if (ds.Tables[0].Rows[0]["HBack"].ToString() != "0")
                //    {
                //        objJsonResult.code = "0";
                //        objJsonResult.count = 1;
                //        objJsonResult.Message = "反禁用失败!原因:" + ds.Tables[0].Rows[0]["HRemark"].ToString(); ;
                //        objJsonResult.data = null;
                //        oCN.RollBack();
                //        return objJsonResult;
                //    }
                //    //================================================================================== 


                //    oCN.RunProc("update Gy_MaterPrice set HStopEmp='',HStopTime=null,HStopflag=0 where HItemID=" + HInterID);


                //    //反禁用后控制=========================================      
                //    string sql2 = "exec h_p_Gy_MaterPrice_AfterUnStopCtrl " + HInterID + ",'" + CurUserName + "'";
                //    ds = oCN.RunProcReturn(sql2, "h_p_Gy_MaterPrice_AfterUnStopCtrl");
                //    if (ds == null || ds.Tables.Count == 0 || ds.Tables[0].Rows.Count == 0)
                //    {
                //        objJsonResult.code = "0";
                //        objJsonResult.count = 1;
                //        objJsonResult.Message = "反禁用失败!原因:反禁用后判断失败，请与网络管理人员联系";
                //        objJsonResult.data = null;
                //        oCN.RollBack();
                //        return objJsonResult;
                //    }

                //    if (ds.Tables[0].Rows[0]["HBack"].ToString() != "0")
                //    {
                //        objJsonResult.code = "0";
                //        objJsonResult.count = 1;
                //        objJsonResult.Message = "反禁用失败!原因:" + ds.Tables[0].Rows[0]["HRemark"].ToString(); ;
                //        objJsonResult.data = null;
                //        oCN.RollBack();
                //        return objJsonResult;
                //    }
                //    //================================================================================== 

                //    objJsonResult.code = "1";
                //    objJsonResult.count = 1;
                //    objJsonResult.Message = "反禁用成功";
                //    objJsonResult.data = null;
                //}
                oCN.Commit();

                return objJsonResult;
            }
            catch (Exception e)
            {
                oCN.RollBack();
                objJsonResult.code = "0";
                objJsonResult.count = 0;
                objJsonResult.Message = "启用失败或者反禁用失败！" + e.ToString();
                objJsonResult.data = null;
                return objJsonResult;
            }
        }
        #endregion

        #region 物料校验
        [Route("MaterialHandingController/CheckMaterial")]
        [HttpGet]
        public object CheckMaterial(string HMaterID, string user, int param,string OrganizationID)
        {
            try
            {
                //ds1获取的sql后期记得改回供应商，修改人->供应商
                var ds1 = oCN.RunProcReturn("select * from h_v_Gy_UserMaterRelationEdit where 物料代码='" + HMaterID + "'" + "and 修改人='" + user + "'", "h_v_Gy_UserMaterRelationEdit");
                var ds = oCN.RunProcReturn("select * from Gy_Material where HNumber='" + HMaterID+ "'", "Gy_Material");

                if (param == 0)
                {
                    if (ds1.Tables[0].Rows.Count > 0)
                    {
                        return 1;
                    }
                    else
                    {
                        return GetMaterialResult(ds);
                    }
                }
                else
                {
                    oCN.BeginTran();
                    string sqlUpd = "UPDATE Gy_UserMaterRelation set HUseFlag=0 where HMaterID="+ ds.Tables[0].Rows[0]["HItemID"];
                    oCN.RunProc(sqlUpd);
                    oCN.Commit();

                    return GetMaterialResult(ds);
                }
            }
            catch (Exception e)
            {
                objJsonResult.code = "0";
                objJsonResult.count = 0;
                objJsonResult.Message = "Exception！" + e.ToString();
                objJsonResult.data = null;
                return objJsonResult;
            }
        }

        private object GetMaterialResult(DataSet ds)
        {
            if (ds.Tables[0].Rows.Count > 0)
            {
                objJsonResult.code = "1";
                objJsonResult.count = 1;
                objJsonResult.Message = "Success！";
                objJsonResult.data = ds.Tables[0];
                return objJsonResult;
            }
            else
            {
                objJsonResult.code = "0";
                objJsonResult.count = 0;
                objJsonResult.Message = "物料不存在！";
                objJsonResult.data = null;
                return objJsonResult;
            }
        }
        #endregion

        #region  编辑查看信息
        [Route("MaterialHandingController/Edit_M")]
        [HttpGet]
        public object Edit_M(string HItemID, string user)
        {
            try
            {
                List<object> columnNameList = new List<object>();
                string sql1 = string.Format(@"select * from h_v_Gy_UserMaterRelationEdit where HItemID = " + HItemID);

                ds = oCN.RunProcReturn(sql1, "h_v_Gy_UserMaterRelationEdit");


                objJsonResult.code = "1";
                objJsonResult.count = 1;
                objJsonResult.Message = "Sucess！";
                objJsonResult.data = ds.Tables[0];
                return objJsonResult;
            }
            catch (Exception e)
            {
                objJsonResult.code = "0";
                objJsonResult.count = 0;
                objJsonResult.Message = "Exception！" + e.ToString();
                objJsonResult.data = null;
                return objJsonResult;
            }
        }
        #endregion

        #region 新增保存
        [Route("MaterialHandingController/AddBill")]
        [HttpPost]
        public object AddBill([FromBody] JObject msg)
        {
            try
            {
                var _value = msg["msg"].ToString();
                string msg3 = _value.ToString();
                //string[] sArray = msg3.Split(new string[] { ";" }, StringSplitOptions.RemoveEmptyEntries);
                //string msg1 = sArray[0].ToString();
                //string msg2 = sArray[1].ToString();
                string msg2 = msg3.ToString();

                //反序列化
                msg2 = "[" + msg2.ToString() + "]";

                List<Model.Cls_MaterialHandingModel> list = Newtonsoft.Json.JsonConvert.DeserializeObject<List<Model.Cls_MaterialHandingModel>>(msg2);
                var ds = oCN.RunProcReturn("select * from Gy_Material where HNumber='" + list[0].HMaterNumber + "'", "Gy_Material");

                int HItemID =Convert.ToInt32(list[0].HItemID);
                string HMaterNumber = list[0].HMaterNumber;
                int HMaterID =Convert.ToInt32(ds.Tables[0].Rows[0]["HItemID"]);
                int HSupID = list[0].HSupID;
                string HUserID = list[0].HUserID;
                decimal HMinPackQty = list[0].HMinPackQty;
                decimal HInBoxPackQty = list[0].HInBoxPackQty;
                decimal HOutBoxPackQty = list[0].HOutBoxPackQty;
                int HUSEORGID = list[0].HUSEORGID;
                bool HUseFlag = list[0].HUseFlag;
                string HMaker = list[0].HMaker!=""? list[0].HMaker :"";
                string HMakeTime = list[0].HMakeTime;
                string HUpDater = list[0].HUpDater != "" ? list[0].HUpDater : "";
                string HUpDateDate = list[0].HUpDateDate;
                string HCheckEmp = list[0].HCheckEmp != "" ? list[0].HCheckEmp : "";
                string HCheckTime = list[0].HCheckTime;

                oCN.BeginTran();

                #region  参数化
                // 构建参数化 SQL 语句
                string sql = @"INSERT INTO Gy_UserMaterRelation 
                (HMaterID, HSupID, HMinPackQty, HInBoxPackQty, HOutBoxPackQty, HUSEORGID, HUseFlag,
                HMaker, HMakeTime, HUpDater, HUpDateDate, HCheckEmp, HCheckTime)
                VALUES(@HMaterID, @HSupID,  @HMinPackQty, @HInBoxPackQty, @HOutBoxPackQty, @HUSEORGID, @HUseFlag,
                @HMaker, @HMakeTime, @HUpDater, @HUpDateDate, @HCheckEmp, @HCheckTime)";

                // 使用 MakeInParam 方法创建参数
                SqlParameter[] parameters = {
                    oCN.MakeInParam("@HMaterID", SqlDbType.Int, 4, HMaterID),
                    oCN.MakeInParam("@HSupID", SqlDbType.Int, 4, HSupID),
                    //oCN.MakeInParam("@HUserID", SqlDbType.NVarChar, 50, HUserID),
                    oCN.MakeInParam("@HMinPackQty", SqlDbType.Decimal, 8, HMinPackQty),
                    oCN.MakeInParam("@HInBoxPackQty", SqlDbType.Decimal, 8, HInBoxPackQty),
                    oCN.MakeInParam("@HOutBoxPackQty", SqlDbType.Decimal, 8, HOutBoxPackQty),
                    oCN.MakeInParam("@HUSEORGID", SqlDbType.Int, 4, HUSEORGID),
                    oCN.MakeInParam("@HUseFlag", SqlDbType.Bit, 1, HUseFlag),
                    oCN.MakeInParam("@HMaker", SqlDbType.NVarChar, 50, (object)HMaker ?? DBNull.Value),
                    oCN.MakeInParam("@HMakeTime", SqlDbType.NVarChar, 50, (object)HMakeTime ?? DBNull.Value),
                    oCN.MakeInParam("@HUpDater", SqlDbType.NVarChar, 50, (object)HUpDater ?? DBNull.Value),
                    oCN.MakeInParam("@HUpDateDate", SqlDbType.NVarChar, 50, (object)HUpDateDate ?? DBNull.Value),
                    oCN.MakeInParam("@HCheckEmp", SqlDbType.NVarChar, 50, (object)HCheckEmp ?? DBNull.Value),
                    oCN.MakeInParam("@HCheckTime", SqlDbType.NVarChar, 50, (object)HCheckTime ?? DBNull.Value)
    
                };

                DataSet result = oCN.RunProcReturn(sql, parameters, "Gy_UserMaterRelation");
                #endregion


                oCN.Commit();
                objJsonResult.code = "1";
                objJsonResult.count = 1;
                objJsonResult.Message = "新增成功！";
                //objJsonResult.data = null;
                return objJsonResult;
            }
            catch (Exception e)
            {
                oCN.RollBack();
                objJsonResult.code = "0";
                objJsonResult.count = 0;
                objJsonResult.Message = "Exception！" + e.Message;
                objJsonResult.data = null;
                return objJsonResult;
            }
        }
        #endregion

        #region 编辑保存
        [Route("MaterialHandingController/EditSaveBill")]
        [HttpPost]
        public object EditSaveBill([FromBody] JObject msg)
        {
            try
            {
                var _value = msg["msg"].ToString();
                string msg3 = _value.ToString();
                string msg2 = msg3.ToString();

                oCN.BeginTran();
                //反序列化
                msg2 = "[" + msg2.ToString() + "]";

                List<Model.Cls_MaterialHandingModel> list = Newtonsoft.Json.JsonConvert.DeserializeObject<List<Model.Cls_MaterialHandingModel>>(msg2);
               
                
                int HItemID = Convert.ToInt32(list[0].HItemID);
                int HMaterID = Convert.ToInt32(list[0].HMaterNumber);
                int HSupID = list[0].HSupID;
                //string HUserID = list[0].HUserID;
                decimal HMinPackQty = list[0].HMinPackQty;
                decimal HInBoxPackQty = list[0].HInBoxPackQty;
                decimal HOutBoxPackQty = list[0].HOutBoxPackQty;
                int HUSEORGID = list[0].HUSEORGID;
                bool HUseFlag = list[0].HUseFlag;
                string HMaker = list[0].HMaker != "" ? list[0].HMaker : "";
                string HMakeTime = list[0].HMakeTime;
                string HUpDater = list[0].HUpDater != "" ? list[0].HUpDater : "";
                string HUpDateDate = list[0].HUpDateDate;
                string HCheckEmp = list[0].HCheckEmp != "" ? list[0].HCheckEmp : "";
                string HCheckTime = list[0].HCheckTime;



                #region  
                //主表
                string sql = @"UPDATE Gy_UserMaterRelation SET 
                HMaterID = @HMaterID, 
                HSupID = @HSupID, 
                HMinPackQty = @HMinPackQty, 
                HInBoxPackQty = @HInBoxPackQty, 
                HUSEORGID = @HUSEORGID, 
                HUseFlag = @HUseFlag,
                HMaker = @HMaker, 
                HMakeTime = @HMakeTime, 
                HUpDater = @HUpDater, 
                HUpDateDate = @HUpDateDate, 
                HCheckEmp = @HCheckEmp, 
                HCheckTime = @HCheckTime
                WHERE HItemID = @HItemID"; 

                SqlParameter[] parameters = {
                        oCN.MakeInParam("@HItemID", SqlDbType.Int, 4, HItemID),
                        oCN.MakeInParam("@HMaterID", SqlDbType.Int, 4, HMaterID),
                        oCN.MakeInParam("@HSupID", SqlDbType.Int, 4, HSupID),
                        //oCN.MakeInParam("@HUserID", SqlDbType.NVarChar, 50, HUserID),
                        oCN.MakeInParam("@HMinPackQty", SqlDbType.Decimal, 8, HMinPackQty),
                        oCN.MakeInParam("@HInBoxPackQty", SqlDbType.Decimal, 8, HInBoxPackQty),
                        oCN.MakeInParam("@HOutBoxPackQty", SqlDbType.Decimal, 8, HOutBoxPackQty),
                        oCN.MakeInParam("@HUSEORGID", SqlDbType.Int, 4, HUSEORGID),
                        oCN.MakeInParam("@HUseFlag", SqlDbType.Bit, 1, HUseFlag),
                        oCN.MakeInParam("@HMaker", SqlDbType.NVarChar, 50, (object)HMaker ?? DBNull.Value),
                        oCN.MakeInParam("@HMakeTime", SqlDbType.NVarChar, 50, (object)HMakeTime ?? DBNull.Value),
                        oCN.MakeInParam("@HUpDater", SqlDbType.NVarChar, 50, (object)HUpDater ?? DBNull.Value),
                        oCN.MakeInParam("@HUpDateDate", SqlDbType.NVarChar, 50, (object)HUpDateDate ?? DBNull.Value),
                        oCN.MakeInParam("@HCheckEmp", SqlDbType.NVarChar, 50, (object)HCheckEmp ?? DBNull.Value),
                        oCN.MakeInParam("@HCheckTime", SqlDbType.NVarChar, 50, (object)HCheckTime ?? DBNull.Value),
};

                // 使用 RunProcReturn 执行参数化UPDATE查询，忽略返回的 DataSet
                DataSet result = oCN.RunProcReturn(sql, parameters, "Gy_UserMaterRelation");
                #endregion

                oCN.Commit();
                objJsonResult.code = "1";
                objJsonResult.count = 1;
                objJsonResult.Message = "更新成功！";
                return objJsonResult;
                
            }
            catch (Exception e)
            {
                oCN.RollBack();
                objJsonResult.code = "0";
                objJsonResult.count = 0;
                objJsonResult.Message = "Exception！" + e.Message;
                objJsonResult.data = null;
                return objJsonResult;
            }
        }
        #endregion

        //#region 供应商报价单 删除
        [Route("MaterialHandingController/DelBill")]
        [HttpGet]
        public object DelBill(string HItemID, string user)
        {
            
                try
                {
                    if (HItemID == null || HItemID.Equals(""))
                    {
                        objJsonResult.code = "0";
                        objJsonResult.count = 0;
                        objJsonResult.Message = "HInterID不能为空！";
                        objJsonResult.data = null;
                        return objJsonResult;
                    }

                    oCN.BeginTran();

                   // oCN.RunProc("delete from Gy_UserMaterRelation where HInterID = " + HItemID);
                    oCN.RunProc("delete from Gy_UserMaterRelation where HItemID='" + HItemID + "'");

                    oCN.Commit();

                    objJsonResult.code = "1";
                    objJsonResult.count = 1;
                    objJsonResult.Message = "Sucess！";
                    objJsonResult.data = null;
                    return objJsonResult;
                }
                catch (Exception e)
                {
                    objJsonResult.code = "0";
                    objJsonResult.count = 0;
                    objJsonResult.Message = "Exception！" + e.ToString();
                    objJsonResult.data = null;
                    return objJsonResult;
                }





        }
        //#endregion


    }
}