同行奖励入库

Areas/Api/Controllers/OutApiController.cs

@@ -131,6 +131,76 @@ namespace MySystem.Areas.Api.Controllers.v1
         #endregion
 
 
+        #region 同行奖同步
+        [Route("/leader/prize/do")]
+        public string LeaderPrize(string month)
+        {
+            DateTime start = DateTime.Parse(month + "-01 00:00:00");
+            DateTime end = start.AddMonths(1);
+            Dictionary<string, string> txjList = TxjList();
+            JavaProductModels.WebCMSEntities dbpro = new JavaProductModels.WebCMSEntities();
+            JavaUserModels.WebCMSEntities dbuser = new JavaUserModels.WebCMSEntities();
+            IQueryable<JavaProductModels.KxsMachineAward> dellist = dbpro.KxsMachineAward.Where(m => m.VariationType == 0 && m.CreateTime >= start && m.CreateTime < end);
+            foreach(JavaProductModels.KxsMachineAward sub in dellist)
+            {
+                dbpro.KxsMachineAward.Remove(sub);
+            }
+            dbpro.SaveChanges();
+            List<JavaProductModels.KxsMachineAward> list = dbpro.KxsMachineAward.Where(m => m.VariationType == 118 && m.CreateTime >= start && m.CreateTime < end).ToList();
+            foreach(JavaProductModels.KxsMachineAward sub in list)
+            {
+                JavaProductModels.KxsShopOrder order = dbpro.KxsShopOrder.FirstOrDefault(m => m.OrderSn == sub.PosSn);
+                if(order != null)
+                {
+                    int UserId = order.UserId;
+                    JavaUserModels.KxsUser user = dbuser.KxsUser.FirstOrDefault(m => m.Id == UserId);
+                    if(user != null)
+                    {
+                        string ParentNav = user.PidPath;
+                        string[] ParentList = ParentNav.TrimEnd(',').Split(',');
+                        Array.Reverse(ParentList);
+                        foreach(string ParentId in ParentList)
+                        {
+                            if(txjList.ContainsKey(ParentId))
+                            {
+                                string[] userData = txjList[ParentId].Split('|');
+                                dbpro.KxsMachineAward.Add(new JavaProductModels.KxsMachineAward()
+                                {
+                                    Amount = 60,
+                                    VariationType = 0,
+                                    Username = userData[1],
+                                    UserCode = userData[0],
+                                    UserId = int.Parse(ParentId),
+                                    MachineId = sub.MachineId,
+                                    PosSn = sub.PosSn,
+                                    CreateTime = DateTime.Now,
+                                    AwardType = 1,
+                                });
+                                break;
+                            }
+                        }
+                    }
+                }
+            }
+            dbpro.Dispose();
+            dbuser.Dispose();
+            return "ok";
+        }
+        private Dictionary<string, string> TxjList()
+        {
+            Dictionary<string, string> dic = new Dictionary<string, string>();
+            string[] list = function.ReadInstance("/TxjList.txt").Split('\n');
+            foreach(string sub in list)
+            {
+                string[] data = sub.Split('|');
+                dic.Add(data[0], data[1] + "|" + data[2]);
+            }
+            return dic;
+        }
+        #endregion
+
+
+
         // [Route("/api/v1/{c1}/{c2}")]
         // public JsonResult ToApServer(string c1, string c2, string value)
         // {