明树Git Lab
Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Submit feedback
Sign in
Toggle navigation
J
jt_backend
Project
Project
Details
Activity
Releases
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
zengfanpei
jt_backend
Commits
52707264
Commit
52707264
authored
Jan 13, 2026
by
zfp1
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
1
parent
18727a12
Pipeline
#106046
passed with stage
in 3 seconds
Changes
1
Pipelines
1
Show whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
23 additions
and
19 deletions
+23
-19
projectTzController.js
controller/projectTzController.js
+23
-19
No files found.
controller/projectTzController.js
View file @
52707264
...
@@ -36,7 +36,7 @@ async function createTzmbzrs(req, res, next) {
...
@@ -36,7 +36,7 @@ async function createTzmbzrs(req, res, next) {
return
o
return
o
});
});
console
.
log
(
ret
.
id
,
"====================="
)
console
.
log
(
tzmbzrsZbs
,
"====================="
)
//
//
//创建指标表数据
//创建指标表数据
...
@@ -74,18 +74,22 @@ async function updateTzmbzrs(req, res, next) {
...
@@ -74,18 +74,22 @@ async function updateTzmbzrs(req, res, next) {
tzmbzrsZbs
.
map
(
o
=>
{
if
(
!
o
.
id
)
{
if
(
!
_
.
isEmpty
(
o
))
{
o
.
projectId
=
req
.
body
.
projectId
;
o
.
sourceId
=
ret
.
id
;
newtzmbzrsZbs
.
push
(
o
);
}
}
else
{
ids
.
push
(
o
.
id
);
infos
.
push
(
o
);
}
return
o
});
tzmbzrsZbs
.
map
(
o
=>
{
if
(
!
o
.
id
)
{
if
(
!
_
.
isEmpty
(
o
))
{
o
.
projectId
=
req
.
body
.
projectId
;
o
.
sourceId
=
ret
.
id
;
newtzmbzrsZbs
.
push
(
o
);
}
}
else
{
ids
.
push
(
o
.
id
);
infos
.
push
(
o
);
}
return
o
});
await
DB
.
TzTzmbzrsZb
.
destroy
({
where
:
{
projectId
:
req
.
body
.
projectId
,
sourceId
:
ret
.
id
,
id
:
{
[
Op
.
notIn
]:
ids
}
}
});
// 删除id不在传入id数组里面的(用户在界面删除的)
await
DB
.
TzTzmbzrsZb
.
destroy
({
where
:
{
projectId
:
req
.
body
.
projectId
,
sourceId
:
ret
.
id
,
id
:
{
[
Op
.
notIn
]:
ids
}
}
});
// 删除id不在传入id数组里面的(用户在界面删除的)
await
DB
.
TzTzmbzrsZb
.
bulkCreate
(
newtzmbzrsZbs
);
//创建新的 没有id的
await
DB
.
TzTzmbzrsZb
.
bulkCreate
(
newtzmbzrsZbs
);
//创建新的 没有id的
await
Promise
.
all
(
infos
.
map
(
item
=>
{
DB
.
TzTzmbzrsZb
.
update
(
item
,
{
where
:
{
id
:
item
.
id
}
})
}));
await
Promise
.
all
(
infos
.
map
(
item
=>
{
return
DB
.
TzTzmbzrsZb
.
update
(
item
,
{
where
:
{
id
:
item
.
id
}
})
}));
console
.
log
(
ids
,
infos
,
newtzmbzrsZbs
,
"==================================================================="
)
//1.更新批复意见
//1.更新批复意见
let
ids1
=
[],
infos1
=
[],
newtzmbzrsPfyjs
=
[];
let
ids1
=
[],
infos1
=
[],
newtzmbzrsPfyjs
=
[];
tzmbzrsPfyjs
.
map
(
o
=>
{
if
(
!
o
.
id
)
{
if
(
!
_
.
isEmpty
(
o
))
{
o
.
projectId
=
req
.
body
.
projectId
;
o
.
sourceId
=
ret
.
id
;
newtzmbzrsPfyjs
.
push
(
o
);
}
}
else
{
ids1
.
push
(
o
.
id
);
infos1
.
push
(
o
);
}
return
o
});
tzmbzrsPfyjs
.
map
(
o
=>
{
if
(
!
o
.
id
)
{
if
(
!
_
.
isEmpty
(
o
))
{
o
.
projectId
=
req
.
body
.
projectId
;
o
.
sourceId
=
ret
.
id
;
newtzmbzrsPfyjs
.
push
(
o
);
}
}
else
{
ids1
.
push
(
o
.
id
);
infos1
.
push
(
o
);
}
return
o
});
await
DB
.
TzTzmbzrsPfyj
.
destroy
({
where
:
{
projectId
:
req
.
body
.
projectId
,
sourceId
:
ret
.
id
,
id
:
{
[
Op
.
notIn
]:
ids1
}
}
});
// 删除id不在传入id数组里面的(用户在界面删除的)
await
DB
.
TzTzmbzrsPfyj
.
destroy
({
where
:
{
projectId
:
req
.
body
.
projectId
,
sourceId
:
ret
.
id
,
id
:
{
[
Op
.
notIn
]:
ids1
}
}
});
// 删除id不在传入id数组里面的(用户在界面删除的)
await
DB
.
TzTzmbzrsPfyj
.
bulkCreate
(
newtzmbzrsPfyjs
);
//创建新的 没有id的
await
DB
.
TzTzmbzrsPfyj
.
bulkCreate
(
newtzmbzrsPfyjs
);
//创建新的 没有id的
await
Promise
.
all
(
infos1
.
map
(
item
=>
{
DB
.
TzTzmbzrsPfyj
.
update
(
item
,
{
where
:
{
id
:
item
.
id
}
})
}));
await
Promise
.
all
(
infos1
.
map
(
item
=>
{
return
DB
.
TzTzmbzrsPfyj
.
update
(
item
,
{
where
:
{
id
:
item
.
id
}
})
}));
let
ids2
=
[],
infos2
=
[],
newtzmbzrsNds
=
[];
let
ids2
=
[],
infos2
=
[],
newtzmbzrsNds
=
[];
tzmbzrsNds
.
map
(
o
=>
{
if
(
!
o
.
id
)
{
if
(
!
_
.
isEmpty
(
o
))
{
o
.
projectId
=
req
.
body
.
projectId
;
o
.
sourceId
=
ret
.
id
;
newtzmbzrsNds
.
push
(
o
);
}
}
else
{
ids2
.
push
(
o
.
id
);
infos2
.
push
(
o
);
}
return
o
});
tzmbzrsNds
.
map
(
o
=>
{
if
(
!
o
.
id
)
{
if
(
!
_
.
isEmpty
(
o
))
{
o
.
projectId
=
req
.
body
.
projectId
;
o
.
sourceId
=
ret
.
id
;
newtzmbzrsNds
.
push
(
o
);
}
}
else
{
ids2
.
push
(
o
.
id
);
infos2
.
push
(
o
);
}
return
o
});
await
DB
.
TzTzmbzrsNd
.
destroy
({
where
:
{
projectId
:
req
.
body
.
projectId
,
sourceId
:
ret
.
id
,
id
:
{
[
Op
.
notIn
]:
ids2
}
}
});
// 删除id不在传入id数组里面的(用户在界面删除的)
await
DB
.
TzTzmbzrsNd
.
destroy
({
where
:
{
projectId
:
req
.
body
.
projectId
,
sourceId
:
ret
.
id
,
id
:
{
[
Op
.
notIn
]:
ids2
}
}
});
// 删除id不在传入id数组里面的(用户在界面删除的)
await
DB
.
TzTzmbzrsNd
.
bulkCreate
(
newtzmbzrsNds
);
//创建新的 没有id的
await
DB
.
TzTzmbzrsNd
.
bulkCreate
(
newtzmbzrsNds
);
//创建新的 没有id的
await
Promise
.
all
(
infos2
.
map
(
item
=>
{
DB
.
TzTzmbzrsNd
.
update
(
item
,
{
where
:
{
id
:
item
.
id
}
})
}));
await
Promise
.
all
(
infos2
.
map
(
item
=>
{
return
DB
.
TzTzmbzrsNd
.
update
(
item
,
{
where
:
{
id
:
item
.
id
}
})
}));
//2.更新责任书
//2.更新责任书
await
DB
.
TzTzmbzrs
.
update
(
req
.
body
,
{
where
:
{
id
:
req
.
body
.
id
}
});
await
DB
.
TzTzmbzrs
.
update
(
req
.
body
,
{
where
:
{
id
:
req
.
body
.
id
}
});
...
@@ -245,21 +249,21 @@ async function updateTzkz(req, res, next) {
...
@@ -245,21 +249,21 @@ async function updateTzkz(req, res, next) {
req
.
body
.
tzkzcwpjs
.
map
(
o
=>
{
if
(
!
o
.
id
)
{
if
(
!
_
.
isEmpty
(
o
))
{
o
.
projectId
=
req
.
body
.
projectId
;
o
.
sourceId
=
ret
.
id
;
newtzkzcwpjs
.
push
(
o
);
}
}
else
{
ids
.
push
(
o
.
id
);
infos
.
push
(
o
);
}
return
o
});
req
.
body
.
tzkzcwpjs
.
map
(
o
=>
{
if
(
!
o
.
id
)
{
if
(
!
_
.
isEmpty
(
o
))
{
o
.
projectId
=
req
.
body
.
projectId
;
o
.
sourceId
=
ret
.
id
;
newtzkzcwpjs
.
push
(
o
);
}
}
else
{
ids
.
push
(
o
.
id
);
infos
.
push
(
o
);
}
return
o
});
await
DB
.
TzTzkzCwpj
.
destroy
({
where
:
{
projectId
:
req
.
body
.
projectId
,
sourceId
:
ret
.
id
,
id
:
{
[
Op
.
notIn
]:
ids
}
}
});
// 删除id不在传入id数组里面的(用户在界面删除的)
await
DB
.
TzTzkzCwpj
.
destroy
({
where
:
{
projectId
:
req
.
body
.
projectId
,
sourceId
:
ret
.
id
,
id
:
{
[
Op
.
notIn
]:
ids
}
}
});
// 删除id不在传入id数组里面的(用户在界面删除的)
await
DB
.
TzTzkzCwpj
.
bulkCreate
(
newtzkzcwpjs
);
//创建新的 没有id的
await
DB
.
TzTzkzCwpj
.
bulkCreate
(
newtzkzcwpjs
);
//创建新的 没有id的
await
Promise
.
all
(
infos
.
map
(
item
=>
{
DB
.
TzTzkzCwpj
.
update
(
item
,
{
where
:
{
id
:
item
.
id
}
})
}));
await
Promise
.
all
(
infos
.
map
(
item
=>
{
return
DB
.
TzTzkzCwpj
.
update
(
item
,
{
where
:
{
id
:
item
.
id
}
})
}));
delete
req
.
body
.
tzkzcwpjs
;
delete
req
.
body
.
tzkzcwpjs
;
//处理决策批复意见
//处理决策批复意见
let
ids1
=
[],
infos1
=
[],
newtzkzjcpfyjs
=
[];
let
ids1
=
[],
infos1
=
[],
newtzkzjcpfyjs
=
[];
req
.
body
.
tzkzjcpfyjs
.
map
(
o
=>
{
if
(
!
o
.
id
)
{
if
(
!
_
.
isEmpty
(
o
))
{
o
.
projectId
=
req
.
body
.
projectId
;
o
.
sourceId
=
ret
.
id
;
newtzkzjcpfyjs
.
push
(
o
);
}
}
else
{
ids1
.
push
(
o
.
id
);
infos1
.
push
(
o
);
}
return
o
});
req
.
body
.
tzkzjcpfyjs
.
map
(
o
=>
{
if
(
!
o
.
id
)
{
if
(
!
_
.
isEmpty
(
o
))
{
o
.
projectId
=
req
.
body
.
projectId
;
o
.
sourceId
=
ret
.
id
;
newtzkzjcpfyjs
.
push
(
o
);
}
}
else
{
ids1
.
push
(
o
.
id
);
infos1
.
push
(
o
);
}
return
o
});
await
DB
.
TzTzkzJcpfyj
.
destroy
({
where
:
{
projectId
:
req
.
body
.
projectId
,
sourceId
:
ret
.
id
,
id
:
{
[
Op
.
notIn
]:
ids1
}
}
});
// 删除id不在传入id数组里面的(用户在界面删除的)
await
DB
.
TzTzkzJcpfyj
.
destroy
({
where
:
{
projectId
:
req
.
body
.
projectId
,
sourceId
:
ret
.
id
,
id
:
{
[
Op
.
notIn
]:
ids1
}
}
});
// 删除id不在传入id数组里面的(用户在界面删除的)
await
DB
.
TzTzkzJcpfyj
.
bulkCreate
(
newtzkzjcpfyjs
);
//创建新的 没有id的
await
DB
.
TzTzkzJcpfyj
.
bulkCreate
(
newtzkzjcpfyjs
);
//创建新的 没有id的
await
Promise
.
all
(
infos1
.
map
(
item
=>
{
DB
.
TzTzkzJcpfyj
.
update
(
item
,
{
where
:
{
id
:
item
.
id
}
})
}));
await
Promise
.
all
(
infos1
.
map
(
item
=>
{
return
DB
.
TzTzkzJcpfyj
.
update
(
item
,
{
where
:
{
id
:
item
.
id
}
})
}));
delete
req
.
body
.
tzkzjcpfyjs
;
delete
req
.
body
.
tzkzjcpfyjs
;
//处理投资收益
//处理投资收益
let
ids2
=
[],
infos2
=
[],
newtzkztzsys
=
[];
let
ids2
=
[],
infos2
=
[],
newtzkztzsys
=
[];
req
.
body
.
tzkztzsys
.
map
(
o
=>
{
if
(
!
o
.
id
)
{
if
(
!
_
.
isEmpty
(
o
))
{
o
.
projectId
=
req
.
body
.
projectId
;
o
.
sourceId
=
ret
.
id
;
newtzkztzsys
.
push
(
o
);
}
}
else
{
ids2
.
push
(
o
.
id
);
infos2
.
push
(
o
);
}
return
o
});
req
.
body
.
tzkztzsys
.
map
(
o
=>
{
if
(
!
o
.
id
)
{
if
(
!
_
.
isEmpty
(
o
))
{
o
.
projectId
=
req
.
body
.
projectId
;
o
.
sourceId
=
ret
.
id
;
newtzkztzsys
.
push
(
o
);
}
}
else
{
ids2
.
push
(
o
.
id
);
infos2
.
push
(
o
);
}
return
o
});
await
DB
.
TzTzkzTzsy
.
destroy
({
where
:
{
projectId
:
req
.
body
.
projectId
,
sourceId
:
ret
.
id
,
id
:
{
[
Op
.
notIn
]:
ids2
}
}
});
// 删除id不在传入id数组里面的(用户在界面删除的)
await
DB
.
TzTzkzTzsy
.
destroy
({
where
:
{
projectId
:
req
.
body
.
projectId
,
sourceId
:
ret
.
id
,
id
:
{
[
Op
.
notIn
]:
ids2
}
}
});
// 删除id不在传入id数组里面的(用户在界面删除的)
await
DB
.
TzTzkzTzsy
.
bulkCreate
(
newtzkztzsys
);
//创建新的 没有id的
await
DB
.
TzTzkzTzsy
.
bulkCreate
(
newtzkztzsys
);
//创建新的 没有id的
await
Promise
.
all
(
infos2
.
map
(
item
=>
{
DB
.
TzTzkzTzsy
.
update
(
item
,
{
where
:
{
id
:
item
.
id
}
})
}));
await
Promise
.
all
(
infos2
.
map
(
item
=>
{
return
DB
.
TzTzkzTzsy
.
update
(
item
,
{
where
:
{
id
:
item
.
id
}
})
}));
delete
req
.
body
.
tzkztzsys
;
delete
req
.
body
.
tzkztzsys
;
//处理投资额控制
//处理投资额控制
let
tzkztzekzs
=
req
.
body
.
tzkztzekzs
||
[[]];
//二维数组 多次上报
let
tzkztzekzs
=
req
.
body
.
tzkztzekzs
||
[[]];
//二维数组 多次上报
...
@@ -282,7 +286,7 @@ async function updateTzkz(req, res, next) {
...
@@ -282,7 +286,7 @@ async function updateTzkz(req, res, next) {
}
}
await
DB
.
TzTzkzTzekz
.
destroy
({
where
:
{
projectId
:
req
.
body
.
projectId
,
sourceId
:
ret
.
id
,
id
:
{
[
Op
.
notIn
]:
ids3
}
}
});
// 删除id不在传入id数组里面的(用户在界面删除的)
await
DB
.
TzTzkzTzekz
.
destroy
({
where
:
{
projectId
:
req
.
body
.
projectId
,
sourceId
:
ret
.
id
,
id
:
{
[
Op
.
notIn
]:
ids3
}
}
});
// 删除id不在传入id数组里面的(用户在界面删除的)
await
DB
.
TzTzkzTzekz
.
bulkCreate
(
newtzkztzekzs
);
//创建新的 没有id的
await
DB
.
TzTzkzTzekz
.
bulkCreate
(
newtzkztzekzs
);
//创建新的 没有id的
await
Promise
.
all
(
infos3
.
map
(
item
=>
{
DB
.
TzTzkzTzekz
.
update
(
item
,
{
where
:
{
id
:
item
.
id
}
})
}));
await
Promise
.
all
(
infos3
.
map
(
item
=>
{
return
DB
.
TzTzkzTzekz
.
update
(
item
,
{
where
:
{
id
:
item
.
id
}
})
}));
delete
req
.
body
.
tzkztzekzs
;
delete
req
.
body
.
tzkztzekzs
;
//处理工期
//处理工期
...
@@ -290,14 +294,14 @@ async function updateTzkz(req, res, next) {
...
@@ -290,14 +294,14 @@ async function updateTzkz(req, res, next) {
req
.
body
.
tzkzgqs
.
map
(
o
=>
{
if
(
!
o
.
id
)
{
if
(
!
_
.
isEmpty
(
o
))
{
o
.
projectId
=
req
.
body
.
projectId
;
o
.
sourceId
=
ret
.
id
;
newtzkzgqs
.
push
(
o
);
}
}
else
{
ids4
.
push
(
o
.
id
);
infos4
.
push
(
o
);
}
return
o
});
req
.
body
.
tzkzgqs
.
map
(
o
=>
{
if
(
!
o
.
id
)
{
if
(
!
_
.
isEmpty
(
o
))
{
o
.
projectId
=
req
.
body
.
projectId
;
o
.
sourceId
=
ret
.
id
;
newtzkzgqs
.
push
(
o
);
}
}
else
{
ids4
.
push
(
o
.
id
);
infos4
.
push
(
o
);
}
return
o
});
await
DB
.
TzTzkzGq
.
destroy
({
where
:
{
projectId
:
req
.
body
.
projectId
,
sourceId
:
ret
.
id
,
id
:
{
[
Op
.
notIn
]:
ids4
}
}
});
// 删除id不在传入id数组里面的(用户在界面删除的)
await
DB
.
TzTzkzGq
.
destroy
({
where
:
{
projectId
:
req
.
body
.
projectId
,
sourceId
:
ret
.
id
,
id
:
{
[
Op
.
notIn
]:
ids4
}
}
});
// 删除id不在传入id数组里面的(用户在界面删除的)
await
DB
.
TzTzkzGq
.
bulkCreate
(
newtzkzgqs
);
//创建新的 没有id的
await
DB
.
TzTzkzGq
.
bulkCreate
(
newtzkzgqs
);
//创建新的 没有id的
await
Promise
.
all
(
infos4
.
map
(
item
=>
{
DB
.
TzTzkzGq
.
update
(
item
,
{
where
:
{
id
:
item
.
id
}
})
}));
await
Promise
.
all
(
infos4
.
map
(
item
=>
{
return
DB
.
TzTzkzGq
.
update
(
item
,
{
where
:
{
id
:
item
.
id
}
})
}));
delete
req
.
body
.
tzkzgqs
;
delete
req
.
body
.
tzkzgqs
;
//处理环保
//处理环保
let
ids5
=
[],
infos5
=
[],
newtzkzaqzlhbs
=
[];
let
ids5
=
[],
infos5
=
[],
newtzkzaqzlhbs
=
[];
req
.
body
.
tzkzaqzlhbs
.
map
(
o
=>
{
if
(
!
o
.
id
)
{
if
(
!
_
.
isEmpty
(
o
))
{
o
.
projectId
=
req
.
body
.
projectId
;
o
.
sourceId
=
ret
.
id
;
newtzkzaqzlhbs
.
push
(
o
);
}
}
else
{
ids5
.
push
(
o
.
id
);
infos5
.
push
(
o
);
}
return
o
});
req
.
body
.
tzkzaqzlhbs
.
map
(
o
=>
{
if
(
!
o
.
id
)
{
if
(
!
_
.
isEmpty
(
o
))
{
o
.
projectId
=
req
.
body
.
projectId
;
o
.
sourceId
=
ret
.
id
;
newtzkzaqzlhbs
.
push
(
o
);
}
}
else
{
ids5
.
push
(
o
.
id
);
infos5
.
push
(
o
);
}
return
o
});
await
DB
.
TzTzkzAqzlhb
.
destroy
({
where
:
{
projectId
:
req
.
body
.
projectId
,
sourceId
:
ret
.
id
,
id
:
{
[
Op
.
notIn
]:
ids5
}
}
});
// 删除id不在传入id数组里面的(用户在界面删除的)
await
DB
.
TzTzkzAqzlhb
.
destroy
({
where
:
{
projectId
:
req
.
body
.
projectId
,
sourceId
:
ret
.
id
,
id
:
{
[
Op
.
notIn
]:
ids5
}
}
});
// 删除id不在传入id数组里面的(用户在界面删除的)
await
DB
.
TzTzkzAqzlhb
.
bulkCreate
(
newtzkzaqzlhbs
);
//创建新的 没有id的
await
DB
.
TzTzkzAqzlhb
.
bulkCreate
(
newtzkzaqzlhbs
);
//创建新的 没有id的
await
Promise
.
all
(
infos5
.
map
(
item
=>
{
DB
.
TzTzkzAqzlhb
.
update
(
item
,
{
where
:
{
id
:
item
.
id
}
})
}));
await
Promise
.
all
(
infos5
.
map
(
item
=>
{
return
DB
.
TzTzkzAqzlhb
.
update
(
item
,
{
where
:
{
id
:
item
.
id
}
})
}));
delete
req
.
body
.
tzkzaqzlhbs
;
delete
req
.
body
.
tzkzaqzlhbs
;
await
DB
.
TzTzkz
.
update
(
req
.
body
,
{
where
:
{
id
:
req
.
body
.
id
}
});
await
DB
.
TzTzkz
.
update
(
req
.
body
,
{
where
:
{
id
:
req
.
body
.
id
}
});
...
@@ -458,21 +462,21 @@ async function updateZdfx(req, res, next) {
...
@@ -458,21 +462,21 @@ async function updateZdfx(req, res, next) {
// req.body.zdfxcwzbs.map(o => { if (!o.id) { if (!_.isEmpty(o)) { o.projectId = req.body.projectId; newzdfxcwzbs.push(o); } } else { ids.push(o.id); infos.push(o); } return o });
// req.body.zdfxcwzbs.map(o => { if (!o.id) { if (!_.isEmpty(o)) { o.projectId = req.body.projectId; newzdfxcwzbs.push(o); } } else { ids.push(o.id); infos.push(o); } return o });
// await DB.TzZdfxcwzb.destroy({ where: { projectId: req.body.projectId, id: { [Op.notIn]: ids } } }); // 删除id不在传入id数组里面的(用户在界面删除的)
// await DB.TzZdfxcwzb.destroy({ where: { projectId: req.body.projectId, id: { [Op.notIn]: ids } } }); // 删除id不在传入id数组里面的(用户在界面删除的)
// await DB.TzZdfxcwzb.bulkCreate(newzdfxcwzbs);//创建新的 没有id的
// await DB.TzZdfxcwzb.bulkCreate(newzdfxcwzbs);//创建新的 没有id的
// await Promise.all(infos.map(item => { DB.TzZdfxcwzb.update(item, { where: { id: item.id } }) }));
// await Promise.all(infos.map(item => {
return
DB.TzZdfxcwzb.update(item, { where: { id: item.id } }) }));
// delete req.body.zdfxcwzbs;
// delete req.body.zdfxcwzbs;
//处理风险处置
//处理风险处置
let
ids1
=
[],
infos1
=
[],
newzdfxczs
=
[];
let
ids1
=
[],
infos1
=
[],
newzdfxczs
=
[];
req
.
body
.
zdfxczs
.
map
(
o
=>
{
if
(
!
o
.
id
)
{
if
(
!
_
.
isEmpty
(
o
))
{
o
.
projectId
=
req
.
body
.
projectId
;
o
.
sourceId
=
ret
.
id
;
newzdfxczs
.
push
(
o
);
}
}
else
{
ids1
.
push
(
o
.
id
);
infos1
.
push
(
o
);
}
return
o
});
req
.
body
.
zdfxczs
.
map
(
o
=>
{
if
(
!
o
.
id
)
{
if
(
!
_
.
isEmpty
(
o
))
{
o
.
projectId
=
req
.
body
.
projectId
;
o
.
sourceId
=
ret
.
id
;
newzdfxczs
.
push
(
o
);
}
}
else
{
ids1
.
push
(
o
.
id
);
infos1
.
push
(
o
);
}
return
o
});
await
DB
.
TzZdfxcz
.
destroy
({
where
:
{
projectId
:
req
.
body
.
projectId
,
sourceId
:
ret
.
id
,
id
:
{
[
Op
.
notIn
]:
ids1
}
}
});
// 删除id不在传入id数组里面的(用户在界面删除的)
await
DB
.
TzZdfxcz
.
destroy
({
where
:
{
projectId
:
req
.
body
.
projectId
,
sourceId
:
ret
.
id
,
id
:
{
[
Op
.
notIn
]:
ids1
}
}
});
// 删除id不在传入id数组里面的(用户在界面删除的)
await
DB
.
TzZdfxcz
.
bulkCreate
(
newzdfxczs
);
//创建新的 没有id的
await
DB
.
TzZdfxcz
.
bulkCreate
(
newzdfxczs
);
//创建新的 没有id的
await
Promise
.
all
(
infos1
.
map
(
item
=>
{
DB
.
TzZdfxcz
.
update
(
item
,
{
where
:
{
id
:
item
.
id
}
})
}));
await
Promise
.
all
(
infos1
.
map
(
item
=>
{
return
DB
.
TzZdfxcz
.
update
(
item
,
{
where
:
{
id
:
item
.
id
}
})
}));
delete
req
.
body
.
zdfxczs
;
delete
req
.
body
.
zdfxczs
;
// //处理风险情况
// //处理风险情况
// let ids2 = [], infos2 = [], newzdfxqks = [];
// let ids2 = [], infos2 = [], newzdfxqks = [];
// req.body.zdfxqks.map(o => { if (!o.id) { if (!_.isEmpty(o)) { o.projectId = req.body.projectId; newzdfxqks.push(o); } } else { ids2.push(o.id); infos2.push(o); } return o });
// req.body.zdfxqks.map(o => { if (!o.id) { if (!_.isEmpty(o)) { o.projectId = req.body.projectId; newzdfxqks.push(o); } } else { ids2.push(o.id); infos2.push(o); } return o });
// await DB.TzZdfxcwzb.destroy({ where: { projectId: req.body.projectId, id: { [Op.notIn]: ids2 } } }); // 删除id不在传入id数组里面的(用户在界面删除的)
// await DB.TzZdfxcwzb.destroy({ where: { projectId: req.body.projectId, id: { [Op.notIn]: ids2 } } }); // 删除id不在传入id数组里面的(用户在界面删除的)
// await DB.TzZdfxcwzb.bulkCreate(newzdfxqks);//创建新的 没有id的
// await DB.TzZdfxcwzb.bulkCreate(newzdfxqks);//创建新的 没有id的
// await Promise.all(infos2.map(item => { DB.TzZdfxcwzb.update(item, { where: { id: item.id } }) }));
// await Promise.all(infos2.map(item => {
return
DB.TzZdfxcwzb.update(item, { where: { id: item.id } }) }));
// delete req.body.zdfxqks;
// delete req.body.zdfxqks;
await
DB
.
TzZdfx
.
update
(
req
.
body
,
{
where
:
{
id
:
req
.
body
.
id
}
});
await
DB
.
TzZdfx
.
update
(
req
.
body
,
{
where
:
{
id
:
req
.
body
.
id
}
});
...
@@ -592,7 +596,7 @@ async function updateJsqtzhs(req, res, next) {
...
@@ -592,7 +596,7 @@ async function updateJsqtzhs(req, res, next) {
}
}
await
DB
.
TzJsqtzhszb
.
destroy
({
where
:
{
projectId
:
req
.
body
.
projectId
,
sourceId
:
tzhs
.
id
,
id
:
{
[
Op
.
notIn
]:
ids3
}
}
});
// 删除id不在传入id数组里面的(用户在界面删除的)
await
DB
.
TzJsqtzhszb
.
destroy
({
where
:
{
projectId
:
req
.
body
.
projectId
,
sourceId
:
tzhs
.
id
,
id
:
{
[
Op
.
notIn
]:
ids3
}
}
});
// 删除id不在传入id数组里面的(用户在界面删除的)
await
DB
.
TzJsqtzhszb
.
bulkCreate
(
newtjsqtzhss
);
//创建新的 没有id的
await
DB
.
TzJsqtzhszb
.
bulkCreate
(
newtjsqtzhss
);
//创建新的 没有id的
await
Promise
.
all
(
infos3
.
map
(
item
=>
{
DB
.
TzJsqtzhszb
.
update
(
item
,
{
where
:
{
id
:
item
.
id
}
})
}));
await
Promise
.
all
(
infos3
.
map
(
item
=>
{
return
DB
.
TzJsqtzhszb
.
update
(
item
,
{
where
:
{
id
:
item
.
id
}
})
}));
delete
req
.
body
.
jsqtzhss
;
delete
req
.
body
.
jsqtzhss
;
await
DB
.
TzJsqtzhs
.
update
(
req
.
body
,
{
where
:
{
id
:
req
.
body
.
id
}
});
await
DB
.
TzJsqtzhs
.
update
(
req
.
body
,
{
where
:
{
id
:
req
.
body
.
id
}
});
...
@@ -758,7 +762,7 @@ async function updateJsqtzjc(req, res, next) {
...
@@ -758,7 +762,7 @@ async function updateJsqtzjc(req, res, next) {
}
}
await
DB
.
TzJsqtzjcTzfx
.
destroy
({
where
:
{
projectId
:
req
.
body
.
projectId
,
sourceId
:
jsqtzjc
.
id
,
id
:
{
[
Op
.
notIn
]:
ids
}
}
});
// 删除id不在传入id数组里面的(用户在界面删除的)
await
DB
.
TzJsqtzjcTzfx
.
destroy
({
where
:
{
projectId
:
req
.
body
.
projectId
,
sourceId
:
jsqtzjc
.
id
,
id
:
{
[
Op
.
notIn
]:
ids
}
}
});
// 删除id不在传入id数组里面的(用户在界面删除的)
await
DB
.
TzJsqtzjcTzfx
.
bulkCreate
(
newArr
);
//创建新的 没有id的
await
DB
.
TzJsqtzjcTzfx
.
bulkCreate
(
newArr
);
//创建新的 没有id的
await
Promise
.
all
(
info
.
map
(
item
=>
{
DB
.
TzJsqtzjcTzfx
.
update
(
item
,
{
where
:
{
id
:
item
.
id
}
})
}));
await
Promise
.
all
(
info
.
map
(
item
=>
{
return
DB
.
TzJsqtzjcTzfx
.
update
(
item
,
{
where
:
{
id
:
item
.
id
}
})
}));
delete
req
.
body
.
jsqtzjcTzfxs
;
delete
req
.
body
.
jsqtzjcTzfxs
;
// let jsqtzjcrcjcs = req.body.jsqtzjcrcjcs || [];
// let jsqtzjcrcjcs = req.body.jsqtzjcrcjcs || [];
...
@@ -776,7 +780,7 @@ async function updateJsqtzjc(req, res, next) {
...
@@ -776,7 +780,7 @@ async function updateJsqtzjc(req, res, next) {
// }
// }
// await DB.TzJsqtzjcrcjc.destroy({ where: { projectId: req.body.projectId, id: { [Op.notIn]: ids1 } } }); // 删除id不在传入id数组里面的(用户在界面删除的)
// await DB.TzJsqtzjcrcjc.destroy({ where: { projectId: req.body.projectId, id: { [Op.notIn]: ids1 } } }); // 删除id不在传入id数组里面的(用户在界面删除的)
// await DB.TzJsqtzjcrcjc.bulkCreate(newArr1);//创建新的 没有id的
// await DB.TzJsqtzjcrcjc.bulkCreate(newArr1);//创建新的 没有id的
// await Promise.all(info1.map(item => { DB.TzJsqtzjcrcjc.update(item, { where: { id: item.id } }) }));
// await Promise.all(info1.map(item => {
return
DB.TzJsqtzjcrcjc.update(item, { where: { id: item.id } }) }));
// delete req.body.jsqtzjcrcjcs;
// delete req.body.jsqtzjcrcjcs;
...
@@ -796,7 +800,7 @@ async function updateJsqtzjc(req, res, next) {
...
@@ -796,7 +800,7 @@ async function updateJsqtzjc(req, res, next) {
}
}
await
DB
.
TzJsqtzjcZxjc
.
destroy
({
where
:
{
projectId
:
req
.
body
.
projectId
,
sourceId
:
jsqtzjc
.
id
,
id
:
{
[
Op
.
notIn
]:
ids2
}
}
});
// 删除id不在传入id数组里面的(用户在界面删除的)
await
DB
.
TzJsqtzjcZxjc
.
destroy
({
where
:
{
projectId
:
req
.
body
.
projectId
,
sourceId
:
jsqtzjc
.
id
,
id
:
{
[
Op
.
notIn
]:
ids2
}
}
});
// 删除id不在传入id数组里面的(用户在界面删除的)
await
DB
.
TzJsqtzjcZxjc
.
bulkCreate
(
newArr2
);
//创建新的 没有id的
await
DB
.
TzJsqtzjcZxjc
.
bulkCreate
(
newArr2
);
//创建新的 没有id的
await
Promise
.
all
(
info2
.
map
(
item
=>
{
DB
.
TzJsqtzjcZxjc
.
update
(
item
,
{
where
:
{
id
:
item
.
id
}
})
}));
await
Promise
.
all
(
info2
.
map
(
item
=>
{
return
DB
.
TzJsqtzjcZxjc
.
update
(
item
,
{
where
:
{
id
:
item
.
id
}
})
}));
delete
req
.
body
.
jsqtzjcZxjcs
;
delete
req
.
body
.
jsqtzjcZxjcs
;
await
DB
.
TzJsqtzjc
.
update
(
req
.
body
,
{
where
:
{
id
:
req
.
body
.
id
}
});
await
DB
.
TzJsqtzjc
.
update
(
req
.
body
,
{
where
:
{
id
:
req
.
body
.
id
}
});
...
@@ -920,7 +924,7 @@ async function updateZdsxsp(req, res, next) {
...
@@ -920,7 +924,7 @@ async function updateZdsxsp(req, res, next) {
}
}
await
DB
.
TzZdsxspfl
.
destroy
({
where
:
{
projectId
:
req
.
body
.
projectId
,
sourceId
:
zdsxsp
.
id
,
id
:
{
[
Op
.
notIn
]:
ids
}
}
});
// 删除id不在传入id数组里面的(用户在界面删除的)
await
DB
.
TzZdsxspfl
.
destroy
({
where
:
{
projectId
:
req
.
body
.
projectId
,
sourceId
:
zdsxsp
.
id
,
id
:
{
[
Op
.
notIn
]:
ids
}
}
});
// 删除id不在传入id数组里面的(用户在界面删除的)
await
DB
.
TzZdsxspfl
.
bulkCreate
(
newArr
);
//创建新的 没有id的
await
DB
.
TzZdsxspfl
.
bulkCreate
(
newArr
);
//创建新的 没有id的
await
Promise
.
all
(
info
.
map
(
item
=>
{
DB
.
TzZdsxspfl
.
update
(
item
,
{
where
:
{
id
:
item
.
id
}
})
}));
await
Promise
.
all
(
info
.
map
(
item
=>
{
return
DB
.
TzZdsxspfl
.
update
(
item
,
{
where
:
{
id
:
item
.
id
}
})
}));
delete
req
.
body
.
zdsxspfls
;
delete
req
.
body
.
zdsxspfls
;
await
DB
.
TzZdsxsp
.
update
(
req
.
body
,
{
where
:
{
id
:
req
.
body
.
id
}
});
await
DB
.
TzZdsxsp
.
update
(
req
.
body
,
{
where
:
{
id
:
req
.
body
.
id
}
});
...
@@ -1024,7 +1028,7 @@ async function updateXmtc(req, res, next) {
...
@@ -1024,7 +1028,7 @@ async function updateXmtc(req, res, next) {
}
}
await
DB
.
TzXmtcCwzb
.
destroy
({
where
:
{
projectId
:
req
.
body
.
projectId
,
id
:
{
[
Op
.
notIn
]:
ids
}
}
});
// 删除id不在传入id数组里面的(用户在界面删除的)
await
DB
.
TzXmtcCwzb
.
destroy
({
where
:
{
projectId
:
req
.
body
.
projectId
,
id
:
{
[
Op
.
notIn
]:
ids
}
}
});
// 删除id不在传入id数组里面的(用户在界面删除的)
await
DB
.
TzXmtcCwzb
.
bulkCreate
(
newArr
);
//创建新的 没有id的
await
DB
.
TzXmtcCwzb
.
bulkCreate
(
newArr
);
//创建新的 没有id的
await
Promise
.
all
(
info
.
map
(
item
=>
{
DB
.
TzXmtcCwzb
.
update
(
item
,
{
where
:
{
id
:
item
.
id
}
})
}));
await
Promise
.
all
(
info
.
map
(
item
=>
{
return
DB
.
TzXmtcCwzb
.
update
(
item
,
{
where
:
{
id
:
item
.
id
}
})
}));
delete
req
.
body
.
tccwzbs
;
delete
req
.
body
.
tccwzbs
;
await
DB
.
TzXmtc
.
update
(
req
.
body
,
{
where
:
{
id
:
req
.
body
.
id
}
});
await
DB
.
TzXmtc
.
update
(
req
.
body
,
{
where
:
{
id
:
req
.
body
.
id
}
});
...
...
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