package com.product.org.admin.service;
|
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import com.product.org.admin.config.CmnConst;
|
import com.product.org.admin.config.SystemCode;
|
import com.product.org.admin.service.idel.IStaffRegularEmployeeService;
|
import com.product.util.BaseUtil;
|
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.permission.PermissionService;
|
import com.product.core.service.support.AbstractBaseService;
|
import com.product.core.service.support.QueryFilterService;
|
import com.product.core.transfer.Transactional;
|
|
/**
|
*
|
* Copyright LX-BASE
|
* @Title: LX-BASE-
|
* @Project: StaffChangeService
|
* @Date: 2020-06-09 15:27
|
* @Author: 杜洪波
|
* @Description:人员转正
|
*/
|
@Component
|
public class StaffRegularEmployeeService extends AbstractBaseService implements IStaffRegularEmployeeService{
|
|
@Autowired
|
public BaseDao baseDao;
|
@Autowired
|
PermissionService permissionService;
|
@Autowired
|
QueryFilterService queryFilterService;
|
|
/**
|
* 人员转正信息列表
|
* @param cpage
|
* @param pageSize
|
* @return
|
* @throws BaseException
|
*/
|
public DataTableEntity listStaffRegularEmployee(Integer cpage,Integer pageSize, FieldSetEntity fse) throws BaseException {
|
//数据策略
|
String dataFilter=permissionService.getDataFilter("b."+CmnConst.ORG_LEVEL_UUID) ;
|
//高级查询
|
String searchFilter=queryFilterService.getQueryFilter(fse);
|
if(!StringUtils.isEmpty(dataFilter)) {
|
dataFilter=" WHERE "+dataFilter;
|
if (!StringUtils.isEmpty(searchFilter)) {
|
dataFilter+=" AND "+ searchFilter;
|
}
|
}else {
|
if (!StringUtils.isEmpty(searchFilter)) {
|
dataFilter=searchFilter;
|
}
|
}
|
|
StringBuilder sql=new StringBuilder();
|
sql.append(" SELECT * FROM ( ");
|
sql.append(" SELECT a.uuid uuid,b.uuid uuid1,c.uuid uuid2,d.uuid uuid3,e.uuid uuid4,f.uuid uuid5,a.staff_uuid,a.employment_date,a.probation_end_date,a.result_status,b.show_name,b.preferred_name,c.client_name,d.org_level_all,e.job_post_name,f.job_grade_name ");
|
sql.append(" FROM product_sys_staff_complete_probation a ");
|
sql.append(" LEFT JOIN product_sys_staffs b ON a.staff_uuid=b.uuid ");
|
sql.append(" LEFT JOIN product_sys_clients c ON c.uuid=b.client_uuid ");
|
sql.append(" LEFT JOIN product_sys_org_levels d ON d.uuid=b.dept_uuid ");
|
sql.append(" LEFT JOIN product_sys_job_posts e ON e.uuid=b.job_post_uuid ");
|
sql.append(" LEFT JOIN product_sys_job_post_grades f ON f.uuid=b.job_post_grade_uuid ");
|
sql.append(dataFilter);
|
sql.append(" )b ");
|
|
DataTableEntity dt=baseDao.listTable(sql.toString(), null, pageSize, cpage);
|
dt.getMeta().addAliasTable("product_sys_staff_complete_probation","a");
|
dt.getMeta().addAliasTable("product_sys_staffs","b");
|
dt.getMeta().addAliasTable("product_sys_clients","c");
|
dt.getMeta().addAliasTable("product_sys_org_levels","d");
|
dt.getMeta().addAliasTable("product_sys_job_posts","e");
|
dt.getMeta().addAliasTable("product_sys_job_post_grades","f");
|
|
if (!BaseUtil.dataTableIsEmpty(dt)) {
|
baseDao.loadPromptData(dt);
|
baseDao.listInternationDataTable(dt, null);
|
}
|
|
return dt;
|
}
|
|
/**
|
* 人员变更信息详情
|
* @param uuid
|
* @return
|
* @throws BaseException
|
*/
|
public FieldSetEntity findStaffRegularEmployee(String uuid) throws BaseException {
|
String sql=" SELECT a.uuid,a.staff_uuid,a.remarks,a.result_status,a.probation_end_date,b.uuid,b.show_name,b.entry_datetime employment_date FROM product_sys_staff_complete_probation a LEFT JOIN product_sys_staffs b ON a.staff_uuid=b.uuid WHERE a.uuid=?";
|
DataTableEntity dtInfo=baseDao.listTable(sql, new String[] {uuid});
|
return baseDao.listInternationDataTable(dtInfo.getFieldSetEntity(0), null);
|
}
|
|
/**
|
* 新增转正信息
|
* @param fs
|
* @return
|
* @throws BaseException
|
*/
|
@Transactional
|
public String addRegularEmployee(FieldSetEntity fse) throws BaseException {
|
String staff_uuid=fse.getString(CmnConst.STAFF_UUID);
|
FieldSetEntity fseStaff=baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_STAFFS, staff_uuid, false);
|
fse.setValue(CmnConst.ORG_LEVEL_UUID, fseStaff.getString(CmnConst.ORG_LEVEL_UUID));
|
fse.setValue(CmnConst.RESULT_STATUS, 0);
|
String uuid= baseDao.add(fse);
|
/*
|
if(uuid !=null ) {
|
//查询对应员工信息
|
FieldSetEntity sfs =baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_STAFFS, fse.getString(CmnConst.STAFF_UUID), false);
|
if(sfs !=null ) {
|
//变更状态为"准备转正"
|
String sql="update product_sys_staffs set staff_status=? where uuid=?";
|
baseDao.executeUpdate(sql, new Object[] {2,fse.getString(CmnConst.STAFF_UUID)});
|
}
|
}
|
*/
|
return uuid;
|
}
|
|
/**
|
* 修改转正信息
|
* @param fse
|
* @return
|
* @throws BaseException
|
*/
|
public boolean updateRegularEmployee(FieldSetEntity fse) throws BaseException {
|
if(fse.getInteger("result_status")==1) {
|
throw new BaseException(SystemCode.SYSTEM_STAFF_REGULAR_EMPLOYEE_UPDATE_FAIL_CHANGED.getValue(),SystemCode.SYSTEM_STAFF_REGULAR_EMPLOYEE_UPDATE_FAIL_CHANGED.getText(),this.getClass(),"updateRegularEmployee");
|
}
|
return baseDao.update(fse);
|
}
|
|
/**
|
* 删除转正信息
|
* @param uuid
|
* @return
|
* @throws BaseException
|
*/
|
@Transactional
|
public boolean deleteRegularEmployee(String uuid) throws BaseException {
|
boolean flag=true;
|
FieldSetEntity fseRegularInfo =baseDao.getFieldSetEntity("product_sys_staff_complete_probation", uuid, false);
|
if(fseRegularInfo !=null) {
|
if(fseRegularInfo.getInteger("result_status")==1) {
|
throw new BaseException(SystemCode.SYSTEM_STAFF_REGULAR_EMPLOYEE_DELETE_FAIL_CHANGED.getValue(),SystemCode.SYSTEM_STAFF_REGULAR_EMPLOYEE_DELETE_FAIL_CHANGED.getText(),this.getClass(),"deleteRegularEmployee");
|
}
|
/*
|
FieldSetEntity fseStaffInfo =baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_STAFFS, fseRegularInfo.getString(CmnConst.STAFF_UUID), false);
|
if(fseStaffInfo !=null ) {//改回
|
//变更状态为"试用"
|
String sql="update product_sys_staffs set staff_status=? where uuid=?";
|
baseDao.executeUpdate(sql, new Object[] {1,fseRegularInfo.getString(CmnConst.STAFF_UUID)});
|
}
|
*/
|
}
|
flag=baseDao.delete(CmnConst.PRODUCT_SYS_STAFF_COMPLETE_PROBATION, new String[] {uuid});
|
return flag;
|
}
|
|
}
|
