Browse Source

同步数据到es优化

litianbiao 2 years ago
parent
commit
bdb24520b2
1 changed files with 7 additions and 7 deletions
  1. 7 7
      src/main/java/com/szwl/controller/EsController.java

+ 7 - 7
src/main/java/com/szwl/controller/EsController.java

@@ -19,9 +19,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.http.HttpStatus;
 import org.springframework.http.ResponseEntity;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
 
 import java.util.List;
 
@@ -39,9 +37,9 @@ public class EsController {
     TCoinOrderService tCoinOrderService;
     @Autowired
     TOrderService orderService;
-    @GetMapping("/saveEsTCoinOrder")
+    @PostMapping("/saveEsTCoinOrder")
     @ApiOperation("同步CoinOrder表数据")
-    public ResponseEntity<?> saveEsTCoinOrder(TCoinOrderParam param) {
+    public ResponseEntity<?> saveEsTCoinOrder(@RequestBody TCoinOrderParam param) {
         try{
             // 初始化旧流水
             int num = 0;
@@ -92,10 +90,12 @@ public class EsController {
 
     }
 
-    @GetMapping("/saveEsTOrder")
+    @PostMapping("/saveEsTOrder")
     @ApiOperation("同步Order表数据")
-    public ResponseEntity<?> saveEsTOrder(TOrderParam param) {
+    public ResponseEntity<?> saveEsTOrder(@RequestBody TOrderParam param) {
         try{
+//            时间跨度不要太大,晚上不要超过一个月,白天访问不要超过一天
+            //从3月20号开始同步
             // 初始化旧流水
             // 查询es 现有的数据
             //1,同步已支付的订单