处理发碰一碰活动奖励

AppStart/HaoDa/GetHaoDaTouchPrizeService.cs

@@ -36,7 +36,7 @@ namespace MySystem
             {
                 if (DateTime.Now > DateTime.Parse(DateTime.Now.ToString("yyyy-MM-dd") + " 10:05:00"))
                 {
-                    SaveTouchRewardData(DateTime.Now.ToString("yyyyMMdd"));
+                    SaveTouchRewardData(DateTime.Now.AddDays(-1).ToString("yyyyMMdd"));
                 }
                 Thread.Sleep(180000);
             }
@@ -98,7 +98,6 @@ namespace MySystem
                     var DataInfo = fileContents.TrimEnd('\n').Split('\n', 2);
                     if (DataInfo.Length > 1)
                     {
-                        int index = 0;
                         var DataList = DataInfo[1].Split('\n');
                         foreach (var DataListItem in DataList)
                         {
@@ -109,19 +108,8 @@ namespace MySystem
                             else
                             {
                                 SaveTouchRewardDataOneReady(db, javauserdb, DataListItem);
-                                index += 1;
-                                if(index % 200 == 0 && index > 0)
-                                {
-                                    index = 0;
-                                    db.SaveChanges();
-                                }
                             }
                         }
-                        if(!IsRedis)
-                        {
-                            index = 0;
-                            db.SaveChanges();
-                        }
                     }
                     db.Dispose();
                     javauserdb.Dispose();
@@ -186,11 +174,12 @@ namespace MySystem
                     if(!dbConn)
                     {
                         db = new MpMainModels2.WebCMSEntities();
+                        javauserdb = new JavaProductModels.WebCMSEntities();
                         dbConn = true;
                     }
                     SaveTouchRewardDataOneReady(db, javauserdb, content);
                     index += 1;
-                    if(index % 200 == 0 && index > 0)
+                    if(index % 20 == 0 && index > 0)
                     {
                         index = 0;
                         db.SaveChanges();
@@ -222,8 +211,8 @@ namespace MySystem
                 string acct_nm = DataListInfo[4]; //活动名称
                 string bonus_type = DataListInfo[5]; //奖励类型
 
-                MpMainModels2.HdTouchRewardTmp edit = db.HdTouchRewardTmp.FirstOrDefault(m => m.SnNo == sn_no);
-                if(edit == null)
+                bool op = db.HdTouchRewardTmp.Any(m => m.SnNo == sn_no);
+                if(!op)
                 {
                     function.WriteLog(DateTime.Now.ToString() + ":add:" + sn_no, "好哒碰一碰奖励");
                     db.HdTouchRewardTmp.Add(new MpMainModels2.HdTouchRewardTmp()
@@ -241,18 +230,10 @@ namespace MySystem
                     if(pos != null)
                     {
                         RedisDbconn.Instance.AddList("HaoDaPrizeDataQueue", "{\"brand_id\":29,\"ext_field\":\"" + bonus_type + "\",\"pos_sn\":\"" + sn_no + "\",\"user_id\":" + pos.UserId + "}");
+                        function.WriteLog("{\"brand_id\":29,\"ext_field\":\"" + bonus_type + "\",\"pos_sn\":\"" + sn_no + "\",\"user_id\":" + pos.UserId + "}", "好哒碰一碰奖励");
                     }
                 }
-                else
-                {
-                    function.WriteLog(DateTime.Now.ToString() + ":update:" + sn_no, "好哒碰一碰奖励");
-                    edit.Status = 1;
-                    edit.LightUpTime = DateTime.Parse(light_up_time);
-                    edit.Reward = decimal.Parse(reward);
-                    edit.EffectiveDate = effective_date;
-                    edit.AcctNm = acct_nm;
-                    edit.BonusType = bonus_type;
-                }
+                db.SaveChanges();
             }
             catch(Exception ex)
             {

Startup.cs

@@ -155,7 +155,7 @@ namespace MySystem
             //必须打开的
             GetHaoDaFTPInfoService.Instance.Start();
             GetHaoDaFTPInfoService.Instance.Start2();
-            // GetHaoDaTouchPrizeService.Instance.Start();
+            GetHaoDaTouchPrizeService.Instance.Start();
             GetHaoDaFTPInfoService.Instance.StartListen();
             GetHaoDaFTPInfoService.Instance.StartTradeListen();
             GetHaoDaFTPInfoService.Instance.StartGetTradeData();