cxf webservice 测温接口

pom.xml

@@ -87,6 +87,13 @@
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-integration</artifactId>
         </dependency>
+        <!-- webservice cxf -->
+        <dependency>
+            <groupId>org.apache.cxf</groupId>
+            <artifactId>cxf-spring-boot-starter-jaxws</artifactId>
+            <version>3.5.5</version>
+        </dependency>
+
         <!-- https://mvnrepository.com/artifact/de.schlichtherle.truelicense/truelicense-core -->
         <!--<dependency>
             <groupId>de.schlichtherle.truelicense</groupId>

src/main/java/com/unissoft/webservice/cxf/CxfConfig.java

@@ -0,0 +1,38 @@
+package com.unissoft.webservice.cxf;
+
+import com.unissoft.webservice.service.GrainTemperatureService;
+import com.unissoft.webservice.service.impl.GrainTemperatureServiceImpl;
+import org.apache.cxf.Bus;
+import org.apache.cxf.bus.spring.SpringBus;
+import org.apache.cxf.jaxws.EndpointImpl;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import javax.xml.ws.Endpoint;
+
+/**
+ * @author qingsong.han
+ * @description: webservice cxf config
+ * @create 2023-03-14 16:01
+ */
+@Configuration
+public class CxfConfig {
+
+    @Bean(name = Bus.DEFAULT_BUS_ID)
+    public SpringBus springBus() {
+        return new SpringBus();
+    }
+
+    // 温度
+    @Bean
+    public GrainTemperatureService grainTemperatureService() {
+        return new GrainTemperatureServiceImpl();
+    }
+
+    @Bean
+    public Endpoint uploadGrainTemperatureData() {
+        EndpointImpl endpoint = new EndpointImpl(springBus(), grainTemperatureService());
+        endpoint.publish("/uploadGrainTemperatureData");
+        return endpoint;
+    }
+}

src/main/java/com/unissoft/webservice/model/ResponseEntity.java

@@ -0,0 +1,59 @@
+package com.unissoft.webservice.model;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+// 返回基类
+@Data
+public class ResponseEntity<T> implements Serializable {
+
+    private static final long serialVersionUID = -2825436079063723409L;
+
+    //成功
+    private static final String OK = "200";
+    //失败
+    private static final String FAILED = "600";
+    private static final String BUSSINESS_FAILED = "550";
+    private static final String UNAUTHENTICATION = "401";
+
+    private String retCode;
+    private String message;
+    private T data;
+
+    private static <T> ResponseEntity<T> buildResponse(String retCode, String message, T data) {
+        ResponseEntity<T> responseEntity = new ResponseEntity<T>();
+        responseEntity.retCode = retCode;
+        responseEntity.message = message;
+        responseEntity.data = data;
+        return responseEntity;
+    }
+
+    public static <T> ResponseEntity<T> ok() {
+        return buildResponse(ResponseEntity.OK, "success", null);
+    }
+
+    public static <T> ResponseEntity<T> ok(T data) {
+        return buildResponse(ResponseEntity.OK, "success", data);
+
+    }
+
+    public static <T> ResponseEntity<T> ok(String message, T data) {
+        return buildResponse(ResponseEntity.OK, message, data);
+    }
+
+
+    public static <T> ResponseEntity<T> failed(String message) {
+        return buildResponse(ResponseEntity.FAILED, message, null);
+    }
+
+    public static <T> ResponseEntity<T> businessFailed(String message) {
+        return buildResponse(ResponseEntity.BUSSINESS_FAILED, message, null);
+    }
+
+    public static <T> ResponseEntity<T> unauthentication(String message) {
+        return buildResponse(ResponseEntity.UNAUTHENTICATION, message, null);
+    }
+
+}
+

src/main/java/com/unissoft/webservice/service/GrainTemperatureService.java

@@ -0,0 +1,22 @@
+package com.unissoft.webservice.service;
+
+import com.unissoft.webservice.model.ResponseEntity;
+
+import javax.jws.WebParam;
+import javax.jws.WebService;
+
+/**
+ * @author qingsong.han
+ * @description: 测温数据
+ * @create 2023-03-14 16:32
+ */
+@WebService
+public interface GrainTemperatureService {
+    /**
+     * 测温webservice 接收数据接口
+     * @param dataSource 数据来源
+     * @param grainTemperatureData 数据
+     * @return
+     */
+    ResponseEntity uploadGrainTemperatureData(@WebParam(name = "dataSource") String dataSource, @WebParam(name = "grainTemperatureData") String grainTemperatureData);
+}

src/main/java/com/unissoft/webservice/service/impl/GrainTemperatureServiceImpl.java

@@ -0,0 +1,35 @@
+package com.unissoft.webservice.service.impl;
+
+import com.alibaba.fastjson2.JSON;
+import com.unissoft.data.mapper.DataGrainTempMapper;
+import com.unissoft.data.model.DataGrainTemp;
+import com.unissoft.webservice.model.ResponseEntity;
+import com.unissoft.webservice.service.GrainTemperatureService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import javax.annotation.Resource;
+import java.util.List;
+
+/**
+ * @author qingsong.han
+ * @description: 测温数据实现
+ * @create 2023-03-14 16:33
+ */
+@Slf4j
+@Service
+public class GrainTemperatureServiceImpl implements GrainTemperatureService {
+//    @Resource
+//    private DataGrainTempMapper grainTempMapper;
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public ResponseEntity uploadGrainTemperatureData(String dataSource, String grainTemperatureData) {
+        // 数据处理逻辑
+        log.info("接收到:{}测温数据:{}", dataSource, grainTemperatureData);
+        // 数据保存
+//        grainTempMapper.insert();
+        return ResponseEntity.ok();
+    }
+}

src/main/resources/application.yml

@@ -62,4 +62,6 @@ mybatis-plus:
     # console show sql
     log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
 web:
-  upload-path: /home/files
+  upload-path: /home/files
+cxf:
+  path: /intelligent