添加推送队列

Util/Queue/PushHelper.cs

@@ -0,0 +1,58 @@
+using System;
+using System.Linq;
+using System.Threading;
+using Library;
+using LitJson;
+using MySystem.Models.Push;
+
+namespace MySystem
+{   
+    public class PushHelper
+    {
+        public readonly static PushHelper Instance = new PushHelper();
+        private PushHelper()
+        {
+        }
+
+        public void Start()//启动
+        {
+            Thread thread = new Thread(threadStart);
+            thread.IsBackground = true;
+            thread.Start();
+        }
+
+        private void threadStart()
+        {
+            while (true)
+            {
+                DoSomeThing();
+                Thread.Sleep(1000);
+            }
+        }
+
+        //要执行的方法
+        public void DoSomeThing()
+        {
+            WebCMSEntities db = new WebCMSEntities();
+            
+            db.Dispose();
+        }
+        
+        //创建表
+        public void CreateTable(string Title, string tableName, string fieldList)
+        {
+            string sql = "CREATE TABLE `" + tableName + "` (\n";
+            sql += "`id` int(11) NOT NULL AUTO_INCREMENT,\n";
+            sql += "`status` int(11) NOT NULL,\n";
+            JsonData fieldJson = JsonMapper.ToObject(fieldList);
+            for (int i = 0; i < fieldJson.Count; i++)
+            {
+                JsonData item = fieldJson[i];
+                sql += "`" + item["name"].ToString() + "` varchar(" + item["len"].ToString() + ") DEFAULT NULL COMMENT '" + item["title"].ToString() + "',\n";
+            }
+            sql += "PRIMARY KEY (`id`)\n";
+            sql += ") ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8 COMMENT='" + Title + "';";
+            CustomerSqlConn.op(sql, AppConfig.Base.SqlConnStr);
+        }
+    }
+}