|
|
@@ -228,30 +228,63 @@ public class TestHelper
|
|
|
|
|
|
private void HaoDaPrizeNew()
|
|
|
{
|
|
|
- List<string> bonusTypes = new List<string>();
|
|
|
- bonusTypes.Add("830_21");
|
|
|
- bonusTypes.Add("830_22");
|
|
|
- bonusTypes.Add("995_21");
|
|
|
- bonusTypes.Add("995_22");
|
|
|
- MySystem.MpMainModels2.WebCMSEntities db = new MySystem.MpMainModels2.WebCMSEntities();
|
|
|
- MySystem.JavaProductModels.WebCMSEntities javauserdb = new MySystem.JavaProductModels.WebCMSEntities();
|
|
|
- List<MySystem.MpMainModels2.HdTouchRewardTmp> items = db.HdTouchRewardTmp.Where(m => bonusTypes.Contains(m.BonusType)).ToList();
|
|
|
- foreach(MySystem.MpMainModels2.HdTouchRewardTmp item in items)
|
|
|
+ List<string> list = new List<string>();
|
|
|
+ list.Add("018272002441,250,833_02,313102");
|
|
|
+ list.Add("018272002202,250,833_02,306007");
|
|
|
+ list.Add("018272002379,80,833_01,315771");
|
|
|
+ list.Add("018272002431,250,833_02,314870");
|
|
|
+ list.Add("018272003586,250,833_02,313356");
|
|
|
+ list.Add("018272003319,250,833_02,136632");
|
|
|
+ foreach(string sub in list)
|
|
|
{
|
|
|
- MySystem.JavaProductModels.KxsMachine pos = javauserdb.KxsMachine.FirstOrDefault(m => m.PosSn == item.SnNo && m.UserId > 0);
|
|
|
- if(pos != null)
|
|
|
+ string[] data = sub.Split(',');
|
|
|
+ string posSn = data[0];
|
|
|
+ string prize = data[1];
|
|
|
+ string extField = data[2];
|
|
|
+ string userId = data[3];
|
|
|
+ Dictionary<string, object> prizeData = new Dictionary<string, object>();
|
|
|
+ prizeData.Add("brand_id", 36);
|
|
|
+ prizeData.Add("ext_field", extField);
|
|
|
+ prizeData.Add("pos_sn", posSn);
|
|
|
+ prizeData.Add("user_id", userId);
|
|
|
+ prizeData.Add("prize", prize);
|
|
|
+ string req = Newtonsoft.Json.JsonConvert.SerializeObject(prizeData);
|
|
|
+ string ids = "";
|
|
|
+ if(extField == "833_01")
|
|
|
{
|
|
|
- Dictionary<string, object> prizeData = new Dictionary<string, object>();
|
|
|
- prizeData.Add("brand_id", 29);
|
|
|
- prizeData.Add("ext_field", item.BonusType);
|
|
|
- prizeData.Add("pos_sn", item.SnNo);
|
|
|
- prizeData.Add("user_id", pos.UserId);
|
|
|
- prizeData.Add("prize", item.Reward.ToString());
|
|
|
- // RedisDbconn.Instance.AddList("HaoDaPrizeDataQueue", Newtonsoft.Json.JsonConvert.SerializeObject(prizeData));
|
|
|
- function.WriteLog(Newtonsoft.Json.JsonConvert.SerializeObject(prizeData), "补好哒新奖励");
|
|
|
+ ids = "81";
|
|
|
}
|
|
|
+ else if(extField == "833_02")
|
|
|
+ {
|
|
|
+ ids = "82";
|
|
|
+ }
|
|
|
+ string result = function.GetWebRequest("http://logic-executor-api.kexiaoshuang.com/noauth/prize/pushbyone?n=QUEUE_KXS_HAODA_PRIZE_CONFIG_DIVISION&m=" + req + "&ids=" + ids + ",83");
|
|
|
}
|
|
|
- db.Dispose();
|
|
|
- javauserdb.Dispose();
|
|
|
+
|
|
|
+ // List<string> bonusTypes = new List<string>();
|
|
|
+ // bonusTypes.Add("830_21");
|
|
|
+ // bonusTypes.Add("830_22");
|
|
|
+ // bonusTypes.Add("995_21");
|
|
|
+ // bonusTypes.Add("995_22");
|
|
|
+ // MySystem.MpMainModels2.WebCMSEntities db = new MySystem.MpMainModels2.WebCMSEntities();
|
|
|
+ // MySystem.JavaProductModels.WebCMSEntities javauserdb = new MySystem.JavaProductModels.WebCMSEntities();
|
|
|
+ // List<MySystem.MpMainModels2.HdTouchRewardTmp> items = db.HdTouchRewardTmp.Where(m => bonusTypes.Contains(m.BonusType)).ToList();
|
|
|
+ // foreach(MySystem.MpMainModels2.HdTouchRewardTmp item in items)
|
|
|
+ // {
|
|
|
+ // MySystem.JavaProductModels.KxsMachine pos = javauserdb.KxsMachine.FirstOrDefault(m => m.PosSn == item.SnNo && m.UserId > 0);
|
|
|
+ // if(pos != null)
|
|
|
+ // {
|
|
|
+ // Dictionary<string, object> prizeData = new Dictionary<string, object>();
|
|
|
+ // prizeData.Add("brand_id", 29);
|
|
|
+ // prizeData.Add("ext_field", item.BonusType);
|
|
|
+ // prizeData.Add("pos_sn", item.SnNo);
|
|
|
+ // prizeData.Add("user_id", pos.UserId);
|
|
|
+ // prizeData.Add("prize", item.Reward.ToString());
|
|
|
+ // // RedisDbconn.Instance.AddList("HaoDaPrizeDataQueue", Newtonsoft.Json.JsonConvert.SerializeObject(prizeData));
|
|
|
+ // function.WriteLog(Newtonsoft.Json.JsonConvert.SerializeObject(prizeData), "补好哒新奖励");
|
|
|
+ // }
|
|
|
+ // }
|
|
|
+ // db.Dispose();
|
|
|
+ // javauserdb.Dispose();
|
|
|
}
|
|
|
}
|