yangys
2024-09-28 d4212be4f036c5972e192a93e9a7f3a2e3bb2535
collect/src/main/java/com/qianwen/mdc/collect/service/OutputAggregateService.java
@@ -48,7 +48,7 @@
           String pathPprefix = IOTDBConstant.DB_PREFIX+IOTDBConstant.TEMPLATE_OUTPUT+"_"+workstationId;
            //this.workstationAggregateOutputMapper.createTable(workStationId);
            //this.workstationOutputMapper.createTable(workStationId);
           iotDBCommonService.setTemmplateIsNotSet(IOTDBConstant.TEMPLATE_AGGREGATEOUTPUT, pathPprefix);
           iotDBCommonService.setTemmplateIfNotSet(IOTDBConstant.TEMPLATE_AGGREGATEOUTPUT, pathPprefix);
           /*
            List<WorkstationOutput> notSyncWorkstationOutputs = this.workstationOutputMapper.selectList(Wrappers.<WorkstationOutput>lambdaQuery()
                    .eq(WorkstationOutput::getWorkstationId, workStationId)
@@ -93,10 +93,10 @@
     */
    void crateOutputTables(long workstationId){
       String aggregatePathPrefix = IOTDBConstant.DB_PREFIX+IOTDBConstant.TEMPLATE_AGGREGATEOUTPUT+"_"+workstationId;
       iotDBCommonService.setTemmplateIsNotSet(IOTDBConstant.TEMPLATE_AGGREGATEOUTPUT, aggregatePathPrefix);
       iotDBCommonService.setTemmplateIfNotSet(IOTDBConstant.TEMPLATE_AGGREGATEOUTPUT, aggregatePathPrefix);
       
       String outputPathPrefix = IOTDBConstant.DB_PREFIX+IOTDBConstant.TEMPLATE_OUTPUT+"_"+workstationId;
       iotDBCommonService.setTemmplateIsNotSet(IOTDBConstant.TEMPLATE_OUTPUT, outputPathPrefix);
       iotDBCommonService.setTemmplateIfNotSet(IOTDBConstant.TEMPLATE_OUTPUT, outputPathPrefix);
       
    }