添加数据库连接字符串

调整下过期机具消息推送

AppStart/Helper/TimeOutPosChargeReturnService.cs

@@ -38,7 +38,7 @@ namespace MySystem
                             function.WritePage("/TimeOutPosChargeReturn/", "check" + DateTime.Now.ToString("yyyy-MM-dd") + ".txt", DateTime.Now.ToString("HH:mm:ss"));
                             WebCMSEntities db = new WebCMSEntities();
                             var date = DateTime.Parse(DateTime.Now.AddDays(-15).ToString("yyyy-MM-dd 00:00:00"));//过期限制时间
-                            var query = db.PosMachinesTwo.Where(m => m.Status > -1 && m.BuyUserId > 0 && m.BindingState == 1 && m.ActivationState == 1 && m.RecycEndDate < date).ToList();//循环过期超过15天激活机具
+                            var query = db.PosMachinesTwo.Where(m => m.Status > -1 && m.BuyUserId > 0 && m.PosSnType == 1 && m.BindingState == 1 && m.ActivationState == 1 && m.RecycEndDate < date).ToList();//循环过期超过15天激活机具
                             var brandInfo = db.KqProducts.ToList();
                             foreach (var pos in query)
                             {
@@ -53,22 +53,19 @@ namespace MySystem
                                 {
                                     amount = 300;
                                 }
-                                if (pos.PosSnType == 1)
+                                var userAccountRecord = db.UserAccountRecord.Add(new UserAccountRecord
                                 {
-                                    var userAccountRecord = db.UserAccountRecord.Add(new UserAccountRecord
-                                    {
-                                        CreateDate = DateTime.Now,
-                                        UserId = pos.BuyUserId,
-                                        BeforeBalanceAmount = userAccount.BalanceAmount,
-                                        AfterBalanceAmount = userAccount.BalanceAmount + amount,
-                                        ChangeAmount = amount,
-                                        ChangeType = 126,//过期购买机具超过15天激活扣费退还
-                                        Remark = "机具货款退还",
+                                    CreateDate = DateTime.Now,
+                                    UserId = pos.BuyUserId,
+                                    BeforeBalanceAmount = userAccount.BalanceAmount,
+                                    AfterBalanceAmount = userAccount.BalanceAmount + amount,
+                                    ChangeAmount = amount,
+                                    ChangeType = 126,//过期购买机具超过15天激活扣费退还
+                                    Remark = "机具货款退还",
 
-                                    }).Entity;
-                                    userAccount.BalanceAmount += amount;
-                                    db.SaveChanges();
-                                }
+                                }).Entity;
+                                userAccount.BalanceAmount += amount;
+                                db.SaveChanges();
                             }
                         }
                     }

AppStart/Helper/TimeOutPosChargeService.cs

@@ -39,7 +39,7 @@ namespace MySystem
                             WebCMSEntities db = new WebCMSEntities();
                             var date = DateTime.Now.AddDays(-15).ToString("yyyy-MM-dd 00:00:00");//过期限制时间
                             var time = DateTime.Parse(DateTime.Now.AddDays(-10).ToString("yyyy-MM-dd 00:00:00"));//过期限制时间
-                            DataTable dt = OtherMySqlConn.dtable("SELECT BuyUserId FROM PosMachinesTwo WHERE `Status`>-1 AND BuyUserId>0 AND BindingState=0 AND RecycEndDate <'" + date + "' GROUP BY BuyUserId");//扣费创客
+                            DataTable dt = CustomerSqlConn.dtable("SELECT BuyUserId FROM PosMachinesTwo WHERE `Status`>-1 AND BuyUserId>0 AND BindingState=0 AND RecycEndDate <'" + date + "' GROUP BY BuyUserId", MysqlConn.connstr);//扣费创客
                             var query = db.PosMachinesTwo.Where(m => m.Status > -1 && m.BuyUserId > 0 && m.BindingState == 0 && m.RecycEndDate < time).ToList();//循环过期超过15天机具
                             var info = db.ToChargeBackRecord.Where(m => m.Status == 0).ToList();//过期机具扣费记录
                             var brandInfo = db.KqProducts.ToList();

AppStart/Helper/TimeOutPosSendMessageService.cs

@@ -39,7 +39,7 @@ namespace MySystem
                             WebCMSEntities db = new WebCMSEntities();
                             var date = DateTime.Now.AddDays(-10).ToString("yyyy-MM-dd 00:00:00");//过期限制时间
                             var time = DateTime.Parse(DateTime.Now.AddDays(-10).ToString("yyyy-MM-dd 00:00:00"));//过期限制时间
-                            DataTable dt = OtherMySqlConn.dtable("SELECT BuyUserId FROM PosMachinesTwo WHERE `Status`>-1 AND BuyUserId>0 AND BindingState=0 AND RecycEndDate <'" + date + "' GROUP BY BuyUserId");//消息推送创客
+                            DataTable dt = CustomerSqlConn.dtable("SELECT BuyUserId FROM PosMachinesTwo WHERE `Status`>-1 AND BuyUserId>0 AND BindingState=0 AND RecycEndDate <'" + date + "' GROUP BY BuyUserId", MysqlConn.connstr);//消息推送创客
                             var query = db.PosMachinesTwo.Where(m => m.Status > -1 && m.BuyUserId > 0 && m.BindingState == 0 && m.RecycEndDate < time).ToList();//循环过期超过10天机具
                             var brandInfo = db.KqProducts.ToList();
                             foreach (DataRow item in dt.Rows)
@@ -55,10 +55,10 @@ namespace MySystem
                                     var posInfo = query.Where(m => m.BuyUserId == BuyUserId && m.BrandId == BrandId);
                                     foreach (var pos in posInfo)
                                     {
-                                        PosSn += pos.PosSn + ",";
+                                        PosSn += pos.PosSn + "," + "<br/>";
                                     }
                                 }
-                                SendInfo = BrandName + "：" + PosSn + ";<br/>";
+                                SendInfo = BrandName + "：" + PosSn.TrimEnd(',') + "<br/>";
                                 RedisDbconn.Instance.AddList("MsgPersonalQueue", Newtonsoft.Json.JsonConvert.SerializeObject(new MsgPersonal()
                                 {
                                     UserId = BuyUserId, //创客

Config/MysqlConn.cs

@@ -0,0 +1,13 @@
+using Library;
+
+/// <summary>
+/// MySql链接
+/// </summary>
+namespace MySystem
+{
+    public class MysqlConn
+    {
+        public static string connstr = ConfigurationManager.AppSettings["SqlConnStr"].ToString();
+
+    }
+}