Commit e6e80b11 authored by wuxiaokai's avatar wuxiaokai

控制指令接口-时间表下发

parent cb25f5d8
...@@ -10,6 +10,7 @@ import net.wanji.utc.mapper.CrossInfoMapper; ...@@ -10,6 +10,7 @@ import net.wanji.utc.mapper.CrossInfoMapper;
import net.wanji.utc.po.CrossInfoPO; import net.wanji.utc.po.CrossInfoPO;
import net.wanji.utc.service.ControlCommandService; import net.wanji.utc.service.ControlCommandService;
import net.wanji.utc.vo.plansend.PlanSendVO; import net.wanji.utc.vo.plansend.PlanSendVO;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value; import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
...@@ -35,10 +36,11 @@ public class ControlCommandController { ...@@ -35,10 +36,11 @@ public class ControlCommandController {
@Resource @Resource
private CrossInfoMapper crossInfoMapper; private CrossInfoMapper crossInfoMapper;
@Resource @Autowired
private ControlCommandService hkControlCommandService; private ControlCommandService hkControlCommandService;
/** /**
*
*/ */
@ApiOperation(value = "方案下发-基础方案下发", notes = "方案下发-基础方案下发") @ApiOperation(value = "方案下发-基础方案下发", notes = "方案下发-基础方案下发")
@PostMapping("/schemeSend") @PostMapping("/schemeSend")
...@@ -168,6 +170,25 @@ public class ControlCommandController { ...@@ -168,6 +170,25 @@ public class ControlCommandController {
} }
} }
/**
* 恢复时间表
*
* @param signalId 信号id
* @return {@link Result}<{@link T}>
*/
@ApiOperation(value = "恢复时间表-恢复路口时间表执行", notes = "恢复时间表-恢复路口时间表执行")
@PostMapping("/scheduleSend")
public <T> Result<T> scheduleSend(@RequestParam String signalId) {
if (mock) return Result.success();
Integer manufacturerId = check(signalId);
if (manufacturerId.equals(BasicEnum.ManufacturerEnum.HK.getCode())) {
return hkControlCommandService.scheduleSend(signalId, null, null, null);
} else {
// todo else
return null;
}
}
private Integer check(String signalId) { private Integer check(String signalId) {
CrossInfoPO crossInfoPO = crossInfoMapper.selectByCode(signalId); CrossInfoPO crossInfoPO = crossInfoMapper.selectByCode(signalId);
if (crossInfoPO == null) { if (crossInfoPO == null) {
......
...@@ -25,7 +25,7 @@ public interface ControlCommandService { ...@@ -25,7 +25,7 @@ public interface ControlCommandService {
/** /**
* 时间表下发 * 时间表下发
*/ */
<T> Result<T> scheduleSend(); <T> Result<T> scheduleSend(String signalId, String sourceType, String signalType, Integer command);
/** /**
* 锁定控制 * 锁定控制
......
...@@ -62,8 +62,8 @@ public class HKControlCommandServiceImpl implements ControlCommandService { ...@@ -62,8 +62,8 @@ public class HKControlCommandServiceImpl implements ControlCommandService {
} }
@Override @Override
public <T> Result<T> scheduleSend() { public <T> Result<T> scheduleSend(String signalId, String sourceType, String signalType, Integer command) {
return null; return controlSignal(signalId, NORMAL_RUNNING_CONTROL);
} }
@Override @Override
...@@ -74,25 +74,25 @@ public class HKControlCommandServiceImpl implements ControlCommandService { ...@@ -74,25 +74,25 @@ public class HKControlCommandServiceImpl implements ControlCommandService {
@Override @Override
public <T> Result<T> stepControl(String signalId, String sourceType, String signalType, Integer command, Integer stepNum) { public <T> Result<T> stepControl(String signalId, String sourceType, String signalType, Integer command, Integer stepNum) {
if (command.equals(TRUE)) return updateManualStep(signalId, STEP_CONTROL, stepNum); if (command.equals(TRUE)) return updateManualStep(signalId, STEP_CONTROL, stepNum);
else return updateManual(signalId, CANCEL_STEP_CONTROL); else return controlSignal(signalId, CANCEL_STEP_CONTROL);
} }
@Override @Override
public <T> Result<T> allRedControl(String signalId, String sourceType, String signalType, Integer command) { public <T> Result<T> allRedControl(String signalId, String sourceType, String signalType, Integer command) {
Integer runningMode = command.equals(TRUE) ? ALL_RED_CONTROL : NORMAL_RUNNING_CONTROL; Integer runningMode = command.equals(TRUE) ? ALL_RED_CONTROL : NORMAL_RUNNING_CONTROL;
return updateManual(signalId, runningMode); return controlSignal(signalId, runningMode);
} }
@Override @Override
public <T> Result<T> yellowLightControl(String signalId, String sourceType, String signalType, Integer command) { public <T> Result<T> yellowLightControl(String signalId, String sourceType, String signalType, Integer command) {
Integer runningMode = command.equals(TRUE) ? YELLOW_LIGHT_CONTROL : NORMAL_RUNNING_CONTROL; Integer runningMode = command.equals(TRUE) ? YELLOW_LIGHT_CONTROL : NORMAL_RUNNING_CONTROL;
return updateManual(signalId, runningMode); return controlSignal(signalId, runningMode);
} }
@Override @Override
public <T> Result<T> closeLightControl(String signalId, String sourceType, String signalType, Integer command) { public <T> Result<T> closeLightControl(String signalId, String sourceType, String signalType, Integer command) {
Integer runningMode = command.equals(TRUE) ? CLOSE_LIGHT_CONTROL : NORMAL_RUNNING_CONTROL; Integer runningMode = command.equals(TRUE) ? CLOSE_LIGHT_CONTROL : NORMAL_RUNNING_CONTROL;
return updateManual(signalId, runningMode); return controlSignal(signalId, runningMode);
} }
@Override @Override
...@@ -148,7 +148,7 @@ public class HKControlCommandServiceImpl implements ControlCommandService { ...@@ -148,7 +148,7 @@ public class HKControlCommandServiceImpl implements ControlCommandService {
* @param signalId 信号机编号 * @param signalId 信号机编号
* @param runningMode 0-多时段控制模式 1-关灯、2-黄闪、3-全红、11-取消步进控制、12-灯态锁定、13-灯态解锁 * @param runningMode 0-多时段控制模式 1-关灯、2-黄闪、3-全红、11-取消步进控制、12-灯态锁定、13-灯态解锁
*/ */
private <T> Result<T> updateManual(String signalId, Integer runningMode) { private <T> Result<T> controlSignal(String signalId, Integer runningMode) {
//执行恢复时间表方案命令 //执行恢复时间表方案命令
if (NORMAL_RUNNING_CONTROL.equals(runningMode) || CANCEL_STEP_CONTROL.equals(runningMode)) { if (NORMAL_RUNNING_CONTROL.equals(runningMode) || CANCEL_STEP_CONTROL.equals(runningMode)) {
//根据实时灯态获取当前运行模式 //根据实时灯态获取当前运行模式
......
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