mqtt

cl

4 天以前 83027cad5e5913f696343f18bc1d213de70f4ef9

 src/main/java/com/zy/integration/iot/task/IotPendingPublishScheduler.java

@@ -1,7 +1,7 @@
package com.zy.integration.iot.task;

import com.zy.integration.iot.publish.IotPublishService;
import com.zy.iot.config.IotProperties;
import com.zy.iot.service.IotDbConfigService;
import com.zy.iot.entity.IotPublishRecord;
import com.zy.iot.service.IotPublishRecordService;
import lombok.extern.slf4j.Slf4j;
@@ -20,7 +20,7 @@
public class IotPendingPublishScheduler {

    @Autowired
    private IotProperties iotProperties;
    private IotDbConfigService iotDbConfigService;
    @Autowired
    private IotPublishRecordService iotPublishRecordService;
    @Autowired
@@ -31,7 +31,7 @@
     */
    @Scheduled(cron = "0/5 * * * * ? ")
    private void execute() {
        if (!iotProperties.isEnabled()) {
        if (!iotDbConfigService.isMqttEnabled()) {
            return;
        }
        List<IotPublishRecord> records = iotPublishRecordService.selectPendingPublishes(50);