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

package com.emato.biz.service.impl;

import java.util.*;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.emato.biz.config.OmsConfig;
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.OWbInveMngMapper;
import com.emato.biz.domain.warehouse.OWbInveMng;
import com.emato.biz.service.warehouse.IOWbInveMngService;
import org.springframework.transaction.annotation.Transactional;

/**
 * 库存管理，wms入库回传时，增加库存数Service业务层处理
 *
 * @author yangbo
 * @date 2021-02-01
 */
@Service
public class OWbInveMngServiceImpl implements IOWbInveMngService
{
    @Autowired
    private OWbInveMngMapper oWbInveMngMapper;

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




    /**
     * 查询库存管理，wms入库回传时，增加库存数
     *
     * @param inveSn 库存管理，wms入库回传时，增加库存数ID
     * @return 库存管理，wms入库回传时，增加库存数
     */
    @Override
    public OWbInveMng selectOWbInveMngById(String inveSn)
    {
        return oWbInveMngMapper.selectOWbInveMngById(inveSn);
    }

    /**
     * 查询库存管理，wms入库回传时，增加库存数列表
     *
     * @param oWbInveMng 库存管理，wms入库回传时，增加库存数
     * @return 库存管理，wms入库回传时，增加库存数
     */
    @Override
    public List<OWbInveMng> selectOWbInveMngList(OWbInveMng oWbInveMng)
    {
        return oWbInveMngMapper.selectOWbInveMngList(oWbInveMng);
    }

    /**
     * 新增库存管理，wms入库回传时，增加库存数
     *
     * @param oWbInveMng 库存管理，wms入库回传时，增加库存数
     * @return 结果
     */
    @Override
    public int insertOWbInveMng(OWbInveMng oWbInveMng)
    {
        oWbInveMng.setCreateTime(DateUtils.getNowDate());
        return oWbInveMngMapper.insertOWbInveMng(oWbInveMng);
    }

    /**
     * 修改库存管理，wms入库回传时，增加库存数
     *
     * @param oWbInveMng 库存管理，wms入库回传时，增加库存数
     * @return 结果
     */
    @Override
    public int updateOWbInveMng(OWbInveMng oWbInveMng)
    {
        return oWbInveMngMapper.updateOWbInveMng(oWbInveMng);
    }

    /**
     * 批量删除库存管理，wms入库回传时，增加库存数
     *
     * @param inveSns 需要删除的库存管理，wms入库回传时，增加库存数ID
     * @return 结果
     */
    @Override
    public int deleteOWbInveMngByIds(String[] inveSns)
    {
        return oWbInveMngMapper.deleteOWbInveMngByIds(inveSns);
    }

    /**
     * 删除库存管理，wms入库回传时，增加库存数信息
     *
     * @param inveSn 库存管理，wms入库回传时，增加库存数ID
     * @return 结果
     */
    @Override
    public int deleteOWbInveMngById(String inveSn)
    {
        return oWbInveMngMapper.deleteOWbInveMngById(inveSn);
    }

    /**
     * 根据商户编号去拉取数据
     *
     * @param merchSn
     * @return
     */
    @Override
    @Transactional
    public int pullInveMng(String merchSn) {
        int page = 1;
        Integer querySize = OmsConfig.getQuerySize();
        int resultCode = pullInveMngFromOms(merchSn,page, querySize);
        while(resultCode != 1){
            page = page + 1;
            resultCode = pullInveMngFromOms(merchSn, page, querySize);
        }
        return resultCode;
    }

    private int pullInveMngFromOms(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.getQueryMngInveUrl();
//        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);
                OWbInveMng oWbInveMng = o.toJavaObject(OWbInveMng.class);
    //                OWbInveMng wb = (OWbInveMng) o;
                oWbInveMngMapper.saveOrUpdate(oWbInveMng);
            }

            if("202".equals(code)){
                return 1;
            }

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


        return 0;
    }
}