Browse Source

[feat]增加ai实时流预警列表查询

pull/6/head
杨威 1 month ago
parent
commit
1685c8892f
  1. 12
      dk-modules/business/src/main/java/org/dromara/business/controller/BusinessAlertController.java
  2. 2
      dk-modules/business/src/main/java/org/dromara/business/service/IBusinessAlertService.java
  3. 20
      dk-modules/business/src/main/java/org/dromara/business/service/impl/BusinessAlertServiceImpl.java
  4. 36
      dk-modules/sample/src/main/resources/mapper/IDeviceProMapper.xml

12
dk-modules/business/src/main/java/org/dromara/business/controller/BusinessAlertController.java

@ -165,4 +165,16 @@ public class BusinessAlertController extends BaseController {
} }
/**
* 查询实时流预警
*/
@SaCheckPermission("business:alertAi:list")
@Operation(summary ="查询实时流预警",description = "查询实时流预警")
@GetMapping("/ai/verify/alert")
public R<List<BusinessAlertVo>> listAiVerifyAlert(BusinessAlertVo vo) {
return R.ok(businessAlertService.listAiVerifyAlert(vo));
}
} }

2
dk-modules/business/src/main/java/org/dromara/business/service/IBusinessAlertService.java

@ -95,4 +95,6 @@ public interface IBusinessAlertService {
Boolean transferAlert(BusinessAlertVo vo); Boolean transferAlert(BusinessAlertVo vo);
BusinessAlert getBusinessAlert(Long alertId); BusinessAlert getBusinessAlert(Long alertId);
List<BusinessAlertVo> listAiVerifyAlert(BusinessAlertVo vo);
} }

20
dk-modules/business/src/main/java/org/dromara/business/service/impl/BusinessAlertServiceImpl.java

@ -669,6 +669,26 @@ public class BusinessAlertServiceImpl implements IBusinessAlertService {
return this.baseMapper.selectVoList(wrapper); return this.baseMapper.selectVoList(wrapper);
} }
@Override
public List<BusinessAlertVo> listAiVerifyAlert(BusinessAlertVo vo) {
LambdaQueryWrapper<BusinessAlert> wrapper = new LambdaQueryWrapper<>();
wrapper.eq(BusinessAlert::getHandleType, BusinessStatusEnum.VERIFY.getStatus());
wrapper.eq(BusinessAlert::getBusinessType, vo.getBusinessType());
if (ObjectUtil.isNotEmpty(vo.getDeptId())){
wrapper.eq(BusinessAlert::getDeptId, vo.getDeptId());
}
List<BusinessAlertVo> businessAlertVos = this.baseMapper.selectVoList(wrapper);
businessAlertVos.forEach(businessAlertVo->{
URL url = MinioUntil.getObjectUrlOne(MinIOConstants.BUCKET_DKCY, businessAlertVo.getImages(), 3600);
businessAlertVo.setImages(url.toString());
});
return businessAlertVos;
}
@Override @Override
public Boolean deleteAlert(List<Long> alertIdList) { public Boolean deleteAlert(List<Long> alertIdList) {
if (ObjectUtil.isEmpty(alertIdList)) { if (ObjectUtil.isEmpty(alertIdList)) {

36
dk-modules/sample/src/main/resources/mapper/IDeviceProMapper.xml

@ -10,24 +10,6 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
<result column="bind_type" property="bindType"/> <result column="bind_type" property="bindType"/>
<result column="nick_name" property="nickName"/> <result column="nick_name" property="nickName"/>
<result column="create_time" property="createTime"/> <result column="create_time" property="createTime"/>
<collection property="deviceProUserEntityList" ofType="org.dromara.sample.manage.model.entity.DeviceProUserEntity">
<result column="pro_user_id" property="id"/>
<result column="device_pro_id" property="deviceProId"/>
<result column="user_id" property="userId"/>
<result column="user_name" property="userName"/>
</collection>
<collection property="deviceEntityList" ofType="org.dromara.sample.manage.model.entity.DeviceEntity">
<result column="device_id" property="id"/>
<result column="device_sn" property="deviceSn"/>
<result column="device_name" property="deviceName"/>
<result column="device_type" property="deviceType"/>
<result column="sub_type" property="subType"/>
<result column="domain" property="domain"/>
<result column="child_sn" property="childSn"/>
<result column="workspace_id" property="workspaceId"/>
<result column="device_pro_number" property="proId"/>
<result column="device_nick_name" property="nickname"/>
</collection>
</resultMap> </resultMap>
<select id="listDeviceProEntityMap" resultMap="listDeviceProEntityMap"> <select id="listDeviceProEntityMap" resultMap="listDeviceProEntityMap">
SELECT SELECT
@ -36,25 +18,9 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
dp.bind_code, dp.bind_code,
dp.bind_type, dp.bind_type,
dp.nick_name, dp.nick_name,
dp.create_time, dp.create_time
dpu.id pro_user_id,
dpu.device_pro_id,
dpu.user_id,
dpu.user_name,
d.id device_id,
d.device_sn,
d.device_name,
d.device_type,
d.sub_type,
d.domain,
d.child_sn,
d.workspace_id,
d.pro_id device_pro_number,
d.nickname device_nick_name
FROM FROM
manage_device_pro dp manage_device_pro dp
LEFT JOIN manage_device d ON dp.id = d.pro_id
LEFT JOIN manage_device_pro_user dpu ON dp.id = dpu.device_pro_id
<where> <where>
<if test="condition.bind_code != null and condition.bind_code != ''"> <if test="condition.bind_code != null and condition.bind_code != ''">
and dp.bind_code like concat(concat('%',#{condition.bind_code}),'%') and dp.bind_code like concat(concat('%',#{condition.bind_code}),'%')

Loading…
Cancel
Save