using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Linq.Expressions;
using WX.CRM.BLL.Application.UserComBox;
using WX.CRM.BLL.Base;
using WX.CRM.BLL.Util;
using WX.CRM.Common;
using WX.CRM.DAL.Res;
using WX.CRM.IBLL.Res;
using WX.CRM.Model.DTO;
using WX.CRM.Model.Entity;
using WX.CRM.Model.MAP;
using WX.CRM.Model.QueryMap;
using WX.CRM.Model.crmModel;

using WX.CRM.BLL.Application.UserComBox;

using WX.CRM.Common.Layui;
using System.Diagnostics;

namespace WX.CRM.BLL.Res
{
    public class RES_ACTIVITY_BL : IRES_ACTIVITY, IRES_ACTIVITY_Q
    {
        private GroupByActivity_DAL groupdByActivity = new GroupByActivity_DAL();
        private CACHE_BL cache_BL = new CACHE_BL();

        /// <summary>
        /// 获取数据分组
        /// </summary>
        /// <param name="sTime"></param>
        /// <param name="eTime"></param>
        /// <param name="resTypeId"></param>
        /// <param name="activityId"></param>
        /// <param name="hasRegisterSoftware"></param>
        /// <param name="hasOpenFuturesAccount"></param>
        /// <param name="hasOpenSilverAccount"></param>
        /// <param name="hasMemo"></param>
        /// <returns></returns>
        //public IList<GroupByActivity> GetList_Activity(DateTime sTime, DateTime eTime, int? resTypeId = null, int? activityId = null, bool? hasRegisterSoftware = null, bool? hasOpenFuturesAccount = null, bool? hasOpenSilverAccount = null, bool? hasMemo = null, decimal? restypeCode = null)
        //{
        //    eTime = eTime.AddDays(1);
        //    var ds = groupdByActivity.GetList_Activity(sTime, eTime, resTypeId, activityId, hasRegisterSoftware, hasOpenFuturesAccount, hasOpenSilverAccount, hasMemo, restypeCode);
        //    if (ds == null)
        //        return null;
        //    return ds.Tables[0].ToList<GroupByActivity>();
        //}
        /// <summary>
        /// 数据导出
        /// </summary>
        /// <param name="resTypeId"></param>
        /// <param name="activityId"></param>
        /// <param name="sTime"></param>
        /// <param name="eTime"></param>
        /// <param name="hasRegisterSoftware"></param>
        /// <param name="hasOpenFuturesAccount"></param>
        /// <param name="hasOpenSilverAccount"></param>
        /// <param name="hasMemo"></param>
        /// <returns></returns>
        public IList<ActivitySourceExport> GetListExport_Activity(decimal resTypeId, decimal activityId, DateTime sTime, DateTime eTime, bool? hasRegisterSoftware = null, bool? hasOpenFuturesAccount = null, bool? hasOpenSilverAccount = null, bool? hasMemo = null)
        {
            eTime = eTime.AddDays(1);
            //return groupdByActivity.GetListExport_Activity(resTypeId, activityId, sTime, eTime, isRegisterSoftware, isOpenFuturesAccount, isOpenSilverAccount);
            var ds = groupdByActivity.GetListExport_Activity(resTypeId, activityId, sTime, eTime, hasRegisterSoftware, hasOpenFuturesAccount, hasOpenSilverAccount, hasMemo);
            if (ds == null)
                return null;
            return ds.Tables[0].ToList<ActivitySourceExport>();
        }

        public IList<WX.CRM.Model.Entity.RES_ACTIVITY> GetList_RESID(decimal resId)
        {
            using (WX.CRM.Model.Entity.crmContext db = new WX.CRM.Model.Entity.crmContext())
            {
                return db.RES_ACTIVITY.Where(obj => obj.RESTYPEID == resId).ToList();
            }
        }

        #region 添加

        /// <summary>
        /// 添加
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public bool Create(ref ValidationErrors errors, WX.CRM.Model.Entity.RES_ACTIVITY model)
        {
            try
            {
                using (WX.CRM.Model.Entity.crmContext db = new WX.CRM.Model.Entity.crmContext())
                {
                    var entry = db.RES_ACTIVITY.FirstOrDefault(m => m.ACTIVITYCODE == model.ACTIVITYCODE);
                    if (entry != null)
                    {
                        errors.Add("该编码已经被占用！");
                        return false;
                    }
                    model.ACTIVITYID = new SEQUENCES_BL().Seq_base_get();
                    model.CTIME = DateTime.Now;
                    db.RES_ACTIVITY.Add(model);
                    return db.SaveChanges().GetResult();
                }
            }
            catch (Exception ex)
            {
                errors.Add(ex.Message);
                return false;
            }
        }

        #endregion 添加

        #region 修改

        /// <summary>
        /// 数据的修改
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public bool Update(ref ValidationErrors errors, WX.CRM.Model.Entity.RES_ACTIVITY model)
        {
            try
            {
                using (var db = new WX.CRM.Model.Entity.crmContext())
                {
                    WX.CRM.Model.Entity.RES_ACTIVITY entry = db.RES_ACTIVITY.FirstOrDefault(m => m.ACTIVITYID == model.ACTIVITYID);
                    if (entry == null)
                        return false;
                    var et = db.RES_ACTIVITY.FirstOrDefault(m => m.ACTIVITYCODE == model.ACTIVITYCODE && m.ACTIVITYID != model.ACTIVITYID);
                    if (et != null)
                    {
                        errors.Add("该编码已经被占用！");
                        return false;
                    }
                    entry.ACTIVITYID = model.ACTIVITYID;
                    entry.ACTIVITYADDR = model.ACTIVITYADDR;
                    entry.ACTIVITYCODE = model.ACTIVITYCODE;
                    entry.RESOURCETAG = model.RESOURCETAG;
                    entry.RESTYPEID = model.RESTYPEID;
                    entry.MEMO = model.MEMO;
                    entry.UTIME = DateTime.Now;
                    entry.UPDATEUSER = model.UPDATEUSER;
                    entry.ACTIVITYNAME = model.ACTIVITYNAME;
                    entry.DEPTID = model.DEPTID;
                    db.SaveChanges();
                    return true;
                }
            }
            catch (Exception ex)
            {
                errors.Add(ex.Message);
                return false;
            }
        }

        #endregion 修改

        #region 删除

        /// <summary>
        /// 删除
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        public bool Delete(ref ValidationErrors errors, decimal id)
        {
            try
            {
                using (var db = new WX.CRM.Model.Entity.crmContext())
                {
                    WX.CRM.Model.Entity.RES_ACTIVITY entry = db.RES_ACTIVITY.FirstOrDefault(m => m.ACTIVITYID == id);
                    if (entry == null)
                    {
                        errors.Add("数据已经被删除！");
                        return false;
                    }
                    db.RES_ACTIVITY.Remove(entry);
                    return db.SaveChanges().GetResult();
                }
            }
            catch (Exception ex) { errors.Add(ex.Message); return false; }
        }

        #endregion 删除

        #region 获取单条信息

        /// <summary>
        /// 获取实体
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        public RES_ACTIVITY GetModel(decimal id)
        {
            using (var db = new crmContext())
            {
                var entry = db.RES_ACTIVITY.FirstOrDefault(m => m.ACTIVITYID == id);
                return entry;
            }
        }

        public RES_ACTIVITY GetModel(Expression<Func<RES_ACTIVITY, bool>> where)
        {
            using (var db = new crmContext())
            {
                var entry = db.RES_ACTIVITY.FirstOrDefault(where);
                return entry;
            }
        }

        #endregion 获取单条信息

        #region 获取分页数据列表

        public List<WX.CRM.Model.Entity.RES_ACTIVITY_EXTEND> GetList(ref Pager pager, string activityName, string activityCode, string resourceTag, string resTypeName, string stime, string etime)
        {
            using (var db = new WX.CRM.Model.Entity.crmContext())
            {
                var queryData = db.RES_ACTIVITY.AsQueryable();
                if (!string.IsNullOrWhiteSpace(activityName))
                    queryData = queryData.Where(m => m.ACTIVITYNAME.Contains(activityName));
                if (!string.IsNullOrWhiteSpace(activityCode))
                    queryData = queryData.Where(m => m.ACTIVITYCODE.Contains(activityCode));
                if (!string.IsNullOrWhiteSpace(resourceTag))
                    queryData = queryData.Where(m => m.RESOURCETAG.Contains(resourceTag));
                if (!string.IsNullOrWhiteSpace(resTypeName))
                {
                    queryData = queryData.Where(m => (from a in db.RES_RESOURCETYPE where a.TYPENAME.Contains(resTypeName) select a.RESTYPEID).Contains(m.RESTYPEID));
                }
                DateTime date1;
                if (!string.IsNullOrWhiteSpace(stime) && DateTime.TryParse(stime, out date1))
                    queryData = queryData.Where(m => m.CTIME >= date1);
                DateTime date2;
                if (!string.IsNullOrWhiteSpace(etime) && DateTime.TryParse(etime, out date2))
                {
                    date2 = date2.AddDays(1);
                    queryData = queryData.Where(m => m.CTIME < date2);
                }

                if (pager.order == "desc")
                {
                    switch (pager.sort)
                    {
                        case "ACTIVITYNAME":
                            queryData = queryData.OrderByDescending(c => c.ACTIVITYNAME);
                            break;

                        case "ACTIVITYCODE":
                            queryData = queryData.OrderByDescending(c => c.ACTIVITYCODE);
                            break;

                        case "RESTYPEID":
                            queryData = queryData.OrderByDescending(c => c.RESTYPEID);
                            break;

                        case "RESOURCETAG":
                            queryData = queryData.OrderByDescending(c => c.RESOURCETAG);
                            break;

                        default:
                            queryData = queryData.OrderByDescending(c => c.CTIME);
                            break;
                    }
                }
                else
                {
                    switch (pager.sort)
                    {
                        case "ACTIVITYNAME":
                            queryData = queryData.OrderBy(c => c.ACTIVITYNAME);
                            break;

                        case "ACTIVITYCODE":
                            queryData = queryData.OrderBy(c => c.ACTIVITYCODE);
                            break;

                        case "RESTYPEID":
                            queryData = queryData.OrderBy(c => c.RESTYPEID);
                            break;

                        case "RESOURCETAG":
                            queryData = queryData.OrderBy(c => c.RESOURCETAG);
                            break;

                        default:
                            queryData = queryData.OrderBy(c => c.CTIME); break;
                    }
                }
                //queryData = queryData.OrderByDescending(m => m.CTIME);
                PagerUtil.SetPager<WX.CRM.Model.Entity.RES_ACTIVITY>(ref queryData, ref pager);
                List<WX.CRM.Model.Entity.RES_ACTIVITY_EXTEND> list = (from a in queryData
                                                                      join x in db.RES_RESOURCETYPE on a.RESTYPEID equals x.RESTYPEID into tmp
                                                                      from ax in tmp.DefaultIfEmpty()
                                                                      select new WX.CRM.Model.Entity.RES_ACTIVITY_EXTEND()
                                                                      {
                                                                          res_ACTIVITY = a,
                                                                          TYPEName = ax.TYPENAME
                                                                      }).OrderByDescending(p => p.res_ACTIVITY.CTIME).ToList();
                return list;
            }
        }

        #endregion 获取分页数据列表

        #region 获取更多的活动信息分页数据列表

        public List<ActivitySourceInfo> GetActivityInfoMoreList(ref Pager pager, string resid, string stime, string etime)
        {
            using (var db = new WX.CRM.Model.Entity.crmContext())
            {
                var res_customer = db.RES_CUSTOMER.Where(p => p.CUSTOMERID == resid).Select(p => p.RESID).ToList();
                //string strresid = "";
                //foreach (var item in res_customer)
                //{
                //    strresid += item.RESID;
                //    strresid += ",";
                //}
                var queryData = db.RES_POOLLOG.AsQueryable();
                //if (res_customer.Any())
                {
                    queryData = queryData.Where(p => res_customer.Contains(p.RESID));
                }
                DateTime date1;
                if (!string.IsNullOrWhiteSpace(stime) && DateTime.TryParse(stime, out date1))
                    queryData = queryData.Where(m => m.APPLYTIME >= date1);
                DateTime date2;
                if (!string.IsNullOrWhiteSpace(etime) && DateTime.TryParse(etime, out date2))
                {
                    date2 = date2.AddDays(1);
                    queryData = queryData.Where(m => m.APPLYTIME < date2);
                }
                var data = queryData.ToList();
                var data2 = db.RES_CUSTOMERDETAIL.Where(p => res_customer.Contains(p.RESID));
                //queryData = queryData.OrderByDescending(p => p.APPLYTIME);
                //PagerUtil.SetPager<WX.CRM.Model.Entity.RES_POOLLOG>(ref queryData, ref pager);
                List<ActivitySourceInfo> list = (from a in data
                                                     //join b in db.RES_CUSTOMERUSER on a.RESID equals b.RESID
                                                     //join cu in db.RES_CUSTOMER on a.RESID equals cu.RESID
                                                 join b in data2 on a.RESID equals b.RESID
                                                 join c in db.RES_ACTIVITY on a.ACTIVITYID equals c.ACTIVITYID
                                                 join d in db.RES_RESOURCETYPE on a.RESTYPEID equals d.RESTYPEID
                                                 select new ActivitySourceInfo()
                                                 {
                                                     ResId = b.UMID,
                                                     //UserName = b == null ? "" :a.USERNAME,
                                                     UserName = b.CNAME,
                                                     ActivityName = c == null ? "" : c.ACTIVITYNAME,
                                                     deptid = a.DEPTID,
                                                     TypeName = d == null ? "" : d.TYPENAME,
                                                     ApplyTime = a.APPLYTIME,
                                                     DataType = a.DATATYPE,
                                                     ExtXml = string.IsNullOrEmpty(a.KWORD) ? a.EXTXML : a.KWORD
                                                 }
                    ).ToList();
                return list.OrderByDescending(p => p.ApplyTime).ToList();
            }
        }

        public WX.CRM.Model.Entity.RES_CUSTOMERUSER GetRES_CUSTOMERUSERModel(string resid)
        {
            using (var db = new WX.CRM.Model.Entity.crmContext())
            {
                WX.CRM.Model.Entity.RES_CUSTOMERUSER entry = db.RES_CUSTOMERUSER.FirstOrDefault(m => m.RESID == resid);
                return entry;
            }
        }

        public WX.CRM.Model.Entity.RES_RESOURCETYPE GetRES_RESOURCETYPEModel(decimal typeid)
        {
            using (var db = new WX.CRM.Model.Entity.crmContext())
            {
                WX.CRM.Model.Entity.RES_RESOURCETYPE entry = db.RES_RESOURCETYPE.FirstOrDefault(m => m.RESTYPEID == typeid);
                return entry;
            }
        }

        #endregion 获取更多的活动信息分页数据列表

        public List<WX.CRM.Model.Entity.RES_ACTIVITY> GetList(decimal resourctId)
        {
            using (var db = new WX.CRM.Model.Entity.crmContext())
            {
                return db.RES_ACTIVITY.Where(p => p.RESTYPEID == resourctId).OrderByDescending(m => m.CTIME).ToList();
            }
        }

        public List<ActivityResListView> GetResList(decimal? resTypeId, decimal? activityId, DateTime? sTime, DateTime? eTime)
        {
            using (var db = new crmContext())
            {
                if (eTime.HasValue)
                {
                    eTime = eTime.Value.AddDays(1);
                }

                var query = from p in db.RES_POOLLOG
                            join t in db.RES_RESOURCETYPE on p.RESTYPEID equals t.RESTYPEID
                            join a in db.RES_ACTIVITY on p.RESOURCETAG equals a.RESOURCETAG
                            //join b in db.CACHE_RES_POOLLOG on p.RESID equals b.RESID
                            where p.CTIME >= sTime.Value && p.CTIME < eTime.Value
                            select new ActivityResListView()
                            {
                                ResId = p.RESID,
                                CTime = p.CTIME,
                                ResTypeId = t.RESTYPEID,
                                ResTypeName = t.TYPENAME,
                                ActivityId = a.ACTIVITYID,
                                ActivityName = a.ACTIVITYNAME,
                                ExtXml = p.EXTXML
                            };

                if (resTypeId.HasValue)
                {
                    query = query.Where(p => p.ResTypeId == resTypeId.Value);
                }
                if (activityId.HasValue)
                {
                    query = query.Where(p => p.ActivityId == activityId.Value);
                }

                return query.Distinct().OrderByDescending(c => c.CTime).ToList();
            }
        }

        public IList<GroupByActivity> GetList_Activity(DateTime sTime, DateTime eTime, int Attribute, decimal userId, int hasRole, bool hasKword = false)
        {
            eTime = eTime.AddDays(1);
            var ds = groupdByActivity.GetList_Activity(sTime, eTime, Attribute, userId, hasRole, hasKword);
            if (ds == null)
                return null;
            return ds.Tables[0].ToList<GroupByActivity>();
        }

        public IList<ActivitySourceExport> GetList_Activity_export(decimal resTypeId, decimal activityId, DateTime sTime, DateTime eTime, decimal userId, int hasRole)
        {
            eTime = eTime.AddDays(1);
            var ds = groupdByActivity.GetList_Activity_export(resTypeId, activityId, sTime, eTime, userId, hasRole, null);
            if (ds == null)
                return null;
            return ds.Tables[0].ToList<ActivitySourceExport>();
        }

        public IList<ActivitySourceExport> GetList_Activity_export(decimal resTypeId, decimal activityId, DateTime sTime, DateTime eTime, decimal userId, int hasRole, int count)
        {
            eTime = eTime.AddDays(1);
            var ds = groupdByActivity.GetList_Activity_export(resTypeId, activityId, sTime, eTime, userId, hasRole, count);
            if (ds == null)
                return null;
            return ds.Tables[0].ToList<ActivitySourceExport>();
        }

        public IList<ActivitySourceExport> GetList_DistributeActivity_export(decimal resTypeId, decimal ActivityId, DateTime? stime, DateTime? etime, string choices, DateTime? Memostime, DateTime? Memoetime, string excludeWeixinRes, string excludeOrderRes, string excludeSpecialMemo)
        {
            var ds = groupdByActivity.GetList_DistributeActivity_export(resTypeId, ActivityId, stime, etime, choices, Memostime, Memoetime, excludeWeixinRes, excludeOrderRes, excludeSpecialMemo);
            if (ds == null)
                return null;
            return ds.Tables[0].ToList<ActivitySourceExport>();
        }

        //获取最近一个月的活动信息
        public List<ActivitySourceInfo> GetMonthActivityByresid(string resid)
        {
            var ds = groupdByActivity.GetMonthActivityByresid(resid);
            if (ds == null)
                return null;
            return ds.Tables[0].ToList<ActivitySourceInfo>();
        }

        public List<MyActivityResDto> GetMyActiviryResList(ref Pager pager, QueryUserComboDto usercomboDto, string resid, decimal? hidResourceId, string hidRESOURCETAG, string activityName, string activityRemark, DateTime? cTime1, DateTime? cTime2, decimal? eid, int? deptlineId)
        {
            Stopwatch stopWatch = new Stopwatch();
            stopWatch.Start();

            var deptList = cache_BL.GetDeptNameMapList();
            using (var db = new crmContext())
            {
                var data = (from a in db.RES_POOLLOG
                            join b in db.RES_RESOURCETYPE on a.RESTYPEID equals b.RESTYPEID
                            where b.SOURCETYPE.Contains("xdzyc")
                            join c in db.RES_ACTIVITY on a.ACTIVITYID equals c.ACTIVITYID
                            join d in db.RES_CUSTOMERDETAIL on a.RESID equals d.RESID
                            join e in db.RES_MYALLOCATERES on new { resid = a.RESID, deptid = a.DEPTID }
                            equals new { resid = e.RESID, deptid = e.DEPTID } into temp
                            from e in temp.DefaultIfEmpty()
                            select new MyActivityResDto
                            {
                                logId = a.LOGID,
                                ResourceTypeId = b.RESTYPEID,
                                ResourceTypeName = b.TYPENAME,
                                ResourceTag = c.RESOURCETAG,
                                ActivityName = c.ACTIVITYNAME,
                                ActivityRemark = a.EXTXML,
                                CName = d.CNAME,
                                CTime = a.CTIME,
                                ResId = d.UMID,
                                InnerUserId = e.INNERUSERID,
                                DeptId = a.DEPTID
                            });

                if (usercomboDto.userId.HasValue)
                {
                    data = data.Where(m => m.InnerUserId == usercomboDto.userId.Value);
                }
                else if (!string.IsNullOrEmpty(usercomboDto.groupIds))
                {
                    var _groupids = OperationUtil.ConvertToDecimal(usercomboDto.groupIds.Split(','));
                    data = (from a in data
                            join b in db.BAS_INNERUSERGROUP on a.InnerUserId equals b.INNERUSERID
                            where _groupids.Contains(b.GID.Value)
                            select a);
                }
                else if (!string.IsNullOrEmpty(usercomboDto.deptId))
                {
                    var depts = OperationUtil.ConvertToDecimal(usercomboDto.deptId.Split(','));
                    List<decimal> ALLdeptIDS = new List<decimal>();
                    List<decimal> ALLgidS = new List<decimal>();
                    UserServices userservices = new UserServices(cache_BL);
                    foreach (var item in depts)
                    {
                        List<decimal> deptIDS = new List<decimal>();
                        List<decimal> gidS = new List<decimal>();
                        userservices.GetAllDeptIDOrGidByDeptId(item, ref deptIDS, ref gidS);//获取所有的组别和gid
                        ALLdeptIDS.AddRange(deptIDS);
                        ALLgidS.AddRange(gidS);
                    }
                    data = (from a in data
                            join b in db.BAS_INNERUSERGROUP on a.InnerUserId equals b.INNERUSERID
                            //join g in db.BAS_INNERGROUP on b.GID equals g.GID
                            where ALLdeptIDS.Contains(b.DEPTID.Value) || ALLgidS.Contains(b.GID.Value)
                            select a);
                }

                if (usercomboDto.IsBound.HasValue)
                {
                    if (usercomboDto.IsBound.GetValueOrDefault() == 0)
                    {
                        data = data.Where(w => !db.RES_RESID_WEWORKUSER.Any(a => a.RESID == w.ResId && a.ISDELETE != 1 && a.STATUS == 1));
                    }
                    else
                    {
                        data = data.Where(w => db.RES_RESID_WEWORKUSER.Any(a => a.RESID == w.ResId && a.ISDELETE != 1 && a.STATUS == 1));
                    }
                }

                if (!string.IsNullOrWhiteSpace(resid))
                    data = data.Where(x => x.ResId == resid);

                if (hidResourceId.HasValue)
                    data = data.Where(p => p.ResourceTypeId == hidResourceId.Value);
                if (!string.IsNullOrEmpty(hidRESOURCETAG))
                    data = data.Where(p => p.ResourceTag == hidRESOURCETAG);
                if (!string.IsNullOrEmpty(activityName))
                    data = data.Where(p => p.ActivityName == activityName);
                if (!string.IsNullOrEmpty(activityRemark))
                    data = data.Where(p => p.ActivityRemark.Contains(activityRemark));
                if (cTime1.HasValue)
                    data = data.Where(p => p.CTime >= cTime1);
                if (cTime2.HasValue)
                {
                    cTime2 = cTime2.Value.AddDays(1);
                    data = data.Where(p => p.CTime < cTime2);
                }
                if (eid.HasValue)
                    data = data.Where(x => x.InnerUserId == eid);
                if (deptlineId.HasValue)
                    data = data.Where(x => x.DeptId == deptlineId);

                data = data.OrderByDescending(m => m.CTime);
                PagerUtil.SetPager<MyActivityResDto>(ref data, ref pager);
                var result = data.ToList();

                if (result.Any())
                {
                    var resIds = result.Select(x => x.ResId);
                    var memos = from a in db.CACHE_ORD_MEMO
                                join b in db.ORD_MEMOCONTENT on a.MEMOCONTENTID equals b.CONTENTID
                                where resIds.Contains(a.RESID)
                                orderby a.CTIME descending
                                select new { a.RESID, a.CTIME, b.STRCONTENT };

                    var relations = new List<RES_RESID_WEWORKUSER>();
                    if (!usercomboDto.IsBound.HasValue)
                    {
                        relations = db.RES_RESID_WEWORKUSER.Where(n => resIds.Contains(n.RESID) && n.ISDELETE != 1 && n.STATUS == 1).ToList();
                    }

                    foreach (var item in result)
                    {
                        var momo = memos.FirstOrDefault(x => x.RESID == item.ResId);
                        item.FollowInfo = momo?.STRCONTENT;
                        item.FollowTime = momo?.CTIME;
                        item.DeptName = deptList.FirstOrDefault(n => n.id == item.DeptId)?.title;
                        if (usercomboDto.IsBound.HasValue)
                        {
                            item.IsBound = usercomboDto.IsBound.GetValueOrDefault() == 0 ? "否" : "是";
                        }
                        else
                        {
                            item.IsBound = relations.FirstOrDefault(n => n.RESID == item.ResId) == null ? "否" : "是";
                        }
                    }
                }
                stopWatch.Stop();
                //记录费时
                LogHelper.Info(string.Concat("新单查询用时:", stopWatch.ElapsedMilliseconds, "ms"));
                return result;
            }
        }

        public List<MyActivityResDto> GetResModels(Laypage pager, ActiveQueryModel querydto)
        {
            List<MyActivityResDto> res = new List<MyActivityResDto>();
            var deptList = cache_BL.GetDeptNameMapList();
            using (var db = new crmContext())
            {
                Stopwatch stopWatch = new Stopwatch();
                stopWatch.Start();
                var data = (from a in db.RES_POOLLOG
                            join e in db.RES_MYALLOCATERES on new { resid = a.RESID, deptid = a.DEPTID }
                            equals new { resid = e.RESID, deptid = e.DEPTID } into temp
                            from e in temp.DefaultIfEmpty()
                            join b in db.RES_RESOURCETYPE on a.RESTYPEID equals b.RESTYPEID
                            where b.SOURCETYPE.Contains("xdzyc")
                            join c in db.RES_ACTIVITY on a.ACTIVITYID equals c.ACTIVITYID
                            join d in db.RES_CUSTOMERDETAIL on a.RESID equals d.RESID
                            select new MyActivityResDto
                            {
                                logId = a.LOGID,
                                ResourceTypeId = b.RESTYPEID,
                                ResourceTypeName = b.TYPENAME,
                                ResourceTag = c.RESOURCETAG,
                                ActivityName = c.ACTIVITYNAME,
                                Activityid = c.ACTIVITYID,
                                ActivityRemark = a.EXTXML,
                                CName = d.CNAME,
                                CTime = a.CTIME,
                                ResId = d.UMID,
                                InnerUserId = e.INNERUSERID,
                                DeptId = a.DEPTID
                            });

                if (!string.IsNullOrWhiteSpace(querydto.resId))
                {
                    data = data.Where(n => n.ResId == querydto.resId);
                }
                if (querydto.resourceType.HasValue && querydto.resourceType > 0)
                {
                    data = data.Where(n => n.ResourceTypeId == querydto.resourceType);
                }
                if (!string.IsNullOrWhiteSpace(querydto.cmbActive) && querydto.cmbActive != "全部")
                {
                    var cmdactivity = Convert.ToDecimal(querydto.cmbActive);
                    data = data.Where(n => n.Activityid == cmdactivity);
                }
                if (!string.IsNullOrWhiteSpace(querydto.actname))
                {
                    data = data.Where(n => n.ActivityName == querydto.actname);
                }
                if (!string.IsNullOrWhiteSpace(querydto.extxml))
                {
                    data = data.Where(n => n.ActivityRemark.Contains(querydto.extxml));
                }
                if (querydto.xstime.HasValue)
                {
                    data = data.Where(n => n.CTime >= querydto.xstime);
                }
                if (querydto.xetime.HasValue)
                {
                    var endtime = querydto.xetime.Value.AddDays(1);
                    data = data.Where(n => n.CTime < endtime);
                }
                if (!string.IsNullOrWhiteSpace(querydto.eid))
                {
                    var user = cache_BL.GetUserList().FirstOrDefault(n => n.EID.ToString() == querydto.eid || n.UNAME == querydto.eid);
                    var userid = user?.PKID;
                    data = data.Where(n => n.InnerUserId == userid);
                }
                if (querydto.deptlineid.HasValue)
                {
                    data = data.Where(n => n.DeptId == querydto.deptlineid);
                }

                if (!string.IsNullOrWhiteSpace(querydto.txt_userId))
                {
                    var userid = Convert.ToDecimal(querydto.txt_userId);
                    data = data.Where(m => m.InnerUserId == userid);
                }
                else if (!string.IsNullOrEmpty(querydto.txt_groupIds))
                {
                    var _groupids = OperationUtil.ConvertToDecimal(querydto.txt_groupIds.Split(','));
                    data = (from a in data
                            join b in db.BAS_INNERUSERGROUP on a.InnerUserId equals b.INNERUSERID
                            where _groupids.Contains(b.GID.Value)
                            select a);
                }
                else if (!string.IsNullOrEmpty(querydto.txt_deptId))
                {
                    var depts = OperationUtil.ConvertToDecimal(querydto.txt_deptId.Split(','));
                    List<decimal> ALLdeptIDS = new List<decimal>();
                    List<decimal> ALLgidS = new List<decimal>();
                    UserServices userservices = new UserServices(cache_BL);
                    foreach (var item in depts)
                    {
                        List<decimal> deptIDS = new List<decimal>();
                        List<decimal> gidS = new List<decimal>();
                        userservices.GetAllDeptIDOrGidByDeptId(item, ref deptIDS, ref gidS);//获取所有的组别和gid
                        ALLdeptIDS.AddRange(deptIDS);
                        ALLgidS.AddRange(gidS);
                    }
                    data = (from a in data
                            join b in db.BAS_INNERUSERGROUP on a.InnerUserId equals b.INNERUSERID
                            //join g in db.BAS_INNERGROUP on b.GID equals g.GID
                            where ALLdeptIDS.Contains(b.DEPTID.Value) || ALLgidS.Contains(b.GID.Value)
                            select a);
                }
                if (querydto.IsBound.HasValue)
                {
                    if (querydto.IsBound.GetValueOrDefault() == 0)
                    {
                        data = data.Where(w => !db.RES_RESID_WEWORKUSER.Any(a => a.RESID == w.ResId && a.ISDELETE != 1 && a.STATUS == 1));
                    }
                    else
                    {
                        data = data.Where(w => db.RES_RESID_WEWORKUSER.Any(a => a.RESID == w.ResId && a.ISDELETE != 1 && a.STATUS == 1));
                    }
                }
                data = data.OrderByDescending(n => n.CTime);
                PagerUtil.SetPager<MyActivityResDto>(ref data, ref pager);
                res = data.ToList();

                if (res.Count > 0)
                {
                    if (querydto.IsBound.HasValue)
                    {
                        foreach (var item in res)
                        {
                            item.IsBound = querydto.IsBound.GetValueOrDefault() == 0 ? "否" : "是";
                        }
                    }
                    else
                    {
                        var resids = res.Select(n => n.ResId).ToList();
                        var relations = db.RES_RESID_WEWORKUSER.Where(n => resids.Contains(n.RESID) && n.ISDELETE != 1 && n.STATUS == 1).ToList();
                        foreach (var item in res)
                        {
                            item.IsBound = relations.FirstOrDefault(n => n.RESID == item.ResId) == null ? "否" : "是";
                        }
                    }
                }
                foreach (var item in res)
                {
                    item.DeptName = deptList.FirstOrDefault(n => n.id == item.DeptId)?.title;
                }
                stopWatch.Stop();
                //记录费时
                LogHelper.Info(string.Concat("查询用时:", stopWatch.ElapsedMilliseconds, "ms"));
            }
            return res;
        }
    }
}