fixbug

crontask/sync_wx.go

@@ -3,7 +3,9 @@ package crontask
 import "wechat-api/internal/service/wechat"
 
 func (l *CronTask) syncWx() {
-	wechat.SyncAllWx(l.svcCtx)
+
+	syncWx := wechat.SyncWx{Ctx: l.ctx, DB: l.svcCtx.DB}
+	syncWx.SyncAll()
 	//// 获取微信列表
 	//var result types.WorkPhoneGetWeChatsResp
 	//client := req.C().DevMode()

internal/logic/WorkPhone/wx_refresh_logic.go

@@ -24,7 +24,8 @@ func NewWxRefreshLogic(ctx context.Context, svcCtx *svc.ServiceContext) *WxRefre
 }
 
 func (l *WxRefreshLogic) WxRefresh() (resp *types.BaseMsgResp, err error) {
-	wechat.SyncAllWx(l.svcCtx)
+	syncWx := wechat.SyncWx{Ctx: l.ctx, DB: l.svcCtx.DB}
+	syncWx.SyncAll()
 
 	return &types.BaseMsgResp{Msg: errormsg.Success}, nil
 }

internal/service/wechat/sync_wx.go

@@ -12,12 +12,12 @@ import (
 	"wechat-api/internal/types"
 )
 
-type SyncAllWx struct {
+type SyncWx struct {
 	Ctx context.Context
 	DB  *ent.Client
 }
 
-func (s *SyncAllWx) SyncAll() {
+func (s *SyncWx) SyncAll() {
 	// 获取微信列表
 	var result types.WorkPhoneGetWeChatsResp
 	client := req.C().DevMode()