RepairRecServiceImpl.java 4.79 KB
package vion.service.impl;

import cn.hutool.core.date.DateUtil;
import cn.hutool.core.io.FileUtil;
import cn.hutool.core.lang.Opt;
import cn.hutool.core.map.MapUtil;
import cn.hutool.core.util.IdUtil;
import cn.hutool.core.util.ObjUtil;
import cn.hutool.core.util.StrUtil;
import cn.hutool.crypto.SecureUtil;
import com.github.yulichang.base.MPJBaseServiceImpl;
import com.github.yulichang.wrapper.MPJLambdaWrapper;
import io.github.linpeilie.Converter;
import lombok.RequiredArgsConstructor;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import vion.dto.RepairRecDTO;
import vion.mapper.RepairRecMapper;
import vion.model.*;
import vion.service.IFileService;
import vion.service.IRepairRecService;
import vion.vo.RepairRecVO;

import java.io.File;
import java.io.IOException;
import java.util.Arrays;
import java.util.Date;
import java.util.List;

/**
 * @author HlQ
 * @date 2024/1/19
 */
@Service
@RequiredArgsConstructor
public class RepairRecServiceImpl extends MPJBaseServiceImpl<RepairRecMapper, RepairRec> implements IRepairRecService {

    private final IFileService fileService;
    private final Converter converter;

    @Value("${fileUrl:}")
    private String fileUrl;

    @Override
    public Object frontSubmit(RepairRecDTO dto) {
        dto.setUuid(IdUtil.nanoId());
        RepairRec repairRec = converter.convert(dto, RepairRec.class);
        if (this.save(repairRec)) {
            Opt.ofNullable(dto.getFiles())
                    .ifPresent(fileList ->
                            Arrays.stream(fileList).forEach(infile -> {
                                //上传url地址
                                String orgName = infile.getOriginalFilename();
                                String mainName = FileUtil.mainName(orgName);
                                String fileExt = FileUtil.extName(orgName);
                                String filename = StrUtil.format("{}_{}.{}", mainName, DateUtil.format(new Date(), "yyyyMMdd_HHmmssSSS"), fileExt);
                                String path = fileUrl + FileUtil.FILE_SEPARATOR + "repairRec" + FileUtil.FILE_SEPARATOR + repairRec.getId() + FileUtil.FILE_SEPARATOR + filename;
                                File file = FileUtil.touch(path);
                                try {
                                    infile.transferTo(file);
                                } catch (IOException e) {
                                    log.error("保存文件出错", e);
                                }

                                FileInfo fileInfo = new FileInfo();
                                fileInfo.setStoreId(-1L);
                                fileInfo.setSourceId(repairRec.getId());
                                fileInfo.setSourceType(23);
                                fileInfo.setName(filename);
                                fileInfo.setUrl(path);
                                fileInfo.setType(fileExt);
                                fileInfo.setSha256(SecureUtil.sha256(file).toUpperCase());
                                fileInfo.setUploader(repairRec.getContact());
                                fileService.save(fileInfo);
                            }));
            return MapUtil.<String, Long>builder()
                    .put("id", repairRec.getId())
                    .build();
        }
        return "提交失败";
    }

    @Override
    public List<RepairRecVO> list(RepairRecDTO dto) {
        MPJLambdaWrapper<RepairRec> wrapper = new MPJLambdaWrapper<>(converter.convert(dto, RepairRec.class))
                .selectAll(RepairRec.class)
                .selectAs(Contract::getName, RepairRecVO::getContractName)
                .selectCollection(RRepairDevice.class, RepairRecVO::getRepairDeviceList)
                .leftJoin(Contract.class, Contract::getId, RepairRec::getContractId)
                .leftJoin(RRepairDevice.class, on -> on.eq(RRepairDevice::getRId, RepairRec::getId).eq(RRepairDevice::getRType, 2))
                .between(RepairRec::getCreateTime, dto.getCreateTimeStart(), dto.getCreateTimeEnd())
                .orderByDesc(RepairRec::getCreateTime);
        return this.selectJoinList(RepairRecVO.class, wrapper);
    }

    @Override
    public RepairRecVO getRepairRecDetail(Long id, String uuid) {
        MPJLambdaWrapper<RepairRec> wrapper = new MPJLambdaWrapper<RepairRec>()
                .selectAll(PointInfo.class)
                .eq(ObjUtil.isNotEmpty(id), RepairRec::getId, id)
                .eq(StrUtil.isNotBlank(uuid), RepairRec::getUuid, uuid)
                .orderByDesc(PointInfo::getCreateTime);
        return this.selectJoinOne(RepairRecVO.class, wrapper);
    }

    @Override
    public String updById(Long id, RepairRecDTO dto) {
        return this.updateById(converter.convert(dto, RepairRec.class)) ? "更新成功" : "更新失败";
    }
}