using Furion.Logging; using static Microsoft.Extensions.Logging.EventSource.LoggingEventSource; namespace NapCatRobotClient.Service.Group.TextProcess { /// /// 保存或更新物品价格 /// public class InertOrUpdateGoodsInfoProcess { private static Regex Regex = new Regex(@"价格[::](\d+(?:\.\d+)?[万亿])\s+([^\s]+)"); public static async Task ProcessGroupRequest(string groupId, string message) { try { if (message.Contains("不鼓励不保障")) { JObject json = JObject.Parse(message); string jsonMessage = json["message"]?.ToString(); jsonMessage = JArray.Parse(jsonMessage) .Where(x => x?["type"]?.ToString() == "text") .Select(x => x?["data"]?["text"]?.ToString()) .FirstOrDefault(t => !string.IsNullOrWhiteSpace(t) && new string[] { "不鼓励不保障" }.All(k => t.Contains(k))); if (string.IsNullOrWhiteSpace(jsonMessage)) return false; List results = new(); MatchCollection matches = Regex.Matches(jsonMessage); foreach (Match match in matches) { string price = match.Groups[1].Value; string name = match.Groups[2].Value.Replace("\u200b", "").Replace("\u200c", "").Replace("\u200d", "").Replace("?", ""); // 去除零宽字符 GoodsInfo gds = new() { Name = name, Price = Utils.ParseChineseNumber(price), ShowPriceDesc = price, LastUpdateTime = DateTime.Now }; results.Add(gds); } foreach (GoodsInfo item in results) { RedisHelper.Client.HSet(RedisPrefix.GoodsKey, item.Name, item); } } } catch (Exception ex) { Log.Error($@"{DateTime.Now:yyyy-MM-dd HH:mm:ss} 保存或更新物品价格 发生异常,异常信息:{ex.Message},异常堆栈:{ex.StackTrace}", true); } return await Task.FromResult(true); } } }