package com.malk.huagao.service.impl;


import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.malk.huagao.entity.*;
import com.malk.huagao.mapper.KdYdOrderDetailMapper;
import com.malk.huagao.mapper.KdYdOrderMapper;
import com.malk.huagao.mapper.KdYdOrderPaymentMapper;
import com.malk.huagao.service.IKdYdOrderService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.malk.server.aliwork.YDConf;
import com.malk.server.aliwork.YDParam;
import com.malk.server.dingtalk.DDR_New;
import com.malk.service.aliwork.YDClient;
import com.malk.utils.UtilMap;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.MDC;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;


import java.math.BigDecimal;
import java.math.RoundingMode;
import java.time.Instant;
import java.time.LocalDateTime;
import java.time.ZoneId;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;

/**
 * <p>
 * 服务实现类
 * </p>
 *
 * @author LQY
 * @since 2025-10-15
 */
@Service
public class KdYdOrderServiceImpl extends ServiceImpl<KdYdOrderMapper, KdYdOrder> implements IKdYdOrderService {
    @Autowired
    private YDClient ydClient;
    @Autowired
    private KdYdOrderMapper kdYdOrderMapper;
    @Autowired
    private KdYdOrderDetailMapper kdYdOrderDetailMapper;
    @Autowired
    private KdYdOrderPaymentMapper kdYdOrderPaymentMapper;


    @Override
    public void insertkdYdOrder(Map map) {
        MDC.put("MDC_KEY_PID", "1003");
        String formInstId = UtilMap.getString(map, "formInstId");
        String type = UtilMap.getString(map, "type");

        if ("3".equals(type)) {
            String bm = UtilMap.getString(map, "bm");
            KdYdOrder kdYdOrder = new KdYdOrder();
            kdYdOrder.setOperationType("3");
            kdYdOrder.setSyncStatus("0");
            kdYdOrderMapper.update(kdYdOrder, new LambdaQueryWrapper<KdYdOrder>().eq(KdYdOrder::getDjbh, bm));
            return; // 或者根据你的业务逻辑返回相应的结果
        }
        DDR_New ddrNew = ydClient.queryData(YDParam.builder()
                .formInstId(formInstId)
                .build(), YDConf.FORM_QUERY.retrieve_id);
        Map formData = ddrNew.getFormData();

        String djlx = UtilMap.getString(formData, "selectField_mejowmna");
        String khmc = UtilMap.getString(formData, "textField_mejnamf2");
        String djbh = UtilMap.getString(formData, "serialNumberField_mewfgzku");
        if("2".equals(type)){
             djbh = UtilMap.getString(formData, "textField_miwvnkep");
        }
        LocalDateTime rq = parseTimestamp(UtilMap.getString(formData, "dateField_mejowmnb"));
        String khxypj = UtilMap.getString(formData, "selectField_mewirdx4");
        String ywlx = UtilMap.getString(formData, "textField_mfxv2vfz");
        String xsy = UtilMap.getString(formData, "employeeField_mejowmng").replace("[\"", "").replace("\"]", "").trim();
        String xslx = UtilMap.getString(formData, "selectField_mejowmnc");
        String bzq = UtilMap.getString(formData, "selectField_mf6gyfkq");
        String xsbm = UtilMap.getString(formData, "departmentSelectField_mfxv2vfu").replace("[\"", "").replace("\"]", "").trim();
        String bz = UtilMap.getString(formData, "textareaField_mejnamfb");
        String jsbb = UtilMap.getString(formData, "selectField_mejowmnk");
        String sktj = UtilMap.getString(formData, "selectField_mgisux07");
        String zdzkestr = UtilMap.getString(formData, "numberField_mejowmni");
        BigDecimal zdzke = toBigDecimal(zdzkestr);
//        String fj = UtilMap.getString(formData, "attachmentField_mfoqcctz");
//        JSONArray array = JSONObject.parseArray(fj);
//        List<String> resultList = new ArrayList<>();
//        if(array != null){
//            for (int i = 0; i < array.size(); i++) {
//                JSONObject jsonObject = array.getJSONObject(i);
//                String url = jsonObject.getString("url");
//                String s = ydClient.convertTemporaryUrl(url, 3600000);
//                resultList.add(s);
//            }
//        }
//        if(StringUtils.isNotBlank(fj)){
//            List<Map> fjList =(List<Map>) JSON.parse(fj);
//            resultList.add(ydClient.convertTemporaryUrl(UtilMap.getString(fjList.get(0),"url"), 3600000));
//        }
        String sestr = UtilMap.getString(formData, "numberField_mfxv2vgh");
        BigDecimal se = toBigDecimal(sestr);
        String jestr = UtilMap.getString(formData, "numberField_mfxv2vgj");
        BigDecimal je = toBigDecimal(jestr);
        String jshjstr = UtilMap.getString(formData, "numberField_mewfgzkv");
        BigDecimal jshj = toBigDecimal(jshjstr);
        String sfhs = UtilMap.getString(formData, "radioField_mfxv2vg4");
        String jws = UtilMap.getString(formData, "radioField_mfxv2vgm");
        List<Map> tableField = (List<Map>) formData.get("tableField_mfbx1pqi");
        List<Map> tableFieldPayment = (List<Map>) formData.get("tableField_mhiui6v5");
        KdYdOrder kdYdOrder = new KdYdOrder();
        kdYdOrder.setDjlx(djlx);
        kdYdOrder.setDjbh(djbh);
        kdYdOrder.setKhmc(khmc);
        kdYdOrder.setRq(rq);
        kdYdOrder.setKhxypj(khxypj);
        kdYdOrder.setYwlx(ywlx);
        kdYdOrder.setXslx(xslx);
        kdYdOrder.setBzq(bzq);
        kdYdOrder.setXsy(xsy);
        kdYdOrder.setXsbm(xsbm);
        kdYdOrder.setBz(bz);
        kdYdOrder.setJsbb(jsbb);
        kdYdOrder.setSktj(sktj);
        kdYdOrder.setZdzke(zdzke);
        kdYdOrder.setSe(se);
        kdYdOrder.setJe(je);
        kdYdOrder.setJshj(jshj);
        kdYdOrder.setSfhs(sfhs);
        kdYdOrder.setJws(jws);
        kdYdOrder.setSyncStatus("0");
        kdYdOrder.setOperationType("1");
//        kdYdOrder.setForminstid(formInstId);
        if ("2".equals(type)) {
            kdYdOrder.setOperationType(type);
            kdYdOrderMapper.update(kdYdOrder, new LambdaQueryWrapper<KdYdOrder>().eq(KdYdOrder::getDjbh, djbh));
        } else {
            kdYdOrderMapper.insert(kdYdOrder);
        }

        Long id = kdYdOrder.getId();
        int count = 1;
        for (Map item : tableField) {

            String wlbm = safeGetString(item, "textField_mfbx1pqt");
            String wlmc = safeGetString(item, "textField_mfbx1pqs");
            String ggxh = safeGetString(item, "textField_mfbx1pqr");
            String xsdw = safeGetString(item, "textField_mfbx1pqq");
            int xssl = parseInt(safeGetString(item, "numberField_mfbx1pr4"), 0); // 如果为空或格式错误，返回 0
            String ssxl = safeGetString(item, "selectField_mfbx1pr1");
            BigDecimal dj = toBigDecimal(safeGetString(item, "numberField_mfbx1prf"));
            BigDecimal hsdj = toBigDecimal(safeGetString(item, "numberField_mfbx1prg"));
            String sfzp = safeGetString(item, "radioField_mfbx1prc");
            int sl = parseInt(safeGetString(item, "numberField_mfbx1prb"), 0);
            BigDecimal zse = toBigDecimal(safeGetString(item, "numberField_mfbx1prh"));
            BigDecimal zje = toBigDecimal(safeGetString(item, "numberField_mfbx1pri"));
            BigDecimal zjshj = toBigDecimal(safeGetString(item, "numberField_mfbx1prj"));
            BigDecimal jj = toBigDecimal(safeGetString(item, "numberField_mfbx1prk"));
            BigDecimal zkl = toBigDecimal(safeGetString(item, "numberField_mfbx1pru"));
            BigDecimal zke = toBigDecimal(safeGetString(item, "numberField_mfbx1prt"));
            LocalDateTime yhrq = parseTimestamp(UtilMap.getString(item, "dateField_mfbx1prs"));
            BigDecimal xsjzj = toBigDecimal(safeGetString(item, "numberField_mfbx1pr0"));
            String zmzs = safeGetString(item, "textField_mfxv2vgv");
            KdYdOrderDetail kdYdOrderDetail = new KdYdOrderDetail();
            kdYdOrderDetail.setOrderId(id);
            kdYdOrderDetail.setWlbm(wlbm);
            kdYdOrderDetail.setWlmc(wlmc);
            kdYdOrderDetail.setGgxh(ggxh);
            kdYdOrderDetail.setXsdw(xsdw);
            kdYdOrderDetail.setXssl(xssl);
            kdYdOrderDetail.setSsxl(ssxl);
            kdYdOrderDetail.setDj(dj);
            kdYdOrderDetail.setHsdj(hsdj);
            kdYdOrderDetail.setSfzp(sfzp);
            kdYdOrderDetail.setSl(sl);
            kdYdOrderDetail.setSe(zse);
            kdYdOrderDetail.setJe(zje);
            kdYdOrderDetail.setJshj(zjshj);
            kdYdOrderDetail.setJj(jj);
            kdYdOrderDetail.setZkl(zkl);
            kdYdOrderDetail.setZke(zke);
            kdYdOrderDetail.setYhrq(yhrq);
            kdYdOrderDetail.setXsjzj(xsjzj);
            kdYdOrderDetail.setDetailId(count);
            kdYdOrderDetail.setSmzs(zmzs);
            kdYdOrderDetail.setSyncStatus("0");
            kdYdOrderDetail.setOperationType("1");
//            kdYdOrderDetail.setForminstid(formInstId);
            if ("2".equals(type) || "3".equals(type)) {
                kdYdOrderDetail.setOperationType(type);
                kdYdOrderDetailMapper.update(kdYdOrderDetail, new LambdaQueryWrapper<KdYdOrderDetail>()
                        .eq(KdYdOrderDetail::getWlbm, wlbm)
                        .eq(KdYdOrderDetail::getOrderId, id));
            } else {
                kdYdOrderDetailMapper.insert(kdYdOrderDetail);
            }
            count++;
        }
        if (tableFieldPayment != null) {
            for (int i = 0; i < tableFieldPayment.size(); i++) {
                Map row = tableFieldPayment.get(i);
                String sfys = safeGetString(row, "radioField_mhiui6v7");
                String gldh = safeGetString(row, "textField_mhiui6va");
                BigDecimal ysbl = toBigDecimal(UtilMap.getString(row, "numberField_mhiui6v6"));
                BigDecimal ysje = toBigDecimal(UtilMap.getString(row, "numberField_mhiui6v8"));
                BigDecimal ssje = toBigDecimal(UtilMap.getString(row, "numberField_mhiui6vb"));
                int detailId = i + 1;
                LocalDateTime endTime = parseTimestamp(UtilMap.getString(row, "dateField_mhiui6v9"));
                KdYdOrderPayment kdYdOrderPayment = new KdYdOrderPayment();
                kdYdOrderPayment.setOrderId(id);
                kdYdOrderPayment.setSfys(sfys);
                kdYdOrderPayment.setGldh(gldh);
                kdYdOrderPayment.setYsbl(ysbl);
                kdYdOrderPayment.setYsje(ysje);
                kdYdOrderPayment.setSsje(ssje);
                kdYdOrderPayment.setDetailId(detailId);
                kdYdOrderPayment.setEndTime(endTime);
                kdYdOrderPayment.setSyncStatus("0");
                kdYdOrderPayment.setOperationType("1");
                if ("2".equals(type) || "3".equals(type)) {
                    kdYdOrderPayment.setOperationType(type);
                    kdYdOrderPaymentMapper.update(kdYdOrderPayment, new LambdaQueryWrapper<KdYdOrderPayment>()
                            .eq(KdYdOrderPayment::getDetailId, detailId)
                            .eq(KdYdOrderPayment::getOrderId, id));
                } else {
                    kdYdOrderPaymentMapper.insert(kdYdOrderPayment);
                }
            }
        }
//        ydClient.operateData(
//                YDParam.builder()
//                        .formInstanceId(formInstId)
//                        .updateFormDataJson(JSONObject.toJSONString(UtilMap.map("textField_mgrmn66f", id)))
//                        .useLatestVersion(true).build(), YDConf.FORM_OPERATION.update);

    }

    private static LocalDateTime parseTimestamp(String timestampStr) {
        if (timestampStr == null || timestampStr.trim().isEmpty()) return null;
        try {
            long timestamp = Long.parseLong(timestampStr.trim());
            return LocalDateTime.ofInstant(
                    Instant.ofEpochMilli(timestamp),
                    ZoneId.systemDefault()
            );
        } catch (NumberFormatException e) {
            return null;
        }
    }

    private static int parseInt(String str, int defaultValue) {
        if (str == null || str.trim().isEmpty()) {
            return defaultValue;
        }
        try {
            return Integer.parseInt(str.trim());
        } catch (NumberFormatException e) {
            return defaultValue;
        }
    }

    private String safeGetString(Map formData, String key) {
        Object val = formData.get(key);
        return val == null ? "" : String.valueOf(val);
    }

    public static BigDecimal toBigDecimal(String str) {
        if (str == null || str.trim().isEmpty()) {
            return BigDecimal.ZERO.setScale(2, RoundingMode.HALF_UP);
        }
        try {
            return new BigDecimal(str.trim())
                    .setScale(2, RoundingMode.HALF_UP);
        } catch (NumberFormatException e) {
            // 返回默认值而不是抛出异常，避免程序中断
            return BigDecimal.ZERO.setScale(2, RoundingMode.HALF_UP);
        }
    }

    /**
     * 重载方法，支持Number类型输入
     */
    public static BigDecimal toBigDecimal(Number number) {
        if (number == null) {
            return BigDecimal.ZERO.setScale(2, RoundingMode.HALF_UP);
        }
        return new BigDecimal(number.toString())
                .setScale(2, RoundingMode.HALF_UP);
    }
}