|
|
@@ -619,9 +619,11 @@ public class LifeUserDynamicsService extends ServiceImpl<LifeUserDynamicsMapper,
|
|
|
lifeUserExpertWorksMapper.updateById(lifeUserExpertWorks);
|
|
|
}
|
|
|
|
|
|
- LifeUserExpertOrder lifeUserExpertOrder = lifeUserExpertOrderMapper.selectOne(new LambdaQueryWrapper<LifeUserExpertOrder>()
|
|
|
- .eq(LifeUserExpertOrder::getId, expertOrderId)
|
|
|
- .eq(LifeUserExpertOrder::getDeleteFlag, 0));
|
|
|
+ LambdaQueryWrapper<LifeUserExpertOrder> lifeUserExpertOrderLambdaQueryWrapper = new LambdaQueryWrapper<>();
|
|
|
+ lifeUserExpertOrderLambdaQueryWrapper.eq(LifeUserExpertOrder::getId, expertOrderId);
|
|
|
+ lifeUserExpertOrderLambdaQueryWrapper.eq(LifeUserExpertOrder::getDeleteFlag, 0);
|
|
|
+ LifeUserExpertOrder lifeUserExpertOrder = lifeUserExpertOrderMapper.selectOne(lifeUserExpertOrderLambdaQueryWrapper);
|
|
|
+
|
|
|
//查询达人购买商户订单状态不是已完成
|
|
|
//判断达人动态浏览数和gmv 是否达到达人设置的限定值
|
|
|
if (lifeUserExpertOrder != null && lifeUserExpertOrder.getStatus() != 5) {
|
|
|
@@ -634,7 +636,8 @@ public class LifeUserDynamicsService extends ServiceImpl<LifeUserDynamicsMapper,
|
|
|
.eq(LifeUserDynamics::getId, dynamicsId)
|
|
|
.eq(LifeUserDynamics::getDeleteFlag, 0));
|
|
|
if (lifeUserDynamics != null) {
|
|
|
- if (lifeUserExpertWorks1.getOrderGmv().compareTo(lifeUserExpertOrder.getOrderGmv()) >= 0 && lifeUserDynamics.getLiulanCount() >= lifeUserExpertOrder.getOrderPlayCount()) {
|
|
|
+ if (lifeUserExpertWorks1.getOrderGmv().compareTo(lifeUserExpertOrder.getOrderGmv()) >= 0
|
|
|
+ && lifeUserDynamics.getLiulanCount() >= lifeUserExpertOrder.getOrderPlayCount()) {
|
|
|
lifeUserExpertOrder.setStatus(5);
|
|
|
lifeUserExpertOrderMapper.updateById(lifeUserExpertOrder);
|
|
|
}
|
|
|
@@ -650,12 +653,15 @@ public class LifeUserDynamicsService extends ServiceImpl<LifeUserDynamicsMapper,
|
|
|
}
|
|
|
|
|
|
public boolean addUserStoreBrowseNumber(LifeBrowseRecord lifeBrowseRecord) {
|
|
|
+ // 浏览数
|
|
|
int liulanNum = 0;
|
|
|
+
|
|
|
// 1.处理当天浏览记录(去重插入)
|
|
|
handleTodayBrowseRecord(lifeBrowseRecord);
|
|
|
|
|
|
// 2.更新动态浏览统计数据并获取浏览数
|
|
|
LifeUserDynamics lifeUserDynamics = lifeUserDynamicsMapper.selectById(lifeBrowseRecord.getDynamicsId());
|
|
|
+
|
|
|
if (lifeUserDynamics == null) {
|
|
|
return false;
|
|
|
}
|
|
|
@@ -667,11 +673,14 @@ public class LifeUserDynamicsService extends ServiceImpl<LifeUserDynamicsMapper,
|
|
|
.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())
|
|
|
+ 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()) {
|
|
|
+ if (lifeUserExpertWorks.getOrderGmv().compareTo(lifeUserExpertOrder.getOrderGmv()) >= 0
|
|
|
+ && liulanNum >= lifeUserExpertOrder.getOrderPlayCount()) {
|
|
|
lifeUserExpertOrder.setStatus(5);
|
|
|
lifeUserExpertOrderMapper.updateById(lifeUserExpertOrder);
|
|
|
}
|
|
|
@@ -686,9 +695,11 @@ public class LifeUserDynamicsService extends ServiceImpl<LifeUserDynamicsMapper,
|
|
|
private void handleTodayBrowseRecord(LifeBrowseRecord lifeBrowseRecord) {
|
|
|
// 获取当天开始时间(00:00:00)
|
|
|
LocalDateTime todayStart = LocalDateTime.of(LocalDate.now(), LocalTime.MIN);
|
|
|
+
|
|
|
// 获取当天结束时间(23:59:59.999)
|
|
|
LocalDateTime todayEnd = LocalDateTime.of(LocalDate.now(), LocalTime.MAX);
|
|
|
|
|
|
+ //封装查询当天浏览记录参数
|
|
|
LifeBrowseRecord existingRecord = lifeBrowseRecordMapper.selectOne(
|
|
|
new LambdaQueryWrapper<LifeBrowseRecord>()
|
|
|
.eq(LifeBrowseRecord::getUserId, lifeBrowseRecord.getUserId())
|
|
|
@@ -699,9 +710,11 @@ public class LifeUserDynamicsService extends ServiceImpl<LifeUserDynamicsMapper,
|
|
|
.eq(LifeBrowseRecord::getDynamicsType, lifeBrowseRecord.getDynamicsType())
|
|
|
);
|
|
|
|
|
|
+ //当天没有记录则插入一条
|
|
|
if (existingRecord == 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);
|
|
|
@@ -714,11 +727,15 @@ public class LifeUserDynamicsService extends ServiceImpl<LifeUserDynamicsMapper,
|
|
|
* @return 正常浏览数,用于后续订单状态判断
|
|
|
*/
|
|
|
private int updateDynamicsBrowseCount(LifeBrowseRecord lifeBrowseRecord, LifeUserDynamics lifeUserDynamics) {
|
|
|
+ //动态id
|
|
|
String dynamicsId = lifeBrowseRecord.getDynamicsId();
|
|
|
+
|
|
|
+ //达人订单id
|
|
|
String orderId = lifeBrowseRecord.getOrderId();
|
|
|
|
|
|
// 更新正常浏览数
|
|
|
int liulanNum = lifeBrowseRecordMapper.getCountBrowseNum(dynamicsId, orderId, 0);
|
|
|
+ //浏览记录表浏览数 > 动态浏览数 更新动态浏览数
|
|
|
if (liulanNum > lifeUserDynamics.getLiulanCount()) {
|
|
|
LambdaUpdateWrapper<LifeUserDynamics> updateWrapper = new LambdaUpdateWrapper<>();
|
|
|
updateWrapper.eq(LifeUserDynamics::getId, dynamicsId)
|
|
|
@@ -728,6 +745,7 @@ public class LifeUserDynamicsService extends ServiceImpl<LifeUserDynamicsMapper,
|
|
|
|
|
|
// 更新停留三秒浏览数
|
|
|
int threeSecondsNum = lifeBrowseRecordMapper.getCountBrowseNum(dynamicsId, orderId, 1);
|
|
|
+ //浏览记录表停留三秒浏览数 > 动态浏览数 更新动态停留三秒浏览数
|
|
|
if (threeSecondsNum > lifeUserDynamics.getRealityCount()) {
|
|
|
LambdaUpdateWrapper<LifeUserDynamics> updateWrapper = new LambdaUpdateWrapper<>();
|
|
|
updateWrapper.eq(LifeUserDynamics::getId, dynamicsId)
|