package com.product.integration.service;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.google.common.collect.Maps;
import com.product.admin.service.PublicService;
import com.product.common.lang.StringUtils;
import com.product.core.dao.BaseDao;
import com.product.core.entity.DataTableEntity;
import com.product.core.entity.FieldSetEntity;
import com.product.core.spring.context.SpringMVCContextHolder;
import com.product.integration.config.CmnConst;
import com.product.integration.config.IntegrationCode;
import com.product.integration.service.idel.IInterfaceIntegrationService;
import com.product.util.BaseUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.Arrays;
import java.util.List;
import java.util.Map;

/**
 * 实现功能：
 *
 * @author 作者[夜丶光]
 * @version 1.0.00  2025-12-01 11:15
 */
@Service
public class InterfaceIntegrationService implements IInterfaceIntegrationService {
    @Autowired
    private BaseDao baseDao;
    @Autowired
    private PublicService publicService;

    /**
     * 查询数据
     * @param fse
     * @return
     */
    public FieldSetEntity find(FieldSetEntity fse) {
        FieldSetEntity integrationFse = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_INTERFACE_INTEGRATION, fse.getUUID(), true);
        DataTableEntity responseInfoDte = integrationFse.getSubDataTable(CmnConst.PRODUCT_SYS_INTERFACE_INTEGRATION_RESPONSE_INFO);
        Map<String, String> acceptKayMap = Maps.newHashMap();
        acceptKayMap.put("uuid", "front_uuid");
        JSONArray arr = BaseUtil.dataTableToTreeData(responseInfoDte, CmnConst.TRICODE, acceptKayMap, null, null);
        integrationFse.removeSubData(CmnConst.PRODUCT_SYS_INTERFACE_INTEGRATION_RESPONSE_INFO);
        integrationFse.setValue(CmnConst.PRODUCT_SYS_INTERFACE_INTEGRATION_RESPONSE_INFO, arr.toString());
        return integrationFse;
    }

    /**
     * 保存
     * @param fse
     * @return
     */
    @Override
    public String save(FieldSetEntity fse) {
        String responseInfo = fse.getString(CmnConst.PRODUCT_SYS_INTERFACE_INTEGRATION_RESPONSE_INFO);

        // 清理响应结构子表
        String uuid = fse.getUUID();
        if (!StringUtils.isEmpty(uuid)) {
            baseDao.delete(CmnConst.PRODUCT_SYS_INTERFACE_INTEGRATION_RESPONSE_INFO, String.format("%s=?", CmnConst.PARENT_UUID), new Object[]{uuid});
        }

        DataTableEntity responseInfoDte = dealResponseInfo(responseInfo);
        fse.addSubDataTable(responseInfoDte);
        return publicService.saveFieldSetEntity(fse);
    }
    /**
     * 处理响应数据结构
     * @param responseInfo  响应树结构子表信息
     * @return
     */
    private DataTableEntity dealResponseInfo(String responseInfo) {
        DataTableEntity responseInfoDte = new DataTableEntity();
        try {
            if (!StringUtils.isEmpty(responseInfo)) {
                saveDealResponseInfoPart(responseInfoDte, JSONArray.parseArray(responseInfo), "");
            }
        } catch (Exception e) {
            SpringMVCContextHolder.getSystemLogger().error(IntegrationCode.SAVE_DEAL_RESPONSE_INFO);
        }
        return responseInfoDte;
    }
    /**
     * 保存-处理响应数据结构-循环方法
     * @param responseInfoDte   存储容器，响应子表数据dte
     * @param responseInfoArr   响应子表数据待处理数组
     * @param parentCode        父编码
     */
    private void saveDealResponseInfoPart(DataTableEntity responseInfoDte, JSONArray responseInfoArr, String parentCode) {
        for (int i = 0; i < responseInfoArr.size(); i++) {
            JSONObject responseInfoObj = responseInfoArr.getJSONObject(i);
            FieldSetEntity fse = new FieldSetEntity(CmnConst.PRODUCT_SYS_INTERFACE_INTEGRATION_RESPONSE_INFO);
            List<String> passList = Arrays.asList("promptName", "children", "front_uuid");
            List<String> fieldList = Arrays.asList("name", "type", "db_info", "unique_sign");
            String code = String.format("%s%0" + 3 + "d", parentCode, i + 1);
            responseInfoObj.forEach((key, value) -> {
                if (!passList.contains(key)) {
                    fse.setValue(key, value);
                }
            });
            fieldList.forEach(fieldName -> {
                if (StringUtils.isEmpty(fse.getString(fieldName))) {
                    fse.setValue(fieldName, "");
                }
            });
            fse.setValue(CmnConst.TRICODE, code);
            responseInfoDte.addFieldSetEntity(fse);
            saveDealResponseInfoPart(responseInfoDte, responseInfoObj.getJSONArray(CmnConst.CHILDREN), code);
        }
    }
}