cont/mjava-kabeiyi/src/main/java/com/malk/kabeiyi/service/impl/KabeiyiServiceImpl.java

package com.malk.kabeiyi.service.impl;

import cn.hutool.core.date.DateTime;
import cn.hutool.core.date.DateUtil;
import cn.hutool.http.HttpRequest;
import cn.hutool.http.HttpResponse;
import cn.hutool.http.HttpUtil;
import cn.hutool.json.JSONUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.core.type.TypeReference;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.malk.core.McProject;
import com.malk.kabeiyi.service.KabeiyiService;
import com.malk.kabeiyi.util.RecognizeAllText;
import com.malk.kabeiyi.util.U8Util;
import com.malk.server.aliwork.YDConf;
import com.malk.server.aliwork.YDParam;
import com.malk.server.common.McException;
import com.malk.server.common.McR;
import com.malk.server.dingtalk.DDConf;
import com.malk.server.dingtalk.DDR;
import com.malk.server.dingtalk.DDR_New;
import com.malk.service.aliwork.YDClient;
import com.malk.service.aliwork.YDService;
import com.malk.service.dingtalk.DDClient;
import com.malk.service.dingtalk.DDClient_Workflow;
import com.malk.utils.UtilHttp;
import com.malk.utils.UtilMap;
import com.malk.utils.UtilToken;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.apache.commons.lang3.time.DateUtils;
import org.slf4j.MDC;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;

import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.math.BigDecimal;
import java.net.HttpURLConnection;
import java.net.URL;
import java.time.LocalDate;
import java.util.*;
import java.util.stream.Collectors;

@Slf4j
@Service
public class KabeiyiServiceImpl implements KabeiyiService {
    @Autowired
    private DDClient_Workflow ddClient_workflow;

    @Autowired
    private DDClient ddClient;

    @Autowired
    private YDService ydService;

    @Autowired
    private YDClient ydClient;

    @Autowired
    private YDConf ydConf;

    @Autowired
    private DDConf ddConf;

    @Value("${tcdingtalk.appKey}")
    private String appKey;

    @Value("${tcdingtalk.appSecret}")
    private String appSecret;

    @Value("${aliwork.accessKeyId}")
    private String accessKeyId;

    @Value("${aliwork.accessKeySecret}")
    private String accessKeySecret;

    @Value("${ocr.filePath}")
    private String filePath;

    @Value("${u8.fromAccount}")
    private String fromAccount;

    @Value("${u8.toAccount}")
    private String toAccount;

    @Value("${u8.appKey}")
    private String u8AppKey;

    @Value("${u8.appSecret}")
    private String u8AppSecret;

    //结算方式
    public final static String PAY_TYPE = "JSFS001";

    //审批实例url前缀（卡倍亿）
    private static final String PROC_INST_PREFIX_URL = "https://aflow.dingtalk.com/dingtalk/web/query/pchomepage.htm?from=oflow&op=true&corpid=dingc3a744cb591a7346f2c783f7214b6d69#/plainapproval?procInstId=";

    //宜搭-关联数据（卡倍亿）
    private static final String RELATION = "FORM-230C40137ED94524B4D4C94F8B23A8D2F8PF";

    //审批实例url前缀（特充）
    private static final String PROC_INST_PREFIX_URL2 = "https://aflow.dingtalk.com/dingtalk/web/query/pchomepage.htm?from=oflow&op=true&corpid=ding3ea249a3b5b466d0f2c783f7214b6d69#/plainapproval?procInstId=";

    //宜搭-关联数据（特充）
    private static final String RELATION2 = "FORM-51E17EFB52C14C9CB9E00168FED2BC18LQ6H";

    //问题整改表
    private static final String QUESTION = "FORM-89F515967FF94C62A9031F28EF6000B1YV5Q";

    //问题整改表流程code
    private static final String QUESTION_PROC_CODE = "TPROC--DP5660A1LEXNP1S37P7KU9GCHD5U3HB6C360M5";

    //审核表
    private static final String CHECK = "FORM-F4ED246EADD8427381BC13C4F0FEF7FDYMKJ";

    //审核表流程code
    private static final String CHECK_PROC_CODE = "TPROC--4XC66Y61XWWNZNJKBZD4VAB5BQAJ2YANX160M5";

    //审核计划
    private static final String CHECK_PLAN = "FORM-A9A7991EEB7D41FDAADADB9B1E1750FE0K5K";

    //产品实发
    private static final String PRODUCT_REAL = "FORM-809458EB6D524CF5AE1A91A3492D8B1BZIMN";

    //内部交易客户
    private static final String INTERNAL_CUSTOMER = "FORM-14782CE27EA54D2C94CC5BEF90554E5ALYP7";

    //内部工厂
    private static final String INTERNAL_FACTORY = "FORM-6CD7A1EDE1134AC8B2EE833769595C2EIWQ6";

     //关联表单（卡倍亿）
    private static final Map<String,String> SCHEMA_MAP = new HashMap<>();
    static{
        SCHEMA_MAP.put("工厂用章流程","1.1、工厂用章流程(除采购营销人事)");
        SCHEMA_MAP.put("中心用章流程","1.2、中心用章流程（除采购营销人事）");
        SCHEMA_MAP.put("人事专用用章审批流程","1.3、人事专用用章审批流程");
        SCHEMA_MAP.put("商务部用章申请流程","1.4、商务部用章申请流程");
        SCHEMA_MAP.put("办公用品采购申请流程","4.3、办公用品采购申请流程");

        //需传其他值
        //对方单位名称 收入或支出 金额 备注
        SCHEMA_MAP.put("信息化建设用章流程","1.7、信息化建设用章流程");
        //合同说明 采购物品类型
        SCHEMA_MAP.put("技术中心请购审批流程","4.10、技术中心请购审批流程");
        //合同总金额 合同说明
        SCHEMA_MAP.put("设备备品备件采购合同审批流程","4.1b、设备备品备件采购合同审批流程");
        SCHEMA_MAP.put("其他物品采购合同流程","4.2b、其他物品采购合同流程");
        SCHEMA_MAP.put("设备采购合同审批流程","4.5c、设备采购合同审批流程");
        SCHEMA_MAP.put("原材料采购合同审批流程","4.9b、原材料采购合同审批流程");
        SCHEMA_MAP.put("墨西哥采购合同审批流程","4.13b、墨西哥采购合同审批流程");
    }

    //关联表单（特充）
    private static final Map<String,String> SCHEMA_MAP2 = new HashMap<>();
    static{
        //需传其他值
        //对方单位名称 收入或支出 金额 备注
        SCHEMA_MAP2.put("特充用章流程","1.2、特充用章流程（除采购营销人事）");

        //合同总金额 合同说明
        SCHEMA_MAP2.put("设备备品备件采购合同审批流程","4.1b、设备备品备件采购合同审批流程");
        SCHEMA_MAP2.put("其他物品采购合同流程","4.2b、其他物品采购合同流程");
        SCHEMA_MAP2.put("母排设备采购合同审批流程","4.5c、母排设备采购合同审批流程");
        SCHEMA_MAP2.put("双铝设备采购合同审批流程","4.6c、双铝设备采购合同审批流程");

        //合同总金额
        SCHEMA_MAP2.put("原材料采购合同审批流程","4.9b、原材料采购合同审批流程");

        //文件类别 对方单位名称 收入或支出 金额 用印文件名称 文件份数 加盖何种印章 备注
        SCHEMA_MAP2.put("信息化建设用章流程","1.7、信息化建设用章流程");
    }

    @Override
    public McR pushProcInstToYD(Map map) {
        MDC.put("MDC_KEY_PID","1002");

        //审批实例
        String procInstId = String.valueOf(map.get("procInstId"));
        //获取审批实例信息
        Map processInstance = ddClient_workflow.getProcessInstanceId(ddClient.getAccessToken(), procInstId);
        if (Objects.nonNull(processInstance)){
            Map formData = new HashMap<>();
            String title = String.valueOf(processInstance.get("title"));
            String type = "";
            List<Map> formComponentValues = (List<Map>) processInstance.get("formComponentValues");
            for (String key : SCHEMA_MAP.keySet()) {
                if (title.contains(key)){
                    type = SCHEMA_MAP.get(key);
                    switch (type){
                        case "1.7、信息化建设用章流程" :
                            for (Map formComponentValue : formComponentValues) {
                                String name = String.valueOf(formComponentValue.get("name"));
                                String value = String.valueOf(formComponentValue.get("value")).equals("null") ? "" : String.valueOf(formComponentValue.get("value"));
                                switch (name){
                                    case "对方单位名称" : formData.put("textField_lygzlf3j",value);break;
                                    case "收入或支出" : formData.put("textField_lygzlf3k",value);break;
                                    case "金额" : formData.put("textField_lygzlf3l",value);break;
                                    case "备注" : formData.put("textField_lygzlf3m",value);break;
                                }
                            }
                            break;
                        case "4.1b、设备备品备件采购合同审批流程" :
                        case "4.2b、其他物品采购合同流程" :
                        case "4.5c、设备采购合同审批流程" :
                        case "4.9b、原材料采购合同审批流程" :
                        case "4.13b、墨西哥采购合同审批流程" :
                            for (Map formComponentValue : formComponentValues) {
                                String name = String.valueOf(formComponentValue.get("name"));
                                switch (name){
                                    case "合同总金额" : formData.put("numberField_lyf81587",formComponentValue.get("value"));break;
                                    case "合同说明" :
                                        if (Objects.nonNull(formComponentValue.get("value"))){
                                            formData.put("textField_lyf81588",formComponentValue.get("value"));
                                        }
                                        break;
                                }
                            }
                            break;
                        case "4.10、技术中心请购审批流程" :
                            for (Map formComponentValue : formComponentValues) {
                                String name = String.valueOf(formComponentValue.get("name"));
                                switch (name){
                                    case "采购物品类型" : formData.put("textField_lyibvb98",formComponentValue.get("value"));break;
                                    case "合同说明" :
                                        if (Objects.nonNull(formComponentValue.get("value"))){
                                            formData.put("textField_lyf81588",formComponentValue.get("value"));
                                        }
                                        break;
                                }
                            }
                            break;
                        default:
                            break;
                    }

                    formData.put("textField_lyf8157x",title);
                    formData.put("selectField_lyf81580",type);

                    Map condition = new HashMap<>();
                    condition.put("textField_lyf81581",PROC_INST_PREFIX_URL + procInstId);
                    //同步到宜搭
                    ydService.upsertFormData(RELATION,condition,formData,null);

                    break;
                }
            }
            return McR.success();
        }

        return McR.errorParam("审批实例不存在！");
    }

    @Override
    public McR pushProcInstToYD2(Map map) {
        MDC.put("MDC_KEY_PID","1003");

        //审批实例
        String procInstId = String.valueOf(map.get("procInstId"));
        //获取审批实例信息
        Map processInstance = ddClient_workflow.getProcessInstanceId(getTcAccessToken(), procInstId);
        if (Objects.nonNull(processInstance)){
            Map formData = new HashMap<>();
            String title = String.valueOf(processInstance.get("title"));
            String type = "";
            List<Map> formComponentValues = (List<Map>) processInstance.get("formComponentValues");
            for (String key : SCHEMA_MAP2.keySet()) {
                if (title.contains(key)){
                    type = SCHEMA_MAP2.get(key);
                    switch (type){
                        case "1.7、信息化建设用章流程" :
                            for (Map formComponentValue : formComponentValues) {
                                String name = String.valueOf(formComponentValue.get("name"));
                                Object value = formComponentValue.get("value");
                                switch (name){
                                    case "文件类别" : formData.put("textField_lymfq9oa",value);break;
                                    case "对方单位名称" : formData.put("textField_lygzlf3j",value);break;
                                    case "收入或支出" : formData.put("textField_lygzlf3k",value);break;
                                    case "金额（元）" : formData.put("textField_lygzlf3l",value);break;
                                    case "用印文件名称" : formData.put("textField_lymfq9oc",value);break;
                                    case "文件份数" : formData.put("numberField_lymfq9od",value);break;
                                    case "加盖何种印章" : formData.put("textField_lymfq9oe",value);break;
                                    case "备注" : formData.put("textField_lygzlf3m",value);break;
                                }
                            }
                            break;

                        case "4.1b、设备备品备件采购合同审批流程" :
                        case "4.2b、其他物品采购合同流程" :
                        case "4.5c、母排设备采购合同审批流程" :
                        case "4.6c、双铝设备采购合同审批流程" :
                        case "4.9b、原材料采购合同审批流程" :
                            for (Map formComponentValue : formComponentValues) {
                                String name = String.valueOf(formComponentValue.get("name"));
                                switch (name){
                                    case "合同总金额（元）":
                                    case "合同总金额" : formData.put("numberField_lyf81587",formComponentValue.get("value"));break;
                                    case "合同说明" :
                                        if (Objects.nonNull(formComponentValue.get("value"))){
                                            formData.put("textField_lyf81588",formComponentValue.get("value"));
                                        }
                                        break;
                                }
                            }
                            break;
                        case "1.2、特充用章流程（除采购营销人事）" :
                            for (Map formComponentValue : formComponentValues) {
                                String name = String.valueOf(formComponentValue.get("name"));
                                String value = String.valueOf(formComponentValue.get("value")).equals("null") ? "" : String.valueOf(formComponentValue.get("value"));
                                switch (name){
                                    case "对方单位名称" : formData.put("textField_lygzlf3j",value);break;
                                    case "收入或支出" : formData.put("textField_lygzlf3k",value);break;
                                    case "金额（元）" : formData.put("textField_lygzlf3l",value);break;
                                    case "备注" : formData.put("textField_lygzlf3m",value);break;
                                }
                            }
                            break;
                        default:
                            break;
                    }

                    formData.put("textField_lyf8157x",title);
                    formData.put("selectField_lyf81580",type);

                    Map condition = new HashMap<>();
                    condition.put("textField_lyf81581",PROC_INST_PREFIX_URL2 + procInstId);


                    //同步到宜搭
                    ydService.upsertFormData(RELATION2,condition,formData,null);

                    break;
                }
            }
            return McR.success();
        }

        return McR.errorParam("审批实例不存在！");
    }

    @Override
    public McR addQuestionApproval(Map map) {
        MDC.put("MDC_KEY_PID","1009");

        if (Objects.isNull(map.get("formInstId"))){
            return McR.errorParam("formInstId不能为空！");
        }
        String formInstId = map.get("formInstId").toString();

        DDR_New ddrNew = ydClient.queryData(YDParam.builder()
                .formInstId(formInstId)
                .build(), YDConf.FORM_QUERY.retrieve_id);
        Map formData = ddrNew.getFormData();

        List<String> reviewerUserIds = (List<String>) formData.get("employeeField_m061zye5_id");//审核人
        String area = formData.get("selectField_m0w4kilf").toString();
        List<Map> details = (List<Map>) formData.get("tableField_m0kqtqoy");
        String[] yida = McProject.getYida("1009");
        for (Map detail : details) {
            String result = detail.get("radioField_m0nm3des").toString();
            if ("NG".equals(result)){
                //发起问题整改审批
                Map question = new HashMap();
                question.put("textField_m061zye8",detail.get("textField_m0on13ob"));//审核项目
                question.put("textareaField_m061zye9",detail.get("textField_m0kqtqoz"));//审核方法和标准
                question.put("attachmentField_m061zyep",detail.get("attachmentField_m061zyep"));//问题证据
                question.put("textareaField_m063drgz",detail.get("textareaField_m063drgz"));//问题描述
                question.put("dateField_m061zyev",detail.get("dateField_m061zyev"));//整改截止时间
                question.put("employeeField_m10dns9c",detail.get("employeeField_m10d5uqj_id"));//部门经理
                question.put("selectField_m0w4kilf",area);//审核区域

                Map<String,Object> body = new HashMap<>();
                body.put("appType",yida[0]);
                body.put("systemToken",yida[1]);
                body.put("userId",reviewerUserIds.get(0));
                body.put("formUuid",QUESTION);
                body.put("processCode",QUESTION_PROC_CODE);
                body.put("formDataJson", JSONObject.toJSONString(question));

                UtilHttp.doPost("https://api.dingtalk.com/v1.0/yida/processes/instances/start", ddClient.initTokenHeader(), null, body, DDR_New.class);

            }
        }
        return McR.success();
    }

    @Override
    public McR ocr(String downloadUrl,String name,String type) {
        MDC.put("MDC_KEY_PID","1020");

        //下载宜搭附件
        try {
            String[] yida = McProject.getYida("1020");
            downloadFile(downloadUrl,filePath + name,yida[0],yida[1]);
            log.info("文件下载成功!");
        } catch (IOException e) {
            e.printStackTrace();
            log.info("文件下载失败:{}" + e.getMessage());
        }
        //ocr识别
        try {
            String content = RecognizeAllText.recognizeText(filePath + name, type, accessKeyId, accessKeySecret);
            return McR.success(content);
        }catch (Exception e) {
            e.printStackTrace();
            log.info("识别失败:{}" + e.getMessage());
        }
        return McR.errorUnknown("识别失败！");
    }

    public void downloadFile(String fileURL, String savePath,String appType,String systemToken) throws IOException {
        //若是宜搭附件url 则需获得附件临时免登地址
        Map<String,Object> param = new HashMap<>();
        param.put("systemToken",systemToken);
        param.put("userId",ddConf.getOperator());
        param.put("fileUrl",fileURL);
        fileURL = ((DDR_New) UtilHttp.doGet("https://api.dingtalk.com/v1.0/yida/apps/temporaryUrls/" + appType, ddClient.initTokenHeader(), param, DDR_New.class)).getResult().toString();

        URL url = new URL(fileURL);
        HttpURLConnection httpConn = (HttpURLConnection) url.openConnection();
        int responseCode = httpConn.getResponseCode();

        // 检查HTTP响应代码是否为200
        if (responseCode == HttpURLConnection.HTTP_OK) {
            InputStream inputStream = httpConn.getInputStream();
            FileOutputStream outputStream = new FileOutputStream(savePath);

            byte[] buffer = new byte[4096];
            int bytesRead = -1;

            while ((bytesRead = inputStream.read(buffer)) != -1) {
                outputStream.write(buffer, 0, bytesRead);
            }

            outputStream.close();
            inputStream.close();
        } else {
            System.out.println("无法下载文件。HTTP响应代码: " + responseCode);
        }
        httpConn.disconnect();
    }

    @Override
    public McR addPlanApproval(Map map) {
        MDC.put("MDC_KEY_PID","1009");

        if (Objects.isNull(map.get("formInstId"))){
            return McR.errorParam("formInstId不能为空！");
        }
        String formInstId = map.get("formInstId").toString();

        DDR_New ddrNew = ydClient.queryData(YDParam.builder()
                .formInstId(formInstId)
                .build(), YDConf.FORM_QUERY.retrieve_id);
        //计划制定人
        Map originator = ddrNew.getOriginator();
        String planUserId = originator.get("userId").toString();

        Map formData = ddrNew.getFormData();
        //审核人
        List<String> reviewerUserIds = (List<String>) formData.get("employeeField_m061zye5_id");
        //频次
        String frequency = formData.get("selectField_m0koxj7g").toString();
        //下次自动发起审核日期
        long nextTime = (long) formData.get("dateField_m0nbpasq");
        Date nextDate = new Date(nextTime);

        //上次自动发起审核日期
        Date lastTime = nextDate;
        //审核截至日期
        Date endDate = new Date();
        switch (frequency){
            case "每周":
                endDate = DateUtils.addDays(nextDate, 6);
                nextDate = DateUtils.addDays(nextDate, 7);
                break;
            case "每两周":
                endDate = DateUtils.addDays(nextDate, 13);
                nextDate = DateUtils.addDays(nextDate, 14);
                break;
            case "每月":
                endDate = DateUtils.addDays(DateUtils.addMonths(nextDate, 1), -1);
                nextDate = DateUtils.addMonths(nextDate, 1);
                break;
            case "每季度":
                endDate = DateUtils.addDays(DateUtils.addMonths(nextDate, 3),-1);
                nextDate = DateUtils.addMonths(nextDate, 3);
                break;
            case "一次":
                endDate = new Date((long)formData.get("dateField_m0oqbh48"));
                nextDate = null;
                break;
            default:break;
        }
        //获取所有子表明细（大于50条）
        List<Map> details = getInnerTable(CHECK_PLAN,formInstId,"tableField_m0kqtqoy",1,50);
        formData.put("tableField_m0kqtqoy",details);
        //每个审批人发起审批
        for (String reviewerUserId : reviewerUserIds) {
            //根据userId获取部门id
            Map body = new HashMap<>();
            body.put("userid", reviewerUserId);

            DDR_New ddrNew1 = (DDR_New) UtilHttp.doPost("https://oapi.dingtalk.com/topapi/v2/department/listparentbyuser", null, ddClient.initTokenParams(), body, DDR_New.class);
            Map result = (Map) ddrNew1.getResult();
            List<Map> parentList = (List<Map>) result.get("parent_list");
            List<Long> parentDeptIdList = (List<Long>) parentList.get(0).get("parent_dept_id_list");
            String deptId = parentDeptIdList.get(0) + "";
            formData.put("departmentSelectField_m0c3qbjn", new String[]{deptId});
            formData.put("dateField_m061zye7", endDate.getTime());
            formData.put("employeeField_m061zye5",new String[]{reviewerUserId});
            //发起审批
            String[] yida = McProject.getYida("1009");
            Map<String,Object> body2 = new HashMap<>();

            body2.put("appType",yida[0]);
            body2.put("systemToken",yida[1]);
            body2.put("userId",planUserId);
            body2.put("formUuid",CHECK);
            body2.put("processCode",CHECK_PROC_CODE);
            body2.put("formDataJson", JSONObject.toJSONString(formData));

            UtilHttp.doPost("https://api.dingtalk.com/v1.0/yida/processes/instances/start", ddClient.initTokenHeader(), null, body2, DDR_New.class);
        }

        //更新审核计划下次发起审批时间及上次发起审批时间
        formData.put("dateField_m0nbpasw", lastTime);
        formData.put("dateField_m0nbpasq", nextDate);
        formData.put("employeeField_m061zye5",reviewerUserIds);
        ydClient.operateData(YDParam.builder()
                        .formInstId(formInstId)
                        .updateFormDataJson(JSON.toJSONString(formData))
                        .build(), YDConf.FORM_OPERATION.update);

        return McR.success();
    }

    private List<Map> getInnerTable(String formUuid, String formInstId, String tableField, int pageNumber, int pageSize) {
        List<Map> details = new ArrayList<>();
        DDR_New ddrNew = new DDR_New();

        do {
            ddrNew = ydClient.queryData(YDParam.builder()
                    .formUuid(formUuid)
                    .formInstId(formInstId)
                    .tableFieldId(tableField)
                    .pageNumber(pageNumber)
                    .pageSize(pageSize)
                    .build(), YDConf.FORM_QUERY.retrieve_details);
            details.addAll((List<Map>)ddrNew.getData());
            pageNumber++;
        }while (ddrNew.getTotalCount() > pageSize * ddrNew.getPageNumber());

        return details;
    }

    @Override
    @Async
    public McR getDeliveryInfo() {
        //现在时间戳
        long beginTime = System.currentTimeMillis();

        MDC.put("MDC_KEY_PID","1019");

        //内部交易客户
        DDR_New ddrNew = ydClient.queryData(YDParam.builder()
                .formUuid(INTERNAL_CUSTOMER)
                .build(), YDConf.FORM_QUERY.retrieve_list);
        List<Map> data = (List<Map>) ddrNew.getData();

        Set<String> cusCodes = new HashSet<>();
        for (Map map : data) {
            Map formData = (Map) map.get("formData");
            cusCodes.add(getString(formData.get("textField_m1g1tp7i")));
        }

        //数据源对应工厂
        Map<Integer,String> factory = new HashMap<>();
        DDR_New ddrNew2 = ydClient.queryData(YDParam.builder()
                .formUuid(INTERNAL_FACTORY)
                .build(), YDConf.FORM_QUERY.retrieve_list);
        List<Map> data2 = (List<Map>) ddrNew2.getData();
        for (Map map : data2) {
            Map formData = (Map) map.get("formData");
            int dqNumber = (int) formData.get("numberField_m1fvucmc");//数据源序号
            String factoryName = getString(formData.get("textField_m1fvucmd"));//工厂名称
            factory.put(dqNumber,factoryName);
        }
        List<Map> errorList = new ArrayList<>();

        //同步当月内的数据 upsert
        DateTime dateTime = DateUtil.offsetDay(new Date(), -1);
        String yesterday = dateTime.toString("yyyy-MM-dd");

        DateTime beginOfMonth = DateUtil.beginOfMonth(DateUtil.lastMonth());
        String beginOfMonthString = beginOfMonth.toString("yyyy-MM-dd");

/*        String beginOfMonthString = "2024-10-09";

        String yesterday = "2024-10-09";*/
        for (Integer dsSequence : factory.keySet()) {
            /*if (dsSequence != 5){
                continue;
            }*/
            List<String> errorCodes = new ArrayList<>();

            Map<String,Object> param = new HashMap<>();
            param.put("from_account",fromAccount);
            param.put("to_account",toAccount);
            param.put("app_key", u8AppKey);
            param.put("token", getU8Token());
            param.put("page_index", 1);
            param.put("rows_per_page", 50);
            param.put("ds_sequence", dsSequence);
            param.put("date_begin", beginOfMonthString);
            param.put("date_end", yesterday);

            Map<String, Object> map = get("https://api.yonyouup.com/api/consignmentlist/batch_get", param, null);
            if (!getString(map.get("errcode")).equals("0")){
                log.error("获取发货单列表失败:{}",map.get("errmsg"));
                continue;
            }
            if (!map.get("page_count").equals("1")){
                Integer rowCount = Integer.valueOf(map.get("row_count").toString());
                param.put("rows_per_page",rowCount);
                map = get("https://api.yonyouup.com/api/consignmentlist/batch_get", param, null);
            }
            List<Map> consignmentList = (List<Map>) map.get("consignmentlist");

            for (Map consignment : consignmentList) {
                //查询单个发货单详情
                String id = getString(consignment.get("code"));

                /*if (!id.equals("南通9月份")){
                    continue;
                }*/

                Map<String, Object> param2 = new HashMap<>();
                param2.put("from_account", fromAccount);
                param2.put("to_account", fromAccount);
                param2.put("app_key", u8AppKey);
                param2.put("token", getU8Token());
                param2.put("id", id);
                param2.put("ds_sequence", dsSequence);

                Map<String, Object> map2 = new HashMap<>();

                int i1 =1 ;
                boolean flag1 = false;
                while (i1<=5 && !flag1) {
                    try {
                        map2 = get("https://api.yonyouup.com/api/consignment/get", param2, null);
                        flag1 = true;
                    } catch (Exception e) {
                        log.error("获取发货单详情失败:{}, 重试次数:{}",e.getMessage(),i1);
                        try {
                            Thread.sleep(3000);
                        } catch (InterruptedException ex) {
                            throw new RuntimeException(ex);
                        }
                        i1++;
                    }
                }
                if (i1 > 5){
                    log.error("获取发货单详情失败");
                    errorCodes.add(id);
                    continue;
                }


                Map consignment2 = (Map) map2.get("consignment");

                Map formData = new HashMap();
                //若为内部交易客户，则不同步
                String cusCode = getString(consignment2.get("custcode"));
                if (cusCodes.contains(cusCode)){
                    continue;
                }

                formData.put("textField_m18nvp7y",getString(consignment2.get("cusname")));//客户名称
                formData.put("textField_m219zpzf",getString(consignment2.get("cusabbname")));//客户码
                formData.put("textField_m18qfuiz",getString(consignment2.get("operation_type")));//操作类型
                formData.put("textField_m18qfuj0",getString(consignment2.get("saletypename")));//销售类型
                formData.put("textField_m18nvp87",getString(consignment2.get("code")));//发货单code
                formData.put("dateField_m18nvp7x",DateUtil.parseDate(getString(consignment.get("date"))).getTime());//发货日期
                formData.put("textField_m18nvp7z",getString(consignment2.get("deptname")));//部门
                formData.put("textField_m18nvp81",getString(consignment2.get("maker")));//生产员
                formData.put("textField_m18nvp80",getString(consignment2.get("verifier")));//质检员
                formData.put("numberField_m18wkih7",dsSequence);//数据源序号
                formData.put("textField_m1er3scl",factory.get(dsSequence));//工厂名称

                List<Map> entry = (List<Map>) consignment2.get("entry");



                //collect拆分成三个list  每个list长度为500
                List<List<Map>> collectList = new ArrayList<>();
                for (int i = 0; i < entry.size(); i += 500) {
                    collectList.add(entry.subList(i, Math.min(i + 500, entry.size())));
                }

                if (collectList.size() > 3){
                    log.error("发货单:{} 发货明细超过1500个, 请检查",id);
                    errorCodes.add(id + "发货明细超过1500");
                }

                //发货明细
                List list1 = collectList.get(0).stream().map(item -> {
                    Map detail = new HashMap();
                    detail.put("textField_m18nvp8c", getString(item.get("socode")));//销售订单号
                    detail.put("textField_m18nvp8d", getString(item.get("warehouse_name")));//仓库名称
                    detail.put("textField_m22mkwzk", getString(item.get("define29")));//客户存货码
                    detail.put("textField_m18nvp8e", getString(item.get("inventory_name")));//存货名称
                    detail.put("textField_m21b1bhg", getString(item.get("free2")));//产品颜色
                    detail.put("textField_m18nvp8f", getString(item.get("cinvm_unit")));//单位
                    detail.put("numberField_m18nvp8h", getString(item.get("quantity")));//发货数量
                    detail.put("numberField_m18nvp8j", getString(item.get("price")));//未税单价
                    detail.put("numberField_m18nvp8l", getString(item.get("money")));//未税总价
                    detail.put("numberField_m18nvp8k", getString(item.get("taxprice")));//含税单价
                    detail.put("numberField_m18nvp8m", getString(item.get("sum")));//含税总价
                    detail.put("numberField_m18nvp8n", getString(item.get("taxrate")));//税率
                    detail.put("numberField_m18nvp8o", getString(item.get("tax")));//总税价
                    detail.put("textField_m219zpzg", getString(item.get("free1")));//发货客户码

                    return detail;
                }).collect(Collectors.toList());

                List<Map> list2 = new ArrayList<>();
                if (collectList.size() > 1){
                    list2 = collectList.get(1).stream().map(item -> {
                        Map detail = new HashMap();
                        detail.put("textField_m2j0wj8m", getString(item.get("socode")));//销售订单号
                        detail.put("textField_m2j0wj8n", getString(item.get("warehouse_name")));//仓库名称
                        detail.put("textField_m2j0wj8o", getString(item.get("define29")));//客户存货码
                        detail.put("textField_m2j0wj8p", getString(item.get("inventory_name")));//存货名称
                        detail.put("textField_m2j0wj8q", getString(item.get("free2")));//产品颜色
                        detail.put("textField_m2j0wj8r", getString(item.get("cinvm_unit")));//单位
                        detail.put("numberField_m2j0wj8s", getString(item.get("quantity")));//发货数量
                        detail.put("numberField_m2j0wj8t", getString(item.get("price")));//未税单价
                        detail.put("numberField_m2j0wj8u", getString(item.get("money")));//未税总价
                        detail.put("numberField_m2j0wj8v", getString(item.get("taxprice")));//含税单价
                        detail.put("numberField_m2j0wj8w", getString(item.get("sum")));//含税总价
                        detail.put("numberField_m2j0wj8x", getString(item.get("taxrate")));//税率
                        detail.put("numberField_m2j0wj8y", getString(item.get("tax")));//总税价
                        detail.put("textField_m2j0wj8z", getString(item.get("free1")));//发货客户码

                        return detail;
                    }).collect(Collectors.toList());
                }
                List<Map> list3 = new ArrayList<>();
                if (collectList.size() > 2){
                    list3 = collectList.get(2).stream().map(item -> {
                        Map detail = new HashMap();
                        detail.put("textField_m2j0wj91", getString(item.get("socode")));//销售订单号
                        detail.put("textField_m2j0wj92", getString(item.get("warehouse_name")));//仓库名称
                        detail.put("textField_m2j0wj93", getString(item.get("define29")));//客户存货码
                        detail.put("textField_m2j0wj94", getString(item.get("inventory_name")));//存货名称
                        detail.put("textField_m2j0wj95", getString(item.get("free2")));//产品颜色
                        detail.put("textField_m2j0wj96", getString(item.get("cinvm_unit")));//单位
                        detail.put("numberField_m2j0wj97", getString(item.get("quantity")));//发货数量
                        detail.put("numberField_m2j0wj98", getString(item.get("price")));//未税单价
                        detail.put("numberField_m2j0wj99", getString(item.get("money")));//未税总价
                        detail.put("numberField_m2j0wj9a", getString(item.get("taxprice")));//含税单价
                        detail.put("numberField_m2j0wj9b", getString(item.get("sum")));//含税总价
                        detail.put("numberField_m2j0wj9c", getString(item.get("taxrate")));//税率
                        detail.put("numberField_m2j0wj9d", getString(item.get("tax")));//总税价
                        detail.put("textField_m2j0wj9e", getString(item.get("free1")));//发货客户码

                        return detail;
                    }).collect(Collectors.toList());
                }

                formData.put("tableField_m18nvp82",list1);
                formData.put("tableField_m2j0wj90",list2);
                formData.put("tableField_m2j0wj9f",list3);

                //精准匹配
                List<Map> jsonString = new ArrayList<>();
                jsonString.add(UtilMap.map("key, value, type, operator, componentName", "textField_m18nvp87",getString(consignment2.get("code")),"TEXT","eq","TextField"));
                jsonString.add(UtilMap.map("key, value, type, operator, componentName", "numberField_m18wkih7",new int[]{dsSequence,dsSequence},"DOUBLE","between","NumberField"));

                String searchCondition = JSONObject.toJSONString(jsonString);
                int i=1;
                boolean flag = false;
                while (i<=5 && !flag){
                    try{
                        ydClient.operateData(YDParam.builder()
                                .formUuid(PRODUCT_REAL)
//                                .searchCondition(JSON.toJSONString(UtilMap.map("textField_m18nvp87, numberField_m18wkih7",getString(consignment2.get("code")),dsSequence)))//模糊查询
                                .searchCondition(searchCondition)//精准查询
                                .formDataJson(JSON.toJSONString(formData))
                                .build(), YDConf.FORM_OPERATION.upsert);
                        flag = true;
                    }catch (McException e){
                        if (e.getMessage().contains("The request has failed due to a temporary failure of the server.")){
                            log.error("upsert失败，尝试次数:{}",i);
                            i++;
                            try {
                                Thread.sleep(3000);
                            } catch (InterruptedException ex) {
                                throw new RuntimeException(ex);
                            }
                        }else {
                            log.error("upsert，失败原因:{}" , e.getMessage());
                            errorCodes.add(id);
                            flag = true;
                        }
                    }catch (Exception e){
                        log.error("发货单:{} 同步失败 失败原因:{}",getString(consignment2.get("code")) , e.getMessage());
                        errorCodes.add(id);
                        flag = true;
                    }
                }
                if (i>5){
                    errorCodes.add(id);
                    log.error("发货单:{} 同步失败 失败原因:{}",getString(consignment2.get("code")) , "重试次数过多");
                }
            }

            Map error = new HashMap();
            error.put("ds_sequence",dsSequence);
            error.put("error_count",errorCodes.size());
            //errorCodes逗号分隔
            error.put("errcodes",errorCodes.stream().collect(Collectors.joining(",")));
            errorList.add(error);

        }
        long endTime = System.currentTimeMillis();
        double time = (endTime - beginTime) / 1000.0;
        log.info("同步完成，耗时:{}秒", time);
        log.info("同步失败列表: {}", errorList);

        //记录失败日志
        Map<String,Object> formData = new HashMap<>();
        formData.put("dateField_m21oifwi",beginTime);
        formData.put("dateField_m21oifwp",endTime);
        formData.put("numberField_m21oifwo",time);
        //换行分隔errorList
        String errorStr = errorList.stream().map(item -> {
            String s = "数据源序号:" + item.get("ds_sequence") + ",错误数量:" + item.get("error_count") + ",发货单codes:" + item.get("errcodes");
            return s;
        }).collect(Collectors.joining("\n"));
        formData.put("textareaField_m21oifwj",errorStr);
        ydClient.operateData(YDParam.builder()
                .formUuid("FORM-F297D439FFF747ACB26DEA940850CD9B13LM")
                .formDataJson(JSON.toJSONString(formData))
                .build(), YDConf.FORM_OPERATION.create);
        return McR.success();
    }

    @Override
    public McR testInnerTable() {
        MDC.put("MDC_KEY_PID","1019");

        Map updateFormData = new HashMap();
        List<Map> details = new ArrayList<>();

        for (int i = 0; i < 1000; i++) {
            Map detail = new HashMap();
            detail.put("textField_m2b95sh3", i+"");
            details.add(detail);
        }

        updateFormData.put("tableField_m2b95sh2",details);
        updateFormData.put("textField_m2b95sh5","4");

        List<Map> jsonString = new ArrayList<>();
        jsonString.add(UtilMap.map("key, value, type, operator, componentName", "textField_m2b95sh5","1","TEXT","eq","TextField"));
        String searchCondition = JSONObject.toJSONString(jsonString);

        ydClient.operateData(YDParam.builder()
                .searchCondition(searchCondition)
                .formUuid("FORM-05AFA58A7DC4495C82AD23717C90A608JQ1F")
                .formDataJson(JSON.toJSONString(updateFormData))
//                        .updateFormDataJson(JSON.toJSONString(updateFormData))
                .build(), YDConf.FORM_OPERATION.upsert);


        return null;
    }

    @Override
    public void addVoucher(Map map) {
        MDC.put("MDC_KEY_PID","1002");
        if (Objects.isNull(map.get("formInstId"))){
            log.info("formInstId不能为空！");
            return;
        }
        String formInstId = map.get("formInstId").toString();

        DDR_New ddrNew = ydClient.queryData(YDParam.builder()
                .formInstId(formInstId)
                .build(), YDConf.FORM_QUERY.retrieve_id);
        Map formData = ddrNew.getFormData();
        String type = formData.get("selectField_m2sdpe2p").toString();
        int dsSequence = (int) formData.get("numberField_m2o5b8sh");
        String createUser = ((Map)ddrNew.getOriginator().get("name")).get("nameInChinese").toString();

        Map data = new HashMap();
        switch (type){
            case "资金审批流程":data = process131(formData,dsSequence,createUser);break;
            case "采购部专用资金审批":data = process136(formData,dsSequence,createUser);break;

//            case "信息化建设专用资金审批":data = process138(formData,dsSequence,createUser);break;//20241112 暂时不推送13.8
            default:break;
        }

        //获取交易号
        Map tradeParam = new HashMap();
        tradeParam.put("from_account",fromAccount);
        tradeParam.put("app_key", u8AppKey);
        tradeParam.put("token", getU8Token());
        Map<String, Object> tradeMap = get("https://api.yonyouup.com/system/tradeid", tradeParam, null);
        Map trade = (Map) tradeMap.get("trade");
        String tradeId = getString(trade.get("id"));


        //推送凭证
        Map<String, Object> pushParam = new HashMap<>();
        pushParam.put("from_account", fromAccount);
        pushParam.put("to_account", toAccount);
        pushParam.put("app_key", u8AppKey);
        pushParam.put("token", getU8Token());
        pushParam.put("tradeid", tradeId);
        pushParam.put("sync", 1);
        pushParam.put("ds_sequence",dsSequence);

        Map result = post("https://api.yonyouup.com/api/voucher/add", pushParam, null, data);

        if (!"0".equals(result.get("errcode").toString())){
            log.info("推送凭证失败:{}",result.get("errmsg").toString());
            throw new RuntimeException("推送凭证失败:"+result.get("errmsg").toString());
        }
    }

    private Map process138(Map formData, int dsSequence, String createUser) {
        String schPayAccount = getString(formData.get("selectField_lxydz0ub"));//付款方账号

        String revName = getString(formData.get("textField_lxwwvggc"));//收款人名称

        String company = getString(formData.get("selectField_lxwwvggb"));//公司抬头

        String purpose = getString(formData.get("textField_lxwwvggy"));//付款理由

        String summary = revName + "/" + purpose;//摘要

        String deptName = getString(formData.get("textField_m2sekyf7"));//部门

        String currency = getString(formData.get("textField_m2sekyfi"));//币种

        List<String> sepVoucherCompany = Arrays.asList("宁波卡倍亿电气技术股份有限公司", "宁波卡倍亿新材料科技有限公司", "宁波卡倍亿铜线有限公司", "湖北卡倍亿电气技术有限公司");

        String voucherType =sepVoucherCompany.contains(company) ? "付" : "记";//凭证类型

        String applyAmount = getString(formData.get("numberField_lxwwvggi"));//本次支付金额（元）

        String producer = createUser;//制单人

        //获取供应商信息
        Map<String,Object> supplierParam = new HashMap<>();
        supplierParam.put("from_account",fromAccount);
        supplierParam.put("to_account",toAccount);
        supplierParam.put("app_key", u8AppKey);
        supplierParam.put("token", getU8Token());
        supplierParam.put("page_index", 1);
        supplierParam.put("rows_per_page", 50);
        supplierParam.put("ds_sequence", dsSequence);
        supplierParam.put("name", revName);

        Map<String, Object> supplierMap = get("https://api.yonyouup.com/api/vendor/batch_get", supplierParam, null);
        if (!"0".equals(supplierMap.get("errcode").toString())){
            log.info("获取供应商信息失败:{},{}",supplierMap.get("errmsg").toString(),revName);
            throw new RuntimeException("获取供应商信息失败:"+supplierMap.get("errmsg").toString()+","+revName);
        }
        List<Map> vendorList = (List<Map>) supplierMap.get("vendor");
        String supplierCode = getString(vendorList.get(0).get("code"));

        //获取部门信息
        Map<String,Object> deptParam = new HashMap<>();
        deptParam.put("from_account",fromAccount);
        deptParam.put("to_account",toAccount);
        deptParam.put("app_key", u8AppKey);
        deptParam.put("token", getU8Token());
        deptParam.put("page_index", 1);
        deptParam.put("rows_per_page", 50);
        deptParam.put("ds_sequence", dsSequence);
        deptParam.put("name", deptName);

        Map<String, Object> deptMap = get("https://api.yonyouup.com/api/department/batch_get", deptParam, null);
        if (!"0".equals(deptMap.get("errcode").toString())){
            log.info("获取部门信息失败:{},{}",deptMap.get("errmsg").toString(),deptName);
            throw new RuntimeException("获取部门信息失败:"+deptMap.get("errmsg").toString()+","+deptName);
        }
        List<Map> deptList = (List<Map>) deptMap.get("department");
        String deptCode = getString(deptList.get(0).get("code"));

        Map resultMap = new HashMap();
        Map topInfoMap = new HashMap();

        //记账类型
        topInfoMap.put("voucher_type",voucherType);
        topInfoMap.put("enter",producer);  //制单人

        //credit entry信息   贷方
        Map infoMap = new HashMap();

        Map<String,Object> subjectParam = new HashMap<>();
        subjectParam.put("from_account",fromAccount);
        subjectParam.put("to_account",toAccount);
        subjectParam.put("app_key", u8AppKey);
        subjectParam.put("token", getU8Token());
        subjectParam.put("page_index", 1);
        subjectParam.put("rows_per_page", 50);
        subjectParam.put("ds_sequence", dsSequence);
        subjectParam.put("name", schPayAccount);

        Map<String, Object> subjectMap = get("https://api.yonyouup.com/api/code/batch_get", subjectParam, null);
        if (!"0".equals(subjectMap.get("errcode").toString())){
            log.info("获取科目信息失败:{},{}",supplierMap.get("errmsg").toString(),schPayAccount);
            throw new RuntimeException("获取科目信息失败:"+supplierMap.get("errmsg").toString()+","+schPayAccount);
        }
        List<Map> subjectList = (List<Map>) subjectMap.get("code");
        String subjectCode = getString(subjectList.get(0).get("code"));

        //贷方科目编码
        infoMap.put("account_code", subjectCode);
        //摘要
        infoMap.put("abstract", summary);
        //币种
        infoMap.put("currency", currency);

        //本币借方发生额*与本币贷方发生额不能同时为空
        infoMap.put("natural_credit_currency", applyAmount);

        List<Map> creditCashFlowList = new ArrayList<>();
        Map creditCashFlow = new HashMap();
        //币种
        creditCashFlow.put("cexch_name", currency);
        //本币借方发生额*与本币贷方发生额不能同时为空
        creditCashFlow.put("natural_credit_currency", applyAmount);
        //凭证类别字
        creditCashFlow.put("csign", voucherType);
        //科目编码 - 根据CBS 方，实际打款账户和公司来确定
        creditCashFlow.put("ccode", subjectCode);
        //贷方金额
        creditCashFlow.put("mc", applyAmount);
/*        //现金项目
        creditCashFlow.put("cCashItem", cashItem);
        //现金项目
        creditCashFlow.put("cash_item", cashItem);*/
        creditCashFlow.put("iyear", LocalDate.now().getYear());
        creditCashFlow.put("RowGuid", UUID.randomUUID().toString());

        creditCashFlowList.add(creditCashFlow);

        infoMap.put("cash_flow", creditCashFlowList);

        Map credit = new HashMap();
        credit.put("entry", infoMap);
        log.info("贷方credit:{}", credit);

        //debit entry信息   借方
        Map debit = new HashMap();
        List<Map> entryMapList = new ArrayList<>();
        List<Map> details = (List<Map>) formData.get("tableField_lyiffepf");
        String taxesSummary = ""; // 税金摘要
        for (Map detail : details) {

            String remark = getString(detail.get("textField_lyiffepn"));//备注
            String payType = "其他";//支付类型

            taxesSummary = revName + "/" + remark;

            BigDecimal taxesAmount = new BigDecimal(getString(detail.get("numberField_m38g47en")));//金额

            Map entryMap = new HashMap();

            //科目编号
            entryMap.put("account_code", "110110");//科目：其他  类型：资产
            //摘要
            entryMap.put("abstract", taxesSummary);
            //本币贷方发生额*与本币借方发生额不能同时为空
            entryMap.put("natural_debit_currency", taxesAmount);

            Map auxiliaryMap = new HashMap();
            auxiliaryMap.put("dept_id", deptCode);//部门
            auxiliaryMap.put("supplier_id", supplierCode);//供应商
            entryMap.put("auxiliary", auxiliaryMap);

            entryMapList.add(entryMap);
        }

        debit.put("entry", entryMapList);
        log.info("借方debit:{}", debit);

        topInfoMap.put("debit",debit);
        topInfoMap.put("credit",credit);
        resultMap.put("voucher", topInfoMap);
        log.info("voucher:{}", resultMap);

        return resultMap;
    }

    private Map process136(Map formData, int dsSequence, String createUser) {
        String schPayAccount = getString(formData.get("selectField_lxydz0ub"));//付款方账号

        String revName = getString(formData.get("textField_lxwwvggc"));//收款人名称

        String company = getString(formData.get("selectField_lxwwvggb"));//公司抬头

        String purpose = getString(formData.get("textField_lxwwvggy"));//付款理由

        String summary = revName + "/" + purpose;//摘要

        String deptName = getString(formData.get("textField_m2sekyf7"));//部门

        String currency = getString(formData.get("textField_m2sekyfi"));//币种

        List<String> sepVoucherCompany = Arrays.asList("宁波卡倍亿电气技术股份有限公司", "宁波卡倍亿新材料科技有限公司", "宁波卡倍亿铜线有限公司", "湖北卡倍亿电气技术有限公司");

        String voucherType =sepVoucherCompany.contains(company) ? "付" : "记";//凭证类型

        String applyAmount = getString(formData.get("numberField_lxwwvggi"));//本次支付金额（元）

        String producer = createUser;//制单人

        String cashItem = getString(formData.get("textField_m2sekyfg"));//现金项目

        //获取供应商信息
        Map<String,Object> supplierParam = new HashMap<>();
        supplierParam.put("from_account",fromAccount);
        supplierParam.put("to_account",toAccount);
        supplierParam.put("app_key", u8AppKey);
        supplierParam.put("token", getU8Token());
        supplierParam.put("page_index", 1);
        supplierParam.put("rows_per_page", 50);
        supplierParam.put("ds_sequence", dsSequence);
        supplierParam.put("name", revName);

        Map<String, Object> supplierMap = get("https://api.yonyouup.com/api/vendor/batch_get", supplierParam, null);
        if (!"0".equals(supplierMap.get("errcode").toString())){
            log.info("获取供应商信息失败:{},{}",supplierMap.get("errmsg").toString(),revName);
            throw new RuntimeException("获取供应商信息失败:"+supplierMap.get("errmsg").toString()+","+revName);
        }
        List<Map> vendorList = (List<Map>) supplierMap.get("vendor");
        String supplierCode = getString(vendorList.get(0).get("code"));

        //获取部门信息
        Map<String,Object> deptParam = new HashMap<>();
        deptParam.put("from_account",fromAccount);
        deptParam.put("to_account",toAccount);
        deptParam.put("app_key", u8AppKey);
        deptParam.put("token", getU8Token());
        deptParam.put("page_index", 1);
        deptParam.put("rows_per_page", 50);
        deptParam.put("ds_sequence", dsSequence);
        deptParam.put("name", deptName);

        Map<String, Object> deptMap = get("https://api.yonyouup.com/api/department/batch_get", deptParam, null);
        if (!"0".equals(deptMap.get("errcode").toString())){
            log.info("获取部门信息失败:{},{}",deptMap.get("errmsg").toString(),deptName);
            throw new RuntimeException("获取部门信息失败:"+deptMap.get("errmsg").toString()+","+deptName);
        }
        List<Map> deptList = (List<Map>) deptMap.get("department");
        String deptCode = getString(deptList.get(0).get("code"));

        Map resultMap = new HashMap();
        Map topInfoMap = new HashMap();

        //记账类型
        topInfoMap.put("voucher_type",voucherType);
        topInfoMap.put("enter",producer);  //制单人

        //credit entry信息   贷方
        Map infoMap = new HashMap();

        Map<String,Object> subjectParam = new HashMap<>();
        subjectParam.put("from_account",fromAccount);
        subjectParam.put("to_account",toAccount);
        subjectParam.put("app_key", u8AppKey);
        subjectParam.put("token", getU8Token());
        subjectParam.put("page_index", 1);
        subjectParam.put("rows_per_page", 50);
        subjectParam.put("ds_sequence", dsSequence);
        subjectParam.put("name", schPayAccount);

        Map<String, Object> subjectMap = get("https://api.yonyouup.com/api/code/batch_get", subjectParam, null);
        if (!"0".equals(subjectMap.get("errcode").toString())){
            log.info("获取科目信息失败:{},{}",supplierMap.get("errmsg").toString(),schPayAccount);
            throw new RuntimeException("获取科目信息失败:"+supplierMap.get("errmsg").toString()+","+schPayAccount);
        }
        List<Map> subjectList = (List<Map>) subjectMap.get("code");
        String subjectCode = getString(subjectList.get(0).get("code"));

        //贷方科目编码
        infoMap.put("account_code", subjectCode);
        //摘要
        infoMap.put("abstract", summary);
        //币种
        infoMap.put("currency", currency);

        //本币借方发生额*与本币贷方发生额不能同时为空
        infoMap.put("natural_credit_currency", applyAmount);

        List<Map> creditCashFlowList = new ArrayList<>();
        Map creditCashFlow = new HashMap();
        //币种
        creditCashFlow.put("cexch_name", currency);
        //本币借方发生额*与本币贷方发生额不能同时为空
        creditCashFlow.put("natural_credit_currency", applyAmount);
        //凭证类别字
        creditCashFlow.put("csign", voucherType);
        //科目编码 - 根据CBS 方，实际打款账户和公司来确定
        creditCashFlow.put("ccode", subjectCode);
        //贷方金额
        creditCashFlow.put("mc", applyAmount);
        //现金项目
        creditCashFlow.put("cCashItem", cashItem);
        //现金项目
        creditCashFlow.put("cash_item", cashItem);
        creditCashFlow.put("iyear", LocalDate.now().getYear());
        creditCashFlow.put("RowGuid", UUID.randomUUID().toString());

        creditCashFlowList.add(creditCashFlow);

        infoMap.put("cash_flow", creditCashFlowList);

        Map credit = new HashMap();
        credit.put("entry", infoMap);
        log.info("贷方credit:{}", credit);

        //debit entry信息   借方
        Map debit = new HashMap();
        List<Map> entryMapList = new ArrayList<>();
        List<Map> details = (List<Map>) formData.get("tableField_lxwwvggl");
        String taxesSummary = ""; // 税金摘要
        for (Map detail : details) {

            String productName = getString(detail.get("textField_lxwwvggm"));//货物或劳务名称
            String payType = getString(detail.get("selectField_m2sekyfa")).split("-")[0].split("\\（")[0];//支付类型

            taxesSummary = revName + "/" + productName;

            BigDecimal taxesAmount = new BigDecimal(getString(detail.get("numberField_lxwwvggo")));//金额

            Map entryMap = new HashMap();
            //科目编号
            subjectParam.put("name",payType);
            subjectMap = get("https://api.yonyouup.com/api/code/batch_get", subjectParam, null);

            if (!"0".equals(subjectMap.get("errcode").toString())){
                log.info("获取科目信息失败:{},{}",supplierMap.get("errmsg").toString(),productName);
                throw new RuntimeException("获取科目信息失败:"+supplierMap.get("errmsg").toString()+","+productName);
            }
            subjectList = (List<Map>) subjectMap.get("code");
            subjectCode = getString(subjectList.get(0).get("code"));
            //科目编号
            entryMap.put("account_code", subjectCode);
            //摘要
            entryMap.put("abstract", taxesSummary);
            //本币贷方发生额*与本币借方发生额不能同时为空
            entryMap.put("natural_debit_currency", taxesAmount);

            Map auxiliaryMap = new HashMap();
            auxiliaryMap.put("dept_id", deptCode);//部门
            auxiliaryMap.put("supplier_id", supplierCode);//供应商
            entryMap.put("auxiliary", auxiliaryMap);

            entryMapList.add(entryMap);
        }

        debit.put("entry", entryMapList);
        log.info("借方debit:{}", debit);

        topInfoMap.put("debit",debit);
        topInfoMap.put("credit",credit);
        resultMap.put("voucher", topInfoMap);
        log.info("voucher:{}", resultMap);

        return resultMap;
    }

    private Map process131(Map formData,int dsSequence,String createUser) {
        String schPayAccount = getString(formData.get("selectField_lxydz0ub"));//付款方账号

        String revName = getString(formData.get("textField_lxwwvggc"));//收款人名称

        String company = getString(formData.get("selectField_lxwwvggb"));//公司抬头

        String purpose = getString(formData.get("textField_lxydz0ug"));//用途

        String summary = revName + "/" + purpose;//摘要

        String deptName = getString(formData.get("textField_m2sekyf7"));//部门

        String currency = getString(formData.get("textField_m2sekyfi"));//币种

        List<String> sepVoucherCompany = Arrays.asList("宁波卡倍亿电气技术股份有限公司", "宁波卡倍亿新材料科技有限公司", "宁波卡倍亿铜线有限公司", "湖北卡倍亿电气技术有限公司");

        String voucherType =sepVoucherCompany.contains(company) ? "付" : "记";//凭证类型

        String applyAmount = getString(formData.get("numberField_lxwwvggi"));//本次支付金额（元）

        String producer = createUser;//制单人

        String cashItem = getString(formData.get("textField_m2sekyfg"));//现金项目

        //获取供应商信息
        Map<String,Object> supplierParam = new HashMap<>();
        supplierParam.put("from_account",fromAccount);
        supplierParam.put("to_account",toAccount);
        supplierParam.put("app_key", u8AppKey);
        supplierParam.put("token", getU8Token());
        supplierParam.put("page_index", 1);
        supplierParam.put("rows_per_page", 50);
        supplierParam.put("ds_sequence", dsSequence);
        supplierParam.put("name", revName);

        Map<String, Object> supplierMap = get("https://api.yonyouup.com/api/vendor/batch_get", supplierParam, null);
        if (!"0".equals(supplierMap.get("errcode").toString())){
            log.info("获取供应商信息失败:{},{}",supplierMap.get("errmsg").toString(),revName);
            throw new RuntimeException("获取供应商信息失败:"+supplierMap.get("errmsg").toString()+","+revName);
        }
        List<Map> vendorList = (List<Map>) supplierMap.get("vendor");
        String supplierCode = getString(vendorList.get(0).get("code"));

        //获取部门信息
        Map<String,Object> deptParam = new HashMap<>();
        deptParam.put("from_account",fromAccount);
        deptParam.put("to_account",toAccount);
        deptParam.put("app_key", u8AppKey);
        deptParam.put("token", getU8Token());
        deptParam.put("page_index", 1);
        deptParam.put("rows_per_page", 50);
        deptParam.put("ds_sequence", dsSequence);
        deptParam.put("name", deptName);

        Map<String, Object> deptMap = get("https://api.yonyouup.com/api/department/batch_get", deptParam, null);
        if (!"0".equals(deptMap.get("errcode").toString())){
            log.info("获取部门信息失败:{},{}",deptMap.get("errmsg").toString(),deptName);
            throw new RuntimeException("获取部门信息失败:"+deptMap.get("errmsg").toString()+","+deptName);
        }
        List<Map> deptList = (List<Map>) deptMap.get("department");
        String deptCode = getString(deptList.get(0).get("code"));

        Map resultMap = new HashMap();
        Map topInfoMap = new HashMap();

        //记账类型
        topInfoMap.put("voucher_type",voucherType);
        topInfoMap.put("enter",producer);  //制单人

       //credit entry信息   贷方
        Map infoMap = new HashMap();

        Map<String,Object> subjectParam = new HashMap<>();
        subjectParam.put("from_account",fromAccount);
        subjectParam.put("to_account",toAccount);
        subjectParam.put("app_key", u8AppKey);
        subjectParam.put("token", getU8Token());
        subjectParam.put("page_index", 1);
        subjectParam.put("rows_per_page", 50);
        subjectParam.put("ds_sequence", dsSequence);
        subjectParam.put("name", schPayAccount);

        Map<String, Object> subjectMap = get("https://api.yonyouup.com/api/code/batch_get", subjectParam, null);
        if (!"0".equals(subjectMap.get("errcode").toString())){
            log.info("获取科目信息失败:{},{}",supplierMap.get("errmsg").toString(),schPayAccount);
            throw new RuntimeException("获取科目信息失败:"+supplierMap.get("errmsg").toString()+","+schPayAccount);
        }
        List<Map> subjectList = (List<Map>) subjectMap.get("code");
        String subjectCode = getString(subjectList.get(0).get("code"));

        //贷方科目编码
        infoMap.put("account_code", subjectCode);
        //摘要
        infoMap.put("abstract", summary);
        //币种
        infoMap.put("currency", currency);

        //本币借方发生额*与本币贷方发生额不能同时为空
        infoMap.put("natural_credit_currency", applyAmount);

        Map auxiliary = new HashMap();

//        //项目档案-现流编号
        auxiliary.put("item_class", "05");
        infoMap.put("auxiliary", auxiliary);

        List<Map> creditCashFlowList = new ArrayList<>();
        Map creditCashFlow = new HashMap();
        //币种
        creditCashFlow.put("cexch_name", currency);
        //本币借方发生额*与本币贷方发生额不能同时为空
        creditCashFlow.put("natural_credit_currency", applyAmount);
        //凭证类别字
        creditCashFlow.put("csign", voucherType);

        creditCashFlow.put("ccode", subjectCode);
        //贷方金额
        creditCashFlow.put("mc", applyAmount);
        //现金项目
        creditCashFlow.put("cCashItem", cashItem);
        //现金项目
        creditCashFlow.put("cash_item", cashItem);
        creditCashFlow.put("iyear", LocalDate.now().getYear());
        creditCashFlow.put("RowGuid", UUID.randomUUID().toString());

        creditCashFlowList.add(creditCashFlow);
        infoMap.put("cash_flow", creditCashFlowList);

        Map credit = new HashMap();
        credit.put("entry", infoMap);
        log.info("贷方credit:{}", credit);
        //debit entry信息   借方
        Map debit = new HashMap();
        List<Map> entryMapList = new ArrayList<>();
        List<Map> details = (List<Map>) formData.get("tableField_lxwwvggl");
        BigDecimal taxesSum = BigDecimal.ZERO; // 税金总计
        String taxesSummary = ""; // 税金摘要
        for (Map detail : details) {
            String productName = getString(detail.get("textField_lxwwvggm"));//货物或劳务名称
            String payType = getString(detail.get("selectField_m2sekyfa")).split("-")[0].split("\\（")[0];//支付类型

            taxesSummary = revName + "/" + productName;

            BigDecimal taxesAmount = new BigDecimal(getString(detail.get("numberField_lxwwvggo")));//金额

            BigDecimal taxes = new BigDecimal(getString(detail.get("numberField_m2sekyf8")));//税金金额

            taxesSum = taxesSum.add(taxes);
            Map entryMap = new HashMap();
            //科目编号
            subjectParam.put("name",payType);
            subjectMap = get("https://api.yonyouup.com/api/code/batch_get", subjectParam, null);

            if (!"0".equals(subjectMap.get("errcode").toString())){
                log.info("获取科目信息失败:{},{}",supplierMap.get("errmsg").toString(),productName);
                throw new RuntimeException("获取科目信息失败:"+supplierMap.get("errmsg").toString()+","+productName);
            }
            subjectList = (List<Map>) subjectMap.get("code");
            subjectCode = getString(subjectList.get(0).get("code"));
            entryMap.put("account_code", subjectCode);

            //摘要
            entryMap.put("abstract", revName + "/" + productName);

            //本币贷方发生额*与本币借方发生额不能同时为空
            entryMap.put("natural_debit_currency", taxesAmount.subtract(taxes).toPlainString());

            Map auxiliaryMap = new HashMap();
            auxiliaryMap.put("dept_id", deptCode);//部门
            auxiliaryMap.put("supplier_id", supplierCode);//供应商
            entryMap.put("auxiliary", auxiliaryMap);

            entryMapList.add(entryMap);
        }
        // 添加税金科目
        if (taxesSum.compareTo(BigDecimal.ZERO) == 1) { // 税金总和大于0
            Map entryMap = new HashMap();

            subjectParam.put("name","进项税额");
            subjectMap = get("https://api.yonyouup.com/api/code/batch_get", subjectParam, null);
            if (!"0".equals(subjectMap.get("errcode").toString())){
                log.info("获取科目信息失败:{},{}",supplierMap.get("errmsg").toString(),"进项税额");
                throw new RuntimeException("获取科目信息失败:"+supplierMap.get("errmsg").toString()+","+"进项税额");
            }
            subjectList = (List<Map>) subjectMap.get("code");
            subjectCode = getString(subjectList.get(0).get("code"));

            //科目编号
            entryMap.put("account_code", subjectCode); // 税金
            //摘要
            entryMap.put("abstract", taxesSummary);
            //本币贷方发生额*与本币借方发生额不能同时为空
            entryMap.put("natural_debit_currency", taxesSum.toPlainString());

            Map auxiliaryMap = new HashMap();
            auxiliaryMap.put("dept_id", deptCode);//部门
            auxiliaryMap.put("supplier_id", supplierCode);//供应商
            entryMap.put("auxiliary", auxiliaryMap);
            entryMapList.add(entryMap);
        }
        debit.put("entry", entryMapList);
        log.info("借方debit:{}", debit);

        topInfoMap.put("debit",debit);
        topInfoMap.put("credit",credit);
        resultMap.put("voucher", topInfoMap);
        log.info("voucher:{}", resultMap);

        return resultMap;
    }

    /**
     * 封装GET请求
     *
     * @param url    请求的URL
     * @param params 请求参数
     * @param headers 请求头
     * @return 响应内容
     */
    public static Map<String, Object> get(String url, Map<String, Object> params, Map<String, String> headers) {
        log.info("GET 请求url:{}, 请求参数:{}, 请求头:{}", url, params, headers);
        HttpRequest get = HttpUtil.createGet(url);
        if (params!= null){
            get.form(params);
        }

        if (headers!= null){
            get.addHeaders(headers);
        }
        HttpResponse response = get.execute();

        Map<String, Object> result = null;
        try {
            ObjectMapper objectMapper = new ObjectMapper();
            result = objectMapper.readValue(response.body(), new TypeReference<Map<String, Object>>() {});
        } catch (JsonProcessingException e) {
            throw new RuntimeException(e);
        }

        log.info("响应结果: {}", result);
        return result;
    }

    /**
     * 封装POST请求
     *
     * @param url    请求的URL
     * @param params 请求参数
     * @param headers 请求头
     * @param body   请求体
     * @return 响应内容
     */
    public static Map<String, Object> post(String url, Map<String, Object> params, Map<String, String> headers, Map<String, Object> body) {
        log.info("POST 请求url:{}, 请求参数:{}, 请求头:{}, 请求体:{}", url, params, headers, body);

        String newUrl = url;
        StringBuffer param = new StringBuffer();
        for (String key : params.keySet()) {
            param.append(key + "=" + params.get(key).toString() + "&");
        }
        String paramStr = param.toString();
        paramStr = paramStr.substring(0, paramStr.length() - 1);
        if (newUrl.indexOf("?") >= 0) {
            newUrl += "&" + paramStr;
        } else {
            newUrl += "?" + paramStr;
        }


        HttpRequest request = HttpUtil.createPost(newUrl);
        /*if (params != null) {
            request.form(params);
        }*/
        if (headers != null) {
            request.addHeaders(headers);
        }
        if (body != null) {
            request.body(JSONUtil.toJsonStr(body), "application/json");
        }
        HttpResponse response = request.execute();
//        Map<String,Object> result = JSONUtil.toBean(response.body(), Map.class);
        Map<String, Object> result = null;
        try {
            ObjectMapper objectMapper = new ObjectMapper();
            result = objectMapper.readValue(response.body(), new TypeReference<Map<String, Object>>() {});
        } catch (JsonProcessingException e) {
            throw new RuntimeException(e);
        }
        log.info("响应结果: {}", result);
        return result;
    }

    private String getU8Token(){
        String accessToken = UtilToken.get("u8-token");
        if (StringUtils.isNotBlank(accessToken)) {
            return accessToken;
        } else {
            Map<String,Object> param = new HashMap<>();
            param.put("from_account", fromAccount);
            param.put("app_key", u8AppKey);
            param.put("app_secret", u8AppSecret);

            Map<String, Object> result = get("https://api.yonyouup.com/system/token", param, null);
            Map token = (Map) result.get("token");
            String id = token.get("id").toString();
            log.info("u响应token, {}", id);
            UtilToken.put("u8-token", id, (int) token.get("expiresIn") * 1000L);

            return id;
        }
    }


    private String getString(Object obj){
        return obj == null ? "" : obj.toString();
    }

    public String getTcAccessToken() {
        String accessToken = UtilToken.get("tc-invalid-token-dingtalk");
        if (StringUtils.isNotBlank(accessToken)) {
            return accessToken;
        } else {
            Map param = new HashMap();
            param.put("appkey", appKey);
            param.put("appsecret", appSecret);
            DDR r = (DDR)UtilHttp.doGet("https://oapi.dingtalk.com/gettoken", param, DDR.class);
            log.info("特充响应token, {}", r.getAccessToken());
            accessToken = r.getAccessToken();
            UtilToken.put("tc-invalid-token-dingtalk", accessToken, (long)r.getExpiresIn() * 1000L);
            return accessToken;
        }
    }
}