using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; using WIDESEA_Core; using WIDESEA_Core.BaseServices; using WIDESEA_Core.Const; using WIDESEA_Core.Helper; using WIDESEA_DTO.ERP; using WIDESEA_IBasicRepository; using WIDESEA_IBasicService; using WIDESEA_ISystemRepository; using WIDESEA_Model.Models; namespace WIDESEA_BasicService { public class UserInfoService : ServiceBase, IUserInfoService { private readonly ISys_UserRepository _userRepository; public UserInfoService(IUserInfoRepository BaseDal, ISys_UserRepository userRepository) : base(BaseDal) { _userRepository = userRepository; } public IUserInfoRepository Repository => BaseDal; public WebResponseContent ReceiveUser(UserInfoDTO model) { try { if (model.OperateType == "0") { Dt_UserInfo userInfo = new Dt_UserInfo() { Code = model.Code, DeptName = model.DeptName, DeptNo = model.DeptNo, InvOrgId = model.InvOrgId, Name = model.Name, State = model.State }; Sys_User user = new Sys_User() { UserName = userInfo.Code, RoleId = 0, UserPwd = "TC123456".EncryptDES(AppSecret.User), RoleName = "", Enable = (byte)userInfo.State, LastModifyPwdDate = DateTime.Now, Address = "系统服务器", TenantId = 0, Creater = "系统", UserTrueName = userInfo.Name, }; BaseDal.AddData(userInfo); _userRepository.AddData(user); } else if (model.OperateType == "1") { Dt_UserInfo userInfo = BaseDal.QueryFirst(x => x.Code == model.Code); if (userInfo == null) { return WebResponseContent.Instance.Error($"未找到该员工号【{model.Code}】信息"); } userInfo.State = model.State; userInfo.DeptName = model.DeptName; userInfo.DeptNo = model.DeptNo; userInfo.InvOrgId = model.InvOrgId; userInfo.Name = model.Name; BaseDal.UpdateData(userInfo); } else if (model.OperateType == "2") { Dt_UserInfo userInfo = BaseDal.QueryFirst(x => x.Code == model.Code); if (userInfo == null) { return WebResponseContent.Instance.Error($"未找到该员工号【{model.Code}】信息"); } BaseDal.DeleteData(userInfo); } return WebResponseContent.Instance.OK(); } catch (Exception ex) { return WebResponseContent.Instance.Error(ex.Message); } } public WebResponseContent AddUser() { try { List userInfos = BaseDal.QueryData().Where(x=>x.Code!= "Admin").ToList(); List userList = new List(); foreach (var item in userInfos) { Sys_User user = new Sys_User() { UserName = item.Code, RoleId = 0, UserPwd="TC123456".EncryptDES(AppSecret.User), RoleName ="", Enable=(byte)item.State, LastModifyPwdDate=DateTime.Now, Address= "系统服务器", TenantId=0, Creater= "系统", UserTrueName=item.Name, }; userList.Add(user); } _userRepository.AddData(userList); return WebResponseContent.Instance.OK(); } catch (Exception ex) { return WebResponseContent.Instance.Error(ex.Message); } } } }