package other.xsy.jinpanPhaseII.trigger;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.rkhd.platform.sdk.data.model.*;
import com.rkhd.platform.sdk.exception.ApiEntityServiceException;
import com.rkhd.platform.sdk.exception.CustomConfigException;
import com.rkhd.platform.sdk.http.RkhdHttpClient;
import com.rkhd.platform.sdk.log.Logger;
import com.rkhd.platform.sdk.log.LoggerFactory;
import com.rkhd.platform.sdk.model.BatchOperateResult;
import com.rkhd.platform.sdk.model.OperateResult;
import com.rkhd.platform.sdk.model.QueryResult;
import com.rkhd.platform.sdk.model.XObject;
import com.rkhd.platform.sdk.service.XObjectService;
import com.rkhd.platform.sdk.trigger.DataResult;
import org.apache.commons.lang.StringUtils;
import other.xsy.oa.common.CommoninterfaceUtil;
import other.xsy.oa.common.XMLParser;
import other.xsy.oa.triggerservice.BidService;

import java.io.IOException;
import java.time.LocalDateTime;
import java.time.ZoneId;
import java.util.*;
import java.util.stream.Collectors;

/**
 * 描述: 项目新增时触发
 */
public class BidAfterInsertTrigger {

    private static Logger logger = LoggerFactory.getLogger();

    //新建bid调用  insert完了之后 xobjectService查一下把list传进来
    public static void BidAfterInsertTriggerAfterInsertTrigger(List<Bid__c> bidlist){
        List<Bid__c> dataList = bidlist;

        List<Bid__c> bidList = new ArrayList<>();
        Map<Long, Bid__c> oldMap = new HashMap<>();
        List<Long> oppIds = new ArrayList<>();
        List<Opportunity> updateOpp = new ArrayList<>();
        List<String> bidIds = new ArrayList<>();

        for(XObject object : dataList){
            Bid__c bid = (Bid__c) object;
            if(bid.getPayee_Account__c()!=null){
                bid.setPayee_Account__c(bid.getPayee_Account__c().replaceAll("[ | ]",""));
            }
            if(bid.getOpportunity__c()!=null){
                oppIds.add(bid.getOpportunity__c());
            }

            bidList.add(bid);
            bidIds.add(String.valueOf(bid.getId()));
        }
        try{
            List<Bid__c> updateBid = BidService.BidTriggerHandler(bidList,oldMap,true,false);

            //BidOpportunityHandler 逻辑 start
            //项目投标新建，修改项目状态
            Map<Long,Long> resultMap = BidService.getBaojiaMap();
            logger.info("resultMap===" + JSONObject.toJSONString(resultMap));
            if(!oppIds.isEmpty()){
                List<Opportunity> oppList = XObjectService.instance().getByIds("opportunity",oppIds);

                for(Opportunity opp : oppList){
                    if(!Objects.equals(opp.getStageName__c(), "报价/招投标")){
                        Opportunity tempOpp = new Opportunity();
                        tempOpp.setId(opp.getId());
                        logger.info("opp.getEntityType()"+opp.getEntityType());
                        tempOpp.setSaleStageId(resultMap.get(opp.getEntityType()));
                        updateOpp.add(tempOpp);
                    }
                }
            }
            logger.info("updateOpp==" + JSONObject.toJSONString(updateOpp));
            if(!updateOpp.isEmpty()){
                BatchOperateResult batchResult = XObjectService.instance().update(updateOpp);
                if(!batchResult.getSuccess()){
                    for(OperateResult o :batchResult.getOperateResults()){
                        logger.info("批量更新项目招标失败: " + o.getErrorMessage());
                    }
                }
            }
            //BidOpportunityHandler 逻辑 end

            //BPCBidCallOutHandler start
            BidService.BPCBidCallOutHandler(bidIds);
            //BPCBidCallOutHandler end

            logger.info("updateBid" + JSONObject.toJSONString(bidList));
            if(!updateBid.isEmpty()){
                BatchOperateResult batchResult = XObjectService.instance().update(updateBid);
                List<OperateResult> results = batchResult.getOperateResults();
                if (batchResult.getSuccess()) {
                    for (OperateResult oresult : results) {
                        logger.info("ID: " + oresult.getDataId());
                    }
                } else {
                    for (OperateResult oresult : results) {
                        logger.info("批量更新项目招标失败: " + oresult.getErrorMessage());
                    }
                }
            }
        } catch (ApiEntityServiceException | CustomConfigException | IOException e) {
            throw new RuntimeException(e);
        }
    }
    //更新之前查 list 组一个map叫oldMap 更新之后查一下对象再组一个map叫newMap
    public static void BidBeforeUpdateTriggerBeforeTrigger(Map<Long, Bid__c> oldMap, Map<Long, Bid__c> newMap){

        List<Long> bidIds = new ArrayList<>();

        Set<Long> idS = new HashSet<>();
        Set<Long> accidS = new HashSet<>();
        Set<Long> approIds = new HashSet<>();
        Set<Long> approIds2 = new HashSet<>();

        for (Long id : newMap.keySet()) {
            bidIds.add(id);
        }

        try {
            String sql = "SELECT id, belone_Company__c, is_Self_DepartMent__c, department__c, product_Group__c, department2__c, product_Group2__c, department3__c, product_Group3__c, is_Cancellation_Bid_Term__c, is_Fit__c, " +
                    "tenderee_Type__c, bid_Info_Source__c, pro_Introduce__c, join_Account__c, judge_Way__c, customer_Credit__c, payment_Response__c, advice_And_Require__c, is_Fit_Requiredment_Tec__c, is_Suggest_Bid__c, " +
                    "is_Fit_Requiredment_Delivery__c, cannotBid__c, start_Date__c, is_ReBid__c, annualFrame__c, prequalification__c  FROM Bid__c WHERE id IN (" + StringUtils.join(bidIds, ",") + ")";
            QueryResult<Bid__c> bidResult = XObjectService.instance().query(sql, true, true);
            if (bidResult.getSuccess()) {
                for (Bid__c bid : bidResult.getRecords()) {
                    Map<String, Object> pcMap = new HashMap<>();
                    pcMap.put("id", bid.getId());
                    pcMap.put("belone_Company__c", bid.getBelone_Company__c());
                    pcMap.put("is_Self_DepartMent__c", bid.getIs_Self_DepartMent__c());
                    pcMap.put("department__c", bid.getDepartment__c());
                    pcMap.put("product_Group__c", bid.getProduct_Group__c());
                    pcMap.put("department2__c", bid.getDepartment2__c());
                    pcMap.put("product_Group2__c", bid.getProduct_Group2__c());
                    pcMap.put("department3__c", bid.getDepartment3__c());
                    pcMap.put("product_Group3__c", bid.getProduct_Group3__c());
                    oldMap.put(bid.getId(), bid);
                }
            }

            //BidCallOutHandler 更新 时走的逻辑 start
            List<Bid__c> uList = new ArrayList<>();
            for (Long id : newMap.keySet()) {
                Bid__c tempBid = new Bid__c();
                tempBid.setId(id);

                Boolean isShowErr = false;
                String nullFiled = ":";

                //当天日期-7的时间戳
                // 获取当前时间
                LocalDateTime now = LocalDateTime.now();

                // 获取7天前0点的时间
                LocalDateTime sevenDaysAgoMidnight = now.minusDays(7)
                        .withHour(0)
                        .withMinute(0)
                        .withSecond(0)
                        .withNano(0);

                // 转换为时间戳
                long before7timestamp = sevenDaysAgoMidnight.atZone(ZoneId.systemDefault())
                        .toInstant()
                        .toEpochMilli();

                System.out.println("7天前0点时间戳: " + before7timestamp);

                if (oldMap.containsKey(id)) {
                    Bid__c newData = newMap.get(id);
                    Bid__c oldData = oldMap.get(id);
                    if (newMap.get(id).getPayee_Account__c() != null) {
                        tempBid.setPayee_Account__c(newMap.get(id).getPayee_Account__c().replaceAll("[ | ]", ""));
                    }
                    //如果作废，解锁记录
                    if (oldData.getIs_Cancel__c() != newData.getIs_Cancel__c() && newData.getIs_Cancel__c().equals(1)) {
                        if (newData.getLockStatus().equals(2)) {
                            tempBid.setLockStatus(1);
                        }
                        tempBid.setIs_Callout__c(true);
                    }

                    //CannotBid 逻辑 start
                    if (tempBid.getCannotBid__c() && ((newData.getStart_Date__c() != oldData.getStart_Date__c() && (newData.getStart_Date__c() > before7timestamp)) || newData.getIs_ReBid__c().equals(1) || newData.getPrequalification__c().equals(1))) {
                        logger.info("*** jin: ");
                        tempBid.setCannotBid__c(false);
                    }
                    //CannotBid 逻辑 end

                    //同步标识勾选。
                    if ((oldData.getIsCheck__c() != newData.getIsCheck__c() && newData.getIsCheck__c())     //同步标识勾选
                            || (newData.getIsCheck__c() && newData.getStart_Date__c() != oldData.getStart_Date__c())//或 初次同步后开标日期修改
                            || (newData.getIsCheck__c() && newData.getIs_ReBid__c() != oldData.getIs_ReBid__c())// 或 初次同步后取消投标
                            || (newData.getIsCheck__c() && newData.getAnnualFrame__c() != oldData.getAnnualFrame__c())) {// 或 初次同步后修改是否年度框架招标
                        idS.add(id);
                        accidS.add(newData.getPurchase_Department__c());
                    }
                    // Is_Callout__c测试
                    if ((newData.getApproveStatus__c().equals(4) && oldData.getApproveStatus__c() != newData.getApproveStatus__c() && !newData.getOA_Check__c()) || (oldData.getIs_Callout__c() != oldData.getIs_Callout__c() && newData.getIs_Callout__c())) {
                        if ((newData.getDeposit_Apply_Type__c().equals(1) || newData.getDeposit_Apply_Type__c().equals(2)) && (newData.getIs_Have_Deposit__c() != null && newData.getIs_Have_Deposit__c().equals(1))) {
                            tempBid.setLink_Address__c(null);
                            approIds.add(id);
                        } else if (newData.getIs_Have_Deposit__c() != null && newData.getIs_Have_Deposit__c().equals(1) && newData.getDeposit_Apply_Type__c() != null && newData.getDeposit_Apply_Type__c().equals(3)) {
                            tempBid.setGuartee_Link__c(null);
                            tempBid.setKjzl__c(null);
                            approIds2.add(id);
                        }
                    }
                    OperateResult operateResult = XObjectService.instance().update(tempBid,true);
                    if (operateResult.getSuccess()) {
                        logger.info("*** uList: 批量更新成功！");
                    }
                }
            }
            //标识勾选后，同步至智能平台
            if (!idS.isEmpty()) {
                //接口请求TODO------
                //Utilities_Interface.outboundVporalExecute(idS,'Bid');
                List<String> idslist = new ArrayList<>();
                for (Long id : idS) {
                    idslist.add(String.valueOf(id));
                }

                String implResponse = CommoninterfaceUtil.sendInterfaceRequest("Bid", idslist, "outbound");
                //同步IMScode
                implResponse = XMLParser.cleanXmlString(implResponse);
                implResponse.replaceAll("\\\\\\\\r", "");
                implResponse.replaceAll("\\\\\\\\n", "");
                implResponse.replaceAll("\\\\\\\\t", "");
                implResponse = XMLParser.processXmlString(implResponse);
                String s1 = XMLParser.xmlToJson(implResponse);  // 使用当前类的xmlToJson方法
                JSONObject json = JSONObject.parseObject(s1);

                //xml转JSONObject  IMScode赋值
                logger.info("json===" + JSONObject.toJSONString(json));
                //要解析imscode去更新到投标上
                if (json.getJSONObject("response").getJSONObject("fields").getString("msg").equals("操作成功")) {
                    JSONObject responese = json.getJSONObject("response");
                    String imsCode = responese.getJSONObject("fields").getString("imsCode");
                    logger.info("imsCode===" + imsCode);
                    Bid__c updatebid = new Bid__c();
                    updatebid.setId(Long.valueOf(idslist.get(0)));
                    updatebid.setBid_Number__c(imsCode);
                    OperateResult uresult = XObjectService.instance().update(updatebid,true);
                    logger.info("updateInq" + JSONObject.toJSONString(updatebid));
                }
            }

            if (!approIds.isEmpty()) {
                Map<Long, String> linkMap = new HashMap<Long, String>();
                String contentSql = "SELECT id, ContentDownloadUrl__c,Title__c,LinkedEntityId__c FROM ContentDocumentPublicLink__c WHERE LinkedEntityId__c IN (" + approIds + ")";
                //QueryResult<ContentDocumentPublicLink__c> contentResult = XObjectService.instance().query(contentSql);
//                for(ContentDocumentPublicLink__c cdp:[SELECT ContentDownloadUrl__c,Title__c,LinkedEntityId__c
//                FROM ContentDocumentPublicLink__c
//                WHERE LinkedEntityId__c IN :approIds]){
//                    if(linkMap.containsKey(cdp.LinkedEntityId__c)){
//                        linkMap.put(cdp.LinkedEntityId__c,linkMap.get(cdp.LinkedEntityId__c)+'|'+cdp.ContentDownloadUrl__c+'&name='+cdp.Title__c);
//                    }else{
//                        linkMap.put(cdp.LinkedEntityId__c,cdp.ContentDownloadUrl__c+'&name='+cdp.Title__c);
//                    }
//                }
//                for(Long id: newMap.keySet()){
//                    if(linkMap.containsKey(inq.Id)){
//                        inq.Link_Address__c=linkMap.get(inq.Id);
//                    }
//                }
                //接口-----
                //Utilities_Interface.outboundVporalExecute(approIds,'BidDeposit');
                //请求接口
                List<String> idsList = new ArrayList<>();
                for(Long id : approIds){
                    idsList.add(String.valueOf(id));
                }
                String implResponse = CommoninterfaceUtil.sendInterfaceRequest("BidDeposit", idsList, "outbound");

                //同步IMScode
                implResponse = XMLParser.cleanXmlString(implResponse);
                implResponse.replaceAll("\\\\\\\\r", "");
                implResponse.replaceAll("\\\\\\\\n", "");
                implResponse.replaceAll("\\\\\\\\t", "");
                implResponse = XMLParser.processXmlString(implResponse);
                String s1 = XMLParser.xmlToJson(implResponse);  // 使用当前类的xmlToJson方法
                JSONObject json = JSONObject.parseObject(s1);

                //xml转JSONObject  IMScode赋值
                logger.info("json===" + JSONObject.toJSONString(json));
                //要解析imscode去更新到投标上
                if (json.getJSONObject("response").getJSONObject("fields").getString("msg").equals("操作成功")) {
                    JSONObject responese = json.getJSONObject("response");
                    String imsCode = responese.getJSONObject("fields").getString("imsCode");
                    logger.info("imsCode===" + imsCode);
                    Bid__c updatebid = new Bid__c();
                    updatebid.setId(Long.valueOf(idsList.get(0)));
                    updatebid.setOA_Check__c(true);
                    updatebid.setOA_Time__c(System.currentTimeMillis());

                    OperateResult uresult = XObjectService.instance().update(updatebid,true);
                    if(uresult.getSuccess()){
                        logger.error("229====" + uresult.getErrorMessage());
                    }else{
                        logger.error("349====" + uresult.getErrorMessage());
                    }
                    logger.info("updateInq" + JSONObject.toJSONString(updatebid));
                }
            }

            if (!approIds2.isEmpty()) {
                //保函文件链接
                Map<Long, String> linkMap = new HashMap<Long, String>();
                //开具资料文件链接
                Map<Long, String> linkMap2 = new HashMap<Long, String>();
//                for(ContentDocumentPublicLink__c cdp:[SELECT ContentDownloadUrl__c,Title__c,LinkedEntityId__c
//                FROM ContentDocumentPublicLink__c
//                WHERE LinkedEntityId__c IN :approIds2
//                AND Title__c != null
//                AND ContentDownloadUrl__c != null]){
//                    if(linkMap.containsKey(cdp.LinkedEntityId__c)){
//                        if(cdp.Title__c.contains('用户格式')){
//                            linkMap.put(cdp.LinkedEntityId__c,linkMap.get(cdp.LinkedEntityId__c)+'|'+cdp.ContentDownloadUrl__c+'&name='+cdp.Title__c);
//                        }
//                    }else{
//                        if(cdp.Title__c.contains('用户格式')){
//                            linkMap.put(cdp.LinkedEntityId__c,cdp.ContentDownloadUrl__c+'&name='+cdp.Title__c);
//                        }
//                    }
//                    if(linkMap2.containsKey(cdp.LinkedEntityId__c)){
//                        if(cdp.Title__c.contains('招标文件')){
//                            linkMap2.put(cdp.LinkedEntityId__c,linkMap2.get(cdp.LinkedEntityId__c)+'|'+cdp.ContentDownloadUrl__c+'&name='+cdp.Title__c);
//                        }
//                    }else{
//                        if(cdp.Title__c.contains('招标文件')){
//                            linkMap2.put(cdp.LinkedEntityId__c,cdp.ContentDownloadUrl__c+'&name='+cdp.Title__c);
//                        }
//                    }
//                }
//                for(Bid__c inq:(List<Bid__c>)Trigger.new){
//                    if(linkMap.containsKey(inq.Id)){
//                        inq.Guartee_Link__c=linkMap.get(inq.Id);
//                    }
//                    if(linkMap2.containsKey(inq.Id)){
//                        inq.Kjzl__c=linkMap2.get(inq.Id);
//                    }
//                }
                //接口传值-----
                //Utilities_Interface.outboundVporalExecute(approIds2,'BidGuarantee');
                List<String> idsList = new ArrayList<>();
                for(Long id : approIds2){
                    idsList.add(String.valueOf(id));
                }
                String implResponse = CommoninterfaceUtil.sendInterfaceRequest("BidGuarantee", idsList, "outbound");
                //同步IMScode
                implResponse = XMLParser.cleanXmlString(implResponse);
                implResponse.replaceAll("\\\\\\\\r", "");
                implResponse.replaceAll("\\\\\\\\n", "");
                implResponse.replaceAll("\\\\\\\\t", "");
                implResponse = XMLParser.processXmlString(implResponse);
                String s1 = XMLParser.xmlToJson(implResponse);  // 使用当前类的xmlToJson方法
                JSONObject json = JSONObject.parseObject(s1);

                //xml转JSONObject  IMScode赋值
                logger.info("json===" + JSONObject.toJSONString(json));
                //要解析imscode去更新到投标上
                if (json.getJSONObject("response").getJSONObject("fields").getString("msg").equals("操作成功")) {
                    JSONObject responese = json.getJSONObject("response");
                    String imsCode = responese.getJSONObject("fields").getString("imsCode");
                    logger.info("imsCode===" + imsCode);
                    Bid__c updatebid = new Bid__c();
                    updatebid.setId(Long.valueOf(idsList.get(0)));
                    updatebid.setOA_Check__c(true);
                    updatebid.setOA_Time__c(System.currentTimeMillis());

                    OperateResult uresult = XObjectService.instance().update(updatebid,true);
                    if(uresult.getSuccess()){
                        logger.info("270====" + uresult.getDataId());
                    }else{
                        logger.error("272====" + uresult.getErrorMessage());
                    }
                    logger.info("updateInq" + JSONObject.toJSONString(updatebid));
                }
            }

            if (!accidS.isEmpty()) {
                List<String> accIdSet = new ArrayList<>();
                for (Long accid : accidS) {
                    accIdSet.add(String.valueOf(accid));
                }
                //调用接口
                //Utilities_Interface.outboundVporalExecute(accidS,'Account');
                CommoninterfaceUtil.sendInterfaceRequest("Account", accIdSet, "outbound");
            }

            //调用after的triger

        } catch (ApiEntityServiceException e) {
            throw new RuntimeException(e);
        }
    }

    public static void BidBeforeUpdateTriggerAfterTrigger(Map<Long, Bid__c> oldMap, Map<Long, Bid__c> newMap) throws ApiEntityServiceException {
        //获取beforeUpdate 的list
        List<Bid__c> bidList = new ArrayList<>();

        List<String> bidIds = new ArrayList<>();


        for(Long id : newMap.keySet()){
            bidList.add(newMap.get(id));
            bidIds.add(String.valueOf(id));
        }


        List<Bid__c> bidupdateList = BidService.BidTriggerHandler(bidList, oldMap,true,false);
        if(bidupdateList.size()>0){
            BatchOperateResult batchResult = XObjectService.instance().update(bidupdateList, true,true);
            List<OperateResult> results = batchResult.getOperateResults();
            if (batchResult.getSuccess()) {
                for (OperateResult oresult : results) {
                    logger.info("ID: " + oresult.getDataId());
                }
            } else {
                for (OperateResult oresult : results) {
                    logger.info("批量更新项目招标失败: " + oresult.getErrorMessage());
                }
            }
        }

        //BPCBidCallOutHandler start
        BidService.BPCBidCallOutHandler(bidIds);
        //BPCBidCallOutHandler end

    }
    /**
     * 市场活动 expense_detail__c 触发  新增后，更新后，删除后，恢复后
     */
    public static void ExpenseDetailTriggerafterInUpDeHf(List<ExpenseDetail__c> newList, List<ExpenseDetail__c> oldList) {
        logger.info("费用报销明细触发器 newList:" + newList);
        try {
            List<DataResult> result = new ArrayList<>();
            if(newList != null && !newList.isEmpty()){
                // 查询市场活动不为空的
                Set<Long> collect = newList.stream()
                        .filter(expenseDetail -> ((ExpenseDetail__c) expenseDetail).getCampaign__c() != null)
                        .map(expenseDetail -> ((ExpenseDetail__c) expenseDetail).getCampaign__c())
                        .collect(Collectors.toSet());
                if(!collect.isEmpty()){
                    for (ExpenseDetail__c expenseDetail__c : oldList) {
                        if (expenseDetail__c.getCampaign__c()!=null) {
                            collect.add(expenseDetail__c.getCampaign__c());
                        }
                    }
                }
                logger.info("需要重新累计的市场活动："+ JSON.toJSONString(collect));
                if (collect.size()>0){
                    String sql = "select id,amount__c,campaign__c from expenseDetail__c where campaign__c  in (" + parseListToStr2(collect)+")";
                    logger.info("sql:"+sql);
                    QueryResult<ExpenseDetail__c> query = XObjectService.instance().query(sql, true, true);
                    HashMap<Long, Double> map = new HashMap<>();
                    // 先给每个 市场活动的金额 初始为空
                    for (Long l : collect) {
                        map.put(l,0.0);
                    }
                    // 给每个市场活动的金额 进行累计汇总
                    for (ExpenseDetail__c record : query.getRecords()) {
                        if (map.containsKey(record.getCampaign__c())) {
                            map.put(record.getCampaign__c(), map.get(record.getCampaign__c()) + record.getAmount__c());
                        }else {
                            map.put(record.getCampaign__c(), record.getAmount__c());
                        }
                    }
                    logger.info("map:"+JSON.toJSONString(map));
                    ArrayList<Campaign> campaignArrayList = new ArrayList<>();
                    if (!map.isEmpty()){
                        for (Map.Entry<Long, Double> entry : map.entrySet()) {
                            Campaign campaign = new Campaign();
                            campaign.setId(entry.getKey());
                            campaign.setActualCost(entry.getValue());
                            campaignArrayList.add(campaign);
                            result.add(new DataResult(true,"",campaign));
                        }
                        logger.info("campaignArrayList:" + JSON.toJSONString(campaignArrayList));
                        BatchOperateResult update = XObjectService.instance().update(campaignArrayList,true,true);
                    }
                }else {
                    for (XObject xObject : newList) {
                        result.add(new DataResult(true, "",xObject));
                    }
                }
            }
            logger.info("费用报销明细触发器 结果:" + JSON.toJSONString(result));
        }catch (Exception e){
            logger.error("费用报销明细触发器 异常:" + e);
        }
    }

    /**
     * 发货单盖章更新 触发
     */
    public static void ReceiptandInspectionNoteTriggerafterUpdate(List<Receipt_and_Inspection_Note__c> newList, List<Receipt_and_Inspection_Note__c> oldList){
        logger.info("发货单盖章更新触发器 newList:" + newList);
        try {
            List<DataResult> results = new ArrayList<>();
            RkhdHttpClient rkhdclient = null;
            try {
                rkhdclient = RkhdHttpClient.instance();
            } catch (IOException e) {
                throw new RuntimeException(e);
            }
            Map<Long,Receipt_and_Inspection_Note__c> newMap = new HashMap<>();
            logger.info("afterUpdateTrigger触发器启动: 更新条数" + newList.size());
            //拿到更新后的新数据
            for (Receipt_and_Inspection_Note__c xObject : newList) {
                newMap.put(xObject.getId(),xObject);
                results.add(new DataResult(true, "", xObject));
            }
            logger.info("新数据" + newMap);
            logger.info("afterUpdate拿到oldlist====" + oldList);
            Map<Long, Receipt_and_Inspection_Note__c> oldMap = new HashMap<>();
            for (Receipt_and_Inspection_Note__c old : oldList) {
                oldMap.put(old.getId(),old);
            }
            logger.info("旧数据" + oldMap);
            Set<Long> raiIdSet = new HashSet<>();
            for(Map.Entry<Long,Receipt_and_Inspection_Note__c> entry : newMap.entrySet()){
                Receipt_and_Inspection_Note__c newPp = entry.getValue();
                Receipt_and_Inspection_Note__c oldPp = oldMap.get(newPp.getId());

                if(!Objects.equals(newPp.getDelivery__c(), oldPp.getDelivery__c())
                        || !newPp.getRecycle_Identification__c().equals(oldPp.getRecycle_Identification__c())
                        || !Objects.equals(newPp.getStatue__c(), oldPp.getStatue__c())
                        || !Objects.equals(newPp.getNot_Recycle_Reason__c(), oldPp.getNot_Recycle_Reason__c())
                        || !Objects.equals(newPp.getAcceptance_Type__c(), oldPp.getAcceptance_Type__c())
                        || !Objects.equals(newPp.getClosed_Reason__c(), oldPp.getClosed_Reason__c())
                        || !Objects.equals(newPp.getRemark__c(), oldPp.getRemark__c())
                ){
                    //更新后数据与更新前数据不一致，则执行更新
                    raiIdSet.add(newPp.getId());
                }
            }

            if(raiIdSet!=null){
                //todo     调用SAP接口
                //Utilities_Interface.outboundSAPVportalExecute(rlIdSet, 'ReconciliationTo_SAP');
                List<String> stringList = raiIdSet.stream()
                        // 将每个 Long 转换为 String
                        .map(String::valueOf)
                        // 收集为 List
                        .collect(Collectors.toList());
                CommoninterfaceUtil.sendInterfaceRequest("NoteStatusToSAP",stringList,"outbound");
                logger.info("调用外部SAP接口===========");
            }
            logger.info("发货单盖章更新触发器 结果:" + JSON.toJSONString(results));
        }catch (Exception e){
            logger.error("发货单盖章更新触发器 异常:" + e);
        }
    }


    /**
     * 将集合转换为SQL IN子句格式的字符串
     * @param collection 需要转换的集合
     * @return 格式化后的字符串，如: 'item1', 'item2'
     */
    public static String parseListToStr2(Collection<?> collection) {
        if (collection == null || collection.isEmpty()) {
            return "";
        }
        return collection.stream()
                .map(item -> "'" + item + "'")
                .collect(Collectors.joining(", "));
    }


}