|
|
@@ -1,6 +1,7 @@
|
|
|
package com.kingdee.eas.custom.server;
|
|
|
|
|
|
import java.math.BigDecimal;
|
|
|
+import java.math.RoundingMode;
|
|
|
import java.security.SecureRandom;
|
|
|
import java.sql.SQLException;
|
|
|
import java.sql.Timestamp;
|
|
|
@@ -21,9 +22,30 @@ import javax.crypto.spec.SecretKeySpec;
|
|
|
import com.kingdee.bos.BOSException;
|
|
|
import com.kingdee.bos.Context;
|
|
|
import com.kingdee.bos.bsf.service.app.IHRMsfService;
|
|
|
+import com.kingdee.bos.dao.IObjectPK;
|
|
|
+import com.kingdee.bos.util.BOSUuid;
|
|
|
import com.kingdee.eas.base.permission.UserInfo;
|
|
|
+import com.kingdee.eas.basedata.person.PersonCollection;
|
|
|
+import com.kingdee.eas.basedata.person.PersonFactory;
|
|
|
+import com.kingdee.eas.basedata.person.PersonInfo;
|
|
|
import com.kingdee.eas.common.EASBizException;
|
|
|
+import com.kingdee.eas.framework.CoreBaseCollection;
|
|
|
+import com.kingdee.eas.framework.LineResult;
|
|
|
+import com.kingdee.eas.framework.Result;
|
|
|
+import com.kingdee.eas.hr.base.HRBillStateEnum;
|
|
|
+import com.kingdee.eas.hr.project.IWorkHoursConfirm;
|
|
|
+import com.kingdee.eas.hr.project.IWorkHoursReport;
|
|
|
+import com.kingdee.eas.hr.project.ProjectManagementInfo;
|
|
|
+import com.kingdee.eas.hr.project.WorkHoursConfirmCollection;
|
|
|
+import com.kingdee.eas.hr.project.WorkHoursConfirmFactory;
|
|
|
+import com.kingdee.eas.hr.project.WorkHoursConfirmInfo;
|
|
|
+import com.kingdee.eas.hr.project.WorkHoursReportEntryInfo;
|
|
|
+import com.kingdee.eas.hr.project.WorkHoursReportFactory;
|
|
|
+import com.kingdee.eas.hr.project.WorkHoursReportInfo;
|
|
|
+import com.kingdee.eas.hr.project.dataSource;
|
|
|
import com.kingdee.eas.util.app.ContextUtil;
|
|
|
+import com.kingdee.eas.util.app.DbUtil;
|
|
|
+import com.kingdee.jdbc.rowset.IRowSet;
|
|
|
import com.kingdee.shr.empresume.util.ErrorCodeUtil;
|
|
|
|
|
|
public class MyShrMobileNewService implements IHRMsfService{
|
|
|
@@ -70,4 +92,546 @@ public class MyShrMobileNewService implements IHRMsfService{
|
|
|
keyGenerator.init(KEY_SIZE, new SecureRandom(password.getBytes()));
|
|
|
return new SecretKeySpec(keyGenerator.generateKey().getEncoded(), ALGORITHM);
|
|
|
}
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 生成打卡确认单
|
|
|
+ */
|
|
|
+ private void _initWorkHoursConfirm(Context ctx, String number, String star, String end, int day)
|
|
|
+ throws BOSException, EASBizException {
|
|
|
+ IRowSet rs = null;
|
|
|
+ List<String> keyList = new ArrayList<String>();
|
|
|
+ IWorkHoursConfirm biz = WorkHoursConfirmFactory.getLocalInstance(ctx);
|
|
|
+
|
|
|
+ WorkHoursConfirmInfo wInfo = null;
|
|
|
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
|
|
+ List<WorkHoursConfirmInfo> listInfo = null;
|
|
|
+ List<String> listproid = new ArrayList<String>();
|
|
|
+ Map<String,String> mapdate = new HashMap<String,String>();
|
|
|
+ Map<String,String> mapproid = new HashMap<String,String>();
|
|
|
+ //存放打卡数据 map
|
|
|
+ Map<String,List<WorkHoursConfirmInfo>> mapInfo = new HashMap<String,List<WorkHoursConfirmInfo>>();
|
|
|
+ StringBuffer sb = new StringBuffer("/*dialect*/");
|
|
|
+ if(day <= 0) {
|
|
|
+ //默认3天
|
|
|
+ day = 3;
|
|
|
+ }
|
|
|
+
|
|
|
+ sb = new StringBuffer("/*dialect*/");
|
|
|
+ sb.append(" select t3.fid pid,t3en.FNAME_L2 CFCLOCKLOCATION from T_HR_ATS_PunchCardRecord t ").append(" \n");
|
|
|
+ sb.append(" inner join T_BD_Person t1 on t1.fid = t.FPROPOSERID ").append(" \n");
|
|
|
+ sb.append(" inner join CT_PRO_MemberManagement t2 on t2.CFEmployeeID = t1.fid ").append(" \n");
|
|
|
+ sb.append(" inner join CT_PRO_ProjectManagement t3 on t3.fid = t2.CFProjectManagemenID ").append(" \n");
|
|
|
+ sb.append(" left join CT_PRO_ProjectClock t3en on t3en.CFPROJECTID = t3.fid and t3en.CFSTATE = '1' ").append(" \n");
|
|
|
+ sb.append(" where t3.CFExpectedStartTime <FPUNCHCARDTIME and t3.CFExpectedEndTime >= FPUNCHCARDTIME ").append(" \n");
|
|
|
+ //按照时间过滤
|
|
|
+ if(star != null && star.length() > 0) {
|
|
|
+ sb.append(" and t.FPUNCHCARDTIME >= TO_DATE('"+star+"', 'YYYY-MM-DD HH24:MI:SS')").append(" \n");
|
|
|
+ }else if(end != null && end.length() > 0) {
|
|
|
+ sb.append(" and t.FPUNCHCARDTIME <= TO_DATE('"+end+"', 'YYYY-MM-DD HH24:MI:SS')").append(" \n");
|
|
|
+ }else {
|
|
|
+ sb.append(" and t.FPUNCHCARDTIME >= sysdate -"+day).append(" \n");
|
|
|
+ }
|
|
|
+ if(number !=null && number.length() > 0) {
|
|
|
+ sb.append(" and t1.fnumber in (").append(number).append(") \n");
|
|
|
+ }
|
|
|
+ //获取打卡数据
|
|
|
+ rs = DbUtil.executeQuery(ctx, sb.toString());
|
|
|
+
|
|
|
+ try {
|
|
|
+ Map<String,List<String>> proCFCLOCKLOCATION = new HashMap<String,List<String>>();
|
|
|
+ List<String> CFCLOCKLOCATIONList = new ArrayList<String>();
|
|
|
+ if(rs != null && rs.size() > 0) {
|
|
|
+ while (rs.next()) {
|
|
|
+ String proid = rs.getString("pid");
|
|
|
+ String CFCLOCKLOCATION = rs.getString("CFCLOCKLOCATION");
|
|
|
+ if(CFCLOCKLOCATION != null && CFCLOCKLOCATION.length() > 0) {
|
|
|
+ if(proCFCLOCKLOCATION.containsKey(proid)) {
|
|
|
+ CFCLOCKLOCATIONList = proCFCLOCKLOCATION.get(proid);
|
|
|
+ }else {
|
|
|
+ CFCLOCKLOCATIONList = new ArrayList<String>();
|
|
|
+ }
|
|
|
+ if(!CFCLOCKLOCATIONList.contains(CFCLOCKLOCATION)) {
|
|
|
+ CFCLOCKLOCATIONList.add(CFCLOCKLOCATION);
|
|
|
+ }
|
|
|
+ proCFCLOCKLOCATION.put(proid, CFCLOCKLOCATIONList);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ System.out.println("proCFCLOCKLOCATION"+proCFCLOCKLOCATION.toString());
|
|
|
+ sb = new StringBuffer("/*dialect*/");
|
|
|
+ sb.append(" select t.fid tfid,t1.fid pid,t1.fnumber,t1.fname_l2,t3.fid proid,t3.fnumber,t3.CFProjectName ,TO_CHAR(t.FPUNCHCARDTIME, 'YYYY-MM-DD') CFCLOCKTIME1 "
|
|
|
+ + ",TO_CHAR(t.FPUNCHCARDTIME, 'YYYY-MM-DD HH24:MI:SS') CFCLOCKTIME,t.FPUNCHCARDPLACE FPUNCHCARDPLACE from T_HR_ATS_PunchCardRecord t ").append(" \n");
|
|
|
+ sb.append(" inner join T_BD_Person t1 on t1.fid = t.FPROPOSERID ").append(" \n");
|
|
|
+ sb.append(" inner join CT_PRO_MemberManagement t2 on t2.CFEmployeeID = t1.fid ").append(" \n");
|
|
|
+ sb.append(" inner join CT_PRO_ProjectManagement t3 on t3.fid = t2.CFProjectManagemenID ").append(" \n");
|
|
|
+ sb.append(" where t3.CFExpectedStartTime <FPUNCHCARDTIME and t3.CFExpectedEndTime >= FPUNCHCARDTIME ").append(" \n");
|
|
|
+ sb.append(" and t.fid not in (select FSOURCEBILLID from CT_PRO_WorkHoursConfirm where FSOURCEBILLID is not null ) ").append(" \n");
|
|
|
+ //按照时间过滤
|
|
|
+ if(star != null && star.length() > 0) {
|
|
|
+ sb.append(" and t.FPUNCHCARDTIME >= TO_DATE('"+star+"', 'YYYY-MM-DD HH24:MI:SS')").append(" \n");
|
|
|
+ }else if(end != null && end.length() > 0) {
|
|
|
+ sb.append(" and t.FPUNCHCARDTIME <= TO_DATE('"+end+"', 'YYYY-MM-DD HH24:MI:SS')").append(" \n");
|
|
|
+ }else {
|
|
|
+ sb.append(" and t.FPUNCHCARDTIME >= sysdate -"+day).append(" \n");
|
|
|
+ }
|
|
|
+ if(number !=null && number.length() > 0) {
|
|
|
+ sb.append(" and t1.fnumber in (").append(number).append(") \n");
|
|
|
+ }
|
|
|
+ sb.append(" order by t1.fid, t.FPUNCHCARDTIME desc ").append(" \n");//排序
|
|
|
+ rs = DbUtil.executeQuery(ctx, sb.toString());
|
|
|
+ while (rs.next()) {
|
|
|
+ String pid = rs.getString("pid");
|
|
|
+ String tfid = rs.getString("tfid");
|
|
|
+ String proid = rs.getString("proid");
|
|
|
+ String FPUNCHCARDPLACE = rs.getString("FPUNCHCARDPLACE"); //考勤位置打卡
|
|
|
+ String CFCLOCKTIME = rs.getString("CFCLOCKTIME"); //年月日时分秒 打卡时间
|
|
|
+ String CFCLOCKTIME1 = rs.getString("CFCLOCKTIME1"); //年月日--------当前
|
|
|
+ String key = pid+CFCLOCKTIME1;//员工id+年月日为 一个 唯一组合
|
|
|
+ //同一天不在多个项目情况下进行标记
|
|
|
+ if(!listproid.contains(key) && mapproid.containsKey(key) && mapproid.get(key).equals(proid)) {
|
|
|
+ listproid.add(key);
|
|
|
+ }
|
|
|
+ //去重-年月日时分秒匹配-跳过
|
|
|
+ if(mapdate.containsKey(key) && mapproid.get(key).equals(CFCLOCKTIME)) {
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ if(mapInfo.containsKey(key)) {
|
|
|
+ listInfo = mapInfo.get(key);
|
|
|
+ }else {
|
|
|
+ listInfo = new ArrayList<WorkHoursConfirmInfo>();
|
|
|
+ keyList.add(key);
|
|
|
+ mapproid.put(key, proid);
|
|
|
+ mapdate.put(key, CFCLOCKTIME);
|
|
|
+ }
|
|
|
+ wInfo = getWConfirmInfo(ctx,pid, proid,proCFCLOCKLOCATION,FPUNCHCARDPLACE,simpleDateFormat.parse(CFCLOCKTIME),tfid);
|
|
|
+ listInfo.add(wInfo);
|
|
|
+ mapInfo.put(key, listInfo);
|
|
|
+ }
|
|
|
+ } catch (SQLException | ParseException e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ }
|
|
|
+ //写入打卡数据
|
|
|
+ WorkHoursConfirmCollection addSubColl = new WorkHoursConfirmCollection();
|
|
|
+ WorkHoursConfirmCollection addAudColl = new WorkHoursConfirmCollection();
|
|
|
+ //多个项目且不在同一个项目情况下
|
|
|
+ List<String> notList = new ArrayList<String>();
|
|
|
+ System.out.println("notList: "+notList.size());
|
|
|
+ if(listproid.size() > 0) {
|
|
|
+ for (int i = 0; i < listproid.size(); i++) {
|
|
|
+ String key = listproid.get(i);
|
|
|
+ listInfo = mapInfo.get(key);
|
|
|
+ String oldprojid = null;
|
|
|
+ boolean isoneprojid = true;
|
|
|
+ for (int j = 0; j < listInfo.size(); j++) {
|
|
|
+ wInfo = listInfo.get(j);
|
|
|
+ if(j == 0) {
|
|
|
+ if(wInfo.getProject() != null && wInfo.getProject().getId() != null) {
|
|
|
+ oldprojid = wInfo.getProject().getId().toString();
|
|
|
+ }else {
|
|
|
+ oldprojid = "0";
|
|
|
+ }
|
|
|
+ }else {
|
|
|
+ //不在同一个项目
|
|
|
+ if((wInfo.getProject() != null && !oldprojid.equals(wInfo.getProject().getId().toString()))
|
|
|
+ || wInfo.getProject() == null ||wInfo.getProject().getId() == null) {
|
|
|
+ isoneprojid = false;
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ //不在同一个项目
|
|
|
+ if(!isoneprojid) {
|
|
|
+ for (int j = 0; j < listInfo.size(); j++) {
|
|
|
+ wInfo = listInfo.get(j);
|
|
|
+ wInfo.setProject(null); //所属项目
|
|
|
+ wInfo.setBillState(HRBillStateEnum.SAVED);//暂存
|
|
|
+ addSubColl.add(wInfo);
|
|
|
+ }
|
|
|
+ notList.add(key);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ //剩余数据处理
|
|
|
+ if (keyList.size() > 0){
|
|
|
+ for (int i = 0; i < keyList.size(); i++) {
|
|
|
+ String key = keyList.get(i);
|
|
|
+ if(notList.contains(key)) {
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ listInfo = mapInfo.get(key);
|
|
|
+ for (int j = 0; j < listInfo.size(); j++) {
|
|
|
+ wInfo = listInfo.get(j);
|
|
|
+ //直接生效
|
|
|
+ if(wInfo.getBillState().compareTo(HRBillStateEnum.AUDITED) == 0) {
|
|
|
+ addAudColl.add(wInfo);
|
|
|
+ }else {
|
|
|
+ //匹配不上的
|
|
|
+ addSubColl.add(wInfo);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ //提交工作流
|
|
|
+ if(addSubColl.size() > 0) {
|
|
|
+ CoreBaseCollection addSubCollnew = new CoreBaseCollection();
|
|
|
+ List<String> addList = new ArrayList<String>();
|
|
|
+ for (int i = 0; i < addSubColl.size(); i++) {
|
|
|
+ WorkHoursConfirmInfo getinfo = addSubColl.get(i);
|
|
|
+ if(!addList.contains(getinfo.getSourceBillId())) {
|
|
|
+ addList.add(getinfo.getSourceBillId());
|
|
|
+ addSubCollnew.add(getinfo);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ System.out.println("addSubCollnew: "+addSubCollnew.size());
|
|
|
+ biz.submit(addSubCollnew);
|
|
|
+ }
|
|
|
+ if(addAudColl.size() > 0) {
|
|
|
+ CoreBaseCollection addAudCollNew = new CoreBaseCollection();
|
|
|
+ List<String> addList = new ArrayList<String>();
|
|
|
+ for (int i = 0; i < addAudColl.size(); i++) {
|
|
|
+ WorkHoursConfirmInfo getinfo = addAudColl.get(i);
|
|
|
+ if(!addList.contains(getinfo.getSourceBillId())) {
|
|
|
+ addList.add(getinfo.getSourceBillId());
|
|
|
+ addAudCollNew.add(getinfo);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ System.out.println("addAudCollNew: "+addAudCollNew.size());
|
|
|
+ //保存处理-审核通过
|
|
|
+ Result re = biz.addnew(addAudCollNew);
|
|
|
+ LineResult lr = null;
|
|
|
+ if(re != null && re.size() > 0){
|
|
|
+ for (int i = 0; i < re.size(); i++) {
|
|
|
+ lr = re.getLineResult(i);
|
|
|
+ biz.setAudited(BOSUuid.read(lr.getPk().toString())); //-审核通过
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 解析为工时确认单
|
|
|
+ * @param pid
|
|
|
+ * @param proid
|
|
|
+ * @param p1
|
|
|
+ * @param p2
|
|
|
+ * @param clockTime
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ private WorkHoursConfirmInfo getWConfirmInfo(Context ctx,String pid,String proid,Map<String,List<String>> map,String p2,Date clockTime,String FSOURCEBILLID) {
|
|
|
+ WorkHoursConfirmInfo wInfo = new WorkHoursConfirmInfo();
|
|
|
+ PersonInfo pinfo = new PersonInfo();pinfo.setId(BOSUuid.read(pid)); //人员
|
|
|
+
|
|
|
+ PersonCollection personCollection = null;
|
|
|
+ try {
|
|
|
+ personCollection = PersonFactory.getLocalInstance(ctx).getPersonCollection(" select * where id = '"+pid+"'");
|
|
|
+ } catch (BOSException e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ }
|
|
|
+ if(personCollection != null && personCollection.size()>0){
|
|
|
+ pinfo = personCollection.get(0);
|
|
|
+ }
|
|
|
+
|
|
|
+ ProjectManagementInfo proinfo = new ProjectManagementInfo();proinfo.setId(BOSUuid.read(proid)); //所属项目
|
|
|
+ wInfo.setEmployee(pinfo);
|
|
|
+ wInfo.setProject(proinfo); //所属项目
|
|
|
+ wInfo.setClockDate(clockTime); //打卡日期
|
|
|
+ wInfo.setSourceBillId(FSOURCEBILLID);//来源id
|
|
|
+ wInfo.setHrOrgUnit(pinfo.getHrOrgUnit());
|
|
|
+ wInfo.setCU(pinfo.getCU());
|
|
|
+ Timestamp t = new Timestamp(clockTime.getTime());
|
|
|
+ wInfo.setClockTime(t); //打卡--------------------------------------------------------------------------------------------------------------
|
|
|
+ //打卡位置 clockLocation
|
|
|
+ if(map != null) {
|
|
|
+ List<String> plist = map.get(proid);
|
|
|
+ System.out.println("p2:"+p2);
|
|
|
+ if(plist != null && plist.contains(p2)) {
|
|
|
+ wInfo.setClockLocation(p2);
|
|
|
+ wInfo.setBillState(HRBillStateEnum.AUDITED);//审核通过
|
|
|
+ }else {
|
|
|
+ wInfo.setProject(null); //所属项目
|
|
|
+ wInfo.setBillState(HRBillStateEnum.SAVED);//暂存
|
|
|
+ }
|
|
|
+ }else {
|
|
|
+ wInfo.setProject(null); //所属项目
|
|
|
+ wInfo.setBillState(HRBillStateEnum.SAVED);//暂存
|
|
|
+ }
|
|
|
+ return wInfo;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 工时计算
|
|
|
+ */
|
|
|
+ private void _updateWorkHoursReport(Context ctx, String number, String star, String end, int day,String type)
|
|
|
+ throws BOSException, EASBizException {
|
|
|
+
|
|
|
+ List<String> proidList = new ArrayList<String>();
|
|
|
+ //获取工时确认单生成工时单
|
|
|
+ String CFCLOCKTIME = null; //年月日-时分秒
|
|
|
+ String CFCLOCKDATE = null; //年月日
|
|
|
+ String CFPROJECTID = null; //项目id
|
|
|
+ String CFEMPLOYEEID = null; //人员id
|
|
|
+ String CFCLOCKLOCATION = null; //位置
|
|
|
+ String fid = null; //fid
|
|
|
+ SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
|
|
+ SimpleDateFormat sdfs = new SimpleDateFormat("HH:mm:ss");
|
|
|
+ IWorkHoursReport biz = WorkHoursReportFactory.getLocalInstance(ctx);
|
|
|
+ CoreBaseCollection coll = new CoreBaseCollection();
|
|
|
+ WorkHoursReportInfo info = null;
|
|
|
+ List<String> listDate = new ArrayList<String>(); //一天天的判断
|
|
|
+ Map<String,List<Map<String,String>>> dateMap = null;
|
|
|
+ List<Map<String,String>> listMap = null;
|
|
|
+ Map<String,List<String>> mapListPersonid = new HashMap<String,List<String>>(); //每天有多少人
|
|
|
+ List<String> personidList = null;
|
|
|
+ Map<String,String> map = null;
|
|
|
+ Map<String,Map<String,List<Map<String,String>>>> mapRs = new HashMap<String,Map<String,List<Map<String,String>>>>();
|
|
|
+ if(day <= 0) {
|
|
|
+ //默认3天
|
|
|
+ day = 3;
|
|
|
+ }
|
|
|
+ StringBuffer sb = new StringBuffer("/*dialect*/");
|
|
|
+ sb.append(" select fid fid,CFPROJECTID CFPROJECTID,CFEMPLOYEEID CFEMPLOYEEID"
|
|
|
+ + " ,TO_CHAR(CFCLOCKDATE, 'YYYY-MM-DD') CFCLOCKDATE"
|
|
|
+ + " ,TO_CHAR(CFCLOCKTIME, 'YYYY-MM-DD HH24:MI:SS') CFCLOCKTIME "
|
|
|
+ + " FROM CT_PRO_WorkHoursConfirm where FBILLSTATE ='3' "
|
|
|
+ + " and CFPROJECTID is not null ").append(" \n");
|
|
|
+ //按照时间过滤
|
|
|
+ if(star != null && star.length() > 0) {
|
|
|
+ sb.append(" and CFCLOCKDATE >= TO_DATE('"+star+"', 'YYYY-MM-DD HH24:MI:SS')").append(" \n");
|
|
|
+ }else if(end != null && end.length() > 0) {
|
|
|
+ sb.append(" and CFCLOCKDATE <= TO_DATE('"+end+"', 'YYYY-MM-DD HH24:MI:SS')").append(" \n");
|
|
|
+ }else {
|
|
|
+ sb.append(" and CFCLOCKDATE >= sysdate -"+day).append(" \n");
|
|
|
+ }
|
|
|
+ if(number !=null && number.length() > 0) {
|
|
|
+ sb.append(" and CFEMPLOYEEID in (select fid from (").append(number).append(")) \n");
|
|
|
+ }
|
|
|
+ sb.append(" order by CFEMPLOYEEID,CFCLOCKTIME asc").append(" \n");//排序
|
|
|
+ //获取打卡数据-审核通过的数据
|
|
|
+ IRowSet rs = DbUtil.executeQuery(ctx, sb.toString());
|
|
|
+ System.out.println("sb："+sb);
|
|
|
+ try {
|
|
|
+ while (rs.next()) {
|
|
|
+ CFCLOCKTIME = rs.getString("CFCLOCKTIME"); //年月日-时分秒
|
|
|
+ CFCLOCKDATE = rs.getString("CFCLOCKDATE"); //年月日
|
|
|
+ CFPROJECTID = rs.getString("CFPROJECTID"); //项目id
|
|
|
+ CFEMPLOYEEID = rs.getString("CFEMPLOYEEID"); //人员id
|
|
|
+ CFCLOCKLOCATION = "";//rs.getString("CFCLOCKLOCATION"); //位置
|
|
|
+ fid = rs.getString("fid"); //fid
|
|
|
+ map = new HashMap<String,String>();
|
|
|
+ map.put("CFCLOCKTIME", CFCLOCKTIME);
|
|
|
+ map.put("CFCLOCKDATE", CFCLOCKDATE);
|
|
|
+ map.put("CFPROJECTID", CFPROJECTID);
|
|
|
+ map.put("CFEMPLOYEEID", CFEMPLOYEEID);
|
|
|
+ map.put("fid", fid);
|
|
|
+ if(!listDate.contains(CFCLOCKDATE)){
|
|
|
+ listDate.add(CFCLOCKDATE);
|
|
|
+ dateMap = new HashMap<String,List<Map<String,String>>>();
|
|
|
+ personidList = new ArrayList<String>();
|
|
|
+ }else {
|
|
|
+ dateMap = mapRs.get(CFCLOCKDATE);
|
|
|
+ personidList = mapListPersonid.get(CFCLOCKDATE);
|
|
|
+ }
|
|
|
+ //重复人员
|
|
|
+ if(!personidList.contains(CFEMPLOYEEID)) {
|
|
|
+ personidList.add(CFEMPLOYEEID);
|
|
|
+ listMap = new ArrayList<Map<String,String>>();
|
|
|
+ }else {
|
|
|
+ listMap = dateMap.get(CFEMPLOYEEID);
|
|
|
+ }
|
|
|
+ listMap.add(map);
|
|
|
+
|
|
|
+ dateMap.put(CFEMPLOYEEID,listMap);
|
|
|
+ mapListPersonid.put(CFCLOCKDATE, personidList);
|
|
|
+ mapRs.put(CFCLOCKDATE, dateMap);
|
|
|
+ }
|
|
|
+ } catch (SQLException e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ }
|
|
|
+ List<String> delist = new ArrayList<String>();
|
|
|
+ //一天一天的处理
|
|
|
+ for (int i = 0; i < listDate.size(); i++) {
|
|
|
+ CFCLOCKDATE = listDate.get(i);
|
|
|
+ dateMap = mapRs.get(CFCLOCKDATE);
|
|
|
+ personidList = mapListPersonid.get(CFCLOCKDATE);
|
|
|
+ for (int j = 0; j < personidList.size(); j++) {
|
|
|
+ CFEMPLOYEEID = personidList.get(j);//人员id
|
|
|
+ listMap = dateMap.get(CFEMPLOYEEID); //这个人有多少打卡数据
|
|
|
+ String oldCFPROJECTID = null; //旧的项目
|
|
|
+ String oldCFCLOCKTIME = null; //旧的打卡时间
|
|
|
+ String oldfid = null; //旧的fid
|
|
|
+ String deleteWhere = " CFEMPLOYEEID='"+CFEMPLOYEEID+"' and to_char(CFDATA,'YYYY-MM-DD') = '"+CFCLOCKDATE+"'";
|
|
|
+ for (int j2 = 0; j2 < listMap.size(); j2++) {
|
|
|
+ map = listMap.get(j2);
|
|
|
+ CFCLOCKTIME = map.get("CFCLOCKTIME"); //年月日-时分秒
|
|
|
+ CFPROJECTID = map.get("CFPROJECTID"); //项目id
|
|
|
+ CFEMPLOYEEID = map.get("CFEMPLOYEEID"); //人员id
|
|
|
+ CFCLOCKLOCATION = map.get("CFEMPLOYEEID"); //位置
|
|
|
+ fid = map.get("fid"); //fid
|
|
|
+ //第一次记录最早的
|
|
|
+ if(j2 == 0){
|
|
|
+ oldCFPROJECTID = CFPROJECTID;
|
|
|
+ oldCFCLOCKTIME = CFCLOCKTIME;
|
|
|
+ oldfid = fid;
|
|
|
+ }
|
|
|
+ //跟上一次的不一致情况下
|
|
|
+ if(!oldCFPROJECTID.equals(CFPROJECTID)) {
|
|
|
+ map = listMap.get(j2-1);
|
|
|
+ CFCLOCKTIME = map.get("CFCLOCKTIME"); //年月日-时分秒
|
|
|
+ CFPROJECTID = map.get("CFPROJECTID"); //项目id
|
|
|
+ CFEMPLOYEEID = map.get("CFEMPLOYEEID"); //人员id
|
|
|
+ CFCLOCKLOCATION = map.get("CFEMPLOYEEID"); //位置
|
|
|
+ fid = map.get("fid"); //fid
|
|
|
+ //取上一次的数据与第一次数据进行比较计算
|
|
|
+ //计算两者时间差几个小时
|
|
|
+ try {
|
|
|
+ Date oldDate = sdf.parse(oldCFCLOCKTIME);
|
|
|
+ Date date = sdf.parse(CFCLOCKTIME);
|
|
|
+ long diffInMillies = date.getTime() - oldDate.getTime();
|
|
|
+ // 将毫秒数转换为小时
|
|
|
+ long diffInHours = diffInMillies / (60 * 60 * 1000);
|
|
|
+ BigDecimal hours = new BigDecimal(diffInHours);
|
|
|
+ //组装数据
|
|
|
+ info = initInfo(ctx,CFEMPLOYEEID, oldCFPROJECTID, date, sdf.format(sdf.parse(CFCLOCKTIME)), null, hours,oldfid+","+fid);
|
|
|
+ if(!delist.contains(deleteWhere)) {
|
|
|
+ delist.add(deleteWhere);
|
|
|
+ }
|
|
|
+ coll.add(info);
|
|
|
+ } catch (ParseException ee) {
|
|
|
+ ee.printStackTrace();
|
|
|
+ }
|
|
|
+ //当前重新开始
|
|
|
+ map = listMap.get(j2);
|
|
|
+ CFCLOCKTIME = map.get("CFCLOCKTIME"); //年月日-时分秒
|
|
|
+ CFPROJECTID = map.get("CFPROJECTID"); //项目id
|
|
|
+ CFEMPLOYEEID = map.get("CFEMPLOYEEID"); //人员id
|
|
|
+ CFCLOCKLOCATION = map.get("CFEMPLOYEEID"); //位置
|
|
|
+ fid = map.get("fid"); //fid
|
|
|
+ oldCFPROJECTID = CFPROJECTID;
|
|
|
+ oldCFCLOCKTIME = CFCLOCKTIME;
|
|
|
+ oldfid = fid;
|
|
|
+ }
|
|
|
+
|
|
|
+ //最后一次记录
|
|
|
+ if(j2 == listMap.size()-1){
|
|
|
+ if(oldCFPROJECTID.equals(CFPROJECTID) && !oldCFCLOCKTIME.equals(CFCLOCKTIME)) { //项目相同时间相同情况下
|
|
|
+ try {
|
|
|
+ Date oldDate = sdf.parse(oldCFCLOCKTIME);
|
|
|
+ Date date = sdf.parse(CFCLOCKTIME);
|
|
|
+ long diffInMillies = date.getTime() - oldDate.getTime();
|
|
|
+ // 将毫秒数转换为小时
|
|
|
+ long diffInHours = diffInMillies / (60 * 60 * 1000);
|
|
|
+ BigDecimal hours = new BigDecimal(diffInHours);
|
|
|
+ //组装数据
|
|
|
+ info = initInfo(ctx,CFEMPLOYEEID, oldCFPROJECTID, date, sdf.format(sdf.parse(CFCLOCKTIME)), null, hours,oldfid+","+fid);
|
|
|
+ if(!delist.contains(deleteWhere)) {
|
|
|
+ delist.add(deleteWhere);
|
|
|
+ }
|
|
|
+ coll.add(info);
|
|
|
+ } catch (ParseException ee) {
|
|
|
+ ee.printStackTrace();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ //删除情况下
|
|
|
+ if(type.equals("update") && delist.size() > 0) {
|
|
|
+ //删除当天
|
|
|
+ for (int i = 0; i < delist.size(); i++) {
|
|
|
+ DbUtil.execute(ctx, " delete from CT_PRO_WorkHoursReport where CFDATASOURCE = 'workHoursCal' and FBILLSTATE = '3' "
|
|
|
+ + "and CFFILLINGSTARTDATE = CFFILLINGENDDATE and fid in(select FParentID from CT_PRO_WorkHoursReportentry where "+delist.get(i)+") ");
|
|
|
+ DbUtil.execute(ctx, " delete from CT_PRO_WorkHoursReportentry where "+delist.get(i)+" ");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ //保存处理-审核通过
|
|
|
+ System.out.println("coll："+coll.toString());
|
|
|
+ if(coll.size() > 0) {
|
|
|
+ for (int i = 0; i < coll.size(); i++) {
|
|
|
+ info = (WorkHoursReportInfo) coll.get(i);
|
|
|
+ proidList.add(info.getAffiliatedProject().getId().toString());//项目id
|
|
|
+ IObjectPK pk = biz.addnew(info);
|
|
|
+ biz.setAudited(BOSUuid.read(pk.toString())); //-审核通过
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ //计算比例
|
|
|
+ if(proidList.size() > 0) {
|
|
|
+ for (int i = 0; i < proidList.size(); i++) {
|
|
|
+ String proid = proidList.get(i);
|
|
|
+ String sql = " SELECT tt.CFPLANNEDMANDAYS CFPLANNEDMANDAYS,sum(CASE when tt.CFWORKINGHOURS >= 8 THEN 8 ELSE tt.CFWORKINGHOURS END) CFWORKINGHOURS"
|
|
|
+ + " FROM (" +
|
|
|
+ " SELECT t2.CFPLANNEDMANDAYS CFPLANNEDMANDAYS ,to_char(t1.CFDATA,'YYYY-MM-DD') CFDATA,sum(t1.CFWORKINGHOURS) CFWORKINGHOURS FROM CT_PRO_WorkHoursReport t" +
|
|
|
+ " inner join CT_PRO_WorkHoursReportentry t1 on t1.FPARENTID = t.fid" +
|
|
|
+ " inner join CT_PRO_ProjectManagement t2 on t2.fid = t.CFAFFILIATEDPROJEC" +
|
|
|
+ " where t.FBILLSTATE = '3' and t2.fid = '"+proid+"'" +
|
|
|
+ " group by t2.CFPLANNEDMANDAYS,to_char(t1.CFDATA,'YYYY-MM-DD')" +
|
|
|
+ " )tt group by tt.CFPLANNEDMANDAYS " +
|
|
|
+ "";
|
|
|
+ rs = DbUtil.executeQuery(ctx,sql );
|
|
|
+ try {
|
|
|
+ System.out.println("sql："+sql);
|
|
|
+ if (rs.next()) {
|
|
|
+ BigDecimal FPRODAYCONSUMPTION = BigDecimal.ZERO;
|
|
|
+ BigDecimal CFPLANNEDMANDAYS = rs.getBigDecimal("CFPLANNEDMANDAYS"); //项目总人天
|
|
|
+ BigDecimal CFWORKINGHOURS = rs.getBigDecimal("CFWORKINGHOURS"); //申报人天 已审核通过
|
|
|
+ if(CFPLANNEDMANDAYS.compareTo(FPRODAYCONSUMPTION) == 1
|
|
|
+ && CFWORKINGHOURS.compareTo(FPRODAYCONSUMPTION) == 1) {
|
|
|
+ //项目总人天除以 申报人天
|
|
|
+ //申报人天= 总数/8
|
|
|
+ CFWORKINGHOURS = CFWORKINGHOURS.divide(new BigDecimal(8),2,BigDecimal.ROUND_HALF_UP); //8小时 四舍五入 保留2位小数
|
|
|
+ FPRODAYCONSUMPTION = CFWORKINGHOURS.divide(CFPLANNEDMANDAYS,4,BigDecimal.ROUND_HALF_UP);
|
|
|
+ FPRODAYCONSUMPTION = FPRODAYCONSUMPTION.multiply(new BigDecimal(100)).setScale(2, RoundingMode.HALF_UP);
|
|
|
+ }
|
|
|
+ DbUtil.execute(ctx, "update CT_PRO_ProjectManagement set FPRODAYCONSUMPTION ="+FPRODAYCONSUMPTION+" where fid = '"+proid+"'");
|
|
|
+ }
|
|
|
+ } catch (SQLException e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 组装工时单据
|
|
|
+ * @param pid
|
|
|
+ * @param proid
|
|
|
+ * @param data
|
|
|
+ * @param ClockTime
|
|
|
+ * @param ClockLocation
|
|
|
+ * @param hours
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ private WorkHoursReportInfo initInfo(Context ctx,String pid,String proid,Date data,String ClockTime
|
|
|
+ ,String ClockLocation,BigDecimal hours,String ids) {
|
|
|
+ WorkHoursReportInfo info = new WorkHoursReportInfo();
|
|
|
+ WorkHoursReportEntryInfo einfo = new WorkHoursReportEntryInfo();
|
|
|
+ PersonInfo pinfo = new PersonInfo();pinfo.setId(BOSUuid.read(pid)); //人员
|
|
|
+ PersonCollection personCollection = null;
|
|
|
+ try {
|
|
|
+ personCollection = PersonFactory.getLocalInstance(ctx).getPersonCollection(" select * where id = '"+pid+"'");
|
|
|
+ } catch (BOSException e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ }
|
|
|
+ if(personCollection != null && personCollection.size()>0){
|
|
|
+ pinfo = personCollection.get(0);
|
|
|
+ }
|
|
|
+ ProjectManagementInfo proinfo = new ProjectManagementInfo();
|
|
|
+ proinfo.setId(BOSUuid.read(proid)); //所属项目
|
|
|
+ info.setHrOrgUnit(pinfo.getHrOrgUnit());
|
|
|
+ info.setCU(pinfo.getCU());
|
|
|
+ info.setDataSource(dataSource.workHoursCal);
|
|
|
+ info.setAffiliatedProject(proinfo);
|
|
|
+ info.setBillState(HRBillStateEnum.AUDITED); //审核通过
|
|
|
+ info.setFillingStartDate(data); //默认当天
|
|
|
+ info.setFillingEndDate(data); //默认当天
|
|
|
+ info.setSourceBillId(ids);
|
|
|
+ einfo.setEmployee(pinfo);
|
|
|
+// einfo.setClockLocation("工时计算");
|
|
|
+ einfo.setClockTime(ClockTime); //打卡时间
|
|
|
+ einfo.setData(data); //日期
|
|
|
+ einfo.setWorkingHours(hours); //工时
|
|
|
+ info.getEntrys().add(einfo);
|
|
|
+ return info;
|
|
|
+ }
|
|
|
}
|
huchenghua