头像-易盾审核-记录

accompany-business/accompany-business-sdk/src/main/java/com/accompany/business/model/YidunCheckAvatarRecord.java

@@ -0,0 +1,22 @@
+package com.accompany.business.model;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import lombok.Data;
+
+import java.util.Date;
+
+@Data
+public class YidunCheckAvatarRecord {
+
+    @TableId(type = IdType.INPUT)
+    private String taskId;
+    private Long uid;
+    private String redisKey;
+    private String avatarUrl;
+    private Long price;
+    private Date createTime;
+    private Date updateTime;
+    private Integer reviewStatus;
+
+}

accompany-business/accompany-business-service/src/main/java/com/accompany/business/mybatismapper/YidunCheckAvatarRecordMapper.java

@@ -0,0 +1,8 @@
+package com.accompany.business.mybatismapper;
+
+import com.accompany.business.model.YidunCheckAvatarRecord;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+public interface YidunCheckAvatarRecordMapper extends BaseMapper<YidunCheckAvatarRecord> {
+
+}

accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/YidunCallbackService.java

@@ -53,6 +53,8 @@ public class YidunCallbackService extends BaseService {
     private PrivatePhotoService privatePhotoService;
     @Autowired
     private UploadAvatarService uploadAvatarService;
+    @Autowired
+    private YidunCheckAvatarRecordService yidunCheckAvatarRecordService;
 
     public YidunBusiResult reportReviewRsult(String secretId, String businessId, String signature, String callbackData) {
         YidunBusiResult yidunBusiResult = new YidunBusiResult(BusiStatus.SUCCESS);
@@ -143,11 +145,13 @@ public class YidunCallbackService extends BaseService {
     }
 
     public void updateAvatar(String newAvatar, Long uid, String redisKey, String taskId){
-        uploadAvatarService.updateAvatar(newAvatar, uid, redisKey, taskId);
+        yidunCheckAvatarRecordService.updateRecord(taskId, Constant.YidunReviewStatus.review_success);
         jedisService.hdel(RedisKey.user_avatar_review_task.getKey(), taskId);
+        uploadAvatarService.updateAvatar(newAvatar, uid, redisKey, taskId);
     }
 
     private void reviewProfileFail(String taskId, String uidStr, String avatarUrl) {
+        yidunCheckAvatarRecordService.updateRecord(taskId, Constant.YidunReviewStatus.review_fail);
         jedisService.hdel(RedisKey.user_avatar_review_task.getKey(), taskId);
         uploadAvatarService.reportReviewProfileFail(uidStr, avatarUrl);
     }

accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/YidunCheckAvatarRecordService.java

@@ -0,0 +1,36 @@
+package com.accompany.business.service;
+
+import com.accompany.business.model.YidunCheckAvatarRecord;
+import com.accompany.business.mybatismapper.YidunCheckAvatarRecordMapper;
+import com.accompany.common.constant.Constant;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.stereotype.Service;
+
+import java.util.Date;
+
+@Service
+public class YidunCheckAvatarRecordService extends ServiceImpl<YidunCheckAvatarRecordMapper, YidunCheckAvatarRecord> {
+    public void record(String taskId, Long uid, String redisKey, String avatar, Long price) {
+        Date now = new Date();
+
+        YidunCheckAvatarRecord record = new YidunCheckAvatarRecord();
+        record.setTaskId(taskId);
+        record.setUid(uid);
+        record.setRedisKey(redisKey);
+        record.setAvatarUrl(avatar);
+        record.setPrice(price);
+        record.setCreateTime(now);
+        record.setUpdateTime(now);
+        record.setReviewStatus(Constant.YidunReviewStatus.in_review);
+
+        this.save(record);
+    }
+
+    public void updateRecord(String taskId, Integer reviewStatus) {
+        this.lambdaUpdate()
+                .set(YidunCheckAvatarRecord::getUpdateTime, new Date())
+                .set(YidunCheckAvatarRecord::getReviewStatus, reviewStatus)
+                .eq(YidunCheckAvatarRecord::getTaskId, taskId)
+                .update();
+    }
+}

accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/netease/YidunCheckUtil.java

@@ -16,6 +16,7 @@ import com.accompany.business.dto.yidun.*;
 import com.accompany.business.sensitvienew.SensitiveConstant;
 import com.accompany.business.sensitvienew.SensitiveFilterUtil;
 import com.accompany.business.service.UploadAvatarService;
+import com.accompany.business.service.YidunCheckAvatarRecordService;
 import com.accompany.common.config.YidunCheckConfig;
 import com.accompany.common.config.YidunImageConfig;
 import com.accompany.common.constant.Constant;
@@ -227,6 +228,7 @@ public class YidunCheckUtil {
 
                     SpringContextHolder.getBean(UploadAvatarService.class).cacheReviewAvatar(redisKey, String.valueOf(uid), avatar, price);
                     SpringContextHolder.getBean(JedisService.class).hset(RedisKey.user_avatar_review_task.getKey(), taskId, String.valueOf(uid));
+                    SpringContextHolder.getBean(YidunCheckAvatarRecordService.class).record(taskId, uid, redisKey,  avatar, price);
                 }
             } else {
                 log.info("用户{}头像审核上传失败code{},msg{}", uid, code, msg);

accompany-business/accompany-business-service/src/main/resources/accompany/sqlmappers/YidunCheckAvatarRecordMapper.xml

@@ -0,0 +1,5 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
+<mapper namespace="com.accompany.business.mybatismapper.YidunCheckAvatarRecordMapper" >
+
+</mapper>