This commit is contained in:
LuoYe_MyWork 2020-09-07 14:52:07 +08:00
parent b934572be4
commit 179877f31e
4 changed files with 27 additions and 19 deletions

1
.gitignore vendored
View File

@ -1,3 +1,4 @@
# Created by .ignore support plugin (hsz.mobi) # Created by .ignore support plugin (hsz.mobi)
/.idea/ /.idea/
/target/ /target/
/src/main/resources/application-online.properties.bak

View File

@ -48,7 +48,7 @@ public class LinkTokenAuthenticationFilter extends OncePerRequestFilter {
} }
} }
log.info("--------------Token鉴权---------------"); log.info("--------------Token鉴权---------------");
/*设置跨域*/ /*设置跨域 最好在nginx处设置*/
HttpServletResponse response = httpServletResponse; HttpServletResponse response = httpServletResponse;
response.setHeader("Access-Control-Allow-Origin", "*"); response.setHeader("Access-Control-Allow-Origin", "*");
response.setHeader("Access-Control-Allow-Credentials", "true"); response.setHeader("Access-Control-Allow-Credentials", "true");
@ -57,7 +57,6 @@ public class LinkTokenAuthenticationFilter extends OncePerRequestFilter {
response.setHeader("Access-Control-Allow-Headers", "Origin, X-Requested-With, Content-Type, Accept, token"); response.setHeader("Access-Control-Allow-Headers", "Origin, X-Requested-With, Content-Type, Accept, token");
/*如果是OPTIONS则结束请求*/ /*如果是OPTIONS则结束请求*/
if (HttpMethod.OPTIONS.toString().equals(httpServletRequest.getMethod())) { if (HttpMethod.OPTIONS.toString().equals(httpServletRequest.getMethod())) {
log.debug("OPTIONS请求");
response.setStatus(HttpStatus.NO_CONTENT.value()); response.setStatus(HttpStatus.NO_CONTENT.value());
} else { } else {
filterChain.doFilter(httpServletRequest, response); filterChain.doFilter(httpServletRequest, response);

View File

@ -1,27 +1,17 @@
package io.qyi.e5.controller.admin; package io.qyi.e5.controller.admin;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.google.gson.Gson;
import io.qyi.e5.outlook.entity.Outlook;
import io.qyi.e5.outlook.service.IOutlookService; import io.qyi.e5.outlook.service.IOutlookService;
import io.qyi.e5.service.task.ITask; import io.qyi.e5.service.task.ITask;
import io.qyi.e5.util.redis.RedisUtil; import io.qyi.e5.util.redis.RedisUtil;
import org.springframework.amqp.core.MessageProperties;
import org.springframework.amqp.rabbit.connection.CorrelationData;
import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.security.access.annotation.Secured; import org.springframework.beans.factory.annotation.Value;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.security.config.annotation.method.configuration.EnableGlobalMethodSecurity;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController; import org.springframework.web.bind.annotation.RestController;
import java.util.UUID;
/** /**
* @program: e5 * @program: 此类里大多都是测试
* @description: * @description:
* @author: 落叶随风 * @author: 落叶随风
* @create: 2020-03-16 01:01 * @create: 2020-03-16 01:01
@ -41,17 +31,38 @@ public class AdminController {
@Autowired @Autowired
RedisUtil redisUtil; RedisUtil redisUtil;
@Value("user.admin.githubId")
int adminGithubId;
/**
* 测试队列
* @Author: 落叶随风
* @Date: 2020/9/7 14:44
* @Return: * @return: void
*/
@GetMapping("/send") @GetMapping("/send")
public void send() { public void send() {
Task.sendTaskOutlookMQ(19658189); Task.sendTaskOutlookMQ(adminGithubId);
} }
/**
* 对所有队列重新添加
* @Author: 落叶随风
* @Date: 2020/9/7 14:43
* @Return: * @return: java.lang.String
*/
@GetMapping("/sendAll") @GetMapping("/sendAll")
public String sendAll() { public String sendAll() {
Task.sendTaskOutlookMQALL(); Task.sendTaskOutlookMQALL();
return "ok"; return "ok";
} }
/**
* 清空redis
* @Author: 落叶随风
* @Date: 2020/9/7 14:41
* @Return: * @return: java.lang.String
*/
@GetMapping("/emptyRedis") @GetMapping("/emptyRedis")
public String emptyRedis() { public String emptyRedis() {
redisUtil.deleteALL(); redisUtil.deleteALL();
@ -62,7 +73,4 @@ public class AdminController {
public String test() { public String test() {
return "ok"; return "ok";
} }
} }

View File

@ -238,7 +238,7 @@ public class OutlookServiceImpl extends ServiceImpl<OutlookMapper, Outlook> impl
JSONObject jsonObject = JSON.parseObject(s); JSONObject jsonObject = JSON.parseObject(s);
if (!jsonObject.containsKey("access_token")) { if (!jsonObject.containsKey("access_token")) {
logger.info("返回的access_token字段不存在"); logger.info("返回的access_token字段不存在");
throw new Exception("返回的access_token字段不存在,无法刷新令牌! 需要重新授权!"); throw new Exception("返回的access_token字段不存在,无法刷新令牌! 需要重新授权!" );
} }
outlook.setRefreshToken(jsonObject.getString("refresh_token")); outlook.setRefreshToken(jsonObject.getString("refresh_token"));
outlook.setAccessToken(jsonObject.getString("access_token")); outlook.setAccessToken(jsonObject.getString("access_token"));