人体成份仪接口
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
34
chenyc
2024-11-04 1accdfa68eab3576c6d8647f12bed8155dad329a 
 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('设备交换患者信息');


})


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


@@ -144,24 +164,22 @@


                                    name: user.patient_name,


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


                                    age: getAgeFromIdCard(user.patient_identity_no),


                                    usernum: user.patient_no,


                                    address: user.code,


                                    usernum: user.code, //这个是数据返回会携带回来UID


                                    address: user.patient_address,


                                    remark: '患者人脸识别111'


                                },


                                remsg: "success"


                            };


                            // res.json(response);


                        } else {


                            response = {


                                retCode: "0",


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


                                retcode: 1001,


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


                            };


                            // res.json(response);


                        }


                    } else {


                        response = {


                            retCode: "0",


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


                            retcode: 1001,


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


                        };


                    }


                    res.json(response);


@@ -194,20 +212,22 @@


    const action = req.body.action;


    const deviceID = req.body.deviceID;


    const mode=req.body


    mode.action='webResults'


    logHttps(mode)


    console.log('----------')


    try {


        const datas=mode.datas


        datas.forEach(async element => {


            await installData(element)


        });


        response = {


            retCode: "1",


            msg: "成功"


            recode: "2000",


            remsg: "成功"


        };


        res.json(response)


       


    }catch(err){


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


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


    }


    


})


@@ -215,7 +235,7 @@


/**


 * patientId={patientId} 


 */


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


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


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


  const patientId = req.query.patientid;


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


@@ -274,7 +294,16 @@


 * PostCheckExam  病人信息及检测结果以JSON的形式回传至服务器


 */


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


    const mode=req.body


    if(mode){


        logHttps(mode)


    }else{


        mode.action='hahhaha'


        logHttps(mode)


    }


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




    


})


// 启动服务器


app.listen(port, async () => {


@@ -320,7 +349,6 @@


        await fs.mkdir(directory, { recursive: true });


    } catch (err) {


        console.error('Error creating directory:', err);


        throw err;


    }


}


// 将文件上传到阿里的oss


@@ -334,16 +362,31 @@


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('Error creating directory2222:', err);


        throw err;


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


    }


}


// 插入数据


const installData=async (mode)=>{


    try{


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


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


     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(updateSql){


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


            console.log(updateSql)


            await pool.promise().query(updateSql)


        }


     }else{


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


            `comm_time,rtcf_json_bmi,`+


            `rtcf_json_bp,`+


            `rtcf_json_bf,`+


@@ -361,15 +404,15 @@


            `rtcf_json_fei,`+


            `rtcf_jiu,`+


            `rtcf_gmd)`+


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


            `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)}')`




        console.log('-------------------')


        console.log(sqlStr)


       await pool.promise().query(sqlStr)


        await pool.promise().query(sqlStr)


     }


     


    }catch(err){


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


    }