1

business/jxstore/event/event_tcp.go

@@ -36,27 +36,6 @@ func ListenTcp() {
 				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
-		//	}
-		//	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
-		//}
 	}
 }