返利配置文件加入系统区分

admin

2020-07-07 c9cbad5f5d18c6b2ac5a063e41007933d7028329

 fanli/src/main/java/com/yeshi/fanli/service/impl/user/tb/UserExtraTaoBaoInfoServiceImpl.java

@@ -5,6 +5,8 @@


import javax.annotation.Resource;



import com.yeshi.fanli.entity.SystemEnum;

import com.yeshi.fanli.service.inter.user.UserInfoService;

import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Transactional;



@@ -43,6 +45,9 @@
   @Resource

   private RocketMQManager rocketMQManager;



    @Resource

    private UserInfoService userInfoService;



   @Transactional(rollbackFor = Exception.class)

   @Override

   public void addRelationId(Long uid, String relationId, String taoBaoUid, String nickName, boolean valid)

@@ -57,6 +62,19 @@
         throw new UserExtraTaoBaoInfoException(Constant.CODE_FORBIDDEN_USER, Constant.FORBIDDEN_USER_REASON_DESC);

      }



        //清除该用户的授权信息

        userExtraTaoBaoInfoMapper.clearUid(uid);

        SystemEnum system = userInfoService.getUserSystem(uid);

        List<UserExtraTaoBaoInfo> list = userExtraTaoBaoInfoMapper.listByTaoBaoUid(taoBaoUid,system);

        UserExtraTaoBaoInfo existInfo = null;

        if (list != null)

            for (UserExtraTaoBaoInfo tb : list) {

                SystemEnum se = userInfoService.getUserSystem(tb.getUser().getId());

                if (se == system) {

                    existInfo = tb;

                    break;

                }

            }

      UserExtraTaoBaoInfo taoBaoInfo = new UserExtraTaoBaoInfo();

      taoBaoInfo.setUser(new UserInfo(uid));

      taoBaoInfo.setTaoBaoNickName(nickName);

@@ -65,16 +83,14 @@
      taoBaoInfo.setRelationValid(valid);

      taoBaoInfo.setRelationUpdateTime(new Date());



      userExtraTaoBaoInfoMapper.clearUid(uid);



      List<UserExtraTaoBaoInfo> list = userExtraTaoBaoInfoMapper.listByTaoBaoUid(taoBaoUid);

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

        if (existInfo==null) {

         // 新增

         taoBaoInfo.setCreateTime(new Date());

         userExtraTaoBaoInfoMapper.insertSelective(taoBaoInfo);

      } else {

         // 取第一个替换uid 等信息

         taoBaoInfo.setId(list.get(0).getId());

            taoBaoInfo.setId(existInfo.getId());

         taoBaoInfo.setUpdateTime(new Date());

         userExtraTaoBaoInfoMapper.updateByPrimaryKeySelective(taoBaoInfo);



@@ -101,6 +117,9 @@
         throw new UserExtraTaoBaoInfoException(Constant.CODE_FORBIDDEN_USER, Constant.FORBIDDEN_USER_REASON_DESC);

      }



        userExtraTaoBaoInfoMapper.clearUid(uid);

        SystemEnum system = userInfoService.getUserSystem(uid);



      UserExtraTaoBaoInfo taoBaoInfo = new UserExtraTaoBaoInfo();

      taoBaoInfo.setUser(new UserInfo(uid));

      taoBaoInfo.setTaoBaoNickName(nickName);

@@ -111,7 +130,7 @@


      userExtraTaoBaoInfoMapper.clearUid(uid);



      List<UserExtraTaoBaoInfo> list = userExtraTaoBaoInfoMapper.listByTaoBaoUid(taoBaoUid);

        List<UserExtraTaoBaoInfo> list = userExtraTaoBaoInfoMapper.listByTaoBaoUid(taoBaoUid,system);

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

         // 新增

         taoBaoInfo.setCreateTime(new Date());

@@ -146,6 +165,8 @@
         throw new UserExtraTaoBaoInfoException(Constant.CODE_FORBIDDEN_USER, Constant.FORBIDDEN_USER_REASON_DESC);

      }



        SystemEnum system=userInfoService.getUserSystem(uid);



      UserExtraTaoBaoInfo taoBaoInfo = new UserExtraTaoBaoInfo();

      taoBaoInfo.setTaoBaoUid(taoBaoUid);

      taoBaoInfo.setTaoBaoNickName(nickName);

@@ -159,7 +180,7 @@
      taoBaoInfo.setSpecialId(specialId);

      taoBaoInfo.setSpecialUpdateTime(new Date());



      List<UserExtraTaoBaoInfo> list = userExtraTaoBaoInfoMapper.listByTaoBaoUid(taoBaoUid);

        List<UserExtraTaoBaoInfo> list = userExtraTaoBaoInfoMapper.listByTaoBaoUid(taoBaoUid,system);



      // 判断之前用户是否绑定过

      UserExtraTaoBaoInfo info = userExtraTaoBaoInfoMapper.selectByUid(uid);

@@ -265,7 +286,7 @@
   public void bindTaoBaoOrderEnd6Num(String taoBaoUid, String orderId) {

      if (taoBaoUid == null || StringUtil.isNullOrEmpty(orderId))

         return;

      UserExtraTaoBaoInfo extraInfo = userExtraTaoBaoInfoMapper.selectByTaoBaoUid(taoBaoUid);

        UserExtraTaoBaoInfo extraInfo = userExtraTaoBaoInfoMapper.selectByTaoBaoUid(taoBaoUid,null);

      if (extraInfo != null) {

         UserExtraTaoBaoInfo update = new UserExtraTaoBaoInfo();

         update.setId(extraInfo.getId());

@@ -277,17 +298,17 @@
   }



   @Override

   public UserExtraTaoBaoInfo getByRelationId(String relationId) {

    public UserExtraTaoBaoInfo getByRelationId(String relationId,SystemEnum system) {

      if (StringUtil.isNullOrEmpty(relationId))

         return null;

      return userExtraTaoBaoInfoMapper.selectByRelationIdWithUidNotNull(relationId);

        return userExtraTaoBaoInfoMapper.selectByRelationIdWithUidNotNull(relationId,system);

   }



   @Override

   public UserExtraTaoBaoInfo getBySpecialId(String specialId) {

    public UserExtraTaoBaoInfo getBySpecialId(String specialId,SystemEnum system) {

      if (StringUtil.isNullOrEmpty(specialId))

         return null;

      return userExtraTaoBaoInfoMapper.selectBySpecialIdWithUidNotNull(specialId);

        return userExtraTaoBaoInfoMapper.selectBySpecialIdWithUidNotNull(specialId,system);

   }



   @Override