ziguang/websrc/com/kingdee/shr/customer/synosf/GetAllSubAccountDataService.java

package com.kingdee.shr.customer.synosf;

import com.kingdee.bos.BOSException;
import com.kingdee.bos.Context;
import com.kingdee.bos.bsf.service.app.IHRMsfService;
import com.kingdee.bos.dao.ormapping.ObjectUuidPK;
import com.kingdee.eas.base.permission.PermItemFactory;
import com.kingdee.eas.base.permission.PermItemInfo;
import com.kingdee.eas.base.permission.UserFactory;
import com.kingdee.eas.base.permission.UserInfo;
import com.kingdee.eas.common.EASBizException;
import com.kingdee.eas.hr.emp.EmployeeInterfacePermBizException;
import com.kingdee.eas.util.app.ContextUtil;
import com.kingdee.eas.util.app.DbUtil;
import com.kingdee.jdbc.rowset.IRowSet;
import com.kingdee.shr.base.permission.api.service.SHRFunctionPermissionService;
import com.kingdee.shr.integration.oa.util.IntegrateOAUtil;
import com.kingdee.shr.integration.oa.util.MappingFieldInfo;
import com.kingdee.util.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.text.SimpleDateFormat;
import java.util.*;


/**
 * 获取子账号数据		
 * @author coyle
 * 202601
 */
public class GetAllSubAccountDataService implements IHRMsfService {
	private static final Logger logger = LoggerFactory.getLogger(GetAllSubAccountDataService.class);

	public Object process(Context ctx, Map param) throws EASBizException, BOSException {
		Object obj = param.get("filterType");
		String type = null;
		if (obj != null) {
			type = String.valueOf(obj);
		}

		logger.error("InteOAGetPersonDataService enter and filterType = " + (obj == null ? "" : obj.toString()));
		String personPermItem = "fffffff0-ffff-efff-e22e-0000000dfa25PERMITEM";
		PermItemInfo permItem = PermItemFactory.getLocalInstance(ctx).getPermItemInfo(new ObjectUuidPK(personPermItem));

		try {
			SHRFunctionPermissionService.checkCurrnetUserFunctionPermission(ctx, permItem);
		} catch (Exception var12) {
			logger.error(var12.getMessage(), var12);
			String userId = ContextUtil.getCurrentUserInfo(ctx).getId().toString();
			UserInfo userInfo = UserFactory.getLocalInstance(ctx).getUserInfo(new ObjectUuidPK(userId));
			throw new EmployeeInterfacePermBizException(EmployeeInterfacePermBizException.NO_FUNCTION_PERMISSION,
					new Object[]{userInfo.getName(), permItem.getAlias()});
		}

		List<MappingFieldInfo> fieldList = this.initMappingField();
		StringBuffer sql = IntegrateOAUtil.getSelectFieldSql(fieldList);
		sql.append(" from t_bd_person person");
		sql.append(" left join t_pm_user puser on person.fid=puser.FPersonID   AND  puser.FISDELETE = '0' AND puser.FForbidden = '0'  ");
		sql.append(" left join CT_MP_SubAccount  subAcc  on person.fid=subAcc.FPersonID");
		//子账号所属公司
		sql.append(" left join T_ORG_Admin  subCom  on subAcc.cfsubcompanyId = subCom.FID");
		sql.append(" left join T_ORG_Admin  subDept  on subAcc.cfDepartmentIdId = subDept.FID");
		sql.append(" left join T_ORG_Position  subPosi  on subAcc.cfPositionNameId = subPosi.FID");
		//
		sql.append(" left join T_HR_PersonPosition pp on pp.fpersonId=person.fid");
		sql.append(" left join T_HR_EmpLaborRelation laber on laber.fpersonId=person.fid");
//		sql.append(" left join T_HR_PersonOtherInfo pother on pother.fpersonId=person.fid");
		sql.append(" left join T_ORG_Admin org on pp.FPersonDep=org.fid");
		sql.append(" left join T_HR_BDEmployeeType empType on empType.fid=person.FEmployeeTypeID");
		sql.append(" left join T_BD_HRFolk folk on person.FFolkID=folk.fid");
		sql.append(" left join T_BD_Nationality nation on person.FNationalityID=nation.fid");
		sql.append(" left join T_ORG_Admin comp  on pp.FCompanyID  =comp.fid");
		sql.append(" left join T_ORG_Position position  on pp.FPrimaryPositionID  =position.fid");
//		sql.append(" left join T_HR_EmpLaborRelation  elr  on  person.fid = elr.fpersonid  ");

		sql.append(" left join T_HR_BDEmployeeType  etype  on  laber.FLABORRELATIONSTATEID = etype.fid  ");
		sql.append(" left join T_HR_EmpPostRank epr on   person.FID = epr.FPersonID  and  epr. FIsLatest =  1  ");
		sql.append(" left join T_HR_JobGrade  jobGrade  on   epr.FJobGradeID = jobGrade.fid  ");
		sql.append(" left join CT_MP_WorkCity  city  on  person.cfworkcityid  = city.fid  ");
		//直接上级
		sql.append(" left join  T_ORG_Position  parentPosi  on  position.FPARENTID  = parentPosi.fid ");
		sql.append(" left join  T_HR_PersonPosition superiorpp  on parentPosi.FID= superiorpp.FPRIMARYPOSITIONID  ");
		sql.append(" left join  T_BD_Person    superiorp  on superiorpp.fpersonid = superiorp.fid   ");
		sql.append(" left join  t_pm_user superioru on superiorp.fid = superioru.FPersonID   AND  superioru.FISDELETE = '0' AND superioru.FForbidden = '0' ");

		sql.append(" left join (select min(u1.fcreatetime) fcreatetime ,u1.fpersonid fpersonid from t_pm_user u1  group by fpersonid) userEarly on userEarly.fpersonid=person.fid and userEarly.fcreatetime=puser.fcreatetime ");
		if (!StringUtils.isEmpty(type) ) {
			if(!"1".equals(type)){
				sql.append(" where empType.fuserstate = 2");
			}else {
				sql.append(" where empType.fuserstate = 1");
			}
		}

		String updateDate = this.increDateParam(param);
		if (!StringUtils.isEmpty(updateDate)) {
			sql.append(" and person.FLastUpdateTime>= " + updateDate);
		}

		sql.append(" and org.FIsStartSHR=1");
		sql.append(" order by  person.fnumber ");
		IRowSet rs = DbUtil.executeQuery(ctx, sql.toString());
		List<HashMap<String, String>> dataList = IntegrateOAUtil.getRsListData(fieldList, rs);
		return dataList;
	}

	private List<MappingFieldInfo> initMappingField() {
		List<MappingFieldInfo> list = new ArrayList();
		MappingFieldInfo fieldInfo = new MappingFieldInfo();

		//lastname	姓名
		fieldInfo.setOaField("lastname");
		fieldInfo.setShrField("person.fname_l2");
		list.add(fieldInfo);
		//workcode	人员编码（工号）
		fieldInfo = new MappingFieldInfo();
		fieldInfo.setOaField("workcode");
		fieldInfo.setShrField("person.fnumber");
		list.add(fieldInfo);
		//mainAccount	主账号
		fieldInfo = new MappingFieldInfo();
		fieldInfo.setOaField("mainAccount");
		fieldInfo.setShrField("puser.FNumber");
		list.add(fieldInfo);
		//subAccount	子账号
		fieldInfo = new MappingFieldInfo();
		fieldInfo.setOaField("subAccount");
		fieldInfo.setShrField("subAcc.CFSUBACCOUNT");
		list.add(fieldInfo);
		//subAccount	子账号Id
		fieldInfo = new MappingFieldInfo();
		fieldInfo.setOaField("subAccId");
		fieldInfo.setShrField("subAcc.FID");
		list.add(fieldInfo);
		//sex	性别
		fieldInfo = new MappingFieldInfo();
		fieldInfo.setOaField("sex");
		fieldInfo.setShrField("CASE person.FGender  WHEN  '1'  THEN '男'  WHEN  '2' THEN '女'  ELSE  NULL  END  ");
		list.add(fieldInfo);
		//subcompany	兼岗分部编码
		fieldInfo = new MappingFieldInfo();
		fieldInfo.setOaField("subcompany");
		fieldInfo.setShrField("subCom.fnumber");
		list.add(fieldInfo);
		//departmentid	兼岗部门编码
		fieldInfo = new MappingFieldInfo();
		fieldInfo.setOaField("departmentid");
		fieldInfo.setShrField("subDept.Fnumber");
		list.add(fieldInfo);
		//positionName	兼岗职位名称  CFPOSITIONNAME
		fieldInfo = new MappingFieldInfo();
		fieldInfo.setOaField("positionName");
		fieldInfo.setShrField("subPosi.Fname_l2");
		list.add(fieldInfo);
		//joblevel	职级名称	字符	　20	是	T6.2  按照职务体系设置 FJobLevelID
		fieldInfo = new MappingFieldInfo();
		fieldInfo.setOaField("joblevel");
		fieldInfo.setShrField("jobGrade.fname_l2");
		list.add(fieldInfo);
		//managerid	直接上级账号	字符	　60  superiorp
		fieldInfo = new MappingFieldInfo();
		fieldInfo.setOaField("managerid");
		fieldInfo.setShrField("superioru.fnumber");
		list.add(fieldInfo);

		//status	状态（在职、试用、离职）
		fieldInfo = new MappingFieldInfo();
		fieldInfo.setOaField("status");
		fieldInfo.setShrField(" CASE  etype.cfOaState  WHEN  'PROBATION'  THEN '试用' WHEN 'ON_THE_JOB' THEN '在职' WHEN 'RESIGNED'  THEN '离职'   ELSE NULL  end  ");
		list.add(fieldInfo);
		//telephone	办公电话
		fieldInfo = new MappingFieldInfo();
		fieldInfo.setOaField("telephone");
		fieldInfo.setShrField("person.FOfficePhone");
		list.add(fieldInfo);
		//mobile	移动电话
		fieldInfo = new MappingFieldInfo();
		fieldInfo.setOaField("mobile");
		fieldInfo.setShrField("person.FCell");
		list.add(fieldInfo);
		//mobilecall	其他电话
		fieldInfo = new MappingFieldInfo();
		fieldInfo.setOaField("mobilecall");
		fieldInfo.setShrField("person.FHomePhone");
		list.add(fieldInfo);
		//fax	传真
		fieldInfo = new MappingFieldInfo();
		fieldInfo.setOaField("fax");
		fieldInfo.setShrField("''");
		list.add(fieldInfo);
		//email	邮箱
		fieldInfo = new MappingFieldInfo();
		fieldInfo.setOaField("email");
		fieldInfo.setShrField("person.FEMail");
		list.add(fieldInfo);
		//birthday	出生日期
		fieldInfo = new MappingFieldInfo();
		fieldInfo.setOaField("birthday");
		fieldInfo.setShrField("TO_CHAR(person.FBirthday, 'YYYY-MM-DD')");
		list.add(fieldInfo);
		//certificatenum	身份证号码
		fieldInfo = new MappingFieldInfo();
		fieldInfo.setOaField("certificatenum");
		fieldInfo.setShrField("person.FIDCardNO");
		list.add(fieldInfo);
		//passport	护照号	字符	50	是
		fieldInfo = new MappingFieldInfo();
		fieldInfo.setOaField("passport");
		fieldInfo.setShrField("person.FPassportNO");
		list.add(fieldInfo);
		//hiredate	入职日期
		fieldInfo = new MappingFieldInfo();
		fieldInfo.setOaField("hiredate");
//		fieldInfo.setShrField("laber.FEnterDate");
		fieldInfo.setShrField("TO_CHAR(laber.FEnterDate, 'YYYY-MM-DD')");
		list.add(fieldInfo);
		//probationenddate	实际转正日期	字符	10	是
		fieldInfo = new MappingFieldInfo();
		fieldInfo.setOaField("probationenddate");
//		fieldInfo.setShrField("pp.FFORMALDATE"); //原转正日期
		fieldInfo.setShrField("TO_CHAR(laber.FACTUALFORMALDATE, 'YYYY-MM-DD')");
		list.add(fieldInfo);
		//workCityCode	工作城市编码
		fieldInfo = new MappingFieldInfo();
		fieldInfo.setOaField("workCityCode");
		fieldInfo.setShrField("city.fnumber");
		list.add(fieldInfo);
		//isDisabled	是否禁用
		fieldInfo = new MappingFieldInfo();
		fieldInfo.setOaField("isDisabled");
		fieldInfo.setShrField("subAcc.CFISDISABLED");
		list.add(fieldInfo);

		return list;
	}

	private String increDateParam(Map param) throws BOSException {
		String daysAgoStr = (String) param.get("daysAgo");
		if (!StringUtils.isEmpty(daysAgoStr)) {
			Integer daysAgo = 0;

			try {
				daysAgo = Integer.parseInt(daysAgoStr);
			} catch (NumberFormatException var5) {
				var5.printStackTrace();
				throw new BOSException("daysAgo must is an integer");
			}

			if (daysAgo >= 0 && daysAgo <= 30) {
				Calendar calendar = Calendar.getInstance();
				calendar.add(5, -daysAgo);
				calendar.set(11, 0);
				calendar.set(12, 0);
				calendar.set(13, 0);
				return "{ts'" + (new SimpleDateFormat("yyyy-MM-dd")).format(calendar.getTime()) + "'}";
			} else {
				throw new BOSException("daysAgo is an integer where 0 <= daysAgo <= 30");
			}
		} else {
			return null;
		}
	}
}