oak-general-business/es/aspects/wechatPublicTag.js

import WechatSDK from "oak-external-sdk/lib/WechatSDK";
import { assert } from "oak-domain/lib/utils/assert";
import { OakPreConditionUnsetException } from "oak-domain/lib/types";
import { generateNewIdAsync } from "oak-domain/lib/utils/uuid";
import { handleException } from "../utils/wechatPublicException";
async function getWechatPublicConfig(applicationId, context) {
    const [application] = await context.select("application", {
        data: {
            id: 1,
            config: 1,
            type: 1,
        },
        filter: {
            id: applicationId,
        },
    }, {
        dontCollect: true,
    });
    return application;
}
async function getWechatPublicTags(applicationId, context) {
    const wechatPublicTags = await context.select("wechatPublicTag", {
        data: {
            id: 1,
            wechatId: 1,
            applicationId: 1,
        },
        filter: {
            applicationId,
        },
    }, {
        dontCollect: true,
    });
    return wechatPublicTags;
}
async function getWechatPublicTagById(applicationId, id, context) {
    const [wechatPublicTag] = await context.select("wechatPublicTag", {
        data: {
            id: 1,
            wechatId: 1,
            text: 1,
            applicationId: 1,
        },
        filter: {
            id,
            applicationId,
        },
    }, {
        dontCollect: true,
    });
    return wechatPublicTag;
}
export async function createTag(params, context) {
    const application = await getWechatPublicConfig(params.applicationId, context);
    assert(application);
    const { type, config, systemId } = application;
    assert(type === "wechatPublic");
    let appId, appSecret;
    const config2 = config;
    appId = config2.appId;
    appSecret = config2.appSecret;
    const wechatInstance = WechatSDK.getInstance(appId, type, appSecret);
    const result = await wechatInstance.createTag({ name: params.name });
    return result;
}
export async function getTags(params, context) {
    const application = await getWechatPublicConfig(params.applicationId, context);
    assert(application);
    const { type, config, systemId } = application;
    assert(type === "wechatPublic");
    let appId, appSecret;
    const config2 = config;
    appId = config2.appId;
    appSecret = config2.appSecret;
    const wechatInstance = WechatSDK.getInstance(appId, type, appSecret);
    const result = await wechatInstance.getTags();
    return result;
}
export async function editTag(params, context) {
    const application = await getWechatPublicConfig(params.applicationId, context);
    assert(application);
    const { type, config, systemId } = application;
    assert(type === "wechatPublic");
    let appId, appSecret;
    const config2 = config;
    appId = config2.appId;
    appSecret = config2.appSecret;
    const wechatInstance = WechatSDK.getInstance(appId, type, appSecret);
    const result = await wechatInstance.editTag({
        id: params.id,
        name: params.name,
    });
    return result;
}
export async function deleteTag(params, context) {
    const application = await getWechatPublicConfig(params.applicationId, context);
    assert(application);
    const { type, config, systemId } = application;
    assert(type === "wechatPublic");
    let appId, appSecret;
    const config2 = config;
    appId = config2.appId;
    appSecret = config2.appSecret;
    const wechatInstance = WechatSDK.getInstance(appId, type, appSecret);
    const result = await wechatInstance.deleteTag({ id: params.wechatId });
    return result;
}
export async function syncTag(params, context) {
    const application = await getWechatPublicConfig(params.applicationId, context);
    assert(application);
    const { type, config, systemId } = application;
    assert(type === "wechatPublic");
    const wechatPublicTag = await getWechatPublicTagById(params.applicationId, params.id, context);
    assert(wechatPublicTag);
    try {
        const { tags } = await getTags({
            applicationId: params.applicationId,
        }, context);
        if (!wechatPublicTag.wechatId) {
            const result = await createTag({
                applicationId: params.applicationId,
                name: wechatPublicTag.text,
            }, context);
            await context.operate("wechatPublicTag", {
                id: await generateNewIdAsync(),
                action: "update",
                data: {
                    syncAt: Date.now(),
                    sync: true,
                    iState: "success",
                    wechatId: result.tag.id,
                },
                filter: {
                    id: params.id,
                },
            }, {});
        }
        if (wechatPublicTag.wechatId &&
            tags.find((ele) => ele.id === wechatPublicTag.wechatId &&
                ele.name !== wechatPublicTag.text)) {
            const result = await editTag({
                applicationId: params.applicationId,
                id: wechatPublicTag.wechatId,
                name: wechatPublicTag.text,
            }, context);
            await context.operate("wechatPublicTag", {
                id: await generateNewIdAsync(),
                action: "update",
                data: {
                    syncAt: Date.now(),
                    sync: true,
                    iState: "success",
                },
                filter: {
                    id: params.id,
                },
            }, {});
        }
        if (wechatPublicTag.wechatId &&
            tags.find((ele) => ele.id === wechatPublicTag.wechatId &&
                ele.name === wechatPublicTag.text)) {
            const result = await deleteTag({
                applicationId: params.applicationId,
                id: wechatPublicTag.id,
                wechatId: wechatPublicTag.wechatId,
            }, context);
            await context.operate("wechatPublicTag", {
                id: await generateNewIdAsync(),
                action: "remove",
                data: {},
                filter: {
                    id: params.id,
                },
            }, {});
        }
    }
    catch (e) {
        await context.operate("wechatPublicTag", {
            id: await generateNewIdAsync(),
            action: "update",
            data: {
                sync: false,
                iState: "fail",
            },
            filter: {
                id: params.id,
            },
        }, {});
        throw new OakPreConditionUnsetException(`${handleException(e)}`);
    }
}
export async function oneKeySync(params, context) {
    const application = await getWechatPublicConfig(params.applicationId, context);
    assert(application);
    const { type, config, systemId } = application;
    assert(type === "wechatPublic");
    const wechatPublicTags = await getWechatPublicTags(params.applicationId, context);
    try {
        const tags = await getTags(params, context);
        if (wechatPublicTags && wechatPublicTags.length > 0) {
            const tagsToAdd = tags.tags?.filter((ele) => {
                return !wechatPublicTags.some((item) => item?.wechatId === ele.id);
            });
            const tagsToRemove = tags.tags?.length
                ? wechatPublicTags.filter((ele) => {
                    return !tags.tags?.some((item) => item.id === ele?.wechatId);
                })
                : wechatPublicTags;
            for (const ele of tagsToAdd || []) {
                await context.operate("wechatPublicTag", {
                    id: await generateNewIdAsync(),
                    action: "create",
                    data: {
                        id: await generateNewIdAsync(),
                        applicationId: params.applicationId,
                        wechatId: ele.id,
                        text: ele.name,
                        sync: true,
                        syncAt: Date.now(),
                        iState: "success",
                    },
                }, {});
            }
            // Remove tags
            for (const ele of tagsToRemove || []) {
                await context.operate("wechatPublicTag", {
                    id: await generateNewIdAsync(),
                    action: "remove",
                    data: {},
                    filter: {
                        id: ele.id,
                    },
                }, {});
            }
            // Update tags
            for (const ele of wechatPublicTags || []) {
                await context.operate("wechatPublicTag", {
                    id: await generateNewIdAsync(),
                    action: "update",
                    data: {
                        syncAt: Date.now(),
                        sync: true,
                        iState: "success",
                    },
                    filter: {
                        id: ele.id,
                    },
                }, {});
            }
        }
        else {
            for (const ele of tags.tags || []) {
                await context.operate("wechatPublicTag", {
                    id: await generateNewIdAsync(),
                    action: "create",
                    data: {
                        id: await generateNewIdAsync(),
                        applicationId: params.applicationId,
                        wechatId: ele.id,
                        text: ele.name,
                        sync: true,
                        syncAt: Date.now(),
                        iState: "success",
                    },
                }, {});
            }
        }
    }
    catch (e) {
        throw new OakPreConditionUnsetException(`${handleException(e)}`);
    }
}