Nuts_Reg/server.js at master · InCodingNowLiu/Nuts_Reg · 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
const yixin = require('./yixin');
const Common = require('./common');
const mongo = require('./mongo');
// const User = require('./user');
// const User = require('./py');
const User = require('./dg');
mongo.config();
// const response = await yixin.login('111', '1111');


let getNumber = async function () {
    let res = await yixin.getMobileNumber('00833695562c636f5486a42834ae226c313e8d486f01', '25232');
    res = Common.clipResponse(JSON.stringify(res));
    const phoneNumb = res[1];
    return phoneNumb;
}

let getMessage = async (phone) => {
    let res = await yixin.getYanzhengMa('00833695562c636f5486a42834ae226c313e8d486f01', '25232', phone);
    res = Common.clipResponse(JSON.stringify(res));
    return res;
}

let releaseThePhoneNumer = async (phone) => {
    let res = await yixin.freeThePhoneNum('00833695562c636f5486a42834ae226c313e8d486f01', '25232', phone);
    res = Common.clipResponse(JSON.stringify(res));
    return res;
}

let blackListNumber = async (phone) => {
    let res = await yixin.blackList('00833695562c636f5486a42834ae226c313e8d486f01', '25232', phone);
    res = Common.clipResponse(JSON.stringify(res));
    return res;
}

let timeInterArr = [];
const schedFunc = (async () => {
    await setInterval(async () => {
        for (let index = 0; index < timeInterArr.length; index++) {
            const element = timeInterArr[index];
            clearInterval(element);
        }
        timeInterArr = [];
        for (let index = 0; index < 10; index++) {
            const response = await yixin.login('ljq132546', 'qq123123');
            let loginArr = Common.clipResponse(JSON.stringify(response));
            const token = loginArr[1];

            let res;
            //1. 获取电话号码
            const phoneNumber = await getNumber();
            res = await yixin.WebSendSmsCode(phoneNumber);
            console.log('send sms repsonse:', res);
            //2. 获取短信
            let timeInter = await setInterval(async () => {
                const messgaeContent = await getMessage(phoneNumber);
                if (messgaeContent[0] === 'success') {
                    let code = Common.clipSecureCode(messgaeContent[1]);
                    res = await yixin.WebRegister(phoneNumber, code);
                    res = JSON.parse(res);
                    if (res.code === 1) {
                        console.log('register success');
                        //插入数据库
                        let user = {
                            phoneNumber: phoneNumber,
                            password: 'qq123123'
                        }
                        let userSchema = new User(user);
                        let temp = await userSchema.save();
                        console.log('insert mongod:', temp);
                        temp = await blackListNumber(phoneNumber);
                        console.log('黑名单: ', temp);
                        // 3. 释放短线号码
                        // const release = await releaseThePhoneNumer(phoneNumber);
                        // console.log('phone number release:', release);
                    } else if (code === 3001) {
                        let temp = await blackListNumber(phoneNumber);
                        console.log('黑名单3001: ', temp);
                    }
                    clearInterval(timeInter);
                }
            }, 8000)
            timeInterArr.push(timeInter);
        }
    }, 100000)

    // for (let index = 0; index < 10; index++) {
    //     const response = await yixin.login('ljq132546', 'qq123123');
    //     let loginArr = Common.clipResponse(JSON.stringify(response));
    //     const token = loginArr[1];

    //     let res;
    //     //1. 获取电话号码
    //     const phoneNumber = await getNumber();
    //     console.log(phoneNumber);
    //     res = await yixin.WebSendSmsCode(phoneNumber);
    //     console.log('send sms repsonse:', res);
    //     if (res.success) {
    //         console.log(success);
    //     }
    //     //2. 获取短信
    //     let timeIn = await setInterval(async () => {
    //         const messgaeContent = await getMessage(phoneNumber);
    //         if (messgaeContent[0] === 'success') {
    //             let code = Common.clipSecureCode(messgaeContent[1]);
    //             res = await yixin.WebRegister(phoneNumber, code);
    //             console.log('register info: ', res, typeof res);
    //             res = JSON.parse(res);
    //             if (res.code === 1) {
    //                 console.log('register success');
    //                 //插入数据库
    //                 let user = {
    //                     phoneNumber: phoneNumber,
    //                     password: 'qq123123'
    //                 }
    //                 let userSchema = new User(user);
    //                 let temp = await userSchema.save();
    //                 console.log('insert mongod:', temp);
    //                 // 3. 释放短线号码
    //                 const release = await releaseThePhoneNumer(phoneNumber);
    //                 console.log('phone number release:', release);
    //             }
    //             clearInterval(timeIn);
    //         }
    //         console.log(messgaeContent);
    //     }, 10000)
    // }
})()