碰一碰奖励995的要重复推送

AppStart/HaoDa/GetHaoDaTouchPrizeService.cs

@@ -211,8 +211,8 @@ namespace MySystem
                 string acct_nm = DataListInfo[4]; //活动名称
                 string bonus_type = DataListInfo[5]; //奖励类型
 
-                bool op = db.HdTouchRewardTmp.Any(m => m.SnNo == sn_no && m.BonusType == bonus_type);
-                if(!op)
+                MpMainModels2.HdTouchRewardTmp item = db.HdTouchRewardTmp.FirstOrDefault(m => m.SnNo == sn_no && m.BonusType == bonus_type);
+                if(item == null)
                 {
                     function.WriteLog(DateTime.Now.ToString() + ":add:" + sn_no, "好哒碰一碰奖励");
                     db.HdTouchRewardTmp.Add(new MpMainModels2.HdTouchRewardTmp()
@@ -232,6 +232,18 @@ namespace MySystem
                         RedisDbconn.Instance.AddList("HaoDaPrizeDataQueue", "{\"brand_id\":29,\"ext_field\":\"" + bonus_type + "\",\"pos_sn\":\"" + sn_no + "\",\"user_id\":" + pos.UserId + "}");
                     }
                 }
+                else if(bonus_type == "995")
+                {
+                    if(item.Status != 2)
+                    {
+                        JavaProductModels.KxsMachine pos = javauserdb.KxsMachine.FirstOrDefault(m => m.PosSn == sn_no && m.UserId > 0);
+                        if(pos != null)
+                        {
+                            RedisDbconn.Instance.AddList("HaoDaPrizeDataQueue", "{\"brand_id\":29,\"ext_field\":\"" + bonus_type + "\",\"pos_sn\":\"" + sn_no + "\",\"user_id\":" + pos.UserId + "}");
+                        }
+                        item.Status = 2;
+                    }
+                }
                 db.SaveChanges();
             }
             catch(Exception ex)