同步商品查询

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

@@ -198,7 +198,7 @@ public class SynCoinJob {
             CoinRequestDto coinRequestDto = new CoinRequestDto();
             coinRequestDto.setPage(1);
             coinRequestDto.setLimit(100);
-            coinRequestDto.setKind(ItemKindEnum.NEPHRITE.getCode());
+        //    coinRequestDto.setKind(ItemKindEnum.NEPHRITE.getCode());
             PageInfo<Item> pageInfo = itemDao.findPageExcludeFilter(coinRequestDto);
             int totalPageNum = pageInfo.getPages();
             logger.info("total page : {}, total : {}", totalPageNum, pageInfo.getTotal());

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

@@ -156,7 +156,7 @@ public class ItemDaoImpl implements ItemDao {
     public PageInfo<Item> findPageExcludeFilter(CoinRequestDto coinRequestDto) {
         ItemExample example = new ItemExample();
         ItemExample.Criteria criteria = example.createCriteria();
-        criteria.andKindEqualTo(coinRequestDto.getKind());
+        JdbcHelper.ifPresent(coinRequestDto.getKind(), criteria :: andKindEqualTo);
         PageHelper.startPage(coinRequestDto.getPage(), coinRequestDto.getLimit());
         List<Item> list = itemMapper.selectByExampleWithBLOBs(example);
         return new PageInfo<>(list);