|
@@ -4,28 +4,28 @@ import (
|
|
|
"context"
|
|
|
"fmt"
|
|
|
"github.com/imroc/req/v3"
|
|
|
- "github.com/suyuan32/simple-admin-common/msg/errormsg"
|
|
|
"time"
|
|
|
+
|
|
|
"wechat-api/internal/svc"
|
|
|
"wechat-api/internal/types"
|
|
|
|
|
|
"github.com/zeromicro/go-zero/core/logx"
|
|
|
)
|
|
|
|
|
|
-type QxRefreshLogic struct {
|
|
|
+type QwRefreshLogic struct {
|
|
|
logx.Logger
|
|
|
ctx context.Context
|
|
|
svcCtx *svc.ServiceContext
|
|
|
}
|
|
|
|
|
|
-func NewQxRefreshLogic(ctx context.Context, svcCtx *svc.ServiceContext) *QxRefreshLogic {
|
|
|
- return &QxRefreshLogic{
|
|
|
+func NewQwRefreshLogic(ctx context.Context, svcCtx *svc.ServiceContext) *QwRefreshLogic {
|
|
|
+ return &QwRefreshLogic{
|
|
|
Logger: logx.WithContext(ctx),
|
|
|
ctx: ctx,
|
|
|
svcCtx: svcCtx}
|
|
|
}
|
|
|
|
|
|
-func (l *QxRefreshLogic) QxRefresh() (resp *types.BaseMsgResp, err error) {
|
|
|
+func (l *QwRefreshLogic) QwRefresh() (resp *types.BaseMsgResp, err error) {
|
|
|
var result types.WorkPhoneGetWeChatsResp
|
|
|
client := req.C().DevMode()
|
|
|
client.SetCommonRetryCount(2).
|
|
@@ -34,12 +34,12 @@ func (l *QxRefreshLogic) QxRefresh() (resp *types.BaseMsgResp, err error) {
|
|
|
res, err := client.R().SetSuccessResult(&result).Post("http://chat.gkscrm.com:15086/pc/GetWeChatsReq?id=13")
|
|
|
|
|
|
if err != nil {
|
|
|
- return
|
|
|
+ return nil, err
|
|
|
}
|
|
|
if !res.IsSuccessState() {
|
|
|
err = fmt.Errorf("GetWeChats failed with status code %d", res.StatusCode)
|
|
|
- return
|
|
|
+ return nil, err
|
|
|
}
|
|
|
|
|
|
- return &types.BaseMsgResp{Msg: errormsg.Success}, nil
|
|
|
+ return resp, nil
|
|
|
}
|