/**
|
* @Date: 2020年6月22日 下午4:11:13
|
* @Author: ZhengMeng
|
* @Description:
|
*/
|
|
package com.product.org.admin.service;
|
|
import java.util.Date;
|
import java.util.Map;
|
|
import com.product.common.lang.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import com.product.org.admin.config.CmnConst;
|
import com.product.admin.config.SystemCode;
|
import com.product.admin.service.RolesService;
|
import com.product.core.dao.BaseDao;
|
import com.product.core.entity.DataTableEntity;
|
import com.product.core.entity.FieldSetEntity;
|
import com.product.core.exception.BaseException;
|
import com.product.core.service.support.AbstractBaseService;
|
import com.product.core.spring.context.SpringMVCContextHolder;
|
import com.product.core.transfer.Transactional;
|
import com.product.module.sys.service.UserService;
|
import com.product.org.admin.service.idel.IManagementUserService;
|
|
/**
|
* Copyright LX-BASE
|
*
|
* @Title:
|
* @Project: LX-BASE-SERVER
|
* @Date: 2020年6月22日 下午4:11:13
|
* @Author: 郑盟
|
* @Description:
|
*/
|
@Component
|
public class ManagementUserService extends AbstractBaseService implements IManagementUserService {
|
@Autowired
|
private BaseDao baseDao;
|
@Autowired
|
private UserService userService;
|
@Autowired
|
private RolesService rolesService;
|
|
/**
|
* 更新管理员
|
*
|
* @throws BaseException
|
*/
|
@Transactional
|
public boolean updateUser(FieldSetEntity fs) throws BaseException {
|
String userUUID = fs.getString("uuid");
|
FieldSetEntity userFs = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_USERS, fs.getString("uuid"), false);
|
if ("1".equals(fs.getString("status")) && "0".equals(userFs.getString("status"))) {
|
fs.setValue("login_fail_num", null);
|
fs.setValue("locked_expire_time", null);
|
}
|
//郑盟 2020年12月17日 下午16:05
|
if (StringUtils.isEmpty(userUUID))
|
return false;
|
// 状态1、获取数据未绑定人员 实际数据未绑定人员
|
String staffs_uuid = fs.getString(CmnConst.STAFFS_UUID);
|
//郑盟 2020年12月17日 下午16:05
|
if (StringUtils.isEmpty(staffs_uuid)) {
|
DataTableEntity listTable = baseDao.listTable(
|
"SELECT b.uuid FROM product_sys_users a JOIN product_sys_staffs b on a.user_id =b.user_id WHERE a.uuid=?",
|
new String[]{userUUID});
|
if (listTable.getRows() > 0) {
|
// 状态1、获取数据未绑定人员 实际数据绑定人员
|
return updateUserStatusOne(fs);
|
} else {
|
// 状态2、获取数据未绑定人员 实际数据未绑定人员
|
return updateUserStatusTwo(fs);
|
}
|
} else {
|
DataTableEntity listTable = baseDao.listTable(
|
"SELECT b.uuid FROM product_sys_users a JOIN product_sys_staffs b on a.user_id =b.user_id WHERE a.uuid=?",
|
new String[]{userUUID});
|
if (listTable.getRows() > 0) {
|
// 状态3、获取数据绑定人员 实际数据绑定人员
|
return updateUserStatusThree(fs);
|
} else {
|
// 状态4、获取数据绑定人员 实际数据未绑定人员
|
return updateUserStatusFour(fs);
|
}
|
}
|
|
}
|
|
// 更具staffsUUID带出user
|
public FieldSetEntity getStaffsUser(FieldSetEntity fs) throws BaseException {
|
String uuid = fs.getString("uuid");
|
//郑盟 2020年12月17日 下午16:05
|
if (StringUtils.isEmpty(uuid))
|
return null;
|
FieldSetEntity staffsFs = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_STAFFS, uuid, false);
|
if (staffsFs != null) {
|
return baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_USERS, "user_id=? ",
|
new String[]{staffsFs.getString(CmnConst.USER_ID)}, false);
|
}
|
|
return null;
|
}
|
|
public boolean updateRole(FieldSetEntity fs, FieldSetEntity managerFs) throws BaseException {
|
DataTableEntity subDataTable = fs.getSubDataTable(CmnConst.PRODUCT_SYS_FUNCTION_PERMISSION);
|
if (subDataTable != null && subDataTable.getRows() > 0) {
|
for (int i = 0; i < subDataTable.getRows(); i++) {
|
subDataTable.setFieldValue(i, "role_uuid", managerFs.getString("role_uuids"));
|
subDataTable.setFieldValue(i, CmnConst.CREATED_BY,
|
SpringMVCContextHolder.getCurrentUser().getUser_id());
|
subDataTable.setFieldValue(i, CmnConst.CREATED_UTC_DATETIME, new Date());
|
}
|
return rolesService.updatePermission(subDataTable);
|
}
|
return true;
|
}
|
|
public boolean updateUserStatusTwo(FieldSetEntity fs) throws BaseException {
|
String org_level_uuid = fs.getString(CmnConst.ORG_LEVEL_UUID);
|
FieldSetEntity userFs = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_USERS, fs.getString("uuid"), false);
|
if (null != userFs) {
|
FieldSetEntity managerFs = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_MANAGER, "user_id= ?",
|
new String[]{userFs.getString(CmnConst.USER_ID)}, false);
|
if (null == managerFs)
|
return false;
|
managerFs.setValue("clients_uuid", fs.getString("clients_uuid"));
|
managerFs.setValue(CmnConst.ORG_LEVEL_UUID, org_level_uuid);
|
managerFs.setValue(CmnConst.UPDATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());
|
managerFs.setValue(CmnConst.UPDATED_UTC_DATETIME, new Date());
|
boolean update2 = baseDao.update(managerFs);
|
if (!update2)
|
return update2;
|
boolean updateRole = updateRole(fs, managerFs);
|
if (!updateRole)
|
return updateRole;
|
Map<String, DataTableEntity> subData = fs.getSubData();
|
if (fs.getString(CmnConst.PRODUCT_SYS_FUNCTION_PERMISSION) != null) {
|
subData.remove(CmnConst.PRODUCT_SYS_FUNCTION_PERMISSION);
|
}
|
fs.setSubData(subData);
|
fs.setValue(CmnConst.IS_MANAGER, 1);
|
fs.setValue(CmnConst.UPDATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());
|
fs.setValue(CmnConst.UPDATED_UTC_DATETIME, new Date());
|
return baseDao.update(fs);
|
}
|
return false;
|
|
}
|
|
public boolean updateUserStatusOne(FieldSetEntity fs) throws BaseException {
|
String userUUID = fs.getString("uuid");
|
FieldSetEntity userFs = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_USERS, "uuid=?",
|
new String[]{userUUID}, false);
|
userFs.setValue(CmnConst.IS_MANAGER, 0);
|
// 修改user管理员状态
|
boolean userUpdate = baseDao.update(userFs);
|
if (!userUpdate)
|
return false;
|
String user_id = userFs.getString(CmnConst.USER_ID);
|
FieldSetEntity staffsFs = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_STAFFS, " user_id=?",
|
new String[]{user_id}, false);
|
staffsFs.setValue(CmnConst.IS_ORG_ADMIN, 0);
|
// 修改staffs管理员状态
|
staffsFs.setValue(CmnConst.UPDATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());
|
staffsFs.setValue(CmnConst.UPDATED_UTC_DATETIME, new Date());
|
boolean staffsFsUpdate = baseDao.update(staffsFs);
|
if (!staffsFsUpdate)
|
return false;
|
fs.remove("uuid");
|
// 新建用户
|
String user_account = fs.getString(CmnConst.USER_ACCOUNT);
|
// 确认用户是否重复
|
DataTableEntity listTable = baseDao.listTable(CmnConst.PRODUCT_SYS_USERS, "user_account='" + user_account + "'");
|
if (listTable.getRows() > 0) {
|
throw new BaseException(SystemCode.SYSTEM_REPEAT_USER_FAIL.getValue(),
|
SystemCode.SYSTEM_REPEAT_USER_FAIL.getText(), this.getClass(), "addUser");
|
}
|
fs.setValue(CmnConst.IS_MANAGER, 1);
|
fs.setValue(CmnConst.USER_PWD, userService.createPassWord(fs.getString(CmnConst.USER_ACCOUNT), fs.getString(CmnConst.USER_PWD)));
|
fs.setValue(CmnConst.CREATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());
|
fs.setValue(CmnConst.CREATED_UTC_DATETIME, new Date());
|
String addUUID = baseDao.add(fs, false);
|
if (null == addUUID)
|
return false;
|
FieldSetEntity addUser = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_USERS, addUUID, false);
|
String add_user_id = addUser.getString(CmnConst.USER_ID);
|
FieldSetEntity managerFs = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_MANAGER, "user_id =?",
|
new String[]{user_id}, false);
|
managerFs.setValue(CmnConst.USER_ID, add_user_id);
|
// 更换修.PRODUCT_SYS_org_manager表关联user_id
|
managerFs.setValue(CmnConst.UPDATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());
|
managerFs.setValue(CmnConst.UPDATED_UTC_DATETIME, new Date());
|
boolean update = baseDao.update(managerFs);
|
if (!update)
|
return update;
|
return updateRole(fs, managerFs);
|
}
|
|
public boolean updateUserStatusThree(FieldSetEntity fs) throws BaseException {
|
String staffs_uuid = fs.getString(CmnConst.STAFFS_UUID);
|
FieldSetEntity userFs = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_USERS, fs.getString("uuid"), false);
|
FieldSetEntity staffsFs = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_STAFFS, "user_id=? ",
|
new String[]{userFs.getString(CmnConst.USER_ID)}, false);
|
// 判断是否更改人员
|
if (staffs_uuid.equals(staffsFs.getString("uuid"))) {
|
// 如果没有更改人员:则保存基础数据
|
FieldSetEntity managerFs = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_MANAGER, " user_id =?",
|
new String[]{userFs.getString(CmnConst.USER_ID)}, false);
|
managerFs.setValue(CmnConst.ORG_LEVEL_UUID, fs.getString(CmnConst.ORG_LEVEL_UUID));
|
managerFs.setValue(CmnConst.UPDATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());
|
managerFs.setValue(CmnConst.UPDATED_UTC_DATETIME, new Date());
|
boolean managerUpdate = baseDao.update(managerFs);
|
if (!managerUpdate)
|
return managerUpdate;
|
boolean updateRole = updateRole(fs, managerFs);
|
if (!updateRole)
|
return updateRole;
|
Map<String, DataTableEntity> subData = fs.getSubData();
|
subData.remove(CmnConst.PRODUCT_SYS_FUNCTION_PERMISSION);
|
fs.setSubData(subData);
|
fs.setValue(CmnConst.UPDATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());
|
fs.setValue(CmnConst.UPDATED_UTC_DATETIME, new Date());
|
fs.setValue(CmnConst.USER_PWD, userService.createPassWord(fs.getString(CmnConst.USER_ACCOUNT), fs.getString(CmnConst.USER_PWD)));
|
return baseDao.update(fs);
|
} else {
|
// 如果更改人员:把被更改人管理员状态取消 更改人增加管理员状态并且关.PRODUCT_SYS_org_manager
|
userFs.setValue(CmnConst.IS_MANAGER, 0);
|
userFs.setValue(CmnConst.UPDATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());
|
userFs.setValue(CmnConst.UPDATED_UTC_DATETIME, new Date());
|
boolean userUpdate = baseDao.update(userFs);
|
if (!userUpdate)
|
return userUpdate;
|
staffsFs.setValue(CmnConst.IS_ORG_ADMIN, 0);
|
staffsFs.setValue(CmnConst.UPDATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());
|
staffsFs.setValue(CmnConst.UPDATED_UTC_DATETIME, new Date());
|
boolean staffsUpdate = baseDao.update(staffsFs);
|
if (!staffsUpdate)
|
return staffsUpdate;
|
FieldSetEntity Fsstaffs = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_STAFFS, staffs_uuid, false);
|
Fsstaffs.setValue(CmnConst.IS_ORG_ADMIN, 1);
|
Fsstaffs.setValue(CmnConst.UPDATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());
|
Fsstaffs.setValue(CmnConst.UPDATED_UTC_DATETIME, new Date());
|
boolean FsstaffsUpdate = baseDao.update(Fsstaffs);
|
if (!FsstaffsUpdate)
|
return FsstaffsUpdate;
|
FieldSetEntity FsUsers = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_USERS, " user_id =?",
|
new String[]{Fsstaffs.getString(CmnConst.USER_ID)}, false);
|
FsUsers.setValue(CmnConst.IS_MANAGER, 1);
|
FsUsers.setValue(CmnConst.UPDATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());
|
FsUsers.setValue(CmnConst.UPDATED_UTC_DATETIME, new Date());
|
FsUsers.setValue(CmnConst.USER_PWD,
|
userService.createPassWord(FsUsers.getString(CmnConst.USER_ACCOUNT), FsUsers.getString(CmnConst.USER_PWD)));
|
boolean FsUsersUpdate = baseDao.update(FsUsers);
|
FieldSetEntity managerFs = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_MANAGER, " user_id = ?",
|
new String[]{userFs.getString(CmnConst.USER_ID)}, false);
|
managerFs.setValue(CmnConst.USER_ID, FsUsers.getString(CmnConst.USER_ID));
|
managerFs.setValue(CmnConst.UPDATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());
|
managerFs.setValue(CmnConst.UPDATED_UTC_DATETIME, new Date());
|
boolean update = baseDao.update(managerFs);
|
if (!update || !FsUsersUpdate)
|
return false;
|
return updateRole(fs, managerFs);
|
}
|
}
|
|
public boolean updateUserStatusFour(FieldSetEntity fs) throws BaseException {
|
String staffs_uuid = fs.getString(CmnConst.STAFFS_UUID);
|
FieldSetEntity userFs = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_USERS, fs.getString("uuid"), false);
|
userFs.setValue(CmnConst.IS_MANAGER, 0);
|
userFs.setValue(CmnConst.UPDATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());
|
userFs.setValue(CmnConst.UPDATED_UTC_DATETIME, new Date());
|
boolean userUpdate = baseDao.update(userFs);
|
if (!userUpdate)
|
return userUpdate;
|
FieldSetEntity Fsstaffs = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_STAFFS, staffs_uuid, false);
|
boolean executeUpdate = baseDao.executeUpdate("update product_sys_staffs set is_org_admin=1 where uuid=?",
|
new String[]{staffs_uuid});
|
if (!executeUpdate)
|
return executeUpdate;
|
FieldSetEntity FsUsers = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_USERS, "user_id=? ",
|
new String[]{Fsstaffs.getString(CmnConst.USER_ID)}, false);
|
FsUsers.setValue(CmnConst.IS_MANAGER, 1);
|
FsUsers.setValue(CmnConst.UPDATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());
|
FsUsers.setValue(CmnConst.UPDATED_UTC_DATETIME, new Date());
|
FsUsers.setValue(CmnConst.USER_PWD,
|
userService.createPassWord(FsUsers.getString(CmnConst.USER_ACCOUNT), FsUsers.getString(CmnConst.USER_PWD)));
|
if(!StringUtils.isEmpty(fs.getString(CmnConst.USER_NAME))){
|
FsUsers.setValue(CmnConst.USER_NAME,fs.getString(CmnConst.USER_NAME));
|
}
|
boolean FsUsersUpdate = baseDao.update(FsUsers);
|
if (!FsUsersUpdate)
|
return FsUsersUpdate;
|
FieldSetEntity managerFs = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_MANAGER, "user_id=?",
|
new String[]{userFs.getString(CmnConst.USER_ID)}, false);
|
managerFs.setValue(CmnConst.USER_ID, FsUsers.getString(CmnConst.USER_ID));
|
managerFs.setValue(CmnConst.UPDATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());
|
managerFs.setValue(CmnConst.UPDATED_UTC_DATETIME, new Date());
|
boolean update = baseDao.update(managerFs);
|
if (!update)
|
return update;
|
return updateRole(fs, managerFs);
|
}
|
|
|
}
|
