修改log的全局map

infra/logger/logger.go

@@ -9,7 +9,7 @@ import (
 var (
 	lock sync.Mutex
 	// 全局log接口map
-	loggerMap map[string]Log
+	loggerMap map[string]map[int]Log
 )
 
 type logger struct {
@@ -33,10 +33,13 @@ func NewLogger(taskId int, module string) (Log, error) {
 	lock.Lock()
 	defer lock.Unlock()
 	if loggerMap == nil {
-		loggerMap = make(map[string]Log)
+		loggerMap = make(map[string]map[int]Log)
 	}
-	if loggerMap[module] != nil {
-		return loggerMap[module], nil
+	if loggerMap[module] == nil {
+		loggerMap[module] = make(map[int]Log)
+	}
+	if loggerMap[module][taskId] != nil {
+		return loggerMap[module][taskId], nil
 	}
 	return initLogger(module, taskId)
 }
@@ -94,7 +97,7 @@ func initLogger(module string, taskId int) (Log, error) {
 	if len(innerLog.output) == 0 {
 		return defaultLogger, errors.New("未获取到日志输出驱动")
 	}
-	loggerMap[module] = innerLog
+	loggerMap[module][taskId] = innerLog
 	return innerLog, nil
 }