比較提交
沒有共同的提交。「master」和「b6478fe9a8256766a80f3e1632e9de0ee36adad0」的歷史完全不同。
master
...
b6478fe9a8
5
.gitignore
vendored
5
.gitignore
vendored
@ -1,7 +1,4 @@
|
|||||||
.idea/*
|
.idea/*
|
||||||
/config.yaml
|
/config.yaml
|
||||||
node_modules/*
|
node_modules/*
|
||||||
/pnpm-lock.yaml
|
/pnpm-lock.yaml
|
||||||
/arr.json
|
|
||||||
backup
|
|
||||||
resetCookieRequest.txt
|
|
@ -4,10 +4,10 @@
|
|||||||
|
|
||||||
#### 特性:
|
#### 特性:
|
||||||
|
|
||||||
- 监控(检视某几门课的剩余人数变化)
|
- 监控
|
||||||
- 抢课(当某几门课剩余人数大于0时自动抢课)
|
- 抢课
|
||||||
- 换课(在课表冲突的情况下先退课再抢课,如果抢课失败进行回滚)
|
- 换课(在课表冲突的情况下先退课再抢课,如果抢课失败进行回滚)
|
||||||
- 将监控、抢课、换课操作信息发送至QQ(调用Qmsg酱API)
|
- 将操作信息发送至QQ(调用Qmsg酱API)
|
||||||
|
|
||||||
#### 环境
|
#### 环境
|
||||||
|
|
||||||
|
@ -1,15 +1,7 @@
|
|||||||
# 学号
|
# 教务cookie
|
||||||
username: "2020123456"
|
cookie: "JSESSIONID=asd;"
|
||||||
# 密码
|
# 在 https://qmsg.zendee.cn 申请
|
||||||
password: "abcdefg123123"
|
qmsgKey: "v9631222364dd7ae99909cb63b7445c5"
|
||||||
# 在 https://qmsg.zendee.cn 获取
|
|
||||||
qmsgKey: "15rg6s5t1h6t1s5g66"
|
|
||||||
## telegram api 域名
|
|
||||||
#tgApiDomain: "api.telegram.org"
|
|
||||||
## @BotFather 建立机器人获取
|
|
||||||
#tgApiKey: ""
|
|
||||||
## @getidsbot 获取
|
|
||||||
#tgChatId: -454888515
|
|
||||||
# 轮询间隔毫秒
|
# 轮询间隔毫秒
|
||||||
interval: 100
|
interval: 100
|
||||||
# 监控列表
|
# 监控列表
|
||||||
|
@ -5,22 +5,17 @@
|
|||||||
"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",
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"@types/node": "^16.9.1",
|
"@types/node": "^16.9.1",
|
||||||
"@types/qs": "^6.9.7",
|
"@types/qs": "^6.9.7",
|
||||||
"@types/tough-cookie": "^4.0.1",
|
|
||||||
"axios": "^0.21.4",
|
"axios": "^0.21.4",
|
||||||
"axios-cookiejar-support": "^1.0.1",
|
|
||||||
"axios-retry": "^3.1.9",
|
"axios-retry": "^3.1.9",
|
||||||
"dayjs": "^1.10.7",
|
"dayjs": "^1.10.7",
|
||||||
"qs": "^6.10.1",
|
"qs": "^6.10.1",
|
||||||
"tough-cookie": "^4.0.0",
|
|
||||||
"ts-node": "^10.2.1",
|
"ts-node": "^10.2.1",
|
||||||
"typescript": "^4.4.3",
|
"typescript": "^4.4.3",
|
||||||
"yaml": "^1.10.2"
|
"yaml": "^1.10.2"
|
||||||
|
@ -57,7 +57,7 @@ export async function replaceProcess(courseList: ICourse[], exit: ICourse) {
|
|||||||
}
|
}
|
||||||
if (parseInt(single.syrs) > 0) {
|
if (parseInt(single.syrs) > 0) {
|
||||||
logAndNotifyUser('[replace]发现 ' + single.kcmc + ' 剩余人数为' + single.syrs + ',进行换课 at ' + getTimeNow())
|
logAndNotifyUser('[replace]发现 ' + single.kcmc + ' 剩余人数为' + single.syrs + ',进行换课 at ' + getTimeNow())
|
||||||
if (!(await exitCourse(exitJsonCourse))) {
|
if (!(await exitCourse(exitJsonCourse, exit.channel))) {
|
||||||
logAndNotifyUser('[replace]退课 ' + exitJsonCourse.kcmc + ' 失败 at ' + getTimeNow())
|
logAndNotifyUser('[replace]退课 ' + exitJsonCourse.kcmc + ' 失败 at ' + getTimeNow())
|
||||||
}
|
}
|
||||||
if (await acquireCourse(single, course.channel)) {
|
if (await acquireCourse(single, course.channel)) {
|
||||||
|
1029
src/des.js
1029
src/des.js
檔案差異因為檔案過大而無法顯示
載入差異
46
src/draw.ts
46
src/draw.ts
@ -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()
|
|
@ -1,60 +0,0 @@
|
|||||||
import {IJsonCourse} from "./types"
|
|
||||||
import {JsonCourseList} from "./poll"
|
|
||||||
import {findJsonCourse, getTimeNow} from "./includes"
|
|
||||||
import {appConfig} from "./config"
|
|
||||||
import {scalarOptions} from "yaml"
|
|
||||||
import Str = scalarOptions.Str
|
|
||||||
|
|
||||||
let lastJsonCourseList: { bx: IJsonCourse[], xx: IJsonCourse[], rx: IJsonCourse[] }
|
|
||||||
let firstRunHealth = true
|
|
||||||
|
|
||||||
export async function health() {
|
|
||||||
let totalAcquireCount = 0
|
|
||||||
let totalExitCount = 0
|
|
||||||
let acquireNames: string[] = []
|
|
||||||
let exitNames: string[] = []
|
|
||||||
if (firstRunHealth) {
|
|
||||||
console.log('[health]程序health监控启动完毕')
|
|
||||||
firstRunHealth = false
|
|
||||||
} else {
|
|
||||||
for (let channel of appConfig.channels) {
|
|
||||||
for (let lastCourse of lastJsonCourseList[channel]) {
|
|
||||||
let currentCourse = findJsonCourse({
|
|
||||||
kch: lastCourse.kch,
|
|
||||||
kxh: parseInt(lastCourse.kxh),
|
|
||||||
channel: channel
|
|
||||||
})
|
|
||||||
if (currentCourse == undefined) {
|
|
||||||
continue
|
|
||||||
}
|
|
||||||
if (parseInt(currentCourse.syrs) > parseInt(lastCourse.syrs)) {
|
|
||||||
totalExitCount += parseInt(currentCourse.syrs) - parseInt(lastCourse.syrs)
|
|
||||||
if (!exitNames.includes(currentCourse.kcmc)) {
|
|
||||||
exitNames.push(currentCourse.kcmc)
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
let num = parseInt(lastCourse.syrs) - parseInt(currentCourse.syrs)
|
|
||||||
totalAcquireCount += num
|
|
||||||
if (!acquireNames.includes(currentCourse.kcmc) && num > 0) {
|
|
||||||
acquireNames.push(currentCourse.kcmc)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
console.log('[health]实时总退课人次:' + totalExitCount + '(' + shuffle(exitNames).slice(0, 3).join(',') + '等),总选课人次:'
|
|
||||||
+ totalAcquireCount + '(' + shuffle(acquireNames).slice(0, 3).join(',') + '等) at ' + getTimeNow())
|
|
||||||
}
|
|
||||||
lastJsonCourseList = JSON.parse(JSON.stringify(JsonCourseList))
|
|
||||||
setTimeout(health, 60 * 1000)
|
|
||||||
}
|
|
||||||
|
|
||||||
function shuffle(array: any[]) {
|
|
||||||
let currentIndex = array.length, randomIndex
|
|
||||||
while (currentIndex != 0) {
|
|
||||||
randomIndex = Math.floor(Math.random() * currentIndex)
|
|
||||||
currentIndex--;
|
|
||||||
[array[currentIndex], array[randomIndex]] = [
|
|
||||||
array[randomIndex], array[currentIndex]]
|
|
||||||
}
|
|
||||||
return array
|
|
||||||
}
|
|
146
src/includes.ts
146
src/includes.ts
@ -3,31 +3,19 @@ import {appConfig} from "./config"
|
|||||||
import * as qs from "qs"
|
import * as qs from "qs"
|
||||||
import dayjs from "dayjs"
|
import dayjs from "dayjs"
|
||||||
import {ICourse, IJsonCourse, TChannel} from "./types"
|
import {ICourse, IJsonCourse, TChannel} from "./types"
|
||||||
import {JsonCourseList, reqBody} from "./poll"
|
import {JsonCourseList} from "./poll"
|
||||||
import axiosRetry from "axios-retry"
|
import axiosRetry from "axios-retry"
|
||||||
import tough from "tough-cookie"
|
|
||||||
import axiosCookieJarSupport from "axios-cookiejar-support"
|
|
||||||
import {strEnc} from "./des"
|
|
||||||
import {scalarOptions} from "yaml"
|
|
||||||
import * as process from "process"
|
|
||||||
|
|
||||||
let sduAxios = axios.create({
|
let sduAxios = axios.create({
|
||||||
headers: {
|
headers: {
|
||||||
'Content-Type': 'application/x-www-form-urlencoded; charset=UTF-8',
|
'Content-Type': 'application/x-www-form-urlencoded; charset=UTF-8',
|
||||||
'X-Requested-With': 'XMLHttpRequest',
|
'Cookie': appConfig.cookie
|
||||||
'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:92.0) Gecko/20100101 Firefox/92.0',
|
|
||||||
},
|
},
|
||||||
baseURL: 'https://bkzhjx.wh.sdu.edu.cn/',
|
baseURL: 'https://bkzhjx.wh.sdu.edu.cn/',
|
||||||
timeout: 5000,
|
timeout: 5,
|
||||||
transformResponse: data => {
|
// maxRedirects: 0
|
||||||
try {
|
|
||||||
return JSON.parse(data)
|
|
||||||
} catch (_e) {
|
|
||||||
return data
|
|
||||||
}
|
|
||||||
},
|
|
||||||
// maxRedirects: 10
|
|
||||||
})
|
})
|
||||||
|
|
||||||
axiosRetry(sduAxios, {
|
axiosRetry(sduAxios, {
|
||||||
retries: 2,
|
retries: 2,
|
||||||
shouldResetTimeout: true,
|
shouldResetTimeout: true,
|
||||||
@ -36,21 +24,13 @@ axiosRetry(sduAxios, {
|
|||||||
|
|
||||||
export async function logAndNotifyUser(text: string) {
|
export async function logAndNotifyUser(text: string) {
|
||||||
console.log(text)
|
console.log(text)
|
||||||
// await axios.post('https://qmsg.zendee.cn/send/' + appConfig.qmsgKey, qs.stringify({
|
await axios.post('https://qmsg.zendee.cn/send/' + appConfig.qmsgKey, qs.stringify({
|
||||||
// msg: text
|
msg: text
|
||||||
// }), {
|
}), {
|
||||||
// headers: {
|
headers: {
|
||||||
// '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({
|
|
||||||
chat_id: appConfig.tgChatId,
|
|
||||||
text: text
|
|
||||||
}))
|
|
||||||
} catch (e) {
|
|
||||||
console.log(e)
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
export function sleep(ms: number) {
|
export function sleep(ms: number) {
|
||||||
@ -66,105 +46,21 @@ export function findJsonCourse(course: ICourse): IJsonCourse | undefined {
|
|||||||
}
|
}
|
||||||
|
|
||||||
export async function acquireCourse(course: IJsonCourse, channel: TChannel): Promise<boolean> {
|
export async function acquireCourse(course: IJsonCourse, channel: TChannel): Promise<boolean> {
|
||||||
let segment = ''
|
if (channel == 'bx' || channel == 'xx') {
|
||||||
switch (channel) {
|
|
||||||
case 'bx':
|
} else {
|
||||||
segment = 'bxxkOper'
|
|
||||||
break
|
|
||||||
case 'xx':
|
|
||||||
segment = 'xxxkOper'
|
|
||||||
break
|
|
||||||
case 'rx':
|
|
||||||
segment = 'ggxxkxkOper'
|
|
||||||
break
|
|
||||||
}
|
|
||||||
try {
|
|
||||||
let resp = await sduAxios.get('/jsxsd/xsxkkc/' + segment + '?kcid=' + course.jx02id + '&cfbs=null&jx0404id=' + course.jx0404id + '&xkzy=&trjf=')
|
|
||||||
if (resp.data.success === true) {
|
|
||||||
return true
|
|
||||||
} else {
|
|
||||||
logAndNotifyUser(resp.data.message)
|
|
||||||
if (resp.data.message.includes('当前账号已在别处登录')) {
|
|
||||||
await resetCookie()// TODO 加锁、优化
|
|
||||||
}
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
} catch (e) {
|
|
||||||
return false
|
|
||||||
}
|
}
|
||||||
|
return true
|
||||||
}
|
}
|
||||||
|
|
||||||
export async function exitCourse(course: IJsonCourse): Promise<boolean> {
|
export async function exitCourse(course: IJsonCourse, channel: TChannel): Promise<boolean> {
|
||||||
try {
|
if (channel == 'bx' || channel == 'xx') {
|
||||||
let resp = await sduAxios.get('/jsxsd/xsxkjg/xstkOper?jx0404id=' + course.jx0404id)
|
|
||||||
if (resp.data.success === true) {
|
|
||||||
return true
|
|
||||||
} else {
|
|
||||||
logAndNotifyUser('[exitCourse]退课失败:' + resp.data.message)
|
|
||||||
if (resp.data.message.includes('当前账号已在别处登录')) {
|
|
||||||
await resetCookie()
|
|
||||||
}
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
} catch (e) {
|
|
||||||
logAndNotifyUser('[exitCourse]网络异常,退课失败')
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
let resetCookieLock = false
|
} else {
|
||||||
|
|
||||||
export async function resetCookie() {
|
|
||||||
if (resetCookieLock) {
|
|
||||||
console.log('resetCookie 已被锁定')
|
|
||||||
return
|
|
||||||
}
|
}
|
||||||
resetCookieLock = true
|
return true
|
||||||
try {
|
|
||||||
let cookieJar = new tough.CookieJar()
|
|
||||||
let cookieAxios = axios.create({
|
|
||||||
headers: {
|
|
||||||
'Content-Type': 'application/x-www-form-urlencoded; charset=UTF-8',
|
|
||||||
'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:92.0) Gecko/20100101 Firefox/92.0'
|
|
||||||
},
|
|
||||||
timeout: 6000,
|
|
||||||
maxRedirects: 10
|
|
||||||
})
|
|
||||||
axiosCookieJarSupport(cookieAxios)
|
|
||||||
cookieAxios.defaults.jar = cookieJar
|
|
||||||
cookieAxios.defaults.withCredentials = true
|
|
||||||
await cookieAxios.get('http://bkzhjx.wh.sdu.edu.cn/sso.jsp')
|
|
||||||
let casUrl = 'https://pass.sdu.edu.cn/cas/login?service=http%3A%2F%2Fbkzhjx.wh.sdu.edu.cn%2Fsso.jsp'
|
|
||||||
let resp = await cookieAxios.get(casUrl)
|
|
||||||
let ticket = /name="lt" value="(.*?)"/.exec(resp.data)?.[1] || null
|
|
||||||
let rsa = strEnc(appConfig.username + appConfig.password + ticket, '1', '2', '3')
|
|
||||||
resp = await cookieAxios.post(casUrl, qs.stringify({
|
|
||||||
rsa,
|
|
||||||
ul: appConfig.username.length,
|
|
||||||
pl: appConfig.password.length,
|
|
||||||
lt: ticket,
|
|
||||||
execution: 'e1s1',
|
|
||||||
_eventId: 'submit'
|
|
||||||
}))
|
|
||||||
let nextUrl = 'https://bkzhjx.wh.sdu.edu.cn' + /<a href="(.*?)">进入选课/.exec(resp.data)![1]
|
|
||||||
resp = await cookieAxios.get(nextUrl)
|
|
||||||
let xkId = /jrxk\('1','(.*?)'/.exec(resp.data)![1]
|
|
||||||
nextUrl = 'https://bkzhjx.wh.sdu.edu.cn/jsxsd/xsxk/newXsxkzx?jx0502zbid=' + xkId
|
|
||||||
await cookieAxios.get(nextUrl)
|
|
||||||
await cookieAxios.get('https://bkzhjx.wh.sdu.edu.cn/jsxsd/xsxk/selectBottom?jx0502zbid=' + xkId)
|
|
||||||
let cookieString = cookieJar.getCookieStringSync('https://bkzhjx.wh.sdu.edu.cn/jsxsd/xsxk')
|
|
||||||
console.log('[cookie]取得Cookie:' + cookieString)
|
|
||||||
appConfig.cookie = cookieString
|
|
||||||
sduAxios.defaults.headers['Cookie'] = cookieString
|
|
||||||
} catch (e) {
|
|
||||||
throw e
|
|
||||||
} finally {
|
|
||||||
resetCookieLock = false
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
export function countStr(str: string, word: string) {
|
|
||||||
return str.split(word).length - 1
|
|
||||||
}
|
}
|
||||||
|
|
||||||
export {sduAxios}
|
export {sduAxios}
|
||||||
|
13
src/index.ts
13
src/index.ts
@ -1,14 +1,9 @@
|
|||||||
import {JsonCourseList, poll} from "./poll"
|
import {JsonCourseList, poll} from "./poll"
|
||||||
import {appConfig} from "./config"
|
import {appConfig} from "./config"
|
||||||
import {acquireProcess, monitProcess, replaceProcess} from "./actions"
|
import {acquireProcess, monitProcess, replaceProcess} from "./actions"
|
||||||
import {resetCookie, sleep} from "./includes"
|
import {sleep} from "./includes"
|
||||||
import {health} from "./health"
|
|
||||||
import * as fs from "fs"
|
|
||||||
|
|
||||||
async function start() {
|
async function start() {
|
||||||
fs.writeFileSync('resetCookieRequest.txt','0')
|
|
||||||
console.log('开始获取Cookie')
|
|
||||||
await resetCookie()
|
|
||||||
console.log('开始启动轮询进程')
|
console.log('开始启动轮询进程')
|
||||||
poll()
|
poll()
|
||||||
while (true) {
|
while (true) {
|
||||||
@ -24,23 +19,17 @@ async function start() {
|
|||||||
await sleep(50)
|
await sleep(50)
|
||||||
}
|
}
|
||||||
console.log('轮询进程启动完毕')
|
console.log('轮询进程启动完毕')
|
||||||
for (let channel of appConfig.channels) {
|
|
||||||
console.log('channel: ' + channel + ': ' + JsonCourseList[channel].length)
|
|
||||||
}
|
|
||||||
console.log('开始启动用户进程')
|
console.log('开始启动用户进程')
|
||||||
for (let course of appConfig.monit?.list || []) {
|
for (let course of appConfig.monit?.list || []) {
|
||||||
monitProcess(course)
|
monitProcess(course)
|
||||||
}
|
}
|
||||||
for (let course of appConfig.acquire?.list || []) {
|
for (let course of appConfig.acquire?.list || []) {
|
||||||
console.log('添加抢课课程:' + course.kch + ' ' + course.kxh)
|
|
||||||
acquireProcess(course)
|
acquireProcess(course)
|
||||||
}
|
}
|
||||||
if (appConfig.replace) {
|
if (appConfig.replace) {
|
||||||
console.log('添加换课课程:' + appConfig.replace.exit.kch + ' ' + appConfig.replace.exit.kxh)
|
|
||||||
replaceProcess(appConfig.replace.list, appConfig.replace.exit)
|
replaceProcess(appConfig.replace.list, appConfig.replace.exit)
|
||||||
}
|
}
|
||||||
console.log('用户进程启动完毕')
|
console.log('用户进程启动完毕')
|
||||||
health()
|
|
||||||
}
|
}
|
||||||
|
|
||||||
start()
|
start()
|
||||||
|
103
src/poll.ts
103
src/poll.ts
@ -1,13 +1,30 @@
|
|||||||
import {IJsonCourse} from "./types"
|
import {IJsonCourse} from "./types"
|
||||||
import {getTimeNow, logAndNotifyUser, resetCookie, sduAxios, sleep} from "./includes"
|
import {getTimeNow, 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'
|
|
||||||
let currentErrorCount = 0
|
|
||||||
let totalErrorCount = 0
|
|
||||||
|
|
||||||
|
let reqData = [
|
||||||
|
{"name": "sEcho", "value": "1"},
|
||||||
|
{"name": "iColumns", "value": "2000"},// 1
|
||||||
|
{"name": "sColumns", "value": ""},
|
||||||
|
{"name": "iDisplayStart", "value": "0"},
|
||||||
|
{"name": "iDisplayLength", "value": "2000"},// 1
|
||||||
|
{"name": "mDataProp_0", "value": "kch"},
|
||||||
|
{"name": "mDataProp_1", "value": "kcmc"},
|
||||||
|
{"name": "mDataProp_2", "value": "kxhnew"},
|
||||||
|
{"name": "mDataProp_3", "value": "jkfs"},
|
||||||
|
{"name": "mDataProp_4", "value": "xmmc"},
|
||||||
|
{"name": "mDataProp_5", "value": "xf"},
|
||||||
|
{"name": "mDataProp_6", "value": "skls"},
|
||||||
|
{"name": "mDataProp_7", "value": "sksj"},
|
||||||
|
{"name": "mDataProp_8", "value": "skdd"},
|
||||||
|
{"name": "mDataProp_9", "value": "xqmc"},
|
||||||
|
{"name": "mDataProp_10", "value": "xkrs"},
|
||||||
|
{"name": "mDataProp_11", "value": "syrs"},
|
||||||
|
{"name": "mDataProp_12", "value": "ctsm"},
|
||||||
|
{"name": "mDataProp_13", "value": "szkcflmc"},
|
||||||
|
{"name": "mDataProp_14", "value": "czOper"}
|
||||||
|
]
|
||||||
export const JsonCourseList = <{ bx: IJsonCourse[], xx: IJsonCourse[], rx: IJsonCourse[] }>{
|
export const JsonCourseList = <{ bx: IJsonCourse[], xx: IJsonCourse[], rx: IJsonCourse[] }>{
|
||||||
bx: [],
|
bx: [],
|
||||||
xx: [],
|
xx: [],
|
||||||
@ -16,51 +33,36 @@ export const JsonCourseList = <{ bx: IJsonCourse[], xx: IJsonCourse[], rx: IJson
|
|||||||
|
|
||||||
async function updateBx() {
|
async function updateBx() {
|
||||||
try {
|
try {
|
||||||
let resp = await sduAxios.post('/jsxsd/xsxkkc/xsxkBxxk?1=1&kcxx=&skls=&skfs=&xqid=', reqBody)
|
let resp = await sduAxios.post('/jsxsd/xsxkkc/xsxkBxxk?1=1&kcxx=&skls=&skfs=', qs.stringify(reqData))
|
||||||
if (resp.data.aaData.length) {
|
JsonCourseList.bx.length = 0
|
||||||
JsonCourseList.bx.length = 0
|
JsonCourseList.bx.push(...resp.data.aaData)
|
||||||
JsonCourseList.bx.push(...resp.data.aaData)
|
console.log('更新必修JsonList成功')
|
||||||
} else {
|
} catch (e) {
|
||||||
throw new Error(resp.data)
|
|
||||||
}
|
|
||||||
} catch (_e) {
|
|
||||||
console.log('获取必修JsonList失败 at ' + getTimeNow())
|
console.log('获取必修JsonList失败 at ' + getTimeNow())
|
||||||
await processError(_e as Error)
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
async function updateXx() {
|
async function updateXx() {
|
||||||
try {
|
try {
|
||||||
let resp = await sduAxios.post('/jsxsd/xsxkkc/xsxkXxxk?1=1&kcxx=&skls=&skfs=&xqid=', reqBody)
|
let resp = await sduAxios.post('/jsxsd/xsxkkc/xsxkXxxk?1=1&kcxx=&skls=&skfs=', qs.stringify(reqData))
|
||||||
if (resp.data.aaData.length) {
|
JsonCourseList.xx.length = 0
|
||||||
JsonCourseList.xx.length = 0
|
JsonCourseList.xx.push(...resp.data.aaData)
|
||||||
JsonCourseList.xx.push(...resp.data.aaData)
|
} catch (e) {
|
||||||
} else {
|
|
||||||
throw new Error(resp.data)
|
|
||||||
}
|
|
||||||
} catch (_e) {
|
|
||||||
console.log('获取限选JsonList失败 at ' + getTimeNow())
|
console.log('获取限选JsonList失败 at ' + getTimeNow())
|
||||||
await processError(_e as Error)
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
async function updateRx() {
|
async function updateRx() {
|
||||||
try {
|
try {
|
||||||
let resp = await sduAxios.post('/jsxsd/xsxkkc/xsxkGgxxkxk?kcxx=&skls=&skxq=&skjc=&sfym=false&sfct=false&szjylb=&sfxx=true&skfs=&xqid=', reqBody)
|
let resp = await sduAxios.post('/jsxsd/xsxkkc/xsxkGgxxkxk?kcxx=&skls=&skxq=&skjc=&sfym=false&sfct=false&szjylb=&sfxx=false&skfs=', qs.stringify(reqData))
|
||||||
if (resp.data.aaData.length) {
|
JsonCourseList.rx.length = 0
|
||||||
JsonCourseList.rx.length = 0
|
JsonCourseList.rx.push(...resp.data.aaData)
|
||||||
JsonCourseList.rx.push(...resp.data.aaData)
|
} catch (e) {
|
||||||
} else {
|
|
||||||
throw new Error(resp.data)
|
|
||||||
}
|
|
||||||
} catch (_e) {
|
|
||||||
console.log('获取任选JsonList失败 at ' + getTimeNow())
|
console.log('获取任选JsonList失败 at ' + getTimeNow())
|
||||||
await processError(_e as Error)
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
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)
|
||||||
@ -75,36 +77,3 @@ 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) {
|
|
||||||
currentErrorCount++
|
|
||||||
if (currentErrorCount >= 30) {
|
|
||||||
console.log('[error]出现轮询error过多,进行重新登录。上一次异常信息:' + e.message)
|
|
||||||
try {
|
|
||||||
await resetCookie()
|
|
||||||
currentErrorCount = 0
|
|
||||||
} catch (_e) {
|
|
||||||
console.log('[error]重新登录失败')
|
|
||||||
}
|
|
||||||
if (totalErrorCount != -1) {
|
|
||||||
totalErrorCount++
|
|
||||||
}
|
|
||||||
}
|
|
||||||
if (totalErrorCount >= 10) {
|
|
||||||
logAndNotifyUser('[error]重新登录失败次数过多,请检查 at ' + getTimeNow())
|
|
||||||
totalErrorCount = -1
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
@ -1,4 +0,0 @@
|
|||||||
import * as fs from "fs"
|
|
||||||
|
|
||||||
fs.writeFileSync('resetCookieRequest.txt','1')
|
|
||||||
console.log('已请求resetCookie')
|
|
64
src/test.ts
64
src/test.ts
@ -1,55 +1,15 @@
|
|||||||
import {appConfig} from "./config"
|
import {appConfig} from "./config"
|
||||||
import {countStr, logAndNotifyUser, sduAxios, sleep} from "./includes"
|
|
||||||
import {reqBody} from "./poll"
|
|
||||||
import * as fs from "fs"
|
|
||||||
import {IJsonCourse} from "./types"
|
|
||||||
|
|
||||||
async function test() {
|
console.log('channels: ' + appConfig.channels)
|
||||||
console.log('channels: ' + appConfig.channels)
|
for (let course of appConfig.monit?.list || []) {
|
||||||
for (let course of appConfig.monit?.list || []) {
|
console.log('添加监控课程 ' + course.kch + ' on channel ' + course.channel)
|
||||||
console.log('添加监控课程 ' + course.kch + ' on channel ' + course.channel)
|
}
|
||||||
}
|
for (let course of appConfig.acquire?.list || []) {
|
||||||
for (let course of appConfig.acquire?.list || []) {
|
console.log('添加抢课课程 ' + course.kch + ' on channel ' + course.channel)
|
||||||
console.log('添加抢课课程 ' + course.kch + ' on channel ' + course.channel)
|
}
|
||||||
}
|
if (appConfig.replace) {
|
||||||
if (appConfig.replace) {
|
console.log('添加退课课程 ' + appConfig.replace.exit.kch + ' on channel ' + appConfig.replace.exit.channel)
|
||||||
console.log('添加退课课程 ' + appConfig.replace.exit.kch + ' on channel ' + appConfig.replace.exit.channel)
|
for (let course of appConfig.replace.list) {
|
||||||
for (let course of appConfig.replace.list) {
|
console.log('添加换课课程 ' + course.kch + ' on channel ' + course.channel)
|
||||||
console.log('添加换课课程 ' + course.kch + ' on channel ' + course.channel)
|
}
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// sduAxios.defaults.headers['Cookie'] = 'bzb_jsxsd=91B210AA0E876E6C973D8CD52DBB9A5C; bzb_njw=705AF60821F8C9A23CB373F2A0369B85; SERVERID=121'
|
|
||||||
// let resp = await sduAxios.post('/jsxsd/xsxkkc/xsxkGgxxkxk?kcxx=&skls=&skxq=&skjc=&sfym=false&sfct=false&szjylb=&sfxx=true&skfs=&xqid=', reqBody)
|
|
||||||
// console.log(resp.data)
|
|
||||||
// fs.writeFileSync('arr.json', JSON.stringify(resp.data.aaData, null, 2))
|
|
||||||
// let courseList: IJsonCourse[] = resp.data.aaData
|
|
||||||
// courseList = courseList.filter(single => single.kcmc.includes('稷下创新')
|
|
||||||
// && single.xf >= 2)
|
|
||||||
// for (let course of courseList) {
|
|
||||||
// console.log(course.kcmc + ' ' + course.kch + ' ' + course.kxh + ' ' + course.syrs + ' ' + course.xf)
|
|
||||||
// }
|
|
||||||
// let lastData = ''
|
|
||||||
// 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()
|
|
||||||
|
@ -1,6 +1,3 @@
|
|||||||
import {scalarOptions} from "yaml"
|
|
||||||
import Str = scalarOptions.Str
|
|
||||||
|
|
||||||
export type TChannel = 'bx' | 'xx' | 'rx'
|
export type TChannel = 'bx' | 'xx' | 'rx'
|
||||||
|
|
||||||
export interface ICourse {
|
export interface ICourse {
|
||||||
@ -10,13 +7,8 @@ export interface ICourse {
|
|||||||
}
|
}
|
||||||
|
|
||||||
export interface IAppConfig {
|
export interface IAppConfig {
|
||||||
username: string,
|
|
||||||
password: string,
|
|
||||||
cookie: string,
|
cookie: string,
|
||||||
qmsgKey: string,
|
qmsgKey: string,
|
||||||
tgApiDomain: string,
|
|
||||||
tgApiKey: string,
|
|
||||||
tgChatId: number,
|
|
||||||
interval: number,
|
interval: number,
|
||||||
channels: TChannel[],
|
channels: TChannel[],
|
||||||
monit?: {
|
monit?: {
|
||||||
|
載入中…
x
新增問題並參考
Block a user