project_boditech_vidas_a8000_v3
/
a8k_app
7
0
Fork 0
Code Issues Pull Requests Projects Releases 1 Wiki Activity
Browse Source

修复一些BUG

master
zhaohe 2 months ago
parent
2f669e2378
commit
586c860833
17 changed files with 63 additions and 256 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Split View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 2
      appenv/restart_chrome.sh
  2. 3
      appenv/start.sh
  3. 15
      appenv/zapp.service
  4. BIN
      bak/20250428-app.db
  5. BIN
      bak/20250429-1app.db
  6. BIN
      bak/20250429-2app.db
  7. BIN
      bak/20250613app.db
  8. BIN
      bak/app20250422-21-18.db
  9. 259
      doc/README/README.md
  10. 2
      sh/deply.bat
  11. 4
      src/main/java/a8k/app/service/analyzer/A8kIdCardDataParseService.java
  12. 20
      src/main/java/a8k/app/service/background/SensorDataUpdateService.java
  13. 2
      src/main/java/a8k/app/service/mainctrl/AppDeviceMainFlowCtrlService.java
  14. 3
      src/main/java/a8k/app/service/mainctrl/MainFlowCtrlScheduler.java
  15. 4
      src/main/java/a8k/app/service/statemgr/ProjectCxtMgr.java
  16. 5
      src/main/resources/application.yml

2
appenv/restart_chrome.sh
View File

@ -0,0 +1,2 @@
killall chromium-bin
/etc/zos/zos_setup.sh &

3
appenv/start.sh
View File

@ -0,0 +1,3 @@
#!/bin/bash
echo "A8000 starting ..."
/iflytop/bin/jdk/bin/java -jar /app/app.jar > /app/app.log 2>&1

15
appenv/zapp.service
View File

@ -0,0 +1,15 @@
[Unit]
# 服务名称，可自定义
Description =A8000
After = network.target
Wants = network.target
[Service]
Type = simple
ExecStart=/app/sh/start.sh
Restart=always
RestartSec=2
WorkingDirectory=/app/
[Install]
WantedBy = multi-user.target

BIN
bak/20250428-app.db
View File

BIN
bak/20250429-1app.db
View File

BIN
bak/20250429-2app.db
View File

BIN
bak/20250429-3app.db → bak/20250613app.db
View File

BIN
bak/app20250422-21-18.db
View File

259
doc/README/README.md
View File

@ -1,259 +1,28 @@
```
TODO:
1. 数据库文件是否被破坏检查
2. 数据库文件如果被破坏，自动恢复默认配置
3. 添加归零保护，底层检测，如果电机未归零就执行moveTo,则报错。
坐标XY方向约定:
0 ----------------------->
| (X)
|
|
|
|
|
v(Y)
舵机位置约定:
抓手
1.夹紧位置为0
2.最大张开位置为300
3.垂直位置70
水平位置
初始位置为0
2.水平移动舵机初始化位置为200(处于设备最后端)
复位要求:
1. 板夹仓推杆电机需要处于零点位置
2. 光学模组推杆电机需要处于零点位置
3. 试管架通道中没有试管架
4. 出料口没有试管架
5. 进出料位置没有试管
逻辑漏洞
1.高试管如果脱帽，会被识别成低试管。
TODO:
1.想办法解决
4:号仓位退不出
14
```
```
<!-- 耗材 -->
<!-- 添加样本 -->
入料:
while(true)
{
}
<!-- startReaction -->
```
```
第一层服务
FrontEndEventRouter 前端事件路由器
用户服务:(OK)
1.添加
2.删除
3.修改
ID卡服务:
1.插入检测，插入事件上报(Service,Fn)
2.删除
3.查询
系统服务:
1.时间修改
2.本机IP
系统配置服务:
1.
设备初始化服务:
设备初始化运行前检查
耗材扫描服务:
样本添加服务:
主运行服务:
入料与预处理控制服务:
滴定
反应
设备运行状态服务:
------------------------------------------------
第二层服务:
硬件层
光学标定服务:
报表打印服务:
开机---> 设备不动
service
core_service
event_bus
app_service
hardware_service
setting_service
appSettingService
TODO:
初始化服务
物料扫描服务
入料服务
预处理服务
孵育服务
取样与反应服务
```
```
```
```
动作:
入料并扫描
准备下一个样本
条件: 当前正在处理的样本处理完成 &&
急诊位Pending | 还有剩余试管未处理
部署说明:
0. 设置好application.properties中的配置项
1. 使用maven打包
2. 将app.jar拷贝到 /app/
3. 将appresource拷贝 到 /app/, (注意,如果是从git上下载下来的工程,需要拷贝bak目录下的最新的app.db到/app/appresource/db/目录下)
4. 将/appenv/目录下的 start.sh 拷贝到/app/sh/目录下
4. 将/appenv/目录下的 restart_chrome.sh 拷贝到/app/sh/目录下
5. 如果目标机器没有安装jdk,则需要参考 https://iflytop1.feishu.cn/wiki/FjbWwRrm2iIT08k9rkqcztFbnje 安装jdk
6. 如果没有安装 zapp.service 则创建zapp.service
样本处理
BEFORE_PROCESS 预处理A(脱帽，摇匀)
BEFORE_PROCESS 预处理B(hbot取tip头，移动到待机位)
BEFORE_PROCESS 预处理C(推出反应板夹)
PROCESS 处理（取样，处理，滴定）
AFTER_PROCESS 后处理
将反应板推出到光学扫描位
光学扫描
代码规范
1. 什么样的检查写在动作中？
需要进行报错处理的检查写在步骤中
```
scp ./target/a8000-1.jar root@192.168.8.10:/app/app.jar
构建基础目录 ssh root@192.168.8.10 'mkdir /app/appresource/static/ && mkdir /app/appresource/db/ && mkdir /app/sh/'
拷贝数据库 scp ./appresource/db/app.db root@192.168.8.10:/app/appresource/db/
拷贝UI scp -r ./appresource/static/app root@192.168.8.10:/app/appresource/static/
拷贝EXUI scp -r ./appresource/static/exui root@192.168.8.10:/app/appresource/static/
```
任务列表:
0. 重新思考整个系统的状态
1. 尽可能完成整个流程的控制，如果中间缺少某些位置参数，则只修改状态，让整个流程执行下去。
2. 支持急诊位置
3. 根据配置，修改对应的动作的细节，使其支持更多的试管架类型，更多的项目类型。
4. 完善日志
3. 完成剩余动作的校准工作。(取样本，取耗材，滴定，光学扫描，结果分析)
5. 添加温度控制。
5. 支持吸空检测。
6. 支持反应板夹类型检测。
```
```
TODO:
1. 如果当前板夹仓对应位置的耗材批次码没有发生变化，则耗材量不重新初始化。
2. tip头只有在第一次扫描时，才会初始化其数量是满的。
```
```
TODO:
1. 软件启动后读取所有单片机版本号。
2. 添加温度控制服务。（不用向前台提供接口）
3. 扫描耗材时，检查ID卡，同时检查温度是否一致。
4. MainFlowCtrl监听，温度控制异常事件，当发生异常时，主动暂停MainFlowCtrl
5. 打印结果
6. 支持扫码枪
添加DEBUG模式，
需要模拟硬件行为的地方。
1. 耗材扫描
2. 初始化
3. 工作流中的所有动作
需要产生的虚假行为
1. 触发.提供插入一个假的ID卡配置的事件
2. 触发.提供假的耗材配置
3. 触发.提供假的样本
4. 触发.添加一个假的急诊
为前台提供的接口:
设备控制
主流程控制
扫描耗材
添加急诊
开关机
配置:
xxx
xxx
xxx
数据
项目管理
用户接口
事件
...
错误码
...
```
```
TODO:
单片机层添加急停指令，同时添加急停错误。
```
```angular2html
查看服务的日志
journalctl -u zapp.service -n 100

2
sh/deply.bat
View File

@ -17,7 +17,7 @@ scp %JAR_FILE% %REMOTE_USER%@%REMOTE_HOST%:%REMOTE_DIR%%REMOTE_FILE%
@REM scp -r appresource %REMOTE_USER%@%REMOTE_HOST%:/app/
:: 重启远程服务器
ssh %REMOTE_USER%@%REMOTE_HOST% `systemctl start zapp`
@REM ssh %REMOTE_USER%@%REMOTE_HOST% `systemctl start zapp`
:: 判断 SCP 命令是否成功
if %errorlevel% neq 0 (

4
src/main/java/a8k/app/service/analyzer/A8kIdCardDataParseService.java
View File

@ -238,8 +238,8 @@ public class A8kIdCardDataParseService {
// ASSERT_IS_TRUE(idcard.expiryDate.before(new Date()), A8kEcode.APPE_A8K_PROJ_CARD_EXPIRYED, "ID CARD EXPIRY");
ASSERT_IS_TRUE(idcard.lotId.length() == 8, "PARSE LOTID IS ERROR");
ASSERT_IS_TRUE(!idcard.projName.isEmpty(), "PARSE PROJNAME IS ERROR");
ASSERT_IS_TRUE(!idcard.lotId.isEmpty(), "LOTID IS EMPTY");
ASSERT_IS_TRUE(!idcard.projName.isEmpty(), "PROJNAME IS EMPTY");
ProjBuildInInfo projBuildinInfo = projInfoMgrService.getProjBuildInInfo(idcard.projId);
ASSERT_IS_TRUE(projBuildinInfo != null, A8kEcode.PROJ_CARD_ERROR_WRONG_UNSUPPORTED, "PROJECT ID %d NOT SUPPORTED", idcard.projId);

20
src/main/java/a8k/app/service/background/SensorDataUpdateService.java
View File

@ -97,6 +97,18 @@ public class SensorDataUpdateService {
}
synchronized private boolean getRecycleBinOverflowState() throws AppException {
Boolean wasteBinFullFlag0 = inputDetectDriver.getIOState(InputIOId.RecycleBinOverflowPPS);
OS.forceSleep(500);
Boolean wasteBinFullFlag1 = inputDetectDriver.getIOState(InputIOId.RecycleBinOverflowPPS);
OS.forceSleep(500);
Boolean wasteBinFullFlag2 = inputDetectDriver.getIOState(InputIOId.RecycleBinOverflowPPS);
OS.forceSleep(500);
Boolean wasteBinFullFlag3 = inputDetectDriver.getIOState(InputIOId.RecycleBinOverflowPPS);
return wasteBinFullFlag0 && wasteBinFullFlag1 && wasteBinFullFlag2 && wasteBinFullFlag3;
}
synchronized public List<TemperatureRecordPoint> getIncubateBoxTemperatureCurve() {
return new ArrayList<>(incubateBoxTemperatureCurve);
}
@ -109,7 +121,7 @@ public class SensorDataUpdateService {
@PostConstruct
public void init() {
updateThread = new Thread(() -> {
OS.forceSleep(3000); //等待webSocket连接
OS.forceSleep(3000);
while (true) {
if (!gStateMgrService.isDeviceInited()) {
@ -134,10 +146,9 @@ public class SensorDataUpdateService {
try {
Boolean wasteBinFullFlag = inputDetectDriver.getIOState(InputIOId.RecycleBinOverflowPPS);
Boolean wasteBinFullFlag = getRecycleBinOverflowState();
gStateMgrService.updateWasteBinFullFlag(wasteBinFullFlag);
OS.forceSleep(100);
Double incubateBoxTemp = temperatureControlDriver.readIncubateBoxTemperature();
gStateMgrService.updateIncubateBoxTemperature((int) (incubateBoxTemp + 0.5));
addIncubateBoxTemperatureCurve(incubateBoxTemp);
@ -152,10 +163,11 @@ public class SensorDataUpdateService {
log.error("Failed to read temperature data {}", e.getMessage());
setErrorFlag(e);
}
if (errorFlag) {
OS.forceSleep(5000);
} else {
OS.forceSleep(1000);
OS.forceSleep(2000);
}
}
});

2
src/main/java/a8k/app/service/mainctrl/AppDeviceMainFlowCtrlService.java
View File

@ -34,7 +34,6 @@ public class AppDeviceMainFlowCtrlService {
public void startWork() throws AppException {
log.info("开始工作");
appWarningFlagStateMgr.clearAllFlagState();
mainFlowCtrlScheduler.startWork();
}
@ -63,7 +62,6 @@ public class AppDeviceMainFlowCtrlService {
public void continueWork() throws AppException {
log.info("继续工作");
appWarningFlagStateMgr.clearAllFlagState();
if (deviceWorkStateMgrService.isMainFlowTaskRun()) {
mainFlowCtrlScheduler.continueWork();
} else if (deviceWorkStateMgrService.isEngineerTaskRun()) {

3
src/main/java/a8k/app/service/mainctrl/MainFlowCtrlScheduler.java
View File

@ -55,6 +55,7 @@ public class MainFlowCtrlScheduler {
private final OptScanModuleLowerCtrlService optScanModuleLowerCtrlService;
private final TubeFeedingCtrlService tubeFeedingCtrlService;
private final AppWarningFlagStateMgr appWarningFlagStateMgr;
private ZWorkThread workThread;
@ -99,6 +100,7 @@ public class MainFlowCtrlScheduler {
}
synchronized public void startWork() throws AppException {
appWarningFlagStateMgr.clearAllFlagState();
startWork(null);
}
@ -121,6 +123,7 @@ public class MainFlowCtrlScheduler {
}
synchronized public void continueWork() throws AppException {
appWarningFlagStateMgr.clearAllFlagState();
checkBeforeCall();
checkBeforeStartOrContinueWork();
deviceWorkStateMgrService.setResumeActionPending(true);

4
src/main/java/a8k/app/service/statemgr/ProjectCxtMgr.java
View File

@ -11,10 +11,10 @@ import java.util.Map;
@Slf4j
public class ProjectCxtMgr {
static public class ProjectCxt {
public Map<String, Object> cxtMap;
public Map<String, Object> cxtMap = new java.util.HashMap<>();
}
Map<String, ProjectCxt> projectCxtMap;
Map<String, ProjectCxt> projectCxtMap = new java.util.HashMap<>();
synchronized public Object getCxtValue(String cxtId, String key) {
ProjectCxt projectCxt = projectCxtMap.get(cxtId);

5
src/main/resources/application.yml
View File

@ -7,6 +7,11 @@ device.runmode: "RealMode"
iflytophald.ip: 192.168.8.10
#server.port: 80
#device.runmode: "RealMode"
#iflytophald.ip: 127.0.0.1
a8k.enableTemperatureCtrl: false
device.enableCanBus: true

Write Preview
Loading…
Cancel
Save