using Furion.Logging;
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);
message = json["message"]?.ToString();
message = JArray.Parse(message).FirstOrDefault(o => o["type"].ToString() == "text" && !string.IsNullOrWhiteSpace(o["data"]["text"].ToString()))["data"]["text"]?.ToString();
if (string.IsNullOrWhiteSpace(message)) return false;
List results = new();
MatchCollection matches = Regex.Matches(message);
foreach (Match match in matches)
{
string price = match.Groups[1].Value;
string name = match.Groups[2].Value.Replace("\u200b", "").Replace("\u200c", "").Replace("\u200d", ""); // 去除零宽字符
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);
}
}
}