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

using System;
using System.Collections.Generic;
using System.Linq;
using MySystem.SpModels;
using Library;
using LitJson;
using System.Threading;

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

        public void Start()
        {
            Thread th = new Thread(StartDo);
            th.IsBackground = true;
            th.Start();
        }

        public void StartDo()
        {
            while (true)
            {
                try
                {
                    List<string> SaveDataBindIds = Utils.Instance.SaveDataBindIds();
                    SaveDataBindIds.Add("36");
                    WebCMSEntities spdb = new WebCMSEntities();
                    PxcModels.WebCMSEntities db = new PxcModels.WebCMSEntities();
                    MpMainModels2.WebCMSEntities mpdb = new MpMainModels2.WebCMSEntities();
                    JavaProductModels.WebCMSEntities javaprodb = new JavaProductModels.WebCMSEntities();
                    string Month = DateTime.Now.ToString("yyyyMM");
                    string Date = DateTime.Now.ToString("yyyyMMdd");
                    DateTime start = DateTime.Now.AddDays(-30);
                    DateTime end = DateTime.Now.AddMinutes(-1);
                    int StartId = int.Parse(function.CheckInt(function.ReadInstance("/SycnSp/ActivateRecordId.txt")));
                    IQueryable<ActivateRecord> acts = spdb.ActivateRecord.Where(m => m.Id >= StartId && m.CreateDate >= start && m.CreateDate < end && SaveDataBindIds.Contains(m.ProductType) && m.Status == 1).OrderByDescending(m => m.Id).Take(20);
                    foreach (ActivateRecord act in acts.ToList())
                    {
                        PosPushDataNewHelper.Deposit(act);
                        decimal PrizeAmt = decimal.Parse(function.CheckNum(act.Field3));
                        if(act.ProductType == "36" && PrizeAmt > 0)
                        {
                            string PrizeKind = act.SeoKeyword;
                            if ((PrizeKind == "830_21" || PrizeKind == "830_22" || PrizeKind == "833_01" || PrizeKind == "833_02" || PrizeKind == "995_21" || PrizeKind == "995_22" || PrizeKind == "995") && PrizeAmt > 0)
                            {
                                JavaProductModels.KxsMachine pos = javaprodb.KxsMachine.FirstOrDefault(m => m.PosSn == act.SnNo && m.UserId > 0);
                                if(pos != null)
                                {
                                    Dictionary<string, object> prizeData = new Dictionary<string, object>();
                                    prizeData.Add("brand_id", 36);
                                    prizeData.Add("ext_field", PrizeKind);
                                    prizeData.Add("pos_sn", act.SnNo);
                                    prizeData.Add("user_id", pos.UserId);
                                    prizeData.Add("prize", PrizeAmt);
                                    string req = Newtonsoft.Json.JsonConvert.SerializeObject(prizeData);
                                    if(PrizeKind == "833_01" || PrizeKind == "833_02")
                                    {
                                        string ids = PrizeKind == "833_01" ? "81" : "82";
                                        function.GetWebRequest("http://logic-executor-api.kexiaoshuang.com/noauth/prize/pushbyone?n=QUEUE_KXS_HAODA_PRIZE_CONFIG_DIVISION&m=" + req + "&ids=" + ids + ",83");
                                    }
                                    else
                                    {
                                        RedisDbconn.Instance.AddList("HaoDaPrizeDataQueue", "{\"brand_id\":36,\"ext_field\":\"" + act.Field3 + "\",\"pos_sn\":\"" + act.SnNo + "\",\"user_id\":" + pos.UserId + "}");
                                    }
                                }
                            }
                            // JavaProductModels.KxsMachine pos = javaprodb.KxsMachine.FirstOrDefault(m => m.PosSn == act.SnNo && m.UserId > 0);
                            // if(pos != null)
                            // {
                            //     RedisDbconn.Instance.AddList("HaoDaPrizeDataQueue", "{\"brand_id\":36,\"ext_field\":\"" + act.Field3 + "\",\"pos_sn\":\"" + act.SnNo + "\",\"user_id\":" + pos.UserId + "}");
                            // }
                        }
                        
                        ActivateRecord edit = spdb.ActivateRecord.FirstOrDefault(m => m.Id == act.Id);
                        if (edit != null)
                        {
                            edit.Status = 2;
                        }
                    }
                    spdb.SaveChanges();
                    spdb.Dispose();
                    db.SaveChanges();
                    db.Dispose();
                    mpdb.Dispose();
                    javaprodb.Dispose();
                }
                catch (Exception ex)
                {
                    Utils.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "同步SP激活数据到MAIN异常");
                }
                Thread.Sleep(1000);
            }
        }
    }
}