diff --git a/business/jxstore/event/event_tcp.go b/business/jxstore/event/event_tcp.go index 2704d85be..6424c6b7c 100644 --- a/business/jxstore/event/event_tcp.go +++ b/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 - //} } }