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
  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
      }
  }