yanghui
2021-04-25 8f4ffb617d82b8bfd3192f5b0f7958737bdf3224
logc.go
@@ -2,9 +2,6 @@
import (
   "basic.com/valib/bhomebus.git"
   "bytes"
   "net/url"
   "encoding/json"
   "fmt"
   uuid "github.com/satori/go.uuid"
@@ -41,16 +38,41 @@
   Info      string `gorm:"column:info" json:"info"`         // 详情
}
type LogRegister struct {
   Nodes      []bhomebus.NetNode
   Topic      string
   Reply       *bhomeclient.Reply
   Payload     []byte
}
type LogReportCallback func(*LogRegister)
var (
   msgChan chan []byte
   bhSock *bhomebus.Socket
   pubFn func(nodes []bhomebus.NetNode, topic string, data []byte, milliseconds int) int
   ProcName string
   ProcID string
   logCallback LogReportCallback
)
func init() {
}
func Init(flogWriter LogReportCallback, procId string, procName string) bool {
   msgChan = make(chan []byte, 100)
   ProcName = procName
   ProcID = procId
   logCallback = flogWriter
   if logCallback == nil {
      return false
   }
   go saveLoop()
   return true
}
func InitBySock(sock *bhomebus.Socket, procId string, procName string) bool {
@@ -141,8 +163,4 @@
         time.Sleep(10*time.Millisecond)
      }
   }
}
func Log(userName, method, path, contentType, module string, body *bytes.Buffer, values url.Values) {
}