321
This commit is contained in:
zpc
parent
1796ec7b50
commit
927ac3045f
|
|
@ -38,62 +38,81 @@ namespace CoreCms.Net.Task
|
|||
|
||||
public async System.Threading.Tasks.Task Execute()
|
||||
{
|
||||
|
||||
Console.WriteLine("SQReservationJob");
|
||||
Console.WriteLine($"[SQReservationJob] 执行开始 @ {DateTime.Now:yyyy-MM-dd HH:mm:ss}");
|
||||
var now = DateTime.Now;
|
||||
Console.WriteLine("将已到结束时间的预约置为已结束（3）");
|
||||
Console.WriteLine("[SQReservationJob] 步骤1：将已到结束时间的预约置为已结束（3）");
|
||||
// 1) 将已到结束时间的预约置为已结束（3）
|
||||
var endedList = await _reservationsServices.QueryListByClauseAsync(
|
||||
r => r.status == 2 && r.end_time <= now,
|
||||
r => r.id, OrderByType.Asc);
|
||||
Console.WriteLine($"[SQReservationJob] 步骤1：查询到待结束记录数量 = {endedList?.Count ?? 0}");
|
||||
if (endedList != null && endedList.Count > 0)
|
||||
{
|
||||
var changedCount = 0;
|
||||
foreach (var item in endedList)
|
||||
{
|
||||
Console.WriteLine($"[SQReservationJob] 步骤1：预约ID={item.id} 从状态2->3，end_time={item.end_time:yyyy-MM-dd HH:mm:ss}");
|
||||
item.status = 3;
|
||||
item.updated_at = now;
|
||||
changedCount++;
|
||||
}
|
||||
Console.WriteLine($"[SQReservationJob] 步骤1：批量更新记录数 = {changedCount}");
|
||||
await _reservationsServices.UpdateAsync(endedList);
|
||||
}
|
||||
Console.WriteLine("将开始时间已到且未结束的预约置为进行中");
|
||||
Console.WriteLine("[SQReservationJob] 步骤2：将开始时间已到且未结束的预约置为进行中（2）");
|
||||
// 2) 将开始时间已到且未结束的预约置为进行中（2）
|
||||
var startedList = await _reservationsServices.QueryListByClauseAsync(
|
||||
r => r.status == 1 && r.start_time <= now && r.end_time > now,
|
||||
r => r.id, OrderByType.Asc);
|
||||
Console.WriteLine($"[SQReservationJob] 步骤2：查询到待置为进行中记录数量 = {startedList?.Count ?? 0}");
|
||||
if (startedList != null && startedList.Count > 0)
|
||||
{
|
||||
var changedCount = 0;
|
||||
foreach (var item in startedList)
|
||||
{
|
||||
Console.WriteLine($"[SQReservationJob] 步骤2：预约ID={item.id} 从状态1->2，start_time={item.start_time:yyyy-MM-dd HH:mm:ss} end_time={item.end_time:yyyy-MM-dd HH:mm:ss}");
|
||||
item.status = 2;
|
||||
item.updated_at = now;
|
||||
changedCount++;
|
||||
}
|
||||
Console.WriteLine($"[SQReservationJob] 步骤2：批量更新记录数 = {changedCount}");
|
||||
await _reservationsServices.UpdateAsync(startedList);
|
||||
}
|
||||
|
||||
|
||||
// 2.5) 到达开始时间但人数未满的预约置为取消（4）
|
||||
Console.WriteLine("到达开始时间但人数未满的预约置为取消（4）");
|
||||
Console.WriteLine("[SQReservationJob] 步骤2.5：到达开始时间但人数未满的预约置为取消（4）");
|
||||
var toCancelList = await _reservationsServices.QueryListByClauseAsync(
|
||||
r => r.status == 0 && r.start_time <= now && r.end_time > now,
|
||||
r => r.id, OrderByType.Asc);
|
||||
Console.WriteLine($"[SQReservationJob] 步骤2.5：查询到候选取消记录数量 = {toCancelList?.Count ?? 0}");
|
||||
if (toCancelList != null && toCancelList.Count > 0)
|
||||
{
|
||||
var examineCount = 0;
|
||||
foreach (var item in toCancelList)
|
||||
{
|
||||
var count = await _participantsServices.GetCountAsync(p => p.reservation_id == item.id && p.status == 0);
|
||||
Console.WriteLine($"[SQReservationJob] 步骤2.5：预约ID={item.id} 参与人数={count}/{item.player_count}，start_time={item.start_time:yyyy-MM-dd HH:mm:ss}");
|
||||
if (count < item.player_count)
|
||||
{
|
||||
Console.WriteLine($"[SQReservationJob] 步骤2.5：预约ID={item.id} 人数未满，置为取消(4)");
|
||||
item.status = 4;
|
||||
item.updated_at = now;
|
||||
}
|
||||
examineCount++;
|
||||
}
|
||||
var toCancelChanged = toCancelList.Where(x => x.status == 4).ToList();
|
||||
Console.WriteLine($"[SQReservationJob] 步骤2.5：需要更新为取消的记录数 = {toCancelChanged.Count}");
|
||||
if (toCancelChanged.Count > 0)
|
||||
{
|
||||
await _reservationsServices.UpdateAsync(toCancelChanged);
|
||||
Console.WriteLine($"[SQReservationJob] 步骤2.5：已更新为取消的记录数 = {toCancelChanged.Count}");
|
||||
foreach (var item in toCancelChanged)
|
||||
{
|
||||
Console.WriteLine($"[SQReservationJob] 步骤2.5：准备通知预约ID={item.id} 的参与用户");
|
||||
var userList = await _participantsServices.QueryListByClauseAsync(p => p.reservation_id == item.id && p.status == 0);
|
||||
Console.WriteLine($"[SQReservationJob] 步骤2.5：预约ID={item.id} 需通知用户数量 = {userList.Count}");
|
||||
var pushed = 0;
|
||||
foreach (var user in userList)
|
||||
{
|
||||
JObject parameters = new JObject();
|
||||
|
|
@ -105,12 +124,15 @@ namespace CoreCms.Net.Task
|
|||
@params.Add("parameters", parameters);
|
||||
var data = new
|
||||
{
|
||||
user.user_id,
|
||||
userId = user.user_id,
|
||||
code = "reservation_change",
|
||||
parameters = @params
|
||||
};
|
||||
await _redisOperationRepository.ListLeftPushAsync(RedisMessageQueueKey.SendWxTemplateMessage, JsonConvert.SerializeObject(data));
|
||||
pushed++;
|
||||
Console.WriteLine($"[SQReservationJob] 步骤2.5：已入队通知 -> reservation_change, user_id={user.user_id}");
|
||||
}
|
||||
Console.WriteLine($"[SQReservationJob] 步骤2.5：预约ID={item.id} 通知入队完成，总计 {pushed} 条");
|
||||
|
||||
|
||||
}
|
||||
|
|
@ -122,31 +144,39 @@ namespace CoreCms.Net.Task
|
|||
}
|
||||
|
||||
// 3) 开始前30分钟内，人数已凑齐则置为锁定（1）
|
||||
Console.WriteLine("开始前30分钟内，人数已凑齐则置为锁定（1）");
|
||||
Console.WriteLine("[SQReservationJob] 步骤3：开始前30分钟内，人数已凑齐则置为锁定（1）");
|
||||
var threshold = now.AddMinutes(30);
|
||||
var toLockList = await _reservationsServices.QueryListByClauseAsync(
|
||||
r => r.status == 0 && r.start_time > now && r.start_time <= threshold,
|
||||
r => r.id, OrderByType.Asc);
|
||||
Console.WriteLine($"[SQReservationJob] 步骤3：查询到候选锁定记录数量 = {toLockList?.Count ?? 0}，阈值时间={threshold:yyyy-MM-dd HH:mm:ss}");
|
||||
if (toLockList != null && toLockList.Count > 0)
|
||||
{
|
||||
foreach (var item in toLockList)
|
||||
{
|
||||
// 当前有效参与人数（未退出）
|
||||
var count = await _participantsServices.GetCountAsync(p => p.reservation_id == item.id && p.status == 0);
|
||||
Console.WriteLine($"[SQReservationJob] 步骤3：预约ID={item.id} 参与人数={count}/{item.player_count}，start_time={item.start_time:yyyy-MM-dd HH:mm:ss}");
|
||||
if (count >= item.player_count)
|
||||
{
|
||||
Console.WriteLine($"[SQReservationJob] 步骤3：预约ID={item.id} 人数已满，置为锁定(1)");
|
||||
item.status = 1;
|
||||
item.updated_at = now;
|
||||
}
|
||||
}
|
||||
// 仅更新被修改的项
|
||||
var changed = toLockList.Where(x => x.status == 1).ToList();
|
||||
Console.WriteLine($"[SQReservationJob] 步骤3：需要更新为锁定的记录数 = {changed.Count}");
|
||||
if (changed.Count > 0)
|
||||
{
|
||||
await _reservationsServices.UpdateAsync(changed);
|
||||
Console.WriteLine($"[SQReservationJob] 步骤3：已更新为锁定的记录数 = {changed.Count}");
|
||||
foreach (var item in changed)
|
||||
{
|
||||
Console.WriteLine($"[SQReservationJob] 步骤3：准备通知预约ID={item.id} 的参与用户");
|
||||
var userList = await _participantsServices.QueryListByClauseAsync(p => p.reservation_id == item.id && p.status == 0);
|
||||
Console.WriteLine($"[SQReservationJob] 步骤3：预约ID={item.id} 需通知用户数量 = {userList.Count}");
|
||||
var pushed = 0;
|
||||
foreach (var user in userList)
|
||||
{
|
||||
JObject parameters = new JObject();
|
||||
|
|
@ -158,18 +188,22 @@ namespace CoreCms.Net.Task
|
|||
@params.Add("parameters", parameters);
|
||||
var data = new
|
||||
{
|
||||
user.user_id,
|
||||
userId = user.user_id,
|
||||
code = "reservation_success",
|
||||
parameters = @params
|
||||
};
|
||||
await _redisOperationRepository.ListLeftPushAsync(RedisMessageQueueKey.SendWxTemplateMessage, JsonConvert.SerializeObject(data));
|
||||
pushed++;
|
||||
Console.WriteLine($"[SQReservationJob] 步骤3：已入队通知 -> reservation_success, user_id={user.user_id}");
|
||||
}
|
||||
Console.WriteLine($"[SQReservationJob] 步骤3：预约ID={item.id} 通知入队完成，总计 {pushed} 条");
|
||||
|
||||
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
Console.WriteLine($"[SQReservationJob] 执行结束 @ {DateTime.Now:yyyy-MM-dd HH:mm:ss}");
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
|
|||
|
|
@ -5,5 +5,13 @@
|
|||
"Microsoft": "Warning",
|
||||
"Microsoft.Hosting.Lifetime": "Information"
|
||||
}
|
||||
},
|
||||
//服务器配置
|
||||
"Kestrel": {
|
||||
"Endpoints": {
|
||||
"Http": {
|
||||
"Url": "http://*:2016"
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
|
|||
Loading…
Reference in New Issue
Block a user