|
@@ -2554,15 +2554,39 @@ namespace TEAMModelOS.Function
|
|
var json = JsonDocument.Parse(message.Body);
|
|
var json = JsonDocument.Parse(message.Body);
|
|
try
|
|
try
|
|
{
|
|
{
|
|
|
|
+ var db = _azureCosmos.GetCosmosClient();
|
|
//await _dingDing.SendBotMsg($"IES5,{Environment.GetEnvironmentVariable("Option:Location")},Imei AF call\n{msg.ToJsonString()}", GroupNames.成都开发測試群組);
|
|
//await _dingDing.SendBotMsg($"IES5,{Environment.GetEnvironmentVariable("Option:Location")},Imei AF call\n{msg.ToJsonString()}", GroupNames.成都开发測試群組);
|
|
if (json.RootElement.TryGetProperty("channel", out JsonElement channel) &&
|
|
if (json.RootElement.TryGetProperty("channel", out JsonElement channel) &&
|
|
json.RootElement.TryGetProperty("userid", out JsonElement userid) &&
|
|
json.RootElement.TryGetProperty("userid", out JsonElement userid) &&
|
|
json.RootElement.TryGetProperty("school", out JsonElement school) &&
|
|
json.RootElement.TryGetProperty("school", out JsonElement school) &&
|
|
json.RootElement.TryGetProperty("stus", out JsonElement stus))
|
|
json.RootElement.TryGetProperty("stus", out JsonElement stus))
|
|
{
|
|
{
|
|
|
|
+ try {
|
|
|
|
+ List<string>? stuids = System.Text.Json.JsonSerializer.Deserialize<List<string>>(stus);
|
|
|
|
+ if (stuids.IsNotEmpty())
|
|
|
|
+ {
|
|
|
|
+ string sqls = $"SELECT value c from c where c.channel='{channel.GetString()}' and c.school='{school.GetString()}' and c.stuid not in ({string.Join(",", stuids!.Select(x => $"'{x}'"))}) ";
|
|
|
|
+ var rs = await _azureCosmos.GetCosmosClient().GetContainer(Constant.TEAMModelOS, Constant.Student).GetList<Imei>(sqls, "Imei");
|
|
|
|
+ if (rs.list.IsNotEmpty())
|
|
|
|
+ {
|
|
|
|
+ foreach (var imei in rs.list)
|
|
|
|
+ {
|
|
|
|
+ imei.channel=null;
|
|
|
|
+ imei.lessonId=null;
|
|
|
|
+ await db.GetContainer(Constant.TEAMModelOS, Constant.Student).ReplaceItemAsync<Imei>(imei, imei.id, new PartitionKey(imei.code));
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ await _dingDing.SendBotMsg($"{_option.Location},清理占用频道号的电子学生证,清理成功,频道号{channel},清理人数{rs.list.Count()}", GroupNames.成都开发測試群組);
|
|
|
|
+ }
|
|
|
|
+ } catch (Exception ex)
|
|
|
|
+ {
|
|
|
|
+ await _dingDing.SendBotMsg($"{_option.Location},清理占用频道号的电子学生证,出现异常", GroupNames.成都开发測試群組);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+
|
|
json.RootElement.TryGetProperty("imeiType", out JsonElement imeiType);
|
|
json.RootElement.TryGetProperty("imeiType", out JsonElement imeiType);
|
|
json.RootElement.TryGetProperty("lessonId", out JsonElement lessonId);
|
|
json.RootElement.TryGetProperty("lessonId", out JsonElement lessonId);
|
|
- var db = _azureCosmos.GetCosmosClient();
|
|
|
|
|
|
+
|
|
foreach (var stu in stus.EnumerateArray())
|
|
foreach (var stu in stus.EnumerateArray())
|
|
{
|
|
{
|
|
await foreach (var item in db.GetContainer(Constant.TEAMModelOS, Constant.Student).GetItemQueryStreamIteratorSql(
|
|
await foreach (var item in db.GetContainer(Constant.TEAMModelOS, Constant.Student).GetItemQueryStreamIteratorSql(
|
|
@@ -2592,7 +2616,7 @@ namespace TEAMModelOS.Function
|
|
imei.imeiType = "tianbo";
|
|
imei.imeiType = "tianbo";
|
|
}
|
|
}
|
|
}
|
|
}
|
|
- await db.GetContainer(Constant.TEAMModelOS, Constant.Student).ReplaceItemAsync<Imei>(imei, imei.id);
|
|
|
|
|
|
+ await db.GetContainer(Constant.TEAMModelOS, Constant.Student).ReplaceItemAsync<Imei>(imei, imei.id,new PartitionKey(imei.code));
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|