JDHY/src/Coldairarrow.Business/HuiYan/catsBusiness.cs

using Coldairarrow.Entity.DTO;
using Coldairarrow.Entity.HuiYan;
using Coldairarrow.IBusiness;
using Coldairarrow.Util;
using EFCore.Sharding;
using LinqKit;
using Microsoft.EntityFrameworkCore;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Linq.Dynamic.Core;
using System.Threading.Tasks;

namespace Coldairarrow.Business.HuiYan
{
    public class catsBusiness : BaseBusiness<cats>, IcatsBusiness, ITransientDependency
    {
        readonly IOperator _operator;
        public catsBusiness(IDbAccessor db, IOperator @operator)
            : base(db)
        {
            _operator = @operator;
        }

        #region 外部接口

        public async Task<List<CatTreeDTO>> GetTreeDataListAsync(CatsTreeInputDTO input)
        {
            var where = LinqHelper.True<cats>().And(c => c.Type == 0);
            if (!input.parentId.IsNullOrEmpty())
                where = where.And(x => x.ParentId == input.parentId);

            var list = await GetIQueryable().Where(where).ToListAsync();
            var treeList = list
                .Select(x => new CatTreeDTO
                {
                    Id = x.Id,
                    ParentId = x.ParentId,
                    Text = x.Name,
                    Value = x.Id,
                    Type = x.Type
                }).ToList();

            return TreeHelper.BuildTree(treeList);
        }




        public AjaxResult GetParentCatList()
        {
            var list = GetIQueryable().Where(c => string.IsNullOrEmpty(c.ParentId)).ToList();
            return Success(list);
        }


        public AjaxResult AddKeyWord(CatDto model)
        {
           var result= Db.RunTransaction(() =>
            {
                /*
                ///判断是否需要添加一级类目
                */
                cats oneCat = null;
                if (!string.IsNullOrEmpty(model.OneCat.Id))
                {
                    oneCat = GetIQueryable().FirstOrDefault(c => c.Id == model.OneCat.Id);
                }

                if (oneCat == null)
                {
                    oneCat = new cats()
                    {
                        Id = IdHelper.GetId(),
                        CreateTime = DateTime.Now,
                        CreatorId = "admin",
                        Deleted = false,
                        Name = model.OneCat.Text,
                        ParentId = null,
                        LastShowJDTime = DateTime.MinValue,
                        LastShowPddTime = DateTime.MinValue,
                        LastShowTBTime = DateTime.MinValue
                    };

                    int row = Db.Insert(oneCat);
                    if (row <= 0)
                    {
                        throw new Exception("一级类目添加失败！");
                    }
                }

                /*
                 ///判断是否需要添加二级类目
                */
                cats twoCat = null;
                if (!string.IsNullOrEmpty(model.TwoCat.Id))
                {
                    twoCat = GetIQueryable().FirstOrDefault(c => c.Id == model.TwoCat.Id);
                }

                if (twoCat == null)
                {
                    twoCat = new cats()
                    {
                        Id = IdHelper.GetId(),
                        CreateTime = DateTime.Now,
                        CreatorId = "admin",
                        Deleted = false,
                        Name = model.TwoCat.Text,
                        ParentId = oneCat.Id,
                        LastShowJDTime = DateTime.MinValue,
                        LastShowPddTime = DateTime.MinValue,
                        LastShowTBTime = DateTime.MinValue
                    };

                   int row= Db.Insert(twoCat);
                    if (row <= 0)
                    {
                        throw new Exception("二级类目添加失败！");
                    }
                }

                /*
                ///判断是否需要添加三级类目
                */
                cats lastCat = null;
                if (!string.IsNullOrEmpty(model.LastCat.Id))
                {
                    lastCat = GetIQueryable().FirstOrDefault(c => c.Id == model.LastCat.Id);
                }

                if (lastCat == null)
                {
                    lastCat = new cats()
                    {
                        Id = IdHelper.GetId(),
                        CreateTime = DateTime.Now,
                        CreatorId = "admin",
                        Deleted = false,
                        Name = model.LastCat.Text,
                        ParentId = twoCat.Id,
                        LastShowJDTime = DateTime.MinValue,
                        LastShowPddTime = DateTime.MinValue,
                        LastShowTBTime = DateTime.MinValue
                    };

                    int row = Db.Insert(lastCat);
                    if (row <= 0)
                    {
                        throw new Exception("三级类目添加失败！");
                    }
                }

                var list = new List<cats>();

                var hasKeys= Db.GetIQueryable<cats>().Where(c =>c.Type==0 &&c.ParentId == lastCat.Id && model.KeyWords.Contains(c.Name)).Select(c=>c.Name).ToList();

                model.KeyWords.Where(c => !hasKeys.Contains(c)).ForEach(key =>
                {
                    list.Add(new cats()
                    {
                        Id = IdHelper.GetId(),
                        CreateTime = DateTime.Now,
                        CreatorId = "admin",
                        Deleted = false,
                        Name = key,
                        ParentId = lastCat.Id,
                        LastShowJDTime = DateTime.MinValue,
                        LastShowPddTime = DateTime.MinValue,
                        LastShowTBTime = DateTime.MinValue,
                        Type = 0
                    });
                });

                Db.BulkInsert(list);
            });
            if(result.Success)
            {
                return Success();
            }
            return Error();
        }

        public async Task<PageResult<cats>> GetDataListAsync(PageInput<ConditionDTO> input)
        {
            var q = GetIQueryable();
            var where = LinqHelper.True<cats>();
            var search = input.Search;

            //筛选
            if (!search.Condition.IsNullOrEmpty() && !search.Keyword.IsNullOrEmpty())
            {
                var newWhere = DynamicExpressionParser.ParseLambda<cats, bool>(
                    ParsingConfig.Default, false, $@"{search.Condition}.Contains(@0)", search.Keyword);
                where = where.And(newWhere);
            }

            return await q.Where(where).GetPageResultAsync(input);
        }

        public async Task<cats> GetTheDataAsync(string id)
        {
            return await GetEntityAsync(id);
        }

        public async Task AddDataAsync(cats data)
        {
            await InsertAsync(data);
        }

        public async Task UpdateDataAsync(cats data)
        {
            await UpdateAsync(data);
        }

        public async Task DeleteDataAsync(List<string> ids)
        {
            await DeleteAsync(ids);
        }

        #endregion

        #region 私有成员

        #endregion



        public async Task<List<CatTreeDTO>> GetTreeDataListAsync()
        {
            var where = LinqHelper.True<cats>().And(c => c.Type == 0 || c.TeamId == _operator.TeamId);

            var list = await GetIQueryable().Where(where).ToListAsync();
            var treeList = list
                .Select(x => new CatTreeDTO
                {
                    Id = x.Id,
                    ParentId = x.ParentId,
                    Text = x.Name,
                    Value = x.Id,
                    Type = x.Type,
                    IsShowJDTime = x.LastShowJDTime == null ? true : (DateTime.Now - x.LastShowJDTime.Value).TotalDays > 3,
                    IsShowPddTime = x.LastShowPddTime == null ? true : (DateTime.Now - x.LastShowPddTime.Value).TotalDays > 3,
                    IsShowTBTime = x.LastShowTBTime == null ? true : (DateTime.Now - x.LastShowTBTime.Value).TotalDays > 3,
                }).ToList();

            return TreeHelper.BuildTree(treeList);
        }

        public AjaxResult SetKeyOpenTime(string id)
        {
            if (Db.Update<cats>(c => c.Id == id, (item) =>
            {
                item.LastShowTBTime = DateTime.Now;
            }) > 0)
                return Success();
            return Error();
        }

        public AjaxResult AddKeyWord(KeyWordDto model)
        {

            var has = GetIQueryable().Count(c => c.Name == model.KeyWord && c.TeamId == _operator.TeamId && c.Type == model.Type)>0;
            if (has)
            {
                return Error("该品类词已存在！");
            }
            var cat = new cats()
            {
                Id = IdHelper.GetId(),
                CreateTime = DateTime.Now,
                CreatorId = "admin",
                Deleted = false,
                Name = model.KeyWord,
                ParentId = model.LastCat,
                //设置为团队库
                Type = model.Type,
                //暂时没有登录信息
                TeamId = _operator.TeamId,
                LastShowJDTime = DateTime.MinValue,
                LastShowPddTime = DateTime.MinValue,
                LastShowTBTime = DateTime.MinValue

            };
            int row = Db.Insert<cats>(cat);

            if (row > 0)
            {
                return Success(cat.Id);
            }
            else
            {
                return Error();
            }
        }

    }
}