omega-make/Task/MakeSqlHelper.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 MakeSqlHelper
{
    public readonly static MakeSqlHelper Instance = new MakeSqlHelper();
    private MakeSqlHelper()
    { }

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

    public void DoWorks(string content)
    {
        try
        {
            if(!string.IsNullOrEmpty(content))
            {
                DoQueue(content);
            }
        }
        catch (Exception ex)
        {
            Utils.WriteLog(DateTime.Now.ToString() + "\n" + ex, "生成SQL异常");
        }
    }

    public void DoQueue(string content)
    { 
        
    }

}