qt
/
weaver-hrm-salary
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

领悦报表2、3、4：薪酬档案职级统计报表

This commit is contained in:
Harryxzy 2025-09-16 17:12:58 +08:00
parent 9a1b7be680
commit a55b20234f
7 changed files with 696 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/com/engine/salary/entity/ly/param/LySalaryReportQueryParam.java
View File

@ -54,4 +54,7 @@ public class LySalaryReportQueryParam extends BaseQueryParam {
private boolean export;
private List<Long> taxAgentIds;
private String startDate;
private String endDate;
}

44
src/com/engine/salary/entity/salaryacct/dto/LyTxdaDTO.java Normal file
View File

@ -0,0 +1,44 @@
package com.engine.salary.entity.salaryacct.dto;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* @author Harryxzy
* @ClassName LyDazjtjReportDTO
* @date 2025/09/15 9:12
* @description 领悦调薪档案
*/
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class LyTxdaDTO {
private String lypq;
private Integer lypqShowOrder;
private String lyxm;
private Integer lyxmShowOrder;
// 职级
private String zj;
// 职务角色
private Long zwjsId;
private String zwjs;
// 调薪人次
private Integer txrc;
// 占周期内调薪总人数比例
private String zzqntxzrsbl;
// 年度调薪总额
private String ndtxze;
// 占周期内调薪总额比例
private String zzqntxzebl;
}

36
src/com/engine/salary/entity/salaryacct/po/LyTxdaPO.java Normal file
View File

@ -0,0 +1,36 @@
package com.engine.salary.entity.salaryacct.po;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.math.BigDecimal;
import java.util.Date;
/**
* @author Harryxzy
* @ClassName LyDazjtjReportDTO
* @date 2025/09/15 9:12
* @description 领悦调薪档案
*/
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class LyTxdaPO {
private Long yg;
private BigDecimal ndyqsrze;
private Date txrq;
private Integer lyzj;
private String lypq;
private String lyxm;
private String lyzwjs;
private String dxyy;
}

8
src/com/engine/salary/service/LySalaryReportService.java
View File

@ -162,4 +162,12 @@ public interface LySalaryReportService {
Map<String, Object> listLyXcdazwjstjReport();
XSSFWorkbook exportXcdazwjstjReport();
Map<String, Object> listLyTxdazjtjReport(LySalaryReportQueryParam param);
XSSFWorkbook exportTxdazjtjReport(LySalaryReportQueryParam param);
Map<String, Object> listLyTxdazwjstjReport(LySalaryReportQueryParam param);
XSSFWorkbook exportTxdazwjstjReport(LySalaryReportQueryParam param);
}

487
src/com/engine/salary/service/impl/LySalaryReportServiceImpl.java
View File

@ -18,6 +18,8 @@ import com.engine.salary.entity.ly.po.UfSbInfo;
import com.engine.salary.entity.salaryacct.bo.SalaryAcctFormulaBO;
import com.engine.salary.entity.salaryacct.bo.SalaryAcctResultBO;
import com.engine.salary.entity.salaryacct.dto.LyDazjtjReportDTO;
import com.engine.salary.entity.salaryacct.dto.LyTxdaDTO;
import com.engine.salary.entity.salaryacct.po.LyTxdaPO;
import com.engine.salary.entity.salaryacct.po.SalaryAcctEmployeePO;
import com.engine.salary.entity.salaryacct.po.SalaryAcctRecordPO;
import com.engine.salary.entity.salaryacct.po.SalaryAcctResultPO;
@ -57,6 +59,7 @@ import weaver.general.TimeUtil;
import weaver.hrm.User;
import weaver.wechat.util.Utils;
import java.io.UnsupportedEncodingException;
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.text.SimpleDateFormat;
@ -3291,4 +3294,488 @@ public class LySalaryReportServiceImpl extends Service implements LySalaryReport
//获取excel
return ExcelUtilPlus.genWorkbookV2(rows, "薪酬档案职级统计报表", false);
}
@Override
public Map<String, Object> listLyTxdazjtjReport(LySalaryReportQueryParam param) {
Date startDate = SalaryDateUtil.dateStrToLocalDate(param.getStartDate());
Date endDate = SalaryDateUtil.dateStrToLocalDate(param.getEndDate());
if (startDate == null || endDate == null) {
throw new SalaryRunTimeException("开始或结束日期不存在或格式错误，正确格式yyyy-MM-dd");
}
BaseBean baseBean = new BaseBean();
RecordSet rs = new RecordSet();
// 查询所有发薪的调薪档案
String excludeTxyy = baseBean.getPropValue("lySalaryReport", "txdatj_exclued_txyy");
try {
excludeTxyy = new String(excludeTxyy.getBytes("ISO-8859-1"), "utf-8");
} catch (UnsupportedEncodingException e) {
}
List<String> excluedeTxyy = Arrays.stream(excludeTxyy.split(",")).collect(Collectors.toList());
String sql = "select yg,ndyqsrze,txrq,dxyy from uf_txda where txrq >=? and txrq<=? ";
rs.executeQuery(sql, Arrays.asList(startDate, endDate));
List<LyTxdaPO> lyTxdaList = new ArrayList<>();
while (rs.next()) {
Date txrqDate = SalaryDateUtil.dateStrToLocalDate(rs.getString("txrq"));
if (txrqDate != null) {
lyTxdaList.add(LyTxdaPO.builder()
.yg(NumberUtils.isCreatable(rs.getString("yg")) ? Long.valueOf(rs.getString("yg")) : -1L)
.ndyqsrze(SalaryEntityUtil.string2BigDecimalDefault0(rs.getString("ndyqsrze")))
.txrq(txrqDate)
.dxyy(rs.getString("dxyy"))
.build());
}
}
String gwzjField = baseBean.getPropValue("lySalaryReport", "gwzj_field_id");
String pqField = baseBean.getPropValue("lySalaryReport", "pq_field_id");
// 查询职等职级信息
rs.execute("select id,gwzj from uf_zdzj_new ");
Map<String, Integer> zdzjInfoMap = new HashMap<>();
while (rs.next()) {
String[] split = StringUtils.split(rs.getString("gwzj"), "-");
if (split != null && split.length > 0) {
String gwzj = split[0];
zdzjInfoMap.put(rs.getString("id"), SalaryEntityUtil.string2Integer(gwzj));
}
}
// 查询员工对应的职级、片区信息
List<Long> employeeIds = lyTxdaList.stream().map(txdaPO -> txdaPO.getYg()).distinct().collect(Collectors.toList());
List<List<Long>> partition = Lists.partition(employeeIds, 800);
Map<Long, Integer> empZjMap = new HashMap<>();
Map<Long, String> empPqMap = new HashMap<>();
partition.forEach(part -> {
rs.execute("select id,"+gwzjField+","+pqField+" from cus_fielddata where scope='HrmCustomFieldByInfoType' and scopeid=-1 and id in (" + StringUtils.join(part, ",") + ")");
while (rs.next()) {
String gwzj = Utils.null2String(rs.getString(gwzjField));
if(StringUtils.isNotBlank(gwzj)) {
if (gwzj.contains("_")) {
String[] split = gwzj.split("_");
gwzj = split != null && split.length > 0 ? split[split.length - 1] : "";
}
empZjMap.put(Long.valueOf(rs.getInt("id")), zdzjInfoMap.get(gwzj));
}
empPqMap.put(Long.valueOf(rs.getInt("id")), Utils.null2String(rs.getString(pqField)));
}
});
// 获取人员分部信息
Map<Long, DataCollectionEmployee> employeeMap = SalaryEntityUtil.convert2Map(getSalaryEmployeeService(user).listByIds(employeeIds), DataCollectionEmployee::getEmployeeId);
// 获取所有分部信息
Map<Long, SubCompanyInfo> subCompanyInfoMap = SalaryEntityUtil.convert2Map(getSalaryEmployeeService(user).listAllSubCompanyInfoList(), SubCompanyInfo::getId);
// 所有档案赋值职级
lyTxdaList.stream().forEach(txdaPO -> {
int zj = empZjMap.get(txdaPO.getYg()) == null ? -1 : empZjMap.get(txdaPO.getYg());
txdaPO.setLyzj(zj);
txdaPO.setLypq(Utils.null2String(empPqMap.get(txdaPO.getYg())));
txdaPO.setLyxm(Utils.null2String(employeeMap.get(txdaPO.getYg()) == null ? "" : employeeMap.get(txdaPO.getYg()).getSubcompanyid()));
});
// 调薪档案根据职级分组
List<LyTxdaDTO> reportDTOS = new ArrayList<LyTxdaDTO>();
Map<String, List<LyTxdaPO>> archiveGroupByZj = SalaryEntityUtil.group2Map(lyTxdaList, po -> po.getLyzj() + "_split" + po.getLypq() + "_split" + po.getLyxm());
BigDecimal[] allNdtxzeSumVal = new BigDecimal[]{new BigDecimal("0")};
int zrc =0;
for (Map.Entry<String, List<LyTxdaPO>> entry : archiveGroupByZj.entrySet()) {
Map<String, BigDecimal> zjSumValueMap = new HashMap<>();
String[] split = entry.getKey().split("_split");
Long zj = split != null && split.length > 0 && NumberUtils.isCreatable(split[0]) ? Long.valueOf(split[0]) : -1;
String lypq = split != null && split.length > 1 ? split[1] : "";
String lyxm = split != null && split.length > 2 ? split[2] : "";
Map<Long, List<LyTxdaPO>> groupByYg = SalaryEntityUtil.group2Map(entry.getValue(), LyTxdaPO::getYg);
BigDecimal zjTxze = new BigDecimal("0");
for (Map.Entry<Long, List<LyTxdaPO>> ygEntry : groupByYg.entrySet()) {
// 计算每个人的调薪总额
List<LyTxdaPO> sortedTxDTO = ygEntry.getValue().stream().sorted((o1, o2) -> o2.getTxrq().compareTo(o1.getTxrq())).collect(Collectors.toList());
BigDecimal ndyqsrze = sortedTxDTO.get(0).getNdyqsrze() == null ? new BigDecimal("0") : sortedTxDTO.get(0).getNdyqsrze();
BigDecimal ndyqsrzeLast = sortedTxDTO.get(sortedTxDTO.size()-1).getNdyqsrze() == null ? new BigDecimal("0") : sortedTxDTO.get(sortedTxDTO.size()-1).getNdyqsrze();
BigDecimal txValue = ndyqsrze.subtract(ndyqsrzeLast);
zjTxze = zjTxze.add(txValue);
allNdtxzeSumVal[0] = allNdtxzeSumVal[0].add(txValue);
}
// 封装
SubCompanyInfo lypqInfo = subCompanyInfoMap.get(SalaryEntityUtil.string2Long(lypq));
SubCompanyInfo lyxmInfo = subCompanyInfoMap.get(SalaryEntityUtil.string2Long(lyxm));
Long txCount = entry.getValue().stream().filter(PO -> !excluedeTxyy.contains(PO.getDxyy())).count();
reportDTOS.add(LyTxdaDTO.builder()
.lypq(lypqInfo == null ? "" : Utils.null2String(lypqInfo.getName()))
.lypqShowOrder(lypqInfo == null || lypqInfo.getShoworder() == null ? -1 :lypqInfo.getShoworder())
.lyxm(lyxmInfo == null ? "" : Utils.null2String(lyxmInfo.getName()))
.lyxmShowOrder(lyxmInfo == null || lyxmInfo.getShoworder() == null? -1 : lyxmInfo.getShoworder())
.zj(zj == null ? "-1" : zj.toString())
.txrc(txCount.intValue())
.ndtxze(zjTxze.toPlainString())
.build());
zrc = zrc + txCount.intValue();
}
// 计算占周期内调薪总人数比例
BigDecimal txZrc = BigDecimal.valueOf(zrc);
reportDTOS.stream().forEach(dto -> {
if (dto.getTxrc() != null) {
BigDecimal txrc = BigDecimal.valueOf(dto.getTxrc());
dto.setZzqntxzrsbl(txrc.divide(txZrc, 4, RoundingMode.HALF_UP).multiply(new BigDecimal("100")).setScale(2, RoundingMode.HALF_UP).toPlainString());
}
if (NumberUtils.isCreatable(dto.getNdtxze())) {
BigDecimal ndtxze = new BigDecimal(dto.getNdtxze());
dto.setZzqntxzebl(ndtxze.divide(allNdtxzeSumVal[0], 4, RoundingMode.HALF_UP).multiply(new BigDecimal("100")).setScale(2, RoundingMode.HALF_UP).toPlainString());
}
});
// reportDTOS根据lypq和lyxm和zj排序
reportDTOS = reportDTOS.stream().sorted(new Comparator<LyTxdaDTO>() {
@Override
public int compare(LyTxdaDTO o1, LyTxdaDTO o2) {
Integer o1zj = NumberUtils.isCreatable(o1.getZj()) ? Integer.valueOf(o1.getZj()) : -1;
Integer o2zj = NumberUtils.isCreatable(o2.getZj()) ? Integer.valueOf(o2.getZj()) : -1;
if (o1zj.equals(o2zj)) {
Integer o1pq = o1.getLypqShowOrder() == null ? -1 : o1.getLypqShowOrder();
Integer o2pq = o2.getLypqShowOrder() == null ? -1 : o2.getLypqShowOrder();
if (o1pq.equals(o2pq)) {
Integer o1xm = o1.getLyxmShowOrder() == null ? -1 : o1.getLyxmShowOrder();
Integer o2xm = o2.getLyxmShowOrder() == null ? -1 : o2.getLyxmShowOrder();
return o1xm.compareTo(o2xm);
} else {
return o1pq.compareTo(o2pq);
}
}
return o1zj.compareTo(o2zj);
}
}).collect(Collectors.toList());
// 计算饼状图（根据职级汇总）
LinkedHashMap<String, String> chartsMapA = new LinkedHashMap<>();
LinkedHashMap<String, String> chartsMapB = new LinkedHashMap<>();
Map<String, List<LyTxdaDTO>> groupByzj = SalaryEntityUtil.group2Map(reportDTOS, LyTxdaDTO::getZj);
LinkedHashMap<String, List<LyTxdaDTO>> sortedGroupByzj = groupByzj.entrySet().stream()
.sorted(new Comparator<Map.Entry<String, List<LyTxdaDTO>>>() {
@Override
public int compare(Map.Entry<String, List<LyTxdaDTO>> o1, Map.Entry<String, List<LyTxdaDTO>> o2) {
Long key1 = NumberUtils.isCreatable(o1.getKey()) ? Long.valueOf(o1.getKey()) : -1L;
Long key2 = NumberUtils.isCreatable(o2.getKey()) ? Long.valueOf(o2.getKey()) : -1L;
return key1.compareTo(key2);
}
})
.collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue, (oldValue, newValue) -> oldValue,
LinkedHashMap::new));
for ( Map.Entry<String, List<LyTxdaDTO>> entry : sortedGroupByzj.entrySet()) {
String zj = entry.getKey();
BigDecimal sumVal = entry.getValue().stream().map(LyTxdaDTO::getNdtxze).filter(NumberUtils::isCreatable).map(BigDecimal::new)
.reduce(new BigDecimal("0"), BigDecimal::add);
String zb = sumVal.divide(allNdtxzeSumVal[0], 4, RoundingMode.HALF_UP).multiply(new BigDecimal("100")).setScale(2, RoundingMode.HALF_UP).toPlainString();
chartsMapB.put(zj, zb);
BigDecimal txrcSumVal = entry.getValue().stream().map(LyTxdaDTO::getTxrc).filter(rc -> rc != null).map(BigDecimal::new)
.reduce(new BigDecimal("0"), BigDecimal::add);
String txrc = txrcSumVal.divide(txZrc, 4, RoundingMode.HALF_UP).multiply(new BigDecimal("100")).setScale(2, RoundingMode.HALF_UP).toPlainString();
chartsMapA.put(zj, txrc);
}
// 构建表头
List<WeaTableColumn> columns = new ArrayList<>();
columns.add(new WeaTableColumn("150px", "片区", "lypq"));
columns.add(new WeaTableColumn("150px", "项目", "lyxm"));
columns.add(new WeaTableColumn("150px", "职级", "zj"));
columns.add(new WeaTableColumn("150px", "调薪人次", "txrc"));
columns.add(new WeaTableColumn("150px", "占周期内调薪总人数比例", "zzqntxzrsbl"));
columns.add(new WeaTableColumn("150px", "年度调薪总额", "ndtxze"));
columns.add(new WeaTableColumn("150px", "占周期内调薪总额比例", "zzqntxzebl"));
Map<String, Object> map = new HashMap<>();
// if (param.isExport()) {
// // 合计或导出需要合计行
// Map<String, Object> sumResultMap = new HashMap<>();
// sumResultMap.put(gsmcItemId.toString(), "合计");
// for (SalaryItemPO salaryItem : salaryItemList) {
// if (salaryItem.getDataType().equals(SalaryDataTypeEnum.NUMBER.getValue())) {
// BigDecimal sumValue = acctResultMap.stream()
// .map(m -> m.get(salaryItem.getId().toString()))
// .filter(value -> value != null && NumberUtils.isCreatable(value.toString()))
// .map(e -> SalaryEntityUtil.empty2Zero(e.toString()))
// .reduce(BigDecimal.ZERO, BigDecimal::add);
// sumResultMap.put(salaryItem.getId().toString(),sumValue);
// }
// }
// map.put("sumRow", sumResultMap);
// }
map.put("columns", columns);
map.put("data", reportDTOS);
map.put("chartsDataA", chartsMapA);
map.put("chartsDataB", chartsMapB);
return map;
}
@Override
public XSSFWorkbook exportTxdazjtjReport(LySalaryReportQueryParam parm) {
Map<String, Object> resultMap = listLyTxdazjtjReport(parm);
List<LyTxdaDTO> dataList = (List<LyTxdaDTO>) resultMap.get("data");
List<WeaTableColumn> columns = (List<WeaTableColumn>) resultMap.get("columns");
// Map<String, Object> sum = (Map<String, Object>) resultMap.get("sum");
// dataList.add(sum);
List<Object> headerList = new ArrayList<>(columns.stream().map(WeaTableColumn::getText).collect(Collectors.toList()));
List<List<Object>> rows = new ArrayList<>();
rows.add(headerList);
for (LyTxdaDTO dto : dataList) {
List<Object> row = Lists.newArrayList();
Map<String, Object> valueMap = BeanUtil.beanToMap(dto);
for (WeaTableColumn column : columns) {
row.add(Utils.null2String(valueMap.get(column.getColumn())));
}
rows.add(row);
}
//获取excel
return ExcelUtilPlus.genWorkbookV2(rows, "调薪档案职级统计报表", false);
}
@Override
public Map<String, Object> listLyTxdazwjstjReport(LySalaryReportQueryParam param) {
Date startDate = SalaryDateUtil.dateStrToLocalDate(param.getStartDate());
Date endDate = SalaryDateUtil.dateStrToLocalDate(param.getEndDate());
if (startDate == null || endDate == null) {
throw new SalaryRunTimeException("开始或结束日期不存在或格式错误，正确格式yyyy-MM-dd");
}
BaseBean baseBean = new BaseBean();
RecordSet rs = new RecordSet();
// 查询所有发薪的调薪档案
String excludeTxyy = baseBean.getPropValue("lySalaryReport", "txdatj_exclued_txyy");
try {
excludeTxyy = new String(excludeTxyy.getBytes("ISO-8859-1"), "utf-8");
} catch (UnsupportedEncodingException e) {
}
List<String> excluedeTxyy = Arrays.stream(excludeTxyy.split(",")).collect(Collectors.toList());
String sql = "select yg,ndyqsrze,txrq,dxyy from uf_txda where txrq >=? and txrq<=? ";
rs.executeQuery(sql, Arrays.asList(startDate, endDate));
List<LyTxdaPO> lyTxdaList = new ArrayList<>();
while (rs.next()) {
Date txrqDate = SalaryDateUtil.dateStrToLocalDate(rs.getString("txrq"));
if (txrqDate != null) {
lyTxdaList.add(LyTxdaPO.builder()
.yg(NumberUtils.isCreatable(rs.getString("yg")) ? Long.valueOf(rs.getString("yg")) : -1L)
.ndyqsrze(SalaryEntityUtil.string2BigDecimalDefault0(rs.getString("ndyqsrze")))
.txrq(txrqDate)
.dxyy(rs.getString("dxyy"))
.build());
}
}
String gwzjField = baseBean.getPropValue("lySalaryReport", "gwzj_field_id");
String pqField = baseBean.getPropValue("lySalaryReport", "pq_field_id");
String zwjsField = baseBean.getPropValue("lySalaryReport", "zwjs_field_id");
// 查询职等职级信息
rs.execute("select id,gwzj from uf_zdzj_new ");
Map<String, Integer> zdzjInfoMap = new HashMap<>();
while (rs.next()) {
String[] split = StringUtils.split(rs.getString("gwzj"), "-");
if (split != null && split.length > 0) {
String gwzj = split[0];
zdzjInfoMap.put(rs.getString("id"), SalaryEntityUtil.string2Integer(gwzj));
}
}
// 查询员工对应的职级、片区信息
List<Long> employeeIds = lyTxdaList.stream().map(txdaPO -> txdaPO.getYg()).distinct().collect(Collectors.toList());
List<List<Long>> partition = Lists.partition(employeeIds, 800);
Map<Long, Integer> empZjMap = new HashMap<>();
Map<Long, String> empPqMap = new HashMap<>();
partition.forEach(part -> {
rs.execute("select id,"+gwzjField+","+pqField+" from cus_fielddata where scope='HrmCustomFieldByInfoType' and scopeid=-1 and id in (" + StringUtils.join(part, ",") + ")");
while (rs.next()) {
String gwzj = Utils.null2String(rs.getString(gwzjField));
if(StringUtils.isNotBlank(gwzj)) {
if (gwzj.contains("_")) {
String[] split = gwzj.split("_");
gwzj = split != null && split.length > 0 ? split[split.length - 1] : "";
}
empZjMap.put(Long.valueOf(rs.getInt("id")), zdzjInfoMap.get(gwzj));
}
empPqMap.put(Long.valueOf(rs.getInt("id")), Utils.null2String(rs.getString(pqField)));
}
});
// 查询员工对应的职务角色信息
Map<Long, String> empZwjsMap = new HashMap<>();
partition.forEach(part -> {
rs.execute("select id,"+zwjsField+" from cus_fielddata where scope='HrmCustomFieldByInfoType' and scopeid=3 and id in (" + StringUtils.join(part, ",") + ")");
while (rs.next()) {
empZwjsMap.put(Long.valueOf(rs.getInt("id")), Utils.null2String(rs.getString(zwjsField)));
}
});
// 获取人员分部信息
Map<Long, DataCollectionEmployee> employeeMap = SalaryEntityUtil.convert2Map(getSalaryEmployeeService(user).listByIds(employeeIds), DataCollectionEmployee::getEmployeeId);
// 获取所有分部信息
Map<Long, SubCompanyInfo> subCompanyInfoMap = SalaryEntityUtil.convert2Map(getSalaryEmployeeService(user).listAllSubCompanyInfoList(), SubCompanyInfo::getId);
// 获取所有职务角色数据
rs.execute("select id,mc from uf_zwjs");
Map<String, String> zwjsMap = new HashMap<>();
while (rs.next()) {
zwjsMap.put(rs.getString("id"), rs.getString("mc"));
}
// 所有档案赋值职级
lyTxdaList.stream().forEach(txdaPO -> {
// int zj = empZjMap.get(txdaPO.getYg()) == null ? -1 : empZjMap.get(txdaPO.getYg());
// txdaPO.setLyzj(zj);
txdaPO.setLypq(Utils.null2String(empPqMap.get(txdaPO.getYg())));
txdaPO.setLyxm(Utils.null2String(employeeMap.get(txdaPO.getYg()) == null ? "" : employeeMap.get(txdaPO.getYg()).getSubcompanyid()));
String zwjs = empZwjsMap.get(txdaPO.getYg()) == null ? "" : empZwjsMap.get(txdaPO.getYg());
txdaPO.setLyzwjs(zwjs);
});
// 调薪档案根据职级分组
List<LyTxdaDTO> reportDTOS = new ArrayList<LyTxdaDTO>();
Map<String, List<LyTxdaPO>> archiveGroupByZwjs = SalaryEntityUtil.group2Map(lyTxdaList, po -> po.getLyzwjs() + "_split" + po.getLypq() + "_split" + po.getLyxm());
BigDecimal[] allNdtxzeSumVal = new BigDecimal[]{new BigDecimal("0")};
int zrc =0;
for (Map.Entry<String, List<LyTxdaPO>> entry : archiveGroupByZwjs.entrySet()) {
Map<String, BigDecimal> zwjsSumValueMap = new HashMap<>();
String[] split = entry.getKey().split("_split");
String zwjs = split != null && split.length > 0 ? split[0] : "";
String lypq = split != null && split.length > 1 ? split[1] : "";
String lyxm = split != null && split.length > 2 ? split[2] : "";
Map<Long, List<LyTxdaPO>> groupByYg = SalaryEntityUtil.group2Map(entry.getValue(), LyTxdaPO::getYg);
BigDecimal zwjsTxze = new BigDecimal("0");
for (Map.Entry<Long, List<LyTxdaPO>> ygEntry : groupByYg.entrySet()) {
// 计算每个人的调薪总额
List<LyTxdaPO> sortedTxDTO = ygEntry.getValue().stream().sorted((o1, o2) -> o2.getTxrq().compareTo(o1.getTxrq())).collect(Collectors.toList());
BigDecimal ndyqsrze = sortedTxDTO.get(0).getNdyqsrze() == null ? new BigDecimal("0") : sortedTxDTO.get(0).getNdyqsrze();
BigDecimal ndyqsrzeLast = sortedTxDTO.get(sortedTxDTO.size()-1).getNdyqsrze() == null ? new BigDecimal("0") : sortedTxDTO.get(sortedTxDTO.size()-1).getNdyqsrze();
BigDecimal txValue = ndyqsrze.subtract(ndyqsrzeLast);
zwjsTxze = zwjsTxze.add(txValue);
allNdtxzeSumVal[0] = allNdtxzeSumVal[0].add(txValue);
}
// 封装
SubCompanyInfo lypqInfo = subCompanyInfoMap.get(SalaryEntityUtil.string2Long(lypq));
SubCompanyInfo lyxmInfo = subCompanyInfoMap.get(SalaryEntityUtil.string2Long(lyxm));
Long txCount = entry.getValue().stream().filter(PO -> !excluedeTxyy.contains(PO.getDxyy())).count();
reportDTOS.add(LyTxdaDTO.builder()
.lypq(lypqInfo == null ? "" : Utils.null2String(lypqInfo.getName()))
.lypqShowOrder(lypqInfo == null || lypqInfo.getShoworder() == null ? -1 :lypqInfo.getShoworder())
.lyxm(lyxmInfo == null ? "" : Utils.null2String(lyxmInfo.getName()))
.lyxmShowOrder(lyxmInfo == null || lyxmInfo.getShoworder() == null? -1 : lyxmInfo.getShoworder())
.zwjs(zwjsMap.getOrDefault(zwjs, ""))
.zwjsId(NumberUtils.isCreatable(zwjs) ? Long.valueOf(zwjs) : -1)
.txrc(txCount.intValue())
.ndtxze(zwjsTxze.toPlainString())
.build());
zrc = zrc + txCount.intValue();
}
// 计算占周期内调薪总人数比例
BigDecimal txZrc = BigDecimal.valueOf(zrc);
reportDTOS.stream().forEach(dto -> {
if (dto.getTxrc() != null) {
BigDecimal txrc = BigDecimal.valueOf(dto.getTxrc());
dto.setZzqntxzrsbl(txrc.divide(txZrc, 4, RoundingMode.HALF_UP).multiply(new BigDecimal("100")).setScale(2, RoundingMode.HALF_UP).toPlainString());
}
if (NumberUtils.isCreatable(dto.getNdtxze())) {
BigDecimal ndtxze = new BigDecimal(dto.getNdtxze());
dto.setZzqntxzebl(ndtxze.divide(allNdtxzeSumVal[0], 4, RoundingMode.HALF_UP).multiply(new BigDecimal("100")).setScale(2, RoundingMode.HALF_UP).toPlainString());
}
});
// reportDTOS排序
reportDTOS = reportDTOS.stream().sorted(new Comparator<LyTxdaDTO>() {
@Override
public int compare(LyTxdaDTO o1, LyTxdaDTO o2) {
Long o1zj = o1.getZwjsId() != null ? o1.getZwjsId() : -1L;
Long o2zj = o2.getZwjsId() != null ? o2.getZwjsId() : -1L;
if (o1zj.equals(o2zj)) {
Integer o1pq = o1.getLypqShowOrder() == null ? -1 : o1.getLypqShowOrder();
Integer o2pq = o2.getLypqShowOrder() == null ? -1 : o2.getLypqShowOrder();
if (o1pq.equals(o2pq)) {
Integer o1xm = o1.getLyxmShowOrder() == null ? -1 : o1.getLyxmShowOrder();
Integer o2xm = o2.getLyxmShowOrder() == null ? -1 : o2.getLyxmShowOrder();
return o1xm.compareTo(o2xm);
} else {
return o1pq.compareTo(o2pq);
}
}
return o1zj.compareTo(o2zj);
}
}).collect(Collectors.toList());
// 计算饼状图（根据职级汇总）
LinkedHashMap<String, String> chartsMapA = new LinkedHashMap<>();
LinkedHashMap<String, String> chartsMapB = new LinkedHashMap<>();
Map<Long, List<LyTxdaDTO>> groupByzj = SalaryEntityUtil.group2Map(reportDTOS, LyTxdaDTO::getZwjsId);
LinkedHashMap<Long, List<LyTxdaDTO>> sortedGroupByzj = groupByzj.entrySet().stream()
.sorted(Map.Entry.comparingByKey())
.collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue, (oldValue, newValue) -> oldValue,
LinkedHashMap::new));
for ( Map.Entry<Long, List<LyTxdaDTO>> entry : sortedGroupByzj.entrySet()) {
Long zwjsId = entry.getKey();
BigDecimal sumVal = entry.getValue().stream().map(LyTxdaDTO::getNdtxze).filter(NumberUtils::isCreatable).map(BigDecimal::new)
.reduce(new BigDecimal("0"), BigDecimal::add);
String zb = sumVal.divide(allNdtxzeSumVal[0], 4, RoundingMode.HALF_UP).multiply(new BigDecimal("100")).setScale(2, RoundingMode.HALF_UP).toPlainString();
chartsMapB.put(zwjsMap.getOrDefault(Utils.null2String(zwjsId), ""), zb);
BigDecimal txrcSumVal = entry.getValue().stream().map(LyTxdaDTO::getTxrc).filter(rc -> rc != null).map(BigDecimal::new)
.reduce(new BigDecimal("0"), BigDecimal::add);
String txrc = txrcSumVal.divide(txZrc, 4, RoundingMode.HALF_UP).multiply(new BigDecimal("100")).setScale(2, RoundingMode.HALF_UP).toPlainString();
chartsMapA.put(zwjsMap.getOrDefault(Utils.null2String(zwjsId), ""), txrc);
}
// 构建表头
List<WeaTableColumn> columns = new ArrayList<>();
columns.add(new WeaTableColumn("150px", "片区", "lypq"));
columns.add(new WeaTableColumn("150px", "项目", "lyxm"));
columns.add(new WeaTableColumn("150px", "职务角色", "zwjs"));
columns.add(new WeaTableColumn("150px", "调薪人次", "txrc"));
columns.add(new WeaTableColumn("150px", "占周期内调薪总人数比例", "zzqntxzrsbl"));
columns.add(new WeaTableColumn("150px", "年度调薪总额", "ndtxze"));
columns.add(new WeaTableColumn("150px", "占周期内调薪总额比例", "zzqntxzebl"));
Map<String, Object> map = new HashMap<>();
// if (param.isExport()) {
// // 合计或导出需要合计行
// Map<String, Object> sumResultMap = new HashMap<>();
// sumResultMap.put(gsmcItemId.toString(), "合计");
// for (SalaryItemPO salaryItem : salaryItemList) {
// if (salaryItem.getDataType().equals(SalaryDataTypeEnum.NUMBER.getValue())) {
// BigDecimal sumValue = acctResultMap.stream()
// .map(m -> m.get(salaryItem.getId().toString()))
// .filter(value -> value != null && NumberUtils.isCreatable(value.toString()))
// .map(e -> SalaryEntityUtil.empty2Zero(e.toString()))
// .reduce(BigDecimal.ZERO, BigDecimal::add);
// sumResultMap.put(salaryItem.getId().toString(),sumValue);
// }
// }
// map.put("sumRow", sumResultMap);
// }
map.put("columns", columns);
map.put("data", reportDTOS);
map.put("chartsDataA", chartsMapA);
map.put("chartsDataB", chartsMapB);
return map;
}
@Override
public XSSFWorkbook exportTxdazwjstjReport(LySalaryReportQueryParam param) {
Map<String, Object> resultMap = listLyTxdazwjstjReport(param);
List<LyTxdaDTO> dataList = (List<LyTxdaDTO>) resultMap.get("data");
List<WeaTableColumn> columns = (List<WeaTableColumn>) resultMap.get("columns");
// Map<String, Object> sum = (Map<String, Object>) resultMap.get("sum");
// dataList.add(sum);
List<Object> headerList = new ArrayList<>(columns.stream().map(WeaTableColumn::getText).collect(Collectors.toList()));
List<List<Object>> rows = new ArrayList<>();
rows.add(headerList);
for (LyTxdaDTO dto : dataList) {
List<Object> row = Lists.newArrayList();
Map<String, Object> valueMap = BeanUtil.beanToMap(dto);
for (WeaTableColumn column : columns) {
row.add(Utils.null2String(valueMap.get(column.getColumn())));
}
rows.add(row);
}
//获取excel
return ExcelUtilPlus.genWorkbookV2(rows, "调薪档案职务角色统计报表", false);
}
}

101
src/com/engine/salary/web/LySalaryController.java
View File

@ -921,5 +921,106 @@ public class LySalaryController {
throw e;
}
}
/**
* 查询调薪档案职级统计报表
*
* @param request
* @param response
* @param param
* @return
*/
@POST
@Path("/txdazjtjReport/list")
@Produces(MediaType.APPLICATION_JSON)
public String listLyTxdazjtjReport(@Context HttpServletRequest request, @Context HttpServletResponse response, @RequestBody LySalaryReportQueryParam param) {
User user = HrmUserVarify.getUser(request, response);
return new ResponseResult<LySalaryReportQueryParam, Map<String, Object>>(user).run(getLySalaryWrapper(user)::listLyTxdazjtjReport, param);
}
/**
* 导出领悦调薪档案职级统计报表
*
* @param request
* @param response
* @param param
* @return
*/
@POST
@Path("/txdazjtjReport/export")
@Produces(MediaType.APPLICATION_OCTET_STREAM)
public Response exportTxdazjtjReport(@Context HttpServletRequest request, @Context HttpServletResponse response, @RequestBody LySalaryReportQueryParam param) {
try {
User user = HrmUserVarify.getUser(request, response);
XSSFWorkbook workbook = getLySalaryWrapper(user).exportTxdazjtjReport(param);
String time = LocalDate.now().toString();
String fileName = "调薪档案职级统计报表" + "-" + time;
try {
fileName = URLEncoder.encode(fileName + ".xlsx", "UTF-8");
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
}
StreamingOutput output = outputStream -> {
workbook.write(outputStream);
outputStream.flush();
};
response.setContentType("application/octet-stream");
return Response.ok(output).header("Content-disposition", "attachment;filename=" + fileName).header("Cache-Control", "no-cache").build();
} catch (Exception e) {
log.error("调薪档案职级统计报表导出异常", e);
throw e;
}
}
/**
* 查询调薪档案职务角色统计报表
*
* @param request
* @param response
* @param param
* @return
*/
@POST
@Path("/txdazwjstjReport/list")
@Produces(MediaType.APPLICATION_JSON)
public String listLyTxdazwjstjReport(@Context HttpServletRequest request, @Context HttpServletResponse response, @RequestBody LySalaryReportQueryParam param) {
User user = HrmUserVarify.getUser(request, response);
return new ResponseResult<LySalaryReportQueryParam, Map<String, Object>>(user).run(getLySalaryWrapper(user)::listLyTxdazwjstjReport, param);
}
/**
* 导出领悦调薪档案职务角色统计报表
*
* @param request
* @param response
* @param param
* @return
*/
@POST
@Path("/txdazwjstjReport/export")
@Produces(MediaType.APPLICATION_OCTET_STREAM)
public Response exportTxdazwjstjReport(@Context HttpServletRequest request, @Context HttpServletResponse response, @RequestBody LySalaryReportQueryParam param) {
try {
User user = HrmUserVarify.getUser(request, response);
XSSFWorkbook workbook = getLySalaryWrapper(user).exportTxdazwjstjReport(param);
String time = LocalDate.now().toString();
String fileName = "调薪档案职务角色统计报表" + "-" + time;
try {
fileName = URLEncoder.encode(fileName + ".xlsx", "UTF-8");
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
}
StreamingOutput output = outputStream -> {
workbook.write(outputStream);
outputStream.flush();
};
response.setContentType("application/octet-stream");
return Response.ok(output).header("Content-disposition", "attachment;filename=" + fileName).header("Cache-Control", "no-cache").build();
} catch (Exception e) {
log.error("调薪档案职务角色统计报表导出异常", e);
throw e;
}
}
//---------------------------------------------------------领悦薪资档案报表end-----------------------------------------
}

17
src/com/engine/salary/wrapper/LySalaryWrapper.java
View File

@ -363,4 +363,21 @@ public class LySalaryWrapper extends Service {
public XSSFWorkbook exportXcdazwjstjReport(LySalaryReportQueryParam param) {
return getLySalaryReportService(user).exportXcdazwjstjReport();
}
public Map<String, Object> listLyTxdazjtjReport(LySalaryReportQueryParam param) {
return getLySalaryReportService(user).listLyTxdazjtjReport(param);
}
public XSSFWorkbook exportTxdazjtjReport(LySalaryReportQueryParam param) {
return getLySalaryReportService(user).exportTxdazjtjReport(param);
}
public Map<String, Object> listLyTxdazwjstjReport(LySalaryReportQueryParam param) {
return getLySalaryReportService(user).listLyTxdazwjstjReport(param);
}
public XSSFWorkbook exportTxdazwjstjReport(LySalaryReportQueryParam param) {
return getLySalaryReportService(user).exportTxdazwjstjReport(param);
}
}