kxs-main/AppStart/Helper/SycnSpServer/SycnSpService.cs

using System;
using System.Collections.Generic;
using System.Linq;
using MySystem.Models;
using Library;
using LitJson;

namespace MySystem
{
    public class SycnSpService
    {
        public readonly static SycnSpService Instance = new SycnSpService();
        private SycnSpService()
        { }

        public void Start(JobMqMsg jobInfo)
        {
            try
            {
                function.WriteLog(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "SycnSpServer监控");
                string OrderString = jobInfo.OrderString;
                function.WriteLog(OrderString, "SycnSpServer监控");
                if (OrderString.StartsWith("Sp:") && OrderString.EndsWith(":SpServer"))
                {
                    function.WriteLog("ok", "SycnSpServer监控");
                    string Kind = OrderString.Split(':')[1];
                    function.WriteLog("Kind:" + Kind, "SycnSpServer监控");
                    dosomething(Kind);
                    function.WriteLog("finish:" + Kind, "SycnSpServer监控");
                    function.WriteLog("\r\n\r\n\r\n", "SycnSpServer监控");
                    jobInfo.Status = 1;
                    jobInfo.Msg = "执行完成";
                    RabbitMQClient.Instance.SendMsg(Newtonsoft.Json.JsonConvert.SerializeObject(jobInfo), "SycnSpServerBack");
                }
            }
            catch (Exception ex)
            {
                function.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "sycn_sp_server_err");
            }
        }

        public void dosomething(string Kind)
        { 
            if (Kind == "bind")
            {
                SycnSpBindService.Instance.Start();
            }
            else if (Kind == "active")
            { 
                SycnSpActiveService.Instance.Start();
            }
            else if (Kind == "trade")
            { 
                SycnSpTradeService.Instance.Start();
            }
            else if (Kind == "merchant")
            { 
                SycnSpMerchantService.Instance.Start();
            }
        }
    }
}