Merge remote-tracking branch 'origin/master'

linwei

2026-02-02 1bfbc52da47b22f00a1c1f5f670c30f70d999873

 drone-service/drone-gd/src/main/java/org/sxkj/gd/xingtu/JianXingtuApiService.java

@@ -1,12 +1,18 @@
package org.sxkj.gd.xingtu;

import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
import org.springblade.core.redis.cache.BladeRedis;
import org.springblade.core.tool.api.R;
import org.springblade.core.tool.utils.StringUtil;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpMethod;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;
import org.sxkj.common.jaxt.JianXingTuApiClient;
import org.sxkj.gd.workorder.dto.GdXingtuFlyTaskSaveDTO;

import java.util.HashMap;
import java.util.Map;
@@ -18,6 +24,7 @@
 * @Date 2026/1/26 15:22
 * @Version 1.0
 */
@Slf4j
@Service
public class JianXingtuApiService {

@@ -74,6 +81,65 @@
   }

   /**
    * 设备列表-无人机
    * @param name 名称
    * @return 接口响应
    */
   public R getDevicePilotList(String name) {
      String url = JianXingTuApiClient.getDevicePilotListUrl();
      return postWithAuthHeader(url, buildListParams(name));
   }

   /**
    * 设备列表-机巢
    * @param name 名称
    * @return 接口响应
    */
   public R getDeviceAirportList(String name) {
      String url = JianXingTuApiClient.getDeviceAirportListUrl();
      return postWithAuthHeader(url, buildListParams(name));
   }

   /**
    * 新增飞行任务
    * @param param 请求参数
    * @return 接口响应
    */
   public R saveFlyTask(GdXingtuFlyTaskSaveDTO param) {
      String url = JianXingTuApiClient.getFlyTaskSaveUrl();
      return postWithAuthHeader(url, param);
   }

   private Map<String, Object> buildListParams(String name) {
      Map<String, Object> params = new HashMap<>();
      if (StringUtil.isNotBlank(name)) {
         params.put("name", name);
      }
      return params;
   }

   private R postWithAuthHeader(String url, Object body) {
      String token = getToken();
      if (StringUtil.isBlank(token) || "获取token失败".equals(token)) {
         return R.fail("获取token失败");
      }
      HttpHeaders headers = new HttpHeaders();
      headers.set("authorization", token);
      log.info("请求外部接口: {} {}", url, body);
      HttpEntity<Object> entity = new HttpEntity<>(body, headers);
      ResponseEntity<R> response = restTemplate.exchange(url, HttpMethod.POST, entity, R.class);
      log.info("响应外部接口: {}", response);
      if (response.getStatusCode().is2xxSuccessful()) {
         R responseBody = response.getBody();
         if (responseBody != null) {
            return responseBody;
         }
         return R.fail("接口返回为空");
      }
      return R.fail("请求外部接口失败");
   }

   /**
    * 解析JSON字符串为Map
    * @param input JSON字符串
    * @return 解析后的Map