添加webservice接口

pom.xml

@@ -138,6 +138,19 @@
 		    <version>1.3.2</version>
 		</dependency>
 
+        <!-- webservice  begin -->
+        <dependency>
+            <groupId>org.apache.cxf</groupId>
+            <artifactId>cxf-rt-frontend-jaxws</artifactId>
+            <version>3.1.10</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.cxf</groupId>
+            <artifactId>cxf-rt-transports-http</artifactId>
+            <version>3.1.10</version>
+        </dependency>
+        <!-- webservice  end -->
+
         <!--<dependency>-->
             <!--<groupId>org.springframework.boot</groupId>-->
             <!--<artifactId>spring-boot-starter-tomcat</artifactId>-->

src/main/java/com/chinaitop/depot/unissoft/model/ResponseEntity.java

@@ -0,0 +1,96 @@
+package com.chinaitop.depot.unissoft.model;
+
+import java.io.Serializable;
+
+//返回基类
+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;
+
+    public String getRetCode() {
+        return retCode;
+    }
+
+    public void setRetCode(String retCode) {
+        this.retCode = retCode;
+    }
+
+    public String getMessage() {
+        return message;
+    }
+
+    public void setMessage(String message) {
+        this.message = message;
+    }
+
+    public T getData() {
+        return data;
+    }
+
+    public void setData(T data) {
+        this.data = 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);
+    }
+
+    private String state;
+    private String msg;
+
+    public String getState() {
+        return state;
+    }
+
+    public void setState(String state) {
+        this.state = state;
+    }
+
+    public String getMsg() {
+        return msg;
+    }
+
+    public void setMsg(String msg) {
+        this.msg = msg;
+    }
+}
+

src/main/java/com/chinaitop/depot/unissoft/serviceconfig/CxfConfig.java

@@ -0,0 +1,33 @@
+package com.chinaitop.depot.unissoft.serviceconfig;
+
+import javax.xml.ws.Endpoint;
+
+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 com.chinaitop.depot.unissoft.webservice.ArchiveWebService;
+import com.chinaitop.depot.unissoft.webservice.ArchiveWebServiceImpl;
+
+@Configuration
+public class CxfConfig {
+    @Bean(name = Bus.DEFAULT_BUS_ID)
+    public SpringBus springBus() {
+        return new SpringBus();
+    }
+
+    //货位管理
+    @Bean
+    public ArchiveWebService ArchiveWebService() {
+        return new ArchiveWebServiceImpl();
+    }
+    @Bean
+    public Endpoint getCRKArchiveList() {
+        EndpointImpl endpoint = new EndpointImpl(springBus(), ArchiveWebService());
+        endpoint.publish("/getCRKArchiveList");
+        return endpoint;
+    }
+
+}

src/main/java/com/chinaitop/depot/unissoft/webservice/ArchiveWebService.java

@@ -0,0 +1,15 @@
+package com.chinaitop.depot.unissoft.webservice;
+
+import javax.jws.WebParam;
+import javax.jws.WebService;
+
+@WebService
+public interface ArchiveWebService {
+
+	/**
+	 * 修改货位的出入库状态（webservice调用）
+	 * @param orgId
+	 * @return
+	 */
+	String getCRKArchiveList(@WebParam(name = "orgId") String orgId);
+}

src/main/java/com/chinaitop/depot/unissoft/webservice/ArchiveWebServiceImpl.java

@@ -0,0 +1,40 @@
+package com.chinaitop.depot.unissoft.webservice;
+
+import com.chinaitop.depot.agent.archive.service.ArchiveService;
+import org.springframework.stereotype.Service;
+
+import com.alibaba.fastjson.JSONArray;
+
+import javax.annotation.Resource;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+@Service
+public class ArchiveWebServiceImpl implements ArchiveWebService {
+
+	@Resource
+	private ArchiveService archiveService;
+
+	@Override
+	@SuppressWarnings("all")
+	public String getCRKArchiveList(String orgId) {
+
+		Map<String,Object> map = new HashMap<String, Object>();
+		try {
+			//执行任务
+			List<Map<String, Object>> archiveList = archiveService.getCRKArchiveList(orgId);
+			map.put("success",true);
+			map.put("msg","查询成功!");
+			map.put("rows",archiveList);
+			map.put("totalCount",archiveList.size());
+		} catch (Exception e) {
+			map.put("success",false);
+			map.put("msg","查询失败!");
+		} finally {
+			JSONArray jsonArray = new JSONArray();
+			jsonArray.add(map);
+			return jsonArray.toString();
+		}
+	}
+}