chtwrs/chirpnest
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

test

Browse Source
This commit is contained in:
shoopea 2019-05-18 18:38:24 +08:00
parent 288817a9fa
commit cbfd8ab06e
1 changed files with 8 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
workers.go
View File

@ -115,13 +115,14 @@ func SQLIdentifyMsgWorker(id int, objIds <-chan int64) {
b, _ := json.Marshal(&p) b, _ := json.Marshal(&p)
err = createJob(objSubTypeJobPillage, objJobPriority, m.UserID64, m.Date.Add(time.Duration(25+rand.Intn(35))*time.Second), b) err = createJob(objSubTypeJobPillage, objJobPriority, m.UserID64, m.Date.Add(time.Duration(25+rand.Intn(35))*time.Second), b)
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : createJob(JobPillage)") logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : createJob(JobPillage)")
s := TGCommand{ /*
Type: commandSendMsg, s := TGCommand{
Text: fmt.Sprintf("Catching pillage (%s)", m.Date.Format(time.RFC3339)), Type: commandSendMsg,
ToUserID64: m.UserID64, Text: fmt.Sprintf("Catching pillage (%s)", m.Date.Format(time.RFC3339)),
} ToUserID64: m.UserID64,
TGCmdQueue <- s }
// } TGCmdQueue <- s
*/
case objSubTypeMessageGo: case objSubTypeMessageGo:
err = setObjSubTypeId(objId, objSubTypeMessageGo) err = setObjSubTypeId(objId, objSubTypeMessageGo)
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : setObjSubTypeId(Go)") logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : setObjSubTypeId(Go)")