统计ConsumerProcess处理时长

node/app/et_node.go

@@ -75,6 +75,9 @@ func isSettleData(data map[string]interface{}) bool {
 
 // ConsumerProcess 将 IotaData -> ProcessData
 func (the *EtNode) ConsumerProcess(iotaData *common_models.IotaData) error {
+	// 记录方法开始时间
+	startTime := time.Now()
+
 	//TODO #TEST BEGIN 测试静力水准仪 (现在有计算公式的单测点计算有问题，为了能跑通 沉降分组计算 测试）
 	//if !isSettleData(iotaData.Data.Data) {
 	//	return nil
@@ -96,6 +99,11 @@ func (the *EtNode) ConsumerProcess(iotaData *common_models.IotaData) error {
 		DeviceData: *deviceData,
 		Stations:   []common_models.Station{},
 	}
+
+	defer func() {
+		duration := time.Since(startTime)
+		log.Printf("ConsumerProcess(iotaData *common_models.IotaData)执行时长: %v", duration)
+	}()
 	return nil
 }