首页关注列表

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

@@ -4,9 +4,10 @@ import com.alibaba.fastjson.JSON;
 import com.github.pagehelper.PageInfo;
 import com.qiniu.storage.model.FileInfo;
 import com.wwdz.ch.core.consts.*;
+import com.wwdz.ch.core.entity.OfficialAccountCollectSubscribeMsg;
 import com.wwdz.ch.core.storage.QiniuStorage;
-import com.wwdz.ch.core.type.PageSearchResult;
 import com.wwdz.ch.core.type.Result;
+import com.wwdz.ch.core.util.CacheUtil;
 import com.wwdz.ch.core.util.MediaUtil;
 import com.wwdz.ch.db.bean.EsPageInfo;
 import com.wwdz.ch.db.bean.ItemOfEs;
@@ -16,6 +17,7 @@ import com.wwdz.ch.db.dto.request.CoinRequestDto;
 import com.wwdz.ch.db.dto.request.EsSearchRequestDto;
 import com.wwdz.ch.db.dto.request.FollowFansRecordRequestDto;
 import com.wwdz.ch.db.es.ItemEsDao;
+import com.wwdz.ch.wx.api.OfficialAccountApi;
 import com.wwdz.ch.wx.constant.CacheCodeConstants;
 import com.wwdz.ch.wx.constant.LoginTypeEnum;
 import com.wwdz.ch.wx.entity.MessageContentText;
@@ -35,8 +37,6 @@ import com.wwdz.ch.wx.util.RedisUtil;
 import com.wwdz.ch.wx.util.StringUtil;
 import com.xxdxxs.utils.CommonUtils;
 import com.xxdxxs.utils.DateUtils;
-import com.xxdxxs.utils.EntityMapper;
-import com.xxdxxs.utils.MapUtils;
 import org.apache.commons.collections.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.slf4j.Logger;
@@ -128,6 +128,15 @@ public class ItemServiceImpl implements ItemService {
     @Autowired
     FollowFansRecordDao followFansRecordDao;
 
+    @Autowired
+    OfficialAccountApi officialAccountApi;
+
+    @Autowired
+    CacheUtil cacheUtil;
+
+    @Autowired
+    OfficialAccountSubscribeRecordDao officialAccountSubscribeRecordDao;
+
     @Override
     public Result nameList(ItemRequestDto dto) {
         try {
@@ -271,6 +280,7 @@ public class ItemServiceImpl implements ItemService {
             List<Item> itemList = pageInfo.getList();
             for (Item item : itemList) {
                 ItemResponseVo itemResponseVo = new ItemResponseVo();
+                itemResponseVo.setId(item.getId());
                 itemResponseVo.setItemId(item.getId());
                 // 查询商品被收藏的次数
                 long collectCount = favoritesItemsRelationDao.countByItemId(item.getId());
@@ -1197,6 +1207,16 @@ public class ItemServiceImpl implements ItemService {
                     messageService.add(messageRequestDto);
                 }
             }
+            //通过公众号发送模板消息
+            User user = cacheUtil.getAppletUsers(userItemsRelation.getUserId());
+            OfficialAccountSubscribeRecord officialAccountSubscribeRecord = officialAccountSubscribeRecordDao.findOne(user.getWeixinOpenid());
+            if (officialAccountSubscribeRecord != null) {
+                String officalAccountOpenid = officialAccountSubscribeRecord.getOpenid();
+                OfficialAccountCollectSubscribeMsg officialAccountCollectSubscribeMsg = new OfficialAccountCollectSubscribeMsg();
+                officialAccountApi.sendModelMsg(officalAccountOpenid, officialAccountCollectSubscribeMsg);
+            }
+
+
         }
         if (idType.equals(MessageEnum.ContentIdTypeEnum.COLLECTION_BOOK.getCode())) {
             Favorites favorites = favoritesDao.info(id);