比較提交

..

沒有共同的提交。「9567fbb889cfa13baa1207bf3116e2d4d00931e9」和「a0ef04285e0840075a2f6be354a05443f8f32ea0」的歷史完全不同。

共有 8 個檔案被更改,包括 7 行新增101 行删除

1
.gitignore vendored
查看文件

@ -4,4 +4,3 @@ node_modules/*
/pnpm-lock.yaml /pnpm-lock.yaml
/arr.json /arr.json
backup backup
resetCookieRequest.txt

查看文件

@ -5,9 +5,7 @@
"main": "index.js", "main": "index.js",
"scripts": { "scripts": {
"test": "ts-node src/test.ts", "test": "ts-node src/test.ts",
"start": "ts-node src/index.ts", "start": "ts-node src/index.ts"
"draw": "ts-node src/draw.ts",
"resetCookie": "ts-node src/resetCookieRequest.ts"
}, },
"author": "", "author": "",
"license": "ISC", "license": "ISC",

查看文件

@ -1,46 +0,0 @@
import {countStr, getTimeNow, logAndNotifyUser, resetCookie, sduAxios, sleep} from "./includes"
import * as fs from "fs"
export async function draw() {
while (true) {
let html = ''
try {
let resp = await sduAxios.get("jsxsd/xsxkjg/comeXkjglb?isktx=true")
html = JSON.stringify(resp.data)
} catch (e) {
console.log(e)
}
if (countStr(html, 'cqOper') < 2) {
logAndNotifyUser('登录失败,重设cookie ' + getTimeNow())
try {
await resetCookie()
} catch (e) {
console.log(e)
}
continue
}
if (countStr(html, 'cqOper') > 2) {
logAndNotifyUser('可以抽签,正在进行抽签')
fs.writeFileSync('draw-' + Date.now() + '.html', html)
let arr = [
'2021202222605',// 英语
'2021202225984',// 周易
'2021202225817',// 刻瓷
'2021202222614',// 众智
'2021202222613',// 移动互联网
]
for (let id of arr) {
try {
let resp = await sduAxios.get('/jsxsd/xsxkjg/xscqOper?jx0404id=' + id + '&cqqk=3')// 3抽的中,2抽不中
logAndNotifyUser(JSON.stringify(resp.data))
} catch (e) {
console.log(e)
}
}
}
console.log('轮询中:' + getTimeNow())
await sleep(1000)
}
}
draw()

查看文件

@ -43,14 +43,10 @@ export async function logAndNotifyUser(text: string) {
// 'Content-Type': 'application/x-www-form-urlencoded' // 'Content-Type': 'application/x-www-form-urlencoded'
// } // }
// }) // })
try { await axios.post('https://' + appConfig.tgApiDomain + '/bot' + appConfig.tgApiKey + '/sendMessage', qs.stringify({
await axios.post('https://' + appConfig.tgApiDomain + '/bot' + appConfig.tgApiKey + '/sendMessage', qs.stringify({ chat_id: appConfig.tgChatId,
chat_id: appConfig.tgChatId, text: text
text: text }))
}))
} catch (e) {
console.log(e)
}
} }
export function sleep(ms: number) { export function sleep(ms: number) {

查看文件

@ -3,10 +3,8 @@ import {appConfig} from "./config"
import {acquireProcess, monitProcess, replaceProcess} from "./actions" import {acquireProcess, monitProcess, replaceProcess} from "./actions"
import {resetCookie, sleep} from "./includes" import {resetCookie, sleep} from "./includes"
import {health} from "./health" import {health} from "./health"
import * as fs from "fs"
async function start() { async function start() {
fs.writeFileSync('resetCookieRequest.txt','0')
console.log('开始获取Cookie') console.log('开始获取Cookie')
await resetCookie() await resetCookie()
console.log('开始启动轮询进程') console.log('开始启动轮询进程')

查看文件

@ -2,7 +2,6 @@ import {IJsonCourse} from "./types"
import {getTimeNow, logAndNotifyUser, resetCookie, sduAxios, sleep} from "./includes" import {getTimeNow, logAndNotifyUser, resetCookie, sduAxios, sleep} from "./includes"
import {appConfig} from "./config" import {appConfig} from "./config"
import * as qs from "qs" import * as qs from "qs"
import * as fs from "fs"
export let reqBody = 'sEcho=1&iColumns=15&sColumns=&iDisplayStart=0&iDisplayLength=2000&mDataProp_0=kch&mDataProp_1=kcmc&mDataProp_2=kxhnew&mDataProp_3=jkfs&mDataProp_4=xmmc&mDataProp_5=fzmc&mDataProp_6=ktmc&mDataProp_7=xf&mDataProp_8=skls&mDataProp_9=sksj&mDataProp_10=skdd&mDataProp_11=xqmc&mDataProp_12=syrs&mDataProp_13=ctsm&mDataProp_14=czOper' export let reqBody = 'sEcho=1&iColumns=15&sColumns=&iDisplayStart=0&iDisplayLength=2000&mDataProp_0=kch&mDataProp_1=kcmc&mDataProp_2=kxhnew&mDataProp_3=jkfs&mDataProp_4=xmmc&mDataProp_5=fzmc&mDataProp_6=ktmc&mDataProp_7=xf&mDataProp_8=skls&mDataProp_9=sksj&mDataProp_10=skdd&mDataProp_11=xqmc&mDataProp_12=syrs&mDataProp_13=ctsm&mDataProp_14=czOper'
let currentErrorCount = 0 let currentErrorCount = 0
@ -60,7 +59,6 @@ async function updateRx() {
} }
export async function poll() { export async function poll() {
await checkResetCookieRequest()
if (appConfig.channels.includes('bx')) { if (appConfig.channels.includes('bx')) {
await updateBx() await updateBx()
await sleep(appConfig.interval) await sleep(appConfig.interval)
@ -76,19 +74,6 @@ export async function poll() {
setImmediate(poll) setImmediate(poll)
} }
async function checkResetCookieRequest() {
let req = parseInt(fs.readFileSync('resetCookieRequest.txt').toString())
if (req) {
try {
await resetCookie()
logAndNotifyUser('[resetCookie]成功')
fs.writeFileSync('resetCookieRequest.txt', '0')
} catch (e) {
logAndNotifyUser('[resetCookie]失败')
}
}
}
async function processError(e: Error) { async function processError(e: Error) {
currentErrorCount++ currentErrorCount++
if (currentErrorCount >= 30) { if (currentErrorCount >= 30) {

查看文件

@ -1,4 +0,0 @@
import * as fs from "fs"
fs.writeFileSync('resetCookieRequest.txt','1')
console.log('已请求resetCookie')

查看文件

@ -1,5 +1,5 @@
import {appConfig} from "./config" import {appConfig} from "./config"
import {countStr, logAndNotifyUser, sduAxios, sleep} from "./includes" import {logAndNotifyUser, sduAxios} from "./includes"
import {reqBody} from "./poll" import {reqBody} from "./poll"
import * as fs from "fs" import * as fs from "fs"
import {IJsonCourse} from "./types" import {IJsonCourse} from "./types"
@ -29,27 +29,7 @@ async function test() {
// for (let course of courseList) { // for (let course of courseList) {
// console.log(course.kcmc + ' ' + course.kch + ' ' + course.kxh + ' ' + course.syrs + ' ' + course.xf) // console.log(course.kcmc + ' ' + course.kch + ' ' + course.kxh + ' ' + course.syrs + ' ' + course.xf)
// } // }
// let lastData = '' logAndNotifyUser('log test')
// let first=true
// let count=0
// while (true) {
// let resp = await sduAxios.get("jsxsd/xsxkjg/comeXkjglb?isktx=true", {
// headers: {
// 'Cookie': 'bzb_jsxsd=329BCA4E7D8E2421309B14C02587784F; bzb_njw=55FFC1D9D9B2EF5A10D3F28BEC294AE1; SERVERID=123'
// }
// })
// if (resp.data !== lastData && !first) {
// logAndNotifyUser('可以抽签了')
// first=false
// break
// }
// lastData = resp.data
// console.log('rotate '+count)
// count++
// await sleep(1000)
// }
let str=fs.readFileSync('backup/2.html')
console.log(countStr(JSON.stringify(str.toString()),'cqOper'))
} }
test() test()