using DIXWeb.DAL;
using DIXWeb.DataRepository;
using DIXWeb.Entity.GlobalM;
using DIXWeb.Entity.Workflow;
using DIXWeb.Util;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Linq.Dynamic;
using System.Text;

namespace DIXWeb.Business.GlobalM
{
    public class WorkListBusiness : BaseBusiness<WorkList>
    {
        #region Íⲿ½Ó¿Ú

        /// <summary>
        /// »ñÈ¡Êý¾ÝÁбí
        /// </summary>
        /// <param name="condition">²éѯÀàÐÍ</param>
        /// <param name="keyword">¹Ø¼ü×Ö</param>
        /// <returns></returns>
        public List<WorkListModel> GetDataList(int viewType, string subject, string billno, Pagination pagination)
        {
            var plist = new List<System.Data.Common.DbParameter>();
            plist.Add(GlobalDataHelper.NewSqlParameter("@Subject", subject));
            plist.Add(GlobalDataHelper.NewSqlParameter("@BillNo", billno));
            plist.Add(GlobalDataHelper.NewSqlParameter("@viewType", viewType));
            plist.Add(GlobalDataHelper.NewSqlParameter("@UserId", GlobalDataHelper.GetLoginUserNo()));
            List<WorkListModel> rlist = Service.GetListByProcNew<WorkListModel>("wp_wf_getMyworklist", plist);

            return rlist.GetPagination(pagination).ToList();
        }

        /// <summary>
        /// »ñÈ¡Ö¸¶¨µÄµ¥ÌõÊý¾Ý
        /// </summary>
        /// <param name="id">Ö÷¼ü</param>
        /// <returns></returns>
        public WorkListModel GetWorkListInst(int btid, string bizdataids)
        {
            WorkListModel rm = null;
            List<WorkListModel> rlist = Service.GetListByProcNew<WorkListModel>("wp_wf_getworklist", new List<System.Data.Common.DbParameter>() { new System.Data.SqlClient.SqlParameter("@btid", btid) });
            if (rlist != null && rlist.Count > 0)
            {
                rm = rlist[0];
                string userindex = GlobalDataHelper.GetLoginUser().Id.ToString().PadLeft(3, '0');
                userindex = userindex.Substring(0, 3);
                if (rm.Id == 0) rm.BillNo = rm.BillCode + userindex + System.DateTime.Now.ToString("yyMMddHHmmssfff");
            }
            else rm = new WorkListModel();
            rm.BizDataIds = bizdataids;
            return rm;
        }

        /// <summary>
        /// »ñÈ¡Ö¸¶¨µÄµ¥ÌõÊý¾Ý
        /// </summary>
        /// <param name="id">Ö÷¼ü</param>
        /// <returns></returns>
        public WorkListModel GetWorkListInstNew(int instid, string billno, int btid)
        {
            WorkListModel rm = null;
            List<WorkListModel> rlist = Service.GetListByProcNew<WorkListModel>("wp_workflow_getworklist", new List<System.Data.Common.DbParameter>()
            { new System.Data.SqlClient.SqlParameter("@id", instid),
            new System.Data.SqlClient.SqlParameter("@billno", billno) ,
            new System.Data.SqlClient.SqlParameter("@btid", btid) });
            if (rlist != null && rlist.Count > 0)
            {
                rm = rlist[0];
                if (billno == "")
                {

                    string userindex = GlobalDataHelper.GetLoginUser().Id.ToString().PadLeft(3, '0');
                    userindex = userindex.Substring(0, 3);
                    if (rm.Id == 0) rm.BillNo = rm.BillCode + userindex + System.DateTime.Now.ToString("yyMMddHHmmssfff");
                }
            }
            else rm = new WorkListModel();
            return rm;
        }
        void SetupSysInfo(WorkList data, bool isCreate)
        {
            if (isCreate)
            {
                data.CreateTime = DateTime.Now;
                data.CreateUserId = GlobalDataHelper.GetLoginUserNo();
            }
            data.CHtime = DateTime.Now;
            data.ChUserId = GlobalDataHelper.GetLoginUserNo();
        }
        /// <summary>
        /// Ìí¼ÓÊý¾Ý
        /// </summary>
        /// <param name="newData">Êý¾Ý</param>
        public ResultMessage SubmitBill(WorkListModel newData)
        {
            SetupSysInfo(newData, true);
            var plist = new List<System.Data.Common.DbParameter>();
            plist.Add(GlobalDataHelper.NewSqlParameter("@Subject", newData.Subject));
            plist.Add(GlobalDataHelper.NewSqlParameter("@BillNo", newData.BillNo));
            plist.Add(GlobalDataHelper.NewSqlParameter("@BillTypeId", newData.BillTypeId));
            plist.Add(GlobalDataHelper.NewSqlParameter("@UserId", GlobalDataHelper.GetLoginUserNo()));


            ResultMessage rm = Service.SubmitDataByProc("wp_worklist_submitbill", plist);
            return rm;
        }

        /// <summary>
        /// Ìí¼ÓÊý¾Ý
        /// </summary>
        /// <param name="newData">Êý¾Ý</param>
        public ResultMessage AddData(WorkListModel newData)
        {
            SetupSysInfo(newData, true);
            var plist = new List<System.Data.Common.DbParameter>();
            plist.Add(GlobalDataHelper.NewSqlParameter("@Subject", newData.Subject));
            plist.Add(GlobalDataHelper.NewSqlParameter("@BillNo", newData.BillNo));
            plist.Add(GlobalDataHelper.NewSqlParameter("@BillTypeId", newData.BillTypeId));
            plist.Add(GlobalDataHelper.NewSqlParameter("@UserId", GlobalDataHelper.GetLoginUserNo()));
            plist.Add(GlobalDataHelper.NewSqlParameter("@BizDataIds", newData.BizDataIds));


            ResultMessage rm = Service.SubmitDataByProc("wp_worklist_newdata", plist);
            return rm;
        }

        /// <summary>
        /// ¸üÐÂÊý¾Ý
        /// </summary>
        public ResultMessage UpdateData(WorkListModel theData)
        {
            SetupSysInfo(theData, false);
            return null;
        }
        
        /// <summary>
        /// ɾ³ýÊý¾Ý
        /// </summary>
        /// <param name="theData">ɾ³ýµÄÊý¾Ý</param>
        public void DeleteData(List<string> ids)
        {
            Delete(ids);
        }
        public ResultMessage HandleBill(string ids, int type)
        {
            ids = string.IsNullOrEmpty(ids) ? "" : ids.Trim();
            ids = ids.Replace("[", "").Replace("]", "");
            string[] idarray = ids.Split(new string[] { "," }, StringSplitOptions.RemoveEmptyEntries);
            string sucessids = "", failids = "";
            int success = 0, fail = 0;
            for (int i = 0; i < idarray.Length; i++)
            {
                var plist = new List<System.Data.Common.DbParameter>();
                plist.Add(GlobalDataHelper.NewSqlParameter("@id", idarray[i]));
                plist.Add(GlobalDataHelper.NewSqlParameter("@type", type));
                plist.Add(GlobalDataHelper.NewSqlParameter("@UserId", GlobalDataHelper.GetLoginUserNo()));
                ResultMessage rm = Service.SubmitDataByProc("wp_worklist_audit", plist);
                if (rm.Count > 0) { sucessids += idarray[i] + ","; success += 1; }
                else { failids += idarray[i] + ","; fail += 1; }
            }

            return new ResultMessage(1, "Ö´Ðнá¹ûΪ¡¾³É¹¦:" + success.ToString() + "±Ê,ID·Ö±ðΪ:" + sucessids + ";Ö´ÐÐʧ°Ü£º" + fail.ToString() + "±Ê,ID·Ö±ðΪ:" + failids + "¡¿");
        }
        #endregion

        #region ˽ÓгÉÔ±

        #endregion

        #region Êý¾ÝÄ£ÐÍ

        #endregion


        public Receive GetMyNeedDealt(string Code, int UserId, int pageIndex = 1, int pageSize = 5)
        {
            Receive receive = new Receive();
            try
            {
                using (DBContext db = new DBContext())
                {
                    System.Data.SqlClient.SqlParameter[] paramList = new System.Data.SqlClient.SqlParameter[] {
                        new System.Data.SqlClient.SqlParameter("@Code", Code),
                        new System.Data.SqlClient.SqlParameter("@UserId", UserId),
                        new System.Data.SqlClient.SqlParameter("@pageIndex", pageIndex),
                        new System.Data.SqlClient.SqlParameter("@pageSize", pageSize),
                        new System.Data.SqlClient.SqlParameter("@Total", 0),
                    };
                    int index = paramList.Length - 1;
                    paramList[index].Direction = ParameterDirection.Output;
                    receive.rows = db.Database.SqlQuery<ReceiveNeedDealt>("EXEC meta.p_myNeedDealt @Code,@UserId,@pageIndex,@pageSize,@Total output ", paramList).ToList();
                    receive.total = int.Parse(paramList[index].Value.ToString());
                    receive.Code = 200;
                    receive.Message = "SUCCESS"; 
                }
            }
            catch (Exception ex)
            {
                receive.Code = 500;
                receive.Message = ex.Message;
            }
            return receive;
        }

        public Receive GetInRepair(string Code, int UserId, int pageIndex = 1, int pageSize = 5)
        {
            Receive receive = new Receive();
            try
            {
                using (DBContext db = new DBContext())
                {
                    System.Data.SqlClient.SqlParameter[] paramList = new System.Data.SqlClient.SqlParameter[] {
                        new System.Data.SqlClient.SqlParameter("@Code", Code),
                        new System.Data.SqlClient.SqlParameter("@UserId", UserId),
                        new System.Data.SqlClient.SqlParameter("@pageIndex", pageIndex),
                        new System.Data.SqlClient.SqlParameter("@pageSize", pageSize),
                        new System.Data.SqlClient.SqlParameter("@Total", 0),
                    };
                    int index = paramList.Length - 1;
                    paramList[index].Direction = ParameterDirection.Output;
                    receive.rows = db.Database.SqlQuery<ReceiveNeedDealt>("EXEC meta.p_myInRepair @Code,@UserId,@pageIndex,@pageSize,@Total output ", paramList).ToList();
                    receive.total = int.Parse(paramList[index].Value.ToString());
                    receive.Code = 200;
                    receive.Message = "SUCCESS";
                }
            }
            catch (Exception ex)
            {
                receive.Code = 500;
                receive.Message = ex.Message;
            }
            return receive;
        }

        public Receive ApproveAgree(int[] BillflowIdArr, int UserId,string Remark,string AppendixUrl)
        {
            Receive record = null;
            StringBuilder sb = new StringBuilder();
            for (int i = 0; i < BillflowIdArr.Length; i++)
            {
                sb.Append(BillflowIdArr[i] + ",");
            }
            using (DBContext db = new DBContext())
            {
                System.Data.SqlClient.SqlParameter[] paramList = new System.Data.SqlClient.SqlParameter[] {
                    new System.Data.SqlClient.SqlParameter("@BillflowIdStr", sb.ToString()),
                    new System.Data.SqlClient.SqlParameter("@UserId", UserId),
                    new System.Data.SqlClient.SqlParameter("@Remark", Remark),
                    new System.Data.SqlClient.SqlParameter("@AppendixUrl", AppendixUrl),
                };
                record = db.Database.SqlQuery<Receive>("EXEC meta.p_ApproveAgree @BillflowIdStr,@UserId,@Remark,@AppendixUrl ", paramList).FirstOrDefault();
            }
            return record;
        }

        public Receive ApproveAgreeAll(int UserId, string Remark, string AppendixUrl)
        {
            Receive record = null;
            using (DBContext db = new DBContext())
            {
                System.Data.SqlClient.SqlParameter[] paramList = new System.Data.SqlClient.SqlParameter[] {
                    new System.Data.SqlClient.SqlParameter("@UserId", UserId),
                    new System.Data.SqlClient.SqlParameter("@Remark", Remark),
                    new System.Data.SqlClient.SqlParameter("@AppendixUrl", AppendixUrl),
                };
                record = db.Database.SqlQuery<Receive>("EXEC meta.p_ApproveAgreeAll @UserId,@Remark,@AppendixUrl ", paramList).FirstOrDefault();
            }
            return record;
        }

        public Receive ApproveRefuse(int[] BillflowIdArr, int UserId,string Remark)
        {
            Receive record = null;
            StringBuilder sb = new StringBuilder();
            for (int i = 0; i < BillflowIdArr.Length; i++)
            {
                sb.Append(BillflowIdArr[i] + ",");
            }
            using (DBContext db = new DBContext())
            {
                System.Data.SqlClient.SqlParameter[] paramList = new System.Data.SqlClient.SqlParameter[] {
                    new System.Data.SqlClient.SqlParameter("@BillflowIdStr", sb.ToString()),
                    new System.Data.SqlClient.SqlParameter("@UserId", UserId),
                    new System.Data.SqlClient.SqlParameter("@Remark", Remark),
                };
                record = db.Database.SqlQuery<Receive>("EXEC meta.p_ApproveRefuse @BillflowIdStr,@UserId,@Remark ", paramList).FirstOrDefault();
            }
            return record;
        }
        public Receive ApproveKeepRemart(int[] BillflowIdArr, int UserId, string Remark)
        {
            Receive record = null;
            StringBuilder sb = new StringBuilder();
            for (int i = 0; i < BillflowIdArr.Length; i++)
            {
                sb.Append(BillflowIdArr[i] + ",");
            }
            using (DBContext db = new DBContext())
            {
                System.Data.SqlClient.SqlParameter[] paramList = new System.Data.SqlClient.SqlParameter[] {
                    new System.Data.SqlClient.SqlParameter("@BillflowIdStr", sb.ToString()),
                    new System.Data.SqlClient.SqlParameter("@UserId", UserId),
                    new System.Data.SqlClient.SqlParameter("@Remark", Remark),
                };
                record = db.Database.SqlQuery<Receive>("EXEC meta.p_ApproveKeepRemart @BillflowIdStr,@UserId,@Remark ", paramList).FirstOrDefault();
            }
            return record;
        }
        public List<ReceiveBillProcess> GetBillProcess(int BillId)
        {
            List<ReceiveBillProcess> list = null;
            using (DBContext db = new DBContext())
            {
                System.Data.SqlClient.SqlParameter[] paramList = new System.Data.SqlClient.SqlParameter[] {
                    new System.Data.SqlClient.SqlParameter("@BillId", BillId),
                };
                list = db.Database.SqlQuery<ReceiveBillProcess>("EXEC meta.p_getBillProcess @BillId ", paramList).ToList();
            }
            return list;
        }

        public Receive GetMyApproved(string Code, int UserId, int pageIndex = 1, int pageSize = 5)
        {
            Receive receive = new Receive();
            try
            {
                using (DBContext db = new DBContext())
                {
                    System.Data.SqlClient.SqlParameter[] paramList = new System.Data.SqlClient.SqlParameter[] {
                        new System.Data.SqlClient.SqlParameter("@Code", Code),
                        new System.Data.SqlClient.SqlParameter("@UserId", UserId),
                        new System.Data.SqlClient.SqlParameter("@pageIndex", pageIndex),
                        new System.Data.SqlClient.SqlParameter("@pageSize", pageSize),
                        new System.Data.SqlClient.SqlParameter("@Total", 0),
                    };
                    int index = paramList.Length - 1;
                    paramList[index].Direction = ParameterDirection.Output;
                    receive.rows = db.Database.SqlQuery<ReceiveNeedDealt>("EXEC meta.p_myApproved @Code,@UserId,@pageIndex,@pageSize,@Total output ", paramList).ToList();
                    receive.total = int.Parse(paramList[index].Value.ToString());
                    receive.Code = 200;
                    receive.Message = "SUCCESS";
                }
            }
            catch (Exception ex)
            {
                receive.Code = 500;
                receive.Message = ex.Message;
            }
            return receive;
        }
    }
    public class WorkListModel : WorkList
    {
        public string BillCode { get; set; }
        public string BizDataIds { get; set; }
        public int ViewType { get; set; }
    }
}