Merge branch 'develop' of http://192.168.11.14:51037/gitadmin/tuoheng_telecomumale into develop

tuoheng-service/tuoheng-admin/src/main/java/com/tuoheng/admin/controller/PermissionController.java

@@ -1,6 +1,6 @@
 package com.tuoheng.admin.controller;
 
-import com.tuoheng.admin.dto.GetPermissionRoleIdListByApiUrlDto;
+import com.tuoheng.admin.dto.PermissionRoleIdListByApiUrlDto;
 import com.tuoheng.admin.entity.OpPermissions;
 import com.tuoheng.admin.enums.MarkEnum;
 import com.tuoheng.admin.query.RoleClientQuery;
@@ -39,8 +39,8 @@ public class PermissionController{
      * @return
      */
     @PostMapping("/getRoleIdList")
-    public JsonResult getRoleIdListByApiUrl(@RequestBody GetPermissionRoleIdListByApiUrlDto getPermissionRoleIdListByApiUrlDto) {
-        return permissionService.getRoleIdListByApiUrl(getPermissionRoleIdListByApiUrlDto.getApiUrl());
+    public JsonResult getRoleIdListByApiUrl(@RequestBody PermissionRoleIdListByApiUrlDto permissionRoleIdListByApiUrlDto) {
+        return permissionService.getRoleIdListByApiUrl(permissionRoleIdListByApiUrlDto.getApiUrl());
     }
 
     /**

tuoheng-service/tuoheng-admin/src/main/java/com/tuoheng/admin/dto/GetPermissionRoleIdListByApiUrlDto.java → tuoheng-service/tuoheng-admin/src/main/java/com/tuoheng/admin/dto/PermissionRoleIdListByApiUrlDto.java

@@ -8,7 +8,7 @@ import lombok.Data;
  * @date 2022/11/17 13:21
  */
 @Data
-public class GetPermissionRoleIdListByApiUrlDto {
+public class PermissionRoleIdListByApiUrlDto {
 
     private String apiUrl;
 

tuoheng-service/tuoheng-admin/src/main/java/com/tuoheng/admin/service/inspection/add/AddInspectionService.java

@@ -1,5 +1,6 @@
 package com.tuoheng.admin.service.inspection.add;
 
+import cn.hutool.core.util.ObjectUtil;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.tuoheng.admin.conver.InspectionConverMapper;
 import com.tuoheng.admin.entity.*;
@@ -10,6 +11,9 @@ import com.tuoheng.admin.enums.code.inspection.AddInspectionCodeEnum;
 import com.tuoheng.admin.mapper.*;
 import com.tuoheng.admin.request.inspection.AddInspectionRequest;
 import com.tuoheng.admin.service.third.pilot.PilotService;
+import com.tuoheng.admin.tzhl.response.TZHLAirportLineResponse;
+import com.tuoheng.admin.tzhl.service.airportline.TZHLGetAirportLineListService;
+import com.tuoheng.admin.tzhl.service.task.ShelterTaskService;
 import com.tuoheng.admin.utils.CurrentUserUtil;
 import com.tuoheng.admin.utils.GaodeUtil;
 import com.tuoheng.common.core.constant.CommonConstants;
@@ -46,6 +50,9 @@ public class AddInspectionService {
     @Autowired
     private InspectionMapper inspectionMapper;
 
+    @Autowired
+    private InspectionHistoryMapper inspectionHistoryMapper;
+
     @Autowired
     private TenantMapper tenantMapper;
 
@@ -55,6 +62,12 @@ public class AddInspectionService {
     @Autowired
     private DspServiceInstMapper dspServiceInstMapper;
 
+    @Autowired
+    private ShelterTaskService shelterTaskService;
+
+    @Autowired
+    private TZHLGetAirportLineListService tzhlGetAirportLineListService;
+
     /**
      * 添加任务
      *
@@ -75,11 +88,17 @@ public class AddInspectionService {
         Inspection inspection = this.buildInspection(user, tenantId, addInspectionRequest);
 
         // 调用第三方平台
-        result = this.callThirdPlatform(user, tenantId, inspection);
+        result = this.callThirdPlatform(user, inspection);
         if (0 != result.getCode()) {
             log.info("添加任务业务：对接第三方平台失败：{}", result.getMsg());
             return result;
         }
+
+        if (InspectionTypeEnum.AIRPORT.getCode() == inspection.getInspectionType()) {
+            Long recordId = (Long) result.getData();
+            inspection.setRecordId(recordId);
+        }
+
         Integer rowId = inspectionMapper.insert(inspection);
         log.info("添加任务, 返回结果: deptId={}", rowId);
         if (rowId <= 0) {
@@ -199,25 +218,24 @@ public class AddInspectionService {
     }
 
     /**
-     * 与第三方平台（飞手、高德）对接
+     * 与第三方平台（天翼、飞手、高德）对接
      *
      * @param user
-     * @param tenantId
      * @param inspection
      * @return
      */
-    private JsonResult callThirdPlatform(User user, String tenantId, Inspection inspection) {
+    private JsonResult callThirdPlatform(User user, Inspection inspection) {
         // 对接高德地图
         JsonResult result = this.callGaode(inspection);
         if (0 != result.getCode()) {
             return result;
         }
-        if (InspectionTypeEnum.MABNNEDFLIGHT.getCode() == inspection.getInspectionType()) {
+        if (InspectionTypeEnum.AIRPORT.getCode() == inspection.getInspectionType()) {
+            // 对接天翼平台
+            return this.callTianYi(inspection);
+        } else if (InspectionTypeEnum.MABNNEDFLIGHT.getCode() == inspection.getInspectionType()) {
             // 对接飞手平台
-            result = pilotService.addTask(user, inspection);
-            if (0 != result.getCode()) {
-                return result;
-            }
+            return pilotService.addTask(user, inspection);
         }
         return JsonResult.success();
     }
@@ -242,4 +260,37 @@ public class AddInspectionService {
         return JsonResult.success();
     }
 
+    private JsonResult callTianYi(Inspection inspection) {
+        TZHLAirportLineResponse tzhlAirportLineResponse = tzhlGetAirportLineListService.getAirportLineById(inspection.getInspectionLine());
+        if (ObjectUtil.isEmpty(tzhlAirportLineResponse)) {
+            this.insertInspectionHistory(inspection, "创建任务，下发任务，航线不存在");
+            return JsonResult.error("创建任务，下发任务，航线不存在");
+        }
+        Long recordId = shelterTaskService.distributeTask(inspection, tzhlAirportLineResponse);
+        if (ObjectUtil.isEmpty(recordId)) {
+            log.info("创建任务，下发任务失败，status={}", inspection.getStatus());
+
+            inspection.setStatus(InspectionStatusEnum.FLIGHT_FAILED.getCode());
+
+            this.insertInspectionHistory(inspection, "创建任务，下发任务失败");
+
+            return JsonResult.error("创建任务，下发任务失败");
+        }
+        return JsonResult.success(recordId);
+    }
+
+    /**
+     * 更新任务失败记录
+     *
+     * @param inspection
+     */
+    private void insertInspectionHistory(Inspection inspection, String msg) {
+        InspectionHistory inspectionHistory = new InspectionHistory();
+        inspectionHistory.setTenantId(inspection.getTenantId());
+        inspectionHistory.setInspectionId(inspection.getId());
+        inspectionHistory.setHistoryName(msg);
+        inspectionHistory.setCreateUser("");
+        inspectionHistory.setCreateTime(DateUtils.now());
+        inspectionHistoryMapper.insert(inspectionHistory);
+    }
 }

tuoheng-service/tuoheng-admin/src/main/java/com/tuoheng/admin/service/third/airport/execute/ExecuteTaskService.java

@@ -2,6 +2,7 @@ package com.tuoheng.admin.service.third.airport.execute;
 
 import cn.hutool.core.util.ObjectUtil;
 import com.alibaba.fastjson.JSONObject;
+import com.tuoheng.admin.dto.GetAirportListDto;
 import com.tuoheng.admin.entity.Inspection;
 import com.tuoheng.admin.entity.InspectionHistory;
 import com.tuoheng.admin.enums.InspectionStatusEnum;
@@ -15,8 +16,10 @@ import com.tuoheng.admin.tzhl.constant.TZHLConstant;
 import com.tuoheng.admin.tzhl.response.TZHLAirportLineResponse;
 import com.tuoheng.admin.tzhl.response.TZHLOnlineUavResponse;
 import com.tuoheng.admin.tzhl.response.TZHLShelterTaskResponse;
+import com.tuoheng.admin.tzhl.service.airport.TZHLGetAirportListService;
 import com.tuoheng.admin.tzhl.service.airportline.TZHLGetAirportLineListService;
 import com.tuoheng.admin.tzhl.service.fly.onlineuav.OnlineUavService;
+import com.tuoheng.admin.tzhl.service.task.FlightTaskService;
 import com.tuoheng.admin.tzhl.service.task.ShelterTaskService;
 import com.tuoheng.common.core.exception.ServiceException;
 import com.tuoheng.common.core.utils.DateUtils;
@@ -41,53 +44,74 @@ public class ExecuteTaskService {
     @Autowired
     private InspectionHistoryMapper inspectionHistoryMapper;
 
+    @Autowired
+    private TZHLGetAirportListService tzhlGetAirportListService;
+
     @Autowired
     private TZHLGetAirportLineListService tzhlGetAirportLineListService;
 
     @Autowired
-    private ShelterTaskService shelterTaskService;
+    private FlightTaskService flightTaskService;
 
     public JsonResult executeTask(String userId, Inspection inspection) {
         log.info("进入泰州海陵区城管，执行任务，inspectionId={}", inspection.getId());
-
-        TZHLAirportLineResponse tzhlAirportLineResponse = tzhlGetAirportLineListService.getAirportLineById(inspection.getInspectionLine());
-        if (ObjectUtil.isEmpty(tzhlAirportLineResponse)) {
-            log.info("泰州海陵区城管，执行任务，航线不存在，airportLineId:{}", tzhlAirportLineResponse.getId());
-            return JsonResult.success("泰州海陵区城管，航线不存在");
+        JsonResult result = this.check(inspection);
+        if (0 != result.getCode()) {
+            this.insertInspectionHistory(inspection, result.getMsg());
+            return JsonResult.error(result.getMsg());
         }
 
-        Long recordId = shelterTaskService.distributeTask(inspection, tzhlAirportLineResponse);
-        if (ObjectUtil.isEmpty(recordId)) {
-            log.info("泰州海陵区城管，执行任务，下发任务失败，status={}", inspection.getStatus());
-
+        result = flightTaskService.flightTask(inspection);
+        if (0 != result.getCode()) {
             inspection.setStatus(InspectionStatusEnum.FLIGHT_FAILED.getCode());
-            this.updateInspection(userId, inspection, recordId);
+            this.updateInspection(userId, inspection);
+
+            log.info("执行任务失败，修改任务状态，status={}", inspection.getStatus());
 
-            this.insertInspectionHistory(inspection, "下发任务失败");
+            this.insertInspectionHistory(inspection, "执行任务失败");
 
-            return JsonResult.success("泰州海陵区城管，执行任务，下发任务失败");
+            return JsonResult.success("执行任务失败");
         }
 
         inspection.setStatus(InspectionStatusEnum.PREPARING.getCode());
-        this.updateInspection(userId, inspection, recordId);
+        this.updateInspection(userId, inspection);
 
-        log.info("任务下发成功，修改任务状态，status={}", inspection.getStatus());
+        log.info("执行任务成功，修改任务状态，status={}", inspection.getStatus());
 
         return JsonResult.success();
     }
 
+    private JsonResult check(Inspection inspection) {
+        GetAirportListDto airportListDto = tzhlGetAirportListService.getAirport(inspection.getAirportId());
+        if (ObjectUtil.isEmpty(airportListDto)) {
+            log.info("泰州海陵区城管，执行任务，机场不存在，inspectionId:{}, airportId", inspection.getId(), inspection.getAirportId());
+            return JsonResult.error("泰州海陵区城管，执行任务，航线不存在");
+        }
+
+        if (1 == airportListDto.getShelterStatus()) {
+            log.info("泰州海陵区城管，执行任务，机场被禁用，inspectionId:{}, airportId", inspection.getId(), inspection.getAirportId());
+            return JsonResult.error("泰州海陵区城管，执行任务，机场被禁用");
+        }
+
+        TZHLAirportLineResponse tzhlAirportLineResponse = tzhlGetAirportLineListService.getAirportLineById(inspection.getInspectionLine());
+        if (ObjectUtil.isEmpty(tzhlAirportLineResponse)) {
+            log.info("泰州海陵区城管，执行任务，航线不存在，inspectionId:{}, airportLineId", inspection.getId(), tzhlAirportLineResponse.getId());
+            return JsonResult.error("泰州海陵区城管，航线不存在");
+        }
+        return JsonResult.success();
+    }
+
     /**
      * 修改任务执行
      *
      * @param userId
      * @param inspection
      */
-    private void updateInspection(String userId, Inspection inspection, Long recordId) {
+    private void updateInspection(String userId, Inspection inspection) {
         inspection.setExecutionStatus(2);   // 修改任务执行状态，防止手动执行和定时重复
         inspection.setStatus(inspection.getStatus());
         inspection.setUpdateUser(userId);
         inspection.setUpdateTime(DateUtils.now());
-        inspection.setRecordId(recordId);
         inspectionMapper.update(inspection);
     }
 

tuoheng-service/tuoheng-admin/src/main/java/com/tuoheng/admin/tzhl/constant/TZHLConstant.java

@@ -28,42 +28,47 @@ public interface TZHLConstant {
     /**
      * 天翼星云机场平台：票据登录
      */
-    String TIAN_YI_API_TICKET_LOGIN = "/prod-api/auth/ticketLogin";
+    String TIAN_YI_API_TICKET_LOGIN = "/auth/ticketLogin";
 
     /**
      * 天翼星云机场平台：获取机场列表
      */
-    String TIAN_YI_API_AIRPORT_LIST = "/prod-api/ctuav/openapi/ctuav/v4/shelter/list";
+    String TIAN_YI_API_AIRPORT_LIST = "/ctuav/openapi/ctuav/v4/shelter/list";
 
     /**
      * 天翼星云机场平台：航线列表（跟据方舱序列号查询待开发）
      */
-    String TIAN_YI_API_FLY_LINE_LIST = "/prod-api/ctuav/openapi/ctuav/v4/flyline/list";
+    String TIAN_YI_API_FLY_LINE_LIST = "/ctuav/openapi/ctuav/v4/flyline/list";
 
     /**
      * 天翼星云机场平台：下发任务
      */
-    String TIAN_YI_API_SHELTER_TASKS = "/prod-api/shelter/task";
+    String TIAN_YI_API_SHELTER_TASKS = "/shelter/task";
+
+    /**
+     * 天翼星云机场平台：执行航线任务
+     */
+    String TIAN_YI_API_WAYLINE_FLIGHT_TASKS = "/shelter/wayline/v1.4/flight-tasks";
 
     /**
      * 天翼星云机场平台：飞行日志回调
      */
-    String TIAN_YI_API_FLIGHT_LOG = "/prod-api/ctuav/mapper/fly/log/listAll";
+    String TIAN_YI_API_FLIGHT_LOG = "/ctuav/mapper/fly/log/listAll";
 
     /**
      * 天翼星云机场平台：飞行画面
      */
-    String TIAN_YI_API_FLIGHT_SCREEN = "/prod-api/ctuav/openapi/ctuav/v4/onlineuav/list";
+    String TIAN_YI_API_FLIGHT_SCREEN = "/ctuav/openapi/ctuav/v4/onlineuav/list";
 
     /**
      * 天翼星云机场平台:飞行数据
      */
-    String TIAN_YI_API_FLIGHT_DATA = "/prod-api/ctuav/openapi/ctuav/v4/flydata/list";
+    String TIAN_YI_API_FLIGHT_DATA = "/ctuav/openapi/ctuav/v4/flydata/list";
 
     /**
      * 天翼星云机场信息：气象数据接口
      */
-    String TIAN_YI_API_AIRPORT_MSG = "/prod-api/ctuav/openapi/ctuav/v4/shelter/info";
+    String TIAN_YI_API_AIRPORT_MSG = "/ctuav/openapi/ctuav/v4/shelter/info";
 
 
 }

tuoheng-service/tuoheng-admin/src/main/java/com/tuoheng/admin/tzhl/service/CallTianYiPlatformService.java

@@ -41,8 +41,10 @@ public class CallTianYiPlatformService {
         HttpHeaders headers = new HttpHeaders();
         headers.add("Authorization", properties);
 
-        HttpEntity<Object> httpEntity = new HttpEntity<>(request, headers);
+        log.info("泰州海陵区城管，url:{}", url);
+        log.info("泰州海陵区城管，request:{}", request);
 
+        HttpEntity<Object> httpEntity = new HttpEntity<>(request, headers);
         ResponseEntity<JsonResult> response;
         try {
             response = restTemplate.exchange(url, HttpMethod.GET, httpEntity, JsonResult.class);
@@ -64,6 +66,9 @@ public class CallTianYiPlatformService {
             log.info("泰州海陵区城管，接口返回失败, request:{}", request);
             throw new ServiceException(HttpStatus.BAD_REQUEST.value(), "泰州海陵区城管，接口返回失败");
         }
+
+        log.info("泰州海陵区城管，接口返回, response={}", response.getBody().getData());
+
         return JSONObject.toJSONString(response.getBody().getData());
     }
 
@@ -104,6 +109,9 @@ public class CallTianYiPlatformService {
             log.info("泰州海陵区城管，接口返回失败, request:{}", request);
             throw new ServiceException(HttpStatus.BAD_REQUEST.value(), "泰州海陵区城管，接口返回失败");
         }
+
+        log.info("泰州海陵区城管，接口返回, response={}", response.getBody().getData());
+
         return JSONObject.toJSONString(response.getBody().getData());
     }
 

tuoheng-service/tuoheng-admin/src/main/java/com/tuoheng/admin/tzhl/service/fly/log/FlyLogBySuccessService.java

@@ -43,7 +43,7 @@ public class FlyLogBySuccessService {
 
         TZHLOnlineUavResponse tzhlOnlineUavResponse = onlineUavService.getOnlineUav();
         if (ObjectUtil.isEmpty(tzhlOnlineUavResponse)) {
-            log.info("泰州海陵区城管，执行任务，获取推流地址失败");
+            log.info("泰州海陵区城管，执行任务，获取推流地址失败，inspectionId={}", inspection.getId());
             return;
         }
 

tuoheng-service/tuoheng-admin/src/main/java/com/tuoheng/admin/tzhl/service/fly/onlineuav/OnlineUavService.java

@@ -1,5 +1,6 @@
 package com.tuoheng.admin.tzhl.service.fly.onlineuav;
 
+import cn.hutool.core.util.ObjectUtil;
 import com.alibaba.fastjson.JSON;
 import com.tuoheng.admin.entity.Inspection;
 import com.tuoheng.admin.tzhl.constant.TZHLConstant;
@@ -8,6 +9,7 @@ import com.tuoheng.admin.tzhl.response.TZHLFlyDataResponse;
 import com.tuoheng.admin.tzhl.response.TZHLOnlineUavResponse;
 import com.tuoheng.admin.tzhl.service.CallTianYiPlatformService;
 import com.tuoheng.common.core.utils.RedisUtils;
+import com.tuoheng.common.core.utils.StringUtils;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Qualifier;
@@ -34,7 +36,13 @@ public class OnlineUavService {
     public TZHLOnlineUavResponse getOnlineUav() {
         String apiPath = TZHLConstant.TIAN_YI_API_FLIGHT_SCREEN;
         String dataJson = callTianYiPlatformService.callGet(apiPath, null);
+        if (StringUtils.isEmpty(dataJson)) {
+            return null;
+        }
         TZHLOnlineUavResponse onlineUavResponse = JSON.parseObject(dataJson, TZHLOnlineUavResponse.class);
+        if (ObjectUtil.isEmpty(onlineUavResponse)) {
+            return null;
+        }
         return onlineUavResponse;
     }
 

tuoheng-service/tuoheng-admin/src/main/java/com/tuoheng/admin/tzhl/service/task/FlightTaskService.java

@@ -0,0 +1,44 @@
+package com.tuoheng.admin.tzhl.service.task;
+
+import com.alibaba.fastjson.JSONObject;
+import com.tuoheng.admin.entity.Inspection;
+import com.tuoheng.admin.tzhl.constant.TZHLConstant;
+import com.tuoheng.admin.tzhl.response.TZHLAirportLineResponse;
+import com.tuoheng.admin.tzhl.service.CallTianYiPlatformService;
+import com.tuoheng.common.core.utils.JsonResult;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.stereotype.Service;
+import org.springframework.web.client.RestTemplate;
+
+import java.util.ArrayList;
+import java.util.List;
+
+@Slf4j
+@Service
+public class FlightTaskService {
+
+    @Autowired
+    @Qualifier("restTemplate")
+    private RestTemplate restTemplate;
+
+    @Autowired
+    private CallTianYiPlatformService callTianYiPlatformService;
+
+    public JsonResult flightTask(Inspection inspection) {
+        String apiPath = TZHLConstant.TIAN_YI_API_WAYLINE_FLIGHT_TASKS;
+        JSONObject jsonObject = this.buildJSONObject(inspection);
+        String dataJson = callTianYiPlatformService.callPost(apiPath, jsonObject);
+        return JsonResult.success(dataJson);
+    }
+
+    private JSONObject buildJSONObject(Inspection inspection) {
+        JSONObject jsonObject = new JSONObject();
+        jsonObject.put("method", "flighttask_prepare");       // 默认值 flighttask_prepare
+        jsonObject.put("sn", inspection.getSn());             // 机库序列号
+        jsonObject.put("recordId", inspection.getRecordId()); // 飞行计划Id
+        return jsonObject;
+    }
+
+}

tuoheng-service/tuoheng-admin/src/main/java/com/tuoheng/admin/tzhl/task/FlyDataTask.java

@@ -33,32 +33,24 @@ public class FlyDataTask {
 
     @XxlJob("telecomumaleFlyDataTaskHandler")
     public void airportTaskHandler() {
-        // 查询当前时间正负1分钟的时间跨度，xxljob执行频率为1分钟1次
-        long start = new Date().getTime() - 1 * 60000L;
-        long end = new Date().getTime() + 1 * 60000L;
-        Date startTime = new Date(start);
-        Date endTime = new Date(end);
-
-        log.info("执行定时执行飞行任务：" + LocalDateTime.now());
+        log.info("执行定时，获取飞行数据：" + LocalDateTime.now());
         List<Inspection> inspectionList = inspectionMapper.selectList(new LambdaQueryWrapper<Inspection>()
                 .eq(Inspection::getMark, MarkEnum.VALID.getCode())
-                //是查询任务表中所有正在执行中的任务(暂时注释掉，没问题删除)
-                //.between(Inspection::getInspectionTime, startTime, endTime)
                 //查询巡检方式为机场的任务
                 .eq(Inspection::getInspectionType, InspectionTypeEnum.AIRPORT.getCode())
                 //查询未执行任务
                 .eq(Inspection::getExecutionStatus, 1)
                 //任务飞行中
                 .eq(Inspection::getStatus, InspectionStatusEnum.IN_FLIGHT.getCode()));
-        log.info("执行定时执行飞行任务：机场任务数" + inspectionList.size());
         if (StringUtils.isEmpty(inspectionList)) {
+            log.info("执行定时，获取飞行数据：任务为空" + inspectionList.size());
             return;
         }
         //遍历任务列表中正在执行的任务进行飞行数据入库
         for (Inspection inspection : inspectionList) {
-            log.info("执行定时，获取飞行数据: inspectionId:{}", inspection.getId());
+            log.info("执行定时，获取飞行数据开始: inspectionId:{}", inspection.getId());
             flyDataService.getFlyData(inspection);
-            log.info("执行定时，获取飞行数据结束: inspectionId:{}");
+            log.info("执行定时，获取飞行数据结束: inspectionId:{}", inspection.getId());
         }
     }
 

tuoheng-service/tuoheng-admin/src/main/java/com/tuoheng/admin/tzhl/task/FlyLogTask.java

@@ -44,16 +44,14 @@ public class FlyLogTask {
                 .eq(Inspection::getMark, MarkEnum.VALID.getCode())
                 .eq(Inspection::getInspectionType, InspectionTypeEnum.AIRPORT.getCode())
                 .in(Inspection::getStatus,statusList));
-        log.info("执行定时执行飞行任务：机场任务数" + inspectionList.size());
         if (StringUtils.isEmpty(inspectionList)) {
+            log.info("执行定时，获取飞行日志：任务为空" + inspectionList.size());
             return;
         }
         for (Inspection inspection : inspectionList) {
-            log.info("执行定时，获取飞行日志: inspectionId:{}", inspection.getId());
-
+            log.info("执行定时，获取飞行日志开始: inspectionId:{}", inspection.getId());
             flyLogService.getFlyLog(inspection);
-
-            log.info("执行定时，获取飞行日志结束: inspectionId:{}");
+            log.info("执行定时，获取飞行日志结束: inspectionId:{}", inspection.getId());
         }
     }
 

tuoheng-service/tuoheng-admin/src/main/resources/application-dev.yml

@@ -208,5 +208,5 @@ aliyun:
 
 # 泰州海陵区城管
 tzhl:
-  url: http://221.230.150.241:8889
+  url: http://221.230.150.241:8889/prod-api
   ticket: b6hd+ymZb5bY//0wNMJZsA==

tuoheng-service/tuoheng-admin/src/main/resources/application-local.yml

@@ -204,5 +204,5 @@ aliyun:
 
 # 泰州海陵区城管
 tzhl:
-  url: http://221.230.150.241:8889
+  url: http://221.230.150.241:8889/prod-api
   ticket: b6hd+ymZb5bY//0wNMJZsA==

tuoheng-service/tuoheng-admin/src/main/resources/application-prod.yml

@@ -208,5 +208,5 @@ aliyun:
 
 # 泰州海陵区城管
 tzhl:
-  url: http://221.230.150.241:8889
+  url: http://221.230.150.241:8889/prod-api
   ticket: b6hd+ymZb5bY//0wNMJZsA==

tuoheng-service/tuoheng-admin/src/main/resources/application-test.yml

@@ -208,5 +208,5 @@ aliyun:
 
 # 泰州海陵区城管
 tzhl:
-  url: http://221.230.150.241:8889
+  url: http://221.230.150.241:8889/prod-api
   ticket: b6hd+ymZb5bY//0wNMJZsA==