Pārlūkot izejas kodu

feat: "esServer...+1"

wangzeyu@tom.com 2 gadi atpakaļ
vecāks
revīzija
74cd8b7b1b

+ 23 - 0
src/main/java/com/szwl/controller/EsController.java

@@ -1,6 +1,14 @@
 package com.szwl.controller;
 
 
+import com.szwl.constant.ResponseCodesEnum;
+import com.szwl.model.bo.R;
+import com.szwl.model.bo.ResponseModel;
+import com.szwl.model.entity.TOrderAbroad;
+import com.szwl.service.impl.EsTOrderAbroadServiceImpl;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
@@ -8,4 +16,19 @@ import org.springframework.web.bind.annotation.RestController;
 @RequestMapping("/es")
 public class EsController {
 
+    EsTOrderAbroadServiceImpl esTOrderAbroadService;
+
+    public EsController(EsTOrderAbroadServiceImpl esTOrderAbroadService) {
+        this.esTOrderAbroadService = esTOrderAbroadService;
+    }
+
+    @ApiOperation(value = "同步海外线上订单到es中")
+    @GetMapping("/saveOrderAbroadToEs")
+    public ResponseModel<?> saveOrderAbroadToEs(@RequestBody TOrderAbroad orderAbroad){
+        if(orderAbroad==null){
+            return R.fail(ResponseCodesEnum.A0001);
+        }
+        esTOrderAbroadService.insertData(orderAbroad);
+        return R.ok("同步es成功");
+    }
 }

+ 1 - 1
src/main/java/com/szwl/service/IEsTOrderAbroadService.java

@@ -3,7 +3,7 @@ package com.szwl.service;
 import org.springframework.stereotype.Service;
 
 @Service
-public interface IEsTOrderAbroadService {
+public interface IEsService {
 
     void initTableFun();
 }

+ 1 - 1
src/main/java/com/szwl/service/ITOrderAbroadService.java

@@ -11,6 +11,6 @@ import com.baomidou.mybatisplus.extension.service.IService;
  * @author Author
  * @since 2023-07-28
  */
-public interface ITOrderAbroadService extends IService<TOrderAbroad> {
+public interface TOrderAbroadService extends IService<TOrderAbroad> {
 
 }

+ 5 - 5
src/main/java/com/szwl/service/impl/EsTOrderAbroadServiceImpl.java

@@ -8,8 +8,8 @@ import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.szwl.model.query.TOrderAbroadParam;
 import com.szwl.model.entity.TOrderAbroad;
-import com.szwl.service.IEsTOrderAbroadService;
-import com.szwl.service.ITOrderAbroadService;
+import com.szwl.service.IEsService;
+import com.szwl.service.TOrderAbroadService;
 import lombok.extern.slf4j.Slf4j;
 import org.elasticsearch.client.RequestOptions;
 import org.elasticsearch.client.indices.GetIndexRequest;
@@ -21,14 +21,14 @@ import java.util.List;
 
 @Slf4j
 @Service
-public class EsTOrderAbroadServiceImpl extends EsBaseService<TOrderAbroad, TOrderAbroadParam> implements IEsTOrderAbroadService {
+public class EsTOrderAbroadServiceImpl extends EsBaseService<TOrderAbroad, TOrderAbroadParam> implements IEsService {
 
     private static boolean InitEsTableStatus = false; // 是否正常完成 es 初始化
     public static final int MAX_ROW = 1000;
 
-    ITOrderAbroadService tOrderAbroadService;
+    TOrderAbroadService tOrderAbroadService;
 
-    public EsTOrderAbroadServiceImpl(ITOrderAbroadService tOrderAbroadService) {
+    public EsTOrderAbroadServiceImpl(TOrderAbroadService tOrderAbroadService) {
         this.tOrderAbroadService = tOrderAbroadService;
     }
 

+ 2 - 2
src/main/java/com/szwl/service/impl/TOrderAbroadServiceImpl.java

@@ -2,7 +2,7 @@ package com.szwl.service.impl;
 
 import com.szwl.model.entity.TOrderAbroad;
 import com.szwl.mapper.TOrderAbroadMapper;
-import com.szwl.service.ITOrderAbroadService;
+import com.szwl.service.TOrderAbroadService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import org.springframework.stereotype.Service;
 
@@ -15,6 +15,6 @@ import org.springframework.stereotype.Service;
  * @since 2023-07-28
  */
 @Service
-public class TOrderAbroadServiceImpl extends ServiceImpl<TOrderAbroadMapper, TOrderAbroad> implements ITOrderAbroadService {
+public class TOrderAbroadServiceImpl extends ServiceImpl<TOrderAbroadMapper, TOrderAbroad> implements TOrderAbroadService {
 
 }