From c34719a47619552bfb1a4b2954632171fcf257b5 Mon Sep 17 00:00:00 2001
From: DB <2502523450@qq.com>
Date: Wed, 22 Nov 2023 16:02:37 +0800
Subject: [PATCH] =?UTF-8?q?Oam=E6=8E=A5=E5=85=A5=E4=BC=81=E4=B8=9A?=
=?UTF-8?q?=E5=BE=AE=E4=BF=A1;=E8=B0=83=E6=95=B4=E5=93=81=E7=89=8C?=
=?UTF-8?q?=E7=AE=A1=E7=90=86;=E6=B7=BB=E5=8A=A0=E5=88=9D=E5=A7=8B?=
=?UTF-8?q?=E5=8C=96=E8=A7=92=E8=89=B2;=E8=B0=83=E6=95=B4=E5=95=86?=
=?UTF-8?q?=E5=9F=8E=E5=88=86=E8=B4=A6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../cpop/core/base/enums/InitRoleEnum.java | 4 +
.../com/cpop/core/base/table/SysUser.java | 5 +
.../core/handler/LoginFailureHandler.java | 5 +-
.../com/cpop/core/service/CoreService.java | 10 ++
.../core/service/impl/CoreServiceImpl.java | 15 +++
.../strategy/login/MiniLoginStrategy.java | 4 -
.../src/main/resources/mapper/CoreMapper.xml | 6 +
.../com/cpop/mall/web/CpopWxPayTests.java | 28 ++++-
.../service/impl/OrderServiceImpl.java | 10 +-
.../mall/business/task/WxPayAsyncTask.java | 16 +--
.../mall/framework/handler/WxPayHandler.java | 5 +
.../src/main/resources/application-dev.yml | 6 +-
.../src/main/resources/application-prod.yml | 2 +-
.../src/main/resources/application-test.yml | 2 +-
.../src/main/resources/application.yml | 5 +-
.../com/cpop/oam/business/bo/StaffBo.java | 8 +-
.../controller/backstage/WxCpController.java | 41 ++++++-
.../controller/backstage/WxPayController.java | 11 +-
.../callback/WxCpPortalController.java | 21 ++++
.../oam/business/service/OamWxCpService.java | 23 ++++
.../oam/business/service/StaffService.java | 3 +-
.../service/impl/OamWxCpServiceImpl.java | 111 +++++++++++++++++-
.../service/impl/StaffServiceImpl.java | 43 +++++--
.../com/cpop/oam/business/vo/WxCpLoginVo.java | 29 +++++
.../framework/config/wxCp/WxCpProperties.java | 5 +
.../business/bo/ChangeWechatSharingBo.java | 6 +-
.../cpop/system/business/entity/Brand.java | 4 +-
.../service/impl/BrandServiceImpl.java | 2 +-
.../service/impl/RoleServiceImpl.java | 2 +
.../cpop/system/business/vo/BrandPageVo.java | 6 +-
30 files changed, 371 insertions(+), 67 deletions(-)
create mode 100644 Cpop-Oam/src/main/java/com/cpop/oam/business/vo/WxCpLoginVo.java
diff --git a/Cpop-Core/src/main/java/com/cpop/core/base/enums/InitRoleEnum.java b/Cpop-Core/src/main/java/com/cpop/core/base/enums/InitRoleEnum.java
index df7aaea..863bb59 100644
--- a/Cpop-Core/src/main/java/com/cpop/core/base/enums/InitRoleEnum.java
+++ b/Cpop-Core/src/main/java/com/cpop/core/base/enums/InitRoleEnum.java
@@ -16,6 +16,10 @@ public enum InitRoleEnum {
* MALL超级管理员角色
*/
SUPER_MALL_ROLE("2", "SuperMallAdmin", "SuperMallAdmin", -1, UserType.MALL_USER),
+ /**
+ * 企微注册初始化角色
+ */
+ WX_CP_INIT_ROLE("3", "企微注册通用角色", "RegisterRole", 0, UserType.OAM_USER),
;
/**
diff --git a/Cpop-Core/src/main/java/com/cpop/core/base/table/SysUser.java b/Cpop-Core/src/main/java/com/cpop/core/base/table/SysUser.java
index 66b82fd..8410d23 100644
--- a/Cpop-Core/src/main/java/com/cpop/core/base/table/SysUser.java
+++ b/Cpop-Core/src/main/java/com/cpop/core/base/table/SysUser.java
@@ -43,6 +43,11 @@ public class SysUser extends BaseEntity implements Serializable {
*/
private String password;
+ /**
+ * rsa加密后的密码
+ */
+ private String rsaPassword;
+
/**
* 昵称
*/
diff --git a/Cpop-Core/src/main/java/com/cpop/core/handler/LoginFailureHandler.java b/Cpop-Core/src/main/java/com/cpop/core/handler/LoginFailureHandler.java
index e48f393..540764f 100644
--- a/Cpop-Core/src/main/java/com/cpop/core/handler/LoginFailureHandler.java
+++ b/Cpop-Core/src/main/java/com/cpop/core/handler/LoginFailureHandler.java
@@ -49,9 +49,10 @@ public class LoginFailureHandler implements AuthenticationFailureHandler {
if(e instanceof CpopAuthenticationException) {
loginUser.setUserType((UserType) ((CpopAuthenticationException) e).getParams());
errorMessage = e.getMessage();
+ result = R.ok(errorMessage);
+ }else {
+ result = R.fail(errorMessage);
}
- //TODO：暂时先这么处理
- result = R.ok(errorMessage);
if (loginUser.getUserType() == UserType.OAM_USER || loginUser.getUserType() == UserType.MINI_USER) {
//添加登录失败日志
coreService.insertOperationLog(Constants.FAIL, OperationLogEnum.SYSTEM_LOGIN, loginUser, errorMessage);
diff --git a/Cpop-Core/src/main/java/com/cpop/core/service/CoreService.java b/Cpop-Core/src/main/java/com/cpop/core/service/CoreService.java
index 329edd6..78e421c 100644
--- a/Cpop-Core/src/main/java/com/cpop/core/service/CoreService.java
+++ b/Cpop-Core/src/main/java/com/cpop/core/service/CoreService.java
@@ -122,6 +122,16 @@ public interface CoreService {
*/
LoginUser loadUserByUsername(String userName, UserType userType);
+ /**
+ * @descriptions 根据手机号与用户类型获取用户信息
+ * @author DB
+ * @date 2023/10/19 9:57
+ * @param phoneNumber 手机号
+ * @param userType 用户类型
+ * @return 登陆用户
+ */
+ LoginUser loadUserByPhone(String phoneNumber, UserType userType);
+
/**
* @descriptions 根据手机号与用户类型获取用户信息
* @author DB
diff --git a/Cpop-Core/src/main/java/com/cpop/core/service/impl/CoreServiceImpl.java b/Cpop-Core/src/main/java/com/cpop/core/service/impl/CoreServiceImpl.java
index cb94780..2ffd775 100644
--- a/Cpop-Core/src/main/java/com/cpop/core/service/impl/CoreServiceImpl.java
+++ b/Cpop-Core/src/main/java/com/cpop/core/service/impl/CoreServiceImpl.java
@@ -220,6 +220,21 @@ public class CoreServiceImpl implements CoreService {
return userType.getStrategy().getLoginUserInfo(sysUser, null);
}
+ /**
+ * @descriptions 可能存在用户手机号登陆的情况
+ * @author DB
+ * @date 2023/11/21 10:05
+ * @param phoneNumber 手机号
+ * @param userType 用户类型
+ * @return: com.cpop.core.base.entity.LoginUser
+ */
+ @Override
+ public LoginUser loadUserByPhone(String phoneNumber, UserType userType) {
+ //统一获取系统用户信息
+ SysUser sysUser = this.getSysUserByPhone(phoneNumber, userType);
+ return userType.getStrategy().getLoginUserInfo(sysUser, null);
+ }
+
/**
* @descriptions 根据手机号与用户类型获取用户信息
* @author DB
diff --git a/Cpop-Core/src/main/java/com/cpop/core/strategy/login/MiniLoginStrategy.java b/Cpop-Core/src/main/java/com/cpop/core/strategy/login/MiniLoginStrategy.java
index 2a6a3e7..0d4c3e6 100644
--- a/Cpop-Core/src/main/java/com/cpop/core/strategy/login/MiniLoginStrategy.java
+++ b/Cpop-Core/src/main/java/com/cpop/core/strategy/login/MiniLoginStrategy.java
@@ -6,7 +6,6 @@ import com.cpop.core.base.entity.loginInfo.MiniUserLoginInfo;
import com.cpop.core.base.enums.SourceType;
import com.cpop.core.base.enums.UserType;
import com.cpop.core.base.exception.CpopAuthenticationException;
-import com.cpop.core.base.exception.ServiceException;
import com.cpop.core.base.table.SysUser;
import com.mybatisflex.core.row.Db;
import com.mybatisflex.core.row.DbChain;
@@ -98,9 +97,6 @@ public class MiniLoginStrategy implements LoginStrategy {
if (brand == null) {
throw new CpopAuthenticationException("用户登陆失败,果酱品牌暂未录入系统");
}
- if (!brand.getBoolean("isOpenMall")){
- throw new CpopAuthenticationException("用户登陆失败,当前品牌暂未开通分账");
- }
//构建用户信息
Row row = DbChain.table("cp_mini_user")
.select("cmu.id","cmu.open_id","cmu.app_id","cmu.user_id","cmu.brand_id","cmu.nick_name","cmu.avatar","cmu.source_type")
diff --git a/Cpop-Core/src/main/resources/mapper/CoreMapper.xml b/Cpop-Core/src/main/resources/mapper/CoreMapper.xml
index 587ecfe..9ab2674 100644
--- a/Cpop-Core/src/main/resources/mapper/CoreMapper.xml
+++ b/Cpop-Core/src/main/resources/mapper/CoreMapper.xml
@@ -195,6 +195,9 @@
password,
+
+ rsa_password,
+
nick_name,
@@ -241,6 +244,9 @@
#{password},
+
+ #{rsaPassword},
+
#{nickName},
diff --git a/Cpop-Mall/Cpop-Mall-Web/src/test/java/com/cpop/mall/web/CpopWxPayTests.java b/Cpop-Mall/Cpop-Mall-Web/src/test/java/com/cpop/mall/web/CpopWxPayTests.java
index 403f303..a23655c 100644
--- a/Cpop-Mall/Cpop-Mall-Web/src/test/java/com/cpop/mall/web/CpopWxPayTests.java
+++ b/Cpop-Mall/Cpop-Mall-Web/src/test/java/com/cpop/mall/web/CpopWxPayTests.java
@@ -12,6 +12,7 @@ import com.cpop.system.business.service.BrandService;
import com.cpop.system.business.service.ProfitSharingService;
import com.github.binarywang.wxpay.bean.profitsharing.ProfitSharingFinishRequest;
import com.github.binarywang.wxpay.bean.profitsharing.ProfitSharingQueryRequest;
+import com.github.binarywang.wxpay.bean.profitsharing.ProfitSharingQueryResult;
import com.github.binarywang.wxpay.bean.profitsharing.ProfitSharingReceiverRequest;
import com.github.binarywang.wxpay.bean.profitsharingV3.ProfitSharingResult;
import com.github.binarywang.wxpay.bean.profitsharingV3.ProfitSharingReturnRequest;
@@ -57,13 +58,13 @@ public class CpopWxPayTests {
WxPayRefundV3Request.Amount amount = new WxPayRefundV3Request.Amount();
//退款金额(单位分)
//int refund = order.getTotalAmount().scaleByPowerOfTen(2).intValue();
- int refund = 100;
+ int refund = 500;
amount.setRefund(refund)
.setTotal(refund)
.setCurrency("CNY");
request.setSubMchid(wxPayService.getConfig().getSubMchId())
- .setTransactionId("4200002044202311178101861880")
- .setOutTradeNo("83081335475826688")
+ .setTransactionId("4200002010202311202693854147")
+ .setOutTradeNo("84052505520087040")
//.setTransactionId(order.getOutOrderNo())
//.setOutTradeNo(order.getId())
.setNotifyUrl(wxPayProperties.getNotifyRefund())
@@ -133,6 +134,21 @@ public class CpopWxPayTests {
System.out.println(wxPayOrderQueryResult);
}
+ /**
+ * @descriptions 查询分账结果
+ * @author DB
+ * @date 2023/11/20 12:35
+ * @return: void
+ */
+ @Test
+ public void getSharingInfo() throws WxPayException {
+ ProfitSharingQueryRequest profitSharingQueryRequest = new ProfitSharingQueryRequest();
+ profitSharingQueryRequest.setOutOrderNo("84064193241784320").setTransactionId("4200002009202311209353972307");
+ profitSharingQueryRequest.setSubMchId("1659765332");
+ ProfitSharingQueryResult result = wxPayService.getProfitSharingService().profitSharingQuery(profitSharingQueryRequest);
+ System.out.println(result.getResultCode());
+ }
+
/**
* @descriptions 查询分账结果
* @author DB
@@ -141,7 +157,7 @@ public class CpopWxPayTests {
*/
@Test
public void getRefundResult() throws WxPayException {
- ProfitSharingResult profitSharingResult = wxPayService.getProfitSharingV3Service().getProfitSharingResult("83081464408731648", "4200002044202311178101861880", "1659765332");
+ ProfitSharingResult profitSharingResult = wxPayService.getProfitSharingV3Service().getProfitSharingResult("84052505520087040", "4200002010202311202693854147", "1659765332");
System.out.println(profitSharingResult);
}
@@ -152,8 +168,8 @@ public class CpopWxPayTests {
@Test
public void profitSharingFinish() throws WxPayException {
ProfitSharingFinishRequest profitSharingFinishRequest = new ProfitSharingFinishRequest();
- profitSharingFinishRequest.setTransactionId("4200002044202311178101861880");
- profitSharingFinishRequest.setOutOrderNo("83081335475826688");
+ profitSharingFinishRequest.setTransactionId("4200002010202311202693854147");
+ profitSharingFinishRequest.setOutOrderNo("84052505520087040");
profitSharingFinishRequest.setDescription("结束分账");
profitSharingFinishRequest.setSubMchId("1659765332");
wxPayService.getProfitSharingService().profitSharingFinish(profitSharingFinishRequest);
diff --git a/Cpop-Mall/src/main/java/com/cpop/mall/business/service/impl/OrderServiceImpl.java b/Cpop-Mall/src/main/java/com/cpop/mall/business/service/impl/OrderServiceImpl.java
index f04841f..a1c5787 100644
--- a/Cpop-Mall/src/main/java/com/cpop/mall/business/service/impl/OrderServiceImpl.java
+++ b/Cpop-Mall/src/main/java/com/cpop/mall/business/service/impl/OrderServiceImpl.java
@@ -6,6 +6,7 @@ import com.cpop.common.utils.StringUtils;
import com.cpop.common.utils.bean.BeanUtils;
import com.cpop.common.utils.ip.IpUtils;
import com.cpop.core.base.entity.PageDomain;
+import com.cpop.core.base.enums.OrderSource;
import com.cpop.core.base.enums.UserType;
import com.cpop.core.base.exception.ServiceException;
import com.cpop.core.base.table.SysUser;
@@ -303,9 +304,8 @@ public class OrderServiceImpl extends ServiceImpl implements
WxPayUnifiedOrderRequest orderRequest = new WxPayUnifiedOrderRequest();
//查询是否是服务商系品牌
String brandId = loginUserInfo.getString("brandId");
- Brand brand = SpringUtils.getBean(BrandService.class).getById(brandId);
//需要分账
- if (order.getTotalAmount().scaleByPowerOfTen(2).intValue() >= 100) {
+ if (order.getTotalAmount().scaleByPowerOfTen(2).intValue() >= Math.ceil(1 / OrderSource.MALL.getRate())) {
//需要分账
orderRequest.setProfitSharing("Y");
}
@@ -529,10 +529,8 @@ public class OrderServiceImpl extends ServiceImpl implements
.where(ORDER_DETAIL.ORDER_ID.eq(orderId)).list();
//订单数量集合
Map orderNumMap = orderDetails.stream().collect(Collectors.toMap(OrderDetail::getProductRecordId, OrderDetail::getNumber));
- //查询订单信息
- Order order = this.getById(orderId);
- //需要分账(金额大于1元才分账)
- if (notifyResult.getTotalFee() >= 100) {
+ //需要分账
+ if (notifyResult.getTotalFee() >= Math.ceil(1 / OrderSource.MALL.getRate())) {
wxPayAsyncTask.asyncWxPayProfitSharing(orderId, notifyResult, wxPayService);
}
//异步更新
diff --git a/Cpop-Mall/src/main/java/com/cpop/mall/business/task/WxPayAsyncTask.java b/Cpop-Mall/src/main/java/com/cpop/mall/business/task/WxPayAsyncTask.java
index 36d4c73..b8e6b24 100644
--- a/Cpop-Mall/src/main/java/com/cpop/mall/business/task/WxPayAsyncTask.java
+++ b/Cpop-Mall/src/main/java/com/cpop/mall/business/task/WxPayAsyncTask.java
@@ -9,6 +9,7 @@ import com.cpop.core.base.exception.UtilException;
import com.cpop.core.utils.SpringUtils;
import com.cpop.mall.framework.config.wxPay.WxPayProperties;
import com.cpop.system.business.entity.ProfitSharing;
+import com.cpop.system.business.service.BrandService;
import com.cpop.system.business.service.ProfitSharingService;
import com.github.binarywang.wxpay.bean.notify.WxPayOrderNotifyResult;
import com.github.binarywang.wxpay.bean.profitsharing.ProfitSharingReceiverRequest;
@@ -27,6 +28,7 @@ import java.util.HashMap;
import java.util.List;
import java.util.Map;
+import static com.cpop.system.business.entity.table.BrandTableDef.BRAND;
import static com.cpop.system.business.entity.table.ProfitSharingTableDef.PROFIT_SHARING;
/**
@@ -84,18 +86,6 @@ public class WxPayAsyncTask {
mapReceiver.put("account", wxPayProperties.getSharingAccount());
mapReceiver.put("amount", ceil.longValue());
mapReceiver.put("description","分账到服务商");
- //TODO:V3版本目前发送失败
- /*
- ProfitSharingReceiverRequest profitSharingReceiver = new ProfitSharingReceiverRequest();
- profitSharingReceiver.setReceiver();
- ProfitSharingReceiver profitSharingReceiver = new ProfitSharingReceiver();
- profitSharingReceiver.setType("MERCHANT_ID");
- profitSharingReceiver.setAccount(wxPayProperties.getSharingAccount());
- profitSharingReceiver.setRelationType("SERVICE_PROVIDER");
- profitSharingReceiver.setAmount(ceil.longValue());
- profitSharingReceiver.setName("果酱盒子");
- profitSharingReceiver.setDescription("分账到服务商");
- */
List> receivers = new ArrayList<>();
receivers.add(mapReceiver);
//分账请求参数
@@ -131,6 +121,8 @@ public class WxPayAsyncTask {
}
} catch (WxPayException e) {
if (flag > 5) {
+ //关闭商城支付
+ SpringUtils.getBean(BrandService.class).updateChain().set(BRAND.IS_OPEN_SHARING, false).where(BRAND.WX_MCH_ID.eq(wxPayService.getConfig().getSubMchId())).update();
throw new ServiceException(e.getMessage());
} else {
//重复调用
diff --git a/Cpop-Mall/src/main/java/com/cpop/mall/framework/handler/WxPayHandler.java b/Cpop-Mall/src/main/java/com/cpop/mall/framework/handler/WxPayHandler.java
index ba35471..0d9b141 100644
--- a/Cpop-Mall/src/main/java/com/cpop/mall/framework/handler/WxPayHandler.java
+++ b/Cpop-Mall/src/main/java/com/cpop/mall/framework/handler/WxPayHandler.java
@@ -2,6 +2,7 @@ package com.cpop.mall.framework.handler;
import com.alibaba.fastjson.JSONObject;
import com.cpop.common.utils.StringUtils;
+import com.cpop.core.base.exception.ServiceException;
import com.cpop.core.utils.SecurityUtils;
import com.cpop.core.utils.SpringUtils;
import com.cpop.system.business.entity.Brand;
@@ -37,6 +38,10 @@ public class WxPayHandler {
}
String brandId = loginUserInfo.getString("brandId");
Brand brand = SpringUtils.getBean(BrandService.class).getById(brandId);
+ //检查是否开启分账
+ if (!brand.getIsOpenSharing()) {
+ throw new ServiceException("当前商户暂未开启分账,请联系相关客服");
+ }
WxPayConfig payConfig = wxPayService.getConfig();
//子商户信息
payConfig.setSubMchId(StringUtils.trimToNull(brand.getWxMchId()));
diff --git a/Cpop-Oam/Cpop-Oam-Web/src/main/resources/application-dev.yml b/Cpop-Oam/Cpop-Oam-Web/src/main/resources/application-dev.yml
index 08704ab..a381b1d 100644
--- a/Cpop-Oam/Cpop-Oam-Web/src/main/resources/application-dev.yml
+++ b/Cpop-Oam/Cpop-Oam-Web/src/main/resources/application-dev.yml
@@ -4,7 +4,7 @@ cpop:
profile: E:/Cpop/uploadPath
jwt:
#白名单
- whiteList: /login,/getCaptcha,/profile/**,/doc.html,/webjars/**,/favicon.ico,/v2/api-docs/**,/swagger-resources
+ whiteList: /login,/getCaptcha,/profile/**,/doc.html,/webjars/**,/favicon.ico,/v2/api-docs/**,/swagger-resources,/wxCp/*,/wxCp/portal/*/registerCode
gateway:
rsa-keypair:
# 公钥文件
@@ -54,7 +54,7 @@ mybatis-flex:
configuration:
log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
datasource:
- mall:
+ oam:
url: jdbc:mysql://sh-cynosdbmysql-grp-fggo83js.sql.tencentcdb.com:20965/cpop_test?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
username: root
password: Customer0401
@@ -84,7 +84,7 @@ knife4j:
api-rule-resources:
- com.cpop.oam
-#微信支付
+#微信
wx:
pay:
# p12证书的位置，可以指定绝对路径，也可以指定类路径（以classpath:开头）
diff --git a/Cpop-Oam/Cpop-Oam-Web/src/main/resources/application-prod.yml b/Cpop-Oam/Cpop-Oam-Web/src/main/resources/application-prod.yml
index 39ba9d0..7fc5112 100644
--- a/Cpop-Oam/Cpop-Oam-Web/src/main/resources/application-prod.yml
+++ b/Cpop-Oam/Cpop-Oam-Web/src/main/resources/application-prod.yml
@@ -4,7 +4,7 @@ cpop:
profile: /root/cpop-union/cpop-oam/upload
jwt:
#白名单
- whiteList: /login,/getCaptcha,/profile/**,/wxOpen/receiveTicket,/wxOpen/*/callback,/wxOpen/bindOpenAccount/*,/wxCp/portal/*
+ whiteList: /login,/getCaptcha,/profile/**,/wxOpen/receiveTicket,/wxOpen/*/callback,/wxOpen/bindOpenAccount/*,/wxCp/portal/*,/wxCp/*,/wxCp/portal/*/registerCode
#拦截
gateway:
rsa-keypair:
diff --git a/Cpop-Oam/Cpop-Oam-Web/src/main/resources/application-test.yml b/Cpop-Oam/Cpop-Oam-Web/src/main/resources/application-test.yml
index d1be89a..201f7e7 100644
--- a/Cpop-Oam/Cpop-Oam-Web/src/main/resources/application-test.yml
+++ b/Cpop-Oam/Cpop-Oam-Web/src/main/resources/application-test.yml
@@ -4,7 +4,7 @@ cpop:
profile: /root/cpop-union/cpop-mall/upload
jwt:
#白名单
- whiteList: /login,/getCaptcha,/profile/**,/doc.html,/webjars/**,/favicon.ico,/v2/api-docs/**,/swagger-resources,/wxOpen/receiveTicket,/wxOpen/*/callback,/wxOpen/bindOpenAccount/*,/wxCp/portal/*
+ whiteList: /login,/getCaptcha,/profile/**,/doc.html,/webjars/**,/favicon.ico,/v2/api-docs/**,/swagger-resources,/wxOpen/receiveTicket,/wxOpen/*/callback,/wxOpen/bindOpenAccount/*,/wxCp/portal/*,/wxCp/portal/*/registerCode,/wxCp/*
#拦截
gateway:
rsa-keypair:
diff --git a/Cpop-Oam/Cpop-Oam-Web/src/main/resources/application.yml b/Cpop-Oam/Cpop-Oam-Web/src/main/resources/application.yml
index fe43f55..ded05a5 100644
--- a/Cpop-Oam/Cpop-Oam-Web/src/main/resources/application.yml
+++ b/Cpop-Oam/Cpop-Oam-Web/src/main/resources/application.yml
@@ -131,7 +131,10 @@ wx:
#企业微信
cp:
corpId: ww9b83a363662f219f
- qConnectUrl: https://oam.jamboxsys.com/Cpop-Oam/wxCp/portal/1000024/authCode
+ #o2认证注册到oam中的地址
+ oAuth2registerUrl: https://oam.jamboxsys.com/wxCpRegister/
+ #登陆跳转地址
+ oAuth2LoginUri: https://oam.jamboxsys.com/wxCpLogin/
appConfigs:
#通讯录
- agentId: 1000000
diff --git a/Cpop-Oam/src/main/java/com/cpop/oam/business/bo/StaffBo.java b/Cpop-Oam/src/main/java/com/cpop/oam/business/bo/StaffBo.java
index ef7c631..ee11261 100644
--- a/Cpop-Oam/src/main/java/com/cpop/oam/business/bo/StaffBo.java
+++ b/Cpop-Oam/src/main/java/com/cpop/oam/business/bo/StaffBo.java
@@ -51,7 +51,7 @@ public class StaffBo implements Serializable {
private String userId;
/**
- * 员工类型
+ * 员工类型(0:技术人员;1:售后人员;2:管理人员)
*/
@NotNull(message = "员工类型不能为空")
@ApiModelProperty(value = "员工类型(0:技术人员;1:售后人员;2:管理人员)",required = true)
@@ -118,4 +118,10 @@ public class StaffBo implements Serializable {
@ApiModelProperty(value = "角色id",required = true)
private String roleId;
+ /**
+ * 企业微信用户id
+ */
+ @ApiModelProperty(value = "企业微信用户id",required = true)
+ private String wxCpUserId;
+
}
diff --git a/Cpop-Oam/src/main/java/com/cpop/oam/business/controller/backstage/WxCpController.java b/Cpop-Oam/src/main/java/com/cpop/oam/business/controller/backstage/WxCpController.java
index 1b00fe2..45a0228 100644
--- a/Cpop-Oam/src/main/java/com/cpop/oam/business/controller/backstage/WxCpController.java
+++ b/Cpop-Oam/src/main/java/com/cpop/oam/business/controller/backstage/WxCpController.java
@@ -2,14 +2,19 @@ package com.cpop.oam.business.controller.backstage;
import com.cpop.core.base.R;
import com.cpop.oam.business.service.OamWxCpService;
+import com.cpop.oam.business.vo.WxCpLoginVo;
+import com.cpop.oam.framework.config.wxCp.WxCpConfiguration;
+import com.cpop.system.business.vo.LoginUserInfoVo;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
+import me.chanjar.weixin.cp.api.WxCpService;
import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
import org.springframework.security.access.prepost.PreAuthorize;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
+
+import javax.servlet.http.HttpServletRequest;
/**
* @author DB
@@ -25,6 +30,36 @@ public class WxCpController {
@Autowired
private OamWxCpService oamWxCpService;
+ @Value("${wx.cp.oAuth2registerUrl}")
+ private String oAuth2registerUrl;
+
+ /**
+ * @author LOST.yuan
+ * @Description 根据code换取用户信息
+ * @date 14:52 2022/9/7
+ * @return {@link R}
+ **/
+ @GetMapping("/getOauth2Url")
+ @ApiOperation("获取oauth2认证链接")
+ public R getOauth2Url() {
+ WxCpService cpService = WxCpConfiguration.getCpService(1000024);
+ String authUrl = cpService.getOauth2Service().buildAuthorizationUrl(oAuth2registerUrl, null, "snsapi_privateinfo");
+ return R.ok(authUrl);
+ }
+
+ /**
+ * @author LOST.yuan
+ * @Description 根据code换取用户信息
+ * @date 14:52 2022/9/7
+ * @return {@link R}
+ **/
+ @GetMapping("/loginUserInfoByCode")
+ @ApiOperation("根据code换取用户信息")
+ public R loginUserInfoByCode(HttpServletRequest httpServletRequest, @RequestParam("code") String code) {
+ WxCpLoginVo loginVo = oamWxCpService.loginUserInfoByCode(httpServletRequest, code);
+ return R.ok(loginVo);
+ }
+
/**
* @return R
* @Description: 同步企业微信部门
diff --git a/Cpop-Oam/src/main/java/com/cpop/oam/business/controller/backstage/WxPayController.java b/Cpop-Oam/src/main/java/com/cpop/oam/business/controller/backstage/WxPayController.java
index 0123e11..8f9fc4c 100644
--- a/Cpop-Oam/src/main/java/com/cpop/oam/business/controller/backstage/WxPayController.java
+++ b/Cpop-Oam/src/main/java/com/cpop/oam/business/controller/backstage/WxPayController.java
@@ -51,9 +51,9 @@ public class WxPayController {
* @return: com.cpop.core.base.R
*/
@PreAuthorize("@aps.hasPermission('brandStore:brand:update')")
- @ApiOperation("开通品牌商城")
- @PutMapping("/changeBrandMall")
- public R changeWechatSharing(@RequestBody @Validated ChangeWechatSharingBo bo) {
+ @ApiOperation("开通微信分账")
+ @PutMapping("/changeBrandSharing")
+ public R changeBrandSharing(@RequestBody @Validated ChangeWechatSharingBo bo) {
//获取品牌下属商户
Brand brand = brandService.getById(bo.getBrandId());
if (StringUtils.isBlank(brand.getWxMchId())) {
@@ -66,12 +66,11 @@ public class WxPayController {
//添加分账接收方
ProfitSharingReceiverRequest profitSharingReceiver = new ProfitSharingReceiverRequest();
//开启
- if (bo.getIsOpenMall()) {
+ if (bo.getIsOpenSharing()) {
mapReceiver.put("relation_type", "SERVICE_PROVIDER");
mapReceiver.put("name", wxPayConfiguration.getProperties().getSharingAccountName());
profitSharingReceiver.setReceiver(JSONObject.toJSONString(mapReceiver));
WxPayConfig config = wxPayService.getConfig();
-
config.setSubMchId(brand.getWxMchId());
try {
wxPayService.getProfitSharingService().addReceiver(profitSharingReceiver);
@@ -89,7 +88,7 @@ public class WxPayController {
throw new ServiceException(e.getMessage());
}
}
- brandService.updateChain().set(BRAND.IS_OPEN_MALL, bo.getIsOpenMall()).where(BRAND.ID.eq(bo.getBrandId())).update();
+ brandService.updateChain().set(BRAND.IS_OPEN_SHARING, bo.getIsOpenSharing()).where(BRAND.ID.eq(bo.getBrandId())).update();
return R.ok();
}
}
diff --git a/Cpop-Oam/src/main/java/com/cpop/oam/business/controller/callback/WxCpPortalController.java b/Cpop-Oam/src/main/java/com/cpop/oam/business/controller/callback/WxCpPortalController.java
index cf88ab4..525c598 100644
--- a/Cpop-Oam/src/main/java/com/cpop/oam/business/controller/callback/WxCpPortalController.java
+++ b/Cpop-Oam/src/main/java/com/cpop/oam/business/controller/callback/WxCpPortalController.java
@@ -4,6 +4,7 @@ import com.cpop.common.utils.JsonUtils;
import com.cpop.common.utils.StringUtils;
import com.cpop.core.service.RedisService;
import com.cpop.core.utils.SpringUtils;
+import com.cpop.oam.business.service.OamWxCpService;
import com.cpop.oam.framework.config.wxCp.WxCpConfiguration;
import com.cpop.oam.framework.constant.WxCpConstant;
import io.swagger.annotations.Api;
@@ -14,6 +15,7 @@ import me.chanjar.weixin.cp.bean.message.WxCpXmlOutMessage;
import me.chanjar.weixin.cp.util.crypto.WxCpCryptUtil;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
/**
@@ -28,6 +30,9 @@ public class WxCpPortalController {
private final Logger logger = LoggerFactory.getLogger(this.getClass());
+ @Autowired
+ private OamWxCpService oamWxCpService;
+
@GetMapping(produces = "text/plain;charset=utf-8")
public String authGet(@PathVariable Integer agentId,
@RequestParam(name = "msg_signature", required = false) String signature,
@@ -80,4 +85,20 @@ public class WxCpPortalController {
return null;
}
+ /**
+ * @descriptions 企微的o2认证可查询用户敏感信息
+ * @author DB
+ * @date 2023/11/17 14:42
+ * @param agentId 企业微信服务应用id
+ * @param code 授权码
+ * @param state 信息 注册
+ * @return: java.lang.String
+ */
+ @GetMapping(produces = "text/plain;charset=utf-8", value = "/registerCode")
+ public void registerCode(@PathVariable Integer agentId,
+ @RequestParam("code") String code,
+ @RequestParam("state") String state) {
+ oamWxCpService.registerCode(agentId, code);
+ }
+
}
diff --git a/Cpop-Oam/src/main/java/com/cpop/oam/business/service/OamWxCpService.java b/Cpop-Oam/src/main/java/com/cpop/oam/business/service/OamWxCpService.java
index 50f7a50..aff6b99 100644
--- a/Cpop-Oam/src/main/java/com/cpop/oam/business/service/OamWxCpService.java
+++ b/Cpop-Oam/src/main/java/com/cpop/oam/business/service/OamWxCpService.java
@@ -1,5 +1,9 @@
package com.cpop.oam.business.service;
+import com.cpop.oam.business.vo.WxCpLoginVo;
+
+import javax.servlet.http.HttpServletRequest;
+
/**
* Oam暴露的企业微信接口
* @author DB
@@ -21,4 +25,23 @@ public interface OamWxCpService {
* @return: void
*/
void syncWxCpStaff();
+
+ /**
+ * @descriptions 根据code换取用户信息
+ * @author DB
+ * @date 2023/11/20 18:19
+ * @param code code
+ * @return: void
+ */
+ WxCpLoginVo loginUserInfoByCode(HttpServletRequest httpServletRequest, String code);
+
+ /**
+ * @descriptions 企微的o2认证可查询用户敏感信息
+ * @author DB
+ * @date 2023/11/21 15:31
+ * @param agentId 应用id
+ * @param code 授权码
+ * @return: void
+ */
+ void registerCode(Integer agentId, String code);
}
diff --git a/Cpop-Oam/src/main/java/com/cpop/oam/business/service/StaffService.java b/Cpop-Oam/src/main/java/com/cpop/oam/business/service/StaffService.java
index 6b42e5f..915f31f 100644
--- a/Cpop-Oam/src/main/java/com/cpop/oam/business/service/StaffService.java
+++ b/Cpop-Oam/src/main/java/com/cpop/oam/business/service/StaffService.java
@@ -1,5 +1,6 @@
package com.cpop.oam.business.service;
+import com.cpop.core.base.table.SysUser;
import com.mybatisflex.core.paginate.Page;
import com.mybatisflex.core.service.IService;
import com.cpop.oam.business.bo.ModifyUserPasswordBo;
@@ -40,7 +41,7 @@ public interface StaffService extends IService {
* @date 2023/09/08 14:12
* @param bo 请求参数
*/
- void insertStaff(StaffBo bo);
+ SysUser insertStaff(StaffBo bo);
/**
* @descriptions 修改员工
diff --git a/Cpop-Oam/src/main/java/com/cpop/oam/business/service/impl/OamWxCpServiceImpl.java b/Cpop-Oam/src/main/java/com/cpop/oam/business/service/impl/OamWxCpServiceImpl.java
index 8fe8537..e600d20 100644
--- a/Cpop-Oam/src/main/java/com/cpop/oam/business/service/impl/OamWxCpServiceImpl.java
+++ b/Cpop-Oam/src/main/java/com/cpop/oam/business/service/impl/OamWxCpServiceImpl.java
@@ -1,12 +1,14 @@
package com.cpop.oam.business.service.impl;
-import com.alibaba.fastjson.JSONArray;
+import com.cpop.common.utils.StringUtils;
+import com.cpop.core.base.enums.InitRoleEnum;
import com.cpop.core.base.enums.UserType;
import com.cpop.core.base.exception.ServiceException;
import com.cpop.core.base.table.SysUser;
import com.cpop.core.mapper.CoreMapper;
-import com.cpop.core.utils.SpringUtils;
+import com.cpop.core.utils.*;
import com.cpop.core.utils.uuid.IdUtils;
+import com.cpop.oam.business.bo.StaffBo;
import com.cpop.oam.business.entity.Dept;
import com.cpop.oam.business.entity.Staff;
import com.cpop.oam.business.entity.StaffMidDept;
@@ -14,25 +16,37 @@ import com.cpop.oam.business.service.DeptService;
import com.cpop.oam.business.service.OamWxCpService;
import com.cpop.oam.business.service.StaffMidDeptService;
import com.cpop.oam.business.service.StaffService;
+import com.cpop.oam.business.vo.WxCpLoginVo;
import com.cpop.oam.framework.config.wxCp.WxCpConfiguration;
+import com.mybatisflex.core.query.QueryWrapper;
import com.mybatisflex.core.row.Db;
+import com.mybatisflex.core.row.Row;
+import com.mybatisflex.core.row.RowUtil;
+import lombok.extern.slf4j.Slf4j;
import me.chanjar.weixin.common.error.WxErrorException;
+import me.chanjar.weixin.cp.api.WxCpOAuth2Service;
import me.chanjar.weixin.cp.api.WxCpService;
import me.chanjar.weixin.cp.bean.WxCpDepart;
+import me.chanjar.weixin.cp.bean.WxCpOauth2UserInfo;
import me.chanjar.weixin.cp.bean.WxCpUser;
+import me.chanjar.weixin.cp.bean.WxCpUserDetail;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
+import javax.servlet.http.HttpServletRequest;
import java.util.*;
import java.util.stream.Collectors;
+import static com.cpop.core.base.table.table.SysUserTableDef.SYS_USER;
import static com.cpop.oam.business.entity.table.DeptTableDef.DEPT;
+import static com.cpop.oam.business.entity.table.StaffTableDef.STAFF;
/**
* @author DB
* @createTime 2023/11/17 9:42
* @description Oam暴露的企业微信接口
*/
+@Slf4j
@Service("oamWxCpService")
public class OamWxCpServiceImpl implements OamWxCpService {
@@ -149,4 +163,97 @@ public class OamWxCpServiceImpl implements OamWxCpService {
throw new ServiceException(e.getMessage());
}
}
+
+ /**
+ * @descriptions 根据code换取用户信息
+ * @author DB
+ * @date 2023/11/20 18:19
+ * @param code code
+ * @return: void
+ */
+ @Override
+ public WxCpLoginVo loginUserInfoByCode(HttpServletRequest httpServletRequest, String code) {
+ WxCpService cpService = WxCpConfiguration.getCpService(1000024);
+ try {
+ //获取用户信息
+ WxCpOAuth2Service oauth2Service = cpService.getOauth2Service();
+ //此处只能获取企业微信的userId
+ WxCpOauth2UserInfo userInfo = oauth2Service.getUserInfo(1000024, code);
+ String wxCpUserId = userInfo.getUserId();
+ //查询用户信息
+ Row row = Db.selectOneByQuery("cp_sys_user",
+ QueryWrapper.create().select(SYS_USER.ALL_COLUMNS)
+ .leftJoin(STAFF).on(STAFF.USER_ID.eq(SYS_USER.ID))
+ .where(STAFF.WX_CP_USER_ID.eq(wxCpUserId)));
+ if (null == row){
+ throw new ServiceException("请先在企微上的Oam应用中进行注册");
+ }
+ SysUser sysUser = RowUtil.toEntity(row, SysUser.class);
+ return new WxCpLoginVo(sysUser.getUserName(),sysUser.getRsaPassword());
+ } catch (WxErrorException e) {
+ throw new ServiceException(e.getMessage());
+ }
+ }
+
+ /**
+ * @descriptions 企微的o2认证可查询用户敏感信息
+ * @author DB
+ * @date 2023/11/21 15:31
+ * @param agentId 应用id
+ * @param code 授权码
+ * @return: void
+ */
+ @Override
+ @Transactional(rollbackFor = Exception.class)
+ public void registerCode(Integer agentId, String code) {
+ WxCpService cpService = WxCpConfiguration.getCpService(agentId);
+ //获取用户信息
+ WxCpOAuth2Service oauth2Service = cpService.getOauth2Service();
+ try {
+ WxCpOauth2UserInfo userInfo = oauth2Service.getUserInfo(agentId, code);
+ //获取用户敏感信息
+ WxCpUserDetail userDetail = oauth2Service.getUserDetail(userInfo.getUserTicket());
+ //此时可以获取敏感信息
+ if (StringUtils.isBlank(userDetail.getMobile())){
+ throw new ServiceException("请重新扫码并授权敏感信息!");
+ }
+ //读取员工信息
+ StaffService staffService = SpringUtils.getBean(StaffService.class);
+ long count = staffService.queryChain().where(STAFF.WX_CP_USER_ID.eq(userDetail.getUserId())).count();
+ if (count > 0) {
+ throw new ServiceException("您已通过注册,请扫码或直接通过用户名密码登陆!");
+ }
+ //获取部门信息
+ WxCpUser wxCpUser = cpService.getUserService().getById(userInfo.getUserId());
+ List deptList = SpringUtils.getBean(DeptService.class).list();
+ Map wxCpDeptMap = deptList.stream().collect(Collectors.toMap(Dept::getWxCpId, item -> item));
+ //创建员工
+ StaffBo staffBo = new StaffBo();
+ String deptIds = "";
+ //调整部门数据
+ for (Long departId : wxCpUser.getDepartIds()) {
+ Dept dept = wxCpDeptMap.get(departId);
+ if (dept != null) {
+ if (StringUtils.isBlank(deptIds)) {
+ deptIds = deptIds + dept.getId();
+ } else {
+ deptIds = deptIds + "," + dept.getId();
+ }
+ }
+ }
+ String encrypt = SpringUtils.getBean(RsaUtils.class).encrypt(userDetail.getMobile());
+ //读取用户通用信息
+ staffBo.setUserName(userDetail.getMobile()).setName(wxCpUser.getName()).setNickName(wxCpUser.getAlias()).setAvatar(userDetail.getAvatar()).setEmail(userDetail.getBizMail()).setPhoneNumber(userDetail.getMobile())
+ .setSex(!StringUtils.equals(userDetail.getGender(), "1")).setStatus(true).setStaffType(2).setWxCpUserId(wxCpUser.getUserId())
+ //密码默认为手机号
+ .setPassword(encrypt)
+ //设置部门
+ .setDeptId(deptIds)
+ .setRoleId(InitRoleEnum.WX_CP_INIT_ROLE.getId());
+ //保存员工
+ staffService.insertStaff(staffBo);
+ } catch (WxErrorException e) {
+ throw new ServiceException(e.getMessage());
+ }
+ }
}
diff --git a/Cpop-Oam/src/main/java/com/cpop/oam/business/service/impl/StaffServiceImpl.java b/Cpop-Oam/src/main/java/com/cpop/oam/business/service/impl/StaffServiceImpl.java
index 36d2aa4..cecddc1 100644
--- a/Cpop-Oam/src/main/java/com/cpop/oam/business/service/impl/StaffServiceImpl.java
+++ b/Cpop-Oam/src/main/java/com/cpop/oam/business/service/impl/StaffServiceImpl.java
@@ -51,10 +51,7 @@ import org.springframework.transaction.annotation.Transactional;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
import java.util.stream.Collectors;
import static com.cpop.core.base.table.table.SysOperationLogTableDef.SYS_OPERATION_LOG;
@@ -118,7 +115,7 @@ public class StaffServiceImpl extends ServiceImpl implements
*/
@Override
@Transactional(rollbackFor = Exception.class)
- public void insertStaff(StaffBo bo) {
+ public SysUser insertStaff(StaffBo bo) {
//先添加用户信息
SysUser sysUser;
if (validatedUserInfo(bo)) {
@@ -127,12 +124,18 @@ public class StaffServiceImpl extends ServiceImpl implements
//用户名-手机-邮箱都需要做唯一校验
sysUser = BeanUtils.mapToClass(bo, SysUser.class);
//解密与重设密码
+ sysUser.setRsaPassword(bo.getPassword());
decryptAndResetPasswords(sysUser);
sysUser.setId(IdUtils.fastSimpleUUID());
//获取当前创建人员信息
LoginUser loginUser = SecurityUtils.getInstance().getLoginUser();
- sysUser.setCreateUserId(loginUser.getUserId());
- sysUser.setUpdateUserId(loginUser.getUserId());
+ if (loginUser == null){
+ sysUser.setCreateUserId("1");
+ sysUser.setUpdateUserId("1");
+ } else {
+ sysUser.setCreateUserId(loginUser.getUserId());
+ sysUser.setUpdateUserId(loginUser.getUserId());
+ }
sysUser.setUserType(UserType.OAM_USER.toString());
SpringUtils.getBean(CoreService.class).insertSysUser(sysUser);
}
@@ -140,6 +143,16 @@ public class StaffServiceImpl extends ServiceImpl implements
Staff sysStaff = BeanUtils.mapToClass(bo, Staff.class);
sysStaff.setUserId(sysUser.getId());
this.save(sysStaff);
+ //批量导入部门信息
+ List deptList = Arrays.asList(bo.getDeptId().split(","));
+ List staffMidDeptList = new ArrayList<>();
+ deptList.forEach(item -> {
+ StaffMidDept staffMidDept = new StaffMidDept();
+ staffMidDept.setDeptId(item).setStaffId(sysStaff.getId());
+ staffMidDeptList.add(staffMidDept);
+ });
+ SpringUtils.getBean(StaffMidDeptService.class).saveBatch(staffMidDeptList);
+ return sysUser;
}
/**
@@ -152,9 +165,9 @@ public class StaffServiceImpl extends ServiceImpl implements
private Boolean validatedUserInfo(StaffBo bo) {
long count = this.count(QueryWrapper.create()
//用户名
- .where(SYS_USER.USER_NAME.eq(bo.getUserName()))
+ .where(SYS_USER.USER_NAME.eq(bo.getUserName()).or(SYS_USER.PHONE_NUMBER.eq(bo.getPhoneNumber())))
//手机号
- .or(SYS_USER.PHONE_NUMBER.eq(bo.getPhoneNumber()))
+ .and(SYS_USER.USER_TYPE.eq(UserType.OAM_USER.toString()))
.from(SYS_USER));
if (StringUtils.isNotBlank(bo.getUserId())) {
return count > 1;
@@ -200,6 +213,18 @@ public class StaffServiceImpl extends ServiceImpl implements
//再修改员工信息
Staff sysStaff = BeanUtils.mapToClass(bo, Staff.class);
this.updateById(sysStaff);
+ //批量删除
+ StaffMidDeptService staffMidDeptService = SpringUtils.getBean(StaffMidDeptService.class);
+ staffMidDeptService.remove(QueryWrapper.create().where(STAFF_MID_DEPT.STAFF_ID.eq(sysStaff.getId())));
+ //批量导入部门信息
+ List deptList = Arrays.asList(bo.getDeptId().split(","));
+ List staffMidDeptList = new ArrayList<>();
+ deptList.forEach(item -> {
+ StaffMidDept staffMidDept = new StaffMidDept();
+ staffMidDept.setDeptId(item).setStaffId(sysStaff.getId());
+ staffMidDeptList.add(staffMidDept);
+ });
+ staffMidDeptService.saveBatch(staffMidDeptList);
//获取缓存信息
RedisService redisService = SpringUtils.getBean(RedisService.class);
JSONObject jsonObject = redisService.getCacheObject(UserType.OAM_USER.getKey() + bo.getUserName());
diff --git a/Cpop-Oam/src/main/java/com/cpop/oam/business/vo/WxCpLoginVo.java b/Cpop-Oam/src/main/java/com/cpop/oam/business/vo/WxCpLoginVo.java
new file mode 100644
index 0000000..639a0a4
--- /dev/null
+++ b/Cpop-Oam/src/main/java/com/cpop/oam/business/vo/WxCpLoginVo.java
@@ -0,0 +1,29 @@
+package com.cpop.oam.business.vo;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @author DB
+ * @createTime 2023/11/21 14:38
+ * @description 企业微信登陆或注册
+ */
+@Data
+@AllArgsConstructor
+public class WxCpLoginVo implements Serializable {
+
+ /**
+ * 用户名
+ */
+ @ApiModelProperty("用户名")
+ private String userName;
+
+ /**
+ * rsa密码
+ */
+ @ApiModelProperty("rsa密码")
+ private String rsaPassword;
+}
diff --git a/Cpop-Oam/src/main/java/com/cpop/oam/framework/config/wxCp/WxCpProperties.java b/Cpop-Oam/src/main/java/com/cpop/oam/framework/config/wxCp/WxCpProperties.java
index 761473d..e556b2c 100644
--- a/Cpop-Oam/src/main/java/com/cpop/oam/framework/config/wxCp/WxCpProperties.java
+++ b/Cpop-Oam/src/main/java/com/cpop/oam/framework/config/wxCp/WxCpProperties.java
@@ -27,6 +27,11 @@ public class WxCpProperties {
*/
private String oAuth2RedirectUri;
+ /**
+ * o2认证注册到oam中的地址
+ */
+ private String oAuth2registerUrl;
+
private List appConfigs;
@Getter
diff --git a/Cpop-System/src/main/java/com/cpop/system/business/bo/ChangeWechatSharingBo.java b/Cpop-System/src/main/java/com/cpop/system/business/bo/ChangeWechatSharingBo.java
index b687581..2a7089e 100644
--- a/Cpop-System/src/main/java/com/cpop/system/business/bo/ChangeWechatSharingBo.java
+++ b/Cpop-System/src/main/java/com/cpop/system/business/bo/ChangeWechatSharingBo.java
@@ -27,7 +27,7 @@ public class ChangeWechatSharingBo implements Serializable {
/**
* 是否开启分账
*/
- @NotNull(message = "是否开启商城不能为空")
- @ApiModelProperty(value = "是否开启商城",required = true)
- private Boolean isOpenMall;
+ @NotNull(message = "是否开启分账不能为空")
+ @ApiModelProperty(value = "是否开启分账",required = true)
+ private Boolean isOpenSharing;
}
diff --git a/Cpop-System/src/main/java/com/cpop/system/business/entity/Brand.java b/Cpop-System/src/main/java/com/cpop/system/business/entity/Brand.java
index e016198..67603f4 100644
--- a/Cpop-System/src/main/java/com/cpop/system/business/entity/Brand.java
+++ b/Cpop-System/src/main/java/com/cpop/system/business/entity/Brand.java
@@ -56,9 +56,9 @@ public class Brand extends BaseEntity implements Serializable {
private String backgroundUrl;
/**
- * 是否开通商城
+ * 是否开通分账
*/
- private Boolean isOpenMall;
+ private Boolean isOpenSharing;
/**
* 逻辑删除（0否1是）
diff --git a/Cpop-System/src/main/java/com/cpop/system/business/service/impl/BrandServiceImpl.java b/Cpop-System/src/main/java/com/cpop/system/business/service/impl/BrandServiceImpl.java
index 8b380b5..259787f 100644
--- a/Cpop-System/src/main/java/com/cpop/system/business/service/impl/BrandServiceImpl.java
+++ b/Cpop-System/src/main/java/com/cpop/system/business/service/impl/BrandServiceImpl.java
@@ -152,7 +152,7 @@ public class BrandServiceImpl extends ServiceImpl implements
PageDomain pageDomain = SqlUtils.getInstance().getPageDomain();
return this.mapper.paginateAs(pageDomain.getPageNum(), pageDomain.getPageSize(),
QueryWrapper.create()
- .select(BRAND.ID, BRAND.BRAND_NAME, BRAND.WX_MCH_ID, BRAND.CREATE_TIME, BRAND.BACKGROUND_URL, BRAND.IS_OPEN_MALL)
+ .select(BRAND.ID, BRAND.BRAND_NAME, BRAND.WX_MCH_ID, BRAND.CREATE_TIME, BRAND.BACKGROUND_URL, BRAND.IS_OPEN_SHARING)
.and(BRAND.BRAND_NAME.like(brandName)),
BrandPageVo.class);
}
diff --git a/Cpop-System/src/main/java/com/cpop/system/business/service/impl/RoleServiceImpl.java b/Cpop-System/src/main/java/com/cpop/system/business/service/impl/RoleServiceImpl.java
index 0a0fea6..981658c 100644
--- a/Cpop-System/src/main/java/com/cpop/system/business/service/impl/RoleServiceImpl.java
+++ b/Cpop-System/src/main/java/com/cpop/system/business/service/impl/RoleServiceImpl.java
@@ -85,7 +85,9 @@ public class RoleServiceImpl extends ServiceImpl implements Ro
@Override
@Transactional(rollbackFor = Exception.class)
public void insertSysRole(RoleBo bo) {
+ LoginUser loginUser = SecurityUtils.getInstance().getLoginUser();
Role role = BeanUtils.mapToClass(bo, Role.class);
+ role.setUserType(loginUser.getUserType());
this.save(role);
//将菜单信息录入中间表
if (!bo.getMenuIds().isEmpty()) {
diff --git a/Cpop-System/src/main/java/com/cpop/system/business/vo/BrandPageVo.java b/Cpop-System/src/main/java/com/cpop/system/business/vo/BrandPageVo.java
index 035ec04..9809c95 100644
--- a/Cpop-System/src/main/java/com/cpop/system/business/vo/BrandPageVo.java
+++ b/Cpop-System/src/main/java/com/cpop/system/business/vo/BrandPageVo.java
@@ -66,10 +66,10 @@ public class BrandPageVo implements Serializable {
private String backgroundUrl;
/**
- * 是否开通商城
+ * 是否开通分账
*/
- @ApiModelProperty("是否开通商城")
- private Boolean isOpenMall;
+ @ApiModelProperty("是否开通分账")
+ private Boolean isOpenSharing;
/**
* 创建时间