Blame view

netcore/src/Modularity/Extend/NCC.Extend/LqHytkHytkService.cs 30.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
  using NCC.Extend.Entitys.Dto.LqHytkMx;
3e508db5   “wangming”   优化开单记录作废功能:添加详细错误...
22
  using NCC.Extend.Entitys.Enum;
00486d53   “wangming”   更新多个.DS_Store文件,优...
23
24
25
26
27
28
  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
29
  using NCC.JsonSerialization;
00486d53   “wangming”   更新多个.DS_Store文件,优...
30
31
  using SqlSugar;
  using Yitter.IdGenerator;
96009bc9   hexiaodong   hxd
32
33
34
35
  
  namespace NCC.Extend.LqHytkHytk
  {
      /// <summary>
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
36
      /// 退卡_信息表服务
96009bc9   hexiaodong   hxd
37
      /// </summary>
00486d53   “wangming”   更新多个.DS_Store文件,优...
38
      [ApiDescriptionSettings(Tag = "绿纤退卡信息表服务", Name = "LqHytkHytk", Order = 200)]
96009bc9   hexiaodong   hxd
39
40
41
42
43
      [Route("api/Extend/[controller]")]
      public class LqHytkHytkService : ILqHytkHytkService, IDynamicApiController, ITransient
      {
          private readonly ISqlSugarRepository<LqHytkHytkEntity> _lqHytkHytkRepository;
          private readonly ISqlSugarRepository<LqHytkMxEntity> _lqHytkMxRepository;
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
44
45
          private readonly ISqlSugarRepository<LqHytkJksyjEntity> _lqHytkJksyjRepository;
          private readonly ISqlSugarRepository<LqHytkKjbsyjEntity> _lqHytkKjbsyjRepository;
96009bc9   hexiaodong   hxd
46
47
48
49
50
51
52
53
54
          private readonly SqlSugarScope _db;
          private readonly IUserManager _userManager;
  
          /// <summary>
          /// 初始化一个<see cref="LqHytkHytkService"/>类型的新实例
          /// </summary>
          public LqHytkHytkService(
              ISqlSugarRepository<LqHytkHytkEntity> lqHytkHytkRepository,
              ISqlSugarRepository<LqHytkMxEntity> lqHytkMxRepository,
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
55
56
              ISqlSugarRepository<LqHytkJksyjEntity> lqHytkJksyjRepository,
              ISqlSugarRepository<LqHytkKjbsyjEntity> lqHytkKjbsyjRepository,
00486d53   “wangming”   更新多个.DS_Store文件,优...
57
58
              IUserManager userManager
          )
96009bc9   hexiaodong   hxd
59
          {
00486d53   “wangming”   更新多个.DS_Store文件,优...
60
              _lqHytkHytkRepository = lqHytkHytkRepository;
96009bc9   hexiaodong   hxd
61
              _lqHytkMxRepository = lqHytkMxRepository;
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
62
63
64
              _lqHytkJksyjRepository = lqHytkJksyjRepository;
              _lqHytkKjbsyjRepository = lqHytkKjbsyjRepository;
              _db = _lqHytkHytkRepository.Context;
96009bc9   hexiaodong   hxd
65
66
67
              _userManager = userManager;
          }
  
0ef47194   “wangming”   Refactor LqHytkHy...
68
          #region 获取退卡信息列表
96009bc9   hexiaodong   hxd
69
          /// <summary>
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
70
          /// 获取退卡信息列表
96009bc9   hexiaodong   hxd
71
          /// </summary>
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
72
          /// <param name="input">查询参数</param>
00486d53   “wangming”   更新多个.DS_Store文件,优...
73
          /// <returns></returns>
96009bc9   hexiaodong   hxd
74
75
76
77
          [HttpGet("")]
          public async Task<dynamic> GetList([FromQuery] LqHytkHytkListQueryInput input)
          {
              var sidx = input.sidx == null ? "id" : input.sidx;
0ef47194   “wangming”   Refactor LqHytkHy...
78
              List<string> queryTksj = input.tksj != null ? input.tksj.Split(',').ToObeject<List<string>>() : null;
96009bc9   hexiaodong   hxd
79
80
81
82
83
              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”   更新退卡相关功能,重构退卡信息表及...
84
                  .WhereIF(!string.IsNullOrEmpty(input.mdbh), p => p.Mdbh.Contains(input.mdbh))
96009bc9   hexiaodong   hxd
85
86
                  .WhereIF(!string.IsNullOrEmpty(input.mdmc), p => p.Mdmc.Contains(input.mdmc))
                  .WhereIF(!string.IsNullOrEmpty(input.hy), p => p.Hy.Equals(input.hy))
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
87
                  .WhereIF(!string.IsNullOrEmpty(input.hymc), p => p.Hymc.Contains(input.hymc))
96009bc9   hexiaodong   hxd
88
                  .WhereIF(!string.IsNullOrEmpty(input.hyzh), p => p.Hyzh.Contains(input.hyzh))
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
89
90
91
                  .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
92
                  .WhereIF(!string.IsNullOrEmpty(input.bz), p => p.Bz.Contains(input.bz))
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
93
94
                  .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...
95
96
97
                  .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”   更新退卡相关功能,重构退卡信息表及...
98
                  .WhereIF(!string.IsNullOrEmpty(input.czry), p => p.Czry.Equals(input.czry))
e745bcc2   “wangming”   修复转卡方法中的空引用异常和Fir...
99
                  .WhereIF(input.isEffective != 0, p => p.IsEffective == input.isEffective)
00486d53   “wangming”   更新多个.DS_Store文件,优...
100
                  .Select(it => new LqHytkHytkListOutput
96009bc9   hexiaodong   hxd
101
102
                  {
                      id = it.Id,
00486d53   “wangming”   更新多个.DS_Store文件,优...
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
                      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,
3e508db5   “wangming”   优化开单记录作废功能:添加详细错误...
118
                      isEffective = it.IsEffective,
fb9d5c60   “wangming”   feat: 更新LqHytkHyt...
119
                      cancelRemark = it.CancelRemark,
63df7ccb   “wangming”   1
120
                      actualRefundAmount = it.ActualRefundAmount
00486d53   “wangming”   更新多个.DS_Store文件,优...
121
122
123
124
125
                  })
                  .MergeTable()
                  .OrderBy(sidx + " " + input.sort)
                  .ToPagedListAsync(input.currentPage, input.pageSize);
              return PageResult<LqHytkHytkListOutput>.SqlSugarPageResult(data);
96009bc9   hexiaodong   hxd
126
          }
0ef47194   “wangming”   Refactor LqHytkHy...
127
          #endregion
96009bc9   hexiaodong   hxd
128
  
0ef47194   “wangming”   Refactor LqHytkHy...
129
          #region 创建退卡信息及其关联的品项明细、健康师业绩、科技部老师业绩信息
96009bc9   hexiaodong   hxd
130
          /// <summary>
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
131
          /// 创建退卡信息及其关联的品项明细、健康师业绩、科技部老师业绩信息
96009bc9   hexiaodong   hxd
132
          /// </summary>
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
133
134
          /// <remarks>
          /// 创建退卡记录及其关联的品项明细、健康师业绩、科技部老师业绩信息
00486d53   “wangming”   更新多个.DS_Store文件,优...
135
          ///
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
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
182
183
184
185
186
          /// 示例请求:
          /// ```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文件,优...
187
          ///
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
188
189
190
191
192
193
194
195
196
197
          /// 参数说明:
          /// - 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
198
199
200
201
202
203
          [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”   更新退卡相关功能,重构退卡信息表及...
204
205
              entity.F_CreateTime = DateTime.Now;
              entity.F_CreateUser = userInfo.userId;
3e508db5   “wangming”   优化开单记录作废功能:添加详细错误...
206
              entity.IsEffective = StatusEnum.有效.GetHashCode();
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
207
              entity.Czry = userInfo.userId;
00486d53   “wangming”   更新多个.DS_Store文件,优...
208
  
96009bc9   hexiaodong   hxd
209
210
              try
              {
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
211
                  // 开启事务
96009bc9   hexiaodong   hxd
212
                  _db.BeginTran();
00486d53   “wangming”   更新多个.DS_Store文件,优...
213
  
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
214
                  // 新增退卡主表记录
0ef47194   “wangming”   Refactor LqHytkHy...
215
                  var newEntity = await _db.Insertable(entity).IgnoreColumns(ignoreNullColumn: true).ExecuteReturnEntityAsync();
96009bc9   hexiaodong   hxd
216
  
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
217
218
219
220
                  // 收集所有需要插入的实体,然后批量插入
                  var allMxEntities = new List<LqHytkMxEntity>();
                  var allJksyjEntities = new List<LqHytkJksyjEntity>();
                  var allKjbsyjEntities = new List<LqHytkKjbsyjEntity>();
00486d53   “wangming”   更新多个.DS_Store文件,优...
221
  
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
222
223
                  // 处理品项明细列表
                  if (input.lqHytkMxList != null && input.lqHytkMxList.Any())
96009bc9   hexiaodong   hxd
224
                  {
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
225
                      foreach (var item in input.lqHytkMxList)
96009bc9   hexiaodong   hxd
226
                      {
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
227
228
229
230
                          // 创建品项明细实体
                          var lqHytkMxEntity = new LqHytkMxEntity
                          {
                              Id = YitIdHelper.NextId().ToString(),
b45d55f7   “wangming”   Refactor LqEventS...
231
232
233
234
                              RefundInfoId = newEntity.Id,
                              BillingItemId = item.billingItemId,
                              CreateTime = DateTime.Now,
                              CreateUser = userInfo.userId,
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
235
236
237
238
                              Px = item.px,
                              Pxmc = item.pxmc,
                              Pxjg = item.pxjg,
                              Tkje = item.tkje,
b45d55f7   “wangming”   Refactor LqEventS...
239
                              ProjectNumber = item.F_ProjectNumber ?? 1,
b45d55f7   “wangming”   Refactor LqEventS...
240
241
                              SourceType = item.F_SourceType,
                              TotalPrice = item.F_TotalPrice ?? (item.pxjg * (item.F_ProjectNumber ?? 1)),
3e508db5   “wangming”   优化开单记录作废功能:添加详细错误...
242
                              IsEffective = StatusEnum.有效.GetHashCode(),
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
243
244
                          };
                          allMxEntities.Add(lqHytkMxEntity);
00486d53   “wangming”   更新多个.DS_Store文件,优...
245
  
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
246
247
248
249
250
                          // 收集该品项关联的健康师业绩
                          if (item.lqHytkJksyjList != null && item.lqHytkJksyjList.Any())
                          {
                              foreach (var ijks_tem in item.lqHytkJksyjList)
                              {
3e508db5   “wangming”   优化开单记录作废功能:添加详细错误...
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
                                  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,
3e508db5   “wangming”   优化开单记录作废功能:添加详细错误...
266
267
268
                                      CardReturn = lqHytkMxEntity.Id,
                                      IsEffective = StatusEnum.有效.GetHashCode(),
                                  }
00486d53   “wangming”   更新多个.DS_Store文件,优...
269
                                  );
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
270
271
                              }
                          }
00486d53   “wangming”   更新多个.DS_Store文件,优...
272
  
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
273
274
275
276
277
                          // 收集该品项关联的科技部老师业绩
                          if (item.lqHytkKjbsyjList != null && item.lqHytkKjbsyjList.Any())
                          {
                              foreach (var ikjbs_tem in item.lqHytkKjbsyjList)
                              {
00486d53   “wangming”   更新多个.DS_Store文件,优...
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
                                  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,
0ef47194   “wangming”   Refactor LqHytkHy...
293
                                          CardReturn = lqHytkMxEntity.Id,
3e508db5   “wangming”   优化开单记录作废功能:添加详细错误...
294
                                          IsEffective = StatusEnum.有效.GetHashCode(),
00486d53   “wangming”   更新多个.DS_Store文件,优...
295
296
                                      }
                                  );
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
297
298
                              }
                          }
96009bc9   hexiaodong   hxd
299
                      }
96009bc9   hexiaodong   hxd
300
                  }
00486d53   “wangming”   更新多个.DS_Store文件,优...
301
  
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
302
303
                  // 批量插入品项明细
                  if (allMxEntities.Any())
96009bc9   hexiaodong   hxd
304
                  {
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
305
                      await _db.Insertable(allMxEntities).ExecuteCommandAsync();
96009bc9   hexiaodong   hxd
306
                  }
00486d53   “wangming”   更新多个.DS_Store文件,优...
307
  
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
308
309
                  // 批量插入健康师业绩
                  if (allJksyjEntities.Any())
96009bc9   hexiaodong   hxd
310
                  {
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
311
                      await _db.Insertable(allJksyjEntities).ExecuteCommandAsync();
96009bc9   hexiaodong   hxd
312
                  }
00486d53   “wangming”   更新多个.DS_Store文件,优...
313
  
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
314
315
                  // 批量插入科技部老师业绩
                  if (allKjbsyjEntities.Any())
96009bc9   hexiaodong   hxd
316
                  {
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
317
                      await _db.Insertable(allKjbsyjEntities).ExecuteCommandAsync();
96009bc9   hexiaodong   hxd
318
                  }
00486d53   “wangming”   更新多个.DS_Store文件,优...
319
  
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
320
321
322
323
324
325
326
                  // 关闭事务
                  _db.CommitTran();
              }
              catch (Exception ex)
              {
                  _db.RollbackTran();
                  throw NCCException.Oh(ErrorCode.COM1005, ex.Message);
96009bc9   hexiaodong   hxd
327
328
              }
          }
0ef47194   “wangming”   Refactor LqHytkHy...
329
          #endregion
96009bc9   hexiaodong   hxd
330
  
0ef47194   “wangming”   Refactor LqHytkHy...
331
          #region 更新退卡信息及其关联的品项明细、健康师业绩、科技部老师业绩信息
96009bc9   hexiaodong   hxd
332
          /// <summary>
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
333
          /// 更新退卡信息及其关联的品项明细、健康师业绩、科技部老师业绩信息
96009bc9   hexiaodong   hxd
334
          /// </summary>
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
335
336
337
338
339
340
341
342
343
344
          /// <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
345
346
347
          [HttpPut("{id}")]
          public async Task Update(string id, [FromBody] LqHytkHytkUpInput input)
          {
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
348
              var userInfo = await _userManager.GetUserInfo();
96009bc9   hexiaodong   hxd
349
              var entity = input.Adapt<LqHytkHytkEntity>();
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
350
351
352
              entity.Id = id;
              entity.F_ModifyTime = DateTime.Now;
              entity.F_ModifyUser = userInfo.userId;
00486d53   “wangming”   更新多个.DS_Store文件,优...
353
  
96009bc9   hexiaodong   hxd
354
355
              try
              {
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
356
                  // 开启事务
96009bc9   hexiaodong   hxd
357
                  _db.BeginTran();
00486d53   “wangming”   更新多个.DS_Store文件,优...
358
  
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
359
360
                  // 更新退卡主表记录
                  await _db.Updateable(entity).IgnoreColumns(true).ExecuteCommandAsync();
00486d53   “wangming”   更新多个.DS_Store文件,优...
361
  
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
362
                  // 删除原有的关联数据
b45d55f7   “wangming”   Refactor LqEventS...
363
                  await _db.Deleteable<LqHytkMxEntity>().Where(x => x.RefundInfoId == id).ExecuteCommandAsync();
0ef47194   “wangming”   Refactor LqHytkHy...
364
365
                  await _db.Deleteable<LqHytkJksyjEntity>().Where(x => x.Gltkbh == id).ExecuteCommandAsync();
                  await _db.Deleteable<LqHytkKjbsyjEntity>().Where(x => x.Gltkbh == id).ExecuteCommandAsync();
00486d53   “wangming”   更新多个.DS_Store文件,优...
366
  
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
367
368
369
370
                  // 收集所有需要插入的实体,然后批量插入
                  var allMxEntities = new List<LqHytkMxEntity>();
                  var allJksyjEntities = new List<LqHytkJksyjEntity>();
                  var allKjbsyjEntities = new List<LqHytkKjbsyjEntity>();
00486d53   “wangming”   更新多个.DS_Store文件,优...
371
  
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
372
373
                  // 处理品项明细列表
                  if (input.lqHytkMxList != null && input.lqHytkMxList.Any())
96009bc9   hexiaodong   hxd
374
                  {
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
375
                      foreach (var item in input.lqHytkMxList)
96009bc9   hexiaodong   hxd
376
                      {
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
377
378
379
380
                          // 创建品项明细实体
                          var lqHytkMxEntity = new LqHytkMxEntity
                          {
                              Id = YitIdHelper.NextId().ToString(),
b45d55f7   “wangming”   Refactor LqEventS...
381
382
383
384
                              RefundInfoId = id,
                              BillingItemId = item.billingItemId,
                              CreateTime = DateTime.Now,
                              CreateUser = userInfo.userId,
dac8767e   “wangming”   111111111
385
                              Tksj = input.tksj,
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
386
387
388
389
                              Px = item.px,
                              Pxmc = item.pxmc,
                              Pxjg = item.pxjg,
                              Tkje = item.tkje,
b45d55f7   “wangming”   Refactor LqEventS...
390
                              ProjectNumber = item.F_ProjectNumber ?? 1,
b45d55f7   “wangming”   Refactor LqEventS...
391
392
                              SourceType = item.F_SourceType,
                              TotalPrice = item.F_TotalPrice ?? (item.pxjg * (item.F_ProjectNumber ?? 1)),
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
393
394
                          };
                          allMxEntities.Add(lqHytkMxEntity);
00486d53   “wangming”   更新多个.DS_Store文件,优...
395
  
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
396
397
398
399
400
                          // 收集该品项关联的健康师业绩
                          if (item.lqHytkJksyjList != null && item.lqHytkJksyjList.Any())
                          {
                              foreach (var ijks_tem in item.lqHytkJksyjList)
                              {
00486d53   “wangming”   更新多个.DS_Store文件,优...
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
                                  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,
00486d53   “wangming”   更新多个.DS_Store文件,优...
417
418
                                      }
                                  );
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
419
420
                              }
                          }
00486d53   “wangming”   更新多个.DS_Store文件,优...
421
  
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
422
423
424
425
426
                          // 收集该品项关联的科技部老师业绩
                          if (item.lqHytkKjbsyjList != null && item.lqHytkKjbsyjList.Any())
                          {
                              foreach (var ikjbs_tem in item.lqHytkKjbsyjList)
                              {
00486d53   “wangming”   更新多个.DS_Store文件,优...
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
                                  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,
00486d53   “wangming”   更新多个.DS_Store文件,优...
442
443
                                      }
                                  );
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
  
2164125c   “wangming”   feat: 删除LqXhmxb相关...
476
          #region 作废退卡信息
96009bc9   hexiaodong   hxd
477
          /// <summary>
2164125c   “wangming”   feat: 删除LqXhmxb相关...
478
          /// 作废退卡信息
96009bc9   hexiaodong   hxd
479
          /// </summary>
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
480
          /// <param name="id">主键</param>
96009bc9   hexiaodong   hxd
481
          /// <returns></returns>
2164125c   “wangming”   feat: 删除LqXhmxb相关...
482
          [HttpPut("VoidRefundCardInfo/{id}")]
fb9d5c60   “wangming”   feat: 更新LqHytkHyt...
483
          public async Task<dynamic> VoidRefundCardInfo(string id, [FromQuery] string remarks = null)
96009bc9   hexiaodong   hxd
484
          {
2164125c   “wangming”   feat: 删除LqXhmxb相关...
485
              try
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
486
              {
2164125c   “wangming”   feat: 删除LqXhmxb相关...
487
488
489
490
491
492
493
494
                  var entity = await _db.Queryable<LqHytkHytkEntity>().FirstAsync(p => p.Id == id && p.IsEffective == StatusEnum.有效.GetHashCode());
                  if (entity == null)
                  {
                      throw NCCException.Oh("退卡信息不存在或已被作废");
                  }
                  // 开启事务
                  _db.BeginTran();
                  // 更新主表
3e508db5   “wangming”   优化开单记录作废功能:添加详细错误...
495
                  entity.IsEffective = StatusEnum.无效.GetHashCode();
2164125c   “wangming”   feat: 删除LqXhmxb相关...
496
                  entity.F_ModifyTime = DateTime.Now;
fb9d5c60   “wangming”   feat: 更新LqHytkHyt...
497
                  entity.CancelRemark = remarks;
2164125c   “wangming”   feat: 删除LqXhmxb相关...
498
499
                  await _db.Updateable(entity).ExecuteCommandAsync();
                  // 更新明细表
3e508db5   “wangming”   优化开单记录作废功能:添加详细错误...
500
                  await _db.Updateable<LqHytkMxEntity>().SetColumns(it => new LqHytkMxEntity { IsEffective = StatusEnum.无效.GetHashCode() }).Where(w => w.RefundInfoId == id).ExecuteCommandAsync();
2164125c   “wangming”   feat: 删除LqXhmxb相关...
501
                  // 更新健康师业绩表
3e508db5   “wangming”   优化开单记录作废功能:添加详细错误...
502
                  await _db.Updateable<LqHytkJksyjEntity>().SetColumns(it => new LqHytkJksyjEntity { IsEffective = StatusEnum.无效.GetHashCode() }).Where(w => w.Gltkbh == id).ExecuteCommandAsync();
2164125c   “wangming”   feat: 删除LqXhmxb相关...
503
                  // 更新科技部业绩表
3e508db5   “wangming”   优化开单记录作废功能:添加详细错误...
504
                  await _db.Updateable<LqHytkKjbsyjEntity>().SetColumns(it => new LqHytkKjbsyjEntity { IsEffective = StatusEnum.无效.GetHashCode() }).Where(w => w.Gltkbh == id).ExecuteCommandAsync();
2164125c   “wangming”   feat: 删除LqXhmxb相关...
505
506
507
508
509
510
511
512
                  // 提交事务
                  _db.CommitTran();
                  return entity;
              }
              catch (Exception ex)
              {
                  _db.RollbackTran();
                  throw NCCException.Oh($"删除退卡信息失败: {ex.Message}");
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
513
514
              }
          }
0ef47194   “wangming”   Refactor LqHytkHy...
515
          #endregion
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
516
  
dac8767e   “wangming”   111111111
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
          #region 物理删除退卡信息
          /// <summary>
          /// 物理删除退卡信息
          /// </summary>
          /// <remarks>
          /// 彻底删除退卡记录及其所有关联数据,包括:
          /// - 退卡主表记录
          /// - 退卡品项明细记录
          /// - 退卡健康师业绩记录
          /// - 退卡科技部老师业绩记录
          /// 
          /// 注意:此操作不可逆,请谨慎使用
          /// </remarks>
          /// <param name="id">退卡记录主键ID</param>
          /// <returns>删除结果</returns>
          /// <response code="200">删除成功</response>
          /// <response code="404">退卡记录不存在</response>
          /// <response code="500">服务器内部错误</response>
          [HttpDelete("physical/{id}")]
          public async Task<dynamic> PhysicalDelete(string id)
          {
              try
              {
                  // 检查退卡记录是否存在
                  var entity = await _db.Queryable<LqHytkHytkEntity>().FirstAsync(p => p.Id == id);
                  if (entity == null)
                  {
                      throw NCCException.Oh("退卡记录不存在");
                  }
  
                  // 开启事务
                  _db.BeginTran();
  
                  // 1. 删除退卡品项明细记录
ce74473f   “wangming”   feat: 新增门店类别枚举和耗卡...
551
                  await _db.Deleteable<LqHytkMxEntity>().Where(x => x.RefundInfoId == id).ExecuteCommandAsync();
dac8767e   “wangming”   111111111
552
553
  
                  // 2. 删除退卡健康师业绩记录
ce74473f   “wangming”   feat: 新增门店类别枚举和耗卡...
554
                  await _db.Deleteable<LqHytkJksyjEntity>().Where(x => x.Gltkbh == id).ExecuteCommandAsync();
dac8767e   “wangming”   111111111
555
556
  
                  // 3. 删除退卡科技部老师业绩记录
ce74473f   “wangming”   feat: 新增门店类别枚举和耗卡...
557
                  await _db.Deleteable<LqHytkKjbsyjEntity>().Where(x => x.Gltkbh == id).ExecuteCommandAsync();
dac8767e   “wangming”   111111111
558
559
  
                  // 4. 删除退卡主表记录
ce74473f   “wangming”   feat: 新增门店类别枚举和耗卡...
560
                  await _db.Deleteable<LqHytkHytkEntity>().Where(x => x.Id == id).ExecuteCommandAsync();
dac8767e   “wangming”   111111111
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
  
                  // 提交事务
                  _db.CommitTran();
  
                  return new
                  {
                      success = true,
                      message = "退卡记录已彻底删除",
                      deletedId = id,
                      deletedTime = DateTime.Now
                  };
              }
              catch (Exception ex)
              {
                  // 回滚事务
                  _db.RollbackTran();
                  throw NCCException.Oh($"物理删除退卡记录失败: {ex.Message}");
              }
          }
          #endregion
  
0ef47194   “wangming”   Refactor LqHytkHy...
582
          #region 获取退卡信息详情
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
583
584
585
586
587
588
          /// <summary>
          /// 获取退卡信息详情
          /// </summary>
          /// <remarks>
          /// 获取退卡记录及其关联的品项明细、健康师业绩、科技部老师业绩信息
          /// 按照退卡的完整格式返回数据,不包含汇总信息
00486d53   “wangming”   更新多个.DS_Store文件,优...
589
          ///
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
590
591
592
593
594
595
596
597
598
599
600
601
602
603
          /// 返回数据结构:
          /// - 主表信息:退卡基础信息、门店信息、会员信息、退卡金额等
          /// - 品项明细列表:每个品项包含完整的项目信息(项目次数、是否有效、来源类型等)
          /// - 健康师业绩列表:按品项关联的健康师业绩信息
          /// - 科技部老师业绩列表:按品项关联的科技部老师业绩信息
          /// </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
604
605
              try
              {
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
606
                  // 1. 查询主表信息
fb9d5c60   “wangming”   feat: 更新LqHytkHyt...
607
                  var entity = await _db.Queryable<LqHytkHytkEntity>().Where(p => p.Id == id).FirstAsync();
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
608
609
                  if (entity == null)
                  {
fb9d5c60   “wangming”   feat: 更新LqHytkHyt...
610
                      throw NCCException.Oh("退卡记录不存在");
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
611
                  }
96009bc9   hexiaodong   hxd
612
  
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
613
614
615
                  var output = entity.Adapt<LqHytkHytkInfoOutput>();
  
                  // 2. 查询品项明细列表
b45d55f7   “wangming”   Refactor LqEventS...
616
                  var lqHytkMxList = await _db.Queryable<LqHytkMxEntity>().Where(w => w.RefundInfoId == entity.Id).ToListAsync();
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
617
618
  
                  // 3. 查询健康师业绩列表
0ef47194   “wangming”   Refactor LqHytkHy...
619
                  var lqHytkJksyjList = await _db.Queryable<LqHytkJksyjEntity>().Where(w => w.Gltkbh == entity.Id).ToListAsync();
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
620
621
  
                  // 4. 查询科技部老师业绩列表
0ef47194   “wangming”   Refactor LqHytkHy...
622
                  var lqHytkKjbsyjList = await _db.Queryable<LqHytkKjbsyjEntity>().Where(w => w.Gltkbh == entity.Id).ToListAsync();
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
623
624
625
626
627
628
629
630
  
                  // 5. 构建品项明细输出,每个品项关联对应的业绩信息
                  var mxOutputList = new List<LqHytkMxInfoOutput>();
                  foreach (var mx in lqHytkMxList)
                  {
                      var mxOutput = new LqHytkMxInfoOutput
                      {
                          id = mx.Id,
b45d55f7   “wangming”   Refactor LqEventS...
631
632
                          refundInfoId = mx.RefundInfoId,
                          billingItemId = mx.BillingItemId,
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
633
634
635
636
                          px = mx.Px,
                          pxmc = mx.Pxmc,
                          pxjg = mx.Pxjg,
                          tkje = mx.Tkje,
b45d55f7   “wangming”   Refactor LqEventS...
637
                          projectNumber = mx.ProjectNumber,
b45d55f7   “wangming”   Refactor LqEventS...
638
639
                          sourceType = mx.SourceType,
                          totalPrice = mx.TotalPrice,
fb9d5c60   “wangming”   feat: 更新LqHytkHyt...
640
                          isEffective = mx.IsEffective,
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
641
642
643
                      };
  
                      // 关联该品项的健康师业绩
0ef47194   “wangming”   Refactor LqHytkHy...
644
                      var jksyjForMx = lqHytkJksyjList.Where(j => j.CardReturn == mx.Id).ToList();
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
645
646
647
                      mxOutput.lqHytkJksyjList = jksyjForMx.Adapt<List<LqHytkJksyjInfoOutput>>();
  
                      // 关联该品项的科技部老师业绩
0ef47194   “wangming”   Refactor LqHytkHy...
648
                      var kjbsyjForMx = lqHytkKjbsyjList.Where(k => k.CardReturn == mx.Id).ToList();
2b23ca5e   “wangming”   更新退卡相关功能,重构退卡信息表及...
649
650
651
652
653
654
655
656
657
658
659
660
661
                      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
662
              }
fb9d5c60   “wangming”   feat: 更新LqHytkHyt...
663
              catch (Exception ex)
96009bc9   hexiaodong   hxd
664
              {
fb9d5c60   “wangming”   feat: 更新LqHytkHyt...
665
                  throw NCCException.Oh($"获取退卡记录详情失败: {ex.Message}");
96009bc9   hexiaodong   hxd
666
667
              }
          }
0ef47194   “wangming”   Refactor LqHytkHy...
668
          #endregion
96009bc9   hexiaodong   hxd
669
670
      }
  }