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

import cn.hutool.core.collection.CollectionUtil;
import com.alibaba.excel.write.merge.AbstractMergeStrategy;
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 com.baomidou.mybatisplus.extension.toolkit.SqlHelper;
import java.lang.invoke.SerializedLambda;
import java.util.Collection;
import java.util.List;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.stream.Collectors;
import java.util.stream.Stream;
import javax.servlet.http.HttpServletResponse;
import com.qianwen.smartman.common.constant.ExcelConstant;
import com.qianwen.smartman.common.constant.I18nRedisKeyConstant;
import com.qianwen.smartman.common.utils.Lambda;
import com.qianwen.smartman.common.utils.MessageUtils;
import com.qianwen.core.excel.util.ExcelUtil;
import com.qianwen.core.log.exception.ServiceException;
import com.qianwen.core.oss.model.BladeFile;
import com.qianwen.core.tool.jackson.JsonUtil;
import com.qianwen.core.tool.utils.DateUtil;
import com.qianwen.core.tool.utils.Func;
import com.qianwen.smartman.modules.resource.builder.oss.OssBuilder;
import com.qianwen.smartman.modules.system.convert.I18nDataConverter;
import com.qianwen.smartman.modules.system.dto.I18nDataDTO;
import com.qianwen.smartman.modules.system.dto.I18nDataQueryDTO;
import com.qianwen.smartman.modules.system.dto.I18nDataUnique;
import com.qianwen.smartman.modules.system.entity.I18nData;
import com.qianwen.smartman.modules.system.mapper.I18nDataMapper;
import com.qianwen.smartman.modules.system.service.I18nDataService;
import com.qianwen.smartman.modules.system.vo.I18nDataExcelVO;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.multipart.MultipartFile;

@Service
/* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/system/service/impl/I18nDataServiceImpl.class */
public class I18nDataServiceImpl extends ServiceImpl<I18nDataMapper, I18nData> implements I18nDataService {
    private final StringRedisTemplate stringRedisTemplate;
    private final OssBuilder ossBuilder;

    public I18nDataServiceImpl(final StringRedisTemplate stringRedisTemplate, final OssBuilder ossBuilder) {
        this.stringRedisTemplate = stringRedisTemplate;
        this.ossBuilder = ossBuilder;
    }

    @Override // org.springblade.modules.system.service.I18nDataService
    public IPage<I18nData> selectPage(IPage<I18nData> page, I18nDataQueryDTO queryDTO) {
        return page(page, wrapper(queryDTO));
    }

    public LambdaQueryWrapper<I18nData> wrapper(I18nDataQueryDTO i18nDataQO) {
        return Wrappers.lambdaQuery(I18nData.class).like(Func.isNotEmpty(i18nDataQO.getCode()), (v0) -> {
            return v0.getCode();
        }, i18nDataQO.getCode()).eq(Func.isNotEmpty(i18nDataQO.getLanguageTag()), (v0) -> {
            return v0.getLanguageTag();
        }, i18nDataQO.getLanguageTag()).and(Func.isNotEmpty(i18nDataQO.getCondition()), w -> {
            LambdaQueryWrapper lambdaQueryWrapper =  w.like((v0) -> {
                return v0.getMessage();
            }, i18nDataQO.getCondition()).or().like((v0) -> {
                return v0.getRemark();
            }, i18nDataQO.getCondition());
        });
    }

    @Override // org.springblade.modules.system.service.I18nDataService
    public List<I18nData> queryList(I18nDataQueryDTO i18nDataQO) {
        return ((I18nDataMapper) this.baseMapper).selectList(wrapper(i18nDataQO));
    }

    @Override // org.springblade.modules.system.service.I18nDataService
    public List<I18nData> listByCode(String code) {
        return this.baseMapper.selectList(Wrappers.lambdaQuery(I18nData.class).eq((v0) -> {
            return v0.getCode();
        }, code));
    }

    @Override // org.springblade.modules.system.service.I18nDataService
    public I18nData getByCodeAndLanguageTag(String code, String languageTag) {
        return this.baseMapper.selectOne(Wrappers.lambdaQuery(I18nData.class).eq((v0) -> {
            return v0.getCode();
        }, code).eq((v0) -> {
            return v0.getLanguageTag();
        }, languageTag));
    }

    public boolean save(I18nData entity) {
        return SqlHelper.retBool(Integer.valueOf(((I18nDataMapper) getBaseMapper()).insert(entity)));
    }

    @Override // org.springblade.modules.system.service.I18nDataService
    public I18nData updateById(I18nDataDTO i18nDataDTO) {
        I18nData entity = I18nDataConverter.INSTANCE.convert(i18nDataDTO);
        boolean updateSuccess = updateById(entity);
        if (updateSuccess) {
            pushUpdateMessage(i18nDataDTO.getCode(), i18nDataDTO.getLanguageTag());
            return entity;
        }
        throw new ServiceException("修改国际化信息失败");
    }

    @Override // org.springblade.modules.system.service.I18nDataService
    @Transactional(rollbackFor = {Exception.class})
    public BladeFile importI18nData(List<I18nDataExcelVO> data) {
        if (Func.isEmpty(data)) {
            throw new ServiceException(MessageUtils.message("excel.import.data.can.not.be.null", new Object[0]));
        }
        if (data.size() > 1000) {
            throw new ServiceException(MessageUtils.message("excel.import.size.failed", new Object[0]));
        }
        if (!checkImport(data)) {
            MultipartFile multipartFile = ExcelUtil.exportFillTemplateToMultipartFile(ExcelConstant.DIRECTORY + "i18nDataFailTemplate" + ExcelConstant.SUFFIX, MessageUtils.message("excel.import.failed.report.name", new Object[0]) + ExcelConstant.SUFFIX, "国际化信息表", data, (Object) null, (AbstractMergeStrategy) null);
            BladeFile bladeFile = this.ossBuilder.tempTemplate().putFile(multipartFile.getOriginalFilename(), multipartFile);
            return bladeFile;
        }
        
        List<I18nData> list = data.stream().map(I18nDataConverter.INSTANCE::excelVoToPo).collect(Collectors.toList());
        /*
        Stream<I18nDataExcelVO> stream = data.stream();
        I18nDataConverter i18nDataConverter = I18nDataConverter.INSTANCE;
        i18nDataConverter.getClass();
        List<I18nData> list = (List) stream.map(this::excelVoToPo).collect(Collectors.toList());
        */
        if (CollectionUtil.isNotEmpty(list)) {
            List<String> collectCode = list.stream().map((v0) -> {
                return v0.getCode();
            }).collect(Collectors.toList());
            List<I18nData> existCodeList = list(Lambda.in((v0) -> {
                return v0.getCode();
            }, collectCode));
            existCodeList.parallelStream().forEach(exist -> {
                list.parallelStream().filter(item -> {
                    return item.getCode().equals(exist.getCode()) && item.getLanguageTag().equals(exist.getLanguageTag());
                }).forEach(item2 -> {
                    item2.setId(exist.getId());
                });
            });
            updateBatchById( list.stream().filter(item -> {
                return item.getId() != null;
            }).collect(Collectors.toList()));
            saveBatch(list.stream().filter(item2 -> {
                return item2.getId() == null;
            }).collect(Collectors.toList()));
            return null;
        }
        return null;
    }

    private boolean checkImport(List<I18nDataExcelVO> data) {
        AtomicBoolean error = new AtomicBoolean(false);
        data.forEach(item -> {
            String message;
            if (Func.isBlank(item.getLanguageTag())) {
                message = MessageUtils.message("i18nMessage.languageTag.not.null", new Object[0]);
            } else if (Func.isBlank(item.getCode())) {
                message = MessageUtils.message("i18nMessage.code.not.null", new Object[0]);
            } else {
                message = Func.isBlank(item.getMessage()) ? MessageUtils.message("i18nMessage.message.not.null", new Object[0]) : null;
            }
            item.setFailReason(message);
            error.set(error.get() || item.getFailReason() != null);
        });
        return !error.get();
    }

    private void pushUpdateMessage(String code, String languageTag) {
        I18nDataUnique channelBody = new I18nDataUnique(code, languageTag);
        String str = JsonUtil.toJson(channelBody);
        this.stringRedisTemplate.convertAndSend(I18nRedisKeyConstant.CHANNEL_I18N_DATA_UPDATED, str);
    }

    private List<I18nData> exists(List<I18nDataExcelVO> list) {
        //Wrapper<I18nData> lambdaQuery = Wrappers.lambdaQuery(I18nData.class);
        LambdaQueryWrapper<I18nData> lambdaQuery = Wrappers.lambdaQuery(I18nData.class);
        for (I18nDataExcelVO excelVO : list) {
            lambdaQuery.or(w -> {
            	String code = excelVO.getCode();
                String languageTag = excelVO.getLanguageTag();
                w.eq(I18nData::getCode, code).eq(I18nData::getLanguageTag, languageTag);
                /*
                w.eq((v0) -> {
                    return v0.getCode();
                }, code).eq((v0) -> {
                    return v0.getLanguageTag();
                }, languageTag);*/
            });
        }
        return this.baseMapper.selectList(lambdaQuery);
    }

    @Override // org.springblade.modules.system.service.I18nDataService
    public BladeFile exportExcel(I18nDataQueryDTO i18nDataQO, HttpServletResponse response) {
        List<I18nData> list = queryList(i18nDataQO);
        List<I18nDataExcelVO> excelVOS = list.stream().map(I18nDataConverter.INSTANCE::poToExcelVo).collect(Collectors.toList());
        /*
        Stream<I18nData> stream = list.stream();
        I18nDataConverter i18nDataConverter = I18nDataConverter.INSTANCE;
        i18nDataConverter.getClass();
        List<I18nDataExcelVO> excelVOS = (List) stream.map(this::poToExcelVo).collect(Collectors.toList());
        */
        String fileName = String.format("%s-%s.xlsx", "多语言信息", DateUtil.time());
        MultipartFile multipartFile = ExcelUtil.exportToMultipartFile(fileName, "多语言表", excelVOS, I18nDataExcelVO.class);
        return this.ossBuilder.tempTemplate().putFile(multipartFile.getOriginalFilename(), multipartFile);
    }
}