using System;
using System.Collections.Generic;
using System.Data;
using System.Data.SqlClient;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace BLL.CQMS.Comprehensive
{
    public class PressurePipeApproveService
    {

        /// <summary>
        /// 增加施工方案审批信息
        /// </summary>
        /// <param name="managerRuleApprove">施工方案审批实体</param>
        public static void EditApprove(Model.Comprehensive_PressurePipeApprove approve)
        {
            var db = Funs.DB;
            Model.Comprehensive_PressurePipeApprove newApprove = new Model.Comprehensive_PressurePipeApprove();

            if (string.IsNullOrWhiteSpace(approve.PressurePipeApproveId))
            {  //新增
                newApprove.PressurePipeApproveId = SQLHelper.GetNewID(typeof(Model.Comprehensive_PressurePipeApprove));
                newApprove.PressurePipeId = approve.PressurePipeId;
                newApprove.ApproveMan = approve.ApproveMan;
                newApprove.ApproveDate = approve.ApproveDate;
                newApprove.ApproveIdea = approve.ApproveIdea;
                newApprove.IsAgree = approve.IsAgree;
                newApprove.ApproveType = approve.ApproveType;
                newApprove.Edition = approve.Edition;
                db.Comprehensive_PressurePipeApprove.InsertOnSubmit(newApprove);
                db.SubmitChanges();
            }
            else
            {   //修改
                Model.Comprehensive_PressurePipeApprove editApprove = db.Comprehensive_PressurePipeApprove.FirstOrDefault(e => e.PressurePipeApproveId == approve.PressurePipeApproveId);
                if (editApprove != null)
                {
                    editApprove.PressurePipeId = approve.PressurePipeId;
                    editApprove.ApproveMan = approve.ApproveMan;
                    editApprove.ApproveDate = approve.ApproveDate;
                    editApprove.ApproveIdea = approve.ApproveIdea;
                    editApprove.IsAgree = approve.IsAgree;
                    editApprove.ApproveType = approve.ApproveType;
                    editApprove.Edition = approve.Edition;
                    db.SubmitChanges();
                }
            }
        }


        public static Model.Comprehensive_PressurePipeApprove GetCurrentApprove(string PressurePipeId)
        {
            var q = from x in Funs.DB.Comprehensive_PressurePipeApprove
                    where x.PressurePipeId == PressurePipeId && x.ApproveType != "S" && x.ApproveDate == null 
                    select x;
            return q.FirstOrDefault();

        }

        public static Model.Comprehensive_PressurePipeApprove GetState(string PressurePipeId)
        {
            var q = from x in Funs.DB.Comprehensive_PressurePipeApprove
                    where x.PressurePipeId == PressurePipeId && x.ApproveType != "S"
                    orderby x.ApproveDate descending
                    select x;
            var res = q.ToList();
            if (res != null && res.Count > 0)
            {
                var q1 = res.Where(x => x.ApproveDate == null);
                var res1 = q1.FirstOrDefault();
                if (res1 != null)
                {
                    return res1;
                }
                else
                {
                    var q2 = res.Where(x => x.ApproveDate != null);
                    var res2 = q2.FirstOrDefault();
                    if (res2 != null)
                    {
                        return res2;
                    }
                    else
                    {
                        return null;
                    }
                }
            }
            else
            {
                return null;
            }

        }

        /// <summary>
        /// 获取当前用户的审核信息
        /// </summary>
        /// <param name="PressurePipeId"></param>
        /// <param name="approveMan"></param>
        /// <returns></returns>
        public static Model.Comprehensive_PressurePipeApprove GetApproveByApproveMan(string PressurePipeId, string approveMan)
        { 
            return Funs.DB.Comprehensive_PressurePipeApprove.FirstOrDefault(x => x.PressurePipeId == PressurePipeId && x.ApproveMan == approveMan &&  x.ApproveDate==null );
        }

        /// <summary>
        /// 根据id 和当前用户获取审核列表
        /// </summary>
        /// <param name="PressurePipeId"></param>
        /// <param name="approveMan"></param>
        /// <returns></returns>
        public static List<Model.Comprehensive_PressurePipeApprove> GetApproveByApproveManList(string PressurePipeId, string approveMan)
        {
            return Funs.DB.Comprehensive_PressurePipeApprove.Where(x => x.PressurePipeId == PressurePipeId && x.ApproveMan == approveMan).ToList();
        }


        /// <summary>
        /// 根据设备材料ID查询 审核记录
        /// </summary>
        /// <param name="PressurePipeId"></param>
        /// <returns></returns>
        public static DataTable GetProjectQualityList(string PressurePipeId)
        {
            string strSql = @"select i.* ,Sys_User.UserName  from Comprehensive_PressurePipeApprove as i  left join  Sys_User  on( i.ApproveMan = Sys_User.UserId)";
            List<System.Data.SqlClient.SqlParameter> listStr = new List<SqlParameter>();
            if (!string.IsNullOrEmpty(PressurePipeId))
            {
                strSql += "where i.PressurePipeId= @PressurePipeId ";
                listStr.Add(new SqlParameter("@PressurePipeId", PressurePipeId));
            }

            strSql += " order by i.ApproveDate ";
            SqlParameter[] parameter = listStr.ToArray();
            DataTable tb = SQLHelper.GetDataTableRunText(strSql, parameter);
            return tb;
        }

    }

}