Weibo-PM/core.js at master · EdwonLim/Weibo-PM · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
/**
 * Core
 * @author Edwon Lim
 * @email Edwon.Lim@gmail.com
 */
(function(module) {

    var fs = require('fs'),
        path = require('path');

    var Core = {
        init : function(username, uid, password, appkey, filter) {
            require('./lib/UserInfo').init(username, uid, password, appkey);
            if (filter) {
                require('./lib/network/MessageListener').addFilter(filter);
            }
        },
        configure : function(options, basePath) {
            if (options) {
                var process;
                if (options.floor) {
                    Core.ReplyManager.openFloor(options.floor);
                }
                if (options.forText) {
                    process = Core.ReplyProcess.replyForText;
                    process.init(options.forText);
                    Core.ReplyManager.addProcess(process);
                }
                if (options.forEvent) {
                    process = Core.ReplyProcess.replyForEvent;
                    process.init(options.forEvent);
                    Core.ReplyManager.addProcess(process);
                }
                if (options.customer) {
                    process = new Core.ReplyProcess.CustomerService();
                    process.setTime(options.customer.startTime, options.customer.endTime);
                    process.setKey(options.customer.key);
                    process.setWorkers(options.customer.workers);
                    process.setContent(options.customer.content);
                    Core.ReplyManager.addProcess(process);
                }
                if (options.box) {
                    options.box.forEach(function(e) {
                        process = new Core.ReplyProcess.MailBox(e.name);
                        process.setKey(e.key);
                        process.setContent(e.content);
                        process.setType(e.type, e.data);
                        Core.ReplyManager.addProcess(process);
                    });
                }
                if (options.event) {
                    options.event.forEach(function(e) {
                        switch (e.type) {
                            case 'Lottery' :
                                process = new Core.ReplyProcess.Lottery(e.name);
                                process.setTime(e.startTime, e.endTime);
                                process.setKey(e.key);
                                process.setContent(e.content);
                                e.prize.forEach(function(item){
                                    process.addPrize.apply(process, item);
                                });
                                process.setLogFile(e.log || (basePath + '/' + e.name + '.xlsx'));
                                Core.ReplyManager.addProcess(process);
                                break;
                            case 'SecKill' :
                                process = new Core.ReplyProcess.SecKill(e.name);
                                process.setTime(e.startTime, e.endTime);
                                process.setKey(e.key);
                                process.setContent(e.content);
                                process.setPrize(e.prize.name, e.prize.num);
                                process.setLogFile(e.log || (basePath + '/' + e.name + '.xlsx'));
                                Core.ReplyManager.addProcess(process);
                                break;
                            case 'RepostDiscount' :
                                process = new Core.ReplyProcess.RepostDiscount(e.name);
                                process.setKey(e.key);
                                process.setNum(e.num);
                                process.setConf(e.startTime, e.endTime, e.status);
                                process.setContent(e.content);
                                process.setLogFile(e.log || (basePath + '/' + e.name + '.xlsx'));
                                Core.ReplyManager.addProcess(process);
                                break;
                       }
                    });
                }
            }
            Core.Util.FileDataBase.init(basePath);
            Core.ReplyManager.start();
            Core.MentionManager.start();
        },
        listener : require('./lib/network/MessageListener'),
        send : require('./lib/network/MessageSend'),
        reply : require('./lib/network/MessageReply'),
        reset : function() {
            Core.ReplyManager.reset();
            Core.MentionManager.reset();
        },

        User : require('./lib/UserInfo'),
        Message : require('./lib/model/Message'),
        ReplyManager : require('./lib/manager/ReplyManager'),
        MentionManager : require('./lib/manager/MentionManager'),

        WeChat : {
            Process : require('./lib/wechat/Process'),
            Server : require('./lib/wechat/Server')
        },
        ReplyProcess : {
            replyForText : require('./lib/process/ReplyForText'),
            replyForEvent : require('./lib/process/ReplyForEvent'),
            Lottery : require('./lib/process/Lottery'),
            SecKill : require('./lib/process/SecKill'),
            RepostDiscount : require('./lib/process/RepostDiscount'),
            CustomerService : require('./lib/process/CustomerService'),
            MailBox : require('./lib/process/MailBox')
        },

        Util : {
            OpenAPI : require('./lib/network/OpenAPI'),
            Status : require('./lib/network/Status'),
            Upload : require('./lib/network/Upload'),
            FileDataBase : require('./lib/util/FileDataBase'),
            Base62 : require('./lib/util/Base62'),
            Debug : require('./lib/util/Debug')
        }

    };

    module.exports = Core;

})(module);