zhanghua
2023-08-17 8945b94fc922fc6598f7558b318dc7674f525b70
bug修改
5个文件已修改
116 ■■■■ 已修改文件
ycl-platform/src/main/java/com/ycl/controller/dingding/DingController.java 76 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
ycl-platform/src/main/java/com/ycl/timer/GetDingToken.java 18 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
ycl-platform/src/main/java/com/ycl/timer/GetDingUserOrgTimer.java 12 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
ycl-platform/src/main/resources/application-dev.yml 8 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
ycl-platform/src/main/resources/application.yml 2 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
ycl-platform/src/main/java/com/ycl/controller/dingding/DingController.java
@@ -1,8 +1,14 @@
package com.ycl.controller.dingding;
import cn.hutool.core.util.ObjectUtil;
import com.alibaba.fastjson.JSONObject;
import com.alibaba.xxpt.gateway.shared.client.http.ExecutableClient;
import com.alibaba.xxpt.gateway.shared.client.http.GetClient;
import com.alibaba.xxpt.gateway.shared.client.http.PostClient;
import com.ycl.api.CommonResult;
import com.ycl.bo.AdminUserDetails;
import com.ycl.common.dingding.DingCommon;
import com.ycl.config.DingConfig;
import com.ycl.controller.BaseController;
import com.ycl.entity.dingding.DingUserInfo;
import com.ycl.service.auth.AuthService;
@@ -12,18 +18,24 @@
import com.ycl.vo.NewAddressBookVO;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.security.core.context.SecurityContextHolder;
import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import static com.ycl.common.constant.DingConst.GET_TIKER;
import static com.ycl.common.constant.DingConst.GET_TOKEN;
@RestController
@RequestMapping("/ding")
@Api(tags = "钉钉")
@Slf4j
public class DingController extends BaseController {
    @Autowired
@@ -46,6 +58,13 @@
    @Autowired
    private BookRemarkService bookRemarkService;
    @Resource
    private ExecutableClient executableClient;
    @Resource
    private DingConfig dingConfig;
    @ApiOperation(value = "根据钉钉授权码获取token")
    @GetMapping("/dingLogin")
    public CommonResult<Map> dingLogin(@RequestParam String code) {
@@ -58,6 +77,60 @@
        map.put("tokenHead", tokenHead);
        map.put("accountId", dingUser.getAccountId());
        return CommonResult.success(map);
    }
    @ApiOperation(value = "根据钉钉授权码获取jsapiToken")
    @GetMapping("/dingTicker")
    public CommonResult<Map> dingTicker() {
        String accessToken = getToken();
        String ticket = getTiker(accessToken);
        HashMap<String, Object> map = new HashMap<>();
        map.put("accessToken", accessToken);
        map.put("ticket", ticket);
        return CommonResult.success(map);
    }
    private String getToken() {
        //调用API
        GetClient getTokenClient = executableClient.newGetClient(GET_TOKEN);
        //设置参数
        getTokenClient.addParameter("appkey", dingConfig.getAppKey());
        getTokenClient.addParameter("appsecret", dingConfig.getAppSecret());
        String apiResult = getTokenClient.get();
        return parsingResult(apiResult);
    }
    private String getTiker(String accToken) {
        //调用API
        PostClient postClient = executableClient.newPostClient(GET_TIKER);
        //设置参数
        if (ObjectUtil.isNotNull(accToken)) {
            postClient.addParameter("accessToken", accToken);
            postClient.addParameter("appkey", dingConfig.getAppKey());
            postClient.addParameter("appsecret", dingConfig.getAppSecret());
            String apiResult = postClient.post();
            return parsingResult(apiResult);
        }
        return null;
    }
    private String parsingResult(String apiResult) {
        if (ObjectUtil.isNotNull(apiResult)) {
            JSONObject resJson = JSONObject.parseObject(apiResult);
            if (resJson.getBoolean("success")) {
                JSONObject content = resJson.getJSONObject("content");
                if (content.getBoolean("success")) {
                    JSONObject dataObj = content.getJSONObject("data");
                    String accessToken = dataObj.getString("accessToken");
                    return accessToken;
                }
            } else {
                log.error(resJson.toJSONString());
            }
        }
        return null;
    }
    @ApiOperation(value = "通讯录")
@@ -77,15 +150,12 @@
    }
    @ApiOperation(value = "通讯录递归")
    @GetMapping("/getDddressBook")
    public CommonResult<NewAddressBookVO> getNewAddressBook(@RequestParam("id") Long id) {
        AdminUserDetails user = (AdminUserDetails) SecurityContextHolder.getContext().getAuthentication().getPrincipal();
        return CommonResult.success(dingService.getAddressBookById(id, user.getUserId()));
    }
    @ApiOperation(value = "修改通讯录备注")
ycl-platform/src/main/java/com/ycl/timer/GetDingToken.java
@@ -93,14 +93,14 @@
    }
    @Scheduled(cron ="0 0/2 * * * ? ")
    public void runAction() {
        // //gettoken
        // String getToken = getToken();
        // //jsApi
        // String jsapiToken = getTiker(getToken);
        // //存储到redis
        // JSONObject dingObj = new JSONObject();
        // dingObj.put("token", getToken);
        // dingObj.put("jsApiTiker", jsapiToken);
        // redisTemplate.opsForValue().set("ding", dingObj.toJSONString(), 2L, TimeUnit.HOURS);
         //gettoken
         String getToken = getToken();
         //jsApi
         String jsapiToken = getTiker(getToken);
         //存储到redis
         JSONObject dingObj = new JSONObject();
         dingObj.put("token", getToken);
         dingObj.put("jsApiTiker", jsapiToken);
         redisTemplate.opsForValue().set("ding", dingObj.toJSONString(), 2L, TimeUnit.HOURS);
    }
}
ycl-platform/src/main/java/com/ycl/timer/GetDingUserOrgTimer.java
@@ -52,11 +52,11 @@
    @Override
    public void onApplicationEvent(ContextRefreshedEvent contextRefreshedEvent) {
        // if (contextRefreshedEvent.getApplicationContext().getParent() == null) {
        //     Thread thread = new Thread(this::run);
        //     thread.setUncaughtExceptionHandler(handler);
        //     thread.start();
        // }
         if (contextRefreshedEvent.getApplicationContext().getParent() == null) {
             Thread thread = new Thread(this::run);
             thread.setUncaughtExceptionHandler(handler);
             thread.start();
         }
    }
    @Autowired
@@ -204,6 +204,6 @@
    @Override
    public void run(ApplicationArguments args) throws Exception {
        // run();
         run();
    }
}
ycl-platform/src/main/resources/application-dev.yml
@@ -79,3 +79,11 @@
    keyId: LTAI5tRpMjypcziJ2WAWEKsV
    keySecret: U7CPi1JqOWvTbdLR99duJ8ev3tcjRp
    bucketName: upload-bzh-new
#专有钉钉参数
zzding :
  app-key : SC_ZHZF-IC5g2YiRDW8tug1DfAfiui
  app-secret : 39RIHFOKd8fUeeW9T7CdBcwEqA6dMKx5d3686B6P
  domain-name : openplatform.dg-work.cn
  protocal : https
  tenant-id : 50645661
ycl-platform/src/main/resources/application.yml
@@ -90,3 +90,5 @@
      - /**/api/**
      - /**/text/**
      - /**/API/**
      - /**/ding/**
      - /**/sccg_region/**