Compare commits

..

No commits in common. '54267255ea279b480d7b1c2bdff7139ddcbf96f0' and 'b8eadae647e2a213626f43123e09bcf55044e16a' have entirely different histories.

  1. 3
      .gitignore
  2. 12
      hzims-service/operational/src/main/java/com/hnac/hzims/operational/station/mapper/StationVideoTypeMapper.java
  3. 10
      hzims-service/operational/src/main/java/com/hnac/hzims/operational/station/mapper/StationVideoTypeMapper.xml
  4. 12
      hzims-service/operational/src/main/java/com/hnac/hzims/operational/station/service/IStationVideoTypeService.java
  5. 57
      hzims-service/operational/src/main/java/com/hnac/hzims/operational/station/service/impl/ImsDeptServiceImpl.java
  6. 10
      hzims-service/operational/src/main/java/com/hnac/hzims/operational/station/service/impl/StationVideoTypeServiceImpl.java

3
.gitignore vendored

@ -20,5 +20,4 @@ build/
target/
*.logs
*.log
logs/
/AGENTS.md
logs/

12
hzims-service/operational/src/main/java/com/hnac/hzims/operational/station/mapper/StationVideoTypeMapper.java

@ -40,16 +40,4 @@ public interface StationVideoTypeMapper extends UserDataScopeBaseMapper<StationV
List<StationEntity> getAgencyStationsByVideo(@Param("type") String type);
IPage<StationVideoTypeVO> getStationVideoOrderByName(@Param(Constants.WRAPPER) QueryWrapper<StationVideoTypeEntity> wrapper, IPage page);
/**
* 获取配置了运行安全视频(video_ower_type=2,video_type为1~5)的去重站点号
* @return
*/
List<String> selectWaterStationIds();
/**
* 获取配置了防汛安全视频(video_ower_type=1,video_type=6)的去重站点号
* @return
*/
List<String> selectWaterSafeStationIds();
}

10
hzims-service/operational/src/main/java/com/hnac/hzims/operational/station/mapper/StationVideoTypeMapper.xml

@ -70,14 +70,4 @@
</where>
order by vt.pingyin ASC,vt.name ASC, vt.sort ASC,vt.create_time DESC
</select>
<select id="selectWaterStationIds" resultType="java.lang.String">
select distinct station_id from hzims_station_video_type
where is_deleted = 0 and video_ower_type = 2 and video_type in (1, 2, 3, 4, 5)
</select>
<select id="selectWaterSafeStationIds" resultType="java.lang.String">
select distinct station_id from hzims_station_video_type
where is_deleted = 0 and video_ower_type = 1 and video_type = 6
</select>
</mapper>

12
hzims-service/operational/src/main/java/com/hnac/hzims/operational/station/service/IStationVideoTypeService.java

@ -70,17 +70,5 @@ public interface IStationVideoTypeService extends BaseService<StationVideoTypeEn
List<StationVideoTypeEntity> getVideoCount(String code,List<String> videoType,String videoOwerType);
/**
* 获取配置了运行安全视频(video_ower_type=2,video_type为1~5)的去重站点号
* @return
*/
List<String> getWaterStationIds();
/**
* 获取配置了防汛安全视频(video_ower_type=1,video_type=6)的去重站点号
* @return
*/
List<String> getWaterSafeStationIds();
WaterMonitorVideoVo waterMonitorVideo();
}

57
hzims-service/operational/src/main/java/com/hnac/hzims/operational/station/service/impl/ImsDeptServiceImpl.java

@ -1,7 +1,7 @@
package com.hnac.hzims.operational.station.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.hnac.hzims.operational.OperationalConstants;
import com.hnac.hzims.operational.main.constant.HomePageConstant;
import com.hnac.hzims.operational.main.service.IWaterService;
import com.hnac.hzims.operational.station.entity.ImsDeptEntity;
@ -366,30 +366,19 @@ public class ImsDeptServiceImpl extends ServiceImpl<ImsDeptMapper, ImsDeptEntity
}
WaterDeptTreeVo waterDeptTreeVo = new WaterDeptTreeVo();
waterDeptTreeVo.setName("霍山县");
// 从视频配置表获取存在运行安全视频的去重站点号
List<String> stationIds = stationVideoTypeService.getWaterStationIds();
if (CollectionUtil.isEmpty(stationIds)) {
waterDeptTreeVo.setChildren(new ArrayList<>());
return waterDeptTreeVo;
}
// 根据站点号获取站点信息,按站点排序
List<StationEntity> stationList = stationService.list(new LambdaQueryWrapper<StationEntity>()
.in(StationEntity::getCode, stationIds)
.orderByAsc(StationEntity::getSort));
if (CollectionUtil.isEmpty(stationList)) {
waterDeptTreeVo.setChildren(new ArrayList<>());
return waterDeptTreeVo;
}
// List<StationEntity> likeRefDept = stationService.getLikeRefDept(2000000134L, null, new ArrayList<>());
List<WaterDeptTreeVo> child = new ArrayList<>();
for (StationEntity station : stationList) {
List<StationVideoTypeEntity> videoCount = stationVideoTypeService.getVideoCount(station.getCode(), Arrays.asList("1", "2", "3", "4", "5"), "2");
// for (StationEntity station : likeRefDept) {
for (OperationalConstants.StaionTypeEnum value : OperationalConstants.StaionTypeEnum.values()) {
List<StationVideoTypeEntity> videoCount = stationVideoTypeService.getVideoCount(value.getStationId(), Arrays.asList("1", "2", "3", "4", "5"), "2");
if (CollectionUtil.isEmpty(videoCount)) {
continue;
}
WaterDeptTreeVo waterDeptTreeVoChild = new WaterDeptTreeVo();
waterDeptTreeVoChild.setName(station.getName());
waterDeptTreeVoChild.setStationId(station.getCode());
waterDeptTreeVoChild.setSort(ObjectUtil.isNotEmpty(station.getSort()) ? station.getSort() : 0);
waterDeptTreeVoChild.setName(value.getName());
waterDeptTreeVoChild.setStationId(value.getStationId().toString());
waterDeptTreeVoChild.setSort(value.getType());
waterDeptTreeVoChild.setVideoNum(videoCount.size());
Map<String, List<StationVideoTypeEntity>> collect = videoCount.stream().collect(Collectors.groupingBy(StationVideoTypeEntity::getVideoType));
List<WaterDeptTreeVo> res = new ArrayList<>();
@ -410,7 +399,7 @@ public class ImsDeptServiceImpl extends ServiceImpl<ImsDeptMapper, ImsDeptEntity
if (stringListEntry.getKey().equals("5")) {
waterDeptTreeVoThree.setWaterName("运行");
}
waterDeptTreeVoThree.setStationId(station.getCode());
waterDeptTreeVoThree.setStationId(value.getStationId().toString());
waterDeptTreeVoThree.setWaterId(stringListEntry.getKey());
waterDeptTreeVoThree.setVideoNum(stringListEntry.getValue().size());
res.add(waterDeptTreeVoThree);
@ -429,31 +418,17 @@ public class ImsDeptServiceImpl extends ServiceImpl<ImsDeptMapper, ImsDeptEntity
}
WaterDeptTreeVo waterDeptTreeVo = new WaterDeptTreeVo();
waterDeptTreeVo.setName("霍山县");
// 从视频配置表获取存在防汛安全视频的去重站点号
List<String> stationIds = stationVideoTypeService.getWaterSafeStationIds();
if (CollectionUtil.isEmpty(stationIds)) {
waterDeptTreeVo.setChildren(new ArrayList<>());
return waterDeptTreeVo;
}
// 根据站点号获取站点信息,按站点排序
List<StationEntity> stationList = stationService.list(new LambdaQueryWrapper<StationEntity>()
.in(StationEntity::getCode, stationIds)
.orderByAsc(StationEntity::getSort));
if (CollectionUtil.isEmpty(stationList)) {
waterDeptTreeVo.setChildren(new ArrayList<>());
return waterDeptTreeVo;
}
List<WaterDeptTreeVo> child = new ArrayList<>();
for (StationEntity station : stationList) {
List<StationVideoTypeEntity> videoCount = stationVideoTypeService.getVideoCount(station.getCode(), Arrays.asList("6"), "1");
for (OperationalConstants.StaionTypeEnum value : OperationalConstants.StaionTypeEnum.values()) {
List<StationVideoTypeEntity> videoCount = stationVideoTypeService.getVideoCount(value.getStationId(), Arrays.asList("6"), "1");
if (CollectionUtil.isEmpty(videoCount)) {
continue;
}
WaterDeptTreeVo waterDeptTreeVoChild = new WaterDeptTreeVo();
waterDeptTreeVoChild.setName(station.getName());
waterDeptTreeVoChild.setSort(ObjectUtil.isNotEmpty(station.getSort()) ? station.getSort() : 0);
waterDeptTreeVoChild.setStationId(station.getCode());
waterDeptTreeVoChild.setWaterId(station.getCode());
waterDeptTreeVoChild.setName(value.getName());
waterDeptTreeVoChild.setSort(value.getType());
waterDeptTreeVoChild.setStationId(value.getStationId().toString());
waterDeptTreeVoChild.setWaterId(value.getStationId().toString());
waterDeptTreeVoChild.setVideoNum(videoCount.size());
child.add(waterDeptTreeVoChild);
}

10
hzims-service/operational/src/main/java/com/hnac/hzims/operational/station/service/impl/StationVideoTypeServiceImpl.java

@ -265,16 +265,6 @@ public class StationVideoTypeServiceImpl extends BaseServiceImpl<StationVideoTyp
}
@Override
public List<String> getWaterStationIds() {
return this.baseMapper.selectWaterStationIds();
}
@Override
public List<String> getWaterSafeStationIds() {
return this.baseMapper.selectWaterSafeStationIds();
}
@Override
public StationVideoTypeEntity getById(Long id, int streamType) {
StationVideoTypeEntity stationVideoTypeEntity = this.getById(id);
if (ObjectUtil.isNotEmpty(stationVideoTypeEntity.getIsHikvideo()) && stationVideoTypeEntity.getIsHikvideo() == 1) {

Loading…
Cancel
Save