最新版本

nidapeng

2024-04-15 e3f60427ef427d966253aa7ecd022aa9f20788ad

 server/dmvisit_service/src/main/java/com/doumee/service/business/impl/hksync/HkSyncParkServiceImpl.java

@@ -61,8 +61,20 @@
                return;
            }
            Date date = new Date();
            //先出所有需要取消包期的数据记录
            //处理所有需要包期的车辆数据记录
            for(ParkBook c : list) {
                    dealParkBookBiz(c,date);
            }
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            Constants.DEALING_HK_PARKBOOK =false;
        }

    }

    private void dealParkBookBiz(ParkBook c,Date date) {
        try {
                if(Constants.equalsObject(c.getIsdeleted(),Constants.ONE)){
                    //如果取消预约，则进行取消包期
                    if(StringUtils.isNotBlank(c.getParkHkId())
@@ -75,16 +87,8 @@
                        c.setRemark("取消包期失败");
                    }
                    c.setHkDate(date);
                    parkBookMapper.updateById(c);
                }
            }
            //处理所有需要包期的车辆数据记录
            for(ParkBook c : list) {
                if(Constants.equalsObject(c.getIsdeleted(),Constants.ONE)) {
                    //删除的已处理，跳过处理
                    continue;
                }
                //数据不合法，直接提示下发失败
            }else{
                //如果是新增包期，数据不合法，直接提示下发失败
                if(StringUtils.isNotBlank(c.getParkHkId())
                        && StringUtils.isNotBlank(c.getCarCode())){
                    boolean result =  addParkBookHk(c);
@@ -94,16 +98,15 @@
                    c.setHkStatus(Constants.TWO);
                    c.setRemark("包期失败~");
                }
            }
                c.setHkDate(date);
                parkBookMapper.updateById(c);
            }
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            Constants.DEALING_HK_PARKBOOK =false;

        }

    }

    @Override
    public  void syncParkBookBySingleModel(ParkBook c) {
                if(Constants.equalsObject(c.getIsdeleted(),Constants.ONE)){
@@ -168,8 +171,27 @@
        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.eq(ParkBook::getHkStatus,Constants.ZERO));
        List<ParkBook> list = parkBookMapper.selectJoinList(ParkBook.class,queryWrapper.eq(ParkBook::getHkStatus,Constants.ZERO).orderByAsc(ParkBook::getId));
        return list;
    }
    private void getDataChangeList(List<Parks> allList, List<ParkListResponse> allHkList, List<Parks> addList, List<Parks> editList,List<Parks> deleteList, Date date) {
        if(allHkList!=null && allHkList.size()>0){
            for(ParkListResponse device : allHkList){
                Parks model = getExistedData(device,allList);
                if(model !=null){
                    //如果已存在，则更新数据
                    model =  initModelByHkData(model,device,date);
                    editList.add(model);
                }else{
                    //如果不存在，则新增数据
                    model = new Parks();
                    model =  initModelByHkData(model,device,date);
                    addList.add(model);
                }
            }
        }
        //判断获取删除的门禁设备，逻辑删除
        getDeleteList(allList,allHkList,deleteList,date);
    }
    /**
     * 同步海康停车库数据
@@ -220,25 +242,6 @@
        }finally {
            Constants.DEALING_HK_SYNCPRIVILEGE =false;
        }
    }
    private void getDataChangeList(List<Parks> allList, List<ParkListResponse> allHkList, List<Parks> addList, List<Parks> editList,List<Parks> deleteList, Date date) {
        if(allHkList!=null && allHkList.size()>0){
            for(ParkListResponse device : allHkList){
                Parks model = getExistedData(device,allList);
                if(model !=null){
                    //如果已存在，则更新数据
                    model =  initModelByHkData(model,device,date);
                    editList.add(model);
                }else{
                    //如果不存在，则新增数据
                    model = new Parks();
                    model =  initModelByHkData(model,device,date);
                    addList.add(model);
                }
            }
        }
        //判断获取删除的门禁设备，逻辑删除
        getDeleteList(allList,allHkList,deleteList,date);
    }

    /**