| | |
| | | |
| | | import ( |
| | | "basic.com/valib/bhomebus.git" |
| | | "bytes" |
| | | "net/url" |
| | | |
| | | "encoding/json" |
| | | "fmt" |
| | | uuid "github.com/satori/go.uuid" |
| | |
| | | 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 { |
| | |
| | | time.Sleep(10*time.Millisecond) |
| | | } |
| | | } |
| | | } |
| | | |
| | | func Log(userName, method, path, contentType, module string, body *bytes.Buffer, values url.Values) { |
| | | |
| | | } |