aaa

server/app.js

@@ -65,7 +65,7 @@ app.listen(1000, function () {
 
 const schedule = require('node-schedule');
  const taskforupdate=require('./comman/frpclinet')
-
+const getliuliang=require('./comman/getliuliang')
 
 
 const  scheduleCronstyle = ()=>{
@@ -73,7 +73,9 @@ const  scheduleCronstyle = ()=>{
     schedule.scheduleJob('* 30 * * * *',()=>{
         console.log('scheduleCronstyle:' + new Date());
         taskforupdate.getfrpserver();
+        getliuliang.updatasimdb();
     }); 
 }
  taskforupdate.getfrpserver();
+ getliuliang.updatasimdb();;
 scheduleCronstyle();

server/comman/frpclinet.js

@@ -123,7 +123,7 @@ async function getfrpserver()
         
         if(aaa[i].name.endsWith('_data'))
         {
-            console.log(aaa[i])
+           // console.log(aaa[i])
             var data=aaa[i]
            //console.log(aaa[i].name)
             //去除后缀
@@ -139,7 +139,7 @@ async function getfrpserver()
             if (data.name=="TowerIS2_2006_data")
             {
                 //将data.nameup 从devlistname中删除
-                console.log("delete TowerIS2_2006_data")
+                //console.log("delete TowerIS2_2006_data")
                 
             }
 
@@ -149,8 +149,8 @@ async function getfrpserver()
                 //将data.nameup 从devlistname中删除
                 let index=devlistname.indexOf(data.nameup)
                 devlistname.splice(index,1)
-                console.log("delete "+data.nameup)
-                console.log(devlistname);
+              //  console.log("delete "+data.nameup)
+               // console.log(devlistname);
 
                 
             }

server/comman/getliuliang.js

@@ -0,0 +1,54 @@
+const axios = require('axios');
+const herader = {
+    'Content-Type': 'application/json',
+    'Uuid':"5e74228e138c4da891f9d49e198ed5b6"
+}
+const db=require("../comman/db")
+let query = {"msisdn":"1441026718896","pageSize":10,"currentPage":1}
+// testgetliuliang();
+
+async function testgetliuliang(){
+    let resulat=await getliuliang(query);
+    console.log(resulat);
+
+}
+
+async function getsiminfobymsisdn(msisdn){
+    let query = {"msisdn":msisdn,"pageSize":10,"currentPage":1}
+    let resulat=await getliuliang(query);
+    return resulat;
+
+}
+exports.updatasimdb=updatasimdb;
+const initdb=require("../comman/initdb")
+async function updatasimdb(){
+
+    initdb.initdb();
+    let sql="select * from devuser where 1"
+    let result=await db.queryacy(sql);
+    for (let i = 0; i < result.length; i++) {
+        let siminfo=await getsiminfobymsisdn(result[i].simnumber);
+       // console.log(siminfo);
+        if(siminfo.length>0){
+            simtotal=siminfo[0].periodCanUsage
+            simused=siminfo[0].hasUseRate
+            simdateline=siminfo[0].exitTime
+            //更新simtotal和 simused simdateline
+            sql="update devuser set simtotal='"+simtotal+"',simused='"+simused+"',simdateline='"+simdateline+"' where autoid="+result[i].autoid;
+
+            await db.queryacy(sql);
+        }
+    }
+
+}
+
+
+
+
+async function getliuliang(query){
+    let result=await axios.post('https://api.wl1688.net/client/card/findMyPage', query, { headers: herader });
+   // console.log(result.data.data.list);
+    return result.data.data.list;
+
+}
+

server/comman/initdb.js

@@ -0,0 +1,27 @@
+const db=require("../comman/db")
+
+let sql="CREATE TABLE IF NOT EXISTS `remotemqtt`.`devuser` (\
+  `autoid` INT NOT NULL AUTO_INCREMENT,\
+  `devid` INT NOT NULL,\
+  `devname` VARCHAR(255) NOT NULL,\
+  `simnumber` VARCHAR(20) NOT NULL,\
+  `simtotal` INT NULL,\
+  `simused` INT NULL,\
+  `simdateline` DATE NULL,\
+  `devusername` TEXT NULL,\
+  `beizhu` TEXT NULL,\
+  PRIMARY KEY (`autoid`)\
+) ENGINE = InnoDB;\
+"
+
+async function initdb(){
+    db.query(sql,(err)=>{
+        if(err){
+            console.log(err);
+        }
+        else{
+            console.log("create devuser success");
+        }
+    })
+}
+exports.initdb=initdb;

server/comman/tstws.js

@@ -38,7 +38,10 @@ async function sendMessageAndWaitForResponse(addres,  message) {
   }
  async function runinws(  message,addres){
     let aa=await sendMessageAndWaitForResponse(addres,message)
-
+    if(typeof aa[0]!="array"||aa.length==0)
+    {
+      aa=[Buffer.from("error")]
+    }
     return aa
 
  //   console.log(aa[1].toString())

server/router/devinfo.js

@@ -3,4 +3,6 @@ var router = express.Router();
 const devinfoHandler = require('../router_handler/devinof_handle')
  
 router.get('/getfilelistinfo', devinfoHandler.getfilelistinfo)
+router.post('/getdevuserinfo', devinfoHandler.getDevUserinfo)
+router.post('/setdevuserinfo', devinfoHandler.setDevUserinfo)
 module.exports = router;

server/router_handler/devinof_handle.js

@@ -1,9 +1,89 @@
-const db=require("../comman/db")
+const { updateLocale } = require("moment");
+const db = require("../comman/db")
 
-exports.getfilelistinfo=(req, res) => {
-    sql='SELECT d.*, i.last_online FROM filebrowerinfo d JOIN frpinfo i ON d.name = i.id;'
-    db.query(sql,(err,result)=>{
+exports.getfilelistinfo = (req, res) => {
+    sql = 'SELECT d.*, i.last_online FROM filebrowerinfo d JOIN frpinfo i ON d.name = i.id;'
+    db.query(sql, (err, result) => {
         res.send(result);
     })
 
-}
+}
+
+exports.getDevUserinfo = (req, res) => {
+    let devid = req.body.devid;
+    sql = 'SELECT * FROM devuser where devid=' + devid + ';'
+
+    db.query(sql, (err, result) => {
+        if (err || result.length == 0) {
+           // console.log(err);
+            let message = { "devid": devid };
+            //去filebrowerinfo查询name
+            let sql = 'SELECT name FROM filebrowerinfo where autoid=' + devid + ';'
+            db.query(sql, (err, result) => {
+                if (err || result.length == 0) {
+                    console.log(err);
+                    message.devname = "未知";
+                    res.send(message);
+
+                    return;
+                }
+
+                message.devname = result[0].name;
+                res.send([message]);
+            })
+
+         
+
+        }else
+        {
+            res.send(result);
+        }
+
+
+       
+    })
+
+}
+exports.setDevUserinfo = (req, res) => {
+    let data=req.body
+    let devid = data.devid;
+    //先查询是否存在
+    let sql = 'SELECT * FROM devuser where devid=' + devid + ';'
+    db.query(sql, (err, result) => {
+        if (err || result.length == 0) {
+            //不存在则插入
+            insertDevUser(data, res);
+        } else {
+            //存在则更新
+            updateDevUser(data, res);
+        }
+    })
+
+
+
+
+}
+function insertDevUser(data,res)
+{
+    let sql = 'INSERT INTO devuser SET ?'
+    db.query(sql, data, (err, result) => {
+        if (err) {
+           // console.log(err);
+            res.send({ "status": "error" });
+        } else {
+            res.send({ "status": "success" });
+        }
+    })
+}
+function updateDevUser(data,res)
+{
+    let sql = 'UPDATE devuser SET ? WHERE devid = ?'
+    db.query(sql, [data, data.devid], (err, result) => {
+        if (err) {
+           // console.log(err);
+            res.send({ "status": "error" });
+        } else {
+            res.send({ "status": "success" });
+        }
+    })
+}