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))
|
00486d53
“wangming”
更新多个.DS_Store文件,优...
|
99
|
.Select(it => new LqHytkHytkListOutput
|
96009bc9
hexiaodong
hxd
|
100
101
|
{
id = it.Id,
|
00486d53
“wangming”
更新多个.DS_Store文件,优...
|
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
|
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”
优化开单记录作废功能:添加详细错误...
|
117
|
isEffective = it.IsEffective,
|
fb9d5c60
“wangming”
feat: 更新LqHytkHyt...
|
118
|
cancelRemark = it.CancelRemark,
|
00486d53
“wangming”
更新多个.DS_Store文件,优...
|
119
120
121
122
123
|
})
.MergeTable()
.OrderBy(sidx + " " + input.sort)
.ToPagedListAsync(input.currentPage, input.pageSize);
return PageResult<LqHytkHytkListOutput>.SqlSugarPageResult(data);
|
96009bc9
hexiaodong
hxd
|
124
|
}
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
125
|
#endregion
|
96009bc9
hexiaodong
hxd
|
126
|
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
127
|
#region 创建退卡信息及其关联的品项明细、健康师业绩、科技部老师业绩信息
|
96009bc9
hexiaodong
hxd
|
128
|
/// <summary>
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
129
|
/// 创建退卡信息及其关联的品项明细、健康师业绩、科技部老师业绩信息
|
96009bc9
hexiaodong
hxd
|
130
|
/// </summary>
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
131
132
|
/// <remarks>
/// 创建退卡记录及其关联的品项明细、健康师业绩、科技部老师业绩信息
|
00486d53
“wangming”
更新多个.DS_Store文件,优...
|
133
|
///
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
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
182
183
184
|
/// 示例请求:
/// ```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文件,优...
|
185
|
///
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
186
187
188
189
190
191
192
193
194
195
|
/// 参数说明:
/// - 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
|
196
197
198
199
200
201
|
[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”
更新退卡相关功能,重构退卡信息表及...
|
202
203
|
entity.F_CreateTime = DateTime.Now;
entity.F_CreateUser = userInfo.userId;
|
3e508db5
“wangming”
优化开单记录作废功能:添加详细错误...
|
204
|
entity.IsEffective = StatusEnum.有效.GetHashCode();
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
205
|
entity.Czry = userInfo.userId;
|
00486d53
“wangming”
更新多个.DS_Store文件,优...
|
206
|
|
96009bc9
hexiaodong
hxd
|
207
208
|
try
{
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
209
|
// 开启事务
|
96009bc9
hexiaodong
hxd
|
210
|
_db.BeginTran();
|
00486d53
“wangming”
更新多个.DS_Store文件,优...
|
211
|
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
212
|
// 新增退卡主表记录
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
213
|
var newEntity = await _db.Insertable(entity).IgnoreColumns(ignoreNullColumn: true).ExecuteReturnEntityAsync();
|
96009bc9
hexiaodong
hxd
|
214
|
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
215
216
217
218
|
// 收集所有需要插入的实体,然后批量插入
var allMxEntities = new List<LqHytkMxEntity>();
var allJksyjEntities = new List<LqHytkJksyjEntity>();
var allKjbsyjEntities = new List<LqHytkKjbsyjEntity>();
|
00486d53
“wangming”
更新多个.DS_Store文件,优...
|
219
|
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
220
221
|
// 处理品项明细列表
if (input.lqHytkMxList != null && input.lqHytkMxList.Any())
|
96009bc9
hexiaodong
hxd
|
222
|
{
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
223
|
foreach (var item in input.lqHytkMxList)
|
96009bc9
hexiaodong
hxd
|
224
|
{
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
225
226
227
228
|
// 创建品项明细实体
var lqHytkMxEntity = new LqHytkMxEntity
{
Id = YitIdHelper.NextId().ToString(),
|
b45d55f7
“wangming”
Refactor LqEventS...
|
229
230
231
232
|
RefundInfoId = newEntity.Id,
BillingItemId = item.billingItemId,
CreateTime = DateTime.Now,
CreateUser = userInfo.userId,
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
233
234
235
236
|
Px = item.px,
Pxmc = item.pxmc,
Pxjg = item.pxjg,
Tkje = item.tkje,
|
b45d55f7
“wangming”
Refactor LqEventS...
|
237
|
ProjectNumber = item.F_ProjectNumber ?? 1,
|
b45d55f7
“wangming”
Refactor LqEventS...
|
238
239
|
SourceType = item.F_SourceType,
TotalPrice = item.F_TotalPrice ?? (item.pxjg * (item.F_ProjectNumber ?? 1)),
|
3e508db5
“wangming”
优化开单记录作废功能:添加详细错误...
|
240
|
IsEffective = StatusEnum.有效.GetHashCode(),
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
241
242
|
};
allMxEntities.Add(lqHytkMxEntity);
|
00486d53
“wangming”
更新多个.DS_Store文件,优...
|
243
|
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
244
245
246
247
248
|
// 收集该品项关联的健康师业绩
if (item.lqHytkJksyjList != null && item.lqHytkJksyjList.Any())
{
foreach (var ijks_tem in item.lqHytkJksyjList)
{
|
3e508db5
“wangming”
优化开单记录作废功能:添加详细错误...
|
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,
|
3e508db5
“wangming”
优化开单记录作废功能:添加详细错误...
|
264
265
266
|
CardReturn = lqHytkMxEntity.Id,
IsEffective = StatusEnum.有效.GetHashCode(),
}
|
00486d53
“wangming”
更新多个.DS_Store文件,优...
|
267
|
);
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
268
269
|
}
}
|
00486d53
“wangming”
更新多个.DS_Store文件,优...
|
270
|
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
271
272
273
274
275
|
// 收集该品项关联的科技部老师业绩
if (item.lqHytkKjbsyjList != null && item.lqHytkKjbsyjList.Any())
{
foreach (var ikjbs_tem in item.lqHytkKjbsyjList)
{
|
00486d53
“wangming”
更新多个.DS_Store文件,优...
|
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,
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
291
|
CardReturn = lqHytkMxEntity.Id,
|
3e508db5
“wangming”
优化开单记录作废功能:添加详细错误...
|
292
|
IsEffective = StatusEnum.有效.GetHashCode(),
|
00486d53
“wangming”
更新多个.DS_Store文件,优...
|
293
294
|
}
);
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
295
296
|
}
}
|
96009bc9
hexiaodong
hxd
|
297
|
}
|
96009bc9
hexiaodong
hxd
|
298
|
}
|
00486d53
“wangming”
更新多个.DS_Store文件,优...
|
299
|
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
300
301
|
// 批量插入品项明细
if (allMxEntities.Any())
|
96009bc9
hexiaodong
hxd
|
302
|
{
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
303
|
await _db.Insertable(allMxEntities).ExecuteCommandAsync();
|
96009bc9
hexiaodong
hxd
|
304
|
}
|
00486d53
“wangming”
更新多个.DS_Store文件,优...
|
305
|
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
306
307
|
// 批量插入健康师业绩
if (allJksyjEntities.Any())
|
96009bc9
hexiaodong
hxd
|
308
|
{
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
309
|
await _db.Insertable(allJksyjEntities).ExecuteCommandAsync();
|
96009bc9
hexiaodong
hxd
|
310
|
}
|
00486d53
“wangming”
更新多个.DS_Store文件,优...
|
311
|
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
312
313
|
// 批量插入科技部老师业绩
if (allKjbsyjEntities.Any())
|
96009bc9
hexiaodong
hxd
|
314
|
{
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
315
|
await _db.Insertable(allKjbsyjEntities).ExecuteCommandAsync();
|
96009bc9
hexiaodong
hxd
|
316
|
}
|
00486d53
“wangming”
更新多个.DS_Store文件,优...
|
317
|
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
318
319
320
321
322
323
324
|
// 关闭事务
_db.CommitTran();
}
catch (Exception ex)
{
_db.RollbackTran();
throw NCCException.Oh(ErrorCode.COM1005, ex.Message);
|
96009bc9
hexiaodong
hxd
|
325
326
|
}
}
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
327
|
#endregion
|
96009bc9
hexiaodong
hxd
|
328
|
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
329
|
#region 更新退卡信息及其关联的品项明细、健康师业绩、科技部老师业绩信息
|
96009bc9
hexiaodong
hxd
|
330
|
/// <summary>
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
331
|
/// 更新退卡信息及其关联的品项明细、健康师业绩、科技部老师业绩信息
|
96009bc9
hexiaodong
hxd
|
332
|
/// </summary>
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
333
334
335
336
337
338
339
340
341
342
|
/// <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
|
343
344
345
|
[HttpPut("{id}")]
public async Task Update(string id, [FromBody] LqHytkHytkUpInput input)
{
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
346
|
var userInfo = await _userManager.GetUserInfo();
|
96009bc9
hexiaodong
hxd
|
347
|
var entity = input.Adapt<LqHytkHytkEntity>();
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
348
349
350
|
entity.Id = id;
entity.F_ModifyTime = DateTime.Now;
entity.F_ModifyUser = userInfo.userId;
|
00486d53
“wangming”
更新多个.DS_Store文件,优...
|
351
|
|
96009bc9
hexiaodong
hxd
|
352
353
|
try
{
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
354
|
// 开启事务
|
96009bc9
hexiaodong
hxd
|
355
|
_db.BeginTran();
|
00486d53
“wangming”
更新多个.DS_Store文件,优...
|
356
|
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
357
358
|
// 更新退卡主表记录
await _db.Updateable(entity).IgnoreColumns(true).ExecuteCommandAsync();
|
00486d53
“wangming”
更新多个.DS_Store文件,优...
|
359
|
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
360
|
// 删除原有的关联数据
|
b45d55f7
“wangming”
Refactor LqEventS...
|
361
|
await _db.Deleteable<LqHytkMxEntity>().Where(x => x.RefundInfoId == id).ExecuteCommandAsync();
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
362
363
|
await _db.Deleteable<LqHytkJksyjEntity>().Where(x => x.Gltkbh == id).ExecuteCommandAsync();
await _db.Deleteable<LqHytkKjbsyjEntity>().Where(x => x.Gltkbh == id).ExecuteCommandAsync();
|
00486d53
“wangming”
更新多个.DS_Store文件,优...
|
364
|
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
365
366
367
368
|
// 收集所有需要插入的实体,然后批量插入
var allMxEntities = new List<LqHytkMxEntity>();
var allJksyjEntities = new List<LqHytkJksyjEntity>();
var allKjbsyjEntities = new List<LqHytkKjbsyjEntity>();
|
00486d53
“wangming”
更新多个.DS_Store文件,优...
|
369
|
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
370
371
|
// 处理品项明细列表
if (input.lqHytkMxList != null && input.lqHytkMxList.Any())
|
96009bc9
hexiaodong
hxd
|
372
|
{
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
373
|
foreach (var item in input.lqHytkMxList)
|
96009bc9
hexiaodong
hxd
|
374
|
{
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
375
376
377
378
|
// 创建品项明细实体
var lqHytkMxEntity = new LqHytkMxEntity
{
Id = YitIdHelper.NextId().ToString(),
|
b45d55f7
“wangming”
Refactor LqEventS...
|
379
380
381
382
|
RefundInfoId = id,
BillingItemId = item.billingItemId,
CreateTime = DateTime.Now,
CreateUser = userInfo.userId,
|
dac8767e
“wangming”
111111111
|
383
|
Tksj = input.tksj,
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
384
385
386
387
|
Px = item.px,
Pxmc = item.pxmc,
Pxjg = item.pxjg,
Tkje = item.tkje,
|
b45d55f7
“wangming”
Refactor LqEventS...
|
388
|
ProjectNumber = item.F_ProjectNumber ?? 1,
|
b45d55f7
“wangming”
Refactor LqEventS...
|
389
390
|
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
|
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文件,优...
|
415
416
|
}
);
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
417
418
|
}
}
|
00486d53
“wangming”
更新多个.DS_Store文件,优...
|
419
|
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
420
421
422
423
424
|
// 收集该品项关联的科技部老师业绩
if (item.lqHytkKjbsyjList != null && item.lqHytkKjbsyjList.Any())
{
foreach (var ikjbs_tem in item.lqHytkKjbsyjList)
{
|
00486d53
“wangming”
更新多个.DS_Store文件,优...
|
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
|
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文件,优...
|
440
441
|
}
);
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
442
443
|
}
}
|
96009bc9
hexiaodong
hxd
|
444
|
}
|
96009bc9
hexiaodong
hxd
|
445
|
}
|
00486d53
“wangming”
更新多个.DS_Store文件,优...
|
446
|
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
447
448
449
450
451
|
// 批量插入品项明细
if (allMxEntities.Any())
{
await _db.Insertable(allMxEntities).ExecuteCommandAsync();
}
|
00486d53
“wangming”
更新多个.DS_Store文件,优...
|
452
|
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
453
454
455
456
457
|
// 批量插入健康师业绩
if (allJksyjEntities.Any())
{
await _db.Insertable(allJksyjEntities).ExecuteCommandAsync();
}
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
458
459
460
461
462
|
// 批量插入科技部老师业绩
if (allKjbsyjEntities.Any())
{
await _db.Insertable(allKjbsyjEntities).ExecuteCommandAsync();
}
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
463
|
// 关闭事务
|
96009bc9
hexiaodong
hxd
|
464
465
|
_db.CommitTran();
}
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
466
|
catch (Exception ex)
|
96009bc9
hexiaodong
hxd
|
467
|
{
|
96009bc9
hexiaodong
hxd
|
468
|
_db.RollbackTran();
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
469
|
throw NCCException.Oh(ErrorCode.COM1005, ex.Message);
|
96009bc9
hexiaodong
hxd
|
470
471
|
}
}
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
472
|
#endregion
|
96009bc9
hexiaodong
hxd
|
473
|
|
2164125c
“wangming”
feat: 删除LqXhmxb相关...
|
474
|
#region 作废退卡信息
|
96009bc9
hexiaodong
hxd
|
475
|
/// <summary>
|
2164125c
“wangming”
feat: 删除LqXhmxb相关...
|
476
|
/// 作废退卡信息
|
96009bc9
hexiaodong
hxd
|
477
|
/// </summary>
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
478
|
/// <param name="id">主键</param>
|
96009bc9
hexiaodong
hxd
|
479
|
/// <returns></returns>
|
2164125c
“wangming”
feat: 删除LqXhmxb相关...
|
480
|
[HttpPut("VoidRefundCardInfo/{id}")]
|
fb9d5c60
“wangming”
feat: 更新LqHytkHyt...
|
481
|
public async Task<dynamic> VoidRefundCardInfo(string id, [FromQuery] string remarks = null)
|
96009bc9
hexiaodong
hxd
|
482
|
{
|
2164125c
“wangming”
feat: 删除LqXhmxb相关...
|
483
|
try
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
484
|
{
|
2164125c
“wangming”
feat: 删除LqXhmxb相关...
|
485
486
487
488
489
490
491
492
|
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”
优化开单记录作废功能:添加详细错误...
|
493
|
entity.IsEffective = StatusEnum.无效.GetHashCode();
|
2164125c
“wangming”
feat: 删除LqXhmxb相关...
|
494
|
entity.F_ModifyTime = DateTime.Now;
|
fb9d5c60
“wangming”
feat: 更新LqHytkHyt...
|
495
|
entity.CancelRemark = remarks;
|
2164125c
“wangming”
feat: 删除LqXhmxb相关...
|
496
497
|
await _db.Updateable(entity).ExecuteCommandAsync();
// 更新明细表
|
3e508db5
“wangming”
优化开单记录作废功能:添加详细错误...
|
498
|
await _db.Updateable<LqHytkMxEntity>().SetColumns(it => new LqHytkMxEntity { IsEffective = StatusEnum.无效.GetHashCode() }).Where(w => w.RefundInfoId == id).ExecuteCommandAsync();
|
2164125c
“wangming”
feat: 删除LqXhmxb相关...
|
499
|
// 更新健康师业绩表
|
3e508db5
“wangming”
优化开单记录作废功能:添加详细错误...
|
500
|
await _db.Updateable<LqHytkJksyjEntity>().SetColumns(it => new LqHytkJksyjEntity { IsEffective = StatusEnum.无效.GetHashCode() }).Where(w => w.Gltkbh == id).ExecuteCommandAsync();
|
2164125c
“wangming”
feat: 删除LqXhmxb相关...
|
501
|
// 更新科技部业绩表
|
3e508db5
“wangming”
优化开单记录作废功能:添加详细错误...
|
502
|
await _db.Updateable<LqHytkKjbsyjEntity>().SetColumns(it => new LqHytkKjbsyjEntity { IsEffective = StatusEnum.无效.GetHashCode() }).Where(w => w.Gltkbh == id).ExecuteCommandAsync();
|
2164125c
“wangming”
feat: 删除LqXhmxb相关...
|
503
504
505
506
507
508
509
510
|
// 提交事务
_db.CommitTran();
return entity;
}
catch (Exception ex)
{
_db.RollbackTran();
throw NCCException.Oh($"删除退卡信息失败: {ex.Message}");
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
511
512
|
}
}
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
513
|
#endregion
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
514
|
|
dac8767e
“wangming”
111111111
|
515
516
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
|
#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: 新增门店类别枚举和耗卡...
|
549
|
await _db.Deleteable<LqHytkMxEntity>().Where(x => x.RefundInfoId == id).ExecuteCommandAsync();
|
dac8767e
“wangming”
111111111
|
550
551
|
// 2. 删除退卡健康师业绩记录
|
ce74473f
“wangming”
feat: 新增门店类别枚举和耗卡...
|
552
|
await _db.Deleteable<LqHytkJksyjEntity>().Where(x => x.Gltkbh == id).ExecuteCommandAsync();
|
dac8767e
“wangming”
111111111
|
553
554
|
// 3. 删除退卡科技部老师业绩记录
|
ce74473f
“wangming”
feat: 新增门店类别枚举和耗卡...
|
555
|
await _db.Deleteable<LqHytkKjbsyjEntity>().Where(x => x.Gltkbh == id).ExecuteCommandAsync();
|
dac8767e
“wangming”
111111111
|
556
557
|
// 4. 删除退卡主表记录
|
ce74473f
“wangming”
feat: 新增门店类别枚举和耗卡...
|
558
|
await _db.Deleteable<LqHytkHytkEntity>().Where(x => x.Id == id).ExecuteCommandAsync();
|
dac8767e
“wangming”
111111111
|
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
|
// 提交事务
_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...
|
580
|
#region 获取退卡信息详情
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
581
582
583
584
585
586
|
/// <summary>
/// 获取退卡信息详情
/// </summary>
/// <remarks>
/// 获取退卡记录及其关联的品项明细、健康师业绩、科技部老师业绩信息
/// 按照退卡的完整格式返回数据,不包含汇总信息
|
00486d53
“wangming”
更新多个.DS_Store文件,优...
|
587
|
///
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
588
589
590
591
592
593
594
595
596
597
598
599
600
601
|
/// 返回数据结构:
/// - 主表信息:退卡基础信息、门店信息、会员信息、退卡金额等
/// - 品项明细列表:每个品项包含完整的项目信息(项目次数、是否有效、来源类型等)
/// - 健康师业绩列表:按品项关联的健康师业绩信息
/// - 科技部老师业绩列表:按品项关联的科技部老师业绩信息
/// </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
|
602
603
|
try
{
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
604
|
// 1. 查询主表信息
|
fb9d5c60
“wangming”
feat: 更新LqHytkHyt...
|
605
|
var entity = await _db.Queryable<LqHytkHytkEntity>().Where(p => p.Id == id).FirstAsync();
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
606
607
|
if (entity == null)
{
|
fb9d5c60
“wangming”
feat: 更新LqHytkHyt...
|
608
|
throw NCCException.Oh("退卡记录不存在");
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
609
|
}
|
96009bc9
hexiaodong
hxd
|
610
|
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
611
612
613
|
var output = entity.Adapt<LqHytkHytkInfoOutput>();
// 2. 查询品项明细列表
|
b45d55f7
“wangming”
Refactor LqEventS...
|
614
|
var lqHytkMxList = await _db.Queryable<LqHytkMxEntity>().Where(w => w.RefundInfoId == entity.Id).ToListAsync();
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
615
616
|
// 3. 查询健康师业绩列表
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
617
|
var lqHytkJksyjList = await _db.Queryable<LqHytkJksyjEntity>().Where(w => w.Gltkbh == entity.Id).ToListAsync();
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
618
619
|
// 4. 查询科技部老师业绩列表
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
620
|
var lqHytkKjbsyjList = await _db.Queryable<LqHytkKjbsyjEntity>().Where(w => w.Gltkbh == entity.Id).ToListAsync();
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
621
622
623
624
625
626
627
628
|
// 5. 构建品项明细输出,每个品项关联对应的业绩信息
var mxOutputList = new List<LqHytkMxInfoOutput>();
foreach (var mx in lqHytkMxList)
{
var mxOutput = new LqHytkMxInfoOutput
{
id = mx.Id,
|
b45d55f7
“wangming”
Refactor LqEventS...
|
629
630
|
refundInfoId = mx.RefundInfoId,
billingItemId = mx.BillingItemId,
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
631
632
633
634
|
px = mx.Px,
pxmc = mx.Pxmc,
pxjg = mx.Pxjg,
tkje = mx.Tkje,
|
b45d55f7
“wangming”
Refactor LqEventS...
|
635
|
projectNumber = mx.ProjectNumber,
|
b45d55f7
“wangming”
Refactor LqEventS...
|
636
637
|
sourceType = mx.SourceType,
totalPrice = mx.TotalPrice,
|
fb9d5c60
“wangming”
feat: 更新LqHytkHyt...
|
638
|
isEffective = mx.IsEffective,
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
639
640
641
|
};
// 关联该品项的健康师业绩
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
642
|
var jksyjForMx = lqHytkJksyjList.Where(j => j.CardReturn == mx.Id).ToList();
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
643
644
645
|
mxOutput.lqHytkJksyjList = jksyjForMx.Adapt<List<LqHytkJksyjInfoOutput>>();
// 关联该品项的科技部老师业绩
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
646
|
var kjbsyjForMx = lqHytkKjbsyjList.Where(k => k.CardReturn == mx.Id).ToList();
|
2b23ca5e
“wangming”
更新退卡相关功能,重构退卡信息表及...
|
647
648
649
650
651
652
653
654
655
656
657
658
659
|
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
|
660
|
}
|
fb9d5c60
“wangming”
feat: 更新LqHytkHyt...
|
661
|
catch (Exception ex)
|
96009bc9
hexiaodong
hxd
|
662
|
{
|
fb9d5c60
“wangming”
feat: 更新LqHytkHyt...
|
663
|
throw NCCException.Oh($"获取退卡记录详情失败: {ex.Message}");
|
96009bc9
hexiaodong
hxd
|
664
665
|
}
}
|
0ef47194
“wangming”
Refactor LqHytkHy...
|
666
|
#endregion
|
96009bc9
hexiaodong
hxd
|
667
668
|
}
}
|