666 lines
18 KiB
JavaScript
666 lines
18 KiB
JavaScript
|
const dayjs = require("dayjs");
|
|||
|
|
const sop = require("../sop");
|
|||
|
|
const common = require("../../common");
|
|||
|
|
const appFunction = require("../app-function");
|
|||
|
|
const customerHisSyncAppFunction = require("../app-function/customerHisSync.js");
|
|||
|
|
let db = null;
|
|||
|
|
let recordDB = null;
|
|||
|
|
|
|||
|
|
exports.main = async (content, DB) => {
|
|||
|
|
db = DB;
|
|||
|
|
recordDB = db.collection("medical-record");
|
|||
|
|
switch (content.type) {
|
|||
|
|
case "addMedicalRecord":
|
|||
|
|
return await exports.add(content);
|
|||
|
|
case "getCustomerMedicalRecord":
|
|||
|
|
return await exports.getList(content);
|
|||
|
|
case "getMedicalRecordById":
|
|||
|
|
return await exports.getById(content);
|
|||
|
|
case "updateMedicalRecord":
|
|||
|
|
return await exports.update(content);
|
|||
|
|
case "removeMedicalRecord":
|
|||
|
|
return await exports.remove(content);
|
|||
|
|
case "mergeMedicalHisRecord":
|
|||
|
|
return await mergeMedicalHisRecord(content);
|
|||
|
|
case "getArriveTime":
|
|||
|
|
return await exports.getArriveTime(content);
|
|||
|
|
case "getMedicalFiledsTrend":
|
|||
|
|
return await exports.getMedicalFiledsTrend(content);
|
|||
|
|
case "addHealthIndicators":
|
|||
|
|
return await addHealthIndicators(content);
|
|||
|
|
case "getHealthIndicators":
|
|||
|
|
return await getHealthIndicators(content);
|
|||
|
|
case "getHealthIndicatorsTemplate":
|
|||
|
|
return await exports.getHealthIndicatorsTemplate(content);
|
|||
|
|
}
|
|||
|
|
};
|
|||
|
|
|
|||
|
|
async function getHealthIndicators({ corpId, memberId }) {
|
|||
|
|
if (!memberId) {
|
|||
|
|
return { success: false, message: "客户id不能为空" };
|
|||
|
|
}
|
|||
|
|
if (!corpId) {
|
|||
|
|
return { success: false, message: "机构id不能为空" };
|
|||
|
|
}
|
|||
|
|
try {
|
|||
|
|
const list = await db
|
|||
|
|
.collection("corp-health-indicators")
|
|||
|
|
.find({ memberId, corpId })
|
|||
|
|
.limit(1000)
|
|||
|
|
.toArray();
|
|||
|
|
return { success: true, message: "获取客户信息成功", list };
|
|||
|
|
} catch (e) {
|
|||
|
|
return { success: false, message: "获取客户信息失败" };
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
exports.getHealthIndicatorsTemplate = async function (context) {
|
|||
|
|
const { corpId } = context;
|
|||
|
|
try {
|
|||
|
|
let list = await db
|
|||
|
|
.collection("health-indicators-template")
|
|||
|
|
.find({ corpId })
|
|||
|
|
.toArray();
|
|||
|
|
if (list.length === 0) {
|
|||
|
|
list = await db
|
|||
|
|
.collection("health-indicators-template")
|
|||
|
|
.find({ corpId: { $exists: false } })
|
|||
|
|
.toArray();
|
|||
|
|
}
|
|||
|
|
const templateList =
|
|||
|
|
Array.isArray(list) && list[0] ? list[0].templateList : [];
|
|||
|
|
return { success: true, message: "获取客户信息成功", templateList };
|
|||
|
|
} catch (e) {
|
|||
|
|
return { success: false, message: "获取客户信息失败" };
|
|||
|
|
}
|
|||
|
|
};
|
|||
|
|
|
|||
|
|
exports.getMedicalFiledsTrend = async function (context) {
|
|||
|
|
const { corpId, memberId, field, dates } = context;
|
|||
|
|
const { startTime, lastTime } = getStartAndEndTime(dates);
|
|||
|
|
if (!memberId) {
|
|||
|
|
return { success: false, message: "客户id不能为空" };
|
|||
|
|
}
|
|||
|
|
if (!corpId) {
|
|||
|
|
return { success: false, message: "机构id不能为空" };
|
|||
|
|
}
|
|||
|
|
if (!field) {
|
|||
|
|
return { success: false, message: "字段不能为空" };
|
|||
|
|
}
|
|||
|
|
let query = { corpId, memberId, [field]: { $exists: true } };
|
|||
|
|
if (startTime && lastTime) {
|
|||
|
|
query.createTime = { $gte: startTime, $lte: lastTime };
|
|||
|
|
}
|
|||
|
|
try {
|
|||
|
|
const list = await recordDB
|
|||
|
|
.find(query)
|
|||
|
|
.project({ [field]: 1, createTime: 1, _id: 0 })
|
|||
|
|
.sort({ createTime: 1 })
|
|||
|
|
.toArray();
|
|||
|
|
return { success: true, message: "获取客户信息成功", list };
|
|||
|
|
} catch (e) {
|
|||
|
|
return { success: false, message: "获取客户信息失败" };
|
|||
|
|
}
|
|||
|
|
};
|
|||
|
|
|
|||
|
|
function getStartAndEndTime(dates) {
|
|||
|
|
if (!dates || dates.length === 0) {
|
|||
|
|
return {
|
|||
|
|
startTime: "",
|
|||
|
|
lastTime: "",
|
|||
|
|
};
|
|||
|
|
}
|
|||
|
|
let t_1 = dates[0];
|
|||
|
|
let t_2 = dates[1];
|
|||
|
|
return {
|
|||
|
|
startTime: t_1 && new Date(t_1).setHours(0, 0, 0, 0),
|
|||
|
|
lastTime: t_2 && new Date(t_2).setHours(23, 59, 59, 999),
|
|||
|
|
};
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
exports.add = async function (context) {
|
|||
|
|
const {
|
|||
|
|
memberId,
|
|||
|
|
corpId,
|
|||
|
|
personResponsibles,
|
|||
|
|
customerUserId,
|
|||
|
|
createTeamId,
|
|||
|
|
createTeamName,
|
|||
|
|
customerName = "",
|
|||
|
|
...rest
|
|||
|
|
} = context;
|
|||
|
|
if (!memberId) {
|
|||
|
|
return { success: false, message: "客户id不能为空" };
|
|||
|
|
}
|
|||
|
|
if (!corpId) {
|
|||
|
|
return { success: false, message: "机构id不能为空" };
|
|||
|
|
}
|
|||
|
|
try {
|
|||
|
|
const id = common.generateRandomString(24);
|
|||
|
|
await recordDB.insertOne({
|
|||
|
|
_id: id,
|
|||
|
|
...rest,
|
|||
|
|
memberId,
|
|||
|
|
corpId,
|
|||
|
|
createTime: new Date().getTime(),
|
|||
|
|
});
|
|||
|
|
|
|||
|
|
// 更新健康指标
|
|||
|
|
const healthIndicatorsActtionTask = healthIndicatorsActtion({
|
|||
|
|
corpId,
|
|||
|
|
memberId,
|
|||
|
|
rest,
|
|||
|
|
type: "add",
|
|||
|
|
recordId: id,
|
|||
|
|
});
|
|||
|
|
const time = rest.sortTime && dayjs(rest.sortTime).isValid();
|
|||
|
|
const case1 =
|
|||
|
|
["outpatient", "inhospital"].includes(rest.medicalType) &&
|
|||
|
|
rest.corp === "本院";
|
|||
|
|
const case2 = [
|
|||
|
|
"healthProjectTemplate",
|
|||
|
|
"physicalExaminationTemplate",
|
|||
|
|
].includes(rest.medicalType);
|
|||
|
|
//更新入院时间到客户档案
|
|||
|
|
let updateCustomerTimeFieldTask = null;
|
|||
|
|
if (time && (case1 || case2)) {
|
|||
|
|
updateCustomerTimeFieldTask = updateCustomerVisitTime({
|
|||
|
|
memberId,
|
|||
|
|
visitTime: rest.sortTime,
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
let triggerSopTask = null;
|
|||
|
|
if (rest.medicalType !== "healthRecord") {
|
|||
|
|
triggerSopTask = triggerSop({
|
|||
|
|
medicalRecord: rest,
|
|||
|
|
memberId,
|
|||
|
|
corpId,
|
|||
|
|
medicalRecordId: id,
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
const params = {
|
|||
|
|
eventType: "customerUpdate",
|
|||
|
|
customerId: memberId,
|
|||
|
|
executorUserId: rest.creator,
|
|||
|
|
executeTeamId: createTeamId,
|
|||
|
|
createTeamName,
|
|||
|
|
creatorUserId: rest.creator,
|
|||
|
|
corpId,
|
|||
|
|
customerName,
|
|||
|
|
createTime: dayjs().valueOf(),
|
|||
|
|
taskContent: `更新${customerName}客户健康档案`,
|
|||
|
|
executionTime: dayjs().valueOf(),
|
|||
|
|
};
|
|||
|
|
const addServiceRecordTask = rest.creator
|
|||
|
|
? appFunction.addServiceRecord(params)
|
|||
|
|
: null;
|
|||
|
|
await Promise.all([
|
|||
|
|
healthIndicatorsActtionTask,
|
|||
|
|
updateCustomerTimeFieldTask,
|
|||
|
|
triggerSopTask,
|
|||
|
|
addServiceRecordTask,
|
|||
|
|
]);
|
|||
|
|
return {
|
|||
|
|
success: true,
|
|||
|
|
message: "新增成功",
|
|||
|
|
data: id,
|
|||
|
|
};
|
|||
|
|
} catch (e) {
|
|||
|
|
return { success: false, message: "新增失败" };
|
|||
|
|
}
|
|||
|
|
};
|
|||
|
|
|
|||
|
|
updateCustomerVisitTime = async function (context) {
|
|||
|
|
const { memberId, visitTime } = context;
|
|||
|
|
if (!memberId) {
|
|||
|
|
return { success: false, message: "客户id不能为空" };
|
|||
|
|
}
|
|||
|
|
if (!visitTime) {
|
|||
|
|
return { success: false, message: "到院时间不能为空" };
|
|||
|
|
}
|
|||
|
|
try {
|
|||
|
|
await db
|
|||
|
|
.collection("member")
|
|||
|
|
.updateOne({ _id: memberId, visitTimes: { $nin: [visitTime] } }, { $push: { visitTimes: visitTime } });
|
|||
|
|
return { success: true, message: "更新成功" };
|
|||
|
|
} catch (e) {
|
|||
|
|
return { success: false, message: "更新失败" };
|
|||
|
|
}
|
|||
|
|
};
|
|||
|
|
|
|||
|
|
// 执行sop
|
|||
|
|
async function triggerSop({
|
|||
|
|
medicalRecord,
|
|||
|
|
memberId,
|
|||
|
|
corpId,
|
|||
|
|
medicalRecordId,
|
|||
|
|
healthIndicators,
|
|||
|
|
}) {
|
|||
|
|
if (!memberId) return;
|
|||
|
|
if (
|
|||
|
|
medicalRecord &&
|
|||
|
|
medicalRecord.medicalType === "outpatient" &&
|
|||
|
|
medicalRecord.diagnosisName
|
|||
|
|
) {
|
|||
|
|
medicalRecord["outpatientDiagnosis"] = medicalRecord.diagnosisName;
|
|||
|
|
}
|
|||
|
|
if (
|
|||
|
|
medicalRecord &&
|
|||
|
|
medicalRecord.medicalType === "inhospital" &&
|
|||
|
|
medicalRecord.diagnosisName
|
|||
|
|
) {
|
|||
|
|
medicalRecord["inhospitalDiagnosis"] = medicalRecord.diagnosisName;
|
|||
|
|
}
|
|||
|
|
const query = {
|
|||
|
|
corpId,
|
|||
|
|
customerId: memberId,
|
|||
|
|
medicalRecord,
|
|||
|
|
medicalRecordId,
|
|||
|
|
healthIndicators,
|
|||
|
|
};
|
|||
|
|
let res = await sop.main(
|
|||
|
|
{
|
|||
|
|
type: "triggerSopTask",
|
|||
|
|
...query,
|
|||
|
|
},
|
|||
|
|
db
|
|||
|
|
);
|
|||
|
|
console.log("sop", res);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 更改健康指标操作
|
|||
|
|
async function healthIndicatorsActtion({
|
|||
|
|
corpId,
|
|||
|
|
memberId,
|
|||
|
|
recordId,
|
|||
|
|
rest,
|
|||
|
|
type,
|
|||
|
|
}) {
|
|||
|
|
try {
|
|||
|
|
let healthIndicators = {};
|
|||
|
|
let { templateList, success } = await exports.getHealthIndicatorsTemplate({
|
|||
|
|
corpId,
|
|||
|
|
});
|
|||
|
|
if (success) {
|
|||
|
|
for (let item of templateList) {
|
|||
|
|
healthIndicators[item.title] = item.name;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
//遍历 rest 的所有字段
|
|||
|
|
let isMatch = false;
|
|||
|
|
for (let key in rest) {
|
|||
|
|
if (healthIndicators[key]) {
|
|||
|
|
isMatch = true;
|
|||
|
|
if (type === "update" || type === "add") {
|
|||
|
|
let value = rest[key];
|
|||
|
|
if (typeof value === "string" && !isNaN(value)) value = Number(value);
|
|||
|
|
await addHealthIndicators({
|
|||
|
|
corpId,
|
|||
|
|
memberId,
|
|||
|
|
field: key,
|
|||
|
|
value,
|
|||
|
|
recordId,
|
|||
|
|
type,
|
|||
|
|
});
|
|||
|
|
} else if (type === "remove") {
|
|||
|
|
await removeRecordMerageHealthIndicators({
|
|||
|
|
corpId,
|
|||
|
|
memberId,
|
|||
|
|
recordId,
|
|||
|
|
field: key,
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
if (isMatch) {
|
|||
|
|
// 触发sop
|
|||
|
|
console.log("触发sop");
|
|||
|
|
const { success, list } = await getHealthIndicators({ corpId, memberId });
|
|||
|
|
let healthIndicators = {};
|
|||
|
|
if (success && list) {
|
|||
|
|
for (let item of list) {
|
|||
|
|
healthIndicators[item.type] = item.value;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
await triggerSop({ memberId, corpId, healthIndicators });
|
|||
|
|
}
|
|||
|
|
} catch (e) {
|
|||
|
|
console.error("healthIndicatorsActtion error:", e);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
async function addHealthIndicators({
|
|||
|
|
corpId,
|
|||
|
|
memberId,
|
|||
|
|
field,
|
|||
|
|
value,
|
|||
|
|
name,
|
|||
|
|
recordId,
|
|||
|
|
type,
|
|||
|
|
}) {
|
|||
|
|
if (!memberId) {
|
|||
|
|
return { success: false, message: "客户id不能为空" };
|
|||
|
|
}
|
|||
|
|
if (!corpId) {
|
|||
|
|
return { success: false, message: "机构id不能为空" };
|
|||
|
|
}
|
|||
|
|
try {
|
|||
|
|
const params = { type: field, memberId, corpId };
|
|||
|
|
const query = type === "update" ? { ...params, recordId } : params;
|
|||
|
|
const count = await db
|
|||
|
|
.collection("corp-health-indicators")
|
|||
|
|
.find(query)
|
|||
|
|
.count();
|
|||
|
|
if (count > 0) {
|
|||
|
|
await db.collection("corp-health-indicators").updateOne(params, {
|
|||
|
|
$set: { value, updateTime: new Date().getTime(), recordId },
|
|||
|
|
});
|
|||
|
|
} else {
|
|||
|
|
type === "add" &&
|
|||
|
|
(await db.collection("corp-health-indicators").insertOne({
|
|||
|
|
_id: common.generateRandomString(24),
|
|||
|
|
...params,
|
|||
|
|
createTime: new Date().getTime(),
|
|||
|
|
value,
|
|||
|
|
name,
|
|||
|
|
recordId,
|
|||
|
|
}));
|
|||
|
|
}
|
|||
|
|
return { success: true, message: "新增成功" };
|
|||
|
|
} catch (e) {
|
|||
|
|
return { success: false, message: "新增失败" };
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
// 删除健康档案后同步健康指标
|
|||
|
|
async function removeRecordMerageHealthIndicators({
|
|||
|
|
corpId,
|
|||
|
|
memberId,
|
|||
|
|
recordId,
|
|||
|
|
field,
|
|||
|
|
}) {
|
|||
|
|
// 获取到档案中最新一条field的值
|
|||
|
|
const record = await recordDB
|
|||
|
|
.find({ corpId, memberId, [field]: { $exists: true } })
|
|||
|
|
.sort({ createTime: -1 })
|
|||
|
|
.limit(1)
|
|||
|
|
.toArray();
|
|||
|
|
let value = record.length ? record[0][field] : "";
|
|||
|
|
const newRecordId = record.length ? record[0]._id : "";
|
|||
|
|
const params = { type: field, memberId, corpId };
|
|||
|
|
if (typeof value === "string" && !isNaN(value)) value = Number(value);
|
|||
|
|
const count = await db
|
|||
|
|
.collection("corp-health-indicators")
|
|||
|
|
.find({ ...params, recordId })
|
|||
|
|
.count();
|
|||
|
|
if (count > 0) {
|
|||
|
|
await db.collection("corp-health-indicators").updateOne(
|
|||
|
|
{ ...params, recordId },
|
|||
|
|
{
|
|||
|
|
$set: {
|
|||
|
|
value,
|
|||
|
|
updateTime: new Date().getTime(),
|
|||
|
|
recordId: newRecordId,
|
|||
|
|
},
|
|||
|
|
}
|
|||
|
|
);
|
|||
|
|
} else {
|
|||
|
|
await db.collection("corp-health-indicators").insertOne({
|
|||
|
|
_id: common.generateRandomString(24),
|
|||
|
|
...params,
|
|||
|
|
createTime: new Date().getTime(),
|
|||
|
|
value,
|
|||
|
|
recordId: newRecordId,
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
exports.getById = async function (context) {
|
|||
|
|
const { corpId, _id, memberId, medicalType } = context;
|
|||
|
|
if (!_id) {
|
|||
|
|
return { success: false, message: "id不能为空" };
|
|||
|
|
}
|
|||
|
|
if (!medicalType) {
|
|||
|
|
return { success: false, message: "类型不能为空" };
|
|||
|
|
}
|
|||
|
|
if (!memberId) {
|
|||
|
|
return { success: false, message: "客户id不能为空" };
|
|||
|
|
}
|
|||
|
|
if (!corpId) {
|
|||
|
|
return { success: false, message: "机构id不能为空" };
|
|||
|
|
}
|
|||
|
|
try {
|
|||
|
|
const record = await recordDB.findOne({
|
|||
|
|
_id,
|
|||
|
|
corpId,
|
|||
|
|
memberId,
|
|||
|
|
medicalType,
|
|||
|
|
});
|
|||
|
|
if (record) {
|
|||
|
|
return { success: true, message: "查询信息成功", record };
|
|||
|
|
}
|
|||
|
|
return { success: false, message: "未查询到信息" };
|
|||
|
|
} catch (e) {
|
|||
|
|
return { success: false, message: "查询信息失败" };
|
|||
|
|
}
|
|||
|
|
};
|
|||
|
|
|
|||
|
|
exports.getList = async function (context) {
|
|||
|
|
let { memberId, corpId, startTime, endTime, medicalType, dataSource } = context;
|
|||
|
|
if (!memberId) {
|
|||
|
|
return { success: false, message: "客户id不能为空" };
|
|||
|
|
}
|
|||
|
|
if (!corpId) {
|
|||
|
|
return { success: false, message: "机构id不能为空" };
|
|||
|
|
}
|
|||
|
|
// 判断medicalType 是否是字符串
|
|||
|
|
if (typeof medicalType === "string") {
|
|||
|
|
medicalType = [medicalType];
|
|||
|
|
}
|
|||
|
|
try {
|
|||
|
|
const query = { memberId, corpId };
|
|||
|
|
if (dataSource) query.dataSource = dataSource;
|
|||
|
|
if (medicalType) query.medicalType = { $in: medicalType };
|
|||
|
|
const dateFilter = {};
|
|||
|
|
if (startTime) dateFilter.$gte = startTime;
|
|||
|
|
if (endTime) dateFilter.$lte = endTime;
|
|||
|
|
|
|||
|
|
// 如果日期筛选条件不为空，添加到 sortTime 字段
|
|||
|
|
if (Object.keys(dateFilter).length) {
|
|||
|
|
query.sortTime = dateFilter;
|
|||
|
|
}
|
|||
|
|
const list = await recordDB.find(query).sort({ sortTime: -1 }).toArray();
|
|||
|
|
// hisList 根据sortTime排序
|
|||
|
|
list.sort((a, b) => b.sortTime - a.sortTime);
|
|||
|
|
return { success: true, message: "获取客户信息成功", list };
|
|||
|
|
} catch (e) {
|
|||
|
|
return { success: false, message: e.message || "获取客户信息失败" };
|
|||
|
|
}
|
|||
|
|
};
|
|||
|
|
async function mergeMedicalHisRecord(context) {
|
|||
|
|
const { corpId, customerNumber, memberId, recordDates } = context;
|
|||
|
|
let startTime = "",
|
|||
|
|
endTime = "";
|
|||
|
|
if (recordDates && Array.isArray(recordDates)) {
|
|||
|
|
startTime = recordDates[0];
|
|||
|
|
endTime = recordDates[1];
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
if (!customerNumber) {
|
|||
|
|
return { success: false, message: "客户编号不能为空" };
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
try {
|
|||
|
|
// 获取现有的医疗记录，仅查询ID和visitId、hospitalizationId等必要字段
|
|||
|
|
const customerMedicalRecord = await recordDB
|
|||
|
|
.find({ corpId, memberId })
|
|||
|
|
.toArray();
|
|||
|
|
const existingVisitIds = new Set(
|
|||
|
|
customerMedicalRecord.map((item) => item.visitId)
|
|||
|
|
);
|
|||
|
|
const existingHospitalizationIds = new Set(
|
|||
|
|
customerMedicalRecord.map((item) => item.hospitalizationId)
|
|||
|
|
);
|
|||
|
|
|
|||
|
|
let medicalTypes = ["outpatient", "inhospital"];
|
|||
|
|
|
|||
|
|
const tasks = medicalTypes.map(async (medicalType) => {
|
|||
|
|
const query = { corpId, customerNumber, startTime, endTime };
|
|||
|
|
let { list, success } =
|
|||
|
|
medicalType === "outpatient"
|
|||
|
|
? await customerHisSyncAppFunction.getHisOutHospitalRecord(query)
|
|||
|
|
: await customerHisSyncAppFunction.getHisInHospitalRecord(query);
|
|||
|
|
console.log(list);
|
|||
|
|
if (!success || !list) return;
|
|||
|
|
const recordsToAdd = list
|
|||
|
|
.filter((i) => {
|
|||
|
|
i.corp = "本院";
|
|||
|
|
i.corpId = corpId;
|
|||
|
|
i.memberId = memberId;
|
|||
|
|
i.medicalType = medicalType;
|
|||
|
|
if (medicalType === "outpatient") {
|
|||
|
|
i.sortTime = i.visitTime ? dayjs(i.visitTime).valueOf() : "";
|
|||
|
|
return !existingVisitIds.has(i.visitId); // 检查是否已存在
|
|||
|
|
} else if (medicalType === "inhospital") {
|
|||
|
|
i.sortTime = i.inhosDate ? dayjs(i.inhosDate).valueOf() : "";
|
|||
|
|
return !existingHospitalizationIds.has(i.hospitalizationId); // 检查是否已存在
|
|||
|
|
}
|
|||
|
|
return false;
|
|||
|
|
})
|
|||
|
|
.map((i) => {
|
|||
|
|
i.visitTime = i.visitTime ? dayjs(i.visitTime).valueOf() : "";
|
|||
|
|
return i;
|
|||
|
|
});
|
|||
|
|
|
|||
|
|
if (recordsToAdd.length > 0) {
|
|||
|
|
await Promise.all(recordsToAdd.map((record) => exports.add(record)));
|
|||
|
|
}
|
|||
|
|
});
|
|||
|
|
|
|||
|
|
// 执行所有异步任务并等待完成
|
|||
|
|
await Promise.all(tasks);
|
|||
|
|
|
|||
|
|
return { success: true, message: "合并成功" };
|
|||
|
|
} catch (e) {
|
|||
|
|
console.error("mergeMedicalHisRecord error:", e);
|
|||
|
|
return { success: false, message: "合并失败" };
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
exports.update = async function (context) {
|
|||
|
|
const { memberId, corpId, _id, userId, creator, ...rest } = context;
|
|||
|
|
if (!_id) {
|
|||
|
|
return { success: false, message: "id不能为空" };
|
|||
|
|
}
|
|||
|
|
if (!corpId) {
|
|||
|
|
return { success: false, message: "机构id不能为空" };
|
|||
|
|
}
|
|||
|
|
try {
|
|||
|
|
const record = await exports.getById({
|
|||
|
|
corpId,
|
|||
|
|
_id,
|
|||
|
|
memberId,
|
|||
|
|
medicalType: rest.medicalType,
|
|||
|
|
});
|
|||
|
|
if (record.success) {
|
|||
|
|
if (record.record.dataSource !== 'customerReport' && !userId) {
|
|||
|
|
return { success: false, message: "员工id不能为空" };
|
|||
|
|
}
|
|||
|
|
await recordDB.updateOne(
|
|||
|
|
{ _id },
|
|||
|
|
{
|
|||
|
|
$set: {
|
|||
|
|
...rest,
|
|||
|
|
memberId,
|
|||
|
|
corpId,
|
|||
|
|
updateBy: userId,
|
|||
|
|
updateTime: new Date().getTime(),
|
|||
|
|
},
|
|||
|
|
}
|
|||
|
|
);
|
|||
|
|
// 更新健康指标
|
|||
|
|
await healthIndicatorsActtion({
|
|||
|
|
corpId,
|
|||
|
|
memberId,
|
|||
|
|
recordId: _id,
|
|||
|
|
rest,
|
|||
|
|
type: "update",
|
|||
|
|
});
|
|||
|
|
if (rest.medicalType !== "healthRecord") {
|
|||
|
|
await triggerSop({
|
|||
|
|
medicalRecord: rest,
|
|||
|
|
memberId,
|
|||
|
|
corpId,
|
|||
|
|
medicalRecordId: _id,
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
return { success: true, message: "更新成功" };
|
|||
|
|
}
|
|||
|
|
return { success: false, message: record.message };
|
|||
|
|
} catch (e) {
|
|||
|
|
console.log(e);
|
|||
|
|
return { success: false, message: "更新失败" };
|
|||
|
|
}
|
|||
|
|
};
|
|||
|
|
|
|||
|
|
exports.remove = async function (context) {
|
|||
|
|
const { memberId, corpId, _id, medicalType } = context;
|
|||
|
|
if (!_id) {
|
|||
|
|
return { success: false, message: "id不能为空" };
|
|||
|
|
}
|
|||
|
|
if (!corpId) {
|
|||
|
|
return { success: false, message: "机构id不能为空" };
|
|||
|
|
}
|
|||
|
|
if (!memberId) {
|
|||
|
|
return { success: false, message: "客户id不能为空" };
|
|||
|
|
}
|
|||
|
|
if (!medicalType) {
|
|||
|
|
return { success: false, message: "类型不能为空" };
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
try {
|
|||
|
|
const record = await exports.getById({
|
|||
|
|
corpId,
|
|||
|
|
_id,
|
|||
|
|
memberId,
|
|||
|
|
medicalType,
|
|||
|
|
});
|
|||
|
|
if (record.success) {
|
|||
|
|
await recordDB.deleteOne({ _id });
|
|||
|
|
await healthIndicatorsActtion({
|
|||
|
|
corpId,
|
|||
|
|
memberId,
|
|||
|
|
recordId: _id,
|
|||
|
|
rest: record.record,
|
|||
|
|
type: "remove",
|
|||
|
|
});
|
|||
|
|
return { success: true, message: "删除成功" };
|
|||
|
|
}
|
|||
|
|
return { success: false, message: record.message };
|
|||
|
|
} catch (e) {
|
|||
|
|
console.log(e);
|
|||
|
|
return { success: false, message: "删除失败" };
|
|||
|
|
}
|
|||
|
|
};
|
|||
|
|
|
|||
|
|
exports.getArriveTime = async (context) => {
|
|||
|
|
try {
|
|||
|
|
const { corpId, memberId } = context;
|
|||
|
|
if (corpId && memberId) {
|
|||
|
|
const query = await recordDB
|
|||
|
|
.find({ corpId, memberId, corp: { $ne: "其他" } })
|
|||
|
|
.sort({ sortTime: -1 })
|
|||
|
|
.limit(1)
|
|||
|
|
.project({ sortTime: 1, _id: 0 })
|
|||
|
|
.toArray();
|
|||
|
|
const time =
|
|||
|
|
query && query.length && query[0].sortTime > 0 ? query[0].sortTime : 0;
|
|||
|
|
if (time > 0) {
|
|||
|
|
return { success: true, message: "查询到最近到院时间成功", time };
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
return { success: false, message: "未查询到最近到院时间" };
|
|||
|
|
} catch (e) {
|
|||
|
|
return { success: false, message: "查询到最近到院时间失败" };
|
|||
|
|
}
|
|||
|
|
};
|