新增商品关注

ch-dao/src/main/java/com/wwdz/ch/db/dao/distribution/SpecialPerformanceItemFollowDao.java

@@ -16,4 +16,6 @@ public interface SpecialPerformanceItemFollowDao {
     boolean update(SpecialPerformanceItemFollow specialPerformanceItemFollow);
 
     boolean updateByPrimaryKey(SpecialPerformanceItemFollow specialPerformanceItemFollow);
+
+    boolean isFollowed(SpecialPerformanceItemFollowRequestDto dto);
 }

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

@@ -76,6 +76,13 @@ public class SpecialPerformanceRequestDto extends BaseRequestDto implements Enti
 
     private Date endQueryTime;
 
+    /**
+     * 专场结束时间的时间范围筛选
+     */
+    private Date startQueryEndTime;
+
+    private Date endQueryEndTime;
+
     /**
      * 搜索内容
      */

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

@@ -30,6 +30,8 @@ public class SpecialPerformanceDaoImpl implements SpecialPerformanceDao {
         JdbcHelper.ifPresent(dto.getFilterState(), criteria::andStateNotEqualTo);
         JdbcHelper.ifPresent(dto.getStartQueryTime(), criteria::andStartTimeLessThanOrEqualTo);
         JdbcHelper.ifPresent(dto.getEndQueryTime(), criteria::andStartTimeGreaterThanOrEqualTo);
+        JdbcHelper.ifPresent(dto.getStartQueryEndTime(), criteria::andEndTimeGreaterThanOrEqualTo);
+        JdbcHelper.ifPresent(dto.getEndQueryEndTime(), criteria::andEndTimeLessThanOrEqualTo);
         example.setOrderByClause(" update_time desc");
         PageHelper.startPage(dto.getPage(), dto.getLimit());
         return specialPerformanceMapper.selectByExample(example);

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

@@ -51,4 +51,16 @@ public class SpecialPerformanceItemFollowDaoImpl implements SpecialPerformanceIt
     public boolean updateByPrimaryKey(SpecialPerformanceItemFollow specialPerformanceItemFollow) {
         return specialPerformanceItemFollowMapper.updateByPrimaryKeySelective(specialPerformanceItemFollow) > 0;
     }
+
+
+    @Override
+    public boolean isFollowed(SpecialPerformanceItemFollowRequestDto dto) {
+        SpecialPerformanceItemFollowExample example = new SpecialPerformanceItemFollowExample();
+        SpecialPerformanceItemFollowExample.Criteria criteria = example.createCriteria();
+        criteria.andSpecialPerformanceIdEqualTo(dto.getSpecialPerformanceId());
+        criteria.andItemIdEqualTo(dto.getItemId());
+        criteria.andUserIdEqualTo(dto.getUserId());
+        criteria.andStateEqualTo(1);
+        return specialPerformanceItemFollowMapper.countByExample(example) > 0;
+    }
 }

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

@@ -35,6 +35,9 @@ public class SpecialPerformanceItemFollowServiceImpl implements SpecialPerforman
     @Override
     public Result addItemFollow(SpecialPerformanceItemFollowRequestDto dto) {
         try {
+            if (specialPerformanceItemFollowDao.isFollowed(dto)) {
+                return Result.failed("已存在关注记录");
+            }
             SpecialPerformanceItemFollow specialPerformanceItemFollow = new SpecialPerformanceItemFollow();
             EntityMapper.copyAttribute(dto, specialPerformanceItemFollow);
             SupplierItem supplierItem = supplierItemDao.findById(dto.getItemId());
@@ -43,6 +46,7 @@ public class SpecialPerformanceItemFollowServiceImpl implements SpecialPerforman
             specialPerformanceItemFollow.setUpdateTime(new Date());
             specialPerformanceItemFollow.setState(DisposableSubscribeRecordEnum.ItemFollowStateEnum.FOLLOWED.getCode());
             specialPerformanceItemFollowDao.insert(specialPerformanceItemFollow);
+            return Result.success();
         } catch (Exception e) {
             logger.error("新增专场商品关注记录失败 error : {}", e);
         }