AcqGoodsOnSeatWmsData.java 2.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657
  1. package com.emato.cus.supervise.biz.acqGoodsSeat;
  2. import com.emato.cus.supervise.biz.WmsData;
  3. import com.emato.cus.supervise.constant.EmtRecordTimeEnum;
  4. import com.emato.cus.supervise.domain.WmsAcqGoodsOnSeat;
  5. import com.emato.cus.supervise.service.wms.WmsAcqGoodsOnSeatService;
  6. import com.google.common.collect.ImmutableMap;
  7. import org.apache.commons.lang3.StringUtils;
  8. import org.slf4j.Logger;
  9. import org.slf4j.LoggerFactory;
  10. import org.springframework.beans.factory.annotation.Autowired;
  11. import org.springframework.stereotype.Component;
  12. import java.util.Collections;
  13. import java.util.List;
  14. /**
  15. * 库位货物数据 业务 WMS
  16. * @author Scott Chen
  17. * @version 1.0
  18. * 2017-10-31 12:24
  19. */
  20. @Component
  21. public class AcqGoodsOnSeatWmsData implements WmsData {
  22. private static final Logger logger = LoggerFactory.getLogger(AcqGoodsOnSeatWmsData.class);
  23. @Autowired
  24. private WmsAcqGoodsOnSeatService wmsAcqGoodsOnSeatService;
  25. private static final String DATA_TYPE_INFO = "[" + EmtRecordTimeEnum.ACQ_GOODS_ON_SEAT.getCode() + "]" + EmtRecordTimeEnum.ACQ_GOODS_ON_SEAT.getName();
  26. @Override
  27. public List getWmsData(String thisTime) {
  28. logger.info("---------- 库位货物数据::获取本次监控数据开始 --------------------");
  29. if (StringUtils.isBlank(thisTime)) {
  30. String err = "---【" + DATA_TYPE_INFO + "】本次扫描时间为空.";
  31. logger.error(err);
  32. return Collections.EMPTY_LIST;
  33. }
  34. ImmutableMap param = ImmutableMap.of("thisTime", thisTime);
  35. List<WmsAcqGoodsOnSeat> resultList = wmsAcqGoodsOnSeatService.getWmsAcqGoodsSeat(param);
  36. if (resultList == null || resultList.size() == 0) {
  37. String err = "---【" + DATA_TYPE_INFO + "】获取本次监控数据为空.";
  38. logger.error(err);
  39. return Collections.EMPTY_LIST;
  40. }
  41. logger.info("---【" + DATA_TYPE_INFO + "】获取本次监控数据{}条.", resultList.size());
  42. logger.info("---------- 库位货物数据::获取本次监控数据结束 --------------------");
  43. return resultList;
  44. }
  45. }