liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

aa

Browse Source
This commit is contained in:
苏尹岚
2020-12-30 18:56:27 +08:00
parent 4f2c857bbf
commit fd6fdd3960
2 changed files with 10 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
business/jxstore/cms/job.go
View File

@@ -419,9 +419,15 @@ func AcceptJob(ctx *jxcontext.Context, jobID, dropShippingDeliveryID, dropShippi
JobTimers.s.Lock() JobTimers.s.Lock()
JobTimers.JobTimerMap[jobOrder.JobOrderID] = timer JobTimers.JobTimerMap[jobOrder.JobOrderID] = timer
JobTimers.s.Unlock() JobTimers.s.Unlock()
} }
dao.Commit(db) dao.Commit(db)
content := new(strings.Builder)
content.WriteString("您已接取任务:")
content.WriteString(job.Title)
content.WriteString("。已发布成功，已扣除您的余额:")
content.WriteString(utils.Float64ToStr(jxutils.IntPrice2Standard(int64(job.TotalPrice))))
content.WriteString("元")
event.SendSysMessageSimple(content.String(), job.UserID)
return jobOrder.JobOrderID, errCode, err return jobOrder.JobOrderID, errCode, err
} }

3
business/jxstore/event/event.go
View File

@@ -716,6 +716,9 @@ func SendSysMessage(ctx *jxcontext.Context, imMessageRecord *model.ImMessageReco
client := wsClient.Clients[groupID][userID] client := wsClient.Clients[groupID][userID]
wsClient.s.RUnlock() wsClient.s.RUnlock()
globals.SugarLogger.Debugf("msg %v", utils.Format4Output(imMessageRecord, false)) globals.SugarLogger.Debugf("msg %v", utils.Format4Output(imMessageRecord, false))
if client == nil {
return
}
err = client.WriteJSON(imMessageRecord) err = client.WriteJSON(imMessageRecord)
if err != nil { if err != nil {
globals.SugarLogger.Debugf("client.WriteJSON error: %v", err) globals.SugarLogger.Debugf("client.WriteJSON error: %v", err)