✨ 适配华侨大学

config.toml

@@ -46,7 +46,7 @@ bucket = "likedream"
 appVersion = "9.7.2"
 systemVersion = "iOS 17"
 calVersion = "firstv"
-
+sliderIds = ["1018764144934965", "sdhyxy", "hqdx"]
 
 [task]
 concurrency = 20

internal/api/v1/cpuser_req.go

@@ -1,6 +1,10 @@
 package v1
 
-import "github.com/gogf/gf/v2/frame/g"
+import (
+	"likedream-goframe/internal/framework/captcha"
+
+	"github.com/gogf/gf/v2/frame/g"
+)
 
 type CpSchoolListReq struct {
 	g.Meta `path:"/school" method:"get" tags:"CpSchool" summary:"获取cp学校列表"`
@@ -14,6 +18,21 @@ type CpUserAddReq struct {
 	SchoolId string `json:"school_id"`
 	Email    string `json:"email" v:"email|regex:^.*@qq\\.com$#邮箱格式不正确|必须是QQ邮箱"`
 }
+type LoginGetCode struct {
+	g.Meta     `path:"/user/getCode" method:"post" tags:"CpUser" summary:"获取手机号登录验证码"`
+	Mobile     string                `json:"mobile" v:"required#手机号不能为空"`
+	CaptchaKey string                `json:"captchaKey" v:"required#验证码不能不能为空"`
+	Dots       []captcha.ConfirmData `json:"dots" v:"required#验证码不能为空"`
+}
+
+type AddByCode struct {
+	g.Meta     `path:"/user/addByCode" method:"post" tags:"CpUser" summary:"手机号登录"`
+	CaptchaKey string                `json:"captchaKey" v:"required#验证码不能不能为空"`
+	Dots       []captcha.ConfirmData `json:"dots" v:"required#验证码不能为空"`
+	Mobile     string                `json:"mobile" v:"required#手机号不能为空"`
+	Code       string                `json:"code"`
+}
+
 type CpUserConfirmAddReq struct {
 	g.Meta      `path:"/user/confirm" method:"post" tags:"CpUser" summary:"多因子确认添加cp用户"`
 	Key         string `json:"key"`

internal/application/cpdaily/cryptoutil/aes_decrypt_test.go

@@ -0,0 +1,15 @@
+package cryptoutil
+
+import (
+	"encoding/base64"
+	"testing"
+)
+
+func TestAesDecrypt(t *testing.T) {
+	str := "szFn6zAbjjU="
+	decodeString, _ := base64.StdEncoding.DecodeString(str)
+	decrypt := AesDecrypt(decodeString)
+	t.Log(string(decrypt))
+	encrypt := AesEncrypt([]byte("c9fe4f05-e1ed-4c15-aeb4-b05fa9bfb16f"))
+	t.Log(base64.StdEncoding.EncodeToString(encrypt))
+}

internal/application/cpdaily/login/cas.go

@@ -23,6 +23,7 @@ import (
 	"github.com/PuerkitoBio/goquery"
 	"github.com/avast/retry-go/v4"
 	"github.com/deatil/go-cryptobin/cryptobin/crypto"
+	"github.com/gogf/gf/v2/frame/g"
 	"github.com/samber/oops"
 	"github.com/tidwall/gjson"
 	"resty.dev/v3"
@@ -192,7 +193,8 @@ func (c *CpdailyCasLogin) Login(ctx context.Context, schoolDetail *school.School
 	}
 
 	// 声明需要滑块验证码的学校id
-	var SliderCaptchaIds = []string{"1018764144934965", "sdhyxy"}
+	var SliderCaptchaIds = g.Cfg().MustGet(ctx, cst.ConfigSliderSchoolIds).Strings()
+	// []string{"1018764144934965", "sdhyxy", "hqdx"}
 	// 判断是否需要验证码
 	if isCasNeedCaptcha(ctx, loginResponseUrl, loginType, username, c.client) {
 		// 如果是滑块验证码

internal/application/cpdaily/login/code.go

@@ -0,0 +1,51 @@
+package login
+
+import (
+	"context"
+	"encoding/base64"
+	"likedream-goframe/internal/application/cpdaily/cryptoutil"
+	"likedream-goframe/internal/application/httpclient"
+
+	"github.com/bytedance/sonic"
+	"resty.dev/v3"
+)
+
+type CpdailyCodeLogin struct {
+	client *resty.Client
+}
+
+func NewCode(ctx context.Context) *CpdailyCodeLogin {
+	return &CpdailyCodeLogin{
+		client: httpclient.NewCpdailyClient(),
+	}
+}
+
+func (c *CpdailyCodeLogin) GetLoginCode(mobile string) {
+	mobileBytes := cryptoutil.AesEncrypt([]byte(mobile))
+	mobile = base64.StdEncoding.EncodeToString(mobileBytes)
+	c.client.R().SetBody(map[string]string{
+		"a": mobile,
+		"b": "first_v4",
+	}).Post("https://mobile.campushoy.com/app/auth/authentication/mobile/messageCode/v-8222")
+}
+
+func (c *CpdailyCodeLogin) LoginByCode(mobile, code string) {
+	type loginStruct struct {
+		C string `json:"c"`
+		D string `json:"d"`
+		E string `json:"e"`
+		F string `json:"f"`
+	}
+	data := loginStruct{
+		C: mobile,
+		D: code,
+		E: "CPDAILY",
+		F: "86",
+	}
+	marshal, _ := sonic.Marshal(data)
+	marshalBytes := cryptoutil.AesEncrypt(marshal)
+	c.client.R().SetBody(map[string]string{
+		"a": base64.StdEncoding.EncodeToString(marshalBytes),
+		"b": "first_v4",
+	}).Post("https://mobile.campushoy.com/app/auth/authentication/mobileLogin/v-8222")
+}

internal/application/cpdaily/login/common.go

@@ -87,10 +87,7 @@ func ActivateSession(ctx context.Context, host string, client *resty.Client) {
 }
 
 func CookieEnabled(ctx context.Context, host string, client *resty.Client) bool {
-	client.SetRedirectPolicy(resty.FlexibleRedirectPolicy(20))
-	defer func() {
-		client.SetRedirectPolicy(resty.NoRedirectPolicy())
-	}()
+	client.SetRedirectPolicy(resty.NoRedirectPolicy())
 	host = strings.TrimSuffix(host, "/")
 	sessionResponse, err := client.R().
 		WithContext(ctx).
@@ -98,13 +95,7 @@ func CookieEnabled(ctx context.Context, host string, client *resty.Client) bool
 		Post(fmt.Sprintf("%s/wec-counselor-attendance-apps/student/attendance/getStuAttendacesInOneDay", host))
 
 	utils.OkOrPanic(err)
-	defer sessionResponse.Body.Close()
-
-	if !sessionResponse.IsSuccess() {
-		return sessionResponse.StatusCode() == 405
-	}
-	responseContentType := sessionResponse.Header().Get("Content-Type")
-	return strings.Contains(responseContentType, "json")
+	return sessionResponse.StatusCode() != 302
 }
 
 func GetClient(ctx context.Context, cookie string) *resty.Client {

internal/application/cpdaily/submitcaptcha/interface.go

@@ -42,9 +42,7 @@ type ApiResponse struct {
 type ITStarResponse struct {
 	Code json.Number `json:"code"`
 	Msg  string      `json:"msg"`
-	Data struct {
-		SuccCode []string `json:"succCode"`
-	} `json:"data"`
+	Data []string    `json:"data"`
 }
 
 type SubmitCaptchaResolver interface {

internal/application/cpdaily/submitcaptcha/resolver.go

@@ -145,10 +145,7 @@ func (r *NormalSubmitCaptchaResolver) getResultFromItStar(rawResponse json.RawMe
 	err := sonic.Unmarshal(rawResponse, &responseMap)
 	utils.OkOrPanic(err)
 
-	responseMap["authKey"] = "ITStarYYDS"
-
-	itstarUrl := strings.TrimSuffix(r.getITStarUrl(), "/")
-	url := itstarUrl + "/captcha/unLimitValidate"
+	url := r.getITStarUrl()
 
 	resp, err := r.client.R().
 		SetBody(responseMap).
@@ -161,7 +158,7 @@ func (r *NormalSubmitCaptchaResolver) getResultFromItStar(rawResponse json.RawMe
 		utils.OkOrPanic(errors.NewBusinessError(503, fmt.Sprintf("验证码识别出错: %s", itstarResp.Msg)))
 	}
 
-	return itstarResp.Data.SuccCode
+	return itstarResp.Data
 }
 
 // submitCaptcha 提交验证码

internal/application/cpdaily/task/sign.go

@@ -495,6 +495,11 @@ func (c *CpdailyAutoSignTask) FillCustomForm(ctx context.Context, form map[strin
 			lon = v.Content
 		case "address":
 			address = v.Content
+		case "latAndLon":
+			{
+				res := strings.Split(v.Content, ",")
+				lat, lon = res[1], res[0]
+			}
 		}
 	}
 

internal/application/cpdaily/task/sleepcheck.go

@@ -528,7 +528,7 @@ func (c *CpdailySleepCheckTask) FillCustomForm(ctx context.Context, form map[str
 		case "latAndLon":
 			{
 				res := strings.Split(v.Content, ",")
-				lat, lon = res[0], res[1]
+				lat, lon = res[1], res[0]
 			}
 
 		}
@@ -551,7 +551,7 @@ func (c *CpdailySleepCheckTask) FillCustomForm(ctx context.Context, form map[str
 			return utils.Catch(func() {
 				ticket = submitCaptchaResolver.GetCaptchaTicket(ctx, captchaInfo)
 			})
-		}, retry.Delay(15*time.Second), retry.Attempts(5), retry.Context(ctx))
+		}, retry.Delay(10*time.Second), retry.Attempts(5), retry.Context(ctx))
 		if e != nil {
 			utils.OkOrPanic(errors.NewBusinessError(503, "提交验证码识别失败").WithInnerError(e), oops.WithContext(ctx).Wrap)
 		}

internal/common/cst/config.go

@@ -22,6 +22,7 @@ const (
 	ConfigCpdailyAppVersion     = "cpdaily.appVersion"
 	ConfigCpdailySystemVersion  = "cpdaily.systemVersion"
 	ConfigCpdailyCalVersion     = "cpdaily.calVersion"
+	ConfigSliderSchoolIds       = "cpdaily.sliderIds"
 
 	ConfigRedisUrl = "redis.url"
 

internal/controller/cpdaily/cpuser_ctrlV1.go

@@ -61,3 +61,12 @@ func (c CpUserCtrlV1) AuthorizeRandom(ctx context.Context, req *v1.CpUserAuthori
 	defer utils.Pass(&err)
 	return service.Global.CpUser.AuthorizeRandom(ctx, req), nil
 }
+func (c CpUserCtrlV1) LoginGetCode(ctx context.Context, req *v1.LoginGetCode) (res *utils.Response[any], err error) {
+	defer utils.Pass(&err)
+	return service.Global.CpUser.LoginGetCode(ctx, req), nil
+}
+
+func (c CpUserCtrlV1) AddByCode(ctx context.Context, req *v1.AddByCode) (res *utils.Response[any], err error) {
+	defer utils.Pass(&err)
+	return service.Global.CpUser.AddByCode(ctx, req), nil
+}

internal/controller/cpdaily/i_cpuser_ctrl.go

@@ -25,4 +25,8 @@ type ICpUserCtrlV1 interface {
 	AuthorizeConfirm(ctx context.Context, req *v1.CpUserAuthorizeConfirmReq) (*utils.Response[any], error)
 	// 随机授权
 	AuthorizeRandom(ctx context.Context, req *v1.CpUserAuthorizeRandomReq) (res *utils.Response[any], err error)
+
+	// 手机登录获取验证码
+	LoginGetCode(ctx context.Context, req *v1.LoginGetCode) (*utils.Response[any], error)
+	AddByCode(ctx context.Context, req *v1.AddByCode) (*utils.Response[any], error)
 }

internal/framework/schedule/cpdaily_handler.go

@@ -94,14 +94,13 @@ func (c *CpdailyTaskHandler) ProcessTask(ctx context.Context, task *asynq.Task)
 	schoolDetail := school.GetSchoolDetail(ctx, targetTask.Edges.CpUser.SchoolID)
 	cookie := targetTask.Edges.CpUser.Cookie
 	restyClient := login.GetClient(ctx, cookie)
-	//if !login.CookieEnabled(ctx, schoolDetail.WecloudUrl, restyClient) {
-	// 定时任务强制登录并更新cookie
-	loginExecutor := login.GetCpdailyLoginBySchoolInfo(ctx, &schoolDetail)
-	loginExecutor.Login(ctx, &schoolDetail, targetTask.Edges.CpUser.Username, targetTask.Edges.CpUser.Password)
-	cookie = loginExecutor.GetCookieString()
-	db.Global.CpUser.UpdateOneID(targetTask.Edges.CpUser.ID).SetCookie(cookie).ExecX(ctx)
-	restyClient = login.GetClient(ctx, cookie)
-	//}
+	if !login.CookieEnabled(ctx, schoolDetail.WecloudUrl, restyClient) {
+		loginExecutor := login.GetCpdailyLoginBySchoolInfo(ctx, &schoolDetail)
+		loginExecutor.Login(ctx, &schoolDetail, targetTask.Edges.CpUser.Username, targetTask.Edges.CpUser.Password)
+		cookie = loginExecutor.GetCookieString()
+		db.Global.CpUser.UpdateOneID(targetTask.Edges.CpUser.ID).SetCookie(cookie).ExecX(ctx)
+		restyClient = login.GetClient(ctx, cookie)
+	}
 	// 获取任务执行handler
 	taskExecutor := task2.GetCpdailyTaskService(ctx, targetTask.TaskType, restyClient, schoolDetail)
 

internal/service/cpdaily/cpuser.go

@@ -43,6 +43,7 @@ func (v CpUserServiceV1) Add(ctx context.Context, req *v1.CpUserAddReq) *utils.R
 		SaveX(ctx)
 	return utils.SuccessWithMsg("添加成功")
 }
+
 func (v CpUserServiceV1) ConfirmAdd(ctx context.Context, req *v1.CpUserConfirmAddReq) *utils.Response[any] {
 	user := utils.GetUserInfoFromCtx(ctx)
 	schoolInfo, err := redis.GetClient().Get(ctx, req.Key+":school").Result()
@@ -171,3 +172,11 @@ func (v CpUserServiceV1) AuthorizeRandom(ctx context.Context, req *v1.CpUserAuth
 	db.Global.CpUser.UpdateOne(cpUser).SetMobileCode(utils.UUID()).SetMobileType(cpuser.MobileTypeRandom).ExecX(ctx)
 	return utils.SuccessWithMsg("已改为随机设备码")
 }
+
+func (v CpUserServiceV1) LoginGetCode(ctx context.Context, req *v1.LoginGetCode) *utils.Response[any] {
+	return utils.SuccessWithMsg("")
+}
+
+func (v CpUserServiceV1) AddByCode(ctx context.Context, req *v1.AddByCode) *utils.Response[any] {
+	return utils.SuccessWithMsg("")
+}