package com.zy.asrs.task.handler;

import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.baomidou.mybatisplus.plugins.Page;
import com.core.common.Cools;
import com.core.common.DateUtils;
import com.zy.asrs.entity.*;
import com.zy.asrs.service.*;
import com.zy.asrs.task.core.ReturnT;
import com.zy.common.constant.OpenApiAddressConstant;
import com.zy.common.utils.HttpHandler;
import com.zy.system.entity.Config;
import com.zy.system.service.ConfigService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import javax.annotation.PostConstruct;
import javax.annotation.Resource;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;

/**
 * @author pang.jiabao
 * @description 冠鸿龙南定时任务具体实现
 * @createDate 2024/7/10 9:28
 */
@Slf4j
@Service
public class GhlnHandler {

    @Resource
    private WrkMastService wrkMastService;

    @Resource
    private BasDevpService basDevpService;

    @Resource
    private WrkDetlService wrkDetlService;

    @Autowired
    private ApiLogService apiLogService;

    @Autowired
    private LoginAuthHandler loginAuthHandler;

    @Resource
    private MatService matService;

    @Autowired
    private LocDetlService locDetlService;

    @Autowired
    private ConfigService configService;

    /**
     * 调用金蝶同步物料接口，增量同步每小时产生的新物料
     */
    public void syncMat() {

        //登录金蝶
        ReturnT<String> start = loginAuthHandler.start();

        //条件和需要获得的结果拼接
        JSONObject jsonObject = new JSONObject();
        jsonObject.put("FormId", "BD_MATERIAL");
        jsonObject.put("OrderString", "");
        jsonObject.put("TopRowCount", 0);
        jsonObject.put("Limit", 3000);
        jsonObject.put("StartRow", "0");
        jsonObject.put("SubSystemId", "");
        // 获取当前时间
        LocalDateTime currentDateTime = LocalDateTime.now();
        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
        // 获取当前时间的前一小时整点时间
        LocalDateTime oneHourAgo = currentDateTime.minusHours(1).withMinute(0).withSecond(0).withNano(0);
        jsonObject.put("FilterString", "FCreateDate <= '2022-08-23 13:37:00'");
//        jsonObject.put("FilterString", "FCreateDate >= '"+oneHourAgo.format(formatter)+"' and FUseOrgId .FNumber='10004'");
//        jsonObject.put("FilterString","FNumber = '0101010003'");
        jsonObject.put("FieldKeys", "FNumber,FName,FCreateDate,FTypeID");

        JSONObject jsonObject1 = new JSONObject();
        jsonObject1.put("data", jsonObject);
        String add = jsonObject1.toJSONString();

        String response = "";
        boolean success = false;
        String url = "http://192.168.16.7";
        String address = "K3CLOUD/Kingdee.BOS.WebApi.ServicesStub.DynamicFormService.ExecuteBillQuery.common.kdsvc";
        try {
            //获取Cookie值
            HashMap<String, Object> headers = new HashMap<>();
            headers.put("Cookie", start.getContent());
            response = new HttpHandler.Builder()
                    .setHeaders(headers)
                    .setUri(url)
                    .setPath(address)
                    .setJson(add)
                    .build()
                    .doPost();
            String[] tempstr;
            if (!"[]".equals(response)) {
                String[] returnstr = response.split("],");
                int count = 0;
                log.info("--------调用金蝶同步物料信息开始--------");
                for (int i = 0; i < returnstr.length; i++) {
                    Mat mat = new Mat();
                    tempstr = returnstr[i].split(",");
                    if (i == 0) {
                        mat.setMatnr(tempstr[0].substring(2));  //物料编码
                    } else {
                        mat.setMatnr(tempstr[0].substring(1));  //物料编码
                    }
                    mat.setMaktx(tempstr[1]); //  物料名称
                    mat.setTagId(Long.valueOf(tempstr[3].substring(0, 1))); // 物料分类
                    mat.setCreateTime(new Date());//商品创建时间
                    mat.setUpdateTime(new Date());
                    mat.setStatus(1);
                    try {
                        matService.insert(mat);
                        count++;
                    } catch (Exception e) {
                        log.error("金蝶同步物料异常：{}", mat);
                    }
                }
                log.info("----调用金蝶同步物料信息结果：总{},成{}--------", returnstr.length, count);
                success = true;
            }
        } catch (Exception e) {
            log.error("fail", e);
        } finally {
            try {
                // 保存接口日志
                apiLogService.save(
                        "请求金蝶同步物料信息",
                        url + address,
                        null,
                        "127.0.0.1",
                        add,
                        response,
                        success
                );
            } catch (Exception e) {
                log.error("", e);
            }
        }
    }

    /**
     * 到达出库口，呼叫agv
     */
    public void OutboundCallAGV() {
        BasDevp basDevp = basDevpService.selectOne(new EntityWrapper<BasDevp>().setSqlSelect("wrk_no as wrkNo", "loading", "autoing", "out_enable as outEnable").eq("dev_no", 210));
        if (basDevp.getWrkNo() > 6000 && basDevp.getWrkNo() <= 9000 && basDevp.getLoading().equals("Y") && basDevp.getAutoing().equals("Y")) { // 出库工作档
            WrkMast wrkMast = wrkMastService.selectById(basDevp.getWrkNo());
            if (wrkMast.getWhsType() == null) {
                WrkDetl wrkDetl = wrkDetlService.selectOne(new EntityWrapper<WrkDetl>().eq("wrk_no", basDevp.getWrkNo()));
                // 调用结果
                boolean success = false;
                // 构造请求头
                Map<String, Object> headers = new HashMap<>();
                headers.put("Content-Type", "application/json;charset=UTF-8");
                // 构造请求体
                JSONObject jsonObject = new JSONObject();
                jsonObject.put("matnr", wrkDetl.getMatnr()); // 物料编码
                jsonObject.put("model", wrkDetl.getModel()); // 型号
                jsonObject.put("batch", wrkDetl.getBatch()); // 批次
                jsonObject.put("specs", wrkDetl.getSpecs()); // 膜类型
                jsonObject.put("manuDate", wrkDetl.getManuDate()); // 生产日期
                jsonObject.put("length", wrkDetl.getLength() + ""); // 长
                jsonObject.put("weight", wrkDetl.getWeight() + ""); // 宽
                jsonObject.put("volume", wrkDetl.getVolume() + ""); // 面积
                String body = jsonObject.toString();
                String response = "";
                try {
                    response = new HttpHandler.Builder()
                            .setUri(OpenApiAddressConstant.AGV_IP)
                            .setPath(OpenApiAddressConstant.CALL_AGV_URL)
                            .setHeaders(headers)
                            .setJson(body)
                            .build()
                            .doPost();
                    if (!Cools.isEmpty(response)) {
                        JSONObject jsonObject1 = JSONObject.parseObject(response);
                        if ((Integer) jsonObject1.get("code") == 200) {
                            success = true;
                            wrkMast.setWhsType(1);
                            wrkMastService.updateById(wrkMast);
                        }
                    } else {
                        log.error("出库呼叫agv接口异常接口失败！！！url：{}；request：{}；response：{}", OpenApiAddressConstant.AGV_IP + OpenApiAddressConstant.CALL_AGV_URL, body, response);
                    }
                } catch (Exception e) {
                    log.error("出库呼叫agv接口异常：{}", e.getMessage());
                } finally {
                    try {
                        // 保存接口日志
                        apiLogService.save(
                                "出库请求agv",
                                OpenApiAddressConstant.AGV_IP + OpenApiAddressConstant.CALL_AGV_URL,
                                null,
                                "127.0.0.1",
                                jsonObject.toJSONString(),
                                response,
                                success
                        );
                    } catch (Exception e) {
                        log.error("出库呼叫agv接口日志异常", e);
                    }
                }
            }
        }
    }

    public void start() {
        long time = System.currentTimeMillis();
        Config config = configService.selectConfigByCode("EXPIREDDAY");
        long day = 180;
        if (config != null) {
            day = Long.parseLong(config.getValue());
        }
        Config config2 = configService.selectConfigByCode("durationOfFilmRollControl");
        long day2 = Long.parseLong(config2.getValue());
        Page<LocDetl> frozen = locDetlService.selectPage(new Page<>(0, 10000), new EntityWrapper<LocDetl>().isNull("sku").orderBy("manu_date"));
        for (LocDetl locDetl : frozen.getRecords()) {
            String manuDate = locDetl.getManuDate();
            Date yyyyMMdd = DateUtils.convert(manuDate, "yyyyMMdd");
            if ((time - yyyyMMdd.getTime()) > day * 24 * 60 * 60 * 1000) {
                locDetl.setFrozen(1);
                locDetlService.update(locDetl, new EntityWrapper<LocDetl>().eq("loc_no", locDetl.getLocNo()).eq("matnr", locDetl.getMatnr()).eq("batch", locDetl.getBatch()));
            } else if ((time - yyyyMMdd.getTime()) > day2 * 24 * 60 * 60 * 1000) {
                locDetl.setFrozen(2);
                locDetlService.update(locDetl, new EntityWrapper<LocDetl>().eq("loc_no", locDetl.getLocNo()).eq("matnr", locDetl.getMatnr()).eq("batch", locDetl.getBatch()));
            }
        }
    }

    @PostConstruct
    public void start2() {
        long time = System.currentTimeMillis();
        Config config = configService.selectConfigByCode("EXPIREDDAY");
        long day = 180;
        if (config != null) {
            day = Long.parseLong(config.getValue());
        }
        Config config2 = configService.selectConfigByCode("durationOfFilmRollControl");
        long day2 = Long.parseLong(config2.getValue());
        Page<LocDetl> frozen = locDetlService.selectPage(new Page<>(0, 10000), new EntityWrapper<LocDetl>().isNull("sku").orderBy("manu_date"));
        for (LocDetl locDetl : frozen.getRecords()) {
            String manuDate = locDetl.getManuDate();
            Date yyyyMMdd = DateUtils.convert(manuDate, "yyyyMMdd");
            if ((time - yyyyMMdd.getTime()) > day * 24 * 60 * 60 * 1000) {
                locDetl.setFrozen(1);
                locDetlService.update(locDetl, new EntityWrapper<LocDetl>().eq("loc_no", locDetl.getLocNo()).eq("matnr", locDetl.getMatnr()).eq("batch", locDetl.getBatch()));
            } else if ((time - yyyyMMdd.getTime()) > day2 * 24 * 60 * 60 * 1000) {
                locDetl.setFrozen(2);
                locDetlService.update(locDetl, new EntityWrapper<LocDetl>().eq("loc_no", locDetl.getLocNo()).eq("matnr", locDetl.getMatnr()).eq("batch", locDetl.getBatch()));
            }
        }
    }
}