ContractRunner.java

package vion.cron;

import com.fasterxml.jackson.databind.JsonNode;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.dromara.hutool.core.collection.CollUtil;
import org.dromara.hutool.core.collection.ListUtil;
import org.dromara.hutool.core.date.TimeUtil;
import org.dromara.hutool.core.lang.Opt;
import org.dromara.hutool.core.math.NumberUtil;
import org.dromara.hutool.core.text.StrUtil;
import org.dromara.hutool.core.util.ObjUtil;
import org.dromara.hutool.crypto.SecureUtil;
import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.http.MediaType;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.client.RestClient;
import vion.constant.RedisKeyEnum;
import vion.model.Dictionary;
import vion.model.*;
import vion.service.*;
import vion.utils.JsonUtil;

import java.math.BigDecimal;
import java.util.*;
import java.util.function.Function;
import java.util.stream.Collectors;
import java.util.stream.StreamSupport;

/**
 * 从crm系统定时同步合同信息
 */
@Component
@RequiredArgsConstructor
@Slf4j
public class ContractRunner {

    private final IContractService contractService;
    private final IDictionaryService dictionaryService;
    private final IContractPaymentService contractPaymentService;
    private final IRContractUserService contractUserService;
    private final IRContractStoreService contractStoreService;
    private final IStoreService storeService;
    private final IPaymentService paymentService;
    private final IRContractProductService contractProductService;
    private final RedissonClient redissonClient;
    private final RestClient bongRestClient;

    @Value("${xbongbong.token}")
    private String token;
    @Value("${xbongbong.corpid}")
    private String corpId;

    @Scheduled(cron = "0 0 8-20 * * *")
    @Transactional(rollbackFor = Exception.class)
    public void contractSync() {
        log.info("【开始】从crm系统同步合同信息");
        Long modifyTime = Opt.ofNullable((Long) redissonClient.getBucket(RedisKeyEnum.CONTRACT_SYNC_NEW_TIME.getVal()).get()).orElse(0L);

        // 只同步申请日期（原CRM中的签订日期）2024-05-07号（含）之后的合同
        var json = JsonUtil.createObj()
                .putPOJO("sortMap", JsonUtil.createObj()
                        .put("field", "updateTime")
                        .put("sort", "desc"))
                .putPOJO("conditions", JsonUtil.createArr()
                        .add(JsonUtil.createObj()
                                .put("attr", "date_3")
                                .put("symbol", "greaterequal")
                                .putPOJO("value", new String[]{"1715356800"}))
                        .add(JsonUtil.createObj()
                                .put("attr", "updateTime")
                                .put("symbol", "greatethan")
                                .putPOJO("value", new String[]{String.valueOf(modifyTime / 1000)}))
                )
                .put("corpid", corpId)
                .put("formId", 8429903)
                .put("pageSize", 100);
        var jobO = bongRestClient.post()
                .uri("/pro/v2/api/contract/list")
                .contentType(MediaType.APPLICATION_JSON)
                .header("sign", SecureUtil.sha256(json.toString() + token))
                .body(json.toString())
                .retrieve()
                .body(JsonNode.class);
        if (ObjUtil.isNull(jobO) || jobO.path("code").asInt() != 1) {
            log.error("获取合同列表失败,错误原因:{}", jobO);
            return;
        }
        var cnt = jobO.path("result").path("totalCount").asInt();
        var page = jobO.path("result").path("totalPage").asInt();
        if (NumberUtil.equals(cnt, 0)) {
            log.info("没有需要插入或更新的合同");
            return;
        }
        var jsonArray = jobO.path("result").withArray("list");
        // 合同记录唯一 dataId
        var dataIdSet = StreamSupport.stream(jsonArray.spliterator(), false)
                .map(v -> v.path("dataId").asInt())
                .collect(Collectors.toSet());

        for (int i = 2; i <= page; i++) {
            var jsonR = JsonUtil.createObj()
                    .putPOJO("sortMap", JsonUtil.createObj()
                            .put("field", "updateTime")
                            .put("sort", "desc"))
                    .putPOJO("conditions", JsonUtil.createArr()
                            .add(JsonUtil.createObj()
                                    .put("attr", "date_3")
                                    .put("symbol", "greaterequal")
                                    .putPOJO("value", new String[]{"1715356800"}))
                            .add(JsonUtil.createObj()
                                    .put("attr", "updateTime")
                                    .put("fieldType", "10015")
                                    .put("symbol", "greatethan")
                                    .putPOJO("value", new String[]{String.valueOf(modifyTime)}))
                    )
                    .put("corpid", corpId)
                    .put("formId", 8429903)
                    .put("page", i)
                    .put("pageSize", 100);
            var jobR = bongRestClient.post()
                    .uri("/pro/v2/api/contract/list")
                    .contentType(MediaType.APPLICATION_JSON)
                    .header("sign", SecureUtil.sha256(jsonR.toString() + token))
                    .body(jsonR.toString())
                    .retrieve()
                    .body(JsonNode.class);
            var jsonArrR = jobR.path("result").withArray("list");
            var dataIdSetR = StreamSupport.stream(jsonArrR.spliterator(), false)
                    .map(v -> v.path("dataId").asInt())
                    .collect(Collectors.toSet());
            dataIdSet.addAll(dataIdSetR);
        }

        Map<String, Integer> contractTypeMap = dictionaryService.lambdaQuery().eq(Dictionary::getType, "contract_type").list().stream().collect(Collectors.toMap(Dictionary::getValue, Dictionary::getKey));

        List<Contract> insOrUpdContractList = new ArrayList<>();
        List<RContractProduct> productList = new ArrayList<>();
        var crmProList = getProductList();
        if (CollUtil.isEmpty(crmProList)) {
            log.error("获取CRM产品信息为空");
            return;
        }
        dataIdSet.forEach(dataId -> {
            var json1 = JsonUtil.createObj()
                    .put("corpid", corpId)
                    .put("dataId", dataId);
            var jobj1 = bongRestClient.post()
                    .uri("/pro/v2/api/contract/detail")
                    .contentType(MediaType.APPLICATION_JSON)
                    .header("sign", SecureUtil.sha256(json1.toString() + token))
                    .body(json1.toString())
                    .retrieve()
                    .body(JsonNode.class);
            if (ObjUtil.isNull(jobj1) || jobj1.path("code").asInt() != 1) {
                log.error("获取合同详情失败,错误原因:{}", jobj1);
                return;
            }
            var result = jobj1.path("result");
            var jsonObj1 = result.path("data");
            Contract contract = new Contract();
            contract.setName(jsonObj1.path("text_14").asText());
            contract.setContractNo(jsonObj1.path("serialNo").asText());
            contract.setType(contractTypeMap.getOrDefault(jsonObj1.path("text_17").path("text").asText(), 0));
            contract.setSignDate(TimeUtil.of(jsonObj1.path("date_1").asLong() * 1000).toLocalDate());
            contract.setMaintainSdate(Opt.ofNullable(jsonObj1.path("date_4")).filter(JsonNode::isNumber).map(sec -> TimeUtil.of(sec.asLong() * 1000).toLocalDate()).orElse(null));
            contract.setMaintainEdate(Opt.ofNullable(jsonObj1.path("date_5")).filter(JsonNode::isNumber).map(sec -> TimeUtil.of(sec.asLong() * 1000).toLocalDate()).orElse(null));
            String warrantyPeriod = jsonObj1.path("text_23").path("text").asText("");
            // 23 质保 没有维保开始时间和结束时间 25 维保
            if (StrUtil.isNotBlank(warrantyPeriod) && warrantyPeriod.contains("个月")) {
                String substring = warrantyPeriod.substring(0, (warrantyPeriod.length() - 2));
                contract.setWarrantyPeriod(Integer.parseInt(substring));
            }
            contract.setStatus(1);
            contract.setTotalAmount(jsonObj1.path("num_1").decimalValue());
            contract.setPaidAmount(BigDecimal.ZERO);
            contract.setReceivableAmount(BigDecimal.ZERO);
            contract.setOutstandingAmount(jsonObj1.path("num_1").decimalValue());
            var paymentForm = jsonObj1.withArray("subForm_1");
            if (!paymentForm.isEmpty()) {
                paymentForm.forEach(pf -> {
                    var ratio = NumberUtil.div(BigDecimal.valueOf(Double.parseDouble(pf.path("text_1").asText())), 100);
                    var date = TimeUtil.of(pf.path("date_1").asLong() * 1000).toLocalDate();
                    var stage = pf.path("text_2").path("text").asText();
                    if (StrUtil.equals(stage, "预付款")) {
                        contract.setSignRatio(ratio);
                        contract.setSignDate1(date);
                    } else if (StrUtil.equals(stage, "到货款")) {
                        contract.setArriveRatio(ratio);
                        contract.setArriveDate(date);
                    } else if (StrUtil.equals(stage, "系统验收款")) {
                        contract.setSystemCheckRatio(ratio);
                        contract.setSystemCheckDate(date);
                    } else if (StrUtil.equals(stage, "项目终验款")) {
                        contract.setProjectCheckRatio(ratio);
                        contract.setProjectCheckDate(date);
                    } else if (StrUtil.equals(stage, "质保款")) {
                        contract.setWarrantyRatio(ratio);
                        contract.setWarrantyDate(date);
                    } else if (StrUtil.equals(stage, "维保第一笔款")) {
                        contract.setMaintainRatio1(ratio);
                        contract.setMaintainDate1(date);
                    } else if (StrUtil.equals(stage, "维保第二笔款")) {
                        contract.setMaintainRatio2(ratio);
                        contract.setMaintainDate2(date);
                    } else if (StrUtil.equals(stage, "维保第三笔款")) {
                        contract.setMaintainRatio3(ratio);
                        contract.setMaintainDate3(date);
                    } else if (StrUtil.equals(stage, "维保进度款")) {
                        contract.setMaintainProgressRatio(ratio);
                        contract.setMaintainProgressDate(date);
                    } else if (StrUtil.equals(stage, "维保验收款")) {
                        contract.setMaintainAcceptanceRatio(ratio);
                        contract.setMaintainAcceptanceDate(date);
                    }
                });
            }
            contract.setSubject("北京文安智能技术股份有限公司");
            contract.setCustomerName(jsonObj1.path("text_2").path("name").asText());
            contract.setSaleName(jsonObj1.path("text_8").path("name").asText());
            contract.setBackInfo(jsonObj1.path("text_29").asText());
            contract.setCreateUser(-1L);
            contract.setModifyUser(-1L);
            contract.setEntryTime(TimeUtil.of(result.path("addTime").asLong() * 1000));
            contract.setOriginalModTime(TimeUtil.of(result.path("updateTime").asLong() * 1000));
            insOrUpdContractList.add(contract);

            var productArr = jsonObj1.withArray("array_4");
            if (!productArr.isEmpty()) {
                productArr.forEach(pro -> {
                    var crmProJson =
                            crmProList.stream()
                                    .filter(p -> p.path("dataId").asInt() != 0 && p.path("dataId").asInt() == pro.path(
                                            "text_1").asInt())
                                    .toList()
                                    .getFirst();
                    var crmPro = crmProJson.path("data");

                    var contractProduct = new RContractProduct();
                    contractProduct.setContractNo(contract.getContractNo());
                    contractProduct.setProductName(crmPro.path("text_1").asText());
                    contractProduct.setProductCode(crmPro.path("serialNo").asText());
                    contractProduct.setProductModel(crmPro.path("text_4").asText());
                    contractProduct.setNum(pro.path("num_3").asInt());
                    contractProduct.setTaxPrice(pro.path("num_1").decimalValue());
                    contractProduct.setTaxRate(BigDecimal.valueOf(Integer.parseInt(crmPro.path("text_12").asText().replace(
                            "%", "")) / 100));
                    // contractProduct.setNoTaxPrice(product.getBigDecimal("num_6"));
                    contractProduct.setDiscountRate(NumberUtil.div(pro.path("num_4").decimalValue(), 100));
                    contractProduct.setActualPrice(pro.path("num_6").decimalValue());
                    // contractProduct.setErase(product);
                    contractProduct.setTotalPrice(pro.path("num_5").decimalValue());
                    productList.add(contractProduct);
                });
            }
        });
        insOrUpdContractList.sort(Comparator.comparing(Contract::getOriginalModTime).reversed());
        var no2ProductMap = productList.stream().collect(Collectors.groupingBy(RContractProduct::getContractNo));

        // 已存在的合同列表
        Map<String, Contract> no2ContactMap = contractService.list().stream().collect(Collectors.toMap(Contract::getContractNo, Function.identity()));

        List<Long> updContractIdList = new ArrayList<>();
        insOrUpdContractList.forEach(v -> {
            if (no2ContactMap.containsKey(v.getContractNo())) {
                Long contractId = no2ContactMap.get(v.getContractNo()).getId();
                v.setId(contractId);
                // 已有合同不更新状态
                v.setStatus(null);
                updContractIdList.add(contractId);
                // 移除已存在合同的关联产品信息，防止重复插入
                no2ProductMap.remove(v.getContractNo());
            }
        });
        contractProductService.saveBatch(no2ProductMap.values().stream().flatMap(Collection::stream).toList());

        // 合同更新，同步调用一下更新项目的维保状态
        Opt.ofEmptyAble(updContractIdList)
                .map(contractIdList -> contractStoreService.lambdaQuery().in(RContractStore::getContractId, contractIdList).list())
                .map(csList -> csList.stream().map(RContractStore::getStoreId).collect(Collectors.toList()))
                .filter(CollUtil::isNotEmpty)
                .ifPresent(storeService::calMaintainStatus);

        contractService.saveOrUpdateBatch(insOrUpdContractList, 500);
        insOrUpdContractList.forEach(v -> {
            // 合同状态不为空，代表此条记录为新增，需要同步销售人信息到 r_contract_user 表中
            if (ObjUtil.isNotNull(v.getStatus())) {
                RContractUser contractUser = new RContractUser();
                String userId = Opt.ofNullable(redissonClient.getBucket(RedisKeyEnum.DING_PREFIX.getVal() + RedisKeyEnum.USER_NAME.getVal() + v.getSaleName()).get())
                        .map(u -> (User) u)
                        .map(User::getUserid)
                        .orElse(null);
                contractUser.setUserId(userId);
                contractUser.setUsername(v.getSaleName());
                contractUser.setEnterDate(v.getSignDate());
                contractUser.setContractId(v.getId());
                contractUser.setContractNo(v.getContractNo());
                contractUserService.save(contractUser);
            }
        });

        List<ContractPayment> existContractPaymentList = contractPaymentService.list();
        Map<Long, Map<Integer, Long>> contractId2PaymentMap = existContractPaymentList.stream().collect(Collectors.groupingBy(ContractPayment::getContractId, Collectors.toMap(ContractPayment::getPaymentType, ContractPayment::getId)));

        // 合同付款比例处理
        contractPaymentHandler(insOrUpdContractList, contractId2PaymentMap);

        List<Payment> paymentList = paymentService.list();
        Map<String, BigDecimal> no2PaymentMap = paymentList.stream().collect(Collectors.groupingBy(Payment::getContractNo, Collectors.reducing(BigDecimal.ZERO, Payment::getPaymentAmount, BigDecimal::add)));

        insOrUpdContractList.forEach(c -> {
            String contractNo = c.getContractNo();
            Contract exist = contractService.lambdaQuery().eq(Contract::getContractNo, contractNo).one();
            Contract updDto = new Contract();
            updDto.setId(exist.getId());
            updDto.setPaidAmount(no2PaymentMap.getOrDefault(contractNo, BigDecimal.ZERO));
            contractPaymentService.calMoney(exist, updDto);
            contractService.updateById(updDto);
        });
        redissonClient.getBucket(RedisKeyEnum.CONTRACT_SYNC_NEW_TIME.getVal()).set(TimeUtil.toEpochMilli(insOrUpdContractList.getFirst().getOriginalModTime()));
        log.info("【结束】从crm系统同步合同信息");
    }

    private void contractPaymentHandler(List<Contract> insOrUpdContractList, Map<Long, Map<Integer, Long>> contractId2PaymentMap) {
        List<ContractPayment> contractPaymentList = new ArrayList<>();
        for (Contract contract : insOrUpdContractList) {
            // 签订
            ContractPayment contractSignPayment = new ContractPayment();
            contractSignPayment.setId(contractId2PaymentMap.getOrDefault(contract.getId(), new HashMap<>()).get(1));
            contractSignPayment.setContractId(contract.getId());
            contractSignPayment.setPaymentType(1);
            contractSignPayment.setPaymentRatio(Opt.ofNullable(contract.getSignRatio()).orElse(BigDecimal.ZERO));
            contractSignPayment.setPaymentDate(contract.getSignDate1());
            contractSignPayment.setNodeDate(contract.getSignDate());
            contractPaymentList.add(contractSignPayment);

            // 到货
            ContractPayment contractArrivePayment = new ContractPayment();
            contractArrivePayment.setId(contractId2PaymentMap.getOrDefault(contract.getId(), new HashMap<>()).get(2));
            contractArrivePayment.setContractId(contract.getId());
            contractArrivePayment.setPaymentType(2);
            contractArrivePayment.setPaymentRatio(Opt.ofNullable(contract.getArriveRatio()).orElse(BigDecimal.ZERO));
            contractArrivePayment.setPaymentDate(contract.getArriveDate());
            contractPaymentList.add(contractArrivePayment);

            // 系统验收
            ContractPayment contractSystemCheckPayment = new ContractPayment();
            contractSystemCheckPayment.setId(contractId2PaymentMap.getOrDefault(contract.getId(), new HashMap<>()).get(3));
            contractSystemCheckPayment.setContractId(contract.getId());
            contractSystemCheckPayment.setPaymentType(3);
            contractSystemCheckPayment.setPaymentRatio(Opt.ofNullable(contract.getSystemCheckRatio()).orElse(BigDecimal.ZERO));
            contractSystemCheckPayment.setPaymentDate(contract.getSystemCheckDate());
            contractPaymentList.add(contractSystemCheckPayment);

            // 项目验收
            ContractPayment contractProjectCheckPayment = new ContractPayment();
            contractProjectCheckPayment.setId(contractId2PaymentMap.getOrDefault(contract.getId(), new HashMap<>()).get(4));
            contractProjectCheckPayment.setContractId(contract.getId());
            contractProjectCheckPayment.setPaymentType(4);
            contractProjectCheckPayment.setPaymentRatio(Opt.ofNullable(contract.getProjectCheckRatio()).orElse(BigDecimal.ZERO));
            contractProjectCheckPayment.setPaymentDate(contract.getProjectCheckDate());
            contractPaymentList.add(contractProjectCheckPayment);

            // 质保
            ContractPayment contractWarrantyPayment = new ContractPayment();
            contractWarrantyPayment.setId(contractId2PaymentMap.getOrDefault(contract.getId(), new HashMap<>()).get(5));
            contractWarrantyPayment.setContractId(contract.getId());
            contractWarrantyPayment.setPaymentType(5);
            contractWarrantyPayment.setPaymentRatio(Opt.ofNullable(contract.getWarrantyRatio()).orElse(BigDecimal.ZERO));
            contractWarrantyPayment.setPaymentDate(contract.getWarrantyDate());
            contractPaymentList.add(contractWarrantyPayment);

            // 第一笔维保款
            ContractPayment contractMaintainPayment1 = new ContractPayment();
            contractMaintainPayment1.setId(contractId2PaymentMap.getOrDefault(contract.getId(), new HashMap<>()).get(6));
            contractMaintainPayment1.setContractId(contract.getId());
            contractMaintainPayment1.setPaymentType(6);
            contractMaintainPayment1.setPaymentRatio(Opt.ofNullable(contract.getMaintainRatio1()).orElse(BigDecimal.ZERO));
            contractMaintainPayment1.setPaymentDate(contract.getMaintainDate1());
            contractPaymentList.add(contractMaintainPayment1);

            // 第二笔维保款
            ContractPayment contractMaintainPayment2 = new ContractPayment();
            contractMaintainPayment2.setId(contractId2PaymentMap.getOrDefault(contract.getId(), new HashMap<>()).get(7));
            contractMaintainPayment2.setContractId(contract.getId());
            contractMaintainPayment2.setPaymentType(7);
            contractMaintainPayment2.setPaymentRatio(Opt.ofNullable(contract.getMaintainRatio2()).orElse(BigDecimal.ZERO));
            contractMaintainPayment2.setPaymentDate(contract.getMaintainDate2());
            contractPaymentList.add(contractMaintainPayment2);

            // 第三笔维保款
            ContractPayment contractMaintainPayment3 = new ContractPayment();
            contractMaintainPayment3.setId(contractId2PaymentMap.getOrDefault(contract.getId(), new HashMap<>()).get(8));
            contractMaintainPayment3.setContractId(contract.getId());
            contractMaintainPayment3.setPaymentType(8);
            contractMaintainPayment3.setPaymentRatio(Opt.ofNullable(contract.getMaintainRatio3()).orElse(BigDecimal.ZERO));
            contractMaintainPayment3.setPaymentDate(contract.getMaintainDate3());
            contractPaymentList.add(contractMaintainPayment3);

            // 维保进度款
            ContractPayment maintainProgressPayment = new ContractPayment();
            maintainProgressPayment.setId(contractId2PaymentMap.getOrDefault(contract.getId(), new HashMap<>()).get(9));
            maintainProgressPayment.setContractId(contract.getId());
            maintainProgressPayment.setPaymentType(9);
            maintainProgressPayment.setPaymentRatio(Opt.ofNullable(contract.getMaintainProgressRatio()).orElse(BigDecimal.ZERO));
            maintainProgressPayment.setPaymentDate(contract.getMaintainDate2());
            contractPaymentList.add(maintainProgressPayment);

            // 维保验收款
            ContractPayment maintainAcceptancePayment = new ContractPayment();
            maintainAcceptancePayment.setId(contractId2PaymentMap.getOrDefault(contract.getId(), new HashMap<>()).get(10));
            maintainAcceptancePayment.setContractId(contract.getId());
            maintainAcceptancePayment.setPaymentType(10);
            maintainAcceptancePayment.setPaymentRatio(Opt.ofNullable(contract.getMaintainAcceptanceRatio()).orElse(BigDecimal.ZERO));
            maintainAcceptancePayment.setPaymentDate(contract.getMaintainDate3());
            contractPaymentList.add(maintainAcceptancePayment);
        }
        contractPaymentService.saveOrUpdateBatch(contractPaymentList);
    }

    /**
     * 获取CRM产品列表，若循环调用接口出现一次失败，则直接返回空列表
     *
     * @return java.util.List<com.fasterxml.jackson.databind.JsonNode>
     */
    public List<JsonNode> getProductList() {
        List<JsonNode> resList = new ArrayList<>();
        var json = JsonUtil.createObj()
                .put("corpid", corpId)
                .put("page", 1)
                .put("pageSize", 100);

        var jobj = bongRestClient.post()
                .uri("/pro/v2/api/product/list")
                .contentType(MediaType.APPLICATION_JSON)
                .header("sign", SecureUtil.sha256(json.toString() + token))
                .body(json.toString())
                .retrieve()
                .body(JsonNode.class);
        if (ObjUtil.isNull(jobj) || jobj.path("code").asInt() != 1) {
            log.error("获取CRM产品列表失败:{}", jobj);
            return List.of();
        }
        var result = jobj.path("result");
        var totalPage = result.path("totalPage").asInt();
        result.withArray("list").forEach(resList::add);

        for (int i = 2; i <= totalPage; i++) {
            var json1 = JsonUtil.createObj()
                    .put("corpid", corpId)
                    .put("page", i)
                    .put("pageSize", 100);
            var jobj1 = bongRestClient.post()
                    .uri("/pro/v2/api/product/list")
                    .contentType(MediaType.APPLICATION_JSON)
                    .header("sign", SecureUtil.sha256(json1.toString() + token))
                    .body(json1.toString())
                    .retrieve()
                    .body(JsonNode.class);
            if (ObjUtil.isNull(jobj1) || jobj1.path("code").asInt() != 1) {
                log.error("获取CRM产品列表失败:{}", jobj1);
                return List.of();
            }
            var result1 = jobj1.path("result");
            result1.withArray("list").forEach(resList::add);
        }
        return resList;
    }

    @Scheduled(cron = "0 0 1 * * ?")
    public void calMaintainStatus() {
        log.info("【开始】计算门店维保状态");
        storeService.calMaintainStatus(ListUtil.empty());
        log.info("【结束】计算门店维保状态");
    }

    @Scheduled(cron = "0 10 8-20 ? * *")
    public void syncContractFile() {
        contractService.syncContractFile(null);
    }
}