Browse Source

fix:业务指令修改

master
王梦远 2 months ago
parent
commit
5b31dc58e9
  1. 2
      src/main/java/com/iflytop/sgs/app/cmd/debug/DebugDoorOpenCommand.java
  2. 4
      src/main/java/com/iflytop/sgs/app/controller/AuthController.java
  3. 4
      src/main/java/com/iflytop/sgs/app/controller/SelfTestController.java
  4. 8
      src/main/java/com/iflytop/sgs/app/model/bo/status/device/DeviceState.java
  5. 7
      src/main/java/com/iflytop/sgs/app/service/api/HeatService.java
  6. 2
      src/main/java/com/iflytop/sgs/app/service/api/SystemConfigService.java
  7. 4
      src/main/java/com/iflytop/sgs/app/service/api/TasksService.java
  8. 10
      src/main/java/com/iflytop/sgs/app/service/api/TrayService.java
  9. 2
      src/main/java/com/iflytop/sgs/app/service/device/DeviceInitService.java
  10. 4
      src/main/java/com/iflytop/sgs/app/ws/client/DeviceEmergencyStopConfig.java
  11. 4
      src/main/resources/sql/init.sql

2
src/main/java/com/iflytop/sgs/app/cmd/debug/DebugDoorOpenCommand.java

@ -31,7 +31,7 @@ public class DebugDoorOpenCommand extends BaseCommandHandler {
@Override @Override
public CompletableFuture<Void> handle(CmdDTO cmdDTO) { public CompletableFuture<Void> handle(CmdDTO cmdDTO) {
Double speed = cmdDTO.getDoubleParam("speed"); Double speed = cmdDTO.getDoubleParam("speed");
DevicePosition devicePosition = devicePositionService.getPosition(DevicePositionCode.doorOpen);
DevicePosition devicePosition = devicePositionService.getPosition(DevicePositionCode.doorOpenPosition);
return runAsync(() -> { return runAsync(() -> {
if (speed != null) { if (speed != null) {
DeviceCommandBundle doorSetDeviceCommandBundle = DeviceCommandGenerator.doorSet(speed); DeviceCommandBundle doorSetDeviceCommandBundle = DeviceCommandGenerator.doorSet(speed);

4
src/main/java/com/iflytop/sgs/app/controller/AuthController.java

@ -35,7 +35,7 @@ public class AuthController {
public Result<User> login(@Valid @RequestBody LoginDTO loginDTO) { public Result<User> login(@Valid @RequestBody LoginDTO loginDTO) {
User user = userService.getOne(new LambdaQueryWrapper<>(User.class).eq(User::getUsername, loginDTO.getUsername())); User user = userService.getOne(new LambdaQueryWrapper<>(User.class).eq(User::getUsername, loginDTO.getUsername()));
if (user != null && !Objects.equals(user.getDeleted(), Deleted.ENABLE) && user.getPassword().equals(loginDTO.getPassword())) { if (user != null && !Objects.equals(user.getDeleted(), Deleted.ENABLE) && user.getPassword().equals(loginDTO.getPassword())) {
deviceStateService.setCurrentUser(user);
deviceStateService.getDeviceState().setCurrentUser(user);
user.setPassword(null); user.setPassword(null);
return Result.success(user); return Result.success(user);
} }
@ -45,7 +45,7 @@ public class AuthController {
@Operation(summary = "用户登出") @Operation(summary = "用户登出")
@PostMapping("/logout") @PostMapping("/logout")
public Result<String> logout() { public Result<String> logout() {
deviceStateService.setCurrentUser(null);
deviceStateService.getDeviceState().setCurrentUser(null);
return Result.success(); return Result.success();
} }

4
src/main/java/com/iflytop/sgs/app/controller/SelfTestController.java

@ -31,7 +31,7 @@ public class SelfTestController {
@Operation(summary = "自检完毕") @Operation(summary = "自检完毕")
@PostMapping("/finish") @PostMapping("/finish")
public Result<?> selfTestFinish() throws Exception { public Result<?> selfTestFinish() throws Exception {
deviceStateService.setSelfTest(true);
deviceStateService.getDeviceState().setSelfTest(true);
new Thread(() -> { new Thread(() -> {
try { try {
//deviceCommandUtilService.capMotorMove(21); //deviceCommandUtilService.capMotorMove(21);
@ -44,7 +44,7 @@ public class SelfTestController {
@Operation(summary = "改变自检状态") @Operation(summary = "改变自检状态")
@PostMapping("/isFinish") @PostMapping("/isFinish")
public Result<?> selfTestFinish(boolean isFinish) throws Exception { public Result<?> selfTestFinish(boolean isFinish) throws Exception {
deviceStateService.setSelfTest(isFinish);
deviceStateService.getDeviceState().setSelfTest(isFinish);
new Thread(() -> { new Thread(() -> {
try { try {
//deviceCommandUtilService.capMotorMove(21); //deviceCommandUtilService.capMotorMove(21);

8
src/main/java/com/iflytop/sgs/app/model/bo/status/device/DeviceState.java

@ -70,5 +70,13 @@ public class DeviceState {
} }
return null; return null;
} }
public synchronized TrayState getTrayState(String trayUUID) {
for (TrayState t : trays) {
if (t.getUuid().equals(trayUUID)) {
return t;
}
}
return null;
}
} }

7
src/main/java/com/iflytop/sgs/app/service/api/HeatService.java

@ -1,5 +1,6 @@
package com.iflytop.sgs.app.service.api; package com.iflytop.sgs.app.service.api;
import com.iflytop.sgs.app.model.bo.status.device.HeatModuleState;
import com.iflytop.sgs.app.model.vo.SetHeatModuleEnableVO; import com.iflytop.sgs.app.model.vo.SetHeatModuleEnableVO;
import com.iflytop.sgs.app.model.vo.SetTargetTemperatureVO; import com.iflytop.sgs.app.model.vo.SetTargetTemperatureVO;
import com.iflytop.sgs.app.service.device.DeviceStateService; import com.iflytop.sgs.app.service.device.DeviceStateService;
@ -15,7 +16,11 @@ public class HeatService {
private final DeviceStateService deviceStateService; private final DeviceStateService deviceStateService;
public void setTargetTemperature(SetTargetTemperatureVO setTargetTemperatureVO) { public void setTargetTemperature(SetTargetTemperatureVO setTargetTemperatureVO) {
deviceStateService.setHeatModuleStatePreSetTemperature(setTargetTemperatureVO.getModuleCode(), setTargetTemperatureVO);
HeatModuleState heatModuleState=deviceStateService.getDeviceState().getHeatModuleByCode(setTargetTemperatureVO.getModuleCode());
heatModuleState.setAnnealTemperature(setTargetTemperatureVO.getAnnealTemperature());
heatModuleState.setDryTemperature(setTargetTemperatureVO.getDryTemperature());
heatModuleState.setHeatTemperature(setTargetTemperatureVO.getHeatTemperature());
} }
public void setEnable(SetHeatModuleEnableVO setHeatModuleEnableVO){ public void setEnable(SetHeatModuleEnableVO setHeatModuleEnableVO){

2
src/main/java/com/iflytop/sgs/app/service/api/SystemConfigService.java

@ -21,8 +21,6 @@ import java.io.InputStreamReader;
@RequiredArgsConstructor @RequiredArgsConstructor
public class SystemConfigService extends ServiceImpl<SystemConfigMapper, SystemConfig> { public class SystemConfigService extends ServiceImpl<SystemConfigMapper, SystemConfig> {
private final SystemConfigMapper systemConfigMapper;
private final DeviceStateService deviceStateService;
/** /**
* 设置系统日期和时间 * 设置系统日期和时间

4
src/main/java/com/iflytop/sgs/app/service/api/TasksService.java

@ -66,7 +66,7 @@ public class TasksService extends ServiceImpl<TasksMapper, Tasks> {
taskSteps.setTaskId(tasks.getId()); taskSteps.setTaskId(tasks.getId());
taskSteps.setStepDescription("开始实验"); taskSteps.setStepDescription("开始实验");
taskStepsService.save(taskSteps); taskStepsService.save(taskSteps);
deviceStateService.setCurrentTasks(tasks);
deviceStateService.getDeviceState().setCurrentTasks(tasks);
return tasks; return tasks;
} }
@ -92,7 +92,7 @@ public class TasksService extends ServiceImpl<TasksMapper, Tasks> {
tasks.setStatus(2); tasks.setStatus(2);
tasks.setEndTime(LocalDateTime.now()); tasks.setEndTime(LocalDateTime.now());
this.updateById(tasks); this.updateById(tasks);
deviceStateService.setCurrentTasks(null);
deviceStateService.getDeviceState().setCurrentTasks(null);
} }
} }

10
src/main/java/com/iflytop/sgs/app/service/api/TrayService.java

@ -21,9 +21,9 @@ public class TrayService {
*/ */
public synchronized TrayState trayIn() { public synchronized TrayState trayIn() {
TrayState trayState = new TrayState(); TrayState trayState = new TrayState();
trayState.setInFeed(true);
trayState.setInFeedArea(true);
deviceStateService.getDeviceState().getTrays().add(trayState); deviceStateService.getDeviceState().getTrays().add(trayState);
deviceStateService.setSolutionModuleStateTrayStatus(1);
deviceStateService.getDeviceState().getSolutionModule().setFeedAreaTrayStatus(true);
return trayState; return trayState;
} }
@ -32,15 +32,15 @@ public class TrayService {
*/ */
public synchronized void trayOut() { public synchronized void trayOut() {
List<TrayState> trayList = deviceStateService.getDeviceState().getTrays(); List<TrayState> trayList = deviceStateService.getDeviceState().getTrays();
trayList.removeIf(TrayState::isInSolutionModule);
deviceStateService.setSolutionModuleStateTrayStatus(0);
trayList.removeIf(TrayState::isInSolutionPositon);
deviceStateService.getDeviceState().getSolutionModule().setFeedAreaTrayStatus(false);
} }
/** /**
* 设置托盘试管 * 设置托盘试管
*/ */
public synchronized void setTrayTube(SetTrayTubeVO setTrayTubeVO) { public synchronized void setTrayTube(SetTrayTubeVO setTrayTubeVO) {
TrayState trayState = deviceStateService.getTrayState(setTrayTubeVO.getTrayUuid());
TrayState trayState = deviceStateService.getDeviceState().getTrayState(setTrayTubeVO.getTrayUuid());
trayState.setTubes(setTrayTubeVO.getTubes()); trayState.setTubes(setTrayTubeVO.getTubes());
} }

2
src/main/java/com/iflytop/sgs/app/service/device/DeviceInitService.java

@ -23,7 +23,7 @@ public class DeviceInitService {
Thread.sleep(2000); Thread.sleep(2000);
initDeviceState(); initDeviceState();
initDeviceSetData(); initDeviceSetData();
deviceStateService.setInitComplete(true);
deviceStateService.getDeviceState().setInitComplete(true);
} catch (Exception e) { } catch (Exception e) {
log.error("设备初始化失败", e); log.error("设备初始化失败", e);
} }

4
src/main/java/com/iflytop/sgs/app/ws/client/DeviceEmergencyStopConfig.java

@ -34,13 +34,13 @@ public class DeviceEmergencyStopConfig {
try { try {
commandPoolManager.forceShutdownAll();//强制终止现在运行的所有指令 commandPoolManager.forceShutdownAll();//强制终止现在运行的所有指令
//stepCommandService.stopAll(); //stepCommandService.stopAll();
deviceStateService.setEmergencyStop(true);
deviceStateService.getDeviceState().setEmergencyStop(true);
} catch (Exception e) { } catch (Exception e) {
log.error("设备急停失败:{}", e.getMessage()); log.error("设备急停失败:{}", e.getMessage());
throw new RuntimeException(e); throw new RuntimeException(e);
} }
} else if (s.get("event").equals("release")) { } else if (s.get("event").equals("release")) {
deviceStateService.setEmergencyStop(false);
deviceStateService.getDeviceState().setEmergencyStop(false);
log.info("解除急停{}", s); log.info("解除急停{}", s);
} }
}); });

4
src/main/resources/sql/init.sql

@ -29,7 +29,7 @@ CREATE TABLE IF NOT EXISTS device_position
( (
id INTEGER PRIMARY KEY AUTOINCREMENT, id INTEGER PRIMARY KEY AUTOINCREMENT,
name TEXT, name TEXT,
code TEXT, NOT NULL UNIQUE,
code TEXT NOT NULL UNIQUE,
type TEXT, type TEXT,
position TEXT, position TEXT,
create_time TIMESTAMP DEFAULT CURRENT_TIMESTAMP, create_time TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
@ -40,7 +40,7 @@ CREATE TABLE IF NOT EXISTS device_position
CREATE TABLE IF NOT EXISTS system_config CREATE TABLE IF NOT EXISTS system_config
( (
id INTEGER PRIMARY KEY AUTOINCREMENT, id INTEGER PRIMARY KEY AUTOINCREMENT,
name TEXT
name TEXT,
code TEXT NOT NULL UNIQUE, code TEXT NOT NULL UNIQUE,
value TEXT, value TEXT,
create_time TIMESTAMP DEFAULT CURRENT_TIMESTAMP, create_time TIMESTAMP DEFAULT CURRENT_TIMESTAMP,

Loading…
Cancel
Save