xFire 實作webservice

實作webservice所需的jar包

伺服器端實作：

業務接口實作：

package com.sk.core.webservice.server;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;

public interface QzqdServer {

    public String saveQzqd(String message);

    public String updateQzqd(String message);

    public String deleteQzqd(String message);

}

業務實作類：

package com.sk.core.webservice.server.impl;

import java.util.HashMap;

import java.util.Iterator;

import javax.annotation.Resource;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;

import javax.xml.ws.WebServiceContext;

import javax.xml.ws.handler.MessageContext;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

import org.codehaus.xfire.transport.http.XFireServletController;

import org.json.JSONArray;

import org.json.JSONException;

import org.json.JSONObject;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Service;

import com.sk.cms.entity.main.CmsSite;

import com.sk.cms.entity.main.CmsUser;

import com.sk.cms.entity.main.Content;

import com.sk.cms.entity.main.ContentExt;

import com.sk.cms.entity.main.ContentTxt;

import com.sk.cms.entity.main.ContentType;

import com.sk.cms.manager.main.CmsSiteMng;

import com.sk.cms.manager.main.CmsUserMng;

import com.sk.cms.manager.main.ContentMng;

import com.sk.cms.web.CmsUtils;

import com.sk.cms.web.WebErrors;

import com.sk.core.manager.UnifiedUserMng;

import com.sk.core.webservice.server.QzqdServer;

@Service

public class QzqdServerImpl implements QzqdServer{

    private static Log log=LogFactory.getLog(QzqdServerImpl.class);

    @Autowired

    private ContentMng contentMng;

    @Autowired

    private CmsUserMng cmsUserMng;

    @Autowired

    private UnifiedUserMng unifiedUserMng;

    @Autowired

    private CmsSiteMng cmsSiteMng;

    public String saveQzqd(String message) {

        HashMap<String, String> messMap = new HashMap<String, String>();  

        try{

        //HttpServletRequest request = XFireServletController.getRequest();

        CmsSite site = cmsSiteMng.findById(1);

        JSONObject json =new JSONObject(message);

        String title=json.getString("title");

        String channelId=json.getString("channelId");

        String username=json.getString("username");

        String password=json.getString("password");

        String picPath=null;

        String picDesc=null;

        if(json.has("picPath")){

            picPath=json.getString("picPath");

        }

        if(json.has("picDesc")){

            picDesc=json.getString("picDesc");

        }

        //String typeId=json.getString("typeId");

        HashMap<String,String> attr=toHashMap(json.getString("attr"));

        Content bean=new Content();

        ContentExt ext=new ContentExt();

        ContentTxt txt=new ContentTxt();

        Integer[] channelIds = null;

        Integer[] topicIds = null;

        Integer typeId=1;

        Integer[] viewGroupIds = null;

        String[] attachmentPaths = null;

        String[] attachmentNames =null;

        String[] attachmentFilenames = null;

        String[] picPaths={picPath};

        String[] picDescs = {picDesc};

        String[] tagArr = null;

        Boolean draft = null;

        CmsUser user = cmsUserMng.findById(unifiedUserMng.getByUsernameAndPass(username, password).getId());// 擷取管理者使用者

        if(null!=user&&!user.getDisabled()){

            bean.setUser(user);

            bean.setAttr(attr);

            bean.setSite(site);

            ext.setTitle(title);

            bean=contentMng.save(bean, ext, txt, channelIds, topicIds, viewGroupIds,

                    tagArr, attachmentPaths, attachmentNames, attachmentFilenames,

                    picPaths, picDescs, Integer.valueOf(channelId), typeId, draft, user, false);

            messMap.put("status", "1");

            messMap.put("contentId",String.valueOf(bean.getId()));

        }else{

            messMap.put("status", "0");

            messMap.put("message", "使用者名或密碼錯誤");    

            }

        }catch(org.json.JSONException e){

            messMap.put("status", "0");

            messMap.put("message", "必需參數存在空值");

            log.info(e.getMessage());

        }

        catch(java.lang.NullPointerException e){

            messMap.put("status", "0");

            messMap.put("message", "使用者名或密碼錯誤");

            log.info(e.getMessage());

        }

        catch(Exception e){

            messMap.put("status", "0");

            messMap.put("message", "資料儲存異常");

            log.info(e.getMessage());

        }

        JSONObject object=new JSONObject(messMap);

        return object.toString();

    }

    public String updateQzqd(String message) {

        HashMap<String, String> messMap = new HashMap<String, String>();  

        try{

        //HttpServletRequest request = XFireServletController.getRequest();

        CmsSite site = cmsSiteMng.findById(1);

        JSONObject json =new JSONObject(message);

        String title=null;

        if(json.has("title")){

        title=json.getString("title");

        }

        String picPath=null;

        String picDesc=null;

        if(json.has("picPath")){

            picPath=json.getString("picPath");

        }

        if(json.has("picDesc")){

            picDesc=json.getString("picDesc");

        }

        String cid=null;

        Integer channelId=null;

        if(json.has("channelId")){

            cid=json.getString("channelId");

            if(cid!=null&&!"".equals("")){

                channelId=Integer.valueOf(cid);

            }

        }

        String username=json.getString("username");

        String password=json.getString("password");

        String id=json.getString("id");

        HashMap<String,String> attr=null;

        if(json.has("attr")){

            attr=toHashMap(json.getString("attr"));

        }

        Content bean=new Content();

        ContentExt ext=new ContentExt();

        ContentTxt txt=new ContentTxt();

        Integer[] channelIds = null;

        Integer[] topicIds = null;

        Integer typeId=1;

        Integer[] viewGroupIds = null;

        String[] attachmentPaths = null;

        String[] attachmentNames =null;

        String[] attachmentFilenames = null;

        String[] picPaths = {picPath};

        String[] picDescs = {picDesc};

        String[] tagArr = null;

        Boolean draft = null;

        CmsUser user = cmsUserMng.findById(unifiedUserMng.getByUsernameAndPass(username, password).getId());// 擷取管理者使用者

        if(null!=user&&!user.getDisabled()){

            bean.setId(Integer.valueOf(id));

            bean.setUser(user);

            //bean.setAttr(attr);

            bean.setSite(site);

            if(title!=null&&!"".equals(title)){

            ext.setTitle(title);

            }

            ext.setId(Integer.valueOf(id));

            bean=contentMng.update(bean, ext, txt, tagArr, channelIds, topicIds, viewGroupIds, attachmentPaths, attachmentNames, attachmentFilenames, picPaths, picDescs, attr, channelId, typeId, draft, user, false);

            messMap.put("status", "1");

            messMap.put("contentId",String.valueOf(bean.getId()));

        }else{

            messMap.put("status", "0");

            messMap.put("message", "使用者名或密碼錯誤");

        }

        }catch(org.json.JSONException e){

            messMap.put("status", "0");

            messMap.put("message", "必需參數存在空值");

            log.info(e.getMessage());

        }

        catch(java.lang.NullPointerException e){

            messMap.put("status", "0");

            messMap.put("message", "使用者名或密碼錯誤");

            log.info(e.getMessage());

        }

        catch(Exception e){

            messMap.put("status", "0");

            messMap.put("message", "資料跟新異常");

            log.info(e.getMessage());

            e.printStackTrace();

        }

        JSONObject object=new JSONObject(messMap);

        return object.toString();

    }

    public String deleteQzqd(String message) {

        HashMap<String, String> messMap = new HashMap<String, String>();  

        try{

        JSONObject json =new JSONObject(message);

        String id=json.getString("id");

        String username=json.getString("username");

        String password=json.getString("password");

        CmsUser user = cmsUserMng.findById(unifiedUserMng.getByUsernameAndPass(username, password).getId());// 擷取管理者使用者

        if(null!=user&&!user.getDisabled()){

            Content bean=contentMng.deleteById(Integer.valueOf(id));

            messMap.put("status", "1");

            messMap.put("contentId",String.valueOf(bean.getId()));

        }else{

            messMap.put("status", "0");

            messMap.put("message", "使用者名或密碼錯誤");

        }

        }catch(org.json.JSONException e){

            messMap.put("status", "0");

            messMap.put("message", "必需參數存在空值");

            log.info(e.getMessage());

        }

        catch(java.lang.NullPointerException e){

            messMap.put("status", "0");

            messMap.put("message", "使用者名或密碼錯誤");

            log.info(e.getMessage());

        }

        catch(Exception e){

            messMap.put("status", "0");

            messMap.put("message", "資料儲存異常");

            log.info(e.getMessage());

        }

        JSONObject object=new JSONObject(messMap);

        return object.toString();

    }

    private  HashMap<String, String> toHashMap(String object) throws JSONException  

    {  

        HashMap<String, String> data = new HashMap<String, String>();  

        // 将json字元串轉換成jsonObject  

        JSONObject jsonObject = new JSONObject(object);  

        Iterator it = jsonObject.keys();  

        // 周遊jsonObject資料，添加到Map對象  

        while (it.hasNext())  

        {  

            String key = String.valueOf(it.next());  

            String value =  jsonObject.getString(key);  

            data.put(key, value);  

        }  

        return data;  

    }  

}

在web.xml檔案中添加：

<!-- begin XFire 配置 -->

    <servlet>   

       <servlet-name>xfire</servlet-name>   

       <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>

    </servlet>  

<!--    <servlet-mapping>

       <servlet-name>xfire</servlet-name>

       <url-pattern>*.ws</url-pattern>

    </servlet-mapping>-->

    <servlet>

       <!-- 配合Spring容器中XFire一起工作的Servlet-->

       <servlet-name>xfireServlet</servlet-name>

       <servlet-class>org.codehaus.xfire.spring.XFireSpringServlet</servlet-class>

    </servlet>

    <servlet-mapping>

       <servlet-name>xfireServlet</servlet-name>

       <!-- 在這個URI下開放Web Service服務 -->

       <url-pattern>/service/XFireServlet/*</url-pattern>

    </servlet-mapping>

    <!-- end XFire 配置 -->

xfire-servlet.xml檔案

<?xml version="1.0" encoding="UTF-8"?>

<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN"

    "http://www.springframework.org/dtd/spring-beans.dtd">

<beans>

    <bean id="webServiceClient" class="com.sk.core.webservice.client.WebServiceClient"/>

    <bean id="HelloWorldBean" class="com.sk.core.webservice.impl.HelloServerImpl"/>

    <!-- 引入XFire預配置資訊 -->

    <import resource="classpath:org/codehaus/xfire/spring/xfire.xml" />

    <!-- 定義通路的url -->

    <bean class="org.springframework.web.servlet.handler.SimpleUrlHandlerMapping">

       <property name="urlMap">             

           <map>                 

              <entry key="/service/XFireServlet/HelloWorldService.ws">                  

                  <ref bean="HelloWorldService" />                 

              </entry>            

           </map>         

       </property>     

    </bean>     

    <!-- 使用XFire導出器 -->

    <bean id="baseWebService" class="org.codehaus.xfire.spring.remoting.XFireExporter" lazy-init="false" abstract="true">

       <!-- 引用xfire.xml中定義的工廠 -->

       <property name="serviceFactory" ref="xfire.serviceFactory" />

       <!-- 引用xfire.xml中的xfire執行個體 -->

       <property name="xfire" ref="xfire" />

    </bean>

    <bean id="HelloWorldService" parent="baseWebService">

       <!-- 業務服務bean -->

       <property name="serviceBean" ref="HelloWorldBean" />

       <!-- 業務服務bean的窄接口類 -->

       <property name="serviceClass" value="com.sk.core.webservice.HelloServer" />

    </bean>

    <!-- 以下是lt在2016-03-21添權重責清單webservice服務 -->

  <bean id="qzqdService" class="com.sk.core.webservice.server.impl.QzqdServerImpl"/>

    <bean id="qzqdWebService" parent="baseWebService">

        <property name="serviceBean" ref="qzqdService"/>

        <property name="serviceClass" value="com.sk.core.webservice.server.QzqdServer"/>

    </bean>

</beans>

用戶端測試類：

package sktask;

import java.net.URL;

import java.util.Date;

import org.apache.commons.httpclient.util.HttpURLConnection;

import org.codehaus.xfire.client.Client;

public class WebServiceTest {

    public boolean newMessage() {

        Client client;

        try {

            client = new Client(

                    new URL(

                            "http://localhost:9090/service/XFireServlet/QzqdServer?wsdl"));

            // 根據WSDL建立客戶執行個體

            String[] objArray = new String[1];

            objArray[0] = "{'id':'14315','picPath':'http://dpxq.gov.cn/u/cms/www/201603/011705420vfw.jpg','title':'test修改222','username':'webqzqd','password':'e10adc3949ba59abbe56e057f20f883e'}";

            //objArray[0] = "{'picPath':'http://dpxq.gov.cn/u/cms/www/201603/011705420vfw.jpg','title':'test2','channelId':'786','username':'webqzqd','password':'e10adc3949ba59abbe56e057f20f883e'}";

            //objArray[0] = "{'id':'14314','username':'webqzqd','password':'e10adc3949ba59abbe56e057f20f883e'}";

            // 調用特定的Web Service方法

            //Object[] results = client.invoke("saveQzqd", objArray);

            Object[] results = client.invoke("updateQzqd", objArray);

            //Object[] results = client.invoke("deleteQzqd", objArray);

            System.out.println("newMessage result: " + results[0]);

            return Boolean.parseBoolean(results[0].toString());

        } catch (Exception e) {

            e.printStackTrace();

        }

        return false;

    }

    public static void main(String[] args){

        WebServiceTest test=new WebServiceTest();

        test.newMessage();

    }

}