diff --git a/business/jxstore/cms/job.go b/business/jxstore/cms/job.go
index 97f87fd9e..f4860f1e8 100644
--- a/business/jxstore/cms/job.go
+++ b/business/jxstore/cms/job.go
@@ -419,9 +419,15 @@ func AcceptJob(ctx *jxcontext.Context, jobID, dropShippingDeliveryID, dropShippi
 		JobTimers.s.Lock()
 		JobTimers.JobTimerMap[jobOrder.JobOrderID] = timer
 		JobTimers.s.Unlock()
-
 	}
 	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
 }
 
diff --git a/business/jxstore/event/event.go b/business/jxstore/event/event.go
index 462eade9a..1530904d8 100644
--- a/business/jxstore/event/event.go
+++ b/business/jxstore/event/event.go
@@ -716,6 +716,9 @@ func SendSysMessage(ctx *jxcontext.Context, imMessageRecord *model.ImMessageReco
 		client := wsClient.Clients[groupID][userID]
 		wsClient.s.RUnlock()
 		globals.SugarLogger.Debugf("msg %v", utils.Format4Output(imMessageRecord, false))
+		if client == nil {
+			return
+		}
 		err = client.WriteJSON(imMessageRecord)
 		if err != nil {
 			globals.SugarLogger.Debugf("client.WriteJSON error: %v", err)