package com.zy.asrs.task;

import com.core.common.R;
import com.zy.api.service.WcsApiService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.util.Objects;

@Slf4j
@Component
public class WcsDeviceStatusScheduler {

    @Autowired
    private WcsApiService wcsApiService;

    @Value("${wcs.status-sync.enabled:true}")
    private Boolean enabled;

//    @Scheduled(
//            initialDelayString = "${wcs.status-sync.initial-delay:10000}",
//            fixedDelayString = "${wcs.status-sync.fixed-delay:5000}"
//    )
    private void execute() {
        if (!Boolean.TRUE.equals(enabled)) {
            return;
        }
        R result = wcsApiService.syncDeviceStatusFromWcs();
        if (!Objects.equals(result.get("code"), 200)) {
            log.warn("轮询同步WCS设备状态失败, result={}", result);
        }
    }
}