liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
邹宗楠
2023-05-29 15:24:18 +08:00
parent 98a52a7559
commit f91749c17f
1 changed files with 28 additions and 31 deletions
Download Patch File Download Diff File Expand all files Collapse all files

51
business/jxstore/event/event_tcp.go
View File

@@ -5,10 +5,7 @@ import (
"encoding/json" "encoding/json"
"errors" "errors"
"fmt" "fmt"
"git.rosy.net.cn/baseapi"
"git.rosy.net.cn/baseapi/utils" "git.rosy.net.cn/baseapi/utils"
"git.rosy.net.cn/jx-callback/business/jxutils/jxcontext"
"git.rosy.net.cn/jx-callback/business/jxutils/tasksch"
"git.rosy.net.cn/jx-callback/business/model" "git.rosy.net.cn/jx-callback/business/model"
"git.rosy.net.cn/jx-callback/business/model/dao" "git.rosy.net.cn/jx-callback/business/model/dao"
"git.rosy.net.cn/jx-callback/globals" "git.rosy.net.cn/jx-callback/globals"
@@ -27,39 +24,39 @@ func ListenTcp() {
return return
} }
for { for {
//c, err := l.Accept()
//if err != nil {
// fmt.Println("accept error:", err)
// break
//}
//go func() {
// t := NewTcpClient()
// if err := t.handleConn(c); err != nil {
// t = nil
// return
// }
//}()
taskFunc := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
c, err := l.Accept() c, err := l.Accept()
if err != nil { if err != nil {
fmt.Println("accept error:", err) fmt.Println("accept error:", err)
return nil, err break
} }
go func() {
t := NewTcpClient() t := NewTcpClient()
if err := handleConn(c, t); err != nil { if err := handleConn(c, t); err != nil {
t = nil t = nil
return nil, err return
}
return nil, nil
} }
}()
task := tasksch.NewParallelTask("定时任务接口监听", tasksch.NewParallelConfig().SetParallelCount(50), jxcontext.AdminCtx, taskFunc, nil) //taskFunc := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
tasksch.HandleTask(task, nil, true).Run() // c, err := l.Accept()
if _, err = task.GetResult(0); err != nil { // if err != nil {
baseapi.SugarLogger.Debugf("LoadingStoreOrderSettleAmount :%v", err) // fmt.Println("accept error:", err)
continue // return nil, err
} // }
// t := NewTcpClient()
// if err := handleConn(c, t); err != nil {
// t = nil
// return nil, err
// }
// return nil, nil
//}
//
//task := tasksch.NewParallelTask("定时任务接口监听", tasksch.NewParallelConfig().SetParallelCount(50), jxcontext.AdminCtx, taskFunc, nil)
//tasksch.HandleTask(task, nil, true).Run()
//if _, err = task.GetResult(0); err != nil {
// baseapi.SugarLogger.Debugf("LoadingStoreOrderSettleAmount :%v", err)
// continue
//}
} }
} }