wangli/riven
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(REQ-3193): 引入加解密包

Browse Source
This commit is contained in:
周敏 2024-11-11 20:56:15 +08:00
parent 4919d04f4d
commit 63f39a6dc8
2 changed files with 18 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
riven-server/pom.xml
View File

@ -120,6 +120,15 @@
<groupId>cn.axzo.maokai</groupId> <groupId>cn.axzo.maokai</groupId>
<artifactId>maokai-api</artifactId> <artifactId>maokai-api</artifactId>
</dependency> </dependency>
<dependency>
<groupId>cn.axzo.trade</groupId>
<artifactId>trade-data-security-core</artifactId>
</dependency>
<dependency>
<groupId>cn.axzo.trade</groupId>
<artifactId>trade-data-security-spring-boot-starter</artifactId>
</dependency>
</dependencies> </dependencies>
<build> <build>

9
riven-server/src/main/java/cn/axzo/riven/controller/PrivateController.java
View File

@ -2,6 +2,7 @@ package cn.axzo.riven.controller;
import cn.axzo.framework.domain.web.result.ApiResult; import cn.axzo.framework.domain.web.result.ApiResult;
import cn.axzo.framework.jackson.utility.JSON; import cn.axzo.framework.jackson.utility.JSON;
import cn.axzo.riven.third.job.RepairThirdPersonEncryptJob;
import cn.axzo.riven.third.job.TaiZhouProjectPersonIncJob; import cn.axzo.riven.third.job.TaiZhouProjectPersonIncJob;
import cn.axzo.riven.third.job.TaiZhouProjectPersonJob; import cn.axzo.riven.third.job.TaiZhouProjectPersonJob;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
@ -27,6 +28,7 @@ public class PrivateController {
private final TaiZhouProjectPersonJob taiZhouProjectPersonJob; private final TaiZhouProjectPersonJob taiZhouProjectPersonJob;
private final TaiZhouProjectPersonIncJob taiZhouProjectPersonIncJob; private final TaiZhouProjectPersonIncJob taiZhouProjectPersonIncJob;
private final RepairThirdPersonEncryptJob repairThirdPersonEncryptJob;
@PostMapping("/job/run") @PostMapping("/job/run")
public ApiResult reconsumeMessage(@RequestBody RunJobParam param) throws Exception { public ApiResult reconsumeMessage(@RequestBody RunJobParam param) throws Exception {
@ -45,6 +47,13 @@ public class PrivateController {
throw new RuntimeException(e); throw new RuntimeException(e);
} }
}) })
.put("repairThirdPersonEncryptJob", p -> {
try {
return repairThirdPersonEncryptJob.execute(p.getParam() == null ? null : p.getParam().toString());
} catch (Exception e) {
throw new RuntimeException(e);
}
})
.build(); .build();
Optional.ofNullable(jobRunners.get(param.getJobName())).ifPresent(c -> c.apply(param)); Optional.ofNullable(jobRunners.get(param.getJobName())).ifPresent(c -> c.apply(param));
return ApiResult.ok("job ran. -> " + JSON.toJSONString(param)); return ApiResult.ok("job ran. -> " + JSON.toJSONString(param));