From c8aee7b9bfd79cfd741d7e5692520f4f51a31a86 Mon Sep 17 00:00:00 2001
From: kimi <kimi42345@gmail.com>
Date: 星期一, 18 五月 2020 18:30:01 +0800
Subject: [PATCH] bak 修改 获取版本数据前
---
src/main/java/com/highdatas/mdm/controller/AssembleController.java | 35 +++++++++++++++++++++++++++--------
1 files changed, 27 insertions(+), 8 deletions(-)
diff --git a/src/main/java/com/highdatas/mdm/controller/AssembleController.java b/src/main/java/com/highdatas/mdm/controller/AssembleController.java
index 59c9750..f961222 100644
--- a/src/main/java/com/highdatas/mdm/controller/AssembleController.java
+++ b/src/main/java/com/highdatas/mdm/controller/AssembleController.java
@@ -75,9 +75,28 @@
}
}
+ @RequestMapping(value = "runTest/{id}", method = RequestMethod.GET)
+ public Result runTest(@PathVariable String id, HttpServletRequest request) {
+ SysAssemble assemble = assembleService.selectById(id);
+ if (assemble == null) {
+ return Result.error(CodeMsg.ERROR_PARAMS_NOT_MATHED);
+ }
+ return assembleService.run(id);
+ }
+
@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 = "saveAutoJobGroup", method = RequestMethod.GET)
+ public Result saveAutoJobGroup(HttpServletRequest request) {
+ boolean b = client.saveAutoJobGroup();
if (b) {
return Result.success(null);
}else {
@@ -99,7 +118,7 @@
@RequestMapping(value = "new", method = RequestMethod.GET)
public Result delete(HttpServletRequest request) {
SysAssemble assemble = new SysAssemble();
- TUser user = (TUser) request.getSession().getAttribute(Constant.USER);
+ TUser user = DbUtils.getUser(request);
assemble.setStatus(SysAssembleStatus.edit).setCreateTime(new Date()).setUserId(user.getUserId()).setUpdateType(SysAssembleUpdateType.All);
boolean insert = assemble.setId(DbUtils.getUUID()).setEmptyData(true).insert();
if (insert) {
@@ -133,7 +152,7 @@
assemble.setUpdateType(updateType).setUpdateFields(updateFields);
assemble.setEmptyData(false);
assemble.setBigdata(Boolean.valueOf(bigData));
- TUser user = (TUser) request.getSession().getAttribute(Constant.USER);
+ TUser user = DbUtils.getUser(request);
boolean insert = assemble.setUserId(user.getUserId()).setMenuId(menuId).setUpdateTime(new Date()).updateById();
if (insert) {
@@ -189,9 +208,7 @@
if (!StringUtils.isEmpty(jobId)) {
b = client.deleteJob(jobId);
}
- if (!b) {
- throw new Exception("xxljob 鍒犻櫎澶辫触");
- }
+
boolean deleted = assemble.deleteById();
if (deleted) {
return Result.success(assemble);
@@ -375,7 +392,7 @@
}else {
page = new Page(pageNo, 15);
}
-
+ wrapper.orderBy("update_time desc, create_time desc");
Page<SysAssemble> resultPage = assembleService.selectPage(page,wrapper);
List<SysAssemble> records = resultPage.getRecords();
@@ -386,8 +403,10 @@
JSONObject o = (JSONObject) JSON.toJSON(record);
SysAssembleParams sysAssembleParams = paramsService.selectOne(eq);
- String val = sysAssembleParams.getVal();
- o.fluentPut("nextTime", val);
+ if(sysAssembleParams != null) {
+ String val = sysAssembleParams.getVal();
+ o.fluentPut("nextTime", val);
+ }
String realMenuId = record.getMenuId();
if (!StringUtils.isEmpty(realMenuId)) {
--
Gitblit v1.8.0