Liferay7 BPM门户开发之37: Liferay7下的OSGi Hook集成开发

AUI()
.use(‘aui-base‘,‘aui-delayed-task‘,    ‘liferay-poller‘,
function(A) {

Liferay.namespace(‘BladePoller‘);

Liferay.BladePoller.Manager = {
init: function() {

var instance = this;

instance._portletId = A.one("#pollerPortletId").val();

instance._bladePollerContainer = A.one(‘#bladePollerContainer‘);


console.log("Init: portletId:"+instance._portletId+
", containerId:"+instance._bladePollerContainer);

instance._updateTask = new A.debounce(instance._updateMessage,30000,
instance);

instance._updateTask.delay(0);

Liferay.Poller.addListener(instance._portletId,instance._onPollerUpdate, instance);

Liferay.on(
‘sessionExpired‘,
function(event) {
Liferay.Poller.removeListener(instance._portletId);
instance._bladePollerContainer.hide();
}
);

},

send: function(options, id) {

console.log("Options:" + options + ", id:" + id);

var instance = this;

Liferay.Poller.submitRequest(instance._portletId, options, id);

instance._updateTask();
},

_updateMessage: function() {
console.log("Update Message");
var instance = this;
instance.send(    {
status : ‘OK‘
});
},

_onPollerUpdate : function(response, chunkId) {

console.log("updating...");

var instance = this;

instance._bladePollerContainer.text(response.content.message);

instance._bladePollerContainer.show();

instance.send(
{
status : ‘OK‘
}
);

}

};

A.augment(Liferay.BladePoller.Manager, A.Attribute, true);

Liferay.publish(
‘pollerPortletReady‘,
{
defaultFn: A.bind(‘init‘, Liferay.BladePoller.Manager),
fireOnce: true
}
);

A.on(
‘domready‘,
function() {
Liferay.fire(‘pollerPortletReady‘);
}
);

}

);

<%@ taglib uri="http://java.sun.com/jsp/jstl/core" prefix="c" %>

<%@ taglib uri="http://java.sun.com/portlet_2_0" prefix="portlet" %>

<%@ taglib uri="http://liferay.com/tld/aui" prefix="aui" %><%@
taglib uri="http://liferay.com/tld/portlet" prefix="liferay-portlet" %><%@
taglib uri="http://liferay.com/tld/theme" prefix="liferay-theme" %><%@
taglib uri="http://liferay.com/tld/ui" prefix="liferay-ui" %>

<liferay-theme:defineObjects />

<portlet:defineObjects />
<p>
<b><liferay-ui:message
key="blade_portlet_BladePollProcessorPortlet.title" /></b>
</p>

<input id="pollerPortletId" type="hidden" value="<%= portletDisplay.getId() %>" />

<p id="bladePollerContainer"></p>

import com.liferay.portal.kernel.portlet.bridges.mvc.MVCPortlet;
import javax.portlet.Portlet;
import org.osgi.service.component.annotations.Component;

@Component(
immediate = true,
property = {
"com.liferay.portlet.css-class-wrapper=portlet-pollprocessor-blade",
"com.liferay.portlet.display-category=category.sample",
"com.liferay.portlet.header-portlet-javascript=/js/main.js",
"com.liferay.portlet.poller-processor-class=blade.portlet.BladePollProcessor",
"com.liferay.portlet.private-request-attributes=false",
"com.liferay.portlet.private-session-attributes=false",
"com.liferay.portlet.remoteable=true",
"com.liferay.portlet.render-weight=50",
"javax.portlet.display-name=BLADE PollProcessor",
"javax.portlet.expiration-cache=0",
"javax.portlet.init-param.template-path=/",
"javax.portlet.init-param.view-template=/view.jsp",
"javax.portlet.portlet.info.keywords=blade,pollprocessor",
"javax.portlet.portlet.info.short-title=BLADE PollProcessor",
"javax.portlet.portlet.info.title=BLADE PollProcessor",
"javax.portlet.resource-bundle=content.Language",
"javax.portlet.security-role-ref=power-user,user"
},
service = Portlet.class
)
public class BladePollProcessorPortlet extends MVCPortlet {
}


import com.liferay.portal.kernel.json.JSONFactoryUtil;
import com.liferay.portal.kernel.json.JSONObject;
import com.liferay.portal.kernel.log.Log;
import com.liferay.portal.kernel.log.LogFactoryUtil;
import com.liferay.portal.kernel.poller.BasePollerProcessor;
import com.liferay.portal.kernel.poller.DefaultPollerResponse;
import com.liferay.portal.kernel.poller.PollerProcessor;
import com.liferay.portal.kernel.poller.PollerRequest;
import com.liferay.portal.kernel.poller.PollerResponse;
import java.util.Date;
import org.osgi.service.component.annotations.Component;

@Component(
immediate = true,
property = {"javax.portlet.name=blade_portlet_BladePollProcessorPortlet"},
service = PollerProcessor.class
)
public class BladePollProcessor extends BasePollerProcessor {

@Override
protected PollerResponse doReceive(PollerRequest pollerRequest)
throws Exception {

if (_log.isDebugEnabled()) {
_log.debug("Recevied the poller request" + pollerRequest);
}

JSONObject responseJSON = JSONFactoryUtil.createJSONObject();
PollerResponse pollerResponse = new DefaultPollerResponse();
responseJSON.put(
"message", "Hello from BLADE Poller, time now is:" + new Date());
pollerResponse.setParameter("content", responseJSON);

return pollerResponse;
}

@Override
protected void doSend(PollerRequest pollerRequest) throws Exception {
String status = getString(pollerRequest, "status");

if (_log.isInfoEnabled()) {
_log.info("Poller status:" + status);
}
}

private final Log _log = LogFactoryUtil.getLog(BladePollProcessor.class);

}

@Component(
    immediate = true, property = {"path=/login/login"},
    service = StrutsPortletAction.class
)
public class BladePortletAction extends BaseStrutsPortletAction {

    @Override
    public void processAction(
            StrutsPortletAction originalStrutsPortletAction,
            PortletConfig portletConfig, ActionRequest actionRequest,
            ActionResponse actionResponse)
        throws Exception {

        if (_log.isDebugEnabled()) {
            _log.debug("BladePortletAction - procesAction");
        }

        ThemeDisplay themeDisplay = (ThemeDisplay)actionRequest.getAttribute(
            WebKeys.THEME_DISPLAY);

        User loggedinUser = themeDisplay.getUser();

        if ((loggedinUser != null) && _log.isInfoEnabled()) {
            _log.info(
                "Logging in with user:[" + loggedinUser.getFirstName() + " " +
                    loggedinUser.getLastName() + "]");

            _log.info(
                "Logged in user: Current Greetings[" +
                    loggedinUser.getGreeting() + "]");
        }

        originalStrutsPortletAction.processAction(
            originalStrutsPortletAction, portletConfig, actionRequest,
            actionResponse);
    }

    @Override
    public String render(
            StrutsPortletAction originalStrutsPortletAction,
            PortletConfig portletConfig, RenderRequest renderRequest,
            RenderResponse renderResponse)
        throws Exception {

        if (_log.isDebugEnabled()) {
            _log.debug("BladePortletAction - render");
        }

        ThemeDisplay themeDisplay = (ThemeDisplay)renderRequest.getAttribute(
            WebKeys.THEME_DISPLAY);

        User loggedinUser = themeDisplay.getUser();

        if (loggedinUser != null) {
            loggedinUser.setLastName("BLADE");

            loggedinUser.setGreeting(
                "Hello," + loggedinUser.getFirstName() + " from BLADE!");

            _userLocalService.updateUser(loggedinUser);
        }

        return originalStrutsPortletAction.render(
            originalStrutsPortletAction, portletConfig, renderRequest,
            renderResponse);
    }

    @Override
    public void serveResource(
            StrutsPortletAction originalStrutsPortletAction,
            PortletConfig portletConfig, ResourceRequest resourceRequest,
            ResourceResponse resourceResponse)
        throws Exception {

        if (_log.isDebugEnabled()) {
            _log.debug("BladePortletAction - serveResource");
        }

        originalStrutsPortletAction.serveResource(
            originalStrutsPortletAction, portletConfig, resourceRequest,
            resourceResponse);
    }

    @Reference(unbind = "-")
    public void setUserService(UserLocalService userService) {
        _userLocalService = userService;
    }

    private static final Log _log = LogFactoryUtil.getLog(
        BladePortletAction.class);

    private UserLocalService _userLocalService;

}

import com.liferay.portal.kernel.language.UTF8Control;
import java.util.Enumeration;
import java.util.ResourceBundle;
import org.osgi.service.component.annotations.Component;

@Component(
    immediate = true, property = {"language.id=en_US"},
    service = ResourceBundle.class
)
public class CustomResourceBundle extends ResourceBundle {

    @Override
    public Enumeration<String> getKeys() {
        return _resourceBundle.getKeys();
    }

    @Override
    protected Object handleGetObject(String key) {
        return _resourceBundle.getObject(key);
    }

    private final ResourceBundle _resourceBundle = ResourceBundle.getBundle(
        "content.Language", UTF8Control.INSTANCE);

}

@Component(
    immediate = true,
    property = {
        "javax.portlet.name=com_liferay_blade_samples_portlet_actioncommand_GreeterPortlet",
        "mvc.command.name=greet"
    },
    service = MVCActionCommand.class
)
public class GreeterActionCommand implements MVCActionCommand {

    @Override
    public boolean processAction(
            ActionRequest actionRequest, ActionResponse actionResponse)
        throws PortletException {

        _handleActionCommand(actionRequest);

        return true;
    }

    private void _handleActionCommand(ActionRequest actionRequest) {
        String name = ParamUtil.get(actionRequest, "name", StringPool.BLANK);

        if (_log.isInfoEnabled()) {
            _log.info("Hello " + name);
        }

        String greetingMessage = "Hello " + name + "! Welcome to OSGi";

        actionRequest.setAttribute("GREETER_MESSAGE", greetingMessage);

        SessionMessages.add(actionRequest, "greetingMessage", greetingMessage);
    }

    private static final Log _log = LogFactoryUtil.getLog(
        GreeterActionCommand.class);

}