|
|
|
|
@ -1,29 +1,46 @@
|
|
|
|
|
package com.fr.design.mainframe.toolbar; |
|
|
|
|
|
|
|
|
|
import com.fr.concurrent.NamedThreadFactory; |
|
|
|
|
import com.fr.design.actions.UpdateAction; |
|
|
|
|
import com.fr.design.actions.help.alphafine.AlphaFineConfigManager; |
|
|
|
|
import com.fr.design.constants.DesignerLaunchStatus; |
|
|
|
|
import com.fr.design.gui.frpane.LoadingBasicPane; |
|
|
|
|
import com.fr.design.utils.concurrent.ThreadFactoryBuilder; |
|
|
|
|
import com.fr.event.Event; |
|
|
|
|
import com.fr.event.EventDispatcher; |
|
|
|
|
import com.fr.event.Listener; |
|
|
|
|
import com.fr.event.Null; |
|
|
|
|
import com.fr.general.ComparatorUtils; |
|
|
|
|
import com.fr.general.GeneralUtils; |
|
|
|
|
import com.fr.log.FineLoggerFactory; |
|
|
|
|
import com.fr.stable.StableUtils; |
|
|
|
|
|
|
|
|
|
import javax.swing.JPanel; |
|
|
|
|
import javax.swing.*; |
|
|
|
|
import java.util.HashMap; |
|
|
|
|
import java.util.List; |
|
|
|
|
import java.util.concurrent.LinkedBlockingQueue; |
|
|
|
|
import java.util.concurrent.ThreadPoolExecutor; |
|
|
|
|
import java.util.concurrent.TimeUnit; |
|
|
|
|
import java.util.Map; |
|
|
|
|
import java.util.concurrent.ExecutorService; |
|
|
|
|
import java.util.concurrent.Executors; |
|
|
|
|
|
|
|
|
|
/** |
|
|
|
|
* Created by XiaXiang on 2017/4/13. |
|
|
|
|
* 按钮面板管理类 |
|
|
|
|
* |
|
|
|
|
* @author XiaXiang |
|
|
|
|
* @date 2017/4/13 |
|
|
|
|
*/ |
|
|
|
|
public class UpdateActionManager { |
|
|
|
|
private static UpdateActionManager updateActionManager = null; |
|
|
|
|
|
|
|
|
|
private List<UpdateActionModel> updateActions; |
|
|
|
|
private ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor( |
|
|
|
|
1, 2, |
|
|
|
|
30000L, TimeUnit.MILLISECONDS, |
|
|
|
|
new LinkedBlockingQueue<Runnable>(), |
|
|
|
|
new ThreadFactoryBuilder().setNameFormat("alphafine-thread-%s").build());//目前测下来一个线程慢慢做处理总共大概也只要两秒,暂时就这样
|
|
|
|
|
|
|
|
|
|
private Map<String, UpdateAction> updateActionsIndexCache = new HashMap<>(16); |
|
|
|
|
|
|
|
|
|
private static boolean isRegisterIndexSearchTextTask = false; |
|
|
|
|
|
|
|
|
|
/** |
|
|
|
|
* 限制初始化 |
|
|
|
|
*/ |
|
|
|
|
private UpdateActionManager() { |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
public synchronized static UpdateActionManager getUpdateActionManager() { |
|
|
|
|
if (updateActionManager == null) { |
|
|
|
|
@ -55,22 +72,92 @@ public class UpdateActionManager {
|
|
|
|
|
return null; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
public synchronized void dealWithSearchText(final String paneClass, final UpdateAction updateAction) { |
|
|
|
|
threadPoolExecutor.allowCoreThreadTimeOut(true); |
|
|
|
|
threadPoolExecutor.execute(new Runnable() { |
|
|
|
|
/** |
|
|
|
|
* 处理action的搜索文本。 |
|
|
|
|
* 缓存逻辑： |
|
|
|
|
* 1.首次索引或缓存失效的时候（更新版本会使缓存失效），会将索引缓存存到env.xml， |
|
|
|
|
* 下次直接加载。 |
|
|
|
|
* 2.需要重新索引，则等待设计器初始化完毕之后单线程运行索引任务。 |
|
|
|
|
* |
|
|
|
|
* @param paneClass 面板类名 |
|
|
|
|
* @param updateAction 待处理的updateAction |
|
|
|
|
*/ |
|
|
|
|
public void dealWithSearchText(String paneClass, UpdateAction updateAction) { |
|
|
|
|
Map<String, String> actionSearchTextCache = AlphaFineConfigManager.getInstance().getActionSearchTextCache(); |
|
|
|
|
if (!cacheValid() |
|
|
|
|
|| actionSearchTextCache.isEmpty() |
|
|
|
|
|| !actionSearchTextCache.containsKey(paneClass)) { |
|
|
|
|
if (!updateActionsIndexCache.containsKey(paneClass)) { |
|
|
|
|
updateActionsIndexCache.put(paneClass, updateAction); |
|
|
|
|
} |
|
|
|
|
registerIndexSearchTextTask(); |
|
|
|
|
} else { |
|
|
|
|
updateAction.setSearchText(actionSearchTextCache.get(paneClass)); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
/** |
|
|
|
|
* 缓存是否有效。 |
|
|
|
|
* 注意：开发工程版本为不是安装版本， |
|
|
|
|
* 索引只会出现在首次启动。 |
|
|
|
|
* |
|
|
|
|
* @return true有效，false失效 |
|
|
|
|
*/ |
|
|
|
|
private boolean cacheValid() { |
|
|
|
|
return ComparatorUtils.equals(GeneralUtils.readBuildNO(), AlphaFineConfigManager.getInstance().getCacheBuildNO()); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
/** |
|
|
|
|
* 由于是UI线程不考虑并发问题 |
|
|
|
|
*/ |
|
|
|
|
private void registerIndexSearchTextTask() { |
|
|
|
|
if (isRegisterIndexSearchTextTask) { |
|
|
|
|
return; |
|
|
|
|
} |
|
|
|
|
isRegisterIndexSearchTextTask = true; |
|
|
|
|
// 没有缓存或者缓存失效的时候，等待设计器启动之后开始索引任务
|
|
|
|
|
EventDispatcher.listen(DesignerLaunchStatus.DESIGNER_INIT_COMPLETE, new Listener<Null>() { |
|
|
|
|
@Override |
|
|
|
|
public void run() { |
|
|
|
|
JPanel panel = null; |
|
|
|
|
try { |
|
|
|
|
panel = (JPanel) StableUtils.classForName(paneClass).newInstance(); |
|
|
|
|
if (panel instanceof LoadingBasicPane) { |
|
|
|
|
panel = ((LoadingBasicPane) panel).getAllComponents(); |
|
|
|
|
} |
|
|
|
|
updateAction.setSearchText(updateAction.getComponentTexts(panel, "_", new StringBuffer(), new StringBuffer(), new StringBuffer())); |
|
|
|
|
} catch (Exception e) { |
|
|
|
|
FineLoggerFactory.getLogger().error(e.getMessage(), e); |
|
|
|
|
public void on(Event event, Null param) { |
|
|
|
|
// 使用单线程索引
|
|
|
|
|
ExecutorService es = Executors.newSingleThreadExecutor(new NamedThreadFactory("IndexAlphaFineSearchText")); |
|
|
|
|
for (Map.Entry<String, UpdateAction> cache : updateActionsIndexCache.entrySet()) { |
|
|
|
|
es.execute(new IndexTask(cache.getKey(), cache.getValue())); |
|
|
|
|
} |
|
|
|
|
updateActionsIndexCache = null; |
|
|
|
|
es.shutdown(); |
|
|
|
|
// 标记一下缓存版本
|
|
|
|
|
AlphaFineConfigManager.getInstance().setCacheBuildNO(GeneralUtils.readBuildNO()); |
|
|
|
|
} |
|
|
|
|
}); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
/** |
|
|
|
|
* 索引任务 |
|
|
|
|
*/ |
|
|
|
|
class IndexTask implements Runnable { |
|
|
|
|
private String className; |
|
|
|
|
private UpdateAction updateAction; |
|
|
|
|
|
|
|
|
|
IndexTask(String className, UpdateAction updateAction) { |
|
|
|
|
this.className = className; |
|
|
|
|
this.updateAction = updateAction; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
public void run() { |
|
|
|
|
JPanel panel; |
|
|
|
|
try { |
|
|
|
|
panel = (JPanel) StableUtils.classForName(className).newInstance(); |
|
|
|
|
if (panel instanceof LoadingBasicPane) { |
|
|
|
|
panel = ((LoadingBasicPane) panel).getAllComponents(); |
|
|
|
|
} |
|
|
|
|
String componentTexts = updateAction.getComponentTexts(panel, "_", new StringBuffer(), new StringBuffer(), new StringBuffer()); |
|
|
|
|
updateAction.setSearchText(componentTexts); |
|
|
|
|
AlphaFineConfigManager.getInstance().setActionSearchTextCache(className, componentTexts); |
|
|
|
|
} catch (Exception e) { |
|
|
|
|
FineLoggerFactory.getLogger().error(e.getMessage(), e); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
vito
6 years ago