明树Git Lab

Commit 0fb101f0 authored by zfp1's avatar zfp1

update

parent 2b987a13
Pipeline #104038 passed with stage
in 3 seconds
...@@ -205,49 +205,49 @@ async function updateProject(req, res, next) { ...@@ -205,49 +205,49 @@ async function updateProject(req, res, next) {
projectJsgms.map(o => { if (!o.id) { if(!_.isEmpty(o)){o.projectId = project.id; newprojectJsgms.push(o);} } else { pnids1.push(o.id); pns1.push(o); } return o }); projectJsgms.map(o => { if (!o.id) { if(!_.isEmpty(o)){o.projectId = project.id; newprojectJsgms.push(o);} } else { pnids1.push(o.id); pns1.push(o); } return o });
await DB.ProjectJsgm.destroy({ where: { projectId: project.id, id: { [Op.notIn]: pnids1 } } }); await DB.ProjectJsgm.destroy({ where: { projectId: project.id, id: { [Op.notIn]: pnids1 } } });
await DB.ProjectJsgm.bulkCreate(newprojectJsgms); await DB.ProjectJsgm.bulkCreate(newprojectJsgms);
await Promise.all(pns1.map(item => {DB.ProjectJsgm.update(item), {where: {id: item.id}}})); await Promise.all(pns1.map(item => {DB.ProjectJsgm.update(item, {where: {id: item.id}})}));
// 处理 projectGdxxs // 处理 projectGdxxs
let projectGdxxs = body.projectGdxxs || []; let projectGdxxs = body.projectGdxxs || [];
let pnids2 = [], pns2 = [], newprojectGdxxs = []; let pnids2 = [], pns2 = [], newprojectGdxxs = [];
projectGdxxs.map(o => { if (!o.id) { if(!_.isEmpty(o)) {o.projectId = project.id; newprojectGdxxs.push(o);} } else { pnids2.push(o.id); pns2.push(o); } return o }); projectGdxxs.map(o => { if (!o.id) { if(!_.isEmpty(o)) {o.projectId = project.id; newprojectGdxxs.push(o);} } else { pnids2.push(o.id); pns2.push(o); } return o });
await DB.ProjectGdxx.destroy({ where: { projectId: project.id, id: { [Op.notIn]: pnids2 } } }); await DB.ProjectGdxx.destroy({ where: { projectId: project.id, id: { [Op.notIn]: pnids2 } } });
await DB.ProjectGdxx.bulkCreate(newprojectGdxxs); await DB.ProjectGdxx.bulkCreate(newprojectGdxxs);
await Promise.all(pns2.map(item => {DB.ProjectGdxx.update(item), {where: {id: item.id}}})); await Promise.all(pns2.map(item => {DB.ProjectGdxx.update(item, {where: {id: item.id}})}));
// 处理 projectXmtzzes // 处理 projectXmtzzes
let projectXmtzzes = body.projectXmtzzes || []; let projectXmtzzes = body.projectXmtzzes || [];
projectXmtzzes = utils.flattenTree(projectXmtzzes, 'xh', 'parentXh'); projectXmtzzes = utils.flattenTree(projectXmtzzes, 'xh', 'parentXh');
let pnids3 = [], pns3 = [], newprojectXmtzzes = []; let pnids3 = [], pns3 = [], newprojectXmtzzes = [];
projectXmtzzes.map(o => { if (!o.id) { if(!_.isEmpty(o)) {o.projectId = project.id; newprojectXmtzzes.push(o);} } else { pnids3.push(o.id); pns3.push(o); } return o }); projectXmtzzes.map(o => { if (!o.id) { if(!_.isEmpty(o)) {o.projectId = project.id; newprojectXmtzzes.push(o);} } else { pnids3.push(o.id); pns3.push(o); } return o });
await DB.ProjectXmtzze.bulkCreate(newprojectXmtzzes); await DB.ProjectXmtzze.bulkCreate(newprojectXmtzzes);
await Promise.all(pns3.map(item => {DB.ProjectXmtzze.update(item), {where: {id: item.id}}})); await Promise.all(pns3.map(item => {DB.ProjectXmtzze.update(item, {where: {id: item.id}})}));
// 处理 projectBjtjs // 处理 projectBjtjs
let projectBjtjs = body.projectBjtjs || []; let projectBjtjs = body.projectBjtjs || [];
let pnids4 = [],pns4 = [], newprojectBjtjs = []; let pnids4 = [],pns4 = [], newprojectBjtjs = [];
projectBjtjs.map(o => { if (!o.id) { if(!_.isEmpty(o)) {o.projectId = project.id; newprojectBjtjs.push(o);} } else { pnids4.push(o.id);pns4.push(o); } return o }); projectBjtjs.map(o => { if (!o.id) { if(!_.isEmpty(o)) {o.projectId = project.id; newprojectBjtjs.push(o);} } else { pnids4.push(o.id);pns4.push(o); } return o });
await DB.ProjectBjtj.destroy({ where: { projectId: project.id, id: { [Op.notIn]: pnids4 } } }); await DB.ProjectBjtj.destroy({ where: { projectId: project.id, id: { [Op.notIn]: pnids4 } } });
await DB.ProjectBjtj.bulkCreate(newprojectBjtjs); await DB.ProjectBjtj.bulkCreate(newprojectBjtjs);
await Promise.all(pns4.map(item => {DB.ProjectBjtj.update(item), {where: {id: item.id}}})); await Promise.all(pns4.map(item => {DB.ProjectBjtj.update(item, {where: {id: item.id}})}));
// 处理 projectFxgl // 处理 projectFxgl
let projectFxgls = body.projectFxgls || []; let projectFxgls = body.projectFxgls || [];
let pnids5 = [], pns5 =[], newprojectFxgls = []; let pnids5 = [], pns5 =[], newprojectFxgls = [];
projectFxgls.map(o => { if (!o.id) { if(!_.isEmpty(o)) {o.projectId = project.id; newprojectFxgls.push(o);} } else { pnids5.push(o.id); pns5.push(o); } return o }); projectFxgls.map(o => { if (!o.id) { if(!_.isEmpty(o)) {o.projectId = project.id; newprojectFxgls.push(o);} } else { pnids5.push(o.id); pns5.push(o); } return o });
await DB.ProjectFxgl.destroy({ where: { projectId: project.id, id: { [Op.notIn]: pnids5 } } }); await DB.ProjectFxgl.destroy({ where: { projectId: project.id, id: { [Op.notIn]: pnids5 } } });
await DB.ProjectFxgl.bulkCreate(newprojectFxgls); await DB.ProjectFxgl.bulkCreate(newprojectFxgls);
await Promise.all(pns5.map(item => {DB.ProjectFxgl.update(item), {where: {id: item.id}}})); await Promise.all(pns5.map(item => {DB.ProjectFxgl.update(item, {where: {id: item.id}})}));
// 处理 ProjectTzzt // 处理 ProjectTzzt
let projectTzzts = body.projectTzzts || []; let projectTzzts = body.projectTzzts || [];
let pnids6 = [], pns6 =[],newprojectTzzts = []; let pnids6 = [], pns6 =[],newprojectTzzts = [];
projectTzzts.map(o => { if (!o.id) { if(!_.isEmpty(o)) {o.projectId = project.id; newprojectTzzts.push(o);} } else { pnids6.push(o.id); pns6.push(o); } return o }); projectTzzts.map(o => { if (!o.id) { if(!_.isEmpty(o)) {o.projectId = project.id; newprojectTzzts.push(o);} } else { pnids6.push(o.id); pns6.push(o); } return o });
await DB.ProjectTzzt.destroy({ where: { projectId: project.id, id: { [Op.notIn]: pnids6 } } }); await DB.ProjectTzzt.destroy({ where: { projectId: project.id, id: { [Op.notIn]: pnids6 } } });
await DB.ProjectTzzt.bulkCreate(newprojectTzzts); await DB.ProjectTzzt.bulkCreate(newprojectTzzts);
await Promise.all(pns6.map(item => {DB.ProjectTzzt.update(item), {where: {id: item.id}}})); await Promise.all(pns6.map(item => {DB.ProjectTzzt.update(item, {where: {id: item.id}})}));
// 处理 ProjectJczt // 处理 ProjectJczt
let projectJczts = body.projectJczts || []; let projectJczts = body.projectJczts || [];
let pnids7 = [], pns7=[], newprojectJczts = []; let pnids7 = [], pns7=[], newprojectJczts = [];
projectJczts.map(o => { if (!o.id) { if(!_.isEmpty(o)) {o.projectId = project.id; newprojectJczts.push(o);} } else { pnids7.push(o.id); pns7.push(o); } return o }); projectJczts.map(o => { if (!o.id) { if(!_.isEmpty(o)) {o.projectId = project.id; newprojectJczts.push(o);} } else { pnids7.push(o.id); pns7.push(o); } return o });
await DB.ProjectJczt.destroy({ where: { projectId: project.id, id: { [Op.notIn]: pnids7 } } }); await DB.ProjectJczt.destroy({ where: { projectId: project.id, id: { [Op.notIn]: pnids7 } } });
await DB.ProjectJczt.bulkCreate(newprojectJczts); await DB.ProjectJczt.bulkCreate(newprojectJczts);
await Promise.all(pns7.map(item => {DB.ProjectJczt.update(item), {where: {id: item.id}}})); await Promise.all(pns7.map(item => {DB.ProjectJczt.update(item, {where: {id: item.id}})}));
// // 处理 projectZqrz // // 处理 projectZqrz
// let projectZqrzs = body.projectZqrzs || []; // let projectZqrzs = body.projectZqrzs || [];
// let pnids8 = [], newprojectZqrzs = []; // let pnids8 = [], newprojectZqrzs = [];
...@@ -260,7 +260,7 @@ async function updateProject(req, res, next) { ...@@ -260,7 +260,7 @@ async function updateProject(req, res, next) {
projectSpyjs.map(o => { if (!o.id) { if(!_.isEmpty(o)) {o.projectId = project.id; newprojectSpyjs.push(o);} } else { pnids9.push(o.id);pns9.push(o); } return o }); projectSpyjs.map(o => { if (!o.id) { if(!_.isEmpty(o)) {o.projectId = project.id; newprojectSpyjs.push(o);} } else { pnids9.push(o.id);pns9.push(o); } return o });
await DB.ProjectSpyj.destroy({ where: { projectId: project.id, id: { [Op.notIn]: pnids9 } } }); await DB.ProjectSpyj.destroy({ where: { projectId: project.id, id: { [Op.notIn]: pnids9 } } });
await DB.ProjectSpyj.bulkCreate(newprojectSpyjs); await DB.ProjectSpyj.bulkCreate(newprojectSpyjs);
await Promise.all(pns9.map(item => {DB.ProjectSpyj.update(item), {where: {id: item.id}}})); await Promise.all(pns9.map(item => {DB.ProjectSpyj.update(item, {where: {id: item.id}})}));
// 处理 projectCwpjzb // 处理 projectCwpjzb
let projectCwpjzbs = body.projectCwpjzbs || []; let projectCwpjzbs = body.projectCwpjzbs || [];
...@@ -268,14 +268,14 @@ async function updateProject(req, res, next) { ...@@ -268,14 +268,14 @@ async function updateProject(req, res, next) {
projectCwpjzbs.map(o => { if (!o.id) { if(!_.isEmpty()) {o.projectId = project.id; newprojectCwpjzbs.push(o); }} else { pnids10.push(o.id);pns10.push(o); } return o }); projectCwpjzbs.map(o => { if (!o.id) { if(!_.isEmpty()) {o.projectId = project.id; newprojectCwpjzbs.push(o); }} else { pnids10.push(o.id);pns10.push(o); } return o });
await DB.ProjectCwpjzb.destroy({ where: { projectId: project.id, id: { [Op.notIn]: pnids10 } } }); await DB.ProjectCwpjzb.destroy({ where: { projectId: project.id, id: { [Op.notIn]: pnids10 } } });
await DB.ProjectCwpjzb.bulkCreate(newprojectCwpjzbs); await DB.ProjectCwpjzb.bulkCreate(newprojectCwpjzbs);
await Promise.all(pns10.map(item => {DB.ProjectCwpjzb.update(item), {where: {id: item.id}}})); await Promise.all(pns10.map(item => {DB.ProjectCwpjzb.update(item, {where: {id: item.id}})}));
// 处理 ProjectLcbjd // 处理 ProjectLcbjd
let projectLcbjds = body.projectLcbjds || []; let projectLcbjds = body.projectLcbjds || [];
let pnids11 = [], pns11 = [],newprojectLcbjds = []; let pnids11 = [], pns11 = [],newprojectLcbjds = [];
projectLcbjds.map(o => { if (!o.id) { if(!_.isEmpty(o)) {o.projectId = project.id; newprojectLcbjds.push(o); }} else { pnids11.push(o.id); pns11.push(o); } return o }); projectLcbjds.map(o => { if (!o.id) { if(!_.isEmpty(o)) {o.projectId = project.id; newprojectLcbjds.push(o); }} else { pnids11.push(o.id); pns11.push(o); } return o });
await DB.ProjectLcbjd.destroy({ where: { projectId: project.id, id: { [Op.notIn]: pnids11 } } }); await DB.ProjectLcbjd.destroy({ where: { projectId: project.id, id: { [Op.notIn]: pnids11 } } });
await DB.ProjectLcbjd.bulkCreate(newprojectLcbjds); await DB.ProjectLcbjd.bulkCreate(newprojectLcbjds);
await Promise.all(pns11.map(item => {DB.ProjectLcbjd.update(item), {where: {id: item.id}}})); await Promise.all(pns11.map(item => {DB.ProjectLcbjd.update(item, {where: {id: item.id}})}));
// 处理 projectTzzjll----- // 处理 projectTzzjll-----
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment