修复水泵分析

lixiaojun

2024-12-09 25f7d54d23dd47d6f2bfd91e7edfd218a4b9ec3e

 BLL/HStation.BLL.Organize.Core/03-localclient/EmployeeMain.cs

@@ -1,5 +1,4 @@
using HStation.Dto;
using Mapster;
using Yw.Dto;

namespace HStation.CAL.LocalClient
@@ -39,6 +38,20 @@
        }

        /// <summary>
        /// 通过编号获取
        /// </summary>
        /// <param name="ErpCode"></param>
        /// <returns></returns>
        public async Task<EmployeeMainDto> GetByErpCode(String ErpCode)
        {
            return await Task.Factory.StartNew(() =>
            {
                var model = _service.GetByErpCode(ErpCode);
                return model == null ? null : new EmployeeMainDto(model);
            });
        }

        /// <summary>
        /// 通过 Ids 获取
        /// </summary>
        public async Task<List<EmployeeMainDto>> GetByIds(List<long> Ids)
@@ -58,56 +71,56 @@
        /// <summary>
        /// 插入一条
        /// </summary>
        public async Task<long> Insert(AddEmployeeMainDto input)
        public async Task<long> Insert(Dto.AddEmployeeMainInput input)
        {
            return await Task.Factory.StartNew(() =>
            {
                var model = input.Adapt<AddEmployeeMainDto, Model.EmployeeMain>();
                var model = input.Adapt<Dto.AddEmployeeMainInput, Model.EmployeeMain>();
                model.SortCode = _service.GetMaxSortCode() + 1;
                var id = _service.Insert(model);
                return id;
            });
        }

        /// <summary>
        /// 插入员工拓展(包含登录用户)
        /// </summary>
        public async Task<long> InsertLoginUserEx(AddEmployeeMainDto employeeMainDto, AddUserLoginMapDto loginmapdto, AddLoginUserMainDto loginuserdto)
        {
            return await Task.Factory.StartNew(() =>
            {
                var employeemodel = employeeMainDto.Adapt<AddEmployeeMainDto, Model.EmployeeMain>();
                employeemodel.SortCode = _service.GetMaxSortCode() + 1;
                var loginmapmodel = loginmapdto.Adapt<AddUserLoginMapDto, Model.UserLoginMap>();
                var loginusermodel = loginuserdto.Adapt<AddLoginUserMainDto, Model.LoginUserMain>();
                var id = _service.InsertLoginEx(employeemodel, loginmapmodel, loginusermodel);
                return id;
            });
        }
        /*        /// <summary>
                /// 插入员工拓展
                /// </summary>
                public async Task<EmployeeAndLoginID> InsertEx(Dto.AddEmployeeMainInput employeeMainDto)
                {
                    return await await Task.Factory.StartNew(async () =>
                    {
                        var employeemodel = employeeMainDto.Adapt<Dto.AddEmployeeMainInput, Model.EmployeeMain>();
                        if (employeemodel.SortCode < 0)
                            employeemodel.SortCode = _service.GetMaxSortCode() + 1;

        /// <summary>
        /// 插入员工拓展(不包含登录用户)
        /// </summary>
        public async Task<long> InsertEx(AddEmployeeMainDto employeeMainDto, AddUserLoginMapDto loginmapdto)
        {
            return await Task.Factory.StartNew(() =>
            {
                var employeemodel = employeeMainDto.Adapt<AddEmployeeMainDto, Model.EmployeeMain>();
                employeemodel.SortCode = _service.GetMaxSortCode() + 1;
                var loginmapmodel = loginmapdto.Adapt<AddUserLoginMapDto, Model.UserLoginMap>();
                var id = _service.InsertEx(employeemodel, loginmapmodel);
                return id;
            });
        }
                        var loginmapmodel = employeeMainDto.User.Adapt<AddUserLoginAccount, Model.UserLoginAccount>();
                        var id = _service.InsertEx(employeemodel, loginmapmodel);
                        if (id > 0)
                        {
                            EmployeeAndLoginID iDList = new EmployeeAndLoginID();
                            iDList.EmployeeID = id;
                            var loginmodel = await new UserLoginAccount().GetLoginUserByEmployeeID(id);
                            if (loginmodel != null)
                            {
                                iDList.LoginID = loginmodel.ID;
                            }
                            return iDList;
                        }
                        else
                        {
                            return null;
                        }
                    });
                }*/

        /// <summary>
        /// 批量插入
        /// </summary>
        public async Task<bool> Inserts(List<AddEmployeeMainDto> inputList)
        public async Task<bool> Inserts(List<Dto.AddEmployeeMainInput> inputList)
        {
            return await Task.Factory.StartNew(() =>
            {
                var list = inputList.Select(x => x.Adapt<AddEmployeeMainDto, Model.EmployeeMain>()).ToList();
                var list = inputList.Select(x => x.Adapt<Dto.AddEmployeeMainInput, Model.EmployeeMain>()).ToList();
                list.ForEach(x =>
                {
                    x.SortCode = _service.GetMaxSortCode() + 1 + list.IndexOf(x);
@@ -120,7 +133,7 @@
        /// <summary>
        /// 大批量插入
        /// </summary>
        public async Task<bool> BulkInserts(List<AddEmployeeMainDto> list)
        public async Task<bool> BulkInserts(List<Dto.AddEmployeeMainInput> list)
        {
            return await Task.Factory.StartNew(() =>
            {
@@ -135,7 +148,7 @@
        /// <summary>
        /// 更新一条
        /// </summary>
        public async Task<bool> Update(UpdateEmployeeMainDto input)
        public async Task<bool> Update(Dto.UpdateEmployeeMainDto input)
        {
            return await Task.Factory.StartNew(() =>
            {
@@ -155,7 +168,7 @@
        /// <summary>
        /// 批量更新
        /// </summary>
        public async Task<bool> Updates(List<UpdateEmployeeMainDto> inputList)
        public async Task<bool> Updates(List<Dto.UpdateEmployeeMainDto> inputList)
        {
            return await Task.Factory.StartNew(() =>
            {
@@ -163,7 +176,7 @@
                {
                    return false;
                }
                var list = inputList.Select(x => x.Adapt<UpdateEmployeeMainDto, Model.EmployeeMain>()).ToList();
                var list = inputList.Select(x => x.Adapt<Dto.UpdateEmployeeMainDto, Model.EmployeeMain>()).ToList();
                var bol = _service.Updates(list);
                return bol;
            });
@@ -172,7 +185,7 @@
        /// <summary>
        /// 大批量更新
        /// </summary>
        public async Task<bool> BulkUpdates(List<UpdateEmployeeMainDto> list)
        public async Task<bool> BulkUpdates(List<Dto.UpdateEmployeeMainDto> list)
        {
            return await Task.Factory.StartNew(() =>
            {