主办 申请

liquidnet-bus-api/liquidnet-service-merchant-api/src/main/java/com/liquidnet/service/merchant/constant/MerchantRedisConst.java

@@ -11,4 +11,7 @@ public class MerchantRedisConst {
 
     // 场地申请（个人）
     public static final String INFO_FIELD_APPLIES = PREFIX.concat("info:field_applies:");
+
+    // 主办申请（个人）
+    public static final String INFO_SPONSOR_APPLIES = PREFIX.concat("info:sponsor_applies:");
 }

liquidnet-bus-api/liquidnet-service-merchant-api/src/main/java/com/liquidnet/service/merchant/dto/param/MerchantSponsorApplyParam.java

@@ -16,6 +16,9 @@ import javax.validation.constraints.Size;
 public class MerchantSponsorApplyParam implements java.io.Serializable  {
     private static final long serialVersionUID = 5869673418720222889L;
 
+    @ApiModelProperty(position = 10, required = true, value = "是否跳过企业信息 0不跳过 1跳过")
+    private Integer skipCompany;
+
     @ApiModelProperty(position = 11, required = true, value = "主办名称[30]", example = "测试")
     @Size(max = 30, message = "主办名称长度限制1-30位")
     @NotBlank(message = "名称不能为空")

liquidnet-bus-api/liquidnet-service-merchant-api/src/main/java/com/liquidnet/service/merchant/service/IMerchantFieldsAppliesService.java → liquidnet-bus-api/liquidnet-service-merchant-api/src/main/java/com/liquidnet/service/merchant/service/IMerchantFieldsService.java

@@ -7,13 +7,16 @@ import com.liquidnet.service.merchant.dto.vo.MerchantFieldsVo;
 
 import java.util.List;
 
-public interface IMerchantFieldsAppliesService {
+public interface IMerchantFieldsService {
     PagedResult<MerchantFieldsVo> search(String name, int page, int size);
 
+
     String apply(String uid, MerchantFieldApplyParam parameter);
 
+
     void editIsCheck(String uid, String fieldId, int isCheck);
 
+
     List<MerchantFieldCheckersVo> checkers(String cuid, String fieldId);
 
     void checkerAdd(String cuid, String fieldId, String uid, String mobile, String name);

liquidnet-bus-api/liquidnet-service-merchant-api/src/main/java/com/liquidnet/service/merchant/service/IMerchantSponsorsService.java

+package com.liquidnet.service.merchant.service;
+
+import com.liquidnet.service.merchant.dto.param.MerchantSponsorApplyParam;
+
+public interface IMerchantSponsorsService {
+    String apply(String uid, MerchantSponsorApplyParam parameter);
+
+
+}

liquidnet-bus-common/liquidnet-common-service-base/src/main/java/com/liquidnet/service/base/constant/MQConst.java

@@ -142,7 +142,9 @@ public class MQConst {
 
     public enum MerchantQueue {
 //        SQL_MERCHANT_FIELD("merchant:stream:rk.sql.field", "group.sql.field", "场地相关")
-        SQL_MERCHANT_FIELD("kylin:stream:rk.performance.lack", "group.performance.lack", "场地相关")
+//        SQL_MERCHANT_SPONSOR("merchant:stream:rk.sql.sponsor", "group.sql.sponsor", "主办相关")
+        SQL_MERCHANT_FIELD("kylin:stream:rk.performance.lack", "group.performance.lack", "场地相关"),
+        SQL_MERCHANT_SPONSOR("kylin:stream:rk.performance.lack", "group.performance.lack", "场地相关")
         ;
 
         private final String key;

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

@@ -8,7 +8,7 @@ import com.liquidnet.service.base.ResponseDto;
 import com.liquidnet.service.merchant.dto.param.MerchantFieldApplyParam;
 import com.liquidnet.service.merchant.dto.vo.MerchantFieldCheckersVo;
 import com.liquidnet.service.merchant.dto.vo.MerchantFieldsVo;
-import com.liquidnet.service.merchant.service.IMerchantFieldsAppliesService;
+import com.liquidnet.service.merchant.service.IMerchantFieldsService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import lombok.extern.slf4j.Slf4j;
@@ -21,7 +21,7 @@ import java.util.List;
 
 /**
  * <p>
- * 场地表 前端控制器
+ * 场地 前端控制器
  * </p>
  *
  * @author liquidnet
@@ -36,7 +36,7 @@ import java.util.List;
 public class MerchantFieldsController {
 
     @Autowired
-    IMerchantFieldsAppliesService merchantFieldsAppliesService;
+    IMerchantFieldsService merchantFieldsService;
 
     @ApiOperationSupport(order = 10)
     @ApiOperation(value = "场地搜索")
@@ -44,7 +44,7 @@ public class MerchantFieldsController {
     public ResponseDto<PagedResult<MerchantFieldsVo>> search(@RequestParam(required = true) String name,
                                                              @RequestParam(defaultValue = "1", required = false) int page,
                                                              @RequestParam(defaultValue = "10", required = false) int size) {
-        return ResponseDto.success(merchantFieldsAppliesService.search(name, page, size));
+        return ResponseDto.success(merchantFieldsService.search(name, page, size));
     }
 
     @ApiOperationSupport(order = 11)
@@ -53,7 +53,7 @@ public class MerchantFieldsController {
     public ResponseDto<Object> apply(@Valid @RequestBody MerchantFieldApplyParam parameter) {
         String currentUid = CurrentUtil.getCurrentUid();
 
-        return ResponseDto.success(merchantFieldsAppliesService.apply(currentUid, parameter));
+        return ResponseDto.success(merchantFieldsService.apply(currentUid, parameter));
     }
 
     @ApiOperationSupport(order = 12)
@@ -63,7 +63,7 @@ public class MerchantFieldsController {
                                            @RequestParam(required = true) int isCheck){
         String currentUid = CurrentUtil.getCurrentUid();
 
-        merchantFieldsAppliesService.editIsCheck(currentUid, fieldId, isCheck);
+        merchantFieldsService.editIsCheck(currentUid, fieldId, isCheck);
 
         return ResponseDto.success();
     }
@@ -74,7 +74,7 @@ public class MerchantFieldsController {
     public ResponseDto<List<MerchantFieldCheckersVo>> checkers(@RequestParam(required = true) String fieldId) {
         String currentUid = CurrentUtil.getCurrentUid();
         
-        return ResponseDto.success(merchantFieldsAppliesService.checkers(currentUid, fieldId));
+        return ResponseDto.success(merchantFieldsService.checkers(currentUid, fieldId));
     }
 
     @ApiOperationSupport(order = 14)
@@ -86,7 +86,7 @@ public class MerchantFieldsController {
                                           @RequestParam(required = true) String name){
         String currentUid = CurrentUtil.getCurrentUid();
 
-        merchantFieldsAppliesService.checkerAdd(currentUid, fieldId, uid, mobile, name);
+        merchantFieldsService.checkerAdd(currentUid, fieldId, uid, mobile, name);
 
         return ResponseDto.success();
     }
@@ -98,7 +98,7 @@ public class MerchantFieldsController {
                                           @RequestParam(required = true) String uid){
         String currentUid = CurrentUtil.getCurrentUid();
 
-        merchantFieldsAppliesService.checkerDel(currentUid, fieldId, uid);
+        merchantFieldsService.checkerDel(currentUid, fieldId, uid);
 
         return ResponseDto.success();
     }

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

+package com.liquidnet.service.merchant.controller;
+
+import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
+import com.github.xiaoymin.knife4j.annotations.ApiSupport;
+import com.liquidnet.commons.lang.util.CurrentUtil;
+import com.liquidnet.service.base.ResponseDto;
+import com.liquidnet.service.merchant.dto.param.MerchantSponsorApplyParam;
+import com.liquidnet.service.merchant.service.IMerchantSponsorsService;
+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.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.validation.Valid;
+
+/**
+ * <p>
+ * 主办 前端控制器
+ * </p>
+ *
+ * @author liquidnet
+ * @since 2021-11-01
+ */
+@ApiSupport(order = 10011)
+@Api(tags = "主办")
+@Slf4j
+@Validated
+@RestController
+@RequestMapping("sponsors")
+public class MerchantSponsorsController {
+
+    @Autowired
+    IMerchantSponsorsService merchantSponsorsService;
+
+    @ApiOperationSupport(order = 10)
+    @ApiOperation(value = "申请主办")
+    @PostMapping("apply")
+    public ResponseDto<Object> apply(@Valid @RequestBody MerchantSponsorApplyParam parameter) {
+        String currentUid = CurrentUtil.getCurrentUid();
+
+        return ResponseDto.success(merchantSponsorsService.apply(currentUid, parameter));
+    }
+
+
+}

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

@@ -5,6 +5,7 @@ import com.liquidnet.service.merchant.constant.MerchantRedisConst;
 import com.liquidnet.service.merchant.dto.vo.MerchantFieldAppliesVo;
 import com.liquidnet.service.merchant.dto.vo.MerchantFieldCheckersVo;
 import com.liquidnet.service.merchant.dto.vo.MerchantFieldsVo;
+import com.liquidnet.service.merchant.dto.vo.MerchantSponsorAppliesVo;
 import com.liquidnet.service.merchant.util.ObjectUtil;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -74,4 +75,20 @@ public class MerchantRdmService {
         return redisUtil.set(MerchantRedisConst.INFO_FIELD_CHECKERS.concat(fieldId), vos);
     }
 
+
+    public List<MerchantSponsorAppliesVo> getSponsorAppliesVosByUid(String uid) {
+        String key = MerchantRedisConst.INFO_SPONSOR_APPLIES.concat(uid);
+        long s = System.currentTimeMillis();
+        List<MerchantSponsorAppliesVo> vos = (List<MerchantSponsorAppliesVo>) redisUtil.get(key);
+        log.debug("#RDM耗时:{}ms", System.currentTimeMillis() - s);
+        return vos;
+    }
+
+    public boolean addSponsorAppliesVoByUid(String uid, List<MerchantSponsorAppliesVo> vos, MerchantSponsorAppliesVo vo) {
+        if (null == vos) {
+            vos = ObjectUtil.getMerchantSponsorAppliesVoArrayList();
+        }
+        vos.add(vo);
+        return redisUtil.set(MerchantRedisConst.INFO_SPONSOR_APPLIES.concat(uid), vos);
+    }
 }

liquidnet-bus-service/liquidnet-service-merchant/liquidnet-service-merchant-impl/src/main/java/com/liquidnet/service/merchant/service/impl/MerchantFieldsAppliesServiceImpl.java → liquidnet-bus-service/liquidnet-service-merchant/liquidnet-service-merchant-impl/src/main/java/com/liquidnet/service/merchant/service/impl/MerchantFieldsServiceImpl.java

@@ -11,7 +11,7 @@ import com.liquidnet.service.merchant.dto.param.MerchantFieldApplyParam;
 import com.liquidnet.service.merchant.dto.vo.MerchantFieldAppliesVo;
 import com.liquidnet.service.merchant.dto.vo.MerchantFieldCheckersVo;
 import com.liquidnet.service.merchant.dto.vo.MerchantFieldsVo;
-import com.liquidnet.service.merchant.service.IMerchantFieldsAppliesService;
+import com.liquidnet.service.merchant.service.IMerchantFieldsService;
 import com.liquidnet.service.merchant.service.MerchantRdmService;
 import com.liquidnet.service.merchant.util.ObjectUtil;
 import com.liquidnet.service.merchant.util.QueueUtil;
@@ -36,7 +36,7 @@ import java.util.stream.IntStream;
 
 @Slf4j
 @Service
-public class MerchantFieldsAppliesServiceImpl implements IMerchantFieldsAppliesService {
+public class MerchantFieldsServiceImpl implements IMerchantFieldsService {
 
     @Autowired
     MerchantRdmService merchantRdmService;
@@ -148,7 +148,8 @@ public class MerchantFieldsAppliesServiceImpl implements IMerchantFieldsAppliesS
                 fieldAppliesVo.getFieldApplyId(), fieldAppliesVo.getApplyStatus(), fieldAppliesVo.getApplyType(), fieldAppliesVo.getReject(), fieldAppliesVo.getUid(), fieldAppliesVo.getFieldId(),
                 fieldAppliesVo.getName(), fieldAppliesVo.getLogo(), fieldAppliesVo.getBackground(), fieldAppliesVo.getDescription(), fieldAppliesVo.getBuiltDate(),
                 fieldAppliesVo.getProvinceId(), fieldAppliesVo.getProvinceName(), fieldAppliesVo.getCityId(), fieldAppliesVo.getCityName(), fieldAppliesVo.getDistrictId(), fieldAppliesVo.getDistrictName(), fieldAppliesVo.getAddress(), fieldAppliesVo.getLongitude(), fieldAppliesVo.getLatitude(),
-                fieldAppliesVo.getContactName(), fieldAppliesVo.getContactEmail(), fieldAppliesVo.getCompanyName(), fieldAppliesVo.getLicenseCode(), fieldAppliesVo.getLicenseImg(),
+                fieldAppliesVo.getContactName(), fieldAppliesVo.getContactEmail(),
+                fieldAppliesVo.getCompanyName(), fieldAppliesVo.getLicenseCode(), fieldAppliesVo.getLicenseImg(),
                 fieldAppliesVo.getLegalName(), fieldAppliesVo.getLegalIdentity(), fieldAppliesVo.getLegalIdentityObverse(), fieldAppliesVo.getLegalIdentityReverse(), fieldAppliesVo.getCreatedAt()
         });
 

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

+package com.liquidnet.service.merchant.service.impl;
+
+import com.liquidnet.common.exception.LiquidnetServiceException;
+import com.liquidnet.commons.lang.util.CollectionUtil;
+import com.liquidnet.commons.lang.util.IDGenerator;
+import com.liquidnet.service.base.ErrorMapping;
+import com.liquidnet.service.base.SqlMapping;
+import com.liquidnet.service.base.constant.MQConst;
+import com.liquidnet.service.merchant.dto.param.MerchantSponsorApplyParam;
+import com.liquidnet.service.merchant.dto.vo.MerchantSponsorAppliesVo;
+import com.liquidnet.service.merchant.service.IMerchantSponsorsService;
+import com.liquidnet.service.merchant.service.MerchantRdmService;
+import com.liquidnet.service.merchant.util.QueueUtil;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.util.CollectionUtils;
+
+import java.time.LocalDateTime;
+import java.util.LinkedList;
+import java.util.List;
+
+@Slf4j
+@Service
+public class MerchantSponsorsServiceImpl implements IMerchantSponsorsService {
+    @Autowired
+    MerchantRdmService merchantRdmService;
+
+    @Autowired
+    QueueUtil queueUtils;
+
+    @Override
+    public String apply(String uid, MerchantSponsorApplyParam parameter) {
+        LinkedList<String> toMqSqls = CollectionUtil.linkedListString();
+        LinkedList<Object[]> sponsorApplyInsertObjs = CollectionUtil.linkedListObjectArr();
+
+        // 申请主办 vos 上限
+        List<MerchantSponsorAppliesVo> sponsorAppliesVos = merchantRdmService.getSponsorAppliesVosByUid(uid);
+        if (!CollectionUtils.isEmpty(sponsorAppliesVos)) {
+            if (sponsorAppliesVos.size() >= 10) {
+                ErrorMapping.ErrorMessage errorMessage = ErrorMapping.get("13021");
+                throw new LiquidnetServiceException(errorMessage.getCode(), errorMessage.getMessage());
+            }
+        }
+
+        LocalDateTime now = LocalDateTime.now();
+
+        // 申请主办 vo
+        MerchantSponsorAppliesVo sponsorAppliesVo = MerchantSponsorAppliesVo.getNew();
+        BeanUtils.copyProperties(parameter, sponsorAppliesVo);
+        sponsorAppliesVo.setSponsorApplyId(IDGenerator.nextSnowId());
+        sponsorAppliesVo.setApplyStatus(0);
+        sponsorAppliesVo.setApplyType("create");
+        sponsorAppliesVo.setReject("");
+        sponsorAppliesVo.setUid(uid);
+        sponsorAppliesVo.setCreatedAt(now);
+        if (parameter.getSkipCompany() < 1) {
+            sponsorAppliesVo.setCompanyName("");
+            sponsorAppliesVo.setLicenseCode("");
+            sponsorAppliesVo.setLicenseImg("");
+            sponsorAppliesVo.setLegalName("");
+            sponsorAppliesVo.setLegalIdentity("");
+            sponsorAppliesVo.setLegalIdentityObverse("");
+            sponsorAppliesVo.setLegalIdentityReverse("");
+        } else {
+            if (sponsorAppliesVo.getCompanyName().isEmpty()
+                    || sponsorAppliesVo.getLicenseCode().isEmpty()
+                    || sponsorAppliesVo.getLicenseImg().isEmpty()
+                    || sponsorAppliesVo.getLegalName().isEmpty()
+                    || sponsorAppliesVo.getLegalIdentity().isEmpty()
+                    || sponsorAppliesVo.getLegalIdentityObverse().isEmpty()
+                    || sponsorAppliesVo.getLegalIdentityReverse().isEmpty()) {
+                ErrorMapping.ErrorMessage errorMessage = ErrorMapping.get("13022");
+                throw new LiquidnetServiceException(errorMessage.getCode(), errorMessage.getMessage());
+            }
+        }
+
+        // 申请主办 redis
+        long s = System.currentTimeMillis();
+        merchantRdmService.addSponsorAppliesVoByUid(uid, sponsorAppliesVos, sponsorAppliesVo);
+        log.debug("#RDS耗时:{}ms", System.currentTimeMillis() - s);
+
+        // 申请主办 sql
+        toMqSqls.add(SqlMapping.get("merchant_sponsor_applies.insert"));
+        sponsorApplyInsertObjs.add(new Object[]{
+                sponsorAppliesVo.getSponsorApplyId(), sponsorAppliesVo.getApplyStatus(), sponsorAppliesVo.getApplyType(), sponsorAppliesVo.getReject(), sponsorAppliesVo.getUid(),
+                sponsorAppliesVo.getName(), sponsorAppliesVo.getLogo(), sponsorAppliesVo.getBackground(), sponsorAppliesVo.getDescription(),
+                sponsorAppliesVo.getContactName(), sponsorAppliesVo.getContactIdentity(), sponsorAppliesVo.getContactIdentityObverse(), sponsorAppliesVo.getContactIdentityReverse(), sponsorAppliesVo.getContactEmail(),
+                sponsorAppliesVo.getCompanyName(), sponsorAppliesVo.getLicenseCode(), sponsorAppliesVo.getLicenseImg(),
+                sponsorAppliesVo.getLegalName(), sponsorAppliesVo.getLegalIdentity(), sponsorAppliesVo.getLegalIdentityObverse(), sponsorAppliesVo.getLegalIdentityReverse(), sponsorAppliesVo.getCreatedAt()
+        });
+
+        // mq
+        s = System.currentTimeMillis();
+        queueUtils.sendMsgByRedis(
+                MQConst.MerchantQueue.SQL_MERCHANT_SPONSOR.getKey(),
+                SqlMapping.gets(toMqSqls, sponsorApplyInsertObjs)
+        );
+        log.debug("#MQ耗时:{}ms", System.currentTimeMillis() - s);
+
+        return sponsorAppliesVo.getSponsorApplyId();
+    }
+}

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

@@ -4,6 +4,7 @@ import com.liquidnet.service.base.PagedResult;
 import com.liquidnet.service.merchant.dto.vo.MerchantFieldAppliesVo;
 import com.liquidnet.service.merchant.dto.vo.MerchantFieldCheckersVo;
 import com.liquidnet.service.merchant.dto.vo.MerchantFieldsVo;
+import com.liquidnet.service.merchant.dto.vo.MerchantSponsorAppliesVo;
 import com.mongodb.BasicDBObject;
 
 import java.util.ArrayList;
@@ -15,6 +16,9 @@ public class ObjectUtil {
 
     private static final PagedResult<MerchantFieldsVo> merchantFieldsVoPagedResult = new PagedResult<>();
 
+    private static final ArrayList<MerchantSponsorAppliesVo> merchantSponsorAppliesVoArrayList = new ArrayList<>();
+
+
     private static final BasicDBObject basicDBObject = new BasicDBObject();
 
 
@@ -30,6 +34,10 @@ public class ObjectUtil {
         return merchantFieldsVoPagedResult.clone();
     }
 
+    public static ArrayList<MerchantSponsorAppliesVo> getMerchantSponsorAppliesVoArrayList() {
+        return (ArrayList<MerchantSponsorAppliesVo>) merchantSponsorAppliesVoArrayList.clone();
+    }
+
     public static BasicDBObject cloneBasicDBObject() {
         return (BasicDBObject) basicDBObject.clone();
     }

liquidnet-bus-service/liquidnet-service-merchant/liquidnet-service-merchant-impl/src/main/resources/errors.properties

@@ -10,3 +10,7 @@
 
 13011=验票员已存在
 13012=验票员不存在
+
+
+13021=主办申请已经达到上限
+13022=主办公司信息不能为空

liquidnet-bus-service/liquidnet-service-merchant/liquidnet-service-merchant-impl/src/main/resources/sqlmap.properties

@@ -8,3 +8,6 @@ merchant_field_applies.insert=INSERT INTO merchant_field_applies (field_apply_id
 #  ---------------------------------------------------------------------------------------------------------------------
 merchant_field_checkers.insert=INSERT INTO merchant_field_checkers (field_checker_id, field_id, uid, mobile, name, cuid, created_at) VALUE (?, ?, ?, ?, ?, ?, ?)
 merchant_field_checkers.update=UPDATE merchant_field_checkers SET cuid = ?, updated_at = ?, delete_at = ? WHERE field_checker_id = ?
+
+#  ---------------------------------------------------------------------------------------------------------------------
+merchant_sponsor_applies.insert=INSERT INTO merchant_sponsor_applies (sponsor_apply_id, apply_status, apply_type, reject, uid, name, logo, background, description, contact_name, contact_identity, contact_identity_obverse, contact_identity_reverse, contact_email, company_name, license_code, license_img, legal_name, legal_identity, legal_identity_obverse, legal_identity_reverse, created_at) VALUE (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
\ No newline at end of file