2.2.0-海信动态推送地址

src/main/java/com/fdkankan/contro/dto/UploadSceneDTO.java

@@ -36,8 +36,15 @@ public class UploadSceneDTO {
 
     private String taskNo;
 
+    //回推地址，示例：http://1.119.159.10:58080
     private String pushAddress;
 
+    //地区编码
+    private String districtCode;
+
+    //地区名称
+    private String districtName;
+
     public String getkNo() {
         return kNo;
     }

src/main/java/com/fdkankan/contro/entity/SceneOrigBd.java

@@ -101,6 +101,14 @@ public class SceneOrigBd implements Serializable {
     @TableField("push_address")
     private String pushAddress;
 
+    //地区编码
+    @TableField("district_code")
+    private String districtCode;
+
+    //地区名称
+    @TableField("district_name")
+    private String districtName;
+
 
 
 }

src/main/java/com/fdkankan/contro/service/impl/HaixinServiceImpl.java

@@ -1,6 +1,7 @@
 package com.fdkankan.contro.service.impl;
 
 import cn.hutool.core.io.FileUtil;
+import cn.hutool.core.util.StrUtil;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.fdkankan.common.util.CmdUtils;
@@ -71,7 +72,12 @@ public class HaixinServiceImpl implements IHaixinService {
         sceneOrigBd.setShootCount(dto.getShootCount());
         sceneOrigBd.setExpectedTime(this.getExpectedTime(dto.getShootCount()));
         sceneOrigBd.setTaskNo(dto.getTaskNo());
+        if(StrUtil.isNotEmpty(dto.getPushAddress()) && dto.getPushAddress().endsWith(File.separator)){
+            dto.setPushAddress(dto.getPushAddress().substring(0, dto.getPushAddress().length() - 1));
+        }
         sceneOrigBd.setPushAddress(dto.getPushAddress());
+        sceneOrigBd.setDistrictCode(dto.getDistrictCode());
+        sceneOrigBd.setDistrictName(dto.getDistrictName());
         sceneOrigBdService.save(sceneOrigBd);
 
         //推送进度
@@ -80,6 +86,11 @@ public class HaixinServiceImpl implements IHaixinService {
         return ResultData.ok();
     }
 
+    public static void main(String[] args) {
+        String aaa = "http://sdfsdf/";
+        System.out.println(aaa.substring(0, aaa.length() - 1));
+    }
+
     private Integer getExpectedTime(Integer shootCount){
         if(shootCount == null){
             return null;
@@ -195,6 +206,9 @@ public class HaixinServiceImpl implements IHaixinService {
         }
 
         String url = haixinHost.concat(API_SYNC_RENDER_STATUS);
+        if(StrUtil.isNotEmpty(sceneOrigBd.getPushAddress())){
+            url = sceneOrigBd.getPushAddress().concat(API_SYNC_RENDER_STATUS);
+        }
         Map<String, Object> params = new HashMap<>();
         params.put("taskNo",sceneOrigBd.getTaskNo());
         params.put("projectId", sceneOrigBd.getTaskId());