I3_YF_SEAT
/
impp-core
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

文件资源 批量删除

Browse Source 
时间表达式 批量删除
定时任务 批量删除，启用，禁用
yun-zuoyi
yunhao.wang 7 years ago
parent 3ab42503d1
commit 1b8178fe82
12 changed files with 216 additions and 30 deletions
Show Stats Download Patch File Download Diff File

6
modules/i3plus-core-api/src/main/java/cn/estsh/i3plus/core/api/iservice/busi/ISysFileService.java
Unescape Escape View File

@ -53,4 +53,10 @@ public interface ISysFileService {
* @return
*/
ListPager querySysFileByPager(SysFile sysFile, Pager pager);
/**
* 批量删除文件资源
* @param ids
*/
void deleteSysFileByIds(String[] ids);
}

6
modules/i3plus-core-api/src/main/java/cn/estsh/i3plus/core/api/iservice/busi/ITaskTimeExpressionService.java
Unescape Escape View File

@ -57,4 +57,10 @@ public interface ITaskTimeExpressionService {
* @return
*/
ListPager queryTaskTimeExpressionByPager(TaskTimeExpression taskTimeExpression, Pager pager);
/**
* 任务表达式批量删除
* @param ids
*/
void deleteTaskTimeExpressionByIds(String[] ids);
}

16
modules/i3plus-core-api/src/main/java/cn/estsh/i3plus/core/api/iservice/busi/ITaskTimeService.java
Unescape Escape View File

@ -4,12 +4,11 @@ import cn.estsh.i3plus.pojo.base.bean.ListPager;
import cn.estsh.i3plus.pojo.base.common.Pager;
import cn.estsh.i3plus.pojo.platform.bean.SessionUser;
import cn.estsh.i3plus.pojo.platform.bean.TaskTime;
import org.springframework.data.domain.Page;
import java.util.List;
/**
* @Description : 定时任务业务接口
* @Description : 定时任务业务接口
* @Reference :
* @Author : wei.peng
* @Date : 2018-10-22 16:58:43.968
@ -64,4 +63,17 @@ public interface ITaskTimeService {
* @return
*/
ListPager queryTaskTimeByPager(TaskTime taskTime, Pager pager);
/**
* 根据id批量删除定时任务
* @param ids
*/
void deleteTaskTimeByIds(String[] ids);
/**
* 批量修改定时任务状态
* @param ids
*
*/
void updateTaskTimeStatusByIds(String[] ids, Integer status);
}

25
modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/controller/busi/SysFileController.java
Unescape Escape View File

@ -4,12 +4,14 @@ import cn.estsh.i3plus.core.api.iservice.busi.ISysFileService;
import cn.estsh.i3plus.platform.common.convert.ConvertBean;
import cn.estsh.i3plus.pojo.base.bean.ListPager;
import cn.estsh.i3plus.pojo.base.common.Pager;
import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil;
import cn.estsh.i3plus.pojo.base.enumutil.ResourceEnumUtil;
import cn.estsh.i3plus.pojo.platform.bean.SessionUser;
import cn.estsh.i3plus.pojo.platform.bean.SysFile;
import cn.estsh.i3plus.pojo.platform.bean.SysMessage;
import cn.estsh.impp.framework.boot.auth.AuthUtil;
import cn.estsh.impp.framework.boot.exception.ImppBusiException;
import cn.estsh.impp.framework.boot.exception.ImppExceptionBuilder;
import cn.estsh.impp.framework.boot.exception.ImppExceptionEnum;
import cn.estsh.impp.framework.boot.util.ResultBean;
import cn.estsh.impp.framework.boot.util.ValidatorBean;
@ -147,4 +149,27 @@ public class SysFileController {
return ResultBean.fail().setCode(ImppExceptionEnum.SYSTEM_EXCEPTION.getCode());
}
}
@DeleteMapping(value = "/batch-delete")
@ApiOperation(value = "批量删除文件资源",notes = "批量删除文件资源")
public ResultBean deleteSysFileByIds(String[] ids){
try{
if(ids.length == 0){
throw ImppExceptionBuilder.newInstance()
.setSystemID(CommonEnumUtil.SOFT_TYPE.CORE.getCode())
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION.getCode())
.setErrorDetail("请选择需要删除的资源。")
.build();
}
sysFileService.deleteSysFileByIds(ids);
return ResultBean.success("删除成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
LOGGER.error(busExcep.getErrorMsg() + "：{}",busExcep.getErrorDetail(),busExcep);
return ResultBean.fail(busExcep.getErrorShow());
}catch(Exception e){
LOGGER.error(ImppExceptionEnum.SYSTEM_EXCEPTION.getDescription() + "：{}",e.getMessage(),e);
return ResultBean.fail().setCode(ImppExceptionEnum.SYSTEM_EXCEPTION.getCode());
}
}
}

58
modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/controller/busi/TaskTimeController.java
Unescape Escape View File

@ -5,10 +5,13 @@ import cn.estsh.i3plus.core.api.iservice.busi.ITaskTimeService;
import cn.estsh.i3plus.platform.common.convert.ConvertBean;
import cn.estsh.i3plus.pojo.base.bean.ListPager;
import cn.estsh.i3plus.pojo.base.common.Pager;
import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil;
import cn.estsh.i3plus.pojo.base.enumutil.ImppEnumUtil;
import cn.estsh.i3plus.pojo.base.enumutil.ResourceEnumUtil;
import cn.estsh.i3plus.pojo.platform.bean.*;
import cn.estsh.impp.framework.boot.auth.AuthUtil;
import cn.estsh.impp.framework.boot.exception.ImppBusiException;
import cn.estsh.impp.framework.boot.exception.ImppExceptionBuilder;
import cn.estsh.impp.framework.boot.exception.ImppExceptionEnum;
import cn.estsh.impp.framework.boot.util.ResultBean;
import cn.estsh.impp.framework.boot.util.ValidatorBean;
@ -49,7 +52,8 @@ public class TaskTimeController {
ValidatorBean.beginValid(taskTime)
.notNull("timeId", taskTime.getTimeId())
.notNull("name", taskTime.getName())
.notNull("taskDescription", taskTime.getTaskDescription());
.notNull("timeId",taskTime.getTimeId())
.notNull("taskMethodTypeId", taskTime.getTaskMethodTypeId());
TaskTimeExpression taskTimeExpression = taskTimeExpressionService.getTaskTimeExpressionById(taskTime.getTimeId().toString());
ValidatorBean.beginValid(taskTimeExpression);
@ -58,9 +62,9 @@ public class TaskTimeController {
taskTime.setRedTimeExpression(taskTimeExpression.getTimeExpression());
ConvertBean.modelInitialize(taskTime, AuthUtil.getSessionUser());
taskTime.setTaskStatus(CommonEnumUtil.DATA_STATUS.ENABLE.getValue());
taskTime = taskTimeService.insertTaskTime(taskTime);
return ResultBean.success("操作成功")
.setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode())
.setResultObject(taskTime);
@ -82,7 +86,7 @@ public class TaskTimeController {
.notNull("id", taskTime.getId())
.notNull("timeId", taskTime.getTimeId())
.notNull("name", taskTime.getName())
.notNull("taskDescription", taskTime.getTaskDescription());
.notNull("taskMethodTypeId",taskTime.getTaskMethodTypeId());
TaskTimeExpression taskTimeExpression = taskTimeExpressionService.getTaskTimeExpressionById(taskTime.getTimeId().toString());
@ -198,4 +202,52 @@ public class TaskTimeController {
return ResultBean.fail().setCode(ImppExceptionEnum.SYSTEM_EXCEPTION.getCode());
}
}
@DeleteMapping("/batch-delete")
@ApiOperation(value = "根据id批量删除定时任务",notes = "根据id批量删除定时任务")
public ResultBean deleteTaskTimeByIds(String[] ids){
try{
if(ids.length == 0){
throw ImppExceptionBuilder.newInstance()
.setSystemID(CommonEnumUtil.SOFT_TYPE.CORE.getCode())
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION.getCode())
.setErrorDetail("请选择需要删除的资源。")
.build();
}
taskTimeService.deleteTaskTimeByIds(ids);
return ResultBean.success("删除成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
LOGGER.error(busExcep.getErrorMsg() + "：{}",busExcep.getErrorDetail(),busExcep);
return ResultBean.fail(busExcep.getErrorShow());
}catch(Exception e){
LOGGER.error(ImppExceptionEnum.SYSTEM_EXCEPTION.getDescription() + "：{}",e.getMessage(),e);
return ResultBean.fail().setCode(ImppExceptionEnum.SYSTEM_EXCEPTION.getCode());
}
}
@PutMapping(value = "/batch-status")
@ApiOperation(value = "批量修改系统任务状态",notes = "批量修改系统任务状态")
public ResultBean updateTaskTimeStatusByIds(String[] ids,Integer status){
try {
// 数据校验
if(ids.length == 0){
throw ImppExceptionBuilder.newInstance()
.setSystemID(CommonEnumUtil.SOFT_TYPE.CORE.getCode())
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION.getCode())
.setErrorDetail("请选择需要删除的资源。")
.build();
}
ValidatorBean.checkNotZero(status,"状态不能为空");
taskTimeService.updateTaskTimeStatusByIds(ids,status);
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
} catch(ImppBusiException busExcep){
LOGGER.error(busExcep.getErrorMsg() + "：{}",busExcep.getErrorDetail(),busExcep);
return ResultBean.fail(busExcep.getErrorShow());
}catch(Exception e){
LOGGER.error(ImppExceptionEnum.BUSINESS_EXCEPTION_DATA_ERROR.getDescription() + "：{}",e.getMessage(),e);
return ResultBean.fail().setCode(ImppExceptionEnum.BUSINESS_EXCEPTION_DATA_ERROR.getCode());
}
}
}

25
modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/controller/busi/TaskTimeExpressionController.java
Unescape Escape View File

@ -4,10 +4,12 @@ import cn.estsh.i3plus.core.api.iservice.busi.ITaskTimeExpressionService;
import cn.estsh.i3plus.platform.common.convert.ConvertBean;
import cn.estsh.i3plus.pojo.base.bean.ListPager;
import cn.estsh.i3plus.pojo.base.common.Pager;
import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil;
import cn.estsh.i3plus.pojo.base.enumutil.ResourceEnumUtil;
import cn.estsh.i3plus.pojo.platform.bean.TaskTimeExpression;
import cn.estsh.impp.framework.boot.auth.AuthUtil;
import cn.estsh.impp.framework.boot.exception.ImppBusiException;
import cn.estsh.impp.framework.boot.exception.ImppExceptionBuilder;
import cn.estsh.impp.framework.boot.exception.ImppExceptionEnum;
import cn.estsh.impp.framework.boot.util.ResultBean;
import cn.estsh.impp.framework.boot.util.ValidatorBean;
@ -160,4 +162,27 @@ public class TaskTimeExpressionController {
return ResultBean.fail().setCode(ImppExceptionEnum.SYSTEM_EXCEPTION.getCode());
}
}
@DeleteMapping("/batch-delete")
@ApiOperation(value = "根据id批量删除时间表达式",notes = "根据id批量删除时间表达式")
public ResultBean deleteTaskTimeExpressionByIds(String[] ids){
try{
if(ids.length == 0){
throw ImppExceptionBuilder.newInstance()
.setSystemID(CommonEnumUtil.SOFT_TYPE.CORE.getCode())
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION.getCode())
.setErrorDetail("请选择需要删除的资源。")
.build();
}
taskTimeExpressionService.deleteTaskTimeExpressionByIds(ids);
return ResultBean.success("删除成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
LOGGER.error(busExcep.getErrorMsg() + "：{}",busExcep.getErrorDetail(),busExcep);
return ResultBean.fail(busExcep.getErrorShow());
}catch(Exception e){
LOGGER.error(ImppExceptionEnum.SYSTEM_EXCEPTION.getDescription() + "：{}",e.getMessage(),e);
return ResultBean.fail().setCode(ImppExceptionEnum.SYSTEM_EXCEPTION.getCode());
}
}
}

3
modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/controller/busi/ToolTypeController.java
Unescape Escape View File

@ -174,8 +174,7 @@ public class ToolTypeController {
.build();
}
toolTypeService.deleteToolTypeByIds(ids);
return ResultBean.success("删除成功")
.setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("删除成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
LOGGER.error(busExcep.getErrorMsg() + "：{}",busExcep.getErrorDetail(),busExcep);
return ResultBean.fail(busExcep.getErrorShow());

12
modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/serviceimpl/busi/SysFileServiceImpl.java
Unescape Escape View File

@ -70,4 +70,16 @@ public class SysFileServiceImpl implements ISysFileService {
return new ListPager(sysFileRDao.findByHqlWherePage(hqlPack + sysFile.orderBy(),pager),pager);
}
}
@Override
public void deleteSysFileByIds(String[] ids) {
LOGGER.info("文件资源 SYS_FILE ids:{}", ids.toString());
// 转换类型
Long[] array = new Long[ids.length];
for (int i = 0; i < ids.length; i++) {
array[i] = Long.parseLong(ids[i]);
}
sysFileRDao.deleteByIds(array);
}
}

60
modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/serviceimpl/busi/TaskTimeExpressionServiceImpl.java
Unescape Escape View File

@ -4,9 +4,14 @@ import cn.estsh.i3plus.core.api.iservice.busi.ITaskTimeExpressionService;
import cn.estsh.i3plus.pojo.base.bean.ListPager;
import cn.estsh.i3plus.pojo.base.common.Pager;
import cn.estsh.i3plus.pojo.base.common.PagerHelper;
import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil;
import cn.estsh.i3plus.pojo.platform.bean.TaskTime;
import cn.estsh.i3plus.pojo.platform.bean.TaskTimeExpression;
import cn.estsh.i3plus.pojo.platform.repository.TaskTimeExpressionRepository;
import cn.estsh.i3plus.pojo.platform.repository.TaskTimeRepository;
import cn.estsh.i3plus.pojo.platform.sqlpack.CoreHqlPack;
import cn.estsh.impp.framework.boot.exception.ImppExceptionBuilder;
import cn.estsh.impp.framework.boot.exception.ImppExceptionEnum;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
@ -27,48 +32,71 @@ public class TaskTimeExpressionServiceImpl implements ITaskTimeExpressionService
public static final Logger LOGGER = LoggerFactory.getLogger(TaskTimeExpressionServiceImpl.class);
@Autowired
private TaskTimeExpressionRepository taskTimeRecordingRDao;
private TaskTimeExpressionRepository taskTimeExpressionRDao;
@Autowired
private TaskTimeRepository taskTimeRDao;
@Override
public void updateTaskTimeExpression(TaskTimeExpression taskTimeExpression) {
LOGGER.info("定时任务时间表达式 Task_TIME_EXPRESSION :{}", taskTimeExpression);
taskTimeRecordingRDao.update(taskTimeExpression);
LOGGER.info("定时任务时间表达式 TASK_TIME_EXPRESSION :{}", taskTimeExpression);
taskTimeExpressionRDao.update(taskTimeExpression);
}
@Override
public void deleteTaskTimeExpressionById(String id) {
LOGGER.info("定时任务时间表达式 Task_TIME_EXPRESSION :{}", id);
taskTimeRecordingRDao.deleteById(Long.parseLong(id));
LOGGER.info("定时任务时间表达式 TASK_TIME_EXPRESSION :{}", id);
taskTimeExpressionRDao.deleteById(Long.parseLong(id));
}
@Override
public TaskTimeExpression insertTaskTimeExpression(TaskTimeExpression taskTimeExpression) {
LOGGER.info("定时任务时间表达式 Task_TIME_EXPRESSION :{}", taskTimeExpression);
return taskTimeRecordingRDao.insert(taskTimeExpression);
LOGGER.info("定时任务时间表达式 TASK_TIME_EXPRESSION :{}", taskTimeExpression);
return taskTimeExpressionRDao.insert(taskTimeExpression);
}
@Override
public List<TaskTimeExpression> listTaskTimeExpression() {
LOGGER.info("定时任务时间表达式 Task_TIME_EXPRESSION list");
return taskTimeRecordingRDao.list();
LOGGER.info("定时任务时间表达式 TASK_TIME_EXPRESSION list");
return taskTimeExpressionRDao.list();
}
@Override
public TaskTimeExpression getTaskTimeExpressionById(String id) {
LOGGER.info("定时任务时间表达式 Task_TIME_EXPRESSION :{}" ,id);
return taskTimeRecordingRDao.getById(Long.parseLong(id));
LOGGER.info("定时任务时间表达式 TASK_TIME_EXPRESSION :{}" ,id);
return taskTimeExpressionRDao.getById(Long.parseLong(id));
}
@Override
public ListPager queryTaskTimeExpressionByPager(TaskTimeExpression taskTimeExpression, Pager pager) {
LOGGER.info("文件表达式 TaskTimeExpression taskTimeExpression:{}，Pager:{}",taskTimeExpression,pager);
LOGGER.info("文件表达式 TASK_TIME_EXPRESSION taskTimeExpression:{}，Pager:{}",taskTimeExpression,pager);
if(taskTimeExpression == null) {
pager = PagerHelper.getPager(pager, taskTimeRecordingRDao.listCount());
return new ListPager(taskTimeRecordingRDao.listPager(pager),pager);
pager = PagerHelper.getPager(pager, taskTimeExpressionRDao.listCount());
return new ListPager(taskTimeExpressionRDao.listPager(pager),pager);
}else {
String hqlPack = CoreHqlPack.packHqlTaskTimeExpression(taskTimeExpression);
pager = PagerHelper.getPager(pager, taskTimeRecordingRDao.findByHqlWhereCount(hqlPack));
return new ListPager(taskTimeRecordingRDao.findByHqlWherePage(hqlPack + taskTimeExpression.orderBy(),pager),pager);
pager = PagerHelper.getPager(pager, taskTimeExpressionRDao.findByHqlWhereCount(hqlPack));
return new ListPager(taskTimeExpressionRDao.findByHqlWherePage(hqlPack + taskTimeExpression.orderBy(),pager),pager);
}
}
@Override
public void deleteTaskTimeExpressionByIds(String[] ids) {
LOGGER.info("文件表达式 SYS_MENU ids:{}", ids);
long count = taskTimeRDao.findByHqlWhereCount(CoreHqlPack.packHqlIds("timeId",ids));
if(count >= 1){
throw ImppExceptionBuilder.newInstance()
.setSystemID(CommonEnumUtil.SOFT_TYPE.CORE.getCode())
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION.getCode())
.setErrorDetail("存在关联定时任务无法删除！")
.setErrorSolution("请重新操作")
.build();
}else {
Long[] array = new Long[ids.length];
for (int i = 0; i < ids.length; i++) {
array[i] = Long.parseLong(ids[i]);
}
taskTimeExpressionRDao.deleteByIds(array);
}
}
}

30
modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/serviceimpl/busi/TaskTimeServiceImpl.java
Unescape Escape View File

@ -4,14 +4,11 @@ import cn.estsh.i3plus.core.api.iservice.busi.ITaskTimeService;
import cn.estsh.i3plus.pojo.base.bean.ListPager;
import cn.estsh.i3plus.pojo.base.common.Pager;
import cn.estsh.i3plus.pojo.base.common.PagerHelper;
import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil;
import cn.estsh.i3plus.pojo.base.tool.HqlPack;
import cn.estsh.i3plus.pojo.platform.bean.SessionUser;
import cn.estsh.i3plus.pojo.platform.bean.SysMenu;
import cn.estsh.i3plus.pojo.platform.bean.TaskTime;
import cn.estsh.i3plus.pojo.platform.repository.TaskTimeRepository;
import cn.estsh.i3plus.pojo.platform.sqlpack.CoreHqlPack;
import cn.estsh.impp.framework.boot.exception.ImppExceptionBuilder;
import cn.estsh.impp.framework.boot.exception.ImppExceptionEnum;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
@ -20,7 +17,7 @@ import org.springframework.stereotype.Service;
import java.util.List;
/**
* @Description : 定时任务业务接口实现
* @Description : 定时任务业务接口实现
* @Reference :
* @Author : wei.peng
* @Date : 2018-10-22 16:58:43.974
@ -85,4 +82,27 @@ public class TaskTimeServiceImpl implements ITaskTimeService {
return new ListPager(taskTimeRDao.findByHqlWherePage(hqlPack + taskTime.orderBy(),pager),pager);
}
}
@Override
public void deleteTaskTimeByIds(String[] ids) {
LOGGER.info("定时任务 TASK_TIME ids:{}", ids.toString());
// 转换类型
Long[] array = new Long[ids.length];
for (int i = 0; i < ids.length; i++) {
array[i] = Long.parseLong(ids[i]);
}
taskTimeRDao.deleteByIds(array);
}
@Override
public void updateTaskTimeStatusByIds(String[] ids, Integer status) {
LOGGER.info("定时任务 TASK_TIME ids：{}，status：{}",ids,status);
StringBuffer where = new StringBuffer();
HqlPack.getInPack(String.join(",", ids), "id", where);
taskTimeRDao.updateByHqlWhere(where.toString(), "taskStatus", status);
}
}

2
modules/i3plus-core-apiservice/src/main/resources/application-dev.properties
Unescape Escape View File

@ -1,5 +1,5 @@
#项目端口
server.port=8080
server.port=8888
#用户登陆路径
filter.shiro.user.loginuri = /login

3
modules/i3plus-core-apiservice/src/test/java/cn/estsh/i3plus/core/apiservice/serviceimpl/busi/TestTaskTimeService.java
Unescape Escape View File

@ -56,6 +56,7 @@ public class TestTaskTimeService extends TestBase {
public void testInsertTaskTime() {
TaskTime taskTime = new TaskTime();
taskTime.setName("时间表达式");
taskTime.setTimeId(1L);
taskTime.setTaskStartDateTime("2018-01-01 00:00:00");
taskTime.setTaskEndDateTime("2018-12-31 00:00:00");
taskTime.setLastRunDateTime("2018-11-03 00:00:00");
@ -88,7 +89,7 @@ public class TestTaskTimeService extends TestBase {
@Test
@Transactional
public void testDeleteTaskTimeById(){
taskTimeService.deleteTaskTimeById("1057111616417566720");
taskTimeService.deleteTaskTimeById("1058406771644829696");
}
/**

Write Preview
Loading…
Cancel
Save