Skip to content

Commit 83b64e4

Browse files
committed
fix
1 parent a3d5ac6 commit 83b64e4

File tree

16 files changed

+88
-136
lines changed

16 files changed

+88
-136
lines changed

README.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -211,7 +211,7 @@ public interface StreamAppContext {
211211

212212
## extension
213213

214-
cn.think.in.java.open.exp.client.TenantCallback
214+
cn.think.in.java.open.exp.client.PluginFilter
215215

216216
```java
217217
public interface TenantCallback {

README_cn.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -204,7 +204,7 @@ public interface StreamAppContext {
204204

205205
## 扩展
206206

207-
cn.think.in.java.open.exp.client.TenantCallback
207+
cn.think.in.java.open.exp.client.PluginFilter
208208

209209
```java
210210
public interface TenantCallback {

example/example-springboot2/src/main/java/cn/think/in/java/open/exp/adapter/springboot2/BaseController.java

Lines changed: 5 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@
44
import cn.think.in.java.open.exp.client.ExpAppContext;
55
import cn.think.in.java.open.exp.client.ExpAppContextSpiFactory;
66
import cn.think.in.java.open.exp.client.Plugin;
7-
import cn.think.in.java.open.exp.client.TenantCallback;
7+
import cn.think.in.java.open.exp.client.PluginFilter;
88
import lombok.extern.slf4j.Slf4j;
99
import org.springframework.web.bind.annotation.RequestMapping;
1010
import org.springframework.web.bind.annotation.RestController;
@@ -27,25 +27,19 @@ public class BaseController {
2727
Map<String, Integer> sortMap = new HashMap<>();
2828
Map<String, String> pluginIdTenantIdMap = new HashMap<>();
2929

30-
TenantCallback callback;
30+
PluginFilter callback;
3131

3232
public BaseController() {
3333
sortMap.put("example-plugin1_1.0.0", 1);
3434
sortMap.put("example-plugin2_2.0.0", 2);
3535
pluginIdTenantIdMap.put("example-plugin2_2.0.0", "12345");
3636
pluginIdTenantIdMap.put("example-plugin1_1.0.0", "12345");
3737

38-
callback = new TenantCallback() {
39-
@Override
40-
public int getSort(String pluginId) {
41-
// 获取这个插件的排序
42-
return sortMap.get(pluginId);
43-
}
38+
callback = new PluginFilter() {
4439

4540
@Override
46-
public boolean filter(String pluginId) {
47-
// 判断当前租户是不是这个匹配这个插件
48-
return context.get().equals(pluginIdTenantIdMap.get(pluginId));
41+
public <T> List<FModel<T>> filter(List<FModel<T>> list) {
42+
return list;
4943
}
5044
};
5145

example/simple-java-app/src/main/java/cn/think/in/java/simple/app/example/SimpleJavaAppMain.java

Lines changed: 4 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22

33
import cn.think.in.java.open.exp.adapter.springboot2.example.UserService;
44
import cn.think.in.java.open.exp.client.ExpAppContext;
5-
import cn.think.in.java.open.exp.client.TenantCallback;
5+
import cn.think.in.java.open.exp.client.PluginFilter;
66
import cn.think.in.java.open.exp.core.impl.Bootstrap;
77
import lombok.extern.slf4j.Slf4j;
88

@@ -13,17 +13,11 @@
1313
@Slf4j
1414
public class SimpleJavaAppMain {
1515
static ExpAppContext expAppContext;
16-
static TenantCallback callback = new TenantCallback() {
17-
@Override
18-
public int getSort(String pluginId) {
19-
int sort = new Random().nextInt(10);
20-
log.info(pluginId + " >>>>>>> " + sort);
21-
return sort;
22-
}
16+
static PluginFilter callback = new PluginFilter() {
2317

2418
@Override
25-
public boolean filter(String pluginId) {
26-
return true;
19+
public <T> List<FModel<T>> filter(List<FModel<T>> list) {
20+
return list;
2721
}
2822
};
2923

open-exp-code/auto-install-exp-maven-plugin/src/main/java/cn/think/in/java/auto/install/maven/plugin/UploadMojo.java

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -57,18 +57,16 @@ public void execute() throws MojoExecutionException {
5757
} catch (MalformedURLException e) {
5858
throw new RuntimeException(e);
5959
}
60-
URL resource = urlClassLoader.findResource("pluginInfo.properties");
61-
URL resource2 = urlClassLoader.findResource("eep.config");
60+
URL resource = urlClassLoader.findResource("pluginMeta.properties");
6261
Properties properties = new Properties();
6362
try {
6463
properties.load(resource.openStream());
65-
properties.load(resource2.openStream());
6664
} catch (IOException e) {
6765
throw new RuntimeException(e);
6866
}
6967

70-
Object o = properties.get("esign.plugin.code");
71-
Object o2 = properties.get("esign.plugin.version");
68+
Object o = properties.get("exp.plugin.code");
69+
Object o2 = properties.get("exp.plugin.version");
7270

7371
String id = o + "_" + o2;
7472

open-exp-code/open-exp-client-api/src/main/java/cn/think/in/java/open/exp/client/ExpAppContext.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@
77
/**
88
* @author cxs
99
*/
10-
public interface ExpAppContext extends StreamAppContext, TenantService {
10+
public interface ExpAppContext extends StreamAppContext, PluginFilterService {
1111

1212
/**
1313
* 获取当前所有的插件 id
Lines changed: 33 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,33 @@
1+
package cn.think.in.java.open.exp.client;
2+
3+
import lombok.Data;
4+
5+
import java.util.List;
6+
7+
/**
8+
* @Author cxs
9+
**/
10+
public interface PluginFilter {
11+
12+
PluginFilter MOCK = new PluginFilterMock();
13+
14+
<T> List<FModel<T>> filter(List<FModel<T>> list);
15+
16+
@Data
17+
class FModel<T> {
18+
T t;
19+
String pluginId;
20+
21+
public FModel(T t, String pluginId) {
22+
this.t = t;
23+
this.pluginId = pluginId;
24+
}
25+
}
26+
27+
class PluginFilterMock implements PluginFilter {
28+
@Override
29+
public <T> List<FModel<T>> filter(List<FModel<T>> list) {
30+
return list;
31+
}
32+
}
33+
}
Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,13 @@
1+
package cn.think.in.java.open.exp.client;
2+
3+
import java.util.List;
4+
5+
/**
6+
* @Author cxs
7+
**/
8+
public interface PluginFilterService {
9+
10+
<P> List<P> get(String extCode, PluginFilter filter);
11+
12+
<P> List<P> get(Class<P> pClass, PluginFilter callback);
13+
}

open-exp-code/open-exp-client-api/src/main/java/cn/think/in/java/open/exp/client/TenantCallback.java

Lines changed: 0 additions & 37 deletions
This file was deleted.

open-exp-code/open-exp-client-api/src/main/java/cn/think/in/java/open/exp/client/TenantService.java

Lines changed: 0 additions & 13 deletions
This file was deleted.

0 commit comments

Comments
 (0)