qin há 9 meses atrás
pai
commit
3a18c55ded

+ 8 - 3
src/main/java/com/poteviohealth/cgp/statistics/controller/fegin/StatisticsFeignController.java

@@ -2,15 +2,18 @@ package com.poteviohealth.cgp.statistics.controller.fegin;
 
 
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.google.common.collect.Lists;
 import com.poteviohealth.cgp.common.controller.BaseFeignController;
 import com.poteviohealth.cgp.common.integrated.LongParams;
 import com.poteviohealth.cgp.common.integrated.statistics.model.FingerParams;
 import com.poteviohealth.cgp.common.model.VaultsResponse;
+import com.poteviohealth.cgp.statistics.mapstruct.DistinctionConverter;
 import com.poteviohealth.cgp.statistics.model.Distinction;
 import com.poteviohealth.cgp.statistics.service.IDistinctionService;
 import com.poteviohealth.cgp.statistics.utils.OssUtils;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
+import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Controller;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
@@ -18,6 +21,7 @@ import org.springframework.web.bind.annotation.RequestMethod;
 import org.springframework.web.bind.annotation.ResponseBody;
 
 import javax.annotation.Resource;
+import java.util.List;
 
 /**
  * <p>
@@ -32,7 +36,6 @@ import javax.annotation.Resource;
 @Api(tags = {"第三方-统计相关接口"})
 public class StatisticsFeignController extends BaseFeignController {
 
-
     @Resource
     private IDistinctionService distinctionService;
     @Resource
@@ -41,8 +44,9 @@ public class StatisticsFeignController extends BaseFeignController {
     @ApiOperation(value = "保存订单图片指纹")
     @RequestMapping(value = "/saveFinger", method = RequestMethod.POST)
     @ResponseBody
+    @Async
     public VaultsResponse saveFinger(@RequestBody FingerParams params){
-        /*List<Distinction> list = Lists.newArrayList();
+        List<Distinction> list = Lists.newArrayList();
         for (String s : params.getUrlList()) {
             Distinction distinction = DistinctionConverter.INSTANCE.model2WebDTO(params);
             String uid =  ossUtils.getFileFinger(s);
@@ -50,7 +54,7 @@ public class StatisticsFeignController extends BaseFeignController {
             distinction.setUrl(s);
             list.add(distinction);
         }
-        distinctionService.insertBatch(list);*/
+        distinctionService.insertBatch(list);
         return VaultsResponse.success();
     }
 
@@ -58,6 +62,7 @@ public class StatisticsFeignController extends BaseFeignController {
     @ApiOperation(value = "删除订单图片指纹")
     @RequestMapping(value = "/deleteFinger", method = RequestMethod.POST)
     @ResponseBody
+    @Async
     public VaultsResponse deleteFinger(@RequestBody LongParams params){
         QueryWrapper<Distinction> queryWrapper = new QueryWrapper<>();
         queryWrapper.eq("order_id", params.getId());