perf(wai): 读取已存的时间字段 → webhook

dev/supplier-email-drawer
Lei OT 9 months ago
parent 83e4ae8075
commit 50321f6015

@ -158,14 +158,15 @@ const setupMessageHandler = () => {
const targetUpsert = messageData.externalId ? { actionId: messageData.externalId } : { id: savedId };
const savedMsg = await getOutboundMessage(targetUpsert);
const bixFields = pick(savedMsg, ['actionId', 'externalId']);
const savedTimeFields = pick(savedMsg, Object.values(timeField));
logger.info('message evt\n', eventName, messageData, savedMsg);
const _type = messageData?.type || savedMsg?.msgtype || 'text';
const typeField = { msgtype: _type }; // fix: type 空
const webhookBody = webhookBodyBuilder({ ...messageData, ...bixFields, ...typeField }, eventName);
const webhookBody = webhookBodyBuilder({ ...savedTimeFields, ...messageData, ...bixFields, ...typeField }, eventName);
const { waiMessage } = webhookBody;
const timeFields = pick(waiMessage, [...Object.values(timeField), 'createTime', 'updateTime']);
const timeFields = pick(waiMessage, Object.values(timeField));
const upsertFields = pick(waiMessage, ['direction', 'wamid', 'id', 'status']);
upsertFields.evt_id = webhookBody.id;
const pusher = { customerProfile_id: waiMessage.customerProfile?.id || '', customerProfile_name: waiMessage.customerProfile?.name || '' };

Loading…
Cancel
Save