修复iotdb大批插入数据问题

yangys

2024-11-02 9a9b747962cc00801d8cce4137d1e123d556a79b

 collect/src/main/java/com/qianwen/mdc/collect/service/DeviceStateAggregateNoFeedbackService.java

@@ -97,13 +97,13 @@
      iotDBCommonService.setTemmplateIfNotSet(IOTDBConstant.TEMPLATE_AGGREGATESTATE, deviceId);//挂载模板
      
      Tablet tablet = new Tablet(deviceId, schemas);
      tablet.rowSize = aggStates.size();
		
	
      AggregateState aggState;
      int tblIndex = 0;
      int tblIndex = -1;
      
      for(int i=0;i<aggStates.size();i++) {
         aggState = aggStates.get(i);
         tblIndex = tablet.rowSize++;
         tablet.addTimestamp(tblIndex, aggState.getTime());
         tablet.addValue("workstation_id", tblIndex, aggState.getWorkstationId());
         tablet.addValue("value_collect", tblIndex, aggState.getValueCollect());
@@ -123,12 +123,16 @@
         tablet.addValue("is_deleted", tblIndex, aggState.getIsDeleted());
         tablet.addValue("employee_id", tblIndex, aggState.getEmployeeId());
         
         tblIndex++;
         if(aggState.getWorkstationId() == 1656819337286631426L) {
            System.out.println("laile"+aggState.getWorkstationId());
         }
         //tblIndex++;
         if(tblIndex >= MAX_COUNT) {
            try {
               //每个工位批量插入一次数据
               this.iotdbConfig.getSessionPool().insertAlignedTablet(tablet);
               log.info("保存聚合状态完成tblIndex={}",tblIndex);
               //tablet.rowSize = 0;
               tablet.reset();
               tblIndex = 0;
            } catch (Exception e) {
@@ -138,13 +142,13 @@
         
      }
      
      if(tblIndex > 0) {
      if(tablet.rowSize > 0) {
         try {
            //每个工位批量插入一次数据
            this.iotdbConfig.getSessionPool().insertAlignedTablet(tablet);
            log.info("保存聚合状态完成finaltblIndex={}",tblIndex);
            tablet.reset();
            tblIndex = 0;
            tblIndex = -1;
         } catch (Exception e) {
            log.error("保存固定点数据异常",e);
         }