调用权限接口

liquidnet-bus-api/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/dto/vo/mongo/KylinPerformanceVo.java

@@ -63,7 +63,8 @@ public class KylinPerformanceVo {
     private String projectId;
     @ApiModelProperty(value = "巡演id")
     private String roadShowId;
-
+    @ApiModelProperty(value = "主办方id")
+    private String sponsorId;
     // OSS
     @ApiModelProperty(value = "演出详情")
     private String details;
@@ -140,6 +141,7 @@ public class KylinPerformanceVo {
         this.notice = performance.getNotice();
         this.approvalUrl = performance.getApprovalUrl();
         this.rejectTxt = performance.getRejectTxt();
+        this.sponsorId = performance.getSponsorId();
     }
 
     public void setTimePriceVipAndLack(int isLackRegister, int isMember, int isExclusive, BigDecimal price, LocalDateTime stopSellTime, LocalDateTime sellMemberTime, LocalDateTime sellTime, int isAdvance, int isDiscount, int payCountdownMinute) {

liquidnet-bus-service/liquidnet-service-merchant/liquidnet-service-merchant-impl/src/main/java/com/liquidnet/service/merchant/service/impl/KylinPerformancesPartnerServiceImpl.java

@@ -24,6 +24,7 @@ import com.liquidnet.service.kylin.dto.vo.partner.*;
 import com.liquidnet.service.kylin.service.partner.IKylinPerformancesPartnerService;
 import com.liquidnet.service.kylin.service.partner.IKylinTicketTimesPartnerService;
 import com.liquidnet.service.kylin.service.partner.IKylinTicketsPartnerService;
+import com.liquidnet.service.merchant.service.IMerchantAuthorizationRecordsService;
 import com.liquidnet.service.merchant.util.*;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.BeanUtils;
@@ -68,6 +69,8 @@ public class KylinPerformancesPartnerServiceImpl implements IKylinPerformancesPa
     IKylinTicketsPartnerService ticketsPartnerService;
     @Autowired
     IKylinTicketTimesPartnerService ticketTimesPartnerService;
+    @Autowired
+    IMerchantAuthorizationRecordsService merchantAuthorizationRecordsService;
 
     @Override
     public String step1(PerformanceStep1Param step1Param) {
@@ -252,6 +255,7 @@ public class KylinPerformancesPartnerServiceImpl implements IKylinPerformancesPa
                                     now, performanceId, now, now
                             ));
                 }
+                merchantAuthorizationRecordsService.authorizationInit(performanceId, merchantId, performancePartnerVo.getFieldId(), performancePartnerVo.getSponsorId());
                 return ResponseDto.success("操作成功");
             } else { //保存
                 performancePartnerVo.setStatus(0);
@@ -379,18 +383,19 @@ public class KylinPerformancesPartnerServiceImpl implements IKylinPerformancesPa
                             KylinTicketExpressModuleVo moduleVo = redisMerchantUtils.getTEMPVo(ticketItem.getTicketsId());
                             redisMerchantUtils.setTEMVo(ticketItem.getTicketsId(), moduleVo);
                             sqlsDataE.add(new Object[]{ticketItem.getTicketsId()});
-                            for (String mVo:moduleVo.getExpressModuleIdList())
+                            for (String mVo : moduleVo.getExpressModuleIdList())
                                 sqlsDataF.add(new Object[]{
-                                        ticketItem.getTicketsId(),mVo,now,now
+                                        ticketItem.getTicketsId(), mVo, now, now
                                 });
                         }
                     }
-                    String sqlData = SqlMapping.gets(sqls, sqlsDataA, sqlsDataB, sqlsDataC, sqlsDataD,sqlsDataE,sqlsDataF);
+                    String sqlData = SqlMapping.gets(sqls, sqlsDataA, sqlsDataB, sqlsDataC, sqlsDataD, sqlsDataE, sqlsDataF);
                     queueUtil.sendMsgByRedis(MQConst.MerchantQueue.SQL_MERCHANT_STEP2.getKey(),
                             sqlData);
 
                     performanceUtils.performanceVoStatus(performanceId, null);
                 }
+                merchantAuthorizationRecordsService.authorizationInit(performanceId, merchantId, performancePartnerVo.getFieldId(), performancePartnerVo.getSponsorId());
                 return ResponseDto.success("操作完成");
             } else { //保存
                 performancePartnerVo.setStatus(0);
@@ -641,6 +646,7 @@ public class KylinPerformancesPartnerServiceImpl implements IKylinPerformancesPa
                                     2, performancesId, now, now
                             ));
                 }
+                merchantAuthorizationRecordsService.authorizationInit(performancesId,merchantId,vo.getFieldId(),vo.getSponsorId());
                 mongoMerchantUtils.updatePerformancePartnerVoById(performancePartnerVo);
                 log.info(UserPathDto.setPartnerData("0", "withdraw", "performancesId=" + performancesId, "撤回成功"));
                 return ResponseDto.success("撤回成功");

liquidnet-bus-service/liquidnet-service-order/liquidnet-service-order-impl/src/main/java/com/liquidnet/service/order/service/impl/KylinOrderTicketsServiceImpl.java

@@ -583,8 +583,9 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ
                 httpData.add("showUrl", payOrderParam.getShowUrl() + orderTicketId);
                 httpData.add("returnUrl", payOrderParam.getReturnUrl() + orderTicketId);
             }
+            log.debug("调用 DRAGON 参数 = " + httpData.toString());
             String returnData = HttpUtil.post(payUrl, httpData);
-            log.info("调用 DRAGON 结果 = " + returnData);
+            log.debug("调用 DRAGON 结果 = " + returnData);
             payResultVo = JsonUtils.fromJson(returnData, PayResultVo.class);
             payResultVo.getData().setOrderId(orderTicketId);
             payResultVo.getData().setPrice(orderTickets.getPriceActual());