-
Notifications
You must be signed in to change notification settings - Fork 0
/
sub_nats.go
44 lines (41 loc) · 1.14 KB
/
sub_nats.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
package OrgWorkTip
import (
"encoding/json"
BaseService "github.com/fotomxq/weeekj_core/v5/base/service"
CoreFilter "github.com/fotomxq/weeekj_core/v5/core/filter"
CoreLog "github.com/fotomxq/weeekj_core/v5/core/log"
CoreNats "github.com/fotomxq/weeekj_core/v5/core/nats"
"github.com/nats-io/nats.go"
)
func subNats() {
//处理新增通知
_ = BaseService.SetService(&BaseService.ArgsSetService{
ExpireAt: CoreFilter.GetNowTimeCarbon().AddDay().Time,
Name: "组织工作区提示",
Description: "",
EventSubType: "all",
Code: "org_work_tip",
EventType: "nats",
EventURL: "/org/work_tip",
//TODO:待补充
EventParams: "",
})
CoreNats.SubDataByteNoErr("org_work_tip", "/org/work_tip", subNatsNew)
}
func subNatsNew(_ *nats.Msg, action string, _ int64, _ string, data []byte) {
//跳出非添加数据
if action != "new" {
return
}
//获取参数
var args argsAppendTip
if err := json.Unmarshal(data, &args); err != nil {
CoreLog.Error("org work tip, get params, ", err)
return
}
//添加数据
if err := appendTip(args); err != nil {
CoreLog.Error("org work tip, insert, ", err)
return
}
}