记得上下班打卡 | git大法好，push需谨慎

Skip to content

L
liquidnet-bus-v1
Commit acf2ddd6 authored by jiangxiulong's avatar jiangxiulong
Browse files
Options

Merge remote-tracking branch 'origin/dev' into dev

parents 05238777 ff07243d
Hide whitespace changes
Inline Side-by-side
Showing with 321 additions and 153 deletions
liquidnet-bus-api/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/dto/param/CheckPerformanceRelationParam.java
View file @ acf2ddd6
package com.liquidnet.service.kylin.dto.param; package com.liquidnet.service.kylin.dto.param;
import com.liquidnet.service.kylin.dto.vo.mongo.KylinCheckUserPerformanceVo;
import io.swagger.annotations.ApiModelProperty; import io.swagger.annotations.ApiModelProperty;
import lombok.Data; import lombok.Data;
import javax.validation.constraints.NotNull; import javax.validation.constraints.NotNull;
@Data @Data
public class CheckPerformanceRelationParam { public class CheckPerformanceRelationParam implements Cloneable {
@ApiModelProperty(value = "演出id") @ApiModelProperty(value = "演出id")
@NotNull(message = "演出ID不能为空") @NotNull(message = "演出ID不能为空")
private String performanceId; private String performanceId;
@ApiModelProperty(value = "可下载时间") @ApiModelProperty(value = "可下载时间")
@NotNull(message = "可下载时间不能为空") @NotNull(message = "可下载时间不能为空")
private String canDownTime; 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
View file @ acf2ddd6
package com.liquidnet.service.kylin.dto.param; package com.liquidnet.service.kylin.dto.param;
import com.fasterxml.jackson.annotation.JsonIgnore; import com.fasterxml.jackson.annotation.JsonIgnore;
import com.liquidnet.service.kylin.dto.vo.middle.KylinBuyNoticeVo;
import io.swagger.annotations.ApiModelProperty; import io.swagger.annotations.ApiModelProperty;
import lombok.Data; import lombok.Data;
...@@ -8,7 +9,7 @@ import java.io.Serializable; ...@@ -8,7 +9,7 @@ import java.io.Serializable;
import java.util.List; import java.util.List;
@Data @Data
public class PerformancePartnerVo implements Serializable { public class PerformancePartnerVo implements Serializable,Cloneable {
@ApiModelProperty(value = "演出id", example = "") @ApiModelProperty(value = "演出id", example = "")
@JsonIgnore @JsonIgnore
...@@ -112,4 +113,13 @@ public class PerformancePartnerVo implements Serializable { ...@@ -112,4 +113,13 @@ public class PerformancePartnerVo implements Serializable {
@ApiModelProperty(value = "是否保存", example = "") @ApiModelProperty(value = "是否保存", example = "")
private Integer isCreateSave; 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
View file @ acf2ddd6
...@@ -9,7 +9,7 @@ import java.io.Serializable; ...@@ -9,7 +9,7 @@ import java.io.Serializable;
import java.util.List; import java.util.List;
@Data @Data
public class PerformanceStep2Param implements Serializable { public class PerformanceStep2Param implements Serializable,Cloneable {
@ApiModelProperty(value = "演出id", example = "") @ApiModelProperty(value = "演出id", example = "")
@NotNull(message = "不能为空") @NotNull(message = "不能为空")
...@@ -35,4 +35,13 @@ public class PerformanceStep2Param implements Serializable { ...@@ -35,4 +35,13 @@ public class PerformanceStep2Param implements Serializable {
@ApiModelProperty(value = "场次数据",hidden = true) @ApiModelProperty(value = "场次数据",hidden = true)
private List<TicketTimesTicketCreatePartnerVo> ticketTimes; 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
View file @ acf2ddd6
package com.liquidnet.service.kylin.dto.vo; package com.liquidnet.service.kylin.dto.vo;
import com.liquidnet.service.kylin.dao.PerformanceOrderStatisticalDao;
import io.swagger.annotations.ApiModelProperty; import io.swagger.annotations.ApiModelProperty;
import lombok.Data; import lombok.Data;
...@@ -15,7 +16,7 @@ import java.math.BigDecimal; ...@@ -15,7 +16,7 @@ import java.math.BigDecimal;
* @date 2021/6/19 16:44 * @date 2021/6/19 16:44
*/ */
@Data @Data
public class PerformanceOrderStatisticalVo { public class PerformanceOrderStatisticalVo implements Cloneable {
private String performancesId; private String performancesId;
private String ticketsId; private String ticketsId;
@ApiModelProperty(value = "票种名称") @ApiModelProperty(value = "票种名称")
...@@ -48,4 +49,13 @@ public class PerformanceOrderStatisticalVo { ...@@ -48,4 +49,13 @@ public class PerformanceOrderStatisticalVo {
private BigDecimal totalPayingNumber = BigDecimal.ZERO; private BigDecimal totalPayingNumber = BigDecimal.ZERO;
@ApiModelProperty(value = "购买人数") @ApiModelProperty(value = "购买人数")
private BigDecimal totalBuyUsers = BigDecimal.ZERO; 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
View file @ acf2ddd6
package com.liquidnet.service.kylin.dto.vo.middle; package com.liquidnet.service.kylin.dto.vo.middle;
import com.liquidnet.service.kylin.dto.vo.returns.KylinOrderListVo;
import lombok.Data; import lombok.Data;
@Data @Data
public class KylinBuyNoticeVo { public class KylinBuyNoticeVo implements Cloneable {
private String buyNoticeId; private String buyNoticeId;
...@@ -14,4 +15,13 @@ public class KylinBuyNoticeVo { ...@@ -14,4 +15,13 @@ public class KylinBuyNoticeVo {
private String message; private String message;
private Integer sort; 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
View file @ acf2ddd6
...@@ -10,10 +10,19 @@ import java.util.List; ...@@ -10,10 +10,19 @@ import java.util.List;
@Data @Data
@ApiModel @ApiModel
public class KylinCheckUserPerformanceVo implements Serializable { public class KylinCheckUserPerformanceVo implements Serializable,Cloneable {
@ApiModelProperty(value = "id") @ApiModelProperty(value = "id")
private String checkUserId; private String checkUserId;
@ApiModelProperty(value = "演出id数组") @ApiModelProperty(value = "演出id数组")
private List<CheckPerformanceRelationParam> relationParams; 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
View file @ acf2ddd6
package com.liquidnet.service.kylin.dto.vo.mongo; 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.ApiModel;
import io.swagger.annotations.ApiModelProperty; import io.swagger.annotations.ApiModelProperty;
import lombok.Data; import lombok.Data;
...@@ -8,7 +9,7 @@ import java.io.Serializable; ...@@ -8,7 +9,7 @@ import java.io.Serializable;
@Data @Data
@ApiModel @ApiModel
public class KylinCheckUserVo implements Serializable { public class KylinCheckUserVo implements Serializable ,Cloneable{
@ApiModelProperty(value = "id") @ApiModelProperty(value = "id")
private String checkUserId; private String checkUserId;
...@@ -28,4 +29,12 @@ public class KylinCheckUserVo implements Serializable { ...@@ -28,4 +29,12 @@ public class KylinCheckUserVo implements Serializable {
@ApiModelProperty(value = "状态") @ApiModelProperty(value = "状态")
private String status; 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
View file @ acf2ddd6
package com.liquidnet.service.kylin.dto.vo.partner; package com.liquidnet.service.kylin.dto.vo.partner;
import com.liquidnet.service.kylin.dto.param.PerformancePartnerVo; import com.liquidnet.service.kylin.dto.param.PerformancePartnerVo;
import com.liquidnet.service.kylin.dto.param.PerformanceStep2Param;
import io.swagger.annotations.ApiModelProperty; import io.swagger.annotations.ApiModelProperty;
import lombok.Data; import lombok.Data;
@Data @Data
public class KylinPerformancePartnerListVo { public class KylinPerformancePartnerListVo implements Cloneable{
//演出数据 //演出数据
@ApiModelProperty(value = "主键id") @ApiModelProperty(value = "主键id")
...@@ -47,4 +48,13 @@ public class KylinPerformancePartnerListVo { ...@@ -47,4 +48,13 @@ public class KylinPerformancePartnerListVo {
this.rejectTxt=""; this.rejectTxt="";
this.createdAt=item.getCreatedAt(); 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
View file @ acf2ddd6
...@@ -11,7 +11,7 @@ import java.math.BigDecimal; ...@@ -11,7 +11,7 @@ import java.math.BigDecimal;
* 修改场地全部显示数据参数 * 修改场地全部显示数据参数
*/ */
@Data @Data
public class KylinTicketPartnerVo implements Serializable { public class KylinTicketPartnerVo implements Serializable,Cloneable {
@ApiModelProperty(value = "主键") @ApiModelProperty(value = "主键")
private String ticketsId; private String ticketsId;
...@@ -116,4 +116,13 @@ public class KylinTicketPartnerVo implements Serializable { ...@@ -116,4 +116,13 @@ public class KylinTicketPartnerVo implements Serializable {
this.setSurplusExchange(this.getTotalExchange()); this.setSurplusExchange(this.getTotalExchange());
this.setSurplusGeneral(this.getTotalGeneral()); 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
View file @ acf2ddd6
package com.liquidnet.service.kylin.dto.vo.partner; package com.liquidnet.service.kylin.dto.vo.partner;
import com.liquidnet.service.kylin.dto.vo.mongo.KylinCheckUserVo;
import io.swagger.annotations.ApiModelProperty; import io.swagger.annotations.ApiModelProperty;
import lombok.Data; import lombok.Data;
...@@ -8,7 +9,7 @@ import java.io.Serializable; ...@@ -8,7 +9,7 @@ import java.io.Serializable;
//返回 //返回
@Data @Data
public class KylinTicketTimesPartnerVo implements Serializable { public class KylinTicketTimesPartnerVo implements Serializable ,Cloneable{
@ApiModelProperty(value = "主键id") @ApiModelProperty(value = "主键id")
private String ticketTimesId; private String ticketTimesId;
...@@ -39,4 +40,13 @@ public class KylinTicketTimesPartnerVo implements Serializable { ...@@ -39,4 +40,13 @@ public class KylinTicketTimesPartnerVo implements Serializable {
@ApiModelProperty(value = "修改时间") @ApiModelProperty(value = "修改时间")
private String updatedAt; 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
View file @ acf2ddd6
...@@ -9,7 +9,7 @@ import java.util.List; ...@@ -9,7 +9,7 @@ import java.util.List;
//包含 票 //包含 票
@Data @Data
public class TicketTimesTicketCreatePartnerVo implements Serializable { public class TicketTimesTicketCreatePartnerVo implements Serializable ,Cloneable{
@ApiModelProperty(value = "主键id") @ApiModelProperty(value = "主键id")
private String ticketTimesId; private String ticketTimesId;
...@@ -40,4 +40,13 @@ public class TicketTimesTicketCreatePartnerVo implements Serializable { ...@@ -40,4 +40,13 @@ public class TicketTimesTicketCreatePartnerVo implements Serializable {
//票 //票
@ApiModelProperty(value = "票数据") @ApiModelProperty(value = "票数据")
private List<KylinTicketPartnerVo> ticket; 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
View file @ acf2ddd6
...@@ -15,7 +15,7 @@ import java.time.LocalDateTime; ...@@ -15,7 +15,7 @@ import java.time.LocalDateTime;
* @date 2021/6/3 16:39 * @date 2021/6/3 16:39
*/ */
@Data @Data
public class PerformanceOrderStatisticalDao { public class PerformanceOrderStatisticalDao implements Cloneable{
private String performancesId; private String performancesId;
private String ticketsId; private String ticketsId;
private String title; private String title;
...@@ -33,4 +33,13 @@ public class PerformanceOrderStatisticalDao { ...@@ -33,4 +33,13 @@ public class PerformanceOrderStatisticalDao {
private BigDecimal totalMemberNumber = BigDecimal.ZERO; private BigDecimal totalMemberNumber = BigDecimal.ZERO;
private BigDecimal totalPayingNumber = BigDecimal.ZERO; private BigDecimal totalPayingNumber = BigDecimal.ZERO;
private BigDecimal totalBuyUsers = 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-order/liquidnet-service-order-impl/src/main/java/com/liquidnet/service/order/service/impl/KylinOrderTicketsServiceImpl.java
View file @ acf2ddd6
...@@ -683,7 +683,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ ...@@ -683,7 +683,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ
sqlsDataA.add(orderTickets.getPayAgainObject(strTime, strTime)); sqlsDataA.add(orderTickets.getPayAgainObject(strTime, strTime));
sqls.add(SqlMapping.get("kylin_order_ticket_status.payAgain")); sqls.add(SqlMapping.get("kylin_order_ticket_status.payAgain"));
LinkedList<Object[]> sqlsDataB = ObjectUtil.cloneLinkedListObj(); LinkedList<Object[]> sqlsDataB = ObjectUtil.cloneLinkedListObj();
Object[] objectB= ObjectUtil.cloneObjectsArray(); Object[] objectB= ObjectUtil.cloneObjectsArray(4);
objectB[0]= orderTickets.getUpdatedAt(); objectB[0]= orderTickets.getUpdatedAt();
objectB[1]= orderTickets.getOrderTicketsId(); objectB[1]= orderTickets.getOrderTicketsId();
objectB[2]= strTime; objectB[2]= strTime;
...@@ -691,7 +691,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ ...@@ -691,7 +691,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ
sqlsDataB.add(objectB); sqlsDataB.add(objectB);
sqls.add(SqlMapping.get("kylin_order_ticket_relation.payAgain")); sqls.add(SqlMapping.get("kylin_order_ticket_relation.payAgain"));
LinkedList<Object[]> sqlsDataC = ObjectUtil.cloneLinkedListObj(); LinkedList<Object[]> sqlsDataC = ObjectUtil.cloneLinkedListObj();
Object[] objectC = ObjectUtil.cloneObjectsArray(); Object[] objectC = ObjectUtil.cloneObjectsArray(4);
objectC[0]= orderTickets.getUpdatedAt(); objectC[0]= orderTickets.getUpdatedAt();
objectC[1]= orderTickets.getOrderTicketsId(); objectC[1]= orderTickets.getOrderTicketsId();
objectC[2]= strTime; objectC[2]= strTime;
...@@ -699,7 +699,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ ...@@ -699,7 +699,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ
sqlsDataC.add(objectC); sqlsDataC.add(objectC);
sqls.add(SqlMapping.get("kylin_order_ticket_entities.payAgain")); sqls.add(SqlMapping.get("kylin_order_ticket_entities.payAgain"));
LinkedList<Object[]> sqlsDataD = ObjectUtil.cloneLinkedListObj(); LinkedList<Object[]> sqlsDataD = ObjectUtil.cloneLinkedListObj();
Object[] objectD = ObjectUtil.cloneObjectsArray(); Object[] objectD = ObjectUtil.cloneObjectsArray(4);
objectD[0]= orderTickets.getUpdatedAt(); objectD[0]= orderTickets.getUpdatedAt();
objectD[1]= orderTickets.getOrderTicketsId(); objectD[1]= orderTickets.getOrderTicketsId();
objectD[2]= strTime; objectD[2]= strTime;
...@@ -727,6 +727,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ ...@@ -727,6 +727,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ
LocalDateTime now = LocalDateTime.now(); LocalDateTime now = LocalDateTime.now();
String lock = "order_lock:" + syncOrderParam.getOrderCode(); String lock = "order_lock:" + syncOrderParam.getOrderCode();
if (!redisLockUtil.tryLock(lock, 1, 5)) { if (!redisLockUtil.tryLock(lock, 1, 5)) {
log.error("参数错误");
return "fail";//参数错误 return "fail";//参数错误
} }
...@@ -734,23 +735,27 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ ...@@ -734,23 +735,27 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ
KylinOrderTicketVo orderTicketData = mongoTemplate.findOne(Query.query(Criteria.where("orderCode").is(syncOrderParam.getOrderCode())), KylinOrderTicketVo.class, KylinOrderTicketVo.class.getSimpleName()); KylinOrderTicketVo orderTicketData = mongoTemplate.findOne(Query.query(Criteria.where("orderCode").is(syncOrderParam.getOrderCode())), KylinOrderTicketVo.class, KylinOrderTicketVo.class.getSimpleName());
if (orderTicketData == null) { if (orderTicketData == null) {
redisLockUtil.unlock(lock); redisLockUtil.unlock(lock);
log.error("订单不存在");
return "fail";//订单不存在 return "fail";//订单不存在
} }
if (orderTicketData.getStatus() != KylinTableStatusConst.ORDER_STATUS0) { if (orderTicketData.getStatus() != KylinTableStatusConst.ORDER_STATUS0) {
if (orderTicketData.getPayCode().equals(syncOrderParam.getCode()) && orderTicketData.getStatus() == KylinTableStatusConst.ORDER_STATUS1) { if (orderTicketData.getPayCode().equals(syncOrderParam.getCode()) && orderTicketData.getStatus() == KylinTableStatusConst.ORDER_STATUS1) {
redisLockUtil.unlock(lock); redisLockUtil.unlock(lock);
log.error("已经支付");
return "success";//已经支付 return "success";//已经支付
} }
if (!orderTicketData.getPayCode().equals(syncOrderParam.getCode())) { if (!orderTicketData.getPayCode().equals(syncOrderParam.getCode())) {
redisLockUtil.unlock(lock); redisLockUtil.unlock(lock);
log.error("重复支付");
return "fail";//重复支付 return "fail";//重复支付
} }
} }
if (orderTicketData.getPriceActual().compareTo(syncOrderParam.getPrice()) != 0) { if (orderTicketData.getPriceActual().compareTo(syncOrderParam.getPrice()) != 0) {
redisLockUtil.unlock(lock); redisLockUtil.unlock(lock);
log.error("价格不符");
return "fail";//价格不符 return "fail";//价格不符
} }
...@@ -773,6 +778,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ ...@@ -773,6 +778,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ
} else if (orderTicketData.getStatus() == 3 || orderTicketData.getStatus() == 4) { } else if (orderTicketData.getStatus() == 3 || orderTicketData.getStatus() == 4) {
log.error("订单号为 {} 的订单正在退款 或者已退款", syncOrderParam.getOrderCode()); log.error("订单号为 {} 的订单正在退款 或者已退款", syncOrderParam.getOrderCode());
} else { } else {
log.error("订单号为 {} 的订单正常流程", syncOrderParam.getOrderCode());
orderTickets.setOrderTicketsId(orderTicketData.getOrderTicketsId()); orderTickets.setOrderTicketsId(orderTicketData.getOrderTicketsId());
orderTickets.setPaymentType(syncOrderParam.getPaymentType()); orderTickets.setPaymentType(syncOrderParam.getPaymentType());
orderTickets.setPayCode(syncOrderParam.getCode()); orderTickets.setPayCode(syncOrderParam.getCode());
...@@ -791,7 +797,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ ...@@ -791,7 +797,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ
sqlsDataB.add(orderTicketStatus.getSynOrderObject(strTime, strTime)); sqlsDataB.add(orderTicketStatus.getSynOrderObject(strTime, strTime));
sqls.add(SqlMapping.get("kylin_order_ticket_relation.synPay")); sqls.add(SqlMapping.get("kylin_order_ticket_relation.synPay"));
Object[] objectC = ObjectUtil.cloneObjectsArray(); Object[] objectC = ObjectUtil.cloneObjectsArray(4);
objectC[0]= orderTickets.getUpdatedAt(); objectC[0]= orderTickets.getUpdatedAt();
objectC[1]= orderTickets.getOrderTicketsId(); objectC[1]= orderTickets.getOrderTicketsId();
objectC[2]= strTime; objectC[2]= strTime;
...@@ -883,7 +889,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ ...@@ -883,7 +889,7 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsOrderServ
log.info(UserPathDto.setData("订单支付成功回调", syncOrderParam, "")); log.info(UserPathDto.setData("订单支付成功回调", syncOrderParam, ""));
return "success"; return "success";
} catch (Exception e) { } catch (Exception e) {
log.error("SYNCE ORDER E = " + e.getMessage()); log.error("SYNCE ORDER E = " , e);
e.printStackTrace(); e.printStackTrace();
return "fail"; return "fail";
} }
......
liquidnet-bus-service/liquidnet-service-order/liquidnet-service-order-impl/src/main/java/com/liquidnet/service/order/service/impl/KylinRefundsStatusServiceImpl.java
View file @ acf2ddd6
...@@ -102,7 +102,7 @@ public class KylinRefundsStatusServiceImpl { ...@@ -102,7 +102,7 @@ public class KylinRefundsStatusServiceImpl {
LinkedList<Object[]> sqlsDataB = ObjectUtil.cloneLinkedListObj(); LinkedList<Object[]> sqlsDataB = ObjectUtil.cloneLinkedListObj();
for (String v : ticketEntityIds) { for (String v : ticketEntityIds) {
Object[] objectB = ObjectUtil.cloneObjectsArray(); Object[] objectB = ObjectUtil.cloneObjectsArray(5);
objectB[0] = entitiesTable.getIsPayment(); objectB[0] = entitiesTable.getIsPayment();
objectB[1] = entitiesTable.getUpdatedAt(); objectB[1] = entitiesTable.getUpdatedAt();
objectB[2] = v; objectB[2] = v;
...@@ -159,7 +159,7 @@ public class KylinRefundsStatusServiceImpl { ...@@ -159,7 +159,7 @@ public class KylinRefundsStatusServiceImpl {
kylinOrderRefundEntities.setRefundPrice(entitiesPrice.get(i)); kylinOrderRefundEntities.setRefundPrice(entitiesPrice.get(i));
kylinOrderRefundEntities.setOrderTicketEntitiesId(ticketEntityIds.get(i)); kylinOrderRefundEntities.setOrderTicketEntitiesId(ticketEntityIds.get(i));
Object[] objectD = ObjectUtil.cloneObjectsArray(); Object[] objectD = ObjectUtil.cloneObjectsArray(5);
objectD[0] = kylinOrderRefundEntities.getOrderRefundsEntitiesId(); objectD[0] = kylinOrderRefundEntities.getOrderRefundsEntitiesId();
objectD[1] = kylinOrderRefundEntities.getOrderRefundsId(); objectD[1] = kylinOrderRefundEntities.getOrderRefundsId();
objectD[2] = kylinOrderRefundEntities.getRefundPrice(); objectD[2] = kylinOrderRefundEntities.getRefundPrice();
...@@ -184,7 +184,7 @@ public class KylinRefundsStatusServiceImpl { ...@@ -184,7 +184,7 @@ public class KylinRefundsStatusServiceImpl {
sqls.add(SqlMapping.get("kylin_order_refund_entities.overtimeRefund")); sqls.add(SqlMapping.get("kylin_order_refund_entities.overtimeRefund"));
sqls.add(SqlMapping.get("kylin_order_tickets.overtimeRefund")); sqls.add(SqlMapping.get("kylin_order_tickets.overtimeRefund"));
Object[] objectE = ObjectUtil.cloneObjectsArray(); Object[] objectE = ObjectUtil.cloneObjectsArray(5);
objectE[0] = paymentId; objectE[0] = paymentId;
objectE[1] = orderStatusTable.getUpdatedAt(); objectE[1] = orderStatusTable.getUpdatedAt();
objectE[2] = orderInfo.getOrderTicketsId(); objectE[2] = orderInfo.getOrderTicketsId();
...@@ -192,7 +192,7 @@ public class KylinRefundsStatusServiceImpl { ...@@ -192,7 +192,7 @@ public class KylinRefundsStatusServiceImpl {
objectE[4] = orderInfo.getChangeDate(); objectE[4] = orderInfo.getChangeDate();
sqlsDataE.add(objectE); sqlsDataE.add(objectE);
Object[] objectA = ObjectUtil.cloneObjectsArray(); Object[] objectA = ObjectUtil.cloneObjectsArray(5);
objectA[0] = orderStatusTable.getStatus(); objectA[0] = orderStatusTable.getStatus();
objectA[1] = orderStatusTable.getUpdatedAt(); objectA[1] = orderStatusTable.getUpdatedAt();
objectA[2] = orderInfo.getOrderTicketsId(); objectA[2] = orderInfo.getOrderTicketsId();
...@@ -200,7 +200,7 @@ public class KylinRefundsStatusServiceImpl { ...@@ -200,7 +200,7 @@ public class KylinRefundsStatusServiceImpl {
objectA[4] = orderInfo.getChangeDate(); objectA[4] = orderInfo.getChangeDate();
sqlsDataA.add(objectA); sqlsDataA.add(objectA);
Object[] objectC = ObjectUtil.cloneObjectsArray(); Object[] objectC = ObjectUtil.cloneObjectsArray(13);
objectC[0] = kylinOrderRefunds.getOrderRefundsId(); objectC[0] = kylinOrderRefunds.getOrderRefundsId();
objectC[1] = kylinOrderRefunds.getOrderTicketsId(); objectC[1] = kylinOrderRefunds.getOrderTicketsId();
objectC[2] = kylinOrderRefunds.getOrderRefundCode(); objectC[2] = kylinOrderRefunds.getOrderRefundCode();
......
liquidnet-bus-service/liquidnet-service-order/liquidnet-service-order-impl/src/main/java/com/liquidnet/service/order/utils/ObjectUtil.java
View file @ acf2ddd6
...@@ -33,7 +33,7 @@ public class ObjectUtil { ...@@ -33,7 +33,7 @@ public class ObjectUtil {
private static final LinkedMultiValueMap<String, String> linkedMultiValueMapStringAndString = new LinkedMultiValueMap<String, String>(); private static final LinkedMultiValueMap<String, String> linkedMultiValueMapStringAndString = new LinkedMultiValueMap<String, String>();
private static final BasicDBObject basicDBObject = new BasicDBObject(); private static final BasicDBObject basicDBObject = new BasicDBObject();
public static final Object[] objectsArray = new Object[100]; public static Object[] objectsArray;
public static final Integer[] integerArray2 = new Integer[2]; public static final Integer[] integerArray2 = new Integer[2];
public static LinkedList<Object[]> cloneLinkedListObj() { public static LinkedList<Object[]> cloneLinkedListObj() {
...@@ -72,8 +72,9 @@ public class ObjectUtil { ...@@ -72,8 +72,9 @@ public class ObjectUtil {
return linkedMultiValueMapStringAndString.clone(); return linkedMultiValueMapStringAndString.clone();
} }
public static Object[] cloneObjectsArray() { public static Object[] cloneObjectsArray(int size) {
return objectsArray.clone(); objectsArray = new Object[size];
return objectsArray;
} }
public static Integer[] cloneInteger2Array() { public static Integer[] cloneInteger2Array() {
......
liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/partner/KylinBuyNoticePartnerServiceImpl.java
View file @ acf2ddd6
package com.liquidnet.service.platform.service.impl.partner; package com.liquidnet.service.platform.service.impl.partner;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; 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.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo; import com.github.pagehelper.PageInfo;
...@@ -34,11 +35,11 @@ public class KylinBuyNoticePartnerServiceImpl extends ServiceImpl<KylinBuyNotice ...@@ -34,11 +35,11 @@ public class KylinBuyNoticePartnerServiceImpl extends ServiceImpl<KylinBuyNotice
PageInfo<KylinBuyNoticeVo> pageInfoTmp = null; PageInfo<KylinBuyNoticeVo> pageInfoTmp = null;
PageHelper.startPage(1, 20); 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<>(); List<KylinBuyNoticeVo> kylinBuyNoticeVoList = new ArrayList<>();
for (KylinBuyNotice item : buyNoticeList) { for (KylinBuyNotice item : buyNoticeList) {
KylinBuyNoticeVo kylinBuyNoticeVo = new KylinBuyNoticeVo(); KylinBuyNoticeVo kylinBuyNoticeVo = KylinBuyNoticeVo.getNew();
BeanUtils.copyProperties(item, kylinBuyNoticeVo); BeanUtils.copyProperties(item, kylinBuyNoticeVo);
kylinBuyNoticeVoList.add(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
View file @ acf2ddd6
package com.liquidnet.service.platform.service.impl.partner; 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.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo; import com.github.pagehelper.PageInfo;
...@@ -14,6 +16,7 @@ import com.liquidnet.service.kylin.entity.KylinCheckUser; ...@@ -14,6 +16,7 @@ import com.liquidnet.service.kylin.entity.KylinCheckUser;
import com.liquidnet.service.kylin.mapper.KylinCheckUserMapper; import com.liquidnet.service.kylin.mapper.KylinCheckUserMapper;
import com.liquidnet.service.kylin.service.partner.IKylinCheckUserPartnerService; import com.liquidnet.service.kylin.service.partner.IKylinCheckUserPartnerService;
import com.liquidnet.service.platform.utils.DataUtils; import com.liquidnet.service.platform.utils.DataUtils;
import com.liquidnet.service.platform.utils.ObjectUtil;
import com.mongodb.BasicDBObject; import com.mongodb.BasicDBObject;
import org.springframework.beans.BeanUtils; import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
...@@ -64,18 +67,14 @@ public class KylinCheckUserPartnerServiceImpl extends ServiceImpl<KylinCheckUser ...@@ -64,18 +67,14 @@ public class KylinCheckUserPartnerServiceImpl extends ServiceImpl<KylinCheckUser
@Override @Override
public ResponseDto<String> del(String merchantId, String checkUserId) { public ResponseDto<String> del(String merchantId, String checkUserId) {
try { try {
KylinCheckUser checkUser = new KylinCheckUser(); KylinCheckUser checkUser = KylinCheckUser.getNew();
checkUser.setUpdatedAt(LocalDateTime.now()); checkUser.setUpdatedAt(LocalDateTime.now());
checkUser.setStatus(0); 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); dataUtils.delCheckUserRedis(checkUserId);
HashMap<String, Object> map = new HashMap<>(); HashMap<String, Object> map = ObjectUtil.cloneHashMapStringAndObject();
map.put("status", 0); 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()); mongoTemplate.remove(Query.query(Criteria.where("checkUserId").is(checkUserId)), KylinCheckUserVo.class, KylinCheckUserVo.class.getSimpleName());
return ResponseDto.success("删除成功"); return ResponseDto.success("删除成功");
} catch (Exception e) { } catch (Exception e) {
...@@ -86,7 +85,7 @@ public class KylinCheckUserPartnerServiceImpl extends ServiceImpl<KylinCheckUser ...@@ -86,7 +85,7 @@ public class KylinCheckUserPartnerServiceImpl extends ServiceImpl<KylinCheckUser
@Override @Override
public ResponseDto<String> create(String merchantId, String name, String pwd, String mobile) { public ResponseDto<String> create(String merchantId, String name, String pwd, String mobile) {
try { try {
KylinCheckUser checkUser = new KylinCheckUser(); KylinCheckUser checkUser = KylinCheckUser.getNew();
checkUser.setName(name); checkUser.setName(name);
checkUser.setPwd(DigestUtils.md5DigestAsHex(pwd.getBytes())); checkUser.setPwd(DigestUtils.md5DigestAsHex(pwd.getBytes()));
checkUser.setMobile(mobile); checkUser.setMobile(mobile);
...@@ -96,7 +95,7 @@ public class KylinCheckUserPartnerServiceImpl extends ServiceImpl<KylinCheckUser ...@@ -96,7 +95,7 @@ public class KylinCheckUserPartnerServiceImpl extends ServiceImpl<KylinCheckUser
checkUser.setStatus(1); checkUser.setStatus(1);
checkUserMapper.insert(checkUser); checkUserMapper.insert(checkUser);
KylinCheckUserVo kylinCheckUserVo = new KylinCheckUserVo(); KylinCheckUserVo kylinCheckUserVo = KylinCheckUserVo.getNew();
BeanUtils.copyProperties(checkUser, kylinCheckUserVo); BeanUtils.copyProperties(checkUser, kylinCheckUserVo);
mongoTemplate.insert(kylinCheckUserVo, KylinCheckUserVo.class.getSimpleName()); mongoTemplate.insert(kylinCheckUserVo, KylinCheckUserVo.class.getSimpleName());
...@@ -109,15 +108,15 @@ public class KylinCheckUserPartnerServiceImpl extends ServiceImpl<KylinCheckUser ...@@ -109,15 +108,15 @@ public class KylinCheckUserPartnerServiceImpl extends ServiceImpl<KylinCheckUser
@Override @Override
public ResponseDto<String> change(String merchantId, String checkUserId, String name, String pwd, String mobile) { public ResponseDto<String> change(String merchantId, String checkUserId, String name, String pwd, String mobile) {
try { try {
KylinCheckUser checkUser = new KylinCheckUser(); KylinCheckUser checkUser = KylinCheckUser.getNew();
checkUser.setName(name); checkUser.setName(name);
if(null!=pwd) { if (null != pwd) {
checkUser.setPwd(DigestUtils.md5DigestAsHex(pwd.getBytes())); checkUser.setPwd(DigestUtils.md5DigestAsHex(pwd.getBytes()));
} }
checkUser.setMobile(mobile); checkUser.setMobile(mobile);
checkUser.setUpdatedAt(LocalDateTime.now()); checkUser.setUpdatedAt(LocalDateTime.now());
checkUserMapper.update(checkUser, new UpdateWrapper<KylinCheckUser>().eq("check_user_id", checkUserId).eq("merchant_id", merchantId)); checkUserMapper.update(checkUser, Wrappers.lambdaUpdate(KylinCheckUser.class).eq(KylinCheckUser::getCheckUserId, checkUserId).eq(KylinCheckUser::getMerchantId, merchantId));
BasicDBObject obj = new BasicDBObject("$set", mongoConverter.convertToMongoType(checkUser)); BasicDBObject obj = ObjectUtil.cloneBasicDBObject().append("$set", mongoConverter.convertToMongoType(checkUser));
mongoTemplate.getCollection(KylinCheckUserVo.class.getSimpleName()).updateOne( mongoTemplate.getCollection(KylinCheckUserVo.class.getSimpleName()).updateOne(
Query.query(Criteria.where("checkUserId").is(checkUserId)).getQueryObject(), Query.query(Criteria.where("checkUserId").is(checkUserId)).getQueryObject(),
obj obj
......
liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/partner/KylinCheckUserPerformancesPartnerServiceImpl.java
View file @ acf2ddd6
package com.liquidnet.service.platform.service.impl.partner; package com.liquidnet.service.platform.service.impl.partner;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; 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.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo; import com.github.pagehelper.PageInfo;
...@@ -79,7 +80,7 @@ public class KylinCheckUserPerformancesPartnerServiceImpl extends ServiceImpl<Ky ...@@ -79,7 +80,7 @@ public class KylinCheckUserPerformancesPartnerServiceImpl extends ServiceImpl<Ky
if (null == item.getCanDownTime()) { if (null == item.getCanDownTime()) {
return ResponseDto.failure(ErrorMapping.get(20101)); return ResponseDto.failure(ErrorMapping.get(20101));
} }
KylinCheckUserPerformances checkUserPerformances = new KylinCheckUserPerformances(); KylinCheckUserPerformances checkUserPerformances = KylinCheckUserPerformances.getNew();
checkUserPerformances.setCheckUserId(param.getCheckUserId()); checkUserPerformances.setCheckUserId(param.getCheckUserId());
checkUserPerformances.setCanDownTime(DateUtil.Formatter.yyyyMMddHHmmss.parse(item.getCanDownTime())); checkUserPerformances.setCanDownTime(DateUtil.Formatter.yyyyMMddHHmmss.parse(item.getCanDownTime()));
checkUserPerformances.setPerformanceId(item.getPerformanceId()); checkUserPerformances.setPerformanceId(item.getPerformanceId());
...@@ -90,11 +91,11 @@ public class KylinCheckUserPerformancesPartnerServiceImpl extends ServiceImpl<Ky ...@@ -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()); 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<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) { 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.setCanDownTime(item.getCanDownTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
performanceRelationParam.setPerformanceId(item.getPerformanceId()); performanceRelationParam.setPerformanceId(item.getPerformanceId());
performanceRelationParamsList.add(performanceRelationParam); performanceRelationParamsList.add(performanceRelationParam);
...@@ -115,15 +116,15 @@ public class KylinCheckUserPerformancesPartnerServiceImpl extends ServiceImpl<Ky ...@@ -115,15 +116,15 @@ public class KylinCheckUserPerformancesPartnerServiceImpl extends ServiceImpl<Ky
public ResponseDto<String> delPerformance(List<String> performanceIds, String checkUserId) { public ResponseDto<String> delPerformance(List<String> performanceIds, String checkUserId) {
try { try {
for (String performanceId : performanceIds) { 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()); 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<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) { 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.setCanDownTime(item.getCanDownTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
performanceRelationParam.setPerformanceId(item.getPerformanceId()); performanceRelationParam.setPerformanceId(item.getPerformanceId());
performanceRelationParamsList.add(performanceRelationParam); 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
View file @ acf2ddd6
package com.liquidnet.service.platform.service.impl.partner; package com.liquidnet.service.platform.service.impl.partner;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; 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.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo; import com.github.pagehelper.PageInfo;
...@@ -23,6 +24,7 @@ import com.liquidnet.service.kylin.entity.*; ...@@ -23,6 +24,7 @@ import com.liquidnet.service.kylin.entity.*;
import com.liquidnet.service.kylin.mapper.*; import com.liquidnet.service.kylin.mapper.*;
import com.liquidnet.service.kylin.service.partner.IKylinPerformancesPartnerService; import com.liquidnet.service.kylin.service.partner.IKylinPerformancesPartnerService;
import com.liquidnet.service.platform.utils.DataUtils; import com.liquidnet.service.platform.utils.DataUtils;
import com.liquidnet.service.platform.utils.ObjectUtil;
import com.liquidnet.service.platform.utils.PerformanceVoTask; import com.liquidnet.service.platform.utils.PerformanceVoTask;
import com.mongodb.BasicDBObject; import com.mongodb.BasicDBObject;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
...@@ -126,7 +128,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor ...@@ -126,7 +128,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
try { try {
step1Param.setPerformancesId(performanceId); step1Param.setPerformancesId(performanceId);
PerformancePartnerVo performancePartnerVo = new PerformancePartnerVo(); PerformancePartnerVo performancePartnerVo = PerformancePartnerVo.getNew();
BeanUtils.copyProperties(step1Param, performancePartnerVo); BeanUtils.copyProperties(step1Param, performancePartnerVo);
performancePartnerVo.setIsTrueName(0); performancePartnerVo.setIsTrueName(0);
performancePartnerVo.setLimitCount(0); performancePartnerVo.setLimitCount(0);
...@@ -164,7 +166,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor ...@@ -164,7 +166,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
} }
step1Param.setPerformancesId(performanceId); step1Param.setPerformancesId(performanceId);
PerformancePartnerVo performancePartnerVo = new PerformancePartnerVo(); PerformancePartnerVo performancePartnerVo = PerformancePartnerVo.getNew();
BeanUtils.copyProperties(step1Param, performancePartnerVo); BeanUtils.copyProperties(step1Param, performancePartnerVo);
performancePartnerVo.setCreatedAt(timeNow.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"))); performancePartnerVo.setCreatedAt(timeNow.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
performancePartnerVo.setUpdatedAt(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 ...@@ -179,14 +181,14 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
performancePartnerVo.setStatusSell(data.getStatusSell()); performancePartnerVo.setStatusSell(data.getStatusSell());
performancePartnerVo.setRoadShowId(data.getRoadShowId()); performancePartnerVo.setRoadShowId(data.getRoadShowId());
performancePartnerVo.setProjectId(data.getProjectId()); 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( mongoTemplate.getCollection(PerformancePartnerVo.class.getSimpleName()).updateOne(
Query.query(Criteria.where("performancesId").is(performanceId)).getQueryObject(), Query.query(Criteria.where("performancesId").is(performanceId)).getQueryObject(),
object object
); );
} else { // 无修改记录 } else { // 无修改记录
KylinPerformanceStatus statusData = performanceStatusMapper.selectOne(new UpdateWrapper<KylinPerformanceStatus>().eq("performanceId", performanceId)); KylinPerformanceStatus statusData = performanceStatusMapper.selectOne(Wrappers.lambdaQuery(KylinPerformanceStatus.class).eq(KylinPerformanceStatus::getPerformanceId, performanceId));
KylinPerformanceRelations relationsData = performanceRelationsMapper.selectOne(new UpdateWrapper<KylinPerformanceRelations>().eq("performancesId", performanceId)); KylinPerformanceRelations relationsData = performanceRelationsMapper.selectOne(Wrappers.lambdaQuery(KylinPerformanceRelations.class).eq(KylinPerformanceRelations::getPerformanceId, performanceId));
performancePartnerVo.setIsTrueName(statusData.getIsTrueName()); performancePartnerVo.setIsTrueName(statusData.getIsTrueName());
performancePartnerVo.setLimitCount(statusData.getLimitCount()); performancePartnerVo.setLimitCount(statusData.getLimitCount());
performancePartnerVo.setStatusSell(statusData.getStatusSell()); performancePartnerVo.setStatusSell(statusData.getStatusSell());
...@@ -208,11 +210,11 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor ...@@ -208,11 +210,11 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
PerformancePartnerVo data = mongoTemplate.findOne( PerformancePartnerVo data = mongoTemplate.findOne(
Query.query(Criteria.where("performancesId").is(performancesId)), PerformancePartnerVo.class, PerformancePartnerVo.class.getSimpleName() 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) { if (data == null) {
return ResponseDto.failure(ErrorMapping.get(20104)); return ResponseDto.failure(ErrorMapping.get(20104));
} }
if(null!=performanceStatus) { if (null != performanceStatus) {
data.setStatus(performanceStatus.getStatus()); data.setStatus(performanceStatus.getStatus());
} }
return ResponseDto.success(data); return ResponseDto.success(data);
...@@ -224,12 +226,12 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor ...@@ -224,12 +226,12 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
// 无 performancesId 则 创建 // 无 performancesId 则 创建
if (step2Param.getPerformancesId().isEmpty()) { if (step2Param.getPerformancesId().isEmpty()) {
} else { // 获取 create 数据 status = 0 或 无数据 创建 } 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) { if (performanceStatus == null || performanceStatus.getStatus() == 0 || performanceStatus.getStatus() == 4) {
result = createStep2(step2Param); 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); result = updateStep2(step2Param);
}else if(performanceStatus.getStatus() == 10){ } else if (performanceStatus.getStatus() == 10) {
result = ResponseDto.failure("演出已结束不可修改"); result = ResponseDto.failure("演出已结束不可修改");
} }
} }
...@@ -253,7 +255,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor ...@@ -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("isTrueName", step2Param.getIsTrueName());
map.put("limitCount", step2Param.getLimitCount()); map.put("limitCount", step2Param.getLimitCount());
map.put("createdAt", createdAt.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"))); map.put("createdAt", createdAt.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
...@@ -265,7 +267,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor ...@@ -265,7 +267,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
map.put("status", 1); map.put("status", 1);
map.put("isCreateSave", 0); map.put("isCreateSave", 0);
map.put("auditStatus", 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( mongoTemplate.getCollection(PerformancePartnerVo.class.getSimpleName()).updateOne(
Query.query(Criteria.where("performancesId").is(performanceId)).getQueryObject(), Query.query(Criteria.where("performancesId").is(performanceId)).getQueryObject(),
object object
...@@ -283,22 +285,22 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor ...@@ -283,22 +285,22 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
} else { } else {
KylinPerformanceMisVo kylinPerformanceMisVo = performanceVoTask.getPerformanceMisVo(performanceId); KylinPerformanceMisVo kylinPerformanceMisVo = performanceVoTask.getPerformanceMisVo(performanceId);
HashMap<String, Object> mapSql = new HashMap<>(); HashMap<String, Object> mapSql = ObjectUtil.cloneHashMapStringAndObject();
mapSql.put("isCreateSave", 0); mapSql.put("isCreateSave", 0);
mapSql.put("rejectTxt", ""); mapSql.put("rejectTxt", "");
mapSql.put("status", 1); mapSql.put("status", 1);
mapSql.put("updatedAt", createdAt.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"))); mapSql.put("updatedAt", createdAt.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
performanceVoTask.createPerformanceMySql(performanceId, mapSql, kylinPerformanceMisVo, createdAt); performanceVoTask.createPerformanceMySql(performanceId, mapSql, kylinPerformanceMisVo, createdAt);
KylinPerformances performances = new KylinPerformances(); KylinPerformances performances = KylinPerformances.getNew();
performances.setAuditTime(LocalDateTime.now()); 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("操作成功"); return ResponseDto.success("操作成功");
} else { //保存 } else { //保存
map.put("status", 0); map.put("status", 0);
map.put("isCreateSave", 1); map.put("isCreateSave", 1);
map.put("auditStatus", -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( mongoTemplate.getCollection(PerformancePartnerVo.class.getSimpleName()).updateMany(
Query.query(Criteria.where("performancesId").is(performanceId)).getQueryObject(), Query.query(Criteria.where("performancesId").is(performanceId)).getQueryObject(),
object object
...@@ -328,7 +330,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor ...@@ -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("isTrueName", step2Param.getIsTrueName());
map.put("limitCount", step2Param.getLimitCount()); map.put("limitCount", step2Param.getLimitCount());
map.put("createdAt", createdAt.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"))); map.put("createdAt", createdAt.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
...@@ -344,7 +346,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor ...@@ -344,7 +346,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
map.put("auditStatus", 1); map.put("auditStatus", 1);
map.put("status", 9); 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( mongoTemplate.getCollection(PerformancePartnerVo.class.getSimpleName()).updateOne(
Query.query(Criteria.where("performancesId").is(performanceId)).getQueryObject(), Query.query(Criteria.where("performancesId").is(performanceId)).getQueryObject(),
object object
...@@ -362,19 +364,19 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor ...@@ -362,19 +364,19 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
} else { } else {
KylinPerformanceMisVo kylinPerformanceMisVo = performanceVoTask.getPerformanceMisVo(performanceId); KylinPerformanceMisVo kylinPerformanceMisVo = performanceVoTask.getPerformanceMisVo(performanceId);
HashMap<String, Object> mapSql = new HashMap<>(); HashMap<String, Object> mapSql = ObjectUtil.cloneHashMapStringAndObject();
mapSql.put("rejectTxt", ""); mapSql.put("rejectTxt", "");
mapSql.put("status", map.get("status")); mapSql.put("status", map.get("status"));
mapSql.put("updatedAt", createdAt.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"))); 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.setAuditTime(LocalDateTime.now());
performances.setNoticeImage(kylinPerformanceMisVo.getNoticeImage()); performances.setNoticeImage(kylinPerformanceMisVo.getNoticeImage());
performancesMapper.update(performances, new UpdateWrapper<KylinPerformances>().eq("performances_id", performanceId)); performancesMapper.update(performances, Wrappers.lambdaQuery(KylinPerformances.class).eq(KylinPerformances::getPerformancesId, performanceId));
KylinPerformanceStatus performanceStatus = new KylinPerformanceStatus(); KylinPerformanceStatus performanceStatus = KylinPerformanceStatus.getNew();
performanceStatus.setAuditStatus((int) map.get("auditStatus")); performanceStatus.setAuditStatus((int) map.get("auditStatus"));
performanceStatus.setIsTrueName(step2Param.getIsTrueName()); performanceStatus.setIsTrueName(step2Param.getIsTrueName());
performanceStatus.setLimitCount(step2Param.getLimitCount()); 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(); List<TicketTimesTicketCreatePartnerVo> timeList = kylinPerformanceMisVo.getTicketTimes();
...@@ -383,7 +385,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor ...@@ -383,7 +385,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
for (KylinTicketPartnerVo ticketItem : ticketList) { for (KylinTicketPartnerVo ticketItem : ticketList) {
//修改 redis库存 //修改 redis库存
if (redisUtil.hasKey(KylinRedisConst.PERFORMANCES_INVENTORY + ticketItem.getTicketsId() + ":" + KylinRedisConst.SURPLUS_GENERAL)) { 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 changeGeneral = ticketItem.getTotalGeneral() - ticketStatus.getTotalGeneral();
int changeExchange = ticketItem.getTotalExchange() - ticketStatus.getTotalExchange(); int changeExchange = ticketItem.getTotalExchange() - ticketStatus.getTotalExchange();
log.debug("ticketItem.getTotalGeneral() = " + ticketItem.getTotalGeneral()); log.debug("ticketItem.getTotalGeneral() = " + ticketItem.getTotalGeneral());
...@@ -392,7 +394,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor ...@@ -392,7 +394,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
dataUtils.changeSurplusExchange(ticketItem.getTicketsId(), changeExchange); dataUtils.changeSurplusExchange(ticketItem.getTicketsId(), changeExchange);
} }
//修改 mysql 库存 //修改 mysql 库存
KylinTicketStatus inventory = new KylinTicketStatus(); KylinTicketStatus inventory = KylinTicketStatus.getNew();
inventory.setTotalExchange(ticketItem.getTotalExchange()); inventory.setTotalExchange(ticketItem.getTotalExchange());
inventory.setTotalGeneral(ticketItem.getTotalGeneral()); inventory.setTotalGeneral(ticketItem.getTotalGeneral());
inventory.setIsTrueName(kylinPerformanceMisVo.getIsTrueName()); inventory.setIsTrueName(kylinPerformanceMisVo.getIsTrueName());
...@@ -405,7 +407,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor ...@@ -405,7 +407,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
inventory.setQrCodeShowTime(DateUtil.Formatter.yyyyMMddHHmmss.parse(ticketItem.getQrCodeShowTime())); inventory.setQrCodeShowTime(DateUtil.Formatter.yyyyMMddHHmmss.parse(ticketItem.getQrCodeShowTime()));
//修改 mysql 售卖时间 //修改 mysql 售卖时间
KylinTickets ticketSellTime = new KylinTickets(); KylinTickets ticketSellTime = KylinTickets.getNew();
ticketSellTime.setTimeEnd(DateUtil.Formatter.yyyyMMddHHmmss.parse(ticketItem.getTimeEnd())); ticketSellTime.setTimeEnd(DateUtil.Formatter.yyyyMMddHHmmss.parse(ticketItem.getTimeEnd()));
ticketSellTime.setTimeStart(DateUtil.Formatter.yyyyMMddHHmmss.parse(ticketItem.getTimeStart())); ticketSellTime.setTimeStart(DateUtil.Formatter.yyyyMMddHHmmss.parse(ticketItem.getTimeStart()));
ticketSellTime.setAdvanceMinuteMember(null); ticketSellTime.setAdvanceMinuteMember(null);
...@@ -414,9 +416,9 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor ...@@ -414,9 +416,9 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
//修改 价格 //修改 价格
ticketSellTime.setPrice(ticketItem.getPrice()); ticketSellTime.setPrice(ticketItem.getPrice());
ticketSellTime.setPriceDiscountMember(null); 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 购票限购 //修改 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); performanceVoTask.performanceVoStatus(performanceId);
...@@ -425,7 +427,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor ...@@ -425,7 +427,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
} else { //保存 } else { //保存
map.put("status", 0); map.put("status", 0);
map.put("auditStatus", -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( mongoTemplate.getCollection(PerformancePartnerVo.class.getSimpleName()).updateMany(
Query.query(Criteria.where("performancesId").is(performanceId)).getQueryObject(), Query.query(Criteria.where("performancesId").is(performanceId)).getQueryObject(),
object object
...@@ -450,19 +452,19 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor ...@@ -450,19 +452,19 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
List<TicketTimesTicketCreatePartnerVo> ticketTimesTicketCreatePartnerVoList = new ArrayList<TicketTimesTicketCreatePartnerVo>(); List<TicketTimesTicketCreatePartnerVo> ticketTimesTicketCreatePartnerVoList = new ArrayList<TicketTimesTicketCreatePartnerVo>();
for (KylinTicketTimesPartnerVo ticketTimes : kylinTicketTimesPartnerVos) { for (KylinTicketTimesPartnerVo ticketTimes : kylinTicketTimesPartnerVos) {
TicketTimesTicketCreatePartnerVo ticketTimesTicketCreatePartnerVo = new TicketTimesTicketCreatePartnerVo(); TicketTimesTicketCreatePartnerVo ticketTimesTicketCreatePartnerVo = TicketTimesTicketCreatePartnerVo.getNew();
BeanUtils.copyProperties(ticketTimes, ticketTimesTicketCreatePartnerVo); BeanUtils.copyProperties(ticketTimes, ticketTimesTicketCreatePartnerVo);
List<KylinTicketPartnerVo> kylinTicketPartnerVos = ticketsPartnerService.getTicketMongoList(ticketTimes.getTicketTimesId()); List<KylinTicketPartnerVo> kylinTicketPartnerVos = ticketsPartnerService.getTicketMongoList(ticketTimes.getTicketTimesId());
ticketTimesTicketCreatePartnerVo.setTicket(kylinTicketPartnerVos); ticketTimesTicketCreatePartnerVo.setTicket(kylinTicketPartnerVos);
ticketTimesTicketCreatePartnerVoList.add(ticketTimesTicketCreatePartnerVo); ticketTimesTicketCreatePartnerVoList.add(ticketTimesTicketCreatePartnerVo);
} }
PerformanceStep2Param performanceStep2Param = new PerformanceStep2Param(); PerformanceStep2Param performanceStep2Param = PerformanceStep2Param.getNew();
BeanUtils.copyProperties(data, performanceStep2Param); BeanUtils.copyProperties(data, performanceStep2Param);
KylinPerformanceStatus performanceStatus = performanceStatusMapper.selectOne(new UpdateWrapper<KylinPerformanceStatus>().eq("performance_id", performancesId)); KylinPerformanceStatus performanceStatus = performanceStatusMapper.selectOne(Wrappers.lambdaQuery(KylinPerformanceStatus.class).eq(KylinPerformanceStatus::getPerformanceId, performancesId));
if(null!=performanceStatus) { if (null != performanceStatus) {
performanceStep2Param.setStatus(performanceStatus.getStatus()); performanceStep2Param.setStatus(performanceStatus.getStatus());
}else{ } else {
performanceStep2Param.setStatus(-1); performanceStep2Param.setStatus(-1);
} }
...@@ -473,41 +475,41 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor ...@@ -473,41 +475,41 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
@Override @Override
public ResponseDto<String> onLinePerformance(String performancesId) { public ResponseDto<String> onLinePerformance(String performancesId) {
try { 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)) { if (!(performanceStatusData.getStatus() == 3 || performanceStatusData.getStatus() == 7)) {
return ResponseDto.failure(ErrorMapping.get(20110)); return ResponseDto.failure(ErrorMapping.get(20110));
} }
// mysql // mysql
LocalDateTime updatedAt = LocalDateTime.now(); LocalDateTime updatedAt = LocalDateTime.now();
KylinPerformanceStatus performanceStatusUpdate = new KylinPerformanceStatus(); KylinPerformanceStatus performanceStatusUpdate = KylinPerformanceStatus.getNew();
performanceStatusUpdate.setStatus(6); performanceStatusUpdate.setStatus(6);
performanceStatusUpdate.setUpdatedAt(updatedAt); performanceStatusUpdate.setUpdatedAt(updatedAt);
performanceStatusMapper.update(performanceStatusUpdate performanceStatusMapper.update(performanceStatusUpdate
, new UpdateWrapper<KylinPerformanceStatus>().eq("performance_id", performancesId)); , Wrappers.lambdaQuery(KylinPerformanceStatus.class).eq(KylinPerformanceStatus::getPerformanceId, performancesId));
//场次 //场次
List<KylinTicketTimeRelation> ticketTimeRelation = ticketTimeRelationMapper.selectList( List<KylinTicketTimeRelation> ticketTimeRelation = ticketTimeRelationMapper.selectList(
new UpdateWrapper<KylinTicketTimeRelation>().eq("performance_id", performancesId) Wrappers.lambdaQuery(KylinTicketTimeRelation.class).eq(KylinTicketTimeRelation::getPerformanceId, performancesId)
); );
for (KylinTicketTimeRelation ticketTimeRelationItem : ticketTimeRelation) { 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) { for (KylinTicketRelations ticketRelationsItem : ticketRelations) {
KylinTicketStatus ticketStatusUpdate = new KylinTicketStatus(); KylinTicketStatus ticketStatusUpdate = KylinTicketStatus.getNew();
ticketStatusUpdate.setStatus(9); ticketStatusUpdate.setStatus(9);
ticketStatusUpdate.setUpdatedAt(updatedAt); ticketStatusUpdate.setUpdatedAt(updatedAt);
ticketStatusMapper.update(ticketStatusUpdate 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("status", 9);
map.put("updatedAt", updatedAt); map.put("updatedAt", updatedAt);
mongoTemplate.getCollection(KylinTicketPartnerVo.class.getSimpleName()).updateOne( mongoTemplate.getCollection(KylinTicketPartnerVo.class.getSimpleName()).updateOne(
Query.query(Criteria.where("ticketsId").is(ticketRelationsItem.getTicketId()).and("status").in(3,6,8,9,10)).getQueryObject(), Query.query(Criteria.where("ticketsId").is(ticketRelationsItem.getTicketId()).and("status").in(3, 6, 8, 9, 10)).getQueryObject(),
new BasicDBObject("$set", mongoConverter.convertToMongoType(map)) ObjectUtil.cloneBasicDBObject().append("$set", mongoConverter.convertToMongoType(map))
); );
} }
} }
...@@ -515,7 +517,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor ...@@ -515,7 +517,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
performanceVoTask.performanceVoStatus(performancesId); performanceVoTask.performanceVoStatus(performancesId);
return ResponseDto.success("上线成功"); return ResponseDto.success("上线成功");
} catch (Exception e) { } catch (Exception e) {
log.debug("上线失败",e); log.debug("上线失败", e);
return ResponseDto.failure(ErrorMapping.get(20108)); return ResponseDto.failure(ErrorMapping.get(20108));
} }
} }
...@@ -523,15 +525,15 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor ...@@ -523,15 +525,15 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
@Override @Override
public ResponseDto<String> outLinePerformance(String performancesId) { public ResponseDto<String> outLinePerformance(String performancesId) {
try { 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) {//未提审||被拒绝 if (performanceStatusData.getStatus() >= 3 && performanceStatusData.getStatus() != 4 && performanceStatusData.getStatus() != 7 && performanceStatusData.getStatus() != 10) {//未提审||被拒绝
LocalDateTime updatedAt = LocalDateTime.now(); LocalDateTime updatedAt = LocalDateTime.now();
KylinPerformanceStatus performanceStatus = new KylinPerformanceStatus(); KylinPerformanceStatus performanceStatus = KylinPerformanceStatus.getNew();
performanceStatus.setStatus(7); performanceStatus.setStatus(7);
performanceStatus.setUpdatedAt(updatedAt); performanceStatus.setUpdatedAt(updatedAt);
performanceStatusMapper.update(performanceStatus performanceStatusMapper.update(performanceStatus
, new UpdateWrapper<KylinPerformanceStatus>().eq("performance_id", performancesId)); , Wrappers.lambdaQuery(KylinPerformanceStatus.class).eq(KylinPerformanceStatus::getPerformanceId, performancesId));
performanceVoTask.performanceVoStatus(performancesId); performanceVoTask.performanceVoStatus(performancesId);
return ResponseDto.success("下线成功"); return ResponseDto.success("下线成功");
...@@ -539,7 +541,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor ...@@ -539,7 +541,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
return ResponseDto.failure(ErrorMapping.get(20111)); return ResponseDto.failure(ErrorMapping.get(20111));
} }
} catch (Exception e) { } catch (Exception e) {
log.debug("下线失败",e); log.debug("下线失败", e);
return ResponseDto.failure(ErrorMapping.get(20109)); return ResponseDto.failure(ErrorMapping.get(20109));
} }
} }
...@@ -559,7 +561,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor ...@@ -559,7 +561,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
for (KylinTicketTimesPartnerVo timeItem : kylinTicketTimesPartnerVos) { for (KylinTicketTimesPartnerVo timeItem : kylinTicketTimesPartnerVos) {
//复制场次 //复制场次
String timesId = timeItem.getTicketTimesId(); String timesId = timeItem.getTicketTimesId();
timeItem.setTicketTimesId(IDGenerator.nextSnowId().toString()); timeItem.setTicketTimesId(IDGenerator.nextSnowId());
timeItem.setPerformancesId(performancePartnerVo.getPerformancesId()); timeItem.setPerformancesId(performancePartnerVo.getPerformancesId());
mongoTemplate.insert(timeItem, KylinTicketTimesPartnerVo.class.getSimpleName()); mongoTemplate.insert(timeItem, KylinTicketTimesPartnerVo.class.getSimpleName());
...@@ -601,7 +603,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor ...@@ -601,7 +603,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
//处理Vo //处理Vo
List<KylinPerformancePartnerListVo> voList = new ArrayList<>(); List<KylinPerformancePartnerListVo> voList = new ArrayList<>();
for (PerformancePartnerVo item : performancePartnerVo) { for (PerformancePartnerVo item : performancePartnerVo) {
KylinPerformancePartnerListVo voData = new KylinPerformancePartnerListVo(); KylinPerformancePartnerListVo voData = KylinPerformancePartnerListVo.getNew();
voData.setStatus0Data(item); voData.setStatus0Data(item);
voList.add(voData); voList.add(voData);
} }
...@@ -636,10 +638,10 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor ...@@ -636,10 +638,10 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
public ResponseDto<String> withdraw(String performancesId) { public ResponseDto<String> withdraw(String performancesId) {
try { try {
//mysql auditStatus //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) { if (performanceStatus != null && performanceStatus.getAuditStatus() == 0) {
KylinPerformanceStatus data1 = new KylinPerformanceStatus(); KylinPerformanceStatus data1 = KylinPerformanceStatus.getNew();
HashMap<String, Object> map = new HashMap<>(); HashMap<String, Object> map = ObjectUtil.cloneHashMapStringAndObject();
if (performanceStatus.getStatus() >= 3) {//通过审核 if (performanceStatus.getStatus() >= 3) {//通过审核
data1.setAuditStatus(1); data1.setAuditStatus(1);
data1.setStatus(null); data1.setStatus(null);
...@@ -654,8 +656,8 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor ...@@ -654,8 +656,8 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
data1.setStatus(null); data1.setStatus(null);
map.put("auditStatus", 2); map.put("auditStatus", 2);
} }
performanceStatusMapper.update(data1, new UpdateWrapper<KylinPerformanceStatus>().eq("performance_id", performancesId)); performanceStatusMapper.update(data1, Wrappers.lambdaQuery(KylinPerformanceStatus.class).eq(KylinPerformanceStatus::getPerformanceId, performancesId));
BasicDBObject object = new BasicDBObject("$set", mongoConverter.convertToMongoType(map)); BasicDBObject object = ObjectUtil.cloneBasicDBObject().append("$set", mongoConverter.convertToMongoType(map));
mongoTemplate.getCollection(PerformancePartnerVo.class.getSimpleName()).updateOne( mongoTemplate.getCollection(PerformancePartnerVo.class.getSimpleName()).updateOne(
Query.query(Criteria.where("performancesId").is(performancesId)).getQueryObject(), Query.query(Criteria.where("performancesId").is(performancesId)).getQueryObject(),
object object
...@@ -672,13 +674,13 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor ...@@ -672,13 +674,13 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
@Override @Override
public List<PerformanceOrderStatisticalVo> getPerformanceOrderStatisticalList(String performancesId) { public List<PerformanceOrderStatisticalVo> getPerformanceOrderStatisticalList(String performancesId) {
PerformanceOrderStatisticalDao countBean = new PerformanceOrderStatisticalDao(); PerformanceOrderStatisticalDao countBean = PerformanceOrderStatisticalDao.getNew();
countBean.setTitle("总计："); countBean.setTitle("总计：");
List<PerformanceOrderStatisticalVo> voList = new ArrayList<>(); List<PerformanceOrderStatisticalVo> voList = new ArrayList<>();
List<PerformanceOrderStatisticalDao> dtoList = performancesMapper.getPerformanceOrderStatisticalList(performancesId); List<PerformanceOrderStatisticalDao> dtoList = performancesMapper.getPerformanceOrderStatisticalList(performancesId);
dtoList.forEach(dto -> { dtoList.forEach(dto -> {
PerformanceOrderStatisticalVo vo = new PerformanceOrderStatisticalVo(); PerformanceOrderStatisticalVo vo = PerformanceOrderStatisticalVo.getNew();
BeanUtil.copy(dto, vo); BeanUtil.copy(dto, vo);
voList.add(vo); voList.add(vo);
...@@ -693,7 +695,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor ...@@ -693,7 +695,7 @@ public class KylinPerformancesPartnerServiceImpl extends ServiceImpl<KylinPerfor
countBean.setTotalPayingNumber(countBean.getTotalPayingNumber().add(dto.getTotalPayingNumber())); countBean.setTotalPayingNumber(countBean.getTotalPayingNumber().add(dto.getTotalPayingNumber()));
countBean.setTotalBuyUsers(dto.getTotalBuyUsers()); countBean.setTotalBuyUsers(dto.getTotalBuyUsers());
}); });
PerformanceOrderStatisticalVo vo = new PerformanceOrderStatisticalVo(); PerformanceOrderStatisticalVo vo = PerformanceOrderStatisticalVo.getNew();
BeanUtil.copy(countBean, vo); BeanUtil.copy(countBean, vo);
voList.add(vo); voList.add(vo);
return voList; return voList;
......
liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/partner/KylinTicketTimesPartnerServiceImpl.java
View file @ acf2ddd6
...@@ -2,6 +2,7 @@ package com.liquidnet.service.platform.service.impl.partner; ...@@ -2,6 +2,7 @@ package com.liquidnet.service.platform.service.impl.partner;
import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; 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.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.liquidnet.commons.lang.util.IDGenerator; import com.liquidnet.commons.lang.util.IDGenerator;
import com.liquidnet.commons.lang.util.JsonUtils; import com.liquidnet.commons.lang.util.JsonUtils;
...@@ -16,6 +17,7 @@ import com.liquidnet.service.kylin.mapper.KylinPerformanceStatusMapper; ...@@ -16,6 +17,7 @@ import com.liquidnet.service.kylin.mapper.KylinPerformanceStatusMapper;
import com.liquidnet.service.kylin.mapper.KylinTicketTimeRelationMapper; import com.liquidnet.service.kylin.mapper.KylinTicketTimeRelationMapper;
import com.liquidnet.service.kylin.mapper.KylinTicketTimesMapper; import com.liquidnet.service.kylin.mapper.KylinTicketTimesMapper;
import com.liquidnet.service.kylin.service.partner.IKylinTicketTimesPartnerService; import com.liquidnet.service.kylin.service.partner.IKylinTicketTimesPartnerService;
import com.liquidnet.service.platform.utils.ObjectUtil;
import com.mongodb.BasicDBObject; import com.mongodb.BasicDBObject;
import com.mongodb.client.model.FindOneAndUpdateOptions; import com.mongodb.client.model.FindOneAndUpdateOptions;
import com.mongodb.client.model.ReturnDocument; import com.mongodb.client.model.ReturnDocument;
...@@ -63,7 +65,7 @@ public class KylinTicketTimesPartnerServiceImpl extends ServiceImpl<KylinTicketT ...@@ -63,7 +65,7 @@ public class KylinTicketTimesPartnerServiceImpl extends ServiceImpl<KylinTicketT
ResponseDto<KylinTicketTimesPartnerVo> ticketTimesPartnerVo = null; ResponseDto<KylinTicketTimesPartnerVo> ticketTimesPartnerVo = null;
//获取演出状态 //获取演出状态
KylinPerformanceStatus performanceStatus = performanceStatusMapper.selectOne( KylinPerformanceStatus performanceStatus = performanceStatusMapper.selectOne(
new UpdateWrapper<KylinPerformanceStatus>().eq("performance_id", createTicketTimesParam.getPerformancesId())); Wrappers.lambdaQuery(KylinPerformanceStatus.class).eq(KylinPerformanceStatus::getPerformanceId, createTicketTimesParam.getPerformancesId()));
if (null == performanceStatus) { if (null == performanceStatus) {
ticketTimesPartnerVo = createTimes(createTicketTimesParam); ticketTimesPartnerVo = createTimes(createTicketTimesParam);
} else if(performanceStatus.getAuditStatus()==0){ } else if(performanceStatus.getAuditStatus()==0){
...@@ -80,7 +82,7 @@ public class KylinTicketTimesPartnerServiceImpl extends ServiceImpl<KylinTicketT ...@@ -80,7 +82,7 @@ public class KylinTicketTimesPartnerServiceImpl extends ServiceImpl<KylinTicketT
public ResponseDto<KylinTicketTimesPartnerVo> createTimes(CreateTicketTimesParam createTicketTimesParam) { public ResponseDto<KylinTicketTimesPartnerVo> createTimes(CreateTicketTimesParam createTicketTimesParam) {
try { try {
// 获取 主键id // 获取 主键id
String ticketTimesId = IDGenerator.nextSnowId().toString(); String ticketTimesId = IDGenerator.nextSnowId();
// 获取 当前时间 -> 创建时间 // 获取 当前时间 -> 创建时间
LocalDateTime createdAt = LocalDateTime.now(); LocalDateTime createdAt = LocalDateTime.now();
// 标题 // 标题
...@@ -97,7 +99,7 @@ public class KylinTicketTimesPartnerServiceImpl extends ServiceImpl<KylinTicketT ...@@ -97,7 +99,7 @@ public class KylinTicketTimesPartnerServiceImpl extends ServiceImpl<KylinTicketT
title = useStart + "-" + useEnd; title = useStart + "-" + useEnd;
} }
// mongo 操作 // mongo 操作
KylinTicketTimesPartnerVo kylinTicketTimesPartnerVo = new KylinTicketTimesPartnerVo(); KylinTicketTimesPartnerVo kylinTicketTimesPartnerVo = KylinTicketTimesPartnerVo.getNew();
kylinTicketTimesPartnerVo.setTicketTimesId(ticketTimesId); kylinTicketTimesPartnerVo.setTicketTimesId(ticketTimesId);
kylinTicketTimesPartnerVo.setUseStart(createTicketTimesParam.getUseStart().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"))); kylinTicketTimesPartnerVo.setUseStart(createTicketTimesParam.getUseStart().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
if(createTicketTimesParam.getType() == 2) { if(createTicketTimesParam.getType() == 2) {
...@@ -141,7 +143,7 @@ public class KylinTicketTimesPartnerServiceImpl extends ServiceImpl<KylinTicketT ...@@ -141,7 +143,7 @@ public class KylinTicketTimesPartnerServiceImpl extends ServiceImpl<KylinTicketT
} }
// mongo 操作 // mongo 操作
KylinTicketTimesPartnerVo kylinTicketTimesPartnerVo = new KylinTicketTimesPartnerVo(); KylinTicketTimesPartnerVo kylinTicketTimesPartnerVo = KylinTicketTimesPartnerVo.getNew();
kylinTicketTimesPartnerVo.setTicketTimesId(ticketTimesId); kylinTicketTimesPartnerVo.setTicketTimesId(ticketTimesId);
kylinTicketTimesPartnerVo.setUseStart(createTicketTimesParam.getUseStart().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"))); 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"))); kylinTicketTimesPartnerVo.setUseEnd(createTicketTimesParam.getUseEnd().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
...@@ -169,24 +171,23 @@ public class KylinTicketTimesPartnerServiceImpl extends ServiceImpl<KylinTicketT ...@@ -169,24 +171,23 @@ public class KylinTicketTimesPartnerServiceImpl extends ServiceImpl<KylinTicketT
return ResponseDto.failure(ErrorMapping.get(20106)); return ResponseDto.failure(ErrorMapping.get(20106));
} }
KylinTicketTimeRelation ticketTimeRelation = ticketTimeRelationMapper.selectOne( KylinTicketTimeRelation ticketTimeRelation = ticketTimeRelationMapper.selectOne(
new UpdateWrapper<KylinTicketTimeRelation>().eq("times_id", ticketTimesId)); Wrappers.lambdaQuery(KylinTicketTimeRelation.class).eq(KylinTicketTimeRelation::getTimesId, ticketTimesId));
if (ticketTimeRelation != null) { if (ticketTimeRelation != null) {
KylinPerformanceStatus performanceStatus = performanceStatusMapper.selectOne( 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){ if(performanceStatus.getAuditStatus()==0){
return ResponseDto.failure(ErrorMapping.get(20101)); return ResponseDto.failure(ErrorMapping.get(20101));
} }
if (performanceStatus.getStatus() == 0 || performanceStatus.getStatus() == 4) {//未提审||被拒绝 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("updatedAt", updatedAt.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
map.put("status", 0); map.put("status", 0);
BasicDBObject object = new BasicDBObject("$set", mongoConverter.convertToMongoType(map)); BasicDBObject object = ObjectUtil.cloneBasicDBObject().append("$set", mongoConverter.convertToMongoType(map));
Document doc = mongoTemplate.getCollection(KylinTicketTimesPartnerVo.class.getSimpleName()).findOneAndUpdate( mongoTemplate.getCollection(KylinTicketTimesPartnerVo.class.getSimpleName()).updateOne(
Query.query(Criteria.where("ticketTimesId").is(ticketTimesId)).getQueryObject(), Query.query(Criteria.where("ticketTimesId").is(ticketTimesId)).getQueryObject(),
object, object
new FindOneAndUpdateOptions().returnDocument(ReturnDocument.AFTER)
); );
return ResponseDto.success("删除成功"); return ResponseDto.success("删除成功");
} else { } else {
...@@ -214,7 +215,7 @@ public class KylinTicketTimesPartnerServiceImpl extends ServiceImpl<KylinTicketT ...@@ -214,7 +215,7 @@ public class KylinTicketTimesPartnerServiceImpl extends ServiceImpl<KylinTicketT
createTicketTimesParam.setTitle(title); createTicketTimesParam.setTitle(title);
// mongo 操作 // mongo 操作
KylinTicketTimesPartnerVo kylinTicketTimesPartnerVo = new KylinTicketTimesPartnerVo(); KylinTicketTimesPartnerVo kylinTicketTimesPartnerVo = KylinTicketTimesPartnerVo.getNew();
BeanUtils.copyProperties(createTicketTimesParam, kylinTicketTimesPartnerVo); BeanUtils.copyProperties(createTicketTimesParam, kylinTicketTimesPartnerVo);
kylinTicketTimesPartnerVo.setTicketTimesId(createTicketTimesParam.getTicketTimesId()); kylinTicketTimesPartnerVo.setTicketTimesId(createTicketTimesParam.getTicketTimesId());
kylinTicketTimesPartnerVo.setUpdatedAt(updatedAt.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"))); kylinTicketTimesPartnerVo.setUpdatedAt(updatedAt.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
...@@ -222,7 +223,7 @@ public class KylinTicketTimesPartnerServiceImpl extends ServiceImpl<KylinTicketT ...@@ -222,7 +223,7 @@ public class KylinTicketTimesPartnerServiceImpl extends ServiceImpl<KylinTicketT
kylinTicketTimesPartnerVo.setUseEnd(createTicketTimesParam.getUseEnd().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"))); kylinTicketTimesPartnerVo.setUseEnd(createTicketTimesParam.getUseEnd().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
kylinTicketTimesPartnerVo.setStatus(null); 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( Document doc = mongoTemplate.getCollection(KylinTicketTimesPartnerVo.class.getSimpleName()).findOneAndUpdate(
Query.query(Criteria.where("ticketTimesId").is(createTicketTimesParam.getTicketTimesId())).getQueryObject(), Query.query(Criteria.where("ticketTimesId").is(createTicketTimesParam.getTicketTimesId())).getQueryObject(),
object, object,
......
liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/partner/KylinTicketsPartnerServiceImpl.java
View file @ acf2ddd6
package com.liquidnet.service.platform.service.impl.partner; package com.liquidnet.service.platform.service.impl.partner;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; 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.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.liquidnet.commons.lang.util.DateUtil; import com.liquidnet.commons.lang.util.DateUtil;
import com.liquidnet.commons.lang.util.IDGenerator; import com.liquidnet.commons.lang.util.IDGenerator;
...@@ -14,6 +15,7 @@ import com.liquidnet.service.kylin.dto.vo.partner.KylinTicketTimesPartnerVo; ...@@ -14,6 +15,7 @@ import com.liquidnet.service.kylin.dto.vo.partner.KylinTicketTimesPartnerVo;
import com.liquidnet.service.kylin.entity.*; import com.liquidnet.service.kylin.entity.*;
import com.liquidnet.service.kylin.mapper.*; import com.liquidnet.service.kylin.mapper.*;
import com.liquidnet.service.kylin.service.partner.IKylinTicketsPartnerService; import com.liquidnet.service.kylin.service.partner.IKylinTicketsPartnerService;
import com.liquidnet.service.platform.utils.ObjectUtil;
import com.liquidnet.service.platform.utils.PerformanceVoTask; import com.liquidnet.service.platform.utils.PerformanceVoTask;
import com.mongodb.BasicDBObject; import com.mongodb.BasicDBObject;
import com.mongodb.client.model.FindOneAndUpdateOptions; import com.mongodb.client.model.FindOneAndUpdateOptions;
...@@ -74,7 +76,7 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp ...@@ -74,7 +76,7 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp
if (null != timesPartnerVo) { if (null != timesPartnerVo) {
KylinPerformanceStatus performanceStatus = performanceStatusMapper.selectOne( KylinPerformanceStatus performanceStatus = performanceStatusMapper.selectOne(
new UpdateWrapper<KylinPerformanceStatus>().eq("performance_id", timesPartnerVo.getPerformancesId())); Wrappers.lambdaQuery(KylinPerformanceStatus.class).eq(KylinPerformanceStatus::getPerformanceId, timesPartnerVo.getPerformancesId()));
if (null == performanceStatus) { if (null == performanceStatus) {
ticketPartnerVo = createTicket(ticketCreateParam); ticketPartnerVo = createTicket(ticketCreateParam);
} else if (performanceStatus.getStatus() >= 3 && performanceStatus.getStatus() != 4) {//未被拒绝 且 通过审核的演出 } else if (performanceStatus.getStatus() >= 3 && performanceStatus.getStatus() != 4) {//未被拒绝 且 通过审核的演出
...@@ -98,7 +100,7 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp ...@@ -98,7 +100,7 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp
ticketCreateParam.setTicketsId(ticketsId); ticketCreateParam.setTicketsId(ticketsId);
// mongo 操作 // mongo 操作
KylinTicketPartnerVo kylinTicketPartnerVo = new KylinTicketPartnerVo(); KylinTicketPartnerVo kylinTicketPartnerVo = KylinTicketPartnerVo.getNew();
BeanUtils.copyProperties(ticketCreateParam, kylinTicketPartnerVo); BeanUtils.copyProperties(ticketCreateParam, kylinTicketPartnerVo);
kylinTicketPartnerVo.setTicketsId(ticketsId); kylinTicketPartnerVo.setTicketsId(ticketsId);
kylinTicketPartnerVo.setCreatedAt(DateUtil.Formatter.yyyyMMddHHmmss.format(createdAt)); kylinTicketPartnerVo.setCreatedAt(DateUtil.Formatter.yyyyMMddHHmmss.format(createdAt));
...@@ -112,12 +114,12 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp ...@@ -112,12 +114,12 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp
kylinTicketPartnerVo.setStatus(0); kylinTicketPartnerVo.setStatus(0);
kylinTicketPartnerVo.setDefault(); kylinTicketPartnerVo.setDefault();
if (ticketCreateParam.getIsExpress() == 1) { if (ticketCreateParam.getIsExpress() == 1) {
kylinTicketPartnerVo.setDescribeExpress(ticketCreateParam.getDescribeExpress()==null?"":ticketCreateParam.getDescribeExpress()); kylinTicketPartnerVo.setDescribeExpress(ticketCreateParam.getDescribeExpress() == null ? "" : ticketCreateParam.getDescribeExpress());
} else { } else {
kylinTicketPartnerVo.setDescribeExpress(""); kylinTicketPartnerVo.setDescribeExpress("");
} }
if (ticketCreateParam.getIsElectronic() == 1) { if (ticketCreateParam.getIsElectronic() == 1) {
kylinTicketPartnerVo.setDescribeElectronic(ticketCreateParam.getDescribeElectronic()==null?"":ticketCreateParam.getDescribeElectronic()); kylinTicketPartnerVo.setDescribeElectronic(ticketCreateParam.getDescribeElectronic() == null ? "" : ticketCreateParam.getDescribeElectronic());
} else { } else {
kylinTicketPartnerVo.setDescribeElectronic(""); kylinTicketPartnerVo.setDescribeElectronic("");
} }
...@@ -150,7 +152,7 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp ...@@ -150,7 +152,7 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp
ticketCreateParam.setTicketsId(ticketsId); ticketCreateParam.setTicketsId(ticketsId);
// mongo 操作 // mongo 操作
KylinTicketPartnerVo kylinTicketPartnerVo = new KylinTicketPartnerVo(); KylinTicketPartnerVo kylinTicketPartnerVo = KylinTicketPartnerVo.getNew();
BeanUtils.copyProperties(ticketCreateParam, kylinTicketPartnerVo); BeanUtils.copyProperties(ticketCreateParam, kylinTicketPartnerVo);
kylinTicketPartnerVo.setTicketsId(ticketsId); kylinTicketPartnerVo.setTicketsId(ticketsId);
kylinTicketPartnerVo.setCreatedAt(createdAt.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"))); kylinTicketPartnerVo.setCreatedAt(createdAt.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
...@@ -162,12 +164,12 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp ...@@ -162,12 +164,12 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp
kylinTicketPartnerVo.setUseEnd(kylinTicketTimesPartnerVo.getUseEnd()); kylinTicketPartnerVo.setUseEnd(kylinTicketTimesPartnerVo.getUseEnd());
kylinTicketPartnerVo.setType(kylinTicketTimesPartnerVo.getType()); kylinTicketPartnerVo.setType(kylinTicketTimesPartnerVo.getType());
if (ticketCreateParam.getIsExpress() == 1) { if (ticketCreateParam.getIsExpress() == 1) {
kylinTicketPartnerVo.setDescribeExpress(ticketCreateParam.getDescribeExpress()==null?"":ticketCreateParam.getDescribeExpress()); kylinTicketPartnerVo.setDescribeExpress(ticketCreateParam.getDescribeExpress() == null ? "" : ticketCreateParam.getDescribeExpress());
} else { } else {
kylinTicketPartnerVo.setDescribeExpress(""); kylinTicketPartnerVo.setDescribeExpress("");
} }
if (ticketCreateParam.getIsElectronic() == 1) { if (ticketCreateParam.getIsElectronic() == 1) {
kylinTicketPartnerVo.setDescribeElectronic(ticketCreateParam.getDescribeElectronic()==null?"":ticketCreateParam.getDescribeElectronic()); kylinTicketPartnerVo.setDescribeElectronic(ticketCreateParam.getDescribeElectronic() == null ? "" : ticketCreateParam.getDescribeElectronic());
} else { } else {
kylinTicketPartnerVo.setDescribeElectronic(""); kylinTicketPartnerVo.setDescribeElectronic("");
} }
...@@ -208,7 +210,7 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp ...@@ -208,7 +210,7 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp
String ticketId = ticketCreateParam.getTicketsId(); String ticketId = ticketCreateParam.getTicketsId();
LocalDateTime updatedAt = LocalDateTime.now(); LocalDateTime updatedAt = LocalDateTime.now();
// mongo 操作 // mongo 操作
KylinTicketPartnerVo kylinTicketPartnerVo = new KylinTicketPartnerVo(); KylinTicketPartnerVo kylinTicketPartnerVo = KylinTicketPartnerVo.getNew();
BeanUtils.copyProperties(ticketCreateParam, kylinTicketPartnerVo); BeanUtils.copyProperties(ticketCreateParam, kylinTicketPartnerVo);
kylinTicketPartnerVo.setUpdatedAt(updatedAt.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"))); 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"))); kylinTicketPartnerVo.setTimeStart(ticketCreateParam.getTimeStart().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
...@@ -216,10 +218,10 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp ...@@ -216,10 +218,10 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp
kylinTicketPartnerVo.setTimesId(null); kylinTicketPartnerVo.setTimesId(null);
kylinTicketPartnerVo.setStatus(null); kylinTicketPartnerVo.setStatus(null);
if (ticketCreateParam.getIsExpress() == 1) { if (ticketCreateParam.getIsExpress() == 1) {
kylinTicketPartnerVo.setDescribeExpress(ticketCreateParam.getDescribeExpress()==null?"":ticketCreateParam.getDescribeExpress()); kylinTicketPartnerVo.setDescribeExpress(ticketCreateParam.getDescribeExpress() == null ? "" : ticketCreateParam.getDescribeExpress());
} }
if (ticketCreateParam.getIsElectronic() == 1) { if (ticketCreateParam.getIsElectronic() == 1) {
kylinTicketPartnerVo.setDescribeElectronic(ticketCreateParam.getDescribeElectronic()==null?"":ticketCreateParam.getDescribeElectronic()); kylinTicketPartnerVo.setDescribeElectronic(ticketCreateParam.getDescribeElectronic() == null ? "" : ticketCreateParam.getDescribeElectronic());
} }
kylinTicketPartnerVo.setDefault(); kylinTicketPartnerVo.setDefault();
...@@ -230,7 +232,7 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp ...@@ -230,7 +232,7 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp
kylinTicketPartnerVo.setQrCodeShowTime(ticketCreateParam.getQrCodeShowTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"))); 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( Document doc = mongoTemplate.getCollection(KylinTicketPartnerVo.class.getSimpleName()).findOneAndUpdate(
Query.query(Criteria.where("ticketsId").is(ticketId)).getQueryObject(), Query.query(Criteria.where("ticketsId").is(ticketId)).getQueryObject(),
object, object,
...@@ -251,15 +253,14 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp ...@@ -251,15 +253,14 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp
LocalDateTime updatedAt = LocalDateTime.now(); LocalDateTime updatedAt = LocalDateTime.now();
KylinTicketRelations ticketRelations = ticketRelationsMapper.selectOne( KylinTicketRelations ticketRelations = ticketRelationsMapper.selectOne(
new UpdateWrapper<KylinTicketRelations>().eq("ticket_id", ticketsId)); Wrappers.lambdaQuery(KylinTicketRelations.class).eq(KylinTicketRelations::getTicketId, ticketsId));
if (ticketRelations == null) { if (ticketRelations == null) {
mongoTemplate.remove(Query.query(Criteria.where("ticketsId").is(ticketsId)), KylinTicketPartnerVo.class, KylinTicketPartnerVo.class.getSimpleName()); mongoTemplate.remove(Query.query(Criteria.where("ticketsId").is(ticketsId)), KylinTicketPartnerVo.class, KylinTicketPartnerVo.class.getSimpleName());
return ResponseDto.success("删除成功"); return ResponseDto.success("删除成功");
} }
KylinTicketTimeRelation ticketTimeRelation = ticketTimeRelationMapper.selectOne( 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 data = mongoTemplate.findOne(Query.query(Criteria.where("performancesId").is(ticketTimeRelation.getPerformanceId())),
PerformancePartnerVo.class, PerformancePartnerVo.class.getSimpleName()); PerformancePartnerVo.class, PerformancePartnerVo.class.getSimpleName());
if (data == null || data.getAuditStatus() == null || data.getAuditStatus() == 0) { if (data == null || data.getAuditStatus() == null || data.getAuditStatus() == 0) {
...@@ -267,19 +268,18 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp ...@@ -267,19 +268,18 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp
} }
KylinPerformanceStatus performanceStatus = performanceStatusMapper.selectOne( 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) {//未提审||被拒绝 if (performanceStatus.getStatus() == 0 || performanceStatus.getStatus() == 4) {//未提审||被拒绝
// mongo 操作 // 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("updatedAt", updatedAt.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
map.put("status", -1); map.put("status", -1);
BasicDBObject object = new BasicDBObject("$set", mongoConverter.convertToMongoType(map)); BasicDBObject object = ObjectUtil.cloneBasicDBObject().append("$set", mongoConverter.convertToMongoType(map));
Document doc = mongoTemplate.getCollection(KylinTicketPartnerVo.class.getSimpleName()).findOneAndUpdate( mongoTemplate.getCollection(KylinTicketPartnerVo.class.getSimpleName()).updateOne(
Query.query(Criteria.where("ticketsId").is(ticketsId)).getQueryObject(), Query.query(Criteria.where("ticketsId").is(ticketsId)).getQueryObject(),
object, object
new FindOneAndUpdateOptions().returnDocument(ReturnDocument.AFTER)
); );
return ResponseDto.success("删除成功"); return ResponseDto.success("删除成功");
} else { } else {
...@@ -320,14 +320,14 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp ...@@ -320,14 +320,14 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp
public boolean submitTicketByTimes(String timesId, Integer status) { public boolean submitTicketByTimes(String timesId, Integer status) {
LocalDateTime updatedAt = LocalDateTime.now(); LocalDateTime updatedAt = LocalDateTime.now();
HashMap<String, Object> map = new HashMap<>(); HashMap<String, Object> map = ObjectUtil.cloneHashMapStringAndObject();
if (null == status) { if (null == status) {
map.put("status", 1); map.put("status", 1);
} else { } else {
map.put("status", status); map.put("status", status);
} }
map.put("updatedAt", updatedAt.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"))); 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( mongoTemplate.getCollection(KylinTicketPartnerVo.class.getSimpleName()).updateMany(
Query.query(Criteria.where("timesId").is(timesId).and("status").nin(-2, 7)).getQueryObject(), Query.query(Criteria.where("timesId").is(timesId).and("status").nin(-2, 7)).getQueryObject(),
object object
...@@ -355,18 +355,18 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp ...@@ -355,18 +355,18 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp
public ResponseDto<String> onLine(String ticketsId, String performancesId) { public ResponseDto<String> onLine(String ticketsId, String performancesId) {
try { try {
LocalDateTime updatedAt = LocalDateTime.now(); 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) {//未提审||被拒绝 if (ticketStatus.getStatus() >= 3 && ticketStatus.getStatus() != 4 && ticketStatus.getStatus() != 6) {//未提审||被拒绝
//mysql //mysql
KylinTicketStatus changeStatus = new KylinTicketStatus(); KylinTicketStatus changeStatus = KylinTicketStatus.getNew();
changeStatus.setUpdatedAt(updatedAt); changeStatus.setUpdatedAt(updatedAt);
changeStatus.setStatus(9); 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); 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( mongoTemplate.getCollection(KylinTicketPartnerVo.class.getSimpleName()).updateOne(
Query.query(Criteria.where("ticketsId").is(ticketsId)).getQueryObject(), Query.query(Criteria.where("ticketsId").is(ticketsId)).getQueryObject(),
object object
...@@ -387,17 +387,17 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp ...@@ -387,17 +387,17 @@ public class KylinTicketsPartnerServiceImpl extends ServiceImpl<KylinTicketsMapp
public ResponseDto<String> outLine(String ticketsId, String performancesId) { public ResponseDto<String> outLine(String ticketsId, String performancesId) {
try { try {
LocalDateTime updatedAt = LocalDateTime.now(); 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) {//未提审||被拒绝 if (ticketStatus.getStatus() >= 3 && ticketStatus.getStatus() != 4 && ticketStatus.getStatus() != 7) {//未提审||被拒绝
//mysql //mysql
KylinTicketStatus changeStatus = new KylinTicketStatus(); KylinTicketStatus changeStatus = KylinTicketStatus.getNew();
changeStatus.setUpdatedAt(updatedAt); changeStatus.setUpdatedAt(updatedAt);
changeStatus.setStatus(7); 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 操作 // mongo 操作
HashMap<String, Object> map = new HashMap<>(); HashMap<String, Object> map = ObjectUtil.cloneHashMapStringAndObject();
map.put("status", 7); 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( mongoTemplate.getCollection(KylinTicketPartnerVo.class.getSimpleName()).updateOne(
Query.query(Criteria.where("ticketsId").is(ticketsId)).getQueryObject(), Query.query(Criteria.where("ticketsId").is(ticketsId)).getQueryObject(),
object object
......
liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/utils/ObjectUtil.java 0 → 100644
View file @ acf2ddd6
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 HashMap<String, Object> hashMapStringAndObject = new HashMap<String, Object>();
private static final BasicDBObject basicDBObject = new BasicDBObject();
public static HashMap<String, Object> cloneHashMapStringAndObject() {
return (HashMap<String, Object>) hashMapStringAndObject.clone();
}
public static BasicDBObject cloneBasicDBObject() {
return (BasicDBObject) basicDBObject.clone();
}
}
liquidnet-bus-service/liquidnet-service-sweet/pom.xml
View file @ acf2ddd6
...@@ -54,4 +54,13 @@ ...@@ -54,4 +54,13 @@
<version>1.0-SNAPSHOT</version> <version>1.0-SNAPSHOT</version>
</dependency> </dependency>
</dependencies> </dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project> </project>
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment