BaseClientInfoService.cs
10.6 KB
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
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
using Hh.Mes.Common.Infrastructure;
using Hh.Mes.Common.log;
using Hh.Mes.Common.Request;
using Hh.Mes.POJO.Entity;
using Hh.Mes.POJO.Response;
using Hh.Mes.Service.Repository;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Linq.Expressions;
using Hh.Mes.Pojo.System;
using Hh.Mes.Common;
using Hh.Mes.POJO.EnumEntitys;
using Hh.Mes.Service.SystemAuth;
namespace Hh.Mes.Service.Configure
{
public class BaseClientInfoService : RepositorySqlSugar<base_client_info>
{
private readonly IAuth _auth;
public BaseClientInfoService(IAuth auth)
{
_auth = auth;
}
public dynamic Load(PageReq pageReq, base_client_info entity)
{
return ExceptionsHelp.Instance.ExecuteT(() =>
{
var result = new Response<List<base_client_info>>();
var expression = LinqWhere(entity);
//先组合查询表达式
var query = Context.Queryable<base_client_info, sys_user_client_rel>((t1, t2) => new object[]
{
JoinType.Left,t1.keys == t2.clientKeys,
}).Where(expression).Select((t1, t2) => new base_client_info
{
id = t1.id,
keys = t1.keys,
userAccount = t2.userAccount,
clientName = t1.clientName,
businessRegistrationCode = t1.businessRegistrationCode,
unifiedSocialCreditCode = t1.unifiedSocialCreditCode,
legalRepresentative = t1.legalRepresentative,
registeredAddress = t1.registeredAddress,
setupDate = t1.setupDate,
telephone = t1.telephone,
email = t1.email,
remark = t1.remark,
createBy = t1.createBy,
createTime = t1.createTime,
});
//Exel为ture就不分页，因为导出的话是全部导出
if (pageReq != null)
{
int total = 0;
result.Result = query.ToOffsetPage(pageReq.page, pageReq.limit, ref total);
result.Count = total;
}
else
{
result.Result = query.ToList();
result.Count = result.Result.Count();
}
return result;
}, catchRetrunValue: "list");
}
public dynamic Ins(base_client_info entity)
{
return ExceptionsHelp.Instance.ExecuteT(() =>
{
Context.Ado.BeginTran();
try
{
var response = new Response();
entity.keys = Guid.NewGuid();
entity.setupDate = DateTime.Now;
entity.createBy = sysWebUser?.Account;
entity.createTime = DateTime.Now;
Context.Insertable(entity).ExecuteCommand();
var account = entity.userAccount.Trim();
//用户输入了账号，需要校验
if (!string.IsNullOrWhiteSpace(account) && Context.Queryable<sys_user>().Where(x => x.account == account).Any())
{
response.Status = false;
response.Message = $"账号“{account}”在系统中已存在，请修改后重试！";
return response;
}
//用户未输入账号，系统自动生成
if (string.IsNullOrWhiteSpace(account))
{
//当前已存在的账户
var allUserAccount = Context.Queryable<sys_user>().Select(x => x.account).ToList();
var temps = Enumerable.Range(1, 999999).Select(x => $"iot{x.ToString().PadLeft(6, '0')}").ToList();
account = temps.Except(allUserAccount).FirstOrDefault();
if (string.IsNullOrWhiteSpace(account))
{
response.Status = false;
response.Message = "自动生成用户账号失败，请输入自定义账号，或联系系统管理员处理！";
return response;
}
}
var user = new sys_user
{
account = account,
password = Encryption.Encrypt("123456"),
name = entity.clientName,
status = 1,
createBy = sysWebUser?.Account,
createTime = DateTime.Now,
};
var userId = Context.Insertable(user).ExecuteReturnIdentity();
var rel = new sys_user_client_rel
{
clientKeys = entity.keys,
userAccount = user.account,
};
Context.Insertable(rel).ExecuteCommand();
var relevance = new SysRelevance
{
RelKey = Define.USERORG,
FirstId = userId,
SecondId = _auth.GetCurrentUser().Orgs.Min(x => x.Id),
CreateBy = sysWebUser?.Account,
CreateTime = DateTime.Now
};
Context.Insertable(relevance).ExecuteCommand();
Context.Ado.CommitTran();
return response;
}
catch (Exception ex)
{
Context.Ado.RollbackTran();
throw ex;
}
});
}
public dynamic Upd(base_client_info entity)
{
return ExceptionsHelp.Instance.ExecuteT(() =>
{
var response = new Response();
entity.setupDate = DateTime.Now;
//entity.updateBy = sysWebUser?.Account;
//entity.updateTime = DateTime.Now;
response.Status = Update(entity);
if (!response.Status) response.Message = SystemVariable.dataActionError;
return response;
});
}
public dynamic DelByIds(Guid[] keys)
{
return ExceptionsHelp.Instance.ExecuteT(() =>
{
var response = new Response();
//客户绑定项目，不允许删除
if (Context.Queryable<base_project_client_rel>().Any(x => keys.Contains(x.clientKeys)))
{
return response.ResponseError("客户绑定了项目，不能直接删除，请先删除项目！");
}
//客户绑定用户，不允许删除
if (Context.Queryable<sys_user_client_rel>().Any(x => keys.Contains(x.clientKeys)))
{
return response.ResponseError("客户绑定了用户账号，不能直接删除，请在[系统管理]目录下的[用户管理]页面解除绑定后再试！");
}
Context.Deleteable<base_client_info>(t => keys.Contains(t.keys)).ExecuteCommand();
Context.Deleteable<sys_user_client_rel>(t => keys.Contains(t.clientKeys)).ExecuteCommand();//删除客户时删除与用户的绑定关系；
return response;
});
}
public Response ExportData(base_client_info entity)
{
return Load(null, entity);
}
public Expression<Func<base_client_info, sys_user_client_rel, bool>> LinqWhere(base_client_info model)
{
try
{
var exp = Expressionable.Create<base_client_info, sys_user_client_rel>();
//数据过滤条件
//if (!string.IsNullOrWhiteSpace(model.XXX)) exp.And(x => x.XXX.Contains(model.XXX));
if (!string.IsNullOrWhiteSpace(model.clientName))
{
exp.And((t1, t2) => t1.clientName.Contains(model.clientName));
}
if (!string.IsNullOrWhiteSpace(model.legalRepresentative))
{
exp.And((t1, t2) => t1.legalRepresentative.Contains(model.legalRepresentative));
}
if (!string.IsNullOrWhiteSpace(model.unifiedSocialCreditCode))
{
exp.And((t1, t2) => t1.unifiedSocialCreditCode.Contains(model.unifiedSocialCreditCode));
}
return exp.ToExpression();//拼接表达式
}
catch (Exception ex)
{
throw new Exception($"{ex.Message}");
}
}
/// <summary>
/// 客户管理项目功能
/// </summary>
/// <param name="clientKeys"></param>
/// <param name="checkeds"></param>
/// <param name="projectKeys"></param>
/// <returns></returns>
public dynamic BindClientProject(Guid clientKeys, bool checkeds, Guid projectKeys)
{
return ExceptionsHelp.Instance.ExecuteT(() =>
{
var response = new Response();
if (checkeds)
{
Context.Deleteable<base_project_client_rel>().Where(x => x.clientKeys == clientKeys && x.projectKeys == projectKeys).ExecuteCommand();
base_project_client_rel bpcr = new base_project_client_rel() { clientKeys = clientKeys, projectKeys = projectKeys };
Context.Insertable(bpcr).AddQueue();
response.Status = Context.SaveQueues() > 0;
if (!response.Status) response.Message = "添加客户项目关系表数据失败！";
}
else
{
Context.Deleteable<base_project_client_rel>().Where(x => x.clientKeys == clientKeys && x.projectKeys == projectKeys).AddQueue();
response.Status = Context.SaveQueues() > 0;
if (!response.Status) response.Message = $"取消客户绑定项目:{projectKeys}失败";
}
return response;
});
}
public dynamic GetClientBindProjects(Guid clientKeys)
{
return ExceptionsHelp.Instance.ExecuteT(() =>
{
var response = new Response();
response.Result = Context.Queryable<base_project_client_rel>().Where(x => x.clientKeys == clientKeys).ToList();
return response;
});
}
}
}