浏览代码

设备状态添加feign

李进 2 年之前
父节点
当前提交
cb3deae973

+ 10 - 0
device-api-cloud/src/main/java/com/xy/feign/DeviceStatusFeign.java

@@ -0,0 +1,10 @@
+package com.xy.feign;
+
+import com.xy.FeignInterceptor;
+import com.xy.consts.ServiceConsts;
+import com.xy.service.DeviceStatusService;
+import org.springframework.cloud.openfeign.FeignClient;
+
+@FeignClient(value = ServiceConsts.SERVICE_NAME, configuration = FeignInterceptor.class)
+public interface DeviceStatusFeign extends DeviceStatusService {
+}

+ 2 - 2
device-api-service/src/main/java/com/xy/service/DeviceStatusServiceImpl.java

@@ -32,9 +32,9 @@ import static com.xy.utils.Beans.copy;
 @Api(tags = "设备-状态")
 public class DeviceStatusServiceImpl extends ServiceImpl<DeviceStatusMapper, DeviceStatus> implements DeviceStatusService {
 
-    @PostMapping("up")
+    @Override
     @ApiOperation("上报信息")
-    public R up(@RequestBody DeviceStatusDto.Up up) {
+    public R up(DeviceStatusDto.Up up) {
         DeviceStatus deviceStatusInfo = getById(up.getDeviceId());
         if (deviceStatusInfo == null) {
             return R.ok();

+ 12 - 0
device-api/src/main/java/com/xy/service/DeviceStatusService.java

@@ -1,6 +1,10 @@
 package com.xy.service;
 
 import com.xy.annotate.RestMappingController;
+import com.xy.dto.DeviceStatusDto;
+import com.xy.utils.R;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
 
 /**
  * <p>
@@ -13,4 +17,12 @@ import com.xy.annotate.RestMappingController;
 @RestMappingController("device-status")
 public interface DeviceStatusService {
 
+    /**
+     * 上报信息
+     *
+     * @param up
+     * @return
+     */
+    @PostMapping("up")
+    R up(@RequestBody DeviceStatusDto.Up up);
 }