123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657 |
- package com.emato.cus.supervise.biz.acqGoodsSeat;
- import com.emato.cus.supervise.biz.WmsData;
- import com.emato.cus.supervise.constant.EmtRecordTimeEnum;
- import com.emato.cus.supervise.domain.WmsAcqGoodsOnSeat;
- import com.emato.cus.supervise.service.wms.WmsAcqGoodsOnSeatService;
- 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 java.util.Collections;
- import java.util.List;
- /**
- * 库位货物数据 业务 WMS
- * @author Scott Chen
- * @version 1.0
- * 2017-10-31 12:24
- */
- @Component
- public class AcqGoodsOnSeatWmsData implements WmsData {
- private static final Logger logger = LoggerFactory.getLogger(AcqGoodsOnSeatWmsData.class);
- @Autowired
- private WmsAcqGoodsOnSeatService wmsAcqGoodsOnSeatService;
- private static final String DATA_TYPE_INFO = "[" + EmtRecordTimeEnum.ACQ_GOODS_ON_SEAT.getCode() + "]" + EmtRecordTimeEnum.ACQ_GOODS_ON_SEAT.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<WmsAcqGoodsOnSeat> resultList = wmsAcqGoodsOnSeatService.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;
- }
- }
|