From 43b3a7ddebfe214bb927763171f45e90df6297fa Mon Sep 17 00:00:00 2001 From: shoopea Date: Thu, 16 May 2019 20:43:47 +0800 Subject: [PATCH] test --- workers.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/workers.go b/workers.go index 0b56591..0fa3fd7 100644 --- a/workers.go +++ b/workers.go @@ -119,7 +119,9 @@ func SQLIdentifyMsgWorker(id int, objIds <-chan int64) { logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : insertMsgMiniWar") err = setObjSubTypeId(objId, objSubTypeMessagePillageInc) logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : setObjSubTypeId(PillageInc)") - err = createJob(objSubTypeJobPillage, objJobPriority, m.UserID64, time.Now().Add((25+rand.Intn(35))*time.Second), `{}`) + p := jobPayloadPillage{} + j, _ := json.Marshal(&c) + err = createJob(objSubTypeJobPillage, objJobPriority, m.UserID64, time.Now().Add(time.Duration(25+rand.Intn(35))*time.Second), j) logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : createJob(JobPillage)") s := TGCommand{ Type: commandSendMsg,