Merge branch 'dev' of http://gitlab.zhengzai.tv/dongjingwei/liquidnet-bus-v1 into dev

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/dto/PerformancePartnerDto.java

+package com.liquidnet.service.kylin.dto;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+@Data
+public class PerformancePartnerDto implements Serializable {
+
+    /**
+     * performances_id
+     */
+    private String performancesId;
+
+    /**
+     * 演出名称
+     */
+    private String title;
+
+    /**
+     * 1音乐节 2演唱会 3小型演出 4展览 6舞台剧
+     */
+    private Integer type;
+
+    /**
+     * 演出海报
+     */
+    private String imgPoster;
+
+    /**
+     * 省id
+     */
+    private String provinceId;
+
+    /**
+     * 省名称
+     */
+    private String provinceName;
+
+    /**
+     * 城市id
+     */
+    private Integer cityId;
+
+    /**
+     * 城市名称
+     */
+    private String cityName;
+
+    /**
+     * 县id
+     */
+    private Integer districtId;
+
+    /**
+     * 县名称
+     */
+    private String districtName;
+
+    /**
+     * 批文地址
+     */
+    private String approvalUrl;
+
+    /**
+     * 演出公告
+     */
+    private String notice;
+
+    /**
+     * 主办方id
+     */
+    private String sponsorId;
+
+    /**
+     * 主办方类型
+     */
+    private String sponsorType;
+
+    /**
+     * 主办方
+     */
+    private String sponsor;
+
+    /**
+     * 联系人
+     */
+    private String contacts;
+
+    /**
+     * 联系电话
+     */
+    private String mobile;
+
+    /**
+     * 演出简介
+     */
+    private String describe;
+
+    /**
+     * 演出详情
+     */
+    private String details;
+
+    /**
+     * 购票须知
+     */
+    private String noticeImage;
+
+    /**
+     * 演出开始时间
+     */
+    private LocalDateTime timeStart;
+
+    /**
+     * 演出结束时间
+     */
+    private LocalDateTime timeEnd;
+
+    /**
+     * 拒绝理由
+     */
+    private String rejectTxt;
+
+    /**
+     * 权重 高则在上
+     */
+    private Integer sort;
+
+    /**
+     * comment
+     */
+    private String comment;
+
+
+    /**
+     * 复制来源演出id
+     */
+    private String copyId;
+
+    /**
+     * 商户id
+     */
+    private String merchantId;
+
+    /**
+     * 场地id
+     */
+    private String fieldId;
+
+    /**
+     * 巡演id
+     */
+    private String roadShowId;
+
+    /**
+     * 专题id
+     */
+    private String projectId;
+
+    /**
+     * 视频id
+     */
+    private String videoId;
+
+    /**
+     * 是否显示 0全部用户可见 1白名单可见 2任何不显示
+     */
+    private Integer isShow;
+
+    /**
+     * 状态:-1删除;0未提交;1审核中;2审核中（自动上线）;3审核通过;4审核未通过;6上线;7下架;8活动结束;9活动取消退款中;10活动取消退
+     */
+    private String status;
+
+    /**
+     * 是否售卖 0停止 1正常
+     */
+    private Integer statusSell;
+
+    /**
+     * 是否开启分销 0关闭 1开启
+     */
+    private Integer isDistribution;
+
+    /**
+     * 是否关联小程序 0不关联 1关联
+     */
+    private Integer syncAgent;
+
+    /**
+     * -1未提交审核，0提交审核，1审核通过，2审核拒绝
+     */
+    private Integer auditStatus;
+
+    /**
+     * 创建时间
+     */
+    private String createdAt;
+
+    /**
+     * 修改时间
+     */
+    private String updatedAt;
+
+
+}

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/dto/param/PerformanceStep1Param.java

+package com.liquidnet.service.kylin.dto.param;
+
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.io.Serializable;
+
+@Data
+public class PerformanceStep1Param implements Serializable {
+
+    @ApiModelProperty(value = "演出id", example = "")
+    @JsonIgnore
+    private String performancesId;
+
+    @ApiModelProperty(value = "封面图", example = "https://img.zhengzai.tv/partner/2019/05/14/5cda2d0520177.png")
+    private String imgPoster;
+
+    @ApiModelProperty(value = "演出名称", example = "测试演出")
+    private String title;
+
+    @ApiModelProperty(value = "演出类型 1音乐节 2演唱会 3小型演出 4展览 6舞台剧", example = "3")
+    private String type;
+
+    @ApiModelProperty(value = "演出开始时间", example = "2021-05-01 12:00:00")
+    private String timeStart;
+
+    @ApiModelProperty(value = "演出结束时间", example = "2021-05-04 12:00:00")
+    private String timeEnd;
+
+    @ApiModelProperty(value = "场地id", example = "1")
+    private String fieldId;
+
+    @ApiModelProperty(value = "演出公告", example = "这是演出公告")
+    private String notice;
+
+    @ApiModelProperty(value = "主办方id", example = "1")
+    private String sponsorId;
+
+    @ApiModelProperty(value = "主办方类型", example = "1")
+    private String sponsorType;
+
+    @ApiModelProperty(value = "主办方名称", example = "主办方名称")
+    private String sponsor;
+
+    @ApiModelProperty(value = "联系人", example = "联系人")
+    private String contacts;
+
+    @ApiModelProperty(value = "联系方式", example = "手机号")
+    private String mobile;
+
+    @ApiModelProperty(value = "演出详情", example = "<p>演出详情</p>")
+    private String details;
+
+    @ApiModelProperty(value = "演出批文地址", example = "这是一个演出批文地址")
+    private String approvalUrl;
+
+    @ApiModelProperty(value = "", example = "")
+    @JsonIgnore
+    private String createdAt;
+}

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/service/IKylinPerformancesService.java

+package com.liquidnet.service.kylin.service;
+
+import com.liquidnet.service.kylin.entity.KylinPerformances;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ * <p>
+ * 演出 服务类
+ * </p>
+ *
+ * @author liquidnet
+ * @since 2021-05-05
+ */
+public interface IKylinPerformancesService extends IService<KylinPerformances> {
+
+}

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/service/partner/IKylinPerformancesPartnerService.java

+package com.liquidnet.service.kylin.service.partner;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.liquidnet.service.kylin.dto.param.PerformanceStep1Param;
+import com.liquidnet.service.kylin.entity.KylinPerformances;
+
+/**
+ * <p>
+ * 演出 服务类
+ * </p>
+ *
+ * @author liquidnet
+ * @since 2021-05-05
+ */
+public interface IKylinPerformancesPartnerService extends IService<KylinPerformances> {
+
+    boolean createStep1(PerformanceStep1Param step1Param);
+
+    boolean createStep2();
+
+}

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/service/partner/KylinFieldsPartnerService.java

+package com.liquidnet.service.kylin.service.partner;
+
+import com.liquidnet.service.kylin.dto.vo.FieldsVo;
+
+import java.util.HashMap;
+
+public interface KylinFieldsPartnerService {
+
+    HashMap<String,Object> fieldList(int page, int size, String name);
+
+    FieldsVo fieldDetails(String fieldId);
+
+}

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-do/src/main/java/com/liquidnet/service/kylin/MybatisPlusCodeGenerator.java

@@ -15,7 +15,7 @@ public class MybatisPlusCodeGenerator {
     /**
      * @param moduleRootPath 项目模块根路径 到 /src 之前 ex：E:\projects\trlabs-bus-v1\trlabs-bus-service\trlabs-common\trlabs-mybatis
      * @param dsc            数据源
-     * @param parentName     相当于业务模块名 com.liquidnet.service.adam 全限定类名
+     * @param parentName     相当于业务模块名 com.liquidnet.service.kylin 全限定类名
      * @param tableNames     表名
      */
     public static void doGenerator(String moduleRootPath,
@@ -95,7 +95,8 @@ public class MybatisPlusCodeGenerator {
 
         String resourcePath = "/Users/hujiachen/Downloads/tmp";
         String directory = "com.liquidnet.service.kylin";
-        String[] dbTableArray = new String[]{"kylin_fields","kylin_field_status","kylin_field_relations"};
+//        String[] dbTableArray = new String[]{"kylin_fields","kylin_field_status","kylin_field_relations"};
+        String[] dbTableArray = new String[]{"kylin_performances","kylin_performance_status","kylin_performance_relations"};
 
         doGenerator(resourcePath, dsc, directory, dbTableArray);
     }

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-do/src/main/java/com/liquidnet/service/kylin/entity/KylinPerformanceRelations.java

+package com.liquidnet.service.kylin.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import java.time.LocalDateTime;
+import java.io.Serializable;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * <p>
+ * 演出状态
+ * </p>
+ *
+ * @author liquidnet
+ * @since 2021-05-05
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+public class KylinPerformanceRelations implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @TableId(value = "mid", type = IdType.AUTO)
+    private Integer mid;
+
+    /**
+     * performance_relations_id
+     */
+    private String performanceRelationsId;
+
+    /**
+     * 演出关联id
+     */
+    private String performanceId;
+
+    /**
+     * 复制来源演出id
+     */
+    private String copyId;
+
+    /**
+     * 商户id
+     */
+    private String merchantId;
+
+    /**
+     * 场地id
+     */
+    private String fieldId;
+
+    /**
+     * 巡演id
+     */
+    private String roadShowId;
+
+    /**
+     * 专题id
+     */
+    private String projectId;
+
+    /**
+     * 视频id
+     */
+    private String videoId;
+
+    /**
+     * 创建时间
+     */
+    private LocalDateTime createdAt;
+
+    /**
+     * 修改时间
+     */
+    private LocalDateTime updatedAt;
+
+
+}

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-do/src/main/java/com/liquidnet/service/kylin/entity/KylinPerformanceStatus.java

+package com.liquidnet.service.kylin.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import java.time.LocalDateTime;
+import java.io.Serializable;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * <p>
+ * 演出状态
+ * </p>
+ *
+ * @author liquidnet
+ * @since 2021-05-05
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+public class KylinPerformanceStatus implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @TableId(value = "mid", type = IdType.AUTO)
+    private Integer mid;
+
+    /**
+     * performance_status_id
+     */
+    private String performanceStatusId;
+
+    /**
+     * 演出关联id
+     */
+    private String performanceId;
+
+    /**
+     * 是否显示 0全部用户可见 1白名单可见 2任何不显示
+     */
+    private Integer isShow;
+
+    /**
+     * 状态:-1删除;0未提交;1审核中;2审核中（自动上线）;3审核通过;4审核未通过;6上线;7下架;8活动结束;9活动取消退款中;10活动取消退
+     */
+    private String status;
+
+    /**
+     * 是否售卖 0停止 1正常
+     */
+    private Integer statusSell;
+
+    /**
+     * 是否开启分销 0关闭 1开启
+     */
+    private Integer isDistribution;
+
+    /**
+     * 是否关联小程序 0不关联 1关联
+     */
+    private Integer syncAgent;
+
+    /**
+     * -1未提交审核，0提交审核，1审核通过，2审核拒绝
+     */
+    private Integer auditStatus;
+
+    /**
+     * 创建时间
+     */
+    private LocalDateTime createdAt;
+
+    /**
+     * 修改时间
+     */
+    private LocalDateTime updatedAt;
+
+
+}

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-do/src/main/java/com/liquidnet/service/kylin/entity/KylinPerformances.java

+package com.liquidnet.service.kylin.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import java.time.LocalDateTime;
+import java.io.Serializable;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * <p>
+ * 演出
+ * </p>
+ *
+ * @author liquidnet
+ * @since 2021-05-05
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+public class KylinPerformances implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @TableId(value = "mid", type = IdType.AUTO)
+    private Integer mid;
+
+    /**
+     * performances_id
+     */
+    private String performancesId;
+
+    /**
+     * 演出名称
+     */
+    private String title;
+
+    /**
+     * 1音乐节 2演唱会 3小型演出 4展览 6舞台剧
+     */
+    private Integer type;
+
+    /**
+     * 演出海报
+     */
+    private String imgPoster;
+
+    /**
+     * 省id
+     */
+    private String provinceId;
+
+    /**
+     * 省名称
+     */
+    private String provinceName;
+
+    /**
+     * 城市id
+     */
+    private Integer cityId;
+
+    /**
+     * 城市名称
+     */
+    private String cityName;
+
+    /**
+     * 县id
+     */
+    private Integer districtId;
+
+    /**
+     * 县名称
+     */
+    private String districtName;
+
+    /**
+     * 批文地址
+     */
+    private String approvalUrl;
+
+    /**
+     * 演出公告
+     */
+    private String notice;
+
+    /**
+     * 主办方id
+     */
+    private String sponsorId;
+
+    /**
+     * 主办方类型
+     */
+    private String sponsorType;
+
+    /**
+     * 主办方
+     */
+    private String sponsor;
+
+    /**
+     * 联系人
+     */
+    private String contacts;
+
+    /**
+     * 联系电话
+     */
+    private String mobile;
+
+    /**
+     * 演出简介
+     */
+    private String describe;
+
+    /**
+     * 演出详情
+     */
+    private String details;
+
+    /**
+     * 购票须知
+     */
+    private String noticeImage;
+
+    /**
+     * 演出开始时间
+     */
+    private LocalDateTime timeStart;
+
+    /**
+     * 演出结束时间
+     */
+    private LocalDateTime timeEnd;
+
+    /**
+     * 拒绝理由
+     */
+    private String rejectTxt;
+
+    /**
+     * 权重 高则在上
+     */
+    private Integer sort;
+
+    /**
+     * comment
+     */
+    private String comment;
+
+    /**
+     * 创建时间
+     */
+    private LocalDateTime createdAt;
+
+    /**
+     * 修改时间
+     */
+    private LocalDateTime updatedAt;
+
+
+}

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-do/src/main/java/com/liquidnet/service/kylin/mapper/KylinPerformanceRelationsMapper.java

+package com.liquidnet.service.kylin.mapper;
+
+import com.liquidnet.service.kylin.entity.KylinPerformanceRelations;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * <p>
+ * 演出状态 Mapper 接口
+ * </p>
+ *
+ * @author liquidnet
+ * @since 2021-05-05
+ */
+public interface KylinPerformanceRelationsMapper extends BaseMapper<KylinPerformanceRelations> {
+
+}

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-do/src/main/java/com/liquidnet/service/kylin/mapper/KylinPerformanceStatusMapper.java

+package com.liquidnet.service.kylin.mapper;
+
+import com.liquidnet.service.kylin.entity.KylinPerformanceStatus;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * <p>
+ * 演出状态 Mapper 接口
+ * </p>
+ *
+ * @author liquidnet
+ * @since 2021-05-05
+ */
+public interface KylinPerformanceStatusMapper extends BaseMapper<KylinPerformanceStatus> {
+
+}

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-do/src/main/java/com/liquidnet/service/kylin/mapper/KylinPerformancesMapper.java

+package com.liquidnet.service.kylin.mapper;
+
+import com.liquidnet.service.kylin.entity.KylinPerformances;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * <p>
+ * 演出 Mapper 接口
+ * </p>
+ *
+ * @author liquidnet
+ * @since 2021-05-05
+ */
+public interface KylinPerformancesMapper extends BaseMapper<KylinPerformances> {
+
+}

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-do/src/main/resources/com.liquidnet.service.kylin.mapper/KylinPerformancesMapper.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.liquidnet.service.kylin.mapper.KylinPerformancesMapper">
+
+</mapper>

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/controller/KylinPerformancesController.java

+package com.liquidnet.service.kylin.controller;
+
+
+import org.springframework.web.bind.annotation.RequestMapping;
+
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * <p>
+ * 演出 前端控制器
+ * </p>
+ *
+ * @author liquidnet
+ * @since 2021-05-05
+ */
+@RestController
+@RequestMapping("/user/performance")
+public class KylinPerformancesController {
+
+}

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/controller/partner/FieldsPartnerController.java

+package com.liquidnet.service.kylin.controller.partner;
+
+import com.liquidnet.service.ResponseDto;
+import com.liquidnet.service.kylin.dto.vo.FieldsVo;
+import com.liquidnet.service.kylin.service.impl.admin.FieldsAdminServiceImpl;
+import com.liquidnet.service.kylin.service.impl.partner.FieldsPartnerServiceImpl;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import io.swagger.annotations.ApiResponse;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.HashMap;
+
+@Api
+@RestController
+@RequestMapping("/partner/fields")
+public class FieldsPartnerController {
+
+    @Autowired
+    private FieldsPartnerServiceImpl fieldsPartnerService;
+
+    @GetMapping(value = "details")
+    @ApiOperation(value = "获取场地详情")
+    @ApiResponse(response = FieldsVo.class, code = 200, message = "接口返回对象参数")
+    public ResponseDto<FieldsVo> fieldDetails(@RequestParam(value = "fieldId", defaultValue = "59666659929161728") String fieldId) {
+        FieldsVo result = null;
+        result = fieldsPartnerService.fieldDetails(fieldId);
+        if (null == result) {
+            return ResponseDto.failure("场地详情查询失败");
+        } else {
+            return ResponseDto.success(result);
+        }
+    }
+
+    @GetMapping(value = "list")
+    @ApiOperation(value = "获取场地列表")
+    @ApiResponse(response = FieldsVo.class, code = 200, message = "接口返回对象参数")
+    public ResponseDto<HashMap<String, Object>> fieldList(@RequestParam(value = "page", defaultValue = "1") int page, @RequestParam(value = "size", defaultValue = "10") int size, @RequestParam(value = "name", defaultValue = "") String name) {
+        HashMap<String, Object> result = null;
+        result = fieldsPartnerService.fieldList(page-1,size,name);
+        if (null == result) {
+            return ResponseDto.failure("场地列表获取失败");
+        } else {
+            return ResponseDto.success(result);
+        }
+    }
+
+}

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/service/impl/KylinPerformancesServiceImpl.java

+package com.liquidnet.service.kylin.service.impl;
+
+import com.liquidnet.service.kylin.entity.KylinPerformances;
+import com.liquidnet.service.kylin.mapper.KylinPerformancesMapper;
+import com.liquidnet.service.kylin.service.IKylinPerformancesService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ * 演出 服务实现类
+ * </p>
+ *
+ * @author liquidnet
+ * @since 2021-05-05
+ */
+@Service
+public class KylinPerformancesServiceImpl extends ServiceImpl<KylinPerformancesMapper, KylinPerformances> implements IKylinPerformancesService {
+
+}

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/service/impl/admin/FieldsAdminServiceImpl.java

@@ -3,8 +3,6 @@ package com.liquidnet.service.kylin.service.impl.admin;
 
 import com.alibaba.fastjson.JSON;
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
-import com.fasterxml.jackson.databind.DeserializationFeature;
-import com.fasterxml.jackson.databind.ObjectMapper;
 import com.liquidnet.common.cache.redis.util.RedisUtil;
 import com.liquidnet.commons.lang.util.BeanUtil;
 import com.liquidnet.commons.lang.util.IDGenerator;
@@ -26,7 +24,6 @@ import com.liquidnet.service.kylin.service.admin.KylinFieldsAdminService;
 import com.mongodb.BasicDBObject;
 import com.mongodb.client.model.FindOneAndUpdateOptions;
 import com.mongodb.client.model.ReturnDocument;
-import com.mongodb.client.result.UpdateResult;
 import org.bson.Document;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -58,6 +55,46 @@ public class FieldsAdminServiceImpl implements KylinFieldsAdminService {
     @Autowired
     private KylinFieldRelationMapper fieldRelationsMapper;
 
+    /**
+     * 创建场地
+     *
+     * @param fieldsParam
+     * @return boolean
+     */
+    @Override
+    @Transactional
+    public boolean fieldCreate(FieldsParam fieldsParam) {
+        try {
+            // 获取 主键id
+            String fieldsId = IDGenerator.nextSnowId().toString();
+            // 获取 当前时间 -> 创建时间
+            LocalDateTime createdAt = LocalDateTime.now();
+
+            // mysql 操作
+            fieldsMapper.insert(fieldsParam.getFields(fieldsId, createdAt));
+            kylinFieldStatusMapper.insert(fieldsParam.getFieldStatus(fieldsId, createdAt, 1, 1, 1, 1));
+            fieldRelationsMapper.insert(fieldsParam.getFieldRelations(fieldsId, createdAt));
+
+            // mongo 操作
+            FieldsVo fieldsVo = new FieldsVo();
+            BeanUtils.copyProperties(fieldsParam, fieldsVo);
+            fieldsVo.setFieldsId(fieldsId);
+            fieldsVo.setCreatedAt(createdAt.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
+            fieldsVo.setUpdatedAt(createdAt.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
+            FieldsVo data = mongoTemplate.insert(
+                    fieldsVo, FieldsVo.class.getSimpleName()
+            );
+
+            // redis 操作
+            redisUtil.hset(KylinRedisConst.FIELDS, fieldsId, fieldsVo);
+
+            return true;
+        } catch (Exception e) {
+            return false;
+        }
+    }
+
+
     /**
      * mis修改场地全部数据
      *
@@ -97,44 +134,6 @@ public class FieldsAdminServiceImpl implements KylinFieldsAdminService {
         }
     }
 
-    /**
-     * 创建场地
-     *
-     * @param fieldsParam
-     * @return boolean
-     */
-    @Override
-    @Transactional
-    public boolean fieldCreate(FieldsParam fieldsParam) {
-        try {
-            // 获取 主键id
-            String fieldsId = IDGenerator.nextSnowId().toString();
-            // 获取 当前时间 -> 创建时间
-            LocalDateTime createdAt = LocalDateTime.now();
-
-            // mysql 操作
-            fieldsMapper.insert(fieldsParam.getFields(fieldsId, createdAt));
-            kylinFieldStatusMapper.insert(fieldsParam.getFieldStatus(fieldsId, createdAt, 1, 1, 1, 1));
-            fieldRelationsMapper.insert(fieldsParam.getFieldRelations(fieldsId, createdAt));
-
-            // mongo 操作
-            FieldsVo fieldsVo = new FieldsVo();
-            BeanUtils.copyProperties(fieldsParam, fieldsVo);
-            fieldsVo.setFieldsId(fieldsId);
-            fieldsVo.setCreatedAt(createdAt.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
-            fieldsVo.setUpdatedAt(createdAt.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
-            FieldsVo data = mongoTemplate.insert(
-                    fieldsVo, FieldsVo.class.getSimpleName()
-            );
-
-            // redis 操作
-            redisUtil.hset(KylinRedisConst.FIELDS, fieldsId, fieldsVo);
-
-            return true;
-        } catch (Exception e) {
-            return false;
-        }
-    }
 
     /**
      * 场地列表 - 条件查询

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/service/impl/partner/FieldsPartnerServiceImpl.java

+package com.liquidnet.service.kylin.service.impl.partner;
+
+import com.liquidnet.common.cache.redis.util.RedisUtil;
+import com.liquidnet.service.kylin.constant.KylinRedisConst;
+import com.liquidnet.service.kylin.dto.vo.FieldsVo;
+import com.liquidnet.service.kylin.mapper.KylinFieldRelationMapper;
+import com.liquidnet.service.kylin.mapper.KylinFieldStatusMapper;
+import com.liquidnet.service.kylin.mapper.KylinFieldsMapper;
+import com.liquidnet.service.kylin.service.partner.KylinFieldsPartnerService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.domain.PageRequest;
+import org.springframework.data.domain.Pageable;
+import org.springframework.data.domain.Sort;
+import org.springframework.data.mongodb.core.MongoTemplate;
+import org.springframework.data.mongodb.core.query.Criteria;
+import org.springframework.data.mongodb.core.query.Query;
+import org.springframework.stereotype.Service;
+
+import java.util.HashMap;
+
+@Service
+public class FieldsPartnerServiceImpl implements KylinFieldsPartnerService {
+
+    @Autowired
+    MongoTemplate mongoTemplate;
+
+    @Autowired
+    private RedisUtil redisUtil;
+
+    @Autowired
+    private KylinFieldsMapper fieldsMapper;
+
+    @Autowired
+    private KylinFieldStatusMapper kylinFieldStatusMapper;
+
+    @Autowired
+    private KylinFieldRelationMapper fieldRelationsMapper;
+
+    /**
+     * 根据名字模糊查询 partner 场地列表
+     * @param page
+     * @param size
+     * @param name
+     * @return
+     */
+    @Override
+    public HashMap<String, Object> fieldList(int page, int size, String name) {
+        HashMap<String,Object> info = new HashMap<>();
+
+        // 排序 分页
+        Pageable pageable = PageRequest.of(0, size, Sort.by(Sort.Direction.DESC, "createdAt"));
+
+        //条件
+        Query query = Query.query(Criteria.where("name").regex(".*?\\" +name));
+
+        // 查询总数
+        long count = mongoTemplate.count(query, FieldsVo.class, FieldsVo.class.getSimpleName());
+
+        query.with(pageable);
+        info.put("total",count);
+        info.put("data", mongoTemplate.find(query, FieldsVo.class, FieldsVo.class.getSimpleName()));
+
+        return info;
+    }
+
+
+    /**
+     * partner 场地详情
+     * @param fieldId
+     * @return
+     */
+    @Override
+    public FieldsVo fieldDetails(String fieldId) {
+        FieldsVo info = null;
+        // 获取 redis数据
+        info = (FieldsVo) redisUtil.hget(KylinRedisConst.FIELDS, fieldId + "");
+        //不存在 获取 mongo数据
+        if (null == info) {
+            info = mongoTemplate.findOne(Query.query(Criteria.where("fieldsId").is(fieldId)), FieldsVo.class, FieldsVo.class.getSimpleName());
+            redisUtil.hset(KylinRedisConst.FIELDS, fieldId + "",info);
+        }
+        return info;
+    }
+}

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

+package com.liquidnet.service.kylin.service.impl.partner;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.liquidnet.commons.lang.util.IDGenerator;
+import com.liquidnet.service.kylin.dto.PerformancePartnerDto;
+import com.liquidnet.service.kylin.dto.param.PerformanceStep1Param;
+import com.liquidnet.service.kylin.entity.KylinPerformances;
+import com.liquidnet.service.kylin.mapper.KylinPerformancesMapper;
+import com.liquidnet.service.kylin.service.partner.IKylinPerformancesPartnerService;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.mongodb.core.MongoTemplate;
+import org.springframework.stereotype.Service;
+
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+
+/**
+ * <p>
+ * 演出 服务实现类
+ * </p>
+ *
+ * @author liquidnet
+ * @since 2021-05-05
+ */
+@Service
+public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerformancesMapper, KylinPerformances> implements IKylinPerformancesPartnerService {
+
+    @Autowired
+    private MongoTemplate mongoTemplate;
+
+    @Override
+    public boolean createStep1(PerformanceStep1Param step1Param) {
+        // 获取 主键id
+        String performanceId = IDGenerator.nextSnowId().toString();
+        // 获取 当前时间 -> 创建时间
+        LocalDateTime createdAt = LocalDateTime.now();
+
+        try {
+            // mongo 操作 记录演出中间数据
+//            PerformancePartnerDto performancePartnerDto = new PerformancePartnerDto();
+//            BeanUtils.copyProperties(step1Param, performancePartnerDto);
+//            performancePartnerDto.setPerformancesId(performanceId);
+//            performancePartnerDto.setCreatedAt(createdAt.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
+//            performancePartnerDto.setUpdatedAt(createdAt.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
+//            PerformancePartnerDto data = mongoTemplate.insert(
+//                    performancePartnerDto, PerformancePartnerDto.class.getSimpleName()
+//            );
+
+            step1Param.setCreatedAt(createdAt.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
+            step1Param.setPerformancesId(performanceId);
+            PerformanceStep1Param data = mongoTemplate.insert(
+                    step1Param, PerformanceStep1Param.class.getSimpleName()
+            );
+            return true;
+        } catch (Exception e) {
+            return false;
+        }
+    }
+
+    @Override
+    public boolean createStep2() {
+        return false;
+    }
+}