增加sls模块

notify/message.go

@@ -15,7 +15,8 @@ const (
 	//通知服务topic
 	MsgOrderTopic = "messageOrder"
 	MsgGoodsTopic = "messageGoods"
-
+	//通知下游topic
+	MsgSenderTopic = "messageSenders"
 	//云仓消息topic
 	MsgCloudTopic = "shopApi"
 	//通知消息系统topic
@@ -126,7 +127,7 @@ func (p *NsqProducer) NotifyMessage(notifyMessage *NotifyMessage) (err error) {
 
 	err = p.msgValidator(notifyMessage)
 
-	if logs.CheckErr(err,"NotifyMessage"){
+	if logs.CheckErr(err, "NotifyMessage") {
 		return
 	}
 	r := rand.New(rand.NewSource(time.Now().UnixNano()))

notify/model.go

@@ -29,6 +29,8 @@ type NotifyMessage struct {
 	Data     interface{} `json:"data"`
 	URL      string      `json:"url"`
 	AppID    int         `json:"appID"`
+	PushTime int         `json:"pushTime"`
+	Times    int         `json:"times"`
 }
 
 type GoodsMsgData struct {

notify/producer.go

@@ -4,6 +4,7 @@ import (
 	"fmt"
 	"github.com/nsqio/go-nsq"
 	"gitlab.jxhh.com/stbz/library.git/logs"
+	"time"
 )
 
 type NsqProducer struct {
@@ -51,3 +52,21 @@ func (p *NsqProducer) Publish(topic string, message string) error {
 
 	return fmt.Errorf("producer is nil", err)
 }
+
+//发布延迟消息
+func (p *NsqProducer) DeferredPublish(topic string,delay time.Duration, message string) error {
+
+	logs.Info("topic",message)
+
+	var err error
+	if p.producer != nil {
+		if message == "" { //不能发布空串，否则会导致error
+			return nil
+		}
+		err = p.producer.DeferredPublish(topic,delay,[]byte(message)) // 发布消息
+		logs.CheckErr(err, "Nsq Publish")
+		return err
+	}
+
+	return fmt.Errorf("producer is nil", err)
+}

sls/sls.go

+package sls
+
+import (
+	"github.com/aliyun/aliyun-log-go-sdk/producer"
+	"github.com/gogf/gf/frame/g"
+	"gitlab.jxhh.com/stbz/library.git/logs"
+	"time"
+)
+
+const (
+	ProjectDefault = "order"
+	ProjectDis     = "dis"
+	ProjectApi     = "api-system"
+	ProjectMessage = "message-system"
+
+	LogstoreDefault    = "post_msg"
+	LogstoreOrder      = "orders"
+	LogstoreDefaultErr = "go_error"
+	LogstoreDisErr     = "dis_err"
+	LogstoreMessage    = "push_msg"
+
+	TopicDefault = "topic"
+	TopicCloud   = "shopApi"
+)
+
+var producerInstance *producer.Producer
+
+func Init() {
+	producerConfig := producer.GetDefaultProducerConfig()
+	producerConfig.Endpoint = g.Cfg().GetString("aliLog.Endpoint")
+	producerConfig.AccessKeyID = g.Cfg().GetString("aliLog.AccessKeyID")
+	producerConfig.AccessKeySecret = g.Cfg().GetString("aliLog.AccessKeySecret")
+	producerInstance = producer.InitProducer(producerConfig)
+	producerInstance.Start()
+}
+
+func Createsls(project, logstore, topic,realIP string, addLogMap map[string]string) (err error) {
+	sls := producer.GenerateLog(uint32(time.Now().Unix()), addLogMap)
+
+	err = producerInstance.SendLog(project, logstore, topic, realIP, sls)
+	if logs.CheckErr(err, "sls") {
+		return
+	}
+	return
+}
+
+func Close() {
+	producerInstance.SafeClose() // 安全关闭
+}
+
+
+