From ea67477738d7a4f1988f41815668fb871a6e2101 Mon Sep 17 00:00:00 2001
From: wuxw <928255095@qq.com>
Date: 星期六, 25 一月 2020 23:51:14 +0800
Subject: [PATCH] 加入进场记录详情
---
Api/src/main/java/com/java110/api/listener/machineTranslate/MachineRoadGateOpenListener.java | 47 ++++++++++++++++++++++++++++++++++++++++++++++-
1 files changed, 46 insertions(+), 1 deletions(-)
diff --git a/Api/src/main/java/com/java110/api/listener/machineTranslate/MachineRoadGateOpenListener.java b/Api/src/main/java/com/java110/api/listener/machineTranslate/MachineRoadGateOpenListener.java
index af426da..6118793 100644
--- a/Api/src/main/java/com/java110/api/listener/machineTranslate/MachineRoadGateOpenListener.java
+++ b/Api/src/main/java/com/java110/api/listener/machineTranslate/MachineRoadGateOpenListener.java
@@ -3,12 +3,15 @@
import com.alibaba.fastjson.JSONObject;
import com.java110.core.annotation.Java110Listener;
import com.java110.core.context.DataFlowContext;
+import com.java110.core.smo.hardwareAdapation.ICarBlackWhiteInnerServiceSMO;
import com.java110.core.smo.hardwareAdapation.IMachineInnerServiceSMO;
+import com.java110.dto.hardwareAdapation.CarBlackWhiteDto;
import com.java110.dto.hardwareAdapation.MachineDto;
import com.java110.event.service.api.ServiceDataFlowEvent;
import com.java110.utils.constant.ServiceCodeMachineTranslateConstant;
import com.java110.utils.util.Assert;
import com.java110.utils.util.StringUtil;
+import com.java110.vo.api.machine.MachineResDataVo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpMethod;
@@ -29,8 +32,18 @@
@Java110Listener("machineRoadGateOpenListener")
public class MachineRoadGateOpenListener extends BaseMachineListener {
+ private static final String MACHINE_DIRECTION_IN = "3306"; // 杩涘叆
+
+ private static final String MACHINE_DIRECTION_OUT = "3307"; //鍑哄幓
+
+ private static final String CAR_BLACK = "1111"; // 杞﹁締榛戝悕鍗�
+ private static final String CAR_WHITE = "2222"; // 杞﹁締鐧藉悕鍗�
+
@Autowired
private IMachineInnerServiceSMO machineInnerServiceSMOImpl;
+
+ @Autowired
+ private ICarBlackWhiteInnerServiceSMO carBlackWhiteInnerServiceSMOImpl;
@Override
protected void validate(ServiceDataFlowEvent event, JSONObject reqJson) {
@@ -66,8 +79,40 @@
outParam.put("message", "璇ヨ澶囥��" + machineCode + "銆戞湭鍦ㄨ灏忓尯銆�" + communityId + "銆戞敞鍐�");
responseEntity = new ResponseEntity<>(outParam.toJSONString(), headers, HttpStatus.OK);
context.setResponseEntity(responseEntity);
- return ;
+ return;
}
+ //璁惧鏂瑰悜
+ String direction = machineDtos.get(0).getDirection();
+
+ //杩涘叆
+ if (MACHINE_DIRECTION_IN.equals(direction)) {
+ dealCarIn(context, reqJson, machineDtos.get(0), communityId, machineCode);
+ }
+
+ }
+
+ /**
+ * 澶勭悊杞﹁締杩涘叆
+ *
+ * @param reqJson
+ * @param machineDto
+ * @param communityId
+ * @param machineCode
+ */
+ private void dealCarIn(DataFlowContext context, JSONObject reqJson, MachineDto machineDto, String communityId, String machineCode) {
+ //杞﹁締鏄惁榛戝悕鍗� 杞﹁締
+ String carNum = reqJson.getString("carNum");
+ CarBlackWhiteDto carBlackWhiteDto = new CarBlackWhiteDto();
+ carBlackWhiteDto.setCommunityId(communityId);
+ carBlackWhiteDto.setCarNum(carNum);
+ carBlackWhiteDto.setBlackWhite(CAR_BLACK);
+ int count = carBlackWhiteInnerServiceSMOImpl.queryCarBlackWhitesCount(carBlackWhiteDto);
+ if (count > 0) {
+ context.setResponseEntity(MachineResDataVo.getResData(MachineResDataVo.CODE_ERROR, carNum + "琚姞鍏ラ粦鍚嶅崟锛屾棤娉曟斁琛�"));
+ return;
+ }
+
+
}
--
Gitblit v1.8.0