|
|
@@ -1,6 +1,7 @@
|
|
|
package shop.alien.store.service.impl;
|
|
|
|
|
|
import cn.hutool.core.bean.BeanUtil;
|
|
|
+import com.alibaba.fastjson2.JSONObject;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
|
|
@@ -12,16 +13,16 @@ import lombok.extern.slf4j.Slf4j;
|
|
|
import org.apache.commons.lang3.StringUtils;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
|
-import com.alibaba.fastjson2.JSONObject;
|
|
|
import shop.alien.entity.store.*;
|
|
|
import shop.alien.entity.store.vo.StoreClockInVo;
|
|
|
import shop.alien.entity.store.vo.WebSocketVo;
|
|
|
import shop.alien.mapper.*;
|
|
|
import shop.alien.store.config.WebSocketProcess;
|
|
|
+import shop.alien.store.service.CommonCommentService;
|
|
|
import shop.alien.store.service.StoreClockInService;
|
|
|
import shop.alien.store.service.StoreCommentService;
|
|
|
import shop.alien.store.util.ai.AiContentModerationUtil;
|
|
|
-import shop.alien.store.util.ai.AiVideoModerationUtil;
|
|
|
+import shop.alien.util.common.constant.CommentSourceTypeEnum;
|
|
|
|
|
|
import javax.annotation.PostConstruct;
|
|
|
import javax.annotation.PreDestroy;
|
|
|
@@ -66,6 +67,8 @@ public class StoreClockInServiceImpl extends ServiceImpl<StoreClockInMapper, Sto
|
|
|
|
|
|
private final LifeNoticeMapper lifeNoticeMapper;
|
|
|
|
|
|
+ private final CommonCommentService commonCommentService;
|
|
|
+
|
|
|
private final WebSocketProcess webSocketProcess;
|
|
|
|
|
|
// 初始化线程池
|
|
|
@@ -253,7 +256,8 @@ public class StoreClockInServiceImpl extends ServiceImpl<StoreClockInMapper, Sto
|
|
|
// vo.setClockInStoreNum(clockInStoreNumMap.get(vo.getStoreId()));
|
|
|
// // 打卡次数
|
|
|
// vo.setClockInNum(clockInNum);
|
|
|
- vo.setCommentCount(Integer.parseInt(storeCommentService.getCommitCountAndScore(vo.getId(), 4, vo.getStoreId(),null,null).get("commitCount").toString()));
|
|
|
+ Map<String, Object> commitCount = commonCommentService.getCommitCount(vo.getId(), CommentSourceTypeEnum.CLOCK_IN_COMMENT.getType(), userId.toString(), null);
|
|
|
+ vo.setCommentCount(Integer.parseInt(commitCount.get("commentCount").toString()));
|
|
|
if(Arrays.asList("酒吧", "KTV", "洗浴汗蒸", "按摩足疗").contains(vo.getBusinessSectionName())){
|
|
|
vo.setStoreTypeNew(1);
|
|
|
} else if (Arrays.asList("丽人美发", "运动健身").contains(vo.getBusinessSectionName())){
|