New file |
| | |
| | | package com.dy.pipIrrApp.config; |
| | | |
| | | import com.dy.common.multiDataSource.DataSourceContext; |
| | | import jakarta.servlet.*; |
| | | import jakarta.servlet.http.HttpServletRequest; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | |
| | | import java.io.IOException; |
| | | |
| | | /** |
| | | * @author ZhuBaoMin |
| | | * @date 2024-11-29 14:24 |
| | | * @LastEditTime 2024-11-29 14:24 |
| | | * @Description |
| | | */ |
| | | |
| | | @Slf4j |
| | | public class DataSourceFilter implements Filter { |
| | | |
| | | @Override |
| | | public void init(FilterConfig filterConfig) throws ServletException { |
| | | } |
| | | |
| | | @Override |
| | | public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws ServletException, IOException { |
| | | HttpServletRequest httpRequest = (HttpServletRequest) servletRequest; |
| | | String wxDataSourceName = httpRequest.getHeader("tag"); |
| | | if (wxDataSourceName != null && wxDataSourceName.trim().length() > 0) { |
| | | log.info("APP开发,设置数据源名称为:" + wxDataSourceName); |
| | | //把组织单位标签作为数据源名称 |
| | | DataSourceContext.set(wxDataSourceName); |
| | | } else { |
| | | log.info("用户未选择数据源"); |
| | | } |
| | | filterChain.doFilter(servletRequest, servletResponse); |
| | | } |
| | | |
| | | @Override |
| | | public void destroy() { |
| | | } |
| | | } |