NatsLogs.go 869 B

12345678910111213141516171819202122232425262728293031323334
  1. package NatsServer
  2. import (
  3. "Cold_GoodsOrder/lib"
  4. "github.com/vmihailenco/msgpack/v5"
  5. )
  6. // 添加系统日志
  7. func AddSysLogs(T_class, T_title string, T_txt interface{}) {
  8. type T_S struct {
  9. T_class string
  10. T_title string
  11. T_txt interface{}
  12. }
  13. b, _ := msgpack.Marshal(&T_S{T_class: T_class, T_title: T_title, T_txt: T_txt})
  14. // 发布-订阅 模式,向 test1 发布一个 `Hello World` 数据
  15. _ = lib.Nats.Publish("Cold_User_AddSysLogs", b)
  16. }
  17. // 添加用户日志
  18. func AddUserLogs(T_uuid, T_class, T_title string, T_txt interface{}) {
  19. type T_S struct {
  20. T_uuid string
  21. T_class string
  22. T_title string
  23. T_txt interface{}
  24. }
  25. b, _ := msgpack.Marshal(&T_S{T_uuid: T_uuid, T_class: T_class, T_title: T_title, T_txt: T_txt})
  26. // 发布-订阅 模式,向 test1 发布一个 `Hello World` 数据
  27. _ = lib.Nats.Publish("Cold_User_AddUserLogs", b)
  28. }