Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
8
8timerapiv200
Overview
Overview
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
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
8timerv2
8timerapiv200
Commits
13863f8d
Commit
13863f8d
authored
Feb 18, 2022
by
翁国栋
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
禅道bug-
1284、合同证照中的到期提醒,如果提醒人一天中存在多个要提醒的证照时,系统只发送最先创建的那一条证照的到期提醒
parent
7ea43215
Show whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
25 additions
and
12 deletions
+25
-12
src/main/java/cn/timer/api/controller/htzz/HtzzController.java
+25
-12
No files found.
src/main/java/cn/timer/api/controller/htzz/HtzzController.java
View file @
13863f8d
...
@@ -69,6 +69,15 @@ public class HtzzController {
...
@@ -69,6 +69,15 @@ public class HtzzController {
@Value
(
"${config-8timer.Aliyun.endpoint}"
)
@Value
(
"${config-8timer.Aliyun.endpoint}"
)
private
String
endpoint
;
private
String
endpoint
;
@Value
(
"${sftp.client.root}"
)
private
String
root
;
@Value
(
"${sftp.client.targetPath}"
)
private
String
targetPath
;
@Value
(
"${sftp.client.serverUrl}"
)
private
String
serverUrl
;
/**
/**
* 新增证件
* 新增证件
...
@@ -116,16 +125,19 @@ public class HtzzController {
...
@@ -116,16 +125,19 @@ public class HtzzController {
List
<
NotifyPersonDto
>
ids
=
zzda
.
getIds
();
//通知人 用户id+手机号码
List
<
NotifyPersonDto
>
ids
=
zzda
.
getIds
();
//通知人 用户id+手机号码
List
<
HtzzAssoHtgx
>
htgxs
=
Lists
.
newArrayList
();
List
<
HtzzAssoHtgx
>
htgxs
=
Lists
.
newArrayList
();
for
(
NotifyPersonDto
pre
:
ids
)
{
for
(
NotifyPersonDto
pre
:
ids
)
{
HtzzAssoHtgx
.
builder
().
build
().
delete
(
new
QueryWrapper
<
HtzzAssoHtgx
>().
lambda
().
eq
(
HtzzAssoHtgx:
:
getOrgCode
,
orgCode
).
eq
(
HtzzAssoHtgx:
:
getTzrid
,
pre
.
getEmpNum
())
// HtzzAssoHtgx.builder().build().delete(new QueryWrapper<HtzzAssoHtgx>().lambda().eq(HtzzAssoHtgx::getOrgCode, orgCode).eq(HtzzAssoHtgx::getTzrid, pre.getEmpNum())
.
eq
(
HtzzAssoHtgx:
:
getPhone
,
pre
.
getPhone
()));
// .eq(HtzzAssoHtgx::getPhone, pre.getPhone()));
HtzzAssoHtgx
htgx
=
HtzzAssoHtgx
.
builder
().
build
().
selectOne
(
new
QueryWrapper
<
HtzzAssoHtgx
>().
lambda
().
eq
(
HtzzAssoHtgx:
:
getOrgCode
,
orgCode
).
eq
(
HtzzAssoHtgx:
:
getTzrid
,
pre
.
getEmpNum
())
HtzzAssoHtgx
htgx
=
HtzzAssoHtgx
.
builder
().
build
();
.
eq
(
HtzzAssoHtgx:
:
getPhone
,
pre
.
getPhone
()).
eq
(
HtzzAssoHtgx:
:
getHtid
,
zzda
.
getId
()));
if
(
htgx
==
null
)
{
htgx
=
HtzzAssoHtgx
.
builder
().
build
();
}
htgx
.
setHtid
(
zzda
.
getId
());
htgx
.
setHtid
(
zzda
.
getId
());
htgx
.
setTzrid
(
pre
.
getEmpNum
());
htgx
.
setTzrid
(
pre
.
getEmpNum
());
htgx
.
setName
(
pre
.
getEmpName
());
htgx
.
setName
(
pre
.
getEmpName
());
htgx
.
setPhone
(
pre
.
getPhone
());
htgx
.
setPhone
(
pre
.
getPhone
());
htgx
.
setOrgCode
(
orgCode
);
htgx
.
setOrgCode
(
orgCode
);
htgx
.
insert
();
htgx
.
insert
OrUpdate
();
htgxs
.
add
(
htgx
);
htgxs
.
add
(
htgx
);
}
}
HtzzAssoZztx
zztx
=
zzda
.
getZztx
();
HtzzAssoZztx
zztx
=
zzda
.
getZztx
();
...
@@ -309,19 +321,20 @@ public class HtzzController {
...
@@ -309,19 +321,20 @@ public class HtzzController {
return
ResultUtil
.
error
(
"操作失败"
);
return
ResultUtil
.
error
(
"操作失败"
);
}
}
Map
<
String
,
String
>
url
=
Maps
.
newHashMap
();
Map
<
String
,
String
>
url
=
Maps
.
newHashMap
();
Map
<
String
,
String
>
ftp
=
Maps
.
newHashMap
();
Map
<
String
,
String
>
ftp
=
Maps
.
newHashMap
();
ids
.
forEach
(
i
->
{
ids
.
forEach
(
i
->
{
HtzzAdminZzda
htzzAdminZzda
=
HtzzAdminZzda
.
builder
().
id
(
i
).
build
().
selectById
();
HtzzAdminZzda
htzzAdminZzda
=
HtzzAdminZzda
.
builder
().
id
(
i
).
build
().
selectById
();
if
(
StringUtil
.
isNotBlank
(
htzzAdminZzda
.
getZjfj
()))
{
if
(
StringUtil
.
isNotBlank
(
htzzAdminZzda
.
getZjfj
()))
{
/*格式化获取文字*/
/*格式化获取文字*/
String
urla
=
UrlEncoded
.
decodeString
(
htzzAdminZzda
.
getZjfj
());
String
urla
=
UrlEncoded
.
decodeString
(
htzzAdminZzda
.
getZjfj
());
/*判断是保存在oss还是
ftp
*/
/*判断是保存在oss还是
服务器
*/
if
(
urla
.
contains
(
endpoint
.
replace
(
"http://"
,
"."
)))
{
if
(
urla
.
contains
(
endpoint
.
replace
(
"http://"
,
"."
)))
{
int
index
=
urla
.
indexOf
(
project_package
);
int
index
=
urla
.
indexOf
(
project_package
);
url
.
put
(
htzzAdminZzda
.
getId
()
+
"_"
+
htzzAdminZzda
.
getZjmc
(),
urla
.
substring
(
index
));
url
.
put
(
htzzAdminZzda
.
getId
()
+
"_"
+
htzzAdminZzda
.
getZjmc
(),
urla
.
substring
(
index
));
}
else
{
}
else
{
//TODO 区分出云盘文件暂时不下载
//TODO 区分出云盘文件暂时不下载
ftp
.
put
(
htzzAdminZzda
.
getId
()+
"_"
+
htzzAdminZzda
.
getZjmc
(),
urla
);
StringBuffer
newUrl
=
new
StringBuffer
(
root
).
append
(
targetPath
).
append
(
urla
.
substring
(
serverUrl
.
length
()));
ftp
.
put
(
htzzAdminZzda
.
getId
()
+
"_"
+
htzzAdminZzda
.
getZjmc
(),
newUrl
.
toString
());
}
}
}
}
});
});
...
...
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