admin/wisdomisite-java
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

设备加企业名称

Browse Source
This commit is contained in:
guoshengxiong 2024-08-02 11:42:23 +08:00
parent afb685614e
commit ef8df07ec2
49 changed files with 381 additions and 64 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

68
src/main/java/com/zhgd/mybatis/DataScopeHandler.java
View File

@ -107,6 +107,53 @@ public class DataScopeHandler implements DataPermissionHandler {
return tables;
}
private HashMap<String, String> getFieldEnterpriseIdsTables() {
HashMap<String, String> tables = new HashMap<>(16);
tables.put("video_item", "enterprise_ids");
tables.put("ai_analyse_hard_ware_record", "enterprise_ids");
tables.put("car_camera", "enterprise_ids");
tables.put("hang_basket_dev", "enterprise_ids");
tables.put("deep_excavation_engineering", "enterprise_ids");
tables.put("high_formwork_plane_figure", "enterprise_ids");
tables.put("high_formwork_measure_point", "enterprise_ids");
tables.put("tower", "enterprise_ids");
tables.put("safety_hat_dev", "enterprise_ids");
tables.put("concrete_monitor_dev", "enterprise_ids");
tables.put("environment_dev", "enterprise_ids");
tables.put("poisonous_gas_dev", "enterprise_ids");
tables.put("uface_dev", "enterprise_ids");
// tables.put("anti_pressure_fold_dev", "enterprise_ids");
// tables.put("bridge_erect_machine_dev", "enterprise_ids");
// tables.put("car_wash_dev", "enterprise_ids");
// tables.put("concrete_mix_station_dev", "enterprise_ids");
// tables.put("discharging_platform_dev", "enterprise_ids");
// tables.put("double_carbon_dev", "enterprise_ids");
// tables.put("electrical_dev", "enterprise_ids");
// tables.put("frontier_protection_dev", "enterprise_ids");
// tables.put("frontier_protection_no_net_dev", "enterprise_ids");
// tables.put("gt_material_device", "enterprise_ids");
// tables.put("high_formwork_measure_device", "enterprise_ids");
// tables.put("mass_rebound_measure_dev", "enterprise_ids");
// tables.put("ms_mixed_soil_dev", "enterprise_ids");
// tables.put("pave_compaction_dev", "enterprise_ids");
// tables.put("pave_dev", "enterprise_ids");
// tables.put("photovoltaic_power_dev", "enterprise_ids");
// tables.put("pitch_mix_station_dev", "enterprise_ids");
// tables.put("pressure_test_machine_dev", "enterprise_ids");
// tables.put("sewage_dev", "enterprise_ids");
// tables.put("smart_grout_dev", "enterprise_ids");
// tables.put("smart_tension_dev", "enterprise_ids");
// tables.put("smoke_dev", "enterprise_ids");
// tables.put("spray_dev", "enterprise_ids");
// tables.put("spray_rt_dev", "enterprise_ids");
// tables.put("stable_water_mix_station_dev", "enterprise_ids");
// tables.put("standard_dev", "enterprise_ids");
// tables.put("universal_test_dev", "enterprise_ids");
// tables.put("vehicle_position_dev", "enterprise_ids");
return tables;
}
private HashMap<String, String> getFieldVideoTables() {
HashMap<String, String> tables = new HashMap<>(16);
tables.put("video_item", "item_id");
@ -151,6 +198,27 @@ public class DataScopeHandler implements DataPermissionHandler {
}
}
if (!EnvironmentUtil.isXingZongProd() && !EnvironmentUtil.isXingZongTest()) {
//对合作单位ids做数据权限
//and (FIND_IN_SET(100,xxx.enterprise_ids) or FIND_IN_SET(102,xxx.enterprise_ids))
List<String> filterEnterpriseIds = getNeedFilterLeftExpression(plainSelect, getFieldEnterpriseIdsTables(), ds);
if (CollUtil.isNotEmpty(filterEnterpriseIds)) {
List<String> enterpriseIds = userEnterpriseService.getEnterpriseIdsIfSubProject();
for (String filterEnterpriseId : filterEnterpriseIds) {
List<String> list1 = enterpriseIds.stream().map(s -> "FIND_IN_SET(" + s + "," + filterEnterpriseId + ")").collect(Collectors.toList());
String s1 = StrUtil.join(" or ", list1);
String sql = " (" + s1 + ")";
Expression expression = null;
try {
expression = CCJSqlParserUtil.parseCondExpression(sql);
expressions.add(expression);
} catch (JSQLParserException e) {
log.error("", e);
}
}
}
}
List<String> filterItems = getNeedFilterLeftExpression(plainSelect, getFieldVideoTables(), ds);
if (CollUtil.isNotEmpty(filterItems)) {
List<String> videoItems = userDevAuthorityService.getVideoItemsIfSubProject();

8
src/main/java/com/zhgd/xmgl/modules/bigdevice/entity/Tower.java
View File

@ -443,6 +443,11 @@ public class Tower implements Serializable {
@ApiModelProperty(value = "钢丝绳设备id")
private java.lang.Long tckwWireRopeId;
/**
* 企业ids（多个，分割）
*/
@ApiModelProperty(value = "企业ids（多个，分割）")
private String enterpriseIds;
@TableField(exist = false)
@ApiModelProperty(value = "视频配置")
@ -474,4 +479,7 @@ public class Tower implements Serializable {
@TableField(exist = false)
@ApiModelProperty(value = "报警数量")
private Integer alarmNum;
@TableField(exist = false)
@ApiModelProperty(value = "企业名称（多个，分割）")
private java.lang.String enterpriseName;
}

12
src/main/java/com/zhgd/xmgl/modules/car/controller/CarCameraController.java
View File

@ -3,9 +3,11 @@ package com.zhgd.xmgl.modules.car.controller;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.zhgd.annotation.OperLog;
import com.zhgd.jeecg.common.api.vo.Result;
import com.zhgd.jeecg.common.system.query.QueryGenerator;
import com.zhgd.xmgl.modules.car.entity.CarCamera;
import com.zhgd.xmgl.modules.car.service.ICarCameraService;
import com.zhgd.xmgl.util.MessageUtil;
import com.zhgd.xmgl.util.RefUtil;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
@ -38,7 +40,7 @@ public class CarCameraController {
private ICarCameraService carCameraService;
/**
* 分页列表查询
* 列表查询
*
* @return
*/
@ -49,9 +51,11 @@ public class CarCameraController {
})
@PostMapping(value = "/list")
public Result<List<CarCamera>> selectCarCameraList(@RequestBody Map<String, Object> map) {
QueryWrapper<CarCamera> queryWrapper = new QueryWrapper<>();
queryWrapper.lambda().eq(CarCamera::getProjectSn, MapUtils.getString(map, "projectSn"));
List<CarCamera> list = carCameraService.list(queryWrapper);
String alias = "t.";
QueryWrapper<CarCamera> queryWrapper = QueryGenerator.initPageQueryWrapper(CarCamera.class, map, alias);
queryWrapper.groupBy(alias + RefUtil.fieldNameUlc(CarCamera::getId));
queryWrapper.orderByDesc(alias + RefUtil.fieldNameUlc(CarCamera::getId));
List<CarCamera> list = carCameraService.queryList(queryWrapper);
return Result.success(list);
}

12
src/main/java/com/zhgd/xmgl/modules/car/entity/CarCamera.java
View File

@ -1,6 +1,7 @@
package com.zhgd.xmgl.modules.car.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.annotation.JsonFormat;
@ -26,7 +27,6 @@ public class CarCamera implements Serializable {
private static final long serialVersionUID = 1L;
/**id*/
@TableId(type = IdType.ASSIGN_ID)
@ApiModelProperty(value="id")
private java.lang.Long id ;
@ -69,4 +69,14 @@ public class CarCamera implements Serializable {
@DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss")
@ApiModelProperty(value="心跳时间，30分钟没接收到实时数据表示设备离线")
private java.util.Date heartBeatTime ;
/**
* 企业ids（多个，分割）
*/
@ApiModelProperty(value = "企业ids（多个，分割）")
private String enterpriseIds;
@TableField(exist = false)
@ApiModelProperty(value = "企业名称（多个，分割）")
private java.lang.String enterpriseName;
}

13
src/main/java/com/zhgd/xmgl/modules/car/mapper/CarCameraMapper.java
View File

@ -1,9 +1,14 @@
package com.zhgd.xmgl.modules.car.mapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.core.toolkit.Constants;
import com.zhgd.annotation.DataScope;
import com.zhgd.xmgl.modules.car.entity.CarCamera;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import java.util.List;
import java.util.Map;
/**
@ -13,6 +18,7 @@ import java.util.Map;
* @version： V1.0
*/
@Mapper
@DataScope(includeTable = "car_camera")
public interface CarCameraMapper extends BaseMapper<CarCamera> {
/**
@ -23,4 +29,11 @@ public interface CarCameraMapper extends BaseMapper<CarCamera> {
*/
Map<String, Object> getCarPassRecordTotalInAndOut(Map<String, Object> map);
/**
* 列表查询车辆相机信息
*
* @param queryWrapper
* @return
*/
List<CarCamera> queryList(@Param(Constants.WRAPPER) QueryWrapper<CarCamera> queryWrapper);
}

7
src/main/java/com/zhgd/xmgl/modules/car/mapper/xml/CarCameraMapper.xml
View File

@ -13,4 +13,11 @@
and a.pass_time>=CONCAT(DATE_FORMAT(now(),"%Y-%m-%d"),' 00:00:00')
</select>
<select id="queryList" resultType="com.zhgd.xmgl.modules.car.entity.CarCamera">
select t.*,group_concat(distinct ei.enterprise_name) as enterprise_name
from car_camera t
left join enterprise_info ei on find_in_set(ei.id,t.enterprise_ids)
${ew.customSqlSegment}
</select>
</mapper>

8
src/main/java/com/zhgd/xmgl/modules/car/service/ICarCameraService.java
View File

@ -1,5 +1,6 @@
package com.zhgd.xmgl.modules.car.service;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.IService;
import com.zhgd.xmgl.modules.car.entity.CarCamera;
@ -49,4 +50,11 @@ public interface ICarCameraService extends IService<CarCamera> {
* @param cameraId
*/
void updateCarCamera(String projectSn, String cameraId);
/**
* 列表查询车辆相机信息
* @param queryWrapper
* @return
*/
List<CarCamera> queryList(QueryWrapper<CarCamera> queryWrapper);
}

5
src/main/java/com/zhgd/xmgl/modules/car/service/impl/CarCameraServiceImpl.java
View File

@ -92,5 +92,10 @@ public class CarCameraServiceImpl extends ServiceImpl<CarCameraMapper, CarCamera
carCameraMapper.update(carCamera,carCameraQueryWrapper);
}
@Override
public List<CarCamera> queryList(QueryWrapper<CarCamera> queryWrapper) {
return baseMapper.queryList(queryWrapper);
}
}

2
src/main/java/com/zhgd/xmgl/modules/concrete/controller/ConcreteMonitorDevController.java
View File

@ -49,7 +49,7 @@ public class ConcreteMonitorDevController {
@ApiImplicitParam(name = "pageSize", value = "每页显示条数", paramType = "body", required = true, dataType = "Integer"),
})
@PostMapping(value = "/list")
public Result<IPage<EntityMap>> queryPageList(@RequestBody Map<String, Object> map) {
public Result<IPage<ConcreteMonitorDev>> queryPageList(@RequestBody Map<String, Object> map) {
return Result.success(concreteMonitorDevService.selectConcreteMonitorDevPageList(map));
}

9
src/main/java/com/zhgd/xmgl/modules/concrete/mapper/ConcreteMonitorDevMapper.java
View File

@ -4,7 +4,11 @@ import java.util.HashMap;
import java.util.List;
import java.util.Map;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Constants;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.zhgd.annotation.DataScope;
import com.zhgd.jeecg.common.mybatis.EntityMap;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
@ -18,9 +22,10 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
* @version： V1.0
*/
@Mapper
@DataScope(includeTable = "concrete_monitor_dev")
public interface ConcreteMonitorDevMapper extends BaseMapper<ConcreteMonitorDev> {
List<EntityMap> selectConcreteMonitorDevPageList(Page<EntityMap> page, @Param("param") Map<String, Object> map);
Integer countPointNum(HashMap<String, Object> paramMap);
IPage<ConcreteMonitorDev> queryList(@Param(Constants.WRAPPER) QueryWrapper<ConcreteMonitorDev> queryWrapper, Page page);
}

13
src/main/java/com/zhgd/xmgl/modules/concrete/mapper/xml/ConcreteMonitorDevMapper.xml
View File

@ -1,15 +1,16 @@
<?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.zhgd.xmgl.modules.concrete.mapper.ConcreteMonitorDevMapper">
<select id="selectConcreteMonitorDevPageList" resultType="com.zhgd.jeecg.common.mybatis.EntityMap">
SELECT a.*
FROM concrete_monitor_dev a
where a.project_sn=#{param.projectSn}
</select>
<select id="countPointNum" resultType="java.lang.Integer">
SELECT ifnull(sum(point_num),0)
FROM concrete_monitor_dev a
where a.project_sn=#{projectSn}
</select>
<select id="queryList" resultType="com.zhgd.xmgl.modules.concrete.entity.ConcreteMonitorDev">
select t.*,group_concat(distinct ei.enterprise_name) as enterprise_name
from concrete_monitor_dev t
left join enterprise_info ei on find_in_set(ei.id,t.enterprise_ids)
${ew.customSqlSegment}
</select>
</mapper>

2
src/main/java/com/zhgd/xmgl/modules/concrete/service/IConcreteMonitorDevService.java
View File

@ -16,7 +16,7 @@ import java.util.Map;
*/
public interface IConcreteMonitorDevService extends IService<ConcreteMonitorDev> {
IPage<EntityMap> selectConcreteMonitorDevPageList(Map<String, Object> map);
IPage<ConcreteMonitorDev> selectConcreteMonitorDevPageList(Map<String, Object> map);
List<ConcreteMonitorDev> selectConcreteMonitorDevList(Map<String, Object> map);

16
src/main/java/com/zhgd/xmgl/modules/concrete/service/impl/ConcreteMonitorDevServiceImpl.java
View File

@ -6,12 +6,16 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.zhgd.jeecg.common.execption.OpenAlertException;
import com.zhgd.jeecg.common.mybatis.EntityMap;
import com.zhgd.jeecg.common.system.query.QueryGenerator;
import com.zhgd.xmgl.modules.car.entity.CarCamera;
import com.zhgd.xmgl.modules.concrete.entity.ConcreteMonitorDev;
import com.zhgd.xmgl.modules.concrete.entity.ConcreteMonitorDevPointPosition;
import com.zhgd.xmgl.modules.concrete.mapper.ConcreteMonitorDevMapper;
import com.zhgd.xmgl.modules.concrete.mapper.ConcreteMonitorDevPointPositionMapper;
import com.zhgd.xmgl.modules.concrete.service.IConcreteMonitorDevService;
import com.zhgd.xmgl.util.MessageUtil;
import com.zhgd.xmgl.util.PageUtil;
import com.zhgd.xmgl.util.RefUtil;
import org.apache.commons.collections.MapUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@ -39,12 +43,12 @@ public class ConcreteMonitorDevServiceImpl extends ServiceImpl<ConcreteMonitorDe
private ConcreteMonitorDevPointPositionMapper concreteMonitorDevPointPositionMapper;
@Override
public IPage<EntityMap> selectConcreteMonitorDevPageList(Map<String, Object> map) {
int pageNo = Integer.parseInt(map.getOrDefault("pageNo", 1).toString());
int pageSize = Integer.parseInt(map.getOrDefault("pageSize", 10).toString());
Page<EntityMap> page = new Page<>(pageNo, pageSize);
List<EntityMap> list = concreteMonitorDevMapper.selectConcreteMonitorDevPageList(page, map);
return page.setRecords(list);
public IPage<ConcreteMonitorDev> selectConcreteMonitorDevPageList(Map<String, Object> map) {
String alias = "t.";
QueryWrapper<ConcreteMonitorDev> queryWrapper = QueryGenerator.initPageQueryWrapper(ConcreteMonitorDev.class, map, alias);
queryWrapper.groupBy(alias + RefUtil.fieldNameUlc(ConcreteMonitorDev::getId));
queryWrapper.orderByDesc(alias + RefUtil.fieldNameUlc(ConcreteMonitorDev::getId));
return baseMapper.queryList(queryWrapper, PageUtil.getPage(map));
}
@Override

2
src/main/java/com/zhgd/xmgl/modules/environment/mapper/EnvironmentDevMapper.java
View File

@ -3,6 +3,7 @@ package com.zhgd.xmgl.modules.environment.mapper;
import java.util.List;
import java.util.Map;
import com.zhgd.annotation.DataScope;
import com.zhgd.jeecg.common.mybatis.EntityMap;
import org.apache.ibatis.annotations.Mapper;
import com.zhgd.xmgl.modules.environment.entity.EnvironmentDev;
@ -16,6 +17,7 @@ import org.apache.ibatis.annotations.Param;
* @version： V1.0
*/
@Mapper
@DataScope(includeTable = "environment_dev")
public interface EnvironmentDevMapper extends BaseMapper<EnvironmentDev> {
List<EnvironmentDev> selectEnvironmentDevList(Map<String, Object> map);

10
src/main/java/com/zhgd/xmgl/modules/environment/mapper/xml/EnvironmentDevMapper.xml
View File

@ -15,13 +15,15 @@
</update>
<select id="selectEnvironmentDevList" resultType="com.zhgd.xmgl.modules.environment.entity.EnvironmentDev">
select *,
select t.*,
<include refid="getOnline">
<property name="real_time" value="real_time"/>
<property name="real_time" value="t.real_time"/>
</include>
dev_online
from environment_dev
dev_online,group_concat(distinct ei.enterprise_name) as enterprise_name
from environment_dev t
left join enterprise_info ei on find_in_set(ei.id,t.enterprise_ids)
where project_sn = #{projectSn}
group by t.id
</select>
<select id="selectAllDevCount" resultType="java.util.Map">

10
src/main/java/com/zhgd/xmgl/modules/foundation/controller/DeepExcavationEngineeringController.java
View File

@ -109,15 +109,7 @@ public class DeepExcavationEngineeringController {
@ApiImplicitParam(name = "id", value = "深基坑-工程ID", paramType = "body", required = true, dataType = "Integer")
@PostMapping(value = "/queryById")
public Result<DeepExcavationEngineering> queryById(@RequestBody Map<String, Object> map) {
Result<DeepExcavationEngineering> result = new Result<DeepExcavationEngineering>();
DeepExcavationEngineering deepExcavationEngineering = deepExcavationEngineeringService.getById(MapUtils.getString(map, "id"));
if (deepExcavationEngineering == null) {
result.error500(MessageUtil.get("notFindErr"));
} else {
result.setResult(deepExcavationEngineering);
result.setSuccess(true);
}
return result;
return Result.success(deepExcavationEngineeringService.queryById(map));
}

10
src/main/java/com/zhgd/xmgl/modules/foundation/entity/DeepExcavationEngineering.java
View File

@ -111,6 +111,16 @@ public class DeepExcavationEngineering implements Serializable {
@Excel(name = "状态，0，未开工，1进行中，2已完成", width = 15)
@ApiModelProperty(value = "状态，0，未开工，1进行中，2已完成")
private Integer status;
/**
* 企业ids（多个，分割）
*/
@ApiModelProperty(value = "企业ids（多个，分割）")
private String enterpriseIds;
@TableField(exist = false)
@ApiModelProperty(value = "企业名称（多个，分割）")
private java.lang.String enterpriseName;
@ApiModelProperty(value = "默认监测内容ID")
@TableField(exist = false)

5
src/main/java/com/zhgd/xmgl/modules/foundation/mapper/DeepExcavationEngineeringMapper.java
View File

@ -2,6 +2,8 @@ package com.zhgd.xmgl.modules.foundation.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.zhgd.annotation.DataScope;
import com.zhgd.jeecg.common.api.vo.Result;
import com.zhgd.xmgl.modules.foundation.entity.DeepExcavationEngineering;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
@ -16,9 +18,12 @@ import java.util.Map;
* @version： V1.0
*/
@Mapper
@DataScope(includeTable = "deep_excavation_engineering")
public interface DeepExcavationEngineeringMapper extends BaseMapper<DeepExcavationEngineering> {
List<DeepExcavationEngineering> selectDeepExcavationEngineeringPage(Page<DeepExcavationEngineering> page, @Param("param")Map<String, Object> map);
List<DeepExcavationEngineering> selectDeepExcavationList(Map<String, Object> map);
DeepExcavationEngineering queryById(Map<String, Object> map);
}

17
src/main/java/com/zhgd/xmgl/modules/foundation/mapper/xml/DeepExcavationEngineeringMapper.xml
View File

@ -13,9 +13,24 @@
<select id="selectDeepExcavationList"
resultType="com.zhgd.xmgl.modules.foundation.entity.DeepExcavationEngineering">
SELECT *
from deep_excavation_engineering
from (SELECT t.*,group_concat(distinct ei.enterprise_name) as enterprise_name
from deep_excavation_engineering t
left join enterprise_info ei on find_in_set(ei.id,t.enterprise_ids)
group by t.id
) t
WHERE project_sn=#{projectSn}
order by start_time
</select>
<select id="queryById" resultType="com.zhgd.xmgl.modules.foundation.entity.DeepExcavationEngineering">
SELECT *
from (SELECT t.*,group_concat(distinct ei.enterprise_name) as enterprise_name
from deep_excavation_engineering t
left join enterprise_info ei on find_in_set(ei.id,t.enterprise_ids)
group by t.id
) t
WHERE id=#{id}
order by start_time
</select>
</mapper>

3
src/main/java/com/zhgd/xmgl/modules/foundation/service/IDeepExcavationEngineeringService.java
View File

@ -2,6 +2,7 @@ package com.zhgd.xmgl.modules.foundation.service;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.service.IService;
import com.zhgd.jeecg.common.api.vo.Result;
import com.zhgd.xmgl.modules.foundation.entity.DeepExcavationEngineering;
import java.util.List;
@ -24,4 +25,6 @@ public interface IDeepExcavationEngineeringService extends IService<DeepExcavati
List<DeepExcavationEngineering> selectDeepExcavationList(Map<String, Object> map);
DeepExcavationEngineering edit(DeepExcavationEngineering deepExcavationEngineering);
DeepExcavationEngineering queryById(Map<String, Object> map);
}

6
src/main/java/com/zhgd/xmgl/modules/foundation/service/impl/DeepExcavationEngineeringServiceImpl.java
View File

@ -8,6 +8,7 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.zhgd.jeecg.common.api.vo.Result;
import com.zhgd.jeecg.common.execption.OpenAlertException;
import com.zhgd.xmgl.modules.foundation.entity.DeepExcavationEngineering;
import com.zhgd.xmgl.modules.foundation.entity.DeepExcavationMonitorTypeRela;
@ -103,6 +104,11 @@ public class DeepExcavationEngineeringServiceImpl extends ServiceImpl<DeepExcava
return deepExcavationEngineering;
}
@Override
public DeepExcavationEngineering queryById(Map<String, Object> map) {
return baseMapper.queryById(map);
}
private void checkParams(DeepExcavationEngineering deepExcavationEngineering) {
if (DateUtil.parse(deepExcavationEngineering.getStartTime()).compareTo(DateUtil.parse(deepExcavationEngineering.getEndTime())) > 0) {
throw new OpenAlertException("开工时间不能大于完工时间");

28
src/main/java/com/zhgd/xmgl/modules/hangbasket/mapper/HangBasketDevMapper.java
View File

@ -1,8 +1,16 @@
package com.zhgd.xmgl.modules.hangbasket.mapper;
import org.apache.ibatis.annotations.Mapper;
import com.zhgd.xmgl.modules.hangbasket.entity.HangBasketDev;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Constants;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.zhgd.annotation.DataScope;
import com.zhgd.xmgl.modules.hangbasket.entity.HangBasketDev;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import java.util.List;
/**
* @Description: 挂篮设备
@ -11,6 +19,22 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
* @version： V1.0
*/
@Mapper
@DataScope(includeTable = "hang_basket_dev")
public interface HangBasketDevMapper extends BaseMapper<HangBasketDev> {
/**
* 列表查询挂篮设备信息
*
* @param queryWrapper
* @return
*/
List<HangBasketDev> queryList(@Param(Constants.WRAPPER) QueryWrapper<HangBasketDev> queryWrapper);
/**
* 分页列表查询挂篮设备信息
*
* @param page
* @param queryWrapper
* @return
*/
IPage<HangBasketDev> queryList(Page<HangBasketDev> page, @Param(Constants.WRAPPER) QueryWrapper<HangBasketDev> queryWrapper);
}

7
src/main/java/com/zhgd/xmgl/modules/hangbasket/mapper/xml/HangBasketDevMapper.xml
View File

@ -1,4 +1,11 @@
<?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.zhgd.xmgl.modules.hangbasket.mapper.HangBasketDevMapper">
<select id="queryList" resultType="com.zhgd.xmgl.modules.hangbasket.entity.HangBasketDev">
select t.*,group_concat(distinct ei.enterprise_name) as enterprise_name
from hang_basket_dev t
left join enterprise_info ei on find_in_set(ei.id,t.enterprise_ids)
${ew.customSqlSegment}
</select>
</mapper>

11
src/main/java/com/zhgd/xmgl/modules/hangbasket/service/impl/HangBasketDevServiceImpl.java
View File

@ -7,6 +7,7 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.zhgd.jeecg.common.execption.OpenAlertException;
import com.zhgd.jeecg.common.system.query.QueryGenerator;
import com.zhgd.xmgl.modules.car.entity.CarCamera;
import com.zhgd.xmgl.modules.hangbasket.entity.HangBasketDev;
import com.zhgd.xmgl.modules.hangbasket.mapper.HangBasketDevMapper;
import com.zhgd.xmgl.modules.hangbasket.service.IHangBasketDevService;
@ -29,7 +30,7 @@ public class HangBasketDevServiceImpl extends ServiceImpl<HangBasketDevMapper, H
public IPage<HangBasketDev> queryPageList(HashMap<String, Object> paramMap) {
QueryWrapper<HangBasketDev> queryWrapper = getQueryWrapper(paramMap);
Page<HangBasketDev> page = PageUtil.getPage(paramMap);
IPage<HangBasketDev> pageList = this.page(page, queryWrapper);
IPage<HangBasketDev> pageList = baseMapper.queryList(page, queryWrapper);
pageList.setRecords(dealList(pageList.getRecords()));
return pageList;
}
@ -37,7 +38,7 @@ public class HangBasketDevServiceImpl extends ServiceImpl<HangBasketDevMapper, H
@Override
public List<HangBasketDev> queryList(HashMap<String, Object> paramMap) {
QueryWrapper<HangBasketDev> queryWrapper = getQueryWrapper(paramMap);
return dealList(this.list(queryWrapper));
return dealList(baseMapper.queryList(queryWrapper));
}
@Override
@ -65,8 +66,10 @@ public class HangBasketDevServiceImpl extends ServiceImpl<HangBasketDevMapper, H
}
private QueryWrapper<HangBasketDev> getQueryWrapper(HashMap<String, Object> paramMap) {
QueryWrapper<HangBasketDev> queryWrapper = QueryGenerator.initPageQueryWrapper(HangBasketDev.class, paramMap);
queryWrapper.orderByDesc(RefUtil.fieldNameUlc(HangBasketDev::getId));
String alias = "t.";
QueryWrapper<HangBasketDev> queryWrapper = QueryGenerator.initPageQueryWrapper(HangBasketDev.class, paramMap, alias);
queryWrapper.groupBy(alias + RefUtil.fieldNameUlc(HangBasketDev::getId));
queryWrapper.orderByDesc(alias + RefUtil.fieldNameUlc(HangBasketDev::getId));
return queryWrapper;
}

11
src/main/java/com/zhgd/xmgl/modules/highformwork/controller/HighFormworkPlaneFigureController.java
View File

@ -2,9 +2,12 @@ package com.zhgd.xmgl.modules.highformwork.controller;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.zhgd.jeecg.common.api.vo.Result;
import com.zhgd.jeecg.common.system.query.QueryGenerator;
import com.zhgd.xmgl.modules.car.entity.CarCamera;
import com.zhgd.xmgl.modules.highformwork.entity.HighFormworkPlaneFigure;
import com.zhgd.xmgl.modules.highformwork.service.IHighFormworkPlaneFigureService;
import com.zhgd.xmgl.util.MessageUtil;
import com.zhgd.xmgl.util.RefUtil;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
@ -46,9 +49,11 @@ public class HighFormworkPlaneFigureController {
})
@PostMapping(value = "/selectList")
public Result<List<HighFormworkPlaneFigure>> selectList(@RequestBody Map<String,Object> map) {
QueryWrapper<HighFormworkPlaneFigure> queryWrapper=new QueryWrapper<>();
queryWrapper.lambda().eq(HighFormworkPlaneFigure::getProjectSn, MapUtils.getString(map,"projectSn"));
List<HighFormworkPlaneFigure> list=highFormworkPlaneFigureService.list(queryWrapper);
String alias = "t.";
QueryWrapper<HighFormworkPlaneFigure> queryWrapper = QueryGenerator.initPageQueryWrapper(HighFormworkPlaneFigure.class, map, alias);
queryWrapper.groupBy(alias + RefUtil.fieldNameUlc(HighFormworkPlaneFigure::getId));
queryWrapper.orderByDesc(alias + RefUtil.fieldNameUlc(HighFormworkPlaneFigure::getId));
List<HighFormworkPlaneFigure> list=highFormworkPlaneFigureService.queryList(queryWrapper);
return Result.success(list);
}

10
src/main/java/com/zhgd/xmgl/modules/highformwork/entity/HighFormworkMeasurePoint.java
View File

@ -63,6 +63,16 @@ public class HighFormworkMeasurePoint implements Serializable {
@Excel(name = "报警状态，1正常，2预警，3报警", width = 15)
@ApiModelProperty(value = "报警状态，1正常，2预警，3报警")
private java.lang.Integer alarmState;
/**
* 企业ids（多个，分割）
*/
@ApiModelProperty(value = "企业ids（多个，分割）")
private String enterpriseIds;
@TableField(exist = false)
@ApiModelProperty(value = "企业名称（多个，分割）")
private java.lang.String enterpriseName;
@TableField(exist = false)
@ApiModelProperty(value = "测量点报警预警阀值")

9
src/main/java/com/zhgd/xmgl/modules/highformwork/entity/HighFormworkPlaneFigure.java
View File

@ -40,6 +40,15 @@ public class HighFormworkPlaneFigure implements Serializable {
@Excel(name = "图片url", width = 15)
@ApiModelProperty(value="图片url")
private String imageUrl ;
/**
* 企业ids（多个，分割）
*/
@ApiModelProperty(value = "企业ids（多个，分割）")
private String enterpriseIds;
@TableField(exist = false)
@ApiModelProperty(value = "企业名称（多个，分割）")
private java.lang.String enterpriseName;
@TableField(exist = false)
@ApiModelProperty(value="测点ID,多个逗号分隔")

2
src/main/java/com/zhgd/xmgl/modules/highformwork/mapper/HighFormworkMeasurePointMapper.java
View File

@ -2,6 +2,7 @@ package com.zhgd.xmgl.modules.highformwork.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.zhgd.annotation.DataScope;
import com.zhgd.jeecg.common.mybatis.EntityMap;
import com.zhgd.xmgl.modules.highformwork.entity.HighFormworkMeasurePoint;
import com.zhgd.xmgl.modules.highformwork.entity.HighFormworkMeasurePointQo;
@ -20,6 +21,7 @@ import java.util.Map;
* @version： V1.0
*/
@Mapper
@DataScope(includeTable = "high_formwork_measure_point")
public interface HighFormworkMeasurePointMapper extends BaseMapper<HighFormworkMeasurePoint> {
List<EntityMap> selectHighFormworkMeasurePointPage(Page<EntityMap> page, @Param("param") Map<String, Object> map);

8
src/main/java/com/zhgd/xmgl/modules/highformwork/mapper/HighFormworkPlaneFigureMapper.java
View File

@ -1,8 +1,14 @@
package com.zhgd.xmgl.modules.highformwork.mapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.core.toolkit.Constants;
import com.zhgd.annotation.DataScope;
import com.zhgd.xmgl.modules.highformwork.entity.HighFormworkPlaneFigure;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import java.util.List;
/**
* @Description: 高支模-平面图配置
@ -11,6 +17,8 @@ import org.apache.ibatis.annotations.Mapper;
* @version： V1.0
*/
@Mapper
@DataScope(includeTable = "high_formwork_plane_figure")
public interface HighFormworkPlaneFigureMapper extends BaseMapper<HighFormworkPlaneFigure> {
List<HighFormworkPlaneFigure> queryList(@Param(Constants.WRAPPER) QueryWrapper<HighFormworkPlaneFigure> queryWrapper);
}

4
src/main/java/com/zhgd/xmgl/modules/highformwork/mapper/xml/HighFormworkMeasurePointMapper.xml
View File

@ -10,12 +10,14 @@
</resultMap>
<select id="selectHighFormworkMeasurePointPage" resultType="com.zhgd.jeecg.common.mybatis.EntityMap">
SELECT a.* ,(case when round((UNIX_TIMESTAMP(now())-UNIX_TIMESTAMP(real_time))/60) &lt;=10 then 1 else 2 end)
is_closed
is_closed,group_concat(distinct ei.enterprise_name) as enterprise_name
from high_formwork_measure_point a
left join enterprise_info ei on find_in_set(ei.id,a.enterprise_ids)
WHERE a.project_sn=#{param.projectSn}
<if test="param.alarmState!=null and param.alarmState!=''">
and a.alarm_state=#{param.alarmState}
</if>
group by a.id
</select>
<select id="selectPointList" resultType="com.zhgd.jeecg.common.mybatis.EntityMap">
SELECT a.*,

6
src/main/java/com/zhgd/xmgl/modules/highformwork/mapper/xml/HighFormworkPlaneFigureMapper.xml
View File

@ -2,4 +2,10 @@
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.zhgd.xmgl.modules.highformwork.mapper.HighFormworkPlaneFigureMapper">
<select id="queryList" resultType="com.zhgd.xmgl.modules.highformwork.entity.HighFormworkPlaneFigure">
select t.*,group_concat(distinct ei.enterprise_name) as enterprise_name
from high_formwork_plane_figure t
left join enterprise_info ei on find_in_set(ei.id,t.enterprise_ids)
${ew.customSqlSegment}
</select>
</mapper>

5
src/main/java/com/zhgd/xmgl/modules/highformwork/service/IHighFormworkPlaneFigureService.java
View File

@ -1,8 +1,11 @@
package com.zhgd.xmgl.modules.highformwork.service;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.IService;
import com.zhgd.xmgl.modules.highformwork.entity.HighFormworkPlaneFigure;
import java.util.List;
/**
* @Description: 高支模-平面图配置
* @author： pds
@ -16,4 +19,6 @@ public interface IHighFormworkPlaneFigureService extends IService<HighFormworkPl
void editHighFormworkPlaneFigure(HighFormworkPlaneFigure highFormworkPlaneFigure);
void deleteHighFormworkPlaneFigure(String id);
List<HighFormworkPlaneFigure> queryList(QueryWrapper<HighFormworkPlaneFigure> queryWrapper);
}

5
src/main/java/com/zhgd/xmgl/modules/highformwork/service/impl/HighFormworkPlaneFigureServiceImpl.java
View File

@ -91,4 +91,9 @@ public class HighFormworkPlaneFigureServiceImpl extends ServiceImpl<HighFormwork
queryWrapper.lambda().eq(HighFormworkPlaneFigureCoordinate::getPlaneFigureId,id);
highFormworkPlaneFigureCoordinateMapper.delete(queryWrapper);
}
@Override
public List<HighFormworkPlaneFigure> queryList(QueryWrapper<HighFormworkPlaneFigure> queryWrapper) {
return baseMapper.queryList(queryWrapper);
}
}

2
src/main/java/com/zhgd/xmgl/modules/poisonous/mapper/PoisonousGasDevMapper.java
View File

@ -5,6 +5,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Constants;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.zhgd.annotation.DataScope;
import com.zhgd.xmgl.modules.poisonous.entity.PoisonousGasDev;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
@ -16,6 +17,7 @@ import org.apache.ibatis.annotations.Param;
* @version： V1.0
*/
@Mapper
@DataScope(includeTable = "poisonous_gas_dev")
public interface PoisonousGasDevMapper extends BaseMapper<PoisonousGasDev> {
IPage<PoisonousGasDev> queryPageList(Page<PoisonousGasDev> page, @Param(Constants.WRAPPER) QueryWrapper<PoisonousGasDev> queryWrapper);

6
src/main/java/com/zhgd/xmgl/modules/poisonous/mapper/xml/PoisonousGasDevMapper.xml
View File

@ -4,9 +4,11 @@
<select id="queryPageList" resultType="com.zhgd.xmgl.modules.poisonous.entity.PoisonousGasDev">
select pgd.*,
ti.team_name dutyTeamInfoName,
1 online
1 online,
group_concat(distinct ei.enterprise_name) as enterprise_name
from poisonous_gas_dev pgd
join team_info ti on ti.id = pgd.duty_team_info_id
left join team_info ti on ti.id = pgd.duty_team_info_id
left join enterprise_info ei on find_in_set(ei.id,pgd.enterprise_ids)
${ew.customSqlSegment}
</select>
</mapper>

4
src/main/java/com/zhgd/xmgl/modules/poisonous/service/impl/PoisonousGasDevServiceImpl.java
View File

@ -29,8 +29,10 @@ public class PoisonousGasDevServiceImpl extends ServiceImpl<PoisonousGasDevMappe
@Override
public IPage<PoisonousGasDev> queryPageList(PoisonousGasDev poisonousGasDev, Integer pageNo, Integer pageSize, HttpServletRequest req) {
String alias = "pgd.";
QueryWrapper<PoisonousGasDev> queryWrapper = QueryGenerator.initQueryWrapper(poisonousGasDev, req.getParameterMap(), null,
RefUtil.fieldNames(PoisonousGasDev::getDevName), "pgd.");
RefUtil.fieldNames(PoisonousGasDev::getDevName), alias);
queryWrapper.groupBy(alias + "id");
queryWrapper.orderByDesc(RefUtil.fieldNameUlc(PoisonousGasDev::getCreateDate));
Page<PoisonousGasDev> page = new Page<PoisonousGasDev>(pageNo, pageSize);
return poisonousGasDevMapper.queryPageList(page, queryWrapper);

2
src/main/java/com/zhgd/xmgl/modules/safetyhat/mapper/SafetyHatDevMapper.java
View File

@ -4,6 +4,7 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Constants;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.zhgd.annotation.DataScope;
import com.zhgd.xmgl.modules.safetyhat.entity.SafetyHatDev;
import com.zhgd.xmgl.modules.vehicleposition.entity.vo.CountVehiclePositionDevVo;
import org.apache.ibatis.annotations.Mapper;
@ -20,6 +21,7 @@ import java.util.List;
* @version： V1.0
*/
@Mapper
@DataScope(includeTable = "safety_hat_dev")
public interface SafetyHatDevMapper extends BaseMapper<SafetyHatDev> {
/**
* 分页列表查询智能安全帽-设备信息

3
src/main/java/com/zhgd/xmgl/modules/safetyhat/mapper/xml/SafetyHatDevMapper.xml
View File

@ -2,9 +2,10 @@
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.zhgd.xmgl.modules.safetyhat.mapper.SafetyHatDevMapper">
<select id="queryList" resultType="com.zhgd.xmgl.modules.safetyhat.entity.SafetyHatDev">
select shd.*,wi.worker_name
select shd.*,wi.worker_name,group_concat(distinct ei.enterprise_name) as enterprise_name
from safety_hat_dev shd
left join worker_info wi on wi.id = shd.worker_info_id
left join enterprise_info ei on find_in_set(ei.id,shd.enterprise_ids)
${ew.customSqlSegment}
</select>

2
src/main/java/com/zhgd/xmgl/modules/safetyhat/service/impl/SafetyHatDevServiceImpl.java
View File

@ -10,6 +10,7 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.zhgd.jeecg.common.execption.OpenAlertException;
import com.zhgd.jeecg.common.execption.OpenPromptException;
import com.zhgd.jeecg.common.system.query.QueryGenerator;
import com.zhgd.xmgl.modules.car.entity.CarCamera;
import com.zhgd.xmgl.modules.safetyhat.entity.SafetyHatAlarm;
import com.zhgd.xmgl.modules.safetyhat.entity.SafetyHatData;
import com.zhgd.xmgl.modules.safetyhat.entity.SafetyHatDev;
@ -76,6 +77,7 @@ public class SafetyHatDevServiceImpl extends ServiceImpl<SafetyHatDevMapper, Saf
String alias = "shd.";
QueryWrapper<SafetyHatDev> queryWrapper = QueryGenerator.initPageQueryWrapper(SafetyHatDev.class, paramMap, alias);
queryWrapper.orderByDesc(alias + RefUtil.fieldNameUlc(SafetyHatDev::getId));
queryWrapper.groupBy(alias + RefUtil.fieldNameUlc(SafetyHatDev::getId));
return queryWrapper;
}

4
src/main/java/com/zhgd/xmgl/modules/video/controller/AiAnalyseHardWareRecordController.java
View File

@ -35,11 +35,11 @@ public class AiAnalyseHardWareRecordController {
private IAiAnalyseHardWareRecordService aiAnalyseHardWareRecordService;
/**
* 分页列表查询
* 列表查询
*
* @return
*/
@ApiOperation(value = "分页列表查询AI分析硬件设备信息", notes = "分页列表查询AI分析硬件设备信息", httpMethod = "POST")
@ApiOperation(value = "列表查询AI分析硬件设备信息", notes = "列表查询AI分析硬件设备信息", httpMethod = "POST")
@ApiImplicitParams({
@ApiImplicitParam(name = "projectSn", value = "项目sn", paramType = "body", required = true, dataType = "String"),
})

12
src/main/java/com/zhgd/xmgl/modules/video/entity/AiAnalyseHardWareRecord.java
View File

@ -1,6 +1,7 @@
package com.zhgd.xmgl.modules.video.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.databind.annotation.JsonSerialize;
@ -62,4 +63,15 @@ public class AiAnalyseHardWareRecord implements Serializable {
@Excel(name = "设备状态，1在线，2离线", width = 15)
@ApiModelProperty(value = "设备状态，1在线，2离线")
private java.lang.Integer deviceState;
/**
* 企业ids（多个，分割）
*/
@ApiModelProperty(value = "企业ids（多个，分割）")
private String enterpriseIds;
@TableField(exist = false)
@ApiModelProperty(value = "企业名称（多个，分割）")
private java.lang.String enterpriseName;
}

10
src/main/java/com/zhgd/xmgl/modules/video/entity/VideoItem.java
View File

@ -139,6 +139,12 @@ public class VideoItem implements Serializable {
private String longitude;
@ApiModelProperty(value = "父级的对象")
private String parentObj;
/**
* 企业id（多个，分割）
*/
@ApiModelProperty(value = "企业id（多个，分割）")
private String enterpriseIds;
/**
* 项目sn
*/
@ -197,4 +203,8 @@ public class VideoItem implements Serializable {
@ApiModelProperty(value = "视频配置")
private ProjectVideoConfig projectVideoConfig;
@TableField(exist = false)
@ApiModelProperty(value = "企业名称（多个，分割）")
private java.lang.String enterpriseName;
}

13
src/main/java/com/zhgd/xmgl/modules/video/mapper/AiAnalyseHardWareRecordMapper.java
View File

@ -1,9 +1,14 @@
package com.zhgd.xmgl.modules.video.mapper;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.core.toolkit.Constants;
import com.zhgd.annotation.DataScope;
import com.zhgd.xmgl.modules.hangbasket.entity.HangBasketDetectData;
import com.zhgd.xmgl.modules.video.entity.AiAnalyseHardWareRecord;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import java.util.List;
@ -14,6 +19,7 @@ import java.util.List;
* @version： V1.0
*/
@Mapper
@DataScope(includeTable = "ai_analyse_hard_ware_record")
public interface AiAnalyseHardWareRecordMapper extends BaseMapper<AiAnalyseHardWareRecord> {
/**
* 根据用户id查询AI分析硬件设备id列表
@ -54,4 +60,11 @@ public interface AiAnalyseHardWareRecordMapper extends BaseMapper<AiAnalyseHardW
* @return
*/
List<JSONObject> getEnterpriseIdAndAiAnalyseHardIdsByProjectSn(String projectSn);
/**
* 列表查询AI分析硬件设备信息
* @param queryWrapper
* @return
*/
List<AiAnalyseHardWareRecord> queryList(@Param(Constants.WRAPPER) QueryWrapper<HangBasketDetectData> queryWrapper);
}

7
src/main/java/com/zhgd/xmgl/modules/video/mapper/xml/AiAnalyseHardWareRecordMapper.xml
View File

@ -47,4 +47,11 @@
join ai_analyse_hard_ware_record aahwr on aahwr.id = qrtaah.ai_analyse_hard_ware_record_id
where aahwr.project_sn = #{projectSn}
</select>
<select id="queryList" resultType="com.zhgd.xmgl.modules.video.entity.AiAnalyseHardWareRecord">
select t.*,group_concat(distinct ei.enterprise_name) as enterprise_name
from ai_analyse_hard_ware_record t
left join enterprise_info ei on find_in_set(ei.id,t.enterprise_ids)
${ew.customSqlSegment}
</select>
</mapper>

4
src/main/java/com/zhgd/xmgl/modules/video/mapper/xml/VideoItemMapper.xml
View File

@ -18,9 +18,10 @@
</resultMap>
<select id="selectVideoItemListByVideoId" resultType="com.zhgd.jeecg.common.mybatis.EntityMap">
SELECT vi.*, vn.nvr_sn nvr_sn
SELECT vi.*, vn.nvr_sn nvr_sn,group_concat(distinct ei.enterprise_name) as enterprise_name
from video_item vi
left join video_nvr vn on vi.nvr_id = vn.id
left join enterprise_info ei on find_in_set(ei.id,vi.enterprise_ids)
WHERE vi.video_id = #{videoId}
<if test="groupId != null and groupId != ''">
and vi.group_id = #{groupId}
@ -31,6 +32,7 @@
#{item}
</foreach>
</if>
group by vi.item_id
order by vi.sort_num
</select>
<select id="selectAllDevCount" resultType="java.util.Map">

11
src/main/java/com/zhgd/xmgl/modules/video/service/impl/AiAnalyseHardWareRecordServiceImpl.java
View File

@ -5,14 +5,16 @@ import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.zhgd.jeecg.common.execption.OpenAlertException;
import com.zhgd.jeecg.common.system.query.QueryGenerator;
import com.zhgd.xmgl.modules.basicdata.enums.SystemUserAccountTypeEnum;
import com.zhgd.xmgl.modules.hangbasket.entity.HangBasketDetectData;
import com.zhgd.xmgl.modules.video.entity.AiAnalyseHardWareRecord;
import com.zhgd.xmgl.modules.video.mapper.AiAnalyseHardWareRecordMapper;
import com.zhgd.xmgl.modules.video.service.IAiAnalyseHardWareRecordService;
import com.zhgd.xmgl.security.entity.UserInfo;
import com.zhgd.xmgl.security.util.SecurityUtils;
import com.zhgd.xmgl.util.MessageUtil;
import org.apache.commons.collections.MapUtils;
import com.zhgd.xmgl.util.RefUtil;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
@ -35,9 +37,10 @@ public class AiAnalyseHardWareRecordServiceImpl extends ServiceImpl<AiAnalyseHar
@Override
public List<AiAnalyseHardWareRecord> getAiAnalyseHardWareRecordList(Map<String, Object> map) {
QueryWrapper<AiAnalyseHardWareRecord> qw = new QueryWrapper<>();
qw.lambda().eq(AiAnalyseHardWareRecord::getProjectSn, MapUtils.getString(map, "projectSn"));
return aiAnalyseHardWareRecordMapper.selectList(qw);
QueryWrapper<HangBasketDetectData> queryWrapper = QueryGenerator.initPageQueryWrapper(HangBasketDetectData.class, map);
queryWrapper.groupBy("t.id");
queryWrapper.orderByDesc("t." + RefUtil.fieldNameUlc(HangBasketDetectData::getId));
return aiAnalyseHardWareRecordMapper.queryList(queryWrapper);
}
@Override

2
src/main/java/com/zhgd/xmgl/modules/worker/mapper/UfaceDevMapper.java
View File

@ -3,6 +3,7 @@ package com.zhgd.xmgl.modules.worker.mapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.core.toolkit.Constants;
import com.zhgd.annotation.DataScope;
import com.zhgd.jeecg.common.mybatis.EntityMap;
import com.zhgd.xmgl.modules.worker.entity.UfaceDev;
import org.apache.ibatis.annotations.Mapper;
@ -21,6 +22,7 @@ import java.util.Map;
*/
@Mapper
@Repository
@DataScope(includeTable = "uface_dev")
public interface UfaceDevMapper extends BaseMapper<UfaceDev> {
/**
* 统计人脸设备数量

4
src/main/java/com/zhgd/xmgl/modules/worker/mapper/xml/UfaceDevMapper.xml
View File

@ -122,8 +122,10 @@
(case
when round((UNIX_TIMESTAMP(now()) - UNIX_TIMESTAMP(ud.heart_beat_time)) / 60) &lt;= 30 then 1
else 0 end)
dev_online
dev_online,
group_concat(distinct ei.enterprise_name) as enterprise_name
from uface_dev ud
left join enterprise_info ei on find_in_set(ei.id,ud.enterprise_ids)
${ew.customSqlSegment}
</select>

1
src/main/java/com/zhgd/xmgl/modules/worker/service/impl/UfaceDevServiceImpl.java
View File

@ -71,6 +71,7 @@ public class UfaceDevServiceImpl extends ServiceImpl<UfaceDevMapper, UfaceDev> i
QueryWrapper<UfaceDev> qw = new QueryWrapper<>();
String ufaceDevGroupId = MapUtils.getString(map, "ufaceDevGroupId");
qw.eq(alias + RefUtil.fieldNameUlc(UfaceDev::getProjectSn), MapUtils.getString(map, "projectSn"));
qw.groupBy(alias + "id");
UserInfo user = SecurityUtils.getUser();
if (Objects.equals(user.getAccountType(), SystemUserAccountTypeEnum.PROJECT_SUB_ACCOUNT.getValue())) {
//项目子账号就筛选自己能看到的