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
1d71c3c2
Commit
1d71c3c2
authored
Aug 09, 2022
by
zhaji
Browse files
Options
Browse Files
Download
Plain Diff
Merge branch 'develop' into feature-zhaji
parents
645db83a
5ef31dc8
Hide whitespace changes
Inline
Side-by-side
Showing
8 changed files
with
88 additions
and
60 deletions
+88
-60
TApprovalRecord.java
...ifu/cloud/plus/v1/yifu/salary/entity/TApprovalRecord.java
+3
-4
TSalaryStandardServiceImpl.java
.../yifu/salary/service/impl/TSalaryStandardServiceImpl.java
+22
-2
TPaymentHeFeiVo.java
...om/yifu/cloud/plus/v1/yifu/social/vo/TPaymentHeFeiVo.java
+2
-2
TPaymentInfoVo.java
...com/yifu/cloud/plus/v1/yifu/social/vo/TPaymentInfoVo.java
+13
-4
TPaymentInfoImportLogController.java
...fu/social/controller/TPaymentInfoImportLogController.java
+3
-9
TPaymentInfoServiceImpl.java
.../v1/yifu/social/service/impl/TPaymentInfoServiceImpl.java
+23
-15
TPreDispatchInfoServiceImpl.java
...yifu/social/service/impl/TPreDispatchInfoServiceImpl.java
+18
-21
TPaymentInfoMapper.xml
...cial-biz/src/main/resources/mapper/TPaymentInfoMapper.xml
+4
-3
No files found.
yifu-salary/yifu-salary-api/src/main/java/com/yifu/cloud/plus/v1/yifu/salary/entity/TApprovalRecord.java
View file @
1d71c3c2
...
@@ -39,9 +39,9 @@ import java.util.Date;
...
@@ -39,9 +39,9 @@ import java.util.Date;
*/
*/
@Data
@Data
@TableName
(
"t_approval_record"
)
@TableName
(
"t_approval_record"
)
@EqualsAndHashCode
(
callSuper
=
true
)
@EqualsAndHashCode
()
@Schema
(
description
=
"审批记录表"
)
@Schema
(
description
=
"审批记录表"
)
public
class
TApprovalRecord
extends
BaseEntity
{
public
class
TApprovalRecord
{
/**
/**
* 主键
* 主键
...
@@ -60,8 +60,7 @@ public class TApprovalRecord extends BaseEntity {
...
@@ -60,8 +60,7 @@ public class TApprovalRecord extends BaseEntity {
/**
/**
* 节点id
* 节点id
*/
*/
@ExcelAttribute
(
name
=
"节点id"
,
isNotEmpty
=
true
,
errorInfo
=
"节点id不能为空"
,
maxLength
=
32
)
@ExcelAttribute
(
name
=
"节点id"
,
maxLength
=
32
)
@NotBlank
(
message
=
"节点id不能为空"
)
@Length
(
max
=
32
,
message
=
"节点id不能超过32个字符"
)
@Length
(
max
=
32
,
message
=
"节点id不能超过32个字符"
)
@ExcelProperty
(
"节点id"
)
@ExcelProperty
(
"节点id"
)
private
String
nodeId
;
private
String
nodeId
;
...
...
yifu-salary/yifu-salary-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/salary/service/impl/TSalaryStandardServiceImpl.java
View file @
1d71c3c2
...
@@ -17,7 +17,6 @@
...
@@ -17,7 +17,6 @@
package
com
.
yifu
.
cloud
.
plus
.
v1
.
yifu
.
salary
.
service
.
impl
;
package
com
.
yifu
.
cloud
.
plus
.
v1
.
yifu
.
salary
.
service
.
impl
;
import
cn.hutool.core.bean.BeanUtil
;
import
cn.hutool.core.bean.BeanUtil
;
import
cn.hutool.core.util.ArrayUtil
;
import
com.alibaba.excel.EasyExcel
;
import
com.alibaba.excel.EasyExcel
;
import
com.alibaba.excel.ExcelWriter
;
import
com.alibaba.excel.ExcelWriter
;
import
com.alibaba.excel.context.AnalysisContext
;
import
com.alibaba.excel.context.AnalysisContext
;
...
@@ -32,13 +31,16 @@ import com.yifu.cloud.plus.v1.yifu.common.core.constant.CommonConstants;
...
@@ -32,13 +31,16 @@ import com.yifu.cloud.plus.v1.yifu.common.core.constant.CommonConstants;
import
com.yifu.cloud.plus.v1.yifu.common.core.util.*
;
import
com.yifu.cloud.plus.v1.yifu.common.core.util.*
;
import
com.yifu.cloud.plus.v1.yifu.common.core.vo.YifuUser
;
import
com.yifu.cloud.plus.v1.yifu.common.core.vo.YifuUser
;
import
com.yifu.cloud.plus.v1.yifu.common.security.util.SecurityUtils
;
import
com.yifu.cloud.plus.v1.yifu.common.security.util.SecurityUtils
;
import
com.yifu.cloud.plus.v1.yifu.salary.entity.TApprovalRecord
;
import
com.yifu.cloud.plus.v1.yifu.salary.entity.TSalaryStandard
;
import
com.yifu.cloud.plus.v1.yifu.salary.entity.TSalaryStandard
;
import
com.yifu.cloud.plus.v1.yifu.salary.mapper.TSalaryStandardMapper
;
import
com.yifu.cloud.plus.v1.yifu.salary.mapper.TSalaryStandardMapper
;
import
com.yifu.cloud.plus.v1.yifu.salary.service.TApprovalRecordService
;
import
com.yifu.cloud.plus.v1.yifu.salary.service.TSalaryStandardService
;
import
com.yifu.cloud.plus.v1.yifu.salary.service.TSalaryStandardService
;
import
com.yifu.cloud.plus.v1.yifu.salary.vo.TSalaryStandardExportVo
;
import
com.yifu.cloud.plus.v1.yifu.salary.vo.TSalaryStandardExportVo
;
import
com.yifu.cloud.plus.v1.yifu.salary.vo.TSalaryStandardSearchVo
;
import
com.yifu.cloud.plus.v1.yifu.salary.vo.TSalaryStandardSearchVo
;
import
com.yifu.cloud.plus.v1.yifu.salary.vo.TSalaryStandardVo
;
import
com.yifu.cloud.plus.v1.yifu.salary.vo.TSalaryStandardVo
;
import
lombok.extern.log4j.Log4j2
;
import
lombok.extern.log4j.Log4j2
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.stereotype.Service
;
import
org.springframework.stereotype.Service
;
import
javax.servlet.ServletOutputStream
;
import
javax.servlet.ServletOutputStream
;
...
@@ -58,6 +60,10 @@ import java.util.List;
...
@@ -58,6 +60,10 @@ import java.util.List;
@Log4j2
@Log4j2
@Service
@Service
public
class
TSalaryStandardServiceImpl
extends
ServiceImpl
<
TSalaryStandardMapper
,
TSalaryStandard
>
implements
TSalaryStandardService
{
public
class
TSalaryStandardServiceImpl
extends
ServiceImpl
<
TSalaryStandardMapper
,
TSalaryStandard
>
implements
TSalaryStandardService
{
@Autowired
private
TApprovalRecordService
approvalRecordService
;
/**
/**
* 标准薪酬工资表简单分页查询
* 标准薪酬工资表简单分页查询
*
*
...
@@ -234,15 +240,29 @@ public class TSalaryStandardServiceImpl extends ServiceImpl<TSalaryStandardMappe
...
@@ -234,15 +240,29 @@ public class TSalaryStandardServiceImpl extends ServiceImpl<TSalaryStandardMappe
YifuUser
user
=
SecurityUtils
.
getUser
();
YifuUser
user
=
SecurityUtils
.
getUser
();
TSalaryStandard
tSalaryStandard
=
baseMapper
.
selectById
(
id
);
TSalaryStandard
tSalaryStandard
=
baseMapper
.
selectById
(
id
);
if
(
Common
.
isNotNull
(
tSalaryStandard
))
{
if
(
Common
.
isNotNull
(
tSalaryStandard
))
{
//新增流程进展明细
TApprovalRecord
tApprovalRecord
=
new
TApprovalRecord
();
if
(
CommonConstants
.
ZERO_STRING
.
equals
(
auditFlag
))
{
if
(
CommonConstants
.
ZERO_STRING
.
equals
(
auditFlag
))
{
tSalaryStandard
.
setStatus
(
CommonConstants
.
TWO_INT
);
tSalaryStandard
.
setStatus
(
CommonConstants
.
TWO_INT
);
tApprovalRecord
.
setApprovalResult
(
CommonConstants
.
ZERO_STRING
);
}
else
{
}
else
{
tSalaryStandard
.
setStatus
(
CommonConstants
.
FIVE_INT
);
tSalaryStandard
.
setStatus
(
CommonConstants
.
FIVE_INT
);
tApprovalRecord
.
setApprovalResult
(
CommonConstants
.
ONE_STRING
);
}
if
(
Common
.
isNotNull
(
auditRemark
))
{
tSalaryStandard
.
setRemark
(
auditRemark
);
tApprovalRecord
.
setApprovalOpinion
(
auditRemark
);
}
}
tSalaryStandard
.
setRemark
(
auditRemark
);
tSalaryStandard
.
setAuditUser
(
user
.
getId
());
tSalaryStandard
.
setAuditUser
(
user
.
getId
());
tSalaryStandard
.
setAuditTime
(
DateUtil
.
getCurrentDateTime
());
tSalaryStandard
.
setAuditTime
(
DateUtil
.
getCurrentDateTime
());
baseMapper
.
updateById
(
tSalaryStandard
);
baseMapper
.
updateById
(
tSalaryStandard
);
tApprovalRecord
.
setSalaryId
(
tSalaryStandard
.
getId
());
tApprovalRecord
.
setApprovalMan
(
user
.
getId
());
tApprovalRecord
.
setApprovalManName
(
user
.
getNickname
());
tApprovalRecord
.
setApprovalTime
(
DateUtil
.
getCurrentDateTime
());
approvalRecordService
.
save
(
tApprovalRecord
);
}
}
return
R
.
ok
();
return
R
.
ok
();
...
...
yifu-social/yifu-social-api/src/main/java/com/yifu/cloud/plus/v1/yifu/social/vo/TPaymentHeFeiVo.java
View file @
1d71c3c2
...
@@ -95,7 +95,7 @@ public class TPaymentHeFeiVo extends RowIndex implements Serializable {
...
@@ -95,7 +95,7 @@ public class TPaymentHeFeiVo extends RowIndex implements Serializable {
* 社保缴纳月份empNo
* 社保缴纳月份empNo
*/
*/
@Length
(
max
=
6
,
message
=
"社保缴纳月份不能超过6个字符"
)
@Length
(
max
=
6
,
message
=
"社保缴纳月份不能超过6个字符"
)
@ExcelAttribute
(
name
=
"社保缴纳月份"
,
isNotEmpty
=
true
,
errorInfo
=
"社保缴纳月份不可为空"
,
maxLength
=
6
)
@ExcelAttribute
(
name
=
"社保缴纳月份"
,
isNotEmpty
=
true
,
errorInfo
=
"社保缴纳月份不可为空"
,
maxLength
=
6
,
isInteger
=
true
)
@Schema
(
description
=
"社保缴纳月份"
)
@Schema
(
description
=
"社保缴纳月份"
)
@ExcelProperty
(
"社保缴纳月份"
)
@ExcelProperty
(
"社保缴纳月份"
)
private
String
socialPayMonth
;
private
String
socialPayMonth
;
...
@@ -103,7 +103,7 @@ public class TPaymentHeFeiVo extends RowIndex implements Serializable {
...
@@ -103,7 +103,7 @@ public class TPaymentHeFeiVo extends RowIndex implements Serializable {
* 社保生成月份
* 社保生成月份
*/
*/
@Length
(
max
=
6
,
message
=
"社保生成月份不能超过6个字符"
)
@Length
(
max
=
6
,
message
=
"社保生成月份不能超过6个字符"
)
@ExcelAttribute
(
name
=
"社保生成月份"
,
isNotEmpty
=
true
,
errorInfo
=
"社保生成月份不可为空"
,
maxLength
=
6
)
@ExcelAttribute
(
name
=
"社保生成月份"
,
isNotEmpty
=
true
,
errorInfo
=
"社保生成月份不可为空"
,
maxLength
=
6
,
isInteger
=
true
)
@Schema
(
description
=
"社保生成月份"
)
@Schema
(
description
=
"社保生成月份"
)
@ExcelProperty
(
"社保生成月份"
)
@ExcelProperty
(
"社保生成月份"
)
private
String
socialCreateMonth
;
private
String
socialCreateMonth
;
...
...
yifu-social/yifu-social-api/src/main/java/com/yifu/cloud/plus/v1/yifu/social/vo/TPaymentInfoVo.java
View file @
1d71c3c2
...
@@ -38,6 +38,15 @@ import java.util.Date;
...
@@ -38,6 +38,15 @@ import java.util.Date;
@Data
@Data
public
class
TPaymentInfoVo
extends
RowIndex
implements
Serializable
{
public
class
TPaymentInfoVo
extends
RowIndex
implements
Serializable
{
/**
* 主键
*/
@TableId
(
type
=
IdType
.
ASSIGN_ID
)
@Length
(
max
=
32
,
message
=
"主键 不能超过32 个字符"
)
@ExcelAttribute
(
name
=
"主键"
,
maxLength
=
32
)
@Schema
(
description
=
"主键"
)
@ExcelProperty
(
"主键"
)
private
String
id
;
/**
/**
* 员工姓名
* 员工姓名
*/
*/
...
@@ -115,7 +124,7 @@ public class TPaymentInfoVo extends RowIndex implements Serializable {
...
@@ -115,7 +124,7 @@ public class TPaymentInfoVo extends RowIndex implements Serializable {
* 社保缴纳月份
* 社保缴纳月份
*/
*/
@Length
(
max
=
6
,
message
=
"社保缴纳月份 不能超过6 个字符"
)
@Length
(
max
=
6
,
message
=
"社保缴纳月份 不能超过6 个字符"
)
@ExcelAttribute
(
name
=
"社保缴纳月份"
,
maxLength
=
6
)
@ExcelAttribute
(
name
=
"社保缴纳月份"
,
maxLength
=
6
,
isInteger
=
true
)
@Schema
(
description
=
"社保缴纳月份"
)
@Schema
(
description
=
"社保缴纳月份"
)
@ExcelProperty
(
"社保缴纳月份"
)
@ExcelProperty
(
"社保缴纳月份"
)
private
String
socialPayMonth
;
private
String
socialPayMonth
;
...
@@ -123,7 +132,7 @@ public class TPaymentInfoVo extends RowIndex implements Serializable {
...
@@ -123,7 +132,7 @@ public class TPaymentInfoVo extends RowIndex implements Serializable {
* 社保生成月份
* 社保生成月份
*/
*/
@Length
(
max
=
6
,
message
=
"社保生成月份 不能超过6 个字符"
)
@Length
(
max
=
6
,
message
=
"社保生成月份 不能超过6 个字符"
)
@ExcelAttribute
(
name
=
"社保生成月份"
,
maxLength
=
6
)
@ExcelAttribute
(
name
=
"社保生成月份"
,
maxLength
=
6
,
isInteger
=
true
)
@Schema
(
description
=
"社保生成月份"
)
@Schema
(
description
=
"社保生成月份"
)
@ExcelProperty
(
"社保生成月份"
)
@ExcelProperty
(
"社保生成月份"
)
private
String
socialCreateMonth
;
private
String
socialCreateMonth
;
...
@@ -146,7 +155,7 @@ public class TPaymentInfoVo extends RowIndex implements Serializable {
...
@@ -146,7 +155,7 @@ public class TPaymentInfoVo extends RowIndex implements Serializable {
* 公积金缴纳月份
* 公积金缴纳月份
*/
*/
@Length
(
max
=
6
,
message
=
"公积金缴纳月份 不能超过6 个字符"
)
@Length
(
max
=
6
,
message
=
"公积金缴纳月份 不能超过6 个字符"
)
@ExcelAttribute
(
name
=
"公积金缴纳月份"
,
maxLength
=
6
)
@ExcelAttribute
(
name
=
"公积金缴纳月份"
,
maxLength
=
6
,
isInteger
=
true
)
@Schema
(
description
=
"公积金缴纳月份"
)
@Schema
(
description
=
"公积金缴纳月份"
)
@ExcelProperty
(
"公积金缴纳月份"
)
@ExcelProperty
(
"公积金缴纳月份"
)
private
String
providentPayMonth
;
private
String
providentPayMonth
;
...
@@ -154,7 +163,7 @@ public class TPaymentInfoVo extends RowIndex implements Serializable {
...
@@ -154,7 +163,7 @@ public class TPaymentInfoVo extends RowIndex implements Serializable {
* 公积金生成月份
* 公积金生成月份
*/
*/
@Length
(
max
=
6
,
message
=
"公积金生成月份 不能超过6 个字符"
)
@Length
(
max
=
6
,
message
=
"公积金生成月份 不能超过6 个字符"
)
@ExcelAttribute
(
name
=
"公积金生成月份"
,
maxLength
=
6
)
@ExcelAttribute
(
name
=
"公积金生成月份"
,
maxLength
=
6
,
isInteger
=
true
)
@Schema
(
description
=
"公积金生成月份"
)
@Schema
(
description
=
"公积金生成月份"
)
@ExcelProperty
(
"公积金生成月份"
)
@ExcelProperty
(
"公积金生成月份"
)
private
String
providentCreateMonth
;
private
String
providentCreateMonth
;
...
...
yifu-social/yifu-social-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/social/controller/TPaymentInfoImportLogController.java
View file @
1d71c3c2
...
@@ -19,14 +19,12 @@ package com.yifu.cloud.plus.v1.yifu.social.controller;
...
@@ -19,14 +19,12 @@ package com.yifu.cloud.plus.v1.yifu.social.controller;
import
com.baomidou.mybatisplus.core.conditions.query.QueryWrapper
;
import
com.baomidou.mybatisplus.core.conditions.query.QueryWrapper
;
import
com.yifu.cloud.plus.v1.yifu.common.core.constant.CommonConstants
;
import
com.yifu.cloud.plus.v1.yifu.common.core.constant.CommonConstants
;
import
com.yifu.cloud.plus.v1.yifu.common.core.util.Common
;
import
com.yifu.cloud.plus.v1.yifu.common.core.util.R
;
import
com.yifu.cloud.plus.v1.yifu.common.core.util.R
;
import
com.yifu.cloud.plus.v1.yifu.common.core.util.RedisUtil
;
import
com.yifu.cloud.plus.v1.yifu.common.core.util.RedisUtil
;
import
com.yifu.cloud.plus.v1.yifu.common.core.vo.YifuUser
;
import
com.yifu.cloud.plus.v1.yifu.common.core.vo.YifuUser
;
import
com.yifu.cloud.plus.v1.yifu.common.security.annotation.Inner
;
import
com.yifu.cloud.plus.v1.yifu.common.security.annotation.Inner
;
import
com.yifu.cloud.plus.v1.yifu.common.security.util.SecurityUtils
;
import
com.yifu.cloud.plus.v1.yifu.common.security.util.SecurityUtils
;
import
com.yifu.cloud.plus.v1.yifu.social.service.TPaymentInfoImportLogService
;
import
com.yifu.cloud.plus.v1.yifu.social.service.TPaymentInfoImportLogService
;
import
com.yifu.cloud.plus.v1.yifu.social.util.ServiceUtil
;
import
org.apache.commons.lang.StringUtils
;
import
org.apache.commons.lang.StringUtils
;
import
io.swagger.v3.oas.annotations.Operation
;
import
io.swagger.v3.oas.annotations.Operation
;
import
io.swagger.v3.oas.annotations.security.SecurityRequirement
;
import
io.swagger.v3.oas.annotations.security.SecurityRequirement
;
...
@@ -57,20 +55,16 @@ public class TPaymentInfoImportLogController {
...
@@ -57,20 +55,16 @@ public class TPaymentInfoImportLogController {
@Operation
(
description
=
"导出社保导入日志"
)
@Operation
(
description
=
"导出社保导入日志"
)
@GetMapping
(
"/exportPaymentInfoLog"
)
@GetMapping
(
"/exportPaymentInfoLog"
)
public
void
exportPaymentInfoLog
(
HttpServletResponse
response
)
{
public
String
exportPaymentInfoLog
(
HttpServletResponse
response
)
{
YifuUser
user
=
SecurityUtils
.
getUser
();
YifuUser
user
=
SecurityUtils
.
getUser
();
String
key
=
user
.
getId
()
+
CommonConstants
.
DOWN_LINE_STRING
+
CommonConstants
.
PAYMENT_SOCIAL_WAIT_EXPORT
;
String
key
=
user
.
getId
()
+
CommonConstants
.
DOWN_LINE_STRING
+
CommonConstants
.
PAYMENT_SOCIAL_WAIT_EXPORT
;
String
importRandom
=
(
String
)
redisUtil
.
get
(
key
);
String
importRandom
=
(
String
)
redisUtil
.
get
(
key
);
if
(
StringUtils
.
isBlank
(
importRandom
))
{
if
(
StringUtils
.
isBlank
(
importRandom
))
{
ServiceUtil
.
runTimeExceptionDiy
(
"当前社保数据还未导入完成或者数据不存在"
);
return
importRandom
;
}
String
res
=
tPaymentInfoImportLogService
.
exportPaymentInfoLog
(
response
,
importRandom
);
if
(
Common
.
isNotNull
(
res
)){
ServiceUtil
.
runTimeExceptionDiy
(
res
);
}
}
return
null
;
}
}
/**
/**
* @description: 清空社保导入日志表
* @description: 清空社保导入日志表
* @return: com.yifu.cloud.v1.common.core.util.R<java.lang.Void>
* @return: com.yifu.cloud.v1.common.core.util.R<java.lang.Void>
...
...
yifu-social/yifu-social-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/social/service/impl/TPaymentInfoServiceImpl.java
View file @
1d71c3c2
...
@@ -54,6 +54,7 @@ import com.yifu.cloud.plus.v1.yifu.common.core.util.R;
...
@@ -54,6 +54,7 @@ import com.yifu.cloud.plus.v1.yifu.common.core.util.R;
import
javax.servlet.http.HttpServletResponse
;
import
javax.servlet.http.HttpServletResponse
;
import
java.io.InputStream
;
import
java.io.InputStream
;
import
java.math.BigDecimal
;
import
java.math.BigDecimal
;
import
java.text.DecimalFormat
;
import
java.util.*
;
import
java.util.*
;
import
com.alibaba.excel.EasyExcel
;
import
com.alibaba.excel.EasyExcel
;
...
@@ -497,7 +498,7 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
...
@@ -497,7 +498,7 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
// 处理第一个0位元素
// 处理第一个0位元素
final
List
<
TPaymentInfoVo
>
finalList
=
list
.
subList
(
0
,
1
);
final
List
<
TPaymentInfoVo
>
finalList
=
list
.
subList
(
0
,
1
);
CompletableFuture
<
List
<
ErrorMessage
>>
listCompletableFuture
=
CompletableFuture
.
supplyAsync
(()
->
CompletableFuture
<
List
<
ErrorMessage
>>
listCompletableFuture
=
CompletableFuture
.
supplyAsync
(()
->
executeImportSocialList
(
user
,
atomicLine
,
random
,
l
ist
,
areaMap
,
areaMap2
,
executeImportSocialList
(
user
,
atomicLine
,
random
,
finalL
ist
,
areaMap
,
areaMap2
,
paymentInfoPensionMap
,
paymentInfoBigMap
,
paymentInfoBirMap
,
paymentInfoPensionMap
,
paymentInfoBigMap
,
paymentInfoBirMap
,
paymentInfoMedicalMap
,
paymentInfoUnEmpMap
,
paymentInfoInjuryMap
,
paymentInfoMedicalMap
,
paymentInfoUnEmpMap
,
paymentInfoInjuryMap
,
CommonConstants
.
ONE_INT
,
errorMessageList
),
yfSocialImportThreadPoolExecutor
);
CommonConstants
.
ONE_INT
,
errorMessageList
),
yfSocialImportThreadPoolExecutor
);
...
@@ -512,7 +513,7 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
...
@@ -512,7 +513,7 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
List
<
TPaymentInfoVo
>
finalTempList
=
tempList
;
List
<
TPaymentInfoVo
>
finalTempList
=
tempList
;
final
int
idx
=
i
-
partSize
+
2
;
final
int
idx
=
i
-
partSize
+
2
;
CompletableFuture
.
supplyAsync
(()
->
CompletableFuture
.
supplyAsync
(()
->
executeImportSocialList
(
user
,
atomicLine
,
random
,
l
ist
,
areaMap
,
areaMap2
,
executeImportSocialList
(
user
,
atomicLine
,
random
,
finalTempL
ist
,
areaMap
,
areaMap2
,
paymentInfoPensionMap
,
paymentInfoBigMap
,
paymentInfoBirMap
,
paymentInfoPensionMap
,
paymentInfoBigMap
,
paymentInfoBirMap
,
paymentInfoMedicalMap
,
paymentInfoUnEmpMap
,
paymentInfoInjuryMap
,
paymentInfoMedicalMap
,
paymentInfoUnEmpMap
,
paymentInfoInjuryMap
,
idx
,
errorMessageList
),
yfSocialImportThreadPoolExecutor
);
idx
,
errorMessageList
),
yfSocialImportThreadPoolExecutor
);
...
@@ -538,7 +539,7 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
...
@@ -538,7 +539,7 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
List
<
TPaymentInfoVo
>
finalTempList
=
tempList
;
List
<
TPaymentInfoVo
>
finalTempList
=
tempList
;
int
finalLastIdx
=
lastIdx
+
1
;
int
finalLastIdx
=
lastIdx
+
1
;
CompletableFuture
<
List
<
ErrorMessage
>>
listCompletableFuture
=
CompletableFuture
.
supplyAsync
(()
->
CompletableFuture
<
List
<
ErrorMessage
>>
listCompletableFuture
=
CompletableFuture
.
supplyAsync
(()
->
executeImportSocialList
(
user
,
atomicLine
,
random
,
l
ist
,
areaMap
,
areaMap2
,
executeImportSocialList
(
user
,
atomicLine
,
random
,
finalTempL
ist
,
areaMap
,
areaMap2
,
paymentInfoPensionMap
,
paymentInfoBigMap
,
paymentInfoBirMap
,
paymentInfoPensionMap
,
paymentInfoBigMap
,
paymentInfoBirMap
,
paymentInfoMedicalMap
,
paymentInfoUnEmpMap
,
paymentInfoInjuryMap
,
paymentInfoMedicalMap
,
paymentInfoUnEmpMap
,
paymentInfoInjuryMap
,
finalLastIdx
,
errorMessageList
),
yfSocialImportThreadPoolExecutor
);
finalLastIdx
,
errorMessageList
),
yfSocialImportThreadPoolExecutor
);
...
@@ -557,7 +558,9 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
...
@@ -557,7 +558,9 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
}
while
(
computeFlag
);
}
while
(
computeFlag
);
String
importSuccessKey
=
user
.
getId
()
+
CommonConstants
.
DOWN_LINE_STRING
+
CommonConstants
.
PAYMENT_SOCIAL_WAIT_EXPORT
;
String
importSuccessKey
=
user
.
getId
()
+
CommonConstants
.
DOWN_LINE_STRING
+
CommonConstants
.
PAYMENT_SOCIAL_WAIT_EXPORT
;
redisUtil
.
set
(
importSuccessKey
,
random
,
1800L
);
DecimalFormat
df
=
new
DecimalFormat
(
"0.00000"
);
String
maerialRatio
=
df
.
format
((
float
)
atomicLine
.
get
()/
list
.
size
());
redisUtil
.
set
(
importSuccessKey
,
maerialRatio
,
1800L
);
}
catch
(
Exception
e
)
{
}
catch
(
Exception
e
)
{
log
.
error
(
"社保缴费库数据批量导入异常:"
+
e
);
log
.
error
(
"社保缴费库数据批量导入异常:"
+
e
);
...
@@ -1021,6 +1024,8 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
...
@@ -1021,6 +1024,8 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
paymentInfo
.
setSocialSum
(
BigDecimalUtils
.
safeAdd
(
paymentInfo
.
setSocialSum
(
BigDecimalUtils
.
safeAdd
(
paymentInfo
.
getUnitSocialSum
(),
paymentInfo
.
getSocialSecurityPersonalSum
()));
paymentInfo
.
getUnitSocialSum
(),
paymentInfo
.
getSocialSecurityPersonalSum
()));
paymentInfo
.
setSumAll
(
paymentInfo
.
getSocialSum
());
paymentInfo
.
setSumAll
(
paymentInfo
.
getSocialSum
());
paymentInfo
.
setCreateBy
(
user
.
getId
());
paymentInfo
.
setCreateName
(
user
.
getNickname
());
if
(
null
!=
paymentInfo
&&
Common
.
isEmpty
(
paymentInfo
.
getSocialId
()))
{
if
(
null
!=
paymentInfo
&&
Common
.
isEmpty
(
paymentInfo
.
getSocialId
()))
{
paymentInfo
.
setSocialId
(
UUID
.
randomUUID
().
toString
());
paymentInfo
.
setSocialId
(
UUID
.
randomUUID
().
toString
());
}
}
...
@@ -1272,7 +1277,7 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
...
@@ -1272,7 +1277,7 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
AreaVo
areaList
=
areaListR
.
getData
();
AreaVo
areaList
=
areaListR
.
getData
();
if
(
null
!=
areaList
&&
!
areaList
.
getSysAreaList
().
isEmpty
())
{
if
(
null
!=
areaList
&&
!
areaList
.
getSysAreaList
().
isEmpty
())
{
for
(
SysArea
area
:
areaList
.
getSysAreaList
())
{
for
(
SysArea
area
:
areaList
.
getSysAreaList
())
{
areaMap
.
put
(
area
.
getAreaName
(),
Integer
.
toString
(
area
.
getId
()
));
areaMap
.
put
(
Integer
.
toString
(
area
.
getId
()),
area
.
getAreaName
(
));
}
}
}
}
}
}
...
@@ -1376,8 +1381,8 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
...
@@ -1376,8 +1381,8 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
+
CommonConstants
.
DOWN_LINE_STRING
+
"公积金缴纳地不可为空!"
));
+
CommonConstants
.
DOWN_LINE_STRING
+
"公积金缴纳地不可为空!"
));
continue
;
continue
;
}
}
if
(
null
!=
fundMap
||
null
!=
fundMapTemp
)
{
if
(
fundMap
.
size
()
>
CommonConstants
.
ZERO_INT
||
fundMapTemp
.
size
()
>
CommonConstants
.
ZERO_INT
)
{
if
(
null
!=
fundMap
)
{
if
(
fundMap
.
size
()
>
CommonConstants
.
ZERO_INT
)
{
fund
=
(
TProvidentFund
)
fundMap
.
get
(
infoVo
.
getEmpIdcard
());
fund
=
(
TProvidentFund
)
fundMap
.
get
(
infoVo
.
getEmpIdcard
());
//对身份证与人员姓名的对应关系进行校验
//对身份证与人员姓名的对应关系进行校验
if
(
null
!=
fund
&&
!
fund
.
getEmpName
().
equals
(
infoVo
.
getEmpName
()))
{
if
(
null
!=
fund
&&
!
fund
.
getEmpName
().
equals
(
infoVo
.
getEmpName
()))
{
...
@@ -1387,10 +1392,10 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
...
@@ -1387,10 +1392,10 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
}
}
}
}
areaArray
=
infoVo
.
getProvidentPayAddr
().
split
(
CommonConstants
.
CENTER_SPLIT_LINE_STRING
);
areaArray
=
infoVo
.
getProvidentPayAddr
().
split
(
CommonConstants
.
CENTER_SPLIT_LINE_STRING
);
fund
=
checkAddress
(
areaArray
,
areaMap
,
fund
);
fund
=
checkAddress
(
areaArray
,
areaMap
,
fund
);
if
(
null
==
fund
||
(
null
!=
fund
&&
!
ServiceUtil
.
checkMothForPaymentImport
(
if
(
null
==
fund
||
(
null
!=
fund
&&
!
ServiceUtil
.
checkMothForPaymentImport
(
fund
.
getProvidentStart
(),
infoVo
.
getProvidentPayMonth
(),
fund
.
getFundReduceDate
())))
{
fund
.
getProvidentStart
(),
infoVo
.
getProvidentPayMonth
(),
fund
.
getFundReduceDate
())))
{
if
(
null
!=
fundMapTemp
)
{
if
(
fundMapTemp
.
size
()
>
CommonConstants
.
ZERO_INT
)
{
fund
=
(
TProvidentFund
)
fundMapTemp
.
get
(
infoVo
.
getEmpIdcard
());
fund
=
(
TProvidentFund
)
fundMapTemp
.
get
(
infoVo
.
getEmpIdcard
());
//对身份证与人员姓名的对应关系进行校验
//对身份证与人员姓名的对应关系进行校验
if
(
null
!=
fund
&&
!
fund
.
getEmpName
().
equals
(
infoVo
.
getEmpName
()))
{
if
(
null
!=
fund
&&
!
fund
.
getEmpName
().
equals
(
infoVo
.
getEmpName
()))
{
...
@@ -1406,7 +1411,7 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
...
@@ -1406,7 +1411,7 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
for
(
TProvidentFund
f
:
fundListTemp
)
{
for
(
TProvidentFund
f
:
fundListTemp
)
{
if
(
f
.
getEmpIdcard
().
equals
(
infoVo
.
getEmpIdcard
())
&&
ServiceUtil
.
checkMothForPaymentImport
(
if
(
f
.
getEmpIdcard
().
equals
(
infoVo
.
getEmpIdcard
())
&&
ServiceUtil
.
checkMothForPaymentImport
(
f
.
getProvidentStart
(),
infoVo
.
getProvidentPayMonth
(),
f
.
getFundReduceDate
()))
{
f
.
getProvidentStart
(),
infoVo
.
getProvidentPayMonth
(),
f
.
getFundReduceDate
()))
{
fund
=
checkAddress
(
areaArray
,
areaMap
,
f
);
fund
=
checkAddress
(
areaArray
,
areaMap
,
f
);
if
(
null
!=
fund
)
{
if
(
null
!=
fund
)
{
break
;
break
;
}
}
...
@@ -1432,7 +1437,7 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
...
@@ -1432,7 +1437,7 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
//计算公积金合计,个人金额和单位金额一致
//计算公积金合计,个人金额和单位金额一致
infoVo
.
setProvidentSum
(
BigDecimalUtils
.
safeAdd
(
infoVo
.
getUnitProvidentSum
(),
infoVo
.
getUnitProvidentSum
()));
infoVo
.
setProvidentSum
(
BigDecimalUtils
.
safeAdd
(
infoVo
.
getUnitProvidentSum
(),
infoVo
.
getUnitProvidentSum
()));
// 判重
// 判重
if
(
null
!=
paymentInfoMap
)
{
if
(
paymentInfoMap
.
size
()
>
CommonConstants
.
ZERO_INT
)
{
paymentInfo
=
(
TPaymentInfo
)
paymentInfoMap
.
get
(
infoVo
.
getProvidentPayAddr
()
paymentInfo
=
(
TPaymentInfo
)
paymentInfoMap
.
get
(
infoVo
.
getProvidentPayAddr
()
+
CommonConstants
.
DOWN_LINE_STRING
+
CommonConstants
.
DOWN_LINE_STRING
+
infoVo
.
getEmpIdcard
().
trim
()
+
infoVo
.
getEmpIdcard
().
trim
()
...
@@ -1849,6 +1854,7 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
...
@@ -1849,6 +1854,7 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
//对身份证与人员姓名的对应关系进行校验
//对身份证与人员姓名的对应关系进行校验
if
(
socialInfo
!=
null
&&
!
socialInfo
.
getEmpName
().
equals
(
infoVo
.
getEmpName
()))
{
if
(
socialInfo
!=
null
&&
!
socialInfo
.
getEmpName
().
equals
(
infoVo
.
getEmpName
()))
{
errorMessageList
.
add
(
new
ErrorMessage
(
infoVo
.
getRowIndex
(),
"姓名与身份证信息不一致,请核实后再次尝试!"
));
errorMessageList
.
add
(
new
ErrorMessage
(
infoVo
.
getRowIndex
(),
"姓名与身份证信息不一致,请核实后再次尝试!"
));
continue
;
}
}
if
(
socialInfo
!=
null
&&
socialInfo
.
getSocialStartDate
()
==
null
)
{
if
(
socialInfo
!=
null
&&
socialInfo
.
getSocialStartDate
()
==
null
)
{
errorMessageList
.
add
(
new
ErrorMessage
(
infoVo
.
getRowIndex
(),
infoVo
.
getEmpIdcard
()
+
"的社保起缴日期为空!"
));
errorMessageList
.
add
(
new
ErrorMessage
(
infoVo
.
getRowIndex
(),
infoVo
.
getEmpIdcard
()
+
"的社保起缴日期为空!"
));
...
@@ -2104,6 +2110,8 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
...
@@ -2104,6 +2110,8 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
}
}
payExists
.
setSocialSum
(
BigDecimalUtils
.
safeAdd
(
payExists
.
getUnitSocialSum
(),
payExists
.
getSocialSecurityPersonalSum
()));
payExists
.
setSocialSum
(
BigDecimalUtils
.
safeAdd
(
payExists
.
getUnitSocialSum
(),
payExists
.
getSocialSecurityPersonalSum
()));
payExists
.
setSumAll
(
payExists
.
getSocialSum
());
payExists
.
setSumAll
(
payExists
.
getSocialSum
());
payExists
.
setCreateBy
(
user
.
getId
());
payExists
.
setCreateName
(
user
.
getNickname
());
if
(
null
!=
payExists
&&
Common
.
isEmpty
(
payExists
.
getSocialId
()))
{
if
(
null
!=
payExists
&&
Common
.
isEmpty
(
payExists
.
getSocialId
()))
{
payExists
.
setSocialId
(
UUID
.
randomUUID
().
toString
());
payExists
.
setSocialId
(
UUID
.
randomUUID
().
toString
());
}
}
...
@@ -2230,12 +2238,12 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
...
@@ -2230,12 +2238,12 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
}
}
if
(
areaArray
.
length
>=
CommonConstants
.
TWO_INT
)
{
if
(
areaArray
.
length
>=
CommonConstants
.
TWO_INT
)
{
if
(
null
!=
s
.
getFundProvince
())
{
if
(
null
!=
s
.
getFundProvince
())
{
if
(
areaArray
[
0
].
equals
(
areaMap
.
get
(
String
.
valueOf
(
s
.
getFundProvince
()
))))
{
if
(
areaArray
[
0
].
equals
(
areaMap
.
get
(
s
.
getFundProvince
(
))))
{
if
(
null
!=
s
.
getFundCity
())
{
if
(
null
!=
s
.
getFundCity
())
{
if
(
areaArray
[
1
].
equals
(
areaMap
.
get
(
String
.
valueOf
(
s
.
getFundCity
()
))))
{
if
(
areaArray
[
1
].
equals
(
areaMap
.
get
(
s
.
getFundCity
(
))))
{
if
(
areaArray
.
length
>=
CommonConstants
.
THREE_INT
)
{
if
(
areaArray
.
length
>=
CommonConstants
.
THREE_INT
)
{
if
(
null
!=
s
.
getFundTown
()
&&
areaArray
[
CommonConstants
.
TWO_INT
].
equals
(
if
(
null
!=
s
.
getFundTown
()
&&
areaArray
[
CommonConstants
.
TWO_INT
].
equals
(
areaMap
.
get
(
String
.
valueOf
(
s
.
getFundTown
()
))))
{
areaMap
.
get
(
s
.
getFundTown
(
))))
{
return
s
;
return
s
;
}
}
}
else
{
}
else
{
...
@@ -2255,7 +2263,7 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
...
@@ -2255,7 +2263,7 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
}
else
if
(
areaArray
.
length
==
1
)
{
}
else
if
(
areaArray
.
length
==
1
)
{
if
(
null
!=
s
.
getFundProvince
()
&&
null
==
s
.
getFundCity
())
{
if
(
null
!=
s
.
getFundProvince
()
&&
null
==
s
.
getFundCity
())
{
if
(
areaArray
[
0
].
equals
(
areaMap
.
get
(
String
.
valueOf
(
s
.
getFundProvince
()
))))
{
if
(
areaArray
[
0
].
equals
(
areaMap
.
get
(
s
.
getFundProvince
(
))))
{
return
s
;
return
s
;
}
}
}
else
{
}
else
{
...
...
yifu-social/yifu-social-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/social/service/impl/TPreDispatchInfoServiceImpl.java
View file @
1d71c3c2
...
@@ -32,7 +32,6 @@ import com.yifu.cloud.plus.v1.yifu.common.core.vo.YifuUser;
...
@@ -32,7 +32,6 @@ import com.yifu.cloud.plus.v1.yifu.common.core.vo.YifuUser;
import
com.yifu.cloud.plus.v1.yifu.common.dapr.util.ArchivesDaprUtil
;
import
com.yifu.cloud.plus.v1.yifu.common.dapr.util.ArchivesDaprUtil
;
import
com.yifu.cloud.plus.v1.yifu.common.dapr.util.UpmsDaprUtils
;
import
com.yifu.cloud.plus.v1.yifu.common.dapr.util.UpmsDaprUtils
;
import
com.yifu.cloud.plus.v1.yifu.common.security.util.SecurityUtils
;
import
com.yifu.cloud.plus.v1.yifu.common.security.util.SecurityUtils
;
import
com.yifu.cloud.plus.v1.yifu.insurances.util.ValidityUtil
;
import
com.yifu.cloud.plus.v1.yifu.social.constants.PreDispatchConstants
;
import
com.yifu.cloud.plus.v1.yifu.social.constants.PreDispatchConstants
;
import
com.yifu.cloud.plus.v1.yifu.social.entity.*
;
import
com.yifu.cloud.plus.v1.yifu.social.entity.*
;
import
com.yifu.cloud.plus.v1.yifu.social.mapper.*
;
import
com.yifu.cloud.plus.v1.yifu.social.mapper.*
;
...
@@ -84,6 +83,9 @@ public class TPreDispatchInfoServiceImpl extends ServiceImpl<TPreDispatchInfoMap
...
@@ -84,6 +83,9 @@ public class TPreDispatchInfoServiceImpl extends ServiceImpl<TPreDispatchInfoMap
@Autowired
@Autowired
private
TDispatchInfoService
dispatchInfoService
;
private
TDispatchInfoService
dispatchInfoService
;
@Autowired
private
SysHouseHoldInfoMapper
sysHouseHoldInfoMapper
;
/**
/**
* 预派单记录简单分页查询
* 预派单记录简单分页查询
*
*
...
@@ -577,7 +579,8 @@ public class TPreDispatchInfoServiceImpl extends ServiceImpl<TPreDispatchInfoMap
...
@@ -577,7 +579,8 @@ public class TPreDispatchInfoServiceImpl extends ServiceImpl<TPreDispatchInfoMap
}
}
@Override
@Override
public
List
<
ErrorMessage
>
batchSavePreDisPatchAdd
(
List
<
TPreDispatchInfo
>
listInfo
,
YifuUser
user
,
String
socialHouse
,
String
fundHouse
,
String
departId
)
{
public
List
<
ErrorMessage
>
batchSavePreDisPatchAdd
(
List
<
TPreDispatchInfo
>
listInfo
,
YifuUser
user
,
String
socialHouse
,
String
fundHouse
,
String
departId
)
{
List
<
ErrorMessage
>
errorList
=
new
ArrayList
<>();
List
<
ErrorMessage
>
errorList
=
new
ArrayList
<>();
R
<
TSettleDomainSelectVo
>
domainR
=
archivesDaprUtil
.
getSettleDomainSelectVoById
(
departId
);
R
<
TSettleDomainSelectVo
>
domainR
=
archivesDaprUtil
.
getSettleDomainSelectVoById
(
departId
);
// 获取区域数据MAP
// 获取区域数据MAP
...
@@ -631,12 +634,8 @@ public class TPreDispatchInfoServiceImpl extends ServiceImpl<TPreDispatchInfoMap
...
@@ -631,12 +634,8 @@ public class TPreDispatchInfoServiceImpl extends ServiceImpl<TPreDispatchInfoMap
info
.
setPreStatus
(
CommonConstants
.
ZERO_STRING
);
info
.
setPreStatus
(
CommonConstants
.
ZERO_STRING
);
// 为验重添加到MAP
// 为验重添加到MAP
existsMap
.
put
(
info
.
getEmpIdcard
()
+
CommonConstants
.
DOWN_LINE_STRING
+
info
.
getPayAddress
(),
info
);
existsMap
.
put
(
info
.
getEmpIdcard
()
+
CommonConstants
.
DOWN_LINE_STRING
+
info
.
getPayAddress
(),
info
);
if
(
Common
.
isEmpty
(
info
.
getExceptionContent
()))
{
if
(!
Common
.
isEmpty
(
info
.
getExceptionContent
()))
{
errorList
.
add
(
new
ErrorMessage
(
i
,
"保存成功!"
,
CommonConstants
.
GREEN
));
}
else
{
info
.
setPreStatus
(
CommonConstants
.
ONE_STRING
);
info
.
setPreStatus
(
CommonConstants
.
ONE_STRING
);
errorList
.
add
(
new
ErrorMessage
(
i
,
"保存成功!"
+
info
.
getExceptionContent
(),
CommonConstants
.
RED
));
}
}
baseMapper
.
insert
(
info
);
baseMapper
.
insert
(
info
);
}
}
...
@@ -705,12 +704,8 @@ public class TPreDispatchInfoServiceImpl extends ServiceImpl<TPreDispatchInfoMap
...
@@ -705,12 +704,8 @@ public class TPreDispatchInfoServiceImpl extends ServiceImpl<TPreDispatchInfoMap
}
}
// 为验重添加到MAP
// 为验重添加到MAP
existsMap
.
put
(
info
.
getEmpIdcard
()
+
CommonConstants
.
DOWN_LINE_STRING
+
info
.
getPayAddress
(),
info
);
existsMap
.
put
(
info
.
getEmpIdcard
()
+
CommonConstants
.
DOWN_LINE_STRING
+
info
.
getPayAddress
(),
info
);
if
(
Common
.
isEmpty
(
info
.
getExceptionContent
()))
{
if
(!
Common
.
isEmpty
(
info
.
getExceptionContent
()))
{
errorList
.
add
(
new
ErrorMessage
(
i
,
CommonConstants
.
SAVE_SUCCESS
,
CommonConstants
.
GREEN
));
}
else
{
info
.
setPreStatus
(
CommonConstants
.
ONE_STRING
);
info
.
setPreStatus
(
CommonConstants
.
ONE_STRING
);
errorList
.
add
(
new
ErrorMessage
(
i
,
CommonConstants
.
SAVE_SUCCESS
+
info
.
getExceptionContent
(),
CommonConstants
.
RED
));
}
}
baseMapper
.
insert
(
info
);
baseMapper
.
insert
(
info
);
}
}
...
@@ -978,11 +973,6 @@ public class TPreDispatchInfoServiceImpl extends ServiceImpl<TPreDispatchInfoMap
...
@@ -978,11 +973,6 @@ public class TPreDispatchInfoServiceImpl extends ServiceImpl<TPreDispatchInfoMap
info
.
setContractEndAdd
(
info
.
getContractEnd
());
info
.
setContractEndAdd
(
info
.
getContractEnd
());
info
.
setContractStartAdd
(
info
.
getContractStart
());
info
.
setContractStartAdd
(
info
.
getContractStart
());
baseMapper
.
updatePreDispatchInfoById
(
info
);
baseMapper
.
updatePreDispatchInfoById
(
info
);
if
(
Common
.
isNotNull
(
info
.
getExceptionContent
())){
errorList
.
add
(
new
ErrorMessage
(
i
,
CommonConstants
.
SAVE_SUCCESS
+
info
.
getExceptionContent
(),
CommonConstants
.
RED
));
}
else
{
errorList
.
add
(
new
ErrorMessage
(
i
,
CommonConstants
.
SAVE_SUCCESS
,
CommonConstants
.
GREEN
));
}
}
}
private
static
boolean
isaBoolean
(
LocalDateTime
temp
,
LocalDateTime
now
)
{
private
static
boolean
isaBoolean
(
LocalDateTime
temp
,
LocalDateTime
now
)
{
...
@@ -1116,8 +1106,13 @@ public class TPreDispatchInfoServiceImpl extends ServiceImpl<TPreDispatchInfoMap
...
@@ -1116,8 +1106,13 @@ public class TPreDispatchInfoServiceImpl extends ServiceImpl<TPreDispatchInfoMap
info
.
setContractTermAdd
(
Integer
.
toString
(
Common
.
getYearOfTime
(
info
.
getContractStart
(),
info
.
getContractEnd
())));
info
.
setContractTermAdd
(
Integer
.
toString
(
Common
.
getYearOfTime
(
info
.
getContractStart
(),
info
.
getContractEnd
())));
// 默认工时制 综合工时制2
// 默认工时制 综合工时制2
info
.
setWorkingHoursAdd
(
CommonConstants
.
TWO_STRING
);
info
.
setWorkingHoursAdd
(
CommonConstants
.
TWO_STRING
);
info
.
setSocialHouseAdd
(
socialHouse
);
info
.
setFundHouseAdd
(
fundHouse
);
SysHouseHoldInfo
sysHouseHoldInfo
=
sysHouseHoldInfoMapper
.
selectOne
(
Wrappers
.<
SysHouseHoldInfo
>
query
().
lambda
()
.
eq
(
SysHouseHoldInfo:
:
getName
,
socialHouse
).
eq
(
SysHouseHoldInfo:
:
getType
,
CommonConstants
.
ZERO_STRING
));
info
.
setSocialHouseAdd
(
sysHouseHoldInfo
.
getId
());
SysHouseHoldInfo
sysHouseHoldFund
=
sysHouseHoldInfoMapper
.
selectOne
(
Wrappers
.<
SysHouseHoldInfo
>
query
().
lambda
()
.
eq
(
SysHouseHoldInfo:
:
getName
,
fundHouse
).
eq
(
SysHouseHoldInfo:
:
getType
,
CommonConstants
.
ONE_STRING
));
info
.
setFundHouseAdd
(
sysHouseHoldFund
.
getId
());
}
}
/**
/**
...
@@ -2207,7 +2202,8 @@ public class TPreDispatchInfoServiceImpl extends ServiceImpl<TPreDispatchInfoMap
...
@@ -2207,7 +2202,8 @@ public class TPreDispatchInfoServiceImpl extends ServiceImpl<TPreDispatchInfoMap
Common
.
isNotNull
(
preInfo
.
getPensionStart
())){
Common
.
isNotNull
(
preInfo
.
getPensionStart
())){
importVo
.
setPensionStart
(
DateUtil
.
getFirstDay
(
preInfo
.
getPensionStart
()));
importVo
.
setPensionStart
(
DateUtil
.
getFirstDay
(
preInfo
.
getPensionStart
()));
if
(
Common
.
isNotNull
(
preInfo
.
getPensionAddress
())){
if
(
Common
.
isNotNull
(
preInfo
.
getPensionAddress
())){
importVo
.
setSocialHousehold
(
preInfo
.
getSocialHouseAdd
());
SysHouseHoldInfo
sysHouseHoldInfo
=
sysHouseHoldInfoMapper
.
selectById
(
preInfo
.
getSocialHouseAdd
());
importVo
.
setSocialHousehold
(
sysHouseHoldInfo
.
getName
());
}
}
SysBaseSetInfo
socialBaseSet
=
getSysBaseSetInfo
(
preInfo
.
getSocialProvince
(),
preInfo
.
getSocialCity
(),
SysBaseSetInfo
socialBaseSet
=
getSysBaseSetInfo
(
preInfo
.
getSocialProvince
(),
preInfo
.
getSocialCity
(),
preInfo
.
getSocialTown
(),
preInfo
.
getSocialHouseAdd
(),
CommonConstants
.
ZERO_STRING
);
preInfo
.
getSocialTown
(),
preInfo
.
getSocialHouseAdd
(),
CommonConstants
.
ZERO_STRING
);
...
@@ -2333,7 +2329,8 @@ public class TPreDispatchInfoServiceImpl extends ServiceImpl<TPreDispatchInfoMap
...
@@ -2333,7 +2329,8 @@ public class TPreDispatchInfoServiceImpl extends ServiceImpl<TPreDispatchInfoMap
importVo
.
setProvidentPer
(
preInfo
.
getFundPersonalPer
());
importVo
.
setProvidentPer
(
preInfo
.
getFundPersonalPer
());
}
}
if
(
Common
.
isNotNull
(
preInfo
.
getFundAddress
())){
if
(
Common
.
isNotNull
(
preInfo
.
getFundAddress
())){
importVo
.
setProvidentHousehold
(
preInfo
.
getFundHouseAdd
());
SysHouseHoldInfo
sysHouseHoldInfo
=
sysHouseHoldInfoMapper
.
selectById
(
preInfo
.
getFundHouseAdd
());
importVo
.
setProvidentHousehold
(
sysHouseHoldInfo
.
getName
());
}
}
}
}
...
...
yifu-social/yifu-social-biz/src/main/resources/mapper/TPaymentInfoMapper.xml
View file @
1d71c3c2
...
@@ -197,10 +197,11 @@
...
@@ -197,10 +197,11 @@
a.SOCIAL_PAY_ADDR,
a.SOCIAL_PAY_ADDR,
a.SOCIAL_PAY_MONTH,
a.SOCIAL_PAY_MONTH,
a.SOCIAL_CREATE_MONTH,
a.SOCIAL_CREATE_MONTH,
a.CREATE_USER,
a.CREATE_BY,
a.UPDATE_TIME,
a.UPDATE_BY,
a.CREATE_NAME,
a.CREATE_TIME,
a.CREATE_TIME,
a.LAST_UPDATE_USER,
a.LAST_UPDATE_TIME,
a.LOCK_STATUS,
a.LOCK_STATUS,
a.SUM_ALL,
a.SUM_ALL,
a.PROVIDENT_PAY_MONTH,
a.PROVIDENT_PAY_MONTH,
...
...
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