diff --git a/xhpc-modules/xhpc-charging-station/src/main/java/com/xhpc/charging/station/controller/XhpcEquipmentAccidentController.java b/xhpc-modules/xhpc-charging-station/src/main/java/com/xhpc/charging/station/controller/XhpcEquipmentAccidentController.java new file mode 100644 index 00000000..0eef8d82 --- /dev/null +++ b/xhpc-modules/xhpc-charging-station/src/main/java/com/xhpc/charging/station/controller/XhpcEquipmentAccidentController.java @@ -0,0 +1,56 @@ +package com.xhpc.charging.station.controller; + + +import com.xhpc.charging.station.service.IXhpcEquipmentAccidentService; +import com.xhpc.common.core.domain.R; +import com.xhpc.common.core.web.controller.BaseController; +import com.xhpc.common.core.web.domain.AjaxResult; +import com.xhpc.common.core.web.page.TableDataInfo; +import com.xhpc.common.domain.XhpcChargingPile; +import com.xhpc.common.domain.XhpcEquipmentAccident; +import com.xhpc.common.log.annotation.Log; +import com.xhpc.common.log.enums.BusinessType; +import org.springframework.web.bind.annotation.*; + +import javax.annotation.Resource; +import javax.servlet.http.HttpServletRequest; +import java.util.List; +import java.util.Map; + +@RestController +@RequestMapping("/accident") +public class XhpcEquipmentAccidentController extends BaseController { + + + @Resource + IXhpcEquipmentAccidentService xhpcEquipmentAccidentService; + + @GetMapping("/list") + public TableDataInfo list(HttpServletRequest request, String address) { + List> list = xhpcEquipmentAccidentService.getLsit(address); + return getDataTable(list); + } + + @PostMapping(value = "/addXhpcEquipmentAccident") + public R addXhpcEquipmentAccident(@RequestBody XhpcEquipmentAccident xhpcEquipmentAccident) { + return xhpcEquipmentAccidentService.insertXhpcEquipmentAccident(xhpcEquipmentAccident); + } + + @PostMapping(value = "/updateXhpcEquipmentAccident") + public R updateXhpcEquipmentAccident(@RequestBody XhpcEquipmentAccident xhpcEquipmentAccident) { + return xhpcEquipmentAccidentService.updateXhpcEquipmentAccident(xhpcEquipmentAccident); + } + + @GetMapping("/getXhpcEquipmentAccidentById") + public R getXhpcEquipmentAccidentById(Long equipmentAccidentId) { + Map map = xhpcEquipmentAccidentService.getXhpcEquipmentAccidentById(equipmentAccidentId); + return R.ok(map); + } + + @Log(title = "删除电站", businessType = BusinessType.DELETE) + @GetMapping("/deleteXhpcEquipmentAccidentById") + public R deleteXhpcEquipmentAccidentById(Long equipmentAccidentId) { + return xhpcEquipmentAccidentService.deleteXhpcEquipmentAccidentById(equipmentAccidentId); + } + +} diff --git a/xhpc-modules/xhpc-charging-station/src/main/java/com/xhpc/charging/station/mapper/XhpcEquipmentAccidentMapper.java b/xhpc-modules/xhpc-charging-station/src/main/java/com/xhpc/charging/station/mapper/XhpcEquipmentAccidentMapper.java new file mode 100644 index 00000000..a7192ceb --- /dev/null +++ b/xhpc-modules/xhpc-charging-station/src/main/java/com/xhpc/charging/station/mapper/XhpcEquipmentAccidentMapper.java @@ -0,0 +1,21 @@ +package com.xhpc.charging.station.mapper; + +import com.xhpc.common.domain.XhpcEquipmentAccident; +import org.springframework.data.repository.query.Param; + +import java.util.List; +import java.util.Map; + +public interface XhpcEquipmentAccidentMapper { + + + List> getLsit(@Param("address")String address); + + void insertXhpcEquipmentAccident(XhpcEquipmentAccident xhpcEquipmentAccident); + + void updateXhpcEquipmentAccident(XhpcEquipmentAccident xhpcEquipmentAccident); + + Map getXhpcEquipmentAccidentById(@Param("equipmentAccidentId")Long equipmentAccidentId); + + void deleteXhpcEquipmentAccidentById(@Param("equipmentAccidentId")Long equipmentAccidentId); +} diff --git a/xhpc-modules/xhpc-charging-station/src/main/java/com/xhpc/charging/station/service/IXhpcEquipmentAccidentService.java b/xhpc-modules/xhpc-charging-station/src/main/java/com/xhpc/charging/station/service/IXhpcEquipmentAccidentService.java new file mode 100644 index 00000000..8718d6a9 --- /dev/null +++ b/xhpc-modules/xhpc-charging-station/src/main/java/com/xhpc/charging/station/service/IXhpcEquipmentAccidentService.java @@ -0,0 +1,20 @@ +package com.xhpc.charging.station.service; + +import com.xhpc.common.core.domain.R; +import com.xhpc.common.domain.XhpcEquipmentAccident; + +import java.util.List; +import java.util.Map; + +public interface IXhpcEquipmentAccidentService { + + List> getLsit(String address); + + R insertXhpcEquipmentAccident(XhpcEquipmentAccident xhpcEquipmentAccident); + + R updateXhpcEquipmentAccident(XhpcEquipmentAccident xhpcEquipmentAccident); + + Map getXhpcEquipmentAccidentById(Long equipmentAccidentId ); + + R deleteXhpcEquipmentAccidentById(Long equipmentAccidentId); +} diff --git a/xhpc-modules/xhpc-charging-station/src/main/java/com/xhpc/charging/station/service/XhpcEquipmentAccidentImpl.java b/xhpc-modules/xhpc-charging-station/src/main/java/com/xhpc/charging/station/service/XhpcEquipmentAccidentImpl.java new file mode 100644 index 00000000..bed9947b --- /dev/null +++ b/xhpc-modules/xhpc-charging-station/src/main/java/com/xhpc/charging/station/service/XhpcEquipmentAccidentImpl.java @@ -0,0 +1,58 @@ +package com.xhpc.charging.station.service; + +import com.xhpc.charging.station.mapper.XhpcEquipmentAccidentMapper; +import com.xhpc.common.core.domain.R; +import com.xhpc.common.core.web.service.BaseService; +import com.xhpc.common.domain.XhpcEquipmentAccident; +import com.xhpc.common.security.service.TokenService; +import com.xhpc.system.api.model.LoginUser; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +import javax.annotation.Resource; +import java.util.List; +import java.util.Map; + +@Service +public class XhpcEquipmentAccidentImpl extends BaseService implements IXhpcEquipmentAccidentService { + + @Resource + XhpcEquipmentAccidentMapper xhpcEquipmentAccidentMapper; + @Autowired + private TokenService tokenService; + + @Override + public List> getLsit(String address) { + return xhpcEquipmentAccidentMapper.getLsit(address); + } + + @Override + public R insertXhpcEquipmentAccident(XhpcEquipmentAccident xhpcEquipmentAccident) { + if(xhpcEquipmentAccident.getEquipmentAccidentId() !=null){ + xhpcEquipmentAccidentMapper.updateXhpcEquipmentAccident(xhpcEquipmentAccident); + }else { + xhpcEquipmentAccidentMapper.insertXhpcEquipmentAccident(xhpcEquipmentAccident); + } + + return R.ok(); + } + + @Override + public R updateXhpcEquipmentAccident(XhpcEquipmentAccident xhpcEquipmentAccident) { + xhpcEquipmentAccidentMapper.updateXhpcEquipmentAccident(xhpcEquipmentAccident); + return R.ok(); + } + + @Override + public Map getXhpcEquipmentAccidentById(Long equipmentAccidentId) { + return xhpcEquipmentAccidentMapper.getXhpcEquipmentAccidentById(equipmentAccidentId); + } + + @Override + public R deleteXhpcEquipmentAccidentById(Long equipmentAccidentId) { + + xhpcEquipmentAccidentMapper.deleteXhpcEquipmentAccidentById(equipmentAccidentId); + + return R.ok(); + } +} diff --git a/xhpc-modules/xhpc-charging-station/src/main/resources/mapper/XhpcEquipmentAccidentMapper.xml b/xhpc-modules/xhpc-charging-station/src/main/resources/mapper/XhpcEquipmentAccidentMapper.xml new file mode 100644 index 00000000..a27700f0 --- /dev/null +++ b/xhpc-modules/xhpc-charging-station/src/main/resources/mapper/XhpcEquipmentAccidentMapper.xml @@ -0,0 +1,261 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + insert into xhpc_equipment_accident + + + area_code, + + + address, + + + accident_entity, + + + type, + + + accident_reason, + + + level, + + + accident_time, + + + description, + + + pictures, + + + analysis_report, + + + del_flag, + + + create_time, + + + create_by, + + + update_time, + + + update_by, + + + remark, + + + tenant_id, + + + + + #{areaCode}, + + + #{address}, + + + #{accidentEntity}, + + + #{type}, + + + #{accidentReason}, + + + #{level}, + + + #{accidentTime}, + + + #{description}, + + + #{pictures}, + + + #{analysisReport}, + + + #{delFlag}, + + + #{createTime}, + + + #{createBy}, + + + #{updateTime}, + + + #{updateBy}, + + + #{remark}, + + + #{tenantId}, + + + + + + update xhpc_equipment_accident + + + area_code=#{areaCode}, + + + address=#{address}, + + + accident_entity=#{accidentEntity}, + + + type=#{type}, + + + accident_reason=#{accidentReason}, + + + level=#{level}, + + + accident_time=#{accidentTime}, + + + description=#{description}, + + + pictures=#{pictures}, + + + analysis_report=#{analysisReport}, + + + del_flag = #{delFlag}, + + + create_time = #{createTime}, + + + create_by = #{createBy}, + + + update_time = #{updateTime}, + + + update_by =#{updateBy}, + + + remark =#{remark}, + + + tenant_id =#{tenantId}, + + + where equipment_accident_id = #{equipmentAccidentId} + + + + + + update xhpc_equipment_accident set del_flag =1 where equipment_accident_id = #{equipmentAccidentId} + + + + + + \ No newline at end of file diff --git a/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/domain/XhpcEquipmentAccident.java b/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/domain/XhpcEquipmentAccident.java new file mode 100644 index 00000000..ffd07a91 --- /dev/null +++ b/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/domain/XhpcEquipmentAccident.java @@ -0,0 +1,49 @@ +package com.xhpc.common.domain; + +import com.xhpc.common.core.web.domain.BaseEntity; +import lombok.Data; + +import java.util.Date; + +@Data +public class XhpcEquipmentAccident extends BaseEntity { + + private static final long serialVersionUID = 1L; + + /** 充电事故id */ + private Long equipmentAccidentId; + + /** 区域代码 */ + private String areaCode; + + /** 事故地点 */ + private String address; + + /** 事故主题 1.运营商 2车企 3.设备制造商 */ + private Integer accidentEntity; + + /** 事故类型 1.充电设备质量问题 2.电动车电池问题 3.电网故障 4.充电站管路 99.其他 */ + private Integer type; + + /** 事故原因 */ + private String accidentReason; + + /** 事故分级 1.造成经济损失且有人员伤亡 2.造成人员伤亡 3.造成经济损失但未造成人员伤亡 4.未造成经济损失且无人员伤亡 */ + private Integer level; + + /** 发生时间 */ + private Date accidentTime; + + /** 事故文字描述 */ + private String description; + + /** 现场图片 */ + private String pictures; + + /** 事故分析报告 */ + private String analysisReport; + + + private Integer delFlag; + +}