Blame view

netcore/src/Modularity/Extend/NCC.Extend/LqHytkHytkService.cs 26.2 KB
00486d53   “wangming”   更新多个.DS_Store文件,优...
1
2
3
4
5
6
7
8
  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;
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
9
  using NCC.Common.Core.Manager;
96009bc9   hexiaodong   hxd
10
11
12
  using NCC.Common.Enum;
  using NCC.Common.Extension;
  using NCC.Common.Filter;
00486d53   “wangming”   更新多个.DS_Store文件,优...
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.LqHytkHytk;
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
19
20
  using NCC.Extend.Entitys.Dto.LqHytkJksyj;
  using NCC.Extend.Entitys.Dto.LqHytkKjbsyj;
00486d53   “wangming”   更新多个.DS_Store文件,优...
21
22
23
24
25
26
27
  using NCC.Extend.Entitys.Dto.LqHytkMx;
  using NCC.Extend.Entitys.lq_hytk_hytk;
  using NCC.Extend.Entitys.lq_hytk_jksyj;
  using NCC.Extend.Entitys.lq_hytk_kjbsyj;
  using NCC.Extend.Entitys.lq_hytk_mx;
  using NCC.Extend.Interfaces.LqHytkHytk;
  using NCC.FriendlyException;
96009bc9   hexiaodong   hxd
28
  using NCC.JsonSerialization;
00486d53   “wangming”   更新多个.DS_Store文件,优...
29
30
  using SqlSugar;
  using Yitter.IdGenerator;
96009bc9   hexiaodong   hxd
31
32
33
34
  
  namespace NCC.Extend.LqHytkHytk
  {
      /// <summary>
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
35
      /// 退卡_信息表服务
96009bc9   hexiaodong   hxd
36
      /// </summary>
00486d53   “wangming”   更新多个.DS_Store文件,优...
37
      [ApiDescriptionSettings(Tag = "绿纤退卡信息表服务", Name = "LqHytkHytk", Order = 200)]
96009bc9   hexiaodong   hxd
38
39
40
41
42
      [Route("api/Extend/[controller]")]
      public class LqHytkHytkService : ILqHytkHytkService, IDynamicApiController, ITransient
      {
          private readonly ISqlSugarRepository<LqHytkHytkEntity> _lqHytkHytkRepository;
          private readonly ISqlSugarRepository<LqHytkMxEntity> _lqHytkMxRepository;
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
43
44
          private readonly ISqlSugarRepository<LqHytkJksyjEntity> _lqHytkJksyjRepository;
          private readonly ISqlSugarRepository<LqHytkKjbsyjEntity> _lqHytkKjbsyjRepository;
96009bc9   hexiaodong   hxd
45
46
47
48
49
50
51
52
53
          private readonly SqlSugarScope _db;
          private readonly IUserManager _userManager;
  
          /// <summary>
          /// 初始化一个<see cref="LqHytkHytkService"/>类型的新实例
          /// </summary>
          public LqHytkHytkService(
              ISqlSugarRepository<LqHytkHytkEntity> lqHytkHytkRepository,
              ISqlSugarRepository<LqHytkMxEntity> lqHytkMxRepository,
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
54
55
              ISqlSugarRepository<LqHytkJksyjEntity> lqHytkJksyjRepository,
              ISqlSugarRepository<LqHytkKjbsyjEntity> lqHytkKjbsyjRepository,
00486d53   “wangming”   更新多个.DS_Store文件,优...
56
57
              IUserManager userManager
          )
96009bc9   hexiaodong   hxd
58
          {
00486d53   “wangming”   更新多个.DS_Store文件,优...
59
              _lqHytkHytkRepository = lqHytkHytkRepository;
96009bc9   hexiaodong   hxd
60
              _lqHytkMxRepository = lqHytkMxRepository;
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
61
62
63
              _lqHytkJksyjRepository = lqHytkJksyjRepository;
              _lqHytkKjbsyjRepository = lqHytkKjbsyjRepository;
              _db = _lqHytkHytkRepository.Context;
96009bc9   hexiaodong   hxd
64
65
66
              _userManager = userManager;
          }
  
0ef47194   “wangming”   Refactor LqHytkHy...
67
          #region 获取退卡信息列表
96009bc9   hexiaodong   hxd
68
          /// <summary>
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
69
          /// 获取退卡信息列表
96009bc9   hexiaodong   hxd
70
          /// </summary>
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
71
          /// <param name="input">查询参数</param>
00486d53   “wangming”   更新多个.DS_Store文件,优...
72
          /// <returns></returns>
96009bc9   hexiaodong   hxd
73
74
75
76
          [HttpGet("")]
          public async Task<dynamic> GetList([FromQuery] LqHytkHytkListQueryInput input)
          {
              var sidx = input.sidx == null ? "id" : input.sidx;
0ef47194   “wangming”   Refactor LqHytkHy...
77
              List<string> queryTksj = input.tksj != null ? input.tksj.Split(',').ToObeject<List<string>>() : null;
96009bc9   hexiaodong   hxd
78
79
80
81
82
              DateTime? startTksj = queryTksj != null ? Ext.GetDateTime(queryTksj.First()) : null;
              DateTime? endTksj = queryTksj != null ? Ext.GetDateTime(queryTksj.Last()) : null;
              var data = await _db.Queryable<LqHytkHytkEntity>()
                  .WhereIF(!string.IsNullOrEmpty(input.id), p => p.Id.Contains(input.id))
                  .WhereIF(!string.IsNullOrEmpty(input.md), p => p.Md.Equals(input.md))
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
83
                  .WhereIF(!string.IsNullOrEmpty(input.mdbh), p => p.Mdbh.Contains(input.mdbh))
96009bc9   hexiaodong   hxd
84
85
                  .WhereIF(!string.IsNullOrEmpty(input.mdmc), p => p.Mdmc.Contains(input.mdmc))
                  .WhereIF(!string.IsNullOrEmpty(input.hy), p => p.Hy.Equals(input.hy))
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
86
                  .WhereIF(!string.IsNullOrEmpty(input.hymc), p => p.Hymc.Contains(input.hymc))
96009bc9   hexiaodong   hxd
87
                  .WhereIF(!string.IsNullOrEmpty(input.hyzh), p => p.Hyzh.Contains(input.hyzh))
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
88
89
90
                  .WhereIF(!string.IsNullOrEmpty(input.gklx), p => p.Gklx.Contains(input.gklx))
                  .WhereIF(input.tkje.HasValue, p => p.Tkje == input.tkje)
                  .WhereIF(input.sgfy.HasValue, p => p.Sgfy == input.sgfy)
96009bc9   hexiaodong   hxd
91
                  .WhereIF(!string.IsNullOrEmpty(input.bz), p => p.Bz.Contains(input.bz))
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
92
93
                  .WhereIF(!string.IsNullOrEmpty(input.tkzt), p => p.Tkzt.Contains(input.tkzt))
                  .WhereIF(!string.IsNullOrEmpty(input.tkyy), p => p.Tkyy.Contains(input.tkyy))
0ef47194   “wangming”   Refactor LqHytkHy...
94
95
96
                  .WhereIF(!string.IsNullOrEmpty(input.fileUrl), p => p.FileUrl.Contains(input.fileUrl))
                  .WhereIF(queryTksj != null, p => p.Tksj >= new DateTime(startTksj.ToDate().Year, startTksj.ToDate().Month, startTksj.ToDate().Day, 0, 0, 0))
                  .WhereIF(queryTksj != null, p => p.Tksj <= new DateTime(endTksj.ToDate().Year, endTksj.ToDate().Month, endTksj.ToDate().Day, 23, 59, 59))
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
97
                  .WhereIF(!string.IsNullOrEmpty(input.czry), p => p.Czry.Equals(input.czry))
00486d53   “wangming”   更新多个.DS_Store文件,优...
98
                  .Select(it => new LqHytkHytkListOutput
96009bc9   hexiaodong   hxd
99
100
                  {
                      id = it.Id,
00486d53   “wangming”   更新多个.DS_Store文件,优...
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
                      md = it.Md,
                      mdbh = it.Mdbh,
                      mdmc = it.Mdmc,
                      hy = it.Hy,
                      hymc = it.Hymc,
                      hyzh = it.Hyzh,
                      gklx = it.Gklx,
                      tkje = it.Tkje,
                      sgfy = it.Sgfy,
                      bz = it.Bz,
                      tkzt = it.Tkzt,
                      tkyy = it.Tkyy,
                      tksj = it.Tksj,
                      czry = it.Czry,
                      fileUrl = it.FileUrl,
                  })
                  .MergeTable()
                  .OrderBy(sidx + " " + input.sort)
                  .ToPagedListAsync(input.currentPage, input.pageSize);
              return PageResult<LqHytkHytkListOutput>.SqlSugarPageResult(data);
96009bc9   hexiaodong   hxd
121
          }
0ef47194   “wangming”   Refactor LqHytkHy...
122
          #endregion
96009bc9   hexiaodong   hxd
123
  
0ef47194   “wangming”   Refactor LqHytkHy...
124
          #region 创建退卡信息及其关联的品项明细、健康师业绩、科技部老师业绩信息
96009bc9   hexiaodong   hxd
125
          /// <summary>
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
126
          /// 创建退卡信息及其关联的品项明细、健康师业绩、科技部老师业绩信息
96009bc9   hexiaodong   hxd
127
          /// </summary>
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
128
129
          /// <remarks>
          /// 创建退卡记录及其关联的品项明细、健康师业绩、科技部老师业绩信息
00486d53   “wangming”   更新多个.DS_Store文件,优...
130
          ///
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
          /// 示例请求:
          /// ```json
          /// {
          ///   "md": "门店ID",
          ///   "mdbh": "门店编号",
          ///   "mdmc": "门店名称",
          ///   "hy": "会员ID",
          ///   "hymc": "会员姓名",
          ///   "hyzh": "会员账号",
          ///   "gklx": "顾客类型",
          ///   "tkje": 1000.00,
          ///   "sgfy": 50.00,
          ///   "bz": "备注",
          ///   "tkzt": "退卡状态",
          ///   "tkyy": "退卡原因",
          ///   "lqHytkMxList": [
          ///     {
          ///       "px": "品项编号",
          ///       "pxmc": "品项名称",
          ///       "pxjg": 100.00,
          ///       "tkje": 100.00,
          ///       "F_ProjectNumber": 1,
          ///       "F_SourceType": "来源类型",
          ///       "F_TotalPrice": 100.00,
          ///       "lqHytkJksyjList": [
          ///         {
          ///           "jks": "健康师",
          ///           "jksxm": "健康师姓名",
          ///           "jkszh": "健康师账号",
          ///           "jksyj": 50.00,
          ///           "F_jsjid": "金三角ID",
          ///           "F_tkpxid": "项目资料ID",
          ///           "F_LaborCost": 10.00,
          ///           "F_tkpxNumber": 1
          ///         }
          ///       ],
          ///       "lqHytkKjbsyjList": [
          ///         {
          ///           "kjbls": "科技部老师",
          ///           "kjblsxm": "科技部老师姓名",
          ///           "kjblszh": "科技部老师账号",
          ///           "kjblsyj": 30.00,
          ///           "F_tkpxid": "项目资料ID",
          ///           "F_LaborCost": 5.00,
          ///           "F_tkpxNumber": 1
          ///         }
          ///       ]
          ///     }
          ///   ]
          /// }
          /// ```
00486d53   “wangming”   更新多个.DS_Store文件,优...
182
          ///
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
183
184
185
186
187
188
189
190
191
192
          /// 参数说明:
          /// - md: 门店ID
          /// - hy: 会员ID
          /// - lqHytkMxList: 退卡品项明细列表
          /// </remarks>
          /// <param name="input">退卡创建参数</param>
          /// <returns>无返回值</returns>
          /// <response code="200">创建成功</response>
          /// <response code="400">参数错误或数据验证失败</response>
          /// <response code="500">服务器内部错误</response>
96009bc9   hexiaodong   hxd
193
194
195
196
197
198
          [HttpPost("")]
          public async Task Create([FromBody] LqHytkHytkCrInput input)
          {
              var userInfo = await _userManager.GetUserInfo();
              var entity = input.Adapt<LqHytkHytkEntity>();
              entity.Id = YitIdHelper.NextId().ToString();
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
199
200
201
              entity.F_CreateTime = DateTime.Now;
              entity.F_CreateUser = userInfo.userId;
              entity.F_DeleteMark = 0;
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
202
              entity.Czry = userInfo.userId;
00486d53   “wangming”   更新多个.DS_Store文件,优...
203
  
96009bc9   hexiaodong   hxd
204
205
              try
              {
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
206
                  // 开启事务
96009bc9   hexiaodong   hxd
207
                  _db.BeginTran();
00486d53   “wangming”   更新多个.DS_Store文件,优...
208
  
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
209
                  // 新增退卡主表记录
0ef47194   “wangming”   Refactor LqHytkHy...
210
                  var newEntity = await _db.Insertable(entity).IgnoreColumns(ignoreNullColumn: true).ExecuteReturnEntityAsync();
96009bc9   hexiaodong   hxd
211
  
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
212
213
214
215
                  // 收集所有需要插入的实体,然后批量插入
                  var allMxEntities = new List<LqHytkMxEntity>();
                  var allJksyjEntities = new List<LqHytkJksyjEntity>();
                  var allKjbsyjEntities = new List<LqHytkKjbsyjEntity>();
00486d53   “wangming”   更新多个.DS_Store文件,优...
216
  
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
217
218
                  // 处理品项明细列表
                  if (input.lqHytkMxList != null && input.lqHytkMxList.Any())
96009bc9   hexiaodong   hxd
219
                  {
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
220
                      foreach (var item in input.lqHytkMxList)
96009bc9   hexiaodong   hxd
221
                      {
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
222
223
224
225
                          // 创建品项明细实体
                          var lqHytkMxEntity = new LqHytkMxEntity
                          {
                              Id = YitIdHelper.NextId().ToString(),
b45d55f7   “wangming”   Refactor LqEventS...
226
227
228
229
230
                              RefundInfoId = newEntity.Id,
                              BillingItemId = item.billingItemId,
                              CreateTime = DateTime.Now,
                              CreateUser = userInfo.userId,
                              DeleteMark = 0,
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
231
232
233
234
                              Px = item.px,
                              Pxmc = item.pxmc,
                              Pxjg = item.pxjg,
                              Tkje = item.tkje,
b45d55f7   “wangming”   Refactor LqEventS...
235
236
237
238
                              ProjectNumber = item.F_ProjectNumber ?? 1,
                              IsEnabled = item.F_IsEnabled ?? 1,
                              SourceType = item.F_SourceType,
                              TotalPrice = item.F_TotalPrice ?? (item.pxjg * (item.F_ProjectNumber ?? 1)),
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
239
240
                          };
                          allMxEntities.Add(lqHytkMxEntity);
00486d53   “wangming”   更新多个.DS_Store文件,优...
241
  
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
242
243
244
245
246
                          // 收集该品项关联的健康师业绩
                          if (item.lqHytkJksyjList != null && item.lqHytkJksyjList.Any())
                          {
                              foreach (var ijks_tem in item.lqHytkJksyjList)
                              {
00486d53   “wangming”   更新多个.DS_Store文件,优...
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
                                  allJksyjEntities.Add(
                                      new LqHytkJksyjEntity
                                      {
                                          Id = YitIdHelper.NextId().ToString(),
                                          Gltkbh = newEntity.Id,
                                          Jks = ijks_tem.jks,
                                          Jksxm = ijks_tem.jksxm,
                                          Jkszh = ijks_tem.jkszh,
                                          Jksyj = ijks_tem.jksyj,
                                          Tksj = DateTime.Now,
                                          F_jsjid = ijks_tem.F_jsjid,
                                          F_tkpxid = ijks_tem.F_tkpxid,
                                          F_LaborCost = ijks_tem.F_LaborCost,
                                          F_tkpxNumber = ijks_tem.F_tkpxNumber,
                                          F_CreateTime = DateTime.Now,
                                          F_CreateUser = userInfo.userId,
                                          F_DeleteMark = 0,
0ef47194   “wangming”   Refactor LqHytkHy...
264
                                          CardReturn = lqHytkMxEntity.Id,
00486d53   “wangming”   更新多个.DS_Store文件,优...
265
266
                                      }
                                  );
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
267
268
                              }
                          }
00486d53   “wangming”   更新多个.DS_Store文件,优...
269
  
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
270
271
272
273
274
                          // 收集该品项关联的科技部老师业绩
                          if (item.lqHytkKjbsyjList != null && item.lqHytkKjbsyjList.Any())
                          {
                              foreach (var ikjbs_tem in item.lqHytkKjbsyjList)
                              {
00486d53   “wangming”   更新多个.DS_Store文件,优...
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
                                  allKjbsyjEntities.Add(
                                      new LqHytkKjbsyjEntity
                                      {
                                          Id = YitIdHelper.NextId().ToString(),
                                          Gltkbh = newEntity.Id,
                                          Kjbls = ikjbs_tem.kjbls,
                                          Kjblsxm = ikjbs_tem.kjblsxm,
                                          Kjblszh = ikjbs_tem.kjblszh,
                                          Kjblsyj = ikjbs_tem.kjblsyj,
                                          Tksj = DateTime.Now,
                                          F_tkpxid = ikjbs_tem.F_tkpxid,
                                          F_LaborCost = ikjbs_tem.F_LaborCost,
                                          F_tkpxNumber = ikjbs_tem.F_tkpxNumber,
                                          F_CreateTime = DateTime.Now,
                                          F_CreateUser = userInfo.userId,
                                          F_DeleteMark = 0,
0ef47194   “wangming”   Refactor LqHytkHy...
291
                                          CardReturn = lqHytkMxEntity.Id,
00486d53   “wangming”   更新多个.DS_Store文件,优...
292
293
                                      }
                                  );
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
294
295
                              }
                          }
96009bc9   hexiaodong   hxd
296
                      }
96009bc9   hexiaodong   hxd
297
                  }
00486d53   “wangming”   更新多个.DS_Store文件,优...
298
  
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
299
300
                  // 批量插入品项明细
                  if (allMxEntities.Any())
96009bc9   hexiaodong   hxd
301
                  {
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
302
                      await _db.Insertable(allMxEntities).ExecuteCommandAsync();
96009bc9   hexiaodong   hxd
303
                  }
00486d53   “wangming”   更新多个.DS_Store文件,优...
304
  
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
305
306
                  // 批量插入健康师业绩
                  if (allJksyjEntities.Any())
96009bc9   hexiaodong   hxd
307
                  {
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
308
                      await _db.Insertable(allJksyjEntities).ExecuteCommandAsync();
96009bc9   hexiaodong   hxd
309
                  }
00486d53   “wangming”   更新多个.DS_Store文件,优...
310
  
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
311
312
                  // 批量插入科技部老师业绩
                  if (allKjbsyjEntities.Any())
96009bc9   hexiaodong   hxd
313
                  {
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
314
                      await _db.Insertable(allKjbsyjEntities).ExecuteCommandAsync();
96009bc9   hexiaodong   hxd
315
                  }
00486d53   “wangming”   更新多个.DS_Store文件,优...
316
  
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
317
318
319
320
321
322
323
                  // 关闭事务
                  _db.CommitTran();
              }
              catch (Exception ex)
              {
                  _db.RollbackTran();
                  throw NCCException.Oh(ErrorCode.COM1005, ex.Message);
96009bc9   hexiaodong   hxd
324
325
              }
          }
0ef47194   “wangming”   Refactor LqHytkHy...
326
          #endregion
96009bc9   hexiaodong   hxd
327
  
0ef47194   “wangming”   Refactor LqHytkHy...
328
          #region 更新退卡信息及其关联的品项明细、健康师业绩、科技部老师业绩信息
96009bc9   hexiaodong   hxd
329
          /// <summary>
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
330
          /// 更新退卡信息及其关联的品项明细、健康师业绩、科技部老师业绩信息
96009bc9   hexiaodong   hxd
331
          /// </summary>
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
332
333
334
335
336
337
338
339
340
341
          /// <remarks>
          /// 更新退卡记录及其关联的品项明细、健康师业绩、科技部老师业绩信息
          /// 先删除原有的关联数据,再插入新的数据
          /// </remarks>
          /// <param name="id">退卡ID</param>
          /// <param name="input">退卡更新参数</param>
          /// <returns>无返回值</returns>
          /// <response code="200">更新成功</response>
          /// <response code="400">参数错误或数据验证失败</response>
          /// <response code="500">服务器内部错误</response>
96009bc9   hexiaodong   hxd
342
343
344
          [HttpPut("{id}")]
          public async Task Update(string id, [FromBody] LqHytkHytkUpInput input)
          {
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
345
              var userInfo = await _userManager.GetUserInfo();
96009bc9   hexiaodong   hxd
346
              var entity = input.Adapt<LqHytkHytkEntity>();
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
347
348
349
              entity.Id = id;
              entity.F_ModifyTime = DateTime.Now;
              entity.F_ModifyUser = userInfo.userId;
00486d53   “wangming”   更新多个.DS_Store文件,优...
350
  
96009bc9   hexiaodong   hxd
351
352
              try
              {
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
353
                  // 开启事务
96009bc9   hexiaodong   hxd
354
                  _db.BeginTran();
00486d53   “wangming”   更新多个.DS_Store文件,优...
355
  
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
356
357
                  // 更新退卡主表记录
                  await _db.Updateable(entity).IgnoreColumns(true).ExecuteCommandAsync();
00486d53   “wangming”   更新多个.DS_Store文件,优...
358
  
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
359
                  // 删除原有的关联数据
b45d55f7   “wangming”   Refactor LqEventS...
360
                  await _db.Deleteable<LqHytkMxEntity>().Where(x => x.RefundInfoId == id).ExecuteCommandAsync();
0ef47194   “wangming”   Refactor LqHytkHy...
361
362
                  await _db.Deleteable<LqHytkJksyjEntity>().Where(x => x.Gltkbh == id).ExecuteCommandAsync();
                  await _db.Deleteable<LqHytkKjbsyjEntity>().Where(x => x.Gltkbh == id).ExecuteCommandAsync();
00486d53   “wangming”   更新多个.DS_Store文件,优...
363
  
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
364
365
366
367
                  // 收集所有需要插入的实体,然后批量插入
                  var allMxEntities = new List<LqHytkMxEntity>();
                  var allJksyjEntities = new List<LqHytkJksyjEntity>();
                  var allKjbsyjEntities = new List<LqHytkKjbsyjEntity>();
00486d53   “wangming”   更新多个.DS_Store文件,优...
368
  
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
369
370
                  // 处理品项明细列表
                  if (input.lqHytkMxList != null && input.lqHytkMxList.Any())
96009bc9   hexiaodong   hxd
371
                  {
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
372
                      foreach (var item in input.lqHytkMxList)
96009bc9   hexiaodong   hxd
373
                      {
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
374
375
376
377
                          // 创建品项明细实体
                          var lqHytkMxEntity = new LqHytkMxEntity
                          {
                              Id = YitIdHelper.NextId().ToString(),
b45d55f7   “wangming”   Refactor LqEventS...
378
379
380
381
382
                              RefundInfoId = id,
                              BillingItemId = item.billingItemId,
                              CreateTime = DateTime.Now,
                              CreateUser = userInfo.userId,
                              DeleteMark = 0,
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
383
384
385
386
                              Px = item.px,
                              Pxmc = item.pxmc,
                              Pxjg = item.pxjg,
                              Tkje = item.tkje,
b45d55f7   “wangming”   Refactor LqEventS...
387
388
389
390
                              ProjectNumber = item.F_ProjectNumber ?? 1,
                              IsEnabled = item.F_IsEnabled ?? 1,
                              SourceType = item.F_SourceType,
                              TotalPrice = item.F_TotalPrice ?? (item.pxjg * (item.F_ProjectNumber ?? 1)),
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
391
392
                          };
                          allMxEntities.Add(lqHytkMxEntity);
00486d53   “wangming”   更新多个.DS_Store文件,优...
393
  
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
394
395
396
397
398
                          // 收集该品项关联的健康师业绩
                          if (item.lqHytkJksyjList != null && item.lqHytkJksyjList.Any())
                          {
                              foreach (var ijks_tem in item.lqHytkJksyjList)
                              {
00486d53   “wangming”   更新多个.DS_Store文件,优...
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
                                  allJksyjEntities.Add(
                                      new LqHytkJksyjEntity
                                      {
                                          Id = YitIdHelper.NextId().ToString(),
                                          Gltkbh = id,
                                          Jks = ijks_tem.jks,
                                          Jksxm = ijks_tem.jksxm,
                                          Jkszh = ijks_tem.jkszh,
                                          Jksyj = ijks_tem.jksyj,
                                          Tksj = DateTime.Now,
                                          F_jsjid = ijks_tem.F_jsjid,
                                          F_tkpxid = ijks_tem.F_tkpxid,
                                          F_LaborCost = ijks_tem.F_LaborCost,
                                          F_tkpxNumber = ijks_tem.F_tkpxNumber,
                                          F_CreateTime = DateTime.Now,
                                          F_CreateUser = userInfo.userId,
                                          F_DeleteMark = 0,
                                      }
                                  );
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
418
419
                              }
                          }
00486d53   “wangming”   更新多个.DS_Store文件,优...
420
  
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
421
422
423
424
425
                          // 收集该品项关联的科技部老师业绩
                          if (item.lqHytkKjbsyjList != null && item.lqHytkKjbsyjList.Any())
                          {
                              foreach (var ikjbs_tem in item.lqHytkKjbsyjList)
                              {
00486d53   “wangming”   更新多个.DS_Store文件,优...
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
                                  allKjbsyjEntities.Add(
                                      new LqHytkKjbsyjEntity
                                      {
                                          Id = YitIdHelper.NextId().ToString(),
                                          Gltkbh = id,
                                          Kjbls = ikjbs_tem.kjbls,
                                          Kjblsxm = ikjbs_tem.kjblsxm,
                                          Kjblszh = ikjbs_tem.kjblszh,
                                          Kjblsyj = ikjbs_tem.kjblsyj,
                                          Tksj = DateTime.Now,
                                          F_tkpxid = ikjbs_tem.F_tkpxid,
                                          F_LaborCost = ikjbs_tem.F_LaborCost,
                                          F_tkpxNumber = ikjbs_tem.F_tkpxNumber,
                                          F_CreateTime = DateTime.Now,
                                          F_CreateUser = userInfo.userId,
                                          F_DeleteMark = 0,
                                      }
                                  );
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
444
445
                              }
                          }
96009bc9   hexiaodong   hxd
446
                      }
96009bc9   hexiaodong   hxd
447
                  }
00486d53   “wangming”   更新多个.DS_Store文件,优...
448
  
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
449
450
451
452
453
                  // 批量插入品项明细
                  if (allMxEntities.Any())
                  {
                      await _db.Insertable(allMxEntities).ExecuteCommandAsync();
                  }
00486d53   “wangming”   更新多个.DS_Store文件,优...
454
  
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
455
456
457
458
459
                  // 批量插入健康师业绩
                  if (allJksyjEntities.Any())
                  {
                      await _db.Insertable(allJksyjEntities).ExecuteCommandAsync();
                  }
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
460
461
462
463
464
                  // 批量插入科技部老师业绩
                  if (allKjbsyjEntities.Any())
                  {
                      await _db.Insertable(allKjbsyjEntities).ExecuteCommandAsync();
                  }
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
465
                  // 关闭事务
96009bc9   hexiaodong   hxd
466
467
                  _db.CommitTran();
              }
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
468
              catch (Exception ex)
96009bc9   hexiaodong   hxd
469
              {
96009bc9   hexiaodong   hxd
470
                  _db.RollbackTran();
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
471
                  throw NCCException.Oh(ErrorCode.COM1005, ex.Message);
96009bc9   hexiaodong   hxd
472
473
              }
          }
0ef47194   “wangming”   Refactor LqHytkHy...
474
          #endregion
96009bc9   hexiaodong   hxd
475
  
0ef47194   “wangming”   Refactor LqHytkHy...
476
          #region 删除退卡信息
96009bc9   hexiaodong   hxd
477
          /// <summary>
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
478
          /// 删除退卡信息
96009bc9   hexiaodong   hxd
479
          /// </summary>
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
480
          /// <param name="id">主键</param>
96009bc9   hexiaodong   hxd
481
482
483
484
485
          /// <returns></returns>
          [HttpDelete("{id}")]
          public async Task Delete(string id)
          {
              var entity = await _db.Queryable<LqHytkHytkEntity>().FirstAsync(p => p.Id == id);
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
486
487
488
489
490
491
              if (entity != null)
              {
                  entity.F_DeleteMark = 1;
                  await _lqHytkHytkRepository.UpdateAsync(entity);
              }
          }
0ef47194   “wangming”   Refactor LqHytkHy...
492
          #endregion
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
493
  
0ef47194   “wangming”   Refactor LqHytkHy...
494
          #region 获取退卡信息详情
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
495
496
497
498
499
500
          /// <summary>
          /// 获取退卡信息详情
          /// </summary>
          /// <remarks>
          /// 获取退卡记录及其关联的品项明细、健康师业绩、科技部老师业绩信息
          /// 按照退卡的完整格式返回数据,不包含汇总信息
00486d53   “wangming”   更新多个.DS_Store文件,优...
501
          ///
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
502
503
504
505
506
507
508
509
510
511
512
513
514
515
          /// 返回数据结构:
          /// - 主表信息:退卡基础信息、门店信息、会员信息、退卡金额等
          /// - 品项明细列表:每个品项包含完整的项目信息(项目次数、是否有效、来源类型等)
          /// - 健康师业绩列表:按品项关联的健康师业绩信息
          /// - 科技部老师业绩列表:按品项关联的科技部老师业绩信息
          /// </remarks>
          /// <param name="id">退卡记录主键ID</param>
          /// <returns>退卡记录完整信息</returns>
          /// <response code="200">查询成功</response>
          /// <response code="404">退卡记录不存在</response>
          /// <response code="500">服务器内部错误</response>
          [HttpGet("{id}")]
          public async Task<dynamic> GetInfo(string id)
          {
96009bc9   hexiaodong   hxd
516
517
              try
              {
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
518
519
520
521
522
523
                  // 1. 查询主表信息
                  var entity = await _db.Queryable<LqHytkHytkEntity>().FirstAsync(p => p.Id == id);
                  if (entity == null)
                  {
                      throw NCCException.Oh(ErrorCode.COM1005, "退卡记录不存在");
                  }
96009bc9   hexiaodong   hxd
524
  
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
525
526
527
                  var output = entity.Adapt<LqHytkHytkInfoOutput>();
  
                  // 2. 查询品项明细列表
b45d55f7   “wangming”   Refactor LqEventS...
528
                  var lqHytkMxList = await _db.Queryable<LqHytkMxEntity>().Where(w => w.RefundInfoId == entity.Id).ToListAsync();
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
529
530
  
                  // 3. 查询健康师业绩列表
0ef47194   “wangming”   Refactor LqHytkHy...
531
                  var lqHytkJksyjList = await _db.Queryable<LqHytkJksyjEntity>().Where(w => w.Gltkbh == entity.Id).ToListAsync();
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
532
533
  
                  // 4. 查询科技部老师业绩列表
0ef47194   “wangming”   Refactor LqHytkHy...
534
                  var lqHytkKjbsyjList = await _db.Queryable<LqHytkKjbsyjEntity>().Where(w => w.Gltkbh == entity.Id).ToListAsync();
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
535
536
537
538
539
540
541
542
  
                  // 5. 构建品项明细输出,每个品项关联对应的业绩信息
                  var mxOutputList = new List<LqHytkMxInfoOutput>();
                  foreach (var mx in lqHytkMxList)
                  {
                      var mxOutput = new LqHytkMxInfoOutput
                      {
                          id = mx.Id,
b45d55f7   “wangming”   Refactor LqEventS...
543
544
                          refundInfoId = mx.RefundInfoId,
                          billingItemId = mx.BillingItemId,
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
545
546
547
548
                          px = mx.Px,
                          pxmc = mx.Pxmc,
                          pxjg = mx.Pxjg,
                          tkje = mx.Tkje,
b45d55f7   “wangming”   Refactor LqEventS...
549
550
551
552
                          projectNumber = mx.ProjectNumber,
                          isEnabled = mx.IsEnabled,
                          sourceType = mx.SourceType,
                          totalPrice = mx.TotalPrice,
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
553
554
555
                      };
  
                      // 关联该品项的健康师业绩
0ef47194   “wangming”   Refactor LqHytkHy...
556
                      var jksyjForMx = lqHytkJksyjList.Where(j => j.CardReturn == mx.Id).ToList();
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
557
558
559
                      mxOutput.lqHytkJksyjList = jksyjForMx.Adapt<List<LqHytkJksyjInfoOutput>>();
  
                      // 关联该品项的科技部老师业绩
0ef47194   “wangming”   Refactor LqHytkHy...
560
                      var kjbsyjForMx = lqHytkKjbsyjList.Where(k => k.CardReturn == mx.Id).ToList();
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
561
562
563
564
565
566
567
568
569
570
571
572
573
                      mxOutput.lqHytkKjbsyjList = kjbsyjForMx.Adapt<List<LqHytkKjbsyjInfoOutput>>();
  
                      mxOutputList.Add(mxOutput);
                  }
  
                  // 6. 设置输出结果
                  output.lqHytkMxList = mxOutputList;
  
                  // 7. 设置全局业绩列表(用于兼容性,但主要使用品项关联的业绩)
                  output.lqHytkJksyjList = lqHytkJksyjList.Adapt<List<LqHytkJksyjInfoOutput>>();
                  output.lqHytkKjbsyjList = lqHytkKjbsyjList.Adapt<List<LqHytkKjbsyjInfoOutput>>();
  
                  return output;
96009bc9   hexiaodong   hxd
574
575
576
              }
              catch (Exception)
              {
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
577
                  throw NCCException.Oh(ErrorCode.COM1000, "获取退卡记录失败");
96009bc9   hexiaodong   hxd
578
579
              }
          }
0ef47194   “wangming”   Refactor LqHytkHy...
580
          #endregion
96009bc9   hexiaodong   hxd
581
582
      }
  }