|
@@ -25,12 +25,9 @@ package main
|
|
|
import (
|
|
|
"flag"
|
|
|
"fmt"
|
|
|
- "github.com/zeromicro/go-zero/core/logx"
|
|
|
- "time"
|
|
|
"wechat-api/crontask"
|
|
|
"wechat-api/internal/config"
|
|
|
"wechat-api/internal/handler"
|
|
|
- "wechat-api/internal/pkg/customer_of_im/channel"
|
|
|
"wechat-api/internal/svc"
|
|
|
|
|
|
"github.com/robfig/cron/v3"
|
|
@@ -53,22 +50,22 @@ func main() {
|
|
|
handler.RegisterHandlers(server, ctx)
|
|
|
|
|
|
//个微处理程序 没有彻底完成之前不能开,和cow重复了
|
|
|
- if len(ctx.WechatWs) == 0 {
|
|
|
- fmt.Println("wechat ws is nil")
|
|
|
- } else if ctx.WechatWs["default"] != nil {
|
|
|
- var ic channel.IChannel
|
|
|
- for _, ws := range ctx.WechatWs {
|
|
|
- switch ws.CTypes {
|
|
|
- case "wechat":
|
|
|
- ic = channel.NewWechatChannel(ws, ctx)
|
|
|
- }
|
|
|
- ws.RegisterMessageHandler(ic.OnMessage)
|
|
|
- }
|
|
|
- logx.Info("注册个微处理通道~")
|
|
|
- }
|
|
|
- for {
|
|
|
- time.Sleep(time.Second * 10)
|
|
|
- }
|
|
|
+ //if len(ctx.WechatWs) == 0 {
|
|
|
+ // fmt.Println("wechat ws is nil")
|
|
|
+ //} else if ctx.WechatWs["default"] != nil {
|
|
|
+ // var ic channel.IChannel
|
|
|
+ // for _, ws := range ctx.WechatWs {
|
|
|
+ // switch ws.CTypes {
|
|
|
+ // case "wechat":
|
|
|
+ // ic = channel.NewWechatChannel(ws, ctx)
|
|
|
+ // }
|
|
|
+ // ws.RegisterMessageHandler(ic.OnMessage)
|
|
|
+ // }
|
|
|
+ // logx.Info("注册个微处理通道~")
|
|
|
+ //}
|
|
|
+ //for {
|
|
|
+ // time.Sleep(time.Second * 10)
|
|
|
+ //}
|
|
|
|
|
|
cronCtx := cron.New(cron.WithChain(
|
|
|
cron.SkipIfStillRunning(cron.DefaultLogger),
|