"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
var tslib_1 = require("tslib");
var assert_1 = require("oak-domain/lib/utils/assert");
var oak_external_sdk_1 = require("oak-external-sdk");
var url_1 = require("oak-domain/lib/utils/url");
var uuid_1 = require("oak-domain/lib/utils/uuid");
var sms_1 = require("../utils/sms");
var message_1 = require("./message");
var domain_1 = require("../utils/domain");
function sendNotification(notification, context) {
    return tslib_1.__awaiter(this, void 0, void 0, function () {
        var data, templateId, channel, messageSystemId, data1, id, _a, messageSystem, _b, system, message, _c, router, userId, type, _d, applications, config, _e, app, config_1, _f, appId, appSecret, instance, page, pathname, url, StateDict, _g, _h, _j, err_1, _k, _l, _m, app, _o, config_2, applicationId, _p, appId, appSecret, _q, domain, instance, _r, openId, wechatMpAppId, page, pathname, url, url, _s, _t, _u, err_2, _v, _w, _x, _y, _z, _0, err_3, _1, _2, _3, err2_1, _4, _5, _6;
        var _7, _8, _9, _10, _11, _12, _13;
        return tslib_1.__generator(this, function (_14) {
            switch (_14.label) {
                case 0:
                    data = notification.data, templateId = notification.templateId, channel = notification.channel, messageSystemId = notification.messageSystemId, data1 = notification.data1, id = notification.id;
                    return [4 /*yield*/, context.select('messageSystem', {
                            data: {
                                id: 1,
                                messageId: 1,
                                message: {
                                    id: 1,
                                    userId: 1,
                                    router: 1,
                                    type: 1,
                                },
                                system: {
                                    id: 1,
                                    application$system: {
                                        $entity: 'application',
                                        data: {
                                            id: 1,
                                            type: 1,
                                            config: 1,
                                        },
                                    },
                                }
                            },
                            filter: {
                                id: messageSystemId,
                            }
                        }, { dontCollect: true })];
                case 1:
                    _a = tslib_1.__read.apply(void 0, [_14.sent(), 1]), messageSystem = _a[0];
                    _b = messageSystem, system = _b.system, message = _b.message;
                    _c = message, router = _c.router, userId = _c.userId, type = _c.type;
                    _d = system, applications = _d.application$system, config = _d.config;
                    _e = channel;
                    switch (_e) {
                        case 'wechatMp': return [3 /*break*/, 2];
                        case 'wechatPublic': return [3 /*break*/, 10];
                    }
                    return [3 /*break*/, 19];
                case 2:
                    app = applications.find(function (ele) { return ele.type === 'wechatMp'; });
                    config_1 = app.config;
                    _f = config_1, appId = _f.appId, appSecret = _f.appSecret;
                    instance = oak_external_sdk_1.WechatSDK.getInstance(appId, 'wechatMp', appSecret);
                    page = void 0;
                    if (router) {
                        pathname = router.pathname;
                        url = pathname.startsWith('/')
                            ? "pages".concat(pathname, "/index")
                            : "pages/".concat(pathname, "/index");
                        page = (0, url_1.composeUrl)(url, Object.assign({}, router.props, router.state));
                    }
                    StateDict = {
                        'development': 'developer',
                        'staging': 'trial',
                        'production': 'former',
                    };
                    _14.label = 3;
                case 3:
                    _14.trys.push([3, 7, , 10]);
                    return [4 /*yield*/, instance.sendSubscribedMessage({
                            templateId: templateId,
                            data: data,
                            openId: data1.openId,
                            page: page,
                            state: StateDict[process.env.NODE_ENV],
                        })];
                case 4:
                    _14.sent();
                    _h = (_g = context).operate;
                    _j = ['notification'];
                    _7 = {};
                    return [4 /*yield*/, (0, uuid_1.generateNewIdAsync)()];
                case 5: return [4 /*yield*/, _h.apply(_g, _j.concat([(_7.id = _14.sent(),
                            _7.action = 'succeed',
                            _7.data = {},
                            _7.filter = {
                                id: id,
                            },
                            _7), { dontCollect: true }]))];
                case 6:
                    _14.sent();
                    return [2 /*return*/, 1];
                case 7:
                    err_1 = _14.sent();
                    console.warn('发微信小程序消息失败', err_1);
                    _l = (_k = context).operate;
                    _m = ['notification'];
                    _8 = {};
                    return [4 /*yield*/, (0, uuid_1.generateNewIdAsync)()];
                case 8: return [4 /*yield*/, _l.apply(_k, _m.concat([(_8.id = _14.sent(),
                            _8.action = 'fail',
                            _8.data = {},
                            _8.filter = {
                                id: id,
                            },
                            _8), { dontCollect: true }]))];
                case 9:
                    _14.sent();
                    return [2 /*return*/, 1];
                case 10:
                    app = applications.find(function (ele) { return ele.type === 'wechatPublic'; });
                    _o = app, config_2 = _o.config, applicationId = _o.id;
                    _p = config_2, appId = _p.appId, appSecret = _p.appSecret;
                    return [4 /*yield*/, context.select('domain', {
                            data: {
                                id: 1,
                                url: 1,
                                apiPath: 1,
                                protocol: 1,
                                port: 1,
                            },
                            filter: {
                                system: {
                                    application$system: {
                                        id: applicationId,
                                    },
                                },
                            },
                        }, { dontCollect: true })];
                case 11:
                    _q = tslib_1.__read.apply(void 0, [_14.sent(), 1]), domain = _q[0];
                    instance = oak_external_sdk_1.WechatSDK.getInstance(appId, 'wechatPublic', appSecret);
                    _r = data1, openId = _r.openId, wechatMpAppId = _r.wechatMpAppId;
                    page = void 0;
                    // message 用户不需要跳转页面
                    if (router) {
                        pathname = router.pathname;
                        if (wechatMpAppId) {
                            url = pathname.startsWith('/')
                                ? "pages".concat(pathname, "/index")
                                : "pages/".concat(pathname, "/index");
                            page = (0, url_1.composeUrl)(url, Object.assign({}, router.props, router.state));
                        }
                        else {
                            url = (0, domain_1.composeDomainUrl)(domain, pathname);
                            page = (0, url_1.composeUrl)(url, Object.assign({}, router.props, router.state));
                        }
                    }
                    _14.label = 12;
                case 12:
                    _14.trys.push([12, 16, , 19]);
                    return [4 /*yield*/, instance.sendTemplateMessage({
                            openId: openId,
                            templateId: templateId,
                            url: !wechatMpAppId ? page : undefined,
                            data: data,
                            miniProgram: wechatMpAppId
                                ? {
                                    appid: wechatMpAppId,
                                    pagepath: page,
                                }
                                : undefined,
                            clientMsgId: id,
                        })];
                case 13:
                    _14.sent();
                    _t = (_s = context).operate;
                    _u = ['notification'];
                    _9 = {};
                    return [4 /*yield*/, (0, uuid_1.generateNewIdAsync)()];
                case 14: return [4 /*yield*/, _t.apply(_s, _u.concat([(_9.id = _14.sent(),
                            _9.action = 'succeed',
                            _9.data = {},
                            _9.filter = {
                                id: id,
                            },
                            _9), { dontCollect: true }]))];
                case 15:
                    _14.sent();
                    return [2 /*return*/, 1];
                case 16:
                    err_2 = _14.sent();
                    console.warn('发微信公众号消息失败', err_2);
                    _w = (_v = context).operate;
                    _x = ['notification'];
                    _10 = {};
                    return [4 /*yield*/, (0, uuid_1.generateNewIdAsync)()];
                case 17: return [4 /*yield*/, _w.apply(_v, _x.concat([(_10.id = _14.sent(),
                            _10.action = 'fail',
                            _10.data = {},
                            _10.filter = {
                                id: id,
                            },
                            _10), { dontCollect: true }]))];
                case 18:
                    _14.sent();
                    return [2 /*return*/, 1];
                case 19:
                    (0, assert_1.assert)(channel === 'sms');
                    _14.label = 20;
                case 20:
                    _14.trys.push([20, 24, , 33]);
                    return [4 /*yield*/, (0, sms_1.sendSms)({
                            origin: 'ali',
                            templateName: type,
                            templateParamSet: data.params,
                            mobile: data1.mobile,
                        }, context)];
                case 21:
                    _14.sent();
                    _z = (_y = context).operate;
                    _0 = ['notification'];
                    _11 = {};
                    return [4 /*yield*/, (0, uuid_1.generateNewIdAsync)()];
                case 22: return [4 /*yield*/, _z.apply(_y, _0.concat([(_11.id = _14.sent(),
                            _11.action = 'succeed',
                            _11.data = {},
                            _11.filter = {
                                id: id,
                            },
                            _11), { dontCollect: true }]))];
                case 23:
                    _14.sent();
                    return [2 /*return*/, 1];
                case 24:
                    err_3 = _14.sent();
                    console.warn('发tencent sms消息失败', err_3);
                    _14.label = 25;
                case 25:
                    _14.trys.push([25, 29, , 32]);
                    return [4 /*yield*/, (0, sms_1.sendSms)({
                            origin: 'tencent',
                            templateName: type,
                            templateParamSet: data.paramsArray,
                            mobile: data1.mobile,
                        }, context)];
                case 26:
                    _14.sent();
                    _2 = (_1 = context).operate;
                    _3 = ['notification'];
                    _12 = {};
                    return [4 /*yield*/, (0, uuid_1.generateNewIdAsync)()];
                case 27: return [4 /*yield*/, _2.apply(_1, _3.concat([(_12.id = _14.sent(),
                            _12.action = 'succeed',
                            _12.data = {},
                            _12.filter = {
                                id: id,
                            },
                            _12), { dontCollect: true }]))];
                case 28:
                    _14.sent();
                    return [2 /*return*/, 1];
                case 29:
                    err2_1 = _14.sent();
                    console.warn('发aliyun sms消息失败', err2_1);
                    _5 = (_4 = context).operate;
                    _6 = ['notification'];
                    _13 = {};
                    return [4 /*yield*/, (0, uuid_1.generateNewIdAsync)()];
                case 30: return [4 /*yield*/, _5.apply(_4, _6.concat([(_13.id = _14.sent(),
                            _13.action = 'fail',
                            _13.data = {},
                            _13.filter = {
                                id: id,
                            },
                            _13), { dontCollect: true }]))];
                case 31:
                    _14.sent();
                    return [2 /*return*/, 1];
                case 32: return [3 /*break*/, 33];
                case 33: return [2 /*return*/];
            }
        });
    });
}
function tryCreateSmsNotification(message, context) {
    return tslib_1.__awaiter(this, void 0, void 0, function () {
        var smsNotification, messageSystem$message, _a, _b, ms, id, _c, _d, _e, e_1_1;
        var e_1, _f, _g;
        return tslib_1.__generator(this, function (_h) {
            switch (_h.label) {
                case 0: return [4 /*yield*/, (0, message_1.tryMakeSmsNotification)(message, context)];
                case 1:
                    smsNotification = _h.sent();
                    if (!smsNotification) return [3 /*break*/, 11];
                    messageSystem$message = message.messageSystem$message;
                    _h.label = 2;
                case 2:
                    _h.trys.push([2, 8, 9, 10]);
                    _a = tslib_1.__values(messageSystem$message), _b = _a.next();
                    _h.label = 3;
                case 3:
                    if (!!_b.done) return [3 /*break*/, 7];
                    ms = _b.value;
                    id = ms.id;
                    _d = (_c = context).operate;
                    _e = ['notification'];
                    _g = {};
                    return [4 /*yield*/, (0, uuid_1.generateNewIdAsync)()];
                case 4: return [4 /*yield*/, _d.apply(_c, _e.concat([(_g.id = _h.sent(),
                            _g.action = 'create',
                            _g.data = Object.assign(smsNotification, {
                                messageSystemId: id,
                            }),
                            _g), { dontCollect: true }]))];
                case 5:
                    _h.sent();
                    _h.label = 6;
                case 6:
                    _b = _a.next();
                    return [3 /*break*/, 3];
                case 7: return [3 /*break*/, 10];
                case 8:
                    e_1_1 = _h.sent();
                    e_1 = { error: e_1_1 };
                    return [3 /*break*/, 10];
                case 9:
                    try {
                        if (_b && !_b.done && (_f = _a.return)) _f.call(_a);
                    }
                    finally { if (e_1) throw e_1.error; }
                    return [7 /*endfinally*/];
                case 10: return [2 /*return*/, messageSystem$message.length];
                case 11: return [2 /*return*/, 0];
            }
        });
    });
}
var triggers = [
    {
        name: '当创建notification后，业务提交后再进行推送',
        entity: 'notification',
        action: 'create',
        when: 'commit',
        strict: 'takeEasy',
        fn: function (_a, context) {
            var operation = _a.operation;
            return tslib_1.__awaiter(void 0, void 0, void 0, function () {
                var data, data_1, data_1_1, d, e_2_1;
                var e_2, _b;
                return tslib_1.__generator(this, function (_c) {
                    switch (_c.label) {
                        case 0:
                            data = operation.data;
                            if (!(data instanceof Array)) return [3 /*break*/, 9];
                            _c.label = 1;
                        case 1:
                            _c.trys.push([1, 6, 7, 8]);
                            data_1 = tslib_1.__values(data), data_1_1 = data_1.next();
                            _c.label = 2;
                        case 2:
                            if (!!data_1_1.done) return [3 /*break*/, 5];
                            d = data_1_1.value;
                            return [4 /*yield*/, sendNotification(d, context)];
                        case 3:
                            _c.sent();
                            _c.label = 4;
                        case 4:
                            data_1_1 = data_1.next();
                            return [3 /*break*/, 2];
                        case 5: return [3 /*break*/, 8];
                        case 6:
                            e_2_1 = _c.sent();
                            e_2 = { error: e_2_1 };
                            return [3 /*break*/, 8];
                        case 7:
                            try {
                                if (data_1_1 && !data_1_1.done && (_b = data_1.return)) _b.call(data_1);
                            }
                            finally { if (e_2) throw e_2.error; }
                            return [7 /*endfinally*/];
                        case 8: return [3 /*break*/, 11];
                        case 9: return [4 /*yield*/, sendNotification(data, context)];
                        case 10:
                            _c.sent();
                            _c.label = 11;
                        case 11: return [2 /*return*/, 0];
                    }
                });
            });
        }
    },
    {
        name: '当notification完成时，根据情况去更新message',
        entity: 'notification',
        when: 'after',
        action: ['fail', 'succeed'],
        fn: function (_a, context) {
            var operation = _a.operation;
            return tslib_1.__awaiter(void 0, void 0, void 0, function () {
                var filter, messages, _b, message, success, allFailed, smsTried, _c, _d, ms, _e, _f, n, _g, _h, _j, result, _k, _l, _m;
                var e_3, _o, e_4, _p, _q, _r;
                return tslib_1.__generator(this, function (_s) {
                    switch (_s.label) {
                        case 0:
                            filter = operation.filter;
                            (0, assert_1.assert)(filter.id);
                            return [4 /*yield*/, context.select('message', {
                                    data: {
                                        id: 1,
                                        weight: 1,
                                        iState: 1,
                                        type: 1,
                                        entity: 1,
                                        entityId: 1,
                                        userId: 1,
                                        messageSystem$message: {
                                            $entity: 'messageSystem',
                                            data: {
                                                id: 1,
                                                notification$messageSystem: {
                                                    $entity: 'notification',
                                                    data: {
                                                        id: 1,
                                                        iState: 1,
                                                        channel: 1,
                                                    },
                                                },
                                            },
                                        },
                                    },
                                    filter: {
                                        messageSystem$message: {
                                            notification$messageSystem: {
                                                id: filter.id,
                                            }
                                        },
                                        /* id: {
                                            $in: {
                                                entity: 'messageSystem',
                                                data: {
                                                    messageId: 1,
                                                },
                                                filter: {
                                                    id: {
                                                        $in: {
                                                            entity: 'notification',
                                                            data: {
                                                                messageSystemId: 1,
                                                            },
                                                            filter: {
                                                                id: filter!.id,
                                                            }
                                                        },
                                                    }
                                                }
                                            }
                                        } */
                                    }
                                }, { dontCollect: true })];
                        case 1:
                            messages = _s.sent();
                            (0, assert_1.assert)(messages.length === 1);
                            _b = tslib_1.__read(messages, 1), message = _b[0];
                            if (message.iState === 'success') {
                                return [2 /*return*/, 0];
                            }
                            success = false;
                            allFailed = true;
                            smsTried = false;
                            try {
                                for (_c = tslib_1.__values(message.messageSystem$message), _d = _c.next(); !_d.done; _d = _c.next()) {
                                    ms = _d.value;
                                    try {
                                        for (_e = (e_4 = void 0, tslib_1.__values(ms.notification$messageSystem)), _f = _e.next(); !_f.done; _f = _e.next()) {
                                            n = _f.value;
                                            if (n.iState === 'success') {
                                                success = true;
                                                break;
                                            }
                                            if (n.iState !== 'failure') {
                                                allFailed = false;
                                            }
                                            if (n.channel === 'sms') {
                                                smsTried = true;
                                            }
                                        }
                                    }
                                    catch (e_4_1) { e_4 = { error: e_4_1 }; }
                                    finally {
                                        try {
                                            if (_f && !_f.done && (_p = _e.return)) _p.call(_e);
                                        }
                                        finally { if (e_4) throw e_4.error; }
                                    }
                                    if (success === true) {
                                        break;
                                    }
                                }
                            }
                            catch (e_3_1) { e_3 = { error: e_3_1 }; }
                            finally {
                                try {
                                    if (_d && !_d.done && (_o = _c.return)) _o.call(_c);
                                }
                                finally { if (e_3) throw e_3.error; }
                            }
                            if (!success) return [3 /*break*/, 4];
                            _h = (_g = context).operate;
                            _j = ['message'];
                            _q = {};
                            return [4 /*yield*/, (0, uuid_1.generateNewIdAsync)()];
                        case 2: 
                        // 有一个完成就算完成
                        return [4 /*yield*/, _h.apply(_g, _j.concat([(_q.id = _s.sent(),
                                    _q.action = 'succeed',
                                    _q.data = {},
                                    _q.filter = {
                                        id: message.id,
                                    },
                                    _q), { dontCollect: true }]))];
                        case 3:
                            // 有一个完成就算完成
                            _s.sent();
                            return [2 /*return*/, 1];
                        case 4:
                            if (!(message.weight === 'medium' && !smsTried && allFailed)) return [3 /*break*/, 6];
                            return [4 /*yield*/, tryCreateSmsNotification(message, context)];
                        case 5:
                            result = _s.sent();
                            return [2 /*return*/, result];
                        case 6:
                            if (!allFailed) return [3 /*break*/, 9];
                            _l = (_k = context).operate;
                            _m = ['message'];
                            _r = {};
                            return [4 /*yield*/, (0, uuid_1.generateNewIdAsync)()];
                        case 7: return [4 /*yield*/, _l.apply(_k, _m.concat([(_r.id = _s.sent(),
                                    _r.action = 'fail',
                                    _r.data = {},
                                    _r.filter = {
                                        id: message.id,
                                    },
                                    _r), { dontCollect: true }]))];
                        case 8:
                            _s.sent();
                            return [2 /*return*/, 1];
                        case 9: return [2 /*return*/];
                    }
                });
            });
        }
    }
];
exports.default = triggers;