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
|
using NCC.Extend.Entitys.lq_eventuser;
|
2164125c
“wangming”
feat: 删除LqXhmxb相关...
|
22
|
using NCC.Extend.Entitys.lq_kd_kdjlb;
|
920afb29
“wangming”
修改了一摩尔的东西,我一个人在客户...
|
23
|
using NCC.Extend.Entitys.lq_khxx;
|
41da4257
“wangming”
Refactor LqEventS...
|
24
|
using NCC.Extend.Entitys.lq_mdxx;
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
25
26
27
|
using NCC.Extend.Entitys.lq_tkjlb;
using NCC.Extend.Interfaces.LqTkjlb;
using NCC.FriendlyException;
|
96009bc9
hexiaodong
hxd
|
28
|
using NCC.JsonSerialization;
|
96009bc9
hexiaodong
hxd
|
29
|
using NCC.System.Entitys.Permission;
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
30
31
|
using SqlSugar;
using Yitter.IdGenerator;
|
96009bc9
hexiaodong
hxd
|
32
33
34
35
36
37
|
namespace NCC.Extend.LqTkjlb
{
/// <summary>
/// 拓客管理服务
/// </summary>
|
b45d55f7
“wangming”
Refactor LqEventS...
|
38
|
[ApiDescriptionSettings(Tag = "绿纤拓客管理服务", Name = "LqTkjlb", Order = 200)]
|
96009bc9
hexiaodong
hxd
|
39
40
41
42
43
44
45
46
47
48
|
[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...
|
49
|
public LqTkjlbService(ISqlSugarRepository<LqTkjlbEntity> lqTkjlbRepository, IUserManager userManager)
|
96009bc9
hexiaodong
hxd
|
50
|
{
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
51
|
_lqTkjlbRepository = lqTkjlbRepository;
|
96009bc9
hexiaodong
hxd
|
52
53
54
55
|
_db = _lqTkjlbRepository.Context;
_userManager = userManager;
}
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
56
|
#region 获取拓客管理
|
96009bc9
hexiaodong
hxd
|
57
58
59
60
61
62
63
64
|
/// <summary>
/// 获取拓客管理
/// </summary>
/// <param name="id">参数</param>
/// <returns></returns>
[HttpGet("{id}")]
public async Task<dynamic> GetInfo(string id)
{
|
b45d55f7
“wangming”
Refactor LqEventS...
|
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
|
// 使用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),
|
2164125c
“wangming”
feat: 删除LqXhmxb相关...
|
84
|
storeName = SqlFunc.Subqueryable<LqMdxxEntity>().Where(u => u.Id == p.StoreId).Select(u => u.Dm)
|
b45d55f7
“wangming”
Refactor LqEventS...
|
85
86
87
88
|
})
.FirstAsync();
return result;
|
96009bc9
hexiaodong
hxd
|
89
|
}
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
90
|
#endregion
|
c842ad9a
“wangming”
Remove analyze_ex...
|
91
|
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
92
|
#region 获取拓客管理列表
|
96009bc9
hexiaodong
hxd
|
93
94
|
/// <summary>
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
95
96
97
98
|
/// 获取拓客管理列表
/// </summary>
/// <param name="input">请求参数</param>
/// <returns></returns>
|
96009bc9
hexiaodong
hxd
|
99
100
101
102
|
[HttpGet("")]
public async Task<dynamic> GetList([FromQuery] LqTkjlbListQueryInput input)
{
var sidx = input.sidx == null ? "id" : input.sidx;
|
b45d55f7
“wangming”
Refactor LqEventS...
|
103
|
List<string> queryTksj = input.expansionTime != null ? input.expansionTime.Split(',').ToObeject<List<string>>() : null;
|
96009bc9
hexiaodong
hxd
|
104
105
106
107
|
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...
|
108
109
110
111
112
113
114
115
116
117
118
119
|
.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...
|
120
|
.Select(it => new LqTkjlbListOutput
|
96009bc9
hexiaodong
hxd
|
121
122
|
{
id = it.Id,
|
b45d55f7
“wangming”
Refactor LqEventS...
|
123
124
|
expansionTime = it.ExpansionTime,
expansionUserId = it.ExpansionUserId,
|
1e118117
“wangming”
新增历史会员权益数据导入功能
|
125
|
expansionUserName = SqlFunc.Subqueryable<UserEntity>().Where(u => u.Id == it.ExpansionUserId).Select(u => u.RealName),
|
b45d55f7
“wangming”
Refactor LqEventS...
|
126
127
128
129
130
131
132
|
customerName = it.CustomerName,
customerPhone = it.CustomerPhone,
buyNumber = it.BuyNumber,
paymentMethod = it.PaymentMethod,
isAddWeChat = it.IsAddWeChat,
remarks = it.Remarks,
storeId = it.StoreId,
|
7f83b333
“wangming”
重构:删除部门管理模块并修复预约记录服务
|
133
|
storeName = SqlFunc.Subqueryable<LqMdxxEntity>().Where(u => u.Id == it.StoreId).Select(u => u.Dm),
|
b45d55f7
“wangming”
Refactor LqEventS...
|
134
|
teamName = it.TeamName,
|
d98270e2
“wangming”
Enhance LqEventSe...
|
135
136
|
eventId = it.EventId,
eventName = SqlFunc.Subqueryable<LqEventEntity>().Where(u => u.Id == it.EventId).Select(u => u.EventName),
|
9864a818
“wangming”
feat: 优化拓客管理功能
|
137
138
|
depId = it.DepId,
depName = SqlFunc.Subqueryable<OrganizeEntity>().Where(u => u.Id == it.DepId).Select(u => u.FullName),
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
139
140
141
142
143
|
})
.MergeTable()
.OrderBy(sidx + " " + input.sort)
.ToPagedListAsync(input.currentPage, input.pageSize);
return PageResult<LqTkjlbListOutput>.SqlSugarPageResult(data);
|
96009bc9
hexiaodong
hxd
|
144
|
}
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
145
|
#endregion
|
c842ad9a
“wangming”
Remove analyze_ex...
|
146
|
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
147
|
#region 新建拓客管理
|
96009bc9
hexiaodong
hxd
|
148
149
150
151
152
153
|
/// <summary>
/// 新建拓客管理
/// </summary>
/// <param name="input">参数</param>
/// <returns></returns>
[HttpPost("")]
|
41da4257
“wangming”
Refactor LqEventS...
|
154
|
public async Task<dynamic> Create([FromBody] LqTkjlbCrInput input)
|
96009bc9
hexiaodong
hxd
|
155
156
|
{
var userInfo = await _userManager.GetUserInfo();
|
920afb29
“wangming”
修改了一摩尔的东西,我一个人在客户...
|
157
|
//通过input.dhhm去查询用户信息
|
b45d55f7
“wangming”
Refactor LqEventS...
|
158
|
var user = _db.Queryable<LqKhxxEntity>().Where(u => u.Sjh == input.customerPhone).Any();
|
920afb29
“wangming”
修改了一摩尔的东西,我一个人在客户...
|
159
|
if (user)
|
96009bc9
hexiaodong
hxd
|
160
|
{
|
41da4257
“wangming”
Refactor LqEventS...
|
161
|
return NCCException.Oh("该手机号码已存在于会员或线索池中");
|
96009bc9
hexiaodong
hxd
|
162
|
}
|
920afb29
“wangming”
修改了一摩尔的东西,我一个人在客户...
|
163
164
165
166
|
// 使用事务确保数据一致性
var result = await _db.Ado.UseTranAsync(async () =>
{
//通过input.eventId去查询拓客活动信息
|
b45d55f7
“wangming”
Refactor LqEventS...
|
167
|
var eventUserInfoList = await _db.Queryable<LqEventUserEntity>().Where(u => u.EventId == input.eventId && u.UserId == input.expansionUserId).ToListAsync();
|
d98270e2
“wangming”
Enhance LqEventSe...
|
168
169
170
171
172
|
if (eventUserInfoList == null || eventUserInfoList.Count == 0)
{
throw NCCException.Oh("未找到对应的拓客活动用户信息,请确认活动ID和用户ID是否正确");
}
var eventUserInfo = eventUserInfoList.First();
|
920afb29
“wangming”
修改了一摩尔的东西,我一个人在客户...
|
173
174
175
|
// 创建拓客记录
var entity = input.Adapt<LqTkjlbEntity>();
entity.Id = YitIdHelper.NextId().ToString();
|
b45d55f7
“wangming”
Refactor LqEventS...
|
176
177
178
179
|
entity.TeamName = eventUserInfo.TeamName;
entity.StoreId = eventUserInfo.StoreId;
entity.DepId = eventUserInfo.DepId;
entity.ExpansionTime = DateTime.Now;
|
920afb29
“wangming”
修改了一摩尔的东西,我一个人在客户...
|
180
181
182
183
184
185
|
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...
|
186
187
|
MemberInfo.Khmc = entity.CustomerName;
MemberInfo.Sjh = input.customerPhone; // 设置手机号
|
759f9f27
“wangming”
123321
|
188
|
MemberInfo.Khlx = MemberTypeEnum.线索.GetHashCode().ToString();
|
ce74473f
“wangming”
feat: 新增门店类别枚举和耗卡...
|
189
|
MemberInfo.Dah = "LQ" + DateTime.Now.ToString("yyyyMMddHHmmssfff");
|
1e118117
“wangming”
新增历史会员权益数据导入功能
|
190
|
MemberInfo.Jdqd = "19.9卡";
|
2164125c
“wangming”
feat: 删除LqXhmxb相关...
|
191
|
|
0380c57d
“wangming”
修复项目编译错误和优化功能
|
192
193
|
//找到input.expansionUserId的用户信息
var userInfo = await _db.Queryable<UserEntity>().Where(u => u.Id == input.expansionUserId).FirstAsync();
|
150862dd
“wangming”
修复GetInfo方法中的空值处理问题
|
194
|
//判断 岗位是否为健康师,如果是健康师,则设置拓客人员是健康师
|
e5e15bcb
“wangming”
优化系统功能和性能
|
195
|
MemberInfo.ExpandUser = input.expansionUserId;
|
0b87d248
“wangming”
Enhance LqEventSe...
|
196
|
MemberInfo.Gsmd = eventUserInfo.StoreId;
|
920afb29
“wangming”
修改了一摩尔的东西,我一个人在客户...
|
197
198
|
var memberResult = await _db.Insertable(MemberInfo).IgnoreColumns(ignoreNullColumn: true).ExecuteCommandAsync();
if (!(memberResult > 0))
|
41da4257
“wangming”
Refactor LqEventS...
|
199
|
{
|
920afb29
“wangming”
修改了一摩尔的东西,我一个人在客户...
|
200
|
throw NCCException.Oh("创建客户信息失败");
|
41da4257
“wangming”
Refactor LqEventS...
|
201
202
203
|
}
var storeinfo = await _db.Queryable<LqMdxxEntity>().Where(u => u.Id == eventUserInfo.StoreId).FirstAsync();
return new { entity = entity, storeinfo = storeinfo };
|
920afb29
“wangming”
修改了一摩尔的东西,我一个人在客户...
|
204
|
});
|
96009bc9
hexiaodong
hxd
|
205
|
|
920afb29
“wangming”
修改了一摩尔的东西,我一个人在客户...
|
206
207
|
if (!result.IsSuccess)
{
|
41da4257
“wangming”
Refactor LqEventS...
|
208
|
return NCCException.Oh($"创建拓客记录失败:{result.ErrorMessage}");
|
920afb29
“wangming”
修改了一摩尔的东西,我一个人在客户...
|
209
|
}
|
41da4257
“wangming”
Refactor LqEventS...
|
210
|
return result.Data;
|
96009bc9
hexiaodong
hxd
|
211
|
}
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
212
|
#endregion
|
c842ad9a
“wangming”
Remove analyze_ex...
|
213
|
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
214
|
#region 获取拓客管理无分页列表
|
96009bc9
hexiaodong
hxd
|
215
|
/// <summary>
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
216
217
218
219
|
/// 获取拓客管理无分页列表
/// </summary>
/// <param name="input">请求参数</param>
/// <returns></returns>
|
96009bc9
hexiaodong
hxd
|
220
221
222
223
|
[NonAction]
public async Task<dynamic> GetNoPagingList([FromQuery] LqTkjlbListQueryInput input)
{
var sidx = input.sidx == null ? "id" : input.sidx;
|
b45d55f7
“wangming”
Refactor LqEventS...
|
224
225
226
|
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
|
227
228
|
var data = await _db.Queryable<LqTkjlbEntity>()
.WhereIF(!string.IsNullOrEmpty(input.id), p => p.Id.Contains(input.id))
|
b45d55f7
“wangming”
Refactor LqEventS...
|
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
|
.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...
|
244
|
.Select(it => new LqTkjlbListOutput
|
96009bc9
hexiaodong
hxd
|
245
246
|
{
id = it.Id,
|
b45d55f7
“wangming”
Refactor LqEventS...
|
247
248
249
250
251
252
253
254
255
256
257
258
259
|
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...
|
260
261
262
263
264
|
})
.MergeTable()
.OrderBy(sidx + " " + input.sort)
.ToListAsync();
return data;
|
96009bc9
hexiaodong
hxd
|
265
|
}
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
266
|
#endregion
|
c842ad9a
“wangming”
Remove analyze_ex...
|
267
|
|
9864a818
“wangming”
feat: 优化拓客管理功能
|
268
|
#region 获取拓客管理带中文名称的数据(简化版)
|
96009bc9
hexiaodong
hxd
|
269
|
/// <summary>
|
9864a818
“wangming”
feat: 优化拓客管理功能
|
270
|
/// 获取拓客管理带中文名称的数据(简化版,用于导出)
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
271
|
/// </summary>
|
9864a818
“wangming”
feat: 优化拓客管理功能
|
272
273
|
/// <param name="eventId">活动编号(可选)</param>
/// <param name="endTime">截止时间(可选)</param>
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
274
|
/// <returns></returns>
|
9864a818
“wangming”
feat: 优化拓客管理功能
|
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
314
315
|
[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
|
316
|
[HttpGet("Actions/Export")]
|
9864a818
“wangming”
feat: 优化拓客管理功能
|
317
|
public async Task<dynamic> Export([FromQuery] string eventId = null, [FromQuery] DateTime? endTime = null)
|
96009bc9
hexiaodong
hxd
|
318
|
{
|
9864a818
“wangming”
feat: 优化拓客管理功能
|
319
|
try
|
96009bc9
hexiaodong
hxd
|
320
|
{
|
9864a818
“wangming”
feat: 优化拓客管理功能
|
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
|
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
|
338
|
{
|
9864a818
“wangming”
feat: 优化拓客管理功能
|
339
|
return new { name = "拓客管理.xls", url = "", message = "参数列表解析失败" };
|
96009bc9
hexiaodong
hxd
|
340
|
}
|
9864a818
“wangming”
feat: 优化拓客管理功能
|
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
368
369
|
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
|
370
|
}
|
96009bc9
hexiaodong
hxd
|
371
|
}
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
372
|
#endregion
|
c842ad9a
“wangming”
Remove analyze_ex...
|
373
|
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
374
|
#region 批量删除拓客管理
|
96009bc9
hexiaodong
hxd
|
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
|
/// <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...
|
392
|
await _db.Deleteable<LqTkjlbEntity>().In(d => d.Id, ids).ExecuteCommandAsync();
|
96009bc9
hexiaodong
hxd
|
393
394
395
396
397
398
399
400
401
402
403
|
//关闭事务
_db.CommitTran();
}
catch (Exception)
{
//回滚事务
_db.RollbackTran();
throw NCCException.Oh(ErrorCode.COM1002);
}
}
}
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
404
|
#endregion
|
c842ad9a
“wangming”
Remove analyze_ex...
|
405
|
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
406
|
#region 更新拓客管理
|
96009bc9
hexiaodong
hxd
|
407
408
409
410
411
412
413
414
415
416
417
|
/// <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...
|
418
419
|
if (!(isOk > 0))
throw NCCException.Oh(ErrorCode.COM1001);
|
96009bc9
hexiaodong
hxd
|
420
|
}
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
421
|
#endregion
|
c842ad9a
“wangming”
Remove analyze_ex...
|
422
|
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
423
|
#region 删除拓客管理
|
96009bc9
hexiaodong
hxd
|
424
425
426
427
428
429
430
431
432
433
|
/// <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...
|
434
435
|
if (!(isOk > 0))
throw NCCException.Oh(ErrorCode.COM1002);
|
96009bc9
hexiaodong
hxd
|
436
|
}
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
437
|
#endregion
|
c842ad9a
“wangming”
Remove analyze_ex...
|
438
|
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
439
|
#region 获取拓客排行榜
|
96009bc9
hexiaodong
hxd
|
440
441
442
443
444
445
446
|
/// <summary>
/// 获取拓客排行榜
/// </summary>
/// <returns></returns>
[HttpGet("Actions/GetRanking")]
public async Task<dynamic> GetRanking()
{
|
b45d55f7
“wangming”
Refactor LqEventS...
|
447
448
449
450
|
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
|
451
452
|
// 在内存中排序并添加排名
|
b45d55f7
“wangming”
Refactor LqEventS...
|
453
|
var sortedData = data.OrderByDescending(it => it.expansionUserCount).ToList();
|
96009bc9
hexiaodong
hxd
|
454
455
456
457
458
459
460
|
for (int i = 0; i < sortedData.Count; i++)
{
sortedData[i].ranking = i + 1;
}
return sortedData;
}
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
461
|
#endregion
|
c842ad9a
“wangming”
Remove analyze_ex...
|
462
|
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
463
|
#region 获取战队人员详细报表
|
96009bc9
hexiaodong
hxd
|
464
465
466
467
468
469
470
471
472
473
|
/// <summary>
/// 获取战队人员详细报表
/// </summary>
/// <returns></returns>
[HttpGet("Actions/GetTeamDetail")]
public async Task<dynamic> GetTeamDetail()
{
var result = new List<LqTkjlbTeamDetailOutput>();
// 获取所有战队
|
b45d55f7
“wangming”
Refactor LqEventS...
|
474
|
var teams = await _db.Queryable<LqTkjlbEntity>().GroupBy(it => it.TeamName).Select(it => it.TeamName).ToListAsync();
|
96009bc9
hexiaodong
hxd
|
475
476
477
478
479
|
foreach (var team in teams)
{
// 获取该战队所有人员的拓客数据
var teamMembers = await _db.Queryable<LqTkjlbEntity>()
|
b45d55f7
“wangming”
Refactor LqEventS...
|
480
481
|
.Where(it => it.TeamName == team)
.GroupBy(it => it.ExpansionUserId)
|
96009bc9
hexiaodong
hxd
|
482
483
|
.Select(it => new
{
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
484
|
// tkry = it.Tkry,
|
b45d55f7
“wangming”
Refactor LqEventS...
|
485
|
tkry = SqlFunc.Subqueryable<UserEntity>().Where(u => u.Id == it.ExpansionUserId).Select(u => u.RealName),
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
486
|
tkrs = SqlFunc.AggregateCount(it.Id),
|
96009bc9
hexiaodong
hxd
|
487
488
489
490
491
|
})
.ToListAsync();
// 按拓客数量排序
var sortedMembers = teamMembers.OrderByDescending(m => m.tkrs).ToList();
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
492
|
|
96009bc9
hexiaodong
hxd
|
493
494
495
496
497
498
499
500
|
// 计算战队总拓客数量
var totalCount = sortedMembers.Sum(m => m.tkrs);
// 构建战队详情
var teamDetail = new LqTkjlbTeamDetailOutput
{
sszd = team,
totalCount = totalCount,
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
501
|
members = new List<TeamMemberDetail>(),
|
96009bc9
hexiaodong
hxd
|
502
503
504
505
506
507
508
|
};
// 添加成员详情
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...
|
509
510
511
512
513
514
515
516
517
518
|
teamDetail.members.Add(
new TeamMemberDetail
{
tkry = member.tkry,
tkrs = member.tkrs,
teamRanking = i + 1,
percentage = percentage,
}
);
|
96009bc9
hexiaodong
hxd
|
519
520
521
522
523
524
525
526
|
}
result.Add(teamDetail);
}
// 按战队总拓客数量排序
return result.OrderByDescending(t => t.totalCount).ToList();
}
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
527
|
#endregion
|
2164125c
“wangming”
feat: 删除LqXhmxb相关...
|
528
|
|
96009bc9
hexiaodong
hxd
|
529
530
|
}
}
|