Merge remote-tracking branch 'remotes/origin/dev' into test
wei.peng
6 years ago
commit
b655974259
@ -0,0 +1,47 @@
|
||||
package cn.estsh.i3plus.core.api.iservice.busi;
|
||||
|
||||
import cn.estsh.i3plus.pojo.base.bean.ListPager;
|
||||
import cn.estsh.i3plus.pojo.base.common.Pager;
|
||||
import cn.estsh.i3plus.pojo.platform.platbean.SysLogTaskTime;
|
||||
import io.swagger.annotations.ApiOperation;
|
||||
|
||||
/**
|
||||
* @Description : 定时任务日志服务接口
|
||||
* @Reference :
|
||||
* @Author : yunhao
|
||||
* @CreateDate : 2019-01-04 15:06
|
||||
* @Modify:
|
||||
**/
|
||||
public interface ISysLogTaskTimeService {
|
||||
|
||||
/**
|
||||
* 添加定时任务日志
|
||||
* @param sysLogTaskTime
|
||||
*/
|
||||
@ApiOperation(value = "添加定时任务日志",notes = "添加定时任务日志")
|
||||
void insertSysLogTaskTime(SysLogTaskTime sysLogTaskTime);
|
||||
|
||||
/**
|
||||
* 根据id删除定时任务日志
|
||||
* @param id
|
||||
*/
|
||||
@ApiOperation(value = "删除定时任务日志",notes = "删除定时任务日志")
|
||||
void deleteSysLogTaskTimeById(Long id);
|
||||
|
||||
/**
|
||||
* 根据id查询定时任务日志
|
||||
* @param id
|
||||
* @return
|
||||
*/
|
||||
@ApiOperation(value = "根据id查询定时任务日志",notes = "根据id查询定时任务日志")
|
||||
SysLogTaskTime getSysLogTaskTimeById(Long id);
|
||||
|
||||
/**
|
||||
* 定时任务日志复杂查询
|
||||
* @param sysLogTaskTime
|
||||
* @param pager
|
||||
* @return
|
||||
*/
|
||||
@ApiOperation(value = "定时任务日志分页复杂查询",notes = "定时任务日志分页复杂查询")
|
||||
ListPager querySysLogTaskTimeByPager(SysLogTaskTime sysLogTaskTime, Pager pager);
|
||||
}
|
||||
@ -0,0 +1,101 @@
|
||||
package cn.estsh.i3plus.core.apiservice.controller.busi;
|
||||
|
||||
import cn.estsh.i3plus.core.api.iservice.busi.ISysLogTaskTimeService;
|
||||
import cn.estsh.i3plus.platform.common.util.PlatformConstWords;
|
||||
import cn.estsh.i3plus.pojo.base.bean.ListPager;
|
||||
import cn.estsh.i3plus.pojo.base.common.Pager;
|
||||
import cn.estsh.i3plus.pojo.base.enumutil.ResourceEnumUtil;
|
||||
import cn.estsh.i3plus.pojo.platform.platbean.SysLogTaskTime;
|
||||
import cn.estsh.impp.framework.base.controller.CoreBaseController;
|
||||
import cn.estsh.impp.framework.boot.exception.ImppBusiException;
|
||||
import cn.estsh.impp.framework.boot.exception.ImppExceptionBuilder;
|
||||
import cn.estsh.impp.framework.boot.util.ResultBean;
|
||||
import cn.estsh.impp.framework.boot.util.ValidatorBean;
|
||||
import io.swagger.annotations.Api;
|
||||
import io.swagger.annotations.ApiOperation;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.web.bind.annotation.*;
|
||||
|
||||
/**
|
||||
* @Description : 定时任务日志服务
|
||||
* @Reference :
|
||||
* @Author : yunhao
|
||||
* @Date : 2019-01-04
|
||||
* @Modify :
|
||||
**/
|
||||
@RestController
|
||||
@Api(description = "定时任务日志服务")
|
||||
@RequestMapping(PlatformConstWords.BASE_URL +"/sys-log-task-time")
|
||||
public class SysLogTaskTimeController extends CoreBaseController{
|
||||
public static final Logger LOGGER = LoggerFactory.getLogger(SysLogTaskTimeController.class);
|
||||
|
||||
@Autowired
|
||||
private ISysLogTaskTimeService logTaskTimeService;
|
||||
|
||||
@PostMapping(value = "/insert")
|
||||
@ApiOperation(value="新增定时任务日志",notes = "新增定时任务日志")
|
||||
public ResultBean insertSyslogTaskTime(SysLogTaskTime sysLogTaskTime) {
|
||||
try {
|
||||
logTaskTimeService.insertSysLogTaskTime(sysLogTaskTime);
|
||||
return ResultBean.success("添加成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
|
||||
}catch(ImppBusiException busExcep){
|
||||
return ResultBean.fail(busExcep);
|
||||
}catch(Exception e){
|
||||
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
|
||||
}
|
||||
}
|
||||
|
||||
@DeleteMapping(value = "/delete")
|
||||
@ApiOperation(value = "删除定时任务日志",notes = "删除定时任务日志")
|
||||
public ResultBean deleteSysLogTaskTimeById(String id) {
|
||||
try {
|
||||
// 条件校验
|
||||
ValidatorBean.checkNotNull(id,"id不能为空");
|
||||
|
||||
logTaskTimeService.deleteSysLogTaskTimeById(Long.parseLong(id));
|
||||
return ResultBean.success("删除成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
|
||||
}catch(ImppBusiException busExcep){
|
||||
return ResultBean.fail(busExcep);
|
||||
}catch(Exception e){
|
||||
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
|
||||
}
|
||||
}
|
||||
|
||||
@GetMapping(value = "/get")
|
||||
@ApiOperation(value = "根据id查询定时任务日志",notes = "根据id查询定时任务日志")
|
||||
public ResultBean getSysLogTaskTimeById(String id){
|
||||
try {
|
||||
SysLogTaskTime logTaskTime = logTaskTimeService.getSysLogTaskTimeById(Long.parseLong(id));
|
||||
if (logTaskTime != null) {
|
||||
return ResultBean.success("查询成功").setResultObject(logTaskTime).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
|
||||
}else {
|
||||
return ResultBean.fail("日志不存在").setCode(ResourceEnumUtil.MESSAGE.EMPTY.getCode());
|
||||
}
|
||||
}catch(ImppBusiException busExcep){
|
||||
return ResultBean.fail(busExcep);
|
||||
}catch(Exception e){
|
||||
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 定时任务日志分页复杂查询
|
||||
* @param sysLogTaskTime
|
||||
* @param pager
|
||||
* @return
|
||||
*/
|
||||
@GetMapping("/query")
|
||||
@ApiOperation(value = "定时任务日志分页复杂查询",notes = "定时任务日志分页复杂查询")
|
||||
public ResultBean querySysLogSystemByPager(SysLogTaskTime sysLogTaskTime, Pager pager){
|
||||
try {
|
||||
ListPager logSystemList = logTaskTimeService.querySysLogTaskTimeByPager(sysLogTaskTime, pager);
|
||||
return ResultBean.success("查询成功").setListPager(logSystemList).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
|
||||
}catch(ImppBusiException busExcep){
|
||||
return ResultBean.fail(busExcep);
|
||||
}catch(Exception e){
|
||||
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,63 @@
|
||||
package cn.estsh.i3plus.core.apiservice.serviceimpl.busi;
|
||||
|
||||
import cn.estsh.i3plus.core.api.iservice.busi.ISysLogTaskTimeService;
|
||||
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.platform.platbean.SysLogSystem;
|
||||
import cn.estsh.i3plus.pojo.platform.platbean.SysLogTaskTime;
|
||||
import cn.estsh.i3plus.pojo.platform.platrepositorymongo.SysLogTaskTimeRepository;
|
||||
import cn.estsh.i3plus.pojo.platform.sqlpack.CoreBsonPack;
|
||||
import io.swagger.annotations.ApiOperation;
|
||||
import org.bson.conversions.Bson;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
/**
|
||||
* @Description : 定时任务服务接口实现
|
||||
* @Reference :
|
||||
* @Author : yunhao
|
||||
* @CreateDate : 2019-01-04 15:10
|
||||
* @Modify:
|
||||
**/
|
||||
@Service
|
||||
public class SysLogTaskTimeService implements ISysLogTaskTimeService {
|
||||
public static final Logger LOGGER = LoggerFactory.getLogger(SysLogTaskTimeService.class);
|
||||
|
||||
@Autowired
|
||||
private SysLogTaskTimeRepository sysLogTaskTimeRDao;
|
||||
|
||||
@Override
|
||||
@ApiOperation(value = "添加定时任务日志",notes = "添加定时任务日志")
|
||||
public void insertSysLogTaskTime(SysLogTaskTime sysLogTaskTime) {
|
||||
sysLogTaskTimeRDao.insert(sysLogTaskTime);
|
||||
}
|
||||
|
||||
@Override
|
||||
@ApiOperation(value = "删除定时任务日志",notes = "删除定时任务日志")
|
||||
public void deleteSysLogTaskTimeById(Long id) {
|
||||
sysLogTaskTimeRDao.deleteById(id);
|
||||
}
|
||||
|
||||
@Override
|
||||
@ApiOperation(value = "根据id查询定时任务日志",notes = "根据id查询定时任务日志")
|
||||
public SysLogTaskTime getSysLogTaskTimeById(Long id) {
|
||||
return sysLogTaskTimeRDao.getById(id);
|
||||
}
|
||||
|
||||
@Override
|
||||
@ApiOperation(value = "定时任务日志分页复杂查询",notes = "定时任务日志分页复杂查询")
|
||||
public ListPager querySysLogTaskTimeByPager(SysLogTaskTime sysLogTaskTime, Pager pager) {
|
||||
if (sysLogTaskTime == null) {
|
||||
pager = PagerHelper.getPager(pager,sysLogTaskTimeRDao.listCount());
|
||||
return new ListPager(sysLogTaskTimeRDao.listPager(pager),pager);
|
||||
} else {
|
||||
Bson bson = CoreBsonPack.packBsonByLogTaskTime(sysLogTaskTime);
|
||||
pager = PagerHelper.getPager(pager,sysLogTaskTimeRDao.findByBsonCount(bson));
|
||||
return new ListPager(sysLogTaskTimeRDao.findByBsonPager(bson,pager,sysLogTaskTime.getOrderByParam()
|
||||
,sysLogTaskTime.getAscOrDesc()),pager);
|
||||
}
|
||||
}
|
||||
}
|
||||
Binary file not shown.
Loading…
Reference in New Issue