87 lines
2.4 KiB
JavaScript
87 lines
2.4 KiB
JavaScript
|
const dayjs = require("dayjs");
|
||
|
|
const common = require("../../common");
|
||
|
|
let db = null;
|
||
|
|
|
||
|
|
exports.main = async (content, DB) => {
|
||
|
|
db = DB;
|
||
|
|
switch (content.type) {
|
||
|
|
case "updateCustomerInHospitalTime":
|
||
|
|
return await updateCustomerInHospitalTime(content);
|
||
|
|
case "pushCustomerTeamId":
|
||
|
|
return await pushCustomerTeamId(content);
|
||
|
|
case "updateCustomerPersonResponsibles":
|
||
|
|
return await updateCustomerPersonResponsibles(content);
|
||
|
|
}
|
||
|
|
};
|
||
|
|
|
||
|
|
// 更新到院时间
|
||
|
|
async function updateCustomerInHospitalTime(content) {
|
||
|
|
const { corpId, customerId, inHospitalTime } = content;
|
||
|
|
if (!corpId) return { success: false, message: "机构id不能为空" };
|
||
|
|
|
||
|
|
const query = { corpId, _id: customerId };
|
||
|
|
const customer = await db.collection("member").findOne(query);
|
||
|
|
|
||
|
|
if (!customer) return { success: false, message: "客户不存在" };
|
||
|
|
|
||
|
|
let { inHospitalTimes } = customer;
|
||
|
|
if (!inHospitalTimes || !Array.isArray(inHospitalTimes)) inHospitalTimes = [];
|
||
|
|
|
||
|
|
// 判断 inHospitalTimes 存在的时间戳 是否跟 inHospitalTime 是在同一天
|
||
|
|
const inHospitalTimeDay = dayjs(inHospitalTime).format("YYYY-MM-DD");
|
||
|
|
const inHospitalTimesDay = inHospitalTimes.map((time) =>
|
||
|
|
dayjs(time).format("YYYY-MM-DD")
|
||
|
|
);
|
||
|
|
|
||
|
|
if (inHospitalTimesDay.includes(inHospitalTimeDay))
|
||
|
|
return { success: false, message: "该天已存在到院时间" };
|
||
|
|
|
||
|
|
inHospitalTimes.push(inHospitalTime);
|
||
|
|
// 根据大小排序
|
||
|
|
inHospitalTimes.sort((a, b) => a - b);
|
||
|
|
|
||
|
|
const res = await db.collection("member").updateOne(
|
||
|
|
{ _id: customer._id },
|
||
|
|
{ $set: { inHospitalTimes } }
|
||
|
|
);
|
||
|
|
|
||
|
|
return { success: true, data: res, message: "更新到院时间成功" };
|
||
|
|
}
|
||
|
|
|
||
|
|
// 更新客户负责人
|
||
|
|
async function updateCustomerPersonResponsibles(item) {
|
||
|
|
try {
|
||
|
|
const { id, personResponsibles, teamId } = item;
|
||
|
|
const res = await db.collection("member").updateOne(
|
||
|
|
{ _id: id },
|
||
|
|
{ $set: { personResponsibles, teamId } }
|
||
|
|
);
|
||
|
|
|
||
|
|
return {
|
||
|
|
message: "添加成功",
|
||
|
|
success: true,
|
||
|
|
data: res,
|
||
|
|
};
|
||
|
|
} catch {
|
||
|
|
return {
|
||
|
|
message: "添加失败",
|
||
|
|
success: false,
|
||
|
|
};
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
// 添加客户团队
|
||
|
|
async function pushCustomerTeamId(content) {
|
||
|
|
const { customerId, teamId } = content;
|
||
|
|
const res = await db.collection("member").updateOne(
|
||
|
|
{ _id: customerId },
|
||
|
|
{ $addToSet: { teamId } }
|
||
|
|
);
|
||
|
|
|
||
|
|
return {
|
||
|
|
message: "添加成功",
|
||
|
|
success: true,
|
||
|
|
data: res,
|
||
|
|
};
|
||
|
|
}
|