package com.product.administration.service;
|
|
import java.util.*;
|
|
import com.product.core.entity.DataTableEntity;
|
import com.product.util.BaseUtil;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import com.product.admin.service.CodeService;
|
import com.product.administration.config.CmnConst;
|
import com.product.administration.config.SystemCode;
|
import com.product.administration.service.ide.ITeamService;
|
import com.product.common.lang.StringUtils;
|
import com.product.core.dao.BaseDao;
|
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;
|
|
@Component
|
public class TeamService extends AbstractBaseService implements ITeamService {
|
|
@Autowired
|
BaseDao baseDao;
|
|
@Autowired
|
CodeService codeService;
|
|
/**
|
* 团队树
|
*
|
* @return
|
*/
|
public DataTableEntity treeTeam() {
|
String sql = "SELECT *,(SELECT GROUP_CONCAT(user_id) FROM product_sys_staffs WHERE team_code =`code`)user_ids FROM product_sys_team_config";
|
DataTableEntity dt = baseDao.listTable(sql, new Object[]{});
|
|
return BaseUtil.dataTableToTreeTable(dt, "code", "parent_code", null);
|
}
|
|
/**
|
* 详情
|
*
|
* @return
|
*/
|
public FieldSetEntity findTeam(String uuid) {
|
String sql = "SELECT *,(SELECT GROUP_CONCAT(user_id) FROM product_sys_staffs WHERE team_code =`code`)user_ids FROM product_sys_team_config where uuid =?";
|
return baseDao.getFieldSetEntityBySQL(sql, new Object[]{uuid}, false);
|
|
}
|
|
/**
|
* 团队保存
|
*
|
* @param fse
|
*/
|
@Transactional
|
public void saveTeam(FieldSetEntity fse) {
|
|
//获取团队名称
|
String teanName = fse.getString("name");
|
FieldSetEntity fseValitation = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_TEAM_CONFIG, "name=?", new Object[]{teanName}, false);
|
if (fseValitation != null) {
|
throw new BaseException(SystemCode.TEAM_SAVE_FAIL_DUPLICATE_NAME.getValue(), SystemCode.TEAM_SAVE_FAIL_DUPLICATE_NAME.getText());
|
}
|
|
//是否生成新上级
|
boolean isNewParent = false;
|
|
//获取上级编码
|
String newParentCode = fse.getString("parent_code");
|
if (newParentCode == null) {
|
newParentCode = "";
|
}
|
|
//原编码
|
String originCode = "";
|
|
//判断是否修改
|
if (!StringUtils.isEmpty(fse.getUUID())) {
|
//查询原数据
|
FieldSetEntity fseOriginTeam = this.findTeam(fse.getUUID());
|
//获取原上级编码
|
String originparentCode = fseOriginTeam.getString("parent_code");
|
if (originparentCode == null) {
|
originparentCode = "";
|
}
|
//判断上级是否变化
|
if (!newParentCode.equals(originparentCode)) {
|
isNewParent = true;
|
originCode = fseOriginTeam.getString("code");
|
}
|
} else { //新增
|
isNewParent = true;
|
}
|
|
//判断是否需要重新生成编码
|
if (isNewParent) {
|
//生成新编码
|
String newCode = codeService.createCode(CmnConst.PRODUCT_SYS_TEAM_CONFIG, "code", newParentCode);
|
fse.setValue("code", newCode);
|
//判断是否修改
|
if (!StringUtils.isEmpty(fse.getUUID())) {
|
//变更员工关联编码
|
StringBuilder sqlStaff = new StringBuilder();
|
sqlStaff.append(" update mrbase_sys_staffs ");
|
sqlStaff.append(" set team_code=concat(replace(substring(team_code,1,locate(?,team_code)+length(?)),?,?),substring(team_code,locate(?,team_code)+length(?)+1)) ");
|
sqlStaff.append(" where team_code like ? ");
|
baseDao.executeUpdate(sqlStaff.toString(), new Object[]{originCode, originCode, originCode, newCode, originCode, originCode, originCode + "%"});
|
|
//变更子代团队编码
|
StringBuilder sqlTeam = new StringBuilder();
|
sqlTeam.append(" update product_sys_team_config ");
|
sqlTeam.append(" set code=concat(replace(substring(code,1,locate(?,code)+length(?)),?,?),substring(code,locate(?,code)+length(?)+1)), ");
|
sqlTeam.append(" parent_code=concat(replace(substring(parent_code,1,locate(?,parent_code)+length(?)),?,?),substring(parent_code,locate(?,parent_code)+length(?)+1)) ");
|
sqlTeam.append(" where code like ? ");
|
baseDao.executeUpdate(sqlStaff.toString(), new Object[]{originCode, originCode, originCode, newCode, originCode, originCode, originCode, originCode, originCode, newCode, originCode, originCode, originCode + "%"});
|
}
|
}
|
BaseUtil.createCreatorAndCreationTime(fse);
|
baseDao.saveFieldSetEntity(fse);
|
}
|
|
/**
|
* 删除团队
|
*
|
* @param code 编码
|
* @return
|
* @throws BaseException
|
*/
|
@Transactional
|
public boolean deleteTeam(String code) throws BaseException {
|
|
//子团队验证
|
DataTableEntity subTeam = baseDao.listTable(CmnConst.PRODUCT_SYS_TEAM_CONFIG, "parent_code like ?", new Object[]{code + "%"});
|
if (!BaseUtil.dataTableIsEmpty(subTeam)) {
|
throw new BaseException(SystemCode.TEAM_MANAGER_DELETE_FAIL_HAS_SUB_TEAM.getValue(), SystemCode.TEAM_MANAGER_DELETE_FAIL_HAS_SUB_TEAM.getText());
|
}
|
|
//员工验证
|
DataTableEntity staffTeam = baseDao.listTable(CmnConst.PRODUCT_SYS_STAFFS, "team_code like ?", new Object[]{code + "%"});
|
if (!BaseUtil.dataTableIsEmpty(staffTeam)) {
|
throw new BaseException(SystemCode.TEAM_MANAGER_DELETE_FAIL_HAS_STAFF_REFERED.getValue(), SystemCode.TEAM_MANAGER_DELETE_FAIL_HAS_STAFF_REFERED.getText());
|
}
|
|
|
//删除团队及及下级团队
|
return baseDao.delete(CmnConst.PRODUCT_SYS_TEAM_CONFIG, "code = ? ", new Object[]{code});
|
}
|
}
|
