const express = require('express');
|
const bodyParser = require('body-parser');
|
const mysql = require('mysql2');
|
const fs = require('fs').promises;
|
const path = require('path');
|
const moment = require('moment')
|
// 转成能识别的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 app = express();
|
const port = 3000;
|
|
// 使用 body-parser 中间件解析 JSON 请求体
|
app.use(bodyParser.json());
|
|
// 创建 MySQL 连接池
|
const pool = mysql.createPool({
|
host: 'rds.leon056.com',
|
port: 26422, // 确保端口号正确
|
user: 'root',
|
password: 'PalGain2007', // 请替换为您的数据库密码
|
database: 'hemodialysis_sys' // 请替换为您的数据库名称
|
});
|
|
const createClient = () => {
|
// 工程代码泄露可能会导致 AccessKey 泄露，并威胁账号下所有资源的安全性。以下代码示例仅供参考。
|
// 建议使用更安全的 STS 方式，更多鉴权访问方式请参见：https://help.aliyun.com/document_detail/378664.html。
|
let config = new OpenApi.Config({
|
// 必填，请确保代码运行环境设置了环境变量 ALIBABA_CLOUD_ACCESS_KEY_ID。
|
accessKeyId: 'LTAI5tPBxZiqgd9h6gcL9Qzc',
|
// 必填，请确保代码运行环境设置了环境变量 ALIBABA_CLOUD_ACCESS_KEY_SECRET。
|
accessKeySecret: 'IE6nsjJMTul2ZHkeQ27bg4wmWIngTu',
|
});
|
// Endpoint 请参考 https://api.aliyun.com/product/facebody
|
config.endpoint = `facebody.cn-shanghai.aliyuncs.com`;
|
return new facebody20191230.default(config);
|
}
|
|
// 定义 /webuser 路由处理器 用患者code 换信息
|
app.post('/webuser', async (req, res) => {
|
const mode=req.body
|
logHttps(mode)
|
const action = req.body.action;
|
const deviceID = req.body.deviceID;
|
const type = req.body.type;
|
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: ''
|
},
|
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) => {
|
const action = req.body.action;
|
const deviceID = req.body.deviceID;
|
// base64图像内容，base64 编码(长宽像素值范围：80*80~200*200，注意：图片的base64 编码是不包含图片头的，如 data:image/jpg;base64,)
|
const content = req.body.content;
|
const mode=req.body
|
logHttps(mode)
|
if (action == 'doFace' && deviceID && content) {
|
// 转成oss路径
|
const ossurl = await base64toFile(content, deviceID)
|
console.log('得到oss图片路径', ossurl)
|
let searchFaceRequest = new facebody20191230.SearchFaceRequest({
|
dbName: 'Face_systemtest',
|
imageUrl: ossurl,
|
limit: 1,
|
});
|
|
let runtime = new Util.RuntimeOptions({});
|
try {
|
// 复制代码运行请自行打印 API 的返回值
|
const data = await createClient().searchFaceWithOptions(searchFaceRequest, runtime);
|
const matchList = data.body.data?.matchList
|
let response = null
|
if (matchList?.length > 0) {
|
const faceItems = matchList[0].faceItems
|
if (faceItems?.length === 0) {
|
console.log('没有找到患者对应的人脸')
|
response = {
|
retCode: "0",
|
msg: "没有找到患者，请先检查患者code"
|
};
|
} 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];
|
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: '患者人脸识别111'
|
},
|
dbinfo: {}, // 如果没有需要更新的数据库信息，可以保持空
|
msg: "success"
|
};
|
// res.json(response);
|
} else {
|
response = {
|
retCode: "0",
|
msg: "没有找到患者，请先检查患者code"
|
};
|
// res.json(response);
|
}
|
} else {
|
response = {
|
retCode: "0",
|
msg: "没有找到患者，请先检查患者code"
|
};
|
}
|
res.json(response);
|
}
|
else {
|
res.status(500).json({ retCode: "-1", msg: "没有识别到患者" });
|
}
|
} catch (error) {
|
// 此处仅做打印展示，请谨慎对待异常处理，在工程项目中切勿直接忽略异常。
|
// 错误 message
|
console.log(error)
|
res.status(400).json({ retCode: "-1", msg: "Invalid request parameters" });
|
|
}
|
} else {
|
// 如果请求参数不符合预期，则返回错误信息
|
res.status(400).json({ retCode: "-1", msg: "Invalid request parameters" });
|
}
|
|
|
|
|
})
|
// 定义设备数据回传接口
|
// 定义数据回传接口
|
app.post('/webResults',async (req, res) =>{
|
const action = req.body.action;
|
const deviceID = req.body.deviceID;
|
const mode=req.body
|
logHttps(mode)
|
try {
|
const datas=mode.datas
|
datas.forEach(async element => {
|
await installData(element)
|
});
|
response = {
|
retCode: "1",
|
msg: "成功"
|
};
|
res.json(response)
|
|
}catch(err){
|
res.status(400).json({ retCode: "-1", msg: "Invalid request parameters" });
|
}
|
|
})
|
// 启动服务器
|
app.listen(port, async () => {
|
console.log(`Server running at http://localhost:${port}/`);
|
});
|
|
/**
|
*
|
* @param {*} file base64图片格式转本地
|
*/
|
// base64z转文件后验证
|
const base64toFile = async (dataurl, imgName) => {
|
// 将 Base64 数据转换为 Buffer
|
const buffer = Buffer.from(dataurl, 'base64');
|
// 定义输出文件路径
|
// 定义输出文件路径
|
const outputDir = path.join(__dirname, 'img');
|
const outputPath = path.join(outputDir, `${imgName}.png`);
|
await ensureDirectoryExists(outputDir);
|
await fs.writeFile(outputPath, buffer);
|
const ossUrl = await getOssUrl(outputPath)
|
// 删除本地图片
|
delImg(outputPath)
|
console.log('File saved to', outputPath);
|
console.log(`得到ossUrl=${ossUrl}`)
|
return ossUrl
|
|
}
|
//验证后删除文件图片
|
const delImg = (path) => {
|
fs.unlink(path, (err) => {
|
if (err) {
|
console.log('删除失败')
|
} else {
|
console.log('删除成功')
|
}
|
})
|
}
|
|
// 确保输出目录存在
|
const ensureDirectoryExists = async (directory) => {
|
try {
|
await fs.mkdir(directory, { recursive: true });
|
} catch (err) {
|
console.error('Error creating directory:', err);
|
throw err;
|
}
|
}
|
// 将文件上传到阿里的oss
|
const getOssUrl = async (path) => {
|
let ossUrl = await ViapiUtil.default.upload('LTAI5tPBxZiqgd9h6gcL9Qzc', 'IE6nsjJMTul2ZHkeQ27bg4wmWIngTu', path);
|
console.log(ossUrl)
|
return ossUrl
|
}
|
|
// 访问日志记录
|
const logHttps=(mode)=>{
|
console.log(mode)
|
console.log(JSON.stringify(mode))
|
let sqlStr=`INSERT INTO system_log (id, code, url, parameter) VALUES (0, '', '${mode.action}', '${JSON.stringify(mode)}')`
|
pool.promise().query(sqlStr)
|
}
|
// 插入数据
|
const installData=async (mode)=>{
|
try{
|
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.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)
|
}catch(err){
|
console.log('数据写入异常')
|
}
|
}
|
const getAge=(idCard)=>{
|
// 检查身份证号码长度是否正确
|
if (idCard.length !== 18) {
|
throw new Error('身份证号码长度必须为18位');
|
}
|
|
// 获取出生年月日
|
const birthYear = parseInt(idCard.substring(6, 10), 10);
|
const birthMonth = parseInt(idCard.substring(10, 12), 10);
|
const birthDay = parseInt(idCard.substring(12, 14), 10);
|
|
// 获取当前日期
|
const now = new Date();
|
const currentYear = now.getFullYear();
|
const currentMonth = now.getMonth() + 1; // 注意：getMonth() 返回的月份是从0开始的
|
const currentDay = now.getDate();
|
|
// 计算年龄
|
let age = currentYear - birthYear;
|
|
// 如果当前日期在生日之前，则年龄减一
|
if (currentMonth < birthMonth || (currentMonth === birthMonth && currentDay < birthDay)) {
|
age--;
|
}
|
|
return age;
|
}
|
function getAgeFromIdCard(idCard) {
|
// 检查身份证号码长度是否正确
|
if (idCard.length !== 18) {
|
// throw new Error('身份证号码长度必须为18位');
|
return ''
|
}
|
|
// 获取出生年月日
|
const birthYear = parseInt(idCard.substring(6, 10), 10);
|
const birthMonth = parseInt(idCard.substring(10, 12), 10);
|
const birthDay = parseInt(idCard.substring(12, 14), 10);
|
|
// 获取当前日期
|
const now = new Date();
|
const currentYear = now.getFullYear();
|
const currentMonth = now.getMonth() + 1; // 注意：getMonth() 返回的月份是从0开始的
|
const currentDay = now.getDate();
|
|
// 计算年龄
|
let age = currentYear - birthYear;
|
|
// 如果当前日期在生日之前，则年龄减一
|
if (currentMonth < birthMonth || (currentMonth === birthMonth && currentDay < birthDay)) {
|
age--;
|
}
|
|
return age;
|
}
|
