Commit b533e8e4 authored by chenhao's avatar chenhao

Merge branch 'developer' of http://172.16.10.76/moa/amos-boot-biz into developer

parents fae62f79 ba852dab
...@@ -20,7 +20,7 @@ public interface IMaintenanceCompanyService { ...@@ -20,7 +20,7 @@ public interface IMaintenanceCompanyService {
/** /**
* 添加保存维保公司基本信息 * 添加保存维保公司基本信息
* *
* @param MaintenanceCompany * @param maintenanceCompany
* @return * @return
*/ */
public boolean saveCompanyDetail(MaintenanceCompany maintenanceCompany); public boolean saveCompanyDetail(MaintenanceCompany maintenanceCompany);
...@@ -28,8 +28,8 @@ public interface IMaintenanceCompanyService { ...@@ -28,8 +28,8 @@ public interface IMaintenanceCompanyService {
/** /**
* 添加保存维保单位人员基本信息 * 添加保存维保单位人员基本信息
* *
* @param MaintenanceCompany * @param maintenanceCompany
* @param sequenceNbr主键 * @param sequenceNbr 主键
* @return * @return
*/ */
public boolean savePersonDetail(MaintenanceCompany maintenanceCompany, long sequenceNbr); public boolean savePersonDetail(MaintenanceCompany maintenanceCompany, long sequenceNbr);
...@@ -92,8 +92,9 @@ public interface IMaintenanceCompanyService { ...@@ -92,8 +92,9 @@ public interface IMaintenanceCompanyService {
* @param sequenceNbr 主键 * @param sequenceNbr 主键
* @return * @return
*/ */
Map<String, Object> findBySequenceNbr(Long sequenceNbr, String maintenanceType);
Map<String, Object> findBySequenceNbr(Long sequenceNbr);
/** /**
* 修改维保单位 * 修改维保单位
* *
......
...@@ -68,12 +68,15 @@ ...@@ -68,12 +68,15 @@
i.INSTANCE_ID instanceId, i.INSTANCE_ID instanceId,
i.GROUP_CODE groupCode, i.GROUP_CODE groupCode,
<foreach collection="fieldCodes" item="value" index="key" separator=","> <foreach collection="fieldCodes" item="value" index="key" separator=",">
MAX(CASE WHEN i.FIELD_CODE = #{key} THEN i.FIELD_VALUE END) as ${key} MAX(CASE WHEN i.FIELD_CODE = #{key} THEN i.FIELD_VALUE END) as ${key},
IF(FIND_IN_SET(i.field_type,'radio,select,treeSelect'), MAX(CASE WHEN i.FIELD_CODE = #{key} THEN
i.FIELD_VALUE_LABEL END), null) as ${key}Label
</foreach> </foreach>
from from
cb_dynamic_form_instance i cb_dynamic_form_instance i
where where
i.GROUP_CODE = #{groupCode} i.GROUP_CODE = #{groupCode}
and i.is_delete = 0
<if test="appKey != null and appKey !=''"> <if test="appKey != null and appKey !=''">
and i.APP_KEY = #{appKey} and i.APP_KEY = #{appKey}
</if> </if>
......
...@@ -7,12 +7,21 @@ public class KeyValueLabel { ...@@ -7,12 +7,21 @@ public class KeyValueLabel {
private String key; private String key;
private String label; private String label;
private Object value; private Object value;
private String unit;
public KeyValueLabel( String label,String key, Object value) { public KeyValueLabel( String label,String key, Object value) {
super(); super();
this.label = label; this.label = label;
this.key = key; this.key = key;
this.value = value; this.value = value;
} }
public KeyValueLabel(String label,String key, Object value, String unit) {
this.label = label;
this.key = key;
this.value = value;
this.unit = unit;
}
public KeyValueLabel() { public KeyValueLabel() {
super(); super();
} }
......
package com.yeejoin.amos.boot.module.jcs.api.dto;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
@Data
@ApiModel(value = "AircraftDto", description = "航空器信息")
public class PowerData {
@ApiModelProperty(value = "所属单位")
private String companyName;
@ApiModelProperty(value = "车辆名称")
private String carName;
@ApiModelProperty(value = "车牌号")
private String carNum;
@ApiModelProperty(value = "随车人员")
private String user;
}
package com.yeejoin.amos.boot.module.jcs.api.dto;
import lombok.Data;
@Data
public class StateDot {
private String name;
private boolean flag=false;
public StateDot(String name, boolean flag) {
this.name = name;
this.flag = flag;
}
public StateDot() {
super();
}
public StateDot(String name) {
this.name = name;
}
}
\ No newline at end of file
...@@ -9,6 +9,7 @@ import com.yeejoin.amos.boot.module.jcs.api.dto.AlertSubmittedSMSDto; ...@@ -9,6 +9,7 @@ import com.yeejoin.amos.boot.module.jcs.api.dto.AlertSubmittedSMSDto;
import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Param;
import java.util.List; import java.util.List;
import java.util.Map;
/** /**
* 警情报送记录 Mapper 接口 * 警情报送记录 Mapper 接口
...@@ -54,6 +55,6 @@ public interface AlertSubmittedMapper extends BaseMapper<AlertSubmitted> { ...@@ -54,6 +55,6 @@ public interface AlertSubmittedMapper extends BaseMapper<AlertSubmitted> {
List<AlertSubmittedZHDto> listAlertSubmittedZHDto(@Param("id") Long id); List<AlertSubmittedZHDto> listAlertSubmittedZHDto(@Param("id") Long id);
Map<String, Integer> getUseNum(@Param("id") Long id);
} }
package com.yeejoin.amos.boot.module.jcs.api.mapper; package com.yeejoin.amos.boot.module.jcs.api.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.yeejoin.amos.boot.module.jcs.api.dto.PowerData;
import com.yeejoin.amos.boot.module.jcs.api.dto.PowerTransferCompanyDto; import com.yeejoin.amos.boot.module.jcs.api.dto.PowerTransferCompanyDto;
import com.yeejoin.amos.boot.module.jcs.api.dto.PowerTransferCompanyResourcesDto; import com.yeejoin.amos.boot.module.jcs.api.dto.PowerTransferCompanyResourcesDto;
import com.yeejoin.amos.boot.module.jcs.api.dto.PowerTransferDto; import com.yeejoin.amos.boot.module.jcs.api.dto.PowerTransferDto;
...@@ -59,4 +60,10 @@ public interface PowerTransferMapper extends BaseMapper<PowerTransfer> { ...@@ -59,4 +60,10 @@ public interface PowerTransferMapper extends BaseMapper<PowerTransfer> {
Map<String, Object> getPowerTransferInfoCount(@Param("beginDate") String beginDate, Map<String, Object> getPowerTransferInfoCount(@Param("beginDate") String beginDate,
@Param("endDate") String endDate); @Param("endDate") String endDate);
Map<String, Integer> getCarNum(@Param("id") Long id);
Map<String, Integer> getCompanyNum(@Param("id") Long id);
List<PowerData> getPowerDataList(@Param("id") Long id);
} }
...@@ -3,6 +3,7 @@ package com.yeejoin.amos.boot.module.jcs.api.service; ...@@ -3,6 +3,7 @@ package com.yeejoin.amos.boot.module.jcs.api.service;
import com.yeejoin.amos.boot.module.common.api.dto.RequestData; import com.yeejoin.amos.boot.module.common.api.dto.RequestData;
import com.yeejoin.amos.boot.module.jcs.api.dto.AlertCalledZhDto; import com.yeejoin.amos.boot.module.jcs.api.dto.AlertCalledZhDto;
import com.yeejoin.amos.boot.module.jcs.api.dto.KeyValueLabel; import com.yeejoin.amos.boot.module.jcs.api.dto.KeyValueLabel;
import com.yeejoin.amos.boot.module.jcs.api.dto.PowerData;
import com.yeejoin.amos.boot.module.jcs.api.entity.AlertCalled; import com.yeejoin.amos.boot.module.jcs.api.entity.AlertCalled;
import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.PathVariable;
...@@ -38,5 +39,13 @@ public interface IAlertCalledService { ...@@ -38,5 +39,13 @@ public interface IAlertCalledService {
Object selectAlertCalledById( Long id); Object selectAlertCalledById( Long id);
Map<String,Object> selectAlertCalledKeyValueLabelById( Long id); Map<String,Object> selectAlertCalledKeyValueLabelById( Long id);
List<KeyValueLabel> selectAlertCalledcount( Long id);
List<KeyValueLabel> powercount( Long id);
List<PowerData> getPowerDataList(Long id);
AlertCalled getAlertCalledById(Long id);
} }
...@@ -6,8 +6,10 @@ import com.yeejoin.amos.boot.module.jcs.api.dto.InstructionsZHDto; ...@@ -6,8 +6,10 @@ import com.yeejoin.amos.boot.module.jcs.api.dto.InstructionsZHDto;
import com.yeejoin.amos.boot.module.jcs.api.entity.AlertSubmitted; import com.yeejoin.amos.boot.module.jcs.api.entity.AlertSubmitted;
import com.yeejoin.amos.boot.module.jcs.api.dto.AlertSubmittedSMSDto; import com.yeejoin.amos.boot.module.jcs.api.dto.AlertSubmittedSMSDto;
import com.yeejoin.amos.boot.module.jcs.api.dto.SchedulingReportingDto; import com.yeejoin.amos.boot.module.jcs.api.dto.SchedulingReportingDto;
import org.apache.ibatis.annotations.Param;
import java.util.List; import java.util.List;
import java.util.Map;
/** /**
* 警情报送记录 服务类 * 警情报送记录 服务类
...@@ -48,5 +50,4 @@ public interface IAlertSubmittedService extends IService<AlertSubmitted> { ...@@ -48,5 +50,4 @@ public interface IAlertSubmittedService extends IService<AlertSubmitted> {
List<InstructionsZHDto> getInstructionsZHDtoList(Long id); List<InstructionsZHDto> getInstructionsZHDtoList(Long id);
} }
...@@ -8,6 +8,7 @@ import com.yeejoin.amos.boot.module.jcs.api.entity.PowerTransfer; ...@@ -8,6 +8,7 @@ import com.yeejoin.amos.boot.module.jcs.api.entity.PowerTransfer;
import com.yeejoin.amos.boot.module.jcs.api.dto.PowerTransferSimpleDto; import com.yeejoin.amos.boot.module.jcs.api.dto.PowerTransferSimpleDto;
import java.util.List; import java.util.List;
import java.util.Map;
/** /**
* 力量调派 服务类 * 力量调派 服务类
...@@ -27,4 +28,5 @@ public interface IPowerTransferService extends IService<PowerTransfer> { ...@@ -27,4 +28,5 @@ public interface IPowerTransferService extends IService<PowerTransfer> {
* 获取力量调派资源树 * 获取力量调派资源树
*/ */
List<FireBrigadeResourceDto> getPowerTree(); List<FireBrigadeResourceDto> getPowerTree();
} }
...@@ -120,7 +120,15 @@ ...@@ -120,7 +120,15 @@
<select id="getUseNum" resultType="Map">
SELECT
COUNT( DISTINCT b.rec_user_id ) useNum
FROM
jc_alert_submitted a
LEFT JOIN jc_alert_submitted_object b ON a.sequence_nbr = b.alert_submitted_id
WHERE
a.alert_called_id = ${id}
</select>
......
...@@ -107,4 +107,53 @@ ...@@ -107,4 +107,53 @@
order by pt.rec_date asc order by pt.rec_date asc
</select> </select>
<select id="getCarNum" resultType="Map">
SELECT
COUNT( DISTINCT b.company_id ) companyNum,
COUNT( DISTINCT c.resources_num ) carNum
FROM
jc_power_transfer a
LEFT JOIN jc_power_transfer_company b ON a.sequence_nbr = b.power_transfer_id
LEFT JOIN jc_power_transfer_company_resources c ON c.power_transfer_company_id = b.sequence_nbr
WHERE
a.alert_called_id = ${id}
</select>
<select id="getCompanyNum" resultType="Map">
select COUNT(*) companyNum from
(SELECT DISTINCT
b.company_id
FROM
jc_power_transfer a
LEFT JOIN jc_power_transfer_company b ON a.sequence_nbr = b.power_transfer_id
LEFT JOIN jc_power_transfer_company_resources c ON c.power_transfer_company_id = b.sequence_nbr
WHERE
a.alert_called_id = ${id} UNION ALL
SELECT DISTINCT
b.company_id
FROM
jc_alert_submitted a
LEFT JOIN jc_alert_submitted_object b ON a.sequence_nbr = b.alert_submitted_id
WHERE
a.alert_called_id = ${id}) m
</select>
<select id="getPowerDataList" resultType="com.yeejoin.amos.boot.module.jcs.api.dto.PowerData">
SELECT DISTINCT
b.company_name companyName,
c.resources_name carName,
c.resources_num carNum
FROM
jc_power_transfer a
LEFT JOIN jc_power_transfer_company b ON a.sequence_nbr = b.power_transfer_id
LEFT JOIN jc_power_transfer_company_resources c ON c.power_transfer_company_id = b.sequence_nbr
WHERE
a.alert_called_id = ${id}
</select>
</mapper> </mapper>
...@@ -110,7 +110,7 @@ public class AlertSummaryController extends BaseController { ...@@ -110,7 +110,7 @@ public class AlertSummaryController extends BaseController {
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "GET",value = "列表全部数据查询", notes = "列表全部数据查询") @ApiOperation(httpMethod = "GET",value = "列表全部数据查询", notes = "列表全部数据查询")
@GetMapping(value = "/list") @GetMapping(value = "/list")
public ResponseModel<List<AlertSummaryDto>> selectForList() { public ResponseModel<List<AlertSummaryDto>> selectForList(@RequestParam(value = "alertCalledId")Long alertCalledId) {
return ResponseHelper.buildResponse(alertSummaryServiceImpl.queryForAlertSummaryList()); return ResponseHelper.buildResponse(alertSummaryServiceImpl.queryForAlertSummaryList(alertCalledId));
} }
} }
...@@ -10,6 +10,8 @@ import com.yeejoin.amos.boot.module.common.api.entity.FireTeam; ...@@ -10,6 +10,8 @@ import com.yeejoin.amos.boot.module.common.api.entity.FireTeam;
import com.yeejoin.amos.boot.module.common.api.service.*; import com.yeejoin.amos.boot.module.common.api.service.*;
import com.yeejoin.amos.boot.module.jcs.api.dto.AlertCalledZhDto; import com.yeejoin.amos.boot.module.jcs.api.dto.AlertCalledZhDto;
import com.yeejoin.amos.boot.module.jcs.api.dto.InstructionsZHDto; import com.yeejoin.amos.boot.module.jcs.api.dto.InstructionsZHDto;
import com.yeejoin.amos.boot.module.jcs.api.dto.StateDot;
import com.yeejoin.amos.boot.module.jcs.api.entity.AlertCalled;
import com.yeejoin.amos.boot.module.jcs.api.enums.AlertStageEnums; import com.yeejoin.amos.boot.module.jcs.api.enums.AlertStageEnums;
import com.yeejoin.amos.boot.module.jcs.api.service.IAlertCalledService; import com.yeejoin.amos.boot.module.jcs.api.service.IAlertCalledService;
import com.yeejoin.amos.boot.module.jcs.api.service.IAlertSubmittedService; import com.yeejoin.amos.boot.module.jcs.api.service.IAlertSubmittedService;
...@@ -24,6 +26,7 @@ import org.typroject.tyboot.core.restful.utils.ResponseHelper; ...@@ -24,6 +26,7 @@ import org.typroject.tyboot.core.restful.utils.ResponseHelper;
import org.typroject.tyboot.core.restful.utils.ResponseModel; import org.typroject.tyboot.core.restful.utils.ResponseModel;
import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletRequest;
import java.util.ArrayList;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
...@@ -458,7 +461,77 @@ public class CommandController extends BaseController { ...@@ -458,7 +461,77 @@ public class CommandController extends BaseController {
} }
/**
*
* 火灾现场统计
*
* **/
@TycloudOperation( needAuth = false, ApiLevel = UserType.AGENCY)
@GetMapping(value = "statistics/{id}")
@ApiOperation(httpMethod = "GET", value = "火灾现场统计", notes = "火灾现场统计")
public ResponseModel<Object> getStatistics(@PathVariable Long id) {
return ResponseHelper.buildResponse(iAlertCalledService.selectAlertCalledcount(id));
}
/**
* * @param null
* @return
* <PRE>
* author tw
* date 2021/7/22
* </PRE>
* 到场力量统计
*/
@TycloudOperation( needAuth = false, ApiLevel = UserType.AGENCY)
@GetMapping(value = "getpower/{id}")
@ApiOperation(httpMethod = "GET", value = "到场力量统计", notes = "到场力量统计")
public ResponseModel<Object> getpower(@PathVariable Long id) {
return ResponseHelper.buildResponse(iAlertCalledService.powercount(id));
}
/**
* * @param null
* @return
* <PRE>
* author tw
* date 2021/7/22
* </PRE>
* 到场力量统计列表
*/
@TycloudOperation( needAuth = false, ApiLevel = UserType.AGENCY)
@GetMapping(value = "getPowerDataList/{id}")
@ApiOperation(httpMethod = "GET", value = "到场力量统计列表", notes = "到场力量统计列表")
public ResponseModel<Object> getPowerDataList(@PathVariable Long id) {
return ResponseHelper.buildResponse(iAlertCalledService.getPowerDataList(id));
}
/**
*
* 当前灾情阶段
*
* */
@TycloudOperation( needAuth = false, ApiLevel = UserType.AGENCY)
@GetMapping(value = "getstate/{id}")
@ApiOperation(httpMethod = "GET", value = "获取灾情当前阶段", notes = "获取灾情当前阶段")
public ResponseModel<Object> getstate(@PathVariable Long id) {
AlertCalled AlertCalled=iAlertCalledService.getAlertCalledById(id);
List<StateDot> list=new ArrayList<>();
list.add(new StateDot("警情接报"));
list.add(new StateDot("力量调派"));
list.add(new StateDot("值班确警"));
list.add(new StateDot("处置跟踪"));
list.add(new StateDot("处置结束"));
list.stream().forEach(stateDot->{
if(AlertCalled.getAlertStage().equals(stateDot.getName())){
stateDot.setFlag(true);
}
});
return ResponseHelper.buildResponse(list);
}
} }
\ No newline at end of file
...@@ -95,11 +95,11 @@ public class FrontlineLiaisonController extends BaseController { ...@@ -95,11 +95,11 @@ public class FrontlineLiaisonController extends BaseController {
@GetMapping(value = "/page") @GetMapping(value = "/page")
@ApiOperation(httpMethod = "GET",value = "前线联络员分页查询", notes = "前线联络员分页查询") @ApiOperation(httpMethod = "GET",value = "前线联络员分页查询", notes = "前线联络员分页查询")
public ResponseModel<Page<FrontlineLiaisonDto>> queryForPage(@RequestParam(value = "current") int current,@RequestParam public ResponseModel<Page<FrontlineLiaisonDto>> queryForPage(@RequestParam(value = "current") int current,@RequestParam
(value = "size") int size) { (value = "size") int size,@RequestParam(value = "alertCalledId")Long alertCalledId) {
Page<FrontlineLiaisonDto> page = new Page<FrontlineLiaisonDto>(); Page<FrontlineLiaisonDto> page = new Page<FrontlineLiaisonDto>();
page.setCurrent(current); page.setCurrent(current);
page.setSize(size); page.setSize(size);
return ResponseHelper.buildResponse(frontlineLiaisonServiceImpl.queryForFrontlineLiaisonPage(page)); return ResponseHelper.buildResponse(frontlineLiaisonServiceImpl.queryForFrontlineLiaisonPage(page,alertCalledId));
} }
/** /**
......
...@@ -4,6 +4,8 @@ import com.yeejoin.amos.boot.module.command.api.entity.AlertSummary; ...@@ -4,6 +4,8 @@ import com.yeejoin.amos.boot.module.command.api.entity.AlertSummary;
import com.yeejoin.amos.boot.module.command.api.mapper.AlertSummaryMapper; import com.yeejoin.amos.boot.module.command.api.mapper.AlertSummaryMapper;
import com.yeejoin.amos.boot.module.command.api.service.IAlertSummaryService; import com.yeejoin.amos.boot.module.command.api.service.IAlertSummaryService;
import com.yeejoin.amos.boot.module.command.api.dto.AlertSummaryDto; import com.yeejoin.amos.boot.module.command.api.dto.AlertSummaryDto;
import org.typroject.tyboot.core.rdbms.annotation.Condition;
import org.typroject.tyboot.core.rdbms.annotation.Operator;
import org.typroject.tyboot.core.rdbms.service.BaseService; import org.typroject.tyboot.core.rdbms.service.BaseService;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
...@@ -27,7 +29,7 @@ public class AlertSummaryServiceImpl extends BaseService<AlertSummaryDto,AlertSu ...@@ -27,7 +29,7 @@ public class AlertSummaryServiceImpl extends BaseService<AlertSummaryDto,AlertSu
/** /**
* 列表查询 示例 * 列表查询 示例
*/ */
public List<AlertSummaryDto> queryForAlertSummaryList() { public List<AlertSummaryDto> queryForAlertSummaryList(@Condition(Operator.eq) Long alertCalledId) {
return this.queryForList("" , false); return this.queryForList("" , false,alertCalledId);
} }
} }
\ No newline at end of file
...@@ -4,6 +4,9 @@ import com.yeejoin.amos.boot.module.command.api.entity.FrontlineLiaison; ...@@ -4,6 +4,9 @@ import com.yeejoin.amos.boot.module.command.api.entity.FrontlineLiaison;
import com.yeejoin.amos.boot.module.command.api.mapper.FrontlineLiaisonMapper; import com.yeejoin.amos.boot.module.command.api.mapper.FrontlineLiaisonMapper;
import com.yeejoin.amos.boot.module.command.api.service.IFrontlineLiaisonService; import com.yeejoin.amos.boot.module.command.api.service.IFrontlineLiaisonService;
import com.yeejoin.amos.boot.module.command.api.dto.FrontlineLiaisonDto; import com.yeejoin.amos.boot.module.command.api.dto.FrontlineLiaisonDto;
import com.yeejoin.amos.boot.module.common.api.dto.FireExpertsDto;
import org.typroject.tyboot.core.rdbms.annotation.Condition;
import org.typroject.tyboot.core.rdbms.annotation.Operator;
import org.typroject.tyboot.core.rdbms.service.BaseService; import org.typroject.tyboot.core.rdbms.service.BaseService;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
...@@ -20,8 +23,10 @@ public class FrontlineLiaisonServiceImpl extends BaseService<FrontlineLiaisonDto ...@@ -20,8 +23,10 @@ public class FrontlineLiaisonServiceImpl extends BaseService<FrontlineLiaisonDto
/** /**
* 分页查询 * 分页查询
*/ */
public Page<FrontlineLiaisonDto> queryForFrontlineLiaisonPage(Page<FrontlineLiaisonDto> page) {
return this.queryForPage(page, null, false);
public Page<FrontlineLiaisonDto> queryForFrontlineLiaisonPage(Page<FrontlineLiaisonDto> page,@Condition(Operator.eq) Long alertCalledId) {
return this.queryForPage(page, null, false,alertCalledId);
} }
/** /**
......
...@@ -227,13 +227,8 @@ public class MaintenanceCompanyController extends BaseController { ...@@ -227,13 +227,8 @@ public class MaintenanceCompanyController extends BaseController {
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@GetMapping(value = "find") @GetMapping(value = "find")
@ApiOperation(httpMethod = "GET", value = "根据sequenceNbr查询单个维保单位-人员-部门", notes = "根据sequenceNbr查询单个维保单位-人员-部门") @ApiOperation(httpMethod = "GET", value = "根据sequenceNbr查询单个维保单位-人员-部门", notes = "根据sequenceNbr查询单个维保单位-人员-部门")
public ResponseModel<Map<String, Object>> seleteOne(@RequestParam long sequenceNbr, public ResponseModel<Map<String, Object>> selectOne(@RequestParam long sequenceNbr) {
@RequestParam String maintenanceType) { return ResponseHelper.buildResponse(maintenanceCompanyService.findBySequenceNbr(sequenceNbr));
if (COMPANY.equals(maintenanceType) || PERSON.equals(maintenanceType) || PERSON.equals(maintenanceType)) {
return ResponseHelper
.buildResponse(maintenanceCompanyService.findBySequenceNbr(sequenceNbr, maintenanceType));
}
return ResponseHelper.buildResponse(null);
} }
/** /**
......
...@@ -308,7 +308,7 @@ public class WaterResourceController extends BaseController { ...@@ -308,7 +308,7 @@ public class WaterResourceController extends BaseController {
@ApiOperation(httpMethod = "GET", value = "分页查询", notes = "分页查询") @ApiOperation(httpMethod = "GET", value = "分页查询", notes = "分页查询")
public ResponseModel<Page<WaterResourceDto>> queryForPage(@RequestParam(value = "current") int current, public ResponseModel<Page<WaterResourceDto>> queryForPage(@RequestParam(value = "current") int current,
@RequestParam(value = "size") int size, String name, @RequestParam(value = "size") int size, String name,
@RequestParam(value = "belongBuildingId")ArrayList<Long> belongBuildingId, ArrayList<Long> belongBuildingId,
Long belongFightingSystemId, Long sequenceNbr, Long belongFightingSystemId, Long sequenceNbr,
String resourceType) { String resourceType) {
Page<WaterResourceDto> page = new Page<>(); Page<WaterResourceDto> page = new Page<>();
......
...@@ -101,7 +101,12 @@ public class DynamicFormInstanceServiceImpl extends BaseService<DynamicFormInsta ...@@ -101,7 +101,12 @@ public class DynamicFormInstanceServiceImpl extends BaseService<DynamicFormInsta
List<DynamicFormColumn> columns = dynamicFormColumnService.list(new LambdaQueryWrapper<DynamicFormColumn>().eq(DynamicFormColumn::getGroupCode, groupCode)); List<DynamicFormColumn> columns = dynamicFormColumnService.list(new LambdaQueryWrapper<DynamicFormColumn>().eq(DynamicFormColumn::getGroupCode, groupCode));
Map<String, Object> instanceMap = Bean.listToMap(list, "fieldCode", "fieldValue", DynamicFormInstance.class); Map<String, Object> instanceMap = Bean.listToMap(list, "fieldCode", "fieldValue", DynamicFormInstance.class);
for (DynamicFormColumn optionModel : columns) { for (DynamicFormColumn optionModel : columns) {
DynamicFormInstance dyFormInstance =
list.stream().filter(i -> i.getFieldCode().equals(optionModel.getFieldCode())).findFirst().get();
instanceMap.put(optionModel.getFieldCode(), instanceMap.get(optionModel.getFieldCode())); instanceMap.put(optionModel.getFieldCode(), instanceMap.get(optionModel.getFieldCode()));
if ("radio,select,treeSelect".contains(optionModel.getFieldType())) {
instanceMap.put(optionModel.getFieldCode() + "Label", dyFormInstance.getFieldValueLabel());
}
} }
optionListMap.putAll(instanceMap); optionListMap.putAll(instanceMap);
optionListMap.put("instanceId", instanceId); optionListMap.put("instanceId", instanceId);
......
...@@ -101,7 +101,8 @@ public class MaintenanceCompanyServiceImpl ...@@ -101,7 +101,8 @@ public class MaintenanceCompanyServiceImpl
* @param maintenanceCompany * @param maintenanceCompany
* @return * @return
*/ */
@Transactional @Override
@Transactional(rollbackFor = Exception.class)
public boolean saveCompanyDetail(MaintenanceCompany maintenanceCompany) { public boolean saveCompanyDetail(MaintenanceCompany maintenanceCompany) {
Long instanceId = saveDynamicFormList(maintenanceCompany); Long instanceId = saveDynamicFormList(maintenanceCompany);
maintenanceCompany.setCode(OrgUsrServiceImpl.getOrgCodeStr()); maintenanceCompany.setCode(OrgUsrServiceImpl.getOrgCodeStr());
...@@ -120,6 +121,7 @@ public class MaintenanceCompanyServiceImpl ...@@ -120,6 +121,7 @@ public class MaintenanceCompanyServiceImpl
return true; return true;
} }
@Override
public boolean savePersonDetail(MaintenanceCompany maintenanceCompany, long sequenceNbr) { public boolean savePersonDetail(MaintenanceCompany maintenanceCompany, long sequenceNbr) {
Long instanceId = saveDynamicFormList(maintenanceCompany); Long instanceId = saveDynamicFormList(maintenanceCompany);
MaintenanceCompany detail = maintenanceCompanyMapper.selectById(sequenceNbr); MaintenanceCompany detail = maintenanceCompanyMapper.selectById(sequenceNbr);
...@@ -188,6 +190,7 @@ public class MaintenanceCompanyServiceImpl ...@@ -188,6 +190,7 @@ public class MaintenanceCompanyServiceImpl
return true; return true;
} }
@Override
public boolean deleteById(Long sequenceNbr) { public boolean deleteById(Long sequenceNbr) {
MaintenanceCompany maintenanceCompany = maintenanceCompanyMapper.selectById(sequenceNbr); MaintenanceCompany maintenanceCompany = maintenanceCompanyMapper.selectById(sequenceNbr);
...@@ -200,8 +203,15 @@ public class MaintenanceCompanyServiceImpl ...@@ -200,8 +203,15 @@ public class MaintenanceCompanyServiceImpl
int number = maintenanceCompanyMapper.update(maintenanceCompany, wrapper); int number = maintenanceCompanyMapper.update(maintenanceCompany, wrapper);
if (number > 0) { if (number > 0) {
// 更新动态表单字段为删除状态
List<DynamicFormInstance> dyInstance =
dynamicFormInstanceService.list(new LambdaQueryWrapper<DynamicFormInstance>().eq(DynamicFormInstance::getInstanceId, maintenanceCompany.getInstanceId()));
dyInstance.forEach(i -> i.setIsDelete(true));
dynamicFormInstanceService.updateBatchById(dyInstance);
return true; return true;
} }
return false; return false;
} }
...@@ -301,6 +311,8 @@ public class MaintenanceCompanyServiceImpl ...@@ -301,6 +311,8 @@ public class MaintenanceCompanyServiceImpl
List<MaintenanceCompany> mainTableList = null; List<MaintenanceCompany> mainTableList = null;
String type = null; String type = null;
LambdaQueryWrapper<MaintenanceCompany> wrapper = new LambdaQueryWrapper<>();
wrapper.eq(MaintenanceCompany::getIsDelete, false);
switch (maintenanceType) { switch (maintenanceType) {
case PERSON: case PERSON:
type = MAINTENANCE_PERSON; type = MAINTENANCE_PERSON;
...@@ -308,21 +320,20 @@ public class MaintenanceCompanyServiceImpl ...@@ -308,21 +320,20 @@ public class MaintenanceCompanyServiceImpl
filedParamsMap = new HashMap<String, String>(); filedParamsMap = new HashMap<String, String>();
filedParamsMap.put("status", paramsMap.get("status").toString()); filedParamsMap.put("status", paramsMap.get("status").toString());
} }
mainTableList = this.checkMaintenanceCompanyList(paramsMap); mainTableList = this.checkMaintenanceCompanyList(wrapper, paramsMap);
break; break;
case COMPANY: case COMPANY:
type = MAINTENANCE_COMPANY; type = MAINTENANCE_COMPANY;
LambdaQueryWrapper<MaintenanceCompany> wrapper = new LambdaQueryWrapper<>();
wrapper.eq(MaintenanceCompany::getType, maintenanceType.toUpperCase()); wrapper.eq(MaintenanceCompany::getType, maintenanceType.toUpperCase());
mainTableList = this.list(wrapper); mainTableList = this.list(wrapper);
break; break;
case DEPARTMENT: case DEPARTMENT:
type = MAINTENANCE_DEPARTMENT; type = MAINTENANCE_DEPARTMENT;
LambdaQueryWrapper<MaintenanceCompany> condition = new LambdaQueryWrapper<>(); wrapper.eq(MaintenanceCompany::getType, maintenanceType.toUpperCase());
condition.eq(MaintenanceCompany::getType, maintenanceType.toUpperCase()); mainTableList = this.list(wrapper);
mainTableList = this.list(condition);
break; break;
default:
throw new IllegalStateException("Unexpected maintenanceType: " + maintenanceType);
} }
if (StringUtils.isBlank(type)) { if (StringUtils.isBlank(type)) {
return null; return null;
...@@ -341,44 +352,41 @@ public class MaintenanceCompanyServiceImpl ...@@ -341,44 +352,41 @@ public class MaintenanceCompanyServiceImpl
return page; return page;
} }
public List<MaintenanceCompany> checkMaintenanceCompanyList(Map<String, Object> paramsMap) { public List<MaintenanceCompany> checkMaintenanceCompanyList(LambdaQueryWrapper<MaintenanceCompany> wrapper,
LambdaQueryWrapper<MaintenanceCompany> wrapper = new LambdaQueryWrapper<>(); Map<String, Object> paramsMap) {
if (paramsMap.containsKey("name")) { if (paramsMap.containsKey("name")) {
wrapper.likeRight(MaintenanceCompany::getName, paramsMap.get("name").toString()); wrapper.likeRight(MaintenanceCompany::getName, paramsMap.get("name").toString());
} }
if (paramsMap.containsKey("parentId")) { if (paramsMap.containsKey("parentId") && !"-1".equals(paramsMap.get("parentId"))) {
wrapper.eq(MaintenanceCompany::getParentId, Long.parseLong(paramsMap.get("parentId").toString())); wrapper.eq(MaintenanceCompany::getParentId, Long.parseLong(paramsMap.get("parentId").toString()));
} }
wrapper.eq(MaintenanceCompany::getType, PERSON); wrapper.eq(MaintenanceCompany::getType, PERSON);
return maintenanceCompanyMapper.selectList(wrapper); return maintenanceCompanyMapper.selectList(wrapper);
} }
@Override @Override
public Map<String, Object> findBySequenceNbr(Long sequenceNbr, String maintenanceType) { public Map<String, Object> findBySequenceNbr(Long sequenceNbr) {
String type = null;
switch (maintenanceType.toUpperCase()) {
case PERSON:
type = MAINTENANCE_PERSON;
break;
case COMPANY:
type = MAINTENANCE_COMPANY;
break;
case DEPARTMENT:
type = MAINTENANCE_DEPARTMENT;
break;
}
if (StringUtils.isBlank(type)) {
return null;
}
MaintenanceCompany maintenanceCompany = maintenanceCompanyMapper.selectById(sequenceNbr); MaintenanceCompany maintenanceCompany = maintenanceCompanyMapper.selectById(sequenceNbr);
Map<String, Object> mianmMap = Bean.BeantoMap(maintenanceCompany); String type;
switch (maintenanceCompany.getType()) {
case PERSON:
type = MAINTENANCE_PERSON;
break;
case DEPARTMENT:
type = MAINTENANCE_DEPARTMENT;
break;
default:
type = MAINTENANCE_COMPANY;
}
Map<String, Object> mainMap = Bean.BeantoMap(maintenanceCompany);
Map<String, Object> dynamicMap = dynamicFormInstanceService.getOneMap(maintenanceCompany.getInstanceId(), type); Map<String, Object> dynamicMap = dynamicFormInstanceService.getOneMap(maintenanceCompany.getInstanceId(), type);
mianmMap.put("dynamicResult", dynamicMap); mainMap.put("dynamicResult", dynamicMap);
return mianmMap; return mainMap;
} }
@Override @Override
@Transactional @Transactional(rollbackFor = Exception.class)
public boolean updateMaintenanceCompanyDetail(MaintenanceCompany model, AgencyUserModel userInfo) { public boolean updateMaintenanceCompanyDetail(MaintenanceCompany model, AgencyUserModel userInfo) {
// 先刪除,后添加 // 先刪除,后添加
MaintenanceCompanyDto maintenanceCompany = this.queryBySeq(model.getSequenceNbr()); MaintenanceCompanyDto maintenanceCompany = this.queryBySeq(model.getSequenceNbr());
...@@ -684,4 +692,5 @@ public class MaintenanceCompanyServiceImpl ...@@ -684,4 +692,5 @@ public class MaintenanceCompanyServiceImpl
return false; return false;
} }
} }
\ No newline at end of file
...@@ -12,17 +12,15 @@ import com.yeejoin.amos.boot.biz.common.utils.RedisKey; ...@@ -12,17 +12,15 @@ import com.yeejoin.amos.boot.biz.common.utils.RedisKey;
import com.yeejoin.amos.boot.biz.common.utils.RedisUtils; import com.yeejoin.amos.boot.biz.common.utils.RedisUtils;
import com.yeejoin.amos.boot.module.common.api.dto.FormValue; import com.yeejoin.amos.boot.module.common.api.dto.FormValue;
import com.yeejoin.amos.boot.module.common.api.dto.RequestData; import com.yeejoin.amos.boot.module.common.api.dto.RequestData;
import com.yeejoin.amos.boot.module.jcs.api.dto.AlertCalledDto; import com.yeejoin.amos.boot.module.jcs.api.dto.*;
import com.yeejoin.amos.boot.module.jcs.api.dto.AlertCalledFormDto;
import com.yeejoin.amos.boot.module.jcs.api.dto.AlertCalledObjsDto;
import com.yeejoin.amos.boot.module.jcs.api.dto.AlertCalledZhDto;
import com.yeejoin.amos.boot.module.jcs.api.dto.KeyValueLabel;
import com.yeejoin.amos.boot.module.jcs.api.entity.AlertCalled; import com.yeejoin.amos.boot.module.jcs.api.entity.AlertCalled;
import com.yeejoin.amos.boot.module.jcs.api.entity.AlertFormValue; import com.yeejoin.amos.boot.module.jcs.api.entity.AlertFormValue;
import com.yeejoin.amos.boot.module.jcs.api.entity.Template; import com.yeejoin.amos.boot.module.jcs.api.entity.Template;
import com.yeejoin.amos.boot.module.jcs.api.enums.AlertStageEnums; import com.yeejoin.amos.boot.module.jcs.api.enums.AlertStageEnums;
import com.yeejoin.amos.boot.module.jcs.api.enums.DutyInfoEnum; import com.yeejoin.amos.boot.module.jcs.api.enums.DutyInfoEnum;
import com.yeejoin.amos.boot.module.jcs.api.mapper.AlertCalledMapper; import com.yeejoin.amos.boot.module.jcs.api.mapper.AlertCalledMapper;
import com.yeejoin.amos.boot.module.jcs.api.mapper.AlertSubmittedMapper;
import com.yeejoin.amos.boot.module.jcs.api.mapper.PowerTransferMapper;
import com.yeejoin.amos.boot.module.jcs.api.mapper.TemplateMapper; import com.yeejoin.amos.boot.module.jcs.api.mapper.TemplateMapper;
import com.yeejoin.amos.boot.module.jcs.api.service.IAlertCalledService; import com.yeejoin.amos.boot.module.jcs.api.service.IAlertCalledService;
import com.yeejoin.amos.component.rule.config.RuleConfig; import com.yeejoin.amos.component.rule.config.RuleConfig;
...@@ -77,8 +75,10 @@ public class AlertCalledServiceImpl extends BaseService<AlertCalledDto,AlertCall ...@@ -77,8 +75,10 @@ public class AlertCalledServiceImpl extends BaseService<AlertCalledDto,AlertCall
@Autowired @Autowired
TemplateMapper templateMapper; TemplateMapper templateMapper;
@Autowired
PowerTransferMapper powerTransferMapper;
@Autowired
AlertSubmittedMapper alertSubmittedMapper;
/** /**
* *
* 指挥系统 未结束的警情列表 * 指挥系统 未结束的警情列表
...@@ -368,4 +368,41 @@ public class AlertCalledServiceImpl extends BaseService<AlertCalledDto,AlertCall ...@@ -368,4 +368,41 @@ public class AlertCalledServiceImpl extends BaseService<AlertCalledDto,AlertCall
return map; return map;
} }
@Override
public List<KeyValueLabel> selectAlertCalledcount(Long id) {
// 警情基本信息
AlertCalled alertCalled = this.getById(id);
List<KeyValueLabel> listdate =new ArrayList<>();
listdate.add(new KeyValueLabel("被困人数","trappedNum",alertCalled.getTrappedNum()));
listdate.add(new KeyValueLabel("伤亡人数","casualtiesNum",alertCalled.getCasualtiesNum()));
return listdate;
}
@Override
public List<KeyValueLabel> powercount(Long id) {
Map<String,Integer> map=powerTransferMapper.getCarNum(id);
// Map<String,Integer> mapc=powerTransferMapper.getCompanyNum(id);
// Map<String,Integer> mapu= alertSubmittedMapper.getUseNum(id);
//统计参与人员
List<KeyValueLabel> listdate =new ArrayList<>();
listdate.add(new KeyValueLabel("调动人力","useNum","0","人"));
//统计参与车辆
listdate.add(new KeyValueLabel("调动人力","carNum",map.get("carNum"),"辆"));
//统计参与队伍
listdate.add(new KeyValueLabel("调动单位","companyNum",map.get("companyNum"),"个"));
return listdate;
}
@Override
public List<PowerData> getPowerDataList(Long id) {
List<PowerData> list=powerTransferMapper.getPowerDataList(id);
return list;
}
@Override
public AlertCalled getAlertCalledById(Long id) {
return this.getById(id);
}
} }
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