OA2023/OASystem/OASystem.Infrastructure/Repositories/Groups/GroupOrderPreInfoRepository.cs

using AutoMapper;
using EyeSoft.Collections.Generic;
using Newtonsoft.Json;
using OASystem.Domain;
using OASystem.Domain.Dtos.Groups;
using OASystem.Domain.Entities.Groups;
using OASystem.Domain.ViewModels.Groups;
using Org.BouncyCastle.Ocsp;
using Org.BouncyCastle.Utilities;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace OASystem.Infrastructure.Repositories.Groups
{
    /// <summary>
    /// 团组下单前信息
    /// </summary>
    public class GroupOrderPreInfoRepository : BaseRepository<Grp_OrderPreInfo, OrderPreInfoView>
    {
        private readonly IMapper _mapper;
        private readonly DelegationInfoRepository _groupInfoRep;
        public GroupOrderPreInfoRepository(SqlSugarClient sqlSugar, IMapper mapper, DelegationInfoRepository groupInfoRep) : base(sqlSugar)
        {
            _mapper = mapper;
            _groupInfoRep = groupInfoRep;
        }

        /// <summary>
        /// 获取模板信息
        /// </summary>
        /// <param name="tempId"></param>
        /// <returns></returns>
        public async Task<JsonView> DataInit()
        {
            var jw = new JsonView() { Code = StatusCodes.Status200OK, Msg = "操作成功!" };

            var groupNames = await _groupInfoRep.GetGroupNameList(new Domain.Dtos.Groups.GroupNameDto() { PortType = 1 });
            var tempDatas = await _sqlSugar.Queryable<Sys_SetData>().Where(x => x.IsDel == 0 && x.STid == 109).Select(x => new { x.Id, x.Name }).ToListAsync();
            var names = await _sqlSugar.Queryable<Grp_OrderPreInfo>().Where(x => x.IsDel == 0).OrderByDescending(x => x.Id).Select(x => new { x.Id, x.Name }).ToListAsync();
            jw.Data = new
            {
                groupNames = groupNames,
                tempDatas = tempDatas,
                names = names
            };
            return jw;
        }


        /// <summary>
        /// 获取模板信息
        /// </summary>
        /// <param name="tempId"></param>
        /// <returns></returns>
        public async Task<GrpOrderPreItemView[]> TempInfoById(int tempId = 1404)
        {
            var tempInfos = await _sqlSugar.Queryable<Sys_FormTemp, Sys_SetData, Sys_SetData>((ft, sd1, sd2) =>
                new JoinQueryInfos(
                    JoinType.Left, ft.FieldNameId == sd1.Id,
                    JoinType.Left, ft.FieldTypeId == sd2.Id
                    ))
                .Where((ft, sd1, sd2) => ft.IsDel == 0 && ft.TempId == tempId)
                .OrderBy((ft, sd1, sd2) => ft.Index)
                .Select((ft, sd1, sd2) => new GrpOrderPreItemView()
                {
                    FieldTempId = ft.Id,
                    FieldName = sd1.Name,
                    OriginVal = "-",
                   // FieldTypeName = !string.IsNullOrEmpty(ft.Remark) ? sd2.Name +"-"+ ft.Remark : sd2.Name,
                    FieldTypeName =  sd2.Name,
                    IsRequired = ft.IsRequired,
                    IsRemark = ft.IsRemark,
                    Index = ft.Index
                })
                .ToArrayAsync();
            return tempInfos;
        }

        /// <summary>
        /// 获取团组下单前信息
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        public async Task<JsonView> InfoAsync(int id, int tempId = 1404)
        {
            var jw = new JsonView() { Code = StatusCodes.Status200OK, Msg = "操作成功!" };
            var view = new GrpOrderPreInfoView();
            var info = await _sqlSugar.Queryable<Grp_OrderPreInfo>().FirstAsync(x => x.IsDel == 0 && x.Id == id);

            var temps = await TempInfoById(tempId);
            if (info == null)
            {
                //view.TempId = tempId;
                view.Items = temps;
                jw.Data = view;
                return jw;
            }
            view.Id = id;
            view.Name = info.Name;
            view.GroupId = info.GroupId;
            var items = await _sqlSugar.Queryable<Sys_FormTemp, Grp_OrderPreItem, Sys_SetData, Sys_SetData>((ft, opi, sd1, sd2) =>
                new JoinQueryInfos(
                    JoinType.Inner, ft.Id == opi.FormTempId,
                    JoinType.Left, ft.FieldNameId == sd1.Id,
                    JoinType.Left, ft.FieldTypeId == sd2.Id
                    ))
                .Where((ft, opi, sd1, sd2) => ft.IsDel == 0 && opi.IsDel == 0 && opi.ParentId == id && ft.TempId == tempId)
                .OrderBy((ft, opi, sd1, sd2) => ft.Index)
                .Select((ft, opi, sd1, sd2) => new GrpOrderPreItemView()
                {
                    Id = opi.Id,
                    ParentId = opi.ParentId,
                    FieldTempId = ft.Id,
                    FieldName = sd1.Name,
                    //FieldTypeName = !string.IsNullOrEmpty(ft.Remark) ? sd2.Name + "-" + ft.Remark : sd2.Name,
                    FieldTypeName = sd2.Name,
                    OriginVal = opi.Value,
                    IsRequired = ft.IsRequired,
                    IsRemark = ft.IsRemark,
                    Index = ft.Index
                })
                .ToArrayAsync();

            if (!items.Any()) view.Items = temps;
            else
            {
                if (items.Length != temps.Length)
                {
                    foreach (var item in temps)
                    {
                        if (items.FirstOrDefault(x => x.FieldName.Equals(item.FieldName)) == null)
                        {
                            var arr = new GrpOrderPreItemView[] { item };
                            view.Items.AddRange(arr);
                        }
                    }
                }
                else view.Items = items;

                view.Items = view.Items.Length > 0 ? view.Items.OrderBy(x => x.Index).ToArray() : view.Items;
            }

            jw.Data = view;
            return jw;
        }

        /// <summary>
        /// 获取团组下单前信息 op
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        public async Task<JsonView> OpAsync(GroupOrderPreInfoOpDto dto)
        {
            var jw = new JsonView() { Code = StatusCodes.Status400BadRequest, Msg = "操作成功!" };
            int currUserId = dto.CurrUserId;
            if (currUserId < 1)
            {
                jw.Msg = MsgTips.UserId;
                return jw;
            }
            if (string.IsNullOrEmpty(dto.Name))
            {
                jw.Msg = $"名称不能为空!";
                return jw;
            }

            var info = new Grp_OrderPreInfo()
            {
                Id = dto.Id,
                Name = dto.Name,
                GroupId = dto.GroupId,
                CreateUserId = currUserId
            };
            var items = new List<Grp_OrderPreItem>();
            foreach (var item in dto.Items)
            {
                var val = "";
                if (item.NewValue is Array obj)
                {
                    val =  JsonConvert.SerializeObject( (string[])item.NewValue);
                }
                else val = item.NewValue.ToString();

                items.Add(new Grp_OrderPreItem()
                {
                    Id = item.Id,
                    ParentId = item.ParentId,
                    FormTempId = item.FieldTempId,
                    Value = val,
                    CreateUserId = currUserId,
                    Remark = item.Remark
                });
            }

            var addItems = items.Where(x => x.Id <= 0).ToArray();
            var updItems = items.Where(x => x.Id > 0).ToArray();

            _sqlSugar.BeginTran();
            if (dto.Id > 0) //修改
            {
                var infoUpd = await _sqlSugar.Updateable(info).UpdateColumns(x => new { x.Name, x.GroupId }).ExecuteCommandAsync();
                if (infoUpd < 1)
                {
                    _sqlSugar.RollbackTran();
                    jw.Msg = $"修改失败!";
                    return jw;
                }

                if (addItems.Any()) await _sqlSugar.Insertable(addItems).ExecuteCommandAsync();

                if (updItems.Any()) await _sqlSugar.Updateable(updItems).UpdateColumns(x => new { x.Value, x.Remark }).ExecuteCommandAsync();
            }
            else if (dto.Id <= 0) //新增
            {
                var isNul = await _sqlSugar.Queryable<Grp_OrderPreInfo>().FirstAsync(x => x.IsDel == 0 && x.Name.Equals(dto.Name));
                if (isNul != null)
                {
                    _sqlSugar.RollbackTran();
                    jw.Msg = $"名称重复!";
                    return jw;
                }

                var addId = await _sqlSugar.Insertable(info).ExecuteReturnIdentityAsync();
                if (addId < 1)
                {
                    _sqlSugar.RollbackTran();
                    jw.Msg = $"新增失败!";
                    return jw;
                }

                foreach (var item in items) item.ParentId = addId;

                if (items.Any()) await _sqlSugar.Insertable(items).ExecuteCommandAsync();
            }

            _sqlSugar.CommitTran();
            jw.Msg = $"操作成功!";
            jw.Code = StatusCodes.Status200OK;
            return jw;
        }
    }
}