204 lines
8.0 KiB
JavaScript
204 lines
8.0 KiB
JavaScript
"use strict";
|
||
Object.defineProperty(exports, "__esModule", { value: true });
|
||
const uuid_1 = require("oak-domain/lib/utils/uuid");
|
||
const wechatPublicTag_1 = require("../aspects/wechatPublicTag");
|
||
const types_1 = require("oak-domain/lib/types");
|
||
const wechatPublicException_1 = require("../utils/wechatPublicException");
|
||
const triggers = [
|
||
// {
|
||
// name: '当wechatPublicTag更新后，执行sync',
|
||
// entity: 'wechatPublicTag',
|
||
// action: 'update',
|
||
// when: 'after',
|
||
// fn: async ({ operation }, context) => {
|
||
// const { data, filter } = operation;
|
||
// const [wechatPublicTag] = await context.select(
|
||
// 'wechatPublicTag',
|
||
// {
|
||
// data: {
|
||
// id: 1,
|
||
// sync: 1,
|
||
// },
|
||
// filter,
|
||
// },
|
||
// {}
|
||
// );
|
||
// await context.operate(
|
||
// 'wechatPublicTag',
|
||
// {
|
||
// id: await generateNewIdAsync(),
|
||
// action: 'sync',
|
||
// data: {
|
||
// },
|
||
// filter: {
|
||
// id: wechatPublicTag.id
|
||
// },
|
||
// },
|
||
// {}
|
||
// );
|
||
// return 1;
|
||
// },
|
||
// },
|
||
// {
|
||
// name: '当wechatPublicTag创建后，执行sync',
|
||
// entity: 'wechatPublicTag',
|
||
// action: 'create',
|
||
// when: 'after',
|
||
// fn: async ({ operation }, context, params) => {
|
||
// const { data, filter } = operation;
|
||
// const [wechatPublicTag] = await context.select(
|
||
// 'wechatPublicTag',
|
||
// {
|
||
// data: {
|
||
// id: 1,
|
||
// },
|
||
// filter,
|
||
// },
|
||
// {}
|
||
// );
|
||
// await context.operate(
|
||
// 'wechatPublicTag',
|
||
// {
|
||
// id: await generateNewIdAsync(),
|
||
// action: 'sync',
|
||
// data: {
|
||
// },
|
||
// filter: {
|
||
// id: wechatPublicTag.id
|
||
// },
|
||
// },
|
||
// {}
|
||
// );
|
||
// return 1;
|
||
// },
|
||
// } as CreateTrigger<EntityDict, 'wechatPublicTag', RuntimeCxt>,
|
||
{
|
||
name: '在删除微信公众号标签前，调用微信删除接口同时删除关联的userWechatPublic和wechatMenu',
|
||
entity: 'wechatPublicTag',
|
||
action: 'remove',
|
||
when: 'before',
|
||
fn: async (event, context) => {
|
||
const { operation: { data, filter }, } = event;
|
||
const [wechatPublicTag] = await context.select('wechatPublicTag', {
|
||
data: {
|
||
id: 1,
|
||
wechatId: 1,
|
||
applicationId: 1,
|
||
},
|
||
filter,
|
||
}, {});
|
||
try {
|
||
const result = await (0, wechatPublicTag_1.deleteTag)({
|
||
applicationId: wechatPublicTag.applicationId,
|
||
id: wechatPublicTag.id,
|
||
wechatId: wechatPublicTag.wechatId,
|
||
}, context);
|
||
await context.operate('userWechatPublicTag', {
|
||
id: await (0, uuid_1.generateNewIdAsync)(),
|
||
action: 'remove',
|
||
data: {},
|
||
filter: {
|
||
wechatPublicTagId: filter.id,
|
||
},
|
||
}, {});
|
||
await context.operate('userWechatPublicTag', {
|
||
id: await (0, uuid_1.generateNewIdAsync)(),
|
||
action: 'remove',
|
||
data: {},
|
||
filter: {
|
||
wechatPublicTagId: filter.id,
|
||
},
|
||
}, {});
|
||
}
|
||
catch (e) {
|
||
throw new types_1.OakPreConditionUnsetException(`${(0, wechatPublicException_1.handleException)(e)}`);
|
||
}
|
||
return 1;
|
||
},
|
||
},
|
||
// {
|
||
// name: '当标签发布前，同步',
|
||
// entity: 'wechatPublicTag',
|
||
// action: 'sync',
|
||
// when: 'before',
|
||
// fn: async ({ operation }, context) => {
|
||
// const { data, filter } = operation;
|
||
// const [wechatPublicTag] = await context.select(
|
||
// 'wechatPublicTag',
|
||
// {
|
||
// data: {
|
||
// id: 1,
|
||
// sync: 1,
|
||
// syncAt: 1,
|
||
// wechatId: 1,
|
||
// applicationId: 1,
|
||
// text: 1,
|
||
// },
|
||
// filter,
|
||
// },
|
||
// {}
|
||
// );
|
||
// assert(wechatPublicTag);
|
||
// try {
|
||
// const { tags } = await getTags({
|
||
// applicationId: wechatPublicTag.applicationId!
|
||
// }, context);
|
||
// if(!wechatPublicTag.wechatId) {
|
||
// try {
|
||
// const result = await createTag({
|
||
// applicationId: wechatPublicTag.applicationId!,
|
||
// name: wechatPublicTag.text!,
|
||
// }, context);
|
||
// data.sync = true;
|
||
// data.syncAt = Date.now();
|
||
// data.wechatId = result.tag.id;
|
||
// data.iState = 'success';
|
||
// } catch(e) {
|
||
// data.sync = false;
|
||
// data.iState = 'fail';
|
||
// // throw new OakPreConditionUnsetException(`${handleException(e as string)}`);
|
||
// }
|
||
// }
|
||
// if(wechatPublicTag.wechatId && tags.find((ele: Tag) => ele.id === wechatPublicTag.wechatId && ele.name !== wechatPublicTag.text)) {
|
||
// try {
|
||
// const result = await editTag({
|
||
// applicationId: wechatPublicTag.applicationId!,
|
||
// id: wechatPublicTag.wechatId!,
|
||
// name: wechatPublicTag.text!,
|
||
// }, context);
|
||
// data.sync = true;
|
||
// data.syncAt = Date.now();
|
||
// data.iState = 'success';
|
||
// } catch(e) {
|
||
// data.sync = false;
|
||
// data.syncAt = Date.now();
|
||
// data.iState = 'fail';
|
||
// // throw new OakPreConditionUnsetException(`${handleException(e as string)}`);
|
||
// }
|
||
// }
|
||
// if(wechatPublicTag.wechatId && tags.find((ele: Tag) => ele.id === wechatPublicTag.wechatId && ele.name === wechatPublicTag.text)) {
|
||
// try {
|
||
// const result = await deleteTag({
|
||
// applicationId: wechatPublicTag.applicationId!,
|
||
// id: wechatPublicTag.id!,
|
||
// wechatId: wechatPublicTag.wechatId!,
|
||
// }, context);
|
||
// data.sync = true;
|
||
// data.syncAt = Date.now();
|
||
// data.iState = 'success';
|
||
// } catch(e) {
|
||
// data.sync = false;
|
||
// data.syncAt = Date.now();
|
||
// data.iState = 'fail';
|
||
// // throw new OakPreConditionUnsetException(`${handleException(e as string)}`);
|
||
// }
|
||
// }
|
||
// } catch (e) {
|
||
// throw new OakPreConditionUnsetException(`${handleException(e as string)}`);
|
||
// }
|
||
// return 1;
|
||
// },
|
||
// },
|
||
];
|
||
exports.default = triggers;
|