ck
/
bsd_cases
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

up

Browse Source
master
ck 6 years ago
parent f7f3323a6f
commit ba9419239e
5 changed files with 265 additions and 370 deletions
Show Stats Download Patch File Download Diff File

178
src/main/java/com/bsd/cases/conf/ShiroConfig.java
Unescape Escape View File

@ -1,89 +1,89 @@
package com.bsd.cases.conf; //package com.bsd.cases.conf;
//
import com.bsd.cases.shiro.CommonRealm; //import com.bsd.cases.shiro.CommonRealm;
import com.bsd.cases.shiro.JWTFilter; //import com.bsd.cases.shiro.JWTFilter;
import org.apache.shiro.mgt.DefaultSessionStorageEvaluator; //import org.apache.shiro.mgt.DefaultSessionStorageEvaluator;
import org.apache.shiro.mgt.DefaultSubjectDAO; //import org.apache.shiro.mgt.DefaultSubjectDAO;
import org.apache.shiro.spring.LifecycleBeanPostProcessor; //import org.apache.shiro.spring.LifecycleBeanPostProcessor;
import org.apache.shiro.spring.security.interceptor.AuthorizationAttributeSourceAdvisor; //import org.apache.shiro.spring.security.interceptor.AuthorizationAttributeSourceAdvisor;
import org.apache.shiro.spring.web.ShiroFilterFactoryBean; //import org.apache.shiro.spring.web.ShiroFilterFactoryBean;
import org.apache.shiro.web.mgt.DefaultWebSecurityManager; //import org.apache.shiro.web.mgt.DefaultWebSecurityManager;
import org.springframework.aop.framework.autoproxy.DefaultAdvisorAutoProxyCreator; //import org.springframework.aop.framework.autoproxy.DefaultAdvisorAutoProxyCreator;
import org.springframework.context.annotation.Bean; //import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration; //import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.DependsOn; //import org.springframework.context.annotation.DependsOn;
//
import javax.servlet.Filter; //import javax.servlet.Filter;
import java.util.HashMap; //import java.util.HashMap;
import java.util.Map; //import java.util.Map;
//
@Configuration //@Configuration
public class ShiroConfig { //public class ShiroConfig {
//
@Bean("securityManager") // @Bean("securityManager")
public DefaultWebSecurityManager getManager() { // public DefaultWebSecurityManager getManager() {
//
DefaultWebSecurityManager manager = new DefaultWebSecurityManager(); // DefaultWebSecurityManager manager = new DefaultWebSecurityManager();
// 使用自己的realm // // 使用自己的realm
manager.setRealm(MyRealm()); // manager.setRealm(MyRealm());
DefaultSubjectDAO subjectDAO = new DefaultSubjectDAO(); // DefaultSubjectDAO subjectDAO = new DefaultSubjectDAO();
DefaultSessionStorageEvaluator defaultSessionStorageEvaluator = new DefaultSessionStorageEvaluator(); // DefaultSessionStorageEvaluator defaultSessionStorageEvaluator = new DefaultSessionStorageEvaluator();
defaultSessionStorageEvaluator.setSessionStorageEnabled(false); // defaultSessionStorageEvaluator.setSessionStorageEnabled(false);
subjectDAO.setSessionStorageEvaluator(defaultSessionStorageEvaluator); // subjectDAO.setSessionStorageEvaluator(defaultSessionStorageEvaluator);
manager.setSubjectDAO(subjectDAO); // manager.setSubjectDAO(subjectDAO);
//
return manager; // return manager;
} // }
//
@Bean("shiroFilter") // @Bean("shiroFilter")
public ShiroFilterFactoryBean factory(DefaultWebSecurityManager securityManager) { // public ShiroFilterFactoryBean factory(DefaultWebSecurityManager securityManager) {
ShiroFilterFactoryBean factoryBean = new ShiroFilterFactoryBean(); // ShiroFilterFactoryBean factoryBean = new ShiroFilterFactoryBean();
//
// 添加自己的过滤器并且取名为jwt // // 添加自己的过滤器并且取名为jwt
Map<String, Filter> filterMap = new HashMap<>(); // Map<String, Filter> filterMap = new HashMap<>();
filterMap.put("jwt", new JWTFilter()); // filterMap.put("jwt", new JWTFilter());
factoryBean.setFilters(filterMap); // factoryBean.setFilters(filterMap);
//
factoryBean.setSecurityManager(securityManager); // factoryBean.setSecurityManager(securityManager);
factoryBean.setUnauthorizedUrl("/api/401"); // factoryBean.setUnauthorizedUrl("/api/401");
//
Map<String, String> filterRuleMap = new HashMap<>(); // Map<String, String> filterRuleMap = new HashMap<>();
// 所有请求通过我们自己的JWT Filter // // 所有请求通过我们自己的JWT Filter
filterRuleMap.put("/**", "jwt"); // filterRuleMap.put("/**", "jwt");
// 访问401和404页面不通过我们的Filter // // 访问401和404页面不通过我们的Filter
filterRuleMap.put("/api/adminlogin", "anon"); // filterRuleMap.put("/api/adminlogin", "anon");
filterRuleMap.put("/api/autologin", "anon"); // filterRuleMap.put("/api/autologin", "anon");
filterRuleMap.put("/api/401", "anon"); // filterRuleMap.put("/api/401", "anon");
factoryBean.setFilterChainDefinitionMap(filterRuleMap); // factoryBean.setFilterChainDefinitionMap(filterRuleMap);
return factoryBean; // return factoryBean;
} // }
//
//
@Bean // @Bean
@DependsOn("lifecycleBeanPostProcessor") // @DependsOn("lifecycleBeanPostProcessor")
public DefaultAdvisorAutoProxyCreator defaultAdvisorAutoProxyCreator() { // public DefaultAdvisorAutoProxyCreator defaultAdvisorAutoProxyCreator() {
//
DefaultAdvisorAutoProxyCreator defaultAdvisorAutoProxyCreator = new DefaultAdvisorAutoProxyCreator(); // DefaultAdvisorAutoProxyCreator defaultAdvisorAutoProxyCreator = new DefaultAdvisorAutoProxyCreator();
defaultAdvisorAutoProxyCreator.setProxyTargetClass(true); // defaultAdvisorAutoProxyCreator.setProxyTargetClass(true);
return defaultAdvisorAutoProxyCreator; // return defaultAdvisorAutoProxyCreator;
} // }
//
@Bean // @Bean
public CommonRealm MyRealm() { // public CommonRealm MyRealm() {
return new CommonRealm(); // return new CommonRealm();
} // }
//
@Bean // @Bean
public LifecycleBeanPostProcessor lifecycleBeanPostProcessor() { // public LifecycleBeanPostProcessor lifecycleBeanPostProcessor() {
return new LifecycleBeanPostProcessor(); // return new LifecycleBeanPostProcessor();
} // }
//
@Bean // @Bean
public AuthorizationAttributeSourceAdvisor authorizationAttributeSourceAdvisor(DefaultWebSecurityManager securityManager) { // public AuthorizationAttributeSourceAdvisor authorizationAttributeSourceAdvisor(DefaultWebSecurityManager securityManager) {
AuthorizationAttributeSourceAdvisor advisor = new AuthorizationAttributeSourceAdvisor(); // AuthorizationAttributeSourceAdvisor advisor = new AuthorizationAttributeSourceAdvisor();
advisor.setSecurityManager(securityManager); // advisor.setSecurityManager(securityManager);
return advisor; // return advisor;
} // }
//
//
} //}

62
src/main/java/com/bsd/cases/event/LogEvent.java
Unescape Escape View File

@ -1,31 +1,31 @@
package com.bsd.cases.event; //package com.bsd.cases.event;
//
import com.bsd.cases.enums.BoBusinessEnum; //import com.bsd.cases.enums.BoBusinessEnum;
import com.bsd.cases.model.BoActivityInstance; //import com.bsd.cases.model.BoActivityInstance;
import org.springframework.context.ApplicationEvent; //import org.springframework.context.ApplicationEvent;
//
/** ///**
* 加载日志时间 // * 加载日志时间
*/ // */
public class LogEvent extends ApplicationEvent { //public class LogEvent extends ApplicationEvent {
//
private BoActivityInstance boActivityInstance; // private BoActivityInstance boActivityInstance;
private BoBusinessEnum boBusinessEnum; // private BoBusinessEnum boBusinessEnum;
//
//
public LogEvent(Object source, BoActivityInstance boActivityInstance, BoBusinessEnum boBusinessEnum) { // public LogEvent(Object source, BoActivityInstance boActivityInstance, BoBusinessEnum boBusinessEnum) {
super(source); // super(source);
this.boActivityInstance = boActivityInstance; // this.boActivityInstance = boActivityInstance;
this.boBusinessEnum = boBusinessEnum; // this.boBusinessEnum = boBusinessEnum;
//
} // }
//
public BoActivityInstance getBoActivityInstance() { // public BoActivityInstance getBoActivityInstance() {
return boActivityInstance; // return boActivityInstance;
} // }
//
public BoBusinessEnum getBoBusinessEnum() { // public BoBusinessEnum getBoBusinessEnum() {
return boBusinessEnum; // return boBusinessEnum;
} // }
//
} //}

152
src/main/java/com/bsd/cases/listener/LogEventListener.java
Unescape Escape View File

@ -1,76 +1,76 @@
package com.bsd.cases.listener; //package com.bsd.cases.listener;
//
import com.bsd.cases.enums.BoActionEnum; //import com.bsd.cases.enums.BoActionEnum;
import com.bsd.cases.enums.BoBusinessEnum; //import com.bsd.cases.enums.BoBusinessEnum;
import com.bsd.cases.event.LogEvent; //import com.bsd.cases.event.LogEvent;
import com.bsd.cases.model.BoActivityInstance; //import com.bsd.cases.model.BoActivityInstance;
import com.bsd.cases.model.BoBussinessLog; //import com.bsd.cases.model.BoBussinessLog;
import com.bsd.cases.model.BoUsers; //import com.bsd.cases.model.BoUsers;
import com.bsd.cases.service.BoBussinessLogService; //import com.bsd.cases.service.BoBussinessLogService;
import com.bsd.cases.service.BoUsersService; //import com.bsd.cases.service.BoUsersService;
import com.bsd.cases.util.DateUtils; //import com.bsd.cases.util.DateUtils;
import org.springframework.context.event.EventListener; //import org.springframework.context.event.EventListener;
import org.springframework.scheduling.annotation.Async; //import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component; //import org.springframework.stereotype.Component;
//
import javax.annotation.Resource; //import javax.annotation.Resource;
//
@Component //@Component
public class LogEventListener { //public class LogEventListener {
//
@Resource // @Resource
BoUsersService boUsersService; // BoUsersService boUsersService;
@Resource // @Resource
BoBussinessLogService boBussinessLogService; // BoBussinessLogService boBussinessLogService;
//
@Async // @Async
@EventListener // @EventListener
public void LogEvent(LogEvent logEvent) { // public void LogEvent(LogEvent logEvent) {
//
BoBussinessLog boBussinessLog = new BoBussinessLog(); // BoBussinessLog boBussinessLog = new BoBussinessLog();
BoBusinessEnum logEnum = logEvent.getBoBusinessEnum(); // BoBusinessEnum logEnum = logEvent.getBoBusinessEnum();
BoActivityInstance boActivityInstance = logEvent.getBoActivityInstance(); // BoActivityInstance boActivityInstance = logEvent.getBoActivityInstance();
String source = logEvent.getSource().toString(); // String source = logEvent.getSource().toString();
boBussinessLog.setActionTime(DateUtils.date()); // boBussinessLog.setActionTime(DateUtils.date());
boBussinessLog.setSource(source); // boBussinessLog.setSource(source);
BoUsers boUsers = boUsersService.currentUser(); // BoUsers boUsers = boUsersService.currentUser();
//
switch (logEnum) { // switch (logEnum) {
//
case IDNEXPAGE: // case IDNEXPAGE:
boBussinessLog.setAction(BoActionEnum.VISIT.getCategory()); // boBussinessLog.setAction(BoActionEnum.VISIT.getCategory());
boBussinessLog.setPageName("首页"); // boBussinessLog.setPageName("首页");
break; // break;
case LOGIN: // case LOGIN:
boBussinessLog.setAction(BoActionEnum.SUBMIT.getCategory()); // boBussinessLog.setAction(BoActionEnum.SUBMIT.getCategory());
break; // break;
case AcvityDETAIL: // case AcvityDETAIL:
boBussinessLog.setAction(BoActionEnum.VISIT.getCategory()); // boBussinessLog.setAction(BoActionEnum.VISIT.getCategory());
boBussinessLog.setPageName("活动详情页"); // boBussinessLog.setPageName("活动详情页");
boBussinessLog.setActivityInstanceId(boActivityInstance.getId()); // boBussinessLog.setActivityInstanceId(boActivityInstance.getId());
break; // break;
case MYACTIVITIES: // case MYACTIVITIES:
boBussinessLog.setAction(BoActionEnum.VISIT.getCategory()); // boBussinessLog.setAction(BoActionEnum.VISIT.getCategory());
boBussinessLog.setPageName("我的活动"); // boBussinessLog.setPageName("我的活动");
case SHARECODE: // case SHARECODE:
boBussinessLog.setAction(BoActionEnum.SUBMIT.getCategory()); // boBussinessLog.setAction(BoActionEnum.SUBMIT.getCategory());
boBussinessLog.setPageName("分享活动"); // boBussinessLog.setPageName("分享活动");
break; // break;
case SIGNUP: // case SIGNUP:
boBussinessLog.setAction(BoActionEnum.SUBMIT.getCategory()); // boBussinessLog.setAction(BoActionEnum.SUBMIT.getCategory());
boBussinessLog.setPageName("分享活动"); // boBussinessLog.setPageName("分享活动");
break; // break;
case REGISTER: // case REGISTER:
boBussinessLog.setAction(BoActionEnum.SUBMIT.getCategory()); // boBussinessLog.setAction(BoActionEnum.SUBMIT.getCategory());
boBussinessLog.setPageName("注册"); // boBussinessLog.setPageName("注册");
break; // break;
default: // default:
//
break; // break;
} // }
//
Long operatorId = boUsers == null ? 0L : boUsers.getId(); // Long operatorId = boUsers == null ? 0L : boUsers.getId();
boBussinessLog.setUserId(operatorId); // boBussinessLog.setUserId(operatorId);
boBussinessLogService.saveOrUpdate(boBussinessLog, operatorId); // boBussinessLogService.saveOrUpdate(boBussinessLog, operatorId);
} // }
} //}

105
src/main/java/com/bsd/cases/service/impl/WxSubscribeMessageServiceImpl.java
Unescape Escape View File

@ -1,105 +0,0 @@
package com.bsd.cases.service.impl;
import com.alibaba.fastjson.JSONObject;
import com.bsd.cases.mapper.BoWechatMiniMapper;
import com.bsd.cases.mapper.ScheduledTaskMapper;
import com.bsd.cases.model.BoWechatMini;
import com.bsd.cases.service.WxSubscribeMessageService;
import com.bsd.cases.util.HttpRequestUtils;
import com.bsd.cases.util.LogUtils;
import org.slf4j.Logger;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import javax.annotation.Resource;
import java.io.IOException;
@Service("wxSubscribeMessageService")
@Transactional
public class WxSubscribeMessageServiceImpl implements WxSubscribeMessageService {
@Value("${wx.SIGNUP_TEMPLATE_ID}")
private String SIGNUP_TEMPLATE_ID;
@Value("${wx.SEND_MESSAGE_URL}")
private String SEND_MESSAGE_URL;
@Value("${wx.APPID}")
private String APPID;
@Resource
private BoWechatMiniMapper boWechatMiniMapper;
@Resource
private ScheduledTaskMapper scheduledTaskMapper;
private Logger logger = LogUtils.getBussinessLogger();
/**
* 报名发模板消息
* @param activityState 活动状态
* @param activityName 活动名称
* @param activityPlace 活动地点
* @param activityStartTime 活动开始时间
* @param note 备注
*/
@Override
public void activitySendMessage(String activityState,String activityName,String activityPlace,
String activityStartTime,String note,String openId,String page) {
BoWechatMini findBoWechatMini = new BoWechatMini();
findBoWechatMini.setMiniAppid(APPID);
findBoWechatMini.setState(1);
BoWechatMini boWechatMini = boWechatMiniMapper.selectOne(findBoWechatMini);
String accessToken = boWechatMini.getAccessToken();
String sendUrl = SEND_MESSAGE_URL + accessToken;
JSONObject jsonObject = new JSONObject();
jsonObject.put("touser",openId);
jsonObject.put("template_id",SIGNUP_TEMPLATE_ID);
jsonObject.put("page",page);
JSONObject data = new JSONObject();
JSONObject phrase1Data = new JSONObject();
phrase1Data.put("value",activityState);
data.put("phrase1",phrase1Data);
JSONObject thing2Data = new JSONObject();
thing2Data.put("value",activityName);
data.put("thing2",thing2Data);
JSONObject thing3Data = new JSONObject();
thing3Data.put("value",activityPlace);
data.put("thing3",thing3Data);
JSONObject date6Data = new JSONObject();
date6Data.put("value",activityStartTime);
data.put("date6",date6Data);
JSONObject thing9Data = new JSONObject();
thing9Data.put("value",note);
data.put("thing9",thing9Data);
jsonObject.put("data",data);
try {
String result = HttpRequestUtils.sendPost(sendUrl,jsonObject);
logger.info("发送活动报名微信模板消息结果:"+result);
} catch (IOException e) {
e.printStackTrace();
}
}
/**
* 活动取消发模板消息
* @param activityName 活动名称
* @param activityTime 活动时间
* @param note 备注
*/
@Override
public void cancelActivity(String activityName, String activityTime, String note,String openId) {
}
@Override
public void changeActivityPlace(String activityName, String changeTime, String changePlace, String note,String openId) {
}
/**
* 更新定时任务状态,执行完的定时任务置为0,不再初始化
* @param scheduledId
*/
@Override
public void updateTaskState(Long scheduledId) {
scheduledTaskMapper.updateScheduledTaskInit(scheduledId,0);
}
}

138
src/main/java/com/bsd/cases/shiro/CommonRealm.java
Unescape Escape View File

@ -1,69 +1,69 @@
package com.bsd.cases.shiro; //package com.bsd.cases.shiro;
//
import com.bsd.cases.model.BoUsers; //import com.bsd.cases.model.BoUsers;
import com.bsd.cases.service.BoUsersService; //import com.bsd.cases.service.BoUsersService;
import com.bsd.cases.util.JWTUtil; //import com.bsd.cases.util.JWTUtil;
import org.apache.shiro.authc.AuthenticationException; //import org.apache.shiro.authc.AuthenticationException;
import org.apache.shiro.authc.AuthenticationInfo; //import org.apache.shiro.authc.AuthenticationInfo;
import org.apache.shiro.authc.AuthenticationToken; //import org.apache.shiro.authc.AuthenticationToken;
import org.apache.shiro.authc.SimpleAuthenticationInfo; //import org.apache.shiro.authc.SimpleAuthenticationInfo;
import org.apache.shiro.authz.AuthorizationInfo; //import org.apache.shiro.authz.AuthorizationInfo;
import org.apache.shiro.authz.SimpleAuthorizationInfo; //import org.apache.shiro.authz.SimpleAuthorizationInfo;
import org.apache.shiro.realm.AuthorizingRealm; //import org.apache.shiro.realm.AuthorizingRealm;
import org.apache.shiro.subject.PrincipalCollection; //import org.apache.shiro.subject.PrincipalCollection;
import org.springframework.stereotype.Component; //import org.springframework.stereotype.Component;
//
import javax.annotation.Resource; //import javax.annotation.Resource;
//
@Component //@Component
public class CommonRealm extends AuthorizingRealm { //public class CommonRealm extends AuthorizingRealm {
//
@Resource // @Resource
private BoUsersService boUsersService; // private BoUsersService boUsersService;
//
/** // /**
* 大坑！，必须重写此方法，不然Shiro会报错 // * 大坑！，必须重写此方法，不然Shiro会报错
*/ // */
@Override // @Override
public boolean supports(AuthenticationToken token) { // public boolean supports(AuthenticationToken token) {
return token instanceof JWTToken; // return token instanceof JWTToken;
} // }
//
/** // /**
* 只有当需要检测用户权限的时候才会调用此方法，例如checkRole,checkPermission之类的 // * 只有当需要检测用户权限的时候才会调用此方法，例如checkRole,checkPermission之类的
*/ // */
@Override // @Override
protected AuthorizationInfo doGetAuthorizationInfo(PrincipalCollection principals) { // protected AuthorizationInfo doGetAuthorizationInfo(PrincipalCollection principals) {
//
String key = JWTUtil.getKey(principals.toString()); // String key = JWTUtil.getKey(principals.toString());
BoUsers boUsers = boUsersService.selectByUserNoOrOpenId(key); // BoUsers boUsers = boUsersService.selectByUserNoOrOpenId(key);
SimpleAuthorizationInfo simpleAuthorizationInfo = new SimpleAuthorizationInfo(); // SimpleAuthorizationInfo simpleAuthorizationInfo = new SimpleAuthorizationInfo();
// simpleAuthorizationInfo.addRole(user.getRole().toString()); //// simpleAuthorizationInfo.addRole(user.getRole().toString());
// Set<String> permission = new HashSet<>(Arrays.asList(user.getPermission().split(","))); //// Set<String> permission = new HashSet<>(Arrays.asList(user.getPermission().split(",")));
// simpleAuthorizationInfo.addStringPermissions(permission); // // simpleAuthorizationInfo.addStringPermissions(permission);
return simpleAuthorizationInfo; // return simpleAuthorizationInfo;
} // }
//
/** // /**
* 默认使用此方法进行用户名正确与否验证，错误抛出异常即可。 // * 默认使用此方法进行用户名正确与否验证，错误抛出异常即可。
*/ // */
@Override // @Override
protected AuthenticationInfo doGetAuthenticationInfo(AuthenticationToken auth) throws AuthenticationException { // protected AuthenticationInfo doGetAuthenticationInfo(AuthenticationToken auth) throws AuthenticationException {
//
String token = (String) auth.getCredentials(); // String token = (String) auth.getCredentials();
// 解密获得username，用于和数据库进行对比 // // 解密获得username，用于和数据库进行对比
String key = JWTUtil.getKey(token); // String key = JWTUtil.getKey(token);
if (key == null) { // if (key == null) {
throw new AuthenticationException("token invalid"); // throw new AuthenticationException("token invalid");
} // }
//
BoUsers boUsers = boUsersService.selectByUserNoOrOpenId(key); // BoUsers boUsers = boUsersService.selectByUserNoOrOpenId(key);
if (boUsers == null) { // if (boUsers == null) {
throw new AuthenticationException("User didn't existed!"); // throw new AuthenticationException("User didn't existed!");
} // }
if (!JWTUtil.verify(token, key)) { // if (!JWTUtil.verify(token, key)) {
throw new AuthenticationException("Username or password error"); // throw new AuthenticationException("Username or password error");
} // }
return new SimpleAuthenticationInfo(token, token, "common_ream"); // return new SimpleAuthenticationInfo(token, token, "common_ream");
} // }
} //}

Write Preview
Loading…
Cancel
Save