支付宝授权

pom.xml

@@ -432,6 +432,17 @@
             <artifactId>weixin-java-mp</artifactId>
             <version>4.3.8.B</version>
         </dependency>
+        <!--集成企业微信-->
+        <dependency>
+            <groupId>com.github.binarywang</groupId>
+            <artifactId>weixin-java-cp</artifactId>
+            <version>4.6.0</version>
+        </dependency>
+        <dependency>
+            <groupId>com.alipay.sdk</groupId>
+            <artifactId>alipay-sdk-java</artifactId>
+            <version>4.34.0.ALL</version>
+        </dependency>
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-configuration-processor</artifactId>

src/main/java/com/ydtech/modules/admin/controller/AlipayController.java

@@ -0,0 +1,63 @@
+package com.ydtech.modules.admin.controller;
+
+import com.alipay.api.AlipayApiException;
+import com.ydtech.core.page.HttpResult;
+import com.ydtech.exception.SystemException;
+import com.ydtech.modules.admin.model.SysUser;
+import com.ydtech.modules.admin.model.vo.*;
+import com.ydtech.modules.admin.service.AlipayService;
+import com.ydtech.modules.admin.service.SysUserService;
+import com.ydtech.modules.admin.service.WechatService;
+import com.ydtech.modules.base.controller.BaseController;
+import com.ydtech.modules.protocol.utils.AssertionUtils;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import me.chanjar.weixin.common.error.WxErrorException;
+import org.springframework.web.bind.annotation.*;
+
+@Api(tags = "支付宝业务")
+@Slf4j
+@RestController
+@RequestMapping("/alipay")
+@RequiredArgsConstructor
+public class AlipayController extends BaseController {
+
+    private final AlipayService alipayService;
+
+    private final SysUserService sysUserService;
+
+
+    @PostMapping("/login")
+    @ApiOperation(value = "登录")
+    public HttpResult<AlipayVo> login(@RequestBody AlipayBindVo alipayBindVo) {
+        try {
+            return alipayService.login(alipayBindVo);
+        } catch (AlipayApiException e) {
+            log.info(e.getMessage());
+            throw new SystemException("支付宝授权失败");
+        }
+    }
+
+
+    @PostMapping("/bind")
+    @ApiOperation(value = "工号绑定支付宝")
+    HttpResult<Object> bind(@RequestBody AlipayBindVo alipayBindVo) throws AlipayApiException {
+        try {
+            String userId = getUserId();
+            return alipayService.bind(alipayBindVo, userId);
+        } catch (AlipayApiException e) {
+            throw new SystemException("支付宝授权失败");
+        }
+    }
+
+    @ApiOperation(value = "是否绑定支付宝")
+    @GetMapping(value = "/isBindAlipay")
+    public HttpResult<Object> isBindAlipay() {
+        SysUser sysUser = sysUserService.getById(getUserId());
+        String alipayId = sysUser.getAlipay();
+        AssertionUtils.isStringEmpty(alipayId, "未绑定支付宝");
+        return HttpResult.ok();
+    }
+}

src/main/java/com/ydtech/modules/admin/model/SysUser.java

@@ -96,6 +96,12 @@ public class SysUser extends BaseEntity {
     @TableField(value = "openid")
     private String openid;
 
+    /**
+     * 支付宝id
+     */
+    @TableField(value = "alipay")
+    private String alipay;
+
     /**
      * 审批意见
      */

src/main/java/com/ydtech/modules/admin/model/vo/AlipayBindVo.java

@@ -0,0 +1,8 @@
+package com.ydtech.modules.admin.model.vo;
+
+import lombok.Data;
+
+@Data
+public class AlipayBindVo {
+    private String code;
+}

src/main/java/com/ydtech/modules/admin/model/vo/AlipayVo.java

@@ -0,0 +1,18 @@
+package com.ydtech.modules.admin.model.vo;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+
+@ApiModel("支付宝登录返回实体")
+@AllArgsConstructor
+@Data
+public class AlipayVo {
+        @ApiModelProperty("登录token")
+        private String token;
+
+        @ApiModelProperty("用户id")
+        private String userId;
+
+    }

src/main/java/com/ydtech/modules/admin/service/AlipayService.java

@@ -0,0 +1,18 @@
+package com.ydtech.modules.admin.service;
+
+import com.alipay.api.AlipayApiException;
+import com.ydtech.core.page.HttpResult;
+import com.ydtech.modules.admin.model.vo.AlipayBindVo;
+import com.ydtech.modules.admin.model.vo.AlipayVo;
+
+public interface AlipayService {
+    /**
+     * 微信登录
+     */
+    HttpResult<AlipayVo> login(AlipayBindVo alipayBindVo) throws AlipayApiException;
+
+    /**
+     * 绑定微信
+     */
+    HttpResult<Object> bind(AlipayBindVo alipayBindVo, String userId) throws AlipayApiException;
+}

src/main/java/com/ydtech/modules/admin/service/impl/AlipayServiceImpl.java

@@ -0,0 +1,106 @@
+package com.ydtech.modules.admin.service.impl;
+
+import cn.dev33.satoken.stp.StpUtil;
+import com.alipay.api.AlipayApiException;
+import com.alipay.api.AlipayClient;
+import com.alipay.api.AlipayConfig;
+import com.alipay.api.DefaultAlipayClient;
+import com.alipay.api.request.AlipaySystemOauthTokenRequest;
+import com.alipay.api.response.AlipaySystemOauthTokenResponse;
+import com.ydtech.core.page.HttpResult;
+import com.ydtech.exception.SystemException;
+import com.ydtech.modules.admin.model.SysUser;
+import com.ydtech.modules.admin.model.vo.AlipayBindVo;
+import com.ydtech.modules.admin.model.vo.AlipayVo;
+import com.ydtech.modules.admin.service.AlipayService;
+import com.ydtech.modules.admin.service.SysUserService;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+import org.springframework.util.ObjectUtils;
+
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class AlipayServiceImpl implements AlipayService {
+
+    private final SysUserService sysUserService;
+    @Override
+    public HttpResult<AlipayVo> login(AlipayBindVo alipayBindVo) throws AlipayApiException {
+        AlipayClient alipayClient = new DefaultAlipayClient(getAlipayConfig());
+
+        // 构造请求参数以调用接口
+        AlipaySystemOauthTokenRequest request = new AlipaySystemOauthTokenRequest();
+
+        // 设置授权码
+        request.setCode(alipayBindVo.getCode());
+
+        // 设置授权方式
+        request.setGrantType("authorization_code");
+
+        AlipaySystemOauthTokenResponse response = alipayClient.execute(request);
+        String aliPayId = response.getUserId();
+        SysUser sysUser = sysUserService.lambdaQuery()
+                .eq(SysUser::getOpenid, aliPayId)
+                .one();
+
+        // 没有绑定微信
+        if (sysUser == null) {
+            throw new SystemException("您还未绑定工号");
+        }
+
+        String token = StpUtil.createLoginSession(sysUser.getId());
+        AlipayVo alipayVo = new AlipayVo(token, sysUser.getId());
+        return HttpResult.ok("",alipayVo);
+    }
+
+
+    @Override
+    public HttpResult<Object> bind(AlipayBindVo alipayBindVo, String userId) throws AlipayApiException {
+
+        AlipayClient alipayClient = new DefaultAlipayClient(getAlipayConfig());
+
+        // 构造请求参数以调用接口
+        AlipaySystemOauthTokenRequest request = new AlipaySystemOauthTokenRequest();
+
+        // 设置授权码
+        request.setCode(alipayBindVo.getCode());
+
+        // 设置授权方式
+        request.setGrantType("authorization_code");
+
+        AlipaySystemOauthTokenResponse response = alipayClient.execute(request);
+        String aliPayId = response.getUserId();
+        SysUser sysUser = sysUserService.lambdaQuery().eq(SysUser::getAlipay, aliPayId).one();
+        if (sysUser != null) {
+            throw new SystemException("同一支付宝不能重复绑定");
+        }
+
+        SysUser user = sysUserService.lambdaQuery().eq(SysUser::getId, userId).one();
+        if (ObjectUtils.isEmpty(user)) {
+            throw new SystemException("你输入的工号不存在");
+        }
+
+        user.setAlipay(aliPayId);
+        boolean update = sysUserService.updateById(user);
+
+        if (update) {
+            return HttpResult.ok("绑定成功");
+        }
+        throw new SystemException("绑定失败");
+    }
+
+    private static AlipayConfig getAlipayConfig() {
+        String privateKey  = "MIIEvQIBADANBgkqhkiG9w0BAQEFAASCBKcwggSjAgEAAoIBAQCmb0GfNv7ex5SmUiBnMn3szFP4XM5c8KnYll6HGoFCQTxwMSVYq652ELBtGAScqV9QOVcF/1Z1NF+a0AabGd0qSKKsPOhHNg3vG4yHHs4gwOdqFxwjATXqgHaZXSIQGnoPUJ3J05AlYLlinm9oOoTAY68880pM9h9d7t4Aq4WqVfnGteNaV5+oaV/KgX2OGo7m3WPR+e5Yjl9xxYXjVF1Uv7hznNER74KuYhRP44759lgfo0RlncGXuaygKHoxCpKTozGmvedP0hTO/WJTEi5l11Gp4mfMN9Gb/VtjsRDJaCFMmXU19UcHOFxyFOrKoyNYxdj3ue07/l51l4+8TVyJAgMBAAECggEBAJGR09qW9nsSIxEJ2e+I+RzpZjRfr9sYX+XhN1KBuzag6mTSh3Cz0IbReA4jKL2BYq0/Sb8kIpGmukwk0PJNv+Rg3W86YosOW0ecV+BC8FUzg/SFvAVd5LNzosfm7okZL1M/1pKVaYlXvS3ll1mZfUzso3Py8zS3PJ4i86ewXdupp2HcQt8c5O57lkzdhi35a38k9RrrSsYgnUClAMFWvmN4x1v7vuddzW0/q5Ztg1k9Ukz209dMOIc5cZ8+zyX5PO0rEofUETMtF5D5N2qtsMsMlDxvYq7aQoNq5I1p8e2mjZv5U7EvkLENTZmPRtAdddut1LGACU0AAlvvOOgu9wECgYEA27Q/EuQPfFh/aOYyi6zq0AWFN2U+tN/y3/nAvGymisdp6c2q1s6ESvENJep7v9PR/cownHKIllTJbzh03DKrQd0LYJrh4CFr6xv5DSUXMft5+6Te+t1FpULqhtkVLcqqTSqMRo8Yl/QMDxI6mRd4pmEFscOIEW+5lzyofxfL7mECgYEAwe4hNIyz2b/uBCCUMPA8CL8kJILqw0ZHB4EekoLugqYHAi3LPCDpJzFJ3pcZXjUdH9TUKQp67eizk+xedfFdicm0ENzPqCoUPidT88QZImaP8uP2LblTlxNCDf8D15BQzBHDlTDN+2tzFi7qAb3v2mgK5U9WGOOkicmMGzv8jykCgYARP3hIKmFQ2L2/5XqIXp3ckOJhc/BVUNOHY9sOr9TvRjJ5aW0FChd2rq/ijyMB70YoD2x7i75PVv6tXZhHBS9Or2TKQ76B0v3e6kZGEuhcQyrTZ6EdvqtOCw/QYFB6VNPD1RhIHcnHfCBKOpshE6ekIC/LQdd3zvaZ+egceijHYQKBgDgN250z2jxjZKnevNbUaZXhodHH4ZGl+5vor2yL2eL7mGUB1Y/At4OzlHV5WUTIt21e+CAQvm2L6HQmSztuE6pjGeAR4xfpacZ5WaPJF7bAzHTZfWvD+KxfTaV8A6FIPoJt1AmIfNFiQna0AsGUJAMONbAIWYuCKSoGjq/EjADZAoGAS0ZaZdPKKQnd4g/lqM8CnHTfhW11ANP/rPZDU+NvjW2jQ6SIdJhwJaKMEQCcDp63j0SADlghzrvm+KMbnTrFqTHlAizcFxnOOOxO1pKXKuOJWWsyNBN33suB3XPFrsobEtmtnWyvph1GoAZOX457RN5LSmBTbqpbyEsjKg/W1zc=";
+        String alipayPublicKey = "MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEArP+St5P9dLhPmm/ggf3jPDc2552wu/+91QSAzlEqRSrdWAIwrHcntM0VY/4/+39Z8h44/0TBNTb0j1gdWrCyb+1ENxwwgCqs7f8C/5gClTQCcoNys4MtGAAM7BbNp/LzmswOuPTOMtjlUBArWFvJDgDoSQJ8vGwGHgRcLsSLPwlhwVdnqVbq60CI185U/yZgNITTCGpDXv5bnQQ26GrUbH+5Qm4fYmT2B/2ijAVJUYq+EaBMOyv+AD8C1+CtXcgH86+g13MdD1T8cw5nkV9/4fcPIWD8R1aj20C1+kCMujaydB4yDpHiqQcQEtJoVbZJk5MYp8JcctqDT01brVct5wIDAQAB";
+        AlipayConfig alipayConfig = new AlipayConfig();
+        alipayConfig.setServerUrl("https://openapi.alipay.com/gateway.do");
+        alipayConfig.setAppId("2021004153668213");
+        alipayConfig.setPrivateKey(privateKey);
+        alipayConfig.setFormat("json");
+        alipayConfig.setAlipayPublicKey(alipayPublicKey);
+        alipayConfig.setCharset("UTF-8");
+        alipayConfig.setSignType("RSA2");
+        return alipayConfig;
+    }
+}