package com.ld.igds.protocol.inoutplug;

import com.alibaba.fastjson.JSONObject;
import com.bstek.bdf2.core.model.DefaultDept;
import com.ld.igds.common.CoreCommonService;
import com.ld.igds.inout.dto.InoutData;
import com.ld.igds.inout.manager.InoutManager;
import com.ld.igds.models.Depot;
import com.ld.igds.protocol.inoutplug.data.InoutPlugRespData;
import com.ld.igds.sys.service.SysDeptService;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.util.HashMap;
import java.util.Map;

/**
 * 出入库数据解析
 *
 * @author chen
 */
@Slf4j
@Component(InoutPlugAnalysis.BEAN_ID)
public class InoutPlugAnalysis {

    /**
     * 匹配仓库编码
     */
    public static final String BEAN_ID = "plug.inoutPlugAnalysis";

    public static Map<String, String> depotMap = new HashMap<String, String>();

    //仓库编码匹配
    static {
        depotMap.put("1L0101", "1L0101");
        depotMap.put("1L0102", "1L0102");
        depotMap.put("1L0103", "1L0103");
        depotMap.put("1L0201", "1L0201");
        depotMap.put("1L0202", "1L0202");
        depotMap.put("1L0203", "1L0203");
        depotMap.put("2L0101", "2L0101");
        depotMap.put("2L0102", "2L0102");
        depotMap.put("2L0103", "2L0103");
        depotMap.put("2L0201", "2L0201");
        depotMap.put("2L0202", "2L0202");
        depotMap.put("2L0203", "2L0203");
        depotMap.put("3L0202", "3L0202");
        depotMap.put("3L0203", "3L0203");
        depotMap.put("3L0301", "3L0301");
        depotMap.put("3L0302", "3L0302");
        depotMap.put("3L0303", "3L0303");
    }

    @Autowired
    private CoreCommonService commonService;
    @Autowired
    private SysDeptService deptService;
    @Autowired
    private InoutManager inoutManager;

    /**
     * 出入库信息解析
     *
     * @param request
     */
    public String analysisInout(JSONObject request) throws Exception {

        InoutPlugRespData inoutPlugRespData = JSONObject.parseObject(request.toString(), InoutPlugRespData.class);

        if (inoutPlugRespData == null) {
            log.warn("出入库数据插件------>>>平台：出入库数据为空，无法进行解析");
            return null;
        }

        if (StringUtils.isEmpty(inoutPlugRespData.getDeptId())
                || StringUtils.isEmpty(inoutPlugRespData.getDepotId())) {
            log.warn("出入库数据插件----->>>平台：库区编码={}，仓库ID={}，出入库数据信息不全，报文无法进行解析", inoutPlugRespData.getDeptId(), inoutPlugRespData.getDepotId());
            return null;
        }

        //获取库区信息
        DefaultDept dept = deptService.getDeptById(inoutPlugRespData.getDeptId());
        if (dept == null) {
            log.warn("出入库数据插件----->>>平台：库区编码={}，系统获取不到库区信息，报文无法进行解析", inoutPlugRespData.getDeptId());
            return null;
        }

        String depotId = depotMap.get(inoutPlugRespData.getDepotId());
        inoutPlugRespData.setDepotId(depotId);
        //获取仓库信息
        Depot depot = commonService.getCacheDepot(dept.getCompanyId(), depotId);
        if (depot == null) {
            log.warn("出入库数据插件----->>>平台：仓库ID={}，系统获取不到仓库信息，报文无法进行解析", inoutPlugRespData.getDepotId());
            return null;
        }

        InoutData data = new InoutData();
        //TODO 封装处理



        inoutManager.addInoutData(data);
        return null;
    }

}