package com.zy.asrs.service.impl;

import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.zy.asrs.mapper.ErpTokenMapper;
import com.zy.asrs.entity.ErpToken;
import com.zy.asrs.service.ErpTokenService;
import com.baomidou.mybatisplus.service.impl.ServiceImpl;
import com.core.common.Cools;
import com.zy.common.utils.HttpHandler;
import com.zy.system.entity.Config;
import com.zy.system.service.ConfigService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.net.URI;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;

@Service("erpTokenService")
public class ErpTokenServiceImpl extends ServiceImpl<ErpTokenMapper, ErpToken> implements ErpTokenService {

    @Autowired
    private ConfigService configService;

    @Override
    public JSONObject refreshToken() {
        String appId = getConfigValue("ErpAppId", "jxlk");
        String appSecrect = getConfigValue("ErpAppSecrect", "jxlk123@jxlk");
        String url = getConfigValue("ErpTokenUrl", "http://127.0.0.1:8080/thb-cloud/rest");

        JSONObject result = callRest(url, buildTokenParams(appId, appSecrect));
        if (result == null) {
            return error("ERP token获取失败：空响应");
        }
        if (!Boolean.TRUE.equals(result.getBoolean("success"))) {
            return result;
        }
        JSONObject data = result.getJSONObject("data");
        String token = data == null ? null : data.getString("access_token");
        if (Cools.isEmpty(token)) {
            return error("ERP token获取失败：响应未包含access_token");
        }
        Date now = new Date();
        this.baseMapper.upsertToken(appId, appSecrect, token, now);
        return result;
    }

    @Override
    public String getAccessToken() {
        String appId = getConfigValue("ErpAppId", "jxlk");
        ErpToken one = this.selectOne(new EntityWrapper<ErpToken>().eq("app_id", appId));
        if (one != null && !Cools.isEmpty(one.getToken())) {
            return one.getToken();
        }
        JSONObject refreshed = refreshToken();
        if (refreshed == null || !Boolean.TRUE.equals(refreshed.getBoolean("success"))) {
            return null;
        }
        ErpToken again = this.selectOne(new EntityWrapper<ErpToken>().eq("app_id", appId));
        return again == null ? null : again.getToken();
    }

    @Override
    public JSONObject stockIn(String labelno) {
        return callWareApi("stockIn", params -> {
            params.put("labelno", labelno);
        });
    }

    @Override
    public JSONObject stockOut(String labelno, String tlocation) {
        return callWareApi("stockOut", params -> {
            params.put("labelno", labelno);
            params.put("tlocation", Cools.isEmpty(tlocation) ? "W001" : tlocation);
        });
    }

    @Override
    public JSONObject stockBack(String labelno, Double qty, String tlocation) {
        return callWareApi("stockBack", params -> {
            params.put("labelno", labelno);
            params.put("qty", qty);
            params.put("tlocation", Cools.isEmpty(tlocation) ? "RW" : tlocation);
        });
    }

    private JSONObject callWareApi(String eventcode, ParamAppender appender) {
        String url = getConfigValue("ErpTokenUrl", "http://127.0.0.1:8080/thb-cloud/rest");
        String appId = getConfigValue("ErpAppId", "jxlk");
        String token = getAccessToken();
        if (Cools.isEmpty(token)) {
            return error("ERP access_token为空");
        }
        Map<String, Object> params = new HashMap<>();
        params.put("funid", "ware_api");
        params.put("eventcode", eventcode);
        params.put("user_code", appId);
        params.put("access_token", token);
        appender.append(params);
        JSONObject result = callRest(url, params);
        if (result != null) {
            return result;
        }
        return error("ERP接口调用失败：空响应");
    }

    private Map<String, Object> buildTokenParams(String appId, String appSecrect) {
        Map<String, Object> params = new HashMap<>();
        params.put("funid", "rest_app");
        params.put("eventcode", "get_token");
        params.put("user_code", appId);
        params.put("appid", appId);
        params.put("appsecrect", appSecrect);
        return params;
    }

    private JSONObject callRest(String url, Map<String, Object> params) {
        try {
            URI uri = URI.create(url);
            String host = uri.getHost();
            int port = uri.getPort();
            String scheme = uri.getScheme();
            String path = uri.getRawPath();
            if (Cools.isEmpty(host) || Cools.isEmpty(scheme) || Cools.isEmpty(path)) {
                return error("ERP接口地址配置错误：" + url);
            }
            String base = host + (port > 0 ? ":" + port : "");
            String resp = new HttpHandler.Builder()
                    .setUri(base)
                    .setHttps("https".equalsIgnoreCase(scheme))
                    .setPath(path)
                    .setParams(params)
                    .build()
                    .doPost();
            if (Cools.isEmpty(resp)) {
                return null;
            }
            return JSONObject.parseObject(resp);
        } catch (Exception e) {
            return error("ERP接口调用异常：" + e.getMessage());
        }
    }

    private String getConfigValue(String code, String defaultValue) {
        try {
            Config config = configService.selectConfigByCode(code);
            if (config != null && !Cools.isEmpty(config.getValue())) {
                return String.valueOf(config.getValue()).trim();
            }
        } catch (Exception ignored) {
        }
        return defaultValue;
    }

    private JSONObject error(String msg) {
        JSONObject obj = new JSONObject();
        obj.put("success", false);
        obj.put("message", msg);
        return obj;
    }

    private interface ParamAppender {
        void append(Map<String, Object> params);
    }
}