Commit 845352cf authored by taabe's avatar taabe

优化关联设备指标添加编辑页面

parent e8fa7dd2
...@@ -24,6 +24,9 @@ public class FmeaEquipmentPoint extends BasicEntity { ...@@ -24,6 +24,9 @@ public class FmeaEquipmentPoint extends BasicEntity {
@Column(name = "state") @Column(name = "state")
private Integer state; private Integer state;
@Column(name = "important_equipment_id")
private Long importantEquipmentId;
public Long getEquipmentPointId() { public Long getEquipmentPointId() {
return equipmentPointId; return equipmentPointId;
} }
...@@ -47,4 +50,12 @@ public class FmeaEquipmentPoint extends BasicEntity { ...@@ -47,4 +50,12 @@ public class FmeaEquipmentPoint extends BasicEntity {
public void setState(Integer state) { public void setState(Integer state) {
this.state = state; this.state = state;
} }
public Long getImportantEquipmentId() {
return importantEquipmentId;
}
public void setImportantEquipmentId(Long importantEquipmentId) {
this.importantEquipmentId = importantEquipmentId;
}
} }
\ No newline at end of file
...@@ -535,9 +535,10 @@ public class RiskSourceController extends BaseController { ...@@ -535,9 +535,10 @@ public class RiskSourceController extends BaseController {
@ApiOperation(value = "查询设备指标", notes = "查询设备指标") @ApiOperation(value = "查询设备指标", notes = "查询设备指标")
@GetMapping(value = "/listEquipmentPointById") @GetMapping(value = "/listEquipmentPointById")
public CommonResponse listEquipmentPointById(@RequestParam Long fmeaId, public CommonResponse listEquipmentPointById(@RequestParam Long fmeaId,
@RequestParam Long importantEquipId,
@RequestParam Long equimentId, @RequestParam Long equimentId,
@RequestParam(required = false) String equipmentPointName) { @RequestParam(required = false) String equipmentPointName) {
return CommonResponseUtil.success(riskSourceService.listEquipmentPointById(fmeaId, equimentId, equipmentPointName)); return CommonResponseUtil.success(riskSourceService.listEquipmentPointById(fmeaId, importantEquipId, equimentId, equipmentPointName));
} }
@Authorization(ingore = true) @Authorization(ingore = true)
......
...@@ -8,7 +8,7 @@ import java.util.Map; ...@@ -8,7 +8,7 @@ import java.util.Map;
public interface FmeaEquipmentPointMapper extends BaseMapper { public interface FmeaEquipmentPointMapper extends BaseMapper {
void deleteByFmeaIdAndEquipmentPointIds(@Param("fmeaId") Long fmeaId, @Param("equipmentPointIds") List<Long> equipmentPointIds); void deleteByFmeaIdAndEquipmentPointIds(@Param("fmeaId") Long fmeaId, @Param("importantEquipId") Long importantEquipId, @Param("equipmentPointIds") List<Long> equipmentPointIds);
void deleteByFmeaIds(Long[] fmeaIds); void deleteByFmeaIds(Long[] fmeaIds);
...@@ -22,7 +22,7 @@ public interface FmeaEquipmentPointMapper extends BaseMapper { ...@@ -22,7 +22,7 @@ public interface FmeaEquipmentPointMapper extends BaseMapper {
List<Long> listEquipmentPointIdsByEquipmentId(Long equipmentId); List<Long> listEquipmentPointIdsByEquipmentId(Long equipmentId);
List<Map<String, Object>> listEquipmentPoint(@Param("fmeaId") Long fmeaId, @Param("equipmentId") Long equipmentId, @Param("equipmentPointName") String equipmentPointName); List<Map<String, Object>> listEquipmentPoint(@Param("fmeaId") Long fmeaId, @Param("importantEquipId") Long importantEquipId, @Param("equipmentId") Long equipmentId, @Param("equipmentPointName") String equipmentPointName);
List<FmeaEquipmentPoint> listByEquipmentPointId(Long equipmentPointId); List<FmeaEquipmentPoint> listByEquipmentPointId(Long equipmentPointId);
......
...@@ -11,8 +11,9 @@ public interface ImpEquipMapper extends BaseMapper { ...@@ -11,8 +11,9 @@ public interface ImpEquipMapper extends BaseMapper {
String queryProtectObjNames(@Param("fireEquipmentId") Long fireEquipmentId); String queryProtectObjNames(@Param("fireEquipmentId") Long fireEquipmentId);
List<Map> getEquipPage(@Param("name") String name, List<Map> getEquipPage(@Param("name") String name,
@Param("id") String id,
@Param("offset") Integer offset, @Param("offset") Integer offset,
@Param("pageSize") Integer pageSize); @Param("pageSize") Integer pageSize);
Long getEquipPageCount(@Param("name") String name); Long getEquipPageCount(@Param("name") String name, @Param("id") String id);
} }
...@@ -14,6 +14,8 @@ public class FmeaBindParam { ...@@ -14,6 +14,8 @@ public class FmeaBindParam {
private List<Long> pointInputitemIds; private List<Long> pointInputitemIds;
private Long importantEquipmentId;
public Long getFmeaId() { public Long getFmeaId() {
return fmeaId; return fmeaId;
} }
...@@ -53,4 +55,12 @@ public class FmeaBindParam { ...@@ -53,4 +55,12 @@ public class FmeaBindParam {
public void setEquipmentId(Long equipmentId) { public void setEquipmentId(Long equipmentId) {
this.equipmentId = equipmentId; this.equipmentId = equipmentId;
} }
public Long getImportantEquipmentId() {
return importantEquipmentId;
}
public void setImportantEquipmentId(Long importantEquipmentId) {
this.importantEquipmentId = importantEquipmentId;
}
} }
...@@ -138,13 +138,17 @@ public class EquipmentServiceImpl implements IEquipmentService { ...@@ -138,13 +138,17 @@ public class EquipmentServiceImpl implements IEquipmentService {
@Override @Override
public Page<Equipment> queryImpEquip(List<DaoCriteria> criterias, CommonPageable commonPageable) { public Page<Equipment> queryImpEquip(List<DaoCriteria> criterias, CommonPageable commonPageable) {
String name = ""; String name = "";
String id = "";
for (DaoCriteria criteria : criterias) { for (DaoCriteria criteria : criterias) {
if (criteria.getPropertyName().equals("name")) { if (criteria.getPropertyName().equals("name")) {
name = String.valueOf(criteria.getValue() != null ? criteria.getValue().toString() : ""); name = String.valueOf(criteria.getValue() != null ? criteria.getValue().toString() : "");
} }
if (criteria.getPropertyName().equals("id")) {
id = String.valueOf(criteria.getValue() != null ? criteria.getValue().toString() : "");
}
} }
Long total = impEquipMapper.getEquipPageCount(name); Long total = impEquipMapper.getEquipPageCount(name, id);
List<Map> content = impEquipMapper.getEquipPage(name, commonPageable.getOffset(), List<Map> content = impEquipMapper.getEquipPage(name, id, commonPageable.getOffset(),
commonPageable.getPageSize()); commonPageable.getPageSize());
Page result = new PageImpl(content, commonPageable, total); Page result = new PageImpl(content, commonPageable, total);
return result; return result;
......
...@@ -403,14 +403,16 @@ public class RiskSourceServiceImpl implements IRiskSourceService { ...@@ -403,14 +403,16 @@ public class RiskSourceServiceImpl implements IRiskSourceService {
@Override @Override
public List<FmeaEquipmentPoint> bindFireEquiment(FmeaBindParam fmeaBindParam) { public List<FmeaEquipmentPoint> bindFireEquiment(FmeaBindParam fmeaBindParam) {
Long fmeaId = fmeaBindParam.getFmeaId(); Long fmeaId = fmeaBindParam.getFmeaId();
Long importantEquipId = fmeaBindParam.getImportantEquipmentId();
List<Long> equipmentPointIds = fmeaEquipmentPointMapper.listEquipmentPointIdsByEquipmentId(fmeaBindParam.getEquipmentId()); List<Long> equipmentPointIds = fmeaEquipmentPointMapper.listEquipmentPointIdsByEquipmentId(fmeaBindParam.getEquipmentId());
if (!CollectionUtils.isEmpty(equipmentPointIds)) { if (!CollectionUtils.isEmpty(equipmentPointIds)) {
fmeaEquipmentPointMapper.deleteByFmeaIdAndEquipmentPointIds(fmeaId, equipmentPointIds); fmeaEquipmentPointMapper.deleteByFmeaIdAndEquipmentPointIds(fmeaId, importantEquipId, equipmentPointIds);
} }
List<FmeaEquipmentPoint> returnList = new ArrayList<>(); List<FmeaEquipmentPoint> returnList = new ArrayList<>();
for (Long equipmentPointId : fmeaBindParam.getEquipmentPointIds()) { for (Long equipmentPointId : fmeaBindParam.getEquipmentPointIds()) {
FmeaEquipmentPoint fmeaEquipmentPoint = new FmeaEquipmentPoint(); FmeaEquipmentPoint fmeaEquipmentPoint = new FmeaEquipmentPoint();
fmeaEquipmentPoint.setFmeaId(fmeaId); fmeaEquipmentPoint.setFmeaId(fmeaId);
fmeaEquipmentPoint.setImportantEquipmentId(importantEquipId);
fmeaEquipmentPoint.setEquipmentPointId(equipmentPointId); fmeaEquipmentPoint.setEquipmentPointId(equipmentPointId);
returnList.add(fmeaEquipmentPoint); returnList.add(fmeaEquipmentPoint);
} }
...@@ -459,8 +461,8 @@ public class RiskSourceServiceImpl implements IRiskSourceService { ...@@ -459,8 +461,8 @@ public class RiskSourceServiceImpl implements IRiskSourceService {
return new PageImpl<>(list, commonPageable, total); return new PageImpl<>(list, commonPageable, total);
} }
public List<Map<String, Object>> listEquipmentPointById(Long fmeaId, Long equipmentId, String equipmentPointName) { public List<Map<String, Object>> listEquipmentPointById(Long fmeaId, Long importantEquipId, Long equipmentId, String equipmentPointName) {
List<Map<String, Object>> list = fmeaEquipmentPointMapper.listEquipmentPoint(fmeaId, equipmentId, equipmentPointName); List<Map<String, Object>> list = fmeaEquipmentPointMapper.listEquipmentPoint(fmeaId, importantEquipId, equipmentId, equipmentPointName);
if (CollectionUtils.isEmpty(list)) { if (CollectionUtils.isEmpty(list)) {
return Lists.newArrayList(); return Lists.newArrayList();
} }
......
...@@ -59,7 +59,7 @@ public interface IRiskSourceService { ...@@ -59,7 +59,7 @@ public interface IRiskSourceService {
*/ */
Page queryEquimentRelation(CommonPageable commonPageable, String equipmentId, String fname); Page queryEquimentRelation(CommonPageable commonPageable, String equipmentId, String fname);
List<Map<String, Object>> listEquipmentPointById(Long fmeaId, Long equipmentId, String equipmentPointName); List<Map<String, Object>> listEquipmentPointById(Long fmeaId, Long importantEquipId, Long equipmentId, String equipmentPointName);
Page<Map<String, Object>> listFmeaPointInputitem(Long fmeaId, Integer pageNumber, Integer pageSize); Page<Map<String, Object>> listFmeaPointInputitem(Long fmeaId, Integer pageNumber, Integer pageSize);
......
...@@ -186,4 +186,16 @@ ...@@ -186,4 +186,16 @@
</sql> </sql>
</changeSet> </changeSet>
<changeSet author="tianbo" id="1583068193000-1">
<preConditions onFail="MARK_RAN">
<not>
<columnExists tableName="f_fmea_equipment_point" columnName="important_equipment_id"/>
</not>
</preConditions>
<comment>f_fmea_equipment_point add column important_equipment_id</comment>
<sql>
ALTER TABLE `f_fmea_equipment_point` ADD COLUMN `important_equipment_id` bigint(20) NOT NULL COMMENT '所属重点设备id';
</sql>
</changeSet>
</databaseChangeLog> </databaseChangeLog>
\ No newline at end of file
...@@ -8,6 +8,7 @@ ...@@ -8,6 +8,7 @@
f_fmea_equipment_point f_fmea_equipment_point
where where
fmea_id = #{fmeaId} fmea_id = #{fmeaId}
and important_equipment_id = #{importantEquipId}
and and
equipment_point_id in equipment_point_id in
<foreach collection="equipmentPointIds" item="item" index="index" separator="," open="(" close=")"> <foreach collection="equipmentPointIds" item="item" index="index" separator="," open="(" close=")">
...@@ -28,12 +29,14 @@ ...@@ -28,12 +29,14 @@
insert into f_fmea_equipment_point insert into f_fmea_equipment_point
( (
fmea_id, fmea_id,
important_equipment_id,
equipment_point_id equipment_point_id
) )
values values
<foreach collection="list" item="item" index="index" separator=","> <foreach collection="list" item="item" index="index" separator=",">
( (
#{item.fmeaId}, #{item.fmeaId},
#{item.importantEquipmentId},
#{item.equipmentPointId} #{item.equipmentPointId}
) )
</foreach> </foreach>
...@@ -62,18 +65,21 @@ ...@@ -62,18 +65,21 @@
select select
c.fmea_id as fmeaId, c.fmea_id as fmeaId,
a.id as equipmentId, a.id as equipmentId,
group_concat(b.name) as equipmentPointNames, group_concat(concat( b.NAME, '##', c.state ) SEPARATOR <![CDATA[ '\n' ]]> ) as equipmentPointNames,
a.name as equipmentName, a.name as equipmentName,
a.code as equipmentCode a.code as equipmentCode,
d.name AS importantEquipName,
d.id AS importantEquipId
from from
f_fire_equipment as a f_fire_equipment as a
left join left join
f_fire_equipment_point as b on b.fire_equipment_id = a.id f_fire_equipment_point as b on b.fire_equipment_id = a.id
left join left join
f_fmea_equipment_point as c on c.equipment_point_id = b.id f_fmea_equipment_point as c on c.equipment_point_id = b.id
LEFT JOIN f_equipment AS d ON d.id = c.important_equipment_id
where where
c.fmea_id = #{fmeaId} c.fmea_id = #{fmeaId}
group by b.fire_equipment_id group by b.fire_equipment_id,c.important_equipment_id
limit #{offset},#{limit} limit #{offset},#{limit}
</select> </select>
...@@ -113,6 +119,8 @@ ...@@ -113,6 +119,8 @@
d.equipment_point_id = a.id d.equipment_point_id = a.id
and and
d.fmea_id = #{fmeaId} d.fmea_id = #{fmeaId}
and
d.important_equipment_id = #{importantEquipId}
) isBound ) isBound
from from
f_fire_equipment_point as a f_fire_equipment_point as a
......
...@@ -37,9 +37,10 @@ ...@@ -37,9 +37,10 @@
FROM FROM
f_equipment eq f_equipment eq
left join f_risk_source frs on frs.id = eq.risk_source_id left join f_risk_source frs on frs.id = eq.risk_source_id
<trim prefix="WHERE" prefixOverrides="AND "> <trim prefix="WHERE" prefixOverrides="AND ">
<if test="name!=null"> and (eq.name like concat(concat("%",#{name}),"%") or eq.code like concat(concat("%",#{name}),"%"))</if> <if test="name !=null and name != ''"> and (eq.name like concat(concat("%",#{name}),"%") or eq.code like concat(concat("%",#{name}),"%"))</if>
</trim> <if test="id != null and id != ''"> and eq.id = #{id}</if>
</trim>
order by eq.id order by eq.id
<choose> <choose>
<when test="pageSize==-1"></when> <when test="pageSize==-1"></when>
...@@ -53,7 +54,8 @@ ...@@ -53,7 +54,8 @@
FROM FROM
f_equipment eq f_equipment eq
<trim prefix="WHERE" prefixOverrides="AND "> <trim prefix="WHERE" prefixOverrides="AND ">
<if test="name!=null"> and (eq.name like concat(concat("%",#{name}),"%") or eq.code like concat(concat("%",#{name}),"%"))</if> <if test="name !=null and name != ''"> and (eq.name like concat(concat("%",#{name}),"%") or eq.code like concat(concat("%",#{name}),"%"))</if>
<if test="id != null and id != ''"> and eq.id = #{id}</if>
</trim> </trim>
</select> </select>
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment