.

SpringBatchServiceServer/src/main/java/com/zswl/cloud/springBtach/server/core/controller/XiaoJuController.java

@@ -1,30 +1,30 @@
-//package com.zswl.cloud.springBtach.server.core.controller;
-//
-//import com.xiaoju.open.oil.interfaces.request.NotificationPushStoreInfoRequest;
-//import com.zswl.cloud.springBtach.server.core.service.XiaoJuService;
-//import io.swagger.annotations.ApiOperation;
-//import lombok.extern.log4j.Log4j2;
-//import org.springframework.beans.factory.annotation.Autowired;
-//import org.springframework.web.bind.annotation.RequestBody;
-//import org.springframework.web.bind.annotation.RequestMapping;
-//import org.springframework.web.bind.annotation.RequestMethod;
-//import org.springframework.web.bind.annotation.RestController;
-//
-//@Log4j2
-//@RestController
-//@RequestMapping("xiaoju")
-//public class XiaoJuController {
-//
-//    @Autowired
-//    XiaoJuService xiaoJuService;
-//
-//    @ApiOperation("同步加油站信息")
-//    @RequestMapping(value = "receivingGasStation", method = RequestMethod.POST)
-//    public String receivingGasStation(@RequestBody NotificationPushStoreInfoRequest notificationPushStoreInfoRequest) {
-//
-//        xiaoJuService.notificationPushStoreInfoRequest(notificationPushStoreInfoRequest);
-//        return "ddddddd";
-//    }
-//
-//
-//}
+package com.zswl.cloud.springBtach.server.core.controller;
+
+import com.xiaoju.open.oil.core.executor.ResponseDTO;
+import com.xiaoju.open.oil.interfaces.request.NotificationPushStoreInfoRequest;
+import com.zswl.cloud.springBtach.server.core.service.XiaoJuService;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.log4j.Log4j2;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RestController;
+
+@Log4j2
+@RestController
+@RequestMapping("xiaoju")
+public class XiaoJuController {
+
+    @Autowired
+    XiaoJuService xiaoJuService;
+
+    @ApiOperation("同步加油站信息")
+    @RequestMapping(value = "receivingGasStation", method = RequestMethod.POST)
+    public ResponseDTO receivingGasStation(@RequestBody NotificationPushStoreInfoRequest notificationPushStoreInfoRequest) {
+
+        return xiaoJuService.notificationPushStoreInfoRequest(notificationPushStoreInfoRequest);
+    }
+
+
+}

SpringBatchServiceServer/src/main/java/com/zswl/cloud/springBtach/server/core/service/XiaoJuService.java

@@ -6,6 +6,7 @@ import com.github.microservice.auth.security.helper.AuthHelper;
 import com.xiaoju.open.oil.commons.config.OilConfig;
 import com.xiaoju.open.oil.core.QueryClient;
 import com.xiaoju.open.oil.core.QueryClientFactory;
+import com.xiaoju.open.oil.core.executor.ResponseDTO;
 import com.xiaoju.open.oil.interfaces.request.NotificationPushStoreInfoRequest;
 import com.xiaoju.open.oil.interfaces.request.QueryStoreDetailRequest;
 import com.xiaoju.open.oil.interfaces.response.QueryStoreDetailResponse;
@@ -49,12 +50,24 @@ public class XiaoJuService {
 
 
 
-    public void notificationPushStoreInfoRequest(NotificationPushStoreInfoRequest notificationPushStoreInfoRequest){
+    public ResponseDTO notificationPushStoreInfoRequest(NotificationPushStoreInfoRequest notificationPushStoreInfoRequest){
 
         XiaoJuStore xiaoJuStore = new XiaoJuStore();
         BeanUtils.copyProperties(notificationPushStoreInfoRequest, xiaoJuStore);
         xiaoJuStore.setItemInfoList(JSONUtil.parseObj(notificationPushStoreInfoRequest.getItemInfoList()));
         xiaoJuStoreDao.save(xiaoJuStore);
+        ResponseDTO responseDTO = new ResponseDTO();
+
+        responseDTO.setAppKey(oilConfig.getAppKey());
+        responseDTO.setCode("0");
+        responseDTO.setMsg("请求成功");
+        responseDTO.setData("heO67plAls2+P9bo/7XJnHz77N8W+WyCP37/COPLr3k=");
+        responseDTO.setSig("B1445B2A12037FADFCD6FAE6D83ECB9A");
+
+        return responseDTO;
+
+
+
 
 
     }