港湾批量调薪处理历史数据接口
This commit is contained in:
Harryxzy
parent
e7de9d7d1e
commit
c59cf6644c
|
|
@ -75,4 +75,6 @@ public interface GwPltxDt1Mapper {
|
|||
void batchUpdate(@Param("collection")List<gwPltxSaveParam> list);
|
||||
|
||||
void deleteByIds(@Param("ids")List<Long> list);
|
||||
|
||||
void deleteByRequestId(@Param("requestId")Integer requestId);
|
||||
}
|
||||
|
|
|
|||
|
|
@ -524,6 +524,12 @@
|
|||
</foreach>
|
||||
</if>
|
||||
</delete>
|
||||
<delete id="deleteByRequestId">
|
||||
UPDATE hrsa_gw_pltx_dt1
|
||||
SET delete_type=1
|
||||
WHERE delete_type = 0
|
||||
AND mainid = #{requestId}
|
||||
</delete>
|
||||
|
||||
|
||||
</mapper>
|
||||
|
|
@ -76,4 +76,6 @@ public interface GwPltxDt1Service {
|
|||
void batchUpdate(List<gwPltxSaveParam> needUpdatelist);
|
||||
|
||||
void deleteByIds(List<Long> needDeleteIds);
|
||||
|
||||
void deleteByRequestId(Integer requestId);
|
||||
}
|
||||
|
|
|
|||
|
|
@ -245,4 +245,6 @@ public interface SalaryAcctResultService {
|
|||
* @param saveParam
|
||||
*/
|
||||
void pltxDetailsToMode(pltxDetailsToModeSaveParam saveParam);
|
||||
|
||||
void pltxHistoryDataHandle();
|
||||
}
|
||||
|
|
|
|||
|
|
@ -108,4 +108,12 @@ public class GwPltxDt1ServiceImpl extends Service implements GwPltxDt1Service {
|
|||
List<List<Long>> partition = Lists.partition(needDeleteIds, 100);
|
||||
partition.forEach(list -> getGwPltxDt1Mapper().deleteByIds(list));
|
||||
}
|
||||
|
||||
@Override
|
||||
public void deleteByRequestId(Integer requestId) {
|
||||
if (requestId == null) {
|
||||
return;
|
||||
}
|
||||
getGwPltxDt1Mapper().deleteByRequestId(requestId);
|
||||
}
|
||||
}
|
||||
|
|
|
|||
|
|
@ -1899,6 +1899,54 @@ public class SalaryAcctResultServiceImpl extends Service implements SalaryAcctRe
|
|||
}).collect(Collectors.toList());
|
||||
}
|
||||
|
||||
/**
|
||||
* 批量调薪历史数据迁移接口
|
||||
* @param
|
||||
*/
|
||||
@Override
|
||||
public void pltxHistoryDataHandle() {
|
||||
BaseBean baseBean = new BaseBean();
|
||||
String mainTableName = baseBean.getPropValue("shgwSalary", "pltx_formtable_main_name");
|
||||
RecordSet rs = new RecordSet();
|
||||
rs.execute("select id,requestid from " +mainTableName);
|
||||
HashMap<Integer, Integer> oldRequestMap = new HashMap<>();
|
||||
while (rs.next()) {
|
||||
oldRequestMap.put(rs.getInt("id"), rs.getInt("requestid"));
|
||||
}
|
||||
|
||||
// 获取对应的明细表1数据
|
||||
for (Map.Entry<Integer, Integer> entry : oldRequestMap.entrySet()) {
|
||||
Integer mainId = entry.getKey();
|
||||
Integer requestId = entry.getValue();
|
||||
// 先删除
|
||||
getGwPltxDt1Service(user).deleteByRequestId(requestId);
|
||||
rs.execute("select xm,bm,gw,qnjxfs,jbgz,dx,dxhjbgz,dxbl,gskjywr,dxbl1,hjxz,dzhhjxz,hjxzdzbl,bz,nzjj from " + mainTableName + "_dt1 where mainid=" + mainId);
|
||||
while (rs.next()) {
|
||||
// 封装对象
|
||||
GwPltxDt1PO gwPltxDt1PO = new GwPltxDt1PO();
|
||||
gwPltxDt1PO.setId(IdGenerator.generate());
|
||||
gwPltxDt1PO.setMainid(Long.valueOf(requestId));
|
||||
gwPltxDt1PO.setXm(rs.getInt("xm"));
|
||||
gwPltxDt1PO.setBm(rs.getInt("bm"));
|
||||
gwPltxDt1PO.setGw(rs.getString("gw"));
|
||||
gwPltxDt1PO.setQnjxfs(NumberUtils.isCreatable(rs.getString("qnjxfs")) ? new BigDecimal(rs.getString("qnjxfs")) : null);
|
||||
gwPltxDt1PO.setJbgz(NumberUtils.isCreatable(rs.getString("jbgz")) ? new BigDecimal(rs.getString("jbgz")) : null);
|
||||
gwPltxDt1PO.setDx(NumberUtils.isCreatable(rs.getString("dx")) ? new BigDecimal(rs.getString("dx")) : null);
|
||||
gwPltxDt1PO.setDxhjbgz(NumberUtils.isCreatable(rs.getString("dxhjbgz")) ? new BigDecimal(rs.getString("dxhjbgz")) : null);
|
||||
gwPltxDt1PO.setDxbl(NumberUtils.isCreatable(rs.getString("dxbl1")) ? new BigDecimal(rs.getString("dxbl1")) : null);
|
||||
gwPltxDt1PO.setGskjywr(rs.getString("gskjywr"));
|
||||
gwPltxDt1PO.setHjxz(NumberUtils.isCreatable(rs.getString("hjxz")) ? new BigDecimal(rs.getString("hjxz")) : null);
|
||||
gwPltxDt1PO.setDzhhjxz(NumberUtils.isCreatable(rs.getString("dzhhjxz")) ? new BigDecimal(rs.getString("dzhhjxz")) : null);
|
||||
gwPltxDt1PO.setHjxzdzbl(NumberUtils.isCreatable(rs.getString("hjxzdzbl")) ? new BigDecimal(rs.getString("hjxzdzbl")) : null);
|
||||
gwPltxDt1PO.setBz(rs.getString("bz"));
|
||||
gwPltxDt1PO.setNzjj(NumberUtils.isCreatable(rs.getString("nzjj")) ? new BigDecimal(rs.getString("nzjj")) : null);
|
||||
gwPltxDt1PO.setDeleteType(0);
|
||||
getGwPltxDt1Service(user).insertIgnoreNull(gwPltxDt1PO);
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void pltxDetailsToMode(pltxDetailsToModeSaveParam saveParam) {
|
||||
// 处理主表, 先根据年度查询是否存在,若存在则更新
|
||||
|
|
|
|||
|
|
@ -1008,6 +1008,18 @@ public class SalaryAcctController {
|
|||
User user = HrmUserVarify.getUser(request, response);
|
||||
return new ResponseResult<pltxDetailsToModeSaveParam, String>(user).run(getSalaryAcctResultWrapper(user)::pltxDetailsToMode, param);
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* 港湾历史批量调薪流程数据迁移
|
||||
*/
|
||||
@GET
|
||||
@Path("/pltxHistoryDataHandle")
|
||||
@Produces(MediaType.APPLICATION_JSON)
|
||||
public String pltxHistoryDataHandle(@Context HttpServletRequest request, @Context HttpServletResponse response, @QueryParam(value = "requestId") Long requestId) {
|
||||
User user = HrmUserVarify.getUser(request, response);
|
||||
return new ResponseResult<String, String>(user).run(getSalaryAcctResultWrapper(user)::pltxHistoryDataHandle);
|
||||
}
|
||||
/**********************************上海港湾 批量调薪流程 NEW end*********************************/
|
||||
|
||||
/**********************************上海港湾 薪酬报表 start*********************************/
|
||||
|
|
|
|||
|
|
@ -300,6 +300,11 @@ public class SalaryAcctResultWrapper extends Service {
|
|||
getSalaryAcctResultService(user).pltxDetailsToMode(saveParam);
|
||||
}
|
||||
|
||||
public String pltxHistoryDataHandle() {
|
||||
getSalaryAcctResultService(user).pltxHistoryDataHandle();
|
||||
return "";
|
||||
}
|
||||
|
||||
/**
|
||||
* 薪资核算-校验
|
||||
*
|
||||
|
|
|
|||
Loading…
Reference in New Issue