WebServiceConfigAction

package gboat2.cxf.action;

import gboat2.base.core.annotation.Business;
import gboat2.base.core.annotation.Domain;
import gboat2.base.core.annotation.Module;
import gboat2.base.core.annotation.Operation;
import gboat2.base.core.annotation.Operations;
import gboat2.base.core.annotation.Preference;
import gboat2.base.core.dao.Page;
import gboat2.base.core.web.BaseActionSupport;
import gboat2.base.core.web.JsonResultSupport;
import gboat2.cxf.Constant;
import gboat2.cxf.business.IWebServiceConfigBusiness;
import gboat2.cxf.model.WebServiceConfig;
import gboat2.cxf.model.WebServiceConfigParam;

import java.util.ArrayList;
import java.util.List;
import java.util.Map;

import net.sf.json.JSONArray;
import net.sf.json.JSONObject;

import org.apache.commons.lang3.StringUtils;
import org.apache.struts2.convention.annotation.ParentPackage;
import org.apache.struts2.convention.annotation.ResultPath;
import org.apache.struts2.convention.annotation.Results;
import org.osgi.framework.Bundle;
import org.osgi.framework.BundleContext;
import org.osgi.framework.Constants;
import org.osgi.framework.ServiceReference;
import org.osgi.service.startlevel.StartLevel;
import org.springframework.beans.factory.annotation.Autowired;

@ParentPackage("webservice")
@Domain(WebServiceConfig.class)
@ResultPath("/content/webServiceConfig")
@Results( { @org.apache.struts2.convention.annotation.Result(name = "return-list", location = "/web-service-config!list.do", type = "redirect") })
@Module(name = "web服务配置", desc = "用来增删查改web服务，以及发布、取消发布web服务")
@Operations(value = { @Operation(name = "添加web服务", code = "add"), @Operation(name = "编辑web服务", code = "edit"),
        @Operation(name = "删除web服务", code = "delete") })
@Business(IWebServiceConfigBusiness.class)
@Preference("系统配置/web 服务管理")
public class WebServiceConfigAction extends BaseActionSupport {

	/** */
	private static final long serialVersionUID = 1L;

	private transient WebServiceConfig webSerConfig;

	private String bundleName;

	private List<String> bundleNames = new ArrayList<String>();

	private List<String> interfaceName = new ArrayList<String>();

	private boolean isEdit = false;

	public List<String> getInterfaceName() {
		return interfaceName;
	}

	public void setInterfaceName(List<String> interfaceName) {
		this.interfaceName = interfaceName;
	}

	@Autowired
	private transient IWebServiceConfigBusiness webSer;

	@Autowired
	private transient StartLevel startLevelSer;

	protected void initList(Map<String, Object> params) {
	}

	@Override
	protected void postList(Page pageinfo) {
		List<WebServiceConfig> webServiceConfigList = pageinfo.getResult();
		for (WebServiceConfig cfg : (List<WebServiceConfig>) webServiceConfigList) {
			cfg.setRelativeAddress(getHostAddress() + cfg.getRelativeAddress() + "?wsdl");
		}
	}

	private String getHostAddress() {
		WebServiceConfigParam siteAddress = webSer.getWebSerConfParam(IWebServiceConfigBusiness.SITE_ADDRESS_KEY);
		WebServiceConfigParam port = webSer.getWebSerConfParam(IWebServiceConfigBusiness.PORT_KEY);
		return siteAddress.getParamValue() + ":" + port.getParamValue() + "/";
	}

	@Override
	protected void initEdit() {
		Bundle[] bundles = context.getBundles();
		for (Bundle tempBundle : bundles) {
			//只有第二级以上的Bundle被获取
			if (startLevelSer.getBundleStartLevel(tempBundle) >= 3) {
				bundleNames.add(tempBundle.getSymbolicName());

			}

		}
		webSerConfig = (WebServiceConfig) getModel();
		if (StringUtils.isEmpty(webSerConfig.getConfigId())) {
			isEdit = false;
		} else {
			isEdit = true;
		}

		Bundle bundle = getBundleBySymbolicName(context, webSerConfig.getBundleName());
		if (null != bundle) {
			String exportPckNames = (String) bundle.getHeaders().get(Constants.EXPORT_PACKAGE);
			ServiceReference[] srs = bundle.getRegisteredServices();
			if (null != srs) {
				for (ServiceReference sr : srs) {
					String[] names = (String[]) sr.getProperty(Constants.OBJECTCLASS);
					if (null == names || names.length == 0) {
						continue;
					}
					String serviceName = names[0];

					//去掉中括号
					//String deleteFront = sr.toString().substring(1);
					//String serviceName = deleteFront.substring(0, deleteFront.length() - 1);
					if (webSer.decideCurrentService(exportPckNames, serviceName)) {
						interfaceName.add(serviceName);
					}
				}
			}
		}

	}

	protected void postSave() {
		WebServiceConfig webSerConfig = (WebServiceConfig) getModel();

		if (Constant.WEBSERVICE_STATUS_ACTIVE.equals(webSerConfig.getStatus())) {
			webSer.publishService(webSerConfig);
		} else {
			webSer.unpublishService(webSerConfig);
		}
	}

	//激活web服务
	public String activeWebservice() {
		WebServiceConfig webSerConfig = (WebServiceConfig) getModel();

		ServiceReference serRef = this.context.getServiceReference(webSerConfig.getInterfaceName());
		if (null != serRef) {
			webSer.publishService(webSerConfig);
		} else {
			webSerConfig.setStatus("0");
			webSer.update(webSerConfig);
		}
		return "return-list";
	}

	//取消激活web服务
	public String inactiveWebservice() {
		WebServiceConfig webSerConfig = (WebServiceConfig) getModel();
		webSer.unpublishService(webSerConfig);
		//		webSerConfig.setStatus("0");//重构到bussiness中
		//		webSer.update(webSerConfig);
		return "return-list";
	}

	public void getInterfaces() {
		JSONArray returnJSONArray = new JSONArray();
		if (!StringUtils.isEmpty(bundleName)) {

			Bundle bundle = getBundleBySymbolicName(context, bundleName);
			if (null != bundle) {
				String exportPckNames = (String) bundle.getHeaders().get(Constants.EXPORT_PACKAGE);
				ServiceReference[] srs = bundle.getRegisteredServices();
				if (null != srs) {
					for (ServiceReference sr : srs) {
						String[] names = (String[]) sr.getProperty(Constants.OBJECTCLASS);
						if (null == names || names.length == 0) {
							continue;
						}
						String serviceName = names[0];
						//去掉中括号
						//String deleteFront = sr.toString().substring(1);
						//String deleteTail = deleteFront.substring(0, deleteFront.length() - 1);
						if (webSer.decideCurrentService(exportPckNames, serviceName)) {
							//TODO:采用toString似乎不够稳定
							JSONObject item = new JSONObject();
							item.put("key", serviceName);
							item.put("value", serviceName);
							returnJSONArray.add(item);
						}
					}
				}
			}
		}
		JsonResultSupport.output(JSONArray.fromObject(returnJSONArray), response);
	}

	private Bundle getBundleBySymbolicName(BundleContext bundleContext, String bundleName) {
		Bundle[] bundles = bundleContext.getBundles();
		for (Bundle bundle : bundles) {
			if (bundle.getSymbolicName().equals(bundleName)) {
				return bundle;

			}
		}
		return null;
	}

	public WebServiceConfig getWebSerConfig() {
		return webSerConfig;
	}

	public void setWebSerConfig(WebServiceConfig webSerConfig) {
		this.webSerConfig = webSerConfig;
	}

	public List<String> getBundleNames() {
		return bundleNames;
	}

	public void setBundleNames(List<String> bundleNames) {
		this.bundleNames = bundleNames;
	}

	public String getBundleName() {
		return bundleName;
	}

	public void setBundleName(String bundleName) {
		this.bundleName = bundleName;
	}


    public boolean getIsEdit() {
    	return isEdit;
    }


    public void setIsEdit(boolean isEdit) {
    	this.isEdit = isEdit;
    }

}