xuhy
7 天以前 18f7360b6d8a02a8ff49e22e1b568a227811beff
ruoyi-service/ruoyi-worker/src/main/java/com/ruoyi/worker/controller/OrderController.java
@@ -4,6 +4,7 @@
import cn.afterturn.easypoi.cache.manager.IFileLoader;
import com.alibaba.fastjson2.JSONObject;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.ruoyi.admin.api.feignClient.AdminClient;
import com.ruoyi.common.core.constant.Constants;
import com.ruoyi.common.core.domain.R;
import com.ruoyi.common.core.domain.Result;
@@ -19,11 +20,14 @@
import com.ruoyi.order.api.feignClient.ExchangeDispatchClient;
import com.ruoyi.order.api.feignClient.OrderClient;
import com.ruoyi.system.api.model.LoginUserInfo;
import com.ruoyi.worker.entity.IamConfig;
import com.ruoyi.worker.entity.MasterWorker;
import com.ruoyi.worker.entity.RecoveryServe;
import com.ruoyi.worker.service.IamConfigService;
import com.ruoyi.worker.service.MasterWorkerService;
import com.ruoyi.worker.service.RecoveryServeService;
import com.ruoyi.worker.vo.ServeCoordinate;
import com.ruoyi.worker.voice.util.AXBUtil;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
@@ -36,18 +40,14 @@
import java.time.Duration;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.ArrayList;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Optional;
import java.util.Set;
import java.util.*;
import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;
import javax.annotation.Resource;
import lombok.Synchronized;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.StringUtils;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
@@ -81,6 +81,8 @@
    @Resource
    private RedisService redisService;
    @Resource
    private IamConfigService iamConfigService;
    /**
     * linux服务器保存订单轨迹文件夹
@@ -288,7 +290,29 @@
        if (null == loginWorker) {
            return R.loginExpire("登录失效!");
        }
        return orderClient.orderSubmit(orderSubmitRequest);
        R<String> result = orderClient.orderSubmit(orderSubmitRequest);
        String subscriptionId = result.getData();
        boolean flag = false;
        if (StringUtils.hasLength(subscriptionId)) {
            IamConfig iamConfig = iamConfigService.getById(1);
            // 查询音频链接
            OrderDetailVO data = orderClient.orderDetail(orderSubmitRequest.getOrderId()).getData();
            if(Objects.nonNull(data)){
                Order orderInfo = data.getOrderInfo();
                if (Objects.nonNull(orderInfo) && Objects.nonNull(orderInfo.getIsOpenVirtualNumber()) && orderInfo.getIsOpenVirtualNumber() == 1){
                    String recordDomain = orderInfo.getRecordDomain();
                    String recordObjectName = orderInfo.getRecordObjectName();
                    String audioUrl = AXBUtil.axbGetRecordDownloadLink(iamConfig.getAppKey(), iamConfig.getAppSecret(),recordDomain, recordObjectName);
                    orderInfo.setPhoneRecording(audioUrl);
                    // 设置音频
                    orderClient.updatePhoneRecording(orderInfo.getId(), audioUrl);
                    // 虚拟号码解绑
                    AXBUtil.axbUnbindNumber(iamConfig.getAppKey(), iamConfig.getAppSecret(),subscriptionId, iamConfig.getVirtualNumber());
                }
            }
            flag = true;
        }
        return R.ok(flag);
    }
    private static final double EARTH_RADIUS_METERS = 6371000.0;
    /**