Blame view

netcore/src/Modularity/Extend/NCC.Extend/LqTkjlbService.cs 25.3 KB
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
      }
  }