diff --git a/.idea/.gitignore b/.idea/.gitignore
deleted file mode 100644
index 01b5f8c..0000000
--- a/.idea/.gitignore
+++ /dev/null
@@ -1,10 +0,0 @@
-# 默认忽略的文件
-/shelf/
-/workspace.xml
-# 基于编辑器的 HTTP 客户端请求
-/httpRequests/
-# Datasource local storage ignored files
-/dataSources/
-/dataSources.local.xml
-# GitHub Copilot persisted chat sessions
-/copilot/chatSessions
diff --git a/.idea/compiler.xml b/.idea/compiler.xml
index 45e8b10..73943a2 100644
--- a/.idea/compiler.xml
+++ b/.idea/compiler.xml
@@ -17,24 +17,19 @@
-
-
+
\ No newline at end of file
diff --git a/.idea/jarRepositories.xml b/.idea/jarRepositories.xml
index 2b124b9..38e2802 100644
--- a/.idea/jarRepositories.xml
+++ b/.idea/jarRepositories.xml
@@ -11,15 +11,20 @@
+
+
+
+
+
-
-
-
+
+
+
@@ -31,6 +36,11 @@
+
+
+
+
+
diff --git a/.idea/misc.xml b/.idea/misc.xml
index dc13fb0..a9e03b0 100644
--- a/.idea/misc.xml
+++ b/.idea/misc.xml
@@ -5,17 +5,19 @@
+
-
+
\ No newline at end of file
diff --git a/hoe-admin/admin-boot/pom.xml b/hoe-admin/admin-boot/pom.xml
index f3f9b61..84e3d7b 100644
--- a/hoe-admin/admin-boot/pom.xml
+++ b/hoe-admin/admin-boot/pom.xml
@@ -12,8 +12,8 @@
admin-boot
- 8
- 8
+ 17
+ 17
UTF-8
@@ -36,6 +36,19 @@
spring-cloud-starter-bootstrap
+
+
+ org.hibernate.validator
+ hibernate-validator
+ 6.2.0.Final
+
+
+
+ org.glassfish
+ jakarta.el
+ 3.0.3
+
+
com.alibaba.cloud
@@ -108,13 +121,9 @@
com.nimbusds
nimbus-jose-jwt
+ 9.22
-
- com.recovery
- common-redis
- ${hoe-version}
-
com.recovery
common-mybatis-plus
@@ -125,6 +134,10 @@
common-web
${hoe-version}
+
+ jakarta.validation
+ jakarta.validation-api
+
diff --git a/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/config/ds/DataSourceConfig.java b/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/config/ds/DataSourceConfig.java
index fa3d126..70946b2 100644
--- a/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/config/ds/DataSourceConfig.java
+++ b/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/config/ds/DataSourceConfig.java
@@ -1,17 +1,16 @@
package com.recovery.admin.boot.config.ds;
import com.alibaba.druid.pool.DruidDataSource;
-
import com.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean;
-
import com.recovery.common.base.ds.DynamicDataSource;
import lombok.extern.slf4j.Slf4j;
import org.apache.ibatis.session.SqlSessionFactory;
-import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.SqlSessionTemplate;
import org.mybatis.spring.annotation.MapperScan;
+import org.mybatis.spring.transaction.SpringManagedTransactionFactory;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
@@ -66,7 +65,7 @@ public class DataSourceConfig {
map.put("master", masterDataSource);
dynamicDataSource.setTargetDataSources(map);
//设置默认数据源
-// dynamicDataSource.setDefaultTargetDataSource(masterDataSource);
+ dynamicDataSource.setDefaultTargetDataSource(masterDataSource);
//
return dynamicDataSource;
}
@@ -76,10 +75,13 @@ public class DataSourceConfig {
public SqlSessionFactory sqlSessionFactory(
@Qualifier("commonDataSource") DataSource dynamicDataSource)
throws Exception {
+// SqlSessionFactoryBean
+// bean = new SqlSessionFactoryBean();
MybatisSqlSessionFactoryBean bean = new MybatisSqlSessionFactoryBean();
bean.setDataSource(dynamicDataSource);
bean.setMapperLocations(new PathMatchingResourcePatternResolver()
.getResources(DataSourceConfig.MAPPER_LOCATION));
+ bean.setTransactionFactory(new SpringManagedTransactionFactory());
return bean.getObject();
}
diff --git a/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/config/ds/DataSourceProxyConfig.java b/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/config/ds/DataSourceProxyConfig.java
new file mode 100644
index 0000000..9d3cc4f
--- /dev/null
+++ b/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/config/ds/DataSourceProxyConfig.java
@@ -0,0 +1,50 @@
+//package com.recovery.admin.boot.config.ds;
+//
+//
+//
+//import com.alibaba.druid.pool.DruidDataSource;
+//import com.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean;
+//import io.seata.rm.datasource.DataSourceProxy;
+//import org.apache.ibatis.session.SqlSessionFactory;
+//import org.mybatis.spring.SqlSessionFactoryBean;
+//import org.mybatis.spring.transaction.SpringManagedTransactionFactory;
+//import org.springframework.beans.factory.annotation.Value;
+//import org.springframework.boot.context.properties.ConfigurationProperties;
+//import org.springframework.context.annotation.Bean;
+//import org.springframework.context.annotation.Configuration;
+//import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
+//
+//import javax.sql.DataSource;
+//
+//
+////使用seata对DataSource进行代理
+//@Configuration
+//public class DataSourceProxyConfig {
+//
+// //mapper.xml路径
+// static final String MAPPER_LOCATION = "classpath:mapper/*.xml";
+//
+// //手动配置bean
+// @Bean
+// @ConfigurationProperties(prefix = "master.datasource")
+// public DataSource druidDataSource(){
+//
+// return new DruidDataSource();
+// }
+//
+// @Bean
+// public SqlSessionFactory sessionFactory(DataSourceProxy dataSourceProxy) throws Exception {
+// MybatisSqlSessionFactoryBean sessionFactoryBean = new MybatisSqlSessionFactoryBean();
+// sessionFactoryBean.setDataSource(dataSourceProxy);
+// sessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources(MAPPER_LOCATION));
+// //事务管理工厂
+// sessionFactoryBean.setTransactionFactory(new SpringManagedTransactionFactory());
+// return sessionFactoryBean.getObject();
+// }
+//
+// @Bean
+// public DataSourceProxy dataSource() {
+// DataSource source = druidDataSource();
+// return new DataSourceProxy(druidDataSource());
+// }
+//}
diff --git a/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/controller/OauthClientController.java b/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/controller/OauthClientController.java
deleted file mode 100644
index dc8349d..0000000
--- a/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/controller/OauthClientController.java
+++ /dev/null
@@ -1,35 +0,0 @@
-//package com.recovery.admin.boot.controller;
-//
-//import cn.hutool.core.bean.BeanUtil;
-//import cn.hutool.core.lang.Assert;
-//
-//import com.recovery.admin.boot.entity.SysOauthClient;
-//import com.recovery.admin.boot.service.ISysOauthClientService;
-//
-//import com.recovery.common.base.dto.OAuth2ClientDTO;
-//import com.recovery.common.base.result.ApiResult;
-//import lombok.AllArgsConstructor;
-//import lombok.extern.slf4j.Slf4j;
-//import org.springframework.web.bind.annotation.GetMapping;
-//import org.springframework.web.bind.annotation.RequestMapping;
-//import org.springframework.web.bind.annotation.RequestParam;
-//import org.springframework.web.bind.annotation.RestController;
-///**
-// * @author:
-// */
-//@RequestMapping("/api/oauth-clients")
-//@Slf4j
-//@AllArgsConstructor
-//@RestController
-//public class OauthClientController {
-// private ISysOauthClientService iSysOauthClientService;
-//
-// @GetMapping("/getOAuth2ClientById")
-// public ApiResult getOAuth2ClientById(@RequestParam String clientId) {
-// SysOauthClient client = iSysOauthClientService.getById(clientId);
-// Assert.notNull(client, "OAuth2 客户端不存在");
-// OAuth2ClientDTO oAuth2ClientDTO = new OAuth2ClientDTO();
-// BeanUtil.copyProperties(client, oAuth2ClientDTO);
-// return ApiResult.ok(oAuth2ClientDTO);
-// }
-//}
diff --git a/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/controller/UserController.java b/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/controller/UserController.java
index 86a4c69..38ce2ab 100644
--- a/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/controller/UserController.java
+++ b/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/controller/UserController.java
@@ -1,7 +1,6 @@
package com.recovery.admin.boot.controller;
-import com.recovery.admin.boot.service.IMemberUserService;
import com.recovery.admin.boot.service.UserService;
import com.recovery.common.base.dto.MemberUserAuthDTO;
@@ -22,7 +21,6 @@ public class UserController {
private final UserService userService;
- private final IMemberUserService memberUserService;
/**
* 获取用户信息
@@ -32,13 +30,5 @@ public class UserController {
UserAuthDTO user = userService.getByUsername(username);
return ApiResult.ok(user);
}
- /**
- * 获取会员用户信息
- */
- @GetMapping("/member/username/{username}")
- public ApiResult getMemberUserByUsername(@PathVariable String username) {
- log.info("获取member user info。。。");
- MemberUserAuthDTO user = memberUserService.getByUsername(username);
- return ApiResult.ok(user);
- }
+
}
diff --git a/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/controller/testController.java b/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/controller/testController.java
index 03b71a6..9817d58 100644
--- a/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/controller/testController.java
+++ b/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/controller/testController.java
@@ -40,13 +40,20 @@ public class testController {
*/
@GetMapping("/cs")
public ApiResult cs(@RequestParam String name, HttpServletRequest request) {
- User user = new User();
- user.setUserName("测试库");
- user.setPhone("123");
- userService.add(user);
+ try {
+ User user = new User();
+ user.setUserName("测试库");
+ user.setPhone("123");
+ List list = userService.list();
+ log.info("测试库:"+list.size());
+ }catch (Exception e) {
+ return ApiResult.failed(e.getMessage());
+ }
+
// try {
// UserAuthDTO authDTO = userService.getByUsername(name);
// List l = userService.list();
+
// log.info("测试库:"+authDTO.getStatus());
// log.info("111获取线程的数据=="+HspHostUtil.getHspHost());
// log.info("获取登陆值去除------"+ UtilTools.getUserId() +"");
@@ -67,7 +74,7 @@ public class testController {
// log.info("cs异常"+e.getMessage(),e);
// return ApiResult.failed("cs异常");
// }
- return ApiResult.failed("cs异常");
+ return ApiResult.ok();
}
diff --git a/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/interceptor/JwtInterceptor.java b/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/interceptor/JwtInterceptor.java
index 5374865..a99ce92 100644
--- a/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/interceptor/JwtInterceptor.java
+++ b/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/interceptor/JwtInterceptor.java
@@ -27,20 +27,6 @@ public class JwtInterceptor implements HandlerInterceptor {
public JwtInterceptor() {}
@Override
public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
- response.setHeader( "Set-Cookie" , "cookiename=httponlyTest;Path=/;Domain=domainvalue;Max-Age=seconds;HTTPOnly");
- response.setHeader( "Content-Security-Policy" , "default-src 'self'; script-src 'self'; frame-ancestors 'self'");
- response.setHeader("Access-Control-Allow-Origin", (request).getHeader("Origin"));
- response.setHeader("Access-Control-Allow-Credentials", "true");
- response.setHeader("Referrer-Policy","no-referrer");
- response.setContentType("application/json");
- response.setCharacterEncoding("UTF-8");
- // 如果请求的header里面的SA-SAME-TOKEN 值和Authorization 值一样,就视为是内部接口调用,就直接返回ture
- // 不在进行认证的相关逻辑。为什么相等时就视为是内部接口调用呢?请看上面的第一部分的feign拦截器的写法。
- String saSameId = request.getHeader("SA-SAME-TOKEN");
- String stoken = request.getHeader("Authorization");
- if(saSameId.equals(stoken)){
- return true;
- }
// 获取当前token(这个token获取的是请求头的token,也可以用 request 获取)
String token = StpUtil.getTokenValue();
long tokenTimeout = StpUtil.getTokenTimeout();// 获取过期时间
diff --git a/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/listener/InitResourcePermissionCache.java b/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/listener/InitResourcePermissionCache.java
index 38acbfd..2f357dc 100644
--- a/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/listener/InitResourcePermissionCache.java
+++ b/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/listener/InitResourcePermissionCache.java
@@ -1,7 +1,6 @@
package com.recovery.admin.boot.listener;
-import com.recovery.admin.boot.service.ISysPermissionService;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.CommandLineRunner;
@@ -15,7 +14,6 @@ import org.springframework.stereotype.Component;
@AllArgsConstructor
public class InitResourcePermissionCache implements CommandLineRunner {
- private ISysPermissionService iSysPermissionService;
@Override
public void run(String... args) {
diff --git a/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/mapper/MemberUserMapper.java b/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/mapper/MemberUserMapper.java
deleted file mode 100644
index 5cce7f2..0000000
--- a/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/mapper/MemberUserMapper.java
+++ /dev/null
@@ -1,18 +0,0 @@
-package com.recovery.admin.boot.mapper;
-
-
-import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-import com.recovery.admin.boot.entity.MemberUser;
-
-import com.recovery.common.base.dto.MemberUserAuthDTO;
-import org.apache.ibatis.annotations.Mapper;
-import org.apache.ibatis.annotations.Param;
-
-/**
- * @author:
- */
-@Mapper
-public interface MemberUserMapper extends BaseMapper {
-
- MemberUserAuthDTO getByUsername(@Param("userName") String userName);
-}
diff --git a/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/mapper/SysOauthClientMapper.java b/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/mapper/SysOauthClientMapper.java
deleted file mode 100644
index 27ff71a..0000000
--- a/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/mapper/SysOauthClientMapper.java
+++ /dev/null
@@ -1,12 +0,0 @@
-package com.recovery.admin.boot.mapper;
-
-
-import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-import com.recovery.admin.boot.entity.SysOauthClient;
-import org.apache.ibatis.annotations.Mapper;
-/**
- * @author:
- */
-@Mapper
-public interface SysOauthClientMapper extends BaseMapper {
-}
diff --git a/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/mapper/SysPermissionMapper.java b/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/mapper/SysPermissionMapper.java
deleted file mode 100644
index 3a28a5c..0000000
--- a/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/mapper/SysPermissionMapper.java
+++ /dev/null
@@ -1,16 +0,0 @@
-package com.recovery.admin.boot.mapper;
-
-
-import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-import com.recovery.admin.boot.entity.SysPermission;
-import org.apache.ibatis.annotations.Mapper;
-
-import java.util.List;
-/**
- * @author:
- */
-@Mapper
-public interface SysPermissionMapper extends BaseMapper {
-
- List listPermRoles();
-}
diff --git a/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/rest/UserRest.java b/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/rest/UserRest.java
index f8331db..ce6ec3c 100644
--- a/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/rest/UserRest.java
+++ b/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/rest/UserRest.java
@@ -1,7 +1,6 @@
package com.recovery.admin.boot.rest;
-import com.recovery.admin.boot.service.IMemberUserService;
import com.recovery.admin.boot.service.UserService;
import com.recovery.common.base.dto.MemberUserAuthDTO;
import com.recovery.common.base.dto.UserAuthDTO;
@@ -21,8 +20,7 @@ public class UserRest {
@Resource
private UserService userService;
- @Resource
- private IMemberUserService memberUserService;
+
/**
* 获取用户信息
@@ -35,13 +33,4 @@ public class UserRest {
}
return ApiResult.ok(user);
}
- /**12
- * 获取会员用户信息
- */
- @GetMapping("/member/username/{username}")
- public ApiResult getMemberUserByUsername(@RequestParam(value = "username") String username) {
- log.info("获取member user info。。。");
- MemberUserAuthDTO user = memberUserService.getByUsername(username);
- return ApiResult.ok(user);
- }
}
diff --git a/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/service/IMemberUserService.java b/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/service/IMemberUserService.java
deleted file mode 100644
index 2730dcd..0000000
--- a/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/service/IMemberUserService.java
+++ /dev/null
@@ -1,25 +0,0 @@
-package com.recovery.admin.boot.service;
-
-
-
-
-import com.baomidou.mybatisplus.extension.service.IService;
-import com.recovery.admin.boot.entity.MemberUser;
-import com.recovery.common.base.dto.MemberUserAuthDTO;
-
-
-/**
- * @author:
- */
-public interface IMemberUserService extends IService {
-
-
- /**
- * 根据用户名获取认证用户信息,携带角色和密码
- *
- * @param username
- * @return
- */
- MemberUserAuthDTO getByUsername(String username);
-
-}
diff --git a/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/service/ISysOauthClientService.java b/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/service/ISysOauthClientService.java
deleted file mode 100644
index 941110a..0000000
--- a/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/service/ISysOauthClientService.java
+++ /dev/null
@@ -1,11 +0,0 @@
-package com.recovery.admin.boot.service;
-
-
-import com.baomidou.mybatisplus.extension.service.IService;
-import com.recovery.admin.boot.entity.SysOauthClient;
-
-/**
- * @author:
- */
-public interface ISysOauthClientService extends IService {
-}
diff --git a/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/service/ISysPermissionService.java b/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/service/ISysPermissionService.java
deleted file mode 100644
index b02eb83..0000000
--- a/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/service/ISysPermissionService.java
+++ /dev/null
@@ -1,17 +0,0 @@
-package com.recovery.admin.boot.service;
-
-import com.baomidou.mybatisplus.extension.service.IService;
-import com.recovery.admin.boot.entity.SysPermission;
-
-import java.util.List;
-/**
- * @author:
- */
-public interface ISysPermissionService extends IService {
- /**
- * 刷新Redis缓存中角色菜单的权限规则,角色和菜单信息变更调用
- */
- boolean refreshPermRolesRules();
-
- List listPermRoles();
-}
diff --git a/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/service/impl/MemberUserServiceImpl.java b/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/service/impl/MemberUserServiceImpl.java
deleted file mode 100644
index b9762ac..0000000
--- a/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/service/impl/MemberUserServiceImpl.java
+++ /dev/null
@@ -1,24 +0,0 @@
-package com.recovery.admin.boot.service.impl;
-
-import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import com.recovery.admin.boot.entity.MemberUser;
-import com.recovery.admin.boot.mapper.MemberUserMapper;
-import com.recovery.admin.boot.service.IMemberUserService;
-
-import com.recovery.common.base.dto.MemberUserAuthDTO;
-import lombok.RequiredArgsConstructor;
-import org.springframework.stereotype.Service;
-
-/**
- * @author:
- */
-@Service
-@RequiredArgsConstructor
-public class MemberUserServiceImpl extends ServiceImpl implements IMemberUserService {
- @Override
- public MemberUserAuthDTO getByUsername(String username) {
- MemberUserAuthDTO memberUserAuthDTO = this.baseMapper.getByUsername(username);
- return memberUserAuthDTO;
- }
-
-}
diff --git a/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/service/impl/SysOauthClientServiceImpl.java b/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/service/impl/SysOauthClientServiceImpl.java
deleted file mode 100644
index 84fbb98..0000000
--- a/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/service/impl/SysOauthClientServiceImpl.java
+++ /dev/null
@@ -1,19 +0,0 @@
-package com.recovery.admin.boot.service.impl;
-
-
-
-import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import com.recovery.admin.boot.entity.SysOauthClient;
-import com.recovery.admin.boot.mapper.SysOauthClientMapper;
-import com.recovery.admin.boot.service.ISysOauthClientService;
-import lombok.RequiredArgsConstructor;
-import org.springframework.stereotype.Service;
-
-/**
- * @author:
- */
-@Service
-@RequiredArgsConstructor
-public class SysOauthClientServiceImpl extends ServiceImpl implements ISysOauthClientService {
-
-}
diff --git a/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/service/impl/SysPermissionServiceImpl.java b/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/service/impl/SysPermissionServiceImpl.java
deleted file mode 100644
index 9e77aae..0000000
--- a/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/service/impl/SysPermissionServiceImpl.java
+++ /dev/null
@@ -1,57 +0,0 @@
-package com.recovery.admin.boot.service.impl;
-
-import cn.hutool.core.collection.CollectionUtil;
-import cn.hutool.core.util.StrUtil;
-
-import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import com.recovery.admin.boot.entity.SysPermission;
-import com.recovery.admin.boot.mapper.SysPermissionMapper;
-import com.recovery.admin.boot.service.ISysPermissionService;
-import com.recovery.common.base.constant.GlobalConstants;
-import lombok.RequiredArgsConstructor;
-import org.springframework.data.redis.core.RedisTemplate;
-import org.springframework.stereotype.Service;
-
-import java.util.Arrays;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.stream.Collectors;
-
-
-/**
- * @author:
- */
-@Service
-@RequiredArgsConstructor
-public class SysPermissionServiceImpl extends ServiceImpl implements ISysPermissionService {
-
- private final RedisTemplate redisTemplate;
-
- @Override
- public boolean refreshPermRolesRules() {
- redisTemplate.delete(Arrays.asList(GlobalConstants.URL_PERM_ROLES_KEY));
- List permissions = this.listPermRoles();
- if (CollectionUtil.isNotEmpty(permissions)) {
- // 初始化URL- 角色规则
- List urlPermList = permissions.stream()
- .filter(item -> StrUtil.isNotBlank(item.getUrlPerm()))
- .collect(Collectors.toList());
- if (CollectionUtil.isNotEmpty(urlPermList)) {
- Map> urlPermRoles = new HashMap<>();
- urlPermList.stream().forEach(item -> {
- String perm = item.getUrlPerm();
- List roles = item.getRoles();
- urlPermRoles.put(perm, roles);
- });
- redisTemplate.opsForHash().putAll(GlobalConstants.URL_PERM_ROLES_KEY, urlPermRoles);
- }
- }
- return true;
- }
-
- @Override
- public List listPermRoles() {
- return this.baseMapper.listPermRoles();
- }
-}
diff --git a/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/service/impl/UserServiceImpl.java b/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/service/impl/UserServiceImpl.java
index 6973bb4..80011af 100644
--- a/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/service/impl/UserServiceImpl.java
+++ b/hoe-admin/admin-boot/src/main/java/com/recovery/admin/boot/service/impl/UserServiceImpl.java
@@ -11,11 +11,13 @@ import com.recovery.common.base.dto.UserAuthDTO;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
import javax.annotation.Resource;
/**
- * @author:
+ * @author:
+ *
*/
@Service
@RequiredArgsConstructor
@@ -29,9 +31,10 @@ public class UserServiceImpl extends ServiceImpl implements Us
}
@Override
+ @Transactional
public void add(User user) {
- user.setId(2l);
- this.baseMapper.deleteById(user);
+ user.setUserName("123");
+ this.baseMapper.insert(user);
String sc= orderFeignClient.test();
System.out.println("123");
diff --git a/hoe-admin/admin-boot/src/main/resources/bootstrap.yml b/hoe-admin/admin-boot/src/main/resources/bootstrap.yml
index 8dc2a9e..6317ffd 100644
--- a/hoe-admin/admin-boot/src/main/resources/bootstrap.yml
+++ b/hoe-admin/admin-boot/src/main/resources/bootstrap.yml
@@ -1,22 +1,23 @@
spring:
-# datasource:
-# dynamic:
-# seata: true
+ datasource:
+ dynamic:
+ seata: true
application:
name: hoe-admin
main:
allow-bean-definition-overriding: true
+ allow-circular-references: true
profiles:
active: dev
cloud:
nacos:
discovery:
- # metadata:
- # serviceGroup: ytChen
- server-addr: 192.168.110.209:8848
+ metadata:
+ serviceGroup: cpp
+ server-addr: 192.168.110.210:8848
namespace: 11bfd099-10d6-4f2c-b969-58b76e435cce
config:
- server-addr: 192.168.110.209:8848
+ server-addr: 192.168.110.210:8848
file-extension: yaml
prefix: hoe-admin
group: dev
@@ -83,7 +84,7 @@ server:
#分布式事务
#seata:
# enabled: true
-# enable-auto-data-source-proxy: true
+# enable-auto-data-source-proxy: false
# config:
# type: nacos
# nacos:
@@ -92,6 +93,7 @@ server:
# username: nacos
# password: nacos
# data-id: seataServer.properties
+# namespace: 11bfd099-10d6-4f2c-b969-58b76e435cce
# registry:
# type: nacos
# nacos:
@@ -100,3 +102,4 @@ server:
# group: SEATA_GROUP
# username: nacos
# password: nacos
+# namespace: 11bfd099-10d6-4f2c-b969-58b76e435cce
diff --git a/hoe-admin/pom.xml b/hoe-admin/pom.xml
index 213d53f..6863591 100644
--- a/hoe-admin/pom.xml
+++ b/hoe-admin/pom.xml
@@ -16,8 +16,8 @@
- 8
- 8
+ 17
+ 17
UTF-8
diff --git a/hoe-auth/pom.xml b/hoe-auth/pom.xml
index 3746785..7359899 100644
--- a/hoe-auth/pom.xml
+++ b/hoe-auth/pom.xml
@@ -36,6 +36,21 @@
+
+
+ org.hibernate.validator
+ hibernate-validator
+ 6.2.0.Final
+
+
+
+ org.glassfish
+ jakarta.el
+ 3.0.3
+
+
+
+
cn.dev33
diff --git a/hoe-auth/src/main/java/com/recovery/auth/config/ds/TeachingDataSourceConfig.java b/hoe-auth/src/main/java/com/recovery/auth/config/ds/TeachingDataSourceConfig.java
index 263c45a..85fe713 100644
--- a/hoe-auth/src/main/java/com/recovery/auth/config/ds/TeachingDataSourceConfig.java
+++ b/hoe-auth/src/main/java/com/recovery/auth/config/ds/TeachingDataSourceConfig.java
@@ -1,58 +1,58 @@
-package com.recovery.auth.config.ds;
-
-import com.alibaba.druid.pool.DruidDataSource;
-import org.apache.ibatis.session.SqlSessionFactory;
-import org.mybatis.spring.SqlSessionFactoryBean;
-import org.springframework.beans.factory.annotation.Qualifier;
-import org.springframework.beans.factory.annotation.Value;
-import org.springframework.context.annotation.Bean;
-import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
-import org.springframework.jdbc.datasource.DataSourceTransactionManager;
-
-import javax.sql.DataSource;
-
-//@Configuration
-//// 扫描 Mapper 接口并容器管理
-//@MapperScan(basePackages = TeachingDataSourceConfig.PACKAGE, sqlSessionFactoryRef = "teachingSqlSessionFactory")
-public class TeachingDataSourceConfig {
- // 精确到 auth 目录,以便跟其他数据源隔离
- static final String PACKAGE = "com.recovery.auth.dao.mapper";
- static final String MAPPER_LOCATION = "classpath:mapper/*.xml";
-
- @Value("${admin.datasource.url}")
- private String url;
-
- @Value("${admin.datasource.username}")
- private String user;
-
- @Value("${admin.datasource.password}")
- private String password;
-
- @Value("${admin.datasource.driverClassName}")
- private String driverClass;
-
- @Bean(name = "adminDataSource")
- public DataSource cpdDataSource() {
- DruidDataSource dataSource = new DruidDataSource();
- dataSource.setDriverClassName(driverClass);
- dataSource.setUrl(url);
- dataSource.setUsername(user);
- dataSource.setPassword(password);
- return dataSource;
- }
-
- @Bean(name = "adminTransactionManager")
- public DataSourceTransactionManager courseTransactionManager() {
- return new DataSourceTransactionManager(cpdDataSource());
- }
-
- @Bean(name = "adminSqlSessionFactory")
- public SqlSessionFactory cpdSqlSessionFactory(@Qualifier("adminDataSource") DataSource cpdDataSource)
- throws Exception {
- final SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
- sessionFactory.setDataSource(cpdDataSource);
- sessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver()
- .getResources(TeachingDataSourceConfig.MAPPER_LOCATION));
- return sessionFactory.getObject();
- }
-}
+//package com.recovery.auth.config.ds;
+//
+//import com.alibaba.druid.pool.DruidDataSource;
+//import org.apache.ibatis.session.SqlSessionFactory;
+//import org.mybatis.spring.SqlSessionFactoryBean;
+//import org.springframework.beans.factory.annotation.Qualifier;
+//import org.springframework.beans.factory.annotation.Value;
+//import org.springframework.context.annotation.Bean;
+//import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
+//import org.springframework.jdbc.datasource.DataSourceTransactionManager;
+//
+//import javax.sql.DataSource;
+//
+////@Configuration
+////// 扫描 Mapper 接口并容器管理
+////@MapperScan(basePackages = TeachingDataSourceConfig.PACKAGE, sqlSessionFactoryRef = "teachingSqlSessionFactory")
+//public class TeachingDataSourceConfig {
+// // 精确到 auth 目录,以便跟其他数据源隔离
+// static final String PACKAGE = "com.recovery.auth.dao.mapper";
+// static final String MAPPER_LOCATION = "classpath:mapper/*.xml";
+//
+// @Value("${admin.datasource.url}")
+// private String url;
+//
+// @Value("${admin.datasource.username}")
+// private String user;
+//
+// @Value("${admin.datasource.password}")
+// private String password;
+//
+// @Value("${admin.datasource.driverClassName}")
+// private String driverClass;
+//
+// @Bean(name = "adminDataSource")
+// public DataSource cpdDataSource() {
+// DruidDataSource dataSource = new DruidDataSource();
+// dataSource.setDriverClassName(driverClass);
+// dataSource.setUrl(url);
+// dataSource.setUsername(user);
+// dataSource.setPassword(password);
+// return dataSource;
+// }
+//
+// @Bean(name = "adminTransactionManager")
+// public DataSourceTransactionManager courseTransactionManager() {
+// return new DataSourceTransactionManager(cpdDataSource());
+// }
+//
+// @Bean(name = "adminSqlSessionFactory")
+// public SqlSessionFactory cpdSqlSessionFactory(@Qualifier("adminDataSource") DataSource cpdDataSource)
+// throws Exception {
+// final SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
+// sessionFactory.setDataSource(cpdDataSource);
+// sessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver()
+// .getResources(TeachingDataSourceConfig.MAPPER_LOCATION));
+// return sessionFactory.getObject();
+// }
+//}
diff --git a/hoe-auth/src/main/resources/bootstrap.yml b/hoe-auth/src/main/resources/bootstrap.yml
index 6f24dd8..e32f2d5 100644
--- a/hoe-auth/src/main/resources/bootstrap.yml
+++ b/hoe-auth/src/main/resources/bootstrap.yml
@@ -4,17 +4,18 @@ spring:
name: hoe-auth
main:
allow-bean-definition-overriding: true
+ allow-circular-references: true
profiles:
active: dev
cloud:
nacos:
discovery:
- metadata:
- serviceGroup: ytChen
- server-addr: 192.168.110.209:8848
+# metadata:
+# serviceGroup: ytChen
+ server-addr: 192.168.110.210:8848
namespace: 11bfd099-10d6-4f2c-b969-58b76e435cce
config:
- server-addr: 192.168.110.209:8848
+ server-addr: 192.168.110.210:8848
file-extension: yaml
prefix: hoe-auth
group: dev
diff --git a/hoe-auth/target/classes/bootstrap.yml b/hoe-auth/target/classes/bootstrap.yml
index df92dee..e32f2d5 100644
--- a/hoe-auth/target/classes/bootstrap.yml
+++ b/hoe-auth/target/classes/bootstrap.yml
@@ -4,17 +4,18 @@ spring:
name: hoe-auth
main:
allow-bean-definition-overriding: true
+ allow-circular-references: true
profiles:
active: dev
cloud:
nacos:
discovery:
- metadata:
- serviceGroup: ytChen
- server-addr: localhost:8848
+# metadata:
+# serviceGroup: ytChen
+ server-addr: 192.168.110.210:8848
namespace: 11bfd099-10d6-4f2c-b969-58b76e435cce
config:
- server-addr: localhost:8848
+ server-addr: 192.168.110.210:8848
file-extension: yaml
prefix: hoe-auth
group: dev
diff --git a/hoe-auth/target/classes/com/recovery/auth/config/ds/DataSourceConfig.class b/hoe-auth/target/classes/com/recovery/auth/config/ds/DataSourceConfig.class
index 58bc40e..69b8e7f 100644
Binary files a/hoe-auth/target/classes/com/recovery/auth/config/ds/DataSourceConfig.class and b/hoe-auth/target/classes/com/recovery/auth/config/ds/DataSourceConfig.class differ
diff --git a/hoe-auth/target/classes/com/recovery/auth/controller/AuthController.class b/hoe-auth/target/classes/com/recovery/auth/controller/AuthController.class
index 19bc245..99f6180 100644
Binary files a/hoe-auth/target/classes/com/recovery/auth/controller/AuthController.class and b/hoe-auth/target/classes/com/recovery/auth/controller/AuthController.class differ
diff --git a/hoe-auth/target/classes/com/recovery/auth/feign/UserFeignClient.class b/hoe-auth/target/classes/com/recovery/auth/feign/UserFeignClient.class
index eb6fdb0..d4eef15 100644
Binary files a/hoe-auth/target/classes/com/recovery/auth/feign/UserFeignClient.class and b/hoe-auth/target/classes/com/recovery/auth/feign/UserFeignClient.class differ
diff --git a/hoe-common/common-base/src/main/java/com/recovery/common/base/po/base/DBInfo.java b/hoe-common/common-base/src/main/java/com/recovery/common/base/po/base/DBInfo.java
index e22aeb7..71a37ea 100644
--- a/hoe-common/common-base/src/main/java/com/recovery/common/base/po/base/DBInfo.java
+++ b/hoe-common/common-base/src/main/java/com/recovery/common/base/po/base/DBInfo.java
@@ -30,7 +30,7 @@ public class DBInfo implements Serializable {
private String module;
- private String hospitalHost;
+ private String dbHost;
- private String hospitalCode;
+ private String dbCode;
}
diff --git a/hoe-common/common-base/src/main/java/com/recovery/common/base/util/EncryptUtil.java b/hoe-common/common-base/src/main/java/com/recovery/common/base/util/EncryptUtil.java
index 2e8ca82..04e361b 100644
--- a/hoe-common/common-base/src/main/java/com/recovery/common/base/util/EncryptUtil.java
+++ b/hoe-common/common-base/src/main/java/com/recovery/common/base/util/EncryptUtil.java
@@ -96,8 +96,8 @@ public final class EncryptUtil {
* @return
*/
private static byte[] hex2byte(byte[] b) {
- if ((b.length % 2) != 0)
- throw new IllegalArgumentException("长度不是偶数");
+ if ((b.length % 2) != 0){
+ throw new IllegalArgumentException("长度不是偶数");}
byte[] b2 = new byte[b.length / 2];
for (int n = 0; n < b.length; n += 2) {
String item = new String(b, n, 2);
@@ -116,10 +116,11 @@ public final class EncryptUtil {
String stmp = "";
for (int n = 0; n < b.length; n++) {
stmp = (Integer.toHexString(b[n] & 0XFF));
- if (stmp.length() == 1)
+ if (stmp.length() == 1){
hs = hs + "0" + stmp;
- else
+ } else {
hs = hs + stmp;
+ }
}
return hs.toUpperCase();
}
diff --git a/hoe-common/common-base/src/main/java/com/recovery/common/base/util/HspHostUtil.java b/hoe-common/common-base/src/main/java/com/recovery/common/base/util/HspHostUtil.java
index da926af..334afd9 100644
--- a/hoe-common/common-base/src/main/java/com/recovery/common/base/util/HspHostUtil.java
+++ b/hoe-common/common-base/src/main/java/com/recovery/common/base/util/HspHostUtil.java
@@ -98,7 +98,7 @@ public class HspHostUtil {
* @param dbInfo
*/
public static void switchDB(DBInfo dbInfo,StringRedisTemplate redisTemplate){
- String host = dbInfo.getHospitalCode();
+ String host = dbInfo.getDbCode();
String dataSourceKey = "dynamic-slave"+"_"+host;
Map