新增倒仓结构

src/main/java/com/chinaitop/depot/pushs/service/PushsService.java

@@ -0,0 +1,13 @@
+package com.chinaitop.depot.pushs.service;
+
+
+public interface PushsService {
+
+
+	//出入库将倒仓通知单记录传回库级平台进行展示
+	String updateChangeStorageHouse(String ChangeStorageHouseData);
+
+	//出入库取库级平台倒仓通知单数据
+	String getContractDatas(String orgId, String ids);
+
+}

src/main/java/com/chinaitop/depot/pushs/service/impl/PushServiceImpl.java

@@ -0,0 +1,71 @@
+package com.chinaitop.depot.pushs.service.impl;
+
+
+import com.alibaba.fastjson.JSON;
+import com.chinaitop.depot.pushs.service.PushsService;
+import com.chinaitop.depot.storage.mapper.StorageChangeStoragehouseDefaultMapper;
+import com.chinaitop.depot.storage.model.StorageChangeStoragehouseRop;
+import com.chinaitop.depot.storage.service.StorageChangeStoragehouseRopService;
+import com.chinaitop.depot.storage.utils.ParameterUtil;
+import com.chinaitop.depot.storage.utils.ResponseEntity;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import javax.annotation.Resource;
+import java.io.IOException;
+import java.util.Arrays;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+@Service
+public class PushServiceImpl implements PushsService {
+	
+    final static Logger logger  =  LoggerFactory.getLogger(PushServiceImpl.class );
+
+
+	@Resource
+	private StorageChangeStoragehouseDefaultMapper storageChangeStoragehouseDefaultMapper;
+
+	@Resource
+	private StorageChangeStoragehouseRopService storageChangeStoragehouseRopService;
+
+	@Transactional(rollbackFor = Exception.class)
+	@Override
+	public String updateChangeStorageHouse(String ChangeStorageHouseData) {
+		String retS = "Success";
+		try {
+			ObjectMapper mapper = new ObjectMapper();
+			StorageChangeStoragehouseRop storageChangeStoragehouseRop = (StorageChangeStoragehouseRop) mapper.readValue(ChangeStorageHouseData, StorageChangeStoragehouseRop.class);
+			storageChangeStoragehouseRopService.insertChangeStorageHouse(storageChangeStoragehouseRop);
+		} catch (IOException e) {
+			return retS = "error";
+		}
+		return retS;
+	}
+
+
+
+	@Transactional(rollbackFor = Exception.class)
+	@Override
+	public String getContractDatas(String orgId, String ids) {
+		//查出数据
+		Map<String,Object> mapCondition = new HashMap<String, Object>();
+		if(ParameterUtil.isnotnull(ids)){
+			List<String> conList = Arrays.asList(ids.split(","));
+			mapCondition.put("ids",conList);
+		}
+		if(ParameterUtil.isnotnull(orgId)){
+			mapCondition.put("orgId",orgId);
+		}
+		List<Map<String,Object>> mainList =storageChangeStoragehouseDefaultMapper.contractData(mapCondition);
+
+		Map<String,Object> mapData = new HashMap<String, Object>();
+		mapData.put("status", "success");
+		mapData.put("mainData", mainList);
+		return JSON.toJSONString(ResponseEntity.ok(mapData));
+	}
+}

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

@@ -0,0 +1,98 @@
+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,54 @@
+package com.chinaitop.depot.unissoft.serviceconfig;
+
+
+
+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.ContractPassService;
+import com.chinaitop.depot.unissoft.webservice.ContractPassServiceImpl;
+import com.chinaitop.depot.unissoft.webservice.NoticePassService;
+import com.chinaitop.depot.unissoft.webservice.NoticePassServiceImpl;
+
+import javax.xml.ws.Endpoint;
+
+
+@Configuration
+public class CxfConfig {
+	/*
+	 * @Bean public ServletRegistrationBean dispatcherServlet() { return new
+	 * ServletRegistrationBean(new CXFServlet(),"/business/*"); }
+	 */
+    @Bean(name = Bus.DEFAULT_BUS_ID)
+    public SpringBus springBus() {
+        return new SpringBus();
+    }
+
+    //倒仓
+    @Bean
+    public ContractPassService contractPassService() {
+        return new ContractPassServiceImpl();
+    }
+    @Bean
+    public Endpoint uploadContractData() {
+        EndpointImpl endpoint = new EndpointImpl(springBus(), contractPassService());
+        endpoint.publish("/selectContractData");
+        return endpoint;
+    }
+
+    //出入库-库级平台
+    @Bean
+    public NoticePassService noticePassService() {
+        return  new NoticePassServiceImpl();
+    }
+    @Bean
+    public Endpoint uploadNoticeData() {
+        EndpointImpl endpoint = new EndpointImpl(springBus(), noticePassService());
+        endpoint.publish("/updateChangeStorageHouse");
+        return endpoint;
+    }
+
+}

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

@@ -0,0 +1,15 @@
+package com.chinaitop.depot.unissoft.webservice;
+
+
+
+import javax.jws.WebParam;
+import javax.jws.WebService;
+
+
+@WebService
+public interface ContractPassService {
+
+    //倒仓通知单接口-(市平台-库级平台-出入库)
+    public String getContractDatas(@WebParam(name = "orgId") String orgId, @WebParam(name = "ids") String ids);
+
+}

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

@@ -0,0 +1,21 @@
+package com.chinaitop.depot.unissoft.webservice;
+
+
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import com.chinaitop.depot.pushs.service.PushsService;
+
+@Service
+@SuppressWarnings("all")
+public class ContractPassServiceImpl implements ContractPassService {
+
+	@Resource
+	private PushsService PushsService;
+
+
+	@Override
+	public String getContractDatas(String orgId, String ids) {
+		return PushsService.getContractDatas(orgId, ids);
+	}
+}

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

@@ -0,0 +1,16 @@
+package com.chinaitop.depot.unissoft.webservice;
+
+
+
+import javax.jws.WebParam;
+import javax.jws.WebService;
+
+
+@WebService
+public interface NoticePassService {
+
+	//倒仓通知单记录接口-(出入库-库级平台)
+	//changeStorageHouseData  出入库数据以json格式传给库级平台
+    public String updateContractStatus(@WebParam(name = "changeStorageHouseData") String changeStorageHouseData);
+
+}

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

@@ -0,0 +1,22 @@
+package com.chinaitop.depot.unissoft.webservice;
+
+
+import com.chinaitop.depot.pushs.service.PushsService;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+
+@Service
+@SuppressWarnings("all")
+public class NoticePassServiceImpl implements NoticePassService {
+
+	@Resource
+	private PushsService PushsService;
+
+	@Override
+	public String updateContractStatus(String changeStorageHouseData) {
+		// TODO Auto-generated method stub
+		return PushsService.updateChangeStorageHouse(changeStorageHouseData);
+	}
+	
+}