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
d6cda77b
Commit
d6cda77b
authored
Jun 09, 2023
by
hongguangwu
Browse files
Options
Browse Files
Download
Plain Diff
Merge branch 'develop'
parents
b21899eb
b1c3af0c
Hide whitespace changes
Inline
Side-by-side
Showing
14 changed files
with
150 additions
and
30 deletions
+150
-30
TEmployeeInfoMapper.java
...oud/plus/v1/yifu/archives/mapper/TEmployeeInfoMapper.java
+2
-0
TEmployeeProjectMapper.java
.../plus/v1/yifu/archives/mapper/TEmployeeProjectMapper.java
+2
-0
TEmployeeInfoService.java
...d/plus/v1/yifu/archives/service/TEmployeeInfoService.java
+1
-0
TEmployeeProjectService.java
...lus/v1/yifu/archives/service/TEmployeeProjectService.java
+3
-0
TEmployeeInfoServiceImpl.java
.../yifu/archives/service/impl/TEmployeeInfoServiceImpl.java
+8
-1
TEmployeeProjectServiceImpl.java
...fu/archives/service/impl/TEmployeeProjectServiceImpl.java
+5
-0
TEmployeeInfoMapper.xml
...ves-biz/src/main/resources/mapper/TEmployeeInfoMapper.xml
+5
-1
TEmployeeProjectMapper.xml
...-biz/src/main/resources/mapper/TEmployeeProjectMapper.xml
+5
-0
OrderAddVO.java
...java/com/yifu/cloud/plus/v1/yifu/order/vo/OrderAddVO.java
+64
-0
TOrderServiceImpl.java
...ud/plus/v1/yifu/order/service/impl/TOrderServiceImpl.java
+7
-6
TForecastLibraryService.java
.../plus/v1/yifu/social/service/TForecastLibraryService.java
+2
-1
TDispatchInfoServiceImpl.java
...v1/yifu/social/service/impl/TDispatchInfoServiceImpl.java
+14
-12
TForecastLibraryServiceImpl.java
...yifu/social/service/impl/TForecastLibraryServiceImpl.java
+29
-7
DoSocialTask.java
...com/yifu/cloud/plus/v1/yifu/social/util/DoSocialTask.java
+3
-2
No files found.
yifu-archives/yifu-archives-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/archives/mapper/TEmployeeInfoMapper.java
View file @
d6cda77b
...
@@ -120,4 +120,6 @@ public interface TEmployeeInfoMapper extends BaseMapper<TEmployeeInfo> {
...
@@ -120,4 +120,6 @@ public interface TEmployeeInfoMapper extends BaseMapper<TEmployeeInfo> {
* @return: int
* @return: int
**/
**/
int
everyDayUpdateEmployeeInfoContractStatus
();
int
everyDayUpdateEmployeeInfoContractStatus
();
void
updateContractStatus
(
@Param
(
"empId"
)
String
empId
,
@Param
(
"status"
)
int
status
);
}
}
yifu-archives/yifu-archives-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/archives/mapper/TEmployeeProjectMapper.java
View file @
d6cda77b
...
@@ -114,4 +114,6 @@ public interface TEmployeeProjectMapper extends BaseMapper<TEmployeeProject> {
...
@@ -114,4 +114,6 @@ public interface TEmployeeProjectMapper extends BaseMapper<TEmployeeProject> {
int
updateSocialAndFundStatusById
(
@Param
(
"project"
)
TEmployeeProject
project
);
int
updateSocialAndFundStatusById
(
@Param
(
"project"
)
TEmployeeProject
project
);
int
updateChangeById
(
@Param
(
"project"
)
TEmployeeProject
project
);
int
updateChangeById
(
@Param
(
"project"
)
TEmployeeProject
project
);
void
updateContractStatus
(
@Param
(
"empId"
)
String
empId
,
@Param
(
"status"
)
int
status
);
}
}
yifu-archives/yifu-archives-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/archives/service/TEmployeeInfoService.java
View file @
d6cda77b
...
@@ -221,4 +221,5 @@ public interface TEmployeeInfoService extends IService<TEmployeeInfo> {
...
@@ -221,4 +221,5 @@ public interface TEmployeeInfoService extends IService<TEmployeeInfo> {
**/
**/
void
everyDayUpdateEmployeeContractStatus
();
void
everyDayUpdateEmployeeContractStatus
();
void
updateContractStatus
(
String
empId
,
int
status
);
}
}
yifu-archives/yifu-archives-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/archives/service/TEmployeeProjectService.java
View file @
d6cda77b
...
@@ -26,6 +26,7 @@ import com.yifu.cloud.plus.v1.yifu.archives.entity.TEmployeeProject;
...
@@ -26,6 +26,7 @@ import com.yifu.cloud.plus.v1.yifu.archives.entity.TEmployeeProject;
import
com.yifu.cloud.plus.v1.yifu.archives.vo.*
;
import
com.yifu.cloud.plus.v1.yifu.archives.vo.*
;
import
com.yifu.cloud.plus.v1.yifu.common.core.util.ErrorMessage
;
import
com.yifu.cloud.plus.v1.yifu.common.core.util.ErrorMessage
;
import
com.yifu.cloud.plus.v1.yifu.common.core.util.R
;
import
com.yifu.cloud.plus.v1.yifu.common.core.util.R
;
import
org.apache.ibatis.annotations.Param
;
import
javax.servlet.http.HttpServletResponse
;
import
javax.servlet.http.HttpServletResponse
;
import
java.io.InputStream
;
import
java.io.InputStream
;
...
@@ -258,4 +259,6 @@ public interface TEmployeeProjectService extends IService<TEmployeeProject> {
...
@@ -258,4 +259,6 @@ public interface TEmployeeProjectService extends IService<TEmployeeProject> {
R
<
List
<
BusinessEmployeeExtentExcelVO
>>
exportByParams
(
THroBusinessUserQuery
query
);
R
<
List
<
BusinessEmployeeExtentExcelVO
>>
exportByParams
(
THroBusinessUserQuery
query
);
void
updateChangeById
(
TEmployeeProject
oldEmpProject
);
void
updateChangeById
(
TEmployeeProject
oldEmpProject
);
void
updateContractStatus
(
String
empId
,
int
status
);
}
}
yifu-archives/yifu-archives-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/archives/service/impl/TEmployeeInfoServiceImpl.java
View file @
d6cda77b
...
@@ -2204,7 +2204,7 @@ public class TEmployeeInfoServiceImpl extends ServiceImpl<TEmployeeInfoMapper, T
...
@@ -2204,7 +2204,7 @@ public class TEmployeeInfoServiceImpl extends ServiceImpl<TEmployeeInfoMapper, T
@Override
@Override
public
Boolean
updateEmpInfo
(
UpdateEmpVo
vo
)
{
public
Boolean
updateEmpInfo
(
UpdateEmpVo
vo
)
{
if
(
Common
.
isNotNull
(
vo
)){
if
(
Common
.
isNotNull
(
vo
)){
TEmployeeInfo
employeeInfo
;
TEmployeeInfo
employeeInfo
=
null
;
TEmployeeProject
p
=
null
;
TEmployeeProject
p
=
null
;
if
(
Common
.
isNotNull
(
vo
.
getEmpIdCard
())){
if
(
Common
.
isNotNull
(
vo
.
getEmpIdCard
())){
if
(
CommonConstants
.
ZERO_STRING
.
equals
(
vo
.
getType
())){
if
(
CommonConstants
.
ZERO_STRING
.
equals
(
vo
.
getType
())){
...
@@ -2254,6 +2254,8 @@ public class TEmployeeInfoServiceImpl extends ServiceImpl<TEmployeeInfoMapper, T
...
@@ -2254,6 +2254,8 @@ public class TEmployeeInfoServiceImpl extends ServiceImpl<TEmployeeInfoMapper, T
contractAudit
.
setRemark
(
vo
.
getRemarkTemp
());
contractAudit
.
setRemark
(
vo
.
getRemarkTemp
());
contractAudit
.
setRootName
(
"合同审核"
);
contractAudit
.
setRootName
(
"合同审核"
);
contractServicer
.
updateInUseStatusById
(
c
.
getEmpId
(),
c
.
getDeptNo
(),
c
.
getId
());
contractServicer
.
updateInUseStatusById
(
c
.
getEmpId
(),
c
.
getDeptNo
(),
c
.
getId
());
tEmployeeProjectService
.
updateContractStatus
(
c
.
getEmpId
(),
CommonConstants
.
ONE_INT
);
baseMapper
.
updateContractStatus
(
c
.
getEmpId
(),
CommonConstants
.
ONE_INT
);
//审核不同
//审核不同
}
else
if
(
CommonConstants
.
ONE_STRING
.
equals
(
vo
.
getType
())){
}
else
if
(
CommonConstants
.
ONE_STRING
.
equals
(
vo
.
getType
())){
c
.
setAuditStatus
(
CommonConstants
.
THREE_INT
);
c
.
setAuditStatus
(
CommonConstants
.
THREE_INT
);
...
@@ -2475,4 +2477,9 @@ public class TEmployeeInfoServiceImpl extends ServiceImpl<TEmployeeInfoMapper, T
...
@@ -2475,4 +2477,9 @@ public class TEmployeeInfoServiceImpl extends ServiceImpl<TEmployeeInfoMapper, T
baseMapper
.
everyDayUpdateEmployeeInfoContractStatus
();
baseMapper
.
everyDayUpdateEmployeeInfoContractStatus
();
tEmployeeProjectService
.
everyDayUpdateEmployeContractStatus
();
tEmployeeProjectService
.
everyDayUpdateEmployeContractStatus
();
}
}
@Override
public
void
updateContractStatus
(
String
empId
,
int
status
)
{
baseMapper
.
updateContractStatus
(
empId
,
status
);
}
}
}
yifu-archives/yifu-archives-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/archives/service/impl/TEmployeeProjectServiceImpl.java
View file @
d6cda77b
...
@@ -1716,4 +1716,9 @@ public class TEmployeeProjectServiceImpl extends ServiceImpl<TEmployeeProjectMap
...
@@ -1716,4 +1716,9 @@ public class TEmployeeProjectServiceImpl extends ServiceImpl<TEmployeeProjectMap
public
void
updateChangeById
(
TEmployeeProject
oldEmpProject
)
{
public
void
updateChangeById
(
TEmployeeProject
oldEmpProject
)
{
baseMapper
.
updateChangeById
(
oldEmpProject
);
baseMapper
.
updateChangeById
(
oldEmpProject
);
}
}
@Override
public
void
updateContractStatus
(
String
empId
,
int
status
)
{
baseMapper
.
updateContractStatus
(
empId
,
status
);
}
}
}
yifu-archives/yifu-archives-biz/src/main/resources/mapper/TEmployeeInfoMapper.xml
View file @
d6cda77b
...
@@ -1181,5 +1181,9 @@
...
@@ -1181,5 +1181,9 @@
and (ec.CONTRACT_END is null or ec.CONTRACT_END >= DATE_FORMAT(curdate(),"%Y-%m-%d"))
and (ec.CONTRACT_END is null or ec.CONTRACT_END >= DATE_FORMAT(curdate(),"%Y-%m-%d"))
)
)
</update>
</update>
<update
id=
"updateContractStatus"
>
update t_employee_info a
set CONTRACT_STATUS = #{status}
WHERE a.id=#{empId}
</update>
</mapper>
</mapper>
yifu-archives/yifu-archives-biz/src/main/resources/mapper/TEmployeeProjectMapper.xml
View file @
d6cda77b
...
@@ -1061,4 +1061,9 @@
...
@@ -1061,4 +1061,9 @@
</trim>
</trim>
WHERE a.id=#{project.id}
WHERE a.id=#{project.id}
</update>
</update>
<update
id=
"updateContractStatus"
>
update t_employee_project a
set CONTRACT_STATUS = #{status}
WHERE a.EMP_ID=#{empId}
</update>
</mapper>
</mapper>
yifu-order/yifu-order-api/src/main/java/com/yifu/cloud/plus/v1/yifu/order/vo/OrderAddVO.java
View file @
d6cda77b
...
@@ -357,5 +357,69 @@ public class OrderAddVO implements Serializable {
...
@@ -357,5 +357,69 @@ public class OrderAddVO implements Serializable {
/**
* 工资附件
*/
@Schema
(
description
=
"附件"
)
private
MultipartFile
[]
wageFile
;
/**
* 薪资附件
*/
@Schema
(
description
=
"附件"
)
private
MultipartFile
[]
salaryFile
;
/**
* 社保附件
*/
@Schema
(
description
=
"附件"
)
private
MultipartFile
[]
socialFile
;
/**
* 公积金附件
*/
@Schema
(
description
=
"附件"
)
private
MultipartFile
[]
fundFile
;
/**
* 商险附件
*/
@Schema
(
description
=
"附件"
)
private
MultipartFile
[]
insuranceFile
;
/**
* 代扣附件
*/
@Schema
(
description
=
"代扣附件"
)
private
MultipartFile
[]
withHoldingFile
;
/**
* 代扣附件
*/
@Schema
(
description
=
"代收附件"
)
private
MultipartFile
[]
collectionFile
;
/**
* 代扣附件
*/
@Schema
(
description
=
"非扣税附件"
)
private
MultipartFile
[]
noTaxFile
;
/**
* 其他
*/
@Schema
(
description
=
"其他"
)
private
MultipartFile
[]
otherFile
;
/**
* 薪资交接手册
*/
@Schema
(
description
=
"非扣税附件"
)
private
MultipartFile
[]
salaryHandoverFile
;
}
}
yifu-order/yifu-order-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/order/service/impl/TOrderServiceImpl.java
View file @
d6cda77b
...
@@ -188,13 +188,16 @@ public class TOrderServiceImpl extends ServiceImpl<TOrderMapper, TOrder> impleme
...
@@ -188,13 +188,16 @@ public class TOrderServiceImpl extends ServiceImpl<TOrderMapper, TOrder> impleme
String
result
;
String
result
;
switch
(
orderStatus
){
switch
(
orderStatus
){
case
0
:
case
0
:
result
=
"待
处理
"
;
result
=
"待
分配
"
;
break
;
break
;
case
1
:
case
1
:
result
=
"
处理
中"
;
result
=
"
制作
中"
;
break
;
break
;
case
2
:
case
2
:
result
=
"已办结"
;
result
=
"待确认"
;
break
;
case
3
:
result
=
"已完结"
;
break
;
break
;
default
:
default
:
result
=
""
;
result
=
""
;
...
@@ -505,9 +508,7 @@ public class TOrderServiceImpl extends ServiceImpl<TOrderMapper, TOrder> impleme
...
@@ -505,9 +508,7 @@ public class TOrderServiceImpl extends ServiceImpl<TOrderMapper, TOrder> impleme
if
(!
Common
.
isEmpty
(
vo
.
getOrderContent
())
&&
!
ValidityUtil
.
validate2048
(
vo
.
getOrderContent
())){
if
(!
Common
.
isEmpty
(
vo
.
getOrderContent
())
&&
!
ValidityUtil
.
validate2048
(
vo
.
getOrderContent
())){
return
R
.
failed
(
OrderConstants
.
ORDER_CONTENT_MORE_THAN_2048
);
return
R
.
failed
(
OrderConstants
.
ORDER_CONTENT_MORE_THAN_2048
);
}
}
if
(
CollectionUtils
.
isEmpty
(
vo
.
getHandleUserList
())){
TSettleDomain
settleDomain
=
new
TSettleDomain
();
return
R
.
failed
(
OrderConstants
.
HANDLE_USER_IS_EMPTY
);
}
TSettleDomain
settleDomain
=
new
TSettleDomain
();
List
<
TSettleDomainSelectVo
>
settleDomainR
;
List
<
TSettleDomainSelectVo
>
settleDomainR
;
R
<
TSettleDomainListVo
>
listVo
;
R
<
TSettleDomainListVo
>
listVo
;
...
...
yifu-social/yifu-social-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/social/service/TForecastLibraryService.java
View file @
d6cda77b
...
@@ -32,6 +32,7 @@ import com.yifu.cloud.plus.v1.yifu.social.entity.TSocialFundInfo;
...
@@ -32,6 +32,7 @@ import com.yifu.cloud.plus.v1.yifu.social.entity.TSocialFundInfo;
import
javax.servlet.http.HttpServletResponse
;
import
javax.servlet.http.HttpServletResponse
;
import
java.util.List
;
import
java.util.List
;
import
java.util.Map
;
import
java.util.Map
;
import
java.util.concurrent.ConcurrentHashMap
;
/**
/**
* 预估费用
* 预估费用
...
@@ -92,7 +93,7 @@ public interface TForecastLibraryService extends IService<TForecastLibrary> {
...
@@ -92,7 +93,7 @@ public interface TForecastLibraryService extends IService<TForecastLibrary> {
* @Date: 2022/7/26 19:02
* @Date: 2022/7/26 19:02
* @return: com.yifu.cloud.plus.v1.yifu.common.core.util.R<java.lang.String>
* @return: com.yifu.cloud.plus.v1.yifu.common.core.util.R<java.lang.String>
**/
**/
R
<
String
>
updateForecastLibaryByDispatch
(
TSocialFundInfo
socialFundInfo
);
R
<
String
>
updateForecastLibaryByDispatch
(
ConcurrentHashMap
<
String
,
String
>
socialMap
,
ConcurrentHashMap
<
String
,
String
>
fundMap
,
TSocialFundInfo
socialFundInfo
);
/**
/**
* @Description: 户调基-基数变更,同步社保公积金查询、预估库
* @Description: 户调基-基数变更,同步社保公积金查询、预估库
...
...
yifu-social/yifu-social-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/social/service/impl/TDispatchInfoServiceImpl.java
View file @
d6cda77b
...
@@ -724,7 +724,7 @@ public class TDispatchInfoServiceImpl extends ServiceImpl<TDispatchInfoMapper, T
...
@@ -724,7 +724,7 @@ public class TDispatchInfoServiceImpl extends ServiceImpl<TDispatchInfoMapper, T
}
}
// 生成预付数据
// 生成预付数据
if
(
Common
.
isNotNull
(
socialFund
)
&&
Common
.
isNotNull
(
socialFund
.
getId
())){
if
(
Common
.
isNotNull
(
socialFund
)
&&
Common
.
isNotNull
(
socialFund
.
getId
())){
forecastLibraryService
.
updateForecastLibaryByDispatch
(
socialFund
);
forecastLibraryService
.
updateForecastLibaryByDispatch
(
null
,
null
,
socialFund
);
}
}
// 同步更新人员档案和项目档案的社保公积金状态
// 同步更新人员档案和项目档案的社保公积金状态
updateDocSocialFund
(
social
,
fund
,
socialFund
,
excel
);
updateDocSocialFund
(
social
,
fund
,
socialFund
,
excel
);
...
@@ -3356,7 +3356,7 @@ public class TDispatchInfoServiceImpl extends ServiceImpl<TDispatchInfoMapper, T
...
@@ -3356,7 +3356,7 @@ public class TDispatchInfoServiceImpl extends ServiceImpl<TDispatchInfoMapper, T
&&
CommonConstants
.
ONE_INT
==
flag
){
&&
CommonConstants
.
ONE_INT
==
flag
){
// 更新预估数据 -- 失败项重新派单审核不通过不处理预估
// 更新预估数据 -- 失败项重新派单审核不通过不处理预估
if
(!
flagTemp
){
if
(!
flagTemp
){
socialTask
.
asynchronousDisPatchHandle
(
sf
,
forecastFlag
,
null
,
null
,
CommonConstants
.
ZERO_INT
);
socialTask
.
asynchronousDisPatchHandle
(
null
,
null
,
sf
,
forecastFlag
,
null
,
null
,
CommonConstants
.
ZERO_INT
);
}
}
// 更新人员档案和项目档案的社保公积金状态
// 更新人员档案和项目档案的社保公积金状态
UpProjectSocialFundVo
vo
=
new
UpProjectSocialFundVo
();
UpProjectSocialFundVo
vo
=
new
UpProjectSocialFundVo
();
...
@@ -3490,7 +3490,7 @@ public class TDispatchInfoServiceImpl extends ServiceImpl<TDispatchInfoMapper, T
...
@@ -3490,7 +3490,7 @@ public class TDispatchInfoServiceImpl extends ServiceImpl<TDispatchInfoMapper, T
}
}
if
(
Common
.
isNotNull
(
requestId
))
{
if
(
Common
.
isNotNull
(
requestId
))
{
try
{
try
{
List
<
ErrorMessage
>
errorInfo
=
addBatchApplyHandle
(
ids
,
typeSub
,
user
,
flag
,
handleStatus
,
List
<
ErrorMessage
>
errorInfo
=
addBatchApplyHandle
(
null
,
null
,
ids
,
typeSub
,
user
,
flag
,
handleStatus
,
Common
.
isNullToString
(
handleRemark
),
socialType
,
remark
);
Common
.
isNullToString
(
handleRemark
),
socialType
,
remark
);
if
(
errorInfo
==
null
||
errorInfo
.
isEmpty
())
{
if
(
errorInfo
==
null
||
errorInfo
.
isEmpty
())
{
return
R
.
ok
(
null
,
"办理成功!"
);
return
R
.
ok
(
null
,
"办理成功!"
);
...
@@ -3536,7 +3536,8 @@ public class TDispatchInfoServiceImpl extends ServiceImpl<TDispatchInfoMapper, T
...
@@ -3536,7 +3536,8 @@ public class TDispatchInfoServiceImpl extends ServiceImpl<TDispatchInfoMapper, T
* @Date 2022-07-26
* @Date 2022-07-26
**/
**/
@Transactional
(
rollbackFor
=
Exception
.
class
)
@Transactional
(
rollbackFor
=
Exception
.
class
)
public
List
<
ErrorMessage
>
addBatchApplyHandle
(
List
<
String
>
idsList
,
String
typeSub
,
YifuUser
user
public
List
<
ErrorMessage
>
addBatchApplyHandle
(
ConcurrentHashMap
<
String
,
String
>
socialMap
,
ConcurrentHashMap
<
String
,
String
>
fundMap
,
List
<
String
>
idsList
,
String
typeSub
,
YifuUser
user
,
int
flag
,
String
handleStatus
,
String
handleRemark
,
String
socialType
,
String
remark
)
{
,
int
flag
,
String
handleStatus
,
String
handleRemark
,
String
socialType
,
String
remark
)
{
List
<
ErrorMessage
>
errorList
=
new
ArrayList
<>();
List
<
ErrorMessage
>
errorList
=
new
ArrayList
<>();
if
(!
Common
.
isNotNull
(
idsList
))
{
if
(!
Common
.
isNotNull
(
idsList
))
{
...
@@ -3877,18 +3878,17 @@ public class TDispatchInfoServiceImpl extends ServiceImpl<TDispatchInfoMapper, T
...
@@ -3877,18 +3878,17 @@ public class TDispatchInfoServiceImpl extends ServiceImpl<TDispatchInfoMapper, T
&&
(
CommonConstants
.
FIVE_STRING
.
equals
(
sf
.
getSocialStatus
())
&&
(
CommonConstants
.
FIVE_STRING
.
equals
(
sf
.
getSocialStatus
())
||
CommonConstants
.
FOUR_STRING
.
equals
(
sf
.
getFundStatus
())))
{
||
CommonConstants
.
FOUR_STRING
.
equals
(
sf
.
getFundStatus
())))
{
// 派增办理,全部失败 同步预估库数据
// 派增办理,全部失败 同步预估库数据
socialTask
.
asynchronousDisPatchHandle
(
sf
,
forecastFlag
,
null
,
null
,
CommonConstants
.
ZERO_INT
);
socialTask
.
asynchronousDisPatchHandle
(
s
ocialMap
,
fundMap
,
s
f
,
forecastFlag
,
null
,
null
,
CommonConstants
.
ZERO_INT
);
}
}
// 社保办理只要办理成功就刷新预估数据 公积金办理不用处理(前面公积金办理成功的时候处理过了)
// 社保办理只要办理成功就刷新预估数据 公积金办理不用处理(前面公积金办理成功的时候处理过了)
if
(
CommonConstants
.
ZERO_STRING
.
equals
(
typeSub
)
if
(
CommonConstants
.
ZERO_STRING
.
equals
(
typeSub
)
&&
(
Common
.
isNotNull
(
dis
.
getSocialId
())
&&
(
Common
.
isNotNull
(
dis
.
getSocialId
())
&&
CommonConstants
.
FOUR_STRING
.
equals
(
sf
.
getSocialStatus
())
&&
CommonConstants
.
FOUR_STRING
.
equals
(
sf
.
getSocialStatus
())
||
CommonConstants
.
TWO_STRING
.
equals
(
sf
.
getSocialStatus
())
||
CommonConstants
.
THREE_STRING
.
equals
(
sf
.
getSocialStatus
())))
{
||
CommonConstants
.
THREE_STRING
.
equals
(
sf
.
getSocialStatus
())))
{
if
(
partSuccess
)
{
if
(
partSuccess
)
{
forecastLibraryService
.
updateForecastLibaryByDispatch
(
sf
);
forecastLibraryService
.
updateForecastLibaryByDispatch
(
s
ocialMap
,
fundMap
,
s
f
);
}
else
{
}
else
{
socialTask
.
asynchronousDisPatchHandle
(
sf
,
0
,
null
,
null
,
CommonConstants
.
ONE_INT
);
socialTask
.
asynchronousDisPatchHandle
(
s
ocialMap
,
fundMap
,
s
f
,
0
,
null
,
null
,
CommonConstants
.
ONE_INT
);
}
}
}
}
}
}
...
@@ -3898,7 +3898,7 @@ public class TDispatchInfoServiceImpl extends ServiceImpl<TDispatchInfoMapper, T
...
@@ -3898,7 +3898,7 @@ public class TDispatchInfoServiceImpl extends ServiceImpl<TDispatchInfoMapper, T
&&
(
CommonConstants
.
EIGHT_STRING
.
equals
(
sf
.
getSocialStatus
())
&&
(
CommonConstants
.
EIGHT_STRING
.
equals
(
sf
.
getSocialStatus
())
||
CommonConstants
.
SEVEN_STRING
.
equals
(
sf
.
getFundStatus
()))){
||
CommonConstants
.
SEVEN_STRING
.
equals
(
sf
.
getFundStatus
()))){
// 同步预估库数据
// 同步预估库数据
socialTask
.
asynchronousDisPatchHandle
(
sf
,
forecastFlag
,
null
,
null
,
CommonConstants
.
ZERO_INT
);
socialTask
.
asynchronousDisPatchHandle
(
s
ocialMap
,
fundMap
,
s
f
,
forecastFlag
,
null
,
null
,
CommonConstants
.
ZERO_INT
);
}
}
// 派减公积金办理失败不同步档案的相关字段信息
// 派减公积金办理失败不同步档案的相关字段信息
if
(!(
CommonConstants
.
ONE_STRING
.
equals
(
dis
.
getType
())
if
(!(
CommonConstants
.
ONE_STRING
.
equals
(
dis
.
getType
())
...
@@ -5163,7 +5163,7 @@ public class TDispatchInfoServiceImpl extends ServiceImpl<TDispatchInfoMapper, T
...
@@ -5163,7 +5163,7 @@ public class TDispatchInfoServiceImpl extends ServiceImpl<TDispatchInfoMapper, T
}
}
try
{
try
{
// 执行数据插入操作 组装
// 执行数据插入操作 组装
messageList
=
addBatchApplyHandle
(
Collections
.
singletonList
(
dispatch
.
getId
()),
CommonConstants
.
ONE_STRING
,
user
messageList
=
addBatchApplyHandle
(
null
,
null
,
Collections
.
singletonList
(
dispatch
.
getId
()),
CommonConstants
.
ONE_STRING
,
user
,
flag
,
handleStatus
,
(
Common
.
isEmpty
(
excel
.
getReasonType
())?
""
:
excel
.
getReasonType
()+
CommonConstants
.
COLON_STRING
)
,
flag
,
handleStatus
,
(
Common
.
isEmpty
(
excel
.
getReasonType
())?
""
:
excel
.
getReasonType
()+
CommonConstants
.
COLON_STRING
)
+
excel
.
getRemark
(),
null
,
excel
.
getReasonType
());
+
excel
.
getRemark
(),
null
,
excel
.
getReasonType
());
if
(
Common
.
isNotNull
(
messageList
)){
if
(
Common
.
isNotNull
(
messageList
)){
...
@@ -5289,6 +5289,8 @@ public class TDispatchInfoServiceImpl extends ServiceImpl<TDispatchInfoMapper, T
...
@@ -5289,6 +5289,8 @@ public class TDispatchInfoServiceImpl extends ServiceImpl<TDispatchInfoMapper, T
String
handlerRemaek
;
String
handlerRemaek
;
List
<
TDispatchInfo
>
failueList
=
new
ArrayList
<>();
List
<
TDispatchInfo
>
failueList
=
new
ArrayList
<>();
ConcurrentHashMap
<
String
,
String
>
socialMap
=
new
ConcurrentHashMap
<>();
ConcurrentHashMap
<
String
,
String
>
fundMap
=
new
ConcurrentHashMap
<>();
for
(
int
i
=
0
;
i
<
excelVOList
.
size
();
i
++)
{
for
(
int
i
=
0
;
i
<
excelVOList
.
size
();
i
++)
{
StringBuilder
socialSucessType
=
new
StringBuilder
();
StringBuilder
socialSucessType
=
new
StringBuilder
();
StringBuilder
socialFailureType
=
new
StringBuilder
();
StringBuilder
socialFailureType
=
new
StringBuilder
();
...
@@ -5366,7 +5368,7 @@ public class TDispatchInfoServiceImpl extends ServiceImpl<TDispatchInfoMapper, T
...
@@ -5366,7 +5368,7 @@ public class TDispatchInfoServiceImpl extends ServiceImpl<TDispatchInfoMapper, T
continue
;
continue
;
}
}
// 执行数据插入操作 组装
// 执行数据插入操作 组装
messageList
=
addBatchApplyHandle
(
Collections
.
singletonList
(
dispatch
.
getId
()),
CommonConstants
.
ZERO_STRING
,
user
messageList
=
addBatchApplyHandle
(
socialMap
,
fundMap
,
Collections
.
singletonList
(
dispatch
.
getId
()),
CommonConstants
.
ZERO_STRING
,
user
,
0
,
CommonConstants
.
ONE_STRING
,
ServiceUtil
.
ifNullToEmpty
(
excel
.
getRemark
()),
socialSucessType
.
substring
(
0
,
socialSucessType
.
length
()
-
1
),
ServiceUtil
.
ifNullToEmpty
(
excel
.
getRemark
()));
,
0
,
CommonConstants
.
ONE_STRING
,
ServiceUtil
.
ifNullToEmpty
(
excel
.
getRemark
()),
socialSucessType
.
substring
(
0
,
socialSucessType
.
length
()
-
1
),
ServiceUtil
.
ifNullToEmpty
(
excel
.
getRemark
()));
if
(
Common
.
isNotNull
(
messageList
))
{
if
(
Common
.
isNotNull
(
messageList
))
{
errorMessage
=
messageList
.
get
(
CommonConstants
.
ZERO_INT
);
errorMessage
=
messageList
.
get
(
CommonConstants
.
ZERO_INT
);
...
@@ -5397,7 +5399,7 @@ public class TDispatchInfoServiceImpl extends ServiceImpl<TDispatchInfoMapper, T
...
@@ -5397,7 +5399,7 @@ public class TDispatchInfoServiceImpl extends ServiceImpl<TDispatchInfoMapper, T
for
(
TDispatchInfo
dispatchInfo
:
failueList
)
{
for
(
TDispatchInfo
dispatchInfo
:
failueList
)
{
vo
=
dispatchInfo
.
getExcel
();
vo
=
dispatchInfo
.
getExcel
();
// 执行数据插入操作 组装
// 执行数据插入操作 组装
messageList
=
addBatchApplyHandle
(
Collections
.
singletonList
(
dispatchInfo
.
getId
()),
CommonConstants
.
ZERO_STRING
,
user
messageList
=
addBatchApplyHandle
(
socialMap
,
fundMap
,
Collections
.
singletonList
(
dispatchInfo
.
getId
()),
CommonConstants
.
ZERO_STRING
,
user
,
1
,
CommonConstants
.
TWO_STRING
,
dispatchInfo
.
getHandlerRemaek
()
+
ServiceUtil
.
ifNullToEmpty
(
vo
.
getRemark
()),
dispatchInfo
.
getSocialFailureType
().
substring
(
0
,
dispatchInfo
.
getSocialFailureType
().
length
()
-
1
),
dispatchInfo
.
getHandlerRemaek
()
+
ServiceUtil
.
ifNullToEmpty
(
vo
.
getRemark
()));
,
1
,
CommonConstants
.
TWO_STRING
,
dispatchInfo
.
getHandlerRemaek
()
+
ServiceUtil
.
ifNullToEmpty
(
vo
.
getRemark
()),
dispatchInfo
.
getSocialFailureType
().
substring
(
0
,
dispatchInfo
.
getSocialFailureType
().
length
()
-
1
),
dispatchInfo
.
getHandlerRemaek
()
+
ServiceUtil
.
ifNullToEmpty
(
vo
.
getRemark
()));
if
(
Common
.
isNotNull
(
messageList
))
{
if
(
Common
.
isNotNull
(
messageList
))
{
errorMessage
=
messageList
.
get
(
CommonConstants
.
ZERO_INT
);
errorMessage
=
messageList
.
get
(
CommonConstants
.
ZERO_INT
);
...
...
yifu-social/yifu-social-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/social/service/impl/TForecastLibraryServiceImpl.java
View file @
d6cda77b
...
@@ -62,6 +62,7 @@ import java.math.BigDecimal;
...
@@ -62,6 +62,7 @@ import java.math.BigDecimal;
import
java.net.URLEncoder
;
import
java.net.URLEncoder
;
import
java.time.LocalDateTime
;
import
java.time.LocalDateTime
;
import
java.util.*
;
import
java.util.*
;
import
java.util.concurrent.ConcurrentHashMap
;
/**
/**
* 预估费用
* 预估费用
...
@@ -1490,7 +1491,7 @@ public class TForecastLibraryServiceImpl extends ServiceImpl<TForecastLibraryMap
...
@@ -1490,7 +1491,7 @@ public class TForecastLibraryServiceImpl extends ServiceImpl<TForecastLibraryMap
sysBaseSetInfoMapper
.
updateById
(
sysBaseSetInfo
);
sysBaseSetInfoMapper
.
updateById
(
sysBaseSetInfo
);
}
}
for
(
TSocialFundInfo
socialFundInfo
:
socialFundInfoMap
.
values
())
{
for
(
TSocialFundInfo
socialFundInfo
:
socialFundInfoMap
.
values
())
{
this
.
updateForecastLibaryCore
(
socialFundInfo
,
socialFundInfo
.
getDoMonth
(),
true
,
false
,
true
);
this
.
updateForecastLibaryCore
(
null
,
null
,
socialFundInfo
,
socialFundInfo
.
getDoMonth
(),
true
,
false
,
true
);
socialFundInfoMapper
.
updateById
(
socialFundInfo
);
socialFundInfoMapper
.
updateById
(
socialFundInfo
);
}
}
}
}
...
@@ -1505,7 +1506,7 @@ public class TForecastLibraryServiceImpl extends ServiceImpl<TForecastLibraryMap
...
@@ -1505,7 +1506,7 @@ public class TForecastLibraryServiceImpl extends ServiceImpl<TForecastLibraryMap
**/
**/
@Override
@Override
public
R
<
String
>
updateToneForecastLibary
(
TSocialFundInfo
socialFundInfo
,
String
doMonth
)
{
public
R
<
String
>
updateToneForecastLibary
(
TSocialFundInfo
socialFundInfo
,
String
doMonth
)
{
return
this
.
updateForecastLibaryCore
(
socialFundInfo
,
doMonth
,
false
,
false
,
true
);
return
this
.
updateForecastLibaryCore
(
null
,
null
,
socialFundInfo
,
doMonth
,
false
,
false
,
true
);
}
}
/**
/**
...
@@ -1516,8 +1517,8 @@ public class TForecastLibraryServiceImpl extends ServiceImpl<TForecastLibraryMap
...
@@ -1516,8 +1517,8 @@ public class TForecastLibraryServiceImpl extends ServiceImpl<TForecastLibraryMap
* @return: void
* @return: void
**/
**/
@Override
@Override
public
R
<
String
>
updateForecastLibaryByDispatch
(
TSocialFundInfo
socialFundInfo
)
{
public
R
<
String
>
updateForecastLibaryByDispatch
(
ConcurrentHashMap
<
String
,
String
>
socialMap
,
ConcurrentHashMap
<
String
,
String
>
fundMap
,
TSocialFundInfo
socialFundInfo
)
{
return
this
.
updateForecastLibaryCore
(
socialFundInfo
,
null
,
false
,
true
,
false
);
return
this
.
updateForecastLibaryCore
(
social
Map
,
fundMap
,
social
FundInfo
,
null
,
false
,
true
,
false
);
}
}
/**
/**
...
@@ -1714,7 +1715,7 @@ public class TForecastLibraryServiceImpl extends ServiceImpl<TForecastLibraryMap
...
@@ -1714,7 +1715,7 @@ public class TForecastLibraryServiceImpl extends ServiceImpl<TForecastLibraryMap
* @Date: 2022/7/26 19:01
* @Date: 2022/7/26 19:01
* @return: com.yifu.cloud.plus.v1.yifu.common.core.util.R<java.lang.String>
* @return: com.yifu.cloud.plus.v1.yifu.common.core.util.R<java.lang.String>
**/
**/
private
R
<
String
>
updateForecastLibaryCore
(
TSocialFundInfo
socialFundInfo
,
String
doMonth
,
boolean
isOnly
,
boolean
isDispatch
,
boolean
synFlag
)
{
private
R
<
String
>
updateForecastLibaryCore
(
ConcurrentHashMap
<
String
,
String
>
socialMap
,
ConcurrentHashMap
<
String
,
String
>
fundMap
,
TSocialFundInfo
socialFundInfo
,
String
doMonth
,
boolean
isOnly
,
boolean
isDispatch
,
boolean
synFlag
)
{
String
empIdCard
=
socialFundInfo
.
getEmpIdcard
();
String
empIdCard
=
socialFundInfo
.
getEmpIdcard
();
//定义未推送的按条件查询得到的预估数据
//定义未推送的按条件查询得到的预估数据
List
<
TForecastLibrary
>
librarySocialList
=
null
;
List
<
TForecastLibrary
>
librarySocialList
=
null
;
...
@@ -1906,8 +1907,29 @@ public class TForecastLibraryServiceImpl extends ServiceImpl<TForecastLibraryMap
...
@@ -1906,8 +1907,29 @@ public class TForecastLibraryServiceImpl extends ServiceImpl<TForecastLibraryMap
log
.
error
(
"更新一条预估耗时:"
+
times
+
"毫秒"
);
log
.
error
(
"更新一条预估耗时:"
+
times
+
"毫秒"
);
isSaveAndUpdate
=
true
;
isSaveAndUpdate
=
true
;
}
else
{
}
else
{
if
(
BigDecimal
.
ZERO
.
compareTo
(
BigDecimalUtils
.
isNullToZero
(
library
.
getUnitSocialSum
()))
!=
CommonConstants
.
ZERO_INT
if
(
BigDecimal
.
ZERO
.
compareTo
(
BigDecimalUtils
.
isNullToZero
(
library
.
getUnitSocialSum
()))
!=
CommonConstants
.
ZERO_INT
)
{
||
BigDecimal
.
ZERO
.
compareTo
(
BigDecimalUtils
.
isNullToZero
(
library
.
getUnitFundSum
()))
!=
CommonConstants
.
ZERO_INT
)
{
if
(
null
!=
socialMap
)
{
String
sameKey
=
library
.
getEmpIdcard
()
+
"_"
+
library
.
getSocialCreateMonth
()
+
"_"
+
library
.
getSocialPayMonth
();
if
(
null
==
socialMap
.
get
(
sameKey
))
{
socialMap
.
put
(
sameKey
,
CommonConstants
.
ONE_STRING
);
}
else
{
continue
;
}
}
library
.
setCreateBy
(
userId
);
library
.
setCreateName
(
userName
);
library
.
setCreateTime
(
LocalDateTime
.
now
());
baseMapper
.
insert
(
library
);
isSaveAndUpdate
=
true
;
}
else
if
(
BigDecimal
.
ZERO
.
compareTo
(
BigDecimalUtils
.
isNullToZero
(
library
.
getUnitFundSum
()))
!=
CommonConstants
.
ZERO_INT
)
{
if
(
null
!=
fundMap
)
{
String
sameKey
=
library
.
getEmpIdcard
()
+
"_"
+
library
.
getProvidentCreateMonth
()
+
"_"
+
library
.
getProvidentPayMonth
();
if
(
null
==
fundMap
.
get
(
sameKey
))
{
fundMap
.
put
(
sameKey
,
CommonConstants
.
ONE_STRING
);
}
else
{
continue
;
}
}
library
.
setCreateBy
(
userId
);
library
.
setCreateBy
(
userId
);
library
.
setCreateName
(
userName
);
library
.
setCreateName
(
userName
);
library
.
setCreateTime
(
LocalDateTime
.
now
());
library
.
setCreateTime
(
LocalDateTime
.
now
());
...
...
yifu-social/yifu-social-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/social/util/DoSocialTask.java
View file @
d6cda77b
...
@@ -27,6 +27,7 @@ import java.math.BigDecimal;
...
@@ -27,6 +27,7 @@ import java.math.BigDecimal;
import
java.util.ArrayList
;
import
java.util.ArrayList
;
import
java.util.Date
;
import
java.util.Date
;
import
java.util.List
;
import
java.util.List
;
import
java.util.concurrent.ConcurrentHashMap
;
/**
/**
* @Author fxj
* @Author fxj
...
@@ -58,7 +59,7 @@ public class DoSocialTask {
...
@@ -58,7 +59,7 @@ public class DoSocialTask {
* @param type=0 updateForecastLibaryByDispatchReduce type=1 updateForecastLibaryByDispatch type=2 pushForecastFundInfo createIncomeInfo(library);
* @param type=0 updateForecastLibaryByDispatchReduce type=1 updateForecastLibaryByDispatch type=2 pushForecastFundInfo createIncomeInfo(library);
**/
**/
@Async
@Async
public
void
asynchronousDisPatchHandle
(
TSocialFundInfo
sf
,
int
forecastFlag
,
List
<
TForecastLibrary
>
libs
,
TForecastLibrary
library
,
int
type
)
{
public
void
asynchronousDisPatchHandle
(
ConcurrentHashMap
<
String
,
String
>
socialMap
,
ConcurrentHashMap
<
String
,
String
>
fundMap
,
TSocialFundInfo
sf
,
int
forecastFlag
,
List
<
TForecastLibrary
>
libs
,
TForecastLibrary
library
,
int
type
)
{
synchronized
(
this
){
synchronized
(
this
){
R
<
String
>
res
;
R
<
String
>
res
;
String
linkId
=
null
;
String
linkId
=
null
;
...
@@ -74,7 +75,7 @@ public class DoSocialTask {
...
@@ -74,7 +75,7 @@ public class DoSocialTask {
// 派单变更预估库
// 派单变更预估库
if
(
type
==
CommonConstants
.
ONE_INT
){
if
(
type
==
CommonConstants
.
ONE_INT
){
linkId
=
sf
.
getId
();
linkId
=
sf
.
getId
();
res
=
forecastLibraryService
.
updateForecastLibaryByDispatch
(
sf
);
res
=
forecastLibraryService
.
updateForecastLibaryByDispatch
(
s
ocialMap
,
fundMap
,
s
f
);
if
(
Common
.
isEmpty
(
res
)
||
CommonConstants
.
SUCCESS
!=
res
.
getCode
()){
if
(
Common
.
isEmpty
(
res
)
||
CommonConstants
.
SUCCESS
!=
res
.
getCode
()){
initSendError
(
sf
.
getId
(),
res
.
getMsg
(),
"updateForecastLibaryByDispatch:"
);
initSendError
(
sf
.
getId
(),
res
.
getMsg
(),
"updateForecastLibaryByDispatch:"
);
}
}
...
...
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