yhlxj/netflix-web/src/main/java/com/cyksj/web/controller/goods/GoodsDonController.java

package com.cyksj.web.controller.goods;

import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.date.DateTime;
import cn.hutool.core.date.DateUnit;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.RandomUtil;
import cn.hutool.core.util.StrUtil;
import cn.hutool.extra.servlet.ServletUtil;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.cyksj.common.constant.Constant;
import com.cyksj.common.i18n.I18nMessageUtil;
import com.cyksj.common.util.Jsons;
import com.cyksj.common.util.StringUtil;
import com.cyksj.dto.Result;
import com.cyksj.enums.GatewayResponse;
import com.cyksj.mapper.GoodsDonSkuMapper;
import com.cyksj.mapper.OrderDonMapper;
import com.cyksj.mapper.RegisterOrderDonMapper;
import com.cyksj.mapper.SysConfigMapper;
import com.cyksj.model.entity.*;
import com.cyksj.model.views.*;
import com.cyksj.redis.RedisService;
import com.ejlchina.searcher.BeanSearcher;
import com.ejlchina.searcher.SearchResult;
import com.ejlchina.searcher.param.Operator;
import com.ejlchina.searcher.util.MapBuilder;
import com.ejlchina.searcher.util.MapUtils;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.*;

import javax.servlet.http.HttpServletRequest;
import java.util.Date;
import java.util.List;
import java.util.Optional;

/**
 * @author chan
 * @date 2022/9/26 5:33 PM
 */
@Slf4j
@RestController
@RequestMapping("/applets/goods")
@RequiredArgsConstructor
public class GoodsDonController {

    private final HttpServletRequest request;

    private final BeanSearcher beanSearcher;

    private final OrderDonMapper orderDonMapper;

    private final RegisterOrderDonMapper registerOrderDonMapper;

    private final GoodsDonSkuMapper goodsDonSkuMapper;

    private final RedisService redisService;

    private final SysConfigMapper sysConfigMapper;

    /**
     * 获取商品列表
     */
    @GetMapping("/get")
    public Result<SearchResult<GoodsDon>> get() {
        SearchResult<GoodsDon> search = beanSearcher.search(GoodsDon.class, MapUtils.flatBuilder(request.getParameterMap())
                .field(GoodsDon::getStatus, true)
                .field(GoodsDon::getDeleted, true)
                .orderBy(GoodsDon::getSortBy).desc()
                .orderBy(GoodsDon::getId).asc()
                .build()
        );
        search.getDataList().forEach(goods -> {
            GoodsDonSku goodsDonSku = goodsDonSkuMapper.selectOne(Wrappers.lambdaQuery(GoodsDonSku.class).eq(GoodsDonSku::getGoodsId, goods.getId())
                    .eq(GoodsDonSku::getStatus, true)
                    .orderByAsc(GoodsDonSku::getPrice)
                    .last("limit 1")
                    .select(GoodsDonSku::getPrice));
            Optional.ofNullable(goodsDonSku).ifPresent(sku->{
                goods.setPrice(goodsDonSku.getPrice());
                goods.setSoldNum(goods.getVirtualSold() + orderDonMapper.selectCount(Wrappers.lambdaQuery(OrderDon.class)
                        .eq(OrderDon::getGoodsId, goods.getId())
                        .notIn(OrderDon::getStatus, Constant.noOrderStatus)));
            });
        });
        return GatewayResponse.SUCCESS.newBuilder().toResult(search);
    }

    /**
     * 推广未登录,虚拟商品列表
     */
    @GetMapping("/get/popularize")
    public Result<SearchResult<GoodsDonPopularizeView>> getPopularizeVipGoods() {
        SearchResult<GoodsDonPopularizeView> search = beanSearcher.search(GoodsDonPopularizeView.class, MapUtils.flatBuilder(request.getParameterMap())
                .field(GoodsDonPopularizeView::getStatus, true)
                .field(GoodsDonPopularizeView::getDeleted, true)
                .field(GoodsDonPopularizeView::getType, 1)
                .orderBy(GoodsDonPopularizeView::getSortBy).desc()
                .orderBy(GoodsDonPopularizeView::getId).asc()
                .build());
        DateTime now = DateTime.now();
        search.getDataList().forEach(data -> {
            data.setSpecs(beanSearcher.searchFirst(GoodsDonSpec.class, MapUtils.builder().field(GoodsDonSpec::getGoodsId, data.getId()).build()));
            data.setSkuList(beanSearcher.searchAll(GoodsDonSku.class, MapUtils.builder().field(GoodsDonSku::getGoodsId, data.getId()).field(GoodsDonSku::getStatus, true).orderBy(GoodsDonSku::getPrice).asc().build()));
            Integer sold = orderDonMapper.selectCount(Wrappers.lambdaQuery(OrderDon.class)
                    .eq(OrderDon::getGoodsId, data.getId()).notIn(OrderDon::getStatus, Constant.noOrderStatus));
            data.setSold(sold + data.getVirtualSold());

            Optional.ofNullable(data.getSkuList()).ifPresent(skuList -> {
                if (skuList.size() > 0) {
                    GoodsDonSku goodsDonSku = skuList.get(0);
                    data.setPrice(goodsDonSku.getPrice());
                    data.setMonths(goodsDonSku.getMonths());
                }
            });
            OrderDon orderDon = orderDonMapper.selectOne(Wrappers.lambdaQuery(OrderDon.class)
                    .eq(OrderDon::getGoodsId, data.getId())
                    .notIn(OrderDon::getStatus, Constant.noOrderStatus).select(OrderDon::getCreatedTime, OrderDon::getPayTime, OrderDon::getId)
                    .orderByDesc(OrderDon::getId)
                    .last("limit 1"));
            data.setNotifyMsg(getPayMsgTime(data.getId(), now, 1));
        });
        return GatewayResponse.SUCCESS.newBuilder().toResult(search);
    }

    /**
     * 官网首页 平台列表
     */
    @GetMapping("/get/list")
    public Result<List<GoodsFrontListView>> getGoodsList() {
        List<Long> filter_goodsIds = getFilterGoodsIds(false);
        String pcCacheKey = RedisService.key.YH_HOME_PAGHE_CACHE.getNameLanguagePrefix() + "PC";
        if (CollUtil.isNotEmpty(filter_goodsIds)) {
            pcCacheKey += ":hz-ip";
        }
        Object value = redisService.get(pcCacheKey);
        if (value != null) {
            try {
                List<GoodsFrontListView> list = Jsons.parseList(value, GoodsFrontListView.class);
                if (CollUtil.isNotEmpty(list)) {
                    return GatewayResponse.SUCCESS.newBuilder().toResult(list);
                }
            } catch (Exception e) {
            }
        }
        MapBuilder builder = MapUtils.flatBuilder(request.getParameterMap());
        if (CollUtil.isNotEmpty(filter_goodsIds)) {
            builder.field(GoodsFrontListView::getId, filter_goodsIds).op(Operator.NotIn);
        }
        List<GoodsFrontListView> list = beanSearcher.searchAll(GoodsFrontListView.class, builder.build());
        DateTime now = DateTime.now();
        list.forEach(data -> {
            data.setSpecs(beanSearcher.searchFirst(GoodsDonSpec.class, MapUtils.builder().field(GoodsDonSpec::getGoodsId, data.getId()).build()));
            data.setSkuList(beanSearcher.searchAll(GoodsDonSkuFrontView.class, MapUtils.builder().field(GoodsDonSkuFrontView::getGoodsId, data.getId()).field(GoodsDonSkuFrontView::getStatus, true).orderBy(GoodsDonSkuFrontView::getPrice).asc().build()));
            data.getSkuList().forEach(sku -> {
                if (sku.getIsDp()) {
                    List<GoodsDiscountPlusPurchaseRelationFrontView> dpSkuViews = beanSearcher.searchAll(GoodsDiscountPlusPurchaseRelationFrontView.class, MapUtils.builder().field(GoodsDiscountPlusPurchaseRelationFrontView::getSkuId, sku.getId()).build());
                    sku.setDpSkuViews(dpSkuViews);
                }
            });
            Integer sold = orderDonMapper.selectCount(Wrappers.lambdaQuery(OrderDon.class)
                    .eq(OrderDon::getGoodsId, data.getId()).notIn(OrderDon::getStatus, Constant.noOrderStatus));
            data.setSold(sold + data.getVirtualSold());
            OrderCommentFrontView comments = beanSearcher.searchFirst(OrderCommentFrontView.class, MapUtils.builder()
                    .field(OrderCommentFrontView::getGoodsId, data.getId())
                    .orderBy(OrderCommentFrontView::getCommentTime).desc()
                    .orderBy(OrderCommentFrontView::getId).desc()
                    .build());
            data.setComments(comments);
	        data.setNotifyMsg(getPayMsgTime(data.getId(), now, 1));
        });
        redisService.setNx(pcCacheKey, list, RedisService.key.YH_HOME_PAGHE_CACHE.getTimeout());
        return GatewayResponse.SUCCESS.newBuilder().toResult(list);
    }

    /**
     * h5 银河首页平台展示
     */
    @GetMapping("/get/homePage")
    public Result<List<GoodsHomePageView>> getGoodsHomePage() {
        List<Long> filter_goodsIds = getFilterGoodsIds(false);
        String h5CacheKey = RedisService.key.YH_HOME_PAGHE_CACHE.getNameLanguagePrefix() + "H5";
        if (CollUtil.isNotEmpty(filter_goodsIds)) {
            h5CacheKey += ":hz-ip";
        }
        Object value = redisService.get(h5CacheKey);
        if (value != null) {
            try {
                List<GoodsHomePageView> list = Jsons.parseList(value, GoodsHomePageView.class);
                if (CollUtil.isNotEmpty(list)) {
                    return GatewayResponse.SUCCESS.newBuilder().toResult(list);
                }
            } catch (Exception e) {
            }
        }
        MapBuilder builder = MapUtils.flatBuilder(request.getParameterMap());
        if (CollUtil.isNotEmpty(filter_goodsIds)) {
            builder.field(GoodsFrontListView::getId, filter_goodsIds).op(Operator.NotIn);
        }
        List<GoodsHomePageView> dataList = beanSearcher.searchAll(GoodsHomePageView.class, builder.build());
        DateTime now = DateTime.now();
        dataList.forEach(data -> {
            Integer sold = orderDonMapper.selectCount(Wrappers.lambdaQuery(OrderDon.class)
                    .eq(OrderDon::getGoodsId, data.getId()).notIn(OrderDon::getStatus, Constant.noOrderStatus));
            data.setSold(sold + data.getVirtualSold());
            data.setNotifyMsg(getPayMsgTime(data.getId(), now, 1));
        });
        redisService.setNx(h5CacheKey, dataList, RedisService.key.YH_HOME_PAGHE_CACHE.getTimeout());
        return GatewayResponse.SUCCESS.newBuilder().toResult(dataList);
    }

    /**
     * 注册首页平台展示
     */
    @GetMapping("/get/register")
    public Result<List<RegisterGoodsDonView>> getRegisterGoodsDon() {
        String registerCacheKey = RedisService.key.REGISTER_HOME_PAGE_CACHE.getNameLanguagePrefix();
        Object value = redisService.get(registerCacheKey);
        if (value != null) {
            try {
                List<RegisterGoodsDonView> list = Jsons.parseList(value, RegisterGoodsDonView.class);
                if (CollUtil.isNotEmpty(list)) {
                    return GatewayResponse.SUCCESS.newBuilder().toResult(list);
                }
            } catch (Exception e) {
            }
        }
        MapBuilder builder = MapUtils.flatBuilder(request.getParameterMap());
        List<RegisterGoodsDonView> dataList = beanSearcher.searchAll(RegisterGoodsDonView.class, builder.build());
	    DateTime now = DateTime.now();
	    dataList.forEach(data->{
            Integer sold = registerOrderDonMapper.selectCount(Wrappers.lambdaQuery(RegisterOrderDon.class)
                    .eq(RegisterOrderDon::getGoodsId, data.getId()).notIn(RegisterOrderDon::getStatus, Constant.noOrderStatus));
            data.setSold(sold + data.getVirtualSold());
		    data.setNotifyMsg(getPayMsgTime(data.getId(), now, 2));
        });
        redisService.setNx(registerCacheKey, dataList, RedisService.key.REGISTER_HOME_PAGE_CACHE.getTimeout());
        return GatewayResponse.SUCCESS.newBuilder().toResult(dataList);
    }


    /**
     * 获取商品详情
     */
    @GetMapping("/get/{id}")
    public Result<GoodsDonViews> getDetail(@PathVariable Long id) {
        GoodsDonViews views = beanSearcher.searchFirst(GoodsDonViews.class, MapUtils.builder().field(GoodsDonViews::getId, id).build());

        views.setSpecs(beanSearcher.searchFirst(GoodsDonSpecFrontView.class, MapUtils.builder().field(GoodsDonSpecFrontView::getGoodsId, views.getId()).build()));
        MapBuilder builder = MapUtils.builder().field(GoodsDonSku::getGoodsId, views.getId()).field(GoodsDonSku::getStatus, true);

        if (views.getType() == 1) {
            builder.orderBy(GoodsDonSku::getOrderBy).asc();
        }
        views.setSkuList(beanSearcher.searchAll(GoodsDonSkuFrontView.class, builder.build()));
        views.getSkuList().forEach(sku -> {
            if (sku.getIsDp()) {
                sku.setDpSkuViews(beanSearcher.searchAll(GoodsDiscountPlusPurchaseRelationFrontView.class, MapUtils.builder()
                        .field(GoodsDiscountPlusPurchaseRelationFrontView::getSkuId, sku.getId())
                        .build()));
            }
        });
        return GatewayResponse.SUCCESS.newBuilder().toResult(views);
    }

    /**
     * 获取商品推荐平台
     */
    @GetMapping("/get/recommend/{id}")
    public Result<List<GoodsRecommendViews>> getRecommendGoodsByGid(@PathVariable Long id) throws Exception {
        String key = RedisService.key.YH_HOME_PAGHE_CACHE.getNameLanguagePrefix() + "recommend:" + id;
        Object value = redisService.get(key);
        if (value != null) {
            List<GoodsRecommendViews> goodsRecommendViews = Jsons.parseList(value.toString(), GoodsRecommendViews.class);
            return GatewayResponse.SUCCESS.newBuilder().toResult(goodsRecommendViews);
        }
        if (value == null) {
            GoodsDon goodsDon = beanSearcher.searchFirst(GoodsDon.class, MapUtils.builder()
                    .field(GoodsDon::getId, id)
                    .field(GoodsDon::getStatus, true)
                    .field(GoodsDon::getDeleted, true)
                    .build());
            if (goodsDon != null && StrUtil.isNotEmpty(goodsDon.getRecommendGoods())) {
                List<Long> recommend_gidList = Jsons.parseList(goodsDon.getRecommendGoods(), Long.class);
                List<GoodsRecommendViews> goodsRecommendViews = beanSearcher.searchAll(GoodsRecommendViews.class, MapUtils.builder().field(GoodsRecommendViews::getGoodsId, recommend_gidList).op(Operator.InList).build());
                goodsRecommendViews.forEach(data->{
                    Integer sold = registerOrderDonMapper.selectCount(Wrappers.lambdaQuery(RegisterOrderDon.class)
                            .eq(RegisterOrderDon::getGoodsId, data.getGoodsId()).notIn(RegisterOrderDon::getStatus, Constant.noOrderStatus));
                    data.setSold(sold + data.getVirtualSold());
                });
                redisService.setNx(key, Jsons.toJson(goodsRecommendViews), 60 * 15l);
                return GatewayResponse.SUCCESS.newBuilder().toResult(goodsRecommendViews);
            }
        }
        return GatewayResponse.SUCCESS.newBuilder().toResult();
    }

    /**
     * 获取商品多规格列表
     */
    @GetMapping("/get/sku")
    public Result<List<GoodsDonSkuView>> getGoodsDonSkuView(@RequestParam(value = "skuIds") List<Long> skuIds) {
        if (skuIds.isEmpty()) {
            return GatewayResponse.SUCCESS.newBuilder().toResult();
        }
        List<GoodsDonSkuView> views = beanSearcher.searchAll(GoodsDonSkuView.class, MapUtils.builder()
                .field(GoodsDonSkuView::getSkuId, skuIds).op(Operator.InList)
                .build());
        return GatewayResponse.SUCCESS.newBuilder().toResult(views);
    }

    /**
     * 获取评价列表
     */
    @GetMapping("/get/comments")
    public Result<SearchResult<OrderCommentFrontView>> getComments() {
        SearchResult<OrderCommentFrontView> search = beanSearcher.search(OrderCommentFrontView.class, MapUtils.flatBuilder(request.getParameterMap())
                .orderBy(OrderCommentFrontView::getCommentTime).desc()
                .orderBy(OrderCommentFrontView::getId).desc()
                .build());
        return GatewayResponse.SUCCESS.newBuilder().toResult(search);
    }

    public List<Long> getFilterGoodsIds(Boolean isOpen) {
        if (!isOpen) {
            return null;
        }
        //过滤杭州Ai ChatGPT平台
        //获取当前ip地址
        SysConfig sysConfig = sysConfigMapper.selectOne(Wrappers.lambdaQuery(SysConfig.class)
                .eq(SysConfig::getSysKey, Constant.LOCATION_FOR_GOODS_IDS).last("limit 1"));
        List<Long> filter_goodsIds = null;
        if (sysConfig != null && StrUtil.isNotBlank(sysConfig.getSysValue())) {
            if (StringUtil.getRealAddressByIP(ServletUtil.getClientIP(request)).contains("杭州")) {
                try {
                    filter_goodsIds = Jsons.parseList(sysConfig.getSysValue(), Long.class);
                } catch (Exception e) {
                }
            }
        }
        return filter_goodsIds;
    }

    /**
     *
     * @param goodsId
     * @param type 1、普通，2、注册平台
     * @return
     */
    public String getPayMsgTime(Long goodsId, DateTime now, Integer type) {
        Date startTime = null;
        StringBuilder notifyMsg = new StringBuilder();
        if (type == 1) {
            OrderDon orderDon = orderDonMapper.selectOne(Wrappers.lambdaQuery(OrderDon.class)
                    .eq(OrderDon::getGoodsId, goodsId)
                    .notIn(OrderDon::getStatus, Constant.noOrderStatus).select(OrderDon::getCreatedTime, OrderDon::getPayTime, OrderDon::getId)
                    .orderByDesc(OrderDon::getId)
                    .last("limit 1"));
            if (orderDon == null) {
                notifyMsg.append(I18nMessageUtil.getI18nMsg("order_buy_now_notify"));
                return notifyMsg.toString();
            }
            startTime = orderDon.getPayTime() != null ? orderDon.getPayTime() : orderDon.getCreatedTime();
        } else if (type == 2) {
            RegisterOrderDon orderDon = registerOrderDonMapper.selectOne(Wrappers.lambdaQuery(RegisterOrderDon.class)
                    .eq(RegisterOrderDon::getGoodsId, goodsId)
                    .notIn(RegisterOrderDon::getStatus, Constant.noOrderStatus).select(RegisterOrderDon::getCreatedTime, RegisterOrderDon::getPayTime, RegisterOrderDon::getId)
                    .orderByDesc(RegisterOrderDon::getId)
                    .last("limit 1"));
            if (orderDon == null) {
                return null;
            }
            startTime = orderDon.getPayTime() != null ? orderDon.getPayTime() : orderDon.getCreatedTime();
        }
        long hour = DateUtil.between(startTime, now, DateUnit.HOUR);
        if (hour == 0) {
            long minute = DateUtil.between(startTime, now, DateUnit.MINUTE);
            if (minute == 0) {
                notifyMsg.append("1");
                notifyMsg.append(I18nMessageUtil.getI18nMsg("minute"));
            } else {
                notifyMsg.append(minute);
                if (minute > 1) {
                    notifyMsg.append(I18nMessageUtil.getI18nMsg("minutes"));
                } else {
                    notifyMsg.append(I18nMessageUtil.getI18nMsg("minute"));
                }
            }
        } else {
            if (hour > 3) {
                int hours = RandomUtil.randomInt(3) + 1;
                notifyMsg.append(hours);
            } else {
                notifyMsg.append(hour);
            }
            if (hour > 1) {
                notifyMsg.append(I18nMessageUtil.getI18nMsg("hours"));
            } else {
                notifyMsg.append(I18nMessageUtil.getI18nMsg("hour"));
            }
        }
        notifyMsg.append(I18nMessageUtil.getI18nMsg("order_pre_buy_it"));
        return notifyMsg.toString();
    }
}