package com.ruoyi.admin.controller;
|
|
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.ruoyi.admin.entity.IamConfig;
|
import com.ruoyi.admin.entity.OrderRecording;
|
import com.ruoyi.admin.service.IamConfigService;
|
import com.ruoyi.admin.service.OrderRecordingService;
|
import com.ruoyi.admin.service.OrderService;
|
import com.ruoyi.admin.voice.util.AXBUtil;
|
import com.ruoyi.common.core.domain.R;
|
import com.ruoyi.order.api.entity.Order;
|
import com.ruoyi.order.api.feignClient.OrderClient;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.web.bind.annotation.PostMapping;
|
import org.springframework.web.bind.annotation.RequestBody;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import javax.annotation.Resource;
|
import java.util.Objects;
|
|
/**
|
* <p>
|
* 协议政策、司机操作指导 前端控制器
|
* </p>
|
*
|
* @author hjl
|
* @since 2024-05-29
|
*/
|
@Slf4j
|
@RestController
|
@RequestMapping("/privateNumber")
|
public class PrivateNumberCallBackController {
|
|
@Resource
|
private OrderClient orderClient;
|
@Resource
|
private OrderRecordingService orderRecordingService;
|
@Resource
|
private IamConfigService iamConfigService;
|
|
/**
|
* 隐私号码回调
|
*/
|
@PostMapping(value = "/callBack")
|
public R<String> callBack(@RequestBody JSONObject jsonObject) {
|
JSONArray feeLst = jsonObject.getJSONArray("feeLst");
|
for (int i = 0; i < feeLst.size(); i++) {
|
JSONObject feeLstJson = feeLst.getJSONObject(i);
|
String subscriptionId = feeLstJson.getString("subscriptionId");
|
String recordDomain = feeLstJson.getString("recordDomain");
|
String recordObjectName = feeLstJson.getString("recordObjectName");
|
String recordBucketName = feeLstJson.getString("recordBucketName");
|
log.info("隐私号码回调：{},录音文件名:{},录音服务器名:{}", subscriptionId, recordObjectName, recordDomain);
|
Order order = orderClient.detailBySubscriptionId(subscriptionId).getData();
|
long count = orderRecordingService.count(Wrappers.<OrderRecording>lambdaQuery()
|
.eq(OrderRecording::getRecordObjectName, recordObjectName)
|
.eq(OrderRecording::getRecordDomain, recordDomain));
|
if (Objects.nonNull(order) && count == 0) {
|
IamConfig iamConfig = iamConfigService.getById(1);
|
OrderRecording orderRecording = new OrderRecording();
|
orderRecording.setOrderId(order.getId());
|
orderRecording.setRecordDomain(recordDomain);
|
orderRecording.setRecordObjectName(recordObjectName);
|
String recordingUrl = AXBUtil.axbGetRecordDownloadLink(iamConfig.getAppKey(), iamConfig.getAppSecret(), recordDomain, recordObjectName);
|
orderRecording.setPhoneRecording(recordingUrl);
|
orderRecordingService.save(orderRecording);
|
}
|
}
|
return R.ok();
|
}
|
|
}
|
