package com.mzl.flower.service.customer;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.mzl.flower.config.exception.ValidationException;
import com.mzl.flower.config.security.SecurityUtils;
import com.mzl.flower.entity.customer.BrowseHistory;
import com.mzl.flower.mapper.customer.BrowseHistoryMapper;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.List;

@Service
@Transactional
@Slf4j
public class BrowseService {

    private final BrowseHistoryMapper browseHistoryMapper;

    public BrowseService(BrowseHistoryMapper browseHistoryMapper) {
        this.browseHistoryMapper = browseHistoryMapper;
    }

    @Async
    public synchronized void addBrowseHistory(String userId, Long flowerId) {
        try {
            if (flowerId == null || flowerId == 0) {
                //throw new ValidationException("鲜花商品ID不能为空");
                return;
            }
            // 添加浏览记录逻辑
            List<BrowseHistory> historyList = browseHistoryMapper.selectList(new QueryWrapper<BrowseHistory>()
                    .eq("user_id", userId)
                    .eq("flower_id", flowerId)
                    .orderByDesc("browse_count")
            );
            BrowseHistory history = null;
            if (historyList != null && historyList.size() > 0) {
                history = historyList.get(0);
                for (int i = 1; i < historyList.size(); i++) {
                    BrowseHistory h = historyList.get(i);
                    history.setBrowseCount(history.getBrowseCount() + h.getBrowseCount());
                    browseHistoryMapper.deleteById(h.getId());
                }
            }

            if (history == null) {
                history = new BrowseHistory();
                history.setUserId(userId);
                history.setFlowerId(flowerId);
                history.setBrowseCount(1);
                history.create(userId);
                browseHistoryMapper.insert(history);
            } else {
                history.update(userId);
                history.setBrowseCount(history.getBrowseCount() + 1);
                browseHistoryMapper.updateById(history);
            }
        } catch (Exception e) {
            log.error(e.getMessage(), e);
        }
    }
}