From a51291a48042de026dcce00cec37e735529d496f Mon Sep 17 00:00:00 2001
From: ZQN <364596817@qq.com>
Date: 星期三, 19 六月 2024 09:48:48 +0800
Subject: [PATCH] 企业状态开关添加
---
project-system/src/main/java/com/project/system/service/impl/SysCompanyServiceImpl.java | 35 +++++++++++++++++++++++++++++++----
1 files changed, 31 insertions(+), 4 deletions(-)
diff --git a/project-system/src/main/java/com/project/system/service/impl/SysCompanyServiceImpl.java b/project-system/src/main/java/com/project/system/service/impl/SysCompanyServiceImpl.java
index e43b05a..8b65360 100644
--- a/project-system/src/main/java/com/project/system/service/impl/SysCompanyServiceImpl.java
+++ b/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
--
Gitblit v1.9.1