Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Contribute to GitLab
Sign in / Register
Toggle navigation
Y
yifu-mvp
Project
Project
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
fangxinjiang
yifu-mvp
Commits
99060503
Commit
99060503
authored
Jun 26, 2023
by
wangzb
Browse files
Options
Browse Files
Download
Plain Diff
Merge remote-tracking branch 'origin/MVP1.5.5' into MVP1.5.5
parents
996a3a48
328adaf6
Expand all
Hide whitespace changes
Inline
Side-by-side
Showing
13 changed files
with
205 additions
and
103 deletions
+205
-103
TPersonnelRoster.java
.../cloud/plus/v1/yifu/archives/entity/TPersonnelRoster.java
+60
-17
TPersonnelRosterSearchVo.java
...ud/plus/v1/yifu/archives/vo/TPersonnelRosterSearchVo.java
+11
-1
TPersonnelRosterController.java
.../yifu/archives/controller/TPersonnelRosterController.java
+0
-1
TEmployeeContractInfoServiceImpl.java
...chives/service/impl/TEmployeeContractInfoServiceImpl.java
+52
-20
TEmployeeProjectServiceImpl.java
...fu/archives/service/impl/TEmployeeProjectServiceImpl.java
+9
-8
TPersonnelRosterServiceImpl.java
...fu/archives/service/impl/TPersonnelRosterServiceImpl.java
+17
-23
TPersonnelRosterMapper.xml
...-biz/src/main/resources/mapper/TPersonnelRosterMapper.xml
+16
-2
daprConfig.properties
...yifu-common-dapr/src/main/resources/daprConfig.properties
+6
-3
ArchiveTask.java
.../java/com/yifu/cloud/plus/v1/job/compont/ArchiveTask.java
+8
-0
SalaryEmpRosterRes.java
...yifu/cloud/plus/v1/yifu/salary/vo/SalaryEmpRosterRes.java
+17
-0
TSalaryEmpRosterVo.java
...yifu/cloud/plus/v1/yifu/salary/vo/TSalaryEmpRosterVo.java
+3
-24
TConfigSalaryController.java
...us/v1/yifu/salary/controller/TConfigSalaryController.java
+1
-1
TSalaryEmployeeController.java
.../v1/yifu/salary/controller/TSalaryEmployeeController.java
+5
-3
No files found.
yifu-archives/yifu-archives-api/src/main/java/com/yifu/cloud/plus/v1/yifu/archives/entity/TPersonnelRoster.java
View file @
99060503
This diff is collapsed.
Click to expand it.
yifu-archives/yifu-archives-api/src/main/java/com/yifu/cloud/plus/v1/yifu/archives/vo/TPersonnelRosterSearchVo.java
View file @
99060503
...
...
@@ -21,6 +21,7 @@ import io.swagger.v3.oas.annotations.media.Schema;
import
lombok.Data
;
import
java.time.LocalDateTime
;
import
java.util.List
;
/**
* @author fxj
...
...
@@ -52,5 +53,14 @@ public class TPersonnelRosterSearchVo extends TPersonnelRoster {
**/
@Schema
(
description
=
"查询limit 数据条数"
)
private
int
limitEnd
;
/**
* @Author fxj
* 业务类型
**/
private
List
<
String
>
businessTypes
;
/**
* @Author fxj
* BU归属
**/
private
List
<
String
>
buBelongs
;
}
yifu-archives/yifu-archives-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/archives/controller/TPersonnelRosterController.java
View file @
99060503
...
...
@@ -130,7 +130,6 @@ public class TPersonnelRosterController {
**/
@Operation
(
description
=
"导出 hasPermission('demo_tpersonnelroster-export')"
)
@PostMapping
(
"/export"
)
@PreAuthorize
(
"@pms.hasPermission('demo_tpersonnelroster-export')"
)
public
void
export
(
HttpServletResponse
response
,
@RequestBody
TPersonnelRosterSearchVo
searchVo
)
{
tPersonnelRosterService
.
listExport
(
response
,
searchVo
);
}
...
...
yifu-archives/yifu-archives-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/archives/service/impl/TEmployeeContractInfoServiceImpl.java
View file @
99060503
...
...
@@ -613,11 +613,9 @@ public class TEmployeeContractInfoServiceImpl extends ServiceImpl<TEmployeeContr
* @Date: 2023/6/16 10:16
* @return: void
**/
private
void
setAuditInfoNew
(
TEmployeeContractInfo
tEmployeeContractInfo
,
String
flag
)
{
private
void
setAuditInfoNew
(
TEmployeeContractInfo
tEmployeeContractInfo
)
{
TEmployeeContractAudit
audit
=
new
TEmployeeContractAudit
();
audit
.
setRootName
(
"合同审核"
);
audit
.
setAuditStatus
(
CommonConstants
.
ZERO_STRING
.
equals
(
flag
)
?
"审核通过"
:
"审核不通过"
);
audit
.
setRemark
(
"终止合同联动"
);
audit
.
setRootName
(
"终止合同联动"
);
audit
.
setLinkId
(
tEmployeeContractInfo
.
getId
());
audit
.
setLinkType
(
CommonConstants
.
ONE_INT
);
tEmployeeContractAuditService
.
save
(
audit
);
...
...
@@ -754,27 +752,31 @@ public class TEmployeeContractInfoServiceImpl extends ServiceImpl<TEmployeeContr
.
lambda
().
eq
(
TEmployeeContractInfo:
:
getEmpId
,
contractInfo
.
getEmpId
())
.
eq
(
TEmployeeContractInfo:
:
getSettleDomain
,
contractInfo
.
getSettleDomain
())
.
eq
(
TEmployeeContractInfo:
:
getInUse
,
CommonConstants
.
ZERO_STRING
)
.
eq
(
TEmployeeContractInfo:
:
getDeleteFlag
,
CommonConstants
.
ZERO_INT
));
.
eq
(
TEmployeeContractInfo:
:
getDeleteFlag
,
CommonConstants
.
ZERO_INT
)
.
ne
(
TEmployeeContractInfo:
:
getId
,
tEmployeeContractInfo
.
getId
()));
if
(
Common
.
isNotNull
(
contractInfoList
))
{
for
(
TEmployeeContractInfo
contractInfo1:
contractInfoList
)
{
contractInfo1
.
setInUse
(
CommonConstants
.
ONE_STRING
);
contractInfo1
.
setAuditUserName
(
user
.
getNickname
());
baseMapper
.
updateById
(
contractInfo1
);
//增加审核记录
this
.
setAuditInfoNew
(
contractInfo1
,
CommonConstants
.
ZERO_STRING
);
this
.
setAuditInfoNew
(
contractInfo1
);
}
}
//在途的合同更新为审核不通过
List
<
TEmployeeContractInfo
>
contractInfoListZt
=
baseMapper
.
selectList
(
Wrappers
.<
TEmployeeContractInfo
>
query
()
.
lambda
().
eq
(
TEmployeeContractInfo:
:
getEmpId
,
contractInfo
.
getEmpId
())
.
eq
(
TEmployeeContractInfo:
:
getSettleDomain
,
contractInfo
.
getSettleDomain
())
.
eq
(
TEmployeeContractInfo:
:
getAuditStatus
,
CommonConstants
.
ZERO_INT
)
.
and
(
obj
->
obj
.
eq
(
TEmployeeContractInfo:
:
getAuditStatus
,
CommonConstants
.
ONE_INT
)
.
or
().
eq
(
TEmployeeContractInfo:
:
getAuditStatus
,
CommonConstants
.
ZERO_INT
))
.
eq
(
TEmployeeContractInfo:
:
getDeleteFlag
,
CommonConstants
.
ZERO_INT
));
if
(
Common
.
isNotNull
(
contractInfoListZt
))
{
for
(
TEmployeeContractInfo
contractInfo1:
contractInfoListZt
)
{
contractInfo1
.
setAuditStatus
(
CommonConstants
.
THREE_INT
);
contractInfo1
.
setAuditUserName
(
user
.
getNickname
());
baseMapper
.
updateById
(
contractInfo1
);
//增加审核记录
this
.
setAuditInfoNew
(
contractInfo1
,
CommonConstants
.
ONE_STRING
);
this
.
setAuditInfoNew
(
contractInfo1
);
}
}
//项目档案处理
...
...
@@ -807,7 +809,19 @@ public class TEmployeeContractInfoServiceImpl extends ServiceImpl<TEmployeeContr
if
(
tEmployeeProject
.
getProjectStatus
()
==
CommonConstants
.
ONE_INT
&&
Common
.
isNotNull
(
tEmployeeInfo
))
{
TEmployeeInfo
tEmployeeInfoOld
=
tEmployeeInfoMapper
.
selectById
(
tEmployeeInfo
.
getId
());
tEmployeeInfo
.
setProjectNum
(
tEmployeeInfo
.
getProjectNum
()
-
CommonConstants
.
ONE_INT
);
tEmployeeInfo
.
setContractStatus
(
CommonConstants
.
TWO_INT
);
// 判断人员有无审核通过的其他合同
TEmployeeContractInfo
contractInfoInUse
=
this
.
getOne
(
Wrappers
.<
TEmployeeContractInfo
>
query
()
.
lambda
().
eq
(
TEmployeeContractInfo:
:
getEmpId
,
contractInfo
.
getEmpId
())
.
and
(
obj
->
obj
.
ge
(
TEmployeeContractInfo:
:
getContractEnd
,
DateUtil
.
getThisDayByPatten
(
"yyyy-MM-dd"
))
.
or
().
isNull
(
TEmployeeContractInfo:
:
getContractEnd
))
.
eq
(
TEmployeeContractInfo:
:
getInUse
,
CommonConstants
.
ZERO_INT
)
.
eq
(
TEmployeeContractInfo:
:
getDeleteFlag
,
CommonConstants
.
ZERO_INT
)
.
last
(
CommonConstants
.
LAST_ONE_SQL
));
if
(
contractInfoInUse
!=
null
)
{
tEmployeeInfo
.
setContractStatus
(
CommonConstants
.
ONE_INT
);
}
else
{
tEmployeeInfo
.
setContractStatus
(
CommonConstants
.
TWO_INT
);
}
//减项成功把人员档案现存项目数减一
if
(
tEmployeeInfo
.
getProjectNum
()
==
CommonConstants
.
ZERO_INT
)
{
//减档
...
...
@@ -817,12 +831,12 @@ public class TEmployeeContractInfoServiceImpl extends ServiceImpl<TEmployeeContr
tEmployeeInfo
.
setLeaveUser
(
user
.
getId
());
tEmployeeInfo
.
setLeaveUserName
(
user
.
getNickname
());
workInfo
.
append
(
"减档成功,"
);
tEmployeeInfoMapper
.
updateById
(
tEmployeeInfo
);
}
else
{
failueInfo
.
append
(
"存在其他项目,无法减档"
);
}
tEmployeeLogService
.
saveModificationRecord
(
CommonConstants
.
dingleDigitIntArray
[
0
],
tEmployeeInfo
.
getId
(),
""
,
tEmployeeInfoOld
,
tEmployeeInfo
);
tEmployeeInfoMapper
.
updateById
(
tEmployeeInfo
);
}
}
//更新任务处理情况数据
...
...
@@ -1679,27 +1693,29 @@ public class TEmployeeContractInfoServiceImpl extends ServiceImpl<TEmployeeContr
.
lambda
().
eq
(
TEmployeeContractInfo:
:
getEmpId
,
contract
.
getEmpId
())
.
eq
(
TEmployeeContractInfo:
:
getSettleDomain
,
contract
.
getSettleDomain
())
.
eq
(
TEmployeeContractInfo:
:
getInUse
,
CommonConstants
.
ZERO_STRING
)
.
eq
(
TEmployeeContractInfo:
:
getDeleteFlag
,
CommonConstants
.
ZERO_INT
));
.
eq
(
TEmployeeContractInfo:
:
getDeleteFlag
,
CommonConstants
.
ZERO_INT
)
.
ne
(
TEmployeeContractInfo:
:
getId
,
contract
.
getId
()));
if
(
Common
.
isNotNull
(
contractInfoList
))
{
for
(
TEmployeeContractInfo
contractInfo1
:
contractInfoList
)
{
contractInfo1
.
setInUse
(
CommonConstants
.
ONE_STRING
);
baseMapper
.
updateById
(
contractInfo1
);
//增加审核记录
this
.
setAuditInfoNew
(
contractInfo1
,
CommonConstants
.
ZERO_STRING
);
this
.
setAuditInfoNew
(
contractInfo1
);
}
}
//在途的合同更新为审核不通过
contractInfoListZt
=
baseMapper
.
selectList
(
Wrappers
.<
TEmployeeContractInfo
>
query
()
.
lambda
().
eq
(
TEmployeeContractInfo:
:
getEmpId
,
contract
.
getEmpId
())
.
eq
(
TEmployeeContractInfo:
:
getSettleDomain
,
contract
.
getSettleDomain
())
.
eq
(
TEmployeeContractInfo:
:
getAuditStatus
,
CommonConstants
.
ZERO_INT
)
.
and
(
obj
->
obj
.
eq
(
TEmployeeContractInfo:
:
getAuditStatus
,
CommonConstants
.
ONE_INT
)
.
or
().
eq
(
TEmployeeContractInfo:
:
getAuditStatus
,
CommonConstants
.
ZERO_INT
))
.
eq
(
TEmployeeContractInfo:
:
getDeleteFlag
,
CommonConstants
.
ZERO_INT
));
if
(
Common
.
isNotNull
(
contractInfoListZt
))
{
for
(
TEmployeeContractInfo
contractInfo1
:
contractInfoListZt
)
{
contractInfo1
.
setAuditStatus
(
CommonConstants
.
THREE_INT
);
baseMapper
.
updateById
(
contractInfo1
);
//增加审核记录
this
.
setAuditInfoNew
(
contractInfo1
,
CommonConstants
.
ONE_STRING
);
this
.
setAuditInfoNew
(
contractInfo1
);
}
}
//项目档案处理
...
...
@@ -1728,23 +1744,39 @@ public class TEmployeeContractInfoServiceImpl extends ServiceImpl<TEmployeeContr
tEmployeeProject
.
getId
(),
tEmployeeProjectOld
,
tEmployeeProject
);
tEmployeeProjectService
.
updateById
(
tEmployeeProject
);
//如果项目档案已减项,如果人员存在多个项目不处理,反之则减档
if
(
tEmployeeProject
.
getProjectStatus
()
==
CommonConstants
.
ONE_INT
)
{
tEmployeeInfo
=
tEmployeeInfoMapper
.
selectById
(
tEmployeeProject
.
getEmpId
());
if
(
Common
.
isNotNull
(
tEmployeeInfo
)
&&
tEmployeeInfo
.
getProjectNum
()
==
CommonConstants
.
ONE_INT
)
{
tEmployeeInfo
=
tEmployeeInfoMapper
.
selectById
(
tEmployeeProject
.
getEmpId
());
if
(
tEmployeeProject
.
getProjectStatus
()
==
CommonConstants
.
ONE_INT
&&
Common
.
isNotNull
(
tEmployeeInfo
))
{
TEmployeeInfo
tEmployeeInfoOld
=
tEmployeeInfoMapper
.
selectById
(
tEmployeeInfo
.
getId
());
tEmployeeInfo
.
setProjectNum
(
tEmployeeInfo
.
getProjectNum
()
-
CommonConstants
.
ONE_INT
);
// 判断人员有无审核通过的其他合同
contractInfoInUse
=
this
.
getOne
(
Wrappers
.<
TEmployeeContractInfo
>
query
()
.
lambda
().
eq
(
TEmployeeContractInfo:
:
getEmpId
,
contract
.
getEmpId
())
.
and
(
obj
->
obj
.
ge
(
TEmployeeContractInfo:
:
getContractEnd
,
DateUtil
.
getThisDayByPatten
(
"yyyy-MM-dd"
))
.
or
().
isNull
(
TEmployeeContractInfo:
:
getContractEnd
))
.
eq
(
TEmployeeContractInfo:
:
getInUse
,
CommonConstants
.
ZERO_INT
)
.
eq
(
TEmployeeContractInfo:
:
getDeleteFlag
,
CommonConstants
.
ZERO_INT
)
.
last
(
CommonConstants
.
LAST_ONE_SQL
));
if
(
contractInfoInUse
!=
null
)
{
tEmployeeInfo
.
setContractStatus
(
CommonConstants
.
ONE_INT
);
}
else
{
tEmployeeInfo
.
setContractStatus
(
CommonConstants
.
TWO_INT
);
}
//减项成功把人员档案现存项目数减一
if
(
tEmployeeInfo
.
getProjectNum
()
==
CommonConstants
.
ZERO_INT
)
{
//减档
TEmployeeInfo
tEmployeeInfoOld
=
tEmployeeInfoMapper
.
selectById
(
tEmployeeInfo
.
getId
());
tEmployeeInfo
.
setFileStatus
(
CommonConstants
.
dingleDigitIntArray
[
1
]);
tEmployeeInfo
.
setLeaveRemark
(
tEmployeeProject
.
getLeaveRemark
());
tEmployeeInfo
.
setLeaveTime
(
DateUtil
.
getCurrentDateTime
());
tEmployeeInfo
.
setLeaveUser
(
user
.
getId
());
tEmployeeInfo
.
setLeaveUserName
(
user
.
getNickname
());
tEmployeeLogService
.
saveModificationRecord
(
CommonConstants
.
dingleDigitIntArray
[
0
],
tEmployeeInfo
.
getId
(),
""
,
tEmployeeInfoOld
,
tEmployeeInfo
);
workInfo
.
append
(
"减档成功,"
);
tEmployeeInfoMapper
.
updateById
(
tEmployeeInfo
);
}
else
{
failueInfo
.
append
(
"存在其他项目,无法减档"
);
}
tEmployeeLogService
.
saveModificationRecord
(
CommonConstants
.
dingleDigitIntArray
[
0
],
tEmployeeInfo
.
getId
(),
""
,
tEmployeeInfoOld
,
tEmployeeInfo
);
tEmployeeInfoMapper
.
updateById
(
tEmployeeInfo
);
}
}
//更新任务处理情况数据
...
...
yifu-archives/yifu-archives-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/archives/service/impl/TEmployeeProjectServiceImpl.java
View file @
99060503
...
...
@@ -1403,23 +1403,26 @@ public class TEmployeeProjectServiceImpl extends ServiceImpl<TEmployeeProjectMap
if
(
Common
.
isNotNull
(
contractInfoList
))
{
for
(
TEmployeeContractInfo
contractInfo1
:
contractInfoList
)
{
contractInfo1
.
setInUse
(
CommonConstants
.
ONE_STRING
);
contractInfo1
.
setAuditUserName
(
vo
.
getUserName
());
contractInfoMapper
.
updateById
(
contractInfo1
);
//增加审核记录
this
.
setAuditInfoNew
(
contractInfo1
,
CommonConstants
.
ZERO_STRING
);
this
.
setAuditInfoNew
(
contractInfo1
);
}
}
//在途的合同更新为审核不通过
contractInfoListZt
=
contractInfoMapper
.
selectList
(
Wrappers
.<
TEmployeeContractInfo
>
query
()
.
lambda
().
eq
(
TEmployeeContractInfo:
:
getEmpIdcard
,
vo
.
getEmpIdCard
())
.
eq
(
TEmployeeContractInfo:
:
getDeptNo
,
vo
.
getDepartNo
())
.
eq
(
TEmployeeContractInfo:
:
getAuditStatus
,
CommonConstants
.
ZERO_INT
)
.
and
(
obj
->
obj
.
eq
(
TEmployeeContractInfo:
:
getAuditStatus
,
CommonConstants
.
ONE_INT
)
.
or
().
eq
(
TEmployeeContractInfo:
:
getAuditStatus
,
CommonConstants
.
ZERO_INT
))
.
eq
(
TEmployeeContractInfo:
:
getDeleteFlag
,
CommonConstants
.
ZERO_INT
));
if
(
Common
.
isNotNull
(
contractInfoListZt
))
{
for
(
TEmployeeContractInfo
contractInfo1
:
contractInfoListZt
)
{
contractInfo1
.
setAuditStatus
(
CommonConstants
.
THREE_INT
);
contractInfo1
.
setAuditUserName
(
vo
.
getUserName
());
contractInfoMapper
.
updateById
(
contractInfo1
);
//增加审核记录
this
.
setAuditInfoNew
(
contractInfo1
,
CommonConstants
.
ONE_STRING
);
this
.
setAuditInfoNew
(
contractInfo1
);
}
}
//项目档案处理
...
...
@@ -1462,12 +1465,12 @@ public class TEmployeeProjectServiceImpl extends ServiceImpl<TEmployeeProjectMap
tEmployeeInfo
.
setLeaveUser
(
vo
.
getUserId
());
tEmployeeInfo
.
setLeaveUserName
(
vo
.
getUserName
());
workInfo
.
append
(
"减档成功,"
);
tEmployeeInfoMapper
.
updateById
(
tEmployeeInfo
);
}
else
{
failueInfo
.
append
(
"存在其他项目,无法减档"
);
}
tEmployeeLogService
.
saveModificationRecord
(
CommonConstants
.
dingleDigitIntArray
[
0
],
tEmployeeInfo
.
getId
(),
""
,
tEmployeeInfoOld
,
tEmployeeInfo
);
tEmployeeInfoMapper
.
updateById
(
tEmployeeInfo
);
}
}
//更新任务处理情况查询表数据
...
...
@@ -1831,11 +1834,9 @@ public class TEmployeeProjectServiceImpl extends ServiceImpl<TEmployeeProjectMap
* @Date: 2023/6/16 10:16
* @return: void
**/
private
void
setAuditInfoNew
(
TEmployeeContractInfo
tEmployeeContractInfo
,
String
flag
)
{
private
void
setAuditInfoNew
(
TEmployeeContractInfo
tEmployeeContractInfo
)
{
TEmployeeContractAudit
audit
=
new
TEmployeeContractAudit
();
audit
.
setRootName
(
"合同审核"
);
audit
.
setAuditStatus
(
CommonConstants
.
ZERO_STRING
.
equals
(
flag
)
?
"审核通过"
:
"审核不通过"
);
audit
.
setRemark
(
"终止合同联动"
);
audit
.
setRootName
(
"社保派减联动减合同"
);
audit
.
setLinkId
(
tEmployeeContractInfo
.
getId
());
audit
.
setLinkType
(
CommonConstants
.
ONE_INT
);
tEmployeeContractAuditService
.
save
(
audit
);
...
...
yifu-archives/yifu-archives-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/archives/service/impl/TPersonnelRosterServiceImpl.java
View file @
99060503
...
...
@@ -16,34 +16,26 @@
*/
package
com
.
yifu
.
cloud
.
plus
.
v1
.
yifu
.
archives
.
service
.
impl
;
import
cn.hutool.core.bean.BeanUtil
;
import
cn.hutool.core.util.ArrayUtil
;
import
com.alibaba.excel.EasyExcel
;
import
com.alibaba.excel.ExcelWriter
;
import
com.alibaba.excel.context.AnalysisContext
;
import
com.alibaba.excel.read.listener.ReadListener
;
import
com.alibaba.excel.read.metadata.holder.ReadRowHolder
;
import
com.alibaba.excel.util.ListUtils
;
import
com.alibaba.excel.write.metadata.WriteSheet
;
import
com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper
;
import
com.baomidou.mybatisplus.core.metadata.IPage
;
import
com.baomidou.mybatisplus.core.toolkit.Wrappers
;
import
com.baomidou.mybatisplus.extension.plugins.pagination.Page
;
import
com.baomidou.mybatisplus.extension.service.impl.ServiceImpl
;
import
com.yifu.cloud.plus.v1.yifu.archives.entity.FddSealPersonAuth
;
import
com.yifu.cloud.plus.v1.yifu.archives.entity.TDepartSettlementInfo
;
import
com.yifu.cloud.plus.v1.yifu.archives.entity.TPersonnelRoster
;
import
com.yifu.cloud.plus.v1.yifu.archives.mapper.TPersonnelRosterMapper
;
import
com.yifu.cloud.plus.v1.yifu.archives.service.TPersonnelRosterService
;
import
com.yifu.cloud.plus.v1.yifu.archives.vo.TPersonnelRosterSearchVo
;
import
com.yifu.cloud.plus.v1.yifu.archives.vo.TPersonnelRosterVo
;
import
com.yifu.cloud.plus.v1.yifu.common.core.constant.CommonConstants
;
import
com.yifu.cloud.plus.v1.yifu.common.core.constant.SecurityConstants
;
import
com.yifu.cloud.plus.v1.yifu.common.core.util.*
;
import
com.yifu.cloud.plus.v1.yifu.common.core.util.Common
;
import
com.yifu.cloud.plus.v1.yifu.common.core.util.DateUtil
;
import
com.yifu.cloud.plus.v1.yifu.common.core.util.ExcelUtil
;
import
com.yifu.cloud.plus.v1.yifu.common.core.util.R
;
import
com.yifu.cloud.plus.v1.yifu.common.dapr.config.DaprArchivesProperties
;
import
com.yifu.cloud.plus.v1.yifu.common.dapr.config.DaprS
ocial
Properties
;
import
com.yifu.cloud.plus.v1.yifu.common.dapr.config.DaprS
alary
Properties
;
import
com.yifu.cloud.plus.v1.yifu.common.dapr.util.HttpDaprUtil
;
import
com.yifu.cloud.plus.v1.yifu.
common.mybatis.base.BaseEntity
;
import
com.yifu.cloud.plus.v1.yifu.
salary.vo.SalaryEmpRosterRes
;
import
com.yifu.cloud.plus.v1.yifu.salary.vo.TSalaryEmpRosterVo
;
import
lombok.AllArgsConstructor
;
import
lombok.extern.log4j.Log4j2
;
...
...
@@ -53,8 +45,8 @@ import org.springframework.stereotype.Service;
import
javax.servlet.ServletOutputStream
;
import
javax.servlet.http.HttpServletResponse
;
import
java.io.IOException
;
import
java.io.InputStream
;
import
java.net.URLEncoder
;
import
java.time.LocalDateTime
;
import
java.util.ArrayList
;
import
java.util.HashMap
;
import
java.util.List
;
...
...
@@ -69,10 +61,11 @@ import java.util.stream.Collectors;
*/
@Log4j2
@AllArgsConstructor
@EnableConfigurationProperties
({
Dapr
Archives
Properties
.
class
})
@EnableConfigurationProperties
({
Dapr
Salary
Properties
.
class
})
@Service
public
class
TPersonnelRosterServiceImpl
extends
ServiceImpl
<
TPersonnelRosterMapper
,
TPersonnelRoster
>
implements
TPersonnelRosterService
{
private
final
DaprArchivesProperties
daprArchivesProperties
;
private
final
DaprSalaryProperties
daprSalaryProperties
;
/**
* 简单分页查询
* @param tPersonnelRoster
...
...
@@ -159,7 +152,7 @@ public class TPersonnelRosterServiceImpl extends ServiceImpl<TPersonnelRosterMap
long
count
=
baseMapper
.
getTPersonnelRosterCount
(
searchVo
);
List
<
TPersonnelRoster
>
list
;
if
(
count
>
CommonConstants
.
ZERO_INT
){
R
<
List
<
TSalaryEmpRosterVo
>
>
res
;
R
<
SalaryEmpRosterRes
>
res
;
Map
<
String
,
TSalaryEmpRosterVo
>
voMap
=
new
HashMap
<>();
TSalaryEmpRosterVo
rosterVo
;
for
(
int
i
=
0
;
i
<=
count
;
)
{
...
...
@@ -168,12 +161,12 @@ public class TPersonnelRosterServiceImpl extends ServiceImpl<TPersonnelRosterMap
list
=
baseMapper
.
getTPersonnelRoster
(
searchVo
);
if
(
Common
.
isNotNull
(
list
)){
// 处理薪资信息
res
=
HttpDaprUtil
.
invokeMethodPost
(
dapr
ArchivesProperties
.
getAppUrl
(),
daprArchives
Properties
.
getAppId
(),
"/tsalaryemployee/
inner/
getSalaryEmpRoster"
,
list
.
stream
()
res
=
HttpDaprUtil
.
invokeMethodPost
(
dapr
SalaryProperties
.
getAppUrl
(),
daprSalary
Properties
.
getAppId
(),
"/tsalaryemployee/getSalaryEmpRoster"
,
list
.
stream
()
.
map
(
TPersonnelRoster:
:
getEmpIdcard
).
collect
(
Collectors
.
toList
()),
TSalaryEmpRosterVo
.
class
,
SecurityConstants
.
FROM_IN
);
if
(
Common
.
isNotNull
(
res
)
&&
Common
.
isNotNull
(
res
.
getData
())
&&
res
.
getData
().
size
()
>
0
){
for
(
TSalaryEmpRosterVo
vo
:
res
.
getData
()){
SalaryEmpRosterRes
.
class
,
SecurityConstants
.
FROM_IN
);
if
(
Common
.
isNotNull
(
res
)
&&
Common
.
isNotNull
(
res
.
getData
())
&&
Common
.
isNotEmpty
(
res
.
getData
().
getRosterVos
())
){
for
(
TSalaryEmpRosterVo
vo
:
res
.
getData
()
.
getRosterVos
()
){
voMap
.
put
(
vo
.
getEmpIdcard
(),
vo
);
}
}
...
...
@@ -187,6 +180,7 @@ public class TPersonnelRosterServiceImpl extends ServiceImpl<TPersonnelRosterMap
r
.
setBankNameSub
(
rosterVo
.
getBankSubName
());
r
.
setBankProvince
(
rosterVo
.
getBankProvince
());
}
r
.
setDataCreateMonth
(
DateUtil
.
getYearAndMonth
(
LocalDateTime
.
now
(),
0
));
}
this
.
saveBatch
(
list
);
}
...
...
yifu-archives/yifu-archives-biz/src/main/resources/mapper/TPersonnelRosterMapper.xml
View file @
99060503
...
...
@@ -240,6 +240,20 @@
AND a.DATA_CREATE_MONTH = #{tPersonnelRoster.dataCreateMonth}
</if>
<if
test=
"tPersonnelRoster.businessTypes != null and tPersonnelRoster.businessTypes.size() > 0"
>
AND a.BUSINESS_TYPE in
<foreach
item=
"item"
index=
"index"
collection=
"tPersonnelRoster.businessTypes"
open=
"("
separator=
","
close=
")"
>
#{item}
</foreach>
</if>
<if
test=
"tPersonnelRoster.buBelongs != null and tPersonnelRoster.buBelongs.size() > 0"
>
AND a.BU_BELONG in
<foreach
item=
"item"
index=
"index"
collection=
"tPersonnelRoster.buBelongs"
open=
"("
separator=
","
close=
")"
>
#{item}
</foreach>
</if>
</if>
</sql>
<!--tPersonnelRoster简单分页查询-->
...
...
@@ -260,7 +274,7 @@
e.EMP_PHONE as 'EMP_PHONE',c1.FILE_PROVINCE as 'EMP_PROVINCE',c1.FILE_CITY as 'EMP_CITY',c1.FILE_TOWN as 'EMP_TOWN',
p.SOCIAL_PROVINCE as 'SOCIAL_PROVINCE',p.SOCIAL_CITY as 'SOCIAL_CITY',p.SOCIAL_TOWN as 'SOCIAL_TOWN',c1.APPLY_NO as 'CONTRACT_APPLY_NO',
c1.CONTRACT_START as 'CONTRACT_START',c1.CONTRACT_END as 'CONTRACT_END',c1.CONTRACT_NAME as 'CONTRACT_TYPE',c1.CONTRACT_SUB_NAME as 'BUSINESS_DETAIL',
c1.SITUATION as 'SIGN_T
ERM',c1.CONTRACT_TYPE as 'SIGN_TYPE
',
c1.SITUATION as 'SIGN_T
YPE',c1.CONTRACT_TYPE as 'SIGN_TERM
',
c1.CONTRACT_PARTY as 'CONTRACT_PARTY_A',c1.POST as 'CONTRACT_POST',c1.WORKING_HOURS as 'CONTRACT_TASK_TIME',
c1.CONTRACT_NO as 'CONTRACT_CODE',c1.CREATE_NAME as 'CONTRACT_CREATER',c1.CREATE_TIME as 'CONTRACT_CREATE_TIME'
from
...
...
@@ -302,7 +316,7 @@
<include
refid=
"Base_Column_List"
/>
from t_personnel_roster a
<where>
a.DELETE_FLAG = '0'
1=1
<include
refid=
"tPersonnelRoster_where"
/>
</where>
order by a.CREATE_TIME desc
...
...
yifu-common/yifu-common-dapr/src/main/resources/daprConfig.properties
View file @
99060503
...
...
@@ -4,16 +4,19 @@ dapr.upms.appId=yifu-upms
#\u6D4B\u8BD5\u73AF\u5883
#dapr.check.appUrl=http://yifu-check.qas-mvp.svc.cluster.local:3500/v1.0/invoke/
#\u6
72C\u5730
#\u6
D4B\u8BD5\u73AF\u5883
dapr.check.appUrl
=
http://yifu-check.qas-mvp.svc.cluster.local:3500/v1.0/invoke/
dapr.check.appId
=
yifu-check
#\u6
72C\u5730
#\u6
D4B\u8BD5\u73AF\u5883
dapr.archives.appUrl
=
http://yifu-archives.qas-mvp.svc.cluster.local:3500/v1.0/invoke/
dapr.archives.appId
=
yifu-archives
#\u6D4B\u8BD5\u73AF\u5883
dapr.salary.appUrl
=
http://yifu-salary.qas-mvp.svc.cluster.local:3500/v1.0/invoke/
dapr.salary.appId
=
yifu-salary
#\u6D4B\u8BD5\u73AF\u5883
dapr.social.appUrl
=
http://yifu-social.qas-mvp.svc.cluster.local:3500/v1.0/invoke/
dapr.social.appId
=
yifu-social
...
...
yifu-job/yifu-job-api/src/main/java/com/yifu/cloud/plus/v1/job/compont/ArchiveTask.java
View file @
99060503
...
...
@@ -60,4 +60,12 @@ public class ArchiveTask {
SecurityConstants
.
FROM_IN
);
log
.
info
(
"-------------每日凌晨1点人员退休提醒-定时任务开始------------"
);
}
public
void
everyMonthUpdateRoster
()
{
log
.
info
(
"-------------每月26号更新人员花名册-定时任务开始------------"
);
HttpDaprUtil
.
invokeMethodPost
(
daprArchivesProperties
.
getAppUrl
(),
daprArchivesProperties
.
getAppId
(),
"/tpersonnelroster/inner/everyMonthUpdateRoster"
,
""
,
Object
.
class
,
SecurityConstants
.
FROM_IN
);
log
.
info
(
"-------------每月26号更新人员花名册-定时任务开始------------"
);
}
}
\ No newline at end of file
yifu-salary/yifu-salary-api/src/main/java/com/yifu/cloud/plus/v1/yifu/salary/vo/SalaryEmpRosterRes.java
0 → 100644
View file @
99060503
package
com
.
yifu
.
cloud
.
plus
.
v1
.
yifu
.
salary
.
vo
;
import
lombok.Data
;
import
java.io.Serializable
;
import
java.util.List
;
/**
* @Author fxj
* @Date 2023/6/26
* @Description
* @Version 1.0
*/
@Data
public
class
SalaryEmpRosterRes
implements
Serializable
{
private
List
<
TSalaryEmpRosterVo
>
rosterVos
;
}
yifu-salary/yifu-salary-api/src/main/java/com/yifu/cloud/plus/v1/yifu/salary/vo/TSalaryEmpRosterVo.java
View file @
99060503
...
...
@@ -8,6 +8,7 @@ import lombok.Data;
import
org.hibernate.validator.constraints.Length
;
import
javax.validation.constraints.NotBlank
;
import
java.io.Serializable
;
/**
* @Author fxj
...
...
@@ -17,54 +18,32 @@ import javax.validation.constraints.NotBlank;
* @return
**/
@Data
public
class
TSalaryEmpRosterVo
{
public
class
TSalaryEmpRosterVo
implements
Serializable
{
/**
* 身份证号
*/
@ExcelAttribute
(
name
=
"身份证号"
,
isNotEmpty
=
true
,
errorInfo
=
"身份证号不能为空"
,
maxLength
=
32
)
@NotBlank
(
message
=
"身份证号不能为空"
)
@Length
(
max
=
32
,
message
=
"身份证号不能超过32个字符"
)
@HeadFontStyle
(
fontHeightInPoints
=
11
)
@ExcelProperty
(
"身份证号"
)
private
String
empIdcard
;
/**
* 开户行总行
*/
@ExcelAttribute
(
name
=
"开户行总行"
,
maxLength
=
50
)
@Length
(
max
=
50
,
message
=
"开户行总行不能超过50个字符"
)
@HeadFontStyle
(
fontHeightInPoints
=
11
)
@ExcelProperty
(
"开户行总行"
)
private
String
bankName
;
/**
* 开户行省
*/
@ExcelAttribute
(
name
=
"开户行省"
,
isArea
=
true
)
@HeadFontStyle
(
fontHeightInPoints
=
11
)
@ExcelProperty
(
"开户行省"
)
private
String
bankProvince
;
/**
* 开户行市
*/
@ExcelAttribute
(
name
=
"开户行市"
,
isArea
=
true
,
parentField
=
"bankProvince"
)
@HeadFontStyle
(
fontHeightInPoints
=
11
)
@ExcelProperty
(
"开户行市"
)
private
String
bankCity
;
/**
* 开户行支行
*/
@ExcelAttribute
(
name
=
"开户行支行"
,
maxLength
=
50
)
@Length
(
max
=
50
,
message
=
"开户行支行不能超过50个字符"
)
@HeadFontStyle
(
fontHeightInPoints
=
11
)
@ExcelProperty
(
"开户行支行"
)
private
String
bankSubName
;
/**
* 银行卡号
*/
@ExcelAttribute
(
name
=
"银行卡号"
,
maxLength
=
50
)
@Length
(
max
=
50
,
message
=
"银行卡号不能超过50个字符"
)
@HeadFontStyle
(
fontHeightInPoints
=
11
)
@ExcelProperty
(
"银行卡号"
)
private
String
bankNo
;
}
yifu-salary/yifu-salary-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/salary/controller/TConfigSalaryController.java
View file @
99060503
...
...
@@ -74,7 +74,7 @@ public class TConfigSalaryController {
// 当前年 未推送或未发放的 发薪次数
int
yearCount
=
tSalaryStandardService
.
getNum
(
settleDepart
,
null
,
nowYear
);
for
(
TConfigSalary
cs
:
configSalaryList
)
{
if
(
cs
.
getSalaryNum
()
<
monthCount
)
{
if
(
cs
.
getSalaryNum
()
<
=
monthCount
)
{
cs
.
setNowMonthSalaryNum
(
monthCount
);
}
cs
.
setNowYearSalaryNum
(
yearCount
);
...
...
yifu-salary/yifu-salary-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/salary/controller/TSalaryEmployeeController.java
View file @
99060503
...
...
@@ -217,8 +217,10 @@ public class TSalaryEmployeeController {
**/
@Operation
(
summary
=
"获取员工花名册信息信息"
,
description
=
"获取员工花名册信息信息"
)
@Inner
@PostMapping
(
"/inner/getSalaryEmpRoster"
)
public
List
<
TSalaryEmpRosterVo
>
getSalaryEmpRoster
(
@RequestBody
List
<
String
>
idCardList
)
{
return
tSalaryEmployeeService
.
getSalaryEmpRoster
(
idCardList
);
@PostMapping
(
"/getSalaryEmpRoster"
)
public
SalaryEmpRosterRes
getSalaryEmpRoster
(
@RequestBody
List
<
String
>
idCardList
)
{
SalaryEmpRosterRes
res
=
new
SalaryEmpRosterRes
();
res
.
setRosterVos
(
tSalaryEmployeeService
.
getSalaryEmpRoster
(
idCardList
));
return
res
;
}
}
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment