using Bro.Common.Helper;
using Bro.Common.Interface;
using Bro.DataBase.Model;
using Newtonsoft.Json;

namespace Bro.M135.DBManager
{
    public class Manager_P_PRODUCT : ModelManager<P_PRODUCT, M135DB>
    {
        public bool NewProduct(P_PRODUCT p, List<P_PRODUCT_DETAIL> details, out string msg)
        {
            msg = "";
            try
            {
                using (var context = new M135DB())
                {
                    p.CREATE_TIME = DateTime.Now;

                    details.ForEach(d =>
                    {
                        d.PID = p.PID;
                        d.SN = p.SN;
                        d.CREATE_TIME = DateTime.Now;
                    });

                    context.P_PRODUCT.Add(p);
                    context.P_PRODUCT_DETAIL.AddRange(details);

                    context.SaveChanges();
                }

                return true;
            }
            catch (Exception ex)
            {
                msg = ex.GetExceptionMessage();
                return false;
            }
        }

        public bool NewProductDetails(List<P_PRODUCT_DETAIL> details, out string msg)
        {
            msg = "";
            try
            {
                using (var context = new M135DB())
                {
                    details.ForEach(d =>
                    {
                        d.CREATE_TIME = DateTime.Now;
                    });

                    context.P_PRODUCT_DETAIL.AddRange(details);
                    context.SaveChanges();
                }

                return true;
            }
            catch (Exception ex)
            {
                msg = ex.GetExceptionMessage();
                return false;
            }
        }

        public List<P_PRODUCT> QueryProduct(Request_P_Product request)
        {
            List<P_PRODUCT> pList = new List<P_PRODUCT>();
            using (var context = new M135DB())
            {
                IQueryable<P_PRODUCT> list = context.P_PRODUCT.Where(u => true);

                if (request.StartTime != null)
                {
                    list = list.Where(u => u.CREATE_TIME >= request.StartTime.Value);
                }

                if (request.EndTime != null)
                {
                    list = list.Where(u => u.CREATE_TIME <= request.EndTime.Value);
                }

                if (!string.IsNullOrWhiteSpace(request.SearchTxt))
                {
                    list = list.Where(u => u.SN.Contains(request.SearchTxt));
                }

                if (!string.IsNullOrWhiteSpace(request.ClassResult))
                {
                    list = list.Where(u => u.Result == request.ClassResult);
                }

                if (request.IsOrderAsc)
                {
                    list = list.OrderBy(u => u.ID);
                }
                else
                {
                    list = list.OrderByDescending(u => u.ID);
                }

                request.TotalNum = list.Count();
                if (request.PageSize > 0 && request.PageNum > 0)
                {
                    pList = list.Skip(request.PageSize * (request.PageNum - 1)).Take(request.PageSize).ToList();
                }
                else
                {
                    pList = list.ToList();
                }

                if (request.IsIncludeDetail)
                {
                    pList.ForEach(p =>
                    {
                        p.Details = context.P_PRODUCT_DETAIL.Where(u => u.PID == p.PID).ToList();
                    });
                }
            }

            return pList;
        }

        public void UpdatePositionResult(P_PRODUCT_DETAIL detail)
        {
            if (detail == null)
            {
                CommonLogger.LogAsync(DateTime.Now, EnumHelper.LogLevel.Error, $"检测工位明细结果上传对象为空");
                return;
            }

            try
            {
                using (var context = new M135DB())
                {
                    P_PRODUCT_DETAIL d = null;
                    if (detail.ID > 0)
                    {
                        d = context.P_PRODUCT_DETAIL.FirstOrDefault(u => u.ID == detail.ID);
                    }
                    else
                    {
                        d = context.P_PRODUCT_DETAIL.OrderByDescending(u => u.ID).FirstOrDefault(u => u.PID == detail.PID && u.STATION_CODE == detail.STATION_CODE && u.PositionName == detail.PositionName);
                    }

                    if (d == null)
                    {
                        CommonLogger.LogAsync(DateTime.Now, EnumHelper.LogLevel.Exception, $"产品{detail.PID} 工位{detail.PositionName}检测明细未能在数据库中查询获取");
                    }
                    else
                    {
                        if (string.IsNullOrWhiteSpace(d.SN) && !string.IsNullOrWhiteSpace(detail.SN))
                        {
                            d.SN = detail.SN;
                        }

                        List<ISpec> specList = detail.ResultList.SelectMany(u => u.Specs).ToList();
                        if (detail.SpecList != null)
                        {
                            specList.AddRange(detail.SpecList);
                        }

                        List<string> defectList = detail.ResultList.GetDefectDescList();
                        if (detail.DefectList != null)
                        {
                            defectList.AddRange(detail.DefectList);
                        }

                        d.IsDone = detail.IsDone;

                        //取消补偿值，避免反序列化时重复执行补偿
                        specList.ForEach(s =>
                        {
                            s.IsEnableCompensation = false;
                            s.CompensationValue = new List<double>() { 0,0};
                        });

                        d.FAIData = JsonConvert.SerializeObject(specList);
                        d.DefectDesc = JsonConvert.SerializeObject(defectList);

                        d.UPDATE_TIME = DateTime.Now;

                        context.SaveChanges();
                    }
                }
            }
            catch (Exception ex)
            {
                CommonLogger.LogAsync(DateTime.Now, EnumHelper.LogLevel.Exception, $"产品{detail?.PID} 条码{detail?.SN} 工位{detail?.PositionName} 检测结果保存异常，{ex.GetExceptionMessage()}");
            }
        }

        public P_PRODUCT QueryProductByBarcode(string sn)
        {
            try
            {
                using (var context = new M135DB())
                {
                    var p = context.P_PRODUCT.OrderByDescending(p => p.ID).FirstOrDefault(u => u.SN == sn);

                    if (p != null)
                    {
                        //var details = context.P_PRODUCT_DETAIL.Where(u => u.PID == p.PID);

                        //details.GroupBy(u => u.STATION_CODE).ToList().ForEach(u =>
                        //{
                        //    u.ToList().GroupBy(m => m.PositionName).ToList().ForEach(c =>
                        //    {
                        //        p.Details.Add(c.OrderByDescending(n => n.ID).FirstOrDefault());
                        //    });
                        //});

                        p.Details = context.P_PRODUCT_DETAIL.Where(u => u.PID == p.PID).ToList();
                    }
                    return p;
                }
            }
            catch (Exception ex)
            {
                CommonLogger.LogAsync(DateTime.Now, EnumHelper.LogLevel.Exception, $"数据库根据条码{sn}获取产品信息异常,{ex.GetExceptionMessage()}");
            }

            return null;
        }

        public P_PRODUCT QueryProductBySequence(string sequence)
        {
            try
            {
                using (var context = new M135DB())
                {
                    var p = context.P_PRODUCT.OrderByDescending(p => p.ID).FirstOrDefault(u => u.SEQUENCE == sequence);

                    if (p != null)
                    {
                        //var details = context.P_PRODUCT_DETAIL.Where(u => u.PID == p.PID);

                        //details.GroupBy(u => u.STATION_CODE).ToList().ForEach(u =>
                        //{
                        //    u.ToList().GroupBy(m => m.PositionName).ToList().ForEach(c =>
                        //    {
                        //        p.Details.Add(c.OrderByDescending(n => n.ID).FirstOrDefault());
                        //    });
                        //});

                        p.Details = context.P_PRODUCT_DETAIL.Where(u => u.PID == p.PID).ToList();
                    }
                    return p;
                }
            }
            catch (Exception ex)
            {
                CommonLogger.LogAsync(DateTime.Now, EnumHelper.LogLevel.Exception, $"数据库根据序列号{sequence}获取产品信息异常,{ex.GetExceptionMessage()}");
            }

            return null;
        }

        public P_PRODUCT QueryProductByPID(string pid)
        {
            try
            {
                using (var context = new M135DB())
                {
                    var p = context.P_PRODUCT.OrderByDescending(p => p.ID).FirstOrDefault(u => u.PID == pid);

                    if (p != null)
                    {
                        //var details = context.P_PRODUCT_DETAIL.Where(u => u.PID == p.PID);

                        //details.GroupBy(u => u.STATION_CODE).ToList().ForEach(u =>
                        //{
                        //    u.ToList().GroupBy(m => m.PositionName).ToList().ForEach(c =>
                        //    {
                        //        p.Details.Add(c.OrderByDescending(n => n.ID).FirstOrDefault());
                        //    });
                        //});

                        p.Details = context.P_PRODUCT_DETAIL.Where(u => u.PID == p.PID).ToList();
                    }
                    return p;
                }
            }
            catch (Exception ex)
            {
                CommonLogger.LogAsync(DateTime.Now, EnumHelper.LogLevel.Exception, $"数据库根据条码{pid}获取产品信息异常,{ex.GetExceptionMessage()}");
            }

            return null;
        }

        public void UpdateProductSN(string pid, string sn)
        {
            try
            {
                using (var context = new M135DB())
                {
                    var p = context.P_PRODUCT.OrderByDescending(p => p.ID).FirstOrDefault(u => u.PID == pid);
                    var details = context.P_PRODUCT_DETAIL.Where(u => u.PID == pid).ToList();
                    DateTime dt = DateTime.Now;
                    if (p != null)
                    {
                        p.SN = sn;
                        p.UPDATE_TIME = dt;
                    }

                    if (details.Count > 0)
                    {
                        List<P_PRODUCT_DETAIL> latestDetail = new List<P_PRODUCT_DETAIL>();
                        details.GroupBy(u => u.STATION_CODE).ToList().ForEach(u =>
                        {
                            u.ToList().GroupBy(m => m.PositionName).ToList().ForEach(c =>
                            {
                                latestDetail.Add(c.OrderByDescending(n => n.ID).FirstOrDefault());
                            });
                        });

                        latestDetail.ForEach(d =>
                        {
                            if (string.IsNullOrWhiteSpace(d.SN) && !string.IsNullOrWhiteSpace(sn))
                            {
                                d.SN = sn;
                                d.UPDATE_TIME = dt;
                            }
                        });
                    }

                    context.SaveChanges();
                }
            }
            catch (Exception ex)
            {
                CommonLogger.LogAsync(DateTime.Now, EnumHelper.LogLevel.Exception, $"产品{pid}更新条码{sn}时异常，{ex.GetExceptionMessage()}");
            }
        }


        public void UpdateProductPID(string pid, string newsen,string newpid)
        {
            try
            {
                using (var context = new M135DB())
                {
                    var p = context.P_PRODUCT.OrderByDescending(p => p.ID).FirstOrDefault(u => u.PID == pid);
                    var details = context.P_PRODUCT_DETAIL.Where(u => u.PID == pid).ToList();
                    DateTime dt = DateTime.Now;
                    if (p != null)
                    {
                        p.PID = newpid;
                        p.SEQUENCE = newsen;
                        p.UPDATE_TIME = dt;
                    }

                    if (details.Count > 0)
                    {
                        List<P_PRODUCT_DETAIL> latestDetail = new List<P_PRODUCT_DETAIL>();
                        details.GroupBy(u => u.STATION_CODE).ToList().ForEach(u =>
                        {
                            u.ToList().GroupBy(m => m.PositionName).ToList().ForEach(c =>
                            {
                                latestDetail.Add(c.OrderByDescending(n => n.ID).FirstOrDefault());
                            });
                        });

                        latestDetail.ForEach(d =>
                        {
                            //if (string.IsNullOrWhiteSpace(d.SN) && !string.IsNullOrWhiteSpace(newpid))
                            //{
                                d.PID = newpid;
                                d.UPDATE_TIME = dt;
                            //}
                        });
                    }

                    context.SaveChanges();
                }
            }
            catch (Exception ex)
            {
                CommonLogger.LogAsync(DateTime.Now, EnumHelper.LogLevel.Exception, $"产品{pid}更新条码{newpid}时异常，{ex.GetExceptionMessage()}");
            }
        }

        public void UpdateProductResult(int iD, string pid, string sn, string result)
        {
            try
            {
                using (var context = new M135DB())
                {
                    var p = context.P_PRODUCT.FirstOrDefault(u => u.ID == iD);
                    p.Result = result;
                    context.SaveChanges();
                }
            }
            catch (Exception ex)
            {
                CommonLogger.LogAsync(DateTime.Now, EnumHelper.LogLevel.Exception, $"产品{pid} 条码{sn} 最终结果{result}上传失败，{ex.GetExceptionMessage()}");
            }
        }

        public bool DeletOldData(DateTime timeLimit, int dataListCountOnce, out int deleteCount, out string msg, out bool isNoData)
        {
            deleteCount = 0;
            msg = "";
            isNoData = false;
            try
            {
                using (var context = new M135DB())
                {
                    var pList = context.P_PRODUCT.Where(u => u.CREATE_TIME < timeLimit).Take(dataListCountOnce);
                    if (!pList.Any())
                    {
                        isNoData = true;
                        return true;
                    }

                    var pidList = pList.Select(p => p.PID).ToList();
                    deleteCount = pidList.Count;

                    var details = context.P_PRODUCT_DETAIL.Where(u => pidList.Contains(u.PID));

                    context.P_PRODUCT_DETAIL.RemoveRange(details);
                    context.P_PRODUCT.RemoveRange(pList);
                    context.SaveChanges();
                }
            }
            catch (Exception ex)
            {
                msg = $"自动删除旧数据异常，{ex.GetExceptionMessage()}";
                return false;
            }

            return true;
        }
    }

    public class Request_P_Product : BaseRequest
    {
        public bool IsIncludeDetail { get; set; } = false;

        public string ClassResult { get; set; }
    }
}