专场商品列表名称模糊查询

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

@@ -5,6 +5,7 @@ import com.wwdz.ch.db.dao.DisposableSubscribeRecordDao;
 import com.wwdz.ch.db.domain.distribution.DisposableSubscribeRecord;
 import com.wwdz.ch.db.dto.request.distribution.DisposableSubscribeRecordRequestDto;
 import com.wwdz.ch.wx.service.distribution.DisposableSubscribeRecordService;
+import com.xxdxxs.utils.EntityMapper;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -23,12 +24,11 @@ public class DisposableSubscribeRecordServiceImpl implements DisposableSubscribe
     @Override
     public Result subscribed(DisposableSubscribeRecordRequestDto dto) {
         try {
-            Long userId = dto.getUserId();
             String openid = dto.getOpenid();
             String templateId = dto.getTemplateId();
             long targetId = dto.getTargetId();
-            boolean isExisted = disposableSubscribeRecordDao.isExisted(openid, targetId, templateId);
             DisposableSubscribeRecord disposableSubscribeRecord = new DisposableSubscribeRecord();
+            EntityMapper.copyAttribute(dto, disposableSubscribeRecord);
             disposableSubscribeRecord.setIsValid(true);
             //如果有历史记录，则做更新
             if (!disposableSubscribeRecordDao.isSubscribed(openid, targetId, templateId)) {
@@ -44,13 +44,15 @@ public class DisposableSubscribeRecordServiceImpl implements DisposableSubscribe
 
     @Override
     public Result update(DisposableSubscribeRecord disposableSubscribeRecord) {
-        return null;
+        try {
+            disposableSubscribeRecordDao.update(disposableSubscribeRecord);
+            return Result.success();
+        } catch (Exception e) {
+            logger.error("更新订阅记录 error: {}", e);
+        }
+        return Result.failed();
     }
 
-    @Override
-    public Result isExisted(DisposableSubscribeRecordRequestDto dto) {
-        return null;
-    }
 
     @Override
     public Result isSubscribed(DisposableSubscribeRecordRequestDto dto) {

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

@@ -288,6 +288,9 @@ public class SpecialPerformanceServiceImpl implements SpecialPerformanceService
                     supplierItemRequestDto.setLimit(dto.getLimit());
                     List<SupplierItem> supplierItemList = supplierItemDao.findList(supplierItemRequestDto);
                     List<Long> itemIds = supplierItemList.stream().map(SupplierItem::getId).collect(Collectors.toList());
+                    if (CollectionUtils.isEmpty(itemIds)) {
+                        return Result.failed("查无商品");
+                    }
                     specialPerformanceConfigRequestDto.setItemIdList(itemIds);
                 }
             }

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

@@ -20,8 +20,6 @@ public interface DisposableSubscribeRecordService {
 
     Result update(DisposableSubscribeRecord disposableSubscribeRecord);
 
-    Result isExisted(DisposableSubscribeRecordRequestDto dto);
-
     Result isSubscribed(DisposableSubscribeRecordRequestDto dto);
 
     List<DisposableSubscribeRecord> findList(long userId);