查价

ch-admin-api/src/main/java/com/wwdz/ch/admin/controller/ItemController.java

@@ -103,13 +103,13 @@ public class ItemController {
     }
 
 
-    @GetMapping("/updateUrl")
+//    @GetMapping("/updateUrl")
     public void syn() {
         synCoinJob.updateImageUrlOfsSize();
     }
 
 
-    @GetMapping("/synToEs")
+//    @GetMapping("/synToEs")
     public void synToEs() {
         synCoinJob.synItemToEs();
     }

ch-admin-api/src/main/java/com/wwdz/ch/admin/job/SynItemToEsJob.java

@@ -78,7 +78,7 @@ public class SynItemToEsJob {
             logger.info("es中最新数据时间为 {}", DateUtils.toString(time));
             CoinRequestDto coinRequestDto = new CoinRequestDto();
             coinRequestDto.setPage(1);
-            coinRequestDto.setLimit(10);
+            coinRequestDto.setLimit(100);
             coinRequestDto.setStartUpdateTime(time);
             coinRequestDto.setSortColumn("update_time");
             List<Item> itemList = itemDao.findListByPage(coinRequestDto);

ch-dao/src/main/java/com/wwdz/ch/db/es/ItemEsDao.java

@@ -149,8 +149,7 @@ public class ItemEsDao {
         List<BulkOperation> opts = new ArrayList<>();
         for (Item item : itemList) {
             CreateOperation<Item> optObj = new CreateOperation.Builder<Item>()
-                    .index("quanku_prod_temp")
-               //     .index(INDEX)
+                    .index(INDEX)
                     .id(String.valueOf(item.getId()))
                     .document(item)
                     .build();

ch-wx-api/src/main/java/com/wwdz/ch/wx/entity/request/QueryPriceRequestDto.java

@@ -7,4 +7,9 @@ import lombok.Data;
 public class QueryPriceRequestDto implements Entity {
 
     private Integer cid;
+
+    /**
+     * 时间跨度
+     */
+    private Integer timeSpan;
 }

ch-wx-api/src/main/java/com/wwdz/ch/wx/impl/QueryPriceServiceImpl.java

@@ -10,15 +10,14 @@ import com.wwdz.ch.db.dao.CategoryDao;
 import com.wwdz.ch.db.domain.BidRecord;
 import com.wwdz.ch.db.domain.Category;
 import com.wwdz.ch.db.dto.request.BidRecordRequestDto;
+import com.wwdz.ch.wx.entity.request.QueryPriceRequestDto;
 import com.wwdz.ch.wx.entity.vo.BidRecordVo;
 import com.wwdz.ch.wx.entity.vo.CategoryVo;
 import com.wwdz.ch.wx.service.QueryPriceService;
-import com.xxdxxs.utils.DateUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
-
 import java.time.*;
 import java.time.format.DateTimeFormatter;
 import java.util.ArrayList;
@@ -40,21 +39,26 @@ public class QueryPriceServiceImpl implements QueryPriceService {
 
 
     @Override
-    public Result queryPrice(Integer id) {
+    public Result queryPrice(QueryPriceRequestDto queryPriceRequestDto) {
         try {
+            Integer id = queryPriceRequestDto.getCid();
             Category category = categoryDao.findById(id);
             //成交记录折线图
             BidRecordRequestDto dto = new BidRecordRequestDto();
             LocalDate now = LocalDate.now();
             int nowMills = (int) now.atStartOfDay(ZoneOffset.UTC).toEpochSecond();
-            LocalDate starTime = now.minusYears(1);
-            int startMills = (int) starTime.atStartOfDay(ZoneOffset.UTC).toEpochSecond();
+            //时间跨度参数为空，默认为近一年, 时间跨度不等于1的时候，代表历史所有数据，则不设置开始时间
+            if (queryPriceRequestDto.getTimeSpan() == null || queryPriceRequestDto.getTimeSpan() == 1) {
+                LocalDate starTime = now.minusYears(1);
+                int startMills = (int) starTime.atStartOfDay(ZoneOffset.UTC).toEpochSecond();
+                dto.setStartBidTime(startMills);
+            }
             dto.setCid(id);
-            dto.setStartBidTime(startMills);
             dto.setEndBidTime(nowMills);
             List<BidRecord> bidRecordList = bidRecordDao.queryByCid(dto);
             List<String> xData = new ArrayList<>();
             List<Object> valueList = new ArrayList<>();
+            double totalPrice = 0;
             for (BidRecord bidRecord : bidRecordList) {
                 int bidTime = bidRecord.getBidTime();
                 Instant instant = Instant.ofEpochSecond(bidTime);
@@ -62,14 +66,17 @@ public class QueryPriceServiceImpl implements QueryPriceService {
                 DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");
                 String time = date.format(formatter);
                 xData.add(time);
+                totalPrice += bidRecord.getPrice() / (double)100;
                 valueList.add(bidRecord.getPrice() / (double)100 / (double)10000);
             }
+            double averagePrice = totalPrice / bidRecordList.size();
             Chart chart = new Chart();
             chart.setXData(xData);
             chart.setValues(valueList);
             Map<String, Object> map = new HashMap<>();
             map.put("details", CategoryVo.of(category));
             map.put("chart", chart);
+            map.put("averagePrice", averagePrice);
             return Result.success(map);
         } catch (Exception e) {
             logger.error("查询类目价格详情失败:{}", e);

ch-wx-api/src/main/java/com/wwdz/ch/wx/service/QueryPriceService.java

@@ -2,10 +2,11 @@ package com.wwdz.ch.wx.service;
 
 import com.wwdz.ch.core.type.Result;
 import com.wwdz.ch.db.dto.request.BidRecordRequestDto;
+import com.wwdz.ch.wx.entity.request.QueryPriceRequestDto;
 
 public interface QueryPriceService {
 
-    Result queryPrice(Integer id);
+    Result queryPrice(QueryPriceRequestDto dto);
 
     /**
      * 查询该子类目的成交记录

ch-wx-api/src/main/java/com/wwdz/ch/wx/web/QueryPriceController.java

@@ -38,7 +38,7 @@ public class QueryPriceController {
         if (StringUtils.isEmpty(dto.getCid())) {
             return Result.failed(ResultCode.PARAM_ERROR);
         }
-        return queryPriceService.queryPrice(dto.getCid());
+        return queryPriceService.queryPrice(dto);
     }
 
     @ApiOperation(value = "查价成交记录")