OnboardingSalaryDataService.java 4.3 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586
  1. package com.kingdee.eas.custom.esign.service;
  2. /**
  3. * 入职薪酬取数
  4. * @author coyle
  5. * 202602
  6. */
  7. public class OnboardingSalaryDataService extends OtherESignConfigDataService {
  8. public String getSql(String id) {
  9. StringBuilder sql = new StringBuilder();
  10. // -------------------------- SELECT子句 --------------------------
  11. // 基础字段:人员姓名、身份证号、甲方名称、入职日期
  12. // 薪资计算字段:固定工资、试用期固定工资、绩效奖金、各类补贴(均为税前)
  13. sql.append("SELECT \n");
  14. sql.append(" person.FNAME_L2 AS person_name ,\n");
  15. sql.append(" person.FIDCardNO AS idcard ,\n");
  16. sql.append(" firstParty.FName_l2 as firstPartyName ,\n");
  17. sql.append(" elation.FEnterDate AS eDate ,\n");
  18. // 1. 固定工资(税前)= 标准基本工资+综合工资+其他工资+加班工资
  19. sql.append(" ISNULL(SUM(CASE WHEN sitem.FNUMBER IN ('TD01', 'T012', 'T013', 'TD02') THEN fas.FMoney ELSE 0 END), 0) AS fixed_salary ,\n");
  20. // 2. 试用期固定工资(税前)= 标准基本工资+综合工资+其他工资+加班工资
  21. sql.append(" ISNULL(SUM(CASE WHEN sitem.FNUMBER IN ('TD01', 'T012', 'T013', 'TD02') THEN fas.FMoney ELSE 0 END), 0) AS prob_fixed_salary ,\n");
  22. // 3. 绩效奖金(税前)= 标准绩效奖金
  23. sql.append(" ISNULL(SUM(CASE WHEN sitem.FNUMBER = 'TD04' THEN fas.FMoney ELSE 0 END), 0) AS perf_bonus ,\n");
  24. // 4. 试用期绩效奖金(税前)= 试用期标准绩效奖金
  25. sql.append(" ISNULL(SUM(CASE WHEN sitem.FNUMBER = 'TD74' THEN fas.FMoney ELSE 0 END), 0) AS prob_perf_bonus ,\n");
  26. // 5. 国内餐补 = 餐补补贴
  27. sql.append(" ISNULL(SUM(CASE WHEN sitem.FNUMBER = 'T025' THEN fas.FMoney ELSE 0 END), 0) AS domestic_meal_subsidy ,\n");
  28. // 6. 艰苦补贴 = 艰苦补贴
  29. sql.append(" ISNULL(SUM(CASE WHEN sitem.FNUMBER = 'T038' THEN fas.FMoney ELSE 0 END), 0) AS hardship_subsidy ,\n");
  30. // 7. 社保公积金补贴 = 社保公积金补贴
  31. sql.append(" ISNULL(SUM(CASE WHEN sitem.FNUMBER = 'TD101' THEN fas.FMoney ELSE 0 END), 0) AS social_fund \n");
  32. // -------------------------- FROM子句 --------------------------
  33. // 表关联逻辑:
  34. // 1. T_bd_Person(人员表)关联T_HR_EmpLaborRelation(用工关系表):取入职日期
  35. // 2. 人员表关联T_HR_SFixAdjustSalary(固定薪资调整表):取薪资金额
  36. // 3. 薪资表关联T_HR_SCmpItem(薪资项目表):按薪资项目编码过滤
  37. // 4. 人员表关联T_HR_EmployeeContract(员工合同表):关联甲方信息
  38. // 5. 合同表关联T_HR_LabContractFirstParty(合同甲方表):取甲方名称
  39. sql.append("FROM \n");
  40. sql.append(" T_bd_Person person \n");
  41. sql.append("LEFT JOIN T_HR_EmpLaborRelation elation on person.fid = elation.FPersonID \n");
  42. sql.append("LEFT JOIN T_HR_SFixAdjustSalary fas ON person.FID = fas.FPersonID\n");
  43. sql.append("LEFT JOIN T_HR_SCmpItem sitem ON fas.FCmpItemID = sitem.FID\n");
  44. sql.append("LEFT JOIN T_HR_EmployeeContract econtract on econtract.FEmployeeID = person.FID\n");
  45. sql.append("LEFT JOIN T_HR_LabContractFirstParty firstParty on econtract.FContFirstPartyID = firstParty.FID \n");
  46. // -------------------------- WHERE子句 --------------------------
  47. // 过滤条件:
  48. // 1. 薪资项目编码仅包含指定项(固定工资、绩效、补贴等)
  49. // 2. 薪资生效日期为2199-12-31(永久生效)
  50. // 3. 可选条件:按人员ID过滤(启用时删除注释,注意数据库注释用--)
  51. sql.append("WHERE \n");
  52. sql.append(" sitem.FNUMBER IN ('TD01', 'T012', 'T013', 'TD02', 'TD04', 'TD74', 'T025', 'T038', 'TD101') \n");
  53. sql.append(" and fas.FLeffectDay = '2199-12-31 00:00:00' \n");
  54. // 数据库兼容的注释:-- 开头,嵌入SQL内不会报错(如需启用可删除前面的//)
  55. // sql.append(" -- and person.fid = 'X+0AAACrsleA733t' \n");
  56. sql.append("and person.fid in (select FEmployeeID from T_HR_EmployeeContract where fid = '"+id+"') ") ;
  57. // -------------------------- GROUP BY子句 --------------------------
  58. // 分组逻辑:按人员唯一标识+基础信息分组,保证聚合函数(SUM)结果正确
  59. sql.append("GROUP BY \n");
  60. sql.append(" person.FID, person.FNAME_L2 , elation.FEnterDate , person.FIDCardNO , firstParty.FName_l2 \n");
  61. // -------------------------- ORDER BY子句 --------------------------
  62. // 排序规则:按人员姓名升序排列
  63. sql.append("ORDER BY \n");
  64. sql.append(" person.FNAME_L2");
  65. System.out.print("osfsql"+sql.toString());
  66. return sql.toString();
  67. }
  68. }