增加 视频重算功能

4dkankan-scene/src/main/java/com/fdkankan/scene/mapper/IRebuildVideoProgressMapper.java

@@ -0,0 +1,30 @@
+package com.fdkankan.scene.mapper;
+
+import com.fdkankan.base.mapper.base.IBaseMapper;
+import com.fdkankan.scene.entity.VideoSceneProgressEntity;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Select;
+import org.apache.ibatis.annotations.Update;
+
+import java.util.List;
+
+@Mapper
+public interface IRebuildVideoProgressMapper extends IBaseMapper<VideoSceneProgressEntity, Long> {
+
+    @Select(" select id,video_name,rebuild_result from t_video_scene_progress  where scene_code = #{sceneCode} AND rec_status = 'A' ")
+    List<VideoSceneProgressEntity> findrebuildVideoProgress(@Param("sceneCode") String sceneCode);
+
+
+    @Update(" UPDATE t_video_scene_progress SET rec_status = 'I',update_time=now()  WHERE scene_code = #{sceneCode} AND video_name = #{videoName} ")
+    int updateProgressRecStatus(@Param("sceneCode") String sceneCode, @Param("videoName") String videoName);
+
+    @Select(" select * from t_video_scene_progress  where scene_code = #{sceneCode} AND video_name = #{videoName} AND rec_status = 'A' ")
+    VideoSceneProgressEntity findrebuildVideoProgressDetail(@Param("sceneCode") String sceneCode, @Param("videoName") String videoName);
+
+    @Update(" UPDATE t_video_scene_progress SET rebuild_result = #{rebuildResult}, update_time=now(), rebuild_end_time=now()   WHERE scene_code = #{sceneCode} AND video_name = #{videoName} AND rec_status = 'A' ")
+    int updateProgressStatus(@Param("sceneCode") String sceneCode, @Param("videoName") String videoName, @Param("rebuildResult") Integer rebuildResult);
+
+    @Update(" UPDATE t_video_scene_progress SET rebuild_result = '9'  WHERE scene_code = #{sceneCode} AND rec_status = 'A' AND rebuild_result = '1' ")
+    int updatePageView(@Param("sceneCode") String sceneCode);
+}

4dkankan-scene/src/main/java/com/fdkankan/scene/service/impl/RebuildVideoProgressServiceImpl.java

@@ -0,0 +1,67 @@
+package com.fdkankan.scene.service.impl;
+
+import com.fdkankan.base.mapper.base.IBaseMapper;
+import com.fdkankan.base.service.impl.BaseServiceImpl;
+import com.fdkankan.common.vo.request.RequestRebuildVedioScene;
+import com.fdkankan.common.vo.response.ResponseVideoSceneProgress;
+import com.fdkankan.scene.entity.VideoSceneProgressEntity;
+import com.fdkankan.scene.mapper.IRebuildVideoProgressMapper;
+import com.fdkankan.scene.service.IRebuildVideoProgressService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * Created by Hb_zzZ on 2019/7/23.
+ */
+@Slf4j
+@Service
+@Transactional
+public class RebuildVideoProgressServiceImpl extends BaseServiceImpl<VideoSceneProgressEntity, Long> implements IRebuildVideoProgressService {
+
+    @Autowired
+    private IRebuildVideoProgressMapper rebuildVideoProgressMapper;
+
+    @Override
+    public IBaseMapper<VideoSceneProgressEntity, Long> getBaseMapper() {
+        return rebuildVideoProgressMapper;
+    }
+
+    @Override
+    public List<ResponseVideoSceneProgress> findVideoSceneProgress(RequestRebuildVedioScene requestRebuildVedioScene) {
+        List<VideoSceneProgressEntity> videoSceneProgressEntityList = rebuildVideoProgressMapper.findrebuildVideoProgress(requestRebuildVedioScene.getSceneNum());
+
+        List<ResponseVideoSceneProgress> responseVideoSceneProgressList = new ArrayList<>();
+        for (VideoSceneProgressEntity videoSceneProgressEntity : videoSceneProgressEntityList){
+            ResponseVideoSceneProgress responseVideoSceneProgress = new ResponseVideoSceneProgress();
+            BeanUtils.copyProperties(videoSceneProgressEntity, responseVideoSceneProgress);
+            responseVideoSceneProgressList.add(responseVideoSceneProgress);
+        }
+
+        //更新访问量
+        rebuildVideoProgressMapper.updatePageView(requestRebuildVedioScene.getSceneNum());
+        return responseVideoSceneProgressList;
+    }
+
+    @Override
+    public int updateProgressRec(RequestRebuildVedioScene requestRebuildVedioScene) {
+        return rebuildVideoProgressMapper.updateProgressRecStatus(requestRebuildVedioScene.getSceneNum(),requestRebuildVedioScene.getPanoId());
+    }
+
+    @Override
+    public VideoSceneProgressEntity findrebuildVideoProgressDetail(String num,String panId) {
+        return rebuildVideoProgressMapper.findrebuildVideoProgressDetail(num,panId);
+    }
+
+    @Override
+    public int updateProgress(String num, String panId, Integer status) {
+        return rebuildVideoProgressMapper.updateProgressStatus(num ,panId ,status );
+    }
+
+
+}