From 665f3fff7378e80195d332dc55a697fd212e9344 Mon Sep 17 00:00:00 2001
From: shoopea <shoopea@siteop.biz>
Date: Fri, 31 May 2019 20:30:08 +0800
Subject: [PATCH] testtest

---
 def.go     | 3 ++-
 job.go     | 2 +-
 main.go    | 4 ++--
 workers.go | 2 +-
 4 files changed, 6 insertions(+), 5 deletions(-)

diff --git a/def.go b/def.go
index f60cf46..559399a 100644
--- a/def.go
+++ b/def.go
@@ -324,7 +324,8 @@ const (
 	SQLIdentifyMsgWorkers   = 6
 	SQLMsgIdentifyQueueSize = 100
 	SQLMsgRescanJobSize     = 25
-	SQLJobWorkers           = 12
+	JobWorkers              = 12
+	JobQueueSize            = 100
 	TGCmdWorkers            = 3
 	TGCmdQueueSize          = 100
 	MQTGCmdWorkers          = 3
diff --git a/job.go b/job.go
index c17f66e..980164c 100644
--- a/job.go
+++ b/job.go
@@ -316,7 +316,7 @@ func jobPillage(j Job) {
 
 	s := TGCommand{
 		Type:       commandSendMsg,
-		Text:       fmt.Sprintf("No outcome for the pillage yet(%s)", m.Date.Format(time.RFC3339)),
+		Text:       fmt.Sprintf("No outcome for the pillage yet"),
 		ToUserID64: j.UserID64,
 	}
 	TGCmdQueue <- s
diff --git a/main.go b/main.go
index c980a4c..df41d82 100644
--- a/main.go
+++ b/main.go
@@ -139,8 +139,8 @@ func main() {
 	for w := 1; w <= SQLIdentifyMsgWorkers; w++ {
 		go SQLIdentifyMsgWorker(w, SQLMsgIdentifyQueue)
 	}
-	for w := 1; w <= jobWorkers; w++ {
-		go jobWorker(w, JobQueue)
+	for w := 1; w <= JobWorkers; w++ {
+		go JobWorker(w, JobQueue)
 	}
 	for w := 1; w <= TGCmdWorkers; w++ {
 		go TGCmdWorker(w, b, TGCmdQueue)
diff --git a/workers.go b/workers.go
index 9c49198..6cbb28c 100644
--- a/workers.go
+++ b/workers.go
@@ -297,7 +297,7 @@ func SQLJobWorker() {
 	log.Printf("SQLJobWorker : Closing.")
 }
 
-func jobWorker(id int, jobs <-chan Job) {
+func JobWorker(id int, jobs <-chan Job) {
 	//log.Printf("jobWorker[" + strconv.Itoa(id) + "] : Starting.")
 	for j := range jobs {
 		switch j.JobTypeID {