package com.product.admin.service;
|
|
import com.alibaba.druid.util.StringUtils;
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.product.admin.config.CmnConst;
|
import com.product.admin.config.SystemCode;
|
import com.product.admin.service.idel.ISelectPersonnelService;
|
import com.product.core.dao.BaseDao;
|
import com.product.core.entity.DataTableEntity;
|
import com.product.core.entity.FieldMetaEntity;
|
import com.product.core.entity.FieldSetEntity;
|
import com.product.core.exception.BaseException;
|
import com.product.core.service.support.AbstractBaseService;
|
import com.product.core.service.support.QueryFilterService;
|
import com.product.core.spring.context.SpringMVCContextHolder;
|
import com.product.core.transfer.Transactional;
|
import com.product.module.sys.entity.SystemUser;
|
import com.product.util.BaseUtil;
|
|
import java.util.Date;
|
import java.util.HashSet;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import com.product.core.permission.PermissionService;
|
import org.springframework.stereotype.Service;
|
|
/**
|
* Copyright LX-BASE
|
*
|
* @Title: SelectPersonnelService
|
* @Project: LX-BASE-SERVER
|
* @Date: 2020年8月26日 17:33:37
|
* @Author: luoxin
|
* @Description: 组织架构
|
*/
|
//
|
@Service
|
public class SelectPersonnelService extends AbstractBaseService implements ISelectPersonnelService {
|
@Autowired
|
public BaseDao baseDao;
|
@Autowired
|
PermissionService permissionService;
|
@Autowired
|
QueryFilterService queryFilterService;
|
@Override
|
public BaseDao getBaseDao() {
|
return baseDao;
|
}
|
@Override
|
public void setBaseDao(BaseDao baseDao) {
|
this.baseDao = baseDao;
|
}
|
|
@Override
|
public JSONObject getOrganizationStructureTree(String theCompanyUuid) throws BaseException {
|
|
FieldSetEntity company = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_ORG_LEVELS, theCompanyUuid, false);
|
DataTableEntity data = baseDao.listTable(
|
"SELECT * FROM product_sys_org_levels a\n"
|
+ "WHERE a.org_level_code LIKE CONCAT((SELECT org_level_code FROM product_sys_org_levels \n"
|
+ "WHERE uuid = ?), '%') AND org_level_type=1 AND org_level_status=0 ORDER BY a.org_level_code",
|
new String[] { theCompanyUuid });
|
|
JSONObject companyObject = new JSONObject();
|
companyObject.put(CmnConst.UUID, company.getString(CmnConst.UUID));
|
companyObject.put(CmnConst.ORG_LEVEL_NAME, company.getString(CmnConst.ORG_LEVEL_NAME));
|
companyObject.put(CmnConst.ORG_LEVEL_ALL, company.getString(CmnConst.ORG_LEVEL_ALL));
|
if (data.getRows() > 0) {
|
companyObject.put("children", OrgLevelChildrenTree(data, company.getString("org_level_code")));
|
}
|
|
return companyObject;
|
}
|
|
@Override
|
public JSONArray getOrganizationThoseWho(String tablenaem, String uuid) throws BaseException {
|
// 获取公司或部门信息
|
FieldSetEntity setEntity = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_ORG_LEVELS, uuid, false);
|
// 1为部门 获取部门下的人或岗位
|
DataTableEntity dataTableEntity;
|
|
String dataFilter=permissionService.getDataFilter(CmnConst.ORG_LEVEL_UUID) ;
|
|
if (setEntity.getString("org_level_type").equals("1")) {
|
// 如果为岗位表
|
if (CmnConst.PRODUCT_SYS_JOB_POSTS.equals(tablenaem)) {
|
StringBuffer sql = new StringBuffer();
|
sql.append(" SELECT * FROM ( ")
|
.append(" SELECT b.*,a.org_level_all FROM product_sys_org_levels a ")
|
.append(" LEFT JOIN product_sys_job_posts b ON a.uuid = b.dept_uuid ")
|
.append(" WHERE b.is_used = '1' AND b.dept_uuid = ? ) c");
|
if(!BaseUtil.strIsNull(dataFilter)) {
|
sql.append(" where " + dataFilter);
|
}
|
dataTableEntity = baseDao.listTable(sql.toString(), new String[] { uuid });
|
} else {
|
StringBuffer filter = new StringBuffer();
|
filter.append(" dept_uuid = ? ");
|
if(!BaseUtil.strIsNull(dataFilter)) {
|
filter.append(" and ").append(dataFilter);
|
}
|
dataTableEntity = baseDao.listTable(tablenaem, filter.toString(), new String[] { uuid });
|
if (!BaseUtil.dataTableIsEmpty(dataTableEntity)) {
|
return acquireInternationalization(CmnConst.PRODUCT_SYS_JOB_POSTS, CmnConst.JOB_POST_NAME, dataTableEntity);
|
}
|
}
|
// 0为公司 获取公司下的人
|
} else {
|
// 如果为岗位表
|
|
if (CmnConst.PRODUCT_SYS_JOB_POSTS.equals(tablenaem)) {
|
StringBuilder sql = new StringBuilder();
|
sql.append(" SELECT * FROM ( ")
|
.append(" SELECT b.*,a.org_level_all FROM ")
|
.append(" product_sys_org_levels a LEFT JOIN ")
|
.append(" product_sys_job_posts b ON a.uuid = b.dept_uuid WHERE b.is_used = '1' AND b.org_level_uuid = ?) c ");
|
if(!BaseUtil.strIsNull(dataFilter)) {
|
sql.append(" where " + dataFilter);
|
}
|
dataTableEntity = baseDao.listTable(sql.toString(), new String[] { uuid });
|
} else {
|
StringBuffer filter = new StringBuffer();
|
filter.append(" org_level_uuid = ? ");
|
if(!BaseUtil.strIsNull(dataFilter)) {
|
filter.append(" and ").append(dataFilter);
|
}
|
dataTableEntity = baseDao.listTable(tablenaem, filter.toString(),
|
new String[] { uuid });
|
if (!BaseUtil.dataTableIsEmpty(dataTableEntity)) {
|
return acquireInternationalization(CmnConst.PRODUCT_SYS_JOB_POSTS, CmnConst.JOB_POST_NAME, dataTableEntity);
|
}
|
}
|
|
}
|
|
return BaseUtil.dataTableEntityToJson(baseDao.listInternationDataTable(dataTableEntity, null));
|
}
|
|
/**
|
* 通过员工data获取对应的国际化岗位 存入员工field
|
*
|
* @param tableName 岗位表名
|
* @param parameter 岗位字段
|
* @param staffField 员工field数据
|
* @return 员工field数据
|
*/
|
public JSONObject acquireInternationalization(String tableName, String parameter, FieldSetEntity staffField)
|
throws BaseException {
|
FieldSetEntity set = staffField;
|
JSONObject jsonObject = new JSONObject();
|
// 员工uuid
|
jsonObject.put(CmnConst.UUID, set.getString(CmnConst.UUID));
|
// 员工展示名称
|
jsonObject.put("show_name", set.getString("show_name"));
|
// 岗位表UUID
|
jsonObject.put(CmnConst.JOB_POST_UUID, set.getString(CmnConst.JOB_POST_UUID));
|
// 公司uuid
|
jsonObject.put("org_level_uuid", set.getString("org_level_uuid"));
|
// 部门uuid
|
jsonObject.put("dept_uuid", set.getString("dept_uuid"));
|
|
// 国际化data
|
// DataTableEntity data = baseDao.listInternationDataTable(tableName, new String[] { parameter },
|
// new String[] { set.getString(CmnConst.JOB_POST_UUID) }, null);
|
// JSONArray subArray = new JSONArray();
|
// JSONObject obj;
|
// FieldSetEntity fe;
|
// for (int j = 0, le = data.getRows(); j < le; j++) {
|
// obj = new JSONObject();
|
// fe = data.getFieldSetEntity(j);
|
// obj.put(String.valueOf(fe.getValues().get(CmnConst.LANGUAGE_CODE)),
|
// String.valueOf(fe.getValues().get(CmnConst.FIELD_VALUE)));
|
// obj.put(CmnConst.UUID, String.valueOf(fe.getValues().get(CmnConst.UUID)));
|
// subArray.add(obj);
|
// }
|
// jsonObject.put(parameter, subArray);
|
return jsonObject;
|
}
|
|
/**
|
* 通过员工data获取对应的国际化岗位 存入员工data
|
*
|
* @param tableName 岗位表名
|
* @param parameter 岗位字段
|
* @param staffData 员工data数据
|
* @return 员工data数据
|
*/
|
public JSONArray acquireInternationalization(String tableName, String parameter, DataTableEntity staffData)
|
throws BaseException {
|
JSONArray array = new JSONArray();
|
for (int i = 0, length = staffData.getRows(); i < length; i++) {
|
array.add(acquireInternationalization(tableName, parameter, staffData.getFieldSetEntity(i)));
|
}
|
return array;
|
}
|
|
@Override
|
@Transactional
|
public String savePersonageTheGroup(FieldSetEntity fse) throws BaseException {
|
SystemUser currentUser=SpringMVCContextHolder.getCurrentUser();
|
String userId = String.valueOf(currentUser.getUser_id());
|
String uuid;
|
Integer groupType = fse.getInteger(CmnConst.GROUP_TYPE);
|
String groupName = fse.getString(CmnConst.GROUP_NAME);
|
FieldSetEntity fieldSetEntity = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_GROUP, "group_name = ? and created_by = ? ",
|
new String[] { groupName,userId }, false);
|
// fieldSetEntity为空 新增
|
if (fieldSetEntity == null) {
|
fieldSetEntity = new FieldSetEntity();
|
fieldSetEntity.setTableName(fse.getTableName());
|
// 个人组 获取当前人ID uuid
|
fieldSetEntity.setValue(CmnConst.USER_ID, SpringMVCContextHolder.getCurrentUser().getUser_id());
|
fieldSetEntity.setValue(CmnConst.GROUP_TYPE, groupType);
|
fieldSetEntity.setValue(CmnConst.GROUP_NAME, groupName);
|
fieldSetEntity = BaseUtil.createCreatorAndCreationTime(SpringMVCContextHolder.getCurrentUser(),
|
fieldSetEntity);
|
FieldMetaEntity f = new FieldMetaEntity();
|
f.setTableName(new Object[]{CmnConst.GROUP_NAME});
|
//luoxin 2020-12-17 11:38:31 新增时虚拟国际化
|
DataTableEntity data = baseDao.listTable("SELECT language_code FROM product_common_language WHERE is_used = 1",new Object[]{});
|
DataTableEntity dt = new DataTableEntity();
|
dt.setMeta(f);
|
for (int i = 0,length = data.getRows(); i < length; i++) {
|
FieldSetEntity entity = new FieldSetEntity();
|
entity.setMeta(f);
|
String languageCode = data.getFieldSetEntity(i).getString("language_code");
|
if(!BaseUtil.strIsNull(languageCode)){
|
entity.setValue(languageCode, groupName);
|
dt.addFieldSetEntity(entity);
|
}
|
}
|
fieldSetEntity.addSubDataTable(dt);
|
uuid = baseDao.add(fieldSetEntity);
|
// fieldSetEntity不为空 替换
|
} else {
|
// 个人组 获取当前人ID uuid
|
uuid = fieldSetEntity.getString(CmnConst.UUID);
|
fieldSetEntity.setValue(CmnConst.USER_ID, SpringMVCContextHolder.getCurrentUser().getUser_id());
|
fieldSetEntity.setValue(CmnConst.GROUP_TYPE, groupType);
|
fieldSetEntity.setValue(CmnConst.GROUP_NAME, groupName);
|
fieldSetEntity = baseDao.listInternationDataTable(fieldSetEntity,null);
|
// 添加创建人
|
fieldSetEntity = BaseUtil.createCreatorAndCreationTime(SpringMVCContextHolder.getCurrentUser(),
|
fieldSetEntity);
|
// 清除子表
|
baseDao.delete(CmnConst.PRODUCT_SYS_GROUP_SUB, CmnConst.GROUP_UUID+" = ? ", new Object[] { uuid });
|
baseDao.update(fieldSetEntity);
|
}
|
// 添加子表
|
DataTableEntity subData;
|
|
// 员工map
|
HashSet<Integer> hashSet = analyticalFramework(fse.getSubDataTable(CmnConst.PRODUCT_SYS_GROUP_SUB));
|
if (hashSet.size() > 0) {
|
subData = encapsulateTheUser(hashSet, uuid);
|
baseDao.add(subData);
|
}
|
|
return uuid;
|
|
}
|
|
@Override
|
@Transactional
|
public String saveCompanyTheGroup(FieldSetEntity fse) throws BaseException {
|
FieldSetEntity fieldSetEntity;
|
String uuid = fse.getString(CmnConst.UUID);
|
Integer groupType = fse.getInteger(CmnConst.GROUP_TYPE);
|
// 获取子表
|
DataTableEntity sub = fse.getSubDataTable(CmnConst.PRODUCT_SYS_GROUP_SUB);
|
// uuid为空 新增
|
if (uuid == null || uuid.isEmpty()) {
|
fieldSetEntity = new FieldSetEntity();
|
FieldMetaEntity f = new FieldMetaEntity();
|
f.setTableName(new Object[] { fse.getTableName() });
|
fieldSetEntity.setMeta(f);
|
// 公司组 获取当前人ID uuid
|
fieldSetEntity.setValue(CmnConst.COMPANY_UUID, fse.getString(CmnConst.COMPANY_UUID));
|
fieldSetEntity.setValue(CmnConst.GROUP_TYPE, groupType);
|
DataTableEntity group_name = fse.getSubDataTable(CmnConst.GROUP_NAME);
|
FieldMetaEntity ff = new FieldMetaEntity();
|
ff.setTableName(new Object[] { CmnConst.GROUP_NAME });
|
group_name.setMeta(ff);
|
fieldSetEntity.addSubDataTable(group_name);
|
if (!StringUtils.isEmpty(fse.getString("sort"))) {
|
fieldSetEntity.setValue("sort", Integer.parseInt(fse.getString("sort")));
|
}
|
fieldSetEntity = BaseUtil.createCreatorAndCreationTime(SpringMVCContextHolder.getCurrentUser(),
|
fieldSetEntity);
|
|
uuid = baseDao.add(fieldSetEntity);
|
|
// uuid不为空 替换
|
} else {
|
fieldSetEntity = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_GROUP, uuid, false);
|
// 公司组 获取选择 uuid
|
fieldSetEntity.setValue(CmnConst.COMPANY_UUID, fse.getString(CmnConst.COMPANY_UUID));
|
fieldSetEntity.setValue(CmnConst.GROUP_TYPE, groupType);
|
fieldSetEntity.setValue(CmnConst.COMPANY_UUID, fse.getString(CmnConst.COMPANY_UUID));
|
fieldSetEntity.setValue(CmnConst.GROUP_TYPE, groupType);
|
DataTableEntity group_name = fse.getSubDataTable(CmnConst.GROUP_NAME);
|
FieldMetaEntity ff = new FieldMetaEntity();
|
ff.setTableName(new Object[] { CmnConst.GROUP_NAME });
|
group_name.setMeta(ff);
|
fieldSetEntity.addSubDataTable(group_name);
|
if (!StringUtils.isEmpty(fse.getString("sort"))) {
|
fieldSetEntity.setValue("sort", Integer.parseInt(fse.getString("sort")));
|
}
|
|
// 添加创建人
|
fieldSetEntity = BaseUtil.createCreatorAndCreationTime(SpringMVCContextHolder.getCurrentUser(),
|
fieldSetEntity);
|
// 清除子表
|
baseDao.delete(CmnConst.PRODUCT_SYS_GROUP_SUB, "group_uuid = ? ", new Object[] { uuid });
|
// 架构子表
|
baseDao.delete(CmnConst.PRODUCT_SYS_GROUP_SELECT, "group_uuid = ? ", new Object[] { uuid });
|
baseDao.update(fieldSetEntity);
|
}
|
// 判断子表是否为空
|
if (BaseUtil.dataTableIsEmpty(sub)) {
|
return uuid;
|
} else {
|
// 添加子表
|
DataTableEntity subData;
|
|
// 员工map
|
HashSet<Integer> hashSet = analyticalFramework(sub);
|
if (hashSet.size() > 0) {
|
// 创建用户子表
|
subData = encapsulateTheUser(hashSet, uuid);
|
// 保存用户子表
|
baseDao.add(subData);
|
}
|
|
// 保存已经选择的架构子表
|
DataTableEntity select = packagingSelect(sub, uuid);
|
baseDao.add(select);
|
return uuid;
|
}
|
|
}
|
|
/**
|
* 封装架构子表
|
*
|
* @param sub 子表data
|
* @param superUuid 组uuid
|
* @return
|
* @throws BaseException
|
*/
|
public DataTableEntity packagingSelect(DataTableEntity sub, String superUuid) throws BaseException {
|
DataTableEntity subData = new DataTableEntity();
|
FieldSetEntity setEntity;
|
FieldMetaEntity f = new FieldMetaEntity();
|
f.setTableName(new Object[] { CmnConst.PRODUCT_SYS_GROUP_SELECT });
|
subData.setMeta(f);
|
// 保存组织架构子表
|
for (int i = 0, length = sub.getRows(); i < length; i++) {
|
setEntity = new FieldSetEntity();
|
setEntity.setMeta(f);
|
setEntity.setValue(CmnConst.ORGANIZATION_TYPES, sub.getFieldSetEntity(i).getString(CmnConst.ORGANIZATION_TYPES));
|
setEntity.setValue(CmnConst.ORGANIZATION_UUIDS, sub.getFieldSetEntity(i).getString(CmnConst.ORGANIZATION_UUIDS));
|
setEntity.setValue(CmnConst.GROUP_UUID, superUuid);
|
setEntity = BaseUtil.createCreatorAndCreationTime(SpringMVCContextHolder.getCurrentUser(), setEntity);
|
subData.addFieldSetEntity(setEntity);
|
}
|
return subData;
|
}
|
|
@Override
|
@Transactional
|
public boolean deleteTheGroup(FieldSetEntity fse) throws BaseException {
|
String uuids = fse.getString("uuids");
|
// 查询是否被引用
|
String parameter = "%" + uuids + "%";
|
DataTableEntity data = baseDao.listTable(
|
"SELECT * FROM product_sys_organizational_structure_storage WHERE organization_uuids like ? ",
|
new String[] { parameter });
|
if (BaseUtil.dataTableIsEmpty(data)) {
|
String[] uuid = uuids.split(",");
|
//luoxin 2020-12-17 11:37:56修改删除方法
|
for (int i = 0, length = uuid.length; i < length; ++i) {
|
baseDao.delete(CmnConst.PRODUCT_SYS_GROUP, new String[] { uuid[i] });
|
}
|
return true;
|
} else {
|
return false;
|
}
|
}
|
|
/**
|
* 封装组子表
|
*
|
* @param hashSet 用户id集
|
* @param uuid 组uuid
|
* @return
|
* @throws BaseException
|
*/
|
public DataTableEntity encapsulateTheUser(HashSet<Integer> hashSet, String uuid) throws BaseException {
|
DataTableEntity subData = new DataTableEntity();
|
FieldSetEntity setEntity;
|
FieldMetaEntity f = new FieldMetaEntity();
|
f.setTableName(new Object[] { CmnConst.PRODUCT_SYS_GROUP_SUB });
|
subData.setMeta(f);
|
for (Integer key : hashSet) {
|
setEntity = new FieldSetEntity();
|
setEntity.setMeta(f);
|
setEntity.setValue(CmnConst.GROUP_UUID, uuid);
|
setEntity.setValue(CmnConst.STAFF_ID, key);
|
setEntity = BaseUtil.createCreatorAndCreationTime(SpringMVCContextHolder.getCurrentUser(), setEntity);
|
subData.addFieldSetEntity(setEntity);
|
}
|
return subData;
|
}
|
|
@Override
|
public DataTableEntity getTheGroup(FieldSetEntity fse) throws BaseException {
|
String uuid = fse.getString(CmnConst.UUID);
|
StringBuilder sql = new StringBuilder();
|
sql.append("SELECT a.* FROM product_sys_staffs a ")
|
.append("LEFT JOIN product_sys_group_sub b ON a.staff_id = b.staff_id WHERE group_uuid = ?");
|
DataTableEntity dataTableEntity = baseDao.listTable(sql.toString(), new Object[] { uuid });
|
return dataTableEntity;
|
}
|
|
@Override
|
public DataTableEntity listAllGroup(FieldSetEntity fse) throws BaseException {
|
// 当前人uuid
|
int userId = SpringMVCContextHolder.getCurrentUser().getUser_id();
|
// 公司uuid 4个人组 5单位组
|
String companyUuid = fse.getString(CmnConst.COMPANY_UUID);
|
companyUuid = "%" + companyUuid + "%";
|
StringBuilder sql = new StringBuilder();
|
sql.append("SELECT * FROM product_sys_group WHERE group_type = 4 AND user_id = ? UNION ALL ")
|
.append("SELECT * FROM product_sys_group WHERE group_type = 5 AND company_uuid like ? order by sort desc");
|
return baseDao.listTable(sql.toString(), new Object[] { userId, companyUuid });
|
}
|
|
@Override
|
public JSONObject listCompanyGroup(FieldSetEntity fse) throws BaseException {
|
// 公司uuid
|
String companyUuid = fse.getString(CmnConst.COMPANY_UUID);
|
if(BaseUtil.strIsNull(companyUuid)){
|
return null;
|
}
|
String queryFilter;
|
Integer cpage = fse.getInteger("cpage");// 当前页数
|
Integer pagesize = fse.getInteger("pagesize");// 每页条数
|
if(BaseUtil.dataTableIsEmpty(fse.getSubDataTable("systemSeniorQueryString"))){
|
queryFilter = " company_uuid = ? ";
|
}else {
|
queryFilter = " company_uuid = ? AND " + queryFilterService.getQueryFilter(fse);
|
}
|
DataTableEntity dataTableEntity = baseDao.listTable(fse.getTableName(),queryFilter,new String[]{companyUuid},null,null, pagesize, cpage);
|
JSONObject object = new JSONObject();
|
if (BaseUtil.dataTableIsEmpty(dataTableEntity)) {
|
object.put("data",dataTableEntity);
|
return object;
|
}
|
JSONArray jsonArray = new JSONArray();
|
for (int i = 0, length = dataTableEntity.getRows(); i < length; ++i) {
|
FieldSetEntity set = dataTableEntity.getFieldSetEntity(i);
|
String group_uuid = set.getString(CmnConst.UUID);
|
JSONObject obj = new JSONObject();
|
// 组名
|
obj.put(CmnConst.UUID, group_uuid);
|
//group_name国际化
|
FieldSetEntity fee;
|
JSONArray arr = new JSONArray();
|
DataTableEntity dd = baseDao.listInternationDataTable(CmnConst.PRODUCT_SYS_GROUP,
|
new String[] { CmnConst.GROUP_NAME }, new String[] { group_uuid }, null);
|
JSONObject object0;
|
for (int j = 0, le = dd.getRows(); j < le; j++) {
|
object0 = new JSONObject();
|
fee = dd.getFieldSetEntity(j);
|
// 国际化标识
|
String languageCode = String.valueOf(fee.getValues().get(CmnConst.LANGUAGE_CODE));
|
// 国际化值
|
String fieldValue = String.valueOf(fee.getValues().get(CmnConst.FIELD_VALUE));
|
// 国际uuid
|
String uuid = String.valueOf(fee.getValues().get(CmnConst.UUID));
|
object0.put(languageCode, fieldValue);
|
object0.put(CmnConst.UUID, uuid);
|
arr.add(object0);
|
}
|
obj.put("groupName", arr);
|
JSONArray array = new JSONArray();
|
StringBuilder sql = new StringBuilder();
|
sql.append("SELECT a.organization_types,b.uuid,b.show_name name FROM product_sys_group_select a ")
|
.append("LEFT JOIN product_sys_staffs b ON a.organization_uuids = b.uuid ")
|
.append("WHERE a.organization_types = 1 AND a.group_uuid = ? UNION ALL ")
|
.append("SELECT a.organization_types,b.uuid,b.org_level_name name FROM product_sys_group_select a ")
|
.append("LEFT JOIN product_sys_org_levels b ON a.organization_uuids = b.uuid ")
|
.append("WHERE a.organization_types = 2 AND a.group_uuid = ? UNION ALL ")
|
.append("SELECT a.organization_types,b.uuid,b.job_post_name FROM product_sys_group_select a ")
|
.append("LEFT JOIN product_sys_job_posts b ON a.organization_uuids = b.uuid ")
|
.append("WHERE a.organization_types = 3 AND a.group_uuid = ? ");
|
DataTableEntity table1 = baseDao.listTable(sql.toString(),new String[] { group_uuid, group_uuid, group_uuid });
|
if (!BaseUtil.dataTableIsEmpty(table1)) {
|
for (int k = 0, ta = table1.getRows(); k < ta; k++) {
|
FieldSetEntity setEntity = table1.getFieldSetEntity(k);
|
JSONObject ob = new JSONObject();
|
ob.put(CmnConst.ORGANIZATION_TYPES, setEntity.getString(CmnConst.ORGANIZATION_TYPES));
|
ob.put(CmnConst.ORGANIZATION_UUIDS, setEntity.getString(CmnConst.UUID));
|
if ("1".equals(setEntity.getString(CmnConst.ORGANIZATION_TYPES))) {
|
ob.put(CmnConst.ORGANIZATION_NAMES, setEntity.getString("name"));
|
}
|
//部门
|
if ("2".equals(setEntity.getString(CmnConst.ORGANIZATION_TYPES))) {
|
FieldSetEntity fe;
|
JSONArray ar = new JSONArray();
|
DataTableEntity d = baseDao.listInternationDataTable(CmnConst.PRODUCT_SYS_ORG_LEVELS,
|
new String[] { CmnConst.ORG_LEVEL_NAME }, new String[] { setEntity.getString(CmnConst.UUID) }, null);
|
JSONObject object1;
|
for (int j = 0, le = d.getRows(); j < le; j++) {
|
object1 = new JSONObject();
|
fe = d.getFieldSetEntity(j);
|
// 国际化标识
|
String languageCode = String.valueOf(fe.getValues().get(CmnConst.LANGUAGE_CODE));
|
// 国际化值
|
String fieldValue = String.valueOf(fe.getValues().get(CmnConst.FIELD_VALUE));
|
// 国际uuid
|
String uuid = String.valueOf(fe.getValues().get(CmnConst.UUID));
|
object1.put(languageCode, fieldValue);
|
object1.put(CmnConst.UUID, uuid);
|
ar.add(object1);
|
}
|
ob.put(CmnConst.ORGANIZATION_NAMES, ar);
|
}
|
//岗位
|
if ("3".equals(setEntity.getString(CmnConst.ORGANIZATION_TYPES))) {
|
FieldSetEntity fe;
|
JSONArray ar = new JSONArray();
|
DataTableEntity d = baseDao.listInternationDataTable(CmnConst.PRODUCT_SYS_JOB_POSTS,
|
new String[] { CmnConst.JOB_POST_NAME }, new String[] { setEntity.getString(CmnConst.UUID) }, null);
|
JSONObject object1;
|
for (int j = 0, le = d.getRows(); j < le; j++) {
|
object1 = new JSONObject();
|
fe = d.getFieldSetEntity(j);
|
// 国际化标识
|
String languageCode = String.valueOf(fe.getValues().get(CmnConst.LANGUAGE_CODE));
|
// 国际化值
|
String fieldValue = String.valueOf(fe.getValues().get(CmnConst.FIELD_VALUE));
|
// 国际uuid
|
String uuid = String.valueOf(fe.getValues().get(CmnConst.UUID));
|
object1.put(languageCode, fieldValue);
|
object1.put(CmnConst.UUID, uuid);
|
ar.add(object1);
|
}
|
ob.put(CmnConst.ORGANIZATION_NAMES, ar);
|
}
|
array.add(ob);
|
}
|
}
|
obj.put("organization_info", array);
|
jsonArray.add(obj);
|
}
|
object.put("data", jsonArray);
|
object.put("totalCount", dataTableEntity.getSqle().getTotalCount());// 总条数
|
object.put("totalpage", dataTableEntity.getSqle().getTotalpage());// 总页数
|
object.put("psize", dataTableEntity.getSqle().getPsize());// 每页条数
|
object.put("pindex", dataTableEntity.getSqle().getPindex());// 当前页
|
object.put("datatable",dataTableEntity);
|
return object;
|
}
|
|
@Override
|
public FieldSetEntity getCompanyGroupInfo(FieldSetEntity fse) throws BaseException {
|
String uuid = fse.getString(CmnConst.UUID);
|
FieldSetEntity fieldSetEntity = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_GROUP, uuid, false);
|
StringBuilder staffsSql = new StringBuilder();
|
staffsSql.append("SELECT c.uuid FROM product_sys_group a ")
|
.append("LEFT JOIN product_sys_group_select b ON a.uuid = b.group_uuid ")
|
.append("LEFT JOIN product_sys_staffs c ON c.uuid = b.organization_uuids ")
|
.append("WHERE a.group_type = 5 AND b.organization_types = '1' AND a.uuid = ?");
|
DataTableEntity staffs = baseDao.listTable(staffsSql.toString(), new String[] { uuid });
|
if (!BaseUtil.dataTableIsEmpty(staffs)) {
|
StringBuilder staffsUuids = new StringBuilder();
|
for (int i = 0, length = staffs.getRows(); i < length; ++i) {
|
staffsUuids.append(staffs.getFieldSetEntity(i).getString(CmnConst.UUID)).append(",");
|
}
|
String suuid = staffsUuids.substring(0, staffsUuids.length() - 1);
|
fieldSetEntity.setValue("staffsUuids", suuid);
|
}
|
StringBuilder levelsSql = new StringBuilder();
|
levelsSql.append("SELECT c.uuid FROM product_sys_group a ")
|
.append("LEFT JOIN product_sys_group_select b ON a.uuid = b.group_uuid ")
|
.append("LEFT JOIN product_sys_org_levels c ON c.uuid = b.organization_uuids ")
|
.append("WHERE a.group_type = 5 AND b.organization_types = '2' AND a.uuid = ? ");
|
DataTableEntity levels = baseDao.listTable(levelsSql.toString(), new String[] { uuid });
|
if (!BaseUtil.dataTableIsEmpty(levels)) {
|
StringBuilder levelsUuids = new StringBuilder();
|
for (int i = 0, length = levels.getRows(); i < length; ++i) {
|
levelsUuids.append(levels.getFieldSetEntity(i).getString(CmnConst.UUID)).append(",");
|
}
|
String luuid = levelsUuids.substring(0, levelsUuids.length() - 1);
|
fieldSetEntity.setValue("levelsUuids", luuid);
|
}
|
StringBuilder postsSql = new StringBuilder();
|
postsSql.append("SELECT c.uuid FROM product_sys_group a ")
|
.append("LEFT JOIN product_sys_group_select b ON a.uuid = b.group_uuid ")
|
.append("LEFT JOIN product_sys_job_posts c ON c.uuid = b.organization_uuids ")
|
.append("WHERE a.group_type = 5 AND b.organization_types = '3' AND a.uuid = ? ");
|
DataTableEntity posts = baseDao.listTable(postsSql.toString(), new String[] { uuid });
|
if (!BaseUtil.dataTableIsEmpty(posts)) {
|
StringBuilder postsUuids = new StringBuilder();
|
for (int i = 0, length = posts.getRows(); i < length; ++i) {
|
postsUuids.append(posts.getFieldSetEntity(i).getString(CmnConst.UUID)).append(",");
|
}
|
String puuid = postsUuids.substring(0, postsUuids.length() - 1);
|
fieldSetEntity.setValue("postsUuids", puuid);
|
}
|
FieldSetEntity fs = baseDao.listInternationDataTable(fieldSetEntity,null);
|
|
return fs;
|
}
|
|
/**
|
*
|
* @param organizationalData 要处理的DATA
|
* @param fieldSetEntity 存值fs
|
* @param name 名称集
|
* @param type 类型集
|
* @param uuid uuid集
|
* @return 返回fs
|
* @throws BaseException
|
*/
|
public FieldSetEntity encapsulatedOrganizationStructure(DataTableEntity organizationalData,
|
FieldSetEntity fieldSetEntity, String name, String type, String uuid) throws BaseException {
|
if (organizationalData != null && organizationalData.getRows() > 0) {
|
StringBuilder names = new StringBuilder();
|
StringBuilder types = new StringBuilder();
|
StringBuilder uuids = new StringBuilder();
|
names.append(organizationalData.getFieldSetEntity(0).getString(name));
|
types.append(organizationalData.getFieldSetEntity(0).getString(type));
|
uuids.append(organizationalData.getFieldSetEntity(0).getString(uuid));
|
for (int i = 1, length = organizationalData.getRows(); i < length; ++i) {
|
FieldSetEntity setEntity = organizationalData.getFieldSetEntity(i);
|
names.append(",").append(setEntity.getString(name));
|
types.append(",").append(setEntity.getString(type));
|
uuids.append(",").append(setEntity.getString(uuid));
|
}
|
fieldSetEntity.setValue(name, names.toString());
|
fieldSetEntity.setValue(type, types.toString());
|
fieldSetEntity.setValue(uuid, uuids.toString());
|
|
} else {
|
fieldSetEntity.setValue(name, "");
|
fieldSetEntity.setValue(type, "");
|
fieldSetEntity.setValue(uuid, "");
|
}
|
return fieldSetEntity;
|
}
|
|
/**
|
* 保存组织架构信息 并保存人的组织架构下的人id
|
*
|
* @param fse 组信息
|
* @return
|
* @throws BaseException
|
*/
|
@Override
|
@Transactional
|
public String saveOrganization(FieldSetEntity fse) throws BaseException {
|
String uuid = fse.getString(CmnConst.UUID);
|
DataTableEntity organizationalData = fse.getSubDataTable("organizational_sub");
|
// 创建组织架构储存表
|
FieldSetEntity fieldSetEntity = new FieldSetEntity();
|
FieldMetaEntity f = new FieldMetaEntity();
|
f.setTableName(new Object[]{fse.getTableName()});
|
fieldSetEntity.setMeta(f);
|
if(!BaseUtil.dataTableIsEmpty(organizationalData)) {
|
fieldSetEntity = encapsulatedOrganizationStructure(organizationalData, fieldSetEntity, CmnConst.ORGANIZATION_NAMES,
|
CmnConst.ORGANIZATION_TYPES, CmnConst.ORGANIZATION_UUIDS);
|
HashSet<Integer> set = analyticalFramework(organizationalData);
|
if (!set.isEmpty() && set.size() > 0) {
|
StringBuilder userIds = new StringBuilder();
|
for (Integer key : set) {
|
// 拼接员工id集
|
userIds.append(key).append(",");
|
}
|
String Ids = userIds.substring(0, userIds.length() - 1);
|
// 储存员工id集
|
fieldSetEntity.setValue("staff_ids", Ids);
|
} else {
|
fieldSetEntity.setValue("staff_ids", "");
|
}
|
// 新增
|
if (uuid == null || uuid.isEmpty()) {
|
fieldSetEntity = BaseUtil.createCreatorAndCreationTime(SpringMVCContextHolder.getCurrentUser(),
|
fieldSetEntity);
|
uuid = baseDao.add(fieldSetEntity);
|
// 修改
|
} else {
|
fieldSetEntity.setValue(CmnConst.UUID, uuid);
|
fieldSetEntity = BaseUtil.updatedRegeneratorAndUpdateTime(SpringMVCContextHolder.getCurrentUser(),
|
fieldSetEntity);
|
baseDao.update(fieldSetEntity);
|
}
|
}else {
|
baseDao.executeUpdate("update product_sys_organizational_structure_storage set `organization_names` = null, `staff_ids` = null, `organization_uuids` = null, `organization_types` = null where uuid = ? ",new String[]{uuid});
|
}
|
return uuid;
|
}
|
|
@Override
|
public JSONArray getAtPresentOrganization(FieldSetEntity fse) throws BaseException {
|
FieldSetEntity set = baseDao.getFieldSetEntity(fse.getTableName(), fse.getString(CmnConst.UUID), false);
|
if (set == null) {
|
return null;
|
}
|
String names = set.getString(CmnConst.ORGANIZATION_NAMES);
|
JSONArray array = new JSONArray();
|
// 没有值
|
if (StringUtils.isEmpty(names)) {
|
return array;
|
} else {
|
String types = set.getString(CmnConst.ORGANIZATION_TYPES);
|
String uuids = set.getString(CmnConst.ORGANIZATION_UUIDS);
|
String[] type = types.split(",");
|
String[] uuid = uuids.split(",");
|
FieldSetEntity fieldSetEntity;
|
|
for (int i = 0, length = type.length; i < length; ++i) {
|
// 员工
|
switch (type[i]){
|
case "1":
|
fieldSetEntity = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_STAFFS, uuid[i], false);
|
break;
|
// 部门
|
case "2":
|
fieldSetEntity = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_ORG_LEVELS, uuid[i], false);
|
break;
|
// 岗位
|
case "3":
|
StringBuilder sql = new StringBuilder();
|
sql.append("SELECT b.*,a.org_level_all FROM product_sys_org_levels a LEFT JOIN ")
|
.append("product_sys_job_posts b ON a.uuid = b.dept_uuid WHERE b.uuid = ? ");
|
DataTableEntity data = baseDao.listTable(sql.toString(), new String[] { uuid[i] });
|
fieldSetEntity = data.getFieldSetEntity(0);
|
fieldSetEntity = baseDao.listInternationDataTable(fieldSetEntity, null);
|
break;
|
// 个人组或单位组
|
default:
|
fieldSetEntity = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_GROUP, uuid[i], false);
|
}
|
// 放入结构类型
|
if (fieldSetEntity != null) {
|
fieldSetEntity.setValue("type", type[i]);
|
// 为人员要添加对应国际化岗位
|
if ("1".equals(type[i])) {
|
JSONObject object = acquireInternationalization(CmnConst.PRODUCT_SYS_JOB_POSTS, CmnConst.JOB_POST_NAME,
|
fieldSetEntity);
|
object.put("type", type[i]);
|
array.add(object);
|
} else {
|
array.add(BaseUtil.fieldSetEntityToJson(fieldSetEntity));
|
}
|
}
|
}
|
return array;
|
}
|
}
|
|
/**
|
* 获取单位 部门 岗位组下的人 员工
|
*
|
* @param dataTableEntity
|
* @return
|
*/
|
public HashSet<Integer> analyticalFramework(DataTableEntity dataTableEntity) throws BaseException {
|
FieldSetEntity fieldSetEntity;
|
FieldSetEntity set;
|
DataTableEntity data;
|
HashSet<Integer> hashSet = new HashSet<>();
|
if(BaseUtil.dataTableIsEmpty(dataTableEntity)){
|
return hashSet;
|
}
|
for (int i = 0, length = dataTableEntity.getRows(); i < length; i++) {
|
fieldSetEntity = dataTableEntity.getFieldSetEntity(i);
|
String type = fieldSetEntity.getString(CmnConst.ORGANIZATION_TYPES);
|
String uuid = fieldSetEntity.getString(CmnConst.ORGANIZATION_UUIDS);
|
// 员工
|
if ("1".equals(type)) {
|
set = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_STAFFS, uuid, false);
|
hashSet.add(set.getInteger(CmnConst.STAFF_ID));
|
// 部门
|
} else if ("2".equals(type)) {
|
data = baseDao.listTable(CmnConst.PRODUCT_SYS_STAFFS, "dept_uuid = ?", new Object[] { uuid });
|
for (int j = 0, len = data.getRows(); j < len; j++) {
|
hashSet.add(data.getFieldSetEntity(j).getInteger(CmnConst.STAFF_ID));
|
}
|
// 岗位
|
} else if ("3".equals(type)) {
|
data = baseDao.listTable(CmnConst.PRODUCT_SYS_STAFFS, "job_post_uuid = ?", new Object[] { uuid });
|
for (int j = 0, len = data.getRows(); j < len; j++) {
|
hashSet.add(data.getFieldSetEntity(j).getInteger(CmnConst.STAFF_ID));
|
}
|
// 单位组或个人组
|
} else {
|
data = baseDao.listTable(
|
"SELECT b.* FROM product_sys_group_sub a LEFT JOIN product_sys_staffs b on a.staff_id = b.staff_id WHERE group_uuid = ?",
|
new Object[] { uuid });
|
for (int j = 0, len = data.getRows(); j < len; j++) {
|
hashSet.add(data.getFieldSetEntity(j).getInteger(CmnConst.STAFF_ID));
|
}
|
}
|
}
|
return hashSet;
|
}
|
|
/**
|
* 封装组织架构树
|
*
|
* @param data
|
* @param org_level_code 上级code
|
* @return
|
* @throws BaseException
|
*/
|
public JSONArray OrgLevelChildrenTree(DataTableEntity data, String org_level_code) throws BaseException {
|
JSONArray children_array = new JSONArray();
|
if (!StringUtils.isEmpty(org_level_code)) {
|
for (int i = 0; i < data.getRows(); i++) {
|
FieldSetEntity fs = data.getFieldSetEntity(i);
|
if (org_level_code.equals(fs.getString("org_level_code_parent"))) {
|
JSONObject org_children = new JSONObject();
|
org_children.put(CmnConst.UUID, fs.getString(CmnConst.UUID));
|
org_children.put(CmnConst.ORG_LEVEL_NAME, fs.getString(CmnConst.ORG_LEVEL_NAME));
|
org_children.put(CmnConst.ORG_LEVEL_ALL, fs.getString(CmnConst.ORG_LEVEL_ALL));
|
org_children.put("children", OrgLevelChildrenTree(data, fs.getString("org_level_code")));
|
children_array.add(org_children);
|
}
|
}
|
}
|
return children_array;
|
}
|
|
/**
|
* 定时执行更新组织架构
|
*
|
* @throws BaseException
|
*/
|
public void timingOrganization() throws BaseException {
|
DataTableEntity dt = baseDao.listTable(CmnConst.PRODUCT_SYS_ORGANIZATIONAL_STRUCTURE_STORAGE, "is_auto_update=1");
|
for (int i = 0; i < dt.getRows(); i++) {
|
FieldSetEntity fs = dt.getFieldSetEntity(i);
|
FieldSetEntity fss = new FieldSetEntity();
|
FieldMetaEntity f = new FieldMetaEntity();
|
f.setTableName(new Object[] { CmnConst.PRODUCT_SYS_ORGANIZATIONAL_STRUCTURE_STORAGE });
|
fss.setMeta(f);
|
fss.setValue(CmnConst.UUID, fs.getString(CmnConst.UUID));
|
|
DataTableEntity subDt = new DataTableEntity();
|
String[] organization_names = fs.getString(CmnConst.ORGANIZATION_NAMES).split(",");
|
String[] organization_types = fs.getString(CmnConst.ORGANIZATION_TYPES).split(",");
|
String[] organization_uuids = fs.getString(CmnConst.ORGANIZATION_UUIDS).split(",");
|
if (organization_names.length != organization_types.length
|
|| organization_types.length != organization_uuids.length) {
|
throw new BaseException(SystemCode.SYSTEM_UPDATE_TIMINGORGANIZATION_CENTER.getText(),
|
SystemCode.SYSTEM_UPDATE_TIMINGORGANIZATION_CENTER.getValue(), this.getClass(),
|
"timingOrganization");
|
}
|
for (int j = 0; j < organization_names.length; j++) {
|
FieldSetEntity existencefSetEntity = null;
|
switch (organization_types[j]){
|
case "1":
|
existencefSetEntity = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_STAFFS, organization_uuids[j], false);
|
break;
|
case "2":
|
existencefSetEntity = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_ORG_LEVELS, organization_uuids[j],
|
false);
|
break;
|
case "3":
|
existencefSetEntity = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_JOB_POSTS, organization_uuids[j],
|
false);
|
|
break;
|
case "4":
|
case "5":
|
existencefSetEntity = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_GROUP, organization_uuids[j], false);
|
break;
|
default:
|
}
|
if (existencefSetEntity != null) {
|
FieldSetEntity sbufss = new FieldSetEntity();
|
FieldMetaEntity subf = new FieldMetaEntity();
|
subf.setTableName(new Object[] { "organizational_sub" });
|
sbufss.setMeta(subf);
|
sbufss.setValue(CmnConst.ORGANIZATION_NAMES, organization_names[j]);
|
sbufss.setValue(CmnConst.ORGANIZATION_TYPES, organization_types[j]);
|
sbufss.setValue(CmnConst.ORGANIZATION_UUIDS, organization_uuids[j]);
|
subDt.addFieldSetEntity(sbufss);
|
}
|
}
|
if (subDt.getRows() == 0) {
|
baseDao.delete(CmnConst.PRODUCT_SYS_ORGANIZATIONAL_STRUCTURE_STORAGE, "uuid=?",
|
new String[] { fs.getString(CmnConst.UUID) });
|
} else {
|
fss.addSubDataTable(subDt);
|
saveOrganization(fss);
|
}
|
}
|
|
}
|
|
|
/**
|
* 修改员工岗位或部门就修改组内容
|
* @param department_uuid 部门uuid
|
* @param company_uuid 岗位uuid
|
* @param staff_uuid 员工uuid
|
*/
|
public void updataGruopContent(String department_uuid,String company_uuid,String staff_uuid) throws BaseException{
|
|
FieldSetEntity staff = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_STAFFS,staff_uuid,false);
|
if (staff == null){
|
return;
|
}
|
String staff_id = staff.getString(CmnConst.STAFF_ID);
|
//当前人之前岗位或部门是否在组里面 在组里
|
|
StringBuilder sql = new StringBuilder();
|
sql.append(" SELECT b.uuid FROM product_sys_group_select a LEFT JOIN product_sys_group_sub b on a.group_uuid = b.group_uuid ")
|
.append(" WHERE b.staff_id = ? AND (a.organization_types = 2 or a.organization_types = 3) AND a.group_uuid not in ( ")
|
.append(" SELECT c.group_uuid FROM product_sys_group_select c WHERE c.organization_types = 1) GROUP BY b.uuid");
|
DataTableEntity dataTableEntity = baseDao.listTable(sql.toString(), new Object[]{staff_id});
|
for (int i = 0,length = dataTableEntity.getRows(); i < length; i++) {
|
FieldSetEntity fieldSetEntity = dataTableEntity.getFieldSetEntity(i);
|
//删除之前的组成员
|
baseDao.delete(CmnConst.PRODUCT_SYS_GROUP_SUB,new String[]{fieldSetEntity.getString(CmnConst.UUID)});
|
}
|
//查询当前部门或岗位是否存在组里面
|
DataTableEntity dataOrganization = baseDao.listTable("SELECT * FROM product_sys_group_select WHERE (organization_types = 2 AND organization_uuids = ? ) or (organization_types = 3 AND organization_uuids = ?)", new Object[]{department_uuid, company_uuid});
|
//当前部门或岗位在组里面
|
if(!BaseUtil.dataTableIsEmpty(dataOrganization)){
|
for (int i = 0,length = dataOrganization.getRows(); i < length; i++) {
|
FieldSetEntity fieldOrganization = dataOrganization.getFieldSetEntity(i);
|
//组主表uuid
|
String group_uuid = fieldOrganization.getString(CmnConst.GROUP_UUID);
|
//组uuid
|
String organization_uuids = fieldOrganization.getString(CmnConst.ORGANIZATION_UUIDS);
|
// 部门 2
|
if(fieldOrganization.getString(CmnConst.ORGANIZATION_TYPES).equals("2")){
|
addGruopContent(organization_uuids,department_uuid,group_uuid,staff_id);
|
// 岗位 3
|
}else if(fieldOrganization.getString(CmnConst.ORGANIZATION_TYPES).equals("3")){
|
addGruopContent(organization_uuids,company_uuid,group_uuid,staff_id);
|
}
|
}
|
}
|
}
|
|
/**
|
* 组岗位部门新增员工 时时修改群主表
|
* @param organization_uuids 组的部门和岗位uuid
|
* @param company_uuid 部门或岗位uuid
|
* @param group_uuid 组uuid
|
* @param staff_id 员工id
|
*/
|
public void addGruopContent(String organization_uuids,String company_uuid,String group_uuid,String staff_id) throws BaseException{
|
//当前人岗位跟公司组岗位相等
|
if(organization_uuids.equals(company_uuid)){
|
//查询组部门下是否有此人
|
DataTableEntity data = baseDao.listTable("SELECT * FROM product_sys_group_sub WHERE group_uuid = ? AND staff_id = ?",new Object[]{group_uuid,staff_id});
|
//为空就新增一条数据
|
if(BaseUtil.dataTableIsEmpty(data)){
|
FieldSetEntity newField = new FieldSetEntity();
|
newField.setTableName(CmnConst.PRODUCT_SYS_GROUP_SUB);
|
newField.setValue(CmnConst.GROUP_UUID,group_uuid);
|
newField.setValue(CmnConst.STAFF_ID,staff_id);
|
newField.setValue(CmnConst.CREATED_BY,SpringMVCContextHolder.getCurrentUser().getUser_id());
|
newField.setValue(CmnConst.CREATED_UTC_DATETIME,new Date());
|
baseDao.add(newField);
|
}
|
}
|
}
|
}
|
