修改交易统计时间范围

AppStart/Helper/HyfAddPrizeService.cs

@@ -47,19 +47,27 @@ namespace MySystem
             List<PosMachinesTwo> posList = db.PosMachinesTwo.Where(m => m.BindingState == 1 && m.ActivationState == 1 && m.BindingTime >= online && m.BindingTime >= leftTime && m.BindingTime <= rightTime && (m.BrandId == 12 || m.BrandId == 13) && m.Sort == 0).ToList();
             foreach (PosMachinesTwo pos in posList)
             {
-                DataTable dt = CustomerSqlConn.dtable("select sum(TradeAmount) from PosMerchantTradeSummay where TradeDate>='20240627' and MerchantId=" + pos.BindMerchantId + "", MysqlConn.ReadSqlConnStr);
                 function.WriteLog(str: "机具号:" + pos.PosSn, "盒力四射加码奖励日志");
-                Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId);
-                if (user != null)
+                decimal amt = 0;
+                DataTable dt = CustomerSqlConn.dtable("select sum(TradeAmount) from PosMerchantTradeSummay where TradeDate>='" + leftTime.ToString("yyyyMMdd") + "' and TradeDate<='" + rightTime.ToString("yyyyMMdd") + "' and MerchantId=" + pos.BindMerchantId + "", MysqlConn.ReadSqlConnStr);
+                if(dt.Rows.Count > 0)
                 {
-                    function.WriteLog("机具所属人:" + user.Id, "盒力四射加码奖励日志");
-                    int GetUserId = user.Id;
-                    AlipayPayBack2Service.Instance.ChangeAccount(db, new Orders(), GetUserId, 50, 139);
-                    PosMachinesTwo edit = db.PosMachinesTwo.FirstOrDefault(m => m.Id == pos.Id);
-                    if(edit != null)
+                    amt = decimal.Parse(function.CheckInt(dt.Rows[0][0].ToString()));
+                }
+                if(amt >= 1000)
+                {
+                    Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId);
+                    if (user != null)
                     {
-                        edit.Sort = 1;
-                        db.SaveChanges();
+                        function.WriteLog("机具所属人:" + user.Id, "盒力四射加码奖励日志");
+                        int GetUserId = user.Id;
+                        AlipayPayBack2Service.Instance.ChangeAccount(db, new Orders(), GetUserId, 50, 139);
+                        PosMachinesTwo edit = db.PosMachinesTwo.FirstOrDefault(m => m.Id == pos.Id);
+                        if(edit != null)
+                        {
+                            edit.Sort = 1;
+                            db.SaveChanges();
+                        }
                     }
                 }
                 function.WriteLog("\n\n\n", "盒力四射加码奖励日志");