bugfix:2990举报成功后删除对应动态/评论

alien-store/src/main/java/shop/alien/store/util/ai/AiReportReviewUtil.java

@@ -1,5 +1,6 @@
 package shop.alien.store.util.ai;
 
+import com.alibaba.fastjson2.JSONObject;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Value;
@@ -12,6 +13,10 @@ import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Component;
 import org.springframework.util.StringUtils;
 import org.springframework.web.client.RestTemplate;
+import shop.alien.entity.store.LifeUserViolation;
+import shop.alien.mapper.CommonCommentMapper;
+import shop.alien.mapper.LifeUserDynamicsMapper;
+import shop.alien.mapper.LifeUserViolationMapper;
 
 import java.util.HashMap;
 import java.util.Map;
@@ -35,6 +40,10 @@ public class AiReportReviewUtil {
     @Value("${third-party-ai.report-review.base-url:http://124.93.18.180:9000/ai/auto-review/api/v1/merchant_dynamic_violation_audit_task/submit}")
     private String aiReportReviewUrl;
 
+    private final LifeUserViolationMapper lifeUserViolationMapper;
+    private final CommonCommentMapper commonCommentMapper;
+    private final LifeUserDynamicsMapper  lifeUserDynamicsMapper;
+
     @Async("taskExecutor")
     public void reviewReport(Integer reportId, String reportType) {
 
@@ -64,8 +73,27 @@ public class AiReportReviewUtil {
         HttpEntity<Map<String, Object>> request = new HttpEntity<>(requestBody, headers);
         log.info("调用ai举报接口URL：{}，requestBody: {}", aiReportReviewUrl, requestBody);
         ResponseEntity<String> response = restTemplate.postForEntity(aiReportReviewUrl, request, String.class);
+
         if(response.getStatusCode().isError()){
             log.error("调用ai举报接口失败，URL：{}，requestBody: {}，response: {}", aiReportReviewUrl, requestBody, response);
+        } else {
+            // 如果举报成功删除对应数据，动态/评论
+            boolean success = JSONObject.parseObject(response.getBody()).getJSONObject("data").getJSONObject("result").getString("processing_status").equals("1");
+            if(success){
+                LifeUserViolation lifeUserViolation = lifeUserViolationMapper.selectById(reportId);
+                int i = 0;
+                if(reportType.equals("2")){
+                    // 删除动态
+                    i = lifeUserDynamicsMapper.deleteById(lifeUserViolation.getDynamicsId());
+                }
+                if(reportType.equals("3")){
+                    // 删除评论
+                    i = commonCommentMapper.deleteById(lifeUserViolation.getBusinessId());
+                }
+                if( i == 0 ){
+                    log.info("删除动态/评论失败，type:{},举报id:{}", reportType, reportId);
+                }
+            }
         }
     }
 }