FaceServiceImpl.java 5.69 KB
package com.ruoyi.service.impl.dss;

import com.arcsoft.face.FaceEngine;
import com.arcsoft.face.FaceFeature;
import com.arcsoft.face.FaceInfo;
import com.arcsoft.face.FaceSimilar;
import com.arcsoft.face.enums.ErrorInfo;
import com.arcsoft.face.toolkit.ImageFactory;
import com.arcsoft.face.toolkit.ImageInfo;
import com.ruoyi.common.utils.file.FileUploadUtils;
import com.ruoyi.config.BsthSystemConfig;
import com.ruoyi.domain.driver.NewDriver;
import com.ruoyi.service.driver.NewDriverService;
import com.ruoyi.service.dss.FaceService;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.collections4.CollectionUtils;
import org.apache.commons.io.IOUtils;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import javax.imageio.ImageIO;
import java.awt.image.BufferedImage;
import java.io.ByteArrayInputStream;
import java.io.File;
import java.io.IOException;
import java.util.*;

import static com.arcsoft.face.toolkit.ImageFactory.getRGBData;

/**
 * @author liujun
 * @date 2024年07月12日 10:51
 */
@Service
@Slf4j
public class FaceServiceImpl implements FaceService {
    @Autowired
    private NewDriverService newDriverService;
    @Autowired
    private FaceEngine faceEngine;
    @Autowired
    private BsthSystemConfig bsthSystemConfig;


    @Override
    public NewDriver checkFace(NewDriver driver) {
        NewDriver driver1 = new NewDriver();
        driver1.setFaceSignIn(1);

        List<NewDriver> drivers = newDriverService.list(driver1);
        return checkFace(drivers, driver);
    }

    private NewDriver checkFace(List<NewDriver> drivers, NewDriver sourceDriver) {
        if (CollectionUtils.isEmpty(drivers)) {
            return null;
        }
        if (StringUtils.isEmpty(sourceDriver.getImage())) {
            return null;
        }
        ByteArrayInputStream byteArrayInputStream = null;
        BufferedImage bufferedImage = null;
        try {
            String content = FileUploadUtils.choosePrictureContent(sourceDriver.getImage());
            byte[] sourceImageData = cn.hutool.core.codec.Base64.decode(content);
            byteArrayInputStream = new ByteArrayInputStream(sourceImageData);
            bufferedImage = ImageIO.read(byteArrayInputStream);
            ImageInfo sourceImage = ImageFactory.bufferedImage2ImageInfo(bufferedImage);


            FaceFeature sourceFaceFeature = generateFaceFeature(sourceDriver, sourceImage);
            if (Objects.isNull(sourceFaceFeature)) {
                return null;
            }


            Optional<NewDriver> optional = drivers.stream().map(dr -> {
                float imageScore = checkFaceScore(dr, sourceFaceFeature);
                dr.setImageScore(imageScore);

                return dr;
            }).max(Comparator.comparing(NewDriver::getImageScore));

            if (Objects.nonNull(bufferedImage)) {
                bufferedImage.flush();
            }

            if (optional.isPresent() && Objects.nonNull(optional.get().getImageScore()) && optional.get().getImageScore() > 0.95) {
                return optional.get();
            }


            return null;
        } catch (IOException e) {
            sourceDriver.setImage(null);
            log.error("图片校验异常:[{}]", sourceDriver, e);
        } finally {

            IOUtils.closeQuietly(byteArrayInputStream);
        }
        return null;
    }

    private float checkFaceScore(NewDriver dr, FaceFeature sourceFaceFeature) {
        if (StringUtils.isEmpty(dr.getImage())) {
            log.error("头像路径为空;[{}]", dr);
            return -1;
        }
        StringBuilder builder = new StringBuilder();
        builder.append(bsthSystemConfig.getImageBasePath());
        builder.append(File.separator);
        builder.append(dr.getImage());

        File targetFile = new File(builder.toString());
        if (!targetFile.exists() || !targetFile.isFile()) {
            log.error("没有比对的图片;[{}]", dr);
            return -1;
        }

        ImageInfo target = getRGBData(targetFile);
        FaceFeature targetFaceFeature = generateFaceFeature(dr, target);
        if (Objects.isNull(targetFaceFeature)) {
            return -1;
        }

        //特征比对
        FaceSimilar faceSimilar = new FaceSimilar();
        int errorCode = faceEngine.compareFaceFeature(targetFaceFeature, sourceFaceFeature, faceSimilar);

        if (errorCode != ErrorInfo.MOK.getValue()) {
            log.error("人脸对比失败:[{}]", dr);
            return -1;
        }
        return faceSimilar.getScore();
    }

    private FaceFeature generateFaceFeature(NewDriver driver, ImageInfo image) {
        List<FaceInfo> faceInfoList = new ArrayList<>();
        int errorCode = faceEngine.detectFaces(image.getImageData(), image.getWidth(), image.getHeight(), image.getImageFormat(), faceInfoList);
        if (errorCode != ErrorInfo.MOK.getValue()) {
            log.error("人脸对比失败,请检查数据:[{}];错误代码:[{}]", driver, errorCode);
            return null;
        }

        int size = CollectionUtils.size(faceInfoList);
        if(size == 0){
            log.error("人脸对比失败,没有人脸特征数据:[{}];错误代码:[{}]", driver, errorCode);
            return null;
        }

        FaceFeature faceFeature = new FaceFeature();
        errorCode = faceEngine.extractFaceFeature(image.getImageData(), image.getWidth(), image.getHeight(), image.getImageFormat(), faceInfoList.get(0), faceFeature);
        if (errorCode != ErrorInfo.MOK.getValue()) {
            log.error("提取对比特征失败,请检查数据:[{}];错误代码:[{}]", driver, errorCode);
            return null;
        }
        return faceFeature;
    }

}