代码优化

alien-entity/src/main/java/shop/alien/mapper/LifeBrowseRecordMapper.java

@@ -1,7 +1,9 @@
 package shop.alien.mapper;
 
+import com.baomidou.mybatisplus.annotation.SqlParser;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
 import org.apache.ibatis.annotations.Select;
 import shop.alien.entity.store.LifeBrowseRecord;
 
@@ -37,4 +39,16 @@ public interface LifeBrowseRecordMapper extends BaseMapper<LifeBrowseRecord> {
             "where lbr.user_id = #{userId} and lbr.dynamics_id is not null\n" +
             "Order by lbr.liulan_time desc")
     List<Map<String, Object>> getDynamicsBrowseRecordByUserId(String userId);
+
+    @SqlParser(filter = true)
+    @Select("SELECT\n" +
+            "\tCOUNT( 1 ) \n" +
+            "FROM\n" +
+            "\tlife_browse_record \n" +
+            "WHERE\n" +
+            "\tdynamics_id = #{dynamicsId} \n" +
+            "\tAND order_id = #{orderId} \n" +
+            "\tAND delete_flag IN ( 0, 1 ) \n" +
+            "\tAND dynamics_type = #{dynamicsType}")
+    int getCountBrowseNum(@Param("dynamicsId") String dynamicsId,@Param("orderId") String orderId, @Param("dynamicsType")int dynamicsType);
 }

alien-store/src/main/java/shop/alien/store/service/LifeUserDynamicsService.java

@@ -670,9 +670,7 @@ public class LifeUserDynamicsService extends ServiceImpl<LifeUserDynamicsMapper,
         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));
+            liulanNum = lifeBrowseRecordMapper.getCountBrowseNum(lifeBrowseRecord.getDynamicsId(),lifeBrowseRecord.getOrderId(),0);
             if (liulanNum > lifeUserDynamics.getLiulanCount()) {
                 LambdaUpdateWrapper<LifeUserDynamics> lambdaUpdateWrapper = new LambdaUpdateWrapper<>();
                 lambdaUpdateWrapper.eq(LifeUserDynamics::getId, lifeBrowseRecord.getDynamicsId());
@@ -680,9 +678,7 @@ public class LifeUserDynamicsService extends ServiceImpl<LifeUserDynamicsMapper,
                 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));
+            threeSecondsNum = lifeBrowseRecordMapper.getCountBrowseNum(lifeBrowseRecord.getDynamicsId(),lifeBrowseRecord.getOrderId(),1);
             if (threeSecondsNum > lifeUserDynamics.getRealityCount()) {
                 LambdaUpdateWrapper<LifeUserDynamics> lambdaUpdateWrapper = new LambdaUpdateWrapper<>();
                 lambdaUpdateWrapper.eq(LifeUserDynamics::getId, lifeBrowseRecord.getDynamicsId());