cxc/yshopb2c
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

修改直播添加商品逻辑

Browse Source
This commit is contained in:
xuwenbo
2020-09-11 21:58:51 +08:00
parent 90cb449b1a
commit eb1b5dc5b9
4 changed files with 51 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
yshop-weixin/src/main/java/co/yixiang/modules/mp/service/YxWechatLiveService.java
View File

@ -10,6 +10,7 @@ package co.yixiang.modules.mp.service;
import cn.binarywang.wx.miniapp.bean.WxMaLiveResult;
import co.yixiang.common.service.BaseService;
import co.yixiang.modules.mp.service.dto.UpdateGoodsDto;
import co.yixiang.modules.mp.service.dto.WxMaLiveInfo;
import co.yixiang.modules.mp.service.dto.YxWechatLiveDto;
import co.yixiang.modules.mp.service.dto.YxWechatLiveQueryCriteria;
@ -94,4 +95,6 @@ public interface YxWechatLiveService extends BaseService<YxWechatLive>{
* @return List
*/
List<YxWechatLiveDto> getList(int page, int limit, int order);
boolean addGoods(UpdateGoodsDto resources);
}

11
yshop-weixin/src/main/java/co/yixiang/modules/mp/service/dto/UpdateGoodsDto.java Normal file
View File

@ -0,0 +1,11 @@
package co.yixiang.modules.mp.service.dto;
import lombok.Data;
@Data
public class UpdateGoodsDto {
private Integer roomId;
private String productId;
}

31
yshop-weixin/src/main/java/co/yixiang/modules/mp/service/impl/YxWechatLiveServiceImpl.java
View File

@ -21,10 +21,7 @@ import co.yixiang.exception.BadRequestException;
import co.yixiang.modules.mp.domain.YxWechatLiveGoods;
import co.yixiang.modules.mp.service.YxWechatLiveGoodsService;
import co.yixiang.modules.mp.service.YxWechatLiveService;
import co.yixiang.modules.mp.service.dto.WxMaLiveInfo;
import co.yixiang.modules.mp.service.dto.YxWechatLiveDto;
import co.yixiang.modules.mp.service.dto.YxWechatLiveGoodsDto;
import co.yixiang.modules.mp.service.dto.YxWechatLiveQueryCriteria;
import co.yixiang.modules.mp.service.dto.*;
import co.yixiang.modules.mp.service.mapper.YxWechatLiveMapper;
import co.yixiang.modules.mp.vo.WechatLiveVo;
import co.yixiang.modules.mp.domain.YxWechatLive;
@ -136,6 +133,30 @@ public class YxWechatLiveServiceImpl extends BaseServiceImpl<YxWechatLiveMapper,
wechatLiveVo.setLastPage(page.getPages());
return wechatLiveVo;
}
@Override
public boolean addGoods(UpdateGoodsDto resources) {
YxWechatLive wechatLive = new YxWechatLive();
WxMaService wxMaService = WxMaConfiguration.getWxMaService();
if(StringUtils.isNotBlank(resources.getProductId())){
wechatLive.setRoomId(Long.valueOf(resources.getRoomId()));
wechatLive.setProductId(resources.getProductId());
String[] productIds = resources.getProductId().split(",");
List<Integer> pids = new ArrayList<>();
for (String productId : productIds) {
pids.add(Integer.valueOf(productId));
}
//添加商品
try {
wxMaService.getLiveService().addGoodsToRoom(resources.getRoomId().intValue(), pids);
this.saveOrUpdate(wechatLive);
} catch (WxErrorException e) {
e.printStackTrace();
}
}
return true;
}
@Override
public boolean saveLive(YxWechatLive resources){
WxMaService wxMaService = WxMaConfiguration.getWxMaService();
@ -259,4 +280,6 @@ public class YxWechatLiveServiceImpl extends BaseServiceImpl<YxWechatLiveMapper,
return generator.convert(pageList.getRecords(),YxWechatLiveDto.class);
}
}