企业状态开关添加

ZQN

2024-06-19 a51291a48042de026dcce00cec37e735529d496f

 project-system/src/main/java/com/project/system/service/impl/SysCompanyServiceImpl.java

@@ -62,7 +62,7 @@
        SysCompany add = Convert.convert(SysCompany.class, bo);
        validEntityBeforeSave(add);
        boolean save = this.save(add);
        addCompanyUser(add);
        addCompanyUser(add, 0);
        return save;
    }

@@ -77,10 +77,23 @@
            if (!delUser) {
                throw new BaseException("原企业用户清除失败，请联系管理员！");
            }
            this.addCompanyUser(update);
            this.addCompanyUser(update, 0);
        }
        validEntityBeforeSave(update);
        return this.updateById(update);
    }

    @Override//状态开关
    @Transactional
    public Boolean updStatus(SysCompanyBo bo)
    {
        if (bo.getCompanyId()==null || bo.getCompanyStatus()==null) {
            throw new BaseException("参数有误，状态修改失败！");
        }
        SysCompany company = this.getById(bo.getCompanyId());
        company.setCompanyStatus(bo.getCompanyStatus());
        updCompanyUserStatus(company.getCompanyPhone(), bo.getCompanyStatus());
        return this.updateById(company);
    }

    @Override//删除
@@ -137,7 +150,9 @@
        });
        List<SysCompany> companies = Convert.toList(SysCompany.class, resultVo.getVoList());
        boolean b = this.saveOrUpdateBatch(companies);
        companies.forEach(this::addCompanyUser);
        for (SysCompany company : companies) {
            addCompanyUser(company,1);
        }
        return b;
    }

@@ -237,9 +252,15 @@
     * @param entity    企业信息
     */
    @Async
    protected void addCompanyUser(SysCompany entity)
    protected void addCompanyUser(SysCompany entity, Integer isImport)
    {

        SysUser user = new SysUser();
        if (isImport==1){
            user.setStatus("0");
        } else {
            user.setStatus("1");
        }
        SysCompany one = this.getOne(lq().eq(SysCompany::getCompanyCode, entity.getCompanyCode()));
        String phone = entity.getCompanyPhone();
        user.setPhonenumber(phone);
@@ -268,6 +289,12 @@
        userService.insertUser(user);
    }

    @Async
    protected void updCompanyUserStatus(String phone, Integer status)
    {
        userService.update(userService.lu().set(SysUser::getStatus,status).eq(SysUser::getPhonenumber, phone));
    }

    /**
     * 删除企业用户
     * @param companyId    企业id