云发单对测试用户显示

yujian

2020-06-16 e7920b14a9baab97035a1a529da85d124a2bcacd

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

@@ -71,6 +71,7 @@
import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.ImageToBase64;

import com.yeshi.fanli.util.MoneyBigDecimalUtil;

import com.yeshi.fanli.util.RedisKeyEnum;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.aitaoker.AitaokerApiUtil;

@@ -216,7 +217,6 @@
   }



   @Override

   @Transactional(rollbackFor = Exception.class)

   public void openCloud(Long uid, Long orderId, CloudOrderMenuEnum menuEnum) throws UserCloudException {

      UserCloud existCloud = userCloudMapper.getByOrderId(orderId);

      if (existCloud != null) {

@@ -230,62 +230,60 @@
         if (userCloud.getEndTime().getTime() > java.lang.System.currentTimeMillis())

            renew = true;

         // 验证套餐是否相同

         if (renew && userCloud.getRobotType() != menuEnum.getType()) {

         if (renew && userCloud.getRobotType() != menuEnum.getRobotType()) {

            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返回为空");

//      }

      RobotInfoDTO dto = null;

      if (renew) { // 续费

         dto = AitaokerApiUtil.robotRenewals(userCloud.getRobotId(), menuEnum.getMonth());

      } else { // 创建机器人

         dto = AitaokerApiUtil.robotCreate(menuEnum.getMonth(), menuEnum.getRobotType(), "wechatrobot", null);

      }



      if (dto == null) {

         LogHelper.cloudInfo("方法openCloud: [uid=" + uid + "][订单ID=" + orderId + "]机器人失败： 机器人创建失败");

      }



      Integer robotId = dto.getId();

      if (robotId == null) {

         LogHelper.cloudInfo("方法openCloud: [uid=" + uid + "][订单ID=" + orderId + "]机器人失败： 机器人ID返回为空");

      }

		
      String endTimeStr = dto.getEndTime();

      if (StringUtil.isNullOrEmpty(endTimeStr)) {

         LogHelper.cloudInfo("方法openCloud: [uid=" + uid + "][订单ID=" + orderId + "]机器人失败： 返回时间为空");

      }



      long endTime = 0;

      try {

         endTime = Long.parseLong(endTimeStr);

      } catch (Exception e) {

         LogHelper.cloudInfo("方法openCloud: [uid=" + uid + "][订单ID=" + orderId + "]机器人失败： 返回时间格式不正确");

      }



      Integer groupNum = dto.getGroupNum();

      if (groupNum == null) {

         LogHelper.cloudInfo("方法openCloud: [uid=" + uid + "][订单ID=" + orderId + "]机器人失败： 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.setGroupNum(groupNum);

      newCloud.setRobotId(robotId);

      newCloud.setRobotType(menuEnum.getRobotType());

      if (renew) {

         newCloud.setWxId(userCloud.getWxId());

         newCloud.setWxName(userCloud.getWxName());

         newCloud.setWxPortrait(userCloud.getPortrait());

         newCloud.setStartTime(userCloud.getStartTime());

      } else {

         newCloud.setStartTime(new Date());

      }

      newCloud.setEndTime(new Date(endTime * 1000)); // Unix 转换 普通时间

      newCloud.setCreateTime(new Date());

      userCloudMapper.insertSelective(newCloud);

      

@@ -306,12 +304,27 @@
      List<WeiXinGroupDTO> list = AitaokerApiUtil.getContract(robotId);

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

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



		
      String wxId = userCloud.getWxId();

      for (WeiXinGroupDTO dto : list) {

         userCloudGroupService.addGroup(uid, dto.getGroupId(), dto.getGroupName(), userCloud.getGroupNum());

         String groupId = dto.getGroupId();

         // 检测是否匹配群

         String key =  RedisKeyEnum.cloudMatchGroup.getKey() + StringUtil.Md5(wxId + "_" + groupId);

         String result = redisManager.getCommonString(key);

          if (!StringUtil.isNullOrEmpty(result)) {

            userCloudGroupService.addGroup(uid, dto.getGroupId(), dto.getGroupName(), userCloud.getGroupNum());

         }

      }

   }

   

   @Override

   public void cacheMatchGroup(String wxId, String groupId) {

       if (StringUtil.isNullOrEmpty(wxId) || StringUtil.isNullOrEmpty(groupId))

         return;

      String key =  RedisKeyEnum.cloudMatchGroup.getKey() + StringUtil.Md5(wxId + "_" + groupId);

      redisManager.cacheCommonString(key , "true" , 60*20);

   }

		
   @Override

   public void sendByDynamic(Long uid, String id) throws UserCloudException{

      sendCircleByDynamic(uid, id, UserCloudSendRecord.SEND_WAY_MANUAL);

@@ -374,6 +387,10 @@
      String wxId = userCloud.getWxId();

      if (StringUtil.isNullOrEmpty(wxId)) 

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

		
      if (!AitaokerApiUtil.onlineCheck(robotId)) {

         throw new UserCloudException(1003, "微信已掉线，请先重新登录微信");

      }

      

      // 验证开启状态

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

@@ -492,7 +509,7 @@
      sendRecord.setWxId(wxId);

      sendRecord.setRobotId(robotId);

      sendRecord.setSendTime(new Date());

      sendRecord.setSendOrigin(UserCloudSendRecord.ORIGIN_STORE);

      sendRecord.setSendOrigin(UserCloudSendRecord.ORIGIN_EVALUATE);

      UserCloudSendRecord result = userCloudSendRecordService.save(sendRecord);

      String pid = result.getId();

      

@@ -516,9 +533,12 @@
                  

               if (listImg.size() > 0) {

                  for (String img: listImg) {

                     picUrl += "," + img;

                     picUrl +=  img + ";" ;

                  }

               }

					
               if (picUrl.endsWith(";")) 
                  picUrl = picUrl.substring(0, picUrl.length()-1);

               sendContent.setTitle(title);

               sendContent.setPicUrl(picUrl);

               // 发送图文

@@ -583,7 +603,7 @@
   @Override

   @Transactional(rollbackFor = Exception.class)

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

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

      sendCircleByGoods(uid, goodsId, goodsType, null, sellerId,  UserCloudSendRecord.SEND_WAY_MANUAL);

   }



   @Override

@@ -610,13 +630,14 @@
      

      try {

         // 发送商品

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

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

      } 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 {

   private void sendCircleByGoods(Long uid, Long goodsId, Integer goodsType, Long storeId,

         Long sellerId, int way) throws UserCloudException {

      // 验证是否授权

      UserInfo user = userInfoService.getUserByIdWithMybatis(uid);

      if (user == null)

@@ -665,7 +686,7 @@
            custom = cloudManage.getCustom();

      }

      if (!custom) {

         throw new UserCloudException(0, "成功加入云发单库");

         return;

      }

            

      Integer robotId = userCloud.getRobotId();

@@ -675,6 +696,11 @@
      String wxId = userCloud.getWxId();

      if (StringUtil.isNullOrEmpty(wxId)) 

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

		
      if (!AitaokerApiUtil.onlineCheck(robotId)) {

         throw new UserCloudException(1003, "微信已掉线，请先重新登录微信");

      }

		
      

      // 验证开启状态

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

@@ -715,27 +741,43 @@
      }

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

      try {

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

         }

			
      } catch (UserCloudException e) {

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

         // 更新发单记录

         if (storeId != null) {

            UserCloudGoods record = new UserCloudGoods();

            record.setId(storeId);

            record.setState(UserCloudGoods.STATE_INVALID);

            record.setSendTime(new Date());

            record.setUpdateTime(new Date());

            userCloudGoodsService.updateByPrimaryKeySelective(record);

         }

      }

	
      

      // 更新发单记录

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

      }

		
   }

   

   /**

@@ -1009,9 +1051,12 @@
            String picUrl = "";

            if (listImg.size() > 0) {

               for (String img: listImg) {

                  picUrl += "," + img;

                  picUrl +=  img + ";" ;

               }

            }

				
            if (picUrl.endsWith(";")) 
               picUrl = picUrl.substring(0, picUrl.length()-1);

            sendContent.setTitle(title);

            sendContent.setPicUrl(picUrl);

            

@@ -1072,17 +1117,20 @@
      Date lastTime =  new Date(time);

      

      for (int i = 0; i < 1000; i ++) {

         List<Long> list = userCloudMapper.listValidUid((i-1)*1000, 1000);

         // 查询哪些用户开通

         List<Long> list = userCloudMapper.listValidUid(i*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;