diff --git a/xhpc-modules/xhpc-charging-station/src/main/java/com/xhpc/charging/station/controller/XhpcBarrierGateController.java b/xhpc-modules/xhpc-charging-station/src/main/java/com/xhpc/charging/station/controller/XhpcBarrierGateController.java index 7bb86d2c..7585d0d2 100644 --- a/xhpc-modules/xhpc-charging-station/src/main/java/com/xhpc/charging/station/controller/XhpcBarrierGateController.java +++ b/xhpc-modules/xhpc-charging-station/src/main/java/com/xhpc/charging/station/controller/XhpcBarrierGateController.java @@ -3,11 +3,18 @@ package com.xhpc.charging.station.controller; import com.xhpc.charging.station.service.IXhpcBarrierGateService; import com.xhpc.common.core.domain.R; import com.xhpc.common.core.web.controller.BaseController; -import org.springframework.web.bind.annotation.GetMapping; -import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RestController; +import com.xhpc.common.core.web.page.TableDataInfo; +import com.xhpc.common.domain.XhpcBarrierGate; +import com.xhpc.common.domain.XhpcEquipmentAccident; +import com.xhpc.common.log.annotation.Log; +import com.xhpc.common.log.enums.BusinessType; +import org.springframework.scheduling.annotation.Scheduled; +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("/barrierGate") @@ -21,5 +28,40 @@ public class XhpcBarrierGateController extends BaseController { return xhpcBarrierGateService.getBarrierGateList(); } + @GetMapping("/list") + public TableDataInfo list(HttpServletRequest request, String barrierGateCompany) { + List> list = xhpcBarrierGateService.getLsit(barrierGateCompany); + return getDataTable(list); + } + @PostMapping(value = "/addBarrierGate") + public R addXhpcEquipmentAccident(@RequestBody XhpcBarrierGate xhpcBarrierGate) { + return xhpcBarrierGateService.insertBarrierGate(xhpcBarrierGate); + } + + @PostMapping(value = "/updateBarrierGate") + public R updateBarrierGate(@RequestBody XhpcBarrierGate xhpcBarrierGate) { + return xhpcBarrierGateService.updateBarrierGate(xhpcBarrierGate); + } + + @Log(title = "删除道闸", businessType = BusinessType.DELETE) + @GetMapping("/deleteBarrierGateById") + public R deleteBarrierGateById(Long barrierGateId) { + return xhpcBarrierGateService.deleteBarrierGateById(barrierGateId); + } + + @GetMapping("/getXhpcBarrierGateById") + public R getXhpcBarrierGateById(Long barrierGateId) { + Map map = xhpcBarrierGateService.getXhpcBarrierGateById(barrierGateId); + return R.ok(map); + } + + /** + * 定时任务时间 + */ + @Scheduled(cron = "0 0 12 * * ? ") + @GetMapping("/getEndTimeExpire") + public void getEndTimeExpire(){ + xhpcBarrierGateService.getEndTimeExpire(); + } } 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 index 0eef8d82..022d0bf8 100644 --- 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 @@ -47,7 +47,7 @@ public class XhpcEquipmentAccidentController extends BaseController { return R.ok(map); } - @Log(title = "删除电站", businessType = BusinessType.DELETE) + @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/XhpcBarrierGateMapper.java b/xhpc-modules/xhpc-charging-station/src/main/java/com/xhpc/charging/station/mapper/XhpcBarrierGateMapper.java index 35a20468..81b057b9 100644 --- a/xhpc-modules/xhpc-charging-station/src/main/java/com/xhpc/charging/station/mapper/XhpcBarrierGateMapper.java +++ b/xhpc-modules/xhpc-charging-station/src/main/java/com/xhpc/charging/station/mapper/XhpcBarrierGateMapper.java @@ -1,5 +1,9 @@ package com.xhpc.charging.station.mapper; +import com.xhpc.common.domain.XhpcBarrierGate; +import com.xhpc.common.domain.XhpcEquipmentAccident; +import org.springframework.data.repository.query.Param; + import java.util.List; import java.util.Map; @@ -7,5 +11,19 @@ public interface XhpcBarrierGateMapper { List> getBarrierGateList(); + List> getLsit(@Param("barrierGateCompany")String barrierGateCompany); + + + void insertBarrierGate(XhpcBarrierGate xhpcBarrierGate); + + void updateBarrierGate(XhpcBarrierGate xhpcBarrierGate); + + void deleteBarrierGateById(@Param("barrierGateId")Long barrierGateId); + + Map getXhpcBarrierGateById(@Param("barrierGateId")Long barrierGateId); + + List getBarrierGateEndTime(@Param("date")String date); + + void updateBarrierGateStatus(@Param("barrierGateId")Long barrierGateId); } diff --git a/xhpc-modules/xhpc-charging-station/src/main/java/com/xhpc/charging/station/service/IXhpcBarrierGateService.java b/xhpc-modules/xhpc-charging-station/src/main/java/com/xhpc/charging/station/service/IXhpcBarrierGateService.java index 22532741..fbf0dcb4 100644 --- a/xhpc-modules/xhpc-charging-station/src/main/java/com/xhpc/charging/station/service/IXhpcBarrierGateService.java +++ b/xhpc-modules/xhpc-charging-station/src/main/java/com/xhpc/charging/station/service/IXhpcBarrierGateService.java @@ -1,9 +1,27 @@ package com.xhpc.charging.station.service; import com.xhpc.common.core.domain.R; +import com.xhpc.common.domain.XhpcBarrierGate; +import com.xhpc.common.domain.XhpcEquipmentAccident; + +import java.util.List; +import java.util.Map; public interface IXhpcBarrierGateService { R getBarrierGateList(); + + List> getLsit(String barrierGateCompany); + + + R insertBarrierGate(XhpcBarrierGate xhpcBarrierGate); + + R updateBarrierGate(XhpcBarrierGate xhpcBarrierGate); + + R deleteBarrierGateById(Long barrierGateId); + + Map getXhpcBarrierGateById(Long barrierGateId ); + + void getEndTimeExpire(); } diff --git a/xhpc-modules/xhpc-charging-station/src/main/java/com/xhpc/charging/station/service/XhpcBarrierGateServiceImpl.java b/xhpc-modules/xhpc-charging-station/src/main/java/com/xhpc/charging/station/service/XhpcBarrierGateServiceImpl.java index 383f3b9c..840a3b61 100644 --- a/xhpc-modules/xhpc-charging-station/src/main/java/com/xhpc/charging/station/service/XhpcBarrierGateServiceImpl.java +++ b/xhpc-modules/xhpc-charging-station/src/main/java/com/xhpc/charging/station/service/XhpcBarrierGateServiceImpl.java @@ -1,11 +1,16 @@ package com.xhpc.charging.station.service; +import cn.hutool.core.date.DateUtil; import com.xhpc.charging.station.mapper.XhpcBarrierGateMapper; import com.xhpc.common.core.domain.R; import com.xhpc.common.core.web.service.BaseService; +import com.xhpc.common.domain.XhpcBarrierGate; import org.springframework.stereotype.Service; import javax.annotation.Resource; +import java.util.Date; +import java.util.List; +import java.util.Map; @Service public class XhpcBarrierGateServiceImpl extends BaseService implements IXhpcBarrierGateService{ @@ -16,4 +21,45 @@ public class XhpcBarrierGateServiceImpl extends BaseService implements IXhpcBarr public R getBarrierGateList() { return R.ok(xhpcBarrierGateMapper.getBarrierGateList()); } + + @Override + public List> getLsit(String barrierGateCompany) { + return xhpcBarrierGateMapper.getLsit(barrierGateCompany); + } + + @Override + public R insertBarrierGate(XhpcBarrierGate xhpcBarrierGate) { + if(xhpcBarrierGate.getBarrierGateId() !=null){ + xhpcBarrierGateMapper.updateBarrierGate(xhpcBarrierGate); + }else { + xhpcBarrierGateMapper.insertBarrierGate(xhpcBarrierGate); + } + + return R.ok(); + } + + @Override + public R updateBarrierGate(XhpcBarrierGate xhpcBarrierGate) { + return null; + } + + @Override + public R deleteBarrierGateById(Long barrierGateId) { + xhpcBarrierGateMapper.deleteBarrierGateById(barrierGateId); + + return R.ok(); + } + + @Override + public Map getXhpcBarrierGateById(Long barrierGateId) { + return xhpcBarrierGateMapper.getXhpcBarrierGateById(barrierGateId); + } + + @Override + public void getEndTimeExpire() { + List barrierGateEndTime = xhpcBarrierGateMapper.getBarrierGateEndTime(DateUtil.now()); + for (int i = 0; i + + + + insert into xhpc_barrier_gate + + + barrier_gate_company, + + + start_time, + + + end_time, + + + status, + + + del_flag, + + + create_time, + + + create_by, + + + update_time, + + + update_by, + + + remark, + + + tenant_id, + + + + + #{barrierGateCompany}, + + + #{startTime}, + + + #{endTime}, + + + #{status}, + + + #{delFlag}, + + + #{createTime}, + + + #{createBy}, + + + #{updateTime}, + + + #{updateBy}, + + + #{remark}, + + + #{tenantId}, + + + + + + update xhpc_barrier_gate + + + barrier_gate_company=#{barrierGateCompany}, + + + start_time=#{startTime}, + + + end_time=#{endTime}, + + + status=#{status}, + + + del_flag = #{delFlag}, + + + create_time = #{createTime}, + + + create_by = #{createBy}, + + + update_time = #{updateTime}, + + + update_by =#{updateBy}, + + + remark =#{remark}, + + + tenant_id =#{tenantId}, + + + where barrier_gate_id = #{barrierGateId} + + + + update xhpc_barrier_gate set del_flag =1 where barrier_gate_id = #{barrierGateId} + + + + + + + update xhpc_barrier_gate set status =1 where barrier_gate_id = #{barrierGateId} + diff --git a/xhpc-modules/xhpc-charging-station/src/main/resources/mapper/XhpcChargingStationMapper.xml b/xhpc-modules/xhpc-charging-station/src/main/resources/mapper/XhpcChargingStationMapper.xml index 2824c40e..17db62c5 100644 --- a/xhpc-modules/xhpc-charging-station/src/main/resources/mapper/XhpcChargingStationMapper.xml +++ b/xhpc-modules/xhpc-charging-station/src/main/resources/mapper/XhpcChargingStationMapper.xml @@ -366,9 +366,7 @@ video_monitor=#{videoMonitor}, - barrier_gate_id=#{barrierGateId}, - where charging_station_id = #{chargingStationId} diff --git a/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/domain/XhpcBarrierGate.java b/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/domain/XhpcBarrierGate.java index fe1103be..4e82263b 100644 --- a/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/domain/XhpcBarrierGate.java +++ b/xhpc-modules/xhpc-common/src/main/java/com/xhpc/common/domain/XhpcBarrierGate.java @@ -1,9 +1,11 @@ package com.xhpc.common.domain; import com.xhpc.common.core.web.domain.BaseEntity; +import lombok.Data; import java.util.Date; +@Data public class XhpcBarrierGate extends BaseEntity { private static final long serialVersionUID = 1L; @@ -11,7 +13,7 @@ public class XhpcBarrierGate extends BaseEntity { /** 道闸id */ private Long barrierGateId; /** 道闸公司名称 */ - private Long barrierGateCompany; + private String barrierGateCompany; /** 有效开始时间 */ private Date startTime; @@ -21,4 +23,6 @@ public class XhpcBarrierGate extends BaseEntity { /** 帐号状态(0 正常 1已过期) */ private Integer status; + + private Integer delFlag; }