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

Commit 2decbaca authored by 张国柄's avatar 张国柄

fix:NEW优化、分页调整;

parent 28a0d02c
package com.liquidnet.service.adam.service; package com.liquidnet.service.adam.service;
import com.github.pagehelper.PageInfo;
import com.liquidnet.service.adam.dto.vo.AdamCollectBaseVo; import com.liquidnet.service.adam.dto.vo.AdamCollectBaseVo;
import com.liquidnet.service.adam.dto.vo.AdamCollectVo; import com.liquidnet.service.adam.dto.vo.AdamCollectVo;
import com.liquidnet.service.base.PagedResult;
/** /**
* <p> * <p>
...@@ -22,5 +22,5 @@ public interface IAdamCollectionService { ...@@ -22,5 +22,5 @@ public interface IAdamCollectionService {
boolean queryState(String uid, String type, String contentId); boolean queryState(String uid, String type, String contentId);
PageInfo<AdamCollectVo> queryPage(String uid, String type, int pageNo, int pageSize); PagedResult<AdamCollectVo> queryPage(String uid, String type, int pageNo, int pageSize);
} }
package com.liquidnet.service.adam.service; package com.liquidnet.service.adam.service;
import com.github.pagehelper.PageInfo;
import com.liquidnet.service.adam.dto.vo.AdamDisposedBaseVo; import com.liquidnet.service.adam.dto.vo.AdamDisposedBaseVo;
import com.liquidnet.service.adam.dto.vo.AdamDisposedUserVo; import com.liquidnet.service.adam.dto.vo.AdamDisposedUserVo;
import com.liquidnet.service.adam.dto.vo.AdamDisposedVo; import com.liquidnet.service.adam.dto.vo.AdamDisposedVo;
import com.liquidnet.service.base.PagedResult;
/** /**
* <p> * <p>
...@@ -23,7 +23,7 @@ public interface IAdamDisposedService { ...@@ -23,7 +23,7 @@ public interface IAdamDisposedService {
boolean queryState(String uid, String type, String contentId); boolean queryState(String uid, String type, String contentId);
PageInfo<AdamDisposedVo> queryPage(String uid, String type, int pageNo, int pageSize); PagedResult<AdamDisposedVo> queryPage(String uid, String type, int pageNo, int pageSize);
PageInfo<AdamDisposedUserVo> queryDisposedUsers(String type, String contentId, int pageNo, int pageSize); PagedResult<AdamDisposedUserVo> queryDisposedUsers(String type, String contentId, int pageNo, int pageSize);
} }
package com.liquidnet.service.adam.service; package com.liquidnet.service.adam.service;
import com.github.pagehelper.PageInfo;
import com.liquidnet.service.adam.dto.AdamMemberOrderCallbackParam; import com.liquidnet.service.adam.dto.AdamMemberOrderCallbackParam;
import com.liquidnet.service.adam.dto.AdamMemberOrderCodeParam; import com.liquidnet.service.adam.dto.AdamMemberOrderCodeParam;
import com.liquidnet.service.adam.dto.AdamMemberOrderParam; import com.liquidnet.service.adam.dto.AdamMemberOrderParam;
import com.liquidnet.service.adam.dto.AdamMemberOrderResult; import com.liquidnet.service.adam.dto.AdamMemberOrderResult;
import com.liquidnet.service.adam.dto.vo.AdamMemberOrderSimpleVo; import com.liquidnet.service.adam.dto.vo.AdamMemberOrderSimpleVo;
import com.liquidnet.service.base.PagedResult;
import com.liquidnet.service.base.ResponseDto; import com.liquidnet.service.base.ResponseDto;
/** /**
...@@ -40,5 +40,5 @@ public interface IAdamMemberOrderService { ...@@ -40,5 +40,5 @@ public interface IAdamMemberOrderService {
* @param pageSize * @param pageSize
* @return * @return
*/ */
PageInfo<AdamMemberOrderSimpleVo> queryPage(String uid, int pageNo, int pageSize); PagedResult<AdamMemberOrderSimpleVo> queryPage(String uid, int pageNo, int pageSize);
} }
/**
* $Id$
* Copyright(C) 2015-2020 kowlone - internet center, All Rights Reserved.
*/
package com.liquidnet.service.base; package com.liquidnet.service.base;
import java.io.Serializable; import java.io.Serializable;
import java.util.List;
/** public class PagedResult<T> implements Serializable, Cloneable {
* 分页显示的结果 private static final long serialVersionUID = 8141034447809038759L;
* @author <a href="mailto:lzm8285@163.com">Li Zhongmin</a> /**
* @version 1.0 2015年12月08日 17:44:00 * 总页数
*/ */
public class PagedResult<T> implements Serializable{ private int pages;
/**
private static final long serialVersionUID = 9014763784496485161L; * 总记录数
/** 总页数 */ */
private int totalPages; private long total;
/** 总记录数 */ /**
private int totalRows; * 分页数据
/** 分页数据 */ */
private T data; private List<T> list;
public PagedResult(){} public PagedResult() {
}
public PagedResult(T data,Object page) { public int getPages() {
this.data = data; return pages;
} }
public PagedResult(T data,int totalPages,int totalRows) { // public PagedResult<T> setTotalPages(int totalPages) {
this.totalPages = totalPages; // this.totalPages = totalPages;
this.totalRows = totalRows; // return this;
this.data = data; // }
public long getTotal() {
return total;
} }
public PagedResult<T> setTotal(long total, int pageSize) {
this.total = total;
if (total == -1L) {
this.pages = 1;
} else {
if (pageSize > 0) {
this.pages = (int) (total / pageSize + (total % pageSize == 0L ? 0 : 1));
} else {
this.pages = 0;
}
}
return this;
}
public T getData() { public List<T> getList() {
return data; return list;
} }
public int getTotalPages() { public PagedResult<T> setList(List<T> list) {
return totalPages; this.list = list;
return this;
} }
public int getTotalRows() { @Override
return totalRows; public PagedResult<T> clone() {
try {
return (PagedResult<T>) super.clone();
} catch (CloneNotSupportedException e) {
return new PagedResult<>();
}
} }
} }
...@@ -7,6 +7,7 @@ import com.liquidnet.commons.lang.util.CurrentUtil; ...@@ -7,6 +7,7 @@ import com.liquidnet.commons.lang.util.CurrentUtil;
import com.liquidnet.service.adam.dto.vo.AdamCollectBaseVo; import com.liquidnet.service.adam.dto.vo.AdamCollectBaseVo;
import com.liquidnet.service.adam.dto.vo.AdamCollectVo; import com.liquidnet.service.adam.dto.vo.AdamCollectVo;
import com.liquidnet.service.adam.service.IAdamCollectionService; import com.liquidnet.service.adam.service.IAdamCollectionService;
import com.liquidnet.service.base.PagedResult;
import com.liquidnet.service.base.ResponseDto; import com.liquidnet.service.base.ResponseDto;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiImplicitParam;
...@@ -19,6 +20,7 @@ import org.springframework.web.bind.annotation.*; ...@@ -19,6 +20,7 @@ import org.springframework.web.bind.annotation.*;
import javax.validation.constraints.NotBlank; import javax.validation.constraints.NotBlank;
import javax.validation.constraints.Pattern; import javax.validation.constraints.Pattern;
import javax.validation.constraints.Size; import javax.validation.constraints.Size;
import java.util.List;
/** /**
* <p> * <p>
...@@ -86,7 +88,7 @@ public class AdamCollectionController { ...@@ -86,7 +88,7 @@ public class AdamCollectionController {
@ApiImplicitParam(type = "form", required = false, dataType = "Integer", name = "pageSize", value = "页展示条数", example = "5"), @ApiImplicitParam(type = "form", required = false, dataType = "Integer", name = "pageSize", value = "页展示条数", example = "5"),
}) })
@PostMapping("list") @PostMapping("list")
public ResponseDto<PageInfo<AdamCollectVo>> list(@Pattern(regexp = "\\b(TICKET|VIDEO)\\b", message = "收藏类型无效") public ResponseDto<PagedResult<AdamCollectVo>> list(@Pattern(regexp = "\\b(TICKET|VIDEO)\\b", message = "收藏类型无效")
@RequestParam String type, @RequestParam String type,
@RequestParam(defaultValue = "1", required = false) int pageNo, @RequestParam(defaultValue = "1", required = false) int pageNo,
@RequestParam(defaultValue = "5", required = false) int pageSize) { @RequestParam(defaultValue = "5", required = false) int pageSize) {
......
package com.liquidnet.service.adam.controller; package com.liquidnet.service.adam.controller;
import com.github.pagehelper.PageInfo;
import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport; import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
import com.github.xiaoymin.knife4j.annotations.ApiSupport; import com.github.xiaoymin.knife4j.annotations.ApiSupport;
import com.liquidnet.commons.lang.util.CurrentUtil; import com.liquidnet.commons.lang.util.CurrentUtil;
...@@ -8,6 +7,7 @@ import com.liquidnet.service.adam.dto.vo.AdamDisposedBaseVo; ...@@ -8,6 +7,7 @@ import com.liquidnet.service.adam.dto.vo.AdamDisposedBaseVo;
import com.liquidnet.service.adam.dto.vo.AdamDisposedUserVo; import com.liquidnet.service.adam.dto.vo.AdamDisposedUserVo;
import com.liquidnet.service.adam.dto.vo.AdamDisposedVo; import com.liquidnet.service.adam.dto.vo.AdamDisposedVo;
import com.liquidnet.service.adam.service.IAdamDisposedService; import com.liquidnet.service.adam.service.IAdamDisposedService;
import com.liquidnet.service.base.PagedResult;
import com.liquidnet.service.base.ResponseDto; import com.liquidnet.service.base.ResponseDto;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiImplicitParam;
...@@ -88,7 +88,7 @@ public class AdamDisposedController { ...@@ -88,7 +88,7 @@ public class AdamDisposedController {
@ApiImplicitParam(type = "form", required = false, dataType = "Integer", name = "pageSize", value = "页展示条数", example = "5"), @ApiImplicitParam(type = "form", required = false, dataType = "Integer", name = "pageSize", value = "页展示条数", example = "5"),
}) })
@PostMapping("list") @PostMapping("list")
public ResponseDto<PageInfo<AdamDisposedVo>> list(@Pattern(regexp = "\\b(TICKET|VIDEO)\\b", message = "想去类型无效") public ResponseDto<PagedResult<AdamDisposedVo>> list(@Pattern(regexp = "\\b(TICKET|VIDEO)\\b", message = "想去类型无效")
@RequestParam String type, @RequestParam String type,
@RequestParam(defaultValue = "1", required = false) int pageNo, @RequestParam(defaultValue = "1", required = false) int pageNo,
@RequestParam(defaultValue = "5", required = false) int pageSize) { @RequestParam(defaultValue = "5", required = false) int pageSize) {
...@@ -107,7 +107,7 @@ public class AdamDisposedController { ...@@ -107,7 +107,7 @@ public class AdamDisposedController {
@ApiImplicitParam(type = "form", required = false, dataType = "Integer", name = "pageSize", value = "页展示条数", example = "10"), @ApiImplicitParam(type = "form", required = false, dataType = "Integer", name = "pageSize", value = "页展示条数", example = "10"),
}) })
@PostMapping("list/user") @PostMapping("list/user")
public ResponseDto<PageInfo<AdamDisposedUserVo>> listUser(@Pattern(regexp = "\\b(TICKET|VIDEO)\\b", message = "想去类型无效") public ResponseDto<PagedResult<AdamDisposedUserVo>> listUser(@Pattern(regexp = "\\b(TICKET|VIDEO)\\b", message = "想去类型无效")
@RequestParam String type, @RequestParam String type,
@Size(min = 1, max = 64, message = "内容ID长度限制1-64位") @Size(min = 1, max = 64, message = "内容ID长度限制1-64位")
@RequestParam String contentId, @RequestParam String contentId,
......
...@@ -20,6 +20,7 @@ import com.liquidnet.service.adam.service.IAdamMemberOrderService; ...@@ -20,6 +20,7 @@ import com.liquidnet.service.adam.service.IAdamMemberOrderService;
import com.liquidnet.service.adam.service.AdamRdmService; import com.liquidnet.service.adam.service.AdamRdmService;
import com.liquidnet.service.adam.service.IAdamUserService; import com.liquidnet.service.adam.service.IAdamUserService;
import com.liquidnet.service.base.ErrorMapping; import com.liquidnet.service.base.ErrorMapping;
import com.liquidnet.service.base.PagedResult;
import com.liquidnet.service.base.ResponseDto; import com.liquidnet.service.base.ResponseDto;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiImplicitParam;
...@@ -139,13 +140,13 @@ public class AdamMemberOrderController { ...@@ -139,13 +140,13 @@ public class AdamMemberOrderController {
@ApiOperation(value = "会员支付回调") @ApiOperation(value = "会员支付回调")
@ApiImplicitParams({ @ApiImplicitParams({
@ApiImplicitParam(type = "form", required = true, dataType = "String", name = "status", value = "1-成功|0-失败", example = "1"), @ApiImplicitParam(type = "form", required = true, dataType = "String", name = "status", value = "1-成功|0-失败", example = "1"),
@ApiImplicitParam(type = "form", required = true, dataType = "String", name = "order_code", value = "会员订单号", example = "77062761607274496V"), @ApiImplicitParam(type = "form", required = true, dataType = "String", name = "orderCode", value = "会员订单号", example = "77062761607274496V"),
@ApiImplicitParam(type = "form", required = true, dataType = "String", name = "code", value = "支付订单号", example = "20210616153954199964032352974P"), @ApiImplicitParam(type = "form", required = true, dataType = "String", name = "code", value = "支付订单号", example = "20210616153954199964032352974P"),
@ApiImplicitParam(type = "form", required = true, dataType = "String", name = "type", value = "购买类型", example = "VIP"), @ApiImplicitParam(type = "form", required = true, dataType = "String", name = "type", value = "购买类型", example = "VIP"),
@ApiImplicitParam(type = "form", required = true, dataType = "String", name = "price", value = "支付金额", example = "0.01"), @ApiImplicitParam(type = "form", required = true, dataType = "String", name = "price", value = "支付金额", example = "0.01"),
@ApiImplicitParam(type = "form", required = true, dataType = "String", name = "payment_type", value = "支付类型", example = "APPALIPAY"), @ApiImplicitParam(type = "form", required = true, dataType = "String", name = "paymentType", value = "支付类型", example = "APPALIPAY"),
@ApiImplicitParam(type = "form", required = true, dataType = "String", name = "payment_at", value = "支付时间", example = "2021-06-16 15:40:02"), @ApiImplicitParam(type = "form", required = true, dataType = "String", name = "paymentAt", value = "支付时间", example = "2021-06-16 15:40:02"),
@ApiImplicitParam(type = "form", required = true, dataType = "String", name = "payment_id", value = "支付ID", example = "2021061622001468121421203878"), @ApiImplicitParam(type = "form", required = true, dataType = "String", name = "paymentId", value = "支付ID", example = "2021061622001468121421203878"),
}) })
@PostMapping("callback") @PostMapping("callback")
public String paymentNotifyCallBack() { public String paymentNotifyCallBack() {
...@@ -239,7 +240,7 @@ public class AdamMemberOrderController { ...@@ -239,7 +240,7 @@ public class AdamMemberOrderController {
@ApiOperationSupport(order = 5) @ApiOperationSupport(order = 5)
@ApiOperation(value = "会员订单列表") @ApiOperation(value = "会员订单列表")
@GetMapping("list") @GetMapping("list")
public ResponseDto<PageInfo<AdamMemberOrderSimpleVo>> list(@RequestParam(defaultValue = "1", required = false) int pageNo, public ResponseDto<PagedResult<AdamMemberOrderSimpleVo>> list(@RequestParam(defaultValue = "1", required = false) int pageNo,
@RequestParam(defaultValue = "5", required = false) int pageSize) { @RequestParam(defaultValue = "5", required = false) int pageSize) {
return ResponseDto.success(adamMemberOrderService.queryPage(CurrentUtil.getCurrentUid(), pageNo, pageSize)); return ResponseDto.success(adamMemberOrderService.queryPage(CurrentUtil.getCurrentUid(), pageNo, pageSize));
} }
......
...@@ -11,6 +11,7 @@ import com.liquidnet.service.adam.dto.vo.*; ...@@ -11,6 +11,7 @@ import com.liquidnet.service.adam.dto.vo.*;
import com.liquidnet.service.adam.service.AdamRdmService; import com.liquidnet.service.adam.service.AdamRdmService;
import com.liquidnet.service.adam.service.IAdamUserInfoService; import com.liquidnet.service.adam.service.IAdamUserInfoService;
import com.liquidnet.service.adam.service.IAdamUserService; import com.liquidnet.service.adam.service.IAdamUserService;
import com.liquidnet.service.adam.util.ObjectUtil;
import com.liquidnet.service.base.ErrorMapping; import com.liquidnet.service.base.ErrorMapping;
import com.liquidnet.service.base.ResponseDto; import com.liquidnet.service.base.ResponseDto;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
...@@ -74,7 +75,7 @@ public class AdamUserController { ...@@ -74,7 +75,7 @@ public class AdamUserController {
// // 已选中的父级标签与系统筛选命中的父级标签数量不同 // // 已选中的父级标签与系统筛选命中的父级标签数量不同
// return ResponseDto.failure(ErrorMapping.get("10012")); // return ResponseDto.failure(ErrorMapping.get("10012"));
// } // }
// List<AdamTagParentVo> tagMeVoList = new ArrayList<>(); // List<AdamTagParentVo> tagMeVoList = ObjectUtil.getAdamTagParentVoArrayList();
// // tagMe子级标签校验处理 // // tagMe子级标签校验处理
// for (AdamTagParentVo parentVo : tagMeVos) { // for (AdamTagParentVo parentVo : tagMeVos) {
// // 系统对应的父级标签 // // 系统对应的父级标签
...@@ -131,7 +132,7 @@ public class AdamUserController { ...@@ -131,7 +132,7 @@ public class AdamUserController {
public ResponseDto<List<AdamTagParentVo>> getTagsForMusic() { public ResponseDto<List<AdamTagParentVo>> getTagsForMusic() {
List<AdamTagParentVo> tagsForMusic = adamRdmService.getTagsForMusic(); List<AdamTagParentVo> tagsForMusic = adamRdmService.getTagsForMusic();
if (CollectionUtils.isEmpty(tagsForMusic)) { if (CollectionUtils.isEmpty(tagsForMusic)) {
tagsForMusic = new ArrayList<>(); tagsForMusic = ObjectUtil.getAdamTagParentVoArrayList();
tagsForMusic.add(AdamTagParentVo.getNew().setVal("MMS01").setDesc("民歌").setTagVos(Arrays.asList( tagsForMusic.add(AdamTagParentVo.getNew().setVal("MMS01").setDesc("民歌").setTagVos(Arrays.asList(
AdamTagVo.getNew().setVal("MMS0101").setDesc("A"), AdamTagVo.getNew().setVal("MMS0101").setDesc("A"),
AdamTagVo.getNew().setVal("MMS0102").setDesc("B") AdamTagVo.getNew().setVal("MMS0102").setDesc("B")
...@@ -156,7 +157,7 @@ public class AdamUserController { ...@@ -156,7 +157,7 @@ public class AdamUserController {
public ResponseDto<List<AdamTagVo>> getTagsForSex() { public ResponseDto<List<AdamTagVo>> getTagsForSex() {
List<AdamTagVo> tagsForSex = adamRdmService.getTagsForSex(); List<AdamTagVo> tagsForSex = adamRdmService.getTagsForSex();
if (CollectionUtils.isEmpty(tagsForSex)) { if (CollectionUtils.isEmpty(tagsForSex)) {
tagsForSex = new ArrayList<>(); tagsForSex = ObjectUtil.getAdamTagVoArrayList();
tagsForSex.add(AdamTagVo.getNew().setVal("MS00").setDesc("保密")); tagsForSex.add(AdamTagVo.getNew().setVal("MS00").setDesc("保密"));
tagsForSex.add(AdamTagVo.getNew().setVal("MS01").setDesc("男性")); tagsForSex.add(AdamTagVo.getNew().setVal("MS01").setDesc("男性"));
tagsForSex.add(AdamTagVo.getNew().setVal("MS02").setDesc("女性")); tagsForSex.add(AdamTagVo.getNew().setVal("MS02").setDesc("女性"));
......
package com.liquidnet.service.adam.service.impl; package com.liquidnet.service.adam.service.impl;
import com.github.pagehelper.PageInfo;
import com.liquidnet.commons.lang.util.CollectionUtil; import com.liquidnet.commons.lang.util.CollectionUtil;
import com.liquidnet.service.adam.dto.vo.AdamCollectBaseVo; import com.liquidnet.service.adam.dto.vo.AdamCollectBaseVo;
import com.liquidnet.service.adam.dto.vo.AdamCollectInfoVo; import com.liquidnet.service.adam.dto.vo.AdamCollectInfoVo;
import com.liquidnet.service.adam.dto.vo.AdamCollectVo; import com.liquidnet.service.adam.dto.vo.AdamCollectVo;
import com.liquidnet.service.adam.service.AdamRdmService; import com.liquidnet.service.adam.service.AdamRdmService;
import com.liquidnet.service.adam.service.IAdamCollectionService; import com.liquidnet.service.adam.service.IAdamCollectionService;
import com.liquidnet.service.adam.util.ObjectUtil;
import com.liquidnet.service.adam.util.QueueUtils; import com.liquidnet.service.adam.util.QueueUtils;
import com.liquidnet.service.base.PagedResult;
import com.liquidnet.service.base.SqlMapping; import com.liquidnet.service.base.SqlMapping;
import com.liquidnet.service.base.constant.MQConst; import com.liquidnet.service.base.constant.MQConst;
import com.liquidnet.service.kylin.dto.vo.mongo.KylinPerformanceVo; import com.liquidnet.service.kylin.dto.vo.mongo.KylinPerformanceVo;
...@@ -99,14 +100,14 @@ public class AdamCollectionServiceImpl implements IAdamCollectionService { ...@@ -99,14 +100,14 @@ public class AdamCollectionServiceImpl implements IAdamCollectionService {
} }
@Override @Override
public PageInfo<AdamCollectVo> queryPage(String uid, String type, int pageNo, int pageSize) { public PagedResult<AdamCollectVo> queryPage(String uid, String type, int pageNo, int pageSize) {
Query query = Query.query(Criteria.where("uid").is(uid).and("type").is(type).and("state").is(1)); Query query = Query.query(Criteria.where("uid").is(uid).and("type").is(type).and("state").is(1));
long s = System.currentTimeMillis(); long s = System.currentTimeMillis();
long count = mongoTemplate.count(query, AdamCollectBaseVo.class.getSimpleName()); long count = mongoTemplate.count(query, AdamCollectBaseVo.class.getSimpleName());
log.debug("#MDB耗时:{}ms", System.currentTimeMillis() - s); log.debug("#MDB耗时:{}ms", System.currentTimeMillis() - s);
PageInfo<AdamCollectVo> voPageInfo = null; PagedResult<AdamCollectVo> pagedResult = ObjectUtil.getAdamCollectVoPagedResult();
if (count > 0) { if (count > 0) {
Pageable pageable = PageRequest.of(pageNo - 1, pageSize, Sort.by(Sort.Direction.DESC, "createdAt")); Pageable pageable = PageRequest.of(pageNo - 1, pageSize, Sort.by(Sort.Direction.DESC, "createdAt"));
...@@ -164,12 +165,9 @@ public class AdamCollectionServiceImpl implements IAdamCollectionService { ...@@ -164,12 +165,9 @@ public class AdamCollectionServiceImpl implements IAdamCollectionService {
log.debug("#COL.RDS.K耗时:{}ms", System.currentTimeMillis() - s); log.debug("#COL.RDS.K耗时:{}ms", System.currentTimeMillis() - s);
} }
voPageInfo = PageInfo.of(collectVoList); pagedResult.setList(collectVoList).setTotal(count, pageSize);
voPageInfo.setTotal(count);
} else {
voPageInfo = new PageInfo<>();
} }
return voPageInfo; return pagedResult;
} }
} }
package com.liquidnet.service.adam.service.impl; package com.liquidnet.service.adam.service.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.github.pagehelper.PageInfo;
import com.liquidnet.commons.lang.util.CollectionUtil; import com.liquidnet.commons.lang.util.CollectionUtil;
import com.liquidnet.service.adam.dto.vo.AdamCollectInfoVo; import com.liquidnet.service.adam.dto.vo.AdamCollectInfoVo;
import com.liquidnet.service.adam.dto.vo.AdamDisposedBaseVo; import com.liquidnet.service.adam.dto.vo.AdamDisposedBaseVo;
import com.liquidnet.service.adam.dto.vo.AdamDisposedUserVo; import com.liquidnet.service.adam.dto.vo.AdamDisposedUserVo;
import com.liquidnet.service.adam.dto.vo.AdamDisposedVo; import com.liquidnet.service.adam.dto.vo.AdamDisposedVo;
import com.liquidnet.service.adam.entity.AdamDisposed;
import com.liquidnet.service.adam.mapper.AdamDisposedMapper;
import com.liquidnet.service.adam.service.AdamRdmService; import com.liquidnet.service.adam.service.AdamRdmService;
import com.liquidnet.service.adam.service.IAdamDisposedService; import com.liquidnet.service.adam.service.IAdamDisposedService;
import com.liquidnet.service.adam.util.ObjectUtil;
import com.liquidnet.service.adam.util.QueueUtils; import com.liquidnet.service.adam.util.QueueUtils;
import com.liquidnet.service.base.PagedResult;
import com.liquidnet.service.base.SqlMapping; import com.liquidnet.service.base.SqlMapping;
import com.liquidnet.service.base.constant.MQConst; import com.liquidnet.service.base.constant.MQConst;
import com.liquidnet.service.kylin.dto.vo.mongo.KylinPerformanceVo; import com.liquidnet.service.kylin.dto.vo.mongo.KylinPerformanceVo;
...@@ -107,14 +105,14 @@ public class AdamDisposedServiceImpl implements IAdamDisposedService { ...@@ -107,14 +105,14 @@ public class AdamDisposedServiceImpl implements IAdamDisposedService {
} }
@Override @Override
public PageInfo<AdamDisposedVo> queryPage(String uid, String type, int pageNo, int pageSize) { public PagedResult<AdamDisposedVo> queryPage(String uid, String type, int pageNo, int pageSize) {
Query query = Query.query(Criteria.where("uid").is(uid).and("type").is(type).and("state").is(1)); Query query = Query.query(Criteria.where("uid").is(uid).and("type").is(type).and("state").is(1));
long s = System.currentTimeMillis(); long s = System.currentTimeMillis();
long count = mongoTemplate.count(query, AdamDisposedBaseVo.class.getSimpleName()); long count = mongoTemplate.count(query, AdamDisposedBaseVo.class.getSimpleName());
log.debug("#MDB耗时:{}ms", System.currentTimeMillis() - s); log.debug("#MDB耗时:{}ms", System.currentTimeMillis() - s);
PageInfo<AdamDisposedVo> voPageInfo = null; PagedResult<AdamDisposedVo> pagedResult = ObjectUtil.getAdamDisposedVoPagedResult();
if (count > 0) { if (count > 0) {
query.with(PageRequest.of(pageNo - 1, pageSize, Sort.by(Sort.Direction.DESC, "createdAt"))); query.with(PageRequest.of(pageNo - 1, pageSize, Sort.by(Sort.Direction.DESC, "createdAt")));
...@@ -179,30 +177,27 @@ public class AdamDisposedServiceImpl implements IAdamDisposedService { ...@@ -179,30 +177,27 @@ public class AdamDisposedServiceImpl implements IAdamDisposedService {
vo.setIsAdvance(performanceVo.getIsAdvance()); vo.setIsAdvance(performanceVo.getIsAdvance());
} }
r.setContentInfo(vo); r.setContentInfo(vo);
PageInfo<AdamDisposedUserVo> disposedUserVoPageInfo = this.queryDisposedUsers(type, r.getContentId(), 1, 3); PagedResult<AdamDisposedUserVo> disposedUserVoPagedResult = this.queryDisposedUsers(type, r.getContentId(), 1, 3);
if (disposedUserVoPageInfo.getTotal() > 0) r.setUserVos(disposedUserVoPageInfo.getList()); if (disposedUserVoPagedResult.getTotal() > 0) r.setUserVos(disposedUserVoPagedResult.getList());
}); });
log.debug("#DIS.RDS.MDB.K耗时:{}ms", System.currentTimeMillis() - s); log.debug("#DIS.RDS.MDB.K耗时:{}ms", System.currentTimeMillis() - s);
} }
voPageInfo = PageInfo.of(disposedVoList); pagedResult.setList(disposedVoList).setTotal(count, pageSize);
voPageInfo.setTotal(count);
} else {
voPageInfo = new PageInfo<>();
} }
return voPageInfo; return pagedResult;
} }
@Override @Override
public PageInfo<AdamDisposedUserVo> queryDisposedUsers(String type, String contentId, int pageNo, int pageSize) { public PagedResult<AdamDisposedUserVo> queryDisposedUsers(String type, String contentId, int pageNo, int pageSize) {
Query query = Query.query(Criteria.where("type").is(type).and("contentId").is(contentId).and("state").is(1)); Query query = Query.query(Criteria.where("type").is(type).and("contentId").is(contentId).and("state").is(1));
long s = System.currentTimeMillis(); long s = System.currentTimeMillis();
long count = mongoTemplate.count(query, AdamDisposedBaseVo.class.getSimpleName()); long count = mongoTemplate.count(query, AdamDisposedBaseVo.class.getSimpleName());
log.debug("#MDB耗时:{}ms", System.currentTimeMillis() - s); log.debug("#MDB耗时:{}ms", System.currentTimeMillis() - s);
PageInfo<AdamDisposedUserVo> voPageInfo = null; PagedResult<AdamDisposedUserVo> pagedResult = ObjectUtil.getAdamDisposedUserVoPagedResult();
if (count > 0) { if (count > 0) {
query.with(PageRequest.of(pageNo - 1, pageSize, Sort.by(Sort.Direction.DESC, "createdAt"))); query.with(PageRequest.of(pageNo - 1, pageSize, Sort.by(Sort.Direction.DESC, "createdAt")));
...@@ -210,11 +205,8 @@ public class AdamDisposedServiceImpl implements IAdamDisposedService { ...@@ -210,11 +205,8 @@ public class AdamDisposedServiceImpl implements IAdamDisposedService {
List<AdamDisposedUserVo> disposedUserVoList = mongoTemplate.find(query, AdamDisposedUserVo.class, AdamDisposedBaseVo.class.getSimpleName()); List<AdamDisposedUserVo> disposedUserVoList = mongoTemplate.find(query, AdamDisposedUserVo.class, AdamDisposedBaseVo.class.getSimpleName());
log.debug("#MDB耗时:{}ms", System.currentTimeMillis() - s); log.debug("#MDB耗时:{}ms", System.currentTimeMillis() - s);
voPageInfo = PageInfo.of(disposedUserVoList); pagedResult.setList(disposedUserVoList).setTotal(count, pageSize);
voPageInfo.setTotal(count);
} else {
voPageInfo = new PageInfo<>();
} }
return voPageInfo; return pagedResult;
} }
} }
package com.liquidnet.service.adam.service.impl; package com.liquidnet.service.adam.service.impl;
import com.fasterxml.jackson.databind.JsonNode; import com.fasterxml.jackson.databind.JsonNode;
import com.github.pagehelper.PageInfo;
import com.liquidnet.commons.lang.util.*; import com.liquidnet.commons.lang.util.*;
import com.liquidnet.service.adam.dto.AdamMemberOrderCallbackParam; import com.liquidnet.service.adam.dto.AdamMemberOrderCallbackParam;
import com.liquidnet.service.adam.dto.AdamMemberOrderCodeParam; import com.liquidnet.service.adam.dto.AdamMemberOrderCodeParam;
...@@ -12,8 +11,10 @@ import com.liquidnet.service.adam.service.AdamRdmService; ...@@ -12,8 +11,10 @@ import com.liquidnet.service.adam.service.AdamRdmService;
import com.liquidnet.service.adam.service.IAdamMemberOrderService; import com.liquidnet.service.adam.service.IAdamMemberOrderService;
import com.liquidnet.service.adam.service.IAdamUserMemberService; import com.liquidnet.service.adam.service.IAdamUserMemberService;
import com.liquidnet.service.adam.util.MemberUtil; import com.liquidnet.service.adam.util.MemberUtil;
import com.liquidnet.service.adam.util.ObjectUtil;
import com.liquidnet.service.adam.util.QueueUtils; import com.liquidnet.service.adam.util.QueueUtils;
import com.liquidnet.service.base.ErrorMapping; import com.liquidnet.service.base.ErrorMapping;
import com.liquidnet.service.base.PagedResult;
import com.liquidnet.service.base.ResponseDto; import com.liquidnet.service.base.ResponseDto;
import com.liquidnet.service.base.SqlMapping; import com.liquidnet.service.base.SqlMapping;
import com.liquidnet.service.base.constant.MQConst; import com.liquidnet.service.base.constant.MQConst;
...@@ -35,7 +36,6 @@ import java.time.LocalDateTime; ...@@ -35,7 +36,6 @@ import java.time.LocalDateTime;
import java.time.LocalTime; import java.time.LocalTime;
import java.util.LinkedList; import java.util.LinkedList;
import java.util.List; import java.util.List;
import java.util.Map;
@Slf4j @Slf4j
@Service @Service
...@@ -117,7 +117,7 @@ public class AdamMemberOrderServiceImpl implements IAdamMemberOrderService { ...@@ -117,7 +117,7 @@ public class AdamMemberOrderServiceImpl implements IAdamMemberOrderService {
payParam.add("expireTime", "5");// 过期时间,单位分钟,默认5 payParam.add("expireTime", "5");// 过期时间,单位分钟,默认5
// 生成订单信息 // 生成订单信息
AdamMemberOrderVo memberOrderVo = new AdamMemberOrderVo(); AdamMemberOrderVo memberOrderVo = AdamMemberOrderVo.getNew();
memberOrderVo.setOrderNo(orderNo); memberOrderVo.setOrderNo(orderNo);
memberOrderVo.setMemberId(param.getMemberId()); memberOrderVo.setMemberId(param.getMemberId());
memberOrderVo.setDays(memberPriceVo.getDays()); memberOrderVo.setDays(memberPriceVo.getDays());
...@@ -435,12 +435,12 @@ public class AdamMemberOrderServiceImpl implements IAdamMemberOrderService { ...@@ -435,12 +435,12 @@ public class AdamMemberOrderServiceImpl implements IAdamMemberOrderService {
} }
@Override @Override
public PageInfo<AdamMemberOrderSimpleVo> queryPage(String uid, int pageNo, int pageSize) { public PagedResult<AdamMemberOrderSimpleVo> queryPage(String uid, int pageNo, int pageSize) {
Query query = Query.query(Criteria.where("uid").is(uid).and("state").in(1,5)); Query query = Query.query(Criteria.where("uid").is(uid).and("state").in(1,5));
long count = mongoTemplate.count(query, AdamMemberOrderVo.class.getSimpleName()); long count = mongoTemplate.count(query, AdamMemberOrderVo.class.getSimpleName());
PageInfo<AdamMemberOrderSimpleVo> pageInfo = null; PagedResult<AdamMemberOrderSimpleVo> pagedResult = ObjectUtil.getAdamMemberOrderSimpleVoPagedResult();
if (count > 0) { if (count > 0) {
query.with(PageRequest.of(pageNo - 1, pageSize, Sort.by(Sort.Direction.DESC, "createdAt"))); query.with(PageRequest.of(pageNo - 1, pageSize, Sort.by(Sort.Direction.DESC, "createdAt")));
...@@ -448,11 +448,8 @@ public class AdamMemberOrderServiceImpl implements IAdamMemberOrderService { ...@@ -448,11 +448,8 @@ public class AdamMemberOrderServiceImpl implements IAdamMemberOrderService {
query, AdamMemberOrderSimpleVo.class, AdamMemberOrderVo.class.getSimpleName() query, AdamMemberOrderSimpleVo.class, AdamMemberOrderVo.class.getSimpleName()
); );
pageInfo = PageInfo.of(voList); pagedResult.setList(voList).setTotal(count, pageSize);
pageInfo.setTotal(count);
} else {
pageInfo = new PageInfo<>();
} }
return pageInfo; return pagedResult;
} }
} }
package com.liquidnet.service.adam.util;
import com.liquidnet.service.adam.dto.vo.*;
import com.liquidnet.service.base.PagedResult;
import java.util.ArrayList;
import java.util.List;
public class ObjectUtil {
private static final ArrayList<AdamTagParentVo> adamTagParentVoArrayList = new ArrayList<>();
private static final ArrayList<AdamTagVo> adamTagVoArrayList = new ArrayList<>();
private static final PagedResult<AdamCollectVo> adamCollectVoPagedResult = new PagedResult<>();
private static final PagedResult<AdamMemberOrderSimpleVo> adamMemberOrderSimpleVoPagedResult = new PagedResult<>();
private static final PagedResult<AdamDisposedVo> adamDisposedVoPagedResult = new PagedResult<>();
private static final PagedResult<AdamDisposedUserVo> adamDisposedUserVoPagedResult = new PagedResult<>();
public static List<AdamTagParentVo> getAdamTagParentVoArrayList() {
return (List<AdamTagParentVo>) adamTagParentVoArrayList.clone();
}
public static List<AdamTagVo> getAdamTagVoArrayList() {
return (List<AdamTagVo>) adamTagVoArrayList.clone();
}
public static PagedResult<AdamCollectVo> getAdamCollectVoPagedResult() {
return adamCollectVoPagedResult.clone();
}
public static PagedResult<AdamMemberOrderSimpleVo> getAdamMemberOrderSimpleVoPagedResult() {
return adamMemberOrderSimpleVoPagedResult.clone();
}
public static PagedResult<AdamDisposedVo> getAdamDisposedVoPagedResult() {
return adamDisposedVoPagedResult.clone();
}
public static PagedResult<AdamDisposedUserVo> getAdamDisposedUserVoPagedResult() {
return adamDisposedUserVoPagedResult.clone();
}
}
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