using Model;
using Newtonsoft.Json.Linq;
using Pub_Class;
using System;
using System.Collections;
using System.Collections.Generic;
using System.Data;
using System.Data.SqlClient;
using System.Web.Http;
using WebAPI.Models;
using Newtonsoft.Json;
using System.Web;
using WebAPI.Controllers.SCGL.日计划管理;
using System.IO;

namespace WebAPI.Controllers
{
    public class PM_ProjectCommunicationBillListController : ApiController
    {
        private json objJsonResult = new json();
        SQLHelper.ClsCN oCN = new SQLHelper.ClsCN();
        DataSet ds;
        [Route("PM_ProjectCommunicationBillList/list")]
        [HttpGet]
        public object list(string sWhere, string user)
        {
            try
            {
                List<object> columnNameList = new List<object>();
                //查看权限
                if (!DBUtility.ClsPub.Security_Log("Gy_SampleScheme_Query", 1, false, user))
                {
                    objJsonResult.code = "0";
                    objJsonResult.count = 0;
                    objJsonResult.Message = "无查看权限！";
                    objJsonResult.data = null;
                    return objJsonResult;
                }

                ds = oCN.RunProcReturn("select * from h_v_PM_ProjectCommunicationBillMain where 1 = 1 " + sWhere, "h_v_PM_ProjectCommunicationBillMain");

                //添加列名
                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 = "1";
                objJsonResult.count = 1;
                objJsonResult.Message = "Sucess！";
                objJsonResult.data = ds.Tables[0];
                objJsonResult.list = columnNameList;
                return objJsonResult;
            }
            catch (Exception e)
            {
                objJsonResult.code = "0";
                objJsonResult.count = 0;
                objJsonResult.Message = "Exception！" + e.ToString();
                objJsonResult.data = null;
                return objJsonResult;
            }
        }

        [Route("PM_ProjectCommunicationBillList/getOriginalBill")]
        [HttpGet]
        public object getOriginalBill(string InterID, string EntryID)
        {
            try
            {
                DataSet ds;
                string sql = $"select * from h_v_PM_ProjectBillList where HInterID ={InterID} and HEntryID={EntryID}";
                ds = oCN.RunProcReturn(sql, "h_v_PM_ProjectBillList");
                if (ds != null && ds.Tables.Count > 0)
                {
                    objJsonResult.code = "1";
                    objJsonResult.count = 1;
                    objJsonResult.Message = "Sucess！";
                    objJsonResult.data = ds.Tables[0];
                    return objJsonResult;
                }
                else
                {
                    objJsonResult.code = "0";
                    objJsonResult.count = 0;
                    objJsonResult.Message = "fail！";
                    objJsonResult.data = "";
                    return objJsonResult;
                }
            }
            catch (Exception e)
            {
                objJsonResult.code = "0";
                objJsonResult.count = 0;
                objJsonResult.Message = "fail！" + e.ToString();
                objJsonResult.data = "";
                return objJsonResult;
            }
        }

        [Route("PM_ProjectCommunicationBillList/Saver")]
        [HttpPost]
        public object Saver([FromBody] JObject oMain)
        {
            try
            {

                var _value = oMain["oMain"].ToString();
                string msg1 = _value.ToString();
                string[] sArray = msg1.Split(new string[] { ";" }, StringSplitOptions.RemoveEmptyEntries);
                string msg2 = sArray[0].ToString();
                string refSav = sArray[1].ToString();
                string msg4 = sArray[2].ToString();

                //判断权限
                if (!ClsPub.Security_Log("Gy_SampleScheme_Edit", 1, false, msg4))
                {
                    objJsonResult.code = "0";
                    objJsonResult.count = 0;
                    objJsonResult.Message = "无保存权限！";
                    objJsonResult.data = null;
                    return objJsonResult;
                }



                //反序列化
                msg2 = "[" + msg2.ToString() + "]";
                List<ClsPM_ProjectCommunicationBillMain_Model> list = Newtonsoft.Json.JsonConvert.DeserializeObject<List<ClsPM_ProjectCommunicationBillMain_Model>>(msg2);

                string UserName = list[0].HMaker;  //制单人
                list[0].HBillType = "4764";
                list[0].HBillSubType = "4764";

                //oItem.HYear = DBUtility.ClsPub.isLong(DateTime.Now.Year);
                list[0].HPeriod = DBUtility.ClsPub.isLong(DateTime.Now.Month);
                list[0].HMakeDate = DBUtility.ClsPub.isStrNull(DateTime.Now.ToString("yyyy-MM-dd"));
                if (DBUtility.ClsPub.isStrNull(list[0].HDate) == "")
                {
                    objJsonResult.code = "0";
                    objJsonResult.count = 0;
                    objJsonResult.Message = "保存失败！没有单据日期，无法保存！";
                    objJsonResult.data = 1;
                    return objJsonResult;
                }
                //保存完毕后处理
                if (refSav == "1")
                {
                    //单据号是否重复
                    string sql = $@"
                INSERT INTO [PM_ProjectCommunicationBillMain] (
                    [HYear], [HPeriod], [HBillType], [HBillSubType], [HInterID], [HDate], [HBillNo], 
                    [HBillStatus], [HCheckItemNowID], [HCheckItemNextID], [HCheckFlowID], 
                    [HRemark], [HBacker], [HBackDate], [HBackRemark], [HChecker], [HCheckDate], 
                    [HMaker], [HMakeDate], [HUpDater], [HUpDateDate], [HCloseMan], [HCloseDate], [HCloseType], 
                    [HDeleteMan], [HDeleteDate], [HMainSourceBillType], [HMainSourceInterID], [HMainSourceEntryID], 
                    [HMainSourceBillNo], [HPrintQty], [HProjectID], [HProNumber], [HProName], 
                    [HCusID], [HPMEmpID], [HWorkEmpID], [HProSituation], [HProRisk], [HProProgramme], 
                    [HReportEmpID], [HOrgID]
                ) 
                VALUES ({DateTime.Now.Year}, {DateTime.Now.Month},  '{list[0].HBillType}',  '{list[0].HBillSubType}', {list[0].HInterID},  '{list[0].HDate}',  '{list[0].HBillNo}',  1, 0,  0, 0, '{list[0].HRemark ?? ""}',  '{list[0].HBacker ?? ""}',  '{(list[0].HBackDate)}',  '{list[0].HBackRemark ?? ""}', '{list[0].HChecker ?? ""}',  '{(list[0].HCheckDate)}',  '{list[0].HMaker ?? ""}',  '{(list[0].HMakeDate)}',  '{list[0].HUpDater ?? ""}',  '{(list[0].HUpDateDate)}',  '{list[0].HCloseMan ?? ""}',  '{(list[0].HCloseDate)}',  '{list[0].HCloseType }',  '{list[0].HDeleteMan ?? ""}',  '{(list[0].HDeleteDate)}',  '{list[0].HMainSourceBillType ?? ""}',  '{list[0].HMainSourceInterID}',  '{list[0].HMainSourceEntryID}',  '{list[0].HMainSourceBillNo ?? ""}',  '{list[0].HPrintQty}',   {list[0].HProjectID },  '{list[0].HProNumber ?? ""}',  '{list[0].HProName ?? ""}',  {list[0].HCusID },  {list[0].HPMEmpID }, {list[0].HWorkEmpID }, '{list[0].HProSituation ?? ""}', '{list[0].HProRisk ?? ""}', '{list[0].HProProgramme ?? ""}', {list[0].HReportEmpID}, {100038} );";
                    oCN.RunProc(sql);
                    objJsonResult.code = "0";
                    objJsonResult.count = 1;
                    objJsonResult.Message = "保存成功！";
                    objJsonResult.data = 1;
                    return objJsonResult;

                    //==================================================================================                                       

                }
                else
                {
                    //若MAINDI重复则重新获取
                    oCN.BeginTran();
                    //主表
                    oCN.RunProc("Update PM_ProjectCommunicationBillMain" + " set " +
                    " HProSituation='" + list[0].HProSituation + "'" +
                    ",HProRisk='" + list[0].HProRisk + "'" +
                    ",HProProgramme='" + list[0].HProProgramme + "'" +
                    ",HReportEmpID=" + list[0].HReportEmpID +
                    " Where HInterID=" + list[0].HInterID, ref DBUtility.ClsPub.sExeReturnInfo);


                }
                objJsonResult.code = "0";
                objJsonResult.count = 1;
                objJsonResult.Message = "保存成功！";
                objJsonResult.data = 1;
                return objJsonResult;
            }
            catch (Exception e)
            {
                //oCN.RollBack();
                objJsonResult.code = "0";
                objJsonResult.count = 0;
                objJsonResult.Message = "Exception！" + e.Message;
                objJsonResult.data = null;
                return objJsonResult;
            }
        }



        [Route("PM_ProjectCommunicationBillList/getBill")]
        [HttpGet]
        public object getBill(string InterID)
        {
            try
            {
                DataSet ds;
                string sql = $"select * from h_v_PM_ProjectCommunicationBillMain where HInterID ={InterID}";
                ds = oCN.RunProcReturn(sql, "h_v_PM_ProjectCommunicationBillMain");
                if (ds != null && ds.Tables.Count > 0)
                {
                    objJsonResult.code = "1";
                    objJsonResult.count = 1;
                    objJsonResult.Message = "Sucess！";
                    objJsonResult.data = ds.Tables[0];
                    return objJsonResult;
                }
                else
                {
                    objJsonResult.code = "0";
                    objJsonResult.count = 0;
                    objJsonResult.Message = "fail！";
                    objJsonResult.data = "";
                    return objJsonResult;
                }
            }
            catch (Exception e)
            {
                objJsonResult.code = "0";
                objJsonResult.count = 0;
                objJsonResult.Message = "fail！" + e.ToString();
                objJsonResult.data = "";
                return objJsonResult;
            }
        }
    }
}