Compare commits
5 Commits
| Author | SHA1 | Date |
|---|---|---|
 richie
|
f533f97d8f | 4 years ago |
|
richie
|
a9ed1f7448 | 4 years ago |
 Dylan.Liu
|
3d393d6ac0 | 4 years ago |
|
Dylan.Liu
|
9219435899 | 4 years ago |
lucian
|
ab081b02e1 | 4 years ago |
36 changed files with 74 additions and 923 deletions
@ -1,17 +0,0 @@
|
||||
package com.fanruan.api.cluster.resource; |
||||
|
||||
import com.fr.io.config.CommonRepoConfig; |
||||
|
||||
/** |
||||
* @author Dylan.Liu |
||||
* @version 10.0 |
||||
* Created by Dylan.Liu on 2021/1/3 |
||||
*/ |
||||
public class BaseCommonRepoConfig extends CommonRepoConfig { |
||||
|
||||
private static final long serialVersionUID = 6713243696930557143L; |
||||
|
||||
public BaseCommonRepoConfig(String identity) { |
||||
super(identity); |
||||
} |
||||
} |
||||
@ -1,25 +0,0 @@
|
||||
package com.fanruan.api.cluster.resource; |
||||
|
||||
import com.fr.decision.fileserver.FineFileServer; |
||||
import com.fr.io.config.RepositoryConfig; |
||||
|
||||
/** |
||||
* 文件服务器Kit. |
||||
* |
||||
* @author Dylan.Liu |
||||
* @version 10.0 |
||||
* Created by Dylan.Liu on 2021/1/12 |
||||
*/ |
||||
public class FineFileServerKit { |
||||
|
||||
/** |
||||
* 获取文件服务器当前配置. |
||||
* |
||||
* @return 文件服务器当前配置 |
||||
* @throws Exception 获取配置失败时异常 |
||||
*/ |
||||
public static <T extends RepositoryConfig> T getRepoConfig() throws Exception { |
||||
return FineFileServer.getInstance().getRepoConfig(); |
||||
} |
||||
|
||||
} |
||||
@ -1,17 +0,0 @@
|
||||
package com.fanruan.api.cluster.resource; |
||||
|
||||
import com.fr.io.config.RepositoryConfig; |
||||
import com.fr.io.context.ResourceModuleContext; |
||||
|
||||
/** |
||||
* @author Dylan.Liu |
||||
* @version 10.0 |
||||
* Created by Dylan.Liu on 2021/1/3 |
||||
*/ |
||||
public class ResourceModuleContextKit { |
||||
|
||||
public static <T extends RepositoryConfig> T getRepoConfig(String hdfs, String srcRepo) { |
||||
return ResourceModuleContext.getRepoConfig(hdfs, srcRepo); |
||||
} |
||||
|
||||
} |
||||
@ -1,15 +0,0 @@
|
||||
package com.fanruan.api.cluster.resource; |
||||
|
||||
import com.fr.workspace.WorkContext; |
||||
import com.fr.workspace.resource.WorkResource; |
||||
|
||||
/** |
||||
* @author Dylan.Liu |
||||
* @version 10.0 |
||||
* Created by Dylan.Liu on 2021/1/3 |
||||
*/ |
||||
public class WorkContextKit { |
||||
public static WorkResource getWorkResource() { |
||||
return WorkContext.getWorkResource(); |
||||
} |
||||
} |
||||
@ -1,17 +0,0 @@
|
||||
package com.fanruan.api.cluster.state; |
||||
|
||||
import com.fr.store.impl.accessor.api.impl.StandAloneStore; |
||||
import com.fr.third.redis.clients.jedis.Jedis; |
||||
|
||||
/** |
||||
* 单机<code>Redis API</code>层. |
||||
* |
||||
* @author Dylan.Liu |
||||
* @version 10.0 |
||||
* Created by Dylan.Liu on 2021/1/18 |
||||
*/ |
||||
public class BaseStandAloneStore extends StandAloneStore { |
||||
public BaseStandAloneStore(Jedis jedis) { |
||||
super(jedis); |
||||
} |
||||
} |
||||
@ -1,20 +1,16 @@
|
||||
package com.fanruan.api.cluster.state; |
||||
|
||||
import com.fr.collections.FineCollections; |
||||
import com.fr.collections.api.FineCollectionClient; |
||||
|
||||
/** |
||||
* @author Dylan.Liu |
||||
* @version 10.0 |
||||
* Created by Dylan.Liu on 2021/1/18 |
||||
* Created by Dylan.Liu on 2020/10/16 |
||||
*/ |
||||
public class FineCollectionsKit { |
||||
|
||||
public FineCollectionsKit() {} |
||||
|
||||
/** |
||||
* 销毁集群集合 |
||||
*/ |
||||
public static void destroy() { |
||||
FineCollections.getInstance().getClient().destroy(); |
||||
public static FineCollectionClient getClient() { |
||||
return FineCollections.getInstance().getClient(); |
||||
} |
||||
} |
||||
|
||||
@ -1,23 +0,0 @@
|
||||
package com.fanruan.api.conf; |
||||
|
||||
import com.fr.config.MarketConfig; |
||||
|
||||
public class MarketConfigKit { |
||||
/** |
||||
* 获取服务器appId |
||||
* |
||||
* @return appId |
||||
*/ |
||||
public static String getAppId() { |
||||
return MarketConfig.getInstance().getCloudOperationMaintenanceId(); |
||||
} |
||||
|
||||
/** |
||||
* 获取已登录帆软市场的用户名 |
||||
* |
||||
* @return userId |
||||
*/ |
||||
public static long getUserId() { |
||||
return MarketConfig.getInstance().getBbsUid(); |
||||
} |
||||
} |
||||
@ -1,55 +0,0 @@
|
||||
package com.fanruan.api.design.ui.component; |
||||
|
||||
import com.fr.design.editlock.EditLockChangeEvent; |
||||
import com.fr.design.editlock.EditLockChangeListener; |
||||
import com.fr.design.editlock.EditLockUtils; |
||||
import com.fr.report.LockItem; |
||||
|
||||
import javax.swing.*; |
||||
|
||||
/** |
||||
* @author Yvan |
||||
* @version 10.0 |
||||
* Created by Yvan on 2021/1/20 |
||||
*/ |
||||
public class UILockButton extends UIButton implements EditLockChangeListener { |
||||
|
||||
/** |
||||
* 锁定状态图标 |
||||
*/ |
||||
private final Icon lockedIcon; |
||||
/** |
||||
* 正常状态图标 |
||||
*/ |
||||
private final Icon normalIcon; |
||||
/** |
||||
* 锁定状态的提示信息 |
||||
*/ |
||||
private final String lockedTooltips; |
||||
/** |
||||
* 正常状态的提示信息 |
||||
*/ |
||||
private final String normalTooltips; |
||||
|
||||
public UILockButton(Icon lockedIcon, Icon normalIcon, String lockedTooltips, String normalTooltips) { |
||||
super(); |
||||
this.lockedIcon = lockedIcon; |
||||
this.normalIcon = normalIcon; |
||||
this.lockedTooltips = lockedTooltips; |
||||
this.normalTooltips = normalTooltips; |
||||
init(); |
||||
} |
||||
|
||||
private void init() { |
||||
boolean locked = EditLockUtils.isLocked(LockItem.CONNECTION); |
||||
this.setIcon(locked ? lockedIcon : normalIcon); |
||||
this.setToolTipText(locked ? lockedTooltips : normalTooltips); |
||||
} |
||||
|
||||
@Override |
||||
public void updateLockedState(EditLockChangeEvent event) { |
||||
this.setIcon(event.isLocked() ? lockedIcon : normalIcon); |
||||
this.setToolTipText(event.isLocked() ? lockedTooltips : normalTooltips); |
||||
this.repaint(); |
||||
} |
||||
} |
||||
@ -1,50 +0,0 @@
|
||||
package com.fanruan.api.design.work.compat; |
||||
|
||||
import com.fanruan.api.design.ui.component.UIButton; |
||||
import com.fanruan.api.design.ui.component.UILockButton; |
||||
import com.fr.base.svg.IconUtils; |
||||
import com.fr.design.editlock.ConnectionLockChangeChecker; |
||||
import com.fr.design.editlock.EditLockUtils; |
||||
import com.fr.report.LockItem; |
||||
|
||||
import java.awt.*; |
||||
import java.awt.event.ActionListener; |
||||
|
||||
/** |
||||
* @author richie |
||||
* @version 10.0 |
||||
* Created by richie on 2021/3/18 |
||||
* 用于兼容没有数据连接lock的版本 |
||||
*/ |
||||
public class ConnectionLockHelper { |
||||
|
||||
public static UIButton generateLockButton(Dimension buttonSize, ActionListener listener) { |
||||
UILockButton editButton = new UILockButton( |
||||
EditLockUtils.CONNECTION_LOCKED_ICON, |
||||
IconUtils.readIcon("/com/fr/design/images/m_web/connection"), |
||||
EditLockUtils.CONNECTION_LOCKED_TOOLTIPS, |
||||
null |
||||
); |
||||
editButton.setPreferredSize(buttonSize); |
||||
editButton.addActionListener(listener); |
||||
ConnectionLockChangeChecker.getInstance().addEditLockChangeListener(editButton); |
||||
return editButton; |
||||
} |
||||
|
||||
public static boolean doLock(Component component) { |
||||
// 尝试为数据连接加锁
|
||||
boolean actionLock = EditLockUtils.lock(LockItem.CONNECTION); |
||||
if (!actionLock) { |
||||
// 锁定失败，代表已经被其他用户锁定，跳出弹窗提示
|
||||
EditLockUtils.showLockMessage(component); |
||||
return true; |
||||
} |
||||
return false; |
||||
} |
||||
|
||||
public static void unlock() { |
||||
// 关闭定义数据连接页面，为其解锁
|
||||
EditLockUtils.unlock(LockItem.CONNECTION); |
||||
} |
||||
|
||||
} |
||||
@ -1,122 +0,0 @@
|
||||
package com.fanruan.api.design.work.component; |
||||
|
||||
import com.fanruan.api.design.ui.component.UIButton; |
||||
import com.fanruan.api.design.ui.component.UIComboBox; |
||||
import com.fanruan.api.util.IOKit; |
||||
import com.fanruan.api.util.StringKit; |
||||
|
||||
import javax.swing.*; |
||||
import java.awt.*; |
||||
import java.awt.event.ActionEvent; |
||||
import java.awt.event.ActionListener; |
||||
|
||||
/** |
||||
* @author richie |
||||
* @version 10.0 |
||||
* Created by richie on 2021/3/18 |
||||
*/ |
||||
public abstract class ItemEditableComboBoxPanel extends JPanel { |
||||
|
||||
private static final long serialVersionUID = 1L; |
||||
|
||||
protected static final Object EMPTY = new Object() { |
||||
public String toString() { |
||||
return StringKit.EMPTY; |
||||
} |
||||
}; |
||||
|
||||
protected UIComboBox<?> itemComboBox; |
||||
protected UIButton editButton; |
||||
protected UIButton refreshButton; |
||||
|
||||
public ItemEditableComboBoxPanel() { |
||||
super(); |
||||
|
||||
initComponents(); |
||||
} |
||||
|
||||
protected void initComponents() { |
||||
this.setLayout(new BorderLayout(4, 4)); |
||||
Dimension buttonSize = new Dimension(26, 20); |
||||
itemComboBox = new UIComboBox<>(); |
||||
itemComboBox.setEnabled(true); |
||||
this.add(itemComboBox, BorderLayout.CENTER); |
||||
refreshButton = new UIButton(IOKit.readIcon("/com/fr/design/images/control/refresh.png")); |
||||
JPanel jPanel = new JPanel(new GridLayout(0, 2, 4, 4)); |
||||
editButton = initEditButton(editButton, buttonSize); |
||||
jPanel.add(editButton); |
||||
jPanel.add(refreshButton); |
||||
this.add(jPanel, BorderLayout.EAST); |
||||
refreshButton.setPreferredSize(buttonSize); |
||||
refreshButton.addActionListener(new ActionListener() { |
||||
public void actionPerformed(ActionEvent e) { |
||||
refreshItems(); |
||||
} |
||||
}); |
||||
} |
||||
|
||||
protected UIButton initEditButton(UIButton editButton, Dimension buttonSize) { |
||||
editButton = new UIButton(IOKit.readIcon("/com/fr/design/images/control/control-center2.png")); |
||||
editButton.setPreferredSize(buttonSize); |
||||
editButton.addActionListener(evt -> editItems()); |
||||
return editButton; |
||||
} |
||||
|
||||
|
||||
/** |
||||
* 给itemComboBox添加ActionListener |
||||
*/ |
||||
public void addComboBoxActionListener(ActionListener l) { |
||||
itemComboBox.addActionListener(l); |
||||
} |
||||
|
||||
protected void refreshItems() { |
||||
// 记录原来选中的Item,重新加载后需要再次选中
|
||||
Object lastSelectedItem = itemComboBox.getSelectedItem(); |
||||
|
||||
DefaultComboBoxModel<Object> model = ((DefaultComboBoxModel<Object>) itemComboBox.getModel()); |
||||
model.removeAllElements(); |
||||
|
||||
// 先加EMPTY,再加items
|
||||
model.addElement(EMPTY); |
||||
|
||||
java.util.Iterator<String> itemIt = items(); |
||||
while (itemIt.hasNext()) { |
||||
model.addElement(itemIt.next()); |
||||
} |
||||
|
||||
// 再次选中之前选中的Item
|
||||
int idx = model.getIndexOf(lastSelectedItem); |
||||
if (idx < 0) { |
||||
idx = 0; |
||||
} |
||||
itemComboBox.setSelectedIndex(idx); |
||||
} |
||||
|
||||
/* |
||||
* 得到其中的itemComboBox所选中的Item |
||||
*/ |
||||
public String getSelectedItem() { |
||||
Object selected = itemComboBox.getSelectedItem(); |
||||
|
||||
return selected instanceof String ? (String) selected : null; |
||||
} |
||||
|
||||
/* |
||||
* 选中name项 |
||||
*/ |
||||
public void setSelectedItem(String name) { |
||||
DefaultComboBoxModel model = ((DefaultComboBoxModel) itemComboBox.getModel()); |
||||
model.setSelectedItem(name); |
||||
} |
||||
|
||||
/* |
||||
* 刷新ComboBox.items |
||||
*/ |
||||
protected abstract java.util.Iterator<String> items(); |
||||
|
||||
/* |
||||
* 弹出对话框编辑Items |
||||
*/ |
||||
protected abstract void editItems(); |
||||
} |
||||
@ -1,24 +0,0 @@
|
||||
package com.fanruan.api.report; |
||||
|
||||
import com.fr.decision.webservice.v10.entry.ReportEntryService; |
||||
|
||||
/** |
||||
* @author Zed |
||||
* @version 10.0 |
||||
* Created by Zed on 2020/12/14 |
||||
* 在平台挂查看FR模板的工具类 |
||||
*/ |
||||
public class ReportEntryKit { |
||||
|
||||
/** |
||||
* 获取FR模板树 |
||||
* |
||||
* @param currentUserId 当前用户id |
||||
* @param keyword keyword |
||||
* @return 模板树 |
||||
* @throws Exception 异常 |
||||
*/ |
||||
public static Object getReportTemplateTree(String currentUserId, String keyword) throws Exception { |
||||
return ReportEntryService.getInstance().getReportTemplateTree(currentUserId, keyword); |
||||
} |
||||
} |
||||
@ -1,29 +0,0 @@
|
||||
package com.fanruan.api.conf; |
||||
|
||||
import com.fr.config.Configuration; |
||||
import org.junit.Assert; |
||||
import org.junit.Test; |
||||
|
||||
import java.lang.reflect.Method; |
||||
import java.util.Map; |
||||
|
||||
/** |
||||
* @author Zed |
||||
* @version 10.0 |
||||
* Created by Zed on 2020/12/15 |
||||
*/ |
||||
public class ConfigurationKitTest { |
||||
|
||||
@Test |
||||
public void update() throws Exception { |
||||
|
||||
Class<?> classBook = Class.forName("com.fanruan.api.conf.ConfigurationKit"); |
||||
Assert.assertNotNull(classBook); |
||||
|
||||
Method method1 = classBook.getDeclaredMethod("getConfig", Configuration.class); |
||||
Assert.assertNotNull(method1); |
||||
|
||||
Method method2 = classBook.getDeclaredMethod("setConfig", Configuration.class, Map.class); |
||||
Assert.assertNotNull(method2); |
||||
} |
||||
} |
||||
@ -1,24 +0,0 @@
|
||||
package com.fanruan.api.report; |
||||
|
||||
import org.junit.Assert; |
||||
import org.junit.Test; |
||||
|
||||
import java.lang.reflect.Method; |
||||
|
||||
/** |
||||
* @author Zed |
||||
* @version 10.0 |
||||
* Created by Zed on 2020/12/15 |
||||
*/ |
||||
public class ReportEntryKitTest { |
||||
|
||||
@Test |
||||
public void getReportTemplateTree() throws Exception { |
||||
|
||||
Class<?> classBook = Class.forName("com.fanruan.api.report.ReportEntryKit"); |
||||
Assert.assertNotNull(classBook); |
||||
|
||||
Method method1 = classBook.getDeclaredMethod("getReportTemplateTree", String.class, String.class); |
||||
Assert.assertNotNull(method1); |
||||
} |
||||
} |
||||
@ -1,25 +1,18 @@
|
||||
package com.fanruan.api.security; |
||||
|
||||
import java.util.*; |
||||
|
||||
import com.fr.stable.CommonCodeUtils; |
||||
import org.junit.Assert; |
||||
import org.junit.Test; |
||||
|
||||
public class SecurityKitTest { |
||||
|
||||
@Test |
||||
public void passwordDecode() { |
||||
public void passwordDecode(){ |
||||
Assert.assertEquals(SecurityKit.passwordDecode("1234"), CommonCodeUtils.passwordDecode("1234")); |
||||
} |
||||
|
||||
@Test |
||||
public void passwordEncode() { |
||||
public void passwordEncode(){ |
||||
Assert.assertEquals(SecurityKit.passwordEncode("1234"), CommonCodeUtils.passwordEncode("1234")); |
||||
} |
||||
|
||||
@Test |
||||
public void aes() { |
||||
String seed = SecurityKit.createSeed(); |
||||
String text = SecurityKit.aesEncrypt("zed", seed); |
||||
Assert.assertEquals("zed", SecurityKit.aesDecrypt(text, seed)); |
||||
} |
||||
} |
||||
|
||||
Loading…
Reference in new issue