修改 partner 的 new

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

 package com.liquidnet.service.kylin.dto.param;
 
+import com.liquidnet.service.kylin.dto.vo.mongo.KylinCheckUserPerformanceVo;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
 
 import javax.validation.constraints.NotNull;
 
 @Data
-public class CheckPerformanceRelationParam {
+public class CheckPerformanceRelationParam implements Cloneable {
     @ApiModelProperty(value = "演出id")
     @NotNull(message = "演出ID不能为空")
     private String performanceId;
     @ApiModelProperty(value = "可下载时间")
     @NotNull(message = "可下载时间不能为空")
     private String canDownTime;
+
+    private static final CheckPerformanceRelationParam obj = new CheckPerformanceRelationParam();
+    public static CheckPerformanceRelationParam getNew() {
+        try {
+            return (CheckPerformanceRelationParam) obj.clone();
+        } catch (CloneNotSupportedException e) {
+            return new CheckPerformanceRelationParam();
+        }
+    }
 }

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

 package com.liquidnet.service.kylin.dto.param;
 
 import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.liquidnet.service.kylin.dto.vo.middle.KylinBuyNoticeVo;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
 
@@ -8,7 +9,7 @@ import java.io.Serializable;
 import java.util.List;
 
 @Data
-public class PerformancePartnerVo implements Serializable {
+public class PerformancePartnerVo implements Serializable,Cloneable {
 
     @ApiModelProperty(value = "演出id", example = "")
     @JsonIgnore
@@ -112,4 +113,13 @@ public class PerformancePartnerVo implements Serializable {
 
     @ApiModelProperty(value = "是否保存", example = "")
     private Integer isCreateSave;
+
+    private static final PerformancePartnerVo obj = new PerformancePartnerVo();
+    public static PerformancePartnerVo getNew() {
+        try {
+            return (PerformancePartnerVo) obj.clone();
+        } catch (CloneNotSupportedException e) {
+            return new PerformancePartnerVo();
+        }
+    }
 }

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

@@ -9,7 +9,7 @@ import java.io.Serializable;
 import java.util.List;
 
 @Data
-public class PerformanceStep2Param implements Serializable {
+public class PerformanceStep2Param implements Serializable,Cloneable {
 
     @ApiModelProperty(value = "演出id", example = "")
     @NotNull(message = "不能为空")
@@ -35,4 +35,13 @@ public class PerformanceStep2Param implements Serializable {
 
     @ApiModelProperty(value = "场次数据",hidden = true)
     private List<TicketTimesTicketCreatePartnerVo> ticketTimes;
+
+    private static final PerformanceStep2Param obj = new PerformanceStep2Param();
+    public static PerformanceStep2Param getNew() {
+        try {
+            return (PerformanceStep2Param) obj.clone();
+        } catch (CloneNotSupportedException e) {
+            return new PerformanceStep2Param();
+        }
+    }
 }

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

 package com.liquidnet.service.kylin.dto.vo;
 
+import com.liquidnet.service.kylin.dao.PerformanceOrderStatisticalDao;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
 
@@ -15,7 +16,7 @@ import java.math.BigDecimal;
  * @date 2021/6/19 16:44
  */
 @Data
-public class PerformanceOrderStatisticalVo {
+public class PerformanceOrderStatisticalVo implements Cloneable {
     private String performancesId;
     private String ticketsId;
     @ApiModelProperty(value = "票种名称")
@@ -48,4 +49,13 @@ public class PerformanceOrderStatisticalVo {
     private BigDecimal totalPayingNumber = BigDecimal.ZERO;
     @ApiModelProperty(value = "购买人数")
     private BigDecimal totalBuyUsers = BigDecimal.ZERO;
+
+    private static final PerformanceOrderStatisticalVo obj = new PerformanceOrderStatisticalVo();
+    public static PerformanceOrderStatisticalVo getNew() {
+        try {
+            return (PerformanceOrderStatisticalVo) obj.clone();
+        } catch (CloneNotSupportedException e) {
+            return new PerformanceOrderStatisticalVo();
+        }
+    }
 }

liquidnet-bus-api/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/dto/vo/middle/KylinBuyNoticeVo.java

 package com.liquidnet.service.kylin.dto.vo.middle;
 
+import com.liquidnet.service.kylin.dto.vo.returns.KylinOrderListVo;
 import lombok.Data;
 
 @Data
-public class KylinBuyNoticeVo {
+public class KylinBuyNoticeVo implements Cloneable {
 
     private String buyNoticeId;
 
@@ -14,4 +15,13 @@ public class KylinBuyNoticeVo {
     private String message;
 
     private Integer sort;
+
+    private static final KylinBuyNoticeVo obj = new KylinBuyNoticeVo();
+    public static KylinBuyNoticeVo getNew() {
+        try {
+            return (KylinBuyNoticeVo) obj.clone();
+        } catch (CloneNotSupportedException e) {
+            return new KylinBuyNoticeVo();
+        }
+    }
 }

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

@@ -10,10 +10,19 @@ import java.util.List;
 
 @Data
 @ApiModel
-public class KylinCheckUserPerformanceVo implements Serializable {
+public class KylinCheckUserPerformanceVo implements Serializable,Cloneable {
     @ApiModelProperty(value = "id")
     private String checkUserId;
 
     @ApiModelProperty(value = "演出id数组")
     private List<CheckPerformanceRelationParam> relationParams;
+
+    private static final KylinCheckUserPerformanceVo obj = new KylinCheckUserPerformanceVo();
+    public static KylinCheckUserPerformanceVo getNew() {
+        try {
+            return (KylinCheckUserPerformanceVo) obj.clone();
+        } catch (CloneNotSupportedException e) {
+            return new KylinCheckUserPerformanceVo();
+        }
+    }
 }

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

 package com.liquidnet.service.kylin.dto.vo.mongo;
 
+import com.liquidnet.service.kylin.dto.vo.middle.KylinBuyNoticeVo;
 import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
@@ -8,7 +9,7 @@ import java.io.Serializable;
 
 @Data
 @ApiModel
-public class KylinCheckUserVo implements Serializable {
+public class KylinCheckUserVo implements Serializable ,Cloneable{
 
     @ApiModelProperty(value = "id")
     private String checkUserId;
@@ -28,4 +29,12 @@ public class KylinCheckUserVo implements Serializable {
     @ApiModelProperty(value = "状态")
     private String status;
 
+    private static final KylinCheckUserVo obj = new KylinCheckUserVo();
+    public static KylinCheckUserVo getNew() {
+        try {
+            return (KylinCheckUserVo) obj.clone();
+        } catch (CloneNotSupportedException e) {
+            return new KylinCheckUserVo();
+        }
+    }
 }

liquidnet-bus-api/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/dto/vo/partner/KylinPerformancePartnerListVo.java

 package com.liquidnet.service.kylin.dto.vo.partner;
 
 import com.liquidnet.service.kylin.dto.param.PerformancePartnerVo;
+import com.liquidnet.service.kylin.dto.param.PerformanceStep2Param;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
 
 @Data
-public class KylinPerformancePartnerListVo {
+public class KylinPerformancePartnerListVo implements Cloneable{
 
     //演出数据
     @ApiModelProperty(value = "主键id")
@@ -47,4 +48,13 @@ public class KylinPerformancePartnerListVo {
         this.rejectTxt="";
         this.createdAt=item.getCreatedAt();
     }
+
+    private static final KylinPerformancePartnerListVo obj = new KylinPerformancePartnerListVo();
+    public static KylinPerformancePartnerListVo getNew() {
+        try {
+            return (KylinPerformancePartnerListVo) obj.clone();
+        } catch (CloneNotSupportedException e) {
+            return new KylinPerformancePartnerListVo();
+        }
+    }
 }

liquidnet-bus-api/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/dto/vo/partner/KylinTicketPartnerVo.java

@@ -11,7 +11,7 @@ import java.math.BigDecimal;
  * 修改场地全部显示数据参数
  */
 @Data
-public class KylinTicketPartnerVo implements Serializable {
+public class KylinTicketPartnerVo implements Serializable,Cloneable {
     @ApiModelProperty(value = "主键")
     private String ticketsId;
 
@@ -116,4 +116,13 @@ public class KylinTicketPartnerVo implements Serializable {
         this.setSurplusExchange(this.getTotalExchange());
         this.setSurplusGeneral(this.getTotalGeneral());
     }
+
+    private static final KylinTicketPartnerVo obj = new KylinTicketPartnerVo();
+    public static KylinTicketPartnerVo getNew() {
+        try {
+            return (KylinTicketPartnerVo) obj.clone();
+        } catch (CloneNotSupportedException e) {
+            return new KylinTicketPartnerVo();
+        }
+    }
 }

liquidnet-bus-api/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/dto/vo/partner/KylinTicketTimesPartnerVo.java

 package com.liquidnet.service.kylin.dto.vo.partner;
 
+import com.liquidnet.service.kylin.dto.vo.mongo.KylinCheckUserVo;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
 
@@ -8,7 +9,7 @@ import java.io.Serializable;
 //返回
 
 @Data
-public class KylinTicketTimesPartnerVo implements Serializable {
+public class KylinTicketTimesPartnerVo implements Serializable ,Cloneable{
     @ApiModelProperty(value = "主键id")
     private String ticketTimesId;
 
@@ -39,4 +40,13 @@ public class KylinTicketTimesPartnerVo implements Serializable {
 
     @ApiModelProperty(value = "修改时间")
     private String updatedAt;
+
+    private static final KylinTicketTimesPartnerVo obj = new KylinTicketTimesPartnerVo();
+    public static KylinTicketTimesPartnerVo getNew() {
+        try {
+            return (KylinTicketTimesPartnerVo) obj.clone();
+        } catch (CloneNotSupportedException e) {
+            return new KylinTicketTimesPartnerVo();
+        }
+    }
 }

liquidnet-bus-api/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/dto/vo/partner/TicketTimesTicketCreatePartnerVo.java

@@ -9,7 +9,7 @@ import java.util.List;
 //包含 票
 
 @Data
-public class TicketTimesTicketCreatePartnerVo implements Serializable {
+public class TicketTimesTicketCreatePartnerVo implements Serializable ,Cloneable{
     @ApiModelProperty(value = "主键id")
     private String ticketTimesId;
 
@@ -40,4 +40,13 @@ public class TicketTimesTicketCreatePartnerVo implements Serializable {
     //票
     @ApiModelProperty(value = "票数据")
     private List<KylinTicketPartnerVo> ticket;
+
+    private static final TicketTimesTicketCreatePartnerVo obj = new TicketTimesTicketCreatePartnerVo();
+    public static TicketTimesTicketCreatePartnerVo getNew() {
+        try {
+            return (TicketTimesTicketCreatePartnerVo) obj.clone();
+        } catch (CloneNotSupportedException e) {
+            return new TicketTimesTicketCreatePartnerVo();
+        }
+    }
 }

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

@@ -15,7 +15,7 @@ import java.time.LocalDateTime;
  * @date 2021/6/3 16:39
  */
 @Data
-public class PerformanceOrderStatisticalDao {
+public class PerformanceOrderStatisticalDao implements Cloneable{
     private String performancesId;
     private String ticketsId;
     private String title;
@@ -33,4 +33,13 @@ public class PerformanceOrderStatisticalDao {
     private BigDecimal totalMemberNumber = BigDecimal.ZERO;
     private BigDecimal totalPayingNumber = BigDecimal.ZERO;
     private BigDecimal totalBuyUsers = BigDecimal.ZERO;
+
+    private static final PerformanceOrderStatisticalDao obj = new PerformanceOrderStatisticalDao();
+    public static PerformanceOrderStatisticalDao getNew() {
+        try {
+            return (PerformanceOrderStatisticalDao) obj.clone();
+        } catch (CloneNotSupportedException e) {
+            return new PerformanceOrderStatisticalDao();
+        }
+    }
 }

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/partner/KylinBuyNoticePartnerServiceImpl.java

 package com.liquidnet.service.platform.service.impl.partner;
 
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.github.pagehelper.PageHelper;
 import com.github.pagehelper.PageInfo;
@@ -34,11 +35,11 @@ public class KylinBuyNoticePartnerServiceImpl extends ServiceImpl<KylinBuyNotice
         PageInfo<KylinBuyNoticeVo> pageInfoTmp = null;
 
         PageHelper.startPage(1, 20);
-        List<KylinBuyNotice> buyNoticeList = kylinBuyNoticeMapper.selectList(new UpdateWrapper<KylinBuyNotice>().eq("status", 1).orderByDesc("sort").orderByDesc("mid"));
+        List<KylinBuyNotice> buyNoticeList = kylinBuyNoticeMapper.selectList(Wrappers.lambdaQuery(KylinBuyNotice.class).eq(KylinBuyNotice::getStatus, 1).orderByDesc(KylinBuyNotice::getSort).orderByDesc(KylinBuyNotice::getMid));
 
         List<KylinBuyNoticeVo> kylinBuyNoticeVoList = new ArrayList<>();
         for (KylinBuyNotice item : buyNoticeList) {
-            KylinBuyNoticeVo kylinBuyNoticeVo = new KylinBuyNoticeVo();
+            KylinBuyNoticeVo kylinBuyNoticeVo = KylinBuyNoticeVo.getNew();
             BeanUtils.copyProperties(item, kylinBuyNoticeVo);
             kylinBuyNoticeVoList.add(kylinBuyNoticeVo);
         }

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/partner/KylinCheckUserPartnerServiceImpl.java

 package com.liquidnet.service.platform.service.impl.partner;
 
+import com.baomidou.mybatisplus.core.conditions.Wrapper;
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.github.pagehelper.PageHelper;
 import com.github.pagehelper.PageInfo;
@@ -14,6 +16,7 @@ import com.liquidnet.service.kylin.entity.KylinCheckUser;
 import com.liquidnet.service.kylin.mapper.KylinCheckUserMapper;
 import com.liquidnet.service.kylin.service.partner.IKylinCheckUserPartnerService;
 import com.liquidnet.service.platform.utils.DataUtils;
+import com.liquidnet.service.platform.utils.ObjectUtil;
 import com.mongodb.BasicDBObject;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -64,18 +67,14 @@ public class KylinCheckUserPartnerServiceImpl extends ServiceImpl<KylinCheckUser
     @Override
     public ResponseDto<String> del(String merchantId, String checkUserId) {
         try {
-            KylinCheckUser checkUser = new KylinCheckUser();
+            KylinCheckUser checkUser = KylinCheckUser.getNew();
             checkUser.setUpdatedAt(LocalDateTime.now());
             checkUser.setStatus(0);
-            checkUserMapper.update(checkUser, new UpdateWrapper<KylinCheckUser>().eq("check_user_id", checkUserId));
+            checkUserMapper.update(checkUser, Wrappers.lambdaUpdate(KylinCheckUser.class).eq(KylinCheckUser::getCheckUserId, checkUserId));
             dataUtils.delCheckUserRedis(checkUserId);
 
-            HashMap<String, Object> map = new HashMap<>();
+            HashMap<String, Object> map = ObjectUtil.cloneHashMapStringAndObject();
             map.put("status", 0);
-//            BasicDBObject obj = new BasicDBObject("$set", mongoConverter.convertToMongoType(map));
-//            mongoTemplate.getCollection(CheckUserVo.class.getSimpleName()).updateOne(
-//                    Query.query(Criteria.where("checkUserId").is(checkUserId)).getQueryObject(),
-//                    obj
             mongoTemplate.remove(Query.query(Criteria.where("checkUserId").is(checkUserId)), KylinCheckUserVo.class, KylinCheckUserVo.class.getSimpleName());
             return ResponseDto.success("删除成功");
         } catch (Exception e) {
@@ -86,7 +85,7 @@ public class KylinCheckUserPartnerServiceImpl extends ServiceImpl<KylinCheckUser
     @Override
     public ResponseDto<String> create(String merchantId, String name, String pwd, String mobile) {
         try {
-            KylinCheckUser checkUser = new KylinCheckUser();
+            KylinCheckUser checkUser = KylinCheckUser.getNew();
             checkUser.setName(name);
             checkUser.setPwd(DigestUtils.md5DigestAsHex(pwd.getBytes()));
             checkUser.setMobile(mobile);
@@ -96,7 +95,7 @@ public class KylinCheckUserPartnerServiceImpl extends ServiceImpl<KylinCheckUser
             checkUser.setStatus(1);
             checkUserMapper.insert(checkUser);
 
-            KylinCheckUserVo kylinCheckUserVo = new KylinCheckUserVo();
+            KylinCheckUserVo kylinCheckUserVo = KylinCheckUserVo.getNew();
             BeanUtils.copyProperties(checkUser, kylinCheckUserVo);
             mongoTemplate.insert(kylinCheckUserVo, KylinCheckUserVo.class.getSimpleName());
 
@@ -109,15 +108,15 @@ public class KylinCheckUserPartnerServiceImpl extends ServiceImpl<KylinCheckUser
     @Override
     public ResponseDto<String> change(String merchantId, String checkUserId, String name, String pwd, String mobile) {
         try {
-            KylinCheckUser checkUser = new KylinCheckUser();
+            KylinCheckUser checkUser = KylinCheckUser.getNew();
             checkUser.setName(name);
-            if(null!=pwd) {
+            if (null != pwd) {
                 checkUser.setPwd(DigestUtils.md5DigestAsHex(pwd.getBytes()));
             }
             checkUser.setMobile(mobile);
             checkUser.setUpdatedAt(LocalDateTime.now());
-            checkUserMapper.update(checkUser, new UpdateWrapper<KylinCheckUser>().eq("check_user_id", checkUserId).eq("merchant_id", merchantId));
-            BasicDBObject obj = new BasicDBObject("$set", mongoConverter.convertToMongoType(checkUser));
+            checkUserMapper.update(checkUser, Wrappers.lambdaUpdate(KylinCheckUser.class).eq(KylinCheckUser::getCheckUserId, checkUserId).eq(KylinCheckUser::getMerchantId, merchantId));
+            BasicDBObject obj = ObjectUtil.cloneBasicDBObject().append("$set", mongoConverter.convertToMongoType(checkUser));
             mongoTemplate.getCollection(KylinCheckUserVo.class.getSimpleName()).updateOne(
                     Query.query(Criteria.where("checkUserId").is(checkUserId)).getQueryObject(),
                     obj

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/partner/KylinCheckUserPerformancesPartnerServiceImpl.java

 package com.liquidnet.service.platform.service.impl.partner;
 
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.github.pagehelper.PageHelper;
 import com.github.pagehelper.PageInfo;
@@ -79,7 +80,7 @@ public class KylinCheckUserPerformancesPartnerServiceImpl extends ServiceImpl<Ky
                 if (null == item.getCanDownTime()) {
                     return ResponseDto.failure(ErrorMapping.get(20101));
                 }
-                KylinCheckUserPerformances checkUserPerformances = new KylinCheckUserPerformances();
+                KylinCheckUserPerformances checkUserPerformances = KylinCheckUserPerformances.getNew();
                 checkUserPerformances.setCheckUserId(param.getCheckUserId());
                 checkUserPerformances.setCanDownTime(DateUtil.Formatter.yyyyMMddHHmmss.parse(item.getCanDownTime()));
                 checkUserPerformances.setPerformanceId(item.getPerformanceId());
@@ -90,11 +91,11 @@ public class KylinCheckUserPerformancesPartnerServiceImpl extends ServiceImpl<Ky
             }
             mongoTemplate.remove(Query.query(Criteria.where("checkUserId").is(param.getCheckUserId())), KylinCheckUserPerformanceVo.class, KylinCheckUserPerformanceVo.class.getSimpleName());
 
-            KylinCheckUserPerformanceVo userPerformanceVo = new KylinCheckUserPerformanceVo();
+            KylinCheckUserPerformanceVo userPerformanceVo = KylinCheckUserPerformanceVo.getNew();
             List<CheckPerformanceRelationParam> performanceRelationParamsList = new ArrayList<>();
-            List<KylinCheckUserPerformances> data = checkUserPerformancesMapper.selectList(new UpdateWrapper<KylinCheckUserPerformances>().eq("check_user_id", param.getCheckUserId()));
+            List<KylinCheckUserPerformances> data = checkUserPerformancesMapper.selectList(Wrappers.lambdaQuery(KylinCheckUserPerformances.class).eq(KylinCheckUserPerformances::getCheckUserId, param.getCheckUserId()));
             for (KylinCheckUserPerformances item : data) {
-                CheckPerformanceRelationParam performanceRelationParam = new CheckPerformanceRelationParam();
+                CheckPerformanceRelationParam performanceRelationParam = CheckPerformanceRelationParam.getNew();
                 performanceRelationParam.setCanDownTime(item.getCanDownTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
                 performanceRelationParam.setPerformanceId(item.getPerformanceId());
                 performanceRelationParamsList.add(performanceRelationParam);
@@ -115,15 +116,15 @@ public class KylinCheckUserPerformancesPartnerServiceImpl extends ServiceImpl<Ky
     public ResponseDto<String> delPerformance(List<String> performanceIds, String checkUserId) {
         try {
             for (String performanceId : performanceIds) {
-                checkUserPerformancesMapper.delete(new UpdateWrapper<KylinCheckUserPerformances>().eq("check_user_id", checkUserId).eq("performance_id", performanceId));
+                checkUserPerformancesMapper.delete(Wrappers.lambdaUpdate(KylinCheckUserPerformances.class).eq(KylinCheckUserPerformances::getCheckUserId, checkUserId).eq(KylinCheckUserPerformances::getPerformanceId, performanceId));
             }
             mongoTemplate.remove(Query.query(Criteria.where("checkUserId").is(checkUserId)), KylinCheckUserPerformanceVo.class, KylinCheckUserPerformanceVo.class.getSimpleName());
 
-            KylinCheckUserPerformanceVo userPerformanceVo = new KylinCheckUserPerformanceVo();
+            KylinCheckUserPerformanceVo userPerformanceVo = KylinCheckUserPerformanceVo.getNew();
             List<CheckPerformanceRelationParam> performanceRelationParamsList = new ArrayList<>();
-            List<KylinCheckUserPerformances> data = checkUserPerformancesMapper.selectList(new UpdateWrapper<KylinCheckUserPerformances>().eq("check_user_id", checkUserId));
+            List<KylinCheckUserPerformances> data = checkUserPerformancesMapper.selectList(Wrappers.lambdaUpdate(KylinCheckUserPerformances.class).eq(KylinCheckUserPerformances::getCheckUserId, checkUserId));
             for (KylinCheckUserPerformances item : data) {
-                CheckPerformanceRelationParam performanceRelationParam = new CheckPerformanceRelationParam();
+                CheckPerformanceRelationParam performanceRelationParam = CheckPerformanceRelationParam.getNew();
                 performanceRelationParam.setCanDownTime(item.getCanDownTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
                 performanceRelationParam.setPerformanceId(item.getPerformanceId());
                 performanceRelationParamsList.add(performanceRelationParam);

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

 package com.liquidnet.service.platform.service.impl.partner;
 
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.github.pagehelper.PageHelper;
 import com.github.pagehelper.PageInfo;
@@ -23,6 +24,7 @@ import com.liquidnet.service.kylin.entity.*;
 import com.liquidnet.service.kylin.mapper.*;
 import com.liquidnet.service.kylin.service.partner.IKylinPerformancesPartnerService;
 import com.liquidnet.service.platform.utils.DataUtils;
+import com.liquidnet.service.platform.utils.ObjectUtil;
 import com.liquidnet.service.platform.utils.PerformanceVoTask;
 import com.mongodb.BasicDBObject;
 import lombok.extern.slf4j.Slf4j;
@@ -126,7 +128,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
 
         try {
             step1Param.setPerformancesId(performanceId);
-            PerformancePartnerVo performancePartnerVo = new PerformancePartnerVo();
+            PerformancePartnerVo performancePartnerVo = PerformancePartnerVo.getNew();
             BeanUtils.copyProperties(step1Param, performancePartnerVo);
             performancePartnerVo.setIsTrueName(0);
             performancePartnerVo.setLimitCount(0);
@@ -164,7 +166,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
             }
 
             step1Param.setPerformancesId(performanceId);
-            PerformancePartnerVo performancePartnerVo = new PerformancePartnerVo();
+            PerformancePartnerVo performancePartnerVo = PerformancePartnerVo.getNew();
             BeanUtils.copyProperties(step1Param, performancePartnerVo);
             performancePartnerVo.setCreatedAt(timeNow.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
             performancePartnerVo.setUpdatedAt(timeNow.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
@@ -179,14 +181,14 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
                 performancePartnerVo.setStatusSell(data.getStatusSell());
                 performancePartnerVo.setRoadShowId(data.getRoadShowId());
                 performancePartnerVo.setProjectId(data.getProjectId());
-                BasicDBObject object = new BasicDBObject("$set", mongoConverter.convertToMongoType(performancePartnerVo));
+                BasicDBObject object = ObjectUtil.cloneBasicDBObject().append("$set", mongoConverter.convertToMongoType(performancePartnerVo));
                 mongoTemplate.getCollection(PerformancePartnerVo.class.getSimpleName()).updateOne(
                         Query.query(Criteria.where("performancesId").is(performanceId)).getQueryObject(),
                         object
                 );
             } else { // 无修改记录
-                KylinPerformanceStatus statusData = performanceStatusMapper.selectOne(new UpdateWrapper<KylinPerformanceStatus>().eq("performanceId", performanceId));
-                KylinPerformanceRelations relationsData = performanceRelationsMapper.selectOne(new UpdateWrapper<KylinPerformanceRelations>().eq("performancesId", performanceId));
+                KylinPerformanceStatus statusData = performanceStatusMapper.selectOne(Wrappers.lambdaQuery(KylinPerformanceStatus.class).eq(KylinPerformanceStatus::getPerformanceId, performanceId));
+                KylinPerformanceRelations relationsData = performanceRelationsMapper.selectOne(Wrappers.lambdaQuery(KylinPerformanceRelations.class).eq(KylinPerformanceRelations::getPerformanceId, performanceId));
                 performancePartnerVo.setIsTrueName(statusData.getIsTrueName());
                 performancePartnerVo.setLimitCount(statusData.getLimitCount());
                 performancePartnerVo.setStatusSell(statusData.getStatusSell());
@@ -208,11 +210,11 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
         PerformancePartnerVo data = mongoTemplate.findOne(
                 Query.query(Criteria.where("performancesId").is(performancesId)), PerformancePartnerVo.class, PerformancePartnerVo.class.getSimpleName()
         );
-        KylinPerformanceStatus performanceStatus = performanceStatusMapper.selectOne(new UpdateWrapper<KylinPerformanceStatus>().eq("performance_id", performancesId));
+        KylinPerformanceStatus performanceStatus = performanceStatusMapper.selectOne(Wrappers.lambdaQuery(KylinPerformanceStatus.class).eq(KylinPerformanceStatus::getPerformanceId, performancesId));
         if (data == null) {
             return ResponseDto.failure(ErrorMapping.get(20104));
         }
-        if(null!=performanceStatus) {
+        if (null != performanceStatus) {
             data.setStatus(performanceStatus.getStatus());
         }
         return ResponseDto.success(data);
@@ -224,12 +226,12 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
         // 无 performancesId 则 创建
         if (step2Param.getPerformancesId().isEmpty()) {
         } else { // 获取 create 数据 status = 0 或 无数据 创建
-            KylinPerformanceStatus performanceStatus = performanceStatusMapper.selectOne(new UpdateWrapper<KylinPerformanceStatus>().eq("performance_id", step2Param.getPerformancesId()));
+            KylinPerformanceStatus performanceStatus = performanceStatusMapper.selectOne(Wrappers.lambdaQuery(KylinPerformanceStatus.class).eq(KylinPerformanceStatus::getPerformanceId, step2Param.getPerformancesId()));
             if (performanceStatus == null || performanceStatus.getStatus() == 0 || performanceStatus.getStatus() == 4) {
                 result = createStep2(step2Param);
-            } else if (performanceStatus.getStatus() == 1 || performanceStatus.getStatus() == 3 || performanceStatus.getStatus() == 6 || performanceStatus.getStatus() == 7 || performanceStatus.getStatus() == 8 || performanceStatus.getStatus() == 9 ) {// 修改
+            } else if (performanceStatus.getStatus() == 1 || performanceStatus.getStatus() == 3 || performanceStatus.getStatus() == 6 || performanceStatus.getStatus() == 7 || performanceStatus.getStatus() == 8 || performanceStatus.getStatus() == 9) {// 修改
                 result = updateStep2(step2Param);
-            }else if(performanceStatus.getStatus() == 10){
+            } else if (performanceStatus.getStatus() == 10) {
                 result = ResponseDto.failure("演出已结束不可修改");
             }
         }
@@ -253,7 +255,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
             }
 
             //演出修改数据
-            HashMap<String, Object> map = new HashMap<>();
+            HashMap<String, Object> map = ObjectUtil.cloneHashMapStringAndObject();
             map.put("isTrueName", step2Param.getIsTrueName());
             map.put("limitCount", step2Param.getLimitCount());
             map.put("createdAt", createdAt.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
@@ -265,7 +267,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
                 map.put("status", 1);
                 map.put("isCreateSave", 0);
                 map.put("auditStatus", 0);
-                BasicDBObject object = new BasicDBObject("$set", mongoConverter.convertToMongoType(map));
+                BasicDBObject object = ObjectUtil.cloneBasicDBObject().append("$set", mongoConverter.convertToMongoType(map));
                 mongoTemplate.getCollection(PerformancePartnerVo.class.getSimpleName()).updateOne(
                         Query.query(Criteria.where("performancesId").is(performanceId)).getQueryObject(),
                         object
@@ -283,22 +285,22 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
                 } else {
                     KylinPerformanceMisVo kylinPerformanceMisVo = performanceVoTask.getPerformanceMisVo(performanceId);
 
-                    HashMap<String, Object> mapSql = new HashMap<>();
+                    HashMap<String, Object> mapSql = ObjectUtil.cloneHashMapStringAndObject();
                     mapSql.put("isCreateSave", 0);
                     mapSql.put("rejectTxt", "");
                     mapSql.put("status", 1);
                     mapSql.put("updatedAt", createdAt.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
                     performanceVoTask.createPerformanceMySql(performanceId, mapSql, kylinPerformanceMisVo, createdAt);
-                    KylinPerformances performances = new KylinPerformances();
+                    KylinPerformances performances = KylinPerformances.getNew();
                     performances.setAuditTime(LocalDateTime.now());
-                    performancesMapper.update(performances, new UpdateWrapper<KylinPerformances>().eq("performances_id", performanceId));
+                    performancesMapper.update(performances, Wrappers.lambdaQuery(KylinPerformances.class).eq(KylinPerformances::getPerformancesId, performanceId));
                 }
                 return ResponseDto.success("操作成功");
             } else { //保存
                 map.put("status", 0);
                 map.put("isCreateSave", 1);
                 map.put("auditStatus", -1);
-                BasicDBObject object = new BasicDBObject("$set", mongoConverter.convertToMongoType(map));
+                BasicDBObject object = ObjectUtil.cloneBasicDBObject().append("$set", mongoConverter.convertToMongoType(map));
                 mongoTemplate.getCollection(PerformancePartnerVo.class.getSimpleName()).updateMany(
                         Query.query(Criteria.where("performancesId").is(performanceId)).getQueryObject(),
                         object
@@ -328,7 +330,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
             }
 
             //演出修改数据
-            HashMap<String, Object> map = new HashMap<>();
+            HashMap<String, Object> map = ObjectUtil.cloneHashMapStringAndObject();
             map.put("isTrueName", step2Param.getIsTrueName());
             map.put("limitCount", step2Param.getLimitCount());
             map.put("createdAt", createdAt.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
@@ -344,7 +346,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
                     map.put("auditStatus", 1);
                     map.put("status", 9);
                 }
-                BasicDBObject object = new BasicDBObject("$set", mongoConverter.convertToMongoType(map));
+                BasicDBObject object = ObjectUtil.cloneBasicDBObject().append("$set", mongoConverter.convertToMongoType(map));
                 mongoTemplate.getCollection(PerformancePartnerVo.class.getSimpleName()).updateOne(
                         Query.query(Criteria.where("performancesId").is(performanceId)).getQueryObject(),
                         object
@@ -362,19 +364,19 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
                 } else {
                     KylinPerformanceMisVo kylinPerformanceMisVo = performanceVoTask.getPerformanceMisVo(performanceId);
 
-                    HashMap<String, Object> mapSql = new HashMap<>();
+                    HashMap<String, Object> mapSql = ObjectUtil.cloneHashMapStringAndObject();
                     mapSql.put("rejectTxt", "");
                     mapSql.put("status", map.get("status"));
                     mapSql.put("updatedAt", createdAt.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
-                    KylinPerformances performances = new KylinPerformances();
+                    KylinPerformances performances = KylinPerformances.getNew();
                     performances.setAuditTime(LocalDateTime.now());
                     performances.setNoticeImage(kylinPerformanceMisVo.getNoticeImage());
-                    performancesMapper.update(performances, new UpdateWrapper<KylinPerformances>().eq("performances_id", performanceId));
-                    KylinPerformanceStatus performanceStatus = new KylinPerformanceStatus();
+                    performancesMapper.update(performances, Wrappers.lambdaQuery(KylinPerformances.class).eq(KylinPerformances::getPerformancesId, performanceId));
+                    KylinPerformanceStatus performanceStatus = KylinPerformanceStatus.getNew();
                     performanceStatus.setAuditStatus((int) map.get("auditStatus"));
                     performanceStatus.setIsTrueName(step2Param.getIsTrueName());
                     performanceStatus.setLimitCount(step2Param.getLimitCount());
-                    performanceStatusMapper.update(performanceStatus, new UpdateWrapper<KylinPerformanceStatus>().eq("performance_id", performanceId));
+                    performanceStatusMapper.update(performanceStatus, Wrappers.lambdaQuery(KylinPerformanceStatus.class).eq(KylinPerformanceStatus::getPerformanceId, performanceId));
 
                     //提示：票种价格、售票时间、票种购票限制 直接生效 (演出购票限制，购票须知 演出是否实名 票种缺货登记 票种是否电子票 票种是否快递票 票种最低购买张数 票种是否显示二维码)
                     List<TicketTimesTicketCreatePartnerVo> timeList = kylinPerformanceMisVo.getTicketTimes();
@@ -383,7 +385,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
                         for (KylinTicketPartnerVo ticketItem : ticketList) {
                             //修改 redis库存
                             if (redisUtil.hasKey(KylinRedisConst.PERFORMANCES_INVENTORY + ticketItem.getTicketsId() + ":" + KylinRedisConst.SURPLUS_GENERAL)) {
-                                KylinTicketStatus ticketStatus = ticketStatusMapper.selectOne(new UpdateWrapper<KylinTicketStatus>().eq("ticket_id", ticketItem.getTicketsId()));
+                                KylinTicketStatus ticketStatus = ticketStatusMapper.selectOne(Wrappers.lambdaQuery(KylinTicketStatus.class).eq(KylinTicketStatus::getTicketId, ticketItem.getTicketsId()));
                                 int changeGeneral = ticketItem.getTotalGeneral() - ticketStatus.getTotalGeneral();
                                 int changeExchange = ticketItem.getTotalExchange() - ticketStatus.getTotalExchange();
                                 log.debug("ticketItem.getTotalGeneral() = " + ticketItem.getTotalGeneral());
@@ -392,7 +394,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
                                 dataUtils.changeSurplusExchange(ticketItem.getTicketsId(), changeExchange);
                             }
                             //修改 mysql 库存
-                            KylinTicketStatus inventory = new KylinTicketStatus();
+                            KylinTicketStatus inventory = KylinTicketStatus.getNew();
                             inventory.setTotalExchange(ticketItem.getTotalExchange());
                             inventory.setTotalGeneral(ticketItem.getTotalGeneral());
                             inventory.setIsTrueName(kylinPerformanceMisVo.getIsTrueName());
@@ -405,7 +407,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
                             inventory.setQrCodeShowTime(DateUtil.Formatter.yyyyMMddHHmmss.parse(ticketItem.getQrCodeShowTime()));
 
                             //修改 mysql 售卖时间
-                            KylinTickets ticketSellTime = new KylinTickets();
+                            KylinTickets ticketSellTime = KylinTickets.getNew();
                             ticketSellTime.setTimeEnd(DateUtil.Formatter.yyyyMMddHHmmss.parse(ticketItem.getTimeEnd()));
                             ticketSellTime.setTimeStart(DateUtil.Formatter.yyyyMMddHHmmss.parse(ticketItem.getTimeStart()));
                             ticketSellTime.setAdvanceMinuteMember(null);
@@ -414,9 +416,9 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
                             //修改 价格
                             ticketSellTime.setPrice(ticketItem.getPrice());
                             ticketSellTime.setPriceDiscountMember(null);
-                            ticketsMapper.update(ticketSellTime, new UpdateWrapper<KylinTickets>().eq("tickets_id", ticketItem.getTicketsId()));
+                            ticketsMapper.update(ticketSellTime, Wrappers.lambdaQuery(KylinTickets.class).eq(KylinTickets::getTicketsId, ticketItem.getTicketsId()));
                             //修改 mysql 购票限购
-                            ticketStatusMapper.update(inventory, new UpdateWrapper<KylinTicketStatus>().eq("ticket_id", ticketItem.getTicketsId()));
+                            ticketStatusMapper.update(inventory, Wrappers.lambdaQuery(KylinTicketStatus.class).eq(KylinTicketStatus::getTicketId, ticketItem.getTicketsId()));
                         }
                     }
                     performanceVoTask.performanceVoStatus(performanceId);
@@ -425,7 +427,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
             } else { //保存
                 map.put("status", 0);
                 map.put("auditStatus", -1);
-                BasicDBObject object = new BasicDBObject("$set", mongoConverter.convertToMongoType(map));
+                BasicDBObject object = ObjectUtil.cloneBasicDBObject().append("$set", mongoConverter.convertToMongoType(map));
                 mongoTemplate.getCollection(PerformancePartnerVo.class.getSimpleName()).updateMany(
                         Query.query(Criteria.where("performancesId").is(performanceId)).getQueryObject(),
                         object
@@ -450,19 +452,19 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
         List<TicketTimesTicketCreatePartnerVo> ticketTimesTicketCreatePartnerVoList = new ArrayList<TicketTimesTicketCreatePartnerVo>();
 
         for (KylinTicketTimesPartnerVo ticketTimes : kylinTicketTimesPartnerVos) {
-            TicketTimesTicketCreatePartnerVo ticketTimesTicketCreatePartnerVo = new TicketTimesTicketCreatePartnerVo();
+            TicketTimesTicketCreatePartnerVo ticketTimesTicketCreatePartnerVo = TicketTimesTicketCreatePartnerVo.getNew();
             BeanUtils.copyProperties(ticketTimes, ticketTimesTicketCreatePartnerVo);
             List<KylinTicketPartnerVo> kylinTicketPartnerVos = ticketsPartnerService.getTicketMongoList(ticketTimes.getTicketTimesId());
             ticketTimesTicketCreatePartnerVo.setTicket(kylinTicketPartnerVos);
             ticketTimesTicketCreatePartnerVoList.add(ticketTimesTicketCreatePartnerVo);
         }
 
-        PerformanceStep2Param performanceStep2Param = new PerformanceStep2Param();
+        PerformanceStep2Param performanceStep2Param = PerformanceStep2Param.getNew();
         BeanUtils.copyProperties(data, performanceStep2Param);
-        KylinPerformanceStatus performanceStatus = performanceStatusMapper.selectOne(new UpdateWrapper<KylinPerformanceStatus>().eq("performance_id", performancesId));
-        if(null!=performanceStatus) {
+        KylinPerformanceStatus performanceStatus = performanceStatusMapper.selectOne(Wrappers.lambdaQuery(KylinPerformanceStatus.class).eq(KylinPerformanceStatus::getPerformanceId, performancesId));
+        if (null != performanceStatus) {
             performanceStep2Param.setStatus(performanceStatus.getStatus());
-        }else{
+        } else {
             performanceStep2Param.setStatus(-1);
         }
 
@@ -473,41 +475,41 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
     @Override
     public ResponseDto<String> onLinePerformance(String performancesId) {
         try {
-            KylinPerformanceStatus performanceStatusData = performanceStatusMapper.selectOne(new UpdateWrapper<KylinPerformanceStatus>().eq("performance_id", performancesId));
+            KylinPerformanceStatus performanceStatusData = performanceStatusMapper.selectOne(Wrappers.lambdaQuery(KylinPerformanceStatus.class).eq(KylinPerformanceStatus::getPerformanceId, performancesId));
             if (!(performanceStatusData.getStatus() == 3 || performanceStatusData.getStatus() == 7)) {
                 return ResponseDto.failure(ErrorMapping.get(20110));
             }
             // mysql
             LocalDateTime updatedAt = LocalDateTime.now();
-            KylinPerformanceStatus performanceStatusUpdate = new KylinPerformanceStatus();
+            KylinPerformanceStatus performanceStatusUpdate = KylinPerformanceStatus.getNew();
             performanceStatusUpdate.setStatus(6);
             performanceStatusUpdate.setUpdatedAt(updatedAt);
             performanceStatusMapper.update(performanceStatusUpdate
-                    , new UpdateWrapper<KylinPerformanceStatus>().eq("performance_id", performancesId));
+                    , Wrappers.lambdaQuery(KylinPerformanceStatus.class).eq(KylinPerformanceStatus::getPerformanceId, performancesId));
 
             //场次
             List<KylinTicketTimeRelation> ticketTimeRelation = ticketTimeRelationMapper.selectList(
-                    new UpdateWrapper<KylinTicketTimeRelation>().eq("performance_id", performancesId)
+                    Wrappers.lambdaQuery(KylinTicketTimeRelation.class).eq(KylinTicketTimeRelation::getPerformanceId, performancesId)
             );
 
 
             for (KylinTicketTimeRelation ticketTimeRelationItem : ticketTimeRelation) {
-                KylinTicketTimes ticketTimes = ticketTimesMapper.selectOne(new UpdateWrapper<KylinTicketTimes>().eq("ticket_times_id", ticketTimeRelationItem.getTimesId()).eq("status", 1));
+                KylinTicketTimes ticketTimes = ticketTimesMapper.selectOne(Wrappers.lambdaQuery(KylinTicketTimes.class).eq(KylinTicketTimes::getTicketTimesId, ticketTimeRelationItem.getTimesId()).eq(KylinTicketTimes::getStatus, 1));
                 //票
-                List<KylinTicketRelations> ticketRelations = ticketRelationsMapper.selectList(new UpdateWrapper<KylinTicketRelations>().eq("times_id", ticketTimes.getTicketTimesId()));
+                List<KylinTicketRelations> ticketRelations = ticketRelationsMapper.selectList(Wrappers.lambdaQuery(KylinTicketRelations.class).eq(KylinTicketRelations::getTimesId, ticketTimes.getTicketTimesId()));
                 for (KylinTicketRelations ticketRelationsItem : ticketRelations) {
-                    KylinTicketStatus ticketStatusUpdate = new KylinTicketStatus();
+                    KylinTicketStatus ticketStatusUpdate = KylinTicketStatus.getNew();
                     ticketStatusUpdate.setStatus(9);
                     ticketStatusUpdate.setUpdatedAt(updatedAt);
                     ticketStatusMapper.update(ticketStatusUpdate
-                            , new UpdateWrapper<KylinTicketStatus>().eq("ticket_id", ticketRelationsItem.getTicketId()).in("status", 3,6,8,9,10));
+                            , Wrappers.lambdaQuery(KylinTicketStatus.class).eq(KylinTicketStatus::getTicketId, ticketRelationsItem.getTicketId()).in(KylinTicketStatus::getStatus, 3, 6, 8, 9, 10));
 
-                    HashMap<String, Object> map = new HashMap<>();
+                    HashMap<String, Object> map = ObjectUtil.cloneHashMapStringAndObject();
                     map.put("status", 9);
                     map.put("updatedAt", updatedAt);
                     mongoTemplate.getCollection(KylinTicketPartnerVo.class.getSimpleName()).updateOne(
-                            Query.query(Criteria.where("ticketsId").is(ticketRelationsItem.getTicketId()).and("status").in(3,6,8,9,10)).getQueryObject(),
-                            new BasicDBObject("$set", mongoConverter.convertToMongoType(map))
+                            Query.query(Criteria.where("ticketsId").is(ticketRelationsItem.getTicketId()).and("status").in(3, 6, 8, 9, 10)).getQueryObject(),
+                            ObjectUtil.cloneBasicDBObject().append("$set", mongoConverter.convertToMongoType(map))
                     );
                 }
             }
@@ -515,7 +517,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
             performanceVoTask.performanceVoStatus(performancesId);
             return ResponseDto.success("上线成功");
         } catch (Exception e) {
-            log.debug("上线失败",e);
+            log.debug("上线失败", e);
             return ResponseDto.failure(ErrorMapping.get(20108));
         }
     }
@@ -523,15 +525,15 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
     @Override
     public ResponseDto<String> outLinePerformance(String performancesId) {
         try {
-            KylinPerformanceStatus performanceStatusData = performanceStatusMapper.selectOne(new UpdateWrapper<KylinPerformanceStatus>().eq("performance_id", performancesId));
+            KylinPerformanceStatus performanceStatusData = performanceStatusMapper.selectOne(Wrappers.lambdaQuery(KylinPerformanceStatus.class).eq(KylinPerformanceStatus::getPerformanceId, performancesId));
 
             if (performanceStatusData.getStatus() >= 3 && performanceStatusData.getStatus() != 4 && performanceStatusData.getStatus() != 7 && performanceStatusData.getStatus() != 10) {//未提审||被拒绝
                 LocalDateTime updatedAt = LocalDateTime.now();
-                KylinPerformanceStatus performanceStatus = new KylinPerformanceStatus();
+                KylinPerformanceStatus performanceStatus = KylinPerformanceStatus.getNew();
                 performanceStatus.setStatus(7);
                 performanceStatus.setUpdatedAt(updatedAt);
                 performanceStatusMapper.update(performanceStatus
-                        , new UpdateWrapper<KylinPerformanceStatus>().eq("performance_id", performancesId));
+                        , Wrappers.lambdaQuery(KylinPerformanceStatus.class).eq(KylinPerformanceStatus::getPerformanceId, performancesId));
 
                 performanceVoTask.performanceVoStatus(performancesId);
                 return ResponseDto.success("下线成功");
@@ -539,7 +541,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
                 return ResponseDto.failure(ErrorMapping.get(20111));
             }
         } catch (Exception e) {
-            log.debug("下线失败",e);
+            log.debug("下线失败", e);
             return ResponseDto.failure(ErrorMapping.get(20109));
         }
     }
@@ -559,7 +561,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
             for (KylinTicketTimesPartnerVo timeItem : kylinTicketTimesPartnerVos) {
                 //复制场次
                 String timesId = timeItem.getTicketTimesId();
-                timeItem.setTicketTimesId(IDGenerator.nextSnowId().toString());
+                timeItem.setTicketTimesId(IDGenerator.nextSnowId());
                 timeItem.setPerformancesId(performancePartnerVo.getPerformancesId());
                 mongoTemplate.insert(timeItem, KylinTicketTimesPartnerVo.class.getSimpleName());
 
@@ -601,7 +603,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
             //处理Vo
             List<KylinPerformancePartnerListVo> voList = new ArrayList<>();
             for (PerformancePartnerVo item : performancePartnerVo) {
-                KylinPerformancePartnerListVo voData = new KylinPerformancePartnerListVo();
+                KylinPerformancePartnerListVo voData = KylinPerformancePartnerListVo.getNew();
                 voData.setStatus0Data(item);
                 voList.add(voData);
             }
@@ -636,10 +638,10 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
     public ResponseDto<String> withdraw(String performancesId) {
         try {
             //mysql auditStatus
-            KylinPerformanceStatus performanceStatus = performanceStatusMapper.selectOne(new UpdateWrapper<KylinPerformanceStatus>().eq("performance_id", performancesId));
+            KylinPerformanceStatus performanceStatus = performanceStatusMapper.selectOne(Wrappers.lambdaQuery(KylinPerformanceStatus.class).eq(KylinPerformanceStatus::getPerformanceId, performancesId));
             if (performanceStatus != null && performanceStatus.getAuditStatus() == 0) {
-                KylinPerformanceStatus data1 = new KylinPerformanceStatus();
-                HashMap<String, Object> map = new HashMap<>();
+                KylinPerformanceStatus data1 = KylinPerformanceStatus.getNew();
+                HashMap<String, Object> map = ObjectUtil.cloneHashMapStringAndObject();
                 if (performanceStatus.getStatus() >= 3) {//通过审核
                     data1.setAuditStatus(1);
                     data1.setStatus(null);
@@ -654,8 +656,8 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
                     data1.setStatus(null);
                     map.put("auditStatus", 2);
                 }
-                performanceStatusMapper.update(data1, new UpdateWrapper<KylinPerformanceStatus>().eq("performance_id", performancesId));
-                BasicDBObject object = new BasicDBObject("$set", mongoConverter.convertToMongoType(map));
+                performanceStatusMapper.update(data1, Wrappers.lambdaQuery(KylinPerformanceStatus.class).eq(KylinPerformanceStatus::getPerformanceId, performancesId));
+                BasicDBObject object = ObjectUtil.cloneBasicDBObject().append("$set", mongoConverter.convertToMongoType(map));
                 mongoTemplate.getCollection(PerformancePartnerVo.class.getSimpleName()).updateOne(
                         Query.query(Criteria.where("performancesId").is(performancesId)).getQueryObject(),
                         object
@@ -672,13 +674,13 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
 
     @Override
     public List<PerformanceOrderStatisticalVo> getPerformanceOrderStatisticalList(String performancesId) {
-        PerformanceOrderStatisticalDao countBean = new PerformanceOrderStatisticalDao();
+        PerformanceOrderStatisticalDao countBean = PerformanceOrderStatisticalDao.getNew();
         countBean.setTitle("总计：");
 
         List<PerformanceOrderStatisticalVo> voList = new ArrayList<>();
         List<PerformanceOrderStatisticalDao> dtoList = performancesMapper.getPerformanceOrderStatisticalList(performancesId);
         dtoList.forEach(dto -> {
-            PerformanceOrderStatisticalVo vo = new PerformanceOrderStatisticalVo();
+            PerformanceOrderStatisticalVo vo = PerformanceOrderStatisticalVo.getNew();
             BeanUtil.copy(dto, vo);
             voList.add(vo);
 
@@ -693,7 +695,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
             countBean.setTotalPayingNumber(countBean.getTotalPayingNumber().add(dto.getTotalPayingNumber()));
             countBean.setTotalBuyUsers(dto.getTotalBuyUsers());
         });
-        PerformanceOrderStatisticalVo vo = new PerformanceOrderStatisticalVo();
+        PerformanceOrderStatisticalVo vo = PerformanceOrderStatisticalVo.getNew();
         BeanUtil.copy(countBean, vo);
         voList.add(vo);
         return voList;

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/partner/KylinTicketTimesPartnerServiceImpl.java

@@ -2,6 +2,7 @@ package com.liquidnet.service.platform.service.impl.partner;
 
 import com.alibaba.fastjson.JSON;
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.liquidnet.commons.lang.util.IDGenerator;
 import com.liquidnet.commons.lang.util.JsonUtils;
@@ -16,6 +17,7 @@ import com.liquidnet.service.kylin.mapper.KylinPerformanceStatusMapper;
 import com.liquidnet.service.kylin.mapper.KylinTicketTimeRelationMapper;
 import com.liquidnet.service.kylin.mapper.KylinTicketTimesMapper;
 import com.liquidnet.service.kylin.service.partner.IKylinTicketTimesPartnerService;
+import com.liquidnet.service.platform.utils.ObjectUtil;
 import com.mongodb.BasicDBObject;
 import com.mongodb.client.model.FindOneAndUpdateOptions;
 import com.mongodb.client.model.ReturnDocument;
@@ -63,7 +65,7 @@ public class KylinTicketTimesPartnerServiceImpl extends ServiceImpl<KylinTicketT
         ResponseDto<KylinTicketTimesPartnerVo> ticketTimesPartnerVo = null;
         //获取演出状态
         KylinPerformanceStatus performanceStatus = performanceStatusMapper.selectOne(
-                new UpdateWrapper<KylinPerformanceStatus>().eq("performance_id", createTicketTimesParam.getPerformancesId()));
+                Wrappers.lambdaQuery(KylinPerformanceStatus.class).eq(KylinPerformanceStatus::getPerformanceId, createTicketTimesParam.getPerformancesId()));
         if (null == performanceStatus) {
             ticketTimesPartnerVo = createTimes(createTicketTimesParam);
         } else if(performanceStatus.getAuditStatus()==0){
@@ -80,7 +82,7 @@ public class KylinTicketTimesPartnerServiceImpl extends ServiceImpl<KylinTicketT
     public ResponseDto<KylinTicketTimesPartnerVo> createTimes(CreateTicketTimesParam createTicketTimesParam) {
         try {
             // 获取 主键id
-            String ticketTimesId = IDGenerator.nextSnowId().toString();
+            String ticketTimesId = IDGenerator.nextSnowId();
             // 获取 当前时间 -> 创建时间
             LocalDateTime createdAt = LocalDateTime.now();
             // 标题
@@ -97,7 +99,7 @@ public class KylinTicketTimesPartnerServiceImpl extends ServiceImpl<KylinTicketT
                 title = useStart + "-" + useEnd;
             }
             // mongo 操作
-            KylinTicketTimesPartnerVo kylinTicketTimesPartnerVo = new KylinTicketTimesPartnerVo();
+            KylinTicketTimesPartnerVo kylinTicketTimesPartnerVo = KylinTicketTimesPartnerVo.getNew();
             kylinTicketTimesPartnerVo.setTicketTimesId(ticketTimesId);
             kylinTicketTimesPartnerVo.setUseStart(createTicketTimesParam.getUseStart().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
             if(createTicketTimesParam.getType() == 2) {
@@ -141,7 +143,7 @@ public class KylinTicketTimesPartnerServiceImpl extends ServiceImpl<KylinTicketT
             }
 
             // mongo 操作
-            KylinTicketTimesPartnerVo kylinTicketTimesPartnerVo = new KylinTicketTimesPartnerVo();
+            KylinTicketTimesPartnerVo kylinTicketTimesPartnerVo = KylinTicketTimesPartnerVo.getNew();
             kylinTicketTimesPartnerVo.setTicketTimesId(ticketTimesId);
             kylinTicketTimesPartnerVo.setUseStart(createTicketTimesParam.getUseStart().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
             kylinTicketTimesPartnerVo.setUseEnd(createTicketTimesParam.getUseEnd().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
@@ -169,24 +171,23 @@ public class KylinTicketTimesPartnerServiceImpl extends ServiceImpl<KylinTicketT
                 return ResponseDto.failure(ErrorMapping.get(20106));
             }
             KylinTicketTimeRelation ticketTimeRelation = ticketTimeRelationMapper.selectOne(
-                    new UpdateWrapper<KylinTicketTimeRelation>().eq("times_id", ticketTimesId));
+                    Wrappers.lambdaQuery(KylinTicketTimeRelation.class).eq(KylinTicketTimeRelation::getTimesId, ticketTimesId));
             if (ticketTimeRelation != null) {
                 KylinPerformanceStatus performanceStatus = performanceStatusMapper.selectOne(
-                        new UpdateWrapper<KylinPerformanceStatus>().eq("performance_id", ticketTimeRelation.getPerformanceId()));
+                        Wrappers.lambdaQuery(KylinPerformanceStatus.class).eq(KylinPerformanceStatus::getPerformanceId, ticketTimeRelation.getPerformanceId()));
                 if(performanceStatus.getAuditStatus()==0){
                     return ResponseDto.failure(ErrorMapping.get(20101));
                 }
 
                 if (performanceStatus.getStatus() == 0 || performanceStatus.getStatus() == 4) {//未提审||被拒绝
-                    HashMap<String, Object> map = new HashMap<>();
+                    HashMap<String, Object> map = ObjectUtil.cloneHashMapStringAndObject();
                     map.put("updatedAt", updatedAt.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
                     map.put("status", 0);
 
-                    BasicDBObject object = new BasicDBObject("$set", mongoConverter.convertToMongoType(map));
-                    Document doc = mongoTemplate.getCollection(KylinTicketTimesPartnerVo.class.getSimpleName()).findOneAndUpdate(
+                    BasicDBObject object = ObjectUtil.cloneBasicDBObject().append("$set", mongoConverter.convertToMongoType(map));
+                    mongoTemplate.getCollection(KylinTicketTimesPartnerVo.class.getSimpleName()).updateOne(
                             Query.query(Criteria.where("ticketTimesId").is(ticketTimesId)).getQueryObject(),
-                            object,
-                            new FindOneAndUpdateOptions().returnDocument(ReturnDocument.AFTER)
+                            object
                     );
                     return ResponseDto.success("删除成功");
                 } else {
@@ -214,7 +215,7 @@ public class KylinTicketTimesPartnerServiceImpl extends ServiceImpl<KylinTicketT
             createTicketTimesParam.setTitle(title);
 
             // mongo 操作
-            KylinTicketTimesPartnerVo kylinTicketTimesPartnerVo = new KylinTicketTimesPartnerVo();
+            KylinTicketTimesPartnerVo kylinTicketTimesPartnerVo = KylinTicketTimesPartnerVo.getNew();
             BeanUtils.copyProperties(createTicketTimesParam, kylinTicketTimesPartnerVo);
             kylinTicketTimesPartnerVo.setTicketTimesId(createTicketTimesParam.getTicketTimesId());
             kylinTicketTimesPartnerVo.setUpdatedAt(updatedAt.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
@@ -222,7 +223,7 @@ public class KylinTicketTimesPartnerServiceImpl extends ServiceImpl<KylinTicketT
             kylinTicketTimesPartnerVo.setUseEnd(createTicketTimesParam.getUseEnd().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
             kylinTicketTimesPartnerVo.setStatus(null);
 
-            BasicDBObject object = new BasicDBObject("$set", JSON.parse(JsonUtils.toJson(kylinTicketTimesPartnerVo)));
+            BasicDBObject object = ObjectUtil.cloneBasicDBObject().append("$set", JSON.parse(JsonUtils.toJson(kylinTicketTimesPartnerVo)));
             Document doc = mongoTemplate.getCollection(KylinTicketTimesPartnerVo.class.getSimpleName()).findOneAndUpdate(
                     Query.query(Criteria.where("ticketTimesId").is(createTicketTimesParam.getTicketTimesId())).getQueryObject(),
                     object,

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/partner/KylinTicketsPartnerServiceImpl.java

 package com.liquidnet.service.platform.service.impl.partner;
 
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.liquidnet.commons.lang.util.DateUtil;
 import com.liquidnet.commons.lang.util.IDGenerator;
@@ -14,6 +15,7 @@ import com.liquidnet.service.kylin.dto.vo.partner.KylinTicketTimesPartnerVo;
 import com.liquidnet.service.kylin.entity.*;
 import com.liquidnet.service.kylin.mapper.*;
 import com.liquidnet.service.kylin.service.partner.IKylinTicketsPartnerService;
+import com.liquidnet.service.platform.utils.ObjectUtil;
 import com.liquidnet.service.platform.utils.PerformanceVoTask;
 import com.mongodb.BasicDBObject;
 import com.mongodb.client.model.FindOneAndUpdateOptions;
@@ -74,7 +76,7 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp
 
         if (null != timesPartnerVo) {
             KylinPerformanceStatus performanceStatus = performanceStatusMapper.selectOne(
-                    new UpdateWrapper<KylinPerformanceStatus>().eq("performance_id", timesPartnerVo.getPerformancesId()));
+                    Wrappers.lambdaQuery(KylinPerformanceStatus.class).eq(KylinPerformanceStatus::getPerformanceId, timesPartnerVo.getPerformancesId()));
             if (null == performanceStatus) {
                 ticketPartnerVo = createTicket(ticketCreateParam);
             } else if (performanceStatus.getStatus() >= 3 && performanceStatus.getStatus() != 4) {//未被拒绝 且 通过审核的演出
@@ -98,7 +100,7 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp
             ticketCreateParam.setTicketsId(ticketsId);
 
             // mongo 操作
-            KylinTicketPartnerVo kylinTicketPartnerVo = new KylinTicketPartnerVo();
+            KylinTicketPartnerVo kylinTicketPartnerVo = KylinTicketPartnerVo.getNew();
             BeanUtils.copyProperties(ticketCreateParam, kylinTicketPartnerVo);
             kylinTicketPartnerVo.setTicketsId(ticketsId);
             kylinTicketPartnerVo.setCreatedAt(DateUtil.Formatter.yyyyMMddHHmmss.format(createdAt));
@@ -112,12 +114,12 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp
             kylinTicketPartnerVo.setStatus(0);
             kylinTicketPartnerVo.setDefault();
             if (ticketCreateParam.getIsExpress() == 1) {
-                kylinTicketPartnerVo.setDescribeExpress(ticketCreateParam.getDescribeExpress()==null?"":ticketCreateParam.getDescribeExpress());
+                kylinTicketPartnerVo.setDescribeExpress(ticketCreateParam.getDescribeExpress() == null ? "" : ticketCreateParam.getDescribeExpress());
             } else {
                 kylinTicketPartnerVo.setDescribeExpress("");
             }
             if (ticketCreateParam.getIsElectronic() == 1) {
-                kylinTicketPartnerVo.setDescribeElectronic(ticketCreateParam.getDescribeElectronic()==null?"":ticketCreateParam.getDescribeElectronic());
+                kylinTicketPartnerVo.setDescribeElectronic(ticketCreateParam.getDescribeElectronic() == null ? "" : ticketCreateParam.getDescribeElectronic());
             } else {
                 kylinTicketPartnerVo.setDescribeElectronic("");
             }
@@ -150,7 +152,7 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp
             ticketCreateParam.setTicketsId(ticketsId);
 
             // mongo 操作
-            KylinTicketPartnerVo kylinTicketPartnerVo = new KylinTicketPartnerVo();
+            KylinTicketPartnerVo kylinTicketPartnerVo = KylinTicketPartnerVo.getNew();
             BeanUtils.copyProperties(ticketCreateParam, kylinTicketPartnerVo);
             kylinTicketPartnerVo.setTicketsId(ticketsId);
             kylinTicketPartnerVo.setCreatedAt(createdAt.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
@@ -162,12 +164,12 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp
             kylinTicketPartnerVo.setUseEnd(kylinTicketTimesPartnerVo.getUseEnd());
             kylinTicketPartnerVo.setType(kylinTicketTimesPartnerVo.getType());
             if (ticketCreateParam.getIsExpress() == 1) {
-                kylinTicketPartnerVo.setDescribeExpress(ticketCreateParam.getDescribeExpress()==null?"":ticketCreateParam.getDescribeExpress());
+                kylinTicketPartnerVo.setDescribeExpress(ticketCreateParam.getDescribeExpress() == null ? "" : ticketCreateParam.getDescribeExpress());
             } else {
                 kylinTicketPartnerVo.setDescribeExpress("");
             }
             if (ticketCreateParam.getIsElectronic() == 1) {
-                kylinTicketPartnerVo.setDescribeElectronic(ticketCreateParam.getDescribeElectronic()==null?"":ticketCreateParam.getDescribeElectronic());
+                kylinTicketPartnerVo.setDescribeElectronic(ticketCreateParam.getDescribeElectronic() == null ? "" : ticketCreateParam.getDescribeElectronic());
             } else {
                 kylinTicketPartnerVo.setDescribeElectronic("");
             }
@@ -208,7 +210,7 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp
             String ticketId = ticketCreateParam.getTicketsId();
             LocalDateTime updatedAt = LocalDateTime.now();
             // mongo 操作
-            KylinTicketPartnerVo kylinTicketPartnerVo = new KylinTicketPartnerVo();
+            KylinTicketPartnerVo kylinTicketPartnerVo = KylinTicketPartnerVo.getNew();
             BeanUtils.copyProperties(ticketCreateParam, kylinTicketPartnerVo);
             kylinTicketPartnerVo.setUpdatedAt(updatedAt.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
             kylinTicketPartnerVo.setTimeStart(ticketCreateParam.getTimeStart().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
@@ -216,10 +218,10 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp
             kylinTicketPartnerVo.setTimesId(null);
             kylinTicketPartnerVo.setStatus(null);
             if (ticketCreateParam.getIsExpress() == 1) {
-                kylinTicketPartnerVo.setDescribeExpress(ticketCreateParam.getDescribeExpress()==null?"":ticketCreateParam.getDescribeExpress());
+                kylinTicketPartnerVo.setDescribeExpress(ticketCreateParam.getDescribeExpress() == null ? "" : ticketCreateParam.getDescribeExpress());
             }
             if (ticketCreateParam.getIsElectronic() == 1) {
-                kylinTicketPartnerVo.setDescribeElectronic(ticketCreateParam.getDescribeElectronic()==null?"":ticketCreateParam.getDescribeElectronic());
+                kylinTicketPartnerVo.setDescribeElectronic(ticketCreateParam.getDescribeElectronic() == null ? "" : ticketCreateParam.getDescribeElectronic());
             }
 
             kylinTicketPartnerVo.setDefault();
@@ -230,7 +232,7 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp
                 kylinTicketPartnerVo.setQrCodeShowTime(ticketCreateParam.getQrCodeShowTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
             }
 
-            BasicDBObject object = new BasicDBObject("$set", mongoConverter.convertToMongoType(kylinTicketPartnerVo));
+            BasicDBObject object = ObjectUtil.cloneBasicDBObject().append("$set", mongoConverter.convertToMongoType(kylinTicketPartnerVo));
             Document doc = mongoTemplate.getCollection(KylinTicketPartnerVo.class.getSimpleName()).findOneAndUpdate(
                     Query.query(Criteria.where("ticketsId").is(ticketId)).getQueryObject(),
                     object,
@@ -251,15 +253,14 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp
             LocalDateTime updatedAt = LocalDateTime.now();
 
             KylinTicketRelations ticketRelations = ticketRelationsMapper.selectOne(
-                    new UpdateWrapper<KylinTicketRelations>().eq("ticket_id", ticketsId));
+                    Wrappers.lambdaQuery(KylinTicketRelations.class).eq(KylinTicketRelations::getTicketId, ticketsId));
 
             if (ticketRelations == null) {
                 mongoTemplate.remove(Query.query(Criteria.where("ticketsId").is(ticketsId)), KylinTicketPartnerVo.class, KylinTicketPartnerVo.class.getSimpleName());
                 return ResponseDto.success("删除成功");
             }
             KylinTicketTimeRelation ticketTimeRelation = ticketTimeRelationMapper.selectOne(
-                    new UpdateWrapper<KylinTicketTimeRelation>().eq("times_id", ticketRelations.getTimesId()));
-
+                    Wrappers.lambdaQuery(KylinTicketTimeRelation.class).eq(KylinTicketTimeRelation::getTimesId, ticketRelations.getTimesId()));
             PerformancePartnerVo data = mongoTemplate.findOne(Query.query(Criteria.where("performancesId").is(ticketTimeRelation.getPerformanceId())),
                     PerformancePartnerVo.class, PerformancePartnerVo.class.getSimpleName());
             if (data == null || data.getAuditStatus() == null || data.getAuditStatus() == 0) {
@@ -267,19 +268,18 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp
             }
 
             KylinPerformanceStatus performanceStatus = performanceStatusMapper.selectOne(
-                    new UpdateWrapper<KylinPerformanceStatus>().eq("performance_id", ticketTimeRelation.getPerformanceId()));
+                    Wrappers.lambdaQuery(KylinPerformanceStatus.class).eq(KylinPerformanceStatus::getPerformanceId, ticketTimeRelation.getPerformanceId()));
 
             if (performanceStatus.getStatus() == 0 || performanceStatus.getStatus() == 4) {//未提审||被拒绝
                 // mongo 操作
-                HashMap<String, Object> map = new HashMap<>();
+                HashMap<String, Object> map = ObjectUtil.cloneHashMapStringAndObject();
                 map.put("updatedAt", updatedAt.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
                 map.put("status", -1);
 
-                BasicDBObject object = new BasicDBObject("$set", mongoConverter.convertToMongoType(map));
-                Document doc = mongoTemplate.getCollection(KylinTicketPartnerVo.class.getSimpleName()).findOneAndUpdate(
+                BasicDBObject object = ObjectUtil.cloneBasicDBObject().append("$set", mongoConverter.convertToMongoType(map));
+                mongoTemplate.getCollection(KylinTicketPartnerVo.class.getSimpleName()).updateOne(
                         Query.query(Criteria.where("ticketsId").is(ticketsId)).getQueryObject(),
-                        object,
-                        new FindOneAndUpdateOptions().returnDocument(ReturnDocument.AFTER)
+                        object
                 );
                 return ResponseDto.success("删除成功");
             } else {
@@ -320,14 +320,14 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp
     public boolean submitTicketByTimes(String timesId, Integer status) {
         LocalDateTime updatedAt = LocalDateTime.now();
 
-        HashMap<String, Object> map = new HashMap<>();
+        HashMap<String, Object> map = ObjectUtil.cloneHashMapStringAndObject();
         if (null == status) {
             map.put("status", 1);
         } else {
             map.put("status", status);
         }
         map.put("updatedAt", updatedAt.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
-        BasicDBObject object = new BasicDBObject("$set", mongoConverter.convertToMongoType(map));
+        BasicDBObject object = ObjectUtil.cloneBasicDBObject().append("$set", mongoConverter.convertToMongoType(map));
         mongoTemplate.getCollection(KylinTicketPartnerVo.class.getSimpleName()).updateMany(
                 Query.query(Criteria.where("timesId").is(timesId).and("status").nin(-2, 7)).getQueryObject(),
                 object
@@ -355,18 +355,18 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp
     public ResponseDto<String> onLine(String ticketsId, String performancesId) {
         try {
             LocalDateTime updatedAt = LocalDateTime.now();
-            KylinTicketStatus ticketStatus = ticketStatusMapper.selectOne(new UpdateWrapper<KylinTicketStatus>().eq("ticket_id", ticketsId));
+            KylinTicketStatus ticketStatus = ticketStatusMapper.selectOne(Wrappers.lambdaQuery(KylinTicketStatus.class).eq(KylinTicketStatus::getTicketId, ticketsId));
             if (ticketStatus.getStatus() >= 3 && ticketStatus.getStatus() != 4 && ticketStatus.getStatus() != 6) {//未提审||被拒绝
                 //mysql
-                KylinTicketStatus changeStatus = new KylinTicketStatus();
+                KylinTicketStatus changeStatus = KylinTicketStatus.getNew();
                 changeStatus.setUpdatedAt(updatedAt);
                 changeStatus.setStatus(9);
-                ticketStatusMapper.update(changeStatus, new UpdateWrapper<KylinTicketStatus>().eq("ticket_id", ticketsId));
+                ticketStatusMapper.update(changeStatus, Wrappers.lambdaQuery(KylinTicketStatus.class).eq(KylinTicketStatus::getTicketId, ticketsId));
 
 
-                HashMap<String, Object> map = new HashMap<>();
+                HashMap<String, Object> map = ObjectUtil.cloneHashMapStringAndObject();
                 map.put("status", 9);
-                BasicDBObject object = new BasicDBObject("$set", mongoConverter.convertToMongoType(map));
+                BasicDBObject object = ObjectUtil.cloneBasicDBObject().append("$set", mongoConverter.convertToMongoType(map));
                 mongoTemplate.getCollection(KylinTicketPartnerVo.class.getSimpleName()).updateOne(
                         Query.query(Criteria.where("ticketsId").is(ticketsId)).getQueryObject(),
                         object
@@ -387,17 +387,17 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp
     public ResponseDto<String> outLine(String ticketsId, String performancesId) {
         try {
             LocalDateTime updatedAt = LocalDateTime.now();
-            KylinTicketStatus ticketStatus = ticketStatusMapper.selectOne(new UpdateWrapper<KylinTicketStatus>().eq("ticket_id", ticketsId));
+            KylinTicketStatus ticketStatus = ticketStatusMapper.selectOne(Wrappers.lambdaQuery(KylinTicketStatus.class).eq(KylinTicketStatus::getTicketId, ticketsId));
             if (ticketStatus.getStatus() >= 3 && ticketStatus.getStatus() != 4 && ticketStatus.getStatus() != 7) {//未提审||被拒绝
                 //mysql
-                KylinTicketStatus changeStatus = new KylinTicketStatus();
+                KylinTicketStatus changeStatus = KylinTicketStatus.getNew();
                 changeStatus.setUpdatedAt(updatedAt);
                 changeStatus.setStatus(7);
-                ticketStatusMapper.update(changeStatus, new UpdateWrapper<KylinTicketStatus>().eq("ticket_id", ticketsId));
+                ticketStatusMapper.update(changeStatus, Wrappers.lambdaQuery(KylinTicketStatus.class).eq(KylinTicketStatus::getTicketId, ticketsId));
                 // mongo 操作
-                HashMap<String, Object> map = new HashMap<>();
+                HashMap<String, Object> map = ObjectUtil.cloneHashMapStringAndObject();
                 map.put("status", 7);
-                BasicDBObject object = new BasicDBObject("$set", mongoConverter.convertToMongoType(map));
+                BasicDBObject object = ObjectUtil.cloneBasicDBObject().append("$set", mongoConverter.convertToMongoType(map));
                 mongoTemplate.getCollection(KylinTicketPartnerVo.class.getSimpleName()).updateOne(
                         Query.query(Criteria.where("ticketsId").is(ticketsId)).getQueryObject(),
                         object

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/utils/ObjectUtil.java

+package com.liquidnet.service.platform.utils;
+
+import com.liquidnet.service.adam.dto.vo.AdamEntersVo;
+import com.liquidnet.service.kylin.dto.vo.returns.KylinOrderListVo;
+import com.mongodb.BasicDBObject;
+import org.springframework.stereotype.Component;
+import org.springframework.util.LinkedMultiValueMap;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.LinkedList;
+
+/**
+ * @author AnJiabin <anjiabin@zhengzai.tv>
+ * @version V1.0
+ * @Description: TODO
+ * @class: ObjectUtil
+ * @Package com.liquidnet.service.dragon.utils
+ * @Copyright: LightNet @ Copyright (c) 2021
+ * @date 2021/7/21 16:00
+ */
+@Component
+public class ObjectUtil {
+    private static final LinkedList<Object[]> linkedListObj = new LinkedList<Object[]>();
+    private static final LinkedList<String> linkedListStr = new LinkedList<String>();
+    private static final HashMap<String, String> hashMapStringAndString = new HashMap<String, String>();
+    private static final HashMap<String, Object> hashMapStringAndObject = new HashMap<String, Object>();
+    private static final HashMap<String, Integer> hashMapStringAndInteger = new HashMap();
+    private static final ArrayList<String> arrayListString = new ArrayList<>();
+    private static final LinkedMultiValueMap<String, String> linkedMultiValueMapStringAndString = new LinkedMultiValueMap<String, String>();
+    private static final BasicDBObject basicDBObject = new BasicDBObject();
+
+    public static final Object[] objectsArray = new Object[100];
+    public static final Integer[] integerArray2 = new Integer[2];
+
+    public static LinkedList<Object[]> cloneLinkedListObj() {
+        return (LinkedList<Object[]>) linkedListObj.clone();
+    }
+
+    public static LinkedList<String> cloneLinkedListStr() {
+        return (LinkedList<String>) linkedListStr.clone();
+    }
+
+    public static HashMap<String, String> cloneHashMapStringAndString() {
+        return (HashMap<String, String>) hashMapStringAndString.clone();
+    }
+
+    public static HashMap<String, Object> cloneHashMapStringAndObject() {
+        return (HashMap<String, Object>) hashMapStringAndObject.clone();
+    }
+
+    public static HashMap<String, Integer> cloneHashMapStringAndInteger() {
+        return (HashMap<String, Integer>) hashMapStringAndInteger.clone();
+    }
+
+    public static ArrayList<String> cloneArrayListString() {
+        return (ArrayList<String>) arrayListString.clone();
+    }
+
+    public static LinkedMultiValueMap<String, String> cloneLinkedMultiValueMapStringAndString() {
+        return linkedMultiValueMapStringAndString.clone();
+    }
+
+    public static Object[] cloneObjectsArray() {
+        return objectsArray.clone();
+    }
+
+    public static Integer[] cloneInteger2Array() {
+        return integerArray2.clone();
+    }
+
+    public static BasicDBObject cloneBasicDBObject() {
+        return (BasicDBObject) basicDBObject.clone();
+    }
+}