design/designer-base/src/main/java/com/fr/design/login/message/DesignerMessageHelper.java

package com.fr.design.login.message;

import com.fr.concurrent.NamedThreadFactory;
import com.fr.design.DesignerEnvManager;
import com.fr.design.dialog.NotificationDialog;
import com.fr.design.dialog.NotificationDialogAction;
import com.fr.design.event.DesignerOpenedListener;
import com.fr.design.login.utils.DesignerLoginUtils;
import com.fr.design.mainframe.DesignerContext;
import com.fr.design.utils.BrowseUtils;
import com.fr.general.CloudCenter;
import com.fr.general.http.HttpToolbox;
import com.fr.json.JSON;
import com.fr.json.JSONFactory;
import com.fr.json.JSONObject;
import com.fr.log.FineLoggerFactory;
import com.fr.stable.StringUtils;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

/**
 * @author Lanlan
 * @version 10.0
 * Created by Lanlan on 2021/6/11
 */
public class DesignerMessageHelper {

    private static final long DELAY = 1L;
    private static final String STATUS = "status";
    private static final String DATA = "data";
    private static final String SUCCESS = "success";
    private static final String MESSAGE_ID = "messageId";
    private static final String TITLE = "title";
    private static final String BODY = "body";
    private static final String JUMP_TYPE = "jumpType";
    private static final String JUMP_TO = "jumpTo";

    private static DesignerMessageHelper instance;

    private DesignerMessageHelper() {
    }

    public static DesignerMessageHelper getInstance() {
        if (instance == null) {
            instance = new DesignerMessageHelper();
        }
        return instance;
    }

    public void prepareShowMessage() {
        DesignerContext.getDesignerFrame().addDesignerOpenedListener(new DesignerOpenedListener() {
            @Override
            public void designerOpened() {
                ScheduledExecutorService service = Executors.newSingleThreadScheduledExecutor(new NamedThreadFactory("DesignerMessageHelper"));
                service.schedule(new Runnable() {
                    @Override
                    public void run() {
                        try {
                            pullLatestMessageAndShow();
                        } catch (Exception e) {
                            FineLoggerFactory.getLogger().error(e.getMessage(), e);
                        }
                    }
                }, DELAY, TimeUnit.MINUTES);
                service.shutdown();
            }
        });
    }

    private void pullLatestMessageAndShow() throws Exception {
        String url = CloudCenter.getInstance().acquireUrlByKind("designer.message.push", "https://market.fanruan.com/api/v1/message/designer");
        Map<String, String> params = new HashMap<>();
        params.put("designerId", DesignerEnvManager.getEnvManager().getUUID());
        String result = HttpToolbox.post(url, params);
        JSONObject response = JSONFactory.createJSON(JSON.OBJECT, result);
        String status = response.optString(STATUS);
        if (SUCCESS.equals(status)) {
            JSONObject data = response.optJSONObject(DATA);
            String messageId = data.optString(MESSAGE_ID);
            String title = data.optString(TITLE);
            String body = data.optString(BODY);
            int jumpType = data.optInt(JUMP_TYPE);
            String jumpTo = data.optString(JUMP_TO);
            if (StringUtils.isNotEmpty(messageId) && StringUtils.isNotEmpty(title) && StringUtils.isNotEmpty(body) && jumpType > 0 && StringUtils.isNotEmpty(jumpTo)) {
                NotificationJumpType notificationJumpType = NotificationJumpType.valueOf(jumpType);
                if (notificationJumpType == NotificationJumpType.WEB_URL) {
                    NotificationDialog.Builder()
                            .owner(DesignerContext.getDesignerFrame())
                            .title(title)
                            .modal(true)
                            .messageType(NotificationDialog.NEW_MESSAGE)
                            .message(body)
                            .notificationDialogAction(new NotificationDialogAction() {
                                @Override
                                public void doClick() {
                                    String ssoUrl = DesignerLoginUtils.generateDesignerSSOUrl(jumpTo);
                                    BrowseUtils.browser(ssoUrl);
                                }
                            }).build();
                } else if (notificationJumpType == NotificationJumpType.DESIGNER_MODULE) {
                    DesignerModuleClickType designerModuleClickType = DesignerModuleClickType.valueOf(jumpTo);
                    NotificationDialog.Builder()
                            .owner(DesignerContext.getDesignerFrame())
                            .title(title)
                            .modal(true)
                            .messageType(NotificationDialog.NEW_MESSAGE)
                            .message(body)
                            .notificationDialogAction(designerModuleClickType.getAction())
                            .build();
                }
            }
        }
    }
}