336 lines
9.8 KiB
JavaScript
336 lines
9.8 KiB
JavaScript
|
const dayjs = require("dayjs");
|
|||
|
|
const Sm4Util = require("../../utils/sm4-util");
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 需要加密的字段列表
|
|||
|
|
*/
|
|||
|
|
const ENCRYPTED_FIELDS = ["name", "mobile", "idCard"];
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 加密诊断记录敏感字段
|
|||
|
|
* @param {Object} data - 诊断记录数据
|
|||
|
|
* @returns {Object} 加密后的数据
|
|||
|
|
*/
|
|||
|
|
function encryptDiagnosticRecordFields(data) {
|
|||
|
|
if (!data || typeof data !== "object") {
|
|||
|
|
return data;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
const encryptedData = { ...data };
|
|||
|
|
|
|||
|
|
ENCRYPTED_FIELDS.forEach((field) => {
|
|||
|
|
if (
|
|||
|
|
encryptedData[field] &&
|
|||
|
|
typeof encryptedData[field] === "string" &&
|
|||
|
|
encryptedData[field].trim() !== ""
|
|||
|
|
) {
|
|||
|
|
try {
|
|||
|
|
encryptedData[field] = Sm4Util.encryptDataForSm3(encryptedData[field]);
|
|||
|
|
} catch (error) {
|
|||
|
|
console.error(`加密字段 ${field} 失败:`, error.message);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
});
|
|||
|
|
|
|||
|
|
return encryptedData;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 解密诊断记录敏感字段
|
|||
|
|
* @param {Object} data - 诊断记录数据
|
|||
|
|
* @returns {Object} 解密后的数据
|
|||
|
|
*/
|
|||
|
|
function decryptDiagnosticRecordFields(data) {
|
|||
|
|
if (!data || typeof data !== "object") {
|
|||
|
|
return data;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
const decryptedData = { ...data };
|
|||
|
|
|
|||
|
|
ENCRYPTED_FIELDS.forEach((field) => {
|
|||
|
|
if (
|
|||
|
|
decryptedData[field] &&
|
|||
|
|
typeof decryptedData[field] === "string" &&
|
|||
|
|
decryptedData[field].trim() !== ""
|
|||
|
|
) {
|
|||
|
|
try {
|
|||
|
|
decryptedData[field] = Sm4Util.decryptDataForSm3(decryptedData[field]) || decryptedData[field];
|
|||
|
|
} catch (error) {
|
|||
|
|
console.error(`解密字段 ${field} 失败:`, error.message);
|
|||
|
|
// 解密失败时保留原值
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
});
|
|||
|
|
|
|||
|
|
return decryptedData;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 批量解密诊断记录列表的敏感字段
|
|||
|
|
* @param {Array} list - 诊断记录列表
|
|||
|
|
* @returns {Array} 解密后的诊断记录列表
|
|||
|
|
*/
|
|||
|
|
function decryptDiagnosticRecordList(list) {
|
|||
|
|
if (!Array.isArray(list)) {
|
|||
|
|
return list;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
return list.map((item) => decryptDiagnosticRecordFields(item));
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
exports.formatUploadRxData = function (data) {
|
|||
|
|
return {
|
|||
|
|
patientid: data.patientId,
|
|||
|
|
orderno: data.medOrgOrderNo,
|
|||
|
|
doctorcode: data.doctorCode,
|
|||
|
|
unitcode: data.unitCode,
|
|||
|
|
hospid: "108",
|
|||
|
|
phar_code: data.pharmacistNo,
|
|||
|
|
phar_name: data.pharmacist,
|
|||
|
|
phar_chk_time: dayjs(data.auditTime).format("YYYY-MM-DD HH:mm:ss"),
|
|||
|
|
ysjd_time: dayjs(data.prescriptionStartTime).format("YYYY-MM-DD HH:mm:ss"),
|
|||
|
|
prsc_time: dayjs(data.prescriptionEndTime).format("YYYY-MM-DD HH:mm:ss"),
|
|||
|
|
details: data.drugs.map((i) => {
|
|||
|
|
const item = {
|
|||
|
|
drug_id: i.insurance_code,
|
|||
|
|
drug_name: i.drugName,
|
|||
|
|
drug_dosform: "",
|
|||
|
|
drug_spec: i.specification || "",
|
|||
|
|
drug_pric: "0",
|
|||
|
|
drug_cnt: i.quantity,
|
|||
|
|
drug_sumamt: "0",
|
|||
|
|
medc_way_codg: i.usageCode,
|
|||
|
|
medc_way_dscr: i.usageName,
|
|||
|
|
medc_days: i.days,
|
|||
|
|
remark: "",
|
|||
|
|
limit_flag: "0",
|
|||
|
|
used_frqu_codg: i.frequencyCode,
|
|||
|
|
used_frqu_name: i.frequencyName,
|
|||
|
|
sin_doscnt: i.dosage,
|
|||
|
|
sin_dosunt: i.dosage_unit,
|
|||
|
|
unit: i.unit,
|
|||
|
|
appr_flag: i.forceSelfPay === 'Y' ? '2' : '1'
|
|||
|
|
}
|
|||
|
|
if (item.appr_flag === '2') {
|
|||
|
|
//[his要求]当appr_flag=2时必填，如果这个药品维护了限制使用范围的，传1，否则就传2
|
|||
|
|
item.self_pay_rea = i.limitUsageScope === 'Y' ? '1' : '2'
|
|||
|
|
}
|
|||
|
|
return item
|
|||
|
|
}),
|
|||
|
|
icds: data.diagnosisList.map((i) => ({
|
|||
|
|
icd_code: i.code,
|
|||
|
|
icd_name: i.name,
|
|||
|
|
})),
|
|||
|
|
};
|
|||
|
|
};
|
|||
|
|
|
|||
|
|
|
|||
|
|
exports.formatOnlineMedicinePurchaseData = function (data) {
|
|||
|
|
const details = data.drugs.map(i => {
|
|||
|
|
const item = {
|
|||
|
|
drug_type: "xy",
|
|||
|
|
drug_groupno: i.hisChargeInfo.drugGroupNo,
|
|||
|
|
drug_group: "",
|
|||
|
|
drug_id: i.hisChargeInfo.drugId,
|
|||
|
|
drug_serial: i.hisChargeInfo.drugSerial,
|
|||
|
|
drug_name: i.drugName,
|
|||
|
|
drug_spec: i.specification || "",
|
|||
|
|
drug_pric: i.hisChargeInfo.drugPrice,
|
|||
|
|
drug_cnt: i.quantity,
|
|||
|
|
drug_sumamt: i.hisChargeInfo.drugSumamt, //总金额 总金额=数量*单价
|
|||
|
|
supple_code: i.usageCode,
|
|||
|
|
supple_name: i.usageName,
|
|||
|
|
medc_days: i.days,
|
|||
|
|
drug_times: 1,
|
|||
|
|
drug_comm: "",
|
|||
|
|
drug_ma: "",
|
|||
|
|
remark: "",
|
|||
|
|
limit_flag: "0",
|
|||
|
|
usage: i.frequencyCode,
|
|||
|
|
usage_name: i.frequencyName,
|
|||
|
|
sin_doscnt: i.dosage,
|
|||
|
|
sin_dosunt: i.dosage_unit_code,
|
|||
|
|
unit: i.unit,
|
|||
|
|
appr_flag: i.forceSelfPay === 'Y' ? '2':'1'
|
|||
|
|
}
|
|||
|
|
if (item.appr_flag === '2') {
|
|||
|
|
//[his要求]当appr_flag=2时必填，如果这个药品维护了限制使用范围的，传1，否则就传2
|
|||
|
|
item.self_pay_rea = i.limitUsageScope === 'Y' ? '1' : '2'
|
|||
|
|
}
|
|||
|
|
return item
|
|||
|
|
})
|
|||
|
|
return {
|
|||
|
|
patientid: data.patientId,
|
|||
|
|
registerid: "",
|
|||
|
|
orderno: data.medOrgOrderNo,
|
|||
|
|
doctorcode: data.doctorCode,
|
|||
|
|
unitcode: data.unitCode,
|
|||
|
|
visit_time: dayjs(data.prescriptionStartTime).format("YYYY-MM-DD HH:mm:ss"),
|
|||
|
|
area_code: data.areaCode,
|
|||
|
|
hospid: "108",
|
|||
|
|
details,
|
|||
|
|
icds: data.diagnosisList.map((i, idx) => ({
|
|||
|
|
icd_code: i.code,
|
|||
|
|
icd_name: i.name,
|
|||
|
|
sort: idx + 1
|
|||
|
|
}))
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
exports.formatWinePurchaseData = function (data, order) {
|
|||
|
|
const [wine] = data.wines;
|
|||
|
|
return {
|
|||
|
|
patientid: data.patientId,
|
|||
|
|
registerid: order.medorg_order_no,
|
|||
|
|
orderno: data.medOrgOrderNo,
|
|||
|
|
doctorcode: data.doctorCode,
|
|||
|
|
unitcode: data.unitCode,
|
|||
|
|
visit_time: dayjs(data.prescriptionStartTime).format("YYYY-MM-DD HH:mm:ss"),
|
|||
|
|
operator_id: data.drugStoreNo,
|
|||
|
|
tc_code: wine.hisId,
|
|||
|
|
drug_times: wine.quantity,
|
|||
|
|
delivery: data.pickUpType === 'delivery' ? 1 :0,//是否配送 1配送 0自提 order.pickUpType === 'delivery' ? 1 :0
|
|||
|
|
hospid: "108",
|
|||
|
|
icds: data.diagnosisList.map((i) => ({
|
|||
|
|
icd_code: i.code,
|
|||
|
|
icd_name: i.name,
|
|||
|
|
})),
|
|||
|
|
};
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 构建支持明文+密文混合搜索的查询条件
|
|||
|
|
* 用于数据迁移期间，数据库中同时存在明文和密文数据的情况
|
|||
|
|
*
|
|||
|
|
* @param {string} fieldName - 字段名（如 'name', 'mobile', 'idCard'）
|
|||
|
|
* @param {string} searchValue - 搜索值（明文）
|
|||
|
|
* @param {boolean} exactMatch - 是否精确匹配，默认为false（模糊匹配）
|
|||
|
|
* @returns {Object} MongoDB查询条件对象
|
|||
|
|
*/
|
|||
|
|
function buildHybridSearchQuery(fieldName, searchValue, exactMatch = false) {
|
|||
|
|
if (
|
|||
|
|
!searchValue ||
|
|||
|
|
typeof searchValue !== "string" ||
|
|||
|
|
searchValue.trim() === ""
|
|||
|
|
) {
|
|||
|
|
return null;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
const trimmedValue = searchValue.trim();
|
|||
|
|
|
|||
|
|
try {
|
|||
|
|
// 尝试加密搜索值
|
|||
|
|
const encryptedValue = Sm4Util.encryptDataForSm3(trimmedValue);
|
|||
|
|
|
|||
|
|
if (exactMatch) {
|
|||
|
|
// 精确匹配：同时匹配明文和密文
|
|||
|
|
return {
|
|||
|
|
$or: [
|
|||
|
|
{ [fieldName]: trimmedValue }, // 明文精确匹配
|
|||
|
|
{ [fieldName]: encryptedValue }, // 密文精确匹配
|
|||
|
|
],
|
|||
|
|
};
|
|||
|
|
} else {
|
|||
|
|
// 模糊匹配：明文用正则，密文用精确匹配（因为密文无法模糊匹配）
|
|||
|
|
return {
|
|||
|
|
$or: [
|
|||
|
|
{ [fieldName]: new RegExp(trimmedValue, "i") }, // 明文模糊匹配（不区分大小写）
|
|||
|
|
{ [fieldName]: encryptedValue }, // 密文精确匹配
|
|||
|
|
],
|
|||
|
|
};
|
|||
|
|
}
|
|||
|
|
} catch (error) {
|
|||
|
|
// 如果加密失败（如环境变量未配置），只搜索明文
|
|||
|
|
console.warn(`加密搜索值失败，只搜索明文数据: ${error.message}`);
|
|||
|
|
|
|||
|
|
if (exactMatch) {
|
|||
|
|
return { [fieldName]: trimmedValue };
|
|||
|
|
} else {
|
|||
|
|
return { [fieldName]: new RegExp(trimmedValue, "i") };
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 批量构建混合搜索条件
|
|||
|
|
* @param {Object} searchParams - 搜索参数对象，如 { name: '张三', mobile: '138' }
|
|||
|
|
* @param {boolean} exactMatch - 是否精确匹配
|
|||
|
|
* @returns {Array} MongoDB $and 条件数组
|
|||
|
|
*/
|
|||
|
|
function buildMultiFieldHybridSearch(searchParams, exactMatch = false) {
|
|||
|
|
const conditions = [];
|
|||
|
|
|
|||
|
|
Object.keys(searchParams).forEach((fieldName) => {
|
|||
|
|
const searchValue = searchParams[fieldName];
|
|||
|
|
const condition = buildHybridSearchQuery(
|
|||
|
|
fieldName,
|
|||
|
|
searchValue,
|
|||
|
|
exactMatch
|
|||
|
|
);
|
|||
|
|
if (condition) {
|
|||
|
|
conditions.push(condition);
|
|||
|
|
}
|
|||
|
|
});
|
|||
|
|
|
|||
|
|
return conditions;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
exports.formatReviewData = function (data) {
|
|||
|
|
const details = data.drugs.map(i => {
|
|||
|
|
const item = {
|
|||
|
|
drug_type: "xy",
|
|||
|
|
drug_groupno: i.hisChargeInfo.drugGroupNo,
|
|||
|
|
drug_group: "",
|
|||
|
|
drug_id: i.hisChargeInfo.drugId,
|
|||
|
|
drug_serial: i.hisChargeInfo.drugSerial,
|
|||
|
|
drug_name: i.drugName,
|
|||
|
|
drug_spec: i.specification || "",
|
|||
|
|
drug_pric: i.hisChargeInfo.drugPrice,
|
|||
|
|
drug_cnt: i.quantity,
|
|||
|
|
drug_sumamt: i.hisChargeInfo.drugSumamt, //总金额 总金额=数量*单价
|
|||
|
|
supple_code: i.usageCode,
|
|||
|
|
supple_name: i.usageName,
|
|||
|
|
medc_days: i.days,
|
|||
|
|
drug_times: 1,
|
|||
|
|
drug_comm: "",
|
|||
|
|
drug_ma: "",
|
|||
|
|
remark: "",
|
|||
|
|
limit_flag: "0",
|
|||
|
|
usage: i.frequencyCode,
|
|||
|
|
usage_name: i.frequencyName,
|
|||
|
|
sin_doscnt: i.dosage,
|
|||
|
|
sin_dosunt: i.dosage_unit_code,
|
|||
|
|
unit: i.unit,
|
|||
|
|
appr_flag: i.forceSelfPay === 'Y' ? '2':'1'
|
|||
|
|
}
|
|||
|
|
if (item.appr_flag === '2') {
|
|||
|
|
//[his要求]当appr_flag=2时必填，如果这个药品维护了限制使用范围的，传1，否则就传2
|
|||
|
|
item.self_pay_rea = i.limitUsageScope === 'Y' ? '1' : '2'
|
|||
|
|
}
|
|||
|
|
return item
|
|||
|
|
})
|
|||
|
|
return {
|
|||
|
|
patientid: data.patientId,
|
|||
|
|
registerid: "",
|
|||
|
|
orderno: data.medOrgOrderNo,
|
|||
|
|
doctorcode: data.doctorCode,
|
|||
|
|
unitcode: data.unitCode,
|
|||
|
|
visit_time: dayjs(data.prescriptionStartTime).format("YYYY-MM-DD HH:mm:ss"),
|
|||
|
|
area_code: data.areaCode,
|
|||
|
|
hospid: "108",
|
|||
|
|
details,
|
|||
|
|
icds: data.diagnosisList.map((i, idx) => ({
|
|||
|
|
icd_code: i.code,
|
|||
|
|
icd_name: i.name,
|
|||
|
|
sort: idx + 1
|
|||
|
|
}))
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
exports.encryptDiagnosticRecordFields = encryptDiagnosticRecordFields;
|
|||
|
|
exports.decryptDiagnosticRecordFields = decryptDiagnosticRecordFields;
|
|||
|
|
exports.decryptDiagnosticRecordList = decryptDiagnosticRecordList;
|
|||
|
|
exports.buildHybridSearchQuery = buildHybridSearchQuery;
|
|||
|
|
exports.buildMultiFieldHybridSearch = buildMultiFieldHybridSearch;
|
|||
|
|
exports.ENCRYPTED_FIELDS = ENCRYPTED_FIELDS;
|