From cd3107ad63c0bf8d17d71962385c05c7f4a68419 Mon Sep 17 00:00:00 2001
From: chengf <2156125618@qq.com>
Date: 星期四, 31 七月 2025 18:42:12 +0800
Subject: [PATCH] 停车道闸系统与物业管理系统接口设计的入口车辆识别接口2025/07/31
---
service-common/src/main/java/com/java110/common/cmd/carInout/SaveCarInoutCmd.java | 40 +++++++++++++++++++++++++++++++++++-----
1 files changed, 35 insertions(+), 5 deletions(-)
diff --git a/service-common/src/main/java/com/java110/common/cmd/carInout/SaveCarInoutCmd.java b/service-common/src/main/java/com/java110/common/cmd/carInout/SaveCarInoutCmd.java
index cbe04d6..f035fb7 100644
--- a/service-common/src/main/java/com/java110/common/cmd/carInout/SaveCarInoutCmd.java
+++ b/service-common/src/main/java/com/java110/common/cmd/carInout/SaveCarInoutCmd.java
@@ -22,7 +22,11 @@
import com.java110.core.event.cmd.Cmd;
import com.java110.core.event.cmd.CmdEvent;
import com.java110.core.factory.GenerateCodeFactory;
+import com.java110.dto.community.CommunityAttrDto;
+import com.java110.dto.community.CommunityDto;
import com.java110.intf.common.ICarInoutV1InnerServiceSMO;
+import com.java110.intf.community.ICommunityInnerServiceSMO;
+import com.java110.intf.community.ICommunityLocationInnerServiceSMO;
import com.java110.po.car.CarInoutPo;
import com.java110.utils.exception.CmdException;
import com.java110.utils.util.Assert;
@@ -31,6 +35,9 @@
import org.slf4j.Logger;
import com.java110.core.log.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+
+import java.util.List;
/**
* 绫昏〃杩帮細淇濆瓨
@@ -52,14 +59,29 @@
@Autowired
private ICarInoutV1InnerServiceSMO carInoutV1InnerServiceSMOImpl;
+ @Autowired
+ private ICommunityInnerServiceSMO communityInnerServiceSMOImpl;
+
@Override
public void validate(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) {
+ Assert.hasKeyAndValue(reqJson, "community_name", "璇锋眰鎶ユ枃涓湭鍖呭惈灏忓尯鍚嶇О");
+ Assert.hasKeyAndValue(reqJson, "plate_number", "璇锋眰鎶ユ枃涓湭鍖呭惈杞︾墝鍙�");
+ Assert.hasKeyAndValue(reqJson, "entry_time", "璇锋眰鎶ユ枃涓湭鍖呭惈杩涘満鏃堕棿");
+ CommunityDto communityDto = new CommunityDto();
+ communityDto.setName(reqJson.getString("community_name"));
+ List<CommunityDto> communityDtos = communityInnerServiceSMOImpl.queryCommunitys(communityDto);
+ if (!(communityDtos == null || communityDtos.size() == 0)) {
+ reqJson.put("communityId",communityDtos.get(0).getCommunityId());
+ }
+ reqJson.put("carNum", reqJson.getString("plate_number"));
Assert.hasKeyAndValue(reqJson, "communityId", "璇锋眰鎶ユ枃涓湭鍖呭惈communityId");
- Assert.hasKeyAndValue(reqJson, "carNum", "璇锋眰鎶ユ枃涓湭鍖呭惈carNum");
- Assert.hasKeyAndValue(reqJson, "state", "璇锋眰鎶ユ枃涓湭鍖呭惈state");
- Assert.hasKeyAndValue(reqJson, "inTime", "璇锋眰鎶ユ枃涓湭鍖呭惈inTime");
- Assert.hasKeyAndValue(reqJson, "paId", "璇锋眰鎶ユ枃涓湭鍖呭惈paId");
+ if (reqJson.containsKey("exit_time")) {
+ reqJson.put("state" , "100500");
+ }else {
+ reqJson.put("state" , "100300");
+ }
+ reqJson.put("inTime", reqJson.getString("entry_time"));
}
@Override
@@ -73,7 +95,15 @@
if (flag < 1) {
throw new CmdException("淇濆瓨鏁版嵁澶辫触");
}
+ JSONObject jsonObject = new JSONObject();
+ jsonObject.put("allow_entry","true");
+ jsonObject.put("message","鍏佽閫氳");
+ jsonObject.put("expire_date","");// 濡傛灉鏄寘鏈堣溅锛岃繑鍥炴湁鏁堟湡
+ ResponseEntity<String> responseEntity = ResponseEntity
+ .ok()
+ .header("Content-Type", "application/json")
+ .body(jsonObject.toString()); // 鍏抽敭锛氱敤toString()杩斿洖鍘熷JSON瀛楃涓�
- cmdDataFlowContext.setResponseEntity(ResultVo.success());
+ cmdDataFlowContext.setResponseEntity(responseEntity);
}
}
--
Gitblit v1.8.0