1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
package cn.ibizlab.util.job;
import cn.ibizlab.util.client.IBZUAAFeignClient;
import cn.ibizlab.util.client.IBZLiteFeignClient;
import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.JSONArray;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.io.IOUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.context.annotation.Lazy;
import org.springframework.stereotype.Component;
import org.springframework.util.DigestUtils;
import java.io.InputStream;
import java.util.*;
/**
* 权限：向uaa同步当前系统菜单、权限资源任务类
*/
@Slf4j
@Component
@ConditionalOnProperty( name = "ibiz.enablePermissionValid", havingValue = "true")
public class PermissionSyncJob implements ApplicationRunner {
@Autowired
@Lazy
private IBZUAAFeignClient client;
@Value("${ibiz.systemid:DemoSys}")
private String systemId;
@Value("${ibiz.systemname:DemoSys}")
private String systemName;
@Autowired
@Lazy
private cn.ibizlab.util.client.IBZWFFeignClient client2;
@Autowired
@Lazy
IBZLiteFeignClient liteFeignClient;
@Override
public void run(ApplicationArguments args) {
try {
Thread.sleep(10000);
InputStream permission = this.getClass().getResourceAsStream("/permission/systemResource.json"); //获取当前系统所有实体资源能力
String permissionResult = IOUtils.toString(permission,"UTF-8");
JSONObject system= new JSONObject();
system.put("pssystemid",systemId);
system.put("pssystemname",systemName);
system.put("sysstructure",JSONObject.parseObject(permissionResult));
system.put("md5check",DigestUtils.md5DigestAsHex(permissionResult.getBytes()));
if(client.syncSysAuthority(system)) {
log.info("向[UAA]同步系统资源成功");
}else{
log.error("向[UAA]同步系统资源失败");
}
}
catch (Exception ex) {
log.error(String.format("向[UAA]同步系统资源失败，请检查[UAA]服务是否正常! [%s]",ex));
}
try {
InputStream sysModel = this.getClass().getResourceAsStream("/sysmodel/DemoSys.json"); //获取当前系统所有实体资源能力
String strSysModel = IOUtils.toString(sysModel,"UTF-8");
if(liteFeignClient.syncSysModel(JSONObject.parseObject(strSysModel))) {
log.info("向[lite]同步系统模型成功");
}else{
log.error("向[lite]同步系统模型失败");
}
}
catch (Exception ex) {
log.error(String.format("向[lite]同步系统模型失败，请检查[lite]服务是否正常! [%s]",ex));
}
try{
List<Map<String,Object>> bpmnfiles = new ArrayList();
bpmnfiles.add(new HashMap<String,Object>(){{put("LPv1.bpmn",IOUtils.toString(this.getClass().getResourceAsStream("/workflow/LPv1.bpmn"),"UTF-8"));}});
bpmnfiles.add(new HashMap<String,Object>(){{put("ODSPMVv1.bpmn",IOUtils.toString(this.getClass().getResourceAsStream("/workflow/ODSPMVv1.bpmn"),"UTF-8"));}});
bpmnfiles.add(new HashMap<String,Object>(){{put("ODSPMVv2.bpmn",IOUtils.toString(this.getClass().getResourceAsStream("/workflow/ODSPMVv2.bpmn"),"UTF-8"));}});
bpmnfiles.add(new HashMap<String,Object>(){{put("ACTv1.bpmn",IOUtils.toString(this.getClass().getResourceAsStream("/workflow/ACTv1.bpmn"),"UTF-8"));}});
bpmnfiles.add(new HashMap<String,Object>(){{put("SNv1.bpmn",IOUtils.toString(this.getClass().getResourceAsStream("/workflow/SNv1.bpmn"),"UTF-8"));}});
bpmnfiles.add(new HashMap<String,Object>(){{put("MNv1.bpmn",IOUtils.toString(this.getClass().getResourceAsStream("/workflow/MNv1.bpmn"),"UTF-8"));}});
bpmnfiles.add(new HashMap<String,Object>(){{put("ODSPv1.bpmn",IOUtils.toString(this.getClass().getResourceAsStream("/workflow/ODSPv1.bpmn"),"UTF-8"));}});
bpmnfiles.add(new HashMap<String,Object>(){{put("ODSPMMv1.bpmn",IOUtils.toString(this.getClass().getResourceAsStream("/workflow/ODSPMMv1.bpmn"),"UTF-8"));}});
bpmnfiles.add(new HashMap<String,Object>(){{put("ODSPMMv2.bpmn",IOUtils.toString(this.getClass().getResourceAsStream("/workflow/ODSPMMv2.bpmn"),"UTF-8"));}});
if(client2.deployBpmnFile(bpmnfiles)) {
log.info("部署流程成功");
}else{
log.error("部署流程失败");
}
}catch(Exception ex) {
log.error(String.format("部署流程失败，请检查[WF]服务是否正常! [%s]",ex));
}
}
}