异物侵限接口开发

hazard-sdk/src/main/java/com/ozs/controller/upload/GeoHazardMonitorTokenController.java

@@ -56,7 +56,8 @@ public class GeoHazardMonitorTokenController {
     private BaseUserService baseUserService;
     @Value("${base.imgUrl}")
     private String imgUrl;
-
+    @Autowired
+    private BaseMeasurePointService baseMeasurePointService;
 
     /**
      * 异物侵限获取web访问令牌
@@ -181,6 +182,12 @@ public class GeoHazardMonitorTokenController {
                 AjaxResults1 = new AjaxResults(0, "文件类型不能为空");
                 return SM4Utils.encryptData_ECB(JSONObject.toJSONString(AjaxResults1), "f5408458becc8c68");
             }
+            BaseMeasurePoint one = baseMeasurePointService.getOne(new LambdaQueryWrapper<BaseMeasurePoint>()
+                    .eq(BaseMeasurePoint::getPointCode, reqMsgAlarmMatterVo.getPointCode()));
+            if (ObjectUtils.isEmpty(one)){
+                AjaxResults1 = new AjaxResults(0, "系统中不存在该测点编码");
+                return SM4Utils.encryptData_ECB(JSONObject.toJSONString(AjaxResults1), "f5408458becc8c68");
+            }
             if (reqMsgAlarmMatterVo.getAlarmTime().toString().length() == 10) {
                 reqMsgAlarmMatterVo.setAlarmTime(reqMsgAlarmMatterVo.getAlarmTime() * 1000);
             }

hazard-sdk/src/main/java/com/ozs/controller/upload/UploadController.java

@@ -7,8 +7,10 @@ import com.ozs.common.utils.StringUtils;
 import com.ozs.common.utils.stateSecrets.SM4Utils;
 import com.ozs.common.utils.uuid.IdUtils;
 import com.ozs.service.entity.BaseCameraManagement;
+import com.ozs.service.entity.BaseMeasurePoint;
 import com.ozs.service.entity.BaseRailwayManagement;
 import com.ozs.service.service.BaseCameraManagementService;
+import com.ozs.service.service.BaseMeasurePointService;
 import com.ozs.service.service.BaseRailwayManagementService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
@@ -37,6 +39,8 @@ public class UploadController {
     BaseCameraManagementService baseCameraManagementService;
     @Autowired
     private BaseRailwayManagementService baseRailwayManagementService;
+    @Autowired
+    private BaseMeasurePointService baseMeasurePointService;
 
 
     @PostMapping("/api/putFile")
@@ -93,6 +97,14 @@ public class UploadController {
             jsonObject.put("data", "文件名不能为空");
             return jsonObject;
         }
+        BaseMeasurePoint one = baseMeasurePointService.getOne(new LambdaQueryWrapper<BaseMeasurePoint>()
+                .eq(BaseMeasurePoint::getPointCode, pointCode));
+        if (ObjectUtils.isEmpty(one)){
+            jsonObject.put("resultCode", 0);
+            jsonObject.put("message", "失败");
+            jsonObject.put("data", "系统中不存在该测点编码");
+            return jsonObject;
+        }
         LambdaQueryWrapper<BaseRailwayManagement> queryWrapper = new LambdaQueryWrapper<BaseRailwayManagement>();
         if (!ObjectUtils.isEmpty(alarmRailway)) {
             queryWrapper.eq(BaseRailwayManagement::getRailwayCode, alarmRailway);