diff --git a/node/app/et_node.go b/node/app/et_node.go index 02bb387..4727f10 100644 --- a/node/app/et_node.go +++ b/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 }