订单搜索引擎增量更新

admin

2020-01-07 6fdcc0c26dd33e87a024a69ed635d9aedb59cad6

 fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserInfoExtraServiceImpl.java

@@ -52,6 +52,7 @@
import com.yeshi.fanli.service.inter.user.UserRankService;

import com.yeshi.fanli.service.inter.user.invite.ThreeSaleSerivce;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.FilePathEnum;

import com.yeshi.fanli.util.InviteCodeFilterUtil;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.account.UserUtil;

@@ -379,10 +380,11 @@
         userInfoExtraMapper.insertSelective(userInfoExtra);

      }



      // 发送激活成功消息

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

            new Gson().toJson(new InviteCodeActiveMQMsg(uid, new Date())));

      producer.send(message);

      if (!Constant.IS_TEST) { // 发送激活成功消息

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

               new Gson().toJson(new InviteCodeActiveMQMsg(uid, new Date())));

         producer.send(message);

      }



      return mycode;

   }

@@ -447,7 +449,7 @@
               LogHelper.test("微信头像下载失败: " + weiXinUser.getUnionid() + " " + headimgurl);

            } else {

               FileUploadResult result = COSManager.getInstance().uploadFile(asInputStream, String.format(

                     "/portrait/wx/%s_%s.jpg", weiXinUser.getUnionid(), System.currentTimeMillis() + ""));

                     FilePathEnum.userWXPortrait.getPath() + "%s_%s.jpg", weiXinUser.getUnionid(), System.currentTimeMillis() + ""));

               if (result != null && !StringUtil.isNullOrEmpty(result.getUrl())) {

                  headimgurl = result.getUrl();

               } else {

@@ -496,10 +498,12 @@
         userInfoExtra.setCreateTime(new Date());

         userInfoExtraMapper.insertSelective(userInfoExtra);

      }

      // 发送激活成功消息

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

            new Gson().toJson(new InviteCodeActiveMQMsg(uid, new Date())));

      producer.send(message);

		
      if (!Constant.IS_TEST) { // 发送激活成功消息

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

               new Gson().toJson(new InviteCodeActiveMQMsg(uid, new Date())));

         producer.send(message);

      }

   }



   @Override

@@ -564,7 +568,7 @@
               LogHelper.test("微信头像下载失败: " + weiXinUser.getUnionid() + " " + headimgurl);

            } else {

               FileUploadResult result = COSManager.getInstance().uploadFile(asInputStream, String.format(

                     "/portrait/wx/%s_%s.jpg", weiXinUser.getUnionid(), System.currentTimeMillis() + ""));

                     FilePathEnum.userWXPortrait.getPath() + "%s_%s.jpg", weiXinUser.getUnionid(), System.currentTimeMillis() + ""));

               if (result != null && !StringUtil.isNullOrEmpty(result.getUrl())) {

                  headimgurl = result.getUrl();

               } else {

@@ -614,6 +618,12 @@
      } else {

         userInfoExtra.setCreateTime(new Date());

         userInfoExtraMapper.insertSelective(userInfoExtra);

      }

		
      if (!Constant.IS_TEST) { // 发送激活成功消息

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

               new Gson().toJson(new InviteCodeActiveMQMsg(uid, new Date())));

         producer.send(message);

      }

   }



@@ -846,10 +856,12 @@
      update.setInviteCodeVip(inviteCodeVip);

      update.setUpdateTime(new Date());

      userInfoExtraMapper.updateByPrimaryKeySelective(update);

       //发送邀请码更改成功的消息

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

            new Gson().toJson(new UserInfoUpdateMQMsg(uid, UserInfoUpdateTypeEnum.inviteCode, inviteCodeVip, new Date())));

      producer.send(message);

	   
      if(!Constant.IS_TEST) { //发送邀请码更改成功的消息

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

               new Gson().toJson(new UserInfoUpdateMQMsg(uid, UserInfoUpdateTypeEnum.inviteCode, inviteCodeVip, new Date())));

         producer.send(message);

      }

   }

   

   

@@ -869,7 +881,7 @@
      }

      

      // 执行上传

      String filePath = "/img/user/erCode/" + UUID.randomUUID().toString().replace("-", "") + ".jpg";

      String filePath = FilePathEnum.userERcode.getPath() + UUID.randomUUID().toString().replace("-", "") + ".jpg";

      String fileLink = COSManager.getInstance().uploadFile(new File(targetPath), filePath).getUrl();

   

      // 删除本地图片