0ef47194
“wangming”
Refactor LqHytkHy...
|
1
2
3
4
5
6
7
8
9
|
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using Mapster;
using Microsoft.AspNetCore.Mvc;
using NCC.ClayObject;
using NCC.Common.Configuration;
using NCC.Common.Core.Manager;
|
96009bc9
hexiaodong
hxd
|
10
11
12
|
using NCC.Common.Enum;
using NCC.Common.Extension;
using NCC.Common.Filter;
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
13
14
15
|
using NCC.Common.Helper;
using NCC.Common.Model.NPOI;
using NCC.DataEncryption;
|
96009bc9
hexiaodong
hxd
|
16
17
|
using NCC.Dependency;
using NCC.DynamicApiController;
|
96009bc9
hexiaodong
hxd
|
18
|
using NCC.Extend.Entitys.Dto.LqTkjlb;
|
759f9f27
“wangming”
123321
|
19
|
using NCC.Extend.Entitys.Enum;
|
d98270e2
“wangming”
Enhance LqEventSe...
|
20
|
using NCC.Extend.Entitys.lq_event;
|
920afb29
“wangming”
修改了一摩尔的东西,我一个人在客户...
|
21
22
|
using NCC.Extend.Entitys.lq_eventuser;
using NCC.Extend.Entitys.lq_khxx;
|
41da4257
“wangming”
Refactor LqEventS...
|
23
|
using NCC.Extend.Entitys.lq_mdxx;
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
24
25
26
|
using NCC.Extend.Entitys.lq_tkjlb;
using NCC.Extend.Interfaces.LqTkjlb;
using NCC.FriendlyException;
|
96009bc9
hexiaodong
hxd
|
27
|
using NCC.JsonSerialization;
|
96009bc9
hexiaodong
hxd
|
28
|
using NCC.System.Entitys.Permission;
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
29
30
|
using SqlSugar;
using Yitter.IdGenerator;
|
96009bc9
hexiaodong
hxd
|
31
32
33
34
35
36
|
namespace NCC.Extend.LqTkjlb
{
/// <summary>
/// 拓客管理服务
/// </summary>
|
b45d55f7
“wangming”
Refactor LqEventS...
|
37
|
[ApiDescriptionSettings(Tag = "绿纤拓客管理服务", Name = "LqTkjlb", Order = 200)]
|
96009bc9
hexiaodong
hxd
|
38
39
40
41
42
43
44
45
46
47
|
[Route("api/Extend/[controller]")]
public class LqTkjlbService : ILqTkjlbService, IDynamicApiController, ITransient
{
private readonly ISqlSugarRepository<LqTkjlbEntity> _lqTkjlbRepository;
private readonly SqlSugarScope _db;
private readonly IUserManager _userManager;
/// <summary>
/// 初始化一个<see cref="LqTkjlbService"/>类型的新实例
/// </summary>
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
48
|
public LqTkjlbService(ISqlSugarRepository<LqTkjlbEntity> lqTkjlbRepository, IUserManager userManager)
|
96009bc9
hexiaodong
hxd
|
49
|
{
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
50
|
_lqTkjlbRepository = lqTkjlbRepository;
|
96009bc9
hexiaodong
hxd
|
51
52
53
54
|
_db = _lqTkjlbRepository.Context;
_userManager = userManager;
}
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
55
|
#region 获取拓客管理
|
96009bc9
hexiaodong
hxd
|
56
57
58
59
60
61
62
63
|
/// <summary>
/// 获取拓客管理
/// </summary>
/// <param name="id">参数</param>
/// <returns></returns>
[HttpGet("{id}")]
public async Task<dynamic> GetInfo(string id)
{
|
b45d55f7
“wangming”
Refactor LqEventS...
|
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
|
// 使用SqlFunc在查询时直接获取用户名和活动名称
var result = await _db.Queryable<LqTkjlbEntity>()
.Where(p => p.Id == id)
.Select(p => new LqTkjlbInfoOutput
{
id = p.Id,
expansionTime = p.ExpansionTime,
expansionUserId = p.ExpansionUserId,
expansionUserName = SqlFunc.Subqueryable<UserEntity>().Where(u => u.Id == p.ExpansionUserId).Select(u => u.RealName),
customerName = p.CustomerName,
customerPhone = p.CustomerPhone,
buyNumber = p.BuyNumber,
paymentMethod = p.PaymentMethod,
isAddWeChat = p.IsAddWeChat,
remarks = p.Remarks,
storeId = p.StoreId,
teamName = p.TeamName,
eventId = p.EventId,
eventName = SqlFunc.Subqueryable<LqEventEntity>().Where(e => e.Id == p.EventId).Select(e => e.EventName),
|
7f83b333
“wangming”
重构:删除部门管理模块并修复预约记录服务
|
83
|
storeName = SqlFunc.Subqueryable<LqMdxxEntity>().Where(u => u.Id == p.StoreId).Select(u => u.Dm),
|
b45d55f7
“wangming”
Refactor LqEventS...
|
84
85
86
87
|
})
.FirstAsync();
return result;
|
96009bc9
hexiaodong
hxd
|
88
|
}
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
89
|
#endregion
|
c842ad9a
“wangming”
Remove analyze_ex...
|
90
|
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
91
|
#region 获取拓客管理列表
|
96009bc9
hexiaodong
hxd
|
92
93
|
/// <summary>
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
94
95
96
97
|
/// 获取拓客管理列表
/// </summary>
/// <param name="input">请求参数</param>
/// <returns></returns>
|
96009bc9
hexiaodong
hxd
|
98
99
100
101
|
[HttpGet("")]
public async Task<dynamic> GetList([FromQuery] LqTkjlbListQueryInput input)
{
var sidx = input.sidx == null ? "id" : input.sidx;
|
b45d55f7
“wangming”
Refactor LqEventS...
|
102
|
List<string> queryTksj = input.expansionTime != null ? input.expansionTime.Split(',').ToObeject<List<string>>() : null;
|
96009bc9
hexiaodong
hxd
|
103
104
105
106
|
DateTime? startTksj = queryTksj != null ? Ext.GetDateTime(queryTksj.First()) : null;
DateTime? endTksj = queryTksj != null ? Ext.GetDateTime(queryTksj.Last()) : null;
var data = await _db.Queryable<LqTkjlbEntity>()
.WhereIF(!string.IsNullOrEmpty(input.id), p => p.Id.Contains(input.id))
|
b45d55f7
“wangming”
Refactor LqEventS...
|
107
108
109
110
111
112
113
114
115
116
117
118
|
.WhereIF(queryTksj != null, p => p.ExpansionTime >= new DateTime(startTksj.ToDate().Year, startTksj.ToDate().Month, startTksj.ToDate().Day, 0, 0, 0))
.WhereIF(queryTksj != null, p => p.ExpansionTime <= new DateTime(endTksj.ToDate().Year, endTksj.ToDate().Month, endTksj.ToDate().Day, 23, 59, 59))
.WhereIF(!string.IsNullOrEmpty(input.expansionUserId), p => p.ExpansionUserId.Equals(input.expansionUserId))
.WhereIF(!string.IsNullOrEmpty(input.customerName), p => p.CustomerName.Contains(input.customerName))
.WhereIF(!string.IsNullOrEmpty(input.customerPhone), p => p.CustomerPhone.Contains(input.customerPhone))
.WhereIF(!string.IsNullOrEmpty(input.buyNumber), p => p.BuyNumber.Equals(input.buyNumber))
.WhereIF(!string.IsNullOrEmpty(input.paymentMethod), p => p.PaymentMethod.Equals(input.paymentMethod))
.WhereIF(!string.IsNullOrEmpty(input.isAddWeChat), p => p.IsAddWeChat.Equals(input.isAddWeChat))
.WhereIF(!string.IsNullOrEmpty(input.remarks), p => p.Remarks.Contains(input.remarks))
.WhereIF(!string.IsNullOrEmpty(input.storeId), p => p.StoreId.Contains(input.storeId))
.WhereIF(!string.IsNullOrEmpty(input.teamName), p => p.TeamName.Contains(input.teamName))
.WhereIF(!string.IsNullOrEmpty(input.eventId), p => p.EventId.Contains(input.eventId))
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
119
|
.Select(it => new LqTkjlbListOutput
|
96009bc9
hexiaodong
hxd
|
120
121
|
{
id = it.Id,
|
b45d55f7
“wangming”
Refactor LqEventS...
|
122
123
|
expansionTime = it.ExpansionTime,
expansionUserId = it.ExpansionUserId,
|
1e118117
“wangming”
新增历史会员权益数据导入功能
|
124
|
expansionUserName = SqlFunc.Subqueryable<UserEntity>().Where(u => u.Id == it.ExpansionUserId).Select(u => u.RealName),
|
b45d55f7
“wangming”
Refactor LqEventS...
|
125
126
127
128
129
130
131
|
customerName = it.CustomerName,
customerPhone = it.CustomerPhone,
buyNumber = it.BuyNumber,
paymentMethod = it.PaymentMethod,
isAddWeChat = it.IsAddWeChat,
remarks = it.Remarks,
storeId = it.StoreId,
|
7f83b333
“wangming”
重构:删除部门管理模块并修复预约记录服务
|
132
|
storeName = SqlFunc.Subqueryable<LqMdxxEntity>().Where(u => u.Id == it.StoreId).Select(u => u.Dm),
|
b45d55f7
“wangming”
Refactor LqEventS...
|
133
|
teamName = it.TeamName,
|
d98270e2
“wangming”
Enhance LqEventSe...
|
134
135
|
eventId = it.EventId,
eventName = SqlFunc.Subqueryable<LqEventEntity>().Where(u => u.Id == it.EventId).Select(u => u.EventName),
|
9864a818
“wangming”
feat: 优化拓客管理功能
|
136
137
|
depId = it.DepId,
depName = SqlFunc.Subqueryable<OrganizeEntity>().Where(u => u.Id == it.DepId).Select(u => u.FullName),
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
138
139
140
141
142
|
})
.MergeTable()
.OrderBy(sidx + " " + input.sort)
.ToPagedListAsync(input.currentPage, input.pageSize);
return PageResult<LqTkjlbListOutput>.SqlSugarPageResult(data);
|
96009bc9
hexiaodong
hxd
|
143
|
}
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
144
|
#endregion
|
c842ad9a
“wangming”
Remove analyze_ex...
|
145
|
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
146
|
#region 新建拓客管理
|
96009bc9
hexiaodong
hxd
|
147
148
149
150
151
152
|
/// <summary>
/// 新建拓客管理
/// </summary>
/// <param name="input">参数</param>
/// <returns></returns>
[HttpPost("")]
|
41da4257
“wangming”
Refactor LqEventS...
|
153
|
public async Task<dynamic> Create([FromBody] LqTkjlbCrInput input)
|
96009bc9
hexiaodong
hxd
|
154
155
|
{
var userInfo = await _userManager.GetUserInfo();
|
920afb29
“wangming”
修改了一摩尔的东西,我一个人在客户...
|
156
|
//通过input.dhhm去查询用户信息
|
b45d55f7
“wangming”
Refactor LqEventS...
|
157
|
var user = _db.Queryable<LqKhxxEntity>().Where(u => u.Sjh == input.customerPhone).Any();
|
920afb29
“wangming”
修改了一摩尔的东西,我一个人在客户...
|
158
|
if (user)
|
96009bc9
hexiaodong
hxd
|
159
|
{
|
41da4257
“wangming”
Refactor LqEventS...
|
160
|
return NCCException.Oh("该手机号码已存在于会员或线索池中");
|
96009bc9
hexiaodong
hxd
|
161
|
}
|
920afb29
“wangming”
修改了一摩尔的东西,我一个人在客户...
|
162
163
164
165
|
// 使用事务确保数据一致性
var result = await _db.Ado.UseTranAsync(async () =>
{
//通过input.eventId去查询拓客活动信息
|
b45d55f7
“wangming”
Refactor LqEventS...
|
166
|
var eventUserInfoList = await _db.Queryable<LqEventUserEntity>().Where(u => u.EventId == input.eventId && u.UserId == input.expansionUserId).ToListAsync();
|
d98270e2
“wangming”
Enhance LqEventSe...
|
167
168
169
170
171
|
if (eventUserInfoList == null || eventUserInfoList.Count == 0)
{
throw NCCException.Oh("未找到对应的拓客活动用户信息,请确认活动ID和用户ID是否正确");
}
var eventUserInfo = eventUserInfoList.First();
|
920afb29
“wangming”
修改了一摩尔的东西,我一个人在客户...
|
172
173
174
|
// 创建拓客记录
var entity = input.Adapt<LqTkjlbEntity>();
entity.Id = YitIdHelper.NextId().ToString();
|
b45d55f7
“wangming”
Refactor LqEventS...
|
175
176
177
178
|
entity.TeamName = eventUserInfo.TeamName;
entity.StoreId = eventUserInfo.StoreId;
entity.DepId = eventUserInfo.DepId;
entity.ExpansionTime = DateTime.Now;
|
920afb29
“wangming”
修改了一摩尔的东西,我一个人在客户...
|
179
180
181
182
183
184
|
var isOk = await _db.Insertable(entity).IgnoreColumns(ignoreNullColumn: true).ExecuteCommandAsync();
if (!(isOk > 0))
throw NCCException.Oh("创建拓客记录失败");
// 创建客户信息
LqKhxxEntity MemberInfo = new LqKhxxEntity();
MemberInfo.Id = YitIdHelper.NextId().ToString();
|
b45d55f7
“wangming”
Refactor LqEventS...
|
185
186
|
MemberInfo.Khmc = entity.CustomerName;
MemberInfo.Sjh = input.customerPhone; // 设置手机号
|
759f9f27
“wangming”
123321
|
187
|
MemberInfo.Khlx = MemberTypeEnum.线索.GetHashCode().ToString();
|
920afb29
“wangming”
修改了一摩尔的东西,我一个人在客户...
|
188
|
MemberInfo.Dah = "GK" + DateTime.Now.ToString("yyyyMMddHHmmss");
|
1e118117
“wangming”
新增历史会员权益数据导入功能
|
189
|
MemberInfo.Jdqd = "19.9卡";
|
0380c57d
“wangming”
修复项目编译错误和优化功能
|
190
191
|
//找到input.expansionUserId的用户信息
var userInfo = await _db.Queryable<UserEntity>().Where(u => u.Id == input.expansionUserId).FirstAsync();
|
150862dd
“wangming”
修复GetInfo方法中的空值处理问题
|
192
|
//判断 岗位是否为健康师,如果是健康师,则设置拓客人员是健康师
|
e5e15bcb
“wangming”
优化系统功能和性能
|
193
|
MemberInfo.ExpandUser = input.expansionUserId;
|
0b87d248
“wangming”
Enhance LqEventSe...
|
194
|
MemberInfo.Gsmd = eventUserInfo.StoreId;
|
920afb29
“wangming”
修改了一摩尔的东西,我一个人在客户...
|
195
196
|
var memberResult = await _db.Insertable(MemberInfo).IgnoreColumns(ignoreNullColumn: true).ExecuteCommandAsync();
if (!(memberResult > 0))
|
41da4257
“wangming”
Refactor LqEventS...
|
197
|
{
|
920afb29
“wangming”
修改了一摩尔的东西,我一个人在客户...
|
198
|
throw NCCException.Oh("创建客户信息失败");
|
41da4257
“wangming”
Refactor LqEventS...
|
199
200
201
|
}
var storeinfo = await _db.Queryable<LqMdxxEntity>().Where(u => u.Id == eventUserInfo.StoreId).FirstAsync();
return new { entity = entity, storeinfo = storeinfo };
|
920afb29
“wangming”
修改了一摩尔的东西,我一个人在客户...
|
202
|
});
|
96009bc9
hexiaodong
hxd
|
203
|
|
920afb29
“wangming”
修改了一摩尔的东西,我一个人在客户...
|
204
205
|
if (!result.IsSuccess)
{
|
41da4257
“wangming”
Refactor LqEventS...
|
206
|
return NCCException.Oh($"创建拓客记录失败:{result.ErrorMessage}");
|
920afb29
“wangming”
修改了一摩尔的东西,我一个人在客户...
|
207
|
}
|
41da4257
“wangming”
Refactor LqEventS...
|
208
|
return result.Data;
|
96009bc9
hexiaodong
hxd
|
209
|
}
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
210
|
#endregion
|
c842ad9a
“wangming”
Remove analyze_ex...
|
211
|
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
212
|
#region 获取拓客管理无分页列表
|
96009bc9
hexiaodong
hxd
|
213
|
/// <summary>
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
214
215
216
217
|
/// 获取拓客管理无分页列表
/// </summary>
/// <param name="input">请求参数</param>
/// <returns></returns>
|
96009bc9
hexiaodong
hxd
|
218
219
220
221
|
[NonAction]
public async Task<dynamic> GetNoPagingList([FromQuery] LqTkjlbListQueryInput input)
{
var sidx = input.sidx == null ? "id" : input.sidx;
|
b45d55f7
“wangming”
Refactor LqEventS...
|
222
223
224
|
List<string> queryExpansionTime = input.expansionTime != null ? input.expansionTime.Split(',').ToObeject<List<string>>() : null;
DateTime? startExpansionTime = queryExpansionTime != null ? Ext.GetDateTime(queryExpansionTime.First()) : null;
DateTime? endExpansionTime = queryExpansionTime != null ? Ext.GetDateTime(queryExpansionTime.Last()) : null;
|
96009bc9
hexiaodong
hxd
|
225
226
|
var data = await _db.Queryable<LqTkjlbEntity>()
.WhereIF(!string.IsNullOrEmpty(input.id), p => p.Id.Contains(input.id))
|
b45d55f7
“wangming”
Refactor LqEventS...
|
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
|
.WhereIF(
queryExpansionTime != null,
p => p.ExpansionTime >= new DateTime(startExpansionTime.ToDate().Year, startExpansionTime.ToDate().Month, startExpansionTime.ToDate().Day, 0, 0, 0)
)
.WhereIF(queryExpansionTime != null, p => p.ExpansionTime <= new DateTime(endExpansionTime.ToDate().Year, endExpansionTime.ToDate().Month, endExpansionTime.ToDate().Day, 23, 59, 59))
.WhereIF(!string.IsNullOrEmpty(input.expansionUserId), p => p.ExpansionUserId.Equals(input.expansionUserId))
.WhereIF(!string.IsNullOrEmpty(input.customerName), p => p.CustomerName.Contains(input.customerName))
.WhereIF(!string.IsNullOrEmpty(input.customerPhone), p => p.CustomerPhone.Contains(input.customerPhone))
.WhereIF(!string.IsNullOrEmpty(input.buyNumber), p => p.BuyNumber.ToString().Equals(input.buyNumber))
.WhereIF(!string.IsNullOrEmpty(input.paymentMethod), p => p.PaymentMethod.Equals(input.paymentMethod))
.WhereIF(!string.IsNullOrEmpty(input.isAddWeChat), p => p.IsAddWeChat.Equals(input.isAddWeChat))
.WhereIF(!string.IsNullOrEmpty(input.remarks), p => p.Remarks.Contains(input.remarks))
.WhereIF(!string.IsNullOrEmpty(input.storeId), p => p.StoreId.Contains(input.storeId))
.WhereIF(!string.IsNullOrEmpty(input.teamName), p => p.TeamName.Contains(input.teamName))
.WhereIF(!string.IsNullOrEmpty(input.eventId), p => p.EventId.Equals(input.eventId))
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
242
|
.Select(it => new LqTkjlbListOutput
|
96009bc9
hexiaodong
hxd
|
243
244
|
{
id = it.Id,
|
b45d55f7
“wangming”
Refactor LqEventS...
|
245
246
247
248
249
250
251
252
253
254
255
256
257
|
expansionTime = it.ExpansionTime,
expansionUserId = it.ExpansionUserId,
expansionUserName = it.ExpansionUserId, // 这里需要根据实际业务逻辑获取用户名
customerName = it.CustomerName,
customerPhone = it.CustomerPhone,
buyNumber = it.BuyNumber,
paymentMethod = it.PaymentMethod,
isAddWeChat = it.IsAddWeChat,
remarks = it.Remarks,
storeId = it.StoreId,
teamName = it.TeamName,
eventId = it.EventId,
eventName = it.EventId, // 这里需要根据实际业务逻辑获取活动名称
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
258
259
260
261
262
|
})
.MergeTable()
.OrderBy(sidx + " " + input.sort)
.ToListAsync();
return data;
|
96009bc9
hexiaodong
hxd
|
263
|
}
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
264
|
#endregion
|
c842ad9a
“wangming”
Remove analyze_ex...
|
265
|
|
9864a818
“wangming”
feat: 优化拓客管理功能
|
266
|
#region 获取拓客管理带中文名称的数据(简化版)
|
96009bc9
hexiaodong
hxd
|
267
|
/// <summary>
|
9864a818
“wangming”
feat: 优化拓客管理功能
|
268
|
/// 获取拓客管理带中文名称的数据(简化版,用于导出)
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
269
|
/// </summary>
|
9864a818
“wangming”
feat: 优化拓客管理功能
|
270
271
|
/// <param name="eventId">活动编号(可选)</param>
/// <param name="endTime">截止时间(可选)</param>
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
272
|
/// <returns></returns>
|
9864a818
“wangming”
feat: 优化拓客管理功能
|
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
|
[NonAction]
public async Task<List<TkjlbExportModel>> GetTkjlbWithChineseNamesSimple(string eventId = null, DateTime? endTime = null)
{
var data = await _db.Queryable<LqTkjlbEntity, LqMdxxEntity, LqEventEntity, UserEntity>(
(tk, md, ev, user) => tk.StoreId == md.Id && tk.EventId == ev.Id && tk.ExpansionUserId == user.Id
)
.WhereIF(!string.IsNullOrEmpty(eventId), (tk, md, ev, user) => tk.EventId == eventId)
.WhereIF(endTime.HasValue, (tk, md, ev, user) => tk.ExpansionTime <= endTime.Value)
.Select((tk, md, ev, user) => new TkjlbExportModel
{
id = tk.Id,
expansionTime = tk.ExpansionTime,
expansionUserId = tk.ExpansionUserId,
expansionUserName = user.RealName,
customerName = tk.CustomerName,
customerPhone = tk.CustomerPhone,
buyNumber = tk.BuyNumber,
paymentMethod = tk.PaymentMethod,
isAddWeChat = tk.IsAddWeChat,
remarks = tk.Remarks,
storeId = tk.StoreId,
storeName = md.Dm,
teamName = tk.TeamName,
eventId = tk.EventId,
eventName = ev.EventName,
})
.MergeTable()
.OrderBy("expansionTime desc")
.ToListAsync();
return data;
}
#endregion
#region 导出拓客管理
/// <summary>
/// 导出拓客管理(固定字段,显示中文名称)
/// </summary>
/// <param name="eventId">活动编号(可选)</param>
/// <param name="endTime">截止时间(可选)</param>
/// <returns>导出文件信息</returns>
|
96009bc9
hexiaodong
hxd
|
314
|
[HttpGet("Actions/Export")]
|
9864a818
“wangming”
feat: 优化拓客管理功能
|
315
|
public async Task<dynamic> Export([FromQuery] string eventId = null, [FromQuery] DateTime? endTime = null)
|
96009bc9
hexiaodong
hxd
|
316
|
{
|
9864a818
“wangming”
feat: 优化拓客管理功能
|
317
|
try
|
96009bc9
hexiaodong
hxd
|
318
|
{
|
9864a818
“wangming”
feat: 优化拓客管理功能
|
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
|
var userInfo = await _userManager.GetUserInfo();
// 使用联合查询获取带中文名称的数据
var exportData = await GetTkjlbWithChineseNamesSimple(eventId, endTime);
// 检查数据是否为空
if (exportData == null || exportData.Count == 0)
{
return new { name = "拓客管理.xls", url = "", message = "没有找到符合条件的数据" };
}
// 固定导出字段
List<ParamsModel> paramList =
"[{\"value\":\"拓客编号\",\"field\":\"id\"},{\"value\":\"拓客时间\",\"field\":\"expansionTime\"},{\"value\":\"拓客人员ID\",\"field\":\"expansionUserId\"},{\"value\":\"拓客人员姓名\",\"field\":\"expansionUserName\"},{\"value\":\"顾客姓名\",\"field\":\"customerName\"},{\"value\":\"顾客电话\",\"field\":\"customerPhone\"},{\"value\":\"购买张数\",\"field\":\"buyNumber\"},{\"value\":\"支付方式\",\"field\":\"paymentMethod\"},{\"value\":\"是否加微信\",\"field\":\"isAddWeChat\"},{\"value\":\"备注\",\"field\":\"remarks\"},{\"value\":\"门店ID\",\"field\":\"storeId\"},{\"value\":\"门店名称\",\"field\":\"storeName\"},{\"value\":\"战队名称\",\"field\":\"teamName\"},{\"value\":\"活动ID\",\"field\":\"eventId\"},{\"value\":\"活动名称\",\"field\":\"eventName\"}]".ToList<ParamsModel>();
// 检查paramList是否为空
if (paramList == null || paramList.Count == 0)
|
96009bc9
hexiaodong
hxd
|
336
|
{
|
9864a818
“wangming”
feat: 优化拓客管理功能
|
337
|
return new { name = "拓客管理.xls", url = "", message = "参数列表解析失败" };
|
96009bc9
hexiaodong
hxd
|
338
|
}
|
9864a818
“wangming”
feat: 优化拓客管理功能
|
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
|
ExcelConfig excelconfig = new ExcelConfig();
excelconfig.FileName = "拓客管理" + DateTime.Now.ToString("yyyyMMddHHmmss") + ".xls";
excelconfig.HeadFont = "微软雅黑";
excelconfig.HeadPoint = 10;
excelconfig.IsAllSizeColumn = true;
excelconfig.ColumnModel = new List<ExcelColumnModel>();
// 固定字段列表
List<string> selectKeyList = new List<string> { "id", "expansionTime", "expansionUserId", "expansionUserName", "customerName", "customerPhone", "buyNumber", "paymentMethod", "isAddWeChat", "remarks", "storeId", "storeName", "teamName", "eventId", "eventName" };
foreach (var item in selectKeyList)
{
var isExist = paramList.Find(p => p.field == item);
if (isExist != null)
{
excelconfig.ColumnModel.Add(new ExcelColumnModel() { Column = isExist.field, ExcelColumn = isExist.value });
}
}
var addPath = FileVariable.TemporaryFilePath + excelconfig.FileName;
ExcelExportHelper<TkjlbExportModel>.Export(exportData, excelconfig, addPath);
var fileName = _userManager.UserId + "|" + excelconfig.FileName + "|temporary";
var output = new { name = excelconfig.FileName, url = "/api/File/Download?encryption=" + DESCEncryption.Encrypt(fileName, "NCC") };
return output;
}
catch (Exception ex)
{
return new { name = "拓客管理" + DateTime.Now.ToString("yyyyMMddHHmmss") + ".xls", url = "", message = $"导出失败: {ex.Message}", stackTrace = ex.StackTrace };
|
96009bc9
hexiaodong
hxd
|
368
|
}
|
96009bc9
hexiaodong
hxd
|
369
|
}
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
370
|
#endregion
|
c842ad9a
“wangming”
Remove analyze_ex...
|
371
|
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
372
|
#region 批量删除拓客管理
|
96009bc9
hexiaodong
hxd
|
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
|
/// <summary>
/// 批量删除拓客管理
/// </summary>
/// <param name="ids">主键数组</param>
/// <returns></returns>
[HttpPost("batchRemove")]
public async Task BatchRemove([FromBody] List<string> ids)
{
var entitys = await _db.Queryable<LqTkjlbEntity>().In(it => it.Id, ids).ToListAsync();
if (entitys.Count > 0)
{
try
{
//开启事务
_db.BeginTran();
//批量删除拓客管理
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
390
|
await _db.Deleteable<LqTkjlbEntity>().In(d => d.Id, ids).ExecuteCommandAsync();
|
96009bc9
hexiaodong
hxd
|
391
392
393
394
395
396
397
398
399
400
401
|
//关闭事务
_db.CommitTran();
}
catch (Exception)
{
//回滚事务
_db.RollbackTran();
throw NCCException.Oh(ErrorCode.COM1002);
}
}
}
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
402
|
#endregion
|
c842ad9a
“wangming”
Remove analyze_ex...
|
403
|
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
404
|
#region 更新拓客管理
|
96009bc9
hexiaodong
hxd
|
405
406
407
408
409
410
411
412
413
414
415
|
/// <summary>
/// 更新拓客管理
/// </summary>
/// <param name="id">主键</param>
/// <param name="input">参数</param>
/// <returns></returns>
[HttpPut("{id}")]
public async Task Update(string id, [FromBody] LqTkjlbUpInput input)
{
var entity = input.Adapt<LqTkjlbEntity>();
var isOk = await _db.Updateable(entity).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync();
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
416
417
|
if (!(isOk > 0))
throw NCCException.Oh(ErrorCode.COM1001);
|
96009bc9
hexiaodong
hxd
|
418
|
}
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
419
|
#endregion
|
c842ad9a
“wangming”
Remove analyze_ex...
|
420
|
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
421
|
#region 删除拓客管理
|
96009bc9
hexiaodong
hxd
|
422
423
424
425
426
427
428
429
430
431
|
/// <summary>
/// 删除拓客管理
/// </summary>
/// <returns></returns>
[HttpDelete("{id}")]
public async Task Delete(string id)
{
var entity = await _db.Queryable<LqTkjlbEntity>().FirstAsync(p => p.Id == id);
_ = entity ?? throw NCCException.Oh(ErrorCode.COM1005);
var isOk = await _db.Deleteable<LqTkjlbEntity>().Where(d => d.Id == id).ExecuteCommandAsync();
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
432
433
|
if (!(isOk > 0))
throw NCCException.Oh(ErrorCode.COM1002);
|
96009bc9
hexiaodong
hxd
|
434
|
}
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
435
|
#endregion
|
c842ad9a
“wangming”
Remove analyze_ex...
|
436
|
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
437
|
#region 获取拓客排行榜
|
96009bc9
hexiaodong
hxd
|
438
439
440
441
442
443
444
|
/// <summary>
/// 获取拓客排行榜
/// </summary>
/// <returns></returns>
[HttpGet("Actions/GetRanking")]
public async Task<dynamic> GetRanking()
{
|
b45d55f7
“wangming”
Refactor LqEventS...
|
445
446
447
448
|
var data = await _db.Queryable<LqTkjlbEntity>()
.GroupBy(it => it.TeamName)
.Select(it => new LqTkjlbRankingOutput { teamName = it.TeamName, expansionUserCount = SqlFunc.AggregateCount(it.Id) })
.ToListAsync();
|
96009bc9
hexiaodong
hxd
|
449
450
|
// 在内存中排序并添加排名
|
b45d55f7
“wangming”
Refactor LqEventS...
|
451
|
var sortedData = data.OrderByDescending(it => it.expansionUserCount).ToList();
|
96009bc9
hexiaodong
hxd
|
452
453
454
455
456
457
458
|
for (int i = 0; i < sortedData.Count; i++)
{
sortedData[i].ranking = i + 1;
}
return sortedData;
}
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
459
|
#endregion
|
c842ad9a
“wangming”
Remove analyze_ex...
|
460
|
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
461
|
#region 获取战队人员详细报表
|
96009bc9
hexiaodong
hxd
|
462
463
464
465
466
467
468
469
470
471
|
/// <summary>
/// 获取战队人员详细报表
/// </summary>
/// <returns></returns>
[HttpGet("Actions/GetTeamDetail")]
public async Task<dynamic> GetTeamDetail()
{
var result = new List<LqTkjlbTeamDetailOutput>();
// 获取所有战队
|
b45d55f7
“wangming”
Refactor LqEventS...
|
472
|
var teams = await _db.Queryable<LqTkjlbEntity>().GroupBy(it => it.TeamName).Select(it => it.TeamName).ToListAsync();
|
96009bc9
hexiaodong
hxd
|
473
474
475
476
477
|
foreach (var team in teams)
{
// 获取该战队所有人员的拓客数据
var teamMembers = await _db.Queryable<LqTkjlbEntity>()
|
b45d55f7
“wangming”
Refactor LqEventS...
|
478
479
|
.Where(it => it.TeamName == team)
.GroupBy(it => it.ExpansionUserId)
|
96009bc9
hexiaodong
hxd
|
480
481
|
.Select(it => new
{
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
482
|
// tkry = it.Tkry,
|
b45d55f7
“wangming”
Refactor LqEventS...
|
483
|
tkry = SqlFunc.Subqueryable<UserEntity>().Where(u => u.Id == it.ExpansionUserId).Select(u => u.RealName),
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
484
|
tkrs = SqlFunc.AggregateCount(it.Id),
|
96009bc9
hexiaodong
hxd
|
485
486
487
488
489
|
})
.ToListAsync();
// 按拓客数量排序
var sortedMembers = teamMembers.OrderByDescending(m => m.tkrs).ToList();
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
490
|
|
96009bc9
hexiaodong
hxd
|
491
492
493
494
495
496
497
498
|
// 计算战队总拓客数量
var totalCount = sortedMembers.Sum(m => m.tkrs);
// 构建战队详情
var teamDetail = new LqTkjlbTeamDetailOutput
{
sszd = team,
totalCount = totalCount,
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
499
|
members = new List<TeamMemberDetail>(),
|
96009bc9
hexiaodong
hxd
|
500
501
502
503
504
505
506
|
};
// 添加成员详情
for (int i = 0; i < sortedMembers.Count; i++)
{
var member = sortedMembers[i];
var percentage = totalCount > 0 ? (int)Math.Round((double)member.tkrs / totalCount * 100) : 0;
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
507
508
509
510
511
512
513
514
515
516
|
teamDetail.members.Add(
new TeamMemberDetail
{
tkry = member.tkry,
tkrs = member.tkrs,
teamRanking = i + 1,
percentage = percentage,
}
);
|
96009bc9
hexiaodong
hxd
|
517
518
519
520
521
522
523
524
|
}
result.Add(teamDetail);
}
// 按战队总拓客数量排序
return result.OrderByDescending(t => t.totalCount).ToList();
}
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
525
|
#endregion
|
96009bc9
hexiaodong
hxd
|
526
527
|
}
}
|