bonus
/
emergencyRap
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

SQLLINE 数据库

This commit is contained in:
haozq 2025-09-26 10:58:44 +08:00
parent 8d9f1afc64
commit e03399c868
12 changed files with 120 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

50
pom.xml
View File

@ -67,7 +67,57 @@
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-quartz</artifactId>
</dependency>
<!--H2数据库-->
<dependency>
<groupId>com.h2database</groupId>
<artifactId>h2</artifactId>
<version>1.4.199</version>
<scope>test</scope>
</dependency>
<!--mp-->
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-boot-starter</artifactId>
<version>3.4.2</version>
</dependency>
<!--springmvc-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!-- Spring Boot Starter MyBatis -->
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>2.2.0</version>
</dependency>
<!--sqlite-->
<dependency>
<groupId>org.xerial</groupId>
<artifactId>sqlite-jdbc</artifactId>
<version>3.40.1.0</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>
<!--mysql驱动-->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>5.1.47</version>
</dependency>
<!-- lombok -->
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</dependency>
</dependencies>

6
src/main/java/com/bonus/emergencyrap/constant/TextConstants.java
View File

@ -4,10 +4,14 @@ package com.bonus.emergencyrap.constant;
* 文本文件名称
*/
public class TextConstants {
public static final String PLATFORM = "platform";
/**
* 系统管理
*/
public static final String PLATFORM = "platform";
public static final String DB_CONFIG = "dbconfig";
/**
* 任务管理
*/

14
src/main/java/com/bonus/emergencyrap/mapper/LoginMapper.java Normal file
View File

@ -0,0 +1,14 @@
package com.bonus.emergencyrap.mapper;
import com.bonus.emergencyrap.vo.LoginFormVo;
import org.apache.ibatis.annotations.Mapper;
@Mapper
public interface LoginMapper {
/**
* 系统登录
* @param loginFormVo
* @return
*/
LoginFormVo login(LoginFormVo loginFormVo);
}

18
src/main/java/com/bonus/emergencyrap/service/loginServiceImpl.java
View File

@ -1,12 +1,14 @@
package com.bonus.emergencyrap.service;
import com.bonus.emergencyrap.constant.SecurityConstants;
import com.bonus.emergencyrap.mapper.LoginMapper;
import com.bonus.emergencyrap.utils.JwtUtils;
import com.bonus.emergencyrap.utils.ResourceLineReader;
import com.bonus.emergencyrap.utils.StringUtils;
import com.bonus.emergencyrap.vo.AjaxResult;
import com.bonus.emergencyrap.vo.LoginFormVo;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.HashMap;
@ -17,6 +19,9 @@ import java.util.Map;
@Service
public class loginServiceImpl implements LoginService{
@Autowired
private LoginMapper mapper;
@Override
public AjaxResult login(LoginFormVo loginFormVo) {
@ -24,16 +29,17 @@ public class loginServiceImpl implements LoginService{
if (StringUtils.isEmpty(loginFormVo.getUsername()) || StringUtils.isEmpty(loginFormVo.getPassword())) {
return AjaxResult.error("请输入账号密码!");
}
Map<String, String> map = ResourceLineReader.getLineMaps("conf.properties","=");
if (loginFormVo.getUsername().equals(map.get("username")) && loginFormVo.getPassword().equals(map.get("password"))) {
Map<String, Object> claimsMap = new HashMap<String, Object>(16);
claimsMap.put(SecurityConstants.USER_KEY, 1);
claimsMap.put(SecurityConstants.DETAILS_USERNAME, map.get("username"));
LoginFormVo user= mapper.login(loginFormVo);
if(user!=null && StringUtils.isNotEmpty(user.getUserId())){
Map<String, Object> claimsMap = new HashMap<String, Object>(3);
claimsMap.put(SecurityConstants.USER_KEY, user.getUserId());
claimsMap.put(SecurityConstants.DETAILS_USERNAME,user.getUsername());
// 接口返回信息
String token = JwtUtils.createToken(claimsMap);
return AjaxResult.success("登录成功", token);
}else{
return AjaxResult.error("账号/密码错误!");
}
return AjaxResult.error("账号/密码错误!");
} catch (Exception e) {
log.error(e.toString(),e);
}

2
src/main/java/com/bonus/emergencyrap/task/job/ScanJob.java
View File

@ -50,7 +50,7 @@ public class ScanJob implements Job {
service.deleteJob(vo);
} else{
//添加或者修改定时任务
service.addTask(vo);
service.addTask(vo,ActuatorJob.class);
}
}
}

2
src/main/java/com/bonus/emergencyrap/task/job/UpdateSuccessJob.java
View File

@ -44,7 +44,7 @@ public class UpdateSuccessJob implements Job {
TaskVo vo= JSON.parseObject(json, TaskVo.class);
vo.setIsSuccess("0");
vo.setFailNum(0);
appendToFile(filePtah,json,key,true);
appendToFile(filePtah,json,key,false);
}

9
src/main/java/com/bonus/emergencyrap/task/service/QuartzJobService.java
View File

@ -59,9 +59,9 @@ public class QuartzJobService {
// 使用cron表达式调度
public void addTask(TaskVo vo) throws SchedulerException {
public void addTask(TaskVo vo,Class<? extends Job> jobClass) throws SchedulerException {
// 定义任务
JobDetail jobDetail = JobBuilder.newJob(ActuatorJob.class)
JobDetail jobDetail = JobBuilder.newJob(jobClass)
.withIdentity(vo.getTaskId(), defeatGroup)
.withDescription("Cron定时任务")
.storeDurably()
@ -92,12 +92,13 @@ public class QuartzJobService {
vo.setTaskId("555555555555");
vo.setTime(taskIntervalSeconds);
vo.setTaskName("定时任务扫描器");
startSampleJobWithSimpleTrigger(vo);
// startSampleJobWithSimpleTrigger(vo);
TaskVo vo2=new TaskVo();
vo2.setTaskId("9999999999999");
vo2.setTaskName("刷新任务的失败次数及成功率");
vo2.setCorn("0 0 1 * * ?");
addTask(vo2);
vo2.setCorn("0/40 * * * * ?");
// addTask(vo2,UpdateSuccessJob.class);
}
// 暂停任务

2
src/main/java/com/bonus/emergencyrap/vo/LoginFormVo.java
View File

@ -5,6 +5,8 @@ import lombok.Data;
@Data
public class LoginFormVo {
private String userId;
private String username;
private String password;

8
src/main/java/com/bonus/emergencyrap/vo/TaskVo.java
View File

@ -18,7 +18,9 @@ public class TaskVo {
* 任务名称
*/
private String taskName;
/**
* 系统表id
*/
private String systemId;
/**
@ -115,7 +117,9 @@ public class TaskVo {
* 失败次数
*/
private int failNum;
/**
* 时间秒
*/
private int time;

15
src/main/resources/application.yml
View File

@ -47,12 +47,20 @@ spring:
# 热部署开关
enabled: true
datasource:
url: jdbc:sqlite:D:\File\text\emergency_rpa.db
driver-class-name: org.sqlite.JDBC
jpa:
hibernate:
ddl-auto: update
show-sql: true
database-platform: org.hibernate.community.dialect.SQLiteDialect
file:
path:
windows: D:/File/text/
linux: /data/text/
# token配置
token:
# 令牌自定义标识
@ -67,6 +75,11 @@ task:
seconds: 60
mybatis:
mapper-locations: classpath:mapper/*Mapper.xml

BIN
src/main/resources/db/emergency_rpa.db Normal file
View File

Binary file not shown.

10
src/main/resources/mapper/LoginMapper.xml Normal file
View File

@ -0,0 +1,10 @@
<?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="com.bonus.emergencyrap.mapper.LoginMapper">
<select id="login" resultType="com.bonus.emergencyrap.vo.LoginFormVo">
select user_name username,password,id userId
from sys_user
where user_name=#{username} and password=#{password}
</select>
</mapper>