棋牌原始碼分享之短信介面，(NODEJS+cron)發送驗證碼短信

棋牌原始碼分享之短信介面，(NODEJS+cron)發送驗證碼短信

如果你的定時需求是簡單的setInterval()與setTimeout()計時器所無法滿足的比較復雜的定時規則，推薦使用cron來配置，

下面我們再來講講Cron風格定時器傳入的引數具體代表什么，先來看看上面執行結果，如下圖

　　從輸出結果可以看出，傳入的'30 * * * * *'帶來的結果是每分鐘的30秒時都會執行，下面來看看這個傳入引數分別代碼什么

　　通配符解釋

┬ ┬ ┬ ┬ ┬ ┬ │ │ │ │ │ | │ │ │ │ │

└ day of week (0 - 7) (0 or 7 is Sun) │ │ │ │

└───── month (1 - 12) │ │ │

└────────── day of month (1 - 31) │ │

└─────────────── hour (0 - 23) │

└──────────────────── minute (0 - 59)

└───────────────────────── second (0 - 59, OPTIONAL)

  1 var configs = config.mysql();
  2 
  3 var client = require('mysql').createConnection(
  4 { host: configs.HOST, 
  5 user: configs.USER, 
  6 password: configs.PSWD, // 
  7 database: configs.DB, 
  8 port: configs.PORT }); //選擇哪個庫
  9 
 10 ClientConnectionReady = function(client) { 
 11 console.log('正在連接資料庫...'); 
 12 client.query('use qp_games139com', function(error, results) { 
 13 if (error) { 
 14 console.log('Connection Error:' + error.message); 
 15 client.end(); return; 
 16 }
 17 
 18    // setTimeout(Get_message, 1000 * 2, client);
 19 
 20         var CronJob = require('cron').CronJob;
 21         var job = new CronJob('*/2 * * * * *', function() {
 22 
 23             const d = new Date().toLocaleString();
 24             console.log(d);
 25             Get_message(client);
 26         }, null, true, 'Asia/Shanghai');
 27         job.start();
 28 
 29 
 30 });
 31 
 32 }
 33 
 34 //遍歷所有資料 
 35 
 36 Get_message = function(client) { 
 37 var sql = "SELECT * FROM t_users_message where state = 0 "; 
 38 client.query(sql, function(error, results, fields) { 
 39 if (error) { 
 40 console.log('查詢記錄出錯:' + error.message); 
 41 client.end(); 
 42 return; 
 43 }
 44 
 45     if (results.length == 0) {
 46         console.log('暫時沒有記錄'.blue);
 47         return;
 48     } else {
 49 
 50         for (var i = 0; i < results.length; i++) {
 51 
 52             send(results[i]['id'],results[i]['imno'], results[i]['content'],
 53             function(err, smsId) {
 54                 console.log(err, smsId);
 55                 if (err == '0000') {
 56 
 57                     var sql = "update t_users_message set state=1 where id = ?  ";
 58                     var values = [smsId];
 59                     var sqls = client.format(sql, values);
 60                    // log.error(sqls);
 61                     client.query(sql, values,
 62                     function(error, results) {
 63                         if (error) {
 64                             console.log('Update Error:' + error.message);
 65                             return;
 66                         }
 67                     });
 68 
 69                 }
 70 
 71             });
 72 
 73         }
 74 
 75     }
 76 });
 77 //client.end();
 78 
 79 }
 80 
 81 send = function(id, mobile, content, callback) {
 82 
 83 var contents = querystring.stringify({
 84 
 85     account: 'cf_fleaphp',
 86     mobile: mobile,
 87     password: 'e5aab66587efffd664b5ad8acab6d112',
 88     content: content
 89 
 90 });
 91 
 92 var options = {
 93     host: '106.ihuyi.com',
 94     path: '/webservice/sms.php?method=Submit',
 95     method: 'POST',
 96     headers: {
 97         'Content-Type': 'application/x-www-form-urlencoded',
 98         'Content-Length': contents.length
 99     }
100 }
101 
102 var req = http.request(options,
103 function(res) {
104     res.setEncoding('utf8');
105     res.on('data',
106     function(data) {
107        // console.log("data:", data); //一段html代碼
108         content = data.replace(/(\r|\n|( xmlns="http:\/\/106.ihuyi.com\/"))/g, "");
109         var doc = new DOMParser().parseFromString(content);
110         var result = doc.lastChild;
111         var json = {};
112         var node = {};
113         for (node = result.firstChild; node !== null; node = node.nextSibling) {
114             json[node.tagName] = node.firstChild.data;
115         }
116 
117         if (parseInt(json.code) === 2) {
118             return callback('0000', id);
119         } else {
120             return callback(new Error(json.code,json.msg));
121         }
122     });
123 
124 }).on("error", callback);
125 
126 req.write(contents);
127 req.end;
128 
129 };

標籤：其他

上一篇：軟體設計模式修煉 -- 外觀模式

下一篇：SecureCRT使用技巧