534 lines
18 KiB
JavaScript
534 lines
18 KiB
JavaScript
|
/**
|
|||
|
|
* 线上购药药品库 online-drug-info
|
|||
|
|
* 与互联网医院药品库（drug-info）字段、功能保持一致，但使用独立的集合
|
|||
|
|
*/
|
|||
|
|
const dayjs = require("dayjs");
|
|||
|
|
const { ObjectId } = require("mongodb");
|
|||
|
|
const { getDrugList } = require("../drug-info/verify");
|
|||
|
|
const validator = require("../../utils/validator");
|
|||
|
|
|
|||
|
|
exports.main = async (item, db) => {
|
|||
|
|
switch (item.type) {
|
|||
|
|
// 供患者/医生侧检索使用的简单查询（已在线使用，保留）
|
|||
|
|
case "getOnlineDrugList":
|
|||
|
|
return await getOnlineDrugList(item, db);
|
|||
|
|
case "getOnlineSimilarDrugInfo":
|
|||
|
|
return await getOnlineSimilarDrugInfo(item, db);
|
|||
|
|
// 供后台管理使用的完整管理接口
|
|||
|
|
case "getOnlineDrugInfo":
|
|||
|
|
return await getOnlineDrugInfo(item, db);
|
|||
|
|
case "addOnlineDrugInfo":
|
|||
|
|
return await addOnlineDrugInfo(item, db);
|
|||
|
|
case "editOnlineDrugInfo":
|
|||
|
|
return await editOnlineDrugInfo(item, db);
|
|||
|
|
case "setOnlineDrugOnSale":
|
|||
|
|
return await setOnlineDrugOnSale(item, db);
|
|||
|
|
case "importOnlineDrugInfo":
|
|||
|
|
return await importOnlineDrugInfo(item, db);
|
|||
|
|
case "checkOnlineDrugInfoStock":
|
|||
|
|
return await checkOnlineDrugInfoStock(item, db);
|
|||
|
|
case "getOnlineDrugRepeatTags":
|
|||
|
|
return await getOnlineDrugRepeatTags(item, db);
|
|||
|
|
default:
|
|||
|
|
return { success: false, message: "未找到接口" };
|
|||
|
|
}
|
|||
|
|
};
|
|||
|
|
|
|||
|
|
// 患者/医生端使用：关键字+在售过滤
|
|||
|
|
async function getOnlineDrugList(ctx, db) {
|
|||
|
|
try {
|
|||
|
|
const page =
|
|||
|
|
Number.isInteger(ctx.page) && ctx.page > 0 ? ctx.page : 1;
|
|||
|
|
const pageSize =
|
|||
|
|
Number.isInteger(ctx.pageSize) && ctx.pageSize > 0
|
|||
|
|
? ctx.pageSize
|
|||
|
|
: 10;
|
|||
|
|
const keyword =
|
|||
|
|
typeof ctx.keyword === "string" ? ctx.keyword.trim() : "";
|
|||
|
|
const query = {};
|
|||
|
|
const onSale = typeof ctx.onSale === "boolean" ? ctx.onSale : true;
|
|||
|
|
query.onSale = onSale;
|
|||
|
|
let fuzzyQuery = null;
|
|||
|
|
if (keyword) {
|
|||
|
|
fuzzyQuery = {
|
|||
|
|
$or: [
|
|||
|
|
{ name: new RegExp(keyword.trim(), "i") },
|
|||
|
|
{ generic_name: new RegExp(keyword.trim(), "i") },
|
|||
|
|
{ barcode: keyword.trim() },
|
|||
|
|
{ pinyin_code: new RegExp(keyword.trim(), "i") },
|
|||
|
|
{ product_id_str: keyword.trim() },
|
|||
|
|
],
|
|||
|
|
};
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
if (Array.isArray(ctx.ids)) {
|
|||
|
|
const ids = ctx.ids
|
|||
|
|
.map((i) =>
|
|||
|
|
typeof i === "string" && i.trim()
|
|||
|
|
? new ObjectId(i.trim())
|
|||
|
|
: null
|
|||
|
|
)
|
|||
|
|
.filter((i) => !!i);
|
|||
|
|
if (ids.length) {
|
|||
|
|
query._id = { $in: ids };
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
const applyQuery = fuzzyQuery ? { $and: [query, fuzzyQuery] } : query;
|
|||
|
|
const [total, list] = await Promise.all([
|
|||
|
|
db.collection("online-drug-info").countDocuments(applyQuery),
|
|||
|
|
db
|
|||
|
|
.collection("online-drug-info")
|
|||
|
|
.find(applyQuery)
|
|||
|
|
.skip((page - 1) * pageSize)
|
|||
|
|
.limit(pageSize)
|
|||
|
|
.toArray(),
|
|||
|
|
]);
|
|||
|
|
return {
|
|||
|
|
success: true,
|
|||
|
|
message: "查询成功",
|
|||
|
|
data: list,
|
|||
|
|
total,
|
|||
|
|
pages: Math.ceil(total / pageSize),
|
|||
|
|
};
|
|||
|
|
} catch (e) {
|
|||
|
|
return { success: false, message: e.message };
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 后台管理：分页查询（字段与 getHlwDrugInfo 一致）
|
|||
|
|
async function getOnlineDrugInfo(ctx, db) {
|
|||
|
|
try {
|
|||
|
|
const page =
|
|||
|
|
Number.isInteger(ctx.page) && ctx.page > 0 ? ctx.page : 1;
|
|||
|
|
const pageSize =
|
|||
|
|
Number.isInteger(ctx.pageSize) && ctx.pageSize > 0
|
|||
|
|
? ctx.pageSize
|
|||
|
|
: 10;
|
|||
|
|
const query = {};
|
|||
|
|
|
|||
|
|
if (typeof ctx.name === "string" && ctx.name.trim()) {
|
|||
|
|
query.name = new RegExp(ctx.name.trim(), "i");
|
|||
|
|
}
|
|||
|
|
if (typeof ctx.onSale === "boolean") {
|
|||
|
|
query.onSale = ctx.onSale;
|
|||
|
|
}
|
|||
|
|
if (typeof ctx.productId === "string" && ctx.productId.trim()) {
|
|||
|
|
query.product_id_str = ctx.productId.trim();
|
|||
|
|
}
|
|||
|
|
if (typeof ctx.barcode === "string" && ctx.barcode.trim()) {
|
|||
|
|
query.barcode = ctx.barcode.trim();
|
|||
|
|
}
|
|||
|
|
if (
|
|||
|
|
typeof ctx.insuranceCode === "string" &&
|
|||
|
|
ctx.insuranceCode.trim()
|
|||
|
|
) {
|
|||
|
|
query.insurance_code = ctx.insuranceCode.trim();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
if (typeof ctx.hisDrugCode === "string" && ctx.hisDrugCode.trim()) {
|
|||
|
|
query.his_drug_code = ctx.hisDrugCode.trim();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
if (typeof ctx.applyPeople === "string" && ctx.applyPeople.trim()) {
|
|||
|
|
query.apply_people = ctx.applyPeople.trim();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
const res = await db
|
|||
|
|
.collection("online-drug-info")
|
|||
|
|
.find(query)
|
|||
|
|
.sort({ onSale: -1, createTime: -1 })
|
|||
|
|
.skip((page - 1) * pageSize)
|
|||
|
|
.limit(pageSize)
|
|||
|
|
.toArray();
|
|||
|
|
const total = await db
|
|||
|
|
.collection("online-drug-info")
|
|||
|
|
.countDocuments(query);
|
|||
|
|
|
|||
|
|
return {
|
|||
|
|
success: true,
|
|||
|
|
message: "查询成功",
|
|||
|
|
data: res,
|
|||
|
|
total,
|
|||
|
|
pages: Math.ceil(total / pageSize),
|
|||
|
|
};
|
|||
|
|
} catch (e) {
|
|||
|
|
return { success: false, message: e.message };
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 新增线上药品
|
|||
|
|
async function addOnlineDrugInfo(ctx, db) {
|
|||
|
|
const { params = {} } = ctx;
|
|||
|
|
if (Object.prototype.toString.call(params) !== "[object Object]") {
|
|||
|
|
return { success: false, message: "参数错误" };
|
|||
|
|
}
|
|||
|
|
try {
|
|||
|
|
const peopleInfo = {
|
|||
|
|
creator: typeof ctx.operator === "string" ? ctx.operator : "",
|
|||
|
|
creatorId:
|
|||
|
|
typeof ctx.operatorId === "string" ? ctx.operatorId : "",
|
|||
|
|
createTime: Date.now(),
|
|||
|
|
};
|
|||
|
|
const { onSale, ...data } = params;
|
|||
|
|
let newDrug = {};
|
|||
|
|
if (Object.keys(data).length) {
|
|||
|
|
if (!data.his_drug_code || !String(data.his_drug_code).trim()) {
|
|||
|
|
return { success: false, message: "ERP编码不能为空" };
|
|||
|
|
}
|
|||
|
|
if (data.his_drug_code) {
|
|||
|
|
const count = await db.collection("online-drug-info").countDocuments({ his_drug_code: data.his_drug_code });
|
|||
|
|
if (count > 0) {
|
|||
|
|
return { success: false, message: "ERP编码已存在" };
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
const [item] = getDrugList([data], true, peopleInfo);
|
|||
|
|
const { msgs, ...drug } = item;
|
|||
|
|
if (msgs.length) {
|
|||
|
|
return { success: false, message: msgs.join(",") };
|
|||
|
|
}
|
|||
|
|
newDrug = { ...drug };
|
|||
|
|
}
|
|||
|
|
if (typeof onSale === "boolean") {
|
|||
|
|
newDrug.onSale = onSale;
|
|||
|
|
}
|
|||
|
|
newDrug.createTime = Date.now();
|
|||
|
|
const res = await db
|
|||
|
|
.collection("online-drug-info")
|
|||
|
|
.insertOne(newDrug);
|
|||
|
|
return {
|
|||
|
|
success: true,
|
|||
|
|
message: "新增药品成功",
|
|||
|
|
id: res.insertedId,
|
|||
|
|
};
|
|||
|
|
} catch (e) {
|
|||
|
|
return {
|
|||
|
|
success: false,
|
|||
|
|
message: e.message || "新增药品失败",
|
|||
|
|
};
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 编辑线上药品
|
|||
|
|
async function editOnlineDrugInfo(ctx, db) {
|
|||
|
|
const { id, params = {} } = ctx;
|
|||
|
|
if (
|
|||
|
|
Object.prototype.toString.call(params) !== "[object Object]" ||
|
|||
|
|
typeof id !== "string"
|
|||
|
|
) {
|
|||
|
|
return { success: false, message: "参数错误" };
|
|||
|
|
}
|
|||
|
|
try {
|
|||
|
|
const { onSale, ...data } = params;
|
|||
|
|
let updateData = {};
|
|||
|
|
if (Object.keys(data).length) {
|
|||
|
|
if ("his_drug_code" in data && !String(data.his_drug_code).trim()) {
|
|||
|
|
return { success: false, message: "ERP编码不能为空" };
|
|||
|
|
}
|
|||
|
|
if (data.his_drug_code) {
|
|||
|
|
const count = await db.collection("online-drug-info").countDocuments({ his_drug_code: data.his_drug_code, _id: { $ne: new ObjectId(id) } });
|
|||
|
|
if (count > 0) {
|
|||
|
|
return { success: false, message: "ERP编码已存在" };
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
const peopleInfo = {
|
|||
|
|
updater: typeof ctx.operator === "string" ? ctx.operator : "",
|
|||
|
|
updaterId:
|
|||
|
|
typeof ctx.operatorId === "string" ? ctx.operatorId : "",
|
|||
|
|
updateTime: Date.now(),
|
|||
|
|
};
|
|||
|
|
const [item] = getDrugList([data], false, peopleInfo);
|
|||
|
|
const { msgs, ...drug } = item;
|
|||
|
|
if (msgs.length) {
|
|||
|
|
return { success: false, message: msgs.join(",") };
|
|||
|
|
}
|
|||
|
|
updateData = { ...drug };
|
|||
|
|
}
|
|||
|
|
if (typeof onSale === "boolean") {
|
|||
|
|
updateData.onSale = onSale;
|
|||
|
|
}
|
|||
|
|
if (Object.keys(updateData).length) {
|
|||
|
|
updateData.updateTime = Date.now();
|
|||
|
|
const res = await db
|
|||
|
|
.collection("online-drug-info")
|
|||
|
|
.updateOne(
|
|||
|
|
{ _id: new ObjectId(id) },
|
|||
|
|
{ $set: updateData }
|
|||
|
|
);
|
|||
|
|
if (res.matchedCount === 0) {
|
|||
|
|
return { success: false, message: "未找到对应药品" };
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
return { success: true, message: "更新成功" };
|
|||
|
|
} catch (e) {
|
|||
|
|
console.log("editOnlineDrugInfo error", e);
|
|||
|
|
return { success: false, message: e.message };
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 批量上/下架
|
|||
|
|
async function setOnlineDrugOnSale(ctx, db) {
|
|||
|
|
const { ids, onSale, updaterId, updater } = ctx;
|
|||
|
|
const _ids = Array.isArray(ids)
|
|||
|
|
? ids
|
|||
|
|
.filter((i) => typeof i === "string" && i.trim())
|
|||
|
|
.map((i) => new ObjectId(i.trim()))
|
|||
|
|
: [ids];
|
|||
|
|
if (
|
|||
|
|
_ids.length === 0 ||
|
|||
|
|
typeof onSale !== "boolean" ||
|
|||
|
|
typeof updaterId !== "string" ||
|
|||
|
|
typeof updater !== "string" ||
|
|||
|
|
!updaterId.trim() ||
|
|||
|
|
!updater.trim()
|
|||
|
|
) {
|
|||
|
|
return { success: false, message: "参数错误" };
|
|||
|
|
}
|
|||
|
|
try {
|
|||
|
|
const res = await db
|
|||
|
|
.collection("online-drug-info")
|
|||
|
|
.updateMany(
|
|||
|
|
{ _id: { $in: _ids } },
|
|||
|
|
{
|
|||
|
|
$set: {
|
|||
|
|
onSale,
|
|||
|
|
updateTime: Date.now(),
|
|||
|
|
updaterId,
|
|||
|
|
updater,
|
|||
|
|
},
|
|||
|
|
}
|
|||
|
|
);
|
|||
|
|
return { success: true, message: "更新成功", res };
|
|||
|
|
} catch (e) {
|
|||
|
|
console.log("setOnlineDrugOnSale error", e);
|
|||
|
|
return { success: false, message: e.message };
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 批量导入（用于程序接口调用，CSV 上传走单独 upload-online-drug-csv）
|
|||
|
|
async function importOnlineDrugInfo(ctx, db) {
|
|||
|
|
const drugs = Array.isArray(ctx.drugs)
|
|||
|
|
? ctx.drugs.filter((i) => typeof i === "object" && i !== null)
|
|||
|
|
: [];
|
|||
|
|
const onSale =
|
|||
|
|
typeof ctx.onSale === "boolean" ? ctx.onSale : true;
|
|||
|
|
if (drugs.length === 0) {
|
|||
|
|
return { success: false, message: "参数错误" };
|
|||
|
|
}
|
|||
|
|
try {
|
|||
|
|
const peopleInfo = {
|
|||
|
|
creator: typeof ctx.operator === "string" ? ctx.operator : "",
|
|||
|
|
creatorId:
|
|||
|
|
typeof ctx.operatorId === "string" ? ctx.operatorId : "",
|
|||
|
|
createTime: Date.now(),
|
|||
|
|
};
|
|||
|
|
const datalist = getDrugList(drugs, true, peopleInfo);
|
|||
|
|
datalist.forEach((i) => {
|
|||
|
|
if (!i.his_drug_code || !String(i.his_drug_code).trim()) {
|
|||
|
|
i.msgs.push("ERP编码不能为空");
|
|||
|
|
}
|
|||
|
|
});
|
|||
|
|
const createTime = dayjs().valueOf();
|
|||
|
|
const list = datalist
|
|||
|
|
.filter((i) => i.msgs.length === 0)
|
|||
|
|
.map((i) => {
|
|||
|
|
const { msgs, ...drug } = i;
|
|||
|
|
drug.createTime = createTime;
|
|||
|
|
drug.onSale = onSale;
|
|||
|
|
return drug;
|
|||
|
|
});
|
|||
|
|
if (!list.length) {
|
|||
|
|
return { success: false, message: "导入失败" };
|
|||
|
|
}
|
|||
|
|
const res = await db
|
|||
|
|
.collection("online-drug-info")
|
|||
|
|
.insertMany(list);
|
|||
|
|
if (res.insertedCount > 0) {
|
|||
|
|
return {
|
|||
|
|
success: true,
|
|||
|
|
message: `成功导入${res.insertedCount}条数据`,
|
|||
|
|
};
|
|||
|
|
}
|
|||
|
|
return { success: false, message: "导入失败" };
|
|||
|
|
} catch (e) {
|
|||
|
|
console.log("importOnlineDrugInfo error", e);
|
|||
|
|
return { success: false, message: e.message };
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
async function getOnlineSimilarDrugInfo(ctx, db) {
|
|||
|
|
try {
|
|||
|
|
const accountId = typeof ctx.accountId === "string" && ctx.accountId.trim() !== "" ? ctx.accountId.trim() : "";
|
|||
|
|
const patientId = typeof ctx.patientId === "string" && ctx.patientId.trim() !== "" ? ctx.patientId.trim() : "";
|
|||
|
|
const patientName = typeof ctx.patientName === "string" && ctx.patientName.trim() !== "" ? ctx.patientName.trim() : "";
|
|||
|
|
const phone = typeof ctx.phone === "string" && ctx.phone.trim() !== "" ? ctx.phone.trim() : "";
|
|||
|
|
const drugs = Array.isArray(ctx.drugs) ? ctx.drugs.filter(i => i && typeof i.insurance_code == 'string' && i.insurance_code.trim() !== "") : [];
|
|||
|
|
const insurance_codes = drugs.map(i => i.insurance_code);
|
|||
|
|
const query = { insurance_code: { $in: insurance_codes }, onSale: true };
|
|||
|
|
const medicines = await db.collection("online-drug-info").find(query).toArray();
|
|||
|
|
const lackMedicines = drugs.filter(i => !medicines.some(med => med.insurance_code === i.insurance_code));
|
|||
|
|
let similarDrugs = [];
|
|||
|
|
if (lackMedicines.length > 0) {
|
|||
|
|
const lackMedicineRegApi = require("../lack-medicine-reg");
|
|||
|
|
// 补全厂商数据：从药品库（包括已下架）中查询完整信息
|
|||
|
|
const lackInsuranceCodes = lackMedicines.map(i => i.insurance_code);
|
|||
|
|
const allDrugsInDb = await db.collection("online-drug-info").find({
|
|||
|
|
insurance_code: { $in: lackInsuranceCodes }
|
|||
|
|
}).toArray();
|
|||
|
|
const lackDrugsWithManufacturer = lackMedicines.map(drug => {
|
|||
|
|
// 尝试从数据库中找到匹配的药品信息
|
|||
|
|
const dbDrug = allDrugsInDb.find(d => d.insurance_code === drug.insurance_code);
|
|||
|
|
return {
|
|||
|
|
...drug,
|
|||
|
|
drugName: drug.drugName || (dbDrug ? dbDrug.name : ''),
|
|||
|
|
spec: drug.spec || (dbDrug ? dbDrug.specification : ''),
|
|||
|
|
manufacturer: drug.manufacturer || (dbDrug ? dbDrug.manufacturer : ''),
|
|||
|
|
insurance_code: drug.insurance_code
|
|||
|
|
};
|
|||
|
|
});
|
|||
|
|
const res = await lackMedicineRegApi({
|
|||
|
|
type: "batchAddLackMedicineReg",
|
|||
|
|
drugs: lackDrugsWithManufacturer,
|
|||
|
|
accountId,
|
|||
|
|
patientId,
|
|||
|
|
patientName,
|
|||
|
|
phone,
|
|||
|
|
inventory: 'online',
|
|||
|
|
regType: 'outOfStock',
|
|||
|
|
corpId: ctx.corpId,
|
|||
|
|
}, db)
|
|||
|
|
const similarQuery = lackMedicines.map(i => ({
|
|||
|
|
$and: [
|
|||
|
|
{ onSale: true, insurance_code: new RegExp(i.insurance_code.slice(0, -5), "i") },
|
|||
|
|
{ insurance_code: { $ne: i.insuranceCode } }
|
|||
|
|
]
|
|||
|
|
}))
|
|||
|
|
similarDrugs = await db.collection("online-drug-info").find({ $or: similarQuery }).toArray();
|
|||
|
|
}
|
|||
|
|
return { success: true, message: "查询成功", drugs: medicines, similarDrugs }
|
|||
|
|
} catch (e) {
|
|||
|
|
return { success: false, message: e.message }
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
async function checkOnlineDrugInfoStock(ctx, db) {
|
|||
|
|
try {
|
|||
|
|
const accountId = typeof ctx.accountId === 'string' ? ctx.accountId.trim() : '';
|
|||
|
|
const patientId = typeof ctx.patientId === 'string' ? ctx.patientId.trim() : '';
|
|||
|
|
const patientName = typeof ctx.patientName === 'string' ? ctx.patientName.trim() : '';
|
|||
|
|
const phone = typeof ctx.phone === 'string' ? ctx.phone.trim() : '';
|
|||
|
|
const drugs = Array.isArray(ctx.drugs) ? ctx.drugs.map(i => ({
|
|||
|
|
insurance_code: i && typeof i.insurance_code === 'string' ? i.insurance_code.trim() : '',
|
|||
|
|
num: i && Number(i.num) > 0 && Number.isInteger(Number(i.num)) ? Number(i.num) : 0,
|
|||
|
|
})) : [];
|
|||
|
|
const areaCode = typeof ctx.areaCode === 'string' ? ctx.areaCode.trim() : '';
|
|||
|
|
|
|||
|
|
if (accountId.length === 0) {
|
|||
|
|
return { success: false, message: "账号id不能为空" }
|
|||
|
|
}
|
|||
|
|
if (accountId.length > 50) {
|
|||
|
|
return { success: false, message: "账号id不能超过50个字" }
|
|||
|
|
}
|
|||
|
|
if (areaCode.length === 0) {
|
|||
|
|
return { success: false, message: "地区编码不能为空" }
|
|||
|
|
}
|
|||
|
|
if (patientId.length > 50) {
|
|||
|
|
return { success: false, message: "患者id不能超过50个字" }
|
|||
|
|
}
|
|||
|
|
if (patientName.length === 0) {
|
|||
|
|
return { success: false, message: "患者姓名不能为空" }
|
|||
|
|
}
|
|||
|
|
if (patientName.length > 30) {
|
|||
|
|
return { success: false, message: "患者姓名不能超过30个字" }
|
|||
|
|
}
|
|||
|
|
// 手机号验证：如果提供了手机号则必须格式正确
|
|||
|
|
if (phone.length > 0 && !validator.isMobile(phone)) {
|
|||
|
|
return { success: false, message: "患者手机号格式不正确" }
|
|||
|
|
}
|
|||
|
|
if (drugs.length === 0 || drugs.length > 5) {
|
|||
|
|
return { success: false, message: "药品数量不能为空且不能超过5个" }
|
|||
|
|
}
|
|||
|
|
if (drugs.some(i => !(i.insurance_code && i.num))) {
|
|||
|
|
return { success: false, message: "药品信息不完整" }
|
|||
|
|
}
|
|||
|
|
const list = await db.collection("online-drug-info").find({ insurance_code: { $in: drugs.map(i => i.insurance_code) } }, { projection: { name: 1, specification: 1, manufacturer: 1, insurance_code: 1 } }).toArray();
|
|||
|
|
const arr = drugs.map(i => {
|
|||
|
|
const drug = list.find(m => m.insurance_code === i.insurance_code);
|
|||
|
|
return { drug, num: i.num, insurance_code: i.insurance_code }
|
|||
|
|
})
|
|||
|
|
const unvalid = arr.find(i => !i.drug);
|
|||
|
|
if (unvalid) {
|
|||
|
|
return { success: false, message: `药品${unvalid.insurance_code}不存在` }
|
|||
|
|
}
|
|||
|
|
const zytHis = require("../zyt-his")
|
|||
|
|
const res = await zytHis({ type: 'getHisDrugInfo', areaCode, insuranceCodes: drugs.map(i => i.insurance_code) });
|
|||
|
|
if (!res || !res.success) {
|
|||
|
|
return { success: false, message: res && res.message ? res.message : '查询his库存信息失败' }
|
|||
|
|
}
|
|||
|
|
const hisDrugs = Array.isArray(res.data) ? res.data : [];
|
|||
|
|
const lackMedicines = [];
|
|||
|
|
const result = [];
|
|||
|
|
arr.forEach(i => {
|
|||
|
|
const hisDrug = hisDrugs.find(m => m.gjbm === i.insurance_code);
|
|||
|
|
const stock = hisDrug && Number(hisDrug.stock_amount) > 0 ? Number(hisDrug.stock_amount) : 0;
|
|||
|
|
const price = hisDrug && Number(hisDrug.pack_retprice) > 0 ? Number(hisDrug.pack_retprice) : undefined;
|
|||
|
|
if (stock < i.num) {
|
|||
|
|
lackMedicines.push({
|
|||
|
|
drugName: i.drug.name,
|
|||
|
|
spec: i.drug.specification,
|
|||
|
|
manufacturer: i.drug.manufacturer,
|
|||
|
|
insuranceCode: i.drug.insurance_code
|
|||
|
|
})
|
|||
|
|
}
|
|||
|
|
result.push({ insuranceCode: i.insurance_code, stock, price })
|
|||
|
|
})
|
|||
|
|
if (lackMedicines.length > 0) {
|
|||
|
|
const lackMedicineRegApi = require("../lack-medicine-reg");
|
|||
|
|
lackMedicineRegApi({
|
|||
|
|
type: "batchAddLackMedicineReg",
|
|||
|
|
drugs: lackMedicines,
|
|||
|
|
accountId,
|
|||
|
|
patientId,
|
|||
|
|
patientName,
|
|||
|
|
phone,
|
|||
|
|
inventory: 'online',
|
|||
|
|
regType: 'lowStock',
|
|||
|
|
corpId: ctx.corpId,
|
|||
|
|
}, db)
|
|||
|
|
}
|
|||
|
|
return { success: true, message: '查询成功', data: result }
|
|||
|
|
} catch (e) {
|
|||
|
|
return { success: false, message: e.message }
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
async function getOnlineDrugRepeatTags(ctx, db) {
|
|||
|
|
try {
|
|||
|
|
const pipeline = [
|
|||
|
|
{
|
|||
|
|
$match: {
|
|||
|
|
repeatTag: {
|
|||
|
|
$type: "array",
|
|||
|
|
$ne: []
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
},
|
|||
|
|
{ $unwind: "$repeatTag" },
|
|||
|
|
{ $match: { repeatTag: { $type: "number", $gt: 0 } } },
|
|||
|
|
{ $group: { _id: "$repeatTag" } },
|
|||
|
|
{ $sort: { _id: 1 } },
|
|||
|
|
{
|
|||
|
|
$group: {
|
|||
|
|
_id: null,
|
|||
|
|
uniqueTags: { $push: "$_id" }
|
|||
|
|
}
|
|||
|
|
},
|
|||
|
|
{ $project: { _id: 0, uniqueTags: 1 } }
|
|||
|
|
];
|
|||
|
|
const result = await db.collection("online-drug-info").aggregate(pipeline).toArray();
|
|||
|
|
const uniqueTags = result.length > 0 ? result[0].uniqueTags : [];
|
|||
|
|
return { success: true, message: '查询成功', data: uniqueTags }
|
|||
|
|
} catch (e) {
|
|||
|
|
return { success: false, message: e.message }
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
}
|