云发单 后台管理

yujian

2020-06-03 80e39e3a40283521fc732c930aa51d9bece7c146

 fanli/src/main/java/com/yeshi/fanli/service/impl/user/cloud/UserCloudServiceImpl.java

@@ -11,15 +11,21 @@
import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Transactional;

import org.yeshi.utils.BigDecimalUtil;

import org.yeshi.utils.entity.FileUploadResult;



import com.yeshi.fanli.controller.client.v2.ShareControllerV2;

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;

@@ -71,7 +77,13 @@
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

@@ -137,6 +149,8 @@
   @Resource

   private UserCloudSendContentService userCloudSendContentService;

   

   @Resource(name = "producer")

   private Producer producer;

   

   

   @Override

@@ -154,6 +168,23 @@
      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)

@@ -298,7 +329,7 @@
      

      String inviteCode = userInfoExtraService.getInviteCodeByUid(uid);

      if (StringUtil.isNullOrEmpty(inviteCode))

         throw new UserCloudException(1, "邀请码未激活");

         throw new UserCloudException(3, "邀请码未激活");



      UserExtraTaoBaoInfo taoBaoInfo = userExtraTaoBaoInfoService.getByUid(uid);

      String relationId = null;

@@ -313,20 +344,20 @@
      // 验证是否开通

      UserCloud userCloud = userCloudMapper.getValidByUid(uid);

      if (userCloud == null)

         throw new UserCloudException(1, "云发单已过期");

         throw new UserCloudException(1001, "云发单已过期");



      Integer robotId = userCloud.getRobotId();

      if (robotId == null)

         throw new UserCloudException(1, "云发单机器人不存在");

         throw new UserCloudException(1002, "云发单机器人不存在");



      String wxId = userCloud.getWxId();

      if (StringUtil.isNullOrEmpty(wxId)) 

         throw new UserCloudException(1, "微信号缺失");

         throw new UserCloudException(1003, "微信号不存在，请先微信登录");

      

      // 验证开启状态

      List<UserCloudGroup> listGroup = userCloudGroupService.listByUid(uid);

      if (listGroup == null || listGroup.size() == 0)

         throw new UserCloudException(1, "请先添加云发单群信息");

         throw new UserCloudException(1004, "请先微信登录");



      List<UserCloudGroup> listOpen = new ArrayList<>();

      for (UserCloudGroup cloudGrou : listGroup) {

@@ -335,7 +366,8 @@
         }

      }

      if (listOpen.size() == 0)

         throw new UserCloudException(1, "请先开启云发单群功能");

         throw new UserCloudException(1005, "请先开启云发单群功能");

		
      

      // 验证发圈是否可行

      GoodsEvaluate evaluate = goodsEvaluateService.getById(id);

@@ -391,6 +423,7 @@
      



      String qrCode = null;

      String cloudPic = null;

      ImgInfo imgVideo = null;

      List<String> listImg = new ArrayList<>();

      

@@ -401,15 +434,26 @@
               imgVideo = imgInfo;

               continue;

            }

            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 (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();

         }

      }

      

@@ -483,17 +527,15 @@
            }

            

            // 发送图片

            String picurl = null;

            if (!StringUtil.isNullOrEmpty(qrCode)) {

               picurl = qrCode;

            } else if (listImg.size() > 0) {

               picurl = listImg.get(0);

            }

            if (!StringUtil.isNullOrEmpty(picurl)) {

               String imgBase64 = ImageToBase64.NetImageToBase64(picurl);

               boolean macsend = AitaokerApiUtil.macsendImgBase64(robotId, cloudGroup.getGroupId(), imgBase64);

               if (macsend)

                  sendContent.setPicUrl(picurl);

            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);

               }

            }

            

            // 评论文本

@@ -511,49 +553,11 @@
      }

   }

   

   private String getJumpLink(GoodsDetailVO goodsVO, UserInfo user, String relationId, String inviteCode,

         String mainPic) {

      String jumpLink = null;

      if (goodsVO.getGoodsType() == Constant.SOURCE_TYPE_TAOBAO) {

         TaoBaoLink taoBaoLink = null;

         try {

            taoBaoLink = shareGoodsService.getTaoBaoLinkForShare(user.getId(), goodsVO.getGoodsId(), relationId);

         } catch (ShareGoodsException e) {

            e.printStackTrace();

         }

         jumpLink = ShareControllerV2.getERCodeContentNew(

               configService.get(ConfigKeyEnum.taobaoShareQrcodeText.getKey()), taoBaoLink.getGoods(),

               TaoBaoUtil.filterTaoToken(taoBaoLink.getTaoToken()));

      } else if (goodsVO.getGoodsType() == Constant.SOURCE_TYPE_JD) {

         JDGoods jdGoods = jdGoodsCacheUtil.getGoodsInfo(goodsVO.getGoodsId());

         if (jdGoods == null) {

            return null;

         }



         String couponUrl = null;

         JDCouponInfo couponInfo = JDUtil.getShowCouponInfo(jdGoods);

         if (couponInfo != null) {

            couponUrl = couponInfo.getLink();

         }

         String materialId = "https://item.jd.com/" + goodsVO.getGoodsId() + ".html";

         jumpLink = JDApiUtil.convertLinkWithSubUnionId(materialId, couponUrl, JDApiUtil.POSITION_SHARE + "",

               user.getId() + "");

      } else if (goodsVO.getGoodsType() == Constant.SOURCE_TYPE_PDD) {

         jumpLink = PinDuoDuoApiUtil.getPromotionUrl(goodsVO.getGoodsId(), PinDuoDuoApiUtil.PID_SHARE + "",

               user.getId() + "");

      }



      FileUploadResult uploadResult = qrCodeService.drawDynamicGoodsPoster(jumpLink, user.getPortrait(), inviteCode, mainPic, goodsVO);

			
      if (uploadResult != null) {

         return uploadResult.getUrl();

      }

      return null;

   }

	
   

   @Override

   public void sendCustomGoods(Long uid, Long goodsId, Integer goodsType) throws UserCloudException{

      sendCircleByGoods(uid, goodsId, goodsType, null);

   public void sendCustomGoods(Long uid, Long goodsId, Integer goodsType, Long sellerId) throws UserCloudException{

      sendCircleByGoods(uid, goodsId, goodsType, null, sellerId);

   }



   @Override

@@ -568,7 +572,7 @@
      

      try {

         // 发送商品

         sendCircleByGoods(uid, cgoods.getGoodsId(), cgoods.getGoodsType(), id);

         sendCircleByGoods(uid, cgoods.getGoodsId(), cgoods.getGoodsType(), id, cgoods.getSellerId());

         

         UserCloudGoods record = new UserCloudGoods();

         record.setId(id);

@@ -580,7 +584,7 @@
      }

   }



   private void sendCircleByGoods(Long uid, Long goodsId, Integer goodsType, Long storeId) throws UserCloudException {

   private void sendCircleByGoods(Long uid, Long goodsId, Integer goodsType, Long storeId, Long sellerId) throws UserCloudException {

      // 验证是否授权

      UserInfo user = userInfoService.getUserByIdWithMybatis(uid);

      if (user == null)

@@ -589,6 +593,10 @@
      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;

@@ -602,7 +610,7 @@
      // 验证是否开通

      UserCloud userCloud = userCloudMapper.getValidByUid(uid);

      if (userCloud == null)

         throw new UserCloudException(1, "云发单已过期");

         throw new UserCloudException(1001, "云发单已过期");



      Integer robotId = userCloud.getRobotId();

      if (robotId == null)

@@ -610,12 +618,12 @@


      String wxId = userCloud.getWxId();

      if (StringUtil.isNullOrEmpty(wxId)) 

         throw new UserCloudException(1, "微信号缺失");

         throw new UserCloudException(1002, "请先登录微信");

      

      // 验证开启状态

      List<UserCloudGroup> listGroup = userCloudGroupService.listByUid(uid);

      if (listGroup == null || listGroup.size() == 0)

         throw new UserCloudException(1, "请先添加云发单群信息");

         throw new UserCloudException(1003, "请先登录微信");



      List<UserCloudGroup> listOpen = new ArrayList<>();

      for (UserCloudGroup cloudGrou : listGroup) {

@@ -625,7 +633,7 @@
      }

      

      if (listOpen.size() == 0)

         throw new UserCloudException(1, "请先开启云发单群功能");

         throw new UserCloudException(1004, "请先开启云发单群功能");

      

      // 保存发送记录

      UserCloudSendRecord sendRecord = new UserCloudSendRecord();

@@ -651,9 +659,9 @@
      } 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());

      }

   }

   

@@ -822,6 +830,85 @@
   

   

   /**

    * 唯品会商品

    * @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.quickShareJDCommentText);

		
      // 云发单

      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 quanPrice = "";

      String couponAmount = "";

      String sales = null;

      // 获取推荐语

      String recommendText = shareGoodsTextTemplateService.getRecommendText(coupon, goods.getCommodityInfo().getCommodityName(), sales, 
            couponAmount, null);

		
      // 获取评论语

      String zkPrice = goods.getCommodityInfo().getCommodityPrice().toString();

      String commentText = shareGoodsTextTemplateService.getCommentTextByLink(coupon, jumpLink, zkPrice, quanPrice, 
            ConfigKeyEnum.quickShareJDCommentText);

		
      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

@@ -875,10 +962,15 @@
            // 发送图片

            String picurl = listImg.get(0);

            if (!StringUtil.isNullOrEmpty(picurl)) {

               String imgBase64 = ImageToBase64.NetImageToBase64(picurl);

               boolean macsend = AitaokerApiUtil.macsendImgBase64(robotId, cloudGroup.getGroupId(), imgBase64);

               if (macsend)

                  sendContent.setPicUrl(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<>();

@@ -893,5 +985,43 @@
      }

   }



	
}

   @Override

   public void fixedTimeSend(String id) {

      if (StringUtil.isNullOrEmpty(id)) 
         return;

		
      // 一个小时之前

      long rand = 1000 * 60 * 60 ;

      long time = java.lang.System.currentTimeMillis() - rand;

      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;

					
               if (!Constant.IS_TEST) {

                  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);

            }

         }

      }

		
   }

}