cont/mjava-huagao/src/main/java/com/malk/huagao/service/impl/YdHuaGaoServiceImpl.java

package com.malk.huagao.service.impl;

import cn.hutool.core.util.ObjectUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.malk.huagao.entity.*;
import com.malk.huagao.mapper.*;
import com.malk.huagao.service.YdHuaGaoService;
import com.malk.server.aliwork.YDConf;
import com.malk.server.aliwork.YDParam;
import com.malk.server.aliwork.YDSearch;
import com.malk.server.dingtalk.DDConf;
import com.malk.service.aliwork.YDClient;
import com.malk.utils.UtilMap;
import lombok.extern.slf4j.Slf4j;
import org.checkerframework.checker.units.qual.A;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.math.BigDecimal;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.*;
import java.util.stream.Collectors;

@Slf4j
@Service
public class YdHuaGaoServiceImpl implements YdHuaGaoService {
    @Autowired
    private KdYdCustomerMapper kdYdCustomerMapper;
    @Autowired
    private YDClient ydClient;
    @Autowired
    private KdYdCustomerReferrerMapper kdYdCustomerReferrerMapper;
    @Autowired
    private KdYdOrderMapper kdYdOrderMapper;
    @Autowired
    private KdYdDeliveryMapper kdYdDeliveryMapper;
    @Autowired
    private KdYdOutboundMapper kdYdOutboundMapper;
    @Autowired
    private KdYdReceivableMapper kdYdReceivableMapper;
    @Autowired
    private KdYdOutboundDetailMapper kdYdOutboundDetailMapper;
    @Autowired
    private KdYdReceivableDetailMapper kdYdReceivableDetailMapper;
    @Autowired
    private KdYdDeliveryDetailMapper kdYdDeliveryDetailMapper;
    @Autowired
    private KdYdPaymentReceiptDetailMapper kdYdPaymentReceiptDetailMapper;
    @Autowired
    private KdYdPaymentReceiptMapper kdYdPaymentReceiptMapper;
    @Autowired
    private KdYdReceivalablePaymentMapper kdYdReceivalablePaymentMapper;
    @Autowired
    private KdYdZpMapper kdYdZpMapper;
    @Autowired
    private KdYdMaterialMapper kdYdMaterialMapper;
    @Autowired
    private YDConf ydConf;
    @Autowired
    private DDConf ddConf;

    @Override
    public void syncKdYdCustomer() {

    }

    @Override
    public void syncKdYDcustomerLiaison() {
        log.info("定时同步-客户推荐人");
        try {

            LocalDateTime now = LocalDateTime.now();
            LocalDateTime fiveMinutesAgo = now.minusMinutes(5);
            DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
            List<KdYdCustomerReferrer> KdYdCustomerReferrers = kdYdCustomerReferrerMapper.selectRecentUpdated(fiveMinutesAgo);
            if (KdYdCustomerReferrers.isEmpty()) {
                log.info("【客户推荐人同步任务】无需要同步的数据，结束");
                return;
            }

            for (KdYdCustomerReferrer kdYdCustomerReferrer : KdYdCustomerReferrers) {
                try {
                    String bm = kdYdCustomerReferrer.getBm();
                    String tjruuid = kdYdCustomerReferrer.getTjruuid();
                    String formInstId = kdYdCustomerReferrer.getFormInstId();
                    if (ObjectUtil.hasEmpty(formInstId, bm)) {
                        log.warn("跳过同步: formInstId 或 khbm 为空, customer={}", kdYdCustomerReferrer.getId());
                        continue;
                    }
//                    if (tjruuid == null) {
//            List<Map> khdata = (List<Map>) ydClient.queryData(
//                    YDParam.builder()
//                            .formUuid("FORM-68154CC0A7054BF0B1C933752CD3881FB0SR")
//                            .searchFieldJson(JSONObject.toJSONString(UtilMap.map("textField_mgqbiov3", tjruuid)))
//                            .build(),
//                    YDConf.FORM_QUERY.retrieve_list_all
//            ).getData();
//            if (khdata.size() > 0) {
//                 khbm = UtilMap.getString(khdata.get(0), "textField_meqhqqvg");
//            }
////        }
//                    LambdaQueryWrapper<KdYdCustomer> YdCustomerLambdaQueryWrapper = new LambdaQueryWrapper<>();
//                    YdCustomerLambdaQueryWrapper.eq(KdYdCustomer::getTjruuid, tjruuid);
//                    KdYdCustomer kdYdCustomer1 = kdYdCustomerMapper.selectOne(YdCustomerLambdaQueryWrapper);
//                    String formInstId1 = kdYdCustomer1.getFormInstId();
//                    ydClient.operateData(
//                            YDParam.builder()
//                                    .formInstanceId(formInstId1)
//                                    .updateFormDataJson(JSONObject.toJSONString(UtilMap.map("textField_mfdrrg87", bm)))
//                                    .useLatestVersion(true).build(), YDConf.FORM_OPERATION.update);
                    ydClient.operateData(
                            YDParam.builder()
                                    .formInstanceId(formInstId)
                                    .updateFormDataJson(JSONObject.toJSONString(UtilMap.map("textField_mgqbiouy", bm)))
                                    .useLatestVersion(true).build(), YDConf.FORM_OPERATION.update);

                } catch (Exception e) {
                    log.error("同步单条客户推荐人数据异常: formInstId={}", kdYdCustomerReferrer.getFormInstId(), e);
                }
            }

            log.info("【客户推荐人同步任务】执行完成，共处理 {} 条记录", KdYdCustomerReferrers.size());
        } catch (Exception e) {
            log.error("【客户推荐人同步任务】执行过程中发生严重错误", e);
        }
    }

    @Override
    public void syncKdYdOrder() {
        log.info("定时同步-订单");
        try {

            LocalDateTime now = LocalDateTime.now();
            LocalDateTime fiveMinutesAgo = now.minusMinutes(5);
            DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
            List<KdYdOrder> KdYdOrders = kdYdOrderMapper.selectRecentUpdated(fiveMinutesAgo);
            if (KdYdOrders.isEmpty()) {
                log.info("【订单同步任务】无需要同步的数据，结束");
                return;
            }

            for (KdYdOrder kdYdOrder : KdYdOrders) {
                try {
                    String bm = kdYdOrder.getDjbh();
//                    String tjruuid = kdYdOrder.getTjruuid();
//                    String formInstId = kdYdOrder.getForminstid();
//                    if (ObjectUtil.hasEmpty(formInstId, bm)) {
//                        log.warn("跳过同步: formInstId 或 khbm 为空, customer={}", kdYdOrder.getId());
//                        continue;
//                    }
//                    if (tjruuid == null) {
//            List<Map> khdata = (List<Map>) ydClient.queryData(
//                    YDParam.builder()
//                            .formUuid("FORM-68154CC0A7054BF0B1C933752CD3881FB0SR")
//                            .searchFieldJson(JSONObject.toJSONString(UtilMap.map("textField_mgqbiov3", tjruuid)))
//                            .build(),
//                    YDConf.FORM_QUERY.retrieve_list_all
//            ).getData();
//            if (khdata.size() > 0) {
//                 khbm = UtilMap.getString(khdata.get(0), "textField_meqhqqvg");
//            }
////        }
//                    LambdaQueryWrapper<KdYdCustomer> YdCustomerLambdaQueryWrapper = new LambdaQueryWrapper<>();
//                    YdCustomerLambdaQueryWrapper.eq(KdYdCustomer::getTjruuid, tjruuid);
//                    KdYdCustomer kdYdCustomer1 = kdYdCustomerMapper.selectOne(YdCustomerLambdaQueryWrapper);
//                    String formInstId1 = kdYdCustomer1.getFormInstId();
//                    ydClient.operateData(
//                            YDParam.builder()
//                                    .formInstanceId(formInstId1)
//                                    .updateFormDataJson(JSONObject.toJSONString(UtilMap.map("textField_mfdrrg87", bm)))
//                                    .useLatestVersion(true).build(), YDConf.FORM_OPERATION.update);
                    ydClient.operateData(
                            YDParam.builder()
//                                    .formInstanceId(formInstId)
                                    .updateFormDataJson(JSONObject.toJSONString(UtilMap.map("textField_mg327tqe", bm)))
                                    .useLatestVersion(true).build(), YDConf.FORM_OPERATION.update);

                } catch (Exception e) {
//                    log.error("同步单条订单数据异常: formInstId={}", kdYdOrder.getForminstid(), e);
                }
            }

            log.info("【订单同步任务】执行完成，共处理 {} 条记录", KdYdOrders.size());
        } catch (Exception e) {
            log.error("【订单同步任务】执行过程中发生严重错误", e);
        }
    }

    @Override
    public void syncKdYdDelivery() {
        log.info("定时同步-发货单");
        try {

            LocalDateTime now = LocalDateTime.now();
            LocalDateTime fiveMinutesAgo = now.minusMinutes(5);
            DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
            List<KdYdDelivery> KdYdDeliverys = kdYdDeliveryMapper.selectRecentUpdated(fiveMinutesAgo);
            if (KdYdDeliverys.isEmpty()) {
                log.info("【发货单同步任务】无需要同步的数据，结束");
                return;
            }

            for (KdYdDelivery kdYdDelivery : KdYdDeliverys) {
                try {
                    String djbh = kdYdDelivery.getDjbh();
//                    String tjruuid = kdYdOrder.getTjruuid();
//                    String formInstId = kdYdDelivery.getForminstid();
//                    if (ObjectUtil.hasEmpty(formInstId, djbh)) {
//                        log.warn("跳过同步: formInstId 或 khbm 为空, customer={}", kdYdDelivery.getId());
//                        continue;
//                    }

                    ydClient.operateData(
                            YDParam.builder()
//                                    .formInstanceId(formInstId)
                                    .updateFormDataJson(JSONObject.toJSONString(UtilMap.map("textField_mg3fuqvh", djbh)))
                                    .useLatestVersion(true).build(), YDConf.FORM_OPERATION.update);

                } catch (Exception e) {
//                    log.error("同步单条发货单数据异常: formInstId={}", kdYdDelivery.getForminstid(), e);
                }
            }

            log.info("【发货单同步任务】执行完成，共处理 {} 条记录", KdYdDeliverys.size());
        } catch (Exception e) {
            log.error("【发货单同步任务】执行过程中发生严重错误", e);
        }
    }


    @Override
    public void synckdYdOutbound() {
        log.info("定时同步-出库单");
        // 查询需要删除的数据
        LambdaQueryWrapper<KdYdOutbound> outbounddel = new LambdaQueryWrapper<>();
        outbounddel.eq(KdYdOutbound::getOperationType, 3)
                .eq(KdYdOutbound::getSyncStatus, "0");
        List<KdYdOutbound> kdYdOutbounddels = kdYdOutboundMapper.selectList(outbounddel);

        // 批量删除处理
        if (!kdYdOutbounddels.isEmpty()) {
            log.info("开始处理出库单删除操作，共{}条数据", kdYdOutbounddels.size());
            ArrayList<String> deleteList = new ArrayList<>();
            int deleteSuccessCount = 0;

            for (KdYdOutbound kdYdOutbound : kdYdOutbounddels) {
                try {
                    String djbh = kdYdOutbound.getDjbh();

                    List<Map> list1 = (List<Map>) ydClient.queryData(YDParam.builder()
                            .formUuid("FORM-AADBCDA8126F41A0ADDEE3353828583192M8")
                            .searchCondition(JSONObject.toJSONString(UtilMap.map("textField_mg34txgm", djbh)))
                            .build(), YDConf.FORM_QUERY.retrieve_list_all).getData();

                    if (list1 != null && !list1.isEmpty()) {
                        for (Map map : list1) {
                            String formInstanceId = UtilMap.getString(map, "formInstanceId");
                            if (formInstanceId != null) {
                                deleteList.add(formInstanceId);
                            }
                        }
                        deleteSuccessCount++;

                        // 同时删除对应的子表数据
                        Long outboundId = kdYdOutbound.getId();
                        LambdaQueryWrapper<KdYdOutboundDetail> detailDelqw = new LambdaQueryWrapper<>();
                        detailDelqw.eq(KdYdOutboundDetail::getOutboundId, outboundId);
                        List<KdYdOutboundDetail> detailDels = kdYdOutboundDetailMapper.selectList(detailDelqw);

                        if (!detailDels.isEmpty()) {
                            for (KdYdOutboundDetail detail : detailDels) {
                                detail.setSyncStatus("1");
                                kdYdOutboundDetailMapper.updateById(detail);
                            }
                        }
                    } else {
                        log.warn("未找到对应的出库单数据: djbh={}", djbh);
                    }

                    // 删除操作完成后更新状态
                    kdYdOutbound.setSyncStatus("1");
                    kdYdOutboundMapper.updateById(kdYdOutbound);

                } catch (Exception e) {
                    log.error("删除出库单数据查询异常: djbh={}", kdYdOutbound.getDjbh(), e);
                }
            }

            // 执行批量删除
            if (!deleteList.isEmpty()) {
                try {
                    ydClient.operateData(YDParam.builder()
                            .formUuid("FORM-AADBCDA8126F41A0ADDEE3353828583192M8")
                            .formInstanceIdList(deleteList)
                            .build(), YDConf.FORM_OPERATION.delete_batch);
                    log.info("出库单批量删除完成，共删除{}条数据", deleteList.size());
                } catch (Exception e) {
                    log.error("出库单批量删除操作异常", e);
                }
            }

            return;
        } else {
            log.info("【出库单删除任务】无需要删除的数据");
        }
        LambdaQueryWrapper<KdYdOutbound> outboundqw = new LambdaQueryWrapper<>();
        outboundqw.eq(KdYdOutbound::getSyncStatus, "0");
        List<KdYdOutbound> kdYdOutbounds = kdYdOutboundMapper.selectList(outboundqw);
        if (kdYdOutbounds.isEmpty()) {
            log.info("【出库单同步任务】无需要同步的数据，结束");
            return;
        }
        log.info("【出库单同步任务】开始同步，共{}条数据", kdYdOutbounds.size());

        int successCount = 0;
        int failCount = 0;

        for (KdYdOutbound kdYdOutbound : kdYdOutbounds) {
            try {
                Long outboundId = kdYdOutbound.getId();
                String djbh = kdYdOutbound.getDjbh();
                String deliveryId = kdYdOutbound.getDeliveryBm();

                log.debug("开始同步出库单: ID={}, 单据编号={}", outboundId, djbh);

                LambdaQueryWrapper<KdYdOutboundDetail> outbounddetailqw = new LambdaQueryWrapper<>();
                outbounddetailqw.eq(KdYdOutboundDetail::getOutboundId, outboundId)
                        .orderByAsc(KdYdOutboundDetail::getDetailId);
                List<KdYdOutboundDetail> kdYdOutboundDetails = kdYdOutboundDetailMapper.selectList(outbounddetailqw);

                ArrayList<Object> tableList = new ArrayList<>();
                List<Map<String, Object>> tableListxlh = new ArrayList<>();
                for (KdYdOutboundDetail kdYdOutboundDetail : kdYdOutboundDetails) {
                    HashMap<String, String> tablemap = new HashMap<>();
                    HashMap<String, String> tablemapxlh = new HashMap<>();
                    tablemap.put("textField_mejnamff", kdYdOutboundDetail.getWlbm());
                    tablemap.put("textField_mejnamfg", kdYdOutboundDetail.getWlmc());
                    tablemap.put("textField_mg34txh1", kdYdOutboundDetail.getTpsb());
                    tablemap.put("textField_mejnamfh", kdYdOutboundDetail.getGgxh());
                    tablemap.put("textField_mejnamfk", kdYdOutboundDetail.getKcdw());
                    tablemap.put("numberField_mejnamfl", String.valueOf(kdYdOutboundDetail.getYfsl() != null ? kdYdOutboundDetail.getYfsl().setScale(2, java.math.RoundingMode.HALF_UP) : java.math.BigDecimal.ZERO.setScale(2, java.math.RoundingMode.HALF_UP)));
                    tablemap.put("numberField_mg34txh2", kdYdOutboundDetail.getSfsl() != null ? kdYdOutboundDetail.getSfsl().setScale(2, java.math.RoundingMode.HALF_UP).toString() : java.math.BigDecimal.ZERO.setScale(2, java.math.RoundingMode.HALF_UP).toString());
                    tablemap.put("numberField_mg34txh3", kdYdOutboundDetail.getDj() != null ? kdYdOutboundDetail.getDj().setScale(2, java.math.RoundingMode.HALF_UP).toString() : java.math.BigDecimal.ZERO.setScale(2, java.math.RoundingMode.HALF_UP).toString());
                    tablemap.put("numberField_mg34txh4", kdYdOutboundDetail.getHsdj() != null ? kdYdOutboundDetail.getHsdj().setScale(2, java.math.RoundingMode.HALF_UP).toString() : java.math.BigDecimal.ZERO.setScale(2, java.math.RoundingMode.HALF_UP).toString());
                    tablemap.put("textField_mg34txh5", kdYdOutboundDetail.getPh());
                    tablemap.put("numberField_mg34txh6", kdYdOutboundDetail.getSl() != null ? kdYdOutboundDetail.getSl().setScale(2, java.math.RoundingMode.HALF_UP).toString() : java.math.BigDecimal.ZERO.setScale(2, java.math.RoundingMode.HALF_UP).toString());
                    tablemap.put("numberField_mg34txh7", kdYdOutboundDetail.getSe() != null ? kdYdOutboundDetail.getSe().setScale(2, java.math.RoundingMode.HALF_UP).toString() : java.math.BigDecimal.ZERO.setScale(2, java.math.RoundingMode.HALF_UP).toString());
                    tablemap.put("numberField_mg34txh8", kdYdOutboundDetail.getJe() != null ? kdYdOutboundDetail.getJe().setScale(2, java.math.RoundingMode.HALF_UP).toString() : java.math.BigDecimal.ZERO.setScale(2, java.math.RoundingMode.HALF_UP).toString());
                    tablemap.put("numberField_mg34txh9", kdYdOutboundDetail.getJshj() != null ? kdYdOutboundDetail.getJshj().setScale(2, java.math.RoundingMode.HALF_UP).toString() : java.math.BigDecimal.ZERO.setScale(2, java.math.RoundingMode.HALF_UP).toString());
                    tablemap.put("textField_mf6a0h6l", kdYdOutboundDetail.getCk());
                    tablemap.put("textField_mf6a0h6k", kdYdOutboundDetail.getCw());
                    tablemap.put("textField_mf6a0h6p", kdYdOutboundDetail.getKczt());
                    tablemap.put("numberField_mg34txha", kdYdOutboundDetail.getJtc() != null ? kdYdOutboundDetail.getJtc().setScale(2, java.math.RoundingMode.HALF_UP).toString() : java.math.BigDecimal.ZERO.setScale(2, java.math.RoundingMode.HALF_UP).toString());
                    tablemap.put("textField_mejnamf6", kdYdOutboundDetail.getSjr());
                    tablemap.put("textField_mejnamf7", kdYdOutboundDetail.getSjdh());
                    tablemap.put("textareaField_mf6a0h5e", kdYdOutboundDetail.getSjdz());
                    tablemap.put("textField_mejnamfx", kdYdOutboundDetail.getSsxl());
                    tablemap.put("textField_mf6a0h6u", kdYdOutboundDetail.getGg());
                    tablemap.put("textField_mhlqeoas", kdYdOutboundDetail.getZbq());
                    tablemap.put("dateField_mg34txhb", kdYdOutboundDetail.getFwdqr() != null ? String.valueOf(kdYdOutboundDetail.getFwdqr().atZone(java.time.ZoneId.systemDefault()).toInstant().toEpochMilli()) : "");
                    tablemap.put("textField_mf6a0h6w", kdYdOutboundDetail.getXlh());
                    tablemap.put("textField_mhlqeoat", kdYdOutboundDetail.getZbqsf());
                    tablemap.put("textField_mf6a0h6x", kdYdOutboundDetail.getKddh());
                    tablemap.put("textField_mf6a0h6y", kdYdOutboundDetail.getJx());
                    String xlhjh = kdYdOutboundDetail.getXlh();
                    if (xlhjh != null && !xlhjh.trim().isEmpty()) {
                         tableListxlh = Arrays.stream(xlhjh.split(","))
                                .map(String::trim)
                                .filter(item -> !item.isEmpty())
                                .map(item -> {
                                    Map<String, Object> map = new HashMap<>();
                                    map.put("textField_mf6a0h6w", item);
                                    return map;
                                })
                                .collect(Collectors.toList());
                    }
                    tablemap.put("radioField_mf6a0h6h", kdYdOutboundDetail.getSfzp());
                    tableList.add(tablemap);
                    kdYdOutboundDetail.setSyncStatus("1");
                    kdYdOutboundDetailMapper.updateById(kdYdOutboundDetail);

                }

                String fhdformInstanceId = null;
                String fhdbh = null;
                try {
                    log.debug("开始查询出库数据: deliveryId={}", deliveryId);

                    List<Map> ddlist = (List<Map>) ydClient.queryData(
                            YDParam.builder()
                                    .formUuid("FORM-A7F03ACEE01D4F609550C86BF7FE87D35M6I")
                                    .appType("APP_VQDMMWS6OR1VHL8VMFD3")
                                    .systemToken("XE766X81JHKXK4Z27SYOI86CPCLQ3J1LV7ODMH2")
                                    .searchCondition(JSON.toJSONString(UtilMap.map("serialNumberField_mheazm7w", deliveryId)))
                                    .build(),
                            YDConf.FORM_QUERY.retrieve_list_all
                    ).getData();

                    if (ddlist != null && !ddlist.isEmpty()) {

                        for (Map<String, Object> khitem : ddlist) {
                            Map<String, Object> khformData = (Map<String, Object>) khitem.get("formData");

                            if (khformData != null && deliveryId.equals(khformData.get("serialNumberField_mheazm7w"))) {
                                fhdformInstanceId = (String) khitem.get("formInstanceId");
                                fhdbh = (String) khformData.get("serialNumberField_mheazm7w");
                                break;
                            }
                        }

                        if (fhdformInstanceId == null) {
                            log.warn("未找到与fhdbh={}完全匹配的订单数据", fhdbh);
                        }
                    } else {
                        log.warn("未查询到订单数据: fhdbh={}", fhdbh);
                    }

                } catch (Exception e) {
                    log.error("查询订单数据异常: fhdbh={}, 错误信息={}", fhdbh, e.getMessage(), e);
                }
                HashMap<Object, Object> updateMap = new HashMap<>();
                updateMap.put("tableField_mejnamfd", tableList);
                updateMap.put("tableField_migw33w7", tableListxlh);
                if (fhdbh != null && fhdformInstanceId != null) {
                    updateMap.put("associationFormField_mejmml36",
                            Arrays.asList(getfhdAss(fhdbh, fhdformInstanceId)));
                }
                 updateMap.put("dateField_krbgloam", kdYdOutbound.getDateTime() != null ? String.valueOf(kdYdOutbound.getDateTime().atZone(java.time.ZoneId.systemDefault()).toInstant().toEpochMilli()) : "");
                updateMap.put("textField_krnn5bmr", kdYdOutbound.getXsDept());
                updateMap.put("textField_mhjxw689", kdYdOutbound.getFhDept());
                updateMap.put("textField_mhjxw686", kdYdOutbound.getCgy());
                updateMap.put("selectField_mejowmna", kdYdOutbound.getDjlx());
                updateMap.put("textField_mg34txgm", kdYdOutbound.getDjbh());
                updateMap.put("textField_mhlqeoar", kdYdOutbound.getJsbb());
                updateMap.put("textField_mejnamf2", kdYdOutbound.getKh());
                updateMap.put("selectField_mejowmnc", kdYdOutbound.getXslx());
                updateMap.put("textField_mhjxw688", kdYdOutbound.getXsy());
                updateMap.put("selectField_mg34txgt", kdYdOutbound.getXssx());
                updateMap.put("selectField_megi74y8", kdYdOutbound.getKhsx());
                updateMap.put("textField_mg34txgy", kdYdOutbound.getKhtjr());
                updateMap.put("textField_mg34txgz", kdYdOutbound.getYsdh());
                updateMap.put("textField_migw33w6", deliveryId);

                // 添加同步操作（根据您的实际需求添加）
                ydClient.operateData(YDParam.builder()
                        .formUuid("FORM-AADBCDA8126F41A0ADDEE3353828583192M8")
                        .searchCondition(JSONObject.toJSONString(UtilMap.map("textField_mg34txgm", kdYdOutbound.getDjbh())))
                        .formDataJson(JSONObject.toJSONString(updateMap))
                        .build(), YDConf.FORM_OPERATION.upsert
                );
                // 更新同步状态
                kdYdOutbound.setSyncStatus("1");
                kdYdOutboundMapper.updateById(kdYdOutbound);
                successCount++;

                log.info("出库单同步成功: 单据编号={}", djbh);

            } catch (Exception e) {
                failCount++;
                log.error("同步单条出库单数据异常: 单据编号={}, 错误信息={}",
                        kdYdOutbound.getDjbh(), e.getMessage(), e);
            }
        }

        log.info("【出库单同步任务】完成: 成功={}, 失败={}, 总计={}",
                successCount, failCount, kdYdOutbounds.size());
    }

    @Override
    public void syncKdYdReceivable() {
        log.info("定时同步-应收单");
        // 查询需要删除的数据
        LambdaQueryWrapper<KdYdReceivable> receivabledel = new LambdaQueryWrapper<>();
        receivabledel.eq(KdYdReceivable::getOperationType, 3)
                .eq(KdYdReceivable::getSyncStatus, "0");
        List<KdYdReceivable> kdYdReceivabledels = kdYdReceivableMapper.selectList(receivabledel);

        // 批量删除处理
        if (!kdYdReceivabledels.isEmpty()) {
            log.info("开始处理应收单删除操作，共{}条数据", kdYdReceivabledels.size());
            ArrayList<String > deleteList = new ArrayList<>();
            int deleteSuccessCount = 0;

            for (KdYdReceivable kdYdReceivable : kdYdReceivabledels) {
                try {
                    String djbh = kdYdReceivable.getDjbh();

                    List<Map> list1 = (List<Map>) ydClient.queryData(YDParam.builder()
                            .formUuid("FORM-4E1CE4550339494A9BE5498FB119FF2E9ERU")
                            .appType("APP_VQDMMWS6OR1VHL8VMFD3")
                            .systemToken("XE766X81JHKXK4Z27SYOI86CPCLQ3J1LV7ODMH2")
                            .searchCondition(JSONObject.toJSONString(UtilMap.map("textField_mg3a0tgs", djbh)))
                            .build(), YDConf.FORM_QUERY.retrieve_list_all).getData();

                    if (list1 != null && !list1.isEmpty()) {
                        for (Map map : list1) {
                            String formInstanceId = UtilMap.getString(map, "formInstanceId");
                            if (formInstanceId != null) {
                                deleteList.add(formInstanceId);
                            }
                        }
                        deleteSuccessCount++;

                        // 同时删除对应的子表数据
                        Long receivableId = kdYdReceivable.getId();

                        // 删除应收单明细
                        LambdaQueryWrapper<KdYdReceivableDetail> detailDelqw = new LambdaQueryWrapper<>();
                        detailDelqw.eq(KdYdReceivableDetail::getReceivableId, receivableId);
                        List<KdYdReceivableDetail> detailDels = kdYdReceivableDetailMapper.selectList(detailDelqw);
                        if (!detailDels.isEmpty()) {
                            for (KdYdReceivableDetail detail : detailDels) {
                                detail.setSyncStatus("1");
                                kdYdReceivableDetailMapper.updateById(detail);
                            }
                            log.debug("更新了{}条应收单明细删除状态", detailDels.size());
                        }

                        // 删除收款计划
                        LambdaQueryWrapper<KdYdReceivablePayment> paymentDelqw = new LambdaQueryWrapper<>();
                        paymentDelqw.eq(KdYdReceivablePayment::getReceivableId, receivableId);
                        List<KdYdReceivablePayment> paymentDels = kdYdReceivalablePaymentMapper.selectList(paymentDelqw);
                        if (!paymentDels.isEmpty()) {
                            for (KdYdReceivablePayment payment : paymentDels) {
                                payment.setSyncStatus("1");
                                kdYdReceivalablePaymentMapper.updateById(payment);
                            }
                            log.debug("更新了{}条收款计划删除状态", paymentDels.size());
                        }
                    } else {
                        log.warn("未找到对应的应收单数据: djbh={}", djbh);
                    }

                    // 删除操作完成后更新状态
                    kdYdReceivable.setSyncStatus("1");
                    kdYdReceivableMapper.updateById(kdYdReceivable);

                } catch (Exception e) {
                    log.error("删除应收单数据查询异常: djbh={}", kdYdReceivable.getDjbh(), e);
                }
            }

            // 执行批量删除
            if (!deleteList.isEmpty()) {
                try {
                    ydClient.operateData(YDParam.builder()
                            .formUuid("FORM-4E1CE4550339494A9BE5498FB119FF2E9ERU")
                            .appType("APP_VQDMMWS6OR1VHL8VMFD3")
                            .systemToken("XE766X81JHKXK4Z27SYOI86CPCLQ3J1LV7ODMH2")
                            .formInstanceIdList(deleteList)
                            .build(), YDConf.FORM_OPERATION.delete_batch);
                    log.info("应收单批量删除完成，共删除{}条数据", deleteList.size());
                } catch (Exception e) {
                    log.error("应收单批量删除操作异常", e);
                }
            }

            log.info("应收单删除操作处理完成: 成功查询={}, 待删除={}", deleteSuccessCount, deleteList.size());
            return;
        } else {
            log.info("【应收单删除任务】无需要删除的数据");
        }
        LambdaQueryWrapper<KdYdReceivable> receivableqw = new LambdaQueryWrapper<>();
        receivableqw.eq(KdYdReceivable::getSyncStatus, "0");
        List<KdYdReceivable> kdYdReceivables = kdYdReceivableMapper.selectList(receivableqw);
        if (kdYdReceivables.isEmpty()) {
            log.info("【应收单同步任务】无需要同步的数据，结束");
            return;
        }

        log.info("【应收单同步任务】开始同步，共{}条数据", kdYdReceivables.size());
        int successCount = 0;
        int failCount = 0;

        for (KdYdReceivable kdYdReceivable : kdYdReceivables) {
            try {
                Long id = kdYdReceivable.getId();
                String djbh = kdYdReceivable.getDjbh();

                log.debug("开始同步应收单: ID={}, 单据编号={}", id, djbh);

                // 同步应收单明细
                LambdaQueryWrapper<KdYdReceivableDetail> receivabledetailqw = new LambdaQueryWrapper<>();
                receivabledetailqw.eq(KdYdReceivableDetail::getReceivableId, id)
                        .orderByAsc(KdYdReceivableDetail::getDetailId);
                List<KdYdReceivableDetail> kdYdReceivabledetails = kdYdReceivableDetailMapper.selectList(receivabledetailqw);
                if (kdYdReceivabledetails.isEmpty()) {
                    log.info("【应收单{}】无需要同步的明细数据", djbh);
                    continue;
                }
                int count = 1;
                ArrayList<Object> tableList = new ArrayList<>();
                for (KdYdReceivableDetail kdYdReceivableDetail : kdYdReceivabledetails) {
                    HashMap<Object, Object> tablemap = new HashMap<>();
                    String wlbm = kdYdReceivableDetail.getWlbm();
                    String wlmc = kdYdReceivableDetail.getWlmc();
                    String ggxh = kdYdReceivableDetail.getGgxh();
                    String jjdw = kdYdReceivableDetail.getJjdw();
                    String ssxl = kdYdReceivableDetail.getSsxl();
                    BigDecimal dj = kdYdReceivableDetail.getDj();
                    BigDecimal hsdj = kdYdReceivableDetail.getHsdj();
                    BigDecimal sl = kdYdReceivableDetail.getSl();
                    BigDecimal je = kdYdReceivableDetail.getJe();
                    BigDecimal zbjshj = kdYdReceivableDetail.getJshj();
                    String kcdw = kdYdReceivableDetail.getKcdw();
                    String ph = kdYdReceivableDetail.getPh();
                    BigDecimal se = kdYdReceivableDetail.getSe();
                    BigDecimal jjsl = kdYdReceivableDetail.getJjsl();
                    BigDecimal zkl = kdYdReceivableDetail.getZkl();
                    BigDecimal bhsje = kdYdReceivableDetail.getBhsje();
                    BigDecimal jjjbsl = kdYdReceivableDetail.getJjjbsl();
                    BigDecimal kcsl = kdYdReceivableDetail.getKcsl();
                    String sfzp = kdYdReceivableDetail.getSfzp();
                    String gg = kdYdReceivableDetail.getGg();
                    BigDecimal tc = kdYdReceivableDetail.getTc();
                    String jx = kdYdReceivableDetail.getJx();
                    BigDecimal zke = kdYdReceivableDetail.getZke();
                    String detailId = kdYdReceivableDetail.getDetailId();

                    // 优化：确保所有金额字段保留两位小数
                    tablemap.put("textField_mgt4w4ip", count);
                    tablemap.put("textField_mf6el3zy", wlbm);
                    tablemap.put("textField_mf6el3zz", wlmc);
                    tablemap.put("textField_mejmtic5", ggxh);
                    tablemap.put("textField_mf6el400", jjdw);
                    tablemap.put("textField_mhllijwo", ssxl);
                    tablemap.put("numberField_mf6el402", dj != null ? dj.setScale(2, java.math.RoundingMode.HALF_UP) : java.math.BigDecimal.ZERO.setScale(2, java.math.RoundingMode.HALF_UP));
                    tablemap.put("numberField_mejmticb", hsdj != null ? hsdj.setScale(2, java.math.RoundingMode.HALF_UP) : java.math.BigDecimal.ZERO.setScale(2, java.math.RoundingMode.HALF_UP));
                    tablemap.put("numberField_mf6el403", sl != null ? sl.setScale(2, java.math.RoundingMode.HALF_UP) : java.math.BigDecimal.ZERO.setScale(2, java.math.RoundingMode.HALF_UP));
                    tablemap.put("numberField_mejmtic7", zbjshj != null ? zbjshj.setScale(2, java.math.RoundingMode.HALF_UP) : java.math.BigDecimal.ZERO.setScale(2, java.math.RoundingMode.HALF_UP));
                    tablemap.put("textField_mf6el409", kcdw);
                    tablemap.put("textField_mf6el408", ph);
                    tablemap.put("numberField_mf6el406", se != null ? se.setScale(2, java.math.RoundingMode.HALF_UP) : java.math.BigDecimal.ZERO.setScale(2, java.math.RoundingMode.HALF_UP));
                    tablemap.put("numberField_mejmtic6", jjsl != null ? jjsl.setScale(2, java.math.RoundingMode.HALF_UP) : java.math.BigDecimal.ZERO.setScale(2, java.math.RoundingMode.HALF_UP));
                    tablemap.put("numberField_mf6el404", zkl != null ? zkl.setScale(2, java.math.RoundingMode.HALF_UP) : java.math.BigDecimal.ZERO.setScale(2, java.math.RoundingMode.HALF_UP));
                    tablemap.put("numberField_mejmticc", bhsje != null ? bhsje.setScale(2, java.math.RoundingMode.HALF_UP) : java.math.BigDecimal.ZERO.setScale(2, java.math.RoundingMode.HALF_UP));
                    tablemap.put("numberField_mf6el407", jjjbsl != null ? jjjbsl.setScale(2, java.math.RoundingMode.HALF_UP) : java.math.BigDecimal.ZERO.setScale(2, java.math.RoundingMode.HALF_UP));
                    tablemap.put("numberField_mf6el40a", kcsl != null ? kcsl.setScale(2, java.math.RoundingMode.HALF_UP) : java.math.BigDecimal.ZERO.setScale(2, java.math.RoundingMode.HALF_UP));
                    tablemap.put("radioField_mejnamfn", sfzp);
                    tablemap.put("numberField_mf6el40c", tc != null ? tc.setScale(2, java.math.RoundingMode.HALF_UP) : java.math.BigDecimal.ZERO.setScale(2, java.math.RoundingMode.HALF_UP));
                    tablemap.put("textField_mf6el40d", jx);
                    tablemap.put("textField_mf6el40b", gg);
                    tablemap.put("numberField_mf6el405", zke != null ? zke.setScale(2, java.math.RoundingMode.HALF_UP) : java.math.BigDecimal.ZERO.setScale(2, java.math.RoundingMode.HALF_UP));
                    count++;
                    tableList.add(tablemap);

                    kdYdReceivableDetail.setSyncStatus("1");
                    kdYdReceivableDetailMapper.updateById(kdYdReceivableDetail);
                }

                // 同步收款计划
                LambdaQueryWrapper<KdYdReceivablePayment> receivablepayqw = new LambdaQueryWrapper<>();
                receivablepayqw
                        .eq(KdYdReceivablePayment::getReceivableId, id)
                        .orderByAsc(KdYdReceivablePayment::getDetailId);
                List<KdYdReceivablePayment> kdYdReceivablePayments = kdYdReceivalablePaymentMapper.selectList(receivablepayqw);

                ArrayList<Object> tableListPay = new ArrayList<>();
                if (!kdYdReceivablePayments.isEmpty()) {
                    for (KdYdReceivablePayment kdYdReceivablePayment : kdYdReceivablePayments) {
                        HashMap<Object, Object> tablemap1 = new HashMap<>();
                        long timestamp = kdYdReceivablePayment.getEndTime().atZone(java.time.ZoneId.systemDefault()).toInstant().toEpochMilli();
                        String xsddh = kdYdReceivablePayment.getXsddh();
                        BigDecimal ysje = kdYdReceivablePayment.getYsje();
                        BigDecimal ysbl = kdYdReceivablePayment.getYsbl();
                        BigDecimal ysjebwb = kdYdReceivablePayment.getYsjebwb();
                        BigDecimal stkdglje = kdYdReceivablePayment.getStkdglje();

                        tablemap1.put("textField_mhiui6va", xsddh);
                        tablemap1.put("dateField_mhiui6v9", timestamp);
                        tablemap1.put("numberField_mhiui6v8", ysje != null ? ysje.setScale(2, java.math.RoundingMode.HALF_UP) : java.math.BigDecimal.ZERO.setScale(2, java.math.RoundingMode.HALF_UP));
                        tablemap1.put("numberField_mhiui6v6", ysbl != null ? ysbl.setScale(2, java.math.RoundingMode.HALF_UP) : java.math.BigDecimal.ZERO.setScale(2, java.math.RoundingMode.HALF_UP));
                        tablemap1.put("numberField_mhiui6vb", ysjebwb != null ? ysjebwb.setScale(2, java.math.RoundingMode.HALF_UP) : java.math.BigDecimal.ZERO.setScale(2, java.math.RoundingMode.HALF_UP));
                        tablemap1.put("numberField_mhjy9hzj", stkdglje != null ? stkdglje.setScale(2, java.math.RoundingMode.HALF_UP) : java.math.BigDecimal.ZERO.setScale(2, java.math.RoundingMode.HALF_UP));
                        tableListPay.add(tablemap1);
                        kdYdReceivablePayment.setSyncStatus("1");
                        kdYdReceivalablePaymentMapper.updateById(kdYdReceivablePayment);
                    }
                }
                String ckddjbh = kdYdReceivable.getCkddjbh();
                String ckdformInstanceId = null;
                String ckdbh = null;

                try {
                    List<Map> ddlist = (List<Map>) ydClient.queryData(
                            YDParam.builder()
                                    .formUuid("FORM-AADBCDA8126F41A0ADDEE3353828583192M8")
                                    .appType("APP_VQDMMWS6OR1VHL8VMFD3")
                                    .systemToken("XE766X81JHKXK4Z27SYOI86CPCLQ3J1LV7ODMH2")
                                    .searchCondition(JSON.toJSONString(UtilMap.map("textField_mg34txgm", ckddjbh)))
                                    .build(),
                            YDConf.FORM_QUERY.retrieve_list_all
                    ).getData();

                    if (ddlist != null && !ddlist.isEmpty()) {
                        for (Map<String, Object> khitem : ddlist) {
                            Map<String, Object> khformData = (Map<String, Object>) khitem.get("formData");
                            if (khformData != null && ckddjbh.equals(khformData.get("textField_mg34txgm"))) {
                                ckdformInstanceId = (String) khitem.get("formInstanceId");
                                ckdbh = (String) khformData.get("textField_mg34txgm");
                                break;
                            }
                        }

                        if (ckdformInstanceId == null) {
                            log.warn("未找到与ckdbh={}完全匹配的订单数据", ckdbh);
                        }
                    } else {
                        log.warn("未查询到订单数据: ckdbh={}", ckdbh);
                    }

                } catch (Exception e) {
                    log.error("查询订单数据异常: ckdbh={}, 错误信息={}", ckdbh, e.getMessage(), e);
                }


                // 构建主表数据
                HashMap<Object, Object> updateData = new HashMap<>();
                updateData.put("tableField_mf6el3zx", tableList);
                if (ckdbh != null && ckdformInstanceId != null) {
                    updateData.put("associationFormField_mejmtick",
                            Arrays.asList(getysdAss(ckdbh, ckdformInstanceId)));
                }
                updateData.put("tableField_mhiui6v5", tableListPay);
                updateData.put("textField_mg3a0tgs", kdYdReceivable.getDjbh());
                updateData.put("selectField_mg3a0th4", kdYdReceivable.getDjlx());
                updateData.put("selectField_mev13l3r", kdYdReceivable.getSktj());
                updateData.put("dateField_mejmtic3", kdYdReceivable.getEndTime().atZone(java.time.ZoneId.systemDefault()).toInstant().toEpochMilli());
                updateData.put("dateField_mejmtic2", kdYdReceivable.getBusinessTime().atZone(java.time.ZoneId.systemDefault()).toInstant().toEpochMilli());
                updateData.put("numberField_mejmtic8", kdYdReceivable.getJshj() != null ? kdYdReceivable.getJshj().setScale(2, java.math.RoundingMode.HALF_UP) : java.math.BigDecimal.ZERO.setScale(2, java.math.RoundingMode.HALF_UP));
                updateData.put("textField_mejmml3k", kdYdReceivable.getKh());
                updateData.put("textField_mhjy9hzh", kdYdReceivable.getXsy());
                updateData.put("selectField_mejowmnc", kdYdReceivable.getXslx());
                updateData.put("selectField_megi74y8", kdYdReceivable.getKhsx());
                updateData.put("textField_krnn5bmr", kdYdReceivable.getXsbm());
                updateData.put("textField_mhjy9hzi", kdYdReceivable.getLzlx());
                updateData.put("textareaField_mg3a0tgx", kdYdReceivable.getBz());
                updateData.put("selectField_mg3fuqvn", kdYdReceivable.getBb());

                log.debug("开始同步到宜搭: 单据编号={}, 表单UUID=FORM-4E1CE4550339494A9BE5498FB119FF2E9ERU", djbh);

                // 执行同步
                ydClient.operateData(YDParam.builder()
                        .formUuid("FORM-4E1CE4550339494A9BE5498FB119FF2E9ERU")
                        .searchCondition(JSONObject.toJSONString(UtilMap.map("textField_mg3a0tgs", kdYdReceivable.getDjbh())))
                        .formDataJson(JSONObject.toJSONString(updateData))
                        .build(), YDConf.FORM_OPERATION.upsert
                );

                kdYdReceivable.setSyncStatus("1");
                kdYdReceivableMapper.updateById(kdYdReceivable);
                successCount++;

                log.info("应收单同步成功: 单据编号={}", djbh);

            } catch (Exception e) {
                failCount++;
                log.error("同步应收单异常: ID={}, 单据编号={}, 错误信息={}",
                        kdYdReceivable.getId(), kdYdReceivable.getDjbh(), e.getMessage(), e);
            }
        }

        log.info("【应收单同步任务】完成: 成功={}, 失败={}, 总计={}",
                successCount, failCount, kdYdReceivables.size());
    }

    @Override
    public void synckdYdZp() {
        log.info("定时同步-发票单");
        try {

            LocalDateTime now = LocalDateTime.now();
            LocalDateTime fiveMinutesAgo = now.minusMinutes(5);
            DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
            List<KdYdZp> kdYdZps = kdYdZpMapper.selectRecentUpdated(fiveMinutesAgo);
            if (kdYdZps.isEmpty()) {
                log.info("【发票单同步任务】无需要同步的数据，结束");
                return;
            }

            for (KdYdZp kdYdZp : kdYdZps) {
                try {
                    String djbh = kdYdZp.getDjbh();
                    String fph = kdYdZp.getFph();
//                    String formInstId = kdYdZp.getForminstid();
//                    if (ObjectUtil.hasEmpty(formInstId, djbh, fph)) {
//                        log.warn("跳过同步: formInstId 或 khbm 为空, customer={}", kdYdZp.getId());
//                        continue;
//                    }

                    ydClient.operateData(
                            YDParam.builder()
//                                    .formInstanceId(formInstId)
                                    .updateFormDataJson(JSONObject.toJSONString(UtilMap.map("textField_mgt6lcqq, textField_mejmml3a", djbh, fph)))
                                    .useLatestVersion(true).build(), YDConf.FORM_OPERATION.update);

                } catch (Exception e) {
//                    log.error("同步单条发票单数据异常: formInstId={}", kdYdZp.getForminstid(), e);
                }
            }

            log.info("【发票单同步任务】执行完成，共处理 {} 条记录", kdYdZps.size());
        } catch (Exception e) {
            log.error("【发票单同步任务】执行过程中发生严重错误", e);
        }
    }

    @Override
    public void synckdYdMaterial() {
        log.info("定时同步-物料单");
        // 查询需要删除的数据
        LambdaQueryWrapper<KdYdMaterial> materialdel = new LambdaQueryWrapper<>();
        materialdel.eq(KdYdMaterial::getOperationType, 3)  // 修正：使用 materialdel 而不是 materialqw
                .eq(KdYdMaterial::getSyncStatus, "0");
        List<KdYdMaterial> kdYdMaterialdels = kdYdMaterialMapper.selectList(materialdel);

        // 批量删除处理
        if (!kdYdMaterialdels.isEmpty()) {
            log.info("开始处理删除操作，共{}条数据", kdYdMaterialdels.size());
            ArrayList<String> list = new ArrayList<>();
            int deleteSuccessCount = 0;

            for (KdYdMaterial kdYdMaterial : kdYdMaterialdels) {
                try {
                    String wlbm = kdYdMaterial.getWlbm();
                    List<Map> list1 = (List<Map>) ydClient.queryData(YDParam.builder()
                            .formUuid("FORM-E64114E9F2C9426E91F92886EDFFA2C08Q90")
                            .appType("APP_VQDMMWS6OR1VHL8VMFD3")  // 新增：添加应用参数
                            .systemToken("XE766X81JHKXK4Z27SYOI86CPCLQ3J1LV7ODMH2")  // 新增：添加系统令牌
                            .searchFieldJson(JSONObject.toJSONString(UtilMap.map("textField_mfxbtcdh", wlbm)))
                            .build(), YDConf.FORM_QUERY.retrieve_list_all).getData();

                    if (list1 != null && !list1.isEmpty()) {
                        for (Map map : list1) {
                            String formInstanceId = UtilMap.getString(map, "formInstanceId");
                            if (formInstanceId != null) {
                                list.add(formInstanceId);
                                log.debug("找到待删除的表单实例: formInstanceId={}", formInstanceId);
                            }
                        }
                        deleteSuccessCount++;
                    } else {
                        log.warn("未找到对应的物料数据: wlbm={}", wlbm);
                    }

                    // 删除操作完成后更新状态
                    kdYdMaterial.setSyncStatus("1");
                    kdYdMaterialMapper.updateById(kdYdMaterial);

                } catch (Exception e) {
                    log.error("删除物料数据查询异常: wlbm={}", kdYdMaterial.getWlbm(), e);
                }
            }

            // 执行批量删除
            if (!list.isEmpty()) {
                try {
                    ydClient.operateData(YDParam.builder()
                            .formUuid("FORM-E64114E9F2C9426E91F92886EDFFA2C08Q90")
                            .appType("APP_VQDMMWS6OR1VHL8VMFD3")
                            .systemToken("XE766X81JHKXK4Z27SYOI86CPCLQ3J1LV7ODMH2")
                            .formInstanceIdList(list)
                            .build(), YDConf.FORM_OPERATION.delete_batch);
                    log.info("批量删除完成，共删除{}条数据", list.size());
                } catch (Exception e) {
                    log.error("批量删除操作异常", e);
                }
            }

            return;
        }
        LambdaQueryWrapper<KdYdMaterial> materialqw = new LambdaQueryWrapper<>();
        materialqw.eq(KdYdMaterial::getSyncStatus, "0");
        List<KdYdMaterial> kdYdMaterials = kdYdMaterialMapper.selectList(materialqw);
        log.info("本次需要同步的物料单数量: {}", kdYdMaterials.size());
        // 同步新增/更新数据
        if (kdYdMaterials.isEmpty()) {
            log.info("【物料单同步任务】无需要同步的数据，结束");
            return;
        }
        int successCount = 0;
        int failCount = 0;

        for (KdYdMaterial kdYdMaterial : kdYdMaterials) {
            try {
                String wlbm = kdYdMaterial.getWlbm();
                String wlmc = kdYdMaterial.getWlmc();
                String xh = kdYdMaterial.getXh();
                String gg = kdYdMaterial.getGg();
                String wlfz = kdYdMaterial.getWlfz();
                String wlsx = kdYdMaterial.getWlsx();
                String jbdw = kdYdMaterial.getJbdw();
                String ssxl = kdYdMaterial.getSsxl();
                String jx = kdYdMaterial.getJx();
                Integer sd = kdYdMaterial.getSd();
                String mrsl = kdYdMaterial.getMrsl();
                String chlb = kdYdMaterial.getChlb();
                String xsy = kdYdMaterial.getXsy();
                BigDecimal xsjzj = kdYdMaterial.getXsjzj();
                String smzs = kdYdMaterial.getSmzs();
                String sjzt = kdYdMaterial.getSjzt();
                String jyzt = kdYdMaterial.getJyzt();
                String dzl = kdYdMaterial.getDzl();
                String pzzt = kdYdMaterial.getPzzt();
                String wlbt = wlmc + wlbm;
//                String materialtitle = kdYdMaterial.getMaterialtitle();
                Map updateFormData = new HashMap();
                updateFormData.put("textField_l43jpnsf", wlmc);
                updateFormData.put("textField_mfxbtcdh", wlbm);
                updateFormData.put("textField_l43jpnsg", xh);
                updateFormData.put("textField_lqbxkzbq", gg);
                updateFormData.put("textField_mhlbx8hi", wlfz);
                updateFormData.put("textField_l43jpnsh", wlsx);
                updateFormData.put("textField_mfxbtcdo", jbdw);
                updateFormData.put("textField_mfxbtcdp", ssxl);
                updateFormData.put("textField_mejl9nrs", jx);
                updateFormData.put("numberField_mfxbtceb", sd);
                updateFormData.put("textField_mejl9nrp", dzl);
                updateFormData.put("selectField_mejl9nrq", pzzt);
                updateFormData.put("textField_mfxbtcdq", mrsl);
                updateFormData.put("textField_mfxbtcdr", chlb);
                updateFormData.put("textField_mfxbtce5", xsy);

                //确保金额字段保留两位小数
                if (xsjzj != null) {
                    updateFormData.put("numberField_mejl9nsc", xsjzj.setScale(2, java.math.RoundingMode.HALF_UP));
                } else {
                    updateFormData.put("numberField_mejl9nsc", java.math.BigDecimal.ZERO.setScale(2, java.math.RoundingMode.HALF_UP));
                }

                updateFormData.put("textField_mfxbtce4", smzs);
                updateFormData.put("textField_mfxbtcea", jyzt);
                updateFormData.put("textField_mg4h6mz5", wlbt);
                ydClient.operateData(YDParam.builder()
                        .formUuid("FORM-E64114E9F2C9426E91F92886EDFFA2C08Q90")
                        .appType("APP_VQDMMWS6OR1VHL8VMFD3")
                        .systemToken("XE766X81JHKXK4Z27SYOI86CPCLQ3J1LV7ODMH2")
//                        .searchCondition(JSONObject.toJSONString(UtilMap.map("textField_mg4h6mz5", wlbt)))
                        .searchCondition(JSONObject.toJSONString(UtilMap.map("textField_mfxbtcdh", wlbm)))
                        .formDataJson(JSONObject.toJSONString(updateFormData))
                        .build(), YDConf.FORM_OPERATION.upsert);

                // 同步成功，更新状态
                kdYdMaterial.setSyncStatus("1");
                kdYdMaterialMapper.updateById(kdYdMaterial);
                successCount++;

                log.info("物料单同步成功: wlbm={}, wlmc={}", wlbm, wlmc);

            } catch (Exception e) {
                failCount++;
                log.error("同步单条物料单数据异常: wlbm={}, wlmc={}",
                        kdYdMaterial.getWlbm(), kdYdMaterial.getWlmc(), e);
            }
        }

        // 添加同步结果统计日志
        log.info("物料单同步完成: 成功={}, 失败={}, 总计={}",
                successCount, failCount, kdYdMaterials.size());
    }

    @Override
    public void syncKdYdDeliveryDetail() {
        log.info("定时同步-发货单详情");
        try {
            LocalDateTime now = LocalDateTime.now();
            LocalDateTime fiveMinutesAgo = now.minusMinutes(5);

            // 1. 查询最近更新的 delivery detail
            List<KdYdDeliveryDetail> kdYdDeliveryDetails = kdYdDeliveryDetailMapper.selectRecentUpdated(fiveMinutesAgo);

            if (kdYdDeliveryDetails.isEmpty()) {
                log.info("【发货详情单同步任务】无需要同步的数据，结束");
                return;
            }

            // 2. 按 deliveryId 提取主单 ID 列表，避免重复查询
            Set<Long> deliveryIds = kdYdDeliveryDetails.stream()
                    .map(KdYdDeliveryDetail::getDeliveryId)
                    .filter(Objects::nonNull)
                    .collect(Collectors.toSet());

            // 3. 批量查询主单信息（包含 formInstId）
            List<KdYdDelivery> mainDeliveries = kdYdDeliveryMapper.selectBatchIds(deliveryIds);
            Map<Long, KdYdDelivery> deliveryMap = mainDeliveries.stream()
                    .collect(Collectors.toMap(KdYdDelivery::getId, d -> d));

            // 4. 按 formInstId 分组，减少 API 调用次数
//            Map<String, List<KdYdDeliveryDetail>> detailsByFormInstId = kdYdDeliveryDetails.stream()
//                    .filter(detail -> deliveryMap.containsKey(detail.getDeliveryId()))
//                    .collect(Collectors.groupingBy(detail -> {
//                        KdYdDelivery main = deliveryMap.get(detail.getDeliveryId());
//                        return main != null ? main.getForminstid() : null;
//                    }));

            int successCount = 0;
            int errorCount = 0;

            // 5. 遍历每个 formInstId，只调用一次 query + 一次 update
//            for (Map.Entry<String, List<KdYdDeliveryDetail>> entry : detailsByFormInstId.entrySet()) {
//                String formInstId = entry.getKey();
//                if (formInstId == null || formInstId.trim().isEmpty()) {
//                    log.warn("跳过空 formInstId 的记录");
//                    continue;
//                }
//
//                try {
//                    // 查询当前表单数据
//                    Map formData = ydClient.queryData(
//                            YDParam.builder()
//                                    .formInstId(formInstId)
//                                    .appType(ydConf.getAppType())
//                                    .systemToken(ydConf.getSystemToken())
//                                    .userId(ddConf.getOperator())
//                                    .build(),
//                            YDConf.FORM_QUERY.retrieve_id
//                    ).getFormData();
//
//                    if (formData == null) {
//                        log.warn("formInstId={} 的 formData 为空", formInstId);
//                        continue;
//                    }
//
//                    List<Map<String, Object>> tableData = (List<Map<String, Object>>) formData.get("tableField_mejnamfd");
//                    if (tableData == null || tableData.isEmpty()) {
//                        log.warn("formInstId={} 的子表 tableField_mejnamfd 为空", formInstId);
//                        continue;
//                    }
//                    // 标记是否需要更新
//                    boolean modified = false;
//
//                    // 处理当前 formInstId 下的所有待同步 detail
//                    for (KdYdDeliveryDetail detail : entry.getValue()) {
//                        String wlbm = detail.getWlbm();
//                        String mdh = detail.getMdh();
//
//                        for (Map<String, Object> row : tableData) {
//                            Object wlbmIdObj = row.get("textField_mejnamff");
//                            if (wlbmIdObj != null && wlbm.equals(wlbmIdObj.toString())) {
//                                row.put("textField_mf6a0h6y", mdh);
//                                modified = true;
//                                successCount++;
//                                break; // 找到匹配行即可跳出
//                            }
//                        }
//                    }
//
//                    // 只有修改了才提交
//                    if (modified) {
//                        ydClient.operateData(
//                                YDParam.builder()
//                                        .formInstanceId(formInstId)
//                                        .updateFormDataJson(JSON.toJSONString(Collections.singletonMap("tableField_mejnamfd", tableData)))
//                                        .useLatestVersion(true)
//                                        .build(),
//                                YDConf.FORM_OPERATION.update
//                        );
//                        log.debug("已更新 formInstId={} 的子表数据", formInstId);
//                    } else {
//                        log.debug("formInstId={} 无需更新", formInstId);
//                    }
//
//                } catch (Exception e) {
//                    errorCount += entry.getValue().size(); // 统计失败数量
//                    log.error("同步 formInstId={} 时发生异常", formInstId, e);
//                }
//            }
//
//            log.info("【发货详情单同步任务】执行完成，共处理 {} 条记录，成功 {} 条，失败 {} 条",
//                    kdYdDeliveryDetails.size(), successCount, errorCount);
//
        } catch (Exception e) {
            log.error("【发货单同步任务】执行过程中发生严重错误", e);
        }
    }

    @Override
    public void synckdYdPayment() {
        log.info("定时同步-收款单");
        LambdaQueryWrapper<KdYdPaymentReceipt> paymentdel = new LambdaQueryWrapper<>();
        paymentdel.eq(KdYdPaymentReceipt::getOperationType, 3)
                .eq(KdYdPaymentReceipt::getSyncStatus, "0");
        List<KdYdPaymentReceipt> kdYdPaymentReceiptdels = kdYdPaymentReceiptMapper.selectList(paymentdel);

        // 批量删除处理
        if (!kdYdPaymentReceiptdels.isEmpty()) {
            log.info("开始处理收款单删除操作，共{}条数据", kdYdPaymentReceiptdels.size());
            ArrayList<String> deleteList = new ArrayList<>();
            int deleteSuccessCount = 0;

            for (KdYdPaymentReceipt kdYdPaymentReceipt : kdYdPaymentReceiptdels) {
                try {
                    String djbh = kdYdPaymentReceipt.getDjbh();
                    log.debug("查询需要删除的收款单: djbh={}", djbh);

                    List<Map> list1 = (List<Map>) ydClient.queryData(YDParam.builder()
                            .formUuid("FORM-0569C06E47074C2981ADEEAFCE083EDAK5AM")
                            .appType("APP_VQDMMWS6OR1VHL8VMFD3")
                            .systemToken("XE766X81JHKXK4Z27SYOI86CPCLQ3J1LV7ODMH2")
                            .searchCondition(JSONObject.toJSONString(UtilMap.map("textField_mh9woamt", djbh)))
                            .build(), YDConf.FORM_QUERY.retrieve_list_all).getData();

                    if (list1 != null && !list1.isEmpty()) {
                        for (Map map : list1) {
                            String formInstanceId = UtilMap.getString(map, "formInstanceId");
                            if (formInstanceId != null) {
                                deleteList.add(formInstanceId);
                            }
                        }
                        deleteSuccessCount++;

                        // 同时删除对应的子表数据
                        Long paymentReceiptId = kdYdPaymentReceipt.getId();
                        LambdaQueryWrapper<KdYdPaymentReceiptDetail> detailDelqw = new LambdaQueryWrapper<>();
                        detailDelqw.eq(KdYdPaymentReceiptDetail::getPayreceiptId, paymentReceiptId);
                        List<KdYdPaymentReceiptDetail> detailDels = kdYdPaymentReceiptDetailMapper.selectList(detailDelqw);

                        if (!detailDels.isEmpty()) {
                            for (KdYdPaymentReceiptDetail detail : detailDels) {
                                detail.setSyncStatus("1");
                                kdYdPaymentReceiptDetailMapper.updateById(detail);
                            }
                        }
                    } else {
                        log.warn("未找到对应的收款单数据: djbh={}", djbh);
                    }

                    // 删除操作完成后更新状态
                    kdYdPaymentReceipt.setSyncStatus("1");
                    kdYdPaymentReceiptMapper.updateById(kdYdPaymentReceipt);

                } catch (Exception e) {
                    log.error("删除收款单数据查询异常: djbh={}", kdYdPaymentReceipt.getDjbh(), e);
                }
            }

            // 执行批量删除
            if (!deleteList.isEmpty()) {
                try {
                    ydClient.operateData(YDParam.builder()
                            .formUuid("FORM-0569C06E47074C2981ADEEAFCE083EDAK5AM")
                            .appType("APP_VQDMMWS6OR1VHL8VMFD3")
                            .systemToken("XE766X81JHKXK4Z27SYOI86CPCLQ3J1LV7ODMH2")
                            .formInstanceIdList(deleteList)
                            .build(), YDConf.FORM_OPERATION.delete_batch);
                    log.info("收款单批量删除完成，共删除{}条数据", deleteList.size());
                } catch (Exception e) {
                    log.error("收款单批量删除操作异常", e);
                }
            }

            log.info("收款单删除操作处理完成: 成功查询={}, 待删除={}", deleteSuccessCount, deleteList.size());
            return;
        } else {
            log.info("【收款单删除任务】无需要删除的数据");
        }
        LambdaQueryWrapper<KdYdPaymentReceipt> paymentqw = new LambdaQueryWrapper<>();
        paymentqw.eq(KdYdPaymentReceipt::getSyncStatus, "0");
        List<KdYdPaymentReceipt> kdYdPaymentReceipts = kdYdPaymentReceiptMapper.selectList(paymentqw);
        if (kdYdPaymentReceipts.isEmpty()) {
            log.info("【收款单同步任务】无需要同步的数据，结束");
            return;
        }
        log.info("【收款单同步任务】开始同步，共{}条数据", kdYdPaymentReceipts.size());

        int successCount = 0;
        int failCount = 0;

        for (KdYdPaymentReceipt kdYdPaymentReceipt : kdYdPaymentReceipts) {
            try {
                Long paymentReceiptId = kdYdPaymentReceipt.getId();
                String djbh = kdYdPaymentReceipt.getDjbh();

                log.debug("开始同步收款单: ID={}, 单据编号={}", paymentReceiptId, djbh);

                LambdaQueryWrapper<KdYdPaymentReceiptDetail> receivedetailqw = new LambdaQueryWrapper<>();
                receivedetailqw.eq(KdYdPaymentReceiptDetail::getPayreceiptId, paymentReceiptId)
                        .orderByAsc(KdYdPaymentReceiptDetail::getDetailId);
                List<KdYdPaymentReceiptDetail> kdYDPaymentReceiptDetails = kdYdPaymentReceiptDetailMapper.selectList(receivedetailqw);
                ArrayList<Object> tableList = new ArrayList<>();
                for (KdYdPaymentReceiptDetail kdYdPaymentReceiptDetail : kdYDPaymentReceiptDetails) {
                    HashMap<String, String> tablemap = new HashMap<>();
                    tablemap.put("textField_mh9woanr", kdYdPaymentReceiptDetail.getJsfs());
                    tablemap.put("textField_mh9woans", kdYdPaymentReceiptDetail.getSkyt());
                    tablemap.put("textField_mh9woant", kdYdPaymentReceiptDetail.getYsxmlx());
                    tablemap.put("textField_mh9woanu", kdYdPaymentReceiptDetail.getYsxsdd());
                    tablemap.put("numberField_mh9woanv", kdYdPaymentReceiptDetail.getYsje() != null ? kdYdPaymentReceiptDetail.getYsje().setScale(2, java.math.RoundingMode.HALF_UP).toString() : java.math.BigDecimal.ZERO.setScale(2, java.math.RoundingMode.HALF_UP).toString());
                    tablemap.put("numberField_mh9woanw", kdYdPaymentReceiptDetail.getSxf() != null ? kdYdPaymentReceiptDetail.getSxf().setScale(2, java.math.RoundingMode.HALF_UP).toString() : java.math.BigDecimal.ZERO.setScale(2, java.math.RoundingMode.HALF_UP).toString());
                    tablemap.put("textField_mhmr1ecr", kdYdPaymentReceiptDetail.getCdk());
                    tablemap.put("textField_mh9woany", kdYdPaymentReceiptDetail.getWfyhzh());
                    tablemap.put("textField_mh9woao2", kdYdPaymentReceiptDetail.getXsddh());
                    tablemap.put("textField_mh9woao1", kdYdPaymentReceiptDetail.getFyxm());
                    tablemap.put("numberField_mh9woanz", kdYdPaymentReceiptDetail.getSsje() != null ? kdYdPaymentReceiptDetail.getSsje().setScale(2, java.math.RoundingMode.HALF_UP).toString() : java.math.BigDecimal.ZERO.setScale(2, java.math.RoundingMode.HALF_UP).toString());
                    tablemap.put("numberField_mh9woao0", kdYdPaymentReceiptDetail.getZhje() != null ? kdYdPaymentReceiptDetail.getZhje().setScale(2, java.math.RoundingMode.HALF_UP).toString() : java.math.BigDecimal.ZERO.setScale(2, java.math.RoundingMode.HALF_UP).toString());
                    kdYdPaymentReceiptDetail.setSyncStatus("1");
                    kdYdPaymentReceiptDetailMapper.updateById(kdYdPaymentReceiptDetail);
//                    tablemap.put("radioField_mf6a0h6h", kdYdOutboundDetail.getSfzp());
                    tableList.add(tablemap);

                }
                String xsddbh = kdYdPaymentReceipt.getXsddbh();
                String ddformInstanceId = null;
                String ddbh = null;

                try {
                    log.debug("开始查询订单数据: xsddbh={}", xsddbh);

                    List<Map> ddlist = (List<Map>) ydClient.queryData(
                            YDParam.builder()
                                    .formUuid("FORM-B62CAE3075CE4098B17BB86C90FFA21C9B7C")
                                    .searchCondition(JSON.toJSONString(UtilMap.map("serialNumberField_mewfgzku", xsddbh)))
                                    .build(),
                            YDConf.FORM_QUERY.retrieve_list_all
                    ).getData();

                    if (ddlist != null && !ddlist.isEmpty()) {
                        for (Map<String, Object> khitem : ddlist) {
                            Map<String, Object> khformData = (Map<String, Object>) khitem.get("formData");

                            if (khformData != null && xsddbh.equals(khformData.get("serialNumberField_mewfgzku"))) {
                                ddformInstanceId = (String) khitem.get("formInstanceId");
                                ddbh = (String) khformData.get("serialNumberField_mewfgzku");
                                break;
                            }
                        }

                        if (ddformInstanceId == null) {
                            log.warn("未找到与xsddbh={}完全匹配的订单数据", xsddbh);
                        }
                    } else {
                        log.warn("未查询到订单数据: xsddbh={}", xsddbh);
                    }

                } catch (Exception e) {
                    log.error("查询订单数据异常: xsddbh={}, 错误信息={}", xsddbh, e.getMessage(), e);
                }
                HashMap<Object, Object> updateMap = new HashMap<>();
                updateMap.put("tableField_mh9woanl", tableList);
                if (ddbh != null && ddformInstanceId != null) {
                    updateMap.put("associationFormField_mh9woamy",
                            Arrays.asList(getddAss(ddbh, ddformInstanceId)));
                }
                updateMap.put("textField_mh9woanm", kdYdPaymentReceipt.getDjlx());
                updateMap.put("textField_mh9woann", kdYdPaymentReceipt.getFkdwlx());
                updateMap.put("textField_mh9woamt", kdYdPaymentReceipt.getDjbh());
                updateMap.put("textField_mh9woamz", kdYdPaymentReceipt.getSkgld());
                updateMap.put("textField_mh9woano", kdYdPaymentReceipt.getBb());
                updateMap.put("dateField_mh9woan5", kdYdPaymentReceipt.getYwrq() != null ? String.valueOf(kdYdPaymentReceipt.getYwrq().atZone(java.time.ZoneId.systemDefault()).toInstant().toEpochMilli()) : "");
                updateMap.put("textField_mh9woanp", kdYdPaymentReceipt.getWldwlx());
                updateMap.put("textField_mh9woanq", kdYdPaymentReceipt.getWldw());
                updateMap.put("numberField_mh9woanc", kdYdPaymentReceipt.getYsje() != null ? kdYdPaymentReceipt.getYsje().setScale(2, java.math.RoundingMode.HALF_UP).toString() : java.math.BigDecimal.ZERO.setScale(2, java.math.RoundingMode.HALF_UP).toString());
                updateMap.put("numberField_mh9woand", kdYdPaymentReceipt.getSsje() != null ? kdYdPaymentReceipt.getSsje().setScale(2, java.math.RoundingMode.HALF_UP).toString() : java.math.BigDecimal.ZERO.setScale(2, java.math.RoundingMode.HALF_UP).toString());
                updateMap.put("textField_mhjxv2tf", kdYdPaymentReceipt.getXsy());
                updateMap.put("textField_mhjxv2tg", kdYdPaymentReceipt.getXsbm());
                updateMap.put("textareaField_mh9woank", kdYdPaymentReceipt.getBz());

                log.debug("开始同步到宜搭: 单据编号={}, 表单UUID=FORM-0569C06E47074C2981ADEEAFCE083EDAK5AM", djbh);

                // 添加同步操作（根据您的实际需求添加）
                ydClient.operateData(YDParam.builder()
                        .formUuid("FORM-0569C06E47074C2981ADEEAFCE083EDAK5AM")
                        .searchCondition(JSONObject.toJSONString(UtilMap.map("textField_mh9woamt", kdYdPaymentReceipt.getDjbh())))
                        .formDataJson(JSONObject.toJSONString(updateMap))
                        .build(), YDConf.FORM_OPERATION.upsert);

                // 更新同步状态
                kdYdPaymentReceipt.setSyncStatus("1");
                kdYdPaymentReceiptMapper.updateById(kdYdPaymentReceipt);
                successCount++;

                log.info("收款单同步成功: 单据编号={}", djbh);

            } catch (Exception e) {
                failCount++;
                log.error("同步单条收款单数据异常: 单据编号={}, 错误信息={}",
                        kdYdPaymentReceipt.getDjbh(), e.getMessage(), e);
            }
        }

        log.info("【收款单同步任务】完成: 成功={}, 失败={}, 总计={}",
                successCount, failCount, kdYdPaymentReceipts.size());
    }

    private Object getddAss(String title, String id) {
        return UtilMap.map("appType, formUuid, formType, instanceId, title, subTitle", "APP_VQDMMWS6OR1VHL8VMFD3", "FORM-B62CAE3075CE4098B17BB86C90FFA21C9B7C", "receipt", id, title, "");
    }

    private Object getfhdAss(String title, String id) {
        return UtilMap.map("appType, formUuid, formType, instanceId, title, subTitle", "APP_VQDMMWS6OR1VHL8VMFD3", "FORM-A7F03ACEE01D4F609550C86BF7FE87D35M6I", "receipt", id, title, "");
    }

    private Object getysdAss(String title, String id) {
        return UtilMap.map("appType, formUuid, formType, instanceId, title, subTitle", "APP_VQDMMWS6OR1VHL8VMFD3", "FORM-AADBCDA8126F41A0ADDEE3353828583192M8", "receipt", id, title, "");
    }
}