Advertising page

src/main/java/com/example/afrishop_v3/controllers/AdvertisementController.java

+package com.example.afrishop_v3.controllers;
+
+import com.example.afrishop_v3.base.Result;
+import com.example.afrishop_v3.models.Advertisement;
+import com.example.afrishop_v3.models.TbCfStationItem;
+import com.example.afrishop_v3.repository.AdvertisementItemRepository;
+import com.example.afrishop_v3.repository.AdvertisementRepository;
+import com.example.afrishop_v3.repository.TbCfStationItemRepository;
+import org.springframework.data.domain.PageRequest;
+import org.springframework.web.bind.annotation.*;
+import org.springframework.data.domain.Sort;
+
+import static org.springframework.data.domain.Sort.Order.asc;
+import static org.springframework.data.domain.Sort.Order.desc;
+
+import java.util.Date;
+import java.util.LinkedHashMap;
+import java.util.List;
+import java.util.Optional;
+
+/**
+ * @Auther: wudepeng
+ * @Date: 2020/11/20
+ * @Description:广告投放页管理
+ */
+@RestController
+@RequestMapping("/advertisement")
+public class AdvertisementController {
+
+
+    private final AdvertisementRepository advertisementRepository;
+
+    private final TbCfStationItemRepository itemRepository;
+
+    private final AdvertisementItemRepository advertisementItemRepository;
+
+    public AdvertisementController(AdvertisementRepository advertisementRepository, TbCfStationItemRepository itemRepository, AdvertisementItemRepository advertisementItemRepository) {
+        this.advertisementRepository = advertisementRepository;
+
+        this.itemRepository = itemRepository;
+        this.advertisementItemRepository = advertisementItemRepository;
+    }
+
+
+    /**
+     * 根据链接查询广告投放页
+     */
+    @GetMapping("/info/{link}")
+    public Result getAdvertisementById(@PathVariable("link") String link,
+                                       @RequestParam(value = "pageNum", defaultValue = "1") Integer pageNum,
+                                       @RequestParam(value = "pageSize", defaultValue = "12") Integer pageSize,
+                                       @RequestParam(value = "order", required = false) String order) {
+        LinkedHashMap advertisementMap = new LinkedHashMap();
+        //广告投放信息主体
+        Optional<Advertisement> firstByAdLink = advertisementRepository.findFirstByAdLink(link);
+        if (firstByAdLink.isPresent()) {
+            Advertisement advertisement = firstByAdLink.get();
+            long now = System.currentTimeMillis();
+            Date endTime = advertisement.getEndTime();//结束时间
+
+            //活动已结束
+            if (now > endTime.getTime()) {
+                advertisement.setStatus(3);
+            }
+
+            List<TbCfStationItem> itemList = itemRepository.getAdvertisementItem(advertisement.getId(), PageRequest.of(pageNum, pageSize, sort(order))).toList();
+            advertisementMap.put("advertisement", advertisement);
+            advertisementMap.put("itemList", itemList);
+        }
+
+        return new Result(advertisementMap);
+    }
+
+    private Sort sort(String order) {
+        String col = "discountPrice";
+        return Sort.by(order(order, col));
+    }
+
+    private Sort.Order order(String order, String col) {
+        return "desc".equals(order) ? desc(col) : asc(col);
+    }
+}

src/main/java/com/example/afrishop_v3/models/Advertisement.java

+package com.example.afrishop_v3.models;
+
+import lombok.Data;
+import org.hibernate.annotations.Where;
+
+import javax.persistence.Entity;
+import javax.persistence.Id;
+import javax.persistence.Table;
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 实体
+ * 表名 advertisement
+ *
+ * @author lipengjun
+ * @date 2020-09-28 17:54:01
+ */
+@Data
+@Entity
+public class Advertisement {
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 广告投放ID
+     */
+    @Id
+    private String id;
+
+    private String itemIds;
+    /**
+     * 广告名
+     */
+    private String adName;
+    /**
+     * 广告链接
+     */
+    private String adLink;
+    /**
+     * banner图
+     */
+    private String picture;
+    /**
+     * 状态 0：已删除 1：活动进行中 2：活动已关闭 3：活动已结束
+     */
+    private Integer status;
+    /**
+     * 活动开始时间
+     */
+    private Date startTime;
+    /**
+     * 活动结束时间
+     */
+    private Date endTime;
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+    /**
+     * 更新时间
+     */
+    private Date updateTime;
+    /**
+     * 备注
+     */
+    private String remark;
+
+}

src/main/java/com/example/afrishop_v3/models/AdvertisementItem.java

+package com.example.afrishop_v3.models;
+
+import lombok.Data;
+
+import javax.persistence.Entity;
+import javax.persistence.Id;
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 实体
+ * 表名 advertisement_item
+ *
+ * @author lipengjun
+ * @date 2020-10-13 17:30:21
+ */
+@Data
+@Entity
+public class AdvertisementItem implements Serializable {
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 广告投放ID
+     */
+    @Id
+    private String adId;
+    /**
+     * 商品ID
+     */
+    private String itemId;
+    /**
+     * 是否置顶 0:  不置顶 1：置顶
+     */
+    private Integer isTop;
+    /**
+     * 排序
+     */
+    private Integer sort;
+    /**
+     * 商品添加时间
+     */
+    private Date createTime;
+
+
+}

src/main/java/com/example/afrishop_v3/repository/AdvertisementItemRepository.java

+package com.example.afrishop_v3.repository;
+
+import com.example.afrishop_v3.models.Advertisement;
+import com.example.afrishop_v3.models.AdvertisementItem;
+import com.example.afrishop_v3.models.TbCfStationItem;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+
+/**
+ * @Auther: wudepeng
+ * @Date: 2020/11/20
+ * @Description:
+ */
+public interface AdvertisementItemRepository extends JpaRepository<AdvertisementItem, String> {
+
+
+}

src/main/java/com/example/afrishop_v3/repository/AdvertisementRepository.java

+package com.example.afrishop_v3.repository;
+
+import com.example.afrishop_v3.models.Advertisement;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+
+import java.util.Optional;
+
+/**
+ * @Auther: wudepeng
+ * @Date: 2020/11/20
+ * @Description:
+ */
+public interface AdvertisementRepository extends JpaRepository<Advertisement, String> {
+
+    //    @Query("select a from Advertisement a where a.adLink=:adLink and a.status=1")
+    Optional<Advertisement> findFirstByAdLink(String adLink);
+}

src/main/java/com/example/afrishop_v3/repository/TbCfStationItemRepository.java

@@ -35,4 +35,8 @@ public interface TbCfStationItemRepository extends PagingAndSortingRepository<Tb
     Page<TbCfStationItem> findByItemCategory(String itemName, Pageable pageable);
 
     List<TbCfStationItem> findAllByItemDescritionId(String id);
+
+    @Query(value = "select i from #{#entityName} i inner join AdvertisementItem a on i.itemId=a.itemId where a.adId=?1  order by a.sort ")
+    Page<TbCfStationItem> getAdvertisementItem(String adId, Pageable pageable);
+
 }