|
|
@@ -131,6 +131,10 @@ public class LifeUserDynamicsService extends ServiceImpl<LifeUserDynamicsMapper,
|
|
|
return this.removeById(id);
|
|
|
}
|
|
|
|
|
|
+ public LifeUserDynamics getDynamicsById(int id){
|
|
|
+ return this.getById(id);
|
|
|
+ }
|
|
|
+
|
|
|
public Map<String, List<LifePinglunVo>> getUserDynamicsCommentById(String id) {
|
|
|
LambdaUpdateWrapper<LifeComment> wrapper = new LambdaUpdateWrapper<>();
|
|
|
wrapper.orderByDesc(LifeComment::getPinglunTime);
|
|
|
@@ -517,8 +521,8 @@ public class LifeUserDynamicsService extends ServiceImpl<LifeUserDynamicsMapper,
|
|
|
targetPhone = myStoreUser.getPhone();
|
|
|
}
|
|
|
|
|
|
- Integer myType ;
|
|
|
- Integer myId ;
|
|
|
+ Integer myType;
|
|
|
+ Integer myId;
|
|
|
if (myLifeUser != null && myLifeUser.getId() != null) {
|
|
|
// 我是用户(类型1)
|
|
|
myType = 1;
|
|
|
@@ -545,14 +549,14 @@ public class LifeUserDynamicsService extends ServiceImpl<LifeUserDynamicsMapper,
|
|
|
blacklist.getBlockerPhoneId()
|
|
|
).filter(Objects::nonNull)) // 过滤null
|
|
|
.collect(Collectors.toSet());
|
|
|
- if (!CollectionUtils.isEmpty(lifeUserDynamicsVos)){
|
|
|
+ if (!CollectionUtils.isEmpty(lifeUserDynamicsVos)) {
|
|
|
for (LifeUserDynamicsVo lifeUserDynamicsVo : lifeUserDynamicsVos) {
|
|
|
- if(combinedSet.contains(lifeUserDynamicsVo.getPhoneId())){
|
|
|
+ if (combinedSet.contains(lifeUserDynamicsVo.getPhoneId())) {
|
|
|
continue;
|
|
|
}
|
|
|
- if (lifeUserDynamicsVo.getType().equals("2")){
|
|
|
+ if (lifeUserDynamicsVo.getType().equals("2")) {
|
|
|
String phoneIdNew = lifeUserDynamicsVo.getPhoneId().substring(6);
|
|
|
- StoreInfo storeInfo=storeInfoMapper.getStoreNameByPhone(phoneIdNew);
|
|
|
+ StoreInfo storeInfo = storeInfoMapper.getStoreNameByPhone(phoneIdNew);
|
|
|
lifeUserDynamicsVo.setStoreName(storeInfo.getStoreName());
|
|
|
} else if (lifeUserDynamicsVo.getType().equals("1")) {
|
|
|
String phoneIdNew = lifeUserDynamicsVo.getPhoneId().substring(5);
|
|
|
@@ -562,7 +566,7 @@ public class LifeUserDynamicsService extends ServiceImpl<LifeUserDynamicsMapper,
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
- return lifeUserDynamicsVos;
|
|
|
+ return lifeUserDynamicsVos;
|
|
|
}
|
|
|
|
|
|
public List<LifeUserDynamicsVo> getDynamicsList(Integer page, Integer size, String nickName, String userType, Integer dynamicsType, String releaseStartTime, String releaseEndTime) {
|
|
|
@@ -574,10 +578,10 @@ public class LifeUserDynamicsService extends ServiceImpl<LifeUserDynamicsMapper,
|
|
|
// 查询动态数据并按类型过滤
|
|
|
LifeUserDynamicsVo lifeUserDynamicsVo = new LifeUserDynamicsVo();
|
|
|
List<LifeUserDynamicsVo> lifeUserDynamicsVoList = lifeUserDynamicsMapper.getDynamicsDetail(id);
|
|
|
- if(!CollectionUtils.isEmpty(lifeUserDynamicsVoList)){
|
|
|
+ if (!CollectionUtils.isEmpty(lifeUserDynamicsVoList)) {
|
|
|
lifeUserDynamicsVo = lifeUserDynamicsVoList.get(0);
|
|
|
String imagePath = lifeUserDynamicsVo.getImagePath();
|
|
|
- if(!StringUtils.isEmpty(imagePath)){
|
|
|
+ if (!StringUtils.isEmpty(imagePath)) {
|
|
|
List<String> imagePathList = Arrays.asList(imagePath.split(","));
|
|
|
lifeUserDynamicsVo.setImagePathList(imagePathList);
|
|
|
}
|
|
|
@@ -600,34 +604,45 @@ public class LifeUserDynamicsService extends ServiceImpl<LifeUserDynamicsMapper,
|
|
|
return lifeUserDynamicsVo;
|
|
|
}
|
|
|
|
|
|
- @Transactional(rollbackFor = Exception.class)
|
|
|
- public R countGvm(Integer dynamicsId, String finalPrice, Integer orderId, Integer expertId, Integer expertOrderId) {
|
|
|
- LambdaQueryWrapper<LifeUserExpertWorks> lambdaQueryWrapper = new LambdaQueryWrapper<>();
|
|
|
- lambdaQueryWrapper.eq(LifeUserExpertWorks :: getExpertId, expertId);
|
|
|
- lambdaQueryWrapper.eq(LifeUserExpertWorks :: getOrderId, expertOrderId);
|
|
|
- lambdaQueryWrapper.eq(LifeUserExpertWorks :: getDynamicsId, dynamicsId);
|
|
|
- LifeUserExpertWorks lifeUserExpertWorks = lifeUserExpertWorksMapper.selectOne(lambdaQueryWrapper);
|
|
|
- if(lifeUserExpertWorks != null){
|
|
|
- BigDecimal price = new BigDecimal(finalPrice);
|
|
|
- lifeUserExpertWorks.setOrderGmv(lifeUserExpertWorks.getOrderGmv().add(price));
|
|
|
- lifeUserExpertWorksMapper.updateById(lifeUserExpertWorks);
|
|
|
- }
|
|
|
+
|
|
|
+ public R countGmv(Integer dynamicsId, String finalPrice, Integer orderId, Integer expertId, Integer expertOrderId) {
|
|
|
+ LambdaQueryWrapper<LifeUserExpertWorks> lambdaQueryWrapper = new LambdaQueryWrapper<>();
|
|
|
+ lambdaQueryWrapper.eq(LifeUserExpertWorks::getExpertId, expertId);
|
|
|
+ lambdaQueryWrapper.eq(LifeUserExpertWorks::getOrderId, expertOrderId);
|
|
|
+ lambdaQueryWrapper.eq(LifeUserExpertWorks::getDynamicsId, dynamicsId);
|
|
|
+ lambdaQueryWrapper.eq(LifeUserExpertWorks::getDeleteFlag, 0);
|
|
|
+ LifeUserExpertWorks lifeUserExpertWorks = lifeUserExpertWorksMapper.selectOne(lambdaQueryWrapper);
|
|
|
+ //用户购买订单 订单金额加入达人gmv中
|
|
|
+ if (lifeUserExpertWorks != null) {
|
|
|
+ BigDecimal price = new BigDecimal(finalPrice);
|
|
|
+ lifeUserExpertWorks.setOrderGmv(lifeUserExpertWorks.getOrderGmv().add(price));
|
|
|
+ lifeUserExpertWorksMapper.updateById(lifeUserExpertWorks);
|
|
|
+ }
|
|
|
|
|
|
LifeUserExpertOrder lifeUserExpertOrder = lifeUserExpertOrderMapper.selectOne(new LambdaQueryWrapper<LifeUserExpertOrder>()
|
|
|
- .eq(LifeUserExpertOrder::getId, expertOrderId));
|
|
|
+ .eq(LifeUserExpertOrder::getId, expertOrderId)
|
|
|
+ .eq(LifeUserExpertOrder::getDeleteFlag,0));
|
|
|
+ //查询达人购买商户订单状态不是已完成
|
|
|
+ //判断达人动态浏览数和gmv 是否达到达人设置的限定值
|
|
|
if (lifeUserExpertOrder != null && lifeUserExpertOrder.getStatus() != 5) {
|
|
|
LifeUserExpertWorks lifeUserExpertWorks1 = lifeUserExpertWorksMapper.selectOne(new LambdaQueryWrapper<LifeUserExpertWorks>()
|
|
|
- .eq(LifeUserExpertWorks :: getOrderId, expertOrderId)
|
|
|
- .eq(LifeUserExpertWorks :: getExpertId, expertId));
|
|
|
- int liulanNum = lifeBrowseRecordMapper.selectCount(new LambdaQueryWrapper<LifeBrowseRecord>()
|
|
|
- .eq(LifeBrowseRecord :: getDynamicsId, dynamicsId).eq(LifeBrowseRecord :: getOrderId, expertOrderId));
|
|
|
- if (lifeUserExpertWorks1.getOrderGmv().compareTo(lifeUserExpertOrder.getOrderGmv()) >= 0 && liulanNum >= lifeUserExpertOrder.getOrderPlayCount()) {
|
|
|
- lifeUserExpertOrder.setStatus(5);
|
|
|
- lifeUserExpertOrderMapper.updateById(lifeUserExpertOrder);
|
|
|
+ .eq(LifeUserExpertWorks::getOrderId, expertOrderId)
|
|
|
+ .eq(LifeUserExpertWorks::getExpertId, expertId)
|
|
|
+ .eq(LifeUserExpertWorks::getDynamicsId, dynamicsId)
|
|
|
+ .eq(LifeUserExpertWorks::getDeleteFlag, 0));
|
|
|
+ LifeUserDynamics lifeUserDynamics = lifeUserDynamicsMapper.selectOne(new LambdaQueryWrapper<LifeUserDynamics>()
|
|
|
+ .eq(LifeUserDynamics::getId, dynamicsId)
|
|
|
+ .eq(LifeUserDynamics::getDeleteFlag, 0));
|
|
|
+ if (lifeUserDynamics != null) {
|
|
|
+ if (lifeUserExpertWorks1.getOrderGmv().compareTo(lifeUserExpertOrder.getOrderGmv()) >= 0 && lifeUserDynamics.getLiulanCount() >= lifeUserExpertOrder.getOrderPlayCount()) {
|
|
|
+ lifeUserExpertOrder.setStatus(5);
|
|
|
+ lifeUserExpertOrderMapper.updateById(lifeUserExpertOrder);
|
|
|
+ }
|
|
|
}
|
|
|
}
|
|
|
+ //用户订单字段设置达人订单id 标识 该用户是从达人gmv链接进入购买订单的
|
|
|
LambdaQueryWrapper<LifeUserOrder> userOrderLambdaQueryWrapper = new LambdaQueryWrapper<>();
|
|
|
- userOrderLambdaQueryWrapper.eq(LifeUserOrder :: getId, orderId);
|
|
|
+ userOrderLambdaQueryWrapper.eq(LifeUserOrder::getId, orderId);
|
|
|
LifeUserOrder lifeUserOrder = lifeUserOrderMapper.selectOne(userOrderLambdaQueryWrapper);
|
|
|
lifeUserOrder.setExpertOrderId(expertOrderId);
|
|
|
lifeUserOrderMapper.updateById(lifeUserOrder);
|
|
|
@@ -635,39 +650,59 @@ public class LifeUserDynamicsService extends ServiceImpl<LifeUserDynamicsMapper,
|
|
|
}
|
|
|
|
|
|
public boolean addUserStoreBrowseNumber(LifeBrowseRecord lifeBrowseRecord) {
|
|
|
+ int liulanNum = 0;
|
|
|
+ int threeSecondsNum = 0;
|
|
|
// 获取当天开始时间(00:00:00)
|
|
|
LocalDateTime todayStart = LocalDateTime.of(LocalDate.now(), LocalTime.MIN);
|
|
|
// 获取当天结束时间(23:59:59.999)
|
|
|
LocalDateTime todayEnd = LocalDateTime.of(LocalDate.now(), LocalTime.MAX);
|
|
|
LifeBrowseRecord selectOne = lifeBrowseRecordMapper.selectOne(new LambdaQueryWrapper<LifeBrowseRecord>().eq(LifeBrowseRecord::getUserId, lifeBrowseRecord.getUserId())
|
|
|
.between(LifeBrowseRecord::getLiulanTime, todayStart, todayEnd).in(LifeBrowseRecord::getDeleteFlag, 0, 1).eq(LifeBrowseRecord::getDynamicsId, lifeBrowseRecord.getDynamicsId())
|
|
|
- .eq(LifeBrowseRecord::getOrderId, lifeBrowseRecord.getOrderId()));
|
|
|
+ .eq(LifeBrowseRecord::getOrderId, lifeBrowseRecord.getOrderId())
|
|
|
+ .eq(LifeBrowseRecord::getDynamicsType, lifeBrowseRecord.getDynamicsType()));
|
|
|
if (selectOne == null) {
|
|
|
lifeBrowseRecord.setCreatedTime(new DateTime());
|
|
|
lifeBrowseRecord.setLiulanTime(new DateTime());
|
|
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
|
|
|
lifeBrowseRecord.setLiulanDate(sdf.format(new Date()));
|
|
|
lifeBrowseRecordMapper.insert(lifeBrowseRecord);
|
|
|
- //查询当前达人动态进入店铺详情浏记录数
|
|
|
- int liulanNum = lifeBrowseRecordMapper.selectCount(new LambdaQueryWrapper<LifeBrowseRecord>().eq(LifeBrowseRecord :: getDynamicsId, lifeBrowseRecord.getDynamicsId())
|
|
|
- .eq(LifeBrowseRecord :: getOrderId, lifeBrowseRecord.getOrderId()).in(LifeBrowseRecord :: getDeleteFlag, 0, 1));
|
|
|
- LambdaUpdateWrapper<LifeUserExpertWorks> lambdaUpdateWrapper = new LambdaUpdateWrapper<>();
|
|
|
- lambdaUpdateWrapper.eq(LifeUserExpertWorks :: getId, lifeBrowseRecord.getDynamicsId());
|
|
|
- lambdaUpdateWrapper.set(LifeUserExpertWorks :: getPlayCount, liulanNum);
|
|
|
- lifeUserExpertWorksMapper.update(null,lambdaUpdateWrapper);
|
|
|
}
|
|
|
+ LifeUserDynamics lifeUserDynamics = lifeUserDynamicsMapper.selectById(lifeBrowseRecord.getDynamicsId());
|
|
|
+ if(lifeUserDynamics != null){
|
|
|
+ //查询达人动态正常浏览数
|
|
|
+ liulanNum = lifeBrowseRecordMapper.selectCount(new LambdaQueryWrapper<LifeBrowseRecord>().eq(LifeBrowseRecord::getDynamicsId, lifeBrowseRecord.getDynamicsId())
|
|
|
+ .eq(LifeBrowseRecord::getOrderId, lifeBrowseRecord.getOrderId()).in(LifeBrowseRecord::getDeleteFlag, 0, 1)
|
|
|
+ .eq(LifeBrowseRecord::getDynamicsType, 0));
|
|
|
+ if (liulanNum > lifeUserDynamics.getLiulanCount()) {
|
|
|
+ LambdaUpdateWrapper<LifeUserDynamics> lambdaUpdateWrapper = new LambdaUpdateWrapper<>();
|
|
|
+ lambdaUpdateWrapper.eq(LifeUserDynamics::getId, lifeBrowseRecord.getDynamicsId());
|
|
|
+ lambdaUpdateWrapper.set(LifeUserDynamics::getLiulanCount, liulanNum);
|
|
|
+ lifeUserDynamicsMapper.update(null, lambdaUpdateWrapper);
|
|
|
+ }
|
|
|
+ //查询达人动态停留三秒浏览数
|
|
|
+ threeSecondsNum = lifeBrowseRecordMapper.selectCount(new LambdaQueryWrapper<LifeBrowseRecord>().eq(LifeBrowseRecord::getDynamicsId, lifeBrowseRecord.getDynamicsId())
|
|
|
+ .eq(LifeBrowseRecord::getOrderId, lifeBrowseRecord.getOrderId()).in(LifeBrowseRecord::getDeleteFlag, 0, 1)
|
|
|
+ .eq(LifeBrowseRecord::getDynamicsType, 1));
|
|
|
+ if (threeSecondsNum > lifeUserDynamics.getRealityCount()) {
|
|
|
+ LambdaUpdateWrapper<LifeUserDynamics> lambdaUpdateWrapper = new LambdaUpdateWrapper<>();
|
|
|
+ lambdaUpdateWrapper.eq(LifeUserDynamics::getId, lifeBrowseRecord.getDynamicsId());
|
|
|
+ lambdaUpdateWrapper.set(LifeUserDynamics::getRealityCount, threeSecondsNum);
|
|
|
+ lifeUserDynamicsMapper.update(null, lambdaUpdateWrapper);
|
|
|
+ }
|
|
|
|
|
|
- //查询gmv和进店详情浏览数数是否满足当前达人订单规定值 都满足修改订单状态为已完成
|
|
|
- LifeUserExpertOrder lifeUserExpertOrder = lifeUserExpertOrderMapper.selectOne(new LambdaQueryWrapper<LifeUserExpertOrder>().eq(LifeUserExpertOrder::getId, lifeBrowseRecord.getOrderId()));
|
|
|
- if (lifeUserExpertOrder != null && lifeUserExpertOrder.getStatus() != 5) {
|
|
|
- int liulanNum = lifeBrowseRecordMapper.selectCount(new LambdaQueryWrapper<LifeBrowseRecord>().eq(LifeBrowseRecord :: getDynamicsId, lifeBrowseRecord.getDynamicsId())
|
|
|
- .eq(LifeBrowseRecord :: getOrderId, lifeBrowseRecord.getOrderId()));
|
|
|
- LifeUserExpertWorks lifeUserExpertWorks = lifeUserExpertWorksMapper.selectOne(new LambdaQueryWrapper<LifeUserExpertWorks>().eq(LifeUserExpertWorks :: getDynamicsId, lifeBrowseRecord.getDynamicsId())
|
|
|
- .eq(LifeUserExpertWorks :: getOrderId, lifeBrowseRecord.getOrderId()));
|
|
|
- if(lifeUserExpertWorks != null){
|
|
|
- if (lifeUserExpertWorks.getOrderGmv().compareTo(lifeUserExpertOrder.getOrderGmv()) >= 0 && liulanNum >= lifeUserExpertOrder.getOrderPlayCount()) {
|
|
|
- lifeUserExpertOrder.setStatus(5);
|
|
|
- lifeUserExpertOrderMapper.updateById(lifeUserExpertOrder);
|
|
|
+ //查询gmv和动态浏览数是否满足当前达人订单规定值 都满足修改订单状态为已完成
|
|
|
+ LifeUserExpertOrder lifeUserExpertOrder = lifeUserExpertOrderMapper.selectOne(new LambdaQueryWrapper<LifeUserExpertOrder>()
|
|
|
+ .eq(LifeUserExpertOrder::getId, lifeBrowseRecord.getOrderId())
|
|
|
+ .eq(LifeUserExpertOrder::getDeleteFlag, 0));
|
|
|
+ if (lifeUserExpertOrder != null && lifeUserExpertOrder.getStatus() != 5) {
|
|
|
+ LifeUserExpertWorks lifeUserExpertWorks = lifeUserExpertWorksMapper.selectOne(new LambdaQueryWrapper<LifeUserExpertWorks>().eq(LifeUserExpertWorks::getDynamicsId, lifeBrowseRecord.getDynamicsId())
|
|
|
+ .eq(LifeUserExpertWorks::getOrderId, lifeBrowseRecord.getOrderId())
|
|
|
+ .eq(LifeUserExpertWorks::getDeleteFlag, 0));
|
|
|
+ if (lifeUserExpertWorks != null) {
|
|
|
+ if (lifeUserExpertWorks.getOrderGmv().compareTo(lifeUserExpertOrder.getOrderGmv()) >= 0 && liulanNum >= lifeUserExpertOrder.getOrderPlayCount()) {
|
|
|
+ lifeUserExpertOrder.setStatus(5);
|
|
|
+ lifeUserExpertOrderMapper.updateById(lifeUserExpertOrder);
|
|
|
+ }
|
|
|
}
|
|
|
}
|
|
|
}
|