wangxinhui
5 天以前 9ec715d2deb18a269dd49c48da91a36632d08c81
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
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<Dt_UserInfo, IUserInfoRepository>, 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)
                    {
                        Dt_UserInfo userInfoAddNew = new Dt_UserInfo()
                        {
                            Code = model.Code,
                            DeptName = model.DeptName,
                            DeptNo = model.DeptNo,
                            InvOrgId = model.InvOrgId,
                            Name = model.Name,
                            State = model.State
                        };
                        Sys_User userAddNew = 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(userInfoAddNew);
                        _userRepository.AddData(userAddNew);
                    }
                    else
                    {
                        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<Dt_UserInfo> userInfos = BaseDal.QueryData().Where(x=>x.Code!= "Admin").ToList();
                List<Sys_User> userList = new List<Sys_User>();
                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);
            }
        }
    }
}