Pu Zhibing
5 小时以前 bc1fd81c844d0f7b17dbe612543073ae049b23a0
ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/service/impl/PartnerServiceImpl.java
@@ -7,7 +7,7 @@
import com.ruoyi.chargingPile.api.model.*;
import com.ruoyi.chargingPile.api.query.GetPartnerList;
import com.ruoyi.chargingPile.api.query.SetPermissionConfiguration;
import com.ruoyi.chargingPile.domain.SiteMenu;
import com.ruoyi.chargingPile.api.domain.SiteMenu;
import com.ruoyi.chargingPile.dto.ResetPassword;
import com.ruoyi.chargingPile.mapper.PartnerMapper;
import com.ruoyi.chargingPile.service.*;
@@ -15,7 +15,6 @@
import com.ruoyi.common.core.utils.StringUtils;
import com.ruoyi.common.core.web.domain.AjaxResult;
import com.ruoyi.common.core.web.page.PageInfo;
import com.ruoyi.common.security.utils.SecurityUtils;
import com.ruoyi.other.api.feignClient.RoleSiteClient;
import com.ruoyi.other.api.feignClient.UserSiteClient;
import com.ruoyi.system.api.domain.SysRole;
@@ -25,12 +24,7 @@
import com.ruoyi.system.api.feignClient.SysUserRoleClient;
import com.ruoyi.system.api.model.GetSysRoleByIds;
import com.ruoyi.system.api.model.SysUserRoleVo;
import io.seata.core.context.RootContext;
import io.seata.core.exception.TransactionException;
import io.seata.spring.annotation.GlobalTransactional;
import io.seata.tm.api.GlobalTransaction;
import io.seata.tm.api.GlobalTransactionContext;
import org.springframework.http.HttpStatus;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
@@ -145,13 +139,15 @@
      user.setDelFlag("0");
      user.setRoleId(partner.getRoleId().longValue());
      user.setRoleType(2);
      user.setObjectId(partner.getId());
      //添加新数据
      this.save(partner);
      R r = sysUserClient.addSysUser(user);
      R<Long> r = sysUserClient.addSysUser(user);
      if(200 != r.getCode()){
         throw new RuntimeException(r.getMsg());
      }
      //添加新数据
      this.save(partner);
      user = sysUserClient.getSysUser(r.getData()).getData();
      user.setObjectId(partner.getId());
      sysUserClient.updateUser(user);
      return AjaxResult.success();
   }
   
@@ -286,7 +282,7 @@
      //站点
      long count = siteService.count(new LambdaQueryWrapper<Site>().in(Site::getPartnerId, ids).eq(Site::getDelFlag, 0));
      if(count > 0){
         return AjaxResult.error("该合作商已关联站点不可删除!");
         return AjaxResult.error("该合作商已关联站点不可删除");
      }
      //充电桩
      long count1 = chargingPileService.count(new LambdaQueryWrapper<TChargingPile>().in(TChargingPile::getPartnerId, ids).eq(TChargingPile::getDelFlag, 0));
@@ -373,7 +369,7 @@
            child.put("selected", collect.contains(siteMenu.getMenuId()));
            list2.add(child);
         }
         menu.put("selected", list2.size() > 0 ? true : false);
         menu.put("selected", collect.contains(tSiteMenu.getMenuId()));
         menu.put("child", list2);
         list1.add(menu);
      }