代码整理1

yangys

2024-05-06 e19227de97d21c10fd22536f85c8153e63072d0c

 smart-man-boot/src/main/java/com/qianwen/smartman/modules/notify/service/impl/NotifyDefaultPersonServiceImpl.java

@@ -34,78 +34,11 @@
    @Autowired
    private ICommonGroupService commonGroupService;

    private static /* synthetic */ Object $deserializeLambda$(SerializedLambda lambda) {
        String implMethodName = lambda.getImplMethodName();
        boolean z = true;
        switch (implMethodName.hashCode()) {
            case -1492577373:
                if (implMethodName.equals("getGroupType")) {
                    z = true;
                    break;
                }
                break;
            case 98245393:
                if (implMethodName.equals("getId")) {
                    z = true;
                    break;
                }
                break;
            case 584947017:
                if (implMethodName.equals("getBusinessKey")) {
                    z = false;
                    break;
                }
                break;
            case 803533544:
                if (implMethodName.equals("getStatus")) {
                    z = true;
                    break;
                }
                break;
        }
        switch (z) {
            case false:
                if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/notify/entity/NotifyDefaultPerson") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) {
                    return (v0) -> {
                        return v0.getBusinessKey();
                    };
                }
                if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/notify/entity/NotifyDefaultPerson") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) {
                    return (v0) -> {
                        return v0.getBusinessKey();
                    };
                }
                break;
            case true:
                if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/cps/entity/CommonGroup") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
                    return (v0) -> {
                        return v0.getId();
                    };
                }
                break;
            case true:
                if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/cps/entity/CommonGroup") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) {
                    return (v0) -> {
                        return v0.getGroupType();
                    };
                }
                break;
            case true:
                if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/modules/cps/entity/CommonGroup") && lambda.getImplMethodSignature().equals("()Ljava/lang/Integer;")) {
                    return (v0) -> {
                        return v0.getStatus();
                    };
                }
                break;
        }
        throw new IllegalArgumentException("Invalid lambda deserialization");
    }

    @Override // org.springblade.modules.notify.service.INotifyDefaultPersonService
    public NotifyDefaultObjectVO getByBusinessKey(String businessKey) {
        NotifyDefaultObjectVO notifyDefaultObjectVO = new NotifyDefaultObjectVO();
        List<NotifyDefaultPerson> personList = getNotifyDefaultPerson(businessKey);
        Map<Integer, Set<Long>> notifyDefaultPersonMap = (Map) personList.parallelStream().collect(Collectors.groupingBy((v0) -> {
        Map<Integer, Set<Long>> notifyDefaultPersonMap = personList.parallelStream().collect(Collectors.groupingBy((v0) -> {
            return v0.getPersonType();
        }, Collectors.mapping((v0) -> {
            return v0.getPersonId();
@@ -118,13 +51,17 @@
        }
        if (notifyDefaultPersonMap.containsKey(Integer.valueOf(ObjectTypeEnum.ORG.getCode()))) {
            Set<Long> ids2 = notifyDefaultPersonMap.get(Integer.valueOf(ObjectTypeEnum.ORG.getCode()));
            List<CommonGroup> list = this.commonGroupService.list(Wrappers.<CommonGroup>lambdaQuery().eq(CommonGroup::getStatus, true)
                  .in(CommonGroup::getId, ids2).eq(CommonGroup::getGroupType, DingConstant.GROUPTYPE));
            ;
            /*
            List<CommonGroup> list = this.commonGroupService.list((Wrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> {
                return v0.getStatus();
            }, true)).in((v0) -> {
                return v0.getId();
            }, ids2)).eq((v0) -> {
                return v0.getGroupType();
            }, DingConstant.GROUPTYPE));
            }, DingConstant.GROUPTYPE));*/
            List<NotifyDefaultPersonDTO> notifyDefaultPersonDTOS2 = NotifyDefaultPersonConvert.INSTANCE.convertByOrgList(list);
            notifyDefaultObjectVO.setOrgList(notifyDefaultPersonDTOS2);
        }
@@ -160,15 +97,19 @@
    }

    private void remove(String businessKey) {
       remove(Wrappers.<NotifyDefaultPerson>lambdaQuery().eq(NotifyDefaultPerson::getBusinessKey, businessKey));
       /*
        remove((Wrapper) Wrappers.lambdaQuery().eq((v0) -> {
            return v0.getBusinessKey();
        }, businessKey));
        }, businessKey));*/
    }

    private List<NotifyDefaultPerson> getNotifyDefaultPerson(String businessKey) {
       Wrapper<NotifyDefaultPerson> defaultPersonWrapper = Wrappers.<NotifyDefaultPerson>lambdaQuery().eq(NotifyDefaultPerson::getBusinessKey, businessKey);
       /*
        Wrapper<NotifyDefaultPerson> defaultPersonWrapper = (Wrapper) Wrappers.lambdaQuery().eq((v0) -> {
            return v0.getBusinessKey();
        }, businessKey);
        }, businessKey);*/
        return list(defaultPersonWrapper);
    }
}