test

items.go

@@ -5,7 +5,7 @@ import (
 )
 
 func reloadObjItem(code string, name string, itemTypeID64 int64, weight int) {
-	id := getObjItemID(code, name)
+	id := silentGetObjItemID(code, name)
 	if id == 0 {
 		_, err := addObjItem(code, name, itemTypeID64, weight)
 		logOnError(err, "reloadObjItem : addObjItem")

obj.go

@@ -500,18 +500,23 @@ func addObjItem(code string, name string, itemTypeID64 int64, weight int) (int64
 }
 
 func getObjItemID(c string, n string) int64 {
+	i := silentGetObjItemID(c, n)
+	if i == 0 {
+		w := TGCommand{
+			Type:       commandSendMsg,
+			Text:       fmt.Sprintf("Object unknown : %s - %s\n", c, n),
+			ToUserID64: cfg.Bot.Admin,
+		}
+		TGCmdQueue <- w
+	}
+	return i
+}
+
+func silentGetObjItemID(c string, n string) int64 {
 	if v, ok := cacheObjItem.Load(c); ok {
 		i := v.(ChatWarsItem)
 		return i.ObjID64
 	} else {
-		/*
-			w := TGCommand{
-				Type:       commandSendMsg,
-				Text:       fmt.Sprintf("Object unknown : %s - %s\n", c, n),
-				ToUserID64: cfg.Bot.Admin,
-			}
-			TGCmdQueue <- w
-		*/
 		return 0
 	}
 }

workers.go

@@ -220,8 +220,6 @@ func SQLJobWorker() {
 		}
 		if len(jobs) < SQLJobSliceSize {
 			time.Sleep(100 * time.Millisecond)
-		} else {
-			time.Sleep(1 * time.Millisecond)
 		}
 	}
 	log.Printf("SQLJobWorker : Closing.")