Jelajahi Sumber

好哒碰一下设备推送奖励

lcl 11 bulan lalu
induk
melakukan
10fc294e49
1 mengubah file dengan 10 tambahan dan 0 penghapusan
  1. 10 0
      AppStart/Helper/SycnSpServer/SycnSpActiveService.cs

+ 10 - 0
AppStart/Helper/SycnSpServer/SycnSpActiveService.cs

@@ -30,6 +30,7 @@ namespace MySystem
                     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);
@@ -39,6 +40,14 @@ namespace MySystem
                     foreach (ActivateRecord act in acts.ToList())
                     {
                         PosPushDataNewHelper.Deposit(act);
+                        if(act.ProductType == "36" && decimal.Parse(function.CheckNum(act.Field3)) > 0)
+                        {
+                            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)
@@ -51,6 +60,7 @@ namespace MySystem
                     db.SaveChanges();
                     db.Dispose();
                     mpdb.Dispose();
+                    javaprodb.Dispose();
                 }
                 catch (Exception ex)
                 {