kxs-sp-net7/Task/SpDataHelper.cs

using System;
using System.Collections.Generic;
using System.IO;
using System.Text;
using System.Threading;
using Common;
using Infrastructure;
using Services;
using Model;
using LitJson;

public class SpDataHelper
{
    public readonly static SpDataHelper Instance = new SpDataHelper();
    private SpDataHelper()
    { }

    public void Start(string QueueName)
    {
        RabbitMQClient.Instance.StartReceive(QueueName, content => DoWorks(content));
    }

    public void DoWorks(string content)
    {
        try
        {
            if(!string.IsNullOrEmpty(content))
            {
                string[] data = content.Split(new string[]{ "#cut#" }, StringSplitOptions.None);
                string tableName = data[0];
                string jsonString = data[1];
                if(tableName == "TradeRecord") DoQueueTrade(jsonString);
            }
        }
        catch (Exception ex)
        {
            Utils.WriteLog(DateTime.Now.ToString() + "\n" + ex, "SP原始数据入库异常");
        }
    }

    public void DoQueueTrade(string jsonString)
    { 
        KxsTradeRecord data = Newtonsoft.Json.JsonConvert.DeserializeObject<KxsTradeRecord>(jsonString);
        var tradeService = App.GetService<IKxsTradeRecordService>();
        tradeService.addKxsTradeRecord(data);
    }

}