加入定时任务，启动时打固定点 ，并且加入工位数据缓存

yangys

2024-09-02 a33c33d48c2c16995130b825355b6883be4eb159

 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);
       
    }