用户商品关联表删除，直接用商品表记录用户id11

ch-dao/src/main/java/com/wwdz/ch/db/dto/request/CoinRequestDto.java

@@ -117,4 +117,10 @@ public class CoinRequestDto extends BaseRequestDto implements Entity {
      * 成交时间
      */
     private String bidTime;
+
+    /**
+     * 上传商品的用户id
+     */
+    private Long userId;
 }
+

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

@@ -50,6 +50,7 @@ public class ItemDaoImpl implements ItemDao {
         ItemExample.Criteria criteria = example.createCriteria();
         JdbcHelper.ifPresent(coinRequestDto.getId(), criteria :: andIdEqualTo);
         JdbcHelper.ifPresent(coinRequestDto.getIds(), criteria::andIdIn);
+        JdbcHelper.ifPresent(coinRequestDto.getUserId(), criteria::andUserIdEqualTo);
         JdbcHelper.ifPresent(coinRequestDto.getCid(), criteria :: andCidEqualTo);
         if (StringUtils.hasLength(coinRequestDto.getName())) {
             criteria.andNameLike("%" + coinRequestDto.getName() + "%");

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

@@ -80,15 +80,12 @@ public class ConsignSaleServiceImpl implements ConsignSaleService {
             if (StringUtils.hasLength(dto.getSearchParam())) {
                 //判断查询条件是否为中文，是的话就根据商品名称模糊查询
                 if (RegexUtil.isContainChinese(dto.getSearchParam())) {
-                    //先查询该用户发布的商品id
-                    List<UserItemsRelation> userItemsRelations = itemDao.listByUserIds(dto.getUserId(), null);
-                    List<Long> itemIds = userItemsRelations.stream().map(UserItemsRelation::getItemId).collect(Collectors.toList());
                     CoinRequestDto coinRequestDto = new CoinRequestDto();
-                    coinRequestDto.setIds(itemIds);
+                    coinRequestDto.setUserId(dto.getUserId());
                     coinRequestDto.setName(dto.getSearchParam());
                     List<Item> items = itemDao.findList(coinRequestDto);
-                    if (!CollectionUtils.isEmpty(items)) {
-                        itemIds = items.stream().map(Item::getId).collect(Collectors.toList());
+                    List<Long> itemIds = items.stream().map(Item::getId).collect(Collectors.toList());
+                    if (!CollectionUtils.isEmpty(itemIds)) {
                         dto.setItemIds(itemIds);
                     }
                 } else {
@@ -115,7 +112,7 @@ public class ConsignSaleServiceImpl implements ConsignSaleService {
             PageSearchResult pageSearchResult = PageSearchResult.of(pageInfo, consignSaleVos);
             return Result.success(pageSearchResult);
         } catch (Exception e) {
-            logger.error("查询接收单列表error : {}", e);
+            logger.error("查询寄售单列表error : {}", e);
         }
         return Result.failed();
     }