aa

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
 }
 

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()