This commit is contained in:
2023-02-18 16:24:19 +08:00
parent 78aff07101
commit 2e70333818
3 changed files with 23 additions and 16 deletions

View File

@@ -134,7 +134,7 @@ public class PaintConveyorDeviceDriver extends AbstractOpcDeviceDriver implement
message = "有报警"; message = "有报警";
//无报警 //无报警
} else { } else {
System.out.println("进入到else。。。。。"); System.out.println("进入到else。。。。。设备号:" + device_code + ",mode = " + mode);
this.setIsonline(true); this.setIsonline(true);
this.setIserror(false); this.setIserror(false);
JSONObject jo = new JSONObject(); JSONObject jo = new JSONObject();
@@ -146,42 +146,46 @@ public class PaintConveyorDeviceDriver extends AbstractOpcDeviceDriver implement
//下料位申请空盘 //下料位申请空盘
if (move == 0 && !requireSucess) { if (move == 0 && !requireSucess) {
//向LMS发送请求发送终点和托盘类型 //向LMS发送请求发送终点和托盘类型
jo.put("type","3"); jo.put("type", "3");
jo.put("point_code",device_code); jo.put("point_code", device_code);
jo.put("vehicle_num","10"); jo.put("vehicle_num", "10");
String result = acsToWmsService.applyTaskToWms(jo); String result = acsToWmsService.applyTaskToWms(jo);
JSONObject res_jo = JSONObject.parseObject(result); JSONObject res_jo = JSONObject.parseObject(result);
if (res_jo.getString("status").equals("200")){ if (res_jo.getString("status").equals("200")) {
requireSucess = true; requireSucess = true;
} }
} }
break;
case 6: case 6:
//下料位满拖申请 //下料位满拖申请
logServer.deviceExecuteLog(this.device_code, "", "", "下料位满拖申请,此时:move == " + move + ",请求标记为:" + requireSucess); logServer.deviceExecuteLog(this.device_code, "", "", "下料位满拖申请,此时:move == " + move + ",请求标记为:" + requireSucess);
if (move == 1 && !requireSucess) { if (move == 1 && !requireSucess) {
//向LMS发送请求发送起点 //向LMS发送请求发送起点
jo.put("type","7"); jo.put("type", "7");
jo.put("point_code",device_code); jo.put("point_code", device_code);
String result = acsToWmsService.applyTaskToWms(jo); String result = acsToWmsService.applyTaskToWms(jo);
JSONObject res_jo = JSONObject.parseObject(result); JSONObject res_jo = JSONObject.parseObject(result);
if (res_jo.getString("status").equals("200")){ if (res_jo.getString("status").equals("200")) {
requireSucess = true; requireSucess = true;
} }
} }
break;
case 7: case 7:
logServer.deviceExecuteLog(this.device_code, "", "", "上料位满拖申请,此时:move == " + move + ",请求标记为:" + requireSucess);
//上料位满拖申请 //上料位满拖申请
if (move == 0 && !requireSucess) { if (move == 0 && !requireSucess) {
//向LMS发送请求发送起点 //向LMS发送请求发送起点
jo.put("type","4"); jo.put("type", "4");
jo.put("point_code",device_code); jo.put("point_code", device_code);
String result = acsToWmsService.applyTaskToWms(jo); String result = acsToWmsService.applyTaskToWms(jo);
JSONObject res_jo = JSONObject.parseObject(result); JSONObject res_jo = JSONObject.parseObject(result);
if (res_jo.getString("status").equals("200")){ if (res_jo.getString("status").equals("200")) {
requireSucess = true; requireSucess = true;
} }
} }
break; break;
case 8: case 8:
logServer.deviceExecuteLog(this.device_code, "", "", "上料位空托入库,此时:move == " + move + ",请求标记为:" + requireSucess);
if (move == 1 && !requireSucess) { if (move == 1 && !requireSucess) {
//上料位空托入库 //上料位空托入库
jo.put("type", "5"); jo.put("type", "5");
@@ -189,12 +193,13 @@ public class PaintConveyorDeviceDriver extends AbstractOpcDeviceDriver implement
jo.put("vehicle_num", number); jo.put("vehicle_num", number);
String result = acsToWmsService.applyTaskToWms(jo); String result = acsToWmsService.applyTaskToWms(jo);
JSONObject res_jo = JSONObject.parseObject(result); JSONObject res_jo = JSONObject.parseObject(result);
if (res_jo.getString("status").equals("200")){ if (res_jo.getString("status").equals("200")) {
requireSucess = true; requireSucess = true;
} }
break; break;
} }
case 9: case 9:
logServer.deviceExecuteLog(this.device_code, "", "", "强制满垛入库,此时:move == " + move + ",请求标记为:" + requireSucess);
if (move == 1 && !requireSucess) { if (move == 1 && !requireSucess) {
//强制满垛入库 //强制满垛入库
jo.put("type", "5"); jo.put("type", "5");
@@ -202,7 +207,7 @@ public class PaintConveyorDeviceDriver extends AbstractOpcDeviceDriver implement
jo.put("vehicle_num", number); jo.put("vehicle_num", number);
String result = acsToWmsService.applyTaskToWms(jo); String result = acsToWmsService.applyTaskToWms(jo);
JSONObject res_jo = JSONObject.parseObject(result); JSONObject res_jo = JSONObject.parseObject(result);
if (res_jo.getString("status").equals("200")){ if (res_jo.getString("status").equals("200")) {
requireSucess = true; requireSucess = true;
} }
break; break;

View File

@@ -6,11 +6,13 @@ public interface ExecutableDeviceDriver extends DeviceDriver {
default void executeAuto() { default void executeAuto() {
try { try {
this.execute(); this.execute();
} catch (Throwable var6) { } catch (Exception e) {
String message = "线程调用异常:" + var6.getMessage(); String message = "线程调用异常:" + e.getMessage();
e.printStackTrace();
} finally { } finally {
} }
} }
void execute() throws Exception; void execute() throws Exception;

View File

@@ -144,7 +144,7 @@ https://juejin.cn/post/6844903775631572999
<appender-ref ref="asyncFileAppender"/> <appender-ref ref="asyncFileAppender"/>
<appender-ref ref="lokiAppender" /> <appender-ref ref="lokiAppender" />
</logger> </logger>
<logger name="org.nl.acs.log.service.impl.DeviceExecuteLogServiceImpl" level="ERROR" additivity="false"> <logger name="org.nl.acs.log.service.impl.DeviceExecuteLogServiceImpl" level="INFO" additivity="false">
<appender-ref ref="asyncFileAppender"/> <appender-ref ref="asyncFileAppender"/>
<appender-ref ref="lokiAppender" /> <appender-ref ref="lokiAppender" />
</logger> </logger>