const express = require('express');
|
const bodyParser = require('body-parser');
|
const mysql = require('mysql2');
|
const fs = require('fs').promises;
|
const path = require('path');
|
// 转成能识别的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 Tea = require('@alicloud/tea-typescript');
|
|
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: user.patient_age_2,
|
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_emeishan',
|
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: user.patient_age_2,
|
headimgurl: user.patient_avatar_icon,
|
imgBaseData: '',
|
remark: ''
|
},
|
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.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)
|
}
|
