From 807e2c7a2ca8283ba6d6f764c83320ad5e023349 Mon Sep 17 00:00:00 2001
From: kimi <kimi42345@gmail.com>
Date: 星期四, 19 三月 2020 09:01:04 +0800
Subject: [PATCH] fix 放开红点的权限
---
src/main/java/com/highdatas/mdm/controller/AssembleController.java | 83 +++++++++++++++++++++++++++++++++--------
1 files changed, 67 insertions(+), 16 deletions(-)
diff --git a/src/main/java/com/highdatas/mdm/controller/AssembleController.java b/src/main/java/com/highdatas/mdm/controller/AssembleController.java
index 32a0729..94cc314 100644
--- a/src/main/java/com/highdatas/mdm/controller/AssembleController.java
+++ b/src/main/java/com/highdatas/mdm/controller/AssembleController.java
@@ -7,10 +7,8 @@
import com.baomidou.mybatisplus.mapper.Wrapper;
import com.baomidou.mybatisplus.plugins.Page;
import com.highdatas.mdm.entity.*;
-import com.highdatas.mdm.pojo.CodeMsg;
-import com.highdatas.mdm.pojo.Result;
-import com.highdatas.mdm.pojo.SysAssembleStatus;
-import com.highdatas.mdm.pojo.SysAssembleUpdateType;
+import com.highdatas.mdm.job.JobClient;
+import com.highdatas.mdm.pojo.*;
import com.highdatas.mdm.pojo.kettle.BigDataDataSourceInfo;
import com.highdatas.mdm.pojo.kettle.DataSourceInfo;
import com.highdatas.mdm.pojo.kettle.UnBigDataDataSourceInfo;
@@ -60,13 +58,42 @@
BigDataDataSourceInfo bigDataDataSourceInfo;
@Autowired
UnBigDataDataSourceInfo unBigDataDataSourceInfo;
+ @Autowired
+ JobClient client;
@RequestMapping(value = "run/{id}", method = RequestMethod.GET)
- public Result delete(@PathVariable String id, HttpServletRequest request) {
- Result run = assembleService.run(id, request.getSession());
- return run;
+ public Result trigger(@PathVariable String id, HttpServletRequest request) {
+ SysAssemble assemble = assembleService.selectById(id);
+ if (assemble == null) {
+ return Result.error(CodeMsg.ERROR_PARAMS_NOT_MATHED);
+ }
+ boolean trigger = client.trigger(assemble);
+ if (trigger) {
+ return Result.success(null);
+ }else {
+ return Result.error(CodeMsg.OPERATR_ERROR);
+ }
}
+ @RequestMapping(value = "saveJobGroup", method = RequestMethod.GET)
+ public Result saveJobGroup(HttpServletRequest request) {
+ boolean b = client.saveJobGroup();
+ if (b) {
+ return Result.success(null);
+ }else {
+ return Result.error(CodeMsg.OPERATR_ERROR);
+ }
+ }
+
+ @RequestMapping(value = "deleteJobGroup", method = RequestMethod.GET)
+ public Result deleteJobGroup(HttpServletRequest request) {
+ boolean b = client.saveJobGroup();
+ if (b) {
+ return Result.success(null);
+ }else {
+ return Result.error(CodeMsg.OPERATR_ERROR);
+ }
+ }
@RequestMapping(value = "new", method = RequestMethod.GET)
@@ -98,7 +125,7 @@
@RequestMapping(value = "/saveCommon/{id}", method = RequestMethod.GET)
- public Result add(@PathVariable String id, @RequestParam String menuId, @RequestParam SysAssembleUpdateType updateType, @RequestParam Boolean bigData, @RequestParam String updateFields, HttpServletRequest request) {
+ public Result saveCommon(@PathVariable String id, @RequestParam String menuId, @RequestParam SysAssembleUpdateType updateType, @RequestParam Boolean bigData, @RequestParam String updateFields, HttpServletRequest request) {
SysAssemble assemble = assembleService.selectById(id);
if (assemble == null) {
return Result.error(CodeMsg.ERROR_PARAMS_NOT_MATHED);
@@ -117,7 +144,7 @@
@Transactional(rollbackFor=Exception.class)
@RequestMapping(value = "delete/{id}", method = RequestMethod.GET)
- public Result add(@PathVariable String id) {
+ public Result delete(@PathVariable String id) throws Exception {
SysAssemble assemble = assembleService.selectById(id);
if (assemble == null) {
return Result.error(CodeMsg.ERROR_PARAMS_NOT_MATHED);
@@ -156,7 +183,14 @@
apiService.delete(new EntityWrapper<SysAssembleApi>().eq(Constant.PARENT_ID, id));
//delete param
paramsService.delete(new EntityWrapper<SysAssembleParams>().eq(Constant.PARENT_ID, id));
-
+ boolean b = true;
+ String jobId = assemble.getJobId();
+ if (!StringUtils.isEmpty(jobId)) {
+ b = client.deleteJob(jobId);
+ }
+ if (!b) {
+ throw new Exception("xxljob 鍒犻櫎澶辫触");
+ }
boolean deleted = assemble.deleteById();
if (deleted) {
return Result.success(assemble);
@@ -165,15 +199,20 @@
}
}
-
-
- @RequestMapping(value = "updateJob/{id}", method = RequestMethod.GET)
- public Result updateStatus(@RequestParam String jobId,@RequestParam String id) {
+ @RequestMapping(value = "saveCheckType/{id}", method = RequestMethod.GET)
+ public Result saveUpdateType(@RequestParam SysAssembleCheckType type, @PathVariable String id,HttpServletRequest request) {
SysAssemble assemble = assembleService.selectById(id);
if (assemble == null) {
return Result.error(CodeMsg.ERROR_PARAMS_NOT_MATHED);
}
- assemble.setJobId(jobId);
+ assemble.setCheckType(type);
+ if (type.equals(SysAssembleCheckType.partSuccessAdd)) {
+ String fields = request.getParameter("fields");
+ if (StringUtils.isEmpty(fields)) {
+ return Result.error(CodeMsg.ERROR_PARAMS_NOT_MATHED);
+ }
+ assemble.setCheckFields(fields);
+ }
boolean updated = assemble.updateById();
if (updated) {
return Result.success(assemble);
@@ -245,8 +284,9 @@
return Result.success(result);
}
+ @Transactional(rollbackFor=Exception.class)
@RequestMapping(value = "saveCorn/{id}", method = RequestMethod.GET)
- public Result add(@RequestParam String cron,@PathVariable String id) {
+ public Result add(@RequestParam String cron,@PathVariable String id) throws Exception {
SysAssemble assemble = assembleService.selectById(id);
if (assemble == null) {
return Result.error(CodeMsg.ERROR_PARAMS_NOT_MATHED);
@@ -261,6 +301,17 @@
return Result.error(new CodeMsg(6007, "corn 琛ㄨ揪寮忔洿鏂板�奸敊璇�"));
}
assemble.setStatus(SysAssembleStatus.working);
+ String jobId = assemble.getJobId();
+ boolean xxljobStatus = true;
+ if (StringUtils.isEmpty(jobId)) {
+ xxljobStatus = client.addJob(assemble);
+ }
+ else {
+ xxljobStatus = client.updateJob(assemble);
+ }
+ if (!xxljobStatus) {
+ throw new Exception("add or update xxxljob fail");
+ }
boolean updated = assemble.updateById();
if (updated) {
--
Gitblit v1.8.0