2
0

style: 替换项目内所有ruoyi转为wfc

This commit is contained in:
TsMask
2024-11-26 17:34:02 +08:00
parent 77a28b06a3
commit fab448f836
300 changed files with 1211 additions and 1428 deletions

View File

@@ -60,7 +60,7 @@
<version>${minio.version}</version>
</dependency>
<!-- RuoYi Api System -->
<!-- WFC Api System -->
<dependency>
<groupId>org.wfc</groupId>
<artifactId>wfc-api-system</artifactId>

View File

@@ -7,7 +7,7 @@ import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
/**
* 文件服务
*
* @author ruoyi
* @author wfc
*/
@SpringBootApplication(exclude = {DataSourceAutoConfiguration.class })
public class WfcFileApplication

View File

@@ -8,7 +8,7 @@ import io.minio.MinioClient;
/**
* Minio 配置信息
*
* @author ruoyi
* @author wfc
*/
@Configuration
@ConfigurationProperties(prefix = "minio")

View File

@@ -10,7 +10,7 @@ import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
/**
* 通用映射配置
*
* @author ruoyi
* @author wfc
*/
@Configuration
public class ResourcesConfig implements WebMvcConfigurer

View File

@@ -14,7 +14,7 @@ import org.wfc.system.api.domain.SysFile;
/**
* 文件请求处理
*
* @author ruoyi
* @author wfc
*/
@RestController
public class SysFileController

View File

@@ -13,7 +13,7 @@ import org.wfc.common.core.utils.file.FileTypeUtils;
/**
* FastDFS 文件存储
*
* @author ruoyi
* @author wfc
*/
@Service
public class FastDfsSysFileServiceImpl implements ISysFileService

View File

@@ -5,7 +5,7 @@ import org.springframework.web.multipart.MultipartFile;
/**
* 文件上传接口
*
* @author ruoyi
* @author wfc
*/
public interface ISysFileService
{

View File

@@ -9,7 +9,7 @@ import org.wfc.file.utils.FileUploadUtils;
/**
* 本地文件存储
*
* @author ruoyi
* @author wfc
*/
@Primary
@Service

View File

@@ -13,7 +13,7 @@ import io.minio.PutObjectArgs;
/**
* Minio 文件存储
*
* @author ruoyi
* @author wfc
*/
@Service
public class MinioSysFileServiceImpl implements ISysFileService

View File

@@ -19,7 +19,7 @@ import org.wfc.common.core.utils.uuid.Seq;
/**
* 文件上传工具类
*
* @author ruoyi
* @author wfc
*/
public class FileUploadUtils
{

View File

@@ -53,13 +53,13 @@
<artifactId>mysql-connector-j</artifactId>
</dependency>
<!-- RuoYi Common Log -->
<!-- WFC Common Log -->
<dependency>
<groupId>org.wfc</groupId>
<artifactId>wfc-common-log</artifactId>
</dependency>
<!-- RuoYi Common Swagger -->
<!-- WFC Common Swagger -->
<dependency>
<groupId>org.wfc</groupId>
<artifactId>wfc-common-swagger</artifactId>

View File

@@ -9,7 +9,7 @@ import org.wfc.common.swagger.annotation.EnableCustomSwagger2;
/**
* 代码生成
*
* @author ruoyi
* @author wfc
*/
@EnableCustomConfig
@EnableRyFeignClients

View File

@@ -6,7 +6,7 @@ import org.springframework.stereotype.Component;
/**
* 代码生成相关配置
*
* @author ruoyi
* @author wfc
*/
@Component
@ConfigurationProperties(prefix = "gen")

View File

@@ -31,7 +31,7 @@ import org.wfc.gen.service.IGenTableService;
/**
* 代码生成 操作处理
*
* @author ruoyi
* @author wfc
*/
@RequestMapping("/gen")
@RestController
@@ -203,7 +203,7 @@ public class GenController extends BaseController
private void genCode(HttpServletResponse response, byte[] data) throws IOException
{
response.reset();
response.setHeader("Content-Disposition", "attachment; filename=\"ruoyi.zip\"");
response.setHeader("Content-Disposition", "attachment; filename=\"wfc.zip\"");
response.addHeader("Content-Length", "" + data.length);
response.setContentType("application/octet-stream; charset=UTF-8");
IOUtils.write(data, response.getOutputStream());

View File

@@ -11,7 +11,7 @@ import org.wfc.common.core.web.domain.BaseEntity;
/**
* 业务表 gen_table
*
* @author ruoyi
* @author wfc
*/
public class GenTable extends BaseEntity
{

View File

@@ -7,7 +7,7 @@ import org.wfc.common.core.web.domain.BaseEntity;
/**
* 代码生成业务字段表 gen_table_column
*
* @author ruoyi
* @author wfc
*/
public class GenTableColumn extends BaseEntity
{

View File

@@ -6,7 +6,7 @@ import org.wfc.gen.domain.GenTableColumn;
/**
* 业务字段 数据层
*
* @author ruoyi
* @author wfc
*/
public interface GenTableColumnMapper
{

View File

@@ -6,7 +6,7 @@ import org.wfc.gen.domain.GenTable;
/**
* 业务 数据层
*
* @author ruoyi
* @author wfc
*/
public interface GenTableMapper
{

View File

@@ -10,7 +10,7 @@ import org.wfc.gen.mapper.GenTableColumnMapper;
/**
* 业务字段 服务层实现
*
* @author ruoyi
* @author wfc
*/
@Service
public class GenTableColumnServiceImpl implements IGenTableColumnService

View File

@@ -40,7 +40,7 @@ import org.wfc.gen.util.VelocityUtils;
/**
* 业务 服务层实现
*
* @author ruoyi
* @author wfc
*/
@Service
public class GenTableServiceImpl implements IGenTableService

View File

@@ -6,7 +6,7 @@ import org.wfc.gen.domain.GenTableColumn;
/**
* 业务字段 服务层
*
* @author ruoyi
* @author wfc
*/
public interface IGenTableColumnService
{

View File

@@ -7,7 +7,7 @@ import org.wfc.gen.domain.GenTable;
/**
* 业务 服务层
*
* @author ruoyi
* @author wfc
*/
public interface IGenTableService
{

View File

@@ -11,7 +11,7 @@ import org.wfc.gen.domain.GenTableColumn;
/**
* 代码生成器 工具类
*
* @author ruoyi
* @author wfc
*/
public class GenUtils
{

View File

@@ -7,7 +7,7 @@ import org.wfc.common.core.constant.Constants;
/**
* VelocityEngine工厂
*
* @author ruoyi
* @author wfc
*/
public class VelocityInitializer
{

View File

@@ -16,7 +16,7 @@ import org.wfc.gen.domain.GenTableColumn;
/**
* 模板工具类
*
* @author ruoyi
* @author wfc
*/
public class VelocityUtils
{

View File

@@ -59,13 +59,13 @@
<artifactId>mysql-connector-j</artifactId>
</dependency>
<!-- RuoYi Common Log -->
<!-- WFC Common Log -->
<dependency>
<groupId>org.wfc</groupId>
<artifactId>wfc-common-log</artifactId>
</dependency>
<!-- RuoYi Common Swagger -->
<!-- WFC Common Swagger -->
<dependency>
<groupId>org.wfc</groupId>
<artifactId>wfc-common-swagger</artifactId>

View File

@@ -8,7 +8,7 @@ import org.wfc.common.security.annotation.EnableRyFeignClients;
/**
* 定时任务
*
* @author ruoyi
* @author wfc
*/
@EnableCustomConfig
@EnableRyFeignClients

View File

@@ -9,7 +9,7 @@
///**
// * 定时任务配置单机部署建议删除此类和qrtz数据库表默认走内存会最高效
// *
// * @author ruoyi
// * @author wfc
// */
//@Configuration
//public class ScheduleConfig
@@ -22,7 +22,7 @@
//
// // quartz参数
// Properties prop = new Properties();
// prop.put("org.quartz.scheduler.instanceName", "RuoyiScheduler");
// prop.put("org.quartz.scheduler.instanceName", "wfcScheduler");
// prop.put("org.quartz.scheduler.instanceId", "AUTO");
// // 线程池配置
// prop.put("org.quartz.threadPool.class", "org.quartz.simpl.SimpleThreadPool");
@@ -42,7 +42,7 @@
// prop.put("org.quartz.jobStore.tablePrefix", "QRTZ_");
// factory.setQuartzProperties(prop);
//
// factory.setSchedulerName("RuoyiScheduler");
// factory.setSchedulerName("wfcScheduler");
// // 延时启动
// factory.setStartupDelay(1);
// factory.setApplicationContextSchedulerContextKey("applicationContextKey");

View File

@@ -31,7 +31,7 @@ import org.wfc.job.util.ScheduleUtils;
/**
* 调度任务信息操作处理
*
* @author ruoyi
* @author wfc
*/
@RestController
@RequestMapping("/job")

View File

@@ -22,7 +22,7 @@ import org.wfc.job.service.ISysJobLogService;
/**
* 调度日志操作处理
*
* @author ruoyi
* @author wfc
*/
@RestController
@RequestMapping("/job/log")

View File

@@ -16,7 +16,7 @@ import org.wfc.job.util.CronUtils;
/**
* 定时任务调度表 sys_job
*
* @author ruoyi
* @author wfc
*/
public class SysJob extends BaseEntity
{

View File

@@ -9,7 +9,7 @@ import org.wfc.common.core.web.domain.BaseEntity;
/**
* 定时任务调度日志表 sys_job_log
*
* @author ruoyi
* @author wfc
*/
public class SysJobLog extends BaseEntity
{

View File

@@ -6,7 +6,7 @@ import org.wfc.job.domain.SysJobLog;
/**
* 调度任务日志信息 数据层
*
* @author ruoyi
* @author wfc
*/
public interface SysJobLogMapper
{

View File

@@ -6,7 +6,7 @@ import org.wfc.job.domain.SysJob;
/**
* 调度任务信息 数据层
*
* @author ruoyi
* @author wfc
*/
public interface SysJobMapper
{

View File

@@ -6,7 +6,7 @@ import org.wfc.job.domain.SysJobLog;
/**
* 定时任务调度日志信息信息 服务层
*
* @author ruoyi
* @author wfc
*/
public interface ISysJobLogService
{

View File

@@ -8,7 +8,7 @@ import org.wfc.job.domain.SysJob;
/**
* 定时任务调度信息信息 服务层
*
* @author ruoyi
* @author wfc
*/
public interface ISysJobService
{

View File

@@ -9,7 +9,7 @@ import org.wfc.job.mapper.SysJobLogMapper;
/**
* 定时任务调度日志信息 服务层
*
* @author ruoyi
* @author wfc
*/
@Service
public class SysJobLogServiceImpl implements ISysJobLogService

View File

@@ -19,7 +19,7 @@ import org.wfc.job.util.ScheduleUtils;
/**
* 定时任务调度信息 服务层
*
* @author ruoyi
* @author wfc
*/
@Service
public class SysJobServiceImpl implements ISysJobService

View File

@@ -6,7 +6,7 @@ import org.wfc.common.core.utils.StringUtils;
/**
* 定时任务调度测试
*
* @author ruoyi
* @author wfc
*/
@Component("ryTask")
public class RyTask

View File

@@ -18,7 +18,7 @@ import org.wfc.job.service.ISysJobLogService;
/**
* 抽象quartz调用
*
* @author ruoyi
* @author wfc
*/
public abstract class AbstractQuartzJob implements Job
{

View File

@@ -7,7 +7,7 @@ import org.quartz.CronExpression;
/**
* cron表达式工具类
*
* @author ruoyi
* @author wfc
*
*/
public class CronUtils

View File

@@ -11,7 +11,7 @@ import org.wfc.job.domain.SysJob;
/**
* 任务执行工具
*
* @author ruoyi
* @author wfc
*/
public class JobInvokeUtil
{

View File

@@ -8,7 +8,7 @@ import org.wfc.job.domain.SysJob;
/**
* 定时任务处理(禁止并发执行)
*
* @author ruoyi
* @author wfc
*
*/
@DisallowConcurrentExecution

View File

@@ -7,7 +7,7 @@ import org.wfc.job.domain.SysJob;
/**
* 定时任务处理(允许并发执行)
*
* @author ruoyi
* @author wfc
*
*/
public class QuartzJobExecution extends AbstractQuartzJob

View File

@@ -21,7 +21,7 @@ import org.wfc.job.domain.SysJob;
/**
* 定时任务工具类
*
* @author ruoyi
* @author wfc
*
*/
public class ScheduleUtils

View File

@@ -4,13 +4,11 @@ import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.wfc.common.security.annotation.EnableCustomConfig;
import org.wfc.common.security.annotation.EnableRyFeignClients;
import org.wfc.common.swagger.annotation.EnableCustomSwagger2;
/**
* 用户平台模块
*/
@EnableCustomConfig
@EnableCustomSwagger2
@EnableRyFeignClients
@SpringBootApplication
public class WfcUserApplication

View File

@@ -1,158 +0,0 @@
package org.wfc.user.controller;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.wfc.common.core.constant.Constants;
import org.wfc.common.core.exception.job.TaskException;
import org.wfc.common.core.utils.StringUtils;
import org.wfc.common.core.utils.poi.ExcelUtil;
import org.wfc.common.core.web.controller.BaseController;
import org.wfc.common.core.web.domain.AjaxResult;
import org.wfc.common.core.web.page.TableDataInfo;
import org.wfc.common.log.annotation.Log;
import org.wfc.common.log.enums.BusinessType;
import org.wfc.common.security.annotation.RequiresPermissions;
import org.wfc.common.security.utils.SecurityUtils;
import org.wfc.user.domain.SysJob;
import org.wfc.user.service.ISysJobService;
import javax.servlet.http.HttpServletResponse;
import java.util.List;
/**
* 调度任务信息操作处理
*
* @author ruoyi
*/
@RestController
@RequestMapping("/job")
public class SysJobController extends BaseController
{
@Autowired
private ISysJobService jobService;
/**
* 查询定时任务列表
*/
@GetMapping("/list")
public TableDataInfo list(SysJob sysJob)
{
startPage();
List<SysJob> list = jobService.selectJobList(sysJob);
return getDataTable(list);
}
/**
* 导出定时任务列表
*/
@RequiresPermissions("monitor:job:export")
@Log(title = "定时任务", businessType = BusinessType.EXPORT)
@PostMapping("/export")
public void export(HttpServletResponse response, SysJob sysJob)
{
List<SysJob> list = jobService.selectJobList(sysJob);
ExcelUtil<SysJob> util = new ExcelUtil<SysJob>(SysJob.class);
util.exportExcel(response, list, "定时任务");
}
/**
* 获取定时任务详细信息
*/
@RequiresPermissions("monitor:job:query")
@GetMapping(value = "/{jobId}")
public AjaxResult getInfo(@PathVariable("jobId") Long jobId)
{
return success(jobService.selectJobById(jobId));
}
/**
* 新增定时任务
*/
@RequiresPermissions("monitor:job:add")
@Log(title = "定时任务", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult add(@RequestBody SysJob job) throws TaskException
{
if (StringUtils.containsIgnoreCase(job.getInvokeTarget(), Constants.LOOKUP_RMI))
{
return error("新增任务'" + job.getJobName() + "'失败,目标字符串不允许'rmi'调用");
}
else if (StringUtils.containsAnyIgnoreCase(job.getInvokeTarget(), new String[] { Constants.LOOKUP_LDAP, Constants.LOOKUP_LDAPS }))
{
return error("新增任务'" + job.getJobName() + "'失败,目标字符串不允许'ldap(s)'调用");
}
else if (StringUtils.containsAnyIgnoreCase(job.getInvokeTarget(), new String[] { Constants.HTTP, Constants.HTTPS }))
{
return error("新增任务'" + job.getJobName() + "'失败,目标字符串不允许'http(s)'调用");
}
else if (StringUtils.containsAnyIgnoreCase(job.getInvokeTarget(), Constants.JOB_ERROR_STR))
{
return error("新增任务'" + job.getJobName() + "'失败,目标字符串存在违规");
}
job.setCreateBy(SecurityUtils.getUsername());
return toAjax(1);
}
/**
* 修改定时任务
*/
@RequiresPermissions("monitor:job:edit")
@Log(title = "定时任务", businessType = BusinessType.UPDATE)
@PutMapping
public AjaxResult edit(@RequestBody SysJob job) throws TaskException
{
if (StringUtils.containsIgnoreCase(job.getInvokeTarget(), Constants.LOOKUP_RMI))
{
return error("修改任务'" + job.getJobName() + "'失败,目标字符串不允许'rmi'调用");
}
else if (StringUtils.containsAnyIgnoreCase(job.getInvokeTarget(), new String[] { Constants.LOOKUP_LDAP, Constants.LOOKUP_LDAPS }))
{
return error("修改任务'" + job.getJobName() + "'失败,目标字符串不允许'ldap(s)'调用");
}
else if (StringUtils.containsAnyIgnoreCase(job.getInvokeTarget(), new String[] { Constants.HTTP, Constants.HTTPS }))
{
return error("修改任务'" + job.getJobName() + "'失败,目标字符串不允许'http(s)'调用");
}
else if (StringUtils.containsAnyIgnoreCase(job.getInvokeTarget(), Constants.JOB_ERROR_STR))
{
return error("修改任务'" + job.getJobName() + "'失败,目标字符串存在违规");
}
job.setUpdateBy(SecurityUtils.getUsername());
return toAjax(false);
}
/**
* 定时任务状态修改
*/
@RequiresPermissions("monitor:job:changeStatus")
@Log(title = "定时任务", businessType = BusinessType.UPDATE)
@PutMapping("/changeStatus")
public AjaxResult changeStatus(@RequestBody SysJob job)
{
return toAjax(false);
}
/**
* 定时任务立即执行一次
*/
@RequiresPermissions("monitor:job:changeStatus")
@Log(title = "定时任务", businessType = BusinessType.UPDATE)
@PutMapping("/run")
public AjaxResult run(@RequestBody SysJob job)
{
return error("任务不存在或已过期!");
}
/**
* 删除定时任务
*/
@RequiresPermissions("monitor:job:remove")
@Log(title = "定时任务", businessType = BusinessType.DELETE)
@DeleteMapping("/{jobIds}")
public AjaxResult remove(@PathVariable Long[] jobIds)
{
return success();
}
}

View File

@@ -1,87 +0,0 @@
package org.wfc.user.controller;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.wfc.common.core.utils.poi.ExcelUtil;
import org.wfc.common.core.web.controller.BaseController;
import org.wfc.common.core.web.domain.AjaxResult;
import org.wfc.common.core.web.page.TableDataInfo;
import org.wfc.common.log.annotation.Log;
import org.wfc.common.log.enums.BusinessType;
import org.wfc.common.security.annotation.RequiresPermissions;
import org.wfc.user.domain.SysJobLog;
import org.wfc.user.service.ISysJobLogService;
import javax.servlet.http.HttpServletResponse;
import java.util.List;
/**
* 调度日志操作处理
*
* @author ruoyi
*/
@RestController
@RequestMapping("/job/log")
public class SysJobLogController extends BaseController
{
@Autowired
private ISysJobLogService jobLogService;
/**
* 查询定时任务调度日志列表
*/
@RequiresPermissions("monitor:job:list")
@GetMapping("/list")
public TableDataInfo list(SysJobLog sysJobLog)
{
startPage();
List<SysJobLog> list = jobLogService.selectJobLogList(sysJobLog);
return getDataTable(list);
}
/**
* 导出定时任务调度日志列表
*/
@RequiresPermissions("monitor:job:export")
@Log(title = "任务调度日志", businessType = BusinessType.EXPORT)
@PostMapping("/export")
public void export(HttpServletResponse response, SysJobLog sysJobLog)
{
List<SysJobLog> list = jobLogService.selectJobLogList(sysJobLog);
ExcelUtil<SysJobLog> util = new ExcelUtil<SysJobLog>(SysJobLog.class);
util.exportExcel(response, list, "调度日志");
}
/**
* 根据调度编号获取详细信息
*/
@RequiresPermissions("monitor:job:query")
@GetMapping(value = "/{jobLogId}")
public AjaxResult getInfo(@PathVariable Long jobLogId)
{
return success(jobLogService.selectJobLogById(jobLogId));
}
/**
* 删除定时任务调度日志
*/
@RequiresPermissions("monitor:job:remove")
@Log(title = "定时任务调度日志", businessType = BusinessType.DELETE)
@DeleteMapping("/{jobLogIds}")
public AjaxResult remove(@PathVariable Long[] jobLogIds)
{
return toAjax(jobLogService.deleteJobLogByIds(jobLogIds));
}
/**
* 清空定时任务调度日志
*/
@RequiresPermissions("monitor:job:remove")
@Log(title = "调度日志", businessType = BusinessType.CLEAN)
@DeleteMapping("/clean")
public AjaxResult clean()
{
jobLogService.cleanJobLog();
return success();
}
}

View File

@@ -0,0 +1,104 @@
package org.wfc.user.controller;
import java.util.List;
import javax.servlet.http.HttpServletResponse;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.PutMapping;
import org.springframework.web.bind.annotation.DeleteMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.wfc.common.log.annotation.Log;
import org.wfc.common.log.enums.BusinessType;
import org.wfc.common.security.annotation.RequiresPermissions;
import org.wfc.user.domain.UUser;
import org.wfc.user.service.IUUserService;
import org.wfc.common.core.web.controller.BaseController;
import org.wfc.common.core.web.domain.AjaxResult;
import org.wfc.common.core.utils.poi.ExcelUtil;
import org.wfc.common.core.web.page.TableDataInfo;
/**
* 用户平台_用户信息Controller
*
* @author wfc
* @date 2024-11-25
*/
@RestController
@RequestMapping("/user")
public class UUserController extends BaseController
{
@Autowired
private IUUserService uUserService;
/**
* 查询用户平台_用户信息列表
*/
@RequiresPermissions("user:user:list")
@GetMapping("/list")
public TableDataInfo list(UUser uUser)
{
startPage();
List<UUser> list = uUserService.selectUUserList(uUser);
return getDataTable(list);
}
/**
* 导出用户平台_用户信息列表
*/
@RequiresPermissions("user:user:export")
@Log(title = "用户平台_用户信息", businessType = BusinessType.EXPORT)
@PostMapping("/export")
public void export(HttpServletResponse response, UUser uUser)
{
List<UUser> list = uUserService.selectUUserList(uUser);
ExcelUtil<UUser> util = new ExcelUtil<UUser>(UUser.class);
util.exportExcel(response, list, "用户平台_用户信息数据");
}
/**
* 获取用户平台_用户信息详细信息
*/
@RequiresPermissions("user:user:query")
@GetMapping(value = "/{userId}")
public AjaxResult getInfo(@PathVariable("userId") Long userId)
{
return success(uUserService.selectUUserByUserId(userId));
}
/**
* 新增用户平台_用户信息
*/
@RequiresPermissions("user:user:add")
@Log(title = "用户平台_用户信息", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult add(@RequestBody UUser uUser)
{
return toAjax(uUserService.insertUUser(uUser));
}
/**
* 修改用户平台_用户信息
*/
@RequiresPermissions("user:user:edit")
@Log(title = "用户平台_用户信息", businessType = BusinessType.UPDATE)
@PutMapping
public AjaxResult edit(@RequestBody UUser uUser)
{
return toAjax(uUserService.updateUUser(uUser));
}
/**
* 删除用户平台_用户信息
*/
@RequiresPermissions("user:user:remove")
@Log(title = "用户平台_用户信息", businessType = BusinessType.DELETE)
@DeleteMapping("/{userIds}")
public AjaxResult remove(@PathVariable Long[] userIds)
{
return toAjax(uUserService.deleteUUserByUserIds(userIds));
}
}

View File

@@ -1,170 +0,0 @@
package org.wfc.user.domain;
import com.fasterxml.jackson.annotation.JsonFormat;
import org.apache.commons.lang3.builder.ToStringBuilder;
import org.apache.commons.lang3.builder.ToStringStyle;
import org.wfc.common.core.annotation.Excel;
import org.wfc.common.core.annotation.Excel.ColumnType;
import org.wfc.common.core.constant.ScheduleConstants;
import org.wfc.common.core.utils.StringUtils;
import org.wfc.common.core.web.domain.BaseEntity;
import javax.validation.constraints.NotBlank;
import javax.validation.constraints.Size;
import java.util.Date;
/**
* 定时任务调度表 sys_job
*
* @author ruoyi
*/
public class SysJob extends BaseEntity
{
private static final long serialVersionUID = 1L;
/** 任务ID */
@Excel(name = "任务序号", cellType = ColumnType.NUMERIC)
private Long jobId;
/** 任务名称 */
@Excel(name = "任务名称")
private String jobName;
/** 任务组名 */
@Excel(name = "任务组名")
private String jobGroup;
/** 调用目标字符串 */
@Excel(name = "调用目标字符串")
private String invokeTarget;
/** cron执行表达式 */
@Excel(name = "执行表达式 ")
private String cronExpression;
/** cron计划策略 */
@Excel(name = "计划策略 ", readConverterExp = "0=默认,1=立即触发执行,2=触发一次执行,3=不触发立即执行")
private String misfirePolicy = ScheduleConstants.MISFIRE_DEFAULT;
/** 是否并发执行0允许 1禁止 */
@Excel(name = "并发执行", readConverterExp = "0=允许,1=禁止")
private String concurrent;
/** 任务状态0正常 1暂停 */
@Excel(name = "任务状态", readConverterExp = "0=正常,1=暂停")
private String status;
public Long getJobId()
{
return jobId;
}
public void setJobId(Long jobId)
{
this.jobId = jobId;
}
@NotBlank(message = "任务名称不能为空")
@Size(min = 0, max = 64, message = "任务名称不能超过64个字符")
public String getJobName()
{
return jobName;
}
public void setJobName(String jobName)
{
this.jobName = jobName;
}
public String getJobGroup()
{
return jobGroup;
}
public void setJobGroup(String jobGroup)
{
this.jobGroup = jobGroup;
}
@NotBlank(message = "调用目标字符串不能为空")
@Size(min = 0, max = 500, message = "调用目标字符串长度不能超过500个字符")
public String getInvokeTarget()
{
return invokeTarget;
}
public void setInvokeTarget(String invokeTarget)
{
this.invokeTarget = invokeTarget;
}
@NotBlank(message = "Cron执行表达式不能为空")
@Size(min = 0, max = 255, message = "Cron执行表达式不能超过255个字符")
public String getCronExpression()
{
return cronExpression;
}
public void setCronExpression(String cronExpression)
{
this.cronExpression = cronExpression;
}
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
public Date getNextValidTime()
{
if (StringUtils.isNotEmpty(cronExpression))
{
}
return null;
}
public String getMisfirePolicy()
{
return misfirePolicy;
}
public void setMisfirePolicy(String misfirePolicy)
{
this.misfirePolicy = misfirePolicy;
}
public String getConcurrent()
{
return concurrent;
}
public void setConcurrent(String concurrent)
{
this.concurrent = concurrent;
}
public String getStatus()
{
return status;
}
public void setStatus(String status)
{
this.status = status;
}
@Override
public String toString() {
return new ToStringBuilder(this,ToStringStyle.MULTI_LINE_STYLE)
.append("jobId", getJobId())
.append("jobName", getJobName())
.append("jobGroup", getJobGroup())
.append("cronExpression", getCronExpression())
.append("nextValidTime", getNextValidTime())
.append("misfirePolicy", getMisfirePolicy())
.append("concurrent", getConcurrent())
.append("status", getStatus())
.append("createBy", getCreateBy())
.append("createTime", getCreateTime())
.append("updateBy", getUpdateBy())
.append("updateTime", getUpdateTime())
.append("remark", getRemark())
.toString();
}
}

View File

@@ -1,156 +0,0 @@
package org.wfc.user.domain;
import org.apache.commons.lang3.builder.ToStringBuilder;
import org.apache.commons.lang3.builder.ToStringStyle;
import org.wfc.common.core.annotation.Excel;
import org.wfc.common.core.web.domain.BaseEntity;
import java.util.Date;
/**
* 定时任务调度日志表 sys_job_log
*
* @author ruoyi
*/
public class SysJobLog extends BaseEntity
{
private static final long serialVersionUID = 1L;
/** ID */
@Excel(name = "日志序号")
private Long jobLogId;
/** 任务名称 */
@Excel(name = "任务名称")
private String jobName;
/** 任务组名 */
@Excel(name = "任务组名")
private String jobGroup;
/** 调用目标字符串 */
@Excel(name = "调用目标字符串")
private String invokeTarget;
/** 日志信息 */
@Excel(name = "日志信息")
private String jobMessage;
/** 执行状态0正常 1失败 */
@Excel(name = "执行状态", readConverterExp = "0=正常,1=失败")
private String status;
/** 异常信息 */
@Excel(name = "异常信息")
private String exceptionInfo;
/** 开始时间 */
private Date startTime;
/** 停止时间 */
private Date stopTime;
public Long getJobLogId()
{
return jobLogId;
}
public void setJobLogId(Long jobLogId)
{
this.jobLogId = jobLogId;
}
public String getJobName()
{
return jobName;
}
public void setJobName(String jobName)
{
this.jobName = jobName;
}
public String getJobGroup()
{
return jobGroup;
}
public void setJobGroup(String jobGroup)
{
this.jobGroup = jobGroup;
}
public String getInvokeTarget()
{
return invokeTarget;
}
public void setInvokeTarget(String invokeTarget)
{
this.invokeTarget = invokeTarget;
}
public String getJobMessage()
{
return jobMessage;
}
public void setJobMessage(String jobMessage)
{
this.jobMessage = jobMessage;
}
public String getStatus()
{
return status;
}
public void setStatus(String status)
{
this.status = status;
}
public String getExceptionInfo()
{
return exceptionInfo;
}
public void setExceptionInfo(String exceptionInfo)
{
this.exceptionInfo = exceptionInfo;
}
public Date getStartTime()
{
return startTime;
}
public void setStartTime(Date startTime)
{
this.startTime = startTime;
}
public Date getStopTime()
{
return stopTime;
}
public void setStopTime(Date stopTime)
{
this.stopTime = stopTime;
}
@Override
public String toString() {
return new ToStringBuilder(this,ToStringStyle.MULTI_LINE_STYLE)
.append("jobLogId", getJobLogId())
.append("jobName", getJobName())
.append("jobGroup", getJobGroup())
.append("jobMessage", getJobMessage())
.append("status", getStatus())
.append("exceptionInfo", getExceptionInfo())
.append("startTime", getStartTime())
.append("stopTime", getStopTime())
.toString();
}
}

View File

@@ -0,0 +1,212 @@
package org.wfc.user.domain;
import java.util.Date;
import com.fasterxml.jackson.annotation.JsonFormat;
import org.apache.commons.lang3.builder.ToStringBuilder;
import org.apache.commons.lang3.builder.ToStringStyle;
import org.wfc.common.core.annotation.Excel;
import org.wfc.common.core.web.domain.BaseEntity;
/**
* 用户平台_用户信息对象 u_user
*
* @author wfc
* @date 2024-11-25
*/
public class UUser extends BaseEntity
{
private static final long serialVersionUID = 1L;
/** 用户ID */
private Long userId;
/** 用户账号 */
@Excel(name = "用户账号")
private String userName;
/** 用户昵称 */
@Excel(name = "用户昵称")
private String nickName;
/** 年龄 */
@Excel(name = "年龄")
private String age;
/** 用户性别0男 1女 2未知 */
@Excel(name = "用户性别", readConverterExp = "0=男,1=女,2=未知")
private String sex;
/** 用户邮箱 */
@Excel(name = "用户邮箱")
private String email;
/** 手机号码 */
@Excel(name = "手机号码")
private String phone;
/** 地址 */
@Excel(name = "地址")
private String address;
/** 密码 */
@Excel(name = "密码")
private String password;
/** 帐号状态0正常 1停用 */
@Excel(name = "帐号状态", readConverterExp = "0=正常,1=停用")
private String status;
/** 删除标志0代表存在 2代表删除 */
private String delFlag;
/** 最后登录IP */
@Excel(name = "最后登录IP")
private String loginIp;
/** 最后登录时间 */
@JsonFormat(pattern = "yyyy-MM-dd")
@Excel(name = "最后登录时间", width = 30, dateFormat = "yyyy-MM-dd")
private Date loginDate;
public void setUserId(Long userId)
{
this.userId = userId;
}
public Long getUserId()
{
return userId;
}
public void setUserName(String userName)
{
this.userName = userName;
}
public String getUserName()
{
return userName;
}
public void setNickName(String nickName)
{
this.nickName = nickName;
}
public String getNickName()
{
return nickName;
}
public void setAge(String age)
{
this.age = age;
}
public String getAge()
{
return age;
}
public void setSex(String sex)
{
this.sex = sex;
}
public String getSex()
{
return sex;
}
public void setEmail(String email)
{
this.email = email;
}
public String getEmail()
{
return email;
}
public void setPhone(String phone)
{
this.phone = phone;
}
public String getPhone()
{
return phone;
}
public void setAddress(String address)
{
this.address = address;
}
public String getAddress()
{
return address;
}
public void setPassword(String password)
{
this.password = password;
}
public String getPassword()
{
return password;
}
public void setStatus(String status)
{
this.status = status;
}
public String getStatus()
{
return status;
}
public void setDelFlag(String delFlag)
{
this.delFlag = delFlag;
}
public String getDelFlag()
{
return delFlag;
}
public void setLoginIp(String loginIp)
{
this.loginIp = loginIp;
}
public String getLoginIp()
{
return loginIp;
}
public void setLoginDate(Date loginDate)
{
this.loginDate = loginDate;
}
public Date getLoginDate()
{
return loginDate;
}
@Override
public String toString() {
return new ToStringBuilder(this,ToStringStyle.MULTI_LINE_STYLE)
.append("userId", getUserId())
.append("userName", getUserName())
.append("nickName", getNickName())
.append("age", getAge())
.append("sex", getSex())
.append("email", getEmail())
.append("phone", getPhone())
.append("address", getAddress())
.append("password", getPassword())
.append("status", getStatus())
.append("delFlag", getDelFlag())
.append("loginIp", getLoginIp())
.append("loginDate", getLoginDate())
.append("createBy", getCreateBy())
.append("createTime", getCreateTime())
.append("updateBy", getUpdateBy())
.append("updateTime", getUpdateTime())
.append("remark", getRemark())
.toString();
}
}

View File

@@ -1,65 +0,0 @@
package org.wfc.user.mapper;
import org.wfc.user.domain.SysJobLog;
import java.util.List;
/**
* 调度任务日志信息 数据层
*
* @author ruoyi
*/
public interface SysJobLogMapper
{
/**
* 获取quartz调度器日志的计划任务
*
* @param jobLog 调度日志信息
* @return 调度任务日志集合
*/
public List<SysJobLog> selectJobLogList(SysJobLog jobLog);
/**
* 查询所有调度任务日志
*
* @return 调度任务日志列表
*/
public List<SysJobLog> selectJobLogAll();
/**
* 通过调度任务日志ID查询调度信息
*
* @param jobLogId 调度任务日志ID
* @return 调度任务日志对象信息
*/
public SysJobLog selectJobLogById(Long jobLogId);
/**
* 新增任务日志
*
* @param jobLog 调度日志信息
* @return 结果
*/
public int insertJobLog(SysJobLog jobLog);
/**
* 批量删除调度日志信息
*
* @param logIds 需要删除的数据ID
* @return 结果
*/
public int deleteJobLogByIds(Long[] logIds);
/**
* 删除任务日志
*
* @param jobId 调度日志ID
* @return 结果
*/
public int deleteJobLogById(Long jobId);
/**
* 清空任务日志
*/
public void cleanJobLog();
}

View File

@@ -1,68 +0,0 @@
package org.wfc.user.mapper;
import org.wfc.user.domain.SysJob;
import java.util.List;
/**
* 调度任务信息 数据层
*
* @author ruoyi
*/
public interface SysJobMapper
{
/**
* 查询调度任务日志集合
*
* @param job 调度信息
* @return 操作日志集合
*/
public List<SysJob> selectJobList(SysJob job);
/**
* 查询所有调度任务
*
* @return 调度任务列表
*/
public List<SysJob> selectJobAll();
/**
* 通过调度ID查询调度任务信息
*
* @param jobId 调度ID
* @return 角色对象信息
*/
public SysJob selectJobById(Long jobId);
/**
* 通过调度ID删除调度任务信息
*
* @param jobId 调度ID
* @return 结果
*/
public int deleteJobById(Long jobId);
/**
* 批量删除调度任务信息
*
* @param ids 需要删除的数据ID
* @return 结果
*/
public int deleteJobByIds(Long[] ids);
/**
* 修改调度任务信息
*
* @param job 调度任务信息
* @return 结果
*/
public int updateJob(SysJob job);
/**
* 新增调度任务信息
*
* @param job 调度任务信息
* @return 结果
*/
public int insertJob(SysJob job);
}

View File

@@ -0,0 +1,61 @@
package org.wfc.user.mapper;
import java.util.List;
import org.wfc.user.domain.UUser;
/**
* 用户平台_用户信息Mapper接口
*
* @author wfc
* @date 2024-11-25
*/
public interface UUserMapper
{
/**
* 查询用户平台_用户信息
*
* @param userId 用户平台_用户信息主键
* @return 用户平台_用户信息
*/
public UUser selectUUserByUserId(Long userId);
/**
* 查询用户平台_用户信息列表
*
* @param uUser 用户平台_用户信息
* @return 用户平台_用户信息集合
*/
public List<UUser> selectUUserList(UUser uUser);
/**
* 新增用户平台_用户信息
*
* @param uUser 用户平台_用户信息
* @return 结果
*/
public int insertUUser(UUser uUser);
/**
* 修改用户平台_用户信息
*
* @param uUser 用户平台_用户信息
* @return 结果
*/
public int updateUUser(UUser uUser);
/**
* 删除用户平台_用户信息
*
* @param userId 用户平台_用户信息主键
* @return 结果
*/
public int deleteUUserByUserId(Long userId);
/**
* 批量删除用户平台_用户信息
*
* @param userIds 需要删除的数据主键集合
* @return 结果
*/
public int deleteUUserByUserIds(Long[] userIds);
}

View File

@@ -1,57 +0,0 @@
package org.wfc.user.service;
import org.wfc.user.domain.SysJobLog;
import java.util.List;
/**
* 定时任务调度日志信息信息 服务层
*
* @author ruoyi
*/
public interface ISysJobLogService
{
/**
* 获取quartz调度器日志的计划任务
*
* @param jobLog 调度日志信息
* @return 调度任务日志集合
*/
public List<SysJobLog> selectJobLogList(SysJobLog jobLog);
/**
* 通过调度任务日志ID查询调度信息
*
* @param jobLogId 调度任务日志ID
* @return 调度任务日志对象信息
*/
public SysJobLog selectJobLogById(Long jobLogId);
/**
* 新增任务日志
*
* @param jobLog 调度日志信息
*/
public void addJobLog(SysJobLog jobLog);
/**
* 批量删除调度日志信息
*
* @param logIds 需要删除的日志ID
* @return 结果
*/
public int deleteJobLogByIds(Long[] logIds);
/**
* 删除任务日志
*
* @param jobId 调度日志ID
* @return 结果
*/
public int deleteJobLogById(Long jobId);
/**
* 清空任务日志
*/
public void cleanJobLog();
}

View File

@@ -1,31 +0,0 @@
package org.wfc.user.service;
import org.wfc.common.core.exception.job.TaskException;
import org.wfc.user.domain.SysJob;
import java.util.List;
/**
* 定时任务调度信息信息 服务层
*
* @author ruoyi
*/
public interface ISysJobService
{
/**
* 获取quartz调度器的计划任务
*
* @param job 调度信息
* @return 调度任务集合
*/
public List<SysJob> selectJobList(SysJob job);
/**
* 通过调度任务ID查询调度信息
*
* @param jobId 调度任务ID
* @return 调度任务对象信息
*/
public SysJob selectJobById(Long jobId);
}

View File

@@ -0,0 +1,61 @@
package org.wfc.user.service;
import java.util.List;
import org.wfc.user.domain.UUser;
/**
* 用户平台_用户信息Service接口
*
* @author wfc
* @date 2024-11-25
*/
public interface IUUserService
{
/**
* 查询用户平台_用户信息
*
* @param userId 用户平台_用户信息主键
* @return 用户平台_用户信息
*/
public UUser selectUUserByUserId(Long userId);
/**
* 查询用户平台_用户信息列表
*
* @param uUser 用户平台_用户信息
* @return 用户平台_用户信息集合
*/
public List<UUser> selectUUserList(UUser uUser);
/**
* 新增用户平台_用户信息
*
* @param uUser 用户平台_用户信息
* @return 结果
*/
public int insertUUser(UUser uUser);
/**
* 修改用户平台_用户信息
*
* @param uUser 用户平台_用户信息
* @return 结果
*/
public int updateUUser(UUser uUser);
/**
* 批量删除用户平台_用户信息
*
* @param userIds 需要删除的用户平台_用户信息主键集合
* @return 结果
*/
public int deleteUUserByUserIds(Long[] userIds);
/**
* 删除用户平台_用户信息信息
*
* @param userId 用户平台_用户信息主键
* @return 结果
*/
public int deleteUUserByUserId(Long userId);
}

View File

@@ -1,87 +0,0 @@
package org.wfc.user.service;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.wfc.user.domain.SysJobLog;
import org.wfc.user.mapper.SysJobLogMapper;
import java.util.List;
/**
* 定时任务调度日志信息 服务层
*
* @author ruoyi
*/
@Service
public class SysJobLogServiceImpl implements ISysJobLogService
{
@Autowired
private SysJobLogMapper jobLogMapper;
/**
* 获取quartz调度器日志的计划任务
*
* @param jobLog 调度日志信息
* @return 调度任务日志集合
*/
@Override
public List<SysJobLog> selectJobLogList(SysJobLog jobLog)
{
return jobLogMapper.selectJobLogList(jobLog);
}
/**
* 通过调度任务日志ID查询调度信息
*
* @param jobLogId 调度任务日志ID
* @return 调度任务日志对象信息
*/
@Override
public SysJobLog selectJobLogById(Long jobLogId)
{
return jobLogMapper.selectJobLogById(jobLogId);
}
/**
* 新增任务日志
*
* @param jobLog 调度日志信息
*/
@Override
public void addJobLog(SysJobLog jobLog)
{
jobLogMapper.insertJobLog(jobLog);
}
/**
* 批量删除调度日志信息
*
* @param logIds 需要删除的数据ID
* @return 结果
*/
@Override
public int deleteJobLogByIds(Long[] logIds)
{
return jobLogMapper.deleteJobLogByIds(logIds);
}
/**
* 删除任务日志
*
* @param jobId 调度日志ID
*/
@Override
public int deleteJobLogById(Long jobId)
{
return jobLogMapper.deleteJobLogById(jobId);
}
/**
* 清空任务日志
*/
@Override
public void cleanJobLog()
{
jobLogMapper.cleanJobLog();
}
}

View File

@@ -1,48 +0,0 @@
package org.wfc.user.service;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.wfc.user.domain.SysJob;
import org.wfc.user.mapper.SysJobMapper;
import java.util.List;
/**
* 定时任务调度信息 服务层
*
* @author ruoyi
*/
@Service
public class SysJobServiceImpl implements ISysJobService
{
@Autowired
private SysJobMapper jobMapper;
/**
* 获取quartz调度器的计划任务列表
*
* @param job 调度信息
* @return
*/
@Override
public List<SysJob> selectJobList(SysJob job)
{
return jobMapper.selectJobList(job);
}
/**
* 通过调度任务ID查询调度信息
*
* @param jobId 调度任务ID
* @return 调度任务对象信息
*/
@Override
public SysJob selectJobById(Long jobId)
{
return jobMapper.selectJobById(jobId);
}
}

View File

@@ -0,0 +1,96 @@
package org.wfc.user.service.impl;
import java.util.List;
import org.wfc.common.core.utils.DateUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.wfc.user.mapper.UUserMapper;
import org.wfc.user.domain.UUser;
import org.wfc.user.service.IUUserService;
/**
* 用户平台_用户信息Service业务层处理
*
* @author wfc
* @date 2024-11-25
*/
@Service
public class UUserServiceImpl implements IUUserService
{
@Autowired
private UUserMapper uUserMapper;
/**
* 查询用户平台_用户信息
*
* @param userId 用户平台_用户信息主键
* @return 用户平台_用户信息
*/
@Override
public UUser selectUUserByUserId(Long userId)
{
return uUserMapper.selectUUserByUserId(userId);
}
/**
* 查询用户平台_用户信息列表
*
* @param uUser 用户平台_用户信息
* @return 用户平台_用户信息
*/
@Override
public List<UUser> selectUUserList(UUser uUser)
{
return uUserMapper.selectUUserList(uUser);
}
/**
* 新增用户平台_用户信息
*
* @param uUser 用户平台_用户信息
* @return 结果
*/
@Override
public int insertUUser(UUser uUser)
{
uUser.setCreateTime(DateUtils.getNowDate());
return uUserMapper.insertUUser(uUser);
}
/**
* 修改用户平台_用户信息
*
* @param uUser 用户平台_用户信息
* @return 结果
*/
@Override
public int updateUUser(UUser uUser)
{
uUser.setUpdateTime(DateUtils.getNowDate());
return uUserMapper.updateUUser(uUser);
}
/**
* 批量删除用户平台_用户信息
*
* @param userIds 需要删除的用户平台_用户信息主键
* @return 结果
*/
@Override
public int deleteUUserByUserIds(Long[] userIds)
{
return uUserMapper.deleteUUserByUserIds(userIds);
}
/**
* 删除用户平台_用户信息信息
*
* @param userId 用户平台_用户信息主键
* @return 结果
*/
@Override
public int deleteUUserByUserId(Long userId)
{
return uUserMapper.deleteUUserByUserId(userId);
}
}

View File

@@ -1,94 +0,0 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="org.wfc.user.mapper.SysJobLogMapper">
<resultMap type="SysJobLog" id="SysJobLogResult">
<id property="jobLogId" column="job_log_id" />
<result property="jobName" column="job_name" />
<result property="jobGroup" column="job_group" />
<result property="invokeTarget" column="invoke_target" />
<result property="jobMessage" column="job_message" />
<result property="status" column="status" />
<result property="exceptionInfo" column="exception_info" />
<result property="createTime" column="create_time" />
</resultMap>
<sql id="selectJobLogVo">
select job_log_id, job_name, job_group, invoke_target, job_message, status, exception_info, create_time
from sys_job_log
</sql>
<select id="selectJobLogList" parameterType="SysJobLog" resultMap="SysJobLogResult">
<include refid="selectJobLogVo"/>
<where>
<if test="jobName != null and jobName != ''">
AND job_name like concat('%', #{jobName}, '%')
</if>
<if test="jobGroup != null and jobGroup != ''">
AND job_group = #{jobGroup}
</if>
<if test="status != null and status != ''">
AND status = #{status}
</if>
<if test="invokeTarget != null and invokeTarget != ''">
AND invoke_target like concat('%', #{invokeTarget}, '%')
</if>
<if test="params.beginTime != null and params.beginTime != ''"><!-- 开始时间检索 -->
and date_format(create_time,'%y%m%d') &gt;= date_format(#{params.beginTime},'%y%m%d')
</if>
<if test="params.endTime != null and params.endTime != ''"><!-- 结束时间检索 -->
and date_format(create_time,'%y%m%d') &lt;= date_format(#{params.endTime},'%y%m%d')
</if>
</where>
order by create_time desc
</select>
<select id="selectJobLogAll" resultMap="SysJobLogResult">
<include refid="selectJobLogVo"/>
</select>
<select id="selectJobLogById" parameterType="Long" resultMap="SysJobLogResult">
<include refid="selectJobLogVo"/>
where job_log_id = #{jobLogId}
</select>
<delete id="deleteJobLogById" parameterType="Long">
delete from sys_job_log where job_log_id = #{jobLogId}
</delete>
<delete id="deleteJobLogByIds" parameterType="Long">
delete from sys_job_log where job_log_id in
<foreach collection="array" item="jobLogId" open="(" separator="," close=")">
#{jobLogId}
</foreach>
</delete>
<update id="cleanJobLog">
truncate table sys_job_log
</update>
<insert id="insertJobLog" parameterType="SysJobLog">
insert into sys_job_log(
<if test="jobLogId != null and jobLogId != 0">job_log_id,</if>
<if test="jobName != null and jobName != ''">job_name,</if>
<if test="jobGroup != null and jobGroup != ''">job_group,</if>
<if test="invokeTarget != null and invokeTarget != ''">invoke_target,</if>
<if test="jobMessage != null and jobMessage != ''">job_message,</if>
<if test="status != null and status != ''">status,</if>
<if test="exceptionInfo != null and exceptionInfo != ''">exception_info,</if>
create_time
)values(
<if test="jobLogId != null and jobLogId != 0">#{jobLogId},</if>
<if test="jobName != null and jobName != ''">#{jobName},</if>
<if test="jobGroup != null and jobGroup != ''">#{jobGroup},</if>
<if test="invokeTarget != null and invokeTarget != ''">#{invokeTarget},</if>
<if test="jobMessage != null and jobMessage != ''">#{jobMessage},</if>
<if test="status != null and status != ''">#{status},</if>
<if test="exceptionInfo != null and exceptionInfo != ''">#{exceptionInfo},</if>
sysdate()
)
</insert>
</mapper>

View File

@@ -1,111 +0,0 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="org.wfc.user.mapper.SysJobMapper">
<resultMap type="SysJob" id="SysJobResult">
<id property="jobId" column="job_id" />
<result property="jobName" column="job_name" />
<result property="jobGroup" column="job_group" />
<result property="invokeTarget" column="invoke_target" />
<result property="cronExpression" column="cron_expression" />
<result property="misfirePolicy" column="misfire_policy" />
<result property="concurrent" column="concurrent" />
<result property="status" column="status" />
<result property="createBy" column="create_by" />
<result property="createTime" column="create_time" />
<result property="updateBy" column="update_by" />
<result property="updateTime" column="update_time" />
<result property="remark" column="remark" />
</resultMap>
<sql id="selectJobVo">
select job_id, job_name, job_group, invoke_target, cron_expression, misfire_policy, concurrent, status, create_by, create_time, remark
from sys_job
</sql>
<select id="selectJobList" parameterType="SysJob" resultMap="SysJobResult">
<include refid="selectJobVo"/>
<where>
<if test="jobName != null and jobName != ''">
AND job_name like concat('%', #{jobName}, '%')
</if>
<if test="jobGroup != null and jobGroup != ''">
AND job_group = #{jobGroup}
</if>
<if test="status != null and status != ''">
AND status = #{status}
</if>
<if test="invokeTarget != null and invokeTarget != ''">
AND invoke_target like concat('%', #{invokeTarget}, '%')
</if>
</where>
</select>
<select id="selectJobAll" resultMap="SysJobResult">
<include refid="selectJobVo"/>
</select>
<select id="selectJobById" parameterType="Long" resultMap="SysJobResult">
<include refid="selectJobVo"/>
where job_id = #{jobId}
</select>
<delete id="deleteJobById" parameterType="Long">
delete from sys_job where job_id = #{jobId}
</delete>
<delete id="deleteJobByIds" parameterType="Long">
delete from sys_job where job_id in
<foreach collection="array" item="jobId" open="(" separator="," close=")">
#{jobId}
</foreach>
</delete>
<update id="updateJob" parameterType="SysJob">
update sys_job
<set>
<if test="jobName != null and jobName != ''">job_name = #{jobName},</if>
<if test="jobGroup != null and jobGroup != ''">job_group = #{jobGroup},</if>
<if test="invokeTarget != null and invokeTarget != ''">invoke_target = #{invokeTarget},</if>
<if test="cronExpression != null and cronExpression != ''">cron_expression = #{cronExpression},</if>
<if test="misfirePolicy != null and misfirePolicy != ''">misfire_policy = #{misfirePolicy},</if>
<if test="concurrent != null and concurrent != ''">concurrent = #{concurrent},</if>
<if test="status !=null">status = #{status},</if>
<if test="remark != null and remark != ''">remark = #{remark},</if>
<if test="updateBy != null and updateBy != ''">update_by = #{updateBy},</if>
update_time = sysdate()
</set>
where job_id = #{jobId}
</update>
<insert id="insertJob" parameterType="SysJob" useGeneratedKeys="true" keyProperty="jobId">
insert into sys_job(
<if test="jobId != null and jobId != 0">job_id,</if>
<if test="jobName != null and jobName != ''">job_name,</if>
<if test="jobGroup != null and jobGroup != ''">job_group,</if>
<if test="invokeTarget != null and invokeTarget != ''">invoke_target,</if>
<if test="cronExpression != null and cronExpression != ''">cron_expression,</if>
<if test="misfirePolicy != null and misfirePolicy != ''">misfire_policy,</if>
<if test="concurrent != null and concurrent != ''">concurrent,</if>
<if test="status != null and status != ''">status,</if>
<if test="remark != null and remark != ''">remark,</if>
<if test="createBy != null and createBy != ''">create_by,</if>
create_time
)values(
<if test="jobId != null and jobId != 0">#{jobId},</if>
<if test="jobName != null and jobName != ''">#{jobName},</if>
<if test="jobGroup != null and jobGroup != ''">#{jobGroup},</if>
<if test="invokeTarget != null and invokeTarget != ''">#{invokeTarget},</if>
<if test="cronExpression != null and cronExpression != ''">#{cronExpression},</if>
<if test="misfirePolicy != null and misfirePolicy != ''">#{misfirePolicy},</if>
<if test="concurrent != null and concurrent != ''">#{concurrent},</if>
<if test="status != null and status != ''">#{status},</if>
<if test="remark != null and remark != ''">#{remark},</if>
<if test="createBy != null and createBy != ''">#{createBy},</if>
sysdate()
)
</insert>
</mapper>

View File

@@ -0,0 +1,130 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="org.wfc.user.mapper.UUserMapper">
<resultMap type="UUser" id="UUserResult">
<result property="userId" column="user_id" />
<result property="userName" column="user_name" />
<result property="nickName" column="nick_name" />
<result property="age" column="age" />
<result property="sex" column="sex" />
<result property="email" column="email" />
<result property="phone" column="phone" />
<result property="address" column="address" />
<result property="password" column="password" />
<result property="status" column="status" />
<result property="delFlag" column="del_flag" />
<result property="loginIp" column="login_ip" />
<result property="loginDate" column="login_date" />
<result property="createBy" column="create_by" />
<result property="createTime" column="create_time" />
<result property="updateBy" column="update_by" />
<result property="updateTime" column="update_time" />
<result property="remark" column="remark" />
</resultMap>
<sql id="selectUUserVo">
select user_id, user_name, nick_name, age, sex, email, phone, address, password, status, del_flag, login_ip, login_date, create_by, create_time, update_by, update_time, remark from u_user
</sql>
<select id="selectUUserList" parameterType="UUser" resultMap="UUserResult">
<include refid="selectUUserVo"/>
<where>
<if test="userName != null and userName != ''"> and user_name like concat('%', #{userName}, '%')</if>
<if test="nickName != null and nickName != ''"> and nick_name like concat('%', #{nickName}, '%')</if>
<if test="age != null and age != ''"> and age = #{age}</if>
<if test="sex != null and sex != ''"> and sex = #{sex}</if>
<if test="email != null and email != ''"> and email = #{email}</if>
<if test="phone != null and phone != ''"> and phone = #{phone}</if>
<if test="address != null and address != ''"> and address = #{address}</if>
<if test="password != null and password != ''"> and password = #{password}</if>
<if test="status != null and status != ''"> and status = #{status}</if>
<if test="loginIp != null and loginIp != ''"> and login_ip = #{loginIp}</if>
<if test="loginDate != null "> and login_date = #{loginDate}</if>
</where>
</select>
<select id="selectUUserByUserId" parameterType="Long" resultMap="UUserResult">
<include refid="selectUUserVo"/>
where user_id = #{userId}
</select>
<insert id="insertUUser" parameterType="UUser" useGeneratedKeys="true" keyProperty="userId">
insert into u_user
<trim prefix="(" suffix=")" suffixOverrides=",">
<if test="userName != null and userName != ''">user_name,</if>
<if test="nickName != null and nickName != ''">nick_name,</if>
<if test="age != null">age,</if>
<if test="sex != null">sex,</if>
<if test="email != null">email,</if>
<if test="phone != null">phone,</if>
<if test="address != null">address,</if>
<if test="password != null">password,</if>
<if test="status != null">status,</if>
<if test="delFlag != null">del_flag,</if>
<if test="loginIp != null">login_ip,</if>
<if test="loginDate != null">login_date,</if>
<if test="createBy != null">create_by,</if>
<if test="createTime != null">create_time,</if>
<if test="updateBy != null">update_by,</if>
<if test="updateTime != null">update_time,</if>
<if test="remark != null">remark,</if>
</trim>
<trim prefix="values (" suffix=")" suffixOverrides=",">
<if test="userName != null and userName != ''">#{userName},</if>
<if test="nickName != null and nickName != ''">#{nickName},</if>
<if test="age != null">#{age},</if>
<if test="sex != null">#{sex},</if>
<if test="email != null">#{email},</if>
<if test="phone != null">#{phone},</if>
<if test="address != null">#{address},</if>
<if test="password != null">#{password},</if>
<if test="status != null">#{status},</if>
<if test="delFlag != null">#{delFlag},</if>
<if test="loginIp != null">#{loginIp},</if>
<if test="loginDate != null">#{loginDate},</if>
<if test="createBy != null">#{createBy},</if>
<if test="createTime != null">#{createTime},</if>
<if test="updateBy != null">#{updateBy},</if>
<if test="updateTime != null">#{updateTime},</if>
<if test="remark != null">#{remark},</if>
</trim>
</insert>
<update id="updateUUser" parameterType="UUser">
update u_user
<trim prefix="SET" suffixOverrides=",">
<if test="userName != null and userName != ''">user_name = #{userName},</if>
<if test="nickName != null and nickName != ''">nick_name = #{nickName},</if>
<if test="age != null">age = #{age},</if>
<if test="sex != null">sex = #{sex},</if>
<if test="email != null">email = #{email},</if>
<if test="phone != null">phone = #{phone},</if>
<if test="address != null">address = #{address},</if>
<if test="password != null">password = #{password},</if>
<if test="status != null">status = #{status},</if>
<if test="delFlag != null">del_flag = #{delFlag},</if>
<if test="loginIp != null">login_ip = #{loginIp},</if>
<if test="loginDate != null">login_date = #{loginDate},</if>
<if test="createBy != null">create_by = #{createBy},</if>
<if test="createTime != null">create_time = #{createTime},</if>
<if test="updateBy != null">update_by = #{updateBy},</if>
<if test="updateTime != null">update_time = #{updateTime},</if>
<if test="remark != null">remark = #{remark},</if>
</trim>
where user_id = #{userId}
</update>
<delete id="deleteUUserByUserId" parameterType="Long">
delete from u_user where user_id = #{userId}
</delete>
<delete id="deleteUUserByUserIds" parameterType="String">
delete from u_user where user_id in
<foreach item="userId" collection="array" open="(" separator="," close=")">
#{userId}
</foreach>
</delete>
</mapper>

View File

@@ -11,7 +11,7 @@ import org.wfc.common.core.web.domain.BaseEntity;
/**
* 参数配置表 sys_config
*
* @author ruoyi
* @author wfc
*/
public class CreditCard extends BaseEntity
{

View File

@@ -18,7 +18,7 @@ import org.wfc.pay.service.ICreditCardService;
/**
* 参数配置 服务层实现
*
* @author ruoyi
* @author wfc
*/
@Service
public class CreditCardServiceImpl implements ICreditCardService

View File

@@ -47,25 +47,25 @@
<artifactId>mysql-connector-j</artifactId>
</dependency>
<!-- RuoYi Common DataSource -->
<!-- WFC Common DataSource -->
<dependency>
<groupId>org.wfc</groupId>
<artifactId>wfc-common-datasource</artifactId>
</dependency>
<!-- RuoYi Common DataScope -->
<!-- WFC Common DataScope -->
<dependency>
<groupId>org.wfc</groupId>
<artifactId>wfc-common-datascope</artifactId>
</dependency>
<!-- RuoYi Common Log -->
<!-- WFC Common Log -->
<dependency>
<groupId>org.wfc</groupId>
<artifactId>wfc-common-log</artifactId>
</dependency>
<!-- RuoYi Common Swagger -->
<!-- WFC Common Swagger -->
<dependency>
<groupId>org.wfc</groupId>
<artifactId>wfc-common-swagger</artifactId>

View File

@@ -8,7 +8,7 @@ import org.wfc.common.security.annotation.EnableRyFeignClients;
/**
* 系统模块
*
* @author ruoyi
* @author wfc
*/
@EnableCustomConfig
@EnableRyFeignClients

View File

@@ -26,7 +26,7 @@ import org.wfc.system.service.ISysConfigService;
/**
* 参数配置 信息操作处理
*
* @author ruoyi
* @author wfc
*/
@RestController
@RequestMapping("/config")

View File

@@ -21,7 +21,7 @@ import java.util.List;
/**
* 部门信息
*
* @author ruoyi
* @author wfc
*/
@RestController
@RequestMapping("/dept")

View File

@@ -29,7 +29,7 @@ import org.wfc.system.service.ISysDictTypeService;
/**
* 数据字典信息
*
* @author ruoyi
* @author wfc
*/
@RestController
@RequestMapping("/dict/data")

View File

@@ -26,7 +26,7 @@ import org.wfc.system.service.ISysDictTypeService;
/**
* 数据字典信息
*
* @author ruoyi
* @author wfc
*/
@RestController
@RequestMapping("/dict/type")

View File

@@ -26,7 +26,7 @@ import org.wfc.system.service.ISysLogininforService;
/**
* 系统访问记录
*
* @author ruoyi
* @author wfc
*/
@RestController
@RequestMapping("/logininfor")

View File

@@ -24,7 +24,7 @@ import java.util.Map;
/**
* 菜单信息
*
* @author ruoyi
* @author wfc
*/
@RestController
@RequestMapping("/menu")

View File

@@ -24,7 +24,7 @@ import org.wfc.system.service.ISysNoticeService;
/**
* 公告 信息操作处理
*
* @author ruoyi
* @author wfc
*/
@RestController
@RequestMapping("/notice")

View File

@@ -24,7 +24,7 @@ import org.wfc.system.service.ISysOperLogService;
/**
* 操作日志记录
*
* @author ruoyi
* @author wfc
*/
@RestController
@RequestMapping("/operlog")

View File

@@ -26,7 +26,7 @@ import org.wfc.system.service.ISysPostService;
/**
* 岗位信息操作处理
*
* @author ruoyi
* @author wfc
*/
@RestController
@RequestMapping("/post")

View File

@@ -29,7 +29,7 @@ import org.wfc.system.service.ISysUserService;
/**
* 个人信息 业务处理
*
* @author ruoyi
* @author wfc
*/
@RestController
@RequestMapping("/user/profile")

View File

@@ -31,7 +31,7 @@ import org.wfc.system.service.ISysUserService;
/**
* 角色信息
*
* @author ruoyi
* @author wfc
*/
@RestController
@RequestMapping("/role")

View File

@@ -48,7 +48,7 @@ import java.util.stream.Collectors;
/**
* 用户信息
*
* @author ruoyi
* @author wfc
*/
@RestController
@RequestMapping("/user")

View File

@@ -26,7 +26,7 @@ import org.wfc.system.service.ISysUserOnlineService;
/**
* 在线用户监控
*
* @author ruoyi
* @author wfc
*/
@RestController
@RequestMapping("/online")

View File

@@ -11,7 +11,7 @@ import org.wfc.common.core.web.domain.BaseEntity;
/**
* 参数配置表 sys_config
*
* @author ruoyi
* @author wfc
*/
public class SysConfig extends BaseEntity
{

View File

@@ -12,7 +12,7 @@ import org.wfc.common.core.web.domain.BaseEntity;
/**
* 菜单权限表 sys_menu
*
* @author ruoyi
* @author wfc
*/
public class SysMenu extends BaseEntity
{

View File

@@ -10,7 +10,7 @@ import org.wfc.common.core.xss.Xss;
/**
* 通知公告表 sys_notice
*
* @author ruoyi
* @author wfc
*/
public class SysNotice extends BaseEntity
{

View File

@@ -12,7 +12,7 @@ import org.wfc.common.core.web.domain.BaseEntity;
/**
* 岗位表 sys_post
*
* @author ruoyi
* @author wfc
*/
public class SysPost extends BaseEntity
{

View File

@@ -6,7 +6,7 @@ import org.apache.commons.lang3.builder.ToStringStyle;
/**
* 角色和部门关联 sys_role_dept
*
* @author ruoyi
* @author wfc
*/
public class SysRoleDept
{

View File

@@ -6,7 +6,7 @@ import org.apache.commons.lang3.builder.ToStringStyle;
/**
* 角色和菜单关联 sys_role_menu
*
* @author ruoyi
* @author wfc
*/
public class SysRoleMenu
{

View File

@@ -3,7 +3,7 @@ package org.wfc.system.domain;
/**
* 当前在线会话
*
* @author ruoyi
* @author wfc
*/
public class SysUserOnline
{

View File

@@ -6,7 +6,7 @@ import org.apache.commons.lang3.builder.ToStringStyle;
/**
* 用户和岗位关联 sys_user_post
*
* @author ruoyi
* @author wfc
*/
public class SysUserPost
{

View File

@@ -6,7 +6,7 @@ import org.apache.commons.lang3.builder.ToStringStyle;
/**
* 用户和角色关联 sys_user_role
*
* @author ruoyi
* @author wfc
*/
public class SysUserRole
{

View File

@@ -5,7 +5,7 @@ import org.wfc.common.core.utils.StringUtils;
/**
* 路由显示信息
*
* @author ruoyi
* @author wfc
*/
public class MetaVo
{

View File

@@ -6,7 +6,7 @@ import java.util.List;
/**
* 路由配置信息
*
* @author ruoyi
* @author wfc
*/
@JsonInclude(JsonInclude.Include.NON_EMPTY)
public class RouterVo

View File

@@ -10,7 +10,7 @@ import org.wfc.system.domain.SysMenu;
/**
* Treeselect树结构实体类
*
* @author ruoyi
* @author wfc
*/
public class TreeSelect implements Serializable
{

View File

@@ -6,7 +6,7 @@ import org.wfc.system.domain.SysConfig;
/**
* 参数配置 数据层
*
* @author ruoyi
* @author wfc
*/
public interface SysConfigMapper
{

View File

@@ -7,7 +7,7 @@ import org.wfc.system.api.domain.SysDept;
/**
* 部门管理 数据层
*
* @author ruoyi
* @author wfc
*/
public interface SysDeptMapper
{

View File

@@ -7,7 +7,7 @@ import org.wfc.system.api.domain.SysDictData;
/**
* 字典表 数据层
*
* @author ruoyi
* @author wfc
*/
public interface SysDictDataMapper
{

View File

@@ -6,7 +6,7 @@ import org.wfc.system.api.domain.SysDictType;
/**
* 字典表 数据层
*
* @author ruoyi
* @author wfc
*/
public interface SysDictTypeMapper
{

View File

@@ -6,7 +6,7 @@ import org.wfc.system.api.domain.SysLogininfor;
/**
* 系统访问日志情况信息 数据层
*
* @author ruoyi
* @author wfc
*/
public interface SysLogininforMapper
{

View File

@@ -7,7 +7,7 @@ import org.wfc.system.domain.SysMenu;
/**
* 菜单表 数据层
*
* @author ruoyi
* @author wfc
*/
public interface SysMenuMapper
{

View File

@@ -6,7 +6,7 @@ import org.wfc.system.domain.SysNotice;
/**
* 通知公告表 数据层
*
* @author ruoyi
* @author wfc
*/
public interface SysNoticeMapper
{

Some files were not shown because too many files have changed in this diff Show More