package com.zy.asrs.task.handler;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.core.common.Cools;
import com.zy.asrs.entity.Mat;
import com.zy.asrs.entity.MaterialInfo;
import com.zy.asrs.service.ApiLogService;
import com.zy.asrs.service.MatService;
import com.zy.asrs.task.AbstractHandler;
import com.zy.asrs.task.core.ReturnT;
import com.zy.asrs.utils.MesSyncUtil;
import com.zy.common.utils.HttpHandler;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.io.IOException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
import java.util.Map;

@Slf4j
@Service
public class MesMatSyncHandler extends AbstractHandler<String> {

    @Value("${mes.mat-sync.uri}")
    private String uri;

    @Value("${mes.mat-sync.path}")
    private String path;

    @Autowired
    private ApiLogService apiLogService;

    @Autowired
    MatService matService;

    @Transactional
    public ReturnT<String> start() throws IOException {
        boolean success = true;
        JSONObject jsonObject = doPostJsonData();
        log.info("MesMatSync jsonObject: " + jsonObject.toJSONString());

        int code = jsonObject.getInteger("code");

        if(code == 200){
            insertOrUpdateMat(jsonObject);

        }else {
            success = false;
            log.error("请求mes接口响应错误，响应码为: " + code);
        }
        saveApiLog(jsonObject.toJSONString(),success);
        return SUCCESS;
    }

    /*
    保存请求日志
     */
    private void saveApiLog(String response, boolean success) {
        apiLogService.save(
                "商品信息同步",
                uri + path,
                null,
                "127.0.0.1",
                null,
                response,
                success
        );
    }

    /*
    发起一个请求来获取商品信息
     */
    private JSONObject doPostJsonData() throws IOException {

        Map<String, Object> requestParamMap = MesSyncUtil.getRequestParamMap();
        Mat mat = matService.selectOne(new EntityWrapper<Mat>().orderBy("update_time", false));
        //如果WMS中有mat信息，则获取最新的mat修改时间，然后获取该时间之后所有更新过的隔膜卷信息。如果没有mat信息，则获取所有隔膜卷信息
        if(!Cools.isEmpty(mat)){
            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
            requestParamMap.put("time",sdf.format(mat.getUpdateTime()));
        }

        return JSON.parseObject( new HttpHandler.Builder()
                .setUri(uri)
                .setPath(path)
                .setParams(requestParamMap)
                .build()
                .doPostWithParam());
    }

    /*
    插入或更改mat信息
     */
    private void insertOrUpdateMat(JSONObject jsonObject){
        List<MaterialInfo> dataList =  JSONObject.parseArray(jsonObject.getString("data"),MaterialInfo.class);
        //MaterialInfo data = jsonObject.getObject("data",MaterialInfo.class);
        dataList.forEach(data -> {
            Mat m = matService.selectByMatnr(data.getItemCode());
            if(m == null){
                m = new Mat();
                //m.setCreateTime(jsonObject.getDate("createDate"));
                matMapping(data,m);
                matService.insert(m);
            }else {
                matMapping(data,m);
                EntityWrapper<Mat> wrapper = new EntityWrapper<>();
                wrapper.eq("matnr",m.getMatnr());
                matService.update(m,wrapper);
            }
        });
    }

    /*
    映射mat和物料档案信息字段
     */
    private void matMapping(MaterialInfo data, Mat m){
        //
        m.setCreateTime((data.getMdate()));
        //修改时间 -- 更新时间
        m.setUpdateTime(new Date());
        //商品编码 -- 物料编码
        m.setMatnr(data.getItemCode());
        //商品名称 -- 物料名称
        m.setMaktx(data.getItemName());
        //规格 -- 规格
        m.setSpecs(data.getStd());
        //型号 -- 材质
        m.setModel(data.getMaterial());
        //品牌 -- 品牌
        m.setBrand(data.getBrand());
        //备注 --备注
        m.setMemo(data.getNote());
        //单位 -- 主单位
        m.setUnit(data.getUnitName());
        //品项数 -- 辅单位
        m.setItemNum(data.getAssUnitName());
        //单位量 -- 主辅关系
        m.setUnits(data.getRate() == null ? null : data.getRate().doubleValue());
        //长度 -- 宽
        m.setLength(data.getWidth() == null ? null : data.getWidth().doubleValue());
        //体积 -- 厚
        m.setVolume(data.getThickness() == null ? null : data.getThickness().doubleValue());

    }
}