cus-wms-supervise2.0/src/main/java/com/emato/cus/supervise/biz/OutFee/OutFeeBiz.java

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

import com.emato.cus.supervise.biz.CusWmsTask;
import com.emato.cus.supervise.biz.acqGoodsMoveSchedule.up.AcqGoodsMoveUpCusData;
import com.emato.cus.supervise.biz.acqGoodsMoveSchedule.up.AcqGoodsMoveUpDataConversion;
import com.emato.cus.supervise.biz.acqGoodsMoveSchedule.up.AcqGoodsMoveUpRecordTime;
import com.emato.cus.supervise.biz.acqGoodsMoveSchedule.up.AcqGoodsMoveUpWmsData;
import com.emato.cus.supervise.biz.acqInventoryInfo.AcqInventoryInfoOmsData;
import com.emato.cus.supervise.constant.EmtRecordTimeEnum;
import com.emato.cus.supervise.domain.WmsAcqGoodsMove;
import com.emato.cus.supervise.domainCus.CusAcqGoodsMove05;
import com.emato.cus.supervise.domainOms.OmsProductInfo;
import com.emato.cus.supervise.util.GsonUtil;
import com.emato.cus.supervise.util.LocalDateTimeUtils;
import com.google.common.collect.Lists;
import com.google.common.collect.Maps;
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.List;
import java.util.Map;

/**
 * @author zengjunlin
 * @version 1.0
 * 2018-02-03 15:21
 */
@Component
public class OutFeeBiz implements CusWmsTask {
    private static final Logger logger = LoggerFactory.getLogger(OutFeeBiz.class);

    @Autowired
    private AcqGoodsMoveUpWmsData acqGoodsMoveUpWmsData;

    @Autowired
    private AcqGoodsMoveUpCusData acqGoodsMoveUpCusData;

    @Autowired
    private AcqGoodsMoveUpDataConversion acqGoodsMoveUpDataConversion;

    @Autowired
    private AcqInventoryInfoOmsData acqInventoryInfoOmsData;

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


    /**
     * 任务入口
     */
    @Override
    public void task() {


        // 扫描旧系统数据，
//        List<WmsAcqGoodsMove> wmsList = acqGoodsMoveUpWmsData.getWmsData(oldThisTime);
//        if (wmsList == null || wmsList.size() == 0) {
//            logger.info("--- 【" + DATA_TYPE_INFO + "】获取到本次扫描数据为空, 不执行写数据操作, 本次扫描提前结束！！！");
//            return;
//        }
//
//        List<String> skuList = Lists.newArrayList();
//        wmsList.forEach(i -> skuList.add(i.getSkuNo()));
//
//        List<OmsProductInfo> productList = acqInventoryInfoOmsData.getOmsProductData(skuList);
//
//        if (productList == null || productList.isEmpty()) {
//            logger.error("oms扫描到的数据" + GsonUtil.toJson(productList));
//            logger.info("--- 【" + DATA_TYPE_INFO + "】获取到本次扫描OMS数据为空, 不执行写数据操作, 本次扫描提前结束！！！");
//            return;
//        }
//
//        Map params = Maps.newHashMap();
//        params.put("wmsList",wmsList);
//        params.put("productInfoList", productList);
//        //将wms数据转换cus
//        List<CusAcqGoodsMove05> cusList = acqGoodsMoveUpDataConversion.conversion(params);
//
//        // 写CUS 数据
//        int res = acqGoodsMoveUpCusData.insertCus(cusList);

    }
}