浦东船舶基础信息和船舶进出港申报接口增加船舶是否在港判断（1小时内有AIS）

ghjg-item-datashare-server/src/main/java/com/shanghaichengdi/ghjgitem/controller/BoatController.java

@@ -91,6 +91,10 @@ public class BoatController extends CommonController {
     if (!StringUtils.isBlank(req.getMmsi()) && req.getMmsi().length() < 6) {
       throw new EnumException("mmsi不足六位");
     }
+    // 判断只能查当前在浦东范围内有AIS信号的船
+    if(!commonService.checkInportByMmsi(req.getMmsi())){
+      throw new EnumException("该船舶不在辖区内");
+    }
     List<ShipDataVo> voList = commonService.selectBoatInfoList(req);
     ResultRes resultRes = ResultRes.encapsulationResult(req.getPageIndex(),
         req.getPageSize(),
@@ -127,6 +131,10 @@ public class BoatController extends CommonController {
     }
     String paramJsonData = getParamJsonData(vo.getData());
     ReportInfoRequest req = JSONObject.parseObject(paramJsonData, ReportInfoRequest.class);
+    // 判断只能查当前在浦东范围内有AIS信号的船
+    if(!commonService.checkInportByShipId(req.getShipId())){
+      throw new EnumException("该船舶不在辖区内");
+    }
     List<BoatReportInfoVo> voList = commonService.selectBoatReportInfoList(req);
     ResultRes resultRes = ResultRes.encapsulationResult(req.getPageIndex(),
         req.getPageSize(),

ghjg-item-datashare-server/src/main/java/com/shanghaichengdi/ghjgitem/mapper/CommonMapper.java

@@ -47,4 +47,8 @@ public interface CommonMapper {
   List<ShipDataVo> selectBoatInfoByMmsi(ShipMmsiReq param);
 
   List<CargoInfoForShipLockVo> selectCargoDeclareInfoByShipId(@Param("shipId") String shipId, ArrayList<String> list);
+
+  int getPdShipCountByMmsi(@Param("mmsi") String mmsi);
+
+  int getPdShipCountByShipId(@Param("shipId") String shipId);
 }

ghjg-item-datashare-server/src/main/java/com/shanghaichengdi/ghjgitem/service/CommonService.java

@@ -38,4 +38,8 @@ public interface CommonService {
     ShipInfoForShipLockVo selectBoatInfoByShipId(String shipId);
 
   CargoInfoForShipLockVo selectCargoDeclareInfoByShipId(String shipId);
+
+  boolean checkInportByMmsi(String mmsi);
+
+  boolean checkInportByShipId(String shipId);
 }

ghjg-item-datashare-server/src/main/java/com/shanghaichengdi/ghjgitem/service/impl/CommonServiceImpl.java

@@ -283,4 +283,24 @@ public class CommonServiceImpl implements CommonService {
             return  cargoInfoForShipLockVo.get(0);
         }
     }
+
+    @Override
+    public boolean checkInportByMmsi(String mmsi){
+        boolean flag = false;
+        int count = mapper.getPdShipCountByMmsi(mmsi);
+        if(count > 0) {
+          flag = true;
+        }
+        return flag;
+    }
+
+    @Override
+    public boolean checkInportByShipId(String shipId){
+        boolean flag = false;
+        int count = mapper.getPdShipCountByShipId(shipId);
+        if(count > 0) {
+            flag = true;
+        }
+        return flag;
+    }
 }

ghjg-item-datashare-server/src/main/resources/mapper/CommonMapper.xml

@@ -363,4 +363,21 @@
             where c.SHIP_ID = #{shipId}
         </foreach>
     </select>
+
+    <select id="getPdShipCountByMmsi" resultType="java.lang.Integer">
+        select count(1) from ghjg_dynamic.vw_gpsinfo_realtime t
+        where t.deviceid = #{mmsi}
+          and t.GPSTIME > sysdate - 1/24
+          and t.MAPX > -2000 and t.MAPX &lt; 48000
+          and t.MAPY > -48000 and t.MAPY &lt; 18000
+    </select>
+
+    <select id="getPdShipCountByShipId" resultType="java.lang.Integer">
+        select count(1) from ghjg_dynamic.vw_gpsinfo_realtime t
+        left join ghjg_basics.mvw_boat_info b on t.deviceid = b.mmsi
+        where b.ship_id = #{shipId}
+          and t.GPSTIME > sysdate - 1/24
+          and t.MAPX > -2000 and t.MAPX &lt; 48000
+          and t.MAPY > -48000 and t.MAPY &lt; 18000
+    </select>
 </mapper>