浏览代码

骄阳回调

yumeng 1 年之前
父节点
当前提交
f4b072b9d8

+ 1 - 0
ruixuan-framework/src/main/java/com/ruixuan/framework/config/SecurityConfig.java

@@ -132,6 +132,7 @@ public class SecurityConfig extends WebSecurityConfigurerAdapter {
                 .antMatchers("/jy/report/**").permitAll()
                 .antMatchers("/testVideo/**").permitAll()
                 .antMatchers("/open/**").permitAll()
+                .antMatchers("/jy/callback/**").permitAll()
 
                 // 除上面外的所有请求全部需要鉴权认证
                 .anyRequest().authenticated()

+ 60 - 0
ruixuan-live/src/main/java/com/ruixuan/jiaoyang/controller/JiaoYangCallbackController.java

@@ -0,0 +1,60 @@
+package com.ruixuan.jiaoyang.controller;
+
+import com.alibaba.fastjson.JSONObject;
+import com.ruixuan.common.utils.Check;
+import com.ruixuan.common.utils.http.HttpUtil;
+import com.ruixuan.jiaoyang.service.IJiaoYangCallbackService;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.*;
+
+@Slf4j
+@RestController
+@RequestMapping("/jy/callback")
+public class JiaoYangCallbackController {
+    @Autowired
+    private IJiaoYangCallbackService jiaoYangCallbackService;
+    private static String appId = "ks690458118961229051";
+    private static String appSecret = "sqc2y31qQEY2E3AIWWvmCg";
+    private static String signSecret = "6ef1e2a231733bb0c38fb2bf0f50e45b";
+
+    @GetMapping("/oauth")
+    @ApiOperation(value = "骄阳-达人授权")
+    public String oauth(String code, String state) {
+        log.info("骄阳达人授权信息,code:{},state:{}", code, state);
+        if (Check.isNull(state)) {
+            return "授权失败,state信息为空";
+        }
+        if (Check.isNull(code)) {
+            return "授权失败,code信息为空";
+        }
+        String url = "https://openapi.kwaixiaodian.com/oauth2/access_token";
+        Map<String, Object> paramsMap = new HashMap<>();
+        paramsMap.put("app_id", appId);
+        paramsMap.put("grant_type", "code");
+        paramsMap.put("app_secret", appSecret);
+        paramsMap.put("code", code);
+        String s = HttpUtil.httpGet(url, paramsMap, null);
+        JSONObject jsonObject = JSONObject.parseObject(s);
+        if (Check.isNull(jsonObject)) {
+            return "授权失败,返回信息为空";
+        }
+        Integer result = jsonObject.getInteger("result");
+        if (result == 1) {
+            String accessToken = jsonObject.getString("access_token");
+            String refreshToken = jsonObject.getString("refresh_token");
+            Long promoterId = Long.valueOf(state);
+            jiaoYangCallbackService.replaceTokenInfo(promoterId, appId, appSecret, signSecret, accessToken, refreshToken);
+
+        } else {
+            return "授权失败,请联系技术解决";
+        }
+
+        return "绑定成功";
+    }
+}

+ 7 - 0
ruixuan-live/src/main/java/com/ruixuan/jiaoyang/mapper/JiaoYangCallbackMapper.java

@@ -0,0 +1,7 @@
+package com.ruixuan.jiaoyang.mapper;
+
+import org.apache.ibatis.annotations.Param;
+
+public interface JiaoYangCallbackMapper {
+    void replaceTokenInfo(@Param("promoterId") Long promoterId, @Param("appId") String appId, @Param("appSecret") String appSecret, @Param("signSecret") String signSecret, @Param("accessToken") String accessToken, @Param("refreshToken") String refreshToken);
+}

+ 5 - 0
ruixuan-live/src/main/java/com/ruixuan/jiaoyang/service/IJiaoYangCallbackService.java

@@ -0,0 +1,5 @@
+package com.ruixuan.jiaoyang.service;
+
+public interface IJiaoYangCallbackService {
+    void replaceTokenInfo(Long promoterId, String appId, String appSecret, String signSecret, String accessToken, String refreshToken);
+}

+ 17 - 0
ruixuan-live/src/main/java/com/ruixuan/jiaoyang/service/impl/JiaoYangCallbackServiceImpl.java

@@ -0,0 +1,17 @@
+package com.ruixuan.jiaoyang.service.impl;
+
+import com.ruixuan.jiaoyang.mapper.JiaoYangCallbackMapper;
+import com.ruixuan.jiaoyang.service.IJiaoYangCallbackService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+@Service
+public class JiaoYangCallbackServiceImpl implements IJiaoYangCallbackService {
+    @Autowired
+    private JiaoYangCallbackMapper jiaoYangCallbackMapper;
+
+    @Override
+    public void replaceTokenInfo(Long promoterId, String appId, String appSecret, String signSecret, String accessToken, String refreshToken) {
+        jiaoYangCallbackMapper.replaceTokenInfo(promoterId, appId, appSecret, signSecret, accessToken, refreshToken);
+    }
+}

+ 1 - 1
ruixuan-live/src/main/java/com/ruixuan/open/service/impl/KuaishouOpenPhotoListServiceImpl.java

@@ -58,7 +58,7 @@ public class KuaishouOpenPhotoListServiceImpl implements IKuaishouOpenPhotoListS
 
             String appKey = "ks690458118961229051";
             String signSecret = "6ef1e2a231733bb0c38fb2bf0f50e45b";
-            String accessToken = "ChFvYXV0aC5hY2Nlc3NUb2tlbhJAhhjrjfDtPkuAuUN5pOWY1hl3SUdOrNORPbgFhIJ1uxNFUrKSaCTdaOcWUvlLqPOZWnnR-1_wWga0cNw-ZsmuYBoSdJTaZfTbRbe4zPS88hU0zxRHIiBA8uLLXu_BaAsO7k5WZayprQWLkUi_G-cvvV_XJMVzBCgFMAE";
+            String accessToken = "ChFvYXV0aC5hY2Nlc3NUb2tlbhJw0bf7W972LfB1ZvhEaRi75OvhHkxPHHN6_cZ74TKgJczDijS_1euj3PMQ9rVLu8-tOmMavY39RA-IqKdFHb7_AskVwj2gOEOnUj5nagoj76WUw0yONJOkQnCQui4IxhN8ITSrZfwyHrEkDobK7DBy8RoSXmId3s_9TpqnCS4FlyiXkIhhIiBCTvX6l7EEIivBhz0OxyrBpjVAUJES5GASUzv3tb_eZigFMAE";
 
             AccessTokenKsMerchantClient client = new AccessTokenKsMerchantClient(url, appKey, signSecret);
 

ruixuan-live/src/main/resources/mapper/bytedance/BytedancePromoterOrderListMapper.xml → ruixuan-live/src/main/resources/mapper/bytedance/JiaoYangCallbackMapper.xml


ruixuan-live/src/main/resources/mapper/isc/KuaishouItemListMapper.xml → ruixuan-live/src/main/resources/mapper/isc/JiaoYangCallbackMapper.xml


+ 20 - 0
ruixuan-live/src/main/resources/mapper/jiaoyang/JiaoYangCallbackMapper.xml

@@ -0,0 +1,20 @@
+<?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.ruixuan.jiaoyang.mapper.JiaoYangCallbackMapper">
+
+
+    <insert id="replaceTokenInfo">
+        replace
+        into jy_promoter_access_token(promoter_id,app_key,app_secret,sign_secret,access_token,refresh_token )
+                VALUES (
+        #{promoterId},
+        #{appId},
+        #{appSecret},
+        #{signSecret},
+        #{accessToken},
+        #{refreshToken}
+        )
+    </insert>
+</mapper>