From d0c4ab05405817381fe6df28d6b4aa15dceef260 Mon Sep 17 00:00:00 2001 From: k94314517 <8417338+k94314517@user.noreply.gitee.com> Date: 星期四, 10 十月 2024 17:27:22 +0800 Subject: [PATCH] 代码初始化 --- server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/hksync/HkSyncPushServiceImpl.java | 41 ++++++++++++++++++++++++++++------------- 1 files changed, 28 insertions(+), 13 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 fe0be93..144a865 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 @@ -888,9 +888,11 @@ .selectAll(PlatformJob.class) .selectAs(Platform::getName,PlatformJob::getPlatformName) .leftJoin(Platform.class,Platform::getId,PlatformJob::getPlatformId) - .eq(StringUtils.equals(status.getStockStatus(),"front"),PlatformJob::getCarCodeFront,status.getPlateNo() )//鍓嶈溅鐗屽彿 - .eq(!StringUtils.equals(status.getStockStatus(),"front"),PlatformJob::getCarCodeBack,status.getPlateNo() )//鍚庤溅鐗屽彿 - .eq(PlatformJob::getIsdeleted,Constants.ZERO ) +// .eq(StringUtils.equals(status.getStockStatus(),"front"),PlatformJob::getCarCodeFront,status.getPlateNo() )//鍓嶈溅鐗屽彿 +// .eq(!StringUtils.equals(status.getStockStatus(),"front"),PlatformJob::getCarCodeBack,status.getPlateNo() )//鍚庤溅鐗屽彿 + .eq(PlatformJob::getPlatformId,Constants.ZERO ) + .eq(PlatformJob::getIsdeleted,model.getPlatformId() ) + .orderByDesc(PlatformJob::getCallDate) .last("limit 1 ")); if(job == null){ continue;//濡傛灉浣滀笟涓虹┖锛岃烦杩囧鐞� @@ -917,9 +919,14 @@ update.setDoneDate(update.getEditDate());*/ }else if(StringUtils.equals(status.getMotionStatus(),"enter")){ //濡傛灉鏄溅杈嗚繘鍏� - if(job ==null || !Constants.equalsInteger(job.getStatus(),Constants.PlatformJobStatus.CALLED.getKey())){ - //璇存槑杞﹁締杩涢敊鏈堝彴 鎴栬�呰繕鏈彨鍙风姸鎬侊紝鍙戣捣璀﹀憡 - dealCarsInErrorPlatformBiz(job,status); + if(!Constants.equalsInteger(job.getStatus(),Constants.PlatformJobStatus.CALLED.getKey())){ + if(!((StringUtils.equals(status.getStockStatus(),"front") && StringUtils.equals(job.getCarCodeFront(),status.getPlateNo())) + ||(!StringUtils.equals(status.getStockStatus(),"front") && StringUtils.equals(job.getCarCodeBack(),status.getPlateNo())) + )){ + //璇存槑杞﹁締杩涢敊鏈堝彴 鎴栬�呰繕鏈彨鍙风姸鎬侊紝鍙戣捣璀﹀憡 + dealCarsInErrorPlatformBiz(job,status); + } + } if(job.getStartDate() == null){ update.setStartDate(update.getEditDate()); @@ -1053,14 +1060,14 @@ return; } String content =Constants.PlatformLedContent.WRONG_IN.getInfo(); - content = content.replace("${param}",model.getPlatformName()); - content = content.replace("${param2}",model.getCarCodeFront()); + content = content.replace("${param2}",model.getPlatformName()); + content = content.replace("${param}",model.getCarCodeFront()); List<String> broadcastList = new ArrayList<>(); List<String> ledList = new ArrayList<>(); String bNames = ""; List<PlatformBroadcastLog> logList = new ArrayList<>(); for(PlatformDevice device : deviceList){ - if(StringUtils.isNotBlank(device.getHkId())){ + if(StringUtils.isBlank(device.getHkId())){ continue; } if(Constants.equalsInteger(device.getType(),Constants.ZERO)){ @@ -1068,23 +1075,31 @@ PlatformBroadcastLog log = dealLedContentBiz(device.getHkNo(),device.getName(),content,speed,1); logList.add(log); ledList.add(device.getHkId()); - }else if(Constants.equalsInteger(device.getType(),Constants.ZERO)){ + }else if(Constants.equalsInteger(device.getType(),Constants.TWO)){ //濡傛灉鏄箍鎾偣 bNames += device.getName()+";"; broadcastList.add(device.getHkId()); } } if(broadcastList.size()>0){ - PlatformBroadcastLog log = dealBroadcastBiz(model,broadcastList,bNames); + PlatformBroadcastLog log = dealBroadcastBiz(model,broadcastList,bNames,Constants.PlatformBroadcastContent.WRONG_IN.getInfo().replace("${param}",model.getCarCodeFront())); logList.add(log); } if(logList.size()>0){ platformBroadcastLogMapper.insert(logList); } } - public static PlatformBroadcastLog dealBroadcastBiz(PlatformJob model, List<String> broadcastList,String bNames) { + + /** + * 骞挎挱閫氱煡 + * @param model + * @param broadcastList + * @param bNames + * @param content1 + * @return + */ + public static PlatformBroadcastLog dealBroadcastBiz(PlatformJob model, List<String> broadcastList,String bNames , String content1) { PlatformBroadcastLog log = new PlatformBroadcastLog(); - String content1 =Constants.PlatformBroadcastContent.WRONG_IN.getInfo(); content1 = content1.replace("${param}",model.getCarCodeFront()); log.setCreateDate(new Date()); -- Gitblit v1.9.3