package com.qianwen.smartman.modules.tpm.service.impl;

import com.baomidou.mybatisplus.core.conditions.Wrapper;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import java.lang.invoke.SerializedLambda;
import java.time.LocalDateTime;
import java.util.ArrayList;
import java.util.Collection;
import java.util.List;
import java.util.Optional;
import java.util.stream.Collectors;
import java.util.stream.Stream;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.qianwen.smartman.common.cache.RegionCache;
import com.qianwen.smartman.common.constant.NotifyConstant;
import com.qianwen.smartman.common.utils.MessageUtils;
import com.qianwen.core.log.exception.ServiceException;
import com.qianwen.core.mp.support.Condition;
import com.qianwen.core.mp.support.Query;
import com.qianwen.core.secure.utils.AuthUtil;
import com.qianwen.core.tool.utils.CollectionUtil;
import com.qianwen.core.tool.utils.Func;
import com.qianwen.smartman.modules.cps.service.IMachineService;
import com.qianwen.smartman.modules.cps.service.IWorkstationService;
import com.qianwen.smartman.modules.cps.vo.WorkstationVO;
import com.qianwen.smartman.modules.notify.business.BusinessSend;
import com.qianwen.smartman.modules.notify.business.BusinessSendFactory;
import com.qianwen.smartman.modules.notify.dto.NotifyBusinessSendDTO;
import com.qianwen.smartman.modules.system.service.ICodeGeneratorService;
import com.qianwen.smartman.modules.tpm.convert.RepairApplyConvert;
import com.qianwen.smartman.modules.tpm.convert.RepairApplyFileConvert;
import com.qianwen.smartman.modules.tpm.dto.RepairApplyFileAddDTO;
import com.qianwen.smartman.modules.tpm.entity.RepairApply;
import com.qianwen.smartman.modules.tpm.entity.RepairApplyFile;
import com.qianwen.smartman.modules.tpm.entity.RepairRecord;
import com.qianwen.smartman.modules.tpm.enums.ActionEnum;
import com.qianwen.smartman.modules.tpm.enums.DeviceRepairStatusEnum;
import com.qianwen.smartman.modules.tpm.enums.MetaTypeEnum;
import com.qianwen.smartman.modules.tpm.enums.RepairApplyStatusEnum;
import com.qianwen.smartman.modules.tpm.enums.RepairRecordEnum;
import com.qianwen.smartman.modules.tpm.enums.UrgencyEnum;
import com.qianwen.smartman.modules.tpm.mapper.RepairApplyMapper;
import com.qianwen.smartman.modules.tpm.service.IRepairApplyFileService;
import com.qianwen.smartman.modules.tpm.service.IRepairApplyService;
import com.qianwen.smartman.modules.tpm.service.IRepairRecordService;
import com.qianwen.smartman.modules.tpm.vo.ApplyCodeVO;
import com.qianwen.smartman.modules.tpm.vo.RepairApplyAddVO;
import com.qianwen.smartman.modules.tpm.vo.RepairApplyDetailVO;
import com.qianwen.smartman.modules.tpm.vo.RepairApplyExportVO;
import com.qianwen.smartman.modules.tpm.vo.RepairApplyLookVO;
import com.qianwen.smartman.modules.tpm.vo.RepairApplySearchVO;
import com.qianwen.smartman.modules.tpm.vo.RepairApplyUpdateVO;
import com.qianwen.smartman.modules.tpm.vo.RepairApplyVO;
import com.qianwen.smartman.modules.tpm.vo.RepairFileVO;
import com.qianwen.smartman.modules.tpm.vo.excel.RepairApplyExcelVO;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Lazy;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

@Service
/* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/tpm/service/impl/RepairApplyServiceImpl.class */
public class RepairApplyServiceImpl extends ServiceImpl<RepairApplyMapper, RepairApply> implements IRepairApplyService {
    private static final Logger log = LoggerFactory.getLogger(RepairApplyServiceImpl.class);
    @Autowired
    private IRepairApplyFileService iRepairApplyFileService;
    @Autowired
    @Lazy
    private IRepairRecordService repairRecordService;
    @Autowired
    private IMachineService machineService;
    @Autowired
    private ICodeGeneratorService codeGeneratorService;
    @Autowired
    private BusinessSendFactory businessSendFactory;
    @Autowired
    private IWorkstationService workstationService;

    private static /* synthetic */ Object $deserializeLambda$(SerializedLambda lambda) {
        String implMethodName = lambda.getImplMethodName();
        boolean z = true;
        switch (implMethodName.hashCode()) {
            case -2085769275:
                if (implMethodName.equals("getApplyCode")) {
                    z = true;
                    break;
                }
                break;
            case -1107875961:
                if (implMethodName.equals("getDeviceId")) {
                    z = true;
                    break;
                }
                break;
            case -826050023:
                if (implMethodName.equals("getRecordStatus")) {
                    z = true;
                    break;
                }
                break;
            case -151423706:
                if (implMethodName.equals("getRepairApplyId")) {
                    z = true;
                    break;
                }
                break;
            case 37124789:
                if (implMethodName.equals("getMalfunctionId")) {
                    z = true;
                    break;
                }
                break;
            case 98245393:
                if (implMethodName.equals("getId")) {
                    z = true;
                    break;
                }
                break;
            case 482925913:
                if (implMethodName.equals("getDeviceCode")) {
                    z = true;
                    break;
                }
                break;
            case 483240439:
                if (implMethodName.equals("getDeviceName")) {
                    z = true;
                    break;
                }
                break;
            case 731625057:
                if (implMethodName.equals("getDeviceTypeId")) {
                    z = true;
                    break;
                }
                break;
            case 771206363:
                if (implMethodName.equals("getTenantId")) {
                    z = true;
                    break;
                }
                break;
            case 862572307:
                if (implMethodName.equals("getUrgency")) {
                    z = true;
                    break;
                }
                break;
            case 1071464927:
                if (implMethodName.equals("getCreateTime")) {
                    z = true;
                    break;
                }
                break;
            case 1317519847:
                if (implMethodName.equals("getMalfunctionTime")) {
                    z = false;
                    break;
                }
                break;
            case 1331332693:
                if (implMethodName.equals("getIsAffect")) {
                    z = true;
                    break;
                }
                break;
            case 1788066762:
                if (implMethodName.equals("getApplyStatus")) {
                    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/tpm/entity/RepairApply") && lambda.getImplMethodSignature().equals("()Ljava/time/LocalDateTime;")) {
                    return (v0) -> {
                        return v0.getMalfunctionTime();
                    };
                }
                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/core/mp/base/BaseEntity") && lambda.getImplMethodSignature().equals("()Ljava/util/Date;")) {
                    return (v0) -> {
                        return v0.getCreateTime();
                    };
                }
                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/tpm/entity/RepairApply") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
                    return (v0) -> {
                        return v0.getMalfunctionId();
                    };
                }
                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/tpm/entity/RepairApply") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) {
                    return (v0) -> {
                        return v0.getApplyCode();
                    };
                }
                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/tpm/entity/RepairApply") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) {
                    return (v0) -> {
                        return v0.getApplyCode();
                    };
                }
                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/tpm/entity/RepairApply") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) {
                    return (v0) -> {
                        return v0.getApplyCode();
                    };
                }
                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/core/mp/base/BaseEntity") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
                    return (v0) -> {
                        return v0.getId();
                    };
                }
                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/core/mp/base/BaseEntity") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
                    return (v0) -> {
                        return v0.getId();
                    };
                }
                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/core/mp/base/BaseEntity") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
                    return (v0) -> {
                        return v0.getId();
                    };
                }
                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/core/mp/base/BaseEntity") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
                    return (v0) -> {
                        return v0.getId();
                    };
                }
                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/core/mp/base/BaseEntity") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
                    return (v0) -> {
                        return v0.getId();
                    };
                }
                break;
            case RegionCache.VILLAGE_LEVEL /* 5 */:
                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/core/tenant/mp/TenantEntity") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) {
                    return (v0) -> {
                        return v0.getTenantId();
                    };
                }
                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/core/tenant/mp/TenantEntity") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) {
                    return (v0) -> {
                        return v0.getTenantId();
                    };
                }
                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/core/tenant/mp/TenantEntity") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) {
                    return (v0) -> {
                        return v0.getTenantId();
                    };
                }
                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/tpm/entity/RepairApply") && lambda.getImplMethodSignature().equals("()Ljava/lang/Integer;")) {
                    return (v0) -> {
                        return v0.getIsAffect();
                    };
                }
                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/tpm/entity/RepairApply") && lambda.getImplMethodSignature().equals("()Ljava/lang/Integer;")) {
                    return (v0) -> {
                        return v0.getIsAffect();
                    };
                }
                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/tpm/entity/RepairApply") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
                    return (v0) -> {
                        return v0.getDeviceId();
                    };
                }
                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/tpm/entity/RepairApply") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
                    return (v0) -> {
                        return v0.getDeviceId();
                    };
                }
                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/tpm/entity/RepairRecord") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
                    return (v0) -> {
                        return v0.getDeviceId();
                    };
                }
                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/tpm/entity/RepairApply") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) {
                    return (v0) -> {
                        return v0.getDeviceCode();
                    };
                }
                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/tpm/entity/RepairApply") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) {
                    return (v0) -> {
                        return v0.getDeviceCode();
                    };
                }
                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/tpm/entity/RepairApply") && lambda.getImplMethodSignature().equals("()Ljava/lang/Integer;")) {
                    return (v0) -> {
                        return v0.getApplyStatus();
                    };
                }
                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/tpm/entity/RepairApply") && lambda.getImplMethodSignature().equals("()Ljava/lang/Integer;")) {
                    return (v0) -> {
                        return v0.getApplyStatus();
                    };
                }
                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/tpm/entity/RepairApply") && lambda.getImplMethodSignature().equals("()Ljava/lang/Integer;")) {
                    return (v0) -> {
                        return v0.getApplyStatus();
                    };
                }
                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/tpm/entity/RepairApply") && lambda.getImplMethodSignature().equals("()Ljava/lang/Integer;")) {
                    return (v0) -> {
                        return v0.getApplyStatus();
                    };
                }
                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/tpm/entity/RepairApply") && lambda.getImplMethodSignature().equals("()Ljava/lang/Integer;")) {
                    return (v0) -> {
                        return v0.getApplyStatus();
                    };
                }
                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/tpm/entity/RepairApply") && lambda.getImplMethodSignature().equals("()Ljava/lang/Integer;")) {
                    return (v0) -> {
                        return v0.getApplyStatus();
                    };
                }
                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/tpm/entity/RepairApply") && lambda.getImplMethodSignature().equals("()Ljava/lang/Integer;")) {
                    return (v0) -> {
                        return v0.getApplyStatus();
                    };
                }
                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/tpm/entity/RepairApply") && lambda.getImplMethodSignature().equals("()Ljava/lang/Integer;")) {
                    return (v0) -> {
                        return v0.getApplyStatus();
                    };
                }
                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/tpm/entity/RepairApply") && lambda.getImplMethodSignature().equals("()Ljava/lang/Integer;")) {
                    return (v0) -> {
                        return v0.getApplyStatus();
                    };
                }
                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/tpm/entity/RepairApply") && lambda.getImplMethodSignature().equals("()Ljava/lang/Integer;")) {
                    return (v0) -> {
                        return v0.getApplyStatus();
                    };
                }
                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/tpm/entity/RepairApply") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
                    return (v0) -> {
                        return v0.getDeviceTypeId();
                    };
                }
                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/tpm/entity/RepairApply") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) {
                    return (v0) -> {
                        return v0.getDeviceName();
                    };
                }
                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/tpm/entity/RepairApply") && lambda.getImplMethodSignature().equals("()Ljava/lang/String;")) {
                    return (v0) -> {
                        return v0.getDeviceName();
                    };
                }
                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/tpm/entity/RepairApply") && lambda.getImplMethodSignature().equals("()Ljava/lang/Integer;")) {
                    return (v0) -> {
                        return v0.getUrgency();
                    };
                }
                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/tpm/entity/RepairApply") && lambda.getImplMethodSignature().equals("()Ljava/lang/Integer;")) {
                    return (v0) -> {
                        return v0.getUrgency();
                    };
                }
                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/tpm/entity/RepairRecord") && lambda.getImplMethodSignature().equals("()Ljava/lang/Integer;")) {
                    return (v0) -> {
                        return v0.getRecordStatus();
                    };
                }
                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/tpm/entity/RepairApplyFile") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
                    return (v0) -> {
                        return v0.getRepairApplyId();
                    };
                }
                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/tpm/entity/RepairApplyFile") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
                    return (v0) -> {
                        return v0.getRepairApplyId();
                    };
                }
                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/tpm/entity/RepairApplyFile") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
                    return (v0) -> {
                        return v0.getRepairApplyId();
                    };
                }
                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/tpm/entity/RepairApplyFile") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
                    return (v0) -> {
                        return v0.getRepairApplyId();
                    };
                }
                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/tpm/entity/RepairApplyFile") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
                    return (v0) -> {
                        return v0.getRepairApplyId();
                    };
                }
                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/tpm/entity/RepairRecord") && lambda.getImplMethodSignature().equals("()Ljava/lang/Long;")) {
                    return (v0) -> {
                        return v0.getRepairApplyId();
                    };
                }
                break;
        }
        throw new IllegalArgumentException("Invalid lambda deserialization");
    }

    @Override // org.springblade.modules.tpm.service.IRepairApplyService
    @Transactional(rollbackFor = {Exception.class})
    public RepairApply createRepairApply(RepairApplyAddVO repairApplyAddVO) {
        RepairApply repairApply = RepairApplyConvert.INSTANCE.convert(repairApplyAddVO);
        if (Func.isBlank(repairApply.getApplyCode())) {
            String code = this.codeGeneratorService.getGeneratorCode(repairApplyAddVO, MetaTypeEnum.REPAIR_APPLY.getCode());
            log.info("维修申请编码规则生成的code:{}", code + " ," + code.length());
            repairApply.setApplyCode(code);
        }
        if (checkApplyCode(repairApply.getApplyCode())) {
            throw new ServiceException(MessageUtils.message("cps.tpm.repair.apply.code.already.exists", new Object[0]));
        }
        repairApply.setApplyStatus(Integer.valueOf(RepairApplyStatusEnum.Y1.getType()));
        this.machineService.createRepairApplyUpdateMachine(repairApply.getDeviceId(), Integer.valueOf(DeviceRepairStatusEnum.TO_BE_REPAIRED.getType()));
        save(repairApply);
        if (Func.isNotEmpty(repairApplyAddVO.getFileAddDTOList())) {
            List<RepairApplyFile> repairApplyFileList = RepairApplyFileConvert.INSTANCE.convert(repairApplyAddVO.getFileAddDTOList());
            repairApplyFileList.forEach(s -> {
                s.setRepairApplyId(repairApply.getId());
            });
            this.iRepairApplyFileService.saveBatch(repairApplyFileList);
        }
        NotifyBusinessSendDTO notifyBusinessSend = repairApplyAddVO.getNotifyBusinessSend();
        sendMessage(repairApply, notifyBusinessSend);
        return repairApply;
    }

    private boolean checkApplyCode(String applyCode) {
        RepairApply repairApply = (RepairApply) this.baseMapper.selectOne((Wrapper) Wrappers.query().lambda().eq(Func.isNotEmpty(AuthUtil.getTenantId()), (v0) -> {
            return v0.getTenantId();
        }, AuthUtil.getTenantId()).eq((v0) -> {
            return v0.getApplyCode();
        }, applyCode));
        return repairApply != null;
    }

    @Override // org.springblade.modules.tpm.service.IRepairApplyService
    public RepairApplyDetailVO detailApply(Long id) {
        RepairApply repairApply = (RepairApply) this.baseMapper.selectOne((Wrapper) Wrappers.query().lambda().eq((v0) -> {
            return v0.getId();
        }, id));
        if (Func.isEmpty(repairApply)) {
            throw new ServiceException(MessageUtils.message("cps.tpm.repair.apply.not.exists", new Object[0]));
        }
        List<RepairApplyFile> fileList = this.iRepairApplyFileService.list((Wrapper) Wrappers.lambdaQuery().eq((v0) -> {
            return v0.getRepairApplyId();
        }, id));
        new RepairApplyDetailVO();
        RepairApplyDetailVO vo = RepairApplyConvert.INSTANCE.convert1(repairApply);
        Stream<RepairApplyFile> stream = fileList.stream();
        RepairApplyFileConvert repairApplyFileConvert = RepairApplyFileConvert.INSTANCE;
        repairApplyFileConvert.getClass();
        List<RepairApplyFileAddDTO> fileAddDtoList = (List) stream.map(this::convert).collect(Collectors.toList());
        if (Func.isNotEmpty(fileAddDtoList)) {
            vo.setFileAddDTOList(fileAddDtoList);
        } else {
            vo.setFileAddDTOList(new ArrayList());
        }
        return vo;
    }

    @Override // org.springblade.modules.tpm.service.IRepairApplyService
    public IPage<RepairApplyVO> getPageApply(RepairApplyLookVO repairApplyLookVO, Query query) {
        IPage<RepairApply> pages = page(Condition.getPage(query), (Wrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq(Func.isNotEmpty(AuthUtil.getTenantId()), (v0) -> {
            return v0.getTenantId();
        }, AuthUtil.getTenantId()).and(Func.isNotEmpty(repairApplyLookVO.getDeviceTypeId()), i -> {
            LambdaQueryWrapper lambdaQueryWrapper = (LambdaQueryWrapper) i.eq((v0) -> {
                return v0.getDeviceTypeId();
            }, repairApplyLookVO.getDeviceTypeId());
        }).and(CollectionUtil.isNotEmpty(repairApplyLookVO.getApplyStatusList()), i2 -> {
            LambdaQueryWrapper lambdaQueryWrapper = (LambdaQueryWrapper) i2.in((v0) -> {
                return v0.getApplyStatus();
            }, repairApplyLookVO.getApplyStatusList());
        }).and(Func.isNotEmpty(repairApplyLookVO.getKeyWords()), i3 -> {
            LambdaQueryWrapper lambdaQueryWrapper = (LambdaQueryWrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) i3.likeRight((v0) -> {
                return v0.getApplyCode();
            }, repairApplyLookVO.getKeyWords())).or()).likeRight((v0) -> {
                return v0.getDeviceCode();
            }, repairApplyLookVO.getKeyWords())).or()).likeRight((v0) -> {
                return v0.getDeviceName();
            }, repairApplyLookVO.getKeyWords());
        }).orderByAsc((v0) -> {
            return v0.getIsAffect();
        })).orderByDesc((v0) -> {
            return v0.getUrgency();
        })).orderByDesc((v0) -> {
            return v0.getCreateTime();
        })).orderByDesc((v0) -> {
            return v0.getId();
        }));
        return RepairApplyConvert.INSTANCE.convert((IPage) pages);
    }

    @Override // org.springblade.modules.tpm.service.IRepairApplyService
    public List<RepairApplyVO> queryApply(RepairApplyLookVO repairApplyLookVO) {
        List<RepairApply> pages = list((Wrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq(Func.isNotEmpty(AuthUtil.getTenantId()), (v0) -> {
            return v0.getTenantId();
        }, AuthUtil.getTenantId()).and(CollectionUtil.isNotEmpty(repairApplyLookVO.getApplyStatusList()), i -> {
            LambdaQueryWrapper lambdaQueryWrapper = (LambdaQueryWrapper) i.in((v0) -> {
                return v0.getApplyStatus();
            }, repairApplyLookVO.getApplyStatusList());
        }).and(Func.isNotEmpty(repairApplyLookVO.getKeyWords()), i2 -> {
            LambdaQueryWrapper lambdaQueryWrapper = (LambdaQueryWrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) i2.likeRight((v0) -> {
                return v0.getApplyCode();
            }, repairApplyLookVO.getKeyWords())).or()).likeRight((v0) -> {
                return v0.getDeviceCode();
            }, repairApplyLookVO.getKeyWords())).or()).likeRight((v0) -> {
                return v0.getDeviceName();
            }, repairApplyLookVO.getKeyWords());
        }).orderByAsc((v0) -> {
            return v0.getIsAffect();
        })).orderByDesc((v0) -> {
            return v0.getUrgency();
        })).orderByAsc((v0) -> {
            return v0.getMalfunctionTime();
        }));
        return RepairApplyConvert.INSTANCE.convert(pages);
    }

    @Override // org.springblade.modules.tpm.service.IRepairApplyService
    @Transactional(rollbackFor = {Exception.class})
    public boolean deleteRepairApply(List<Long> ids) {
        if (Func.isEmpty(ids) || ids.size() < 1) {
            throw new ServiceException(MessageUtils.message("cps.tpm.repair.delete.id.not.empty.and.least.one", new Object[0]));
        }
        if (!checkApplyStatus(ids)) {
            throw new ServiceException(MessageUtils.message("cps.tpm.repair.delete.apply.status.is.pending", new Object[0]));
        }
        for (Long id : ids) {
            RepairApply repairApply = (RepairApply) getById(id);
            removeById(id);
            List<RepairApplyFile> list = this.iRepairApplyFileService.list((Wrapper) Wrappers.lambdaQuery().eq((v0) -> {
                return v0.getRepairApplyId();
            }, id));
            if (Func.isNotEmpty(list)) {
                list.forEach(i -> {
                    this.iRepairApplyFileService.removeById(i.getId());
                });
            }
            List<RepairApply> y1List = list((Wrapper) ((LambdaQueryWrapper) Wrappers.query().lambda().eq((v0) -> {
                return v0.getDeviceId();
            }, repairApply.getDeviceId())).eq((v0) -> {
                return v0.getApplyStatus();
            }, Integer.valueOf(RepairApplyStatusEnum.Y1.getType())));
            List<RepairApply> y2List = list((Wrapper) ((LambdaQueryWrapper) Wrappers.query().lambda().eq((v0) -> {
                return v0.getDeviceId();
            }, repairApply.getDeviceId())).eq((v0) -> {
                return v0.getApplyStatus();
            }, Integer.valueOf(RepairApplyStatusEnum.Y2.getType())));
            List<RepairRecord> r1List = this.repairRecordService.list((Wrapper) ((LambdaQueryWrapper) Wrappers.query().lambda().eq((v0) -> {
                return v0.getDeviceId();
            }, repairApply.getDeviceId())).eq((v0) -> {
                return v0.getRecordStatus();
            }, Integer.valueOf(RepairRecordEnum.R1.getType())));
            this.machineService.updateMachineRepairPriority(repairApply.getDeviceId(), r1List, y2List, y1List);
        }
        return true;
    }

    private boolean checkApplyStatus(List<Long> ids) {
        List<RepairApply> list = list((Wrapper) ((LambdaQueryWrapper) Wrappers.query().lambda().ne((v0) -> {
            return v0.getApplyStatus();
        }, Integer.valueOf(RepairApplyStatusEnum.Y1.getType()))).in((v0) -> {
            return v0.getId();
        }, ids));
        return Func.isEmpty(list);
    }

    @Override // org.springblade.modules.tpm.service.IRepairApplyService
    public boolean checkRepairApplyStatus(Long id) {
        RepairApply repairApply = (RepairApply) this.baseMapper.selectOne((Wrapper) ((LambdaQueryWrapper) Wrappers.query().lambda().eq((v0) -> {
            return v0.getId();
        }, id)).eq((v0) -> {
            return v0.getApplyStatus();
        }, Integer.valueOf(RepairApplyStatusEnum.Y1.getType())));
        return Func.isNotEmpty(repairApply);
    }

    @Override // org.springblade.modules.tpm.service.IRepairApplyService
    @Transactional(rollbackFor = {Exception.class})
    public boolean implementApply(Long id) {
        if (!checkRepairApplyStatus(id)) {
            throw new ServiceException(MessageUtils.message("cps.tpm.repair.execution.apply.status.is.pending", new Object[0]));
        }
        RepairApply repairApply = (RepairApply) getOne((Wrapper) Wrappers.query().lambda().eq((v0) -> {
            return v0.getId();
        }, id));
        if (Func.isEmpty(repairApply)) {
            throw new ServiceException(MessageUtils.message("cps.tpm.repair.apply.not.exists", new Object[0]));
        }
        repairApply.setApplyStatus(Integer.valueOf(RepairApplyStatusEnum.Y2.getType()));
        repairApply.setStartTime(LocalDateTime.now());
        this.machineService.implementRepairApply(repairApply.getDeviceId(), Integer.valueOf(DeviceRepairStatusEnum.IN_MAINTENANCE.getType()));
        return updateById(repairApply);
    }

    @Override // org.springblade.modules.tpm.service.IRepairApplyService
    @Transactional(rollbackFor = {Exception.class})
    public RepairApply updateRepairApply(RepairApplyUpdateVO repairApplyUpdateVO) {
        RepairApply re = (RepairApply) getById(repairApplyUpdateVO.getId());
        if (Func.isNull(re)) {
            throw new ServiceException(MessageUtils.message("cps.tpm.repair.apply.not.exists", new Object[0]));
        }
        if (!checkRepairApplyStatus(repairApplyUpdateVO.getId())) {
            throw new ServiceException(MessageUtils.message("cps.tpm.repair.execution.apply.status.is.pending", new Object[0]));
        }
        RepairApply repairApply = RepairApplyConvert.INSTANCE.convertUpdate(repairApplyUpdateVO);
        updateById(repairApply);
        if (Func.isNotEmpty(repairApplyUpdateVO.getFileAddDTOList())) {
            List<RepairApplyFile> oldFiles = this.iRepairApplyFileService.list((Wrapper) Wrappers.query().lambda().eq((v0) -> {
                return v0.getRepairApplyId();
            }, repairApplyUpdateVO.getId()));
            if (!Func.isNull(oldFiles)) {
                this.iRepairApplyFileService.removeByIds((Collection) oldFiles.stream().map((v0) -> {
                    return v0.getId();
                }).collect(Collectors.toList()));
            }
            List<RepairApplyFile> newFiles = RepairApplyFileConvert.INSTANCE.convert(repairApplyUpdateVO.getFileAddDTOList());
            newFiles.forEach(s -> {
                s.setRepairApplyId(repairApply.getId());
            });
            this.iRepairApplyFileService.saveBatch(newFiles);
        } else {
            List<RepairApplyFile> oldFiles2 = this.iRepairApplyFileService.list((Wrapper) Wrappers.query().lambda().eq((v0) -> {
                return v0.getRepairApplyId();
            }, repairApplyUpdateVO.getId()));
            if (!Func.isNull(oldFiles2)) {
                this.iRepairApplyFileService.removeByIds((Collection) oldFiles2.stream().map((v0) -> {
                    return v0.getId();
                }).collect(Collectors.toList()));
            }
        }
        updateApplyMalFunction(repairApplyUpdateVO.getMalfunctionId(), repairApplyUpdateVO.getMalfunctionName(), repairApplyUpdateVO.getMalfunctionCode(), Integer.valueOf(ActionEnum.UPDATE_MAL.getType()));
        return re;
    }

    @Override // org.springblade.modules.tpm.service.IRepairApplyService
    public RepairFileVO getFileAndDes(Long id) {
        RepairApply repairApply = (RepairApply) getById(id);
        if (Func.isNull(repairApply)) {
            throw new ServiceException(MessageUtils.message("cps.tpm.repair.apply.not.exists", new Object[0]));
        }
        List<RepairApplyFile> files = this.iRepairApplyFileService.list((Wrapper) Wrappers.query().lambda().eq((v0) -> {
            return v0.getRepairApplyId();
        }, id));
        RepairFileVO repairFileVo = new RepairFileVO();
        if (!Func.isNull(repairApply.getDescription())) {
            repairFileVo.setDescription(repairApply.getDescription());
        }
        if (!Func.isNull(files)) {
            Stream<RepairApplyFile> stream = files.stream();
            RepairApplyFileConvert repairApplyFileConvert = RepairApplyFileConvert.INSTANCE;
            repairApplyFileConvert.getClass();
            repairFileVo.setFileAddDTOList((List) stream.map(this::convert).collect(Collectors.toList()));
        } else {
            repairFileVo.setFileAddDTOList(new ArrayList());
        }
        return repairFileVo;
    }

    @Override // org.springblade.modules.tpm.service.IRepairApplyService
    public List<ApplyCodeVO> queryApplyCode() {
        List<RepairApply> list = list((Wrapper) Wrappers.query().lambda().eq((v0) -> {
            return v0.getApplyStatus();
        }, Integer.valueOf(RepairApplyStatusEnum.Y2.getType())));
        if (Func.isNotEmpty(list)) {
            return (List) list.stream().map(i -> {
                ApplyCodeVO applyCodeVo = new ApplyCodeVO();
                applyCodeVo.setId(i.getId());
                applyCodeVo.setApplyCode(i.getApplyCode());
                return applyCodeVo;
            }).collect(Collectors.toList());
        }
        return new ArrayList();
    }

    @Override // org.springblade.modules.tpm.service.IRepairApplyService
    public List<RepairApply> getRepairApplyByMalId(Long malId) {
        List<RepairApply> repairApplyList = list((Wrapper) ((LambdaQueryWrapper) Wrappers.query().lambda().eq((v0) -> {
            return v0.getMalfunctionId();
        }, malId)).and(i -> {
            LambdaQueryWrapper lambdaQueryWrapper = (LambdaQueryWrapper) i.ne((v0) -> {
                return v0.getApplyStatus();
            }, Integer.valueOf(RepairApplyStatusEnum.Y4.getType()));
        }));
        if (Func.isNull(repairApplyList)) {
            throw new ServiceException(MessageUtils.message("cps.tpm.repair.apply.malfunction.not.exists", new Object[0]));
        }
        return repairApplyList;
    }

    @Override // org.springblade.modules.tpm.service.IRepairApplyService
    public boolean updateApplyMalFunction(Long malId, String malName, String malCode, Integer action) {
        List<RepairApply> repairApplyByMalList = getRepairApplyByMalId(malId);
        if (Func.isNotEmpty(repairApplyByMalList)) {
            List<RepairApply> collect = null;
            if (action.equals(Integer.valueOf(ActionEnum.UPDATE_MAL.getType()))) {
                collect = (List) repairApplyByMalList.stream().map(i -> {
                    i.setMalfunctionId(malId);
                    i.setMalfunctionName(malName);
                    i.setMalfunctionCode(malCode);
                    return i;
                }).collect(Collectors.toList());
            } else if (action.equals(Integer.valueOf(ActionEnum.DELETE_MAL.getType()))) {
                collect = (List) repairApplyByMalList.stream().peek(i2 -> {
                    i2.setMalfunctionId(null);
                    i2.setMalfunctionName(null);
                    i2.setMalfunctionCode(null);
                }).collect(Collectors.toList());
            }
            updateBatchById(collect);
            return true;
        }
        return false;
    }

    @Override // org.springblade.modules.tpm.service.IRepairApplyService
    public boolean updateApplyByRecord(Long applyId, Long malId, String malName, String malCode) {
        RepairApply repairApply = (RepairApply) getById(applyId);
        if (Func.isNull(repairApply)) {
            throw new ServiceException(MessageUtils.message("cps.tpm.repair.apply.not.exists", new Object[0]));
        }
        repairApply.setMalfunctionId(malId).setMalfunctionCode(malCode).setMalfunctionName(malName);
        return updateById(repairApply);
    }

    @Override // org.springblade.modules.tpm.service.IRepairApplyService
    public List<RepairApplyExcelVO> exportRepairApply(RepairApplyExportVO repairApplyExportVO) {
        List<RepairApplyExcelVO> repairApplyExcelVoList = this.baseMapper.exportApplyVo(repairApplyExportVO, AuthUtil.getTenantId());
        if (Func.isNotEmpty(repairApplyExcelVoList)) {
            repairApplyExcelVoList.forEach(i -> {
                if (Func.isNotBlank(i.getUrgency())) {
                    if (i.getUrgency().equals(String.valueOf(UrgencyEnum.U1.getType()))) {
                        i.setUrgency(UrgencyEnum.U1.getDesc());
                    } else if (i.getUrgency().equals(String.valueOf(UrgencyEnum.U2.getType()))) {
                        i.setUrgency(UrgencyEnum.U2.getDesc());
                    } else {
                        i.setUrgency(UrgencyEnum.U3.getDesc());
                    }
                }
            });
            return repairApplyExcelVoList;
        }
        return new ArrayList();
    }

    @Override // org.springblade.modules.tpm.service.IRepairApplyService
    public IPage<RepairApplyVO> applyWaringPage(RepairApplySearchVO repairApplySearchVO, Query query) {
        IPage<RepairApplyVO> page = Condition.getPage(query);
        List<RepairApplyVO> vos = this.baseMapper.pageRepairApplyToday(query, page, repairApplySearchVO);
        return page.setRecords(vos);
    }

    @Override // org.springblade.modules.tpm.service.IRepairApplyService
    public Long countApplyNum() {
        Long count = Long.valueOf(count((Wrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> {
            return v0.getApplyStatus();
        }, Integer.valueOf(RepairApplyStatusEnum.Y2.getType()))).or()).eq((v0) -> {
            return v0.getApplyStatus();
        }, Integer.valueOf(RepairApplyStatusEnum.Y1.getType()))));
        return (Long) Optional.of(count).orElse(0L);
    }

    @Override // org.springblade.modules.tpm.service.IRepairApplyService
    public RepairApplyDetailVO detail(Long id) {
        RepairApplyDetailVO repairApplyDetailVO = detailApply(id);
        RepairRecord bean = (RepairRecord) this.repairRecordService.getOne((Wrapper) Wrappers.query().lambda().eq((v0) -> {
            return v0.getRepairApplyId();
        }, id));
        if (bean != null) {
            repairApplyDetailVO.setRepairRecordDetailVO(this.repairRecordService.detailRecord(bean.getId()));
        }
        return repairApplyDetailVO;
    }

    private void sendMessage(RepairApply repairApply, NotifyBusinessSendDTO notifyBusinessSend) {
        BusinessSend businessSend = this.businessSendFactory.getBusinessSend(NotifyConstant.MAINTENANCE_APPLY);
        businessSend.saveState(repairApply, notifyBusinessSend);
    }

    @Override // org.springblade.modules.tpm.service.IRepairApplyService
    public IPage<RepairApplyVO> getPageApplyForHmi(Long workstationId, Query query) {
        WorkstationVO workstationVO = this.workstationService.getDetail(workstationId);
        return this.baseMapper.getPageApplyForHmi(workstationVO.getMachineId(), Condition.getPage(query));
    }
}