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

import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Map;
import java.util.function.Function;
import java.util.stream.Collectors;

import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.qianwen.core.log.exception.ServiceException;
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.oss.model.OssFile;
import com.qianwen.core.secure.utils.AuthUtil;
import com.qianwen.core.tool.utils.Func;
import com.qianwen.smartman.common.constant.CommonConstant;
import com.qianwen.smartman.common.utils.MessageUtils;
import com.qianwen.smartman.modules.dnc.convert.DncFactoryFileConvert;
import com.qianwen.smartman.modules.dnc.dto.DncOperationLogDto;
import com.qianwen.smartman.modules.dnc.entity.DncFactoryFile;
import com.qianwen.smartman.modules.dnc.enums.DncEnums;
import com.qianwen.smartman.modules.dnc.mapper.DncFactoryFileMapper;
import com.qianwen.smartman.modules.dnc.service.IDncFactoryFileService;
import com.qianwen.smartman.modules.dnc.service.IDncOperationLogService;
import com.qianwen.smartman.modules.dnc.service.IObsFileService;
import com.qianwen.smartman.modules.dnc.vo.DncFactoryFileVO;
import com.qianwen.smartman.modules.dnc.vo.FileHistoryVO;
import com.qianwen.smartman.modules.dnc.vo.FileVersionSwitchVO;
import com.qianwen.smartman.modules.resource.builder.oss.OssBuilder;
import com.qianwen.smartman.modules.system.entity.User;
import com.qianwen.smartman.modules.system.service.IUserService;

@Service
/* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/dnc/service/impl/DncFactoryFileServiceImpl.class */
public class DncFactoryFileServiceImpl extends BaseServiceImpl<DncFactoryFileMapper, DncFactoryFile> implements IDncFactoryFileService {
    private final IUserService userService;
    private final IDncOperationLogService dncOperationLogService;
    private final IObsFileService obsFileService;
    private final OssBuilder ossBuilder;


    public DncFactoryFileServiceImpl(final IUserService userService, final IDncOperationLogService dncOperationLogService, final IObsFileService obsFileService, final OssBuilder ossBuilder) {
        this.userService = userService;
        this.dncOperationLogService = dncOperationLogService;
        this.obsFileService = obsFileService;
        this.ossBuilder = ossBuilder;
    }

    @Override // org.springblade.modules.dnc.service.IDncFactoryFileService
    public DncFactoryFileVO addFactoryFile(DncFactoryFileVO dncFactoryFileVO) {
        DncFactoryFile dncFactoryFile = DncFactoryFileConvert.INSTANCE.convert(dncFactoryFileVO);
        String filename = dncFactoryFileVO.getFilename();
        
        DncFactoryFile oldFile = getOne(Wrappers.<DncFactoryFile>lambdaQuery()
                .eq(DncFactoryFile::getFilename, filename)
                .eq(DncFactoryFile::getIsCurrent, DncEnums.CurrentVersion.YES.getCode()));
        /*
        DncFactoryFile oldFile = (DncFactoryFile) getOne((Wrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> {
            return v0.getFilename();
        }, filename)).eq((v0) -> {
            return v0.getIsCurrent();
        }, DncEnums.CurrentVersion.YES.getCode()));*/
        OssFile ossFile = this.ossBuilder.template().statFile(dncFactoryFile.getObjectKey());
        String hash = ossFile.getHash();
        if (Func.isNull(oldFile)) {
            dncFactoryFile.setContentMd5(hash);
            dncFactoryFile.setVersion(CommonConstant.VERSION_NUM);
            saveFactoryFile(dncFactoryFileVO, dncFactoryFile, filename);
        } else if (!hash.equals(oldFile.getContentMd5())) {
        	update(Wrappers.<DncFactoryFile>lambdaUpdate()
        	          .eq(DncFactoryFile::getFilename, filename)
        	          .set(DncFactoryFile::getIsCurrent, DncEnums.CurrentVersion.NO.getCode()));
        	/*
            update((Wrapper) ((LambdaUpdateWrapper) Wrappers.lambdaUpdate().eq((v0) -> {
                return v0.getFilename();
            }, filename)).set((v0) -> {
                return v0.getIsCurrent();
            }, DncEnums.CurrentVersion.NO.getCode()));*/
            dncFactoryFile.setContentMd5(hash);
            dncFactoryFile.setVersion(Integer.valueOf((oldFile.getVersion() != null ? oldFile.getVersion() : CommonConstant.VERSION_NUM).intValue() + CommonConstant.VERSION_NUM.intValue()));
            saveFactoryFile(dncFactoryFileVO, dncFactoryFile, filename);
        }
        return dncFactoryFileVO;
    }

    private void saveFactoryFile(DncFactoryFileVO dncFactoryFileVO, DncFactoryFile dncFactoryFile, String filename) {
        dncFactoryFile.setIsCurrent(DncEnums.CurrentVersion.YES.getCode());
        save(dncFactoryFile);
        DncOperationLogDto dncOperationLogDto = new DncOperationLogDto();
        dncOperationLogDto.setFileId(dncFactoryFile.getId()).setFileName(filename).setObjectKey(dncFactoryFileVO.getObjectKey()).setSuffix(dncFactoryFileVO.getSuffix()).setOperatorId(AuthUtil.getUserId()).setOperatorName(AuthUtil.getUserAccount()).setOperationType(DncEnums.LogOperationType.UPLOAD.getCode()).setOperationResponse(CommonConstant.VERSION_NUM).setOperationTime(new Date()).setSourceType(DncEnums.LogFileSourceType.LOCAL_FILE.getCode()).setTargetType(DncEnums.LogFileSourceType.STATION_FILE.getCode()).setLink(dncFactoryFileVO.getLink()).setFileLocation(DncEnums.FileLocation.ETHERNET.getCode()).setVersion(dncFactoryFile.getVersion());
        this.dncOperationLogService.insertLog(dncOperationLogDto);
    }

    @Override // org.springblade.modules.dnc.service.IDncFactoryFileService
    public void writeFileLog(DncFactoryFile dncFactoryFile) {
        DncOperationLogDto dncOperationLogDto = new DncOperationLogDto();
        dncOperationLogDto.setFileId(dncFactoryFile.getId()).setFileName(dncFactoryFile.getFilename()).setObjectKey(dncFactoryFile.getObjectKey()).setSuffix(dncFactoryFile.getSuffix()).setOperatorId(AuthUtil.getUserId()).setOperatorName(AuthUtil.getUserAccount()).setOperationType(DncEnums.LogOperationType.DELETE.getCode()).setOperationResponse(CommonConstant.VERSION_NUM).setOperationTime(new Date()).setSourceType(DncEnums.LogFileSourceType.STATION_FILE.getCode()).setTargetType(DncEnums.LogFileSourceType.STATION_FILE.getCode()).setLink(dncFactoryFile.getLink()).setFileLocation(DncEnums.FileLocation.ETHERNET.getCode()).setVersion(dncFactoryFile.getVersion());
        this.dncOperationLogService.insertLog(dncOperationLogDto);
    }

    @Override // org.springblade.modules.dnc.service.IDncFactoryFileService
    public Boolean verifyFileName(String fileName, String objectKey) {
    	DncFactoryFile one = getOne(Wrappers.<DncFactoryFile>lambdaQuery().eq(DncFactoryFile::getFilename, fileName)
    			.eq(DncFactoryFile::getIsCurrent, DncEnums.CurrentVersion.YES.getCode()));
    	/*
        DncFactoryFile one = (DncFactoryFile) getOne((Wrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> {
            return v0.getFilename();
        }, fileName)).eq((v0) -> {
            return v0.getIsCurrent();
        }, DncEnums.CurrentVersion.YES.getCode()));*/
        if (one != null) {
            boolean result = this.obsFileService.verifyFileContent(objectKey, one.getContentMd5());
            if (result) {
                return true;
            }
        }
        return false;
    }

    @Override // org.springblade.modules.dnc.service.IDncFactoryFileService
    public IPage<DncFactoryFileVO> listPages(String keywords, Query query) {
        Map<Long, User> userMap = this.userService.list().stream().collect(Collectors.toMap((v0) -> {
            return v0.getId();
        }, Function.identity()));
        
        IPage<DncFactoryFile> pages = page(Condition.getPage(query), Wrappers.<DncFactoryFile>lambdaQuery()
                .eq(DncFactoryFile::getIsCurrent, DncEnums.CurrentVersion.YES.getCode())
                .and(Func.isNotEmpty(keywords), i -> i.likeRight(DncFactoryFile::getFilename, keywords).or().likeRight(DncFactoryFile::getSuffix, keywords))
                
                .orderByDesc(DncFactoryFile::getCreateTime));
        /*
        IPage<DncFactoryFile> pages = page(Condition.getPage(query), (Wrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> {
            return v0.getIsCurrent();
        }, DncEnums.CurrentVersion.YES.getCode())).and(Func.isNotEmpty(keywords), i -> {
            LambdaQueryWrapper lambdaQueryWrapper = (LambdaQueryWrapper) ((LambdaQueryWrapper) ((LambdaQueryWrapper) i.likeRight((v0) -> {
                return v0.getFilename();
            }, keywords)).or()).likeRight((v0) -> {
                return v0.getSuffix();
            }, keywords);
        }).orderByDesc((v0) -> {
            return v0.getCreateTime();
        }));*/
        IPage<DncFactoryFileVO> convert = DncFactoryFileConvert.INSTANCE.convert(pages);
        convert.getRecords().forEach(s -> {
            User upUser = (User) userMap.get(s.getUpdateUser());
            User crUser = (User) userMap.get(s.getCreateUser());
            s.setUpdateUserName(upUser != null ? upUser.getAccount() : "");
            s.setCreateUserName(crUser != null ? crUser.getAccount() : "");
            s.setVersionDesc(Func.isNotEmpty(s.getVersion()) ? s.getVersion() + CommonConstant.FILE_SUFFIX : "");
        });
        return convert;
    }

    @Override // org.springblade.modules.dnc.service.IDncFactoryFileService
    public List<FileHistoryVO> getFactoryFileHistory(String fileId) {
        Map<Long, User> userMap = this.userService.list().stream().collect(Collectors.toMap((v0) -> {
            return v0.getId();
        }, Function.identity()));
        DncFactoryFile dncFactoryFile = (DncFactoryFile) getById(fileId);
        if (dncFactoryFile == null) {
            throw new ServiceException(MessageUtils.message("dnc.file.is.not.exists", new Object[0]));
        }
        List<DncFactoryFile> list = list(Wrappers.<DncFactoryFile>lambdaQuery()
                .eq(DncFactoryFile::getFilename, dncFactoryFile.getFilename())
                .orderByDesc(DncFactoryFile::getVersion));
        /*
        List<DncFactoryFile> list = list((Wrapper) ((LambdaQueryWrapper) Wrappers.lambdaQuery().eq((v0) -> {
            return v0.getFilename();
        }, dncFactoryFile.getFilename())).orderByDesc((v0) -> {
            return v0.getVersion();
        }));*/
        if (Func.isNotEmpty(list)) {
            return  list.stream().map(s -> {
                return FileHistoryVO.builder().id(s.getId()).createTime(s.getCreateTime()).filename(s.getFilename()).objectKey(s.getObjectKey()).isCurrent(s.getIsCurrent()).link(s.getLink()).contentMd5(s.getContentMd5()).contentLength(s.getContentLength()).contentType(s.getContentType()).suffix(s.getSuffix()).createUser(((User) userMap.get(s.getCreateUser())).getAccount()).updateUser(((User) userMap.get(s.getUpdateUser())).getAccount()).updateTime(s.getUpdateTime()).version(s.getVersion() != null ? String.valueOf(s.getVersion()) : "1").versionDesc(s.getVersion() != null ? s.getVersion() + CommonConstant.FILE_SUFFIX : CommonConstant.VERSION_NUM + CommonConstant.FILE_SUFFIX).build();
            }).collect(Collectors.toList());
        }
        return new ArrayList<>();
    }

    @Override // org.springblade.modules.dnc.service.IDncFactoryFileService
    @Transactional(rollbackFor = {Exception.class})
    public Boolean switchVersion(FileVersionSwitchVO fileVersionSwitchVO) {
        boolean result = false;
        if (Func.isNotBlank(fileVersionSwitchVO.getSwitchFileId()) && Func.isNotBlank(fileVersionSwitchVO.getCurrentFileId())) {
            DncFactoryFile file = (DncFactoryFile) getById(fileVersionSwitchVO.getCurrentFileId());
            if (file == null || !DncEnums.CurrentVersion.YES.getCode().equals(file.getIsCurrent())) {
                throw new ServiceException(MessageUtils.message("dnc.workstation.file.is.not.exist.or.is.not.current.version", new Object[0]));
            }
            boolean updateSwitch = update(Wrappers.<DncFactoryFile>lambdaUpdate().set(DncFactoryFile::getIsCurrent, DncEnums.CurrentVersion.YES.getCode()).eq(DncFactoryFile::getId, fileVersionSwitchVO.getSwitchFileId()));
            boolean updateCurrent = update(Wrappers.<DncFactoryFile>lambdaUpdate().set(DncFactoryFile::getIsCurrent, DncEnums.CurrentVersion.NO.getCode()).eq(DncFactoryFile::getId, fileVersionSwitchVO.getCurrentFileId()));
            /*
            boolean updateSwitch = update((Wrapper) ((LambdaUpdateWrapper) Wrappers.lambdaUpdate().set((v0) -> {
                return v0.getIsCurrent();
            }, DncEnums.CurrentVersion.YES.getCode())).eq((v0) -> {
                return v0.getId();
            }, fileVersionSwitchVO.getSwitchFileId()));
            boolean updateCurrent = update((Wrapper) ((LambdaUpdateWrapper) Wrappers.lambdaUpdate().set((v0) -> {
                return v0.getIsCurrent();
            }, DncEnums.CurrentVersion.NO.getCode())).eq((v0) -> {
                return v0.getId();
            }, fileVersionSwitchVO.getCurrentFileId()));*/
            if (updateSwitch && updateCurrent) {
                result = true;
            }
        }
        return Boolean.valueOf(result);
    }
}