From a383a31892e2d3c43771f0d96eacba819411dc9b Mon Sep 17 00:00:00 2001
From: jiangping <jp@doumee.com>
Date: 星期三, 07 五月 2025 19:26:02 +0800
Subject: [PATCH] 最新版本541200007
---
server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/hksync/HkSyncPushServiceImpl.java | 106 +++++++++++++++++++++++++++++++++++++++++-----------
1 files changed, 83 insertions(+), 23 deletions(-)
diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/hksync/HkSyncPushServiceImpl.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/hksync/HkSyncPushServiceImpl.java
index 0806679..b8f27dc 100644
--- a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/hksync/HkSyncPushServiceImpl.java
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/hksync/HkSyncPushServiceImpl.java
@@ -239,14 +239,15 @@
record.setCreateDate(DateUtil.getISO8601DateByStr2(request.getHappenTime()));
record.setTimeInfo(Utils.Date.getStart(record.getCreateDate()));
record.setType(Constants.ONE);//浜哄憳
- record.setMemberType(Constants.ZERO);//榛樿涓烘湭鐭ヤ汉鍛橈紙璁垮锛�
+ record.setDeviceName(request.getSrcName());
+ record.setMemberType(Constants.RetentionMemberType.fk);//榛樿涓烘湭鐭ヤ汉鍛橈紙璁垮锛�
record.setIsdeleted(Constants.ZERO);
- record.setInOrOut(Constants.ZERO);
record.setHkEventId(request.getEventId());
record.setHkId(userNo);
if(d!=null && Constants.equalsInteger(d.getIsEntrance(),Constants.ONE)){
- if(Constants.formatIntegerNum(request.getData().getExtEventInOut()) != Constants.ONE){
+ if(Constants.formatIntegerNum(request.getData().getExtEventInOut()) == Constants.ONE){
//濡傛灉鏄繘闂紝褰曞叆浜哄憳鐨勫湪鍦烘暟鎹褰�
+ record.setInOrOut(Constants.ZERO);
inoutDayCount.setInMemberNum(Constants.formatIntegerNum(inoutDayCount.getInMemberNum())+1);//鍏ュ満浜烘
}else{
//濡傛灉鏄嚭闂�
@@ -255,10 +256,11 @@
}
}
if(member !=null){
+ record.setMemberId(member.getId());
record.setMemberName(member.getName());
+ record.setMemberPhone(member.getPhone());
record.setObjId(member.getId());
record.setObjType(Constants.ONE);
- record.setMemberPhone(member.getPhone());
record.setCompanyId(member.getCompanyId());
record.setCompanyName(member.getCompanyNamePath());
if(d!=null && Constants.equalsInteger(d.getIsEntrance(),Constants.ONE)){
@@ -267,22 +269,26 @@
//濡傛灉鏄繘闂紝褰曞叆浜哄憳鐨勫湪鍦烘暟鎹褰�
retentionList.add(getRetentionModelByRequest(member,request));
if(Constants.equalsInteger(member.getCompanyType(),Constants.ONE)){
- record.setMemberType(Constants.ONE);
+ record.setMemberType(Constants.RetentionMemberType.internalMember);
inoutDayCount.setInSelfMemberNum(Constants.formatIntegerNum(inoutDayCount.getInSelfMemberNum())+1);//鍐呴儴浜哄憳鍏ュ満浜烘
}else{
- record.setMemberType(Constants.TWO);
+ record.setMemberType(Constants.RetentionMemberType.relMember);
inoutDayCount.setInOtherMemberNum(Constants.formatIntegerNum(inoutDayCount.getInOtherMemberNum())+1);//鐩稿叧鏂瑰叆鍦轰汉娆�
}
}else{
if(Constants.equalsInteger(member.getCompanyType(),Constants.ONE)){
+ record.setMemberType(Constants.RetentionMemberType.internalMember);
inoutDayCount.setOutSelfMemberNum(Constants.formatIntegerNum(inoutDayCount.getOutSelfMemberNum())+1);//鍐呴儴浜哄憳鍑哄満浜烘
}else{
+ record.setMemberType(Constants.RetentionMemberType.relMember);
inoutDayCount.setOutOtherMemberNum(Constants.formatIntegerNum(inoutDayCount.getOutOtherMemberNum())+1);//鐩稿叧鏂瑰嚭鍦轰汉娆�
}
}
}
+ if(record.getMemberType()!=null){
+ inoutRecordList.add(record);
+ }
}
- inoutRecordList.add(record);
}
}
@@ -562,19 +568,38 @@
//濡傛灉浜哄憳淇℃伅瀛樺湪锛屽垏鏄瀹㈤�氳锛屽垯鍒犻櫎涔嬪墠鐨勬墍鏈夎繘鍦烘暟鎹紙鏃犺姝ゆ鎺ㄩ�佹槸杩涘巶杩樻槸鍑哄満鎺ㄩ�佷簨浠讹級
delRetentionLis.add(visits.getMemberId());
InoutRecord record = new InoutRecord();
+ record.setDeviceName((request.getData()!=null &&request.getData().getParamValues()!=null)?
+ request.getData().getParamValues().getSrcName():request.getSrcName());
record.setCreateDate(DateUtil.getISO8601DateByStr2(request.getHappenTime()));
record.setTimeInfo(Utils.Date.getStart(record.getCreateDate()));
record.setType(Constants.ONE);//浜哄憳
record.setMemberType(Constants.ZERO);
record.setIsdeleted(Constants.ZERO);
record.setMemberName(visits.getName());
+ record.setCarCode(request.getData().getVisitorInformationList().get(0).getPlateNo());
record.setObjId(visits.getId());
+ record.setMemberId(visits.getMemberId());
record.setObjType(Constants.TWO);
record.setMemberPhone(visits.getPhone());
record.setCompanyName(visits.getCompanyName());
record.setInOrOut(Constants.ZERO);
record.setHkEventId(request.getEventId());
record.setHkId(visits.getHkId());
+ Category category = null;
+ if(StringUtils.isNotBlank(record.getCarCode())){
+ category = categoryMapper.selectJoinOne(Category.class, new MPJLambdaWrapper<Category>()
+ .selectAll(Category.class)
+ .select("t4.name",Category::getParentName)
+ .leftJoin("category t4 on t.parent_id=t4.id")
+ .eq(Category::getIsdeleted,Constants.ZERO)
+ .eq(Category::getBizType,Constants.RetentionCarType.fkCar)
+ .last("limit 1"));
+ if(category ==null){
+ category = new Category();
+ category.setName("璁垮杞﹁締");
+ }
+ category.setParentName(StringUtils.defaultString(category.getParentName(),"璁垮杞﹁締"));
+ }
//濡傛灉鏄瀹㈤�氳
if(request.getData()!=null&&request.getData().getParamValues()!=null &&
StringUtils.equals(request.getData().getParamValues().getInOrOut(),"0")){
@@ -591,6 +616,20 @@
!StringUtils.equals(request.getData().getParamValues().getInOrOut(),"0")){
inoutDayCount.setOutVisitorNum(Constants.formatIntegerNum(inoutDayCount.getOutVisitorNum())+1);
record.setInOrOut(Constants.ONE);
+ }
+ if(record.getCarCode()!=null){
+ record.setCarBizType(Constants.RetentionCarType.fkCar);
+ record.setCategoryId(category.getId());
+ record.setCategoryName(category.getName());
+ record.setCategoryParentId(category.getParentId());
+ record.setCategoryParentName(category.getParentName());
+ record.setRemark("璁垮璺熼殢杞﹁締绂诲洯骞惰嚜鍔ㄧ绂�");
+ try {
+ //璁垮鐢宠鑷姩绛剧
+ visitsService.visitLevelForCarOut(visits);
+ }catch (Exception e){
+ log.error("璁垮璺熼殢杞﹁締鍑哄洯鑷姩绛剧澶辫触锛�==========="+e.getMessage());
+ }
}
inoutRecordList.add(record);
}
@@ -893,6 +932,7 @@
carrecord.setType(Constants.ZERO);//杞﹁締
carrecord.setIsdeleted(Constants.ZERO);
carrecord.setObjType(Constants.ZERO);
+ carrecord.setDeviceName(request.getData().getGateName()+request.getData().getRoadwayName());//鍋滆溅鍦哄拰鍑哄叆鍙�
carrecord.setHkEventId(request.getEventId());
carrecord.setCarCode(event.getPlateNos());
Cars carModel = carsMapper.selectJoinOne(Cars.class,new MPJLambdaWrapper<Cars>()
@@ -922,11 +962,12 @@
event.setMemberId(carModel.getMemberId());
event.setCompanyId(carModel.getGroupId());
//-----------------20250429鏀归��----start---------------
- event.setCarType(carModel.getBizType());//杞﹁締涓氬姟绫诲瀷
+ event.setCarType(carModel.getBizType()==null?Constants.RetentionCarType.self : carModel.getBizType());//杞﹁締涓氬姟绫诲瀷
carrecord.setObjType(Constants.FOUR);
carrecord.setMemberName(carModel.getMemberName());//鍙告満
carrecord.setMemberPhone(carModel.getMemberPhone());//鍙告満
carrecord.setObjId(carModel.getId());
+ carrecord.setMemberId(carModel.getMemberId());
carrecord.setObjType(Constants.ZERO);
carrecord.setFaceImg(carModel.getFaceImg());
carrecord.setIdcardDecode(carModel.getIdcardDecode());
@@ -937,8 +978,8 @@
carrecord.setCategoryId(carModel.getCateId());
carrecord.setCategoryName(carModel.getCateName());
carrecord.setCategoryParentId(carModel.getCatePId());
- carrecord.setCategoryParentName(carModel.getCatePName());
- carrecord.setMemberType( Constants.RetentionMemberType.car);//鍙槸杞﹁締鐨勮褰�
+ carrecord.setCategoryParentName(StringUtils.defaultString(carModel.getCatePName(),carModel.getCateName()));
+ carrecord.setType( Constants.RetentionMemberType.car);//鍙槸杞﹁締鐨勮褰�
if(carModel.getMemberId()!=null){
if(Constants.equalsInteger(carModel.getCompanyType(),Constants.ONE)){
//鍐呴儴缁勭粐
@@ -976,7 +1017,7 @@
carrecord.setObjType(Constants.FOUR);
carrecord.setCompanyId(carTypeJob.getCompanyId());
carrecord.setCompanyName(carTypeJob.getCompanyNamePath());
- carrecord.setMemberType(Constants.RetentionMemberType.car);
+ carrecord.setType(Constants.RetentionMemberType.car);
if(carModel.getMemberPhone()!=null || StringUtils.isNotBlank(carModel.getMemberName())){
//璐ц繍鍙告満(濡傛灉鍙告満鎵嬫満鍙锋垨鑰呭鍚嶄笉涓虹┖锛�
carrecord.setMemberType(Constants.RetentionMemberType.driver);
@@ -1016,7 +1057,7 @@
//濡傛灉鏄叆鍘傛斁琛�
delRetentionList.add(event.getPlateNos());
delMemberRetentionList.add(event.getMemberId());
- retentionList.add(getRetentionModelByParkRequest(request,event));//鍦ㄥ巶杞﹁締淇℃伅
+ retentionList.add(getRetentionModelByParkRequest(request,event,carrecord));//鍦ㄥ巶杞﹁締淇℃伅
inoutDayCount.setInCarNum(Constants.formatIntegerNum(inoutDayCount.getInCarNum())+1);
carrecord.setInOrOut(Constants.ZERO);
}else if(Constants.formatIntegerNum(request.getEventType()) == HKConstants.EventTypes.PARK_PASS_OUT.getKey()){
@@ -1024,10 +1065,10 @@
delRetentionList.add(event.getPlateNos());
delMemberRetentionList.add(event.getMemberId());
inoutDayCount.setOutCarNum(Constants.formatIntegerNum(inoutDayCount.getOutCarNum())+1);
- carrecord.setInOrOut(Constants.ZERO);
+ carrecord.setInOrOut(Constants.ONE);
}
//杞﹁締杩涘叆璁板綍瀵瑰簲涓氬姟绫诲瀷
- if(event.getCarType() ==null || event.getCarType().equals(Constants.RetentionCarType.other)){
+ if(1==2 && isCarInOrOutEvent(request) &&( event.getCarType() ==null || event.getCarType().equals(Constants.RetentionCarType.other))){
//濡傛灉鏈瘑鍒埌杞﹀瀷锛屼笉鏄浐瀹氳溅 涔熶笉鏄揣杩愯溅杈嗭紝鍒欐鏌ユ槸鍚︽槸璁垮杞�
visitsList = visitsMapper.selectList(new QueryWrapper<Visits>().lambda()
.eq(Visits::getCarNos,event.getPlateNos())
@@ -1045,8 +1086,8 @@
carrecord.setCarBizType(Constants.RetentionCarType.fkCar);
Category category =findCategoryByBizType(Constants.RetentionCarType.fkCar,"璁垮杞﹁締","璁垮杞﹁締",categoryList);
carrecord.setCategoryId(category.getId());
- carrecord.setCategoryName(category.getName());
- carrecord.setCategoryParentName(category.getParentName());
+ carrecord.setCategoryName(StringUtils.defaultString(category.getName(),"璁垮杞﹁締"));
+ carrecord.setCategoryParentName(StringUtils.defaultString(category.getParentName(),"璁垮杞﹁締"));
carrecord.setCategoryParentId(category.getParentId());
for(Visits v :visitsList){
delMemberRetentionList.add(event.getMemberId());
@@ -1056,9 +1097,9 @@
copyObj.setMemberName(v.getName());
copyObj.setMemberPhone(v.getPhone());
copyObj.setCompanyName(v.getCompanyName());
- copyObj.setMemberType(Constants.ZERO);
- copyObj.setRemark(carrecord.getCarCode());
- copyObj.setCarCode(index>=0?null:carrecord.getCarCode());
+ copyObj.setType(Constants.ONE);
+ copyObj.setRemark("璁垮璺熼殢杞﹁締銆�"+carrecord.getCarCode()+"銆戠鍥�");
+ copyObj.setCarCode(index>0?null:carrecord.getCarCode());
copyObj.setMemberType(Constants.RetentionMemberType.fk);
inoutRecordList.add(copyObj);
index++;
@@ -1082,12 +1123,20 @@
}
}
}
- if(event.getCarType() !=null && !event.getCarType().equals(Constants.RetentionCarType.fkCar)){
+ if(isCarInOrOutEvent(request) && event.getCarType() !=null && !event.getCarType().equals(Constants.RetentionCarType.fkCar)){
//褰曞叆闈炶瀹㈢被鍨嬭溅杈嗚繘鍑鸿褰�
dealNotFkCarMemberBiz(event,request,carrecord,retentionList,inoutDayCount,inoutRecordList);
}
}
return event;
+ }
+
+ private boolean isCarInOrOutEvent(EventParkInfoRequest request) {
+ if(Constants.formatIntegerNum(request.getEventType()) == HKConstants.EventTypes.PARK_PASS_IN.getKey() ||
+ Constants.formatIntegerNum(request.getEventType()) == HKConstants.EventTypes.PARK_PASS_OUT.getKey()){
+ return true;
+ }
+ return false;
}
private void dealNotFkCarMemberBiz( CarEvent event ,EventParkInfoRequest request, InoutRecord carrecord,List<Retention> retentionList,InoutDayCount inoutDayCount,List<InoutRecord> inoutRecordList) {
@@ -1109,7 +1158,7 @@
}
//缁熻浠婃棩鍏ュ洯鎬讳汉娆�
inoutDayCount.setInMemberNum(Constants.formatIntegerNum(inoutDayCount.getInMemberNum())+1);
- }else if(carrecord.getMemberId()!=null && Constants.equalsInteger(carrecord.getInOrOut(),Constants.ONE)) {
+ }else if( Constants.equalsInteger(carrecord.getInOrOut(),Constants.ONE)) {
//濡傛灉鏄嚭鍥尯
if(Constants.equalsInteger(carrecord.getMemberType(),Constants.RetentionMemberType.relMember)){
//濡傛灉鏄浉鍏虫柟锛岀粺璁′粖鏃ョ疮璁℃暟
@@ -1122,6 +1171,10 @@
inoutDayCount.setOutMemberNum(Constants.formatIntegerNum(inoutDayCount.getOutMemberNum())+1);
}
}
+ if(Constants.equalsInteger(carrecord.getCarBizType(),Constants.RetentionCarType.other)){
+ carrecord.setCategoryName("鏈煡杞﹁締");//榛樿鏈煡杞﹁締
+ carrecord.setCategoryParentName("鏈煡杞﹁締");//榛樿鏈煡杞﹁締
+ }
inoutRecordList.add(carrecord);//褰曞叆杞﹁締浠ュ強鎼哄甫浜哄憳鐨勫叆鍥槑缁嗚褰曪紙闈炶瀹級
}
@@ -1129,6 +1182,9 @@
if(categoryList!=null){
for(Category category :categoryList){
if(Constants.equalsInteger(carType,category.getBizType())){
+ if(StringUtils.isBlank(category.getParentName() )){
+ category.setParentName(category.getName());
+ }
return category;
}
}
@@ -1208,7 +1264,6 @@
event.setSrcName(request.getSrcName());
event.setSrcIndex(request.getSrcIndex());
event.setRoadwayType(request.getData().getRoadwayType());
- event.setRoadwayName(request.getData().getRoadwayName());
event.setRoadwayIndex(request.getData().getRoadwayIndex());
event.setPlateType(request.getData().getPlateType());
event.setTimeout(request.getTimeout());
@@ -1221,6 +1276,7 @@
event.setInoutType(request.getData().getInoutType());
event.setHappenTime(request.getHappenTime());
event.setGateName(request.getData().getGateName());
+ event.setRoadwayName(request.getData().getRoadwayName());
event.setGateIndex(request.getData().getGateIndex());
event.setEventType(request.getEventType());
event.setEventIndex(request.getData().getEventIndex());
@@ -1306,7 +1362,7 @@
retention.setRemark("璺熼殢杞﹁締鍏ュ洯鍖�");
return retention;
}
- private Retention getRetentionModelByParkRequest(EventParkInfoRequest request,CarEvent event ) {
+ private Retention getRetentionModelByParkRequest(EventParkInfoRequest request,CarEvent event ,InoutRecord carrecord ) {
Retention retention = new Retention();
retention.setIsdeleted(Constants.ZERO);
retention.setCreateDate(DateUtil.getISO8601DateByStr(request.getHappenTime()));
@@ -1315,6 +1371,10 @@
retention.setMemberId(event.getMemberId());
retention.setCarType(event.getCarType());
retention.setCompanyId(event.getCompanyId());
+ retention.setCategoryId(carrecord.getCategoryId());
+ retention.setCategoryName(carrecord.getCategoryName());
+ retention.setCategoryParentId(carrecord.getCategoryParentId());
+ retention.setCategoryParentName(carrecord.getCategoryParentName());
// retention.setDeviceName(request.getSrcName());
// retention.setDeviceIndex(request.getSrcIndex());
--
Gitblit v1.9.3