feat:sync auth

api/src/main/java/com/jiejing/fitness/finance/api/merchant/StudioMerchantApi.java

@@ -69,6 +69,10 @@ public interface StudioMerchantApi {
   @PostMapping(value = "/private/studioMerchant/authSubChannel")
   JsonResult<StudioMerchantAuthSubChannelVO> authSubChannel(AuthStudioSubChannelRequest request);
 
+  @ApiOperation(value = "同步子渠道授权状态", tags = {TAG})
+  @PostMapping(value = "/private/studioMerchant/syncAuthSubChannel")
+  JsonResult<StudioMerchantAuthSubChannelVO> syncAuthSubChannel(AuthStudioSubChannelRequest request);
+
   @ApiOperation(value = "查询授权子渠道结果", tags = {TAG})
   @PostMapping(value = "/private/studioMerchant/listAuthSubChannel")
   JsonResult<List<StudioMerchantAuthSubChannelVO>> listAuthSubChannel(GetAuthStudioSubChannelRequest request);

api/src/main/java/com/jiejing/fitness/finance/api/merchant/StudioMerchantApiFallback.java

@@ -80,6 +80,12 @@ public class StudioMerchantApiFallback implements FallbackFactory<StudioMerchant
       }
 
       @Override
+      public JsonResult<StudioMerchantAuthSubChannelVO> syncAuthSubChannel(
+          AuthStudioSubChannelRequest request) {
+        return JsonResult.rpcError();
+      }
+
+      @Override
       public JsonResult<List<StudioMerchantAuthSubChannelVO>> listAuthSubChannel(
           GetAuthStudioSubChannelRequest request) {
         return JsonResult.rpcError();

app/src/main/java/com/jiejing/fitness/finance/app/controller/merchant/StudioMerchantController.java

@@ -121,6 +121,16 @@ public class StudioMerchantController implements StudioMerchantApi {
             request.getAuthType()));
   }
 
+  @ApiOperation(value = "同步子渠道授权状态", tags = {TAG})
+  @PostMapping(value = "/private/studioMerchant/syncAuthSubChannel")
+  @Override
+  public JsonResult<StudioMerchantAuthSubChannelVO> syncAuthSubChannel(
+      @RequestBody @Valid AuthStudioSubChannelRequest request) {
+    return JsonResult.success(
+        studioMerchantService.syncAuthSubChannel(request.getStudioId(), request.getSubChannel(),
+            request.getAuthType()));
+  }
+
   @ApiOperation(value = "查询授权子渠道结果", tags = {TAG})
   @PostMapping(value = "/private/studioMerchant/listAuthSubChannel")
   @Override

service/src/main/java/com/jiejing/fitness/finance/service/merchant/StudioMerchantService.java

@@ -109,6 +109,17 @@ public interface StudioMerchantService {
       SubChannelAuthTypeEnums authType);
 
   /**
+   * 同步认证状态
+   *
+   * @param studioId   场馆ID
+   * @param subChannel 子渠道
+   * @param authType   授权类型
+   * @return 认证状态
+   */
+  StudioMerchantAuthSubChannelVO syncAuthSubChannel(Long studioId, SubChannelEnums subChannel,
+      SubChannelAuthTypeEnums authType);
+
+  /**
    * 查询授权子渠道结果
    *
    * @param studioId 场馆ID

service/src/main/java/com/jiejing/fitness/finance/service/merchant/impl/StudioMerchantServiceImpl.java

@@ -249,6 +249,18 @@ public class StudioMerchantServiceImpl implements StudioMerchantService {
   }
 
   @Override
+  public StudioMerchantAuthSubChannelVO syncAuthSubChannel(Long studioId, SubChannelEnums subChannel,
+      SubChannelAuthTypeEnums authType) {
+    PartyToMerchant relation = getRelation(studioId);
+    if (null == relation) {
+      throw new BizException(FinanceErrorEnums.MERCHANT_NOT_OPEN);
+    }
+    AuthSubChannelVO vo = merchantRpcService.syncAuthSubChannel(relation.getMerchantId(), subChannel,
+        authType);
+    return BeanUtil.map(vo, StudioMerchantAuthSubChannelVO.class);
+  }
+
+  @Override
   public List<StudioMerchantAuthSubChannelVO> listAuthSubChannel(Long studioId) {
     PartyToMerchant relation = getRelation(studioId);
     if (null == relation) {

service/src/main/java/com/jiejing/fitness/finance/service/rpc/MerchantRpcService.java

@@ -9,6 +9,7 @@ import com.jiejing.paycenter.api.merchant.request.AuthSubChannelRequest;
 import com.jiejing.paycenter.api.merchant.request.ConfigSubChannelRequest;
 import com.jiejing.paycenter.api.merchant.request.GetMerchantByIdRequest;
 import com.jiejing.paycenter.api.merchant.request.ListMerchantByIdsRequest;
+import com.jiejing.paycenter.api.merchant.request.SyncSubChannelAuthRequest;
 import com.jiejing.paycenter.api.merchant.request.UploadRequest;
 import com.jiejing.paycenter.common.model.vo.ApplyMerchantResultVO;
 import com.jiejing.paycenter.common.model.vo.AuthSubChannelVO;
@@ -92,6 +93,17 @@ public class MerchantRpcService {
     return result.getResult();
   }
 
+
+  public AuthSubChannelVO syncAuthSubChannel(Long merchantId, SubChannelEnums subChannel,
+      SubChannelAuthTypeEnums authType) {
+    JsonResult<AuthSubChannelVO> result = merchantApi.syncAuthSubChannel(SyncSubChannelAuthRequest.builder()
+        .merchantId(merchantId)
+        .subChannel(subChannel)
+        .authType(authType)
+        .build());
+    return result.getResult();
+  }
+
   public List<MerchantVO> listByIds(List<Long> merchantIds) {
     ListMerchantByIdsRequest request = new ListMerchantByIdsRequest();
     request.setMerchantIds(merchantIds);