多APP优化

admin

2020-07-03 651a15c78f668bef3859d9ed1bb7ad0b669d3600

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

@@ -8,6 +8,9 @@


import javax.annotation.Resource;



import com.yeshi.fanli.entity.SystemEnum;

import com.yeshi.fanli.exception.taobao.TaoBaoConvertLinkException;

import com.yeshi.fanli.service.manger.goods.TaoBaoLinkManager;

import org.springframework.core.task.TaskExecutor;

import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Transactional;

@@ -73,6 +76,7 @@
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.service.manger.msg.RocketMQManager;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.ImageToBase64;

import com.yeshi.fanli.util.MoneyBigDecimalUtil;

@@ -134,23 +138,13 @@
   @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;

@@ -161,8 +155,8 @@
   @Resource

   private UserCloudManageService userCloudManageService;



   @Resource(name = "producer")

   private Producer producer;

   @Resource

   private RocketMQManager rocketMQManager;



   @Resource

   private UserOtherMsgNotificationService userOtherMsgNotificationService;

@@ -170,11 +164,11 @@
   @Resource

   private PushService pushService;



   @Resource

   private UserSystemMsgService userSystemMsgService;



   @Resource(name = "taskExecutor")

   private TaskExecutor executor;



   @Resource

   private TaoBaoLinkManager taoBaoLinkManager;



   @Override

   public UserCloud getValidByUid(Long uid) {

@@ -354,7 +348,7 @@
      if (robotId == null)

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



      List<String> list = AitaokerApiUtil.getContract(12793);

      List<String> list = AitaokerApiUtil.getContract(robotId);

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

         throw new UserCloudException(1, "未检索到对应群");



@@ -364,7 +358,7 @@
         String result = redisManager.getCommonString(key);

         if (!StringUtil.isNullOrEmpty(result)) {

            String groupName = null;

            WeiXinGroupDTO groupDetail = AitaokerApiUtil.getGroupDetail(12793, roomId);

            WeiXinGroupDTO groupDetail = AitaokerApiUtil.getGroupDetail(robotId, roomId);

            if (groupDetail != null) {

               groupName = groupDetail.getGroupName();

            }

@@ -407,6 +401,7 @@
   }



   private void sendCircleByDynamic(Long uid, String id, int way) throws UserCloudException {

      long time1= java.lang.System.currentTimeMillis();

      UserInfo user = userInfoService.getUserByIdWithMybatis(uid);

      if (user == null)

         throw new UserCloudException(1, "用户信息不存在");

@@ -427,7 +422,11 @@


      if (StringUtil.isNullOrEmpty(relationId))

         throw new UserCloudException(2, "淘宝未授权，请前往\"我的\"绑定淘宝账号");

		
      long time2= java.lang.System.currentTimeMillis();

      LogHelper.test("sendCircleByDynamic保验证用户状态：" + (time2 - time1));



		
      // 验证是否开通

      UserCloud userCloud = userCloudMapper.getValidByUid(uid);

      if (userCloud == null)

@@ -441,6 +440,10 @@
      if (StringUtil.isNullOrEmpty(wxId))

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



      long time3= java.lang.System.currentTimeMillis();

      LogHelper.test("sendCircleByDynamic验证是否满足开通：" + (time3 - time2));



		
      // 验证开启状态

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

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

@@ -455,6 +458,9 @@
      if (listOpen.size() == 0)

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



      long time4= java.lang.System.currentTimeMillis();

      LogHelper.test("sendCircleByDynamic验证是否开启：" + (time4 - time3));

		
      // 验证发圈是否可行

      GoodsEvaluate evaluate = goodsEvaluateService.getById(id);

      if (evaluate == null || evaluate.getState() == 0)

@@ -468,6 +474,9 @@
      if (comments == null || comments.size() == 0)

         throw new UserCloudException(1, "该内容不能转链");



      long time5= java.lang.System.currentTimeMillis();

      LogHelper.test("sendCircleByDynamic验证发圈内容是否满足：" + (time5 - time4));

		
      // 检测微信是否登录状态

      if (!AitaokerApiUtil.onlineCheck(robotId)) {

         // 通知登录微信

@@ -476,6 +485,9 @@
         throw new UserCloudException(1003, "微信已掉线，需要重新扫描二维码登录");

      }



      long time6= java.lang.System.currentTimeMillis();

      LogHelper.test("sendCircleByDynamic验证发是否登录：" + (time6 - time5));

		
      boolean hasToken = false;

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

      for (CommentInfo commentInfo : comments) {

@@ -513,7 +525,18 @@


      if (!hasToken)

         throw new UserCloudException(1, "该内容包含可转链口令或链接");

		
      // 异步执行发送

      executor.execute(new Runnable() {

         @Override

         public void run() {

            sendEvaluate(uid, evaluate, way, userCloud, listOpen, listComment);

         }

      });

   }



   private void sendEvaluate(Long uid, GoodsEvaluate evaluate, int way, UserCloud userCloud, 
         List<UserCloudGroup> listOpen, List<String> listComment) {

      ImgInfo imgVideo = null;

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



@@ -528,10 +551,14 @@
         }

      }





		
      String wxId = userCloud.getWxId();

      Integer robotId = userCloud.getRobotId();

      // 保存发送记录

      UserCloudSendRecord sendRecord = new UserCloudSendRecord();

      sendRecord.setUid(uid);

      sendRecord.setSendId(id);

      sendRecord.setSendId(evaluate.getId());

      sendRecord.setSendWay(way);

      sendRecord.setWxId(wxId);

      sendRecord.setRobotId(robotId);

@@ -540,6 +567,7 @@
      UserCloudSendRecord result = userCloudSendRecordService.save(sendRecord);

      String pid = result.getId();



		
      for (UserCloudGroup cloudGroup : listOpen) {

         String title = evaluate.getTitle();



@@ -597,10 +625,10 @@
               if (macsend)

                  sendContent.setTitle(title);

            }



            SystemEnum system=userInfoService.getUserSystem(uid);

            // 发送图片

            int num = 1;

            String picNum = configService.get(ConfigKeyEnum.robotCloudGroupPictureNum.getKey());

            String picNum = configService.getValue(ConfigKeyEnum.robotCloudGroupPictureNum.getKey(),system);

            if (!StringUtil.isNullOrEmpty(picNum)) {

               num = Integer.parseInt(picNum);

            }

@@ -632,7 +660,9 @@
         userCloudSendContentService.save(sendContent);

      }

   }



	
	
	
   @Override

   @Transactional(rollbackFor = Exception.class)

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

@@ -672,6 +702,8 @@


   private void sendCircleByGoods(Long uid, Long goodsId, Integer goodsType, Long storeId, Long sellerId, int way)

         throws UserCloudException {

      long begainTime = java.lang.System.currentTimeMillis();

		
      // 验证是否授权

      UserInfo user = userInfoService.getUserByIdWithMybatis(uid);

      if (user == null)

@@ -694,11 +726,19 @@
      if (StringUtil.isNullOrEmpty(relationId))

         throw new UserCloudException(2, "淘宝未授权，请前往\"我的\"绑定淘宝账号");



      long time2 = java.lang.System.currentTimeMillis();

      LogHelper.test("sendCircleByGoods验证用户耗时：" + (time2 - begainTime));

		
		
      // 验证是否开通

      UserCloud userCloud = userCloudMapper.getValidByUid(uid);

      if (userCloud == null)

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



		
      long time3= java.lang.System.currentTimeMillis();

      LogHelper.test("sendCircleByGoods验证是否开通：" + (time3 - time2));

		
      long time4 = time3;

      // 加入我的备选库

      if (storeId == null) {

         try {

@@ -710,6 +750,8 @@
                  + "]原因：" + e.getMsg());

            throw new UserCloudException(1, "加入云发单备选库失败");

         }

         time4= java.lang.System.currentTimeMillis();

         LogHelper.test("sendCircleByGoods加入备选库：" + (time4 - time3));

      }



      // 自选库商品是否打开

@@ -736,6 +778,9 @@
      if (listGroup == null || listGroup.size() == 0)

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



      long time5= java.lang.System.currentTimeMillis();

      LogHelper.test("sendCircleByGoods验证是否绑定微信：" + (time5 - time4));

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

      for (UserCloudGroup cloudGrou : listGroup) {

         if (cloudGrou.getState()) {

@@ -754,6 +799,9 @@
         throw new UserCloudException(1003, "微信已掉线，需要重新扫描二维码登录");

      }



      long time6= java.lang.System.currentTimeMillis();

      LogHelper.test("sendCircleByGoods验证是否登录微信：" + (time6 - time5));

		
      // 保存发送记录

      UserCloudSendRecord sendRecord = new UserCloudSendRecord();

      sendRecord.setUid(uid);

@@ -770,6 +818,9 @@
         sendRecord.setSendWay(UserCloudSendRecord.SEND_WAY_MANUAL);

      }

      UserCloudSendRecord result = userCloudSendRecordService.save(sendRecord);

		
      long time7= java.lang.System.currentTimeMillis();

      LogHelper.test("sendCircleByGoods保存发送记录：" + (time7 - time6));



      try {

         if (goodsType == Constant.SOURCE_TYPE_TAOBAO) {

@@ -792,7 +843,8 @@
            record.setUpdateTime(new Date());

            userCloudGoodsService.updateByPrimaryKeySelective(record);

         }



         long time8= java.lang.System.currentTimeMillis();

         LogHelper.test("sendCircleByGoods执行发送：" + (time8 - time7));

      } catch (UserCloudException e) {

         LogHelper.cloudInfo("autoSendCustomGoods - [uid:" + uid + " 库id:" + storeId + "]原因：" + e.getMsg());

         // 更新发单记录

@@ -812,7 +864,6 @@
    * 淘宝商品信息处理

    * 

    * @param user

    * @param inviteCode

    * @param robotId

    * @param wxId

    * @param goodsId

@@ -824,8 +875,8 @@
         List<UserCloudGroup> listOpen, String pid) throws UserCloudException {

      TaoBaoLink taoBaoLink = null;

      try {

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

      } catch (ShareGoodsException e) {

         taoBaoLink = taoBaoLinkManager.getTaoBaoLinkForShare(user.getId(), goodsId, relationId,null);

      } catch (TaoBaoConvertLinkException e) {

         LogHelper.errorDetailInfo(e);

         throw new UserCloudException(1, "该商品已下架");

      }

@@ -848,15 +899,22 @@
      }

      String sales = TaoBaoUtil.getSaleCount(goods.getBiz30day());



      SystemEnum system=userInfoService.getUserSystem(user.getId());



      // 获取推荐语

      String recommendText = shareGoodsTextTemplateService.getRecommendText(coupon, goods.getTitle(), sales,

            couponAmount, description);

            couponAmount, description,system);

      // 获取评论语

      String commentText = shareGoodsTextTemplateService.getCommentTextByTaoToken(coupon, taoBaoLink.getTaoToken(),

            goods.getZkPrice().toString(), quanPrice);

            goods.getZkPrice().toString(), quanPrice,system);



      // 云发单

      sendGoods(robotId, wxId, listOpen, recommendText, commentText, goods.getImgList(), user.getId(), pid);

      // 异步执行发送

      executor.execute(new Runnable() {

         @Override

         public void run() {

            sendGoods(robotId, wxId, listOpen, recommendText, commentText, goods.getImgList(), user.getId(), pid);

         }

      });

   }



   /**

@@ -899,9 +957,11 @@


      String sales = JDUtil.getSaleCount(jdGoods.getInOrderCount30Days());



      SystemEnum system=userInfoService.getUserSystem(user.getId());



      // 获取推荐语

      String recommendText = shareGoodsTextTemplateService.getRecommendText(coupon, jdGoods.getSkuName(), sales,

            couponAmount, null);

            couponAmount, null,system);



      // 获取评论语

      BigDecimal price = jdGoods.getPrice();

@@ -911,10 +971,16 @@
      }

      String zkPrice = BigDecimalUtil.getWithNoZera(price).toString();

      String commentText = shareGoodsTextTemplateService.getCommentTextByLink(coupon, jumpLink, zkPrice, quanPrice,

            ConfigKeyEnum.quickShareJDCommentText);

            ConfigKeyEnum.quickShareJDCommentText,system);



      // 云发单

      sendGoods(robotId, wxId, listOpen, recommendText, commentText, jdGoods.getImageList(), user.getId(), pid);

      // 异步执行发送

      executor.execute(new Runnable() {

         @Override

         public void run() {

            sendGoods(robotId, wxId, listOpen, recommendText, commentText, jdGoods.getImageList(), user.getId(), pid);

         }

      });

				
   }



   /**

@@ -955,23 +1021,33 @@
         sales = "0";

      }



      SystemEnum system=userInfoService.getUserSystem(user.getId());



      // 获取推荐语

      String recommendText = shareGoodsTextTemplateService.getRecommendText(coupon, goods.getGoodsName(), sales,

            couponAmount, null);

            couponAmount, null,system);



      // 获取评论语

      String zkPrice = MoneyBigDecimalUtil.div(new BigDecimal(goods.getMinGroupPrice()), new BigDecimal(100))

            .setScale(2).toString();

      String commentText = shareGoodsTextTemplateService.getCommentTextByLink(coupon, jumpLink, zkPrice, quanPrice,

            ConfigKeyEnum.quickSharePDDCommentText);

            ConfigKeyEnum.quickSharePDDCommentText,system);



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

		
      List<String> list2 = list;

      // 异步执行发送

      executor.execute(new Runnable() {

         @Override

         public void run() {

            sendGoods(robotId, wxId, listOpen, recommendText, commentText, list2, user.getId(), pid);

         }

      });

				
   }



   /**

@@ -999,16 +1075,22 @@
      boolean coupon = false;

      String quanPrice = "";

      String couponAmount = "";

        SystemEnum system=userInfoService.getUserSystem(user.getId());

      // 获取推荐语

      String recommendText = shareGoodsTextTemplateService.getRecommendText(coupon, goods.getGoodsName(), null,

            couponAmount, null);

            couponAmount, null,system);

      // 获取评论语

      String commentText = shareGoodsTextTemplateService.getCommentTextByLink(coupon, jumpLink,

            goods.getMarketPrice(), quanPrice, ConfigKeyEnum.quickShareVIPCommentText);

            goods.getMarketPrice(), quanPrice, ConfigKeyEnum.quickShareVIPCommentText,system);



      // 云发单

      sendGoods(robotId, wxId, listOpen, recommendText, commentText, goods.getGoodsDetailPictures(), user.getId(),

            pid);

      // 异步执行发送

      executor.execute(new Runnable() {

         @Override

         public void run() {

            sendGoods(robotId, wxId, listOpen, recommendText, commentText, goods.getGoodsDetailPictures(), user.getId(),

                  pid);

         }

      });

   }



   /**

@@ -1040,21 +1122,28 @@
         coupon = true;

      }



      SystemEnum system=userInfoService.getUserSystem(user.getId());



      // 获取推荐语

      String recommendText = shareGoodsTextTemplateService.getRecommendText(coupon,

            goods.getCommodityInfo().getCommodityName(), sales, couponAmount, null);

            goods.getCommodityInfo().getCommodityName(), sales, couponAmount, null,system);



      // 生成快捷分享内容

      String template = configService.get(ConfigKeyEnum.quickShareSuNingCommentText.getKey());

      String template = configService.getValue(ConfigKeyEnum.quickShareSuNingCommentText.getKey(),system);

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

		
      executor.execute(new Runnable() {

         @Override

         public void run() {

            // 云发单

            sendGoods(robotId, wxId, listOpen, recommendText, commentText, imgList, user.getId(), pid);

         }

      });

   }



   /**

@@ -1112,10 +1201,10 @@
               if (macsend)

                  sendContent.setTitle(title);

            }



            SystemEnum system=userInfoService.getUserSystem(uid);

            // 发送图片

            int num = 1;

            String picNum = configService.get(ConfigKeyEnum.robotCloudGroupPictureNum.getKey());

            String picNum = configService.getValue(ConfigKeyEnum.robotCloudGroupPictureNum.getKey(),system);

            if (!StringUtil.isNullOrEmpty(picNum)) {

               num = Integer.parseInt(picNum);

            }

@@ -1147,7 +1236,7 @@
   }



   @Override

   public void fixedTimeSend(List<GoodsEvaluate> listActivity, List<GoodsEvaluate> listGoods) {

   public void fixedTimeSend(List<GoodsEvaluate> listActivity, List<GoodsEvaluate> listGoods, boolean timeLimit) {

      if (listGoods == null && listActivity == null)

         return;

      // 一个小时之前

@@ -1166,11 +1255,15 @@
               if (cloudManage == null || cloudManage.getOfficial() == null || !cloudManage.getOfficial()) {

                  continue;

               }

               // 是否在一个小时内已发送过

               UserCloudSendRecord last = userCloudSendRecordService.getLastByUid(uid, lastTime);

               if (last != null)

                  continue;



					
               // 时间间隔：是否在一个小时内已发送过

               if (timeLimit) {

                  UserCloudSendRecord last = userCloudSendRecordService.getLastByUid(uid, lastTime);

                  if (last != null)

                     continue;

               }

					
				
               String evaluateId = null;

               // 活动

               if (listActivity != null && listActivity.size() > 0) {

@@ -1201,7 +1294,7 @@
                  UserCloudMQMsg msg = new UserCloudMQMsg(uid, evaluateId, UserCloudMQMsg.TYPE_EVALUATE);

                  Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER, UserTopicTagEnum.userCloud,

                        msg);

                  producer.send(message);

                  rocketMQManager.sendNormalMsg(message, null);

               }

            } catch (Exception e) {

               LogHelper.errorDetailInfo(e);

@@ -1235,7 +1328,7 @@
         UserCloudMQMsg msg = new UserCloudMQMsg(uid, UserCloudMQMsg.TYPE_PUSH);

         Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER, UserTopicTagEnum.userCloud, msg);

         message.setStartDeliverTime(java.lang.System.currentTimeMillis() + 1000 * 60 * 10);

         producer.send(message);

         rocketMQManager.sendNormalMsg(message, null);

      }



      // 更新已提醒