104 lines
3.7 KiB
JavaScript
104 lines
3.7 KiB
JavaScript
|
const { getDatabase } = require("../../mongodb");
|
|||
|
|
const tencentIM = require("../tencent-im");
|
|||
|
|
/**
|
|||
|
|
*
|
|||
|
|
* orderStatus completed(已完成) processing(处理中) pending(待处理) cancelled(已取消) finished(已结束)
|
|||
|
|
* syncOtherMachine 若不希望将消息同步至 From_Account，则 SyncOtherMachine 填写2；若希望将消息同步至 From_Account，则 SyncOtherMachine 填写1。
|
|||
|
|
* MsgType TIMTextElem（文本消息） TIMLocationElem（位置消息） TIMFaceElem（表情消息） TIMCustomElem（自定义消息） TIMSoundElem（语音消息） TIMImageElem（图像消息） TIMFileElem（文件消息） TIMVideoFileElem（视频消息）
|
|||
|
|
* MsgContent.Text 文本消息内容
|
|||
|
|
* MsgContent.Data 自定义消息类型 SUBMITMEDICALADVICE(提交医嘱) FINISHED(问诊结束) COMPLETED(问诊完成) CANCELLED(问诊取消) STARTCONSULT(开始问诊) ACCEPTCONSULT(接诊)
|
|||
|
|
* MsgContent.Desc notification
|
|||
|
|
*
|
|||
|
|
*/
|
|||
|
|
const handEvent = {
|
|||
|
|
finished: "FINISHED", // 问诊结束
|
|||
|
|
completed: "COMPLETED", // 问诊完成
|
|||
|
|
cancelled: "CANCELLED", // 问诊取消
|
|||
|
|
startConsult: "STARTCONSULT", // 开始问诊
|
|||
|
|
acceptConsult: "ACCEPTCONSULT", // 接诊
|
|||
|
|
submitMedicalAdvice: "SUBMITMEDICALADVICE", // 提交医嘱
|
|||
|
|
};
|
|||
|
|
exports.updateOrderStatusAndSendNotification = async (item) => {
|
|||
|
|
const { orderId, doctorCode, corpId, msgType, expireTime } = item;
|
|||
|
|
const db = await getDatabase("Internet-hospital");
|
|||
|
|
let orderStatus = "";
|
|||
|
|
let notification = "";
|
|||
|
|
let syncOtherMachine = 2;
|
|||
|
|
let formAccount = "";
|
|||
|
|
let toAccount = "";
|
|||
|
|
switch (msgType) {
|
|||
|
|
case "submitMedicalAdvice":
|
|||
|
|
// 提交医嘱 更新问诊状态为已完成 completed 并向医生发送一条系统消息
|
|||
|
|
orderStatus = "completed";
|
|||
|
|
formAccount = orderId;
|
|||
|
|
toAccount = doctorCode;
|
|||
|
|
notification = "";
|
|||
|
|
break;
|
|||
|
|
case "FINISHED":
|
|||
|
|
// 问诊结束 更新问诊状态为已结束 finished 并向医生和患者同时发送一条系统消息
|
|||
|
|
orderStatus = "finished";
|
|||
|
|
formAccount = orderId;
|
|||
|
|
toAccount = doctorCode;
|
|||
|
|
syncOtherMachine = 1;
|
|||
|
|
notification = "";
|
|||
|
|
break;
|
|||
|
|
case "COMPLETED":
|
|||
|
|
// 问诊完成 更新问诊状态为已完成 completed 并向医生发送一条系统消息, 医嘱已提交
|
|||
|
|
orderStatus = "completed";
|
|||
|
|
formAccount = orderId;
|
|||
|
|
toAccount = doctorCode;
|
|||
|
|
notification = "";
|
|||
|
|
break;
|
|||
|
|
case "CANCELLED":
|
|||
|
|
// 问诊取消 一般为超时未处理, 更新问诊状态为已取消 cancelled 并向患者发送一条系统消息
|
|||
|
|
orderStatus = "cancelled";
|
|||
|
|
formAccount = doctorCode;
|
|||
|
|
toAccount = orderId;
|
|||
|
|
syncOtherMachine = 1;
|
|||
|
|
notification = "";
|
|||
|
|
break;
|
|||
|
|
case "ACCEPTCONSULT":
|
|||
|
|
// 接诊 更新问诊状态为处理中 processing 并向患者发送一条系统消息
|
|||
|
|
orderStatus = "processing";
|
|||
|
|
formAccount = doctorCode;
|
|||
|
|
toAccount = orderId;
|
|||
|
|
syncOtherMachine = 2;
|
|||
|
|
notification = "医生已接受您的问诊请求";
|
|||
|
|
break;
|
|||
|
|
default:
|
|||
|
|
break;
|
|||
|
|
}
|
|||
|
|
let query = {
|
|||
|
|
orderStatus,
|
|||
|
|
updateTime: Date.now(),
|
|||
|
|
};
|
|||
|
|
if (expireTime) query.expireTime = expireTime;
|
|||
|
|
// 当医生开始处理, 开始加过期时间, 过期时间为30分钟
|
|||
|
|
await db.collection("consult-order").updateOne(
|
|||
|
|
{ orderId },
|
|||
|
|
{
|
|||
|
|
$set: {
|
|||
|
|
orderStatus,
|
|||
|
|
updateTime: Date.now(),
|
|||
|
|
},
|
|||
|
|
}
|
|||
|
|
);
|
|||
|
|
await tencentIM({
|
|||
|
|
type: "sendSystemNotification",
|
|||
|
|
corpId,
|
|||
|
|
formAccount,
|
|||
|
|
toAccount,
|
|||
|
|
SyncOtherMachine: syncOtherMachine,
|
|||
|
|
msgBody: [
|
|||
|
|
{
|
|||
|
|
MsgType: "TIMCustomElem",
|
|||
|
|
MsgContent: {
|
|||
|
|
Data: msgType, //medical advice
|
|||
|
|
Desc: "notification",
|
|||
|
|
Ext: notification,
|
|||
|
|
},
|
|||
|
|
},
|
|||
|
|
],
|
|||
|
|
});
|
|||
|
|
};
|