ERP接口

k94314517

2024-03-07 cc80794e556bbe1e43f9c1369e1dfc9c61318fda

 server/dmvisit_service/src/main/java/com/doumee/service/business/impl/erp/ErpSyncServiceImpl.java

@@ -44,6 +44,7 @@
import org.springframework.beans.factory.annotation.Value;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.PostConstruct;
@@ -524,7 +525,7 @@
                   for (DeviceRole deviceRole:deviceRoleList) {
                       RoleListResponse roleListResponse = new RoleListResponse();
                       BeanUtils.copyProperties(deviceRole,roleListResponse);
                       if(deviceRole.getType().equals(Constants.TWO)){
                       if(deviceRole.getType().equals("2")){
                           roleListResponse.setType(Constants.ONE);
                       }else{
                           roleListResponse.setType(Constants.ZERO);
@@ -877,6 +878,7 @@
                    member.setFsStatus(Constants.ZERO);
                    member.setCompanyId(company.getId());
                    member.setType(Constants.memberType.internal);
                    member.setCanVisit(Constants.ONE);
                    String encryptIdNo = DESUtil.encrypt(Constants.EDS_PWD,param.getIdNo());
                    member.setIdcardNo(encryptIdNo);
                    member.setStartTime(param.getValidStartTime());
@@ -1008,6 +1010,30 @@

    @Override
    public void roleUserAuthor(UserAuthorRequest param){
        try{
//            if(Objects.isNull(param)
//                    ||StringUtils.isBlank(param.getUserId())){
//                throw new BusinessException(ResponseStatus.BAD_REQUEST);
//            }
//            Member member = memberMapper.selectOne(new QueryWrapper<Member>().lambda().eq(Member::getErpId,param.getUserId()).last("limit 1"));
//            if(Objects.isNull(member)){
//                throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"对不起，用户信息不存在！");
//            }
//            List<Integer> doorIds = getRoleIdByParam(param.getRoleIds(),member);
//            if(StringUtils.isBlank(member.getRoleId())){
//                throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"未查询到门禁组数据");
//            }
//            //更新授权有效期
//            Member update = new Member();
//            update.setId(member.getId());
//            update.setEditDate(new Date());
//            update.setStartTime(param.getValidStartTime());
//            update.setEndTime(param.getValidEndTime());
//            update.setRoleId(StringUtils.isNotBlank(member.getRoleId())?member.getRoleId():null);
//            update.setHkStatus(Constants.ZERO);//做一遍更新逻辑
//            update.setRemark("待同步安防平台");
//            memberMapper.updateById(update);

        if(Objects.isNull(param)
                ||StringUtils.isBlank(param.getUserId())){
            throw new BusinessException(ResponseStatus.BAD_REQUEST);
@@ -1042,61 +1068,68 @@
                .set(Member::getEndTime,param.getValidEndTime())
                .set(Member::getEditDate,new Date())
                .set(Member::getHkStatus,Constants.ZERO ));
        }catch (BusinessException e){
            throw e;
        }finally {
            saveInterfaceLog(param,"/event/role/userAuthor",null,Constants.ZERO);
        }
    }


    @Override
    public void parkCarAuthor(CarAuthorRequest param){
        if(Objects.isNull(param)
                ||StringUtils.isBlank(param.getCarCode())){
            throw new BusinessException(ResponseStatus.BAD_REQUEST);
        }
        if(Objects.nonNull(param.getValidStartTime())&&Objects.nonNull(param.getValidEndTime())){
            if(param.getValidStartTime().getTime()> param.getValidEndTime().getTime()){
                throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起，有效期时间不合法！");
        try{
            if(Objects.isNull(param)
                    ||StringUtils.isBlank(param.getCarCode())){
                throw new BusinessException(ResponseStatus.BAD_REQUEST);
            }
        }
        Member member = memberMapper.selectOne(new QueryWrapper<Member>().lambda().eq(Member::getErpId,param.getUserId()).last("limit 1"));
        if(Objects.isNull(member)){
            throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"对不起，用户信息不存在！");
        }
        //删除车量库记录数据
        parkBookMapper.update(null,new UpdateWrapper<ParkBook>().lambda()
                .eq(ParkBook::getCarCode,param.getCarCode())
                .set(ParkBook::getIsdeleted,Constants.ONE)
                .set(ParkBook::getHkStatus,Constants.ZERO)
        );
        //查询车库信息
        List<Parks> parksList = new ArrayList<>();
        if(CollectionUtils.isNotEmpty(param.getParkIdList())){
             parksList  = parksMapper.selectList(new QueryWrapper<Parks>().lambda()
                    .in(Parks::getId,param.getParkIdList())
            if(Objects.nonNull(param.getValidStartTime())&&Objects.nonNull(param.getValidEndTime())){
                if(param.getValidStartTime().getTime()> param.getValidEndTime().getTime()){
                    throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起，有效期时间不合法！");
                }
            }
            Member member = memberMapper.selectOne(new QueryWrapper<Member>().lambda().eq(Member::getErpId,param.getUserId()).last("limit 1"));
            if(Objects.isNull(member)){
                throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"对不起，用户信息不存在！");
            }
            //删除车量库记录数据
            parkBookMapper.update(null,new UpdateWrapper<ParkBook>().lambda()
                    .eq(ParkBook::getCarCode,param.getCarCode())
                    .set(ParkBook::getIsdeleted,Constants.ONE)
                    .set(ParkBook::getHkStatus,Constants.ZERO)
            );
        }else{
            throw  new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"对不起，停车库信息不存在，授权失败");
        }
        if(CollectionUtils.isNotEmpty(parksList)){
            List<ParkBook> parkBookList = new ArrayList<>();
            for (Parks parks:parksList) {
                ParkBook parkBook = new ParkBook();
                parkBook.setIsdeleted(Constants.ZERO);
                parkBook.setCreateDate(new Date());
                parkBook.setCarCode(param.getCarCode());
                parkBook.setParkId(parks.getId());
                parkBook.setOrigin(Constants.ZERO);
                parkBook.setStartTime(Objects.isNull(param.getValidStartTime())?new Date():param.getValidStartTime());
                parkBook.setEndTime(Objects.isNull(param.getValidEndTime())?null:param.getValidEndTime());
                parkBook.setTimeType(Objects.isNull(param.getValidEndTime())?Constants.ZERO:Constants.ONE);
                parkBook.setMemberId(member.getId());
                parkBook.setHkStatus(Constants.ZERO);
                parkBook.setRemark("待同步安防平台");
                parkBookList.add(parkBook);
            //查询车库信息
            if(CollectionUtils.isNotEmpty(param.getParkIdList())){
                List<Parks>  parksList  = parksMapper.selectList(new QueryWrapper<Parks>().lambda()
                        .in(Parks::getId,param.getParkIdList())
                );
                if(CollectionUtils.isNotEmpty(parksList)){
                    List<ParkBook> parkBookList = new ArrayList<>();
                    for (Parks parks:parksList) {
                        ParkBook parkBook = new ParkBook();
                        parkBook.setIsdeleted(Constants.ZERO);
                        parkBook.setCreateDate(new Date());
                        parkBook.setCarCode(param.getCarCode());
                        parkBook.setParkId(parks.getId());
                        parkBook.setOrigin(Constants.ZERO);
                        parkBook.setStartTime(Objects.isNull(param.getValidStartTime())?null:param.getValidStartTime());
                        parkBook.setEndTime(Objects.isNull(param.getValidEndTime())?null:param.getValidEndTime());
                        parkBook.setTimeType(Objects.isNull(param.getValidEndTime())?Constants.ZERO:Constants.ONE);
                        parkBook.setMemberId(member.getId());
                        parkBook.setHkStatus(Constants.ZERO);
                        parkBook.setRemark("待同步安防平台");
                        parkBookList.add(parkBook);
                    }
                    parkBookMapper.insertBatchSomeColumn(parkBookList);
                }else{
                    throw  new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"对不起，停车库信息不存在，授权失败");
                }
            }
            parkBookMapper.insertBatchSomeColumn(parkBookList);
        }else{
            throw  new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"对不起，停车库信息不存在，授权失败");
        }catch (BusinessException e){
            throw e;
        }finally {
            saveInterfaceLog(param,"/event/park/carAuthor",null,Constants.ZERO);
        }

    }


@@ -1142,8 +1175,8 @@
    }



    private void saveInterfaceLog(Object param, String path,String result,Integer type) {
    @Transactional(propagation = Propagation.NOT_SUPPORTED)
    public void saveInterfaceLog(Object param, String path, String result, Integer type) {
        InterfaceLog interfaceLog=new InterfaceLog();
        interfaceLog.setType(type);
        interfaceLog.setCreateDate(new Date());