tnb.server/EquipMgr/Tnb.EquipMgr/ToolMoldMaintainGroupService.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Linq.Expressions;
using System.Reflection;
using System.Text;
using System.Threading.Tasks;
using Aspose.Cells.Drawing;
using JNPF.Common.Core.Manager;
using JNPF.Common.Enums;
using JNPF.Common.Security;
using JNPF.DependencyInjection;
using JNPF.DynamicApiController;
using JNPF.FriendlyException;
using Mapster;
using Microsoft.AspNetCore.Mvc;
using NPOI.SS.Formula.Functions;
using Qiniu.Util;
using Spire.Pdf.Widget;
using SqlSugar;
using Tnb.Common.Contracts;
using Tnb.EquipMgr.Entities;
using Tnb.EquipMgr.Entities.Dto;
using Tnb.EquipMgr.Entities.Entity;
using Tnb.EquipMgr.Interfaces;

namespace Tnb.EquipMgr
{
    [ApiDescriptionSettings(Tag = ModuleConsts.Tag, Area = ModuleConsts.Area, Order = 700)]
    [Route("api/[area]/[controller]/[action]")]

    public class ToolMoldMaintainGroupService : IToolMoldMaintainGroupService, IDynamicApiController, ITransient
    {
        private readonly ISqlSugarRepository<ToolMoldMaintainGroup> _repository;
        private readonly IUserManager _userManager;
        private readonly ISqlSugarClient _db;
        public ToolMoldMaintainGroupService(ISqlSugarRepository<ToolMoldMaintainGroup> repository, IUserManager userManager)
        {
            _repository = repository;
            _userManager = userManager;
            _db = repository.AsSugarClient();
        }

        #region Get
        /// <summary>
        /// 根据项目组Id获取关联保养项信息
        /// </summary>
        /// <param name="itemGroupId"></param>
        /// <returns></returns>
        [HttpGet("{itemGroupId}")]
        public async Task<dynamic> GetMaintianItemListByGroupId(string itemGroupId)
        {
            var list = new List<MoldMaintainItemListOutput>();
            var itemIds = await _db.Queryable<ToolMoldMaintainGroupItem>().Where(it => it.item_group_id == itemGroupId).Select(it => it.item_id).ToListAsync();
            if (itemIds?.Count > 0)
            {
                var items = await _db.Queryable<MoldMaintenance>().Where(it => itemIds.Contains(it.id)).ToListAsync();
                list = items.Adapt<List<MoldMaintainItemListOutput>>();
            }
            return list;
        }
        /// <summary>
        /// 根据项目组Id获取关联模具信息 
        /// </summary>
        /// <param name="itemGroupId"></param>
        /// <returns></returns>
        [HttpGet("{itemGroupId}")]
        public async Task<dynamic> GetMoldListByGroupId(string itemGroupId)
        {
            var list = new List<RelevanceMoldListOutput>();
            var moldIds = await _db.Queryable<ToolMoldMaintainGroupRelation>().Where(it => it.item_group_id == itemGroupId).Select(it => it.mold_id).ToListAsync();
            if (moldIds?.Count > 0)
            {
                var items = await _db.Queryable<ToolMolds>().Where(it => moldIds.Contains(it.id)).ToListAsync();
                list = items.Adapt<List<RelevanceMoldListOutput>>();
            }
            return list;
        }
        #endregion


        #region Post
        /// <summary>
        /// 关联保养组与保养项
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        [HttpPost]
        public async Task RelevanceMaintianGroupAndItem(MoldMaintainGroupItemInput input) =>
            await Relevance<MoldMaintainGroupItemInput, ToolMoldMaintainGroupItem>(input, nameof(ToolMoldMaintainGroupItem.item_id), it => it.item_group_id == input.item_group_id);

        /// <summary>
        /// 关联项目组与模具
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        [HttpPost]
        public async Task RelevanceMaintianGroupAndMold(MoldMaintainGroupItemRelationInput input) =>
            await Relevance<MoldMaintainGroupItemRelationInput, ToolMoldMaintainGroupRelation>(input, nameof(ToolMoldMaintainGroupRelation.mold_id), it => it.item_group_id == input.item_group_id);



        #endregion

        private async Task Relevance<TSrc, TDest>(TSrc input, string name, Expression<Func<TDest, bool>> deleleExp) where TDest : BaseEntity<string>, new()
                                                              where TSrc : BaseInput
        {

            await _db.Deleteable<TDest>().Where(deleleExp).ExecuteCommandAsync();
            var itemGroupId = nameof(ToolMoldMaintainGroupRelation.item_group_id);
            if (input == null) throw new ArgumentNullException(nameof(input));
            var entities = new List<TDest>();
            if (input.ids?.Count > 0)
            {
                foreach (var id in input.ids)
                {
                    var pk = id;
                    TDest entity = new();
                    entity.id = SnowflakeIdHelper.NextId();
                    if (!PropertySet<TDest>.ValueFactories.TryGetValue(itemGroupId, out Action<object, object> setGroupIdAction))
                    {
                        setGroupIdAction = PropertySet<TDest>.CreateSetPropertyValueAction(itemGroupId);
                        PropertySet<TDest>.ValueFactories.Add(itemGroupId, setGroupIdAction);
                    }
                    setGroupIdAction(entity, input.item_group_id);
                    if (!PropertySet<TDest>.ValueFactories.TryGetValue(name, out Action<object, object> setAction))
                    {
                        setAction = PropertySet<TDest>.CreateSetPropertyValueAction(name);
                        PropertySet<TDest>.ValueFactories.Add(name, setAction);
                    }
                    setAction(entity, pk);
                    entities.Add(entity);
                }
            }
            var row = await _db.Insertable(entities).ExecuteCommandAsync();
            if (row < 1) throw Oops.Oh(ErrorCode.COM1000);
        }

    }

    public class PropertySet<T>
    {
        public static Dictionary<string, Action<object, object>> ValueFactories = new Dictionary<string, Action<object, object>>(StringComparer.OrdinalIgnoreCase);

        public static Action<object, object> CreateSetPropertyValueAction(string propertyName)
        {
            var property = typeof(T).GetProperty(propertyName);
            var target = Expression.Parameter(typeof(object));
            var propertyValue = Expression.Parameter(typeof(object));
            var castTarget = Expression.Convert(target, typeof(T));
            var castPropertyValue = Expression.Convert(propertyValue, property.PropertyType);
            var setPropertyValue = Expression.Call(castTarget, property.GetSetMethod(), castPropertyValue);
            return Expression.Lambda<Action<object, object>>(setPropertyValue, target, propertyValue).Compile();
        }

    }


}