package com.gkhy.assess.system.service.impl;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.gkhy.assess.common.enums.DeleteFlagEnum;
import com.gkhy.assess.common.exception.ApiException;
import com.gkhy.assess.system.domain.AssFaceRecord;
import com.gkhy.assess.system.mapper.AssFaceRecordMapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.gkhy.assess.system.domain.vo.UploadObjectVO;
import com.gkhy.assess.system.service.AssFaceRecordService;
import com.gkhy.assess.system.service.AssProjectService;
import com.gkhy.assess.system.service.SysCommonService;
import com.gkhy.assess.system.utils.ShiroUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;

/**
 * <p>
 * 现场勘验人员人脸识别记录表 服务实现类
 * </p>
 *
 * @author kzy
 * @since 2023-12-12 10:46:54
 */
@Service
public class AssFaceRecordServiceImpl extends ServiceImpl<AssFaceRecordMapper, AssFaceRecord> implements AssFaceRecordService {
    @Autowired
    private SysCommonService commonService;
    @Autowired
    private AssProjectService projectService;

    @Override
    public int addFaceRecord(AssFaceRecord faceRecord) {
        int row=0;
        projectService.checkUserAllowed(faceRecord.getProjectId());
        UploadObjectVO uploadObjectVO=commonService.doUpload(faceRecord.getFile());
        faceRecord.setFacePath(uploadObjectVO.getPath());
        AssFaceRecord existRecord=checkFaceUnique(faceRecord.getPersonId(),faceRecord.getProjectId());
        if(existRecord!=null){
       //     throw new ApiException("已存在人脸识别记录");
            existRecord.setFacePath(uploadObjectVO.getPath());
            existRecord.setLocation(faceRecord.getLocation());
            existRecord.setScene(faceRecord.getScene());
            row =baseMapper.updateById(existRecord);
        }else{
            faceRecord.setCreateBy(ShiroUtils.getSysUser().getUsername());
            row=baseMapper.insert(faceRecord);
        }
        return row;
    }

    public AssFaceRecord checkFaceUnique(Long personId,Long projectId) {
        LambdaQueryWrapper<AssFaceRecord> lambdaQueryWrapper = Wrappers.<AssFaceRecord>lambdaQuery()
                .eq(AssFaceRecord::getPersonId, personId)
                .eq(AssFaceRecord::getProjectId, projectId)
                .eq(AssFaceRecord::getDelFlag, DeleteFlagEnum.UN_DELETE);
        return getOne(lambdaQueryWrapper);
    }


    @Override
    public List<AssFaceRecord> faceRecordList(Long projectId,Integer scene) {
        projectService.checkUserAllowed(projectId);
        return baseMapper.faceRecordList(projectId,scene);
    }

    @Override
    public int editFaceRecord(AssFaceRecord faceRecord) {
        projectService.checkUserAllowed(faceRecord.getProjectId());
        faceRecord.setUpdateBy(ShiroUtils.getSysUser().getUsername());
        int row =baseMapper.updateById(faceRecord);
        return row;
    }

    @Override
    public int deleteById(Long faceId) {
        AssFaceRecord faceRecord=getById(faceId);
        projectService.checkUserAllowed(faceRecord.getProjectId());
        faceRecord=new AssFaceRecord().setId(faceId)
                .setDelFlag(DeleteFlagEnum.DELETED.getCode());
        faceRecord.setUpdateBy(ShiroUtils.getSysUser().getUsername());
        return baseMapper.updateById(faceRecord);
    }
}