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

import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Optional;
import java.util.stream.Collectors;

import org.springframework.stereotype.Service;

import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.qianwen.core.mp.base.BaseServiceImpl;
import com.qianwen.core.mp.support.Condition;
import com.qianwen.core.mp.support.Query;
import com.qianwen.core.tool.utils.Func;
import com.qianwen.smartman.common.constant.CommonConstant;
import com.qianwen.smartman.modules.dnc.convert.DncOperationLogConvert;
import com.qianwen.smartman.modules.dnc.dto.DncOperationLogDto;
import com.qianwen.smartman.modules.dnc.entity.DncOperationLog;
import com.qianwen.smartman.modules.dnc.enums.DncEnums;
import com.qianwen.smartman.modules.dnc.mapper.DncOperationLogMapper;
import com.qianwen.smartman.modules.dnc.service.IDncOperationLogService;
import com.qianwen.smartman.modules.dnc.vo.DncLogExcelVO;
import com.qianwen.smartman.modules.dnc.vo.DncOperationLogSearchVO;
import com.qianwen.smartman.modules.dnc.vo.DncOperationLogVO;
import com.qianwen.smartman.modules.dnc.vo.LogSearchVO;
import com.qianwen.smartman.modules.dnc.vo.SuffixListVO;

@Service
/* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/dnc/service/impl/DncOperationLogServiceImpl.class */
public class DncOperationLogServiceImpl extends BaseServiceImpl<DncOperationLogMapper, DncOperationLog> implements IDncOperationLogService {
    

    @Override // org.springblade.modules.dnc.service.IDncOperationLogService
    public IPage<DncOperationLogVO> listPages(String workstationId, LogSearchVO search, Query query) {
        String fileName = search.getFileName();
        String fileType = search.getFileType();
        Date operationStartTime = search.getOperationStartTime();
        Date operationEndTime = search.getOperationEndTime();
        String operationType = search.getOperationType();
        
        IPage<DncOperationLog> pages = page(Condition.getPage(query),Wrappers.<DncOperationLog>lambdaQuery()
                .eq(DncOperationLog::getWorkstationId, workstationId)
                .likeRight(Func.isNotEmpty(fileName), DncOperationLog::getFileName, fileName)
                .eq(Func.isNotBlank(fileType), DncOperationLog::getSuffix, fileType)
                .ge(Func.isNotEmpty(operationStartTime), DncOperationLog::getCreateTime, operationStartTime)
                .le(Func.isNotEmpty(operationEndTime), DncOperationLog::getCreateTime, operationEndTime)
                .eq(Func.isNotBlank(operationType), DncOperationLog::getOperationType, operationType)
                .orderByDesc(DncOperationLog::getCreateTime));
        /*
        IPage<DncOperationLog> pages = page(Condition.getPage(query), (Wrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> {
            return v0.getWorkstationId();
        }, workstationId)).likeRight(Func.isNotEmpty(fileName), (v0) -> {
            return v0.getFileName();
        }, fileName).eq(Func.isNotBlank(fileType), (v0) -> {
            return v0.getSuffix();
        }, fileType).ge(Func.isNotEmpty(operationStartTime), (v0) -> {
            return v0.getCreateTime();
        }, operationStartTime).le(Func.isNotEmpty(operationEndTime), (v0) -> {
            return v0.getCreateTime();
        }, operationEndTime).eq(Func.isNotBlank(operationType), (v0) -> {
            return v0.getOperationType();
        }, operationType).orderByDesc((v0) -> {
            return v0.getCreateTime();
        }));*/
        IPage<DncOperationLogVO> dncOperationLogVOIPage = Optional.<IPage<DncOperationLog>>ofNullable(pages).map(DncOperationLogConvert.INSTANCE::convert).orElse(new Page<>());
        dncOperationLogVOIPage.getRecords().forEach(dncOperationLogVO -> dncOperationLogVO.setVersion((dncOperationLogVO.getVersion() == null) ? "" : (dncOperationLogVO.getVersion() + CommonConstant.FILE_SUFFIX)));
        /*
        DncOperationLogConvert dncOperationLogConvert = DncOperationLogConvert.INSTANCE;
        dncOperationLogConvert.getClass();
        IPage<DncOperationLogVO> dncOperationLogVOIPage = ofNullable.map(this::convert).orElse(new Page());
        dncOperationLogVOIPage.getRecords().forEach(dncOperationLogVO -> {
            dncOperationLogVO.setVersion(dncOperationLogVO.getVersion() == null ? "" : dncOperationLogVO.getVersion() + CommonConstant.FILE_SUFFIX);
        });*/
        return dncOperationLogVOIPage;
    }

    @Override // org.springblade.modules.dnc.service.IDncOperationLogService
    public void insertLog(DncOperationLogDto operationLog) {
        DncOperationLog log = DncOperationLogConvert.INSTANCE.convert(operationLog);
        log.setTenantId("000000");
        save(log);
    }

    @Override // org.springblade.modules.dnc.service.IDncOperationLogService
    public IPage<DncOperationLogVO> allDataPage(DncOperationLogSearchVO search, Query query) {
    	IPage<DncOperationLog> pages = page(Condition.getPage(query), Wrappers.<DncOperationLog>lambdaQuery()
    	        .and(Func.isNotEmpty(search.getKeyWord()), i -> i.likeRight(DncOperationLog::getFileName, search.getKeyWord()).or()
    	        		.likeRight(DncOperationLog::getSuffix, search.getKeyWord()))
    	        
    	        .eq(Func.isNotEmpty(search.getOperationType()), DncOperationLog::getOperationType, search.getOperationType())
    	        .eq(Func.isNotEmpty(search.getSourceType()), DncOperationLog::getSourceType, search.getSourceType())
    	        .between((Func.isNotEmpty(search.getStartTime()) && Func.isNotEmpty(search.getEndTime())), DncOperationLog::getCreateTime, search.getStartTime(), search.getEndTime())
    	        .orderByDesc(DncOperationLog::getCreateTime));
    	/*
        IPage<DncOperationLog> pages = page(Condition.getPage(query), (Wrapper) Wrappers.lambdaQuery().and(Func.isNotEmpty(search.getKeyWord()), i -> {
            LambdaQueryWrapper lambdaQueryWrapper = (LambdaQueryWrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) i.likeRight((v0) -> {
                return v0.getFileName();
            }, search.getKeyWord())).or()).likeRight((v0) -> {
                return v0.getSuffix();
            }, search.getKeyWord());
        }).eq(Func.isNotEmpty(search.getOperationType()), (v0) -> {
            return v0.getOperationType();
        }, search.getOperationType()).eq(Func.isNotEmpty(search.getSourceType()), (v0) -> {
            return v0.getSourceType();
        }, search.getSourceType()).between(Func.isNotEmpty(search.getStartTime()) && Func.isNotEmpty(search.getEndTime()), (v0) -> {
            return v0.getCreateTime();
        }, search.getStartTime(), search.getEndTime()).orderByDesc((v0) -> {
            return v0.getCreateTime();
        }));*/
        IPage<DncOperationLogVO> convert = DncOperationLogConvert.INSTANCE.convert( pages);
        convert.getRecords().forEach(dncOperationLogVO -> {
            dncOperationLogVO.setVersion(Func.isNotBlank(dncOperationLogVO.getVersion()) ? dncOperationLogVO.getVersion() + CommonConstant.FILE_SUFFIX : "");
        });
        return convert;
    }

    @Override // org.springblade.modules.dnc.service.IDncOperationLogService
    public List<DncLogExcelVO> exportDncLog(DncOperationLogSearchVO dncOperationLogSearchVO) {
    	List<DncOperationLog> list = list(Wrappers.<DncOperationLog>lambdaQuery()
    	        .and(Func.isNotEmpty(dncOperationLogSearchVO.getKeyWord()), i -> i.likeRight(DncOperationLog::getFileName, dncOperationLogSearchVO.getKeyWord()).or()
    	        		.likeRight(DncOperationLog::getSuffix, dncOperationLogSearchVO.getKeyWord()))
    	        
    	        .eq(Func.isNotEmpty(dncOperationLogSearchVO.getOperationType()), DncOperationLog::getOperationType, dncOperationLogSearchVO.getOperationType())
    	        .eq(Func.isNotEmpty(dncOperationLogSearchVO.getSourceType()), DncOperationLog::getSourceType, dncOperationLogSearchVO.getSourceType())
    	        .between((Func.isNotEmpty(dncOperationLogSearchVO.getStartTime()) && Func.isNotEmpty(dncOperationLogSearchVO.getEndTime())), DncOperationLog::getCreateTime, dncOperationLogSearchVO.getStartTime(), dncOperationLogSearchVO.getEndTime())
    	        .orderByDesc(DncOperationLog::getCreateTime));
    	/*
        List<DncOperationLog> list = list((Wrapper) Wrappers.lambdaQuery().and(Func.isNotEmpty(dncOperationLogSearchVO.getKeyWord()), i -> {
            LambdaQueryWrapper lambdaQueryWrapper = (LambdaQueryWrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) i.likeRight((v0) -> {
                return v0.getFileName();
            }, dncOperationLogSearchVO.getKeyWord())).or()).likeRight((v0) -> {
                return v0.getSuffix();
            }, dncOperationLogSearchVO.getKeyWord());
        }).eq(Func.isNotEmpty(dncOperationLogSearchVO.getOperationType()), (v0) -> {
            return v0.getOperationType();
        }, dncOperationLogSearchVO.getOperationType()).eq(Func.isNotEmpty(dncOperationLogSearchVO.getSourceType()), (v0) -> {
            return v0.getSourceType();
        }, dncOperationLogSearchVO.getSourceType()).between(Func.isNotEmpty(dncOperationLogSearchVO.getStartTime()) && Func.isNotEmpty(dncOperationLogSearchVO.getEndTime()), (v0) -> {
            return v0.getCreateTime();
        }, dncOperationLogSearchVO.getStartTime(), dncOperationLogSearchVO.getEndTime()).orderByDesc((v0) -> {
            return v0.getCreateTime();
        }));*/
        if (Func.isNotEmpty(list)) {
            return list.stream().map(s -> {
                return DncLogExcelVO.builder().fileName(s.getFileName()).operatorName(s.getOperatorName()).operationType(s.getOperationType()).operationTypeDesc(DncEnums.LogOperationType.getNameByCode(s.getOperationType())).sourceTypeDesc(DncEnums.LogFileSourceType.getNameByCode(s.getSourceType())).operationTime(s.getOperationTime()).sourceType(s.getSourceType()).sourcePathName(s.getSourcePathName()).targetPathName(s.getTargetPathName()).fileLocationDesc(DncEnums.FileLocation.getNameByCode(s.getFileLocation())).storageSpaceDec(DncEnums.StorageSpace.getNameByCode(s.getStorageSpace())).version((s.getVersion() != null ? s.getVersion() : CommonConstant.VERSION_NUM) + CommonConstant.FILE_SUFFIX).suffix(s.getSuffix()).build();
            }).collect(Collectors.toList());
        }
        return new ArrayList<>();
    }

    @Override // org.springblade.modules.dnc.service.IDncOperationLogService
    public SuffixListVO getSuffixList() {
        List<String> suffixList = list().stream().map((v0) -> {
            return v0.getSuffix();
        }).filter((v0) -> {
            return Func.isNotEmpty(v0);
        }).collect(Collectors.toList());
        return SuffixListVO.builder().suffix(suffixList).build();
    }
}