cus-wms-supervise/src/main/java/com/emato/cus/supervise/biz/acq06Seat/Acq06WmsData.java

package com.emato.cus.supervise.biz.acq06Seat;

import com.emato.cus.supervise.biz.WmsData;
import com.emato.cus.supervise.constant.EmtRecordTimeEnum;
import com.emato.cus.supervise.domain.WmsAcqGoodsSeat06;
import com.emato.cus.supervise.service.wms.WmsAcqGoodsSeatService06;
import com.google.common.collect.ImmutableMap;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.stereotype.Service;

import java.util.Collections;
import java.util.List;

/**
 * 库位货物数据 业务 WMS
 * @author Scott Chen
 * @version 1.0
 * 2017-10-31 12:24
 */
@Component
public class Acq06WmsData implements WmsData {
    private static final Logger logger = LoggerFactory.getLogger(Acq06WmsData.class);

    @Autowired
    private WmsAcqGoodsSeatService06 wmsAcqGoodsSeatService06;

    private static final String DATA_TYPE_INFO = "[" + EmtRecordTimeEnum.I_03.getCode() + "]" + EmtRecordTimeEnum.I_03.getName();


    @Override
    public List getWmsData(String thisTime) {
        logger.info("---------- 库位货物数据::获取本次监控数据开始 --------------------");

        if (StringUtils.isBlank(thisTime)) {
            String err = "---【" + DATA_TYPE_INFO + "】本次扫描时间为空.";
            logger.error(err);
            return Collections.EMPTY_LIST;
        }

        ImmutableMap param = ImmutableMap.of("thisTime", thisTime);
        List<WmsAcqGoodsSeat06> resultList = wmsAcqGoodsSeatService06.getWmsAcqGoodsSeat(param);

        if (resultList == null || resultList.size() == 0) {
            String err = "---【" + DATA_TYPE_INFO + "】获取本次监控数据为空.";
            logger.error(err);
            return Collections.EMPTY_LIST;
        }
        logger.info("---【" + DATA_TYPE_INFO + "】获取本次监控数据{}条.", resultList.size());

        logger.info("---------- 库位货物数据::获取本次监控数据结束 --------------------");

        return resultList;
    }
}