using CoreCms.Net.Configuration;
|
using CoreCms.Net.IServices;
|
using CoreCms.Net.Loging;
|
using InitQ.Abstractions;
|
using InitQ.Attributes;
|
using Newtonsoft.Json;
|
using NPOI.Util;
|
using System;
|
using System.Collections.Generic;
|
using System.ComponentModel.Design;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace CoreCms.Net.RedisMQ
|
{
|
public class DistributionAchievementMQ : IRedisSubscribe
|
{
|
private ICoreCmsDistributionServices _dbService;
|
|
public DistributionAchievementMQ(ICoreCmsDistributionServices dictionaryService)
|
{
|
_dbService = dictionaryService;
|
|
}
|
/// <summary>
|
/// 处理代理业绩商订单
|
/// </summary>
|
/// <param name="message"></param>
|
[Subscribe(RedisMessageQueueKey.DistributionAchievementOder)]
|
public async void DistributionAchievementOder(string message)
|
{
|
try
|
{
|
var Param = JsonConvert.DeserializeObject<CreateDAOrderInParam>(message);
|
if (await _dbService.CreateDistributionAchievementOrder(Param))
|
return;
|
else
|
{
|
NLogUtil.WriteAll(NLog.LogLevel.Fatal, LogType.RedisMessageQueue, "经销商处理经销商业绩单失败", $"CreateDistributionAchievementOrder 返回失败, 参数：{message}");
|
return;
|
}
|
}
|
catch (Exception e)
|
{
|
NLogUtil.WriteAll(NLog.LogLevel.Fatal, LogType.RedisMessageQueue, "经销商处理经销商业绩单失败", $" 错误提示，{e.Message}， 输入参数：{message}");
|
throw;
|
}
|
|
|
|
|
|
}
|
|
|
|
}
|
}
|
