From 2c9bfdac17d711c8913c058b7e12b5291c69e3f9 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=8B=8F=E5=B0=B9=E5=B2=9A?= <770236076@qq.com>
Date: Wed, 30 Dec 2020 16:12:41 +0800
Subject: [PATCH] aa

---
 business/jxstore/cms/job.go     | 16 ++++++++++++++++
 business/jxstore/event/event.go | 13 +++++++++++++
 2 files changed, 29 insertions(+)

diff --git a/business/jxstore/cms/job.go b/business/jxstore/cms/job.go
index fe8214493..97f87fd9e 100644
--- a/business/jxstore/cms/job.go
+++ b/business/jxstore/cms/job.go
@@ -8,6 +8,8 @@ import (
 	"sync"
 	"time"
 
+	"git.rosy.net.cn/jx-callback/business/jxstore/event"
+
 	"git.rosy.net.cn/baseapi/platformapi/txcloudapi"
 
 	"git.rosy.net.cn/jx-callback/business/jxutils/ddmsg"
@@ -186,6 +188,13 @@ func PublishJob(ctx *jxcontext.Context, jobExt *model.JobExt) (errCode string, e
 		}
 	}
 	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 errCode, err
 }
 
@@ -236,6 +245,13 @@ func CancelPublishJob(ctx *jxcontext.Context, jobID int) (err error) {
 		return
 	}
 	dao.Commit(db)
+	content := new(strings.Builder)
+	content.WriteString("您的任务:")
+	content.WriteString(job.Title)
+	content.WriteString("。已过期或被取消，")
+	content.WriteString(utils.Float64ToStr(jxutils.IntPrice2Standard(int64(price))))
+	content.WriteString("元已返回您的余额中！")
+	event.SendSysMessageSimple(content.String(), job.UserID)
 	return err
 }
 
diff --git a/business/jxstore/event/event.go b/business/jxstore/event/event.go
index dae759298..590232443 100644
--- a/business/jxstore/event/event.go
+++ b/business/jxstore/event/event.go
@@ -29,6 +29,10 @@ var (
 	broadcast = make(chan *model.ImMessageRecord)
 )
 
+const (
+	sysMessageTitle = "猴儿通知您："
+)
+
 //连接的客户端,吧每个客户端都放进来
 type WSClient struct {
 	Clients      map[int]map[string]*websocket.Conn
@@ -673,6 +677,15 @@ func TransferMessageGroupMaster(ctx *jxcontext.Context, groupID int, userID stri
 	return err
 }
 
+func SendSysMessageSimple(content, toUserID string) (err error) {
+	return SendSysMessage(nil, &model.ImMessageRecord{
+		Content:     sysMessageTitle + " " + content,
+		ToUserID:    toUserID,
+		GroupID:     model.SysGroupID,
+		MessageType: 1, // 普通文字消息
+	})
+}
+
 func SendSysMessage(ctx *jxcontext.Context, imMessageRecord *model.ImMessageRecord) (err error) {
 	var (
 		db      = dao.GetDB()