船舶视频Id刷新

src/main/java/com/ghjg/shoreline/Schedule/DredgeVideoIdSchedule.java

@@ -0,0 +1,44 @@
+package com.ghjg.shoreline.Schedule;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.ghjg.shoreline.dto.DredgingProjectShips;
+import com.ghjg.shoreline.eum.ShipVideEnum;
+import com.ghjg.shoreline.service.DredgingProjectShipsService;
+import java.util.List;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+/**
+ * @ClassName: DredgVideoIdSchedule
+ * @description: TODO
+ * @author: sbj
+ * @time: 2023/12/6 17:13
+ * @Version: 1.0
+ */
+@Component
+public class DredgeVideoIdSchedule {
+
+  @Autowired
+  private DredgingProjectShipsService shipsService;
+
+  @Scheduled(cron = "0 0 3 * * ? ")
+  public void updateVideoIdSchedule(){
+    List<String> dredgingImportRules =  shipsService.getAllProjectId();
+    for (String dredgingImportRule : dredgingImportRules) {
+      LambdaQueryWrapper<DredgingProjectShips> wrapper = Wrappers.<DredgingProjectShips>lambdaQuery()
+          .eq(DredgingProjectShips::getOverviewId, dredgingImportRule);
+      List<DredgingProjectShips> list = shipsService.list(wrapper);
+      for (DredgingProjectShips ship : list) {
+        for (ShipVideEnum value : ShipVideEnum.values()) {
+          if (ship.getName().equals(value.getShipName())){
+            ship.setVideoId(value.getVideoId());
+            shipsService.updateVideoId(ship);
+            break;
+          }
+        }
+      }
+    }
+  }
+}

src/main/java/com/ghjg/shoreline/dto/DredgingProjectShips.java

@@ -0,0 +1,74 @@
+package com.ghjg.shoreline.dto;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import java.io.Serializable;
+import java.util.Date;
+import lombok.Data;
+
+/**
+ * 疏浚工程概况船只信息
+ * @TableName DREDGING_PROJECT_SHIPS
+ */
+@TableName(value ="GHJG_CHANNEL.DREDGING_PROJECT_SHIPS")
+@Data
+public class DredgingProjectShips implements Serializable {
+    /**
+     * 船舶九位码
+     */
+    @TableField("MMSI")
+    private String mmsi;
+    /**
+     * 船舶名称
+     */
+    @TableField("NAME")
+    private String Name;
+    /**
+     * 船舶编号
+     */
+    @TableField("CODE")
+    private String Code;
+    /**
+     * 1：挖泥船 2：运泥船
+     */
+    @TableField("TYPE")
+    private Long Type;
+    /**
+     * 船长
+     */
+    @TableField("CAPTIAN")
+    private String Captian;
+    /**
+     * 固定方量，单位:方
+     */
+    @TableField("TONNAGE")
+    private String Tonnage;
+    @TableField("CREATE_TIME")
+    private Date createTime;
+
+    @TableField("CREATE_USER")
+    private String createUser;
+
+    @TableField("UPDATE_TIME")
+    private Date updateTime;
+
+    @TableField("UPDATE_USER")
+    private String updateUser;
+    /**
+     * 0:未删除 1:已删除
+     */
+    @TableField("IS_REMOVE")
+    private Long isRemove;
+    /**
+     * project_overview主表主键
+     */
+    @TableField("OVERVIEW_ID")
+    private String overviewId;
+
+    @TableField("ID")
+    private String id;
+
+    @TableField("VIDEO_ID")
+    private String videoId;
+}

src/main/java/com/ghjg/shoreline/dao/ShoreLineMangeFile.java

@@ -1,4 +1,4 @@
-package com.ghjg.shoreline.dao;
+package com.ghjg.shoreline.dto;
 
 import com.baomidou.mybatisplus.annotation.TableField;
 import com.baomidou.mybatisplus.annotation.TableId;

src/main/java/com/ghjg/shoreline/dao/ShorelineManage.java

@@ -1,4 +1,4 @@
-package com.ghjg.shoreline.dao;
+package com.ghjg.shoreline.dto;
 
 
 import com.baomidou.mybatisplus.annotation.TableField;

src/main/java/com/ghjg/shoreline/dao/ShorelineManageHistory.java

@@ -1,4 +1,4 @@
-package com.ghjg.shoreline.dao;
+package com.ghjg.shoreline.dto;
 
 import com.baomidou.mybatisplus.annotation.TableField;
 import com.baomidou.mybatisplus.annotation.TableId;

src/main/java/com/ghjg/shoreline/eum/ShipVideEnum.java

@@ -0,0 +1,35 @@
+package com.ghjg.shoreline.eum;
+
+/**
+ * @author Administrator
+ */
+
+public enum ShipVideEnum {
+  SYG007("J49239481","顺洋工007"),
+  HJ1301("J49239421","航捷1301"),
+  YM001("J10265149","盐马001"),
+  WS608("J10265090","盛旺608");
+  private String videoId;
+  private String shipName;
+
+  ShipVideEnum(String videoId, String shipName) {
+    this.shipName = shipName;
+    this.videoId = videoId;
+  }
+
+  public String getShipName() {
+    return shipName;
+  }
+
+  public void setShipName(String shipName) {
+    this.shipName = shipName;
+  }
+
+  public String getVideoId() {
+    return videoId;
+  }
+
+  public void setVideoId(String videoId) {
+    this.videoId = videoId;
+  }
+}

src/main/java/com/ghjg/shoreline/mapper/DredgingProjectShipsMapper.java

@@ -0,0 +1,19 @@
+package com.ghjg.shoreline.mapper;
+
+import com.ghjg.shoreline.dto.DredgingProjectShips;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import java.util.List;
+
+/**
+ * @Entity com.ghjg.shoreline.dto.DredgingProjectShips
+ */
+public interface DredgingProjectShipsMapper extends BaseMapper<DredgingProjectShips> {
+
+  List<String> getAllProjectId();
+
+  void updateVideoId(DredgingProjectShips ship);
+}
+
+
+
+

src/main/java/com/ghjg/shoreline/mapper/ShoreLineHistoryMapper.java

@@ -1,11 +1,9 @@
 package com.ghjg.shoreline.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-import com.ghjg.shoreline.dao.ShorelineManageHistory;
+import com.ghjg.shoreline.dto.ShorelineManageHistory;
 import org.apache.ibatis.annotations.Mapper;
 
-import java.util.List;
-
 @Mapper
 public interface ShoreLineHistoryMapper extends BaseMapper<ShorelineManageHistory> {
 }

src/main/java/com/ghjg/shoreline/mapper/ShoreLineManageFileMapper.java

@@ -1,11 +1,8 @@
 package com.ghjg.shoreline.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-import com.ghjg.shoreline.dao.ShoreLineMangeFile;
+import com.ghjg.shoreline.dto.ShoreLineMangeFile;
 import org.apache.ibatis.annotations.Mapper;
-import org.apache.ibatis.annotations.Param;
-
-import java.util.List;
 
 @Mapper
 public interface ShoreLineManageFileMapper extends BaseMapper<ShoreLineMangeFile> {

src/main/java/com/ghjg/shoreline/mapper/ShoreLineMapper.java

@@ -1,7 +1,7 @@
 package com.ghjg.shoreline.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-import com.ghjg.shoreline.dao.ShorelineManage;
+import com.ghjg.shoreline.dto.ShorelineManage;
 import org.apache.ibatis.annotations.Mapper;
 
 import java.util.List;

src/main/java/com/ghjg/shoreline/service/DredgingProjectShipsService.java

@@ -0,0 +1,15 @@
+package com.ghjg.shoreline.service;
+
+import com.ghjg.shoreline.dto.DredgingProjectShips;
+import com.baomidou.mybatisplus.extension.service.IService;
+import java.util.List;
+
+/**
+ *
+ */
+public interface DredgingProjectShipsService extends IService<DredgingProjectShips> {
+
+  List<String> getAllProjectId();
+
+  void updateVideoId(DredgingProjectShips ship);
+}

src/main/java/com/ghjg/shoreline/service/ShoreLineHistoryService.java

@@ -1,7 +1,7 @@
 package com.ghjg.shoreline.service;
 
 import com.baomidou.mybatisplus.extension.service.IService;
-import com.ghjg.shoreline.dao.ShorelineManageHistory;
+import com.ghjg.shoreline.dto.ShorelineManageHistory;
 
 
 public interface ShoreLineHistoryService extends IService<ShorelineManageHistory> {

src/main/java/com/ghjg/shoreline/service/ShoreLineMangeFileService.java

@@ -1,10 +1,7 @@
 package com.ghjg.shoreline.service;
 
 import com.baomidou.mybatisplus.extension.service.IService;
-import com.ghjg.shoreline.dao.ShoreLineMangeFile;
-
-
-import java.util.List;
+import com.ghjg.shoreline.dto.ShoreLineMangeFile;
 
 public interface ShoreLineMangeFileService extends IService<ShoreLineMangeFile> {
 }

src/main/java/com/ghjg/shoreline/service/ShoreLineService.java

@@ -1,7 +1,7 @@
 package com.ghjg.shoreline.service;
 
 import com.baomidou.mybatisplus.extension.service.IService;
-import com.ghjg.shoreline.dao.ShorelineManage;
+import com.ghjg.shoreline.dto.ShorelineManage;
 
 public interface ShoreLineService extends IService<ShorelineManage> {
     void updateAllThreeTable();

src/main/java/com/ghjg/shoreline/service/impl/DredgingProjectShipsServiceImpl.java

@@ -0,0 +1,34 @@
+package com.ghjg.shoreline.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ghjg.shoreline.dto.DredgingProjectShips;
+import com.ghjg.shoreline.service.DredgingProjectShipsService;
+import com.ghjg.shoreline.mapper.DredgingProjectShipsMapper;
+import java.util.List;
+import javax.annotation.Resource;
+import org.springframework.stereotype.Service;
+
+/**
+ *
+ */
+@Service
+public class DredgingProjectShipsServiceImpl extends ServiceImpl<DredgingProjectShipsMapper, DredgingProjectShips>
+    implements DredgingProjectShipsService{
+
+  @Resource
+  private DredgingProjectShipsMapper dredgingProjectShipsMapper;
+
+  @Override
+  public List<String> getAllProjectId() {
+    return dredgingProjectShipsMapper.getAllProjectId();
+  }
+
+  @Override
+  public void updateVideoId(DredgingProjectShips ship) {
+    dredgingProjectShipsMapper.updateVideoId(ship);
+  }
+}
+
+
+
+

src/main/java/com/ghjg/shoreline/service/impl/ShoreLineHistoryServiceImpl.java

@@ -2,13 +2,12 @@ package com.ghjg.shoreline.service.impl;
 
 
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import com.ghjg.shoreline.dao.ShorelineManageHistory;
+import com.ghjg.shoreline.dto.ShorelineManageHistory;
 import com.ghjg.shoreline.mapper.ShoreLineHistoryMapper;
 import com.ghjg.shoreline.service.ShoreLineHistoryService;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
-import java.util.List;
 
 @Service
 public class ShoreLineHistoryServiceImpl extends ServiceImpl<ShoreLineHistoryMapper, ShorelineManageHistory> implements ShoreLineHistoryService {

src/main/java/com/ghjg/shoreline/service/impl/ShoreLineMangeFileServiceImpl.java

@@ -1,13 +1,12 @@
 package com.ghjg.shoreline.service.impl;
 
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import com.ghjg.shoreline.dao.ShoreLineMangeFile;
+import com.ghjg.shoreline.dto.ShoreLineMangeFile;
 import com.ghjg.shoreline.mapper.ShoreLineManageFileMapper;
 import com.ghjg.shoreline.service.ShoreLineMangeFileService;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
-import java.util.List;
 
 @Service
 public class ShoreLineMangeFileServiceImpl extends ServiceImpl<ShoreLineManageFileMapper, ShoreLineMangeFile> implements ShoreLineMangeFileService {

src/main/java/com/ghjg/shoreline/service/impl/ShoreLineServiceImpl.java

@@ -2,12 +2,11 @@ package com.ghjg.shoreline.service.impl;
 
 
 import cn.hutool.core.lang.generator.SnowflakeGenerator;
-import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import com.ghjg.shoreline.dao.ShoreLineMangeFile;
-import com.ghjg.shoreline.dao.ShorelineManage;
-import com.ghjg.shoreline.dao.ShorelineManageHistory;
+import com.ghjg.shoreline.dto.ShoreLineMangeFile;
+import com.ghjg.shoreline.dto.ShorelineManage;
+import com.ghjg.shoreline.dto.ShorelineManageHistory;
 import com.ghjg.shoreline.mapper.ShoreLineMapper;
 import com.ghjg.shoreline.service.ShoreLineHistoryService;
 import com.ghjg.shoreline.service.ShoreLineService;
@@ -19,7 +18,6 @@ import com.ghjg.shoreline.service.ShoreLineMangeFileService;
 
 import javax.annotation.Resource;
 import java.util.ArrayList;
-import java.util.Date;
 import java.util.List;
 import java.util.UUID;
 

src/main/resources/mapper/DredgingProjectShipsMapper.xml

@@ -0,0 +1,37 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper
+        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.ghjg.shoreline.mapper.DredgingProjectShipsMapper">
+
+    <resultMap id="BaseResultMap" type="com.ghjg.shoreline.dto.DredgingProjectShips">
+            <result property="mmsi" column="MMSI" jdbcType="VARCHAR"/>
+            <result property="name" column="NAME" jdbcType="VARCHAR"/>
+            <result property="code" column="CODE" jdbcType="VARCHAR"/>
+            <result property="type" column="TYPE" jdbcType="DECIMAL"/>
+            <result property="captian" column="CAPTIAN" jdbcType="VARCHAR"/>
+            <result property="tonnage" column="TONNAGE" jdbcType="VARCHAR"/>
+            <result property="createTime" column="CREATE_TIME" jdbcType="TIMESTAMP"/>
+            <result property="createUser" column="CREATE_USER" jdbcType="VARCHAR"/>
+            <result property="updateTime" column="UPDATE_TIME" jdbcType="TIMESTAMP"/>
+            <result property="updateUser" column="UPDATE_USER" jdbcType="VARCHAR"/>
+            <result property="isRemove" column="IS_REMOVE" jdbcType="DECIMAL"/>
+            <result property="overviewId" column="OVERVIEW_ID" jdbcType="VARCHAR"/>
+            <result property="id" column="ID" jdbcType="VARCHAR"/>
+            <result property="videoId" column="VIDEO_ID" jdbcType="VARCHAR"/>
+    </resultMap>
+
+    <sql id="Base_Column_List">
+        MMSI,NAME,CODE,
+        TYPE,CAPTIAN,TONNAGE,
+        CREATE_TIME,CREATE_USER,UPDATE_TIME,
+        UPDATE_USER,IS_REMOVE,OVERVIEW_ID,
+        ID,VIDEO_ID
+    </sql>
+  <update id="updateVideoId">
+    update GHJG_CHANNEL.DREDGING_PROJECT_SHIPS SET VIDEO_ID = #{videoId} WHERE NAME = #{Name}
+  </update>
+  <select id="getAllProjectId" resultType="java.lang.String">
+    select project_overview_id from GHJG_CHANNEL.DREDGING_IMPORT_RULE where IS_USEFUL = 0
+  </select>
+</mapper>

src/main/resources/mapper/ShoreLineMapper.xml

@@ -1,7 +1,7 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.ghjg.shoreline.mapper.ShoreLineMapper">
-    <select id="getPassDateList" resultType="com.ghjg.shoreline.dao.ShorelineManage">
+    <select id="getPassDateList" resultType="com.ghjg.shoreline.dto.ShorelineManage">
         select * from ghjg_channel.shoreline_manage
         where EFFECTIVE_DATE &lt;= sysdate
         and (certification_status = '已发证' or certification_status = '批文')