package com.yeshi.fanli.service.impl.user.cloud;
|
|
import java.math.BigDecimal;
|
import java.util.ArrayList;
|
import java.util.Arrays;
|
import java.util.Date;
|
import java.util.List;
|
|
import javax.annotation.Resource;
|
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.yeshi.utils.BigDecimalUtil;
|
|
import com.aliyun.openservices.ons.api.Message;
|
import com.aliyun.openservices.ons.api.Producer;
|
import com.yeshi.fanli.dao.mybatis.user.cloud.UserCloudMapper;
|
import com.yeshi.fanli.dto.aitaoker.RobotInfoDTO;
|
import com.yeshi.fanli.dto.aitaoker.WeiXinGroupDTO;
|
import com.yeshi.fanli.dto.jd.JDCouponInfo;
|
import com.yeshi.fanli.dto.jd.JDPingouInfo;
|
import com.yeshi.fanli.dto.mq.user.UserTopicTagEnum;
|
import com.yeshi.fanli.dto.mq.user.body.UserCloudMQMsg;
|
import com.yeshi.fanli.dto.pdd.PDDGoodsDetail;
|
import com.yeshi.fanli.dto.suning.SuningGoodsImg;
|
import com.yeshi.fanli.dto.suning.SuningGoodsInfo;
|
import com.yeshi.fanli.dto.vip.VIPConvertResultDTO;
|
import com.yeshi.fanli.dto.vip.goods.VIPGoodsInfo;
|
import com.yeshi.fanli.entity.bus.user.UserExtraTaoBaoInfo;
|
import com.yeshi.fanli.entity.bus.user.UserInfo;
|
import com.yeshi.fanli.entity.bus.user.cloud.CloudOrderMenuEnum;
|
import com.yeshi.fanli.entity.bus.user.cloud.UserCloud;
|
import com.yeshi.fanli.entity.bus.user.cloud.UserCloudGoods;
|
import com.yeshi.fanli.entity.bus.user.cloud.UserCloudGroup;
|
import com.yeshi.fanli.entity.bus.user.cloud.UserCloudManage;
|
import com.yeshi.fanli.entity.bus.user.cloud.UserCloudSendContent;
|
import com.yeshi.fanli.entity.bus.user.cloud.UserCloudSendRecord;
|
import com.yeshi.fanli.entity.dynamic.CommentInfo;
|
import com.yeshi.fanli.entity.dynamic.GoodsEvaluate;
|
import com.yeshi.fanli.entity.dynamic.GoodsEvaluate.EvaluateEnum;
|
import com.yeshi.fanli.entity.dynamic.ImgInfo;
|
import com.yeshi.fanli.entity.dynamic.ImgInfo.ImgEnum;
|
import com.yeshi.fanli.entity.goods.CommonGoods;
|
import com.yeshi.fanli.entity.jd.JDGoods;
|
import com.yeshi.fanli.entity.system.ConfigKeyEnum;
|
import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;
|
import com.yeshi.fanli.entity.taobao.TaoBaoLink;
|
import com.yeshi.fanli.exception.goods.ConvertLinkExceptionException;
|
import com.yeshi.fanli.exception.share.ShareGoodsException;
|
import com.yeshi.fanli.exception.user.cloud.UserCloudException;
|
import com.yeshi.fanli.exception.user.cloud.UserCloudGoodsException;
|
import com.yeshi.fanli.log.LogHelper;
|
import com.yeshi.fanli.service.inter.config.ConfigService;
|
import com.yeshi.fanli.service.inter.dynamic.GoodsEvaluateService;
|
import com.yeshi.fanli.service.inter.goods.CommonGoodsService;
|
import com.yeshi.fanli.service.inter.goods.ShareGoodsService;
|
import com.yeshi.fanli.service.inter.goods.ShareGoodsTextTemplateService;
|
import com.yeshi.fanli.service.inter.order.OrderHongBaoMoneyComputeService;
|
import com.yeshi.fanli.service.inter.order.config.HongBaoManageService;
|
import com.yeshi.fanli.service.inter.user.QrCodeService;
|
import com.yeshi.fanli.service.inter.user.UserInfoExtraService;
|
import com.yeshi.fanli.service.inter.user.UserInfoService;
|
import com.yeshi.fanli.service.inter.user.cloud.UserCloudGoodsService;
|
import com.yeshi.fanli.service.inter.user.cloud.UserCloudGroupService;
|
import com.yeshi.fanli.service.inter.user.cloud.UserCloudManageService;
|
import com.yeshi.fanli.service.inter.user.cloud.UserCloudSendContentService;
|
import com.yeshi.fanli.service.inter.user.cloud.UserCloudSendRecordService;
|
import com.yeshi.fanli.service.inter.user.cloud.UserCloudService;
|
import com.yeshi.fanli.service.inter.user.tb.UserExtraTaoBaoInfoService;
|
import com.yeshi.fanli.service.manger.goods.ConvertLinkManager;
|
import com.yeshi.fanli.util.Constant;
|
import com.yeshi.fanli.util.ImageToBase64;
|
import com.yeshi.fanli.util.MoneyBigDecimalUtil;
|
import com.yeshi.fanli.util.RedisManager;
|
import com.yeshi.fanli.util.StringUtil;
|
import com.yeshi.fanli.util.aitaoker.AitaokerApiUtil;
|
import com.yeshi.fanli.util.cache.JDGoodsCacheUtil;
|
import com.yeshi.fanli.util.cache.PinDuoDuoCacheUtil;
|
import com.yeshi.fanli.util.jd.JDApiUtil;
|
import com.yeshi.fanli.util.jd.JDUtil;
|
import com.yeshi.fanli.util.pinduoduo.PinDuoDuoApiUtil;
|
import com.yeshi.fanli.util.pinduoduo.PinDuoDuoUtil;
|
import com.yeshi.fanli.util.rocketmq.MQMsgBodyFactory;
|
import com.yeshi.fanli.util.rocketmq.MQTopicName;
|
import com.yeshi.fanli.util.suning.SuningApiUtil;
|
import com.yeshi.fanli.util.suning.SuningUtil;
|
import com.yeshi.fanli.util.taobao.TaoBaoUtil;
|
import com.yeshi.fanli.util.vipshop.VipShopApiUtil;
|
import com.yeshi.fanli.util.vipshop.VipShopUtil;
|
import com.yeshi.fanli.vo.goods.GoodsDetailVO;
|
|
@Service
|
public class UserCloudServiceImpl implements UserCloudService {
|
|
@Resource
|
private UserCloudMapper userCloudMapper;
|
|
@Resource
|
private UserCloudGroupService userCloudGroupService;
|
|
@Resource
|
private GoodsEvaluateService goodsEvaluateService;
|
|
@Resource
|
private ConvertLinkManager convertLinkManager;
|
|
@Resource
|
private UserCloudGoodsService userCloudGoodsService;
|
|
@Resource
|
private UserInfoExtraService userInfoExtraService;
|
|
@Resource
|
private UserExtraTaoBaoInfoService userExtraTaoBaoInfoService;
|
|
@Resource
|
private UserInfoService userInfoService;
|
|
@Resource
|
private ShareGoodsService shareGoodsService;
|
|
@Resource
|
private ConfigService configService;
|
|
@Resource
|
private JDGoodsCacheUtil jdGoodsCacheUtil;
|
|
@Resource
|
private PinDuoDuoCacheUtil pinDuoDuoCacheUtil;
|
|
@Resource
|
private QrCodeService qrCodeService;
|
|
@Resource
|
private RedisManager redisManager;
|
|
@Resource
|
private OrderHongBaoMoneyComputeService orderHongBaoMoneyComputeService;
|
|
@Resource
|
private HongBaoManageService hongBaoManageService;
|
|
@Resource
|
private ShareGoodsTextTemplateService shareGoodsTextTemplateService;
|
|
@Resource
|
private CommonGoodsService commonGoodsService;
|
|
@Resource
|
private UserCloudSendRecordService userCloudSendRecordService;
|
|
@Resource
|
private UserCloudSendContentService userCloudSendContentService;
|
|
@Resource
|
private UserCloudManageService userCloudManageService;
|
|
@Resource(name = "producer")
|
private Producer producer;
|
|
|
@Override
|
public UserCloud getValidByUid(Long uid) {
|
return userCloudMapper.getValidByUid(uid);
|
}
|
|
@Override
|
public UserCloud getLastByUid(Long uid) {
|
return userCloudMapper.getLastByUid(uid);
|
}
|
|
@Override
|
public long countByUid(Long uid) {
|
Long count = userCloudMapper.countByUid(uid);
|
return count;
|
}
|
|
|
@Override
|
public List<UserCloud> query(int page, int count,String key, Integer state) {
|
return userCloudMapper.query((page-1)* count, count, key, state);
|
}
|
|
@Override
|
public long count(String key, Integer state) {
|
Long count = userCloudMapper.count(key, state);
|
if (count == null)
|
count = 0L;
|
return count;
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void updateWXInfo(Long uid, String wxId, String wxName, String wxPortrait) throws UserCloudException {
|
UserCloud userCloud = userCloudMapper.getValidByUid(uid);
|
if (userCloud == null)
|
throw new UserCloudException(1, "云发单已过期");
|
|
// 更新信息
|
UserCloud update = new UserCloud();
|
update.setId(userCloud.getId());
|
update.setWxId(wxId);
|
update.setWxName(wxName);
|
update.setWxPortrait(wxPortrait);
|
userCloudMapper.updateByPrimaryKeySelective(update);
|
|
// 微信号变化-清空群信息
|
if (!wxId.equals(userCloud.getWxId())) {
|
userCloudGroupService.deleteGroupByUid(uid);
|
}
|
|
// 加入朋友圈
|
if (StringUtil.isNullOrEmpty(userCloud.getWxId())) {
|
userCloudGroupService.addCircle(uid);
|
}
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void openCloud(Long uid, Long orderId, CloudOrderMenuEnum menuEnum) throws UserCloudException {
|
UserCloud existCloud = userCloudMapper.getByOrderId(orderId);
|
if (existCloud != null) {
|
return; // 该订单已处理完成
|
}
|
|
boolean renew = false;
|
UserCloud userCloud = userCloudMapper.getLastByUid(uid);
|
if (userCloud != null) {
|
// 续费
|
if (userCloud.getEndTime().getTime() > java.lang.System.currentTimeMillis())
|
renew = true;
|
// 验证套餐是否相同
|
if (renew && userCloud.getRobotType() != menuEnum.getType()) {
|
LogHelper.cloudInfo("方法openCloud: [uid=" + uid + "][订单ID=" + orderId + "]已有其他云发单套餐还未结束");
|
throw new UserCloudException(1, "已有其他云发单套餐还未结束");
|
}
|
}
|
|
RobotInfoDTO dto = null;
|
if (renew) { // 续费
|
dto = AitaokerApiUtil.robotRenewals(userCloud.getRobotId(), menuEnum.getMonth());
|
} else {
|
dto = AitaokerApiUtil.robotCreate(menuEnum.getMonth(), menuEnum.getType(), "wechatrobot", null);
|
}
|
|
if (dto == null) {
|
LogHelper.cloudInfo("方法openCloud: [uid=" + uid + "][订单ID=" + orderId + "]机器人失败： 返回空值");
|
throw new UserCloudException(1, "机器人获取失败");
|
}
|
|
String endTimeStr = dto.getEndTime();
|
if (StringUtil.isNullOrEmpty(endTimeStr)) {
|
LogHelper.cloudInfo("方法openCloud: [uid=" + uid + "][订单ID=" + orderId + "]机器人失败： 返回时间为空");
|
throw new UserCloudException(1, "机器人返回时间为空");
|
}
|
|
long endTime = 0;
|
try {
|
endTime = Long.parseLong(endTimeStr);
|
} catch (Exception e) {
|
LogHelper.cloudInfo("方法openCloud: [uid=" + uid + "][订单ID=" + orderId + "]机器人失败： 返回时间格式不正确");
|
throw new UserCloudException(1, "机器人返回时间格式不正确");
|
}
|
|
Integer robotId = dto.getId();
|
if (robotId == null) {
|
LogHelper.cloudInfo("方法openCloud: [uid=" + uid + "][订单ID=" + orderId + "]机器人失败： 机器人ID返回为空");
|
throw new UserCloudException(1, "机器人ID返回为空");
|
}
|
|
Integer groupNum = dto.getGroupNum();
|
if (groupNum == null) {
|
LogHelper.cloudInfo("方法openCloud: [uid=" + uid + "][订单ID=" + orderId + "]机器人失败： groupNum返回为空");
|
throw new UserCloudException(1, "groupNum返回为空");
|
}
|
|
UserCloud newCloud = new UserCloud();
|
newCloud.setUid(uid);
|
newCloud.setOrderId(orderId);
|
newCloud.setGroupNum(groupNum);
|
newCloud.setRobotId(robotId);
|
newCloud.setRobotType(menuEnum.getType());
|
if (renew) {
|
newCloud.setStartTime(userCloud.getStartTime());
|
} else {
|
newCloud.setStartTime(new Date());
|
}
|
newCloud.setEndTime(new Date(endTime * 1000)); // Unix 转换 普通时间
|
newCloud.setCreateTime(new Date());
|
userCloudMapper.insertSelective(newCloud);
|
|
// 开启发圈功能
|
userCloudManageService.save(uid, null, null);
|
}
|
|
@Override
|
public void searchGroup(Long uid) throws UserCloudException {
|
UserCloud userCloud = userCloudMapper.getValidByUid(uid);
|
if (userCloud == null)
|
throw new UserCloudException(1, "云发单已过期");
|
|
Integer robotId = userCloud.getRobotId();
|
if (robotId == null)
|
throw new UserCloudException(1, "云发单机器人不存在");
|
|
List<WeiXinGroupDTO> list = AitaokerApiUtil.getContract(robotId);
|
if (list == null || list.size() == 0)
|
throw new UserCloudException(1, "未检索到对应群");
|
|
for (WeiXinGroupDTO dto : list) {
|
userCloudGroupService.addGroup(uid, dto.getGroupId(), dto.getGroupName(), userCloud.getGroupNum());
|
}
|
}
|
|
@Override
|
public void sendByDynamic(Long uid, String id) throws UserCloudException{
|
sendCircleByDynamic(uid, id, UserCloudSendRecord.SEND_WAY_MANUAL);
|
}
|
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void autoSendByDynamic(Long uid, String id) {
|
boolean official = false;
|
UserCloudManage cloudManage = userCloudManageService.selectByPrimaryKey(uid);
|
if (cloudManage != null) {
|
if (cloudManage.getOfficial() != null)
|
official = cloudManage.getOfficial();
|
}
|
|
if (!official)
|
return;
|
|
try {
|
sendCircleByDynamic(uid, id, UserCloudSendRecord.SEND_WAY_AUTO);
|
} catch (UserCloudException e) {
|
LogHelper.cloudInfo("autoSendByDynamic - [uid:" +uid + " 动态id:"+ id + "]原因："+ e.getMsg());
|
}
|
}
|
|
|
private void sendCircleByDynamic(Long uid, String id, int way) throws UserCloudException {
|
UserInfo user = userInfoService.getUserByIdWithMybatis(uid);
|
if (user == null)
|
throw new UserCloudException(1, "用户信息不存在");
|
|
if (user != null && user.getState() != UserInfo.STATE_NORMAL) {
|
throw new UserCloudException(Constant.CODE_FORBIDDEN_USER, Constant.FORBIDDEN_USER_REASON_DESC);
|
}
|
|
String inviteCode = userInfoExtraService.getInviteCodeByUid(uid);
|
if (StringUtil.isNullOrEmpty(inviteCode))
|
throw new UserCloudException(3, "邀请码未激活");
|
|
UserExtraTaoBaoInfo taoBaoInfo = userExtraTaoBaoInfoService.getByUid(uid);
|
String relationId = null;
|
if (taoBaoInfo != null && taoBaoInfo.getRelationId() != null && taoBaoInfo.getRelationValid() != null
|
&& taoBaoInfo.getRelationValid() == true)
|
relationId = taoBaoInfo.getRelationId();
|
|
if (StringUtil.isNullOrEmpty(relationId))
|
throw new UserCloudException(2, "淘宝未授权，请前往\"我的\"绑定淘宝账号");
|
|
|
// 验证是否开通
|
UserCloud userCloud = userCloudMapper.getValidByUid(uid);
|
if (userCloud == null)
|
throw new UserCloudException(1001, "云发单已过期");
|
|
Integer robotId = userCloud.getRobotId();
|
if (robotId == null)
|
throw new UserCloudException(1002, "云发单机器人不存在");
|
|
String wxId = userCloud.getWxId();
|
if (StringUtil.isNullOrEmpty(wxId))
|
throw new UserCloudException(1003, "微信号不存在，请先微信登录");
|
|
// 验证开启状态
|
List<UserCloudGroup> listGroup = userCloudGroupService.listByUid(uid);
|
if (listGroup == null || listGroup.size() == 0)
|
throw new UserCloudException(1004, "请先微信登录");
|
|
List<UserCloudGroup> listOpen = new ArrayList<>();
|
for (UserCloudGroup cloudGrou : listGroup) {
|
if (cloudGrou.getState()) {
|
listOpen.add(cloudGrou);
|
}
|
}
|
if (listOpen.size() == 0)
|
throw new UserCloudException(1005, "请先开启云发单群功能");
|
|
|
// 验证发圈是否可行
|
GoodsEvaluate evaluate = goodsEvaluateService.getById(id);
|
if (evaluate == null || evaluate.getState() == 0)
|
throw new UserCloudException(1, "该内容已下架");
|
|
if (evaluate.getType() != EvaluateEnum.single && evaluate.getType() != EvaluateEnum.activity)
|
throw new UserCloudException(1, "该内容不支持云发单");
|
|
// 验证是否可转链
|
List<CommentInfo> comments = evaluate.getComments();
|
if (comments == null || comments.size() == 0)
|
throw new UserCloudException(1, "该内容不能转链");
|
|
// 检测微信是否登录状态
|
if (!AitaokerApiUtil.onlineCheck(robotId)) {
|
throw new UserCloudException(1003, "请重新登录微信");
|
}
|
|
|
boolean hasToken = false;
|
List<String> listComment = new ArrayList<>();
|
for (CommentInfo commentInfo : comments) {
|
String comment = null;
|
try {
|
comment = convertLinkManager.convertLinkFromText(commentInfo.getContent(), uid, true);
|
hasToken = true;
|
} catch (ConvertLinkExceptionException e) {
|
if (e.getCode() != ConvertLinkExceptionException.CODE_NONE) {
|
throw new UserCloudException(1, e.getMsg());
|
}
|
} catch (Exception e) {
|
LogHelper.errorDetailInfo(e);
|
throw new UserCloudException(1, "该内容包含可转链口令或链接");
|
}
|
|
if (StringUtil.isNullOrEmpty(comment))
|
comment = commentInfo.getContent();
|
|
// 替换价格
|
if (evaluate.getType() == EvaluateEnum.single) {
|
GoodsDetailVO goods = evaluate.getGoods();
|
comment = comment.replace("[原价]", MoneyBigDecimalUtil.getWithNoZera(goods.getZkPrice()) + "");
|
if (!goods.isHasCoupon()) {
|
comment = comment.replace("领券抢购", "抢购");
|
comment = comment.replace("【券后价】[券后价]元", "");
|
} else {
|
comment = comment.replace("[券后价]", MoneyBigDecimalUtil.getWithNoZera(goods.getCouponPrice()) + "");
|
}
|
comment = comment.replace("\r\n\r\n", "\r\n").replace("\r\n\r\n", "\r\n").replace("\r\n\r\n", "\r\n");
|
}
|
|
listComment.add(comment);
|
}
|
|
if (!hasToken)
|
throw new UserCloudException(1, "该内容包含可转链口令或链接");
|
|
|
String qrCode = null;
|
String cloudPic = null;
|
ImgInfo imgVideo = null;
|
List<String> listImg = new ArrayList<>();
|
|
List<ImgInfo> imgs = evaluate.getImgList();
|
if (imgs != null && imgs.size() > 0) {
|
for (ImgInfo imgInfo : imgs) {
|
if (imgInfo.getType() == ImgEnum.video) {
|
imgVideo = imgInfo;
|
continue;
|
}
|
|
if (imgInfo.getType() == ImgEnum.goods) {
|
cloudPic = imgInfo.getUrl();
|
}
|
listImg.add(imgInfo.getUrl());
|
|
// 取消二维码图
|
// GoodsDetailVO goodsVO = imgInfo.getGoodsVO();
|
// if (goodsVO == null) {
|
// listImg.add(imgInfo.getUrl());
|
// } else {
|
// String jumpLink = getJumpLink(goodsVO, user, relationId, inviteCode, imgInfo.getUrl());
|
// if (!StringUtil.isNullOrEmpty(jumpLink)) {
|
// qrCode = jumpLink;
|
// }
|
// }
|
}
|
|
if (cloudPic == null) {
|
cloudPic = imgs.get(0).getUrl();
|
}
|
}
|
|
|
// 保存发送记录
|
UserCloudSendRecord sendRecord = new UserCloudSendRecord();
|
sendRecord.setUid(uid);
|
sendRecord.setSendId(id);
|
sendRecord.setSendWay(way);
|
sendRecord.setWxId(wxId);
|
sendRecord.setRobotId(robotId);
|
sendRecord.setSendTime(new Date());
|
sendRecord.setSendOrigin(UserCloudSendRecord.ORIGIN_STORE);
|
UserCloudSendRecord result = userCloudSendRecordService.save(sendRecord);
|
String pid = result.getId();
|
|
for (UserCloudGroup cloudGroup: listOpen) {
|
String title = evaluate.getTitle();
|
|
UserCloudSendContent sendContent = new UserCloudSendContent();
|
sendContent.setPid(pid);
|
sendContent.setUid(uid);
|
sendContent.setGroupId(cloudGroup.getGroupId());
|
sendContent.setCreateTime(new Date());
|
|
if(cloudGroup.getType() == UserCloudGroup.TYPE_CIRCLE) { // 朋友圈
|
String circleId = null;
|
sendContent.setType(UserCloudSendContent.TYPE_CIRCLE);
|
|
if (imgVideo == null) {
|
String picUrl = "";
|
if (!StringUtil.isNullOrEmpty(qrCode))
|
picUrl += qrCode;
|
|
if (listImg.size() > 0) {
|
for (String img: listImg) {
|
picUrl += "," + img;
|
}
|
}
|
sendContent.setTitle(title);
|
sendContent.setPicUrl(picUrl);
|
// 发送图文
|
circleId = AitaokerApiUtil.macsendCircle(robotId, title, picUrl);
|
} else {
|
sendContent.setPicUrl(imgVideo.getUrl());
|
sendContent.setVideoUrl(imgVideo.getVideoUrl());
|
// 发送视频
|
circleId = AitaokerApiUtil.macsendCircleVideo(robotId, imgVideo.getVideoUrl(), imgVideo.getUrl());
|
}
|
|
// 评论文本
|
if (!StringUtil.isNullOrEmpty(circleId)) {
|
sendContent.setState(true);
|
List<String> list = new ArrayList<>();
|
for (String comment: listComment) {
|
boolean macsend = AitaokerApiUtil.macsendCircleComment(robotId, wxId, circleId, comment);
|
if (macsend) {
|
list.add(comment);
|
}
|
}
|
sendContent.setComments(list);
|
}
|
} else { // 群
|
sendContent.setType(UserCloudSendContent.TYPE_GROUP);
|
|
// 发送文本
|
if (!StringUtil.isNullOrEmpty(title)) {
|
boolean macsend = AitaokerApiUtil.macsendText(robotId, cloudGroup.getGroupId(), title);
|
if (macsend)
|
sendContent.setTitle(title);
|
}
|
|
// 发送图片
|
if (!StringUtil.isNullOrEmpty(cloudPic)) {
|
try {
|
String imgBase64 = ImageToBase64.NetImageToBase64(cloudPic);
|
boolean macsend = AitaokerApiUtil.macsendImgBase64(robotId, cloudGroup.getGroupId(), imgBase64);
|
if (macsend)
|
sendContent.setPicUrl(cloudPic);
|
} catch (Exception e) {
|
LogHelper.errorDetailInfo(e);
|
}
|
}
|
|
// 评论文本
|
List<String> list = new ArrayList<>();
|
for (String comment: listComment) {
|
boolean macsend = AitaokerApiUtil.macsendText(robotId, cloudGroup.getGroupId(), comment);
|
if (macsend) {
|
list.add(comment);
|
}
|
}
|
sendContent.setState(true);
|
sendContent.setComments(list);
|
}
|
userCloudSendContentService.save(sendContent);
|
}
|
}
|
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void sendCustomGoods(Long uid, Long goodsId, Integer goodsType, Long sellerId) throws UserCloudException{
|
sendCircleByGoods(uid, goodsId, goodsType, null, sellerId);
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void autoSendCustomGoods(Long uid, Long id) {
|
boolean custom = false;
|
UserCloudManage cloudManage = userCloudManageService.selectByPrimaryKey(uid);
|
if (cloudManage != null) {
|
if (cloudManage.getCustom() != null)
|
custom = cloudManage.getCustom();
|
}
|
|
if (!custom) {
|
return;
|
}
|
|
UserCloudGoods cloudGoods = userCloudGoodsService.selectByPrimaryKey(id);
|
if (cloudGoods == null) {
|
return;
|
}
|
CommonGoods cgoods = cloudGoods.getCommonGoods();
|
if (cgoods == null)
|
return;
|
|
try {
|
// 发送商品
|
sendCircleByGoods(uid, cgoods.getGoodsId(), cgoods.getGoodsType(), id, cgoods.getSellerId());
|
} catch (UserCloudException e) {
|
LogHelper.cloudInfo("autoSendCustomGoods - [uid:" +uid + " 库id:"+ id + "]原因："+ e.getMsg());
|
}
|
}
|
|
private void sendCircleByGoods(Long uid, Long goodsId, Integer goodsType, Long storeId, Long sellerId) throws UserCloudException {
|
// 验证是否授权
|
UserInfo user = userInfoService.getUserByIdWithMybatis(uid);
|
if (user == null)
|
throw new UserCloudException(1, "用户信息不存在");
|
|
if (user != null && user.getState() != UserInfo.STATE_NORMAL) {
|
throw new UserCloudException(Constant.CODE_FORBIDDEN_USER, Constant.FORBIDDEN_USER_REASON_DESC);
|
}
|
|
String inviteCode = userInfoExtraService.getInviteCodeByUid(uid);
|
if (StringUtil.isNullOrEmpty(inviteCode))
|
throw new UserCloudException(3, "邀请码未激活");
|
|
UserExtraTaoBaoInfo taoBaoInfo = userExtraTaoBaoInfoService.getByUid(uid);
|
String relationId = null;
|
if (taoBaoInfo != null && taoBaoInfo.getRelationId() != null && taoBaoInfo.getRelationValid() != null
|
&& taoBaoInfo.getRelationValid() == true)
|
relationId = taoBaoInfo.getRelationId();
|
|
if (StringUtil.isNullOrEmpty(relationId))
|
throw new UserCloudException(2, "淘宝未授权，请前往\"我的\"绑定淘宝账号");
|
|
// 验证是否开通
|
UserCloud userCloud = userCloudMapper.getValidByUid(uid);
|
if (userCloud == null)
|
throw new UserCloudException(1001, "云发单已过期");
|
|
|
// 加入我的备选库
|
if (storeId == null) {
|
try {
|
UserCloudGoods cloudGoods = userCloudGoodsService.addGoods(uid, goodsId, goodsType, sellerId);
|
if (cloudGoods != null)
|
storeId =cloudGoods.getId();
|
} catch (UserCloudGoodsException e) {
|
LogHelper.cloudInfo("sendCustomGoods - [uid:" +uid + "goodsId:"+ goodsId + "goodsType" + goodsType +"]原因："+ e.getMsg());
|
throw new UserCloudException(1, "加入云发单备选库失败");
|
}
|
}
|
|
// 自选库商品是否打开
|
boolean custom = false;
|
UserCloudManage cloudManage = userCloudManageService.selectByPrimaryKey(uid);
|
if (cloudManage != null) {
|
if (cloudManage.getCustom() != null)
|
custom = cloudManage.getCustom();
|
}
|
if (!custom) {
|
throw new UserCloudException(0, "成功加入云发单库");
|
}
|
|
Integer robotId = userCloud.getRobotId();
|
if (robotId == null)
|
throw new UserCloudException(1, "云发单机器人不存在");
|
|
String wxId = userCloud.getWxId();
|
if (StringUtil.isNullOrEmpty(wxId))
|
throw new UserCloudException(1002, "请先登录微信");
|
|
// 验证开启状态
|
List<UserCloudGroup> listGroup = userCloudGroupService.listByUid(uid);
|
if (listGroup == null || listGroup.size() == 0)
|
throw new UserCloudException(1003, "请先登录微信");
|
|
List<UserCloudGroup> listOpen = new ArrayList<>();
|
for (UserCloudGroup cloudGrou : listGroup) {
|
if (cloudGrou.getState()) {
|
listOpen.add(cloudGrou);
|
}
|
}
|
|
if (listOpen.size() == 0)
|
throw new UserCloudException(1004, "请先开启云发单群功能");
|
|
|
// 检测微信是否登录状态
|
if (!AitaokerApiUtil.onlineCheck(robotId)) {
|
throw new UserCloudException(1003, "请重新登录微信");
|
}
|
|
|
// 保存发送记录
|
UserCloudSendRecord sendRecord = new UserCloudSendRecord();
|
sendRecord.setUid(uid);
|
sendRecord.setGoodsId(goodsId + "");
|
sendRecord.setGoodsType(goodsType + "");
|
sendRecord.setWxId(wxId);
|
sendRecord.setRobotId(robotId);
|
sendRecord.setSendTime(new Date());
|
if (storeId != null) {
|
sendRecord.setSendId(storeId + "");
|
sendRecord.setSendOrigin(UserCloudSendRecord.ORIGIN_STORE);
|
sendRecord.setSendWay(UserCloudSendRecord.SEND_WAY_AUTO);
|
} else {
|
sendRecord.setSendWay(UserCloudSendRecord.SEND_WAY_MANUAL);
|
}
|
UserCloudSendRecord result = userCloudSendRecordService.save(sendRecord);
|
|
if (goodsType == Constant.SOURCE_TYPE_TAOBAO) {
|
sendTaoBaoGoods(user, robotId, wxId, goodsId, relationId, listOpen, result.getId());
|
} else if (goodsType == Constant.SOURCE_TYPE_JD) {
|
sendJDGoods(user, robotId, wxId, goodsId, relationId, listOpen, result.getId());
|
} else if (goodsType == Constant.SOURCE_TYPE_PDD) {
|
sendPDDGoods(user, robotId, wxId, goodsId, relationId, listOpen, result.getId());
|
} else if (goodsType == Constant.SOURCE_TYPE_VIP) {
|
sendVIPGoods(user, robotId, wxId, goodsId, relationId, listOpen, result.getId());
|
} else if (goodsType == Constant.SOURCE_TYPE_SUNING) {
|
sendSuNingGoods(user, robotId, wxId, goodsId, sellerId, relationId, listOpen, result.getId());
|
}
|
|
// 更新发单记录
|
if (storeId != null) {
|
UserCloudGoods record = new UserCloudGoods();
|
record.setId(storeId);
|
record.setState(UserCloudGoods.STATE_SHARED);
|
record.setSendTime(new Date());
|
record.setUpdateTime(new Date());
|
userCloudGoodsService.updateByPrimaryKeySelective(record);
|
}
|
}
|
|
/**
|
* 淘宝商品信息处理
|
* @param user
|
* @param inviteCode
|
* @param robotId
|
* @param wxId
|
* @param goodsId
|
* @param relationId
|
* @param listOpen
|
* @throws UserCloudException
|
*/
|
private void sendTaoBaoGoods(UserInfo user, int robotId, String wxId, Long goodsId, String relationId,
|
List<UserCloudGroup> listOpen, String pid) throws UserCloudException {
|
TaoBaoLink taoBaoLink = null;
|
try {
|
taoBaoLink = shareGoodsService.getTaoBaoLinkForShare(user.getId(), goodsId, relationId);
|
} catch (ShareGoodsException e) {
|
LogHelper.errorDetailInfo(e);
|
throw new UserCloudException(1, "该商品已下架");
|
}
|
if (taoBaoLink == null)
|
throw new UserCloudException(1, "该商品已下架");
|
|
TaoBaoGoodsBrief goods = taoBaoLink.getGoods();
|
boolean coupon = false;
|
if (!StringUtil.isNullOrEmpty(goods.getCouponInfo())) {
|
coupon = true;
|
}
|
|
String quanPrice = "";
|
String description = "";
|
String couponAmount = "";
|
if (coupon) {
|
description = goods.getDescription();
|
quanPrice = TaoBaoUtil.getAfterUseCouplePrice(goods) + "";
|
couponAmount = MoneyBigDecimalUtil.getWithNoZera(goods.getCouponAmount()).toString();
|
}
|
String sales = TaoBaoUtil.getSaleCount(goods.getBiz30day());
|
|
// 获取推荐语
|
String recommendText = shareGoodsTextTemplateService.getRecommendText(coupon, goods.getTitle(), sales,
|
couponAmount, description);
|
// 获取评论语
|
String commentText = shareGoodsTextTemplateService.getCommentTextByTaoToken(coupon, taoBaoLink.getTaoToken(),
|
goods.getZkPrice().toString(), quanPrice);
|
|
// 云发单
|
sendGoods(robotId, wxId, listOpen, recommendText, commentText, goods.getImgList(), user.getId(), pid);
|
}
|
|
|
/**
|
* 京东商品云发单
|
* @param user
|
* @param robotId
|
* @param wxId
|
* @param goodsId
|
* @param relationId
|
* @param listOpen
|
* @throws UserCloudException
|
*/
|
private void sendJDGoods(UserInfo user, int robotId, String wxId, Long goodsId, String relationId,
|
List<UserCloudGroup> listOpen, String pid) throws UserCloudException {
|
JDGoods jdGoods = jdGoodsCacheUtil.getGoodsInfo(goodsId);
|
if (jdGoods == null)
|
throw new UserCloudException(1, "该商品已下架");
|
|
|
String couponUrl = null;
|
JDCouponInfo couponInfo = JDUtil.getShowCouponInfo(jdGoods);
|
if (couponInfo != null) {
|
couponUrl = couponInfo.getLink();
|
}
|
String materialId = "https://item.jd.com/" + goodsId + ".html";
|
String jumpLink = JDApiUtil.convertLinkWithSubUnionId(materialId, couponUrl, JDApiUtil.POSITION_SHARE + "",user.getId() + "");
|
|
boolean coupon = false;
|
if (couponInfo != null) {
|
coupon = true;
|
}
|
|
String quanPrice = "";
|
String couponAmount = "";
|
if (coupon) {
|
quanPrice = BigDecimalUtil.getWithNoZera(JDUtil.getQuanPrice(jdGoods)).toString() + "";
|
couponAmount = BigDecimalUtil.getWithNoZera(couponInfo.getDiscount()).toString();
|
}
|
|
String sales = JDUtil.getSaleCount(jdGoods.getInOrderCount30Days());
|
|
// 获取推荐语
|
String recommendText = shareGoodsTextTemplateService.getRecommendText(coupon, jdGoods.getSkuName(), sales,
|
couponAmount, null);
|
|
// 获取评论语
|
BigDecimal price = jdGoods.getPrice();
|
JDPingouInfo pinGouInfo = jdGoods.getPinGouInfo();
|
if (pinGouInfo != null) {
|
price = pinGouInfo.getPingouPrice();
|
}
|
String zkPrice = BigDecimalUtil.getWithNoZera(price).toString();
|
String commentText = shareGoodsTextTemplateService.getCommentTextByLink(coupon, jumpLink, zkPrice, quanPrice,
|
ConfigKeyEnum.quickShareJDCommentText);
|
|
// 云发单
|
sendGoods(robotId, wxId, listOpen, recommendText, commentText, jdGoods.getImageList(), user.getId(), pid);
|
}
|
|
/**
|
* 京东商品云发单
|
* @param user
|
* @param robotId
|
* @param wxId
|
* @param goodsId
|
* @param relationId
|
* @param listOpen
|
* @throws UserCloudException
|
*/
|
private void sendPDDGoods(UserInfo user, int robotId, String wxId, Long goodsId, String relationId,
|
List<UserCloudGroup> listOpen, String pid) throws UserCloudException {
|
PDDGoodsDetail goods = pinDuoDuoCacheUtil.getGoodsInfo(goodsId);
|
if (goods == null)
|
throw new UserCloudException(1, "该商品已下架");
|
|
String jumpLink = PinDuoDuoApiUtil.getPromotionUrl(goodsId, PinDuoDuoApiUtil.PID_SHARE + "", user.getId() + "");
|
|
boolean coupon = true;
|
if (goods.getHasCoupon() == null || !goods.getHasCoupon()) {
|
coupon = false;
|
}
|
|
String quanPrice = "";
|
String couponAmount = "";
|
if (coupon) {
|
BigDecimal hundred = new BigDecimal(100);
|
BigDecimal amount = MoneyBigDecimalUtil.div(new BigDecimal(goods.getCouponDiscount()), hundred);
|
quanPrice = BigDecimalUtil.getWithNoZera(amount).toString();
|
couponAmount = BigDecimalUtil.getWithNoZera(PinDuoDuoUtil.getQuanPrice(goods)).toString();
|
}
|
|
String sales = goods.getSalesTip();
|
if (StringUtil.isNullOrEmpty(sales)) {
|
sales = "0";
|
}
|
|
// 获取推荐语
|
String recommendText = shareGoodsTextTemplateService.getRecommendText(coupon, goods.getGoodsName(), sales,
|
couponAmount, null);
|
|
// 获取评论语
|
String zkPrice = MoneyBigDecimalUtil.div(new BigDecimal(goods.getMinGroupPrice()), new BigDecimal(100)).setScale(2).toString();
|
String commentText = shareGoodsTextTemplateService.getCommentTextByLink(coupon, jumpLink, zkPrice, quanPrice,
|
ConfigKeyEnum.quickSharePDDCommentText);
|
|
List<String> list = null;
|
String[] goodsGalleryUrls = goods.getGoodsGalleryUrls();
|
if (goodsGalleryUrls != null && goodsGalleryUrls.length > 0) {
|
list = Arrays.asList(goodsGalleryUrls);
|
}
|
// 云发单
|
sendGoods(robotId, wxId, listOpen, recommendText, commentText, list, user.getId(), pid );
|
}
|
|
|
/**
|
* 唯品会商品
|
* @param user
|
* @param robotId
|
* @param wxId
|
* @param goodsId
|
* @param relationId
|
* @param listOpen
|
* @param pid
|
* @throws UserCloudException
|
*/
|
private void sendVIPGoods(UserInfo user, int robotId, String wxId, Long goodsId, String relationId,
|
List<UserCloudGroup> listOpen, String pid) throws UserCloudException {
|
VIPGoodsInfo goods = VipShopApiUtil.getGoodsDetail(goodsId + "");
|
if (goods == null)
|
throw new UserCloudException(1, "该商品已下架");
|
|
VIPConvertResultDTO resultDTO = VipShopApiUtil.convertLink(goodsId + "", VipShopUtil.getShareChanTag(user.getId()));
|
String jumpLink = resultDTO.getUrl();
|
|
boolean coupon = false;
|
String quanPrice = "";
|
String couponAmount = "";
|
// 获取推荐语
|
String recommendText = shareGoodsTextTemplateService.getRecommendText(coupon, goods.getGoodsName(), null,
|
couponAmount, null);
|
// 获取评论语
|
String commentText = shareGoodsTextTemplateService.getCommentTextByLink(coupon, jumpLink, goods.getMarketPrice(),
|
quanPrice, ConfigKeyEnum.quickShareVIPCommentText);
|
|
// 云发单
|
sendGoods(robotId, wxId, listOpen, recommendText, commentText, goods.getGoodsDetailPictures(), user.getId(), pid);
|
}
|
|
|
/**
|
* 京东商品云发单
|
* @param user
|
* @param robotId
|
* @param wxId
|
* @param goodsId
|
* @param relationId
|
* @param listOpen
|
* @throws UserCloudException
|
*/
|
private void sendSuNingGoods(UserInfo user, int robotId, String wxId, Long goodsId, Long sellerId, String relationId,
|
List<UserCloudGroup> listOpen, String pid) throws UserCloudException {
|
SuningGoodsInfo goods = SuningApiUtil.getGoodsDetail(goodsId +"", sellerId +"");
|
if (goods == null)
|
throw new UserCloudException(1, "该商品已下架");
|
|
|
String couponLink = goods.getCouponInfo().getCouponUrl();
|
String jumpLink = SuningApiUtil.convertLink(SuningUtil.getProductUrl(sellerId +"", goodsId +""),
|
StringUtil.isNullOrEmpty(couponLink) ? null : couponLink, SuningApiUtil.PID_SHARE, user.getId() + "");
|
|
|
boolean coupon = false;
|
String couponAmount = "";
|
String sales = null;
|
if (goods.getCouponInfo() != null && !StringUtil.isNullOrEmpty(goods.getCouponInfo().getCouponUrl())) {// 有券
|
couponAmount = new BigDecimal(goods.getCouponInfo().getCouponValue()).toString();
|
coupon = true;
|
}
|
|
// 获取推荐语
|
String recommendText = shareGoodsTextTemplateService.getRecommendText(coupon, goods.getCommodityInfo().getCommodityName(), sales,
|
couponAmount, null);
|
|
// 生成快捷分享内容
|
String template = configService.get(ConfigKeyEnum.quickShareSuNingCommentText.getKey());
|
String commentText = shareGoodsTextTemplateService.createQuickShareTextSuNing(template, goods, jumpLink);
|
|
|
List<String> imgList = new ArrayList<>();
|
for (SuningGoodsImg img : goods.getCommodityInfo().getPictureUrl()) {
|
imgList.add(img.getPicUrl());
|
}
|
|
// 云发单
|
sendGoods(robotId, wxId, listOpen, recommendText, commentText, imgList, user.getId(), pid);
|
}
|
|
/**
|
* 发送商品
|
* @param robotId
|
* @param title
|
* @param comment
|
* @param listImg
|
* @param wxId
|
* @param listOpen
|
*/
|
private void sendGoods(int robotId,String wxId, List<UserCloudGroup> listOpen, String title,
|
String comment, List<String> listImg, Long uid, String pid) {
|
// 遍历群-朋友圈
|
for (UserCloudGroup cloudGroup: listOpen) {
|
UserCloudSendContent sendContent = new UserCloudSendContent();
|
sendContent.setPid(pid);
|
sendContent.setUid(uid);
|
sendContent.setGroupId(cloudGroup.getGroupId());
|
sendContent.setCreateTime(new Date());
|
|
if(cloudGroup.getType() == UserCloudGroup.TYPE_CIRCLE) { // 朋友圈
|
sendContent.setType(UserCloudSendContent.TYPE_CIRCLE);
|
String picUrl = "";
|
if (listImg.size() > 0) {
|
for (String img: listImg) {
|
picUrl += "," + img;
|
}
|
}
|
sendContent.setTitle(title);
|
sendContent.setPicUrl(picUrl);
|
|
// 发圈内容
|
String circleId = AitaokerApiUtil.macsendCircle(robotId, title, picUrl);
|
// 评论文本
|
if (!StringUtil.isNullOrEmpty(circleId)) {
|
sendContent.setState(true);
|
List<String> list = new ArrayList<>();
|
boolean macsend = AitaokerApiUtil.macsendCircleComment(robotId, wxId, circleId, comment);
|
if (macsend) {
|
list.add(comment);
|
}
|
sendContent.setComments(list);
|
}
|
} else {
|
sendContent.setType(UserCloudSendContent.TYPE_GROUP);
|
// 发送文本
|
if (!StringUtil.isNullOrEmpty(title)) {
|
boolean macsend = AitaokerApiUtil.macsendText(robotId, cloudGroup.getGroupId(), title);
|
if (macsend)
|
sendContent.setTitle(title);
|
}
|
|
// 发送图片
|
String picurl = listImg.get(0);
|
if (!StringUtil.isNullOrEmpty(picurl)) {
|
try {
|
String imgBase64 = ImageToBase64.NetImageToBase64(picurl);
|
boolean macsend = AitaokerApiUtil.macsendImgBase64(robotId, cloudGroup.getGroupId(), imgBase64);
|
if (macsend)
|
sendContent.setPicUrl(picurl);
|
} catch (Exception e) {
|
LogHelper.errorDetailInfo(e);
|
}
|
|
}
|
// 评论文本
|
List<String> list = new ArrayList<>();
|
boolean macsend = AitaokerApiUtil.macsendText(robotId, cloudGroup.getGroupId(), comment);
|
if (macsend) {
|
list.add(comment);
|
}
|
sendContent.setState(true);
|
sendContent.setComments(list);
|
}
|
userCloudSendContentService.save(sendContent);
|
}
|
}
|
|
@Override
|
public void fixedTimeSend(String id) {
|
if (StringUtil.isNullOrEmpty(id))
|
return;
|
|
// 一个小时之前
|
long time = java.lang.System.currentTimeMillis() - 1000 * 60 * 60 ;
|
Date lastTime = new Date(time);
|
|
for (int i = 0; i < 1000; i ++) {
|
List<Long> list = userCloudMapper.listValidUid((i-1)*1000, 1000);
|
if (list == null || list.size() == 0) {
|
break;
|
}
|
|
for (Long uid: list) {
|
try {
|
UserCloudSendRecord record = userCloudSendRecordService.getByUidAndSendId(uid, id);
|
if (record != null)
|
continue;
|
|
UserCloudSendRecord last = userCloudSendRecordService.getLastByUid(uid, lastTime);
|
if (last != null)
|
continue;
|
|
boolean official = false;
|
UserCloudManage cloudManage = userCloudManageService.selectByPrimaryKey(uid);
|
if (cloudManage != null) {
|
if (cloudManage.getOfficial() != null)
|
official = cloudManage.getOfficial();
|
}
|
|
if (!Constant.IS_TEST && official) {
|
UserCloudMQMsg msg = new UserCloudMQMsg(uid, id, UserCloudMQMsg.TYPE_EVALUATE);
|
Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER, UserTopicTagEnum.userCloud, msg);
|
producer.send(message);
|
}
|
} catch (Exception e) {
|
LogHelper.errorDetailInfo(e);
|
}
|
}
|
}
|
|
}
|
}
|
