缓存接口请求

chenyc

2024-12-23 45a0ba031e6d453f26b0e4ca181ebed4e119f829

缓存接口请求

 app.js

@@ -5,12 +5,19 @@
const fs2=require('fs')
const path = require('path');
const moment = require('moment')
const axios = require('axios');
// 转成能识别的url
const ViapiUtil = require('@alicloud/viapi-utils');

const facebody20191230 = require('@alicloud/facebody20191230');
const OpenApi = require('@alicloud/openapi-client');
const Util = require('@alicloud/tea-util');
const thirdPartyApi = require('./thirdPartyApi');

/**token缓存 */
let cachedToken = null;
/**token缓存时间 */
let tokenExpiresAt = null;

const app = express();
const port = 3000;
@@ -78,35 +85,34 @@
    const xid = req.body.xid;
    console.log(`action=${action},deviceID=${deviceID},type=${type},xid=${xid}`)
    if (action === 'doWebUser' && deviceID && type !== undefined) {
        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: ''
            const pathParams={code:xid}
            const data = await thirdPartyApi.fetchThirdPartyData('/patient/info/detail2', 'POST', {}, null,  pathParams,{});
            console.log('--------------获取到了患者信息',data.data)
            // console.log(data)
            if(data?.code===200&&data?.message==='SUCCESS'&&data?.data){
                const user = data.data;
                response = {
                    recode: 2001,
                    userinfo: {
                        name: user.patientName,
                        sex: user.patientGenderText,
                        age: user.age,
                        usernum: user.code, //这个是数据返回会携带回来UID
                        address: user.patientAddress,
                        remark: '患者人脸识别111'
                    },
                    dbinfo: {}, // 如果没有需要更新的数据库信息，可以保持空
                    msg: "success"
                    remsg: "success"
                };
                res.json(response);
            } else {
                const response = {
                    retCode: "0",
                    msg: "没有找到患者，请先检查患者code"
                console.log('返回患者信息成功')
            }else{
                response = {
                    retcode: 1001,
                    remsg: "没有找到患者，请先检查患者code"
                };
                res.json(response);
            }
            res.json(response);

        } catch (err) {
            console.error(err);
            res.status(500).json({ retCode: "-1", msg: "Database error" });
@@ -121,34 +127,31 @@
    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: ''
            const pathParams={code:xid}
            const data = await thirdPartyApi.fetchThirdPartyData('/patient/info/detail2', 'POST', {}, null,  pathParams,{});
            console.log('--------------获取到了患者信息')
            // console.log(data)
            if(data?.code===200&&data?.message==='SUCCESS'&&data?.data){
                const user = data.data;
                response = {
                    recode: 2001,
                    userinfo: {
                        name: user.patientName,
                        sex: user.patientGenderText,
                        age: user.age,
                        usernum: user.code, //这个是数据返回会携带回来UID
                        address: user.patientAddress,
                        remark: '患者人脸识别111'
                    },
                    dbinfo: {}, // 如果没有需要更新的数据库信息，可以保持空
                    msg: "success"
                    remsg: "success"
                };
                res.json(response);
            } else {
                const response = {
                    retCode: "0",
                    msg: "没有找到患者，请先检查患者code"
                console.log('返回患者信息成功')
            }else{
                response = {
                    retcode: 1001,
                    remsg: "没有找到患者，请先检查患者code"
                };
                res.json(response);
            }
        } catch (err) {
            console.error(err);
@@ -197,28 +200,32 @@
                    } else if (faceItems[0].score >= 0.2) {
                        const entityId = faceItems[0].entityId
                        console.log(entityId, '患者id找到了')
                        let query = `SELECT * FROM patient_info WHERE code = '${entityId}'`
                        const [rows] = await pool.promise().query(query);
                        if (rows.length > 0) {
                            const user = rows[0];
                        const pathParams={code:entityId}
                        const data = await thirdPartyApi.fetchThirdPartyData('/patient/info/detail2', 'POST', {}, null,  pathParams,{});
                        console.log('--------------获取到了患者信息')
                        // console.log(data)
                        if(data?.code===200&&data?.message==='SUCCESS'&&data?.data){
                            const user = data.data;
                            response = {
                                recode: 2001,
                                userinfo: {
                                    name: user.patient_name,
                                    sex: user.patient_gender === 0 ? '男' : '女',
                                    age: getAgeFromIdCard(user.patient_identity_no),
                                    name: user.patientName,
                                    sex: user.patientGenderText,
                                    age: user.age,
                                    usernum: user.code, //这个是数据返回会携带回来UID
                                    address: user.patient_address,
                                    address: user.patientAddress,
                                    remark: '患者人脸识别111'
                                },
                                remsg: "success"
                            };
                        } else {
                            console.log('返回患者信息成功')
                        }else{
                            response = {
                                retcode: 1001,
                                remsg: "没有找到患者，请先检查患者code"
                            };
                        }
                        
                    } else {
                        response = {
                            retcode: 1001,
@@ -258,10 +265,35 @@
    mode.action='webResults'
    logHttps(mode)
    try {

      
        const datas=mode.datas
        datas.forEach(async element => {
            await installData(element)
            // 组合数据
            let data={}
            // 没有BF
            if(element.fatFree){
                data={
                    id:0,
                    code:element.recordNo,
                    patientCode:element.userID,
                    commTime:element.measureTime,
                    rtcfJsonBf:JSON.stringify(element)
                }
            }
            // 没有BMI
            if(element.bmi){
                data={
                    id:0,
                    code:element.recordNo,
                    patientCode:element.userID,
                    commTime:element.measureTime,
                    rtcfJsonBmi:JSON.stringify(element)
                }
            }
            console.log(data)
            const resdata = await thirdPartyApi.fetchThirdPartyData('/patient/rtcf/result/save', 'POST', {}, data,{},{});
            console.log('-----返回人体成分分析保存')
            console.log(resdata)
        });
        response = {
            recode: "2000",
@@ -287,25 +319,28 @@
  logHttps(mode)
  if(patientId&&clientCode){
    // 输出传入的patientid值
    console.log('Patient ID:',patientId)
    let query = `SELECT * FROM patient_info WHERE patient_name_py LIKE '${patientId}' AND client_code = '${clientCode}'`
    console.log(query)
    try {
        const [rows] = await pool.promise().query(query);
        //查询参数
        const pathParams={
            clientCode:clientCode,
            patQueryCode:patientId
        }
        const data = await thirdPartyApi.fetchThirdPartyDataNoToke('/patient/info/listPatsPublic', 'POST', {}, null,  pathParams,{});
        console.log(data.data.list)
        const rows= data.data.list
        if (rows.length > 0) {
            // const user = rows[0];
            let users=[]
            rows.forEach(user=>{
                users.push({
                    patientId: user.code,
                    fullName: user.patient_name,
                    gender: user.patient_gender,
                    age: getAgeFromIdCard(user.patient_identity_no),
                    fullName: user.patientName,
                    gender: user.patientGender,
                    age: user.age,
                    birthday:'',
                    phoneNum:user.patient_mobile,
                    address: user.patient_avatar_icon,
                    idType: user.patient_identity_type,
                    idNum: user.patient_identity_no,
                    phoneNum:user.patientMobile,
                    address: user.patientAvatarIcon,
                    idType: user.patientIdentityType,
                    idNum: user.patientIdentityNo,
                    height:'',
                    weight:'',
                    requestDoctor:'',
@@ -325,33 +360,39 @@
        }
    } catch (err) {
        console.error(err);
        res.status(500).json({ retCode: "-1", msg: "Database error" });
        res.status(500).json({ retCode: "-1", msg: "接口出错！"+err });
    }

  }else{
    // 如果请求参数不符合预期，则返回错误信息
    res.status(400).json({ retCode: "-1", msg: "Invalid request parameters333" });
    res.status(400).json({ retCode: "-1", msg: "请求参数出错" });
  }

})
/**
 * PostCheckExam  病人信息及检测结果以JSON的形式回传至服务器
 */
app.post('/PostCheckExam',(req,res)=>{
app.post('/PostCheckExam',async (req,res)=>{
    try {
        const mode={
            action:'PostCheckExam',
            params:'jjjj'
        const clientCode = req.query.clientCode;
        console.log('-------------------',clientCode)
        if(!clientCode){
            res.json({"Msg": "请求参数没有clientCode", "Status": "err" });
            return
        }
        logHttps(mode)
        // 查看body参数
        const body=req.body
        console.log(body)
        const mode={
            action:'PostCheckExam',
            params:body.examId
        }
        logHttps(mode)
        // 组合上传数据
        const data={
            id:0,
            code:body.examId,
            code:'',
            patient_code :body.patientId,
            client_code:'',
            client_code:clientCode,
            exam_id:body.examId,
            SBPLB:body.SBPLB,
            MBPLB:body.MBPLB,
@@ -412,15 +453,13 @@
            abi_advice:body.abiAdvice,
            pwv_result:body.pwvResult
        }
        const { query, params } = createInsertQuery('patient_result_from_doppler_blood_flow_device', data);
        pool.query(query, params, (error, results) => {
            if (error) {
              console.error('Error inserting data:', error);
              return res.status(500).json({Status:'error', Msg: '数据库错误'+error });
            }
            
            res.json({ Status:'SUCCESS',Msg: '插入成功'+ results.insertId });
        });
        const resdata = await thirdPartyApi.fetchThirdPartyDataNoToke('/patient/result/from/doppler/blood/flow/device/saveData', 'POST', {}, data,{},{});
        console.log(resdata)
        if(resdata.code===200&&resdata?.data=='OK'){
            res.json({"Msg": "检查结果上传成功", "Status": "SUCCESS" });
        }else{
            res.json({"Msg": "检查结果上传失败", "Status": "err" });
        } 
    }
    catch(err){
        console.log(err)
@@ -435,25 +474,6 @@
app.listen(port, async () => {
    console.log(`Server running at http://localhost:${port}/`);
});
/**
 * 
 * @param {表名称} tableName 
 * @param {表列内容} data 
 * @returns 
 */
const createInsertQuery=(tableName, data) =>{
    const columns = Object.keys(data).map(key => `\`${key}\``).join(', ');
    const placeholders = Object.keys(data).map(() => '?').join(', ');
  
    const query = `INSERT INTO \`${tableName}\` (${columns}) VALUES (${placeholders})`;
  
    // 返回查询字符串和参数数组
    return {
      query,
      params: Object.values(data)
    };
}

/**
 * 
 * @param {*} file base64图片格式转本地
@@ -512,50 +532,10 @@
        console.error('访问日志记录错误:', err);
    }
}
// 插入数据
const installData=async (mode)=>{
    console.log(mode)
    try{
     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.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}---------`)
            console.log(updateSql)
            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_bf,`+
            `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('数据写入异常22')
    }
}

/**
 * 根据身份证算年龄
 */

function getAgeFromIdCard(idCard) {
    // 检查身份证号码长度是否正确
@@ -584,4 +564,3 @@

    return age;
}


 package.json

@@ -16,6 +16,7 @@
  "dependencies": {
    "@alicloud/facebody20191230": "^5.1.2",
    "@alicloud/viapi-utils": "^1.0.0",
    "axios": "^1.7.9",
    "body-parser": "^1.20.3",
    "express": "^4.21.1",
    "moment": "^2.30.1",

 thirdPartyApi.js

New file
@@ -0,0 +1,145 @@
// thirdPartyApi.js
const axios = require('axios');
// BASIC_API = 'https://hemobs.icoldchain.cn/'
const BASIC_API = 'http://testbs.ihemodialysis.com/'
let cachedToken = null;
let tokenExpiresAt = null;

// 获取 Token 的函数
async function getAccessToken() {
  try {
    const formData = new FormData();
    formData.append('user_no', 'data_cyc');
    formData.append('user_password', 'cheng0624');
    const response = await axios.post(`${BASIC_API}/user/info/login`, formData, {
      headers: {
        'Content-Type': 'multipart/form-data', // 通常不需要手动设置，axios 会自动处理
      }
    });
    // 假设响应中包含 token 字段和 expires_in 秒数
    const { data } = response.data;
    const expires_in=3600
    return { data ,expires_in};
  } catch (error) {
    console.error('Error getting access token:', error.message);
    throw error;
  }
}

// 获取缓存或新的 Token
async function getCachedOrNewToken() {
  if (cachedToken && tokenExpiresAt > Date.now()) {
    return cachedToken;
  }

  // 如果 token 已经过期或不存在，则重新获取
  const { data, expires_in } = await getAccessToken();
  cachedToken = data;
  tokenExpiresAt = Date.now() + (expires_in - 60) * 1000; // 提前 60 秒刷新 token
  return cachedToken;
}

// 构建 URL 函数
function buildUrl(base, pathParams) {
  let url = BASIC_API+base;
  Object.keys(pathParams).forEach(key => {
    url = url.replace(`:${key}`, encodeURIComponent(pathParams[key]));
  });
  return url;
}

// 发起第三方 API 请求 不需要token
async function fetchThirdPartyDataNoToke(url, method = 'GET', headers = {}, data = null, queryParams = {}, pathParams = {}) {
  try {
    const fullUrl = buildUrl(url, pathParams);
    const response = await axios({
      url: fullUrl,
      method,
      headers: {
        ...headers
      },
      params: queryParams, // 查询字符串参数
      data // 请求体参数
    });

    return response.data;
  } catch (error) {
    console.error('Error fetching third-party data:', error.message);
    throw error;
  }
}

// 发起第三方 API 请求
async function fetchThirdPartyData(url, method = 'GET', headers = {}, data = null, queryParams = {}, pathParams = {}) {
  try {
    const token = await getCachedOrNewToken();
    console.log('得到了token------------------------',token)
    const fullUrl = buildUrl(url, pathParams);

    const response = await axios({
      url: fullUrl,
      method,
      headers: {
        ...headers,
        Authorization: `Bearer ${token}`
      },
      params: queryParams, // 查询字符串参数
      data // 请求体参数
    });

    return response.data;
  } catch (error) {
    console.error('Error fetching third-party data:', error.message);
    throw error;
  }
}

module.exports = {
  fetchThirdPartyDataNoToke,
  fetchThirdPartyData
};

// 插入数据
const installData=async (mode)=>{
  console.log(mode)
  try{
   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.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}---------`)
          console.log(updateSql)
          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_bf,`+
          `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('数据写入异常22')
  }
}