yangys
2024-09-27 26f8e5990686bdba2119024a260d986266506757
collect/src/main/java/com/qianwen/mdc/collect/service/DeviceStateAggregateNoFeedbackService.java
@@ -93,7 +93,7 @@
      schemas.add(new MeasurementSchema("rps", TSDataType.INT32));
      //schemas.add(new MeasurementSchema("is_sync", TSDataType.BOOLEAN));
      schemas.add(new MeasurementSchema("is_plan", TSDataType.INT32));//TODO 这个属性应该是GlobalWcsOfRps中的值,如何填写?
      schemas.add(new MeasurementSchema("feedback_id", TSDataType.INT64));
      //schemas.add(new MeasurementSchema("feedback_id", TSDataType.INT64));
      schemas.add(new MeasurementSchema("is_deleted", TSDataType.BOOLEAN));
      schemas.add(new MeasurementSchema("employee_id", TSDataType.INT64));
      
@@ -124,7 +124,7 @@
         tablet.addValue("rps", i, aggState.getRps());
         
         tablet.addValue("is_plan", i, aggState.getIsPlan());
         tablet.addValue("feedback_id", i, aggState.getFeedbackId());
         //tablet.addValue("feedback_id", i, aggState.getFeedbackId());
         tablet.addValue("is_deleted", i, aggState.getIsDeleted());
         tablet.addValue("employee_id", i, aggState.getEmployeeId());