package com.yeshi.fanli.service.impl.user;
|
|
import java.io.InputStream;
|
import java.math.BigDecimal;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
import javax.annotation.Resource;
|
import javax.transaction.Transactional;
|
|
import org.springframework.stereotype.Service;
|
import org.yeshi.utils.HttpUtil;
|
import org.yeshi.utils.QRCodeUtil;
|
import org.yeshi.utils.entity.FileUploadResult;
|
import org.yeshi.utils.exception.HttpException;
|
import org.yeshi.utils.tencentcloud.COSManager;
|
|
import com.yeshi.fanli.dao.mybatis.UserInfoMapper;
|
import com.yeshi.fanli.dao.mybatis.share.UserShareGoodsRecordMapper;
|
import com.yeshi.fanli.entity.bus.share.UserShareGoodsGroup;
|
import com.yeshi.fanli.entity.bus.share.UserShareGoodsRecord;
|
import com.yeshi.fanli.entity.bus.share.UserShareGoodsRecord.ShareSourceTypeEnum;
|
import com.yeshi.fanli.entity.bus.user.UserInfo;
|
import com.yeshi.fanli.entity.goods.CommonGoods;
|
import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;
|
import com.yeshi.fanli.exception.goods.CommonGoodsException;
|
import com.yeshi.fanli.exception.share.UserShareGoodsRecordException;
|
import com.yeshi.fanli.service.inter.config.ConfigService;
|
import com.yeshi.fanli.service.inter.goods.CommonGoodsService;
|
import com.yeshi.fanli.service.inter.hongbao.HongBaoManageService;
|
import com.yeshi.fanli.service.inter.user.UserAccountService;
|
import com.yeshi.fanli.service.inter.user.UserShareGoodsGroupService;
|
import com.yeshi.fanli.service.inter.user.UserShareGoodsRecordService;
|
import com.yeshi.fanli.util.AESUtil;
|
import com.yeshi.fanli.util.Constant;
|
import com.yeshi.fanli.util.ImageUtil;
|
import com.yeshi.fanli.util.StringUtil;
|
import com.yeshi.fanli.util.factory.CommonGoodsFactory;
|
import com.yeshi.fanli.util.taobao.TaoBaoUtil;
|
|
@Service
|
public class UserShareGoodsRecordServiceImpl implements UserShareGoodsRecordService {
|
|
@Resource
|
private ConfigService configService;
|
|
@Resource
|
private UserInfoMapper userInfoMapper;
|
|
@Resource
|
private UserAccountService userAccountService;
|
|
@Resource
|
private UserShareGoodsRecordMapper userShareGoodsRecordMapper;
|
|
@Resource
|
private CommonGoodsService commonGoodsService;
|
|
@Resource
|
private UserShareGoodsGroupService userShareGoodsGroupService;
|
|
@Resource
|
private HongBaoManageService hongBaoManageService;
|
|
@Override
|
public int insert(UserShareGoodsRecord record) {
|
return userShareGoodsRecordMapper.insert(record);
|
}
|
|
@Override
|
public int insertSelective(UserShareGoodsRecord record) {
|
return userShareGoodsRecordMapper.insertSelective(record);
|
}
|
|
@Override
|
public UserShareGoodsRecord selectByPrimaryKey(Long id) {
|
return userShareGoodsRecordMapper.selectByPrimaryKey(id);
|
}
|
|
@Override
|
public int updateByPrimaryKeySelective(UserShareGoodsRecord record) {
|
return userShareGoodsRecordMapper.updateByPrimaryKeySelective(record);
|
}
|
|
@Override
|
public int updateByPrimaryKey(UserShareGoodsRecord record) {
|
return userShareGoodsRecordMapper.updateByPrimaryKey(record);
|
}
|
|
|
@Override
|
public List<UserShareGoodsRecord> listQueryByUid(long start, int count, Long uid, String source) {
|
return userShareGoodsRecordMapper.listQueryByUid(start, count, uid, source);
|
}
|
|
@Override
|
public long countQueryByUid(Long uid, String source) {
|
return userShareGoodsRecordMapper.countQueryByUid(uid, source);
|
}
|
|
|
@Override
|
public List<UserShareGoodsRecord> listCountRecord(List<Long> list) {
|
return userShareGoodsRecordMapper.listCountRecord(list);
|
}
|
|
@Override
|
public List<UserShareGoodsRecord> getMyShareGoodsRecords(long start, int count, Long uid, String source) {
|
|
List<UserShareGoodsRecord> list = listQueryByUid(start, count, uid, source);
|
if (list == null) {
|
list = new ArrayList<UserShareGoodsRecord>();
|
}
|
|
if (list.size() > 0) {
|
List<Long> listId = new ArrayList<Long>();
|
|
for (UserShareGoodsRecord userShareGoodsRecord: list) {
|
userShareGoodsRecord.setShareTime(userShareGoodsRecord.getUpdateTime().getTime());
|
userShareGoodsRecord.setCreateTime(null);
|
userShareGoodsRecord.setUpdateTime(null);
|
listId.add(userShareGoodsRecord.getId());
|
}
|
|
// 今日浏览统计
|
List<UserShareGoodsRecord> listTodayBrowse= userShareGoodsRecordMapper.listCountTodayBrowse(listId);
|
|
// 订单、浏览数量、金额统计
|
List<UserShareGoodsRecord> listCountRecord = listCountRecord(listId);
|
|
if ((listCountRecord != null && listCountRecord.size() > 0)
|
|| (listTodayBrowse != null && listTodayBrowse.size() > 0)) {
|
|
for (UserShareGoodsRecord shareRecord: list) {
|
Long id = shareRecord.getId() ;
|
|
if (listTodayBrowse != null && listTodayBrowse.size() > 0){
|
for (UserShareGoodsRecord goodsRecord: listTodayBrowse) {
|
Long recordId = goodsRecord.getId();
|
if (id == recordId || id.equals(recordId)) {
|
shareRecord.setTodayBrowse(goodsRecord.getTodayBrowse());
|
break;
|
}
|
}
|
}
|
|
if (listCountRecord != null && listCountRecord.size() > 0) {
|
for (UserShareGoodsRecord goodsRecord: listCountRecord) {
|
Long recordId = goodsRecord.getId();
|
if (id == recordId || id.equals(recordId)) {
|
shareRecord.setTotalBrowse(goodsRecord.getTotalBrowse());
|
shareRecord.setTotalOrder(goodsRecord.getTotalOrder());
|
|
BigDecimal totalMoney = goodsRecord.getTotalMoney();
|
if (totalMoney != null && totalMoney.compareTo(new BigDecimal(0))>0 ) {
|
shareRecord.setTotalMoney(goodsRecord.getTotalMoney());
|
} else {
|
shareRecord.setTotalMoney(goodsRecord.getRevenueMoney());
|
}
|
shareRecord.setRevenueMoney(null);
|
|
|
Integer totalGoods = goodsRecord.getTotalGoods();
|
shareRecord.setTotalGoods(totalGoods);
|
if (totalGoods > 1) {
|
shareRecord.setShareType(UserShareGoodsRecord.SHARETYPE_GROUP);
|
} else {
|
shareRecord.setShareType(UserShareGoodsRecord.SHARETYPE_SINGLE);
|
}
|
break;
|
}
|
}
|
}
|
}
|
}
|
}
|
|
return list;
|
}
|
|
/**
|
* 保存分享记录
|
* @param userShareGoodsRecord 分享记录： uid、picture、source 为必输入
|
* @throws UserShareGoodsRecordException
|
*/
|
@Override
|
public void save(Long uid, ShareSourceTypeEnum source , TaoBaoGoodsBrief taoBaoGoodsBrief) throws UserShareGoodsRecordException {
|
|
if (taoBaoGoodsBrief == null) {
|
throw new UserShareGoodsRecordException(1, "分享商品不能为空");
|
}
|
|
if (uid == null) {
|
throw new UserShareGoodsRecordException(1, "用户ID不能为空");
|
}
|
|
if (source == null) {
|
throw new UserShareGoodsRecordException(1, "分享来源不能为空");
|
}
|
|
UserShareGoodsRecord userShareGoodsRecord = new UserShareGoodsRecord();
|
userShareGoodsRecord.setUid(uid);
|
userShareGoodsRecord.setSource(source);
|
// 单个商品分享
|
singleGoodsShare(userShareGoodsRecord, taoBaoGoodsBrief);
|
}
|
|
|
/**
|
* 保存分享记录
|
* @param userShareGoodsRecord 分享记录： uid、picture、source 为必输入
|
* @throws UserShareGoodsRecordException
|
*/
|
@Override
|
public FileUploadResult save(Long uid, ShareSourceTypeEnum source , List<TaoBaoGoodsBrief> listGoods) throws UserShareGoodsRecordException {
|
|
if (listGoods == null || listGoods.size() <= 1) {
|
throw new UserShareGoodsRecordException(1, "分享商品数量不足");
|
}
|
|
if (uid == null) {
|
throw new UserShareGoodsRecordException(1, "用户ID不能为空");
|
}
|
|
if (source == null) {
|
throw new UserShareGoodsRecordException(1, "分享来源不能为空");
|
}
|
|
UserShareGoodsRecord userShareGoodsRecord = new UserShareGoodsRecord();
|
userShareGoodsRecord.setUid(uid);
|
userShareGoodsRecord.setSource(source);
|
// 取一个商品图片作为主图
|
userShareGoodsRecord.setPicture(listGoods.get(0).getPictUrl());
|
|
Date date = new Date();
|
userShareGoodsRecord.setCreateTime(date);
|
userShareGoodsRecord.setUpdateTime(date);
|
userShareGoodsRecordMapper.insertSelective(userShareGoodsRecord);
|
|
FileUploadResult shareImg = createShareImg(userShareGoodsRecord, listGoods);
|
|
// 多个商品分享
|
multipleGoodsShare(userShareGoodsRecord, listGoods);
|
|
return shareImg;
|
|
}
|
|
/**
|
* 单个商品分享生成记录
|
* @param userShareGoodsRecord
|
* @param taoBaoGoodsBrief
|
*/
|
@Transactional
|
public void singleGoodsShare(UserShareGoodsRecord userShareGoodsRecord, TaoBaoGoodsBrief taoBaoGoodsBrief) {
|
|
CommonGoods commonGoods = CommonGoodsFactory.create(taoBaoGoodsBrief);
|
try {
|
CommonGoods resultCommonGoods = commonGoodsService.addOrUpdateCommonGoods(commonGoods);
|
|
if (resultCommonGoods == null) {
|
return;
|
}
|
|
UserShareGoodsGroup shareGoodsGroup = null;
|
|
UserShareGoodsGroup singleGoods = userShareGoodsGroupService.getSingleGoods(resultCommonGoods.getId(),
|
userShareGoodsRecord.getUid());
|
if (singleGoods != null && singleGoods.getTotalGoods() == 1) {
|
// 同一个商品多次分享
|
shareGoodsGroup = singleGoods;
|
}
|
|
if (shareGoodsGroup != null) {
|
// 单个商品多次分享
|
userShareGoodsRecord.setPicture(taoBaoGoodsBrief.getPictUrl());
|
userShareGoodsRecord.setId(shareGoodsGroup.getRecordId());
|
userShareGoodsRecord.setUpdateTime(new Date());
|
userShareGoodsRecordMapper.updateByPrimaryKey(userShareGoodsRecord);
|
|
Integer totalOrder = shareGoodsGroup.getTotalOrder();
|
if (totalOrder == null ||totalOrder == 0 || totalOrder.equals(0)) {
|
// 预计金额
|
String rateStr = hongBaoManageService.get("hongbao_goods_proportion");
|
shareGoodsGroup.setUpdateTime(new Date());
|
BigDecimal money = TaoBaoUtil.getGoodsHongBaoMoney(taoBaoGoodsBrief, new BigDecimal(rateStr));
|
shareGoodsGroup.setTotalMoney(money);
|
|
userShareGoodsGroupService.updateByPrimaryKeySelective(shareGoodsGroup);
|
}
|
} else {
|
// 单个商品第一次分享
|
Date date = new Date();
|
userShareGoodsRecord.setPicture(taoBaoGoodsBrief.getPictUrl());
|
userShareGoodsRecord.setCreateTime(date);
|
userShareGoodsRecord.setUpdateTime(date);
|
userShareGoodsRecordMapper.insertSelective(userShareGoodsRecord);
|
|
shareGoodsGroup = new UserShareGoodsGroup();
|
shareGoodsGroup.setTotalOrder(0);
|
shareGoodsGroup.setTotalBrowse(0);
|
shareGoodsGroup.setTodayBrowse(0);
|
shareGoodsGroup.setCreateTime(date);
|
shareGoodsGroup.setUpdateTime(date);
|
shareGoodsGroup.setCommonGoods(resultCommonGoods);
|
shareGoodsGroup.setRecordId(userShareGoodsRecord.getId());
|
|
// 预计金额
|
String rateStr = hongBaoManageService.get("hongbao_goods_proportion");
|
BigDecimal money = TaoBaoUtil.getGoodsHongBaoMoney(taoBaoGoodsBrief, new BigDecimal(rateStr));
|
shareGoodsGroup.setTotalMoney(money);
|
|
userShareGoodsGroupService.insertSelective(shareGoodsGroup);
|
}
|
|
} catch (CommonGoodsException e) {
|
e.printStackTrace();
|
}
|
|
}
|
|
|
/**
|
* 多个商品分享生成记录
|
* @param userShareGoodsRecord
|
* @param listGoods
|
*/
|
@Transactional
|
public void multipleGoodsShare(UserShareGoodsRecord userShareGoodsRecord, List<TaoBaoGoodsBrief> listGoods) {
|
|
// 分享记录
|
Date date = new Date();
|
String rateStr = hongBaoManageService.get("hongbao_goods_proportion");
|
|
List<UserShareGoodsGroup> listGroup = new ArrayList<UserShareGoodsGroup>();
|
for (TaoBaoGoodsBrief taoBaoGoodsBrief: listGoods) {
|
CommonGoods commonGoods = CommonGoodsFactory.create(taoBaoGoodsBrief);
|
try {
|
CommonGoods resultCommonGoods = commonGoodsService.addOrUpdateCommonGoods(commonGoods);
|
UserShareGoodsGroup shareGoodsGroup = new UserShareGoodsGroup();
|
shareGoodsGroup.setTotalOrder(0);
|
shareGoodsGroup.setTotalBrowse(0);
|
shareGoodsGroup.setTodayBrowse(0);
|
shareGoodsGroup.setCreateTime(date);
|
shareGoodsGroup.setUpdateTime(date);
|
shareGoodsGroup.setCommonGoods(resultCommonGoods);
|
shareGoodsGroup.setRecordId(userShareGoodsRecord.getId());
|
|
// 预计金额
|
BigDecimal money = TaoBaoUtil.getGoodsHongBaoMoney(taoBaoGoodsBrief, new BigDecimal(rateStr));
|
shareGoodsGroup.setTotalMoney(money);
|
|
listGroup.add(shareGoodsGroup);
|
|
} catch (CommonGoodsException e) {
|
e.printStackTrace();
|
continue;
|
}
|
}
|
|
if (listGroup.size() > 0) {
|
userShareGoodsGroupService.insertBatch(listGroup);
|
}
|
|
}
|
|
|
|
|
|
/**
|
* 生成分享图
|
* @param uid 用户id
|
* @param shareId 分享记录id
|
* @param source 来源
|
* @param listGoods
|
* @return
|
* @throws UserShareGoodsRecordException
|
*/
|
public FileUploadResult createShareImg (UserShareGoodsRecord shareRecord, List<TaoBaoGoodsBrief> listGoods)
|
throws UserShareGoodsRecordException{
|
|
Long uid = shareRecord.getUid();
|
Long shareId = shareRecord.getId();
|
String source = shareRecord.getSource().getDesc();
|
|
String url = String.format("http://%s/shareMuchImg2.html?uid=%s&shareId=%s&source=%s", configService.getH5Host(),
|
AESUtil.encrypt(uid + "", Constant.UIDAESKEY), shareRecord.getId() + "", source +"");
|
|
String shortLink = HttpUtil.getShortLink(url);
|
if (!StringUtil.isNullOrEmpty(shortLink)) {
|
url = shortLink;
|
}
|
InputStream erCodeInputStream = null;
|
|
// 生成链接二维码
|
try {
|
erCodeInputStream = QRCodeUtil.getInstance(500).encode(url);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
|
// 获取到用户的头像
|
UserInfo user = userInfoMapper.selectByPrimaryKey(uid);
|
if (user == null) {
|
throw new UserShareGoodsRecordException(1, "用户信息不存在");
|
}
|
|
InputStream portrait = null;
|
|
if (!StringUtil.isNullOrEmpty(user.getPortrait())) {
|
try {
|
portrait = HttpUtil.downLoadImg(user.getPortrait());
|
} catch (HttpException e) {
|
String portraitUrl = userAccountService.repairPortrait(uid);
|
if (StringUtil.isNullOrEmpty(portraitUrl))
|
throw new UserShareGoodsRecordException(1, "获取头像出错");
|
else {
|
// 再次获取头像
|
try {
|
portrait = HttpUtil.downLoadImg(portraitUrl);
|
} catch (HttpException e1) {
|
throw new UserShareGoodsRecordException(1, "获取头像出错");
|
}
|
}
|
}
|
}
|
|
InputStream inputStream = ImageUtil.drawGoodsShareBigImg(erCodeInputStream, portrait, listGoods);
|
|
FileUploadResult shareImg = COSManager.getInstance().uploadInputStream(inputStream,
|
"sharegoods/share_" + uid + "_" + shareId + "_" + System.currentTimeMillis() + ".png");
|
|
return shareImg;
|
}
|
|
}
|
