![](https://img.laitimes.com/img/9ZDMuAjOiMmIsIjOiQnIsICM38FdsYkRGZkRG9lcvx2bjxiNx8VZ6l2csQzaI1Uej1mYoR2MMBjVtJWd0ckW65UbM5WOHJWa5kHT20ESjBjUIF2X0hXZ0xCMx81dvRWYoNHLrdEZwZ1Rh5WNXp1bwNjW1ZUba9VZwlHdssmch1mclRXY39CXldWYtlWPzNXZj9mcw1ycz9WL49zZuBnL3IzM2EzNxATMzAjNwAjMwIzLc52YucWbp5GZzNmLn9Gbi1yZtl2Lc9CX6MHc0RHaiojIsJye.png)
代码
@Component
@Order(value = 1)
@Log4j2
public class LiftProcessor implements CommandLineRunner{
@Autowired
private ISmartsiteLiftDeviceService deviceService;
@Autowired
private ISmartsiteLiftWorkcycService workcycService;
@Autowired
private ISmartsiteLiftDataService liftDataService;
@Override
public void run(String... args) throws Exception {
log.info(">>>>>>>>>>>>>>>服务启动执行,执行加载数据等操作<<<<<<<<<<<<<");
MqttLift mqttLift = new MqttLift();
mqttLift.initMqttLift();
while (true) {
deviceService.pushDevice();
workcycService.pushLiftWorkcyc();
liftDataService.pushLiftData();
try {
Thread.sleep(480000);
} catch (InterruptedException e) {
log.error("Lift run error",e);
}
}
}
}