成交价格

ch-dao/src/main/java/com/wwdz/ch/db/dao/ItemDao.java

@@ -31,6 +31,13 @@ public interface ItemDao {
 
     List<Item> findListByPage(CoinRequestDto coinRequestDto);
 
+    /**
+     * 查价功能的商品查询
+     * @param coinRequestDto
+     * @return
+     */
+    List<Item> findListByPageForQueryPrice(CoinRequestDto coinRequestDto);
+
     PageInfo<Item> findByPage(CoinRequestDto coinRequestDto);
 
     PageInfo<Item> findPageExcludeFilter(CoinRequestDto coinRequestDto);

ch-dao/src/main/java/com/wwdz/ch/db/impl/ItemDaoImpl.java

@@ -77,11 +77,7 @@ public class ItemDaoImpl implements ItemDao {
     public List<Item> findListByPage(CoinRequestDto coinRequestDto) {
         ItemExample example = new ItemExample();
         ItemExample.Criteria criteria = example.createCriteria();
-        if (StringUtils.hasLength(coinRequestDto.getSortColumn())) {
-            example.setOrderByClause(coinRequestDto.getSortColumn() + " " + coinRequestDto.getOrder());
-        } else {
         example.setOrderByClause("create_time asc");
-        }
         JdbcHelper.ifPresent(coinRequestDto.getIsDeleted(), criteria::andIsDeletedEqualTo);
         JdbcHelper.ifPresent(coinRequestDto.getCid(), criteria::andCidEqualTo);
         JdbcHelper.ifPresent(coinRequestDto.getStartUpdateTime(), criteria::andUpdateTimeGreaterThan);
@@ -90,6 +86,21 @@ public class ItemDaoImpl implements ItemDao {
     }
 
 
+    @Override
+    public List<Item> findListByPageForQueryPrice(CoinRequestDto coinRequestDto) {
+        ItemExample example = new ItemExample();
+        ItemExample.Criteria criteria = example.createCriteria();
+        if (StringUtils.hasLength(coinRequestDto.getSortColumn())) {
+            example.setOrderByClause(coinRequestDto.getSortColumn() + " " + coinRequestDto.getOrder());
+        }
+        criteria.andPriceNotEqualTo(0L);
+        criteria.andIsDeletedEqualTo(false);
+        JdbcHelper.ifPresent(coinRequestDto.getCid(), criteria::andCidEqualTo);
+        JdbcHelper.ifPresent(coinRequestDto.getStartUpdateTime(), criteria::andUpdateTimeGreaterThan);
+        PageHelper.startPage(coinRequestDto.getPage(), coinRequestDto.getLimit());
+        return itemMapper.selectByExampleWithBLOBs(example);
+    }
+
     @Override
     public PageInfo<Item> findByPage(CoinRequestDto coinRequestDto) {
         ItemExample example = new ItemExample();

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

@@ -108,8 +108,7 @@ public class QueryPriceServiceImpl implements QueryPriceService {
     @Override
     public Result findBidRecord(CoinRequestDto dto) {
         try {
-            dto.setIsDeleted(false);
-            List<Item> itemList = itemDao.findListByPage(dto);
+            List<Item> itemList = itemDao.findListByPageForQueryPrice(dto);
             PageInfo pageInfo = PageInfo.of(itemList);
             List<Map<String, Object>> mapList = new ArrayList<>();
             for (Item i : itemList) {