From d495e97e5f55c02486d8bb205e23aea5760c359f Mon Sep 17 00:00:00 2001
From: jiangping <jp@doumee.com>
Date: 星期一, 04 三月 2024 13:51:40 +0800
Subject: [PATCH] 整理
---
server/dmvisit_service/src/main/java/com/doumee/service/business/impl/hksync/HkSyncParkServiceImpl.java | 182 +++++++++++++++++++++++++++++++++++++++++++--
1 files changed, 174 insertions(+), 8 deletions(-)
diff --git a/server/dmvisit_service/src/main/java/com/doumee/service/business/impl/hksync/HkSyncParkServiceImpl.java b/server/dmvisit_service/src/main/java/com/doumee/service/business/impl/hksync/HkSyncParkServiceImpl.java
index b5b1367..b902487 100644
--- a/server/dmvisit_service/src/main/java/com/doumee/service/business/impl/hksync/HkSyncParkServiceImpl.java
+++ b/server/dmvisit_service/src/main/java/com/doumee/service/business/impl/hksync/HkSyncParkServiceImpl.java
@@ -1,16 +1,23 @@
package com.doumee.service.business.impl.hksync;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
+import com.doumee.config.DataSyncConfig;
import com.doumee.core.constants.ResponseStatus;
import com.doumee.core.exception.BusinessException;
import com.doumee.core.haikang.model.HKConstants;
+import com.doumee.core.haikang.model.param.BaseListPageResponse;
import com.doumee.core.haikang.model.param.BaseResponse;
-import com.doumee.core.haikang.model.param.request.CarChargeAddRequest;
-import com.doumee.core.haikang.model.param.request.CarChargeDelRequest;
-import com.doumee.core.haikang.model.param.request.ParkListRequest;
+import com.doumee.core.haikang.model.param.request.*;
+import com.doumee.core.haikang.model.param.respose.AppointmentInfoResponse;
+import com.doumee.core.haikang.model.param.respose.ParkCrossRecordInfoResponse;
import com.doumee.core.haikang.model.param.respose.ParkListResponse;
import com.doumee.core.haikang.service.HKService;
import com.doumee.core.utils.Constants;
+import com.doumee.core.utils.DESUtil;
import com.doumee.core.utils.DateUtil;
+import com.doumee.core.utils.Utils;
+import com.doumee.dao.business.CarEventMapper;
import com.doumee.dao.business.ParksMapper;
import com.doumee.dao.business.join.ParkBookJoinMapper;
import com.doumee.dao.business.model.*;
@@ -18,6 +25,8 @@
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
@@ -31,9 +40,13 @@
public class HkSyncParkServiceImpl extends HkSyncBaseServiceImpl {
@Autowired
+ private DataSyncConfig dataSyncConfig;
+ @Autowired
private ParksMapper parksMapper;
@Autowired
private ParkBookJoinMapper parkBookMapper;
+ @Autowired
+ private CarEventMapper carEventMapper;
@Override
public void syncParkBookData() {
if(Constants.DEALING_HK_PARKBOOK){
@@ -55,8 +68,10 @@
&& StringUtils.isNotBlank(c.getCarCode())){
boolean result = cancelParkBookHk(c);
c.setHkStatus(result?Constants.ONE:Constants.TWO);
+ c.setRemark(result?"鍙栨秷鍖呮湡鎴愬姛":"鍙栨秷鍖呮湡澶辫触");
}else{
c.setHkStatus(Constants.TWO);//涓嬪彂澶辫触
+ c.setRemark("鍙栨秷鍖呮湡澶辫触");
}
c.setHkDate(date);
parkBookMapper.updateById(c);
@@ -73,8 +88,10 @@
&& StringUtils.isNotBlank(c.getCarCode())){
boolean result = addParkBookHk(c);
c.setHkStatus(result?Constants.ONE:Constants.TWO);
+ c.setRemark(result?"鍖呮湡鎴愬姛":"鍖呮湡澶辫触");
}else{
c.setHkStatus(Constants.TWO);
+ c.setRemark("鍖呮湡澶辫触~");
}
c.setHkDate(date);
parkBookMapper.updateById(c);
@@ -86,13 +103,43 @@
}
}
-
+ @Override
+ public void syncParkBookBySingleModel(ParkBook c) {
+ if(Constants.equalsObject(c.getIsdeleted(),Constants.ONE)){
+ //濡傛灉鍙栨秷棰勭害锛屽垯杩涜鍙栨秷鍖呮湡
+ if(StringUtils.isNotBlank(c.getParkHkId())
+ && StringUtils.isNotBlank(c.getCarCode())){
+ boolean result = cancelParkBookHk(c);
+ c.setHkStatus(result?Constants.ONE:Constants.TWO);
+ c.setRemark(result?"鍙栨秷鍖呮湡鎴愬姛":"鍙栨秷鍖呮湡澶辫触");
+ }else{
+ c.setHkStatus(Constants.TWO);//涓嬪彂澶辫触
+ c.setRemark("鍙栨秷鍖呮湡澶辫触");
+ }
+ c.setHkDate(new Date());
+ parkBookMapper.updateById(c);
+ }else {
+ //澶勭悊鎵�鏈夐渶瑕佸寘鏈熺殑杞﹁締鏁版嵁璁板綍
+ //鏁版嵁涓嶅悎娉曪紝鐩存帴鎻愮ず涓嬪彂澶辫触
+ if (StringUtils.isNotBlank(c.getParkHkId())
+ && StringUtils.isNotBlank(c.getCarCode())) {
+ boolean result = addParkBookHk(c);
+ c.setHkStatus(result ? Constants.ONE : Constants.TWO);
+ c.setRemark(result ? "鍖呮湡鎴愬姛" : "鍖呮湡澶辫触");
+ } else {
+ c.setHkStatus(Constants.TWO);
+ c.setRemark("鍖呮湡澶辫触~");
+ }
+ c.setHkDate(new Date());
+ parkBookMapper.updateById(c);
+ }
+ }
private boolean addParkBookHk(ParkBook c) {
CarChargeAddRequest param = new CarChargeAddRequest();
param.setPlateNo(c.getCarCode());
param.setParkSyscode(c.getParkHkId());
- param.setStartTime(DateUtil.getISO8601Timestamp(c.getStartTime()));
- param.setEndTime(DateUtil.getISO8601Timestamp(c.getEndTime()));
+ param.setStartTime(DateUtil.getShortTime(c.getStartTime()));
+ param.setEndTime(DateUtil.getShortTime(c.getEndTime()));
BaseResponse response = HKService.carChargeAddtion(param);
if(response!=null
&& StringUtils.equals(response.getCode(),HKConstants.RESPONSE_SUCCEE)){
@@ -120,7 +167,7 @@
queryWrapper.selectAs(Parks::getHkId,ParkBook::getParkHkId);
queryWrapper.leftJoin(Parks.class,Parks::getId,ParkBook::getParkId);
queryWrapper.selectAs(Device::getHkId,Empower::getDeviceIndexCode);
- List<ParkBook> list = parkBookMapper.selectJoinList(ParkBook.class,queryWrapper);
+ List<ParkBook> list = parkBookMapper.selectJoinList(ParkBook.class,queryWrapper.eq(ParkBook::getHkStatus,Constants.ZERO));
return list;
}
/**
@@ -248,5 +295,124 @@
return true;
}
-
+
+
+
+ @Override
+ @Transactional
+ public void syncParkRecords(Date date){
+ try {
+ if( Constants.formatIntegerNum(dataSyncConfig.getVisitorDataOrigin()) != DataSyncConfig.origin.hk){
+ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "瀵逛笉璧凤紝褰撳墠涓嶆敮鎸佹捣搴锋暟鎹悓姝ユ搷浣渵");
+ }
+ ParkCrossRecordListRequest param = new ParkCrossRecordListRequest();
+ //锛堝叏閲忓悓姝ワ級
+ boolean hasNext = true;
+ int curTotal = 0;
+ int curPage = 1;
+ //鏌ヨ浠婂ぉ鐨�
+ Date start = Utils.Date.getStart(date);
+ Date end = new Date();
+ if(DateUtil.daysBetweenDates(end,start) >1){
+ end = Utils.Date.getEnd(date);
+ }
+ param.setStartTime(DateUtil.getISO8601Timestamp2( start));
+ param.setEndTime(DateUtil.getISO8601Timestamp2( end));
+
+ List<CarEvent> allHkList = new ArrayList<>();
+ while (hasNext){
+ //鍒嗛〉閬嶅巻寰幆鏌ヨ鎵�鏈夐棬绂佽澶囨暟鎹�
+ param.setPageNo(curPage);
+ param.setPageSize(100);
+ BaseResponse<BaseListPageResponse<ParkCrossRecordInfoResponse>> response = HKService.parkCrossRecords(param);
+ if(response == null || !StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE) ){
+ throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "瀵逛笉璧凤紝娴峰悍鍚屾鏁版嵁澶辫触~");
+ }
+ if(response.getData() == null || response.getData().getTotal() ==0){
+ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"鏈悓姝ュ埌浠讳綍淇℃伅锛�");
+ }
+ BaseListPageResponse<ParkCrossRecordInfoResponse> r = response.getData();
+ curTotal += 100;
+ if(curTotal >= r.getTotal()){
+ hasNext = false;
+ }
+ if(r.getList() == null || r.getList().size()==0){
+ hasNext =false;
+ }else{
+ allHkList.addAll(getNewCarEventModelBYList(r.getList()));
+ }
+ curPage++;
+ }
+ if(allHkList .size() == 0){
+ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"鏈悓姝ュ埌浠讳綍淇℃伅锛�");
+ }
+ //娓呯┖鍘熸湁褰撳ぉ鐨勬暟鎹�
+ carEventMapper.delete(new UpdateWrapper<CarEvent>().lambda()
+ .ge(CarEvent::getCreateDate,start)
+ .le(CarEvent::getCreateDate,end));
+ if(allHkList.size()>0){
+ int sublistSize = 500;
+
+ int startIndex = 0;
+ int endIndex = sublistSize;
+
+ while (startIndex < allHkList.size()) {
+ if (endIndex > allHkList.size()) {
+ endIndex = allHkList.size();
+ }
+
+ List<CarEvent> sublist = allHkList.subList(startIndex, endIndex);
+ if(sublist.size()>0){
+ carEventMapper.insertBatchSomeColumn(sublist);//鎻掑叆鏂版暟鎹�
+ }
+ startIndex = endIndex;
+ endIndex += sublistSize;
+ }
+ }
+
+ }catch (BusinessException e){
+ throw e;
+ }
+ }
+
+ private List<CarEvent> getNewCarEventModelBYList(List<ParkCrossRecordInfoResponse> list ) {
+ List<CarEvent> newList = new ArrayList<>();
+ if(list == null || list.size()==0){
+ return newList;
+ }
+ for(ParkCrossRecordInfoResponse model :list){
+ if( model.getReleaseResult() ==null || !( model.getReleaseResult() == 1|| model.getReleaseResult() == 2 )){
+ continue;
+ }
+ CarEvent c = new CarEvent();
+ c.setHappenTime(model.getCrossTime());
+ c.setCreateDate(DateUtil.getISO8601DateByStr2(model.getCrossTime()));
+ c.setSvrIndex(model.getAswSyscode());
+ c.setVehiclePicUrl(model.getVehiclePicUri());
+ c.setPlatePicUrl(model.getPlateNoPicUri());
+ c.setVehicleType(model.getVehicleType());
+ c.setPlateColor(model.getPlateColor());
+ c.setPlateType(model.getPlateType());
+ c.setCardNo(model.getCardNo());
+ c.setReleaseReason(model.getReleaseReason());
+ c.setPlateNos(model.getPlateNo());
+ c.setReleaseResult(model.getReleaseResult());
+ c.setInoutType(model.getVehicleOut());
+ c.setParkIndex(model.getParkSyscode());
+ c.setParkName(model.getParkName());
+ c.setEventId(model.getCrossRecordSyscode());
+ c.setGateIndex(model.getEntranceSyscode());
+ c.setGateName(model.getEntranceName());
+ c.setIsdeleted(Constants.ZERO);
+ if(model.getVehicleOut() !=null &&model.getVehicleOut() == 0 ){
+ c.setEventType(HKConstants.EventTypes.PARK_PASS_IN.getKey());
+ }else {
+ c.setEventType(HKConstants.EventTypes.PARK_PASS_OUT.getKey());
+ }
+ newList.add(c);
+ }
+ return newList;
+ }
+
+
}
--
Gitblit v1.9.3