sub: 过滤掉数据为null

module/mqtt/sub.go

@@ -119,7 +119,9 @@ func (d *DataEventEntry) SubMsgLog(configOption *config.AppConfig) {
 		select {
 		case msg := <-subMsgChan:
 			subMsLog := d.CreatMsgLog(msg)
-			batchList = append(batchList, subMsLog)
+			if subMsLog != nil {
+				batchList = append(batchList, subMsLog)
+			}
 			if len(batchList) >= batchSize {
 				DSMLog.Mx.Lock()
 				DSMLog.SubMsgLogList = append(DSMLog.SubMsgLogList, batchList...)