package com.product.org.admin.service;
|
|
|
import java.util.ArrayList;
|
import java.util.Arrays;
|
import java.util.Iterator;
|
import java.util.List;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.product.common.lang.StringUtils;
|
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.permission.PermissionService;
|
import com.product.core.service.support.AbstractBaseService;
|
import com.product.core.service.support.QueryFilterService;
|
import com.product.core.transfer.Transactional;
|
import com.product.org.admin.config.CmnConst;
|
import com.product.org.admin.config.SystemCode;
|
import com.product.org.admin.service.idel.IStaffSysPropertyService;
|
import com.product.util.BaseUtil;
|
|
/**
|
*
|
* Copyright LX-BASE
|
* @Title: LX-BASE-
|
* @Project: StaffSysPropertyService
|
* @Date: 2020-06-20 14:20
|
* @Author: 杜洪波
|
* @Description:员工系统属性
|
*/
|
@Component
|
public class StaffSysPropertyService extends AbstractBaseService implements IStaffSysPropertyService{
|
|
@Autowired
|
private BaseDao baseDao;
|
|
@Autowired
|
PermissionService permissionService;
|
|
@Autowired
|
QueryFilterService queryFilterService;
|
|
/**
|
* 员工属性分组列表
|
* @param cpage
|
* @param pageSize
|
* @return
|
* @throws BaseException
|
*/
|
public DataTableEntity listPropertyGroup(Integer cpage,Integer pageSize, FieldSetEntity fse) throws BaseException {
|
|
//数据策略
|
String dataFilter=permissionService.getDataFilter(CmnConst.ORG_LEVEL_UUID) ;
|
|
//高级搜索
|
String searchFilter=queryFilterService.getQueryFilter(fse);
|
if (!StringUtils.isEmpty(dataFilter)) {
|
if (!StringUtils.isEmpty(searchFilter)) {
|
dataFilter+=" AND "+ searchFilter;
|
}
|
}else {
|
if (!StringUtils.isEmpty(searchFilter)) {
|
dataFilter=searchFilter;
|
}
|
}
|
|
return baseDao.listInternationDataTable(baseDao.listTable(CmnConst.PRODUCT_SYS_STAFF_PROPERTY_GROUP, dataFilter, null, null, null, pageSize, cpage),null);
|
}
|
|
/**
|
* 属性分组详情与属性列表
|
* @param uuid
|
* @return
|
* @throws BaseException
|
*/
|
public JSONObject findPropertyGroup(String uuid)throws BaseException{
|
FieldSetEntity fsePropertyGroup=baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_STAFF_PROPERTY_GROUP, uuid, false);
|
if (fsePropertyGroup==null) {
|
throw new BaseException(SystemCode.STSTEM_STAFFS_PROPERTY_GROUP_NO_EXIST.getValue(), SystemCode.STSTEM_STAFFS_PROPERTY_GROUP_NO_EXIST.getText(), this.getClass(), "findPropertyGroup");
|
}
|
FieldSetEntity fsePropertyGroupLanguage=baseDao.listInternationDataTable(fsePropertyGroup, null);
|
JSONObject as= BaseUtil.fieldSetEntityToJson(fsePropertyGroupLanguage);
|
StringBuilder sqlCommon=new StringBuilder();
|
|
sqlCommon.append(" SELECT ");
|
sqlCommon.append(" d.staff_property_group_value_id,d.uuid,d.staff_property_group_uuid,e.uuid staff_property_master_uuid,e.staff_property_master_code,d.value,d.effective_utc_datetime,d.org_level_uuid,d.remarks,e.uuid,e.staff_property_master_name,e.prompt_name,e.data_type ");
|
sqlCommon.append(" FROM ( ");
|
|
sqlCommon.append(" SELECT ");
|
sqlCommon.append(" a.staff_property_group_value_id,a.uuid,a.staff_property_group_uuid,a.staff_property_master_uuid,a.staff_property_master_code,a.value,a.effective_utc_datetime,a.org_level_uuid,a.remarks, ");
|
sqlCommon.append(" CASE WHEN LOCATE( '|', a.staff_property_master_code) THEN REVERSE(SUBSTR(REVERSE(a.staff_property_master_code) FROM INSTR(REVERSE( a.staff_property_master_code ), '|' ) + 1 )) END AS parent_code ");
|
sqlCommon.append(" FROM product_sys_staff_property_group_default_value AS a, ");
|
sqlCommon.append(" ( ");
|
sqlCommon.append(" SELECT ");
|
sqlCommon.append(" staff_property_master_uuid, ");
|
sqlCommon.append(" MAX(effective_utc_datetime) AS effective_utc_datetime ");
|
sqlCommon.append(" FROM product_sys_staff_property_group_default_value ");
|
sqlCommon.append(" WHERE effective_utc_datetime <= NOW() AND staff_property_group_uuid = ? ");
|
sqlCommon.append(" GROUP BY staff_property_master_uuid ");
|
sqlCommon.append(" ) AS c ");
|
sqlCommon.append(" WHERE a.staff_property_master_uuid = c.staff_property_master_uuid AND a.effective_utc_datetime = c.effective_utc_datetime AND a.staff_property_group_uuid = ? ");
|
|
sqlCommon.append(" UNION ALL ");
|
sqlCommon.append(" SELECT ");
|
sqlCommon.append(" a.staff_property_group_value_id,a.uuid,a.staff_property_group_uuid,a.staff_property_master_uuid,a.staff_property_master_code,'',a.effective_utc_datetime,a.org_level_uuid,a.remarks, ");
|
sqlCommon.append(" CASE WHEN LOCATE( '|', a.staff_property_master_code) THEN REVERSE(SUBSTR(REVERSE(a.staff_property_master_code) FROM INSTR(REVERSE( a.staff_property_master_code ), '|' ) + 1 )) END AS parent_code");
|
sqlCommon.append(" FROM product_sys_staff_property_group_default_value AS a, ");
|
sqlCommon.append(" ( ");
|
sqlCommon.append(" SELECT ");
|
sqlCommon.append(" staff_property_master_uuid, ");
|
sqlCommon.append(" MIN(effective_utc_datetime) AS effective_utc_datetime ");
|
sqlCommon.append(" FROM product_sys_staff_property_group_default_value ");
|
sqlCommon.append(" WHERE staff_property_group_uuid= ? ");
|
sqlCommon.append(" GROUP BY staff_property_master_uuid ");
|
sqlCommon.append(" HAVING MIN(effective_utc_datetime) > NOW() ");
|
sqlCommon.append(" ) AS c ");
|
sqlCommon.append(" WHERE a.staff_property_master_uuid = c.staff_property_master_uuid AND a.effective_utc_datetime = c.effective_utc_datetime AND a.staff_property_group_uuid = ? ");
|
|
sqlCommon.append(" UNION ALL ");
|
sqlCommon.append(" SELECT ");
|
sqlCommon.append(" a.staff_property_group_value_id,a.uuid,a.staff_property_group_uuid,a.staff_property_master_uuid,a.staff_property_master_code,'',a.effective_utc_datetime,a.org_level_uuid,a.remarks, ");
|
sqlCommon.append(" CASE WHEN LOCATE( '|', a.staff_property_master_code) THEN REVERSE(SUBSTR(REVERSE(a.staff_property_master_code) FROM INSTR(REVERSE( a.staff_property_master_code ), '|' ) + 1 )) END AS parent_code");
|
sqlCommon.append(" FROM product_sys_staff_property_group_default_value AS a, ");
|
sqlCommon.append(" ( ");
|
sqlCommon.append(" SELECT ");
|
sqlCommon.append(" staff_property_master_uuid, ");
|
sqlCommon.append(" staff_property_master_code ");
|
sqlCommon.append(" FROM product_sys_staff_property_group_default_value ");
|
sqlCommon.append(" WHERE staff_property_group_uuid= ? AND effective_utc_datetime IS NULL AND value IS NULL ");
|
sqlCommon.append(" ) AS c ");
|
sqlCommon.append(" WHERE a.staff_property_master_uuid = c.staff_property_master_uuid AND a.staff_property_group_uuid = ? ");
|
|
sqlCommon.append(" ) AS d ");
|
sqlCommon.append(" RIGHT JOIN product_sys_staff_property_master AS e ON d.staff_property_master_uuid = e.uuid AND d.staff_property_master_code=e.staff_property_master_code"); //杜洪波 updateTime 2020-01-06 11:40:00 属性显示异常
|
|
String sqlParent=sqlCommon+" WHERE d.parent_code IS NULL ORDER BY e.sequence";
|
String sqlSub=sqlCommon+" WHERE d.parent_code IS NOT NULL ORDER BY e.sequence";
|
|
|
//根属性
|
DataTableEntity dtParent=baseDao.listTable(sqlParent.toString(), new Object[] {uuid,uuid,uuid,uuid,uuid,uuid});
|
//子属性
|
DataTableEntity dtSub=baseDao.listTable(sqlSub.toString(), new Object[] {uuid,uuid,uuid,uuid,uuid,uuid});
|
|
baseDao.listInternationDataTable(dtParent, null);
|
baseDao.listInternationDataTable(dtSub, null);
|
|
if (dtParent.getRows()>0) {
|
//装载属性
|
JSONArray json=sysPropertyGroup(dtParent,dtSub,2);
|
as.put(CmnConst.PRODUCT_SYS_STAFF_PROPERTY_GROUP_DEFALUT_VALUE, json);
|
}
|
return as;
|
}
|
|
/**
|
* 属性详情
|
* @param group_uuid 分组uuid
|
* @param master_uuid 属性uuid
|
* @return
|
* @throws BaseException
|
*/
|
public DataTableEntity findProperty(String group_uuid,String master_uuid) throws BaseException {
|
StringBuilder sql=new StringBuilder();
|
sql.append(" SELECT ");
|
sql.append(" a.uuid, ");
|
sql.append(" a.staff_property_group_value_id,a.staff_property_group_uuid,a.staff_property_master_uuid,a.staff_property_master_code,a.value, ");
|
sql.append(" a.effective_utc_datetime,a.org_level_uuid,b.prompt_name,b.data_type ");
|
sql.append(" FROM product_sys_staff_property_group_default_value a ");
|
sql.append(" LEFT JOIN product_sys_staff_property_master b ");
|
sql.append(" ON a.staff_property_master_uuid=b.uuid AND a.staff_property_master_code=b.staff_property_master_code ");
|
sql.append(" WHERE a.staff_property_group_uuid=? and a.staff_property_master_uuid=? ");
|
return baseDao.listInternationDataTable(baseDao.listTable(sql.toString(), new Object[] {group_uuid,master_uuid}),null);
|
}
|
|
/**
|
* 新增属性分组
|
* @param fse 业务数据
|
* @return
|
* @throws BaseException
|
*/
|
@Transactional
|
public String addPropertyGroup(FieldSetEntity fse)throws BaseException{
|
return baseDao.add(fse);
|
}
|
|
/**
|
* 修改属性分组
|
* @param fse
|
* @return
|
* @throws BaseException
|
*/
|
@Transactional
|
public boolean updatePropertyGroup(FieldSetEntity fse)throws BaseException{
|
DataTableEntity dtDefaultProperty=fse.getSubDataTable(CmnConst.PRODUCT_SYS_STAFF_PROPERTY_GROUP_DEFALUT_VALUE);
|
if (dtDefaultProperty!=null && dtDefaultProperty.getRows()>0) {
|
int delCount=0;
|
int rowCount=dtDefaultProperty.getRows();
|
for (int i = 0; i < rowCount; i++) {
|
FieldSetEntity fseDefaultProperty=dtDefaultProperty.getFieldSetEntity(i);
|
String doMethod=fseDefaultProperty.getString("~type~");
|
if (doMethod!=null && "del".equals(doMethod)) {
|
delCount++;
|
}
|
}
|
if (delCount==rowCount) {
|
FieldSetEntity fseSaveDefaultProperty=dtDefaultProperty.getFieldSetEntity(0);
|
baseDao.executeUpdate("update product_sys_staff_property_group_default_value set effective_utc_datetime = NULL,value=NULL where uuid=?", new Object[] {fseSaveDefaultProperty.getUUID()});
|
dtDefaultProperty.removeFieldSetEntity(0);
|
}
|
if (dtDefaultProperty.getRows()==0) {
|
return true;
|
}else {
|
return baseDao.update(fse, true);
|
}
|
}else {
|
return baseDao.update(fse,true);
|
}
|
}
|
|
/**
|
* 删除属性分组
|
* @param uuid
|
* @return
|
* @throws BaseException
|
*/
|
@Transactional
|
public boolean deletePropertyGroup(String uuid)throws BaseException{
|
return baseDao.delete(CmnConst.PRODUCT_SYS_STAFF_PROPERTY_GROUP, "uuid=?", new String[] {uuid});
|
}
|
|
/**
|
* 系统分组属性封装
|
* @param dataParent 根属性
|
* @param dataSub 子属性
|
* @param type 封装类型 1.从master表获取 2.从业务表获取
|
* @return
|
* @throws BaseException
|
*/
|
public JSONArray sysPropertyGroup(DataTableEntity dataParent,DataTableEntity dataSub,int type) throws BaseException {
|
JSONArray propertyArray=new JSONArray();
|
//遍历根属性
|
for (int i = 0; i < dataParent.getRows(); i++) {
|
JSONObject sysProperty=new JSONObject();
|
FieldSetEntity fs=dataParent.getFieldSetEntity(i);
|
if (!StringUtils.isEmpty(fs.getString(CmnConst.STAFF_PROPERTY_MASTER_CODE))) { //杜洪波 updateTime 2020-12-17 15:16:00
|
if (type==1) {
|
sysProperty.put(CmnConst.STAFF_PROPERTY_MASTER_UUID, dataParent.getString(i, "uuid")); //uuid
|
}else {
|
sysProperty.put(CmnConst.VALUE, dataParent.getString(i, CmnConst.VALUE)); //默认值
|
sysProperty.put(CmnConst.STAFF_PROPERTY_MASTER_UUID, dataParent.getString(i, CmnConst.STAFF_PROPERTY_MASTER_UUID)); //uuid
|
}
|
sysProperty.put(CmnConst.DATA_TYPE, dataParent.getString(i, CmnConst.DATA_TYPE)); //数据类型
|
sysProperty.put(CmnConst.STAFF_PROPERTY_MASTER_CODE, dataParent.getString(i, CmnConst.STAFF_PROPERTY_MASTER_CODE)); //编码code
|
sysProperty.put(CmnConst.PARENT_CODE, dataParent.getString(i, CmnConst.PARENT_CODE)); //父级编码code
|
sysProperty.put(CmnConst.PROMPT_NAME, dataParent.getString(i, CmnConst.PROMPT_NAME)); //参照名
|
sysProperty.put(CmnConst.STAFF_PROPERTY_MASTER_NAME, getPropertyNameLanguage(fs.getSubDataTable(CmnConst.STAFF_PROPERTY_MASTER_NAME))); //属性名称
|
//获取当前根属性的子属性
|
if (dataSub!=null && dataSub.getRows()>0) {
|
JSONArray moduleChild = sysPropertyGroupSub(dataSub,fs.getString(CmnConst.STAFF_PROPERTY_MASTER_CODE),type);
|
sysProperty.put("children", moduleChild);
|
}
|
propertyArray.add(sysProperty);
|
}
|
}
|
return propertyArray;
|
}
|
|
/**
|
* 系统属性分组子属性封装
|
* @param data
|
* @param tricode_parent 父级属性节点编码
|
* @param type 封装类型
|
* @return
|
* @throws BaseException
|
*/
|
public JSONArray sysPropertyGroupSub(DataTableEntity dataSub,String tricode_parent,int type) throws BaseException {
|
JSONArray propertyArray=new JSONArray();
|
//遍历子属性
|
for (int i = 0; i < dataSub.getRows(); i++) {
|
|
JSONObject sysProperty=new JSONObject();
|
FieldSetEntity fs=dataSub.getFieldSetEntity(i);
|
//匹配子属性
|
if(tricode_parent.equals(dataSub.getString(i, CmnConst.PARENT_CODE))) {
|
//装载属性
|
if (type==1) {
|
sysProperty.put(CmnConst.STAFF_PROPERTY_MASTER_UUID, dataSub.getString(i, "uuid")); //uuid
|
|
}else {
|
sysProperty.put(CmnConst.VALUE, dataSub.getString(i, CmnConst.VALUE));
|
sysProperty.put(CmnConst.STAFF_PROPERTY_MASTER_UUID, dataSub.getString(i, CmnConst.STAFF_PROPERTY_MASTER_UUID)); //uuid
|
}
|
sysProperty.put(CmnConst.DATA_TYPE, dataSub.getString(i, CmnConst.DATA_TYPE)); //数据类型
|
sysProperty.put(CmnConst.STAFF_PROPERTY_MASTER_CODE, dataSub.getString(i, CmnConst.STAFF_PROPERTY_MASTER_CODE)); //属性编码
|
sysProperty.put(CmnConst.PARENT_CODE, dataSub.getString(i, CmnConst.PARENT_CODE)); //父级属性编码
|
sysProperty.put(CmnConst.PROMPT_NAME, dataSub.getString(i, CmnConst.PROMPT_NAME)); //参照名
|
sysProperty.put(CmnConst.STAFF_PROPERTY_MASTER_NAME, getPropertyNameLanguage(fs.getSubDataTable(CmnConst.STAFF_PROPERTY_MASTER_NAME))); //属性名称
|
//封装后代属性
|
JSONArray jsonSub=sysPropertyGroupSub(dataSub, dataSub.getString(i, CmnConst.STAFF_PROPERTY_MASTER_CODE),type);
|
|
if (!jsonSub.isEmpty()) {
|
sysProperty.put("children", jsonSub);
|
}
|
propertyArray.add(sysProperty);
|
}
|
}
|
return propertyArray;
|
}
|
|
/**
|
* 新增属性组,获取所有系统属性
|
* @return
|
* @throws BaseException
|
*/
|
public JSONArray getAllSysProperty() throws BaseException {
|
|
StringBuilder sqlCommon=new StringBuilder();
|
sqlCommon.append(" SELECT uuid,staff_property_master_code,staff_property_master_name,prompt_name,data_type,parent_code FROM ( ");
|
sqlCommon.append(" SELECT ");
|
sqlCommon.append(" a.*, ");
|
sqlCommon.append(" CASE WHEN LOCATE( '|', a.staff_property_master_code ) THEN REVERSE( SUBSTR( REVERSE( a.staff_property_master_code )FROM INSTR( REVERSE( a.staff_property_master_code ), '|' ) + 1 ) ) END AS parent_code ");
|
sqlCommon.append(" FROM (SELECT * FROM product_sys_staff_property_master)a ");
|
sqlCommon.append(" )b ");
|
|
//第一层系统属性
|
String sqlParent =sqlCommon.toString() + " where b.parent_code is NULL ";
|
//后代系统属性
|
String sqlSub=sqlCommon.toString() + " where b.parent_code is not NULL ";
|
|
DataTableEntity dtParentProperty=baseDao.listTable(sqlParent, new Object[] {});
|
DataTableEntity dtSubProperty=baseDao.listTable(sqlSub, new Object[] {});
|
|
baseDao.listInternationDataTable(dtParentProperty, null);
|
baseDao.listInternationDataTable(dtSubProperty, null);
|
|
JSONArray json=null;
|
if (dtParentProperty.getRows()>0) {
|
//装载属性
|
json=sysPropertyGroup(dtParentProperty,dtSubProperty,1);
|
}
|
|
return json;
|
}
|
|
/**
|
* 封装系统属性名称国际化
|
* @return
|
* @throws BaseException
|
*/
|
public List<JSONObject> getPropertyNameLanguage(DataTableEntity dtPropertyLanguage) throws BaseException {
|
|
List<JSONObject>listPropertyName=new ArrayList<JSONObject>();
|
|
if (dtPropertyLanguage!=null && dtPropertyLanguage.getRows()>0) {
|
|
//遍历获取语言代码和国际化值
|
FieldMetaEntity meta = dtPropertyLanguage.getMeta();
|
Object[] fields12 = meta.getFields();
|
List<Object> asList =new ArrayList<>();
|
asList.addAll(Arrays.asList(fields12));
|
Iterator<Object> iterator = asList.iterator();
|
for (int i = 0; i < dtPropertyLanguage.getRows(); i++) {
|
while (iterator.hasNext()) {
|
Object next = iterator.next();
|
if(!next.toString().equals("uuid") &&!next.toString().equals("language_code")) {
|
String string = dtPropertyLanguage.getString(i, next.toString());
|
if(!StringUtils.isEmpty(string)) {
|
JSONObject propertyName=new JSONObject();
|
propertyName.put(next.toString(), string);
|
listPropertyName.add(propertyName);
|
iterator.remove();
|
break;
|
}
|
}else {
|
iterator.remove();
|
}
|
}
|
}
|
|
}
|
return listPropertyName;
|
}
|
}
|
