From f91749c17fbdc659351369bed0ee3c16e388d019 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=82=B9=E5=AE=97=E6=A5=A0?= <zouzongnan1995@icloud.com>
Date: Mon, 29 May 2023 15:24:18 +0800
Subject: [PATCH] 1

---
 business/jxstore/event/event_tcp.go | 59 ++++++++++++++---------------
 1 file changed, 28 insertions(+), 31 deletions(-)

diff --git a/business/jxstore/event/event_tcp.go b/business/jxstore/event/event_tcp.go
index dbe0dbcf4..855ca6cc3 100644
--- a/business/jxstore/event/event_tcp.go
+++ b/business/jxstore/event/event_tcp.go
@@ -5,10 +5,7 @@ import (
 	"encoding/json"
 	"errors"
 	"fmt"
-	"git.rosy.net.cn/baseapi"
 	"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/dao"
 	"git.rosy.net.cn/jx-callback/globals"
@@ -27,39 +24,39 @@ func ListenTcp() {
 		return
 	}
 	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()
-			if err != nil {
-				fmt.Println("accept error:", err)
-				return nil, err
-			}
+		c, err := l.Accept()
+		if err != nil {
+			fmt.Println("accept error:", err)
+			break
+		}
+		go func() {
 			t := NewTcpClient()
 			if err := handleConn(c, t); err != nil {
 				t = nil
-				return nil, err
+				return
 			}
-			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
-		}
+		//taskFunc := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
+		//	c, err := l.Accept()
+		//	if err != nil {
+		//		fmt.Println("accept error:", err)
+		//		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
+		//}
 	}
 }