366 lines
8.8 KiB
Go
366 lines
8.8 KiB
Go
package main
|
||
|
||
import (
|
||
"flag"
|
||
"fmt"
|
||
"io"
|
||
"math/rand"
|
||
"net/http"
|
||
"os"
|
||
"path"
|
||
"strconv"
|
||
"time"
|
||
|
||
"github.com/gin-gonic/gin"
|
||
rotates "github.com/lestrrat-go/file-rotatelogs"
|
||
"github.com/robfig/cron/v3"
|
||
log "github.com/sirupsen/logrus"
|
||
|
||
nested "github.com/Lyrics-you/sail-logrus-formatter/sailor"
|
||
|
||
"github.com/johlanse/study_xxqg/conf"
|
||
"github.com/johlanse/study_xxqg/utils"
|
||
// "github.com/johlanse/study_xxqg/gui"
|
||
"github.com/johlanse/study_xxqg/lib"
|
||
"github.com/johlanse/study_xxqg/model"
|
||
"github.com/johlanse/study_xxqg/push"
|
||
"github.com/johlanse/study_xxqg/utils/update"
|
||
"github.com/johlanse/study_xxqg/web"
|
||
)
|
||
|
||
var (
|
||
u bool
|
||
i bool
|
||
configPath = ""
|
||
)
|
||
|
||
var VERSION = "unknown"
|
||
|
||
func init() {
|
||
|
||
fmt.Printf("\033[1;31;40m%s\033[0m\n\n", "******************************************************************")
|
||
|
||
fmt.Printf("\033[1;31;40m%s\033[0m\n\n", "软件仅可用户学习和个人使用，禁止用于任何商业活动！！！！")
|
||
|
||
fmt.Printf("\033[1;31;40m%s\033[0m\n\n", "软件仅可用户学习和个人使用，禁止用于任何商业活动！！！！")
|
||
|
||
fmt.Printf("\033[1;31;40m%s\033[0m\n\n", "软件仅可用户学习和个人使用，禁止用于任何商业活动！！！！")
|
||
|
||
fmt.Printf("\033[1;31;40m%s\033[0m\n\n", "******************************************************************")
|
||
time.Sleep(5 * time.Second)
|
||
|
||
flag.BoolVar(&u, "u", false, "更新应用")
|
||
flag.BoolVar(&i, "init", false, "init the app")
|
||
flag.StringVar(&configPath, "config", "./config/config.yml", "设置配置文件路径")
|
||
flag.Parse()
|
||
// 初始化配置文件
|
||
conf.InitConfig(configPath, utils.Restart)
|
||
config = conf.GetConfig()
|
||
w, err := rotates.New(path.Join("config", "logs", "%Y-%m-%d.log"), rotates.WithRotationTime(time.Hour*24))
|
||
if err != nil {
|
||
log.Errorf("rotates init err: %v", err)
|
||
panic(err)
|
||
}
|
||
gin.DefaultWriter = io.MultiWriter(w, &utils.LogWriter{})
|
||
log.SetOutput(io.MultiWriter(w, os.Stdout))
|
||
|
||
level, err := log.ParseLevel(config.LogLevel)
|
||
if err != nil {
|
||
log.SetLevel(log.DebugLevel)
|
||
}
|
||
log.SetLevel(level)
|
||
|
||
showPosition := false
|
||
|
||
if level == log.DebugLevel {
|
||
showPosition = true
|
||
}
|
||
log.SetFormatter(&nested.Formatter{
|
||
FieldsOrder: nil,
|
||
TimeStampFormat: "2006-01-02 15:04:05",
|
||
CharStampFormat: "",
|
||
HideKeys: false,
|
||
Position: showPosition,
|
||
Colors: true,
|
||
FieldsColors: true,
|
||
FieldsSpace: true,
|
||
ShowFullLevel: false,
|
||
LowerCaseLevel: true,
|
||
TrimMessages: true,
|
||
CallerFirst: false,
|
||
CustomCallerFormatter: nil,
|
||
})
|
||
if !utils.CheckQuestionDB() {
|
||
utils.DownloadDbFile()
|
||
log.Errorln("题库文件不存在或已损坏，请手动前往 https://github.com/johlanse/study_xxqg/blob/main/conf/QuestionBank.db 下载并放入程序根目录")
|
||
}
|
||
}
|
||
|
||
func init() {
|
||
pid := os.Getpid()
|
||
pi := strconv.Itoa(pid)
|
||
err := os.WriteFile("pid.pid", []byte(pi), 0666)
|
||
if err != nil {
|
||
log.Errorln("pid写入失败")
|
||
return
|
||
}
|
||
}
|
||
|
||
var (
|
||
config conf.Config
|
||
)
|
||
|
||
func init() {
|
||
_, err := os.Stat(`./config/`)
|
||
if err != nil {
|
||
os.Mkdir("./config/", 0666) //nolint:errcheck
|
||
return
|
||
}
|
||
}
|
||
|
||
func main() {
|
||
conf.SetVersion(VERSION)
|
||
log.Infoln("当前程序运行版本： " + VERSION)
|
||
if i {
|
||
core := &lib.Core{}
|
||
core.Init()
|
||
core.Quit()
|
||
return
|
||
}
|
||
|
||
go update.CheckUpdate(VERSION)
|
||
|
||
if u {
|
||
update.SelfUpdate("", VERSION)
|
||
log.Infoln("请重启应用")
|
||
os.Exit(1)
|
||
}
|
||
|
||
engine := web.RouterInit()
|
||
go func() {
|
||
h := http.NewServeMux()
|
||
if config.Web.Enable {
|
||
log.Infoln(fmt.Sprintf("已开启web配置，web监听地址 ==> %v:%v", config.Web.Host, config.Web.Port))
|
||
h.Handle("/", engine)
|
||
}
|
||
if config.Wechat.Enable {
|
||
log.Infoln(fmt.Sprintf("已开启wechat公众号配置,监听地址： ==》 %v:%v", config.Web.Host, config.Web.Port))
|
||
h.HandleFunc("/wx", push.HandleWechat)
|
||
}
|
||
if config.Web.Enable || config.Wechat.Enable {
|
||
err := http.ListenAndServe(fmt.Sprintf("%s:%d", config.Web.Host, config.Web.Port), h)
|
||
if err != nil {
|
||
return
|
||
}
|
||
}
|
||
}()
|
||
|
||
if config.StartWait > 0 {
|
||
log.Infoln(fmt.Sprintf("将等待%d秒后启动程序", config.StartWait))
|
||
time.Sleep(time.Second * time.Duration(config.StartWait))
|
||
}
|
||
|
||
if config.Cron != "" {
|
||
go func() {
|
||
defer func() {
|
||
err := recover()
|
||
if err != nil {
|
||
log.Errorln("定时任务执行出现问题")
|
||
log.Errorln(err)
|
||
}
|
||
}()
|
||
log.Infoln("已采用定时执行模式")
|
||
c := cron.New()
|
||
|
||
_, err := c.AddFunc(config.Cron, func() {
|
||
defer func() {
|
||
i := recover()
|
||
if i != nil {
|
||
log.Errorln(i)
|
||
log.Errorln("执行定时任务出现异常")
|
||
}
|
||
}()
|
||
log.Infoln("即将开始执行定时任务")
|
||
// 检测是否开启了随机等待
|
||
if config.CronRandomWait > 0 {
|
||
rand.Seed(time.Now().UnixNano())
|
||
r := rand.Intn(config.CronRandomWait)
|
||
log.Infoln(fmt.Sprintf("随机延迟%d分钟", r))
|
||
time.Sleep(time.Duration(r) * time.Minute)
|
||
}
|
||
do("cron")
|
||
})
|
||
if err != nil {
|
||
log.Errorln(err.Error())
|
||
return
|
||
}
|
||
c.Start()
|
||
}()
|
||
}
|
||
|
||
if config.TG.Enable {
|
||
push.TgInit()
|
||
}
|
||
getPush := push.GetPush(config)
|
||
getPush("", "flush", "学习强国助手已上线")
|
||
|
||
if config.CustomCron != "" {
|
||
c2 := cron.New()
|
||
_, err := c2.AddFunc(config.CustomCron, func() {
|
||
getPush("all", "flush", config.CustomMessage)
|
||
})
|
||
if err != nil {
|
||
log.Errorln("添加自定义定时消息推送错误" + err.Error())
|
||
return
|
||
}
|
||
c2.Run()
|
||
}
|
||
|
||
model.SetPush(getPush)
|
||
if !config.TG.Enable && config.Cron == "" && !config.Wechat.Enable {
|
||
log.Infoln("已采用普通学习模式")
|
||
do("normal")
|
||
} else {
|
||
// gui.InitWindow()
|
||
select {}
|
||
}
|
||
}
|
||
|
||
func do(m string) {
|
||
defer func() {
|
||
err := recover()
|
||
if err != nil {
|
||
log.Errorln("do 方法执行错误")
|
||
log.Errorln(err)
|
||
}
|
||
}()
|
||
|
||
log.Infoln(` 刷课模式，默认为1，
|
||
1：只刷文章何视频
|
||
2：只刷文章和视频和每日答题
|
||
3：刷文章和视频和每日答题每周答题和专项答题`)
|
||
log.Infoln("检测到模式", config.Model)
|
||
|
||
getPush := push.GetPush(config)
|
||
getPush("", "flush", "学习强国助手已上线")
|
||
|
||
core := &lib.Core{ShowBrowser: config.ShowBrowser, Push: getPush}
|
||
defer core.Quit()
|
||
core.Init()
|
||
var user *model.User
|
||
users, _ := model.Query()
|
||
study := func(core2 *lib.Core, u *model.User) {
|
||
defer func() {
|
||
err := recover()
|
||
if err != nil {
|
||
log.Errorln("学习过程异常")
|
||
log.Errorln(err)
|
||
}
|
||
}()
|
||
startTime := time.Now()
|
||
core2.LearnArticle(u)
|
||
core2.LearnVideo(u)
|
||
if config.Model == 2 {
|
||
core2.RespondDaily(u, "daily")
|
||
} else if config.Model == 3 {
|
||
core2.RespondDaily(u, "daily")
|
||
core2.RespondDaily(u, "weekly")
|
||
core2.RespondDaily(u, "special")
|
||
}
|
||
endTime := time.Now()
|
||
score, err := lib.GetUserScore(u.ToCookies())
|
||
if err != nil {
|
||
log.Errorln("获取成绩失败")
|
||
log.Debugln(err.Error())
|
||
return
|
||
}
|
||
|
||
score, _ = lib.GetUserScore(u.ToCookies())
|
||
message := fmt.Sprintf("%v 学习完成,用时%.1f分钟</br>%v", u.Nick, endTime.Sub(startTime).Minutes(), lib.FormatScoreShort(score))
|
||
core2.Push(u.PushId, "flush", message)
|
||
}
|
||
|
||
failUser, _ := model.QueryFailUser()
|
||
for _, user := range failUser {
|
||
go func(user2 *model.User) {
|
||
c := &lib.Core{Push: getPush, ShowBrowser: config.ShowBrowser}
|
||
getPush(user2.PushId, "flush", user2.Nick+"的cookie已过期")
|
||
newUser, err := c.L(config.Retry.Times, user2.PushId)
|
||
if err != nil {
|
||
c.Push(user2.PushId, "flush", "用户"+user2.Nick+"登录超时！")
|
||
return
|
||
}
|
||
c.Init()
|
||
defer c.Quit()
|
||
study(c, newUser)
|
||
}(user)
|
||
}
|
||
|
||
// 用户小于1时自动登录
|
||
if len(users) < 1 {
|
||
log.Infoln("未检测到有效用户信息，将采用登录模式")
|
||
u, err := core.L(config.Retry.Times, "")
|
||
if err != nil {
|
||
log.Errorln(err.Error())
|
||
return
|
||
}
|
||
user = u
|
||
} else {
|
||
// 如果为定时模式则直接循环所以用户依次运行
|
||
if m == "cron" {
|
||
for _, u := range users {
|
||
study(core, u)
|
||
}
|
||
if len(users) < 1 {
|
||
user, err := core.L(config.Retry.Times, "")
|
||
if err != nil {
|
||
core.Push(user.PushId, "msg", "登录超时")
|
||
return
|
||
}
|
||
study(core, user)
|
||
}
|
||
return
|
||
}
|
||
|
||
for i, user := range users {
|
||
log.Infoln("序号：", i+1, " ===> ", user.Nick)
|
||
}
|
||
log.Infoln("请输入对应序号选择对应账户，输入0添加用户：")
|
||
|
||
inputChan := make(chan int, 1)
|
||
go func(c chan int) {
|
||
var i int
|
||
_, _ = fmt.Scanln(&i)
|
||
c <- i
|
||
}(inputChan)
|
||
|
||
var i int
|
||
select {
|
||
case i = <-inputChan:
|
||
log.Infoln("已获取到输入")
|
||
case <-time.After(time.Minute):
|
||
log.Errorln("获取输入超时，默认选择第一个用户")
|
||
if len(users) < 1 {
|
||
return
|
||
} else {
|
||
i = 1
|
||
}
|
||
}
|
||
|
||
if i == 0 {
|
||
u, err := core.L(config.Retry.Times, "")
|
||
if err != nil {
|
||
log.Errorln(err.Error())
|
||
return
|
||
}
|
||
user = u
|
||
} else {
|
||
user = users[i-1]
|
||
log.Infoln("已选择用户: ", users[i-1].Nick)
|
||
}
|
||
}
|
||
|
||
study(core, user)
|
||
core.Push(user.PushId, "flush", "")
|
||
}
|