人体成份仪接口
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
gx
chenyc
2024-12-19 538cd003c2ff88d4beae458cf66c89f52f01f5e3 
 app.js


@@ -2,6 +2,7 @@


const bodyParser = require('body-parser');


const mysql = require('mysql2');


const fs = require('fs').promises;


const fs2=require('fs')


const path = require('path');


const moment = require('moment')


// 转成能识别的url


@@ -45,9 +46,28 @@


    config.endpoint = `facebody.cn-shanghai.aliyuncs.com`;


    return new facebody20191230.default(config);


}


app.get('/',async(req,res)=>{


    res.send('设备交换患者信息333');


})


app.get('/', (req, res) => {


    const title = '岱特智能'; // 动态设置标题


    const html = `


      <!DOCTYPE html>


      <html lang="zh-CN">


      <head>


          <meta charset="UTF-8">


          <meta name="viewport" content="width=device-width, initial-scale=1.0">


          <title>${title}</title>


      </head>


      <body>


      <iframe


        src="https://udify.app/chatbot/irsmISE8DBCWAhxz"


        style="width: 100%; height: 100%; min-height: 700px"


        frameborder="0"


        allow="microphone">


      </iframe>


      </body>


      </html>


    `;


    res.send(html);


  });


// 定义 /webuser 路由处理器  用患者code 换信息


app.post('/webuser', async (req, res) => {


    const mode=req.body


@@ -96,6 +116,49 @@


        res.status(400).json({ retCode: "-1", msg: "Invalid request parameters" });


    }


});


app.post('/webuserPatientId',async(req,res)=>{


    const mode=req.body


    logHttps(mode)


    const patientId = req.query.patientId;


    if (patientId) {


        let query = `SELECT * FROM patient_info WHERE code = '${xid}'`


        try {


            const [rows] = await pool.promise().query(query);


            if (rows.length > 0) {


                const user = rows[0];


                const response = {


                    retCode: "1",


                    uinfo: {


                        title: user.client_code,


                        cardID: user.code,


                        userNum: user.patient_no,


                        name: user.patient_name,


                        sex: user.patient_gender === 0 ? '男' : '女',


                        age: getAgeFromIdCard(user.patient_identity_no),


                        headimgurl: user.patient_avatar_icon,


                        imgBaseData: '',


                        remark: ''


                    },


                    dbinfo: {}, // 如果没有需要更新的数据库信息，可以保持空


                    msg: "success"


                };


                res.json(response);


            } else {


                const response = {


                    retCode: "0",


                    msg: "没有找到患者，请先检查患者code"


                };


                res.json(response);


            }


        } catch (err) {


            console.error(err);


            res.status(500).json({ retCode: "-1", msg: "Database error" });


        }


    } else {


        // 如果请求参数不符合预期，则返回错误信息


        res.status(400).json({ retCode: "-1", msg: "Invalid request parameters" });


    }


})




// 定义人脸识别  用base64图片文件换患者信息


app.post('/faceuser', async (req, res) => {


@@ -192,20 +255,22 @@


    const action = req.body.action;


    const deviceID = req.body.deviceID;


    const mode=req.body


    mode.action='webResults'


    logHttps(mode)


    try {




        const datas=mode.datas


        datas.forEach(async element => {


            await installData(element)


        });


        response = {


            retCode: "1",


            msg: "成功"


            recode: "2000",


            remsg: "成功2222"


        };


        res.json(response)


       


    }catch(err){


        res.status(400).json({ retCode: "-1", msg: "Invalid request parameters" });


        res.status(4000).json({ reCode: "4000", msg: "Invalid request parameters" });


    }


    


})


@@ -215,8 +280,9 @@


 */


app.get('/getpatientInfo',async(req,res)=>{


    // 使用req.query访问查询字符串参数


  const patientId = req.query.patientid;


  const patientId = req.query.patientId;


  const mode={"action":'getpatientInfo',"patientId":patientId}


  console.log(patientId,'-----------------')


  logHttps(mode)


  if(patientId){


    // 输出传入的patientid值


@@ -262,7 +328,7 @@




  }else{


    // 如果请求参数不符合预期，则返回错误信息


    res.status(400).json({ retCode: "-1", msg: "Invalid request parameters" });


    res.status(400).json({ retCode: "-1", msg: "Invalid request parameters333" });


  }




  


@@ -340,6 +406,7 @@


const logHttps=(mode)=>{


    try{


        let sqlStr=`INSERT INTO system_log (id, code, url, parameter) VALUES (0, '', '${mode.action}', '${JSON.stringify(mode)}')`


        console.log(sqlStr)


        pool.promise().query(sqlStr)


    }catch (err) {


        console.error('访问日志记录错误:', err);


@@ -347,15 +414,16 @@


}


// 插入数据


const installData=async (mode)=>{


    console.log(mode)


    try{


     let selectSql=`SELECT * FROM patient_rtcf_result WHERE code='${mode.occurTime}'`


     let selectSql=`SELECT * FROM patient_rtcf_result WHERE code='${mode.recordNo}'`


     const [rows] = await pool.promise().query(selectSql);


     if(rows.length>0){


        let updateSql=''


        if(mode.BF){


             updateSql=`UPDATE patient_rtcf_result SET rtcf_json_bf ='${JSON.stringify(mode.BF)}'`


        }else if (mode.BMI){


             updateSql=`UPDATE patient_rtcf_result SET rtcf_json_bmi ='${JSON.stringify(mode.BMI)}'`


        if(mode.fatFree){


             updateSql=`UPDATE patient_rtcf_result SET rtcf_json_bf ='${JSON.stringify(mode)}'`


        }else if (mode.bmi){


             updateSql=`UPDATE patient_rtcf_result SET rtcf_json_bmi ='${JSON.stringify(mode)}'`


        }


        if(updateSql){


            console.log(`-------------------------更新${updateSql}---------`)


@@ -363,35 +431,29 @@


            await pool.promise().query(updateSql)


        }


     }else{


        console.log('34')


        // 临时的人体成分分析


        let bf=''


        // 临时的身高体重


        let bmi=''


        if(mode.fatFree){


            bf=JSON.stringify(mode)


        }


        if(mode.bmi){


            bmi=JSON.stringify(mode)


        }


        console.log(`bf=${bf},bmi=====${bmi}`)


        let sqlStr=`INSERT INTO  patient_rtcf_result (id, code, patient_code,`+


            `comm_time,rtcf_json_bmi,`+


            `rtcf_json_bp,`+


            `rtcf_json_bf,`+


            `rtcf_json_temp,`+


            `rtcf_json_bo,`+


            `rtcf_json_bs,`+


            `rtcf_json_whr,`+


            `rtcf_json_ncg,`+


            `rtcf_json_zytz,`+


            `rtcf_json_ecg,`+


            `rtcf_json_xzsx,`+


            `rtcf_json_eye,`+


            `rtcf_json_sds,`+


            `rtcf_json_txhxdb,`+


            `rtcf_json_fei,`+


            `rtcf_jiu,`+


            `rtcf_gmd)`+


            `VALUES (0, '${mode.occurTime}', '${mode.UID}', '${moment(new Date()).format('YYYY-MM-DD HH:mm:ss')}','${JSON.stringify(mode.BMI)}',`+


            `'${JSON.stringify(mode.BP)}','${JSON.stringify(mode.BF)}','${JSON.stringify(mode.temp)}','${JSON.stringify(mode.bo)}',`+


            `'${JSON.stringify(mode.bs)}','${JSON.stringify(mode.whr)}','${JSON.stringify(mode.ncg)}','${JSON.stringify(mode.zytz)}',`+


            `'${JSON.stringify(mode.ecg)}','${JSON.stringify(mode.xzsx)}','${JSON.stringify(mode.eye)}',`+


            `'${JSON.stringify(mode.sds)}','${JSON.stringify(mode.thxhdb)}','${JSON.stringify(mode.fei)}','${JSON.stringify(mode.jiu)}','${JSON.stringify(mode.gmd)}')`


            `create_time)`+


            `VALUES (0, '${mode.recordNo}', '${mode.userID}', '${mode.measureTime}','${bmi}','${bf}','${moment(new Date()).format('YYYY-MM-DD HH:mm:ss')}')`


        console.log(sqlStr)


        await pool.promise().query(sqlStr)


     }


     


    }catch(err){


        console.log('数据写入异常')


        console.log('数据写入异常22')


    }


}