eccs/eccs-biz/src/main/java/com/emato/biz/service/impl/OWbInveReceiptGoodsServiceImpl.java

package com.emato.biz.service.impl;

import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.TreeMap;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.emato.biz.config.OmsConfig;
import com.emato.biz.domain.warehouse.OWbInveMng;
import com.emato.common.utils.DateUtils;
import com.emato.common.utils.oms.request.OkHttpUtils;
import com.emato.common.utils.oms.request.OmsSign;
import okhttp3.Request;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import com.emato.biz.mapper.warehouse.OWbInveReceiptGoodsMapper;
import com.emato.biz.domain.warehouse.OWbInveReceiptGoods;
import com.emato.biz.service.warehouse.IOWbInveReceiptGoodsService;
import org.springframework.transaction.annotation.Transactional;

/**
 * 库存入库货品，发WMS货品数据Service业务层处理
 *
 * @author yangbo
 * @date 2021-02-01
 */
@Service
public class OWbInveReceiptGoodsServiceImpl implements IOWbInveReceiptGoodsService
{
    @Autowired
    private OWbInveReceiptGoodsMapper oWbInveReceiptGoodsMapper;

    private static final Logger LOGGER = LoggerFactory.getLogger(OWbInveReceiptGoodsServiceImpl.class);

    /**
     * 查询库存入库货品，发WMS货品数据
     *
     * @param receiptGoodsSn 库存入库货品，发WMS货品数据ID
     * @return 库存入库货品，发WMS货品数据
     */
    @Override
    public OWbInveReceiptGoods selectOWbInveReceiptGoodsById(String receiptGoodsSn)
    {
        return oWbInveReceiptGoodsMapper.selectOWbInveReceiptGoodsById(receiptGoodsSn);
    }

    /**
     * 查询库存入库货品，发WMS货品数据列表
     *
     * @param oWbInveReceiptGoods 库存入库货品，发WMS货品数据
     * @return 库存入库货品，发WMS货品数据
     */
    @Override
    public List<OWbInveReceiptGoods> selectOWbInveReceiptGoodsList(OWbInveReceiptGoods oWbInveReceiptGoods)
    {
        return oWbInveReceiptGoodsMapper.selectOWbInveReceiptGoodsList(oWbInveReceiptGoods);
    }

    /**
     * 新增库存入库货品，发WMS货品数据
     *
     * @param oWbInveReceiptGoods 库存入库货品，发WMS货品数据
     * @return 结果
     */
    @Override
    public int insertOWbInveReceiptGoods(OWbInveReceiptGoods oWbInveReceiptGoods)
    {
        oWbInveReceiptGoods.setCreateTime(DateUtils.getNowDate());
        return oWbInveReceiptGoodsMapper.insertOWbInveReceiptGoods(oWbInveReceiptGoods);
    }

    /**
     * 修改库存入库货品，发WMS货品数据
     *
     * @param oWbInveReceiptGoods 库存入库货品，发WMS货品数据
     * @return 结果
     */
    @Override
    public int updateOWbInveReceiptGoods(OWbInveReceiptGoods oWbInveReceiptGoods)
    {
        return oWbInveReceiptGoodsMapper.updateOWbInveReceiptGoods(oWbInveReceiptGoods);
    }

    /**
     * 批量删除库存入库货品，发WMS货品数据
     *
     * @param receiptGoodsSns 需要删除的库存入库货品，发WMS货品数据ID
     * @return 结果
     */
    @Override
    public int deleteOWbInveReceiptGoodsByIds(String[] receiptGoodsSns)
    {
        return oWbInveReceiptGoodsMapper.deleteOWbInveReceiptGoodsByIds(receiptGoodsSns);
    }

    /**
     * 删除库存入库货品，发WMS货品数据信息
     *
     * @param receiptGoodsSn 库存入库货品，发WMS货品数据ID
     * @return 结果
     */
    @Override
    public int deleteOWbInveReceiptGoodsById(String receiptGoodsSn)
    {
        return oWbInveReceiptGoodsMapper.deleteOWbInveReceiptGoodsById(receiptGoodsSn);
    }


    @Override
    @Transactional
    public int pullReceiptGoods(String merchSn) {
        int page = 1;
        Integer querySize = OmsConfig.getQuerySize();
        int resultCode = pullReceiptGoods(merchSn,page, querySize);
        while(resultCode != 1){
            page = page + 1;
            resultCode = pullReceiptGoods(merchSn, page, querySize);
        }
        return resultCode==0?1:resultCode;
    }

    private int pullReceiptGoods(String merchSn, int page, Integer querySize) {


        Map<String,String> data = new HashMap();
        data.put("merchId",merchSn);
        data.put("page",page+"");
        data.put("limit",querySize.toString());


        Map<String, String> sParaTemp = new TreeMap<String, String>();
        sParaTemp.put("data", JSON.toJSONString(data));
        sParaTemp.put("merchId",OmsConfig.getMerchSn());
        String timestamp = String.valueOf(System.currentTimeMillis()/1000);
        sParaTemp.put("timestamp", timestamp);
        //生成要请求给oms秘钥
//        String sign = OmsSign.sign(sParaTemp,cus.getWaybill().get("secret-key"));
        LOGGER.info("md5混淆码参数:" + OmsConfig.getMd5Salt());
        String sign = OmsSign.sign(sParaTemp,OmsConfig.getMd5Salt());
        sParaTemp.put("sign", sign);
        //构建Request
        String  url = OmsConfig.getQueryInveReceiptDetailUrl();
//        url = "http://127.0.0.1:8680/al/shop/order/query";
        Request request = OkHttpUtils.buildRequest(url, JSON.toJSONString(sParaTemp));
        LOGGER.info("oms的请求报文：" + request);
        // 同步访问,返回结果字符串
        String responseString = null;
        try {

            responseString = OkHttpUtils.post(request);

        } catch (Exception e) {
            e.printStackTrace();
            LOGGER.error(e.getMessage());
            return 1;
//            throw e;
        }

        try {
            LOGGER.info("oms的响应报文"+responseString);

            //解析响应数据
            JSONObject jsonObject = JSONObject.parseObject(responseString);
            JSONArray result = (JSONArray) jsonObject.get("data");
            Object msg = jsonObject.get("msg");
            Object code = jsonObject.get("code");

            if(result == null || result.size() == 0){
                return 1;
            }


            for(int i = 0 ; i < result.size(); i ++){

                JSONObject o = (JSONObject) result.get(i);
                OWbInveReceiptGoods oWbInveReceiptGoods = o.toJavaObject(OWbInveReceiptGoods.class);
                //                OWbInveMng wb = (OWbInveMng) o;
                oWbInveReceiptGoodsMapper.saveOrUpdate(oWbInveReceiptGoods);
            }
        } catch (Exception e) {
            e.printStackTrace();
            LOGGER.error(e.getMessage());
            return 1;
        }


        return 0;
    }
}