从中间表取数更新TW付款单数据（不含表体）

2023-10-14 07:30
文章标签 数据 更新 中间 付款单 表取数 tw 含表体

本文主要是介绍从中间表取数更新TW付款单数据（不含表体），希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！ 

package nc.bs.backgroundtasks;import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;import nc.bs.dao.BaseDAO;
import nc.bs.framework.common.NCLocator;
import nc.bs.pub.pa.PreAlertObject;
import nc.bs.pub.taskcenter.BgWorkingContext;
import nc.bs.pub.taskcenter.IBackgroundWorkPlugin;
import nc.impl.pubapp.pattern.data.bill.BillQuery;
import nc.itf.jych.IPaymentorderMaintain;
import nc.jdbc.framework.processor.BeanListProcessor;
import nc.jdbc.framework.processor.ColumnListProcessor;
import nc.vo.jych.oavo.OaPaymentOrderVO;
import nc.vo.jych.paymentorder.AggPaymentOrderVO;
import nc.vo.jych.paymentorder.PaymentOrderVO;
import nc.vo.pub.BusinessException;
import nc.vo.pub.SuperVOUtil;
import nc.vo.pub.VOStatus;
import nc.vo.pub.lang.UFDate;
import nc.vo.pub.lang.UFDateTime;
import nc.vo.wgbfb.tool.NullValueUtils;
import nc.vo.zkch.utils.SqlBuilder;/*** @desc : 从中间表取数更新TW付款单数据* @author hanh* @date : 2023-10-10*/
public class OAPaymentOrderPlugin implements IBackgroundWorkPlugin{@Overridepublic PreAlertObject executeTask(BgWorkingContext arg0) throws BusinessException {//抽取中间表数据generatePaymentOrder();return null;}//抽取中间表数据@SuppressWarnings("unchecked")private void generatePaymentOrder() throws BusinessException {//通过是否执行标识查询中间表中未执行的主表数据SqlBuilder sqlname = new SqlBuilder();sqlname.append(" select * from jych_zj_fkd where nvl(dr,0) = 0 and nvl(iszx,'N') != 'Y' ");//volist存放中间表中未执行的主表数据List<OaPaymentOrderVO> volist = (List<OaPaymentOrderVO>) getDao().executeQuery(sqlname.toString(), new BeanListProcessor(OaPaymentOrderVO.class));if(volist == null || volist.size() < 1){return;}/*通过id+数据来源+付款类型来判断新增或修改*///idlist存放id+sjly+fklxList<String> idlist = new ArrayList<String>();//zjpklist存放中间表主表主键List<String> zjpklist = new ArrayList<String>();for (OaPaymentOrderVO vo : volist) {//给idlist和zjpklist赋值String id = vo.getId() + vo.getSjly() + NullValueUtils.getNullStringValue(vo.getFklx());idlist.add(id);zjpklist.add(vo.getPk_fkd());}//根据中间表id+sjly+fklx，查询nc系统中已存在的主表主键SqlBuilder pksql = new SqlBuilder();pksql.append(" select pk_paymentorder from jych_paymentorder where nvl(dr,0) = 0 and ");pksql.append(" wxtbs||sjly||fklx ", idlist.toArray(new String[0]));List<String> pklist = (List<String>) getDao().executeQuery(pksql.toString(), new ColumnListProcessor());//Map<key : id+sjly=fklx , value : AggVO> 将已存在的AggVO放入MapMap<String, AggPaymentOrderVO> vomap = new HashMap<String, AggPaymentOrderVO>();if(pklist != null && pklist.size() > 0){//根据已存在的主表主键获取已存在的AggVOBillQuery<AggPaymentOrderVO> billQuery = new BillQuery<AggPaymentOrderVO>(AggPaymentOrderVO.class);AggPaymentOrderVO[] vos = billQuery.query(pklist.toArray(new String[0]));for (AggPaymentOrderVO aggvo : vos) {//将aggvo对应的id和aggvo捆绑String wxtbs = aggvo.getParentVO().getWxtbs();String sjly = aggvo.getParentVO().getSjly();String fklx = aggvo.getParentVO().getFklx();String id = wxtbs + sjly + fklx;vomap.put(id, aggvo);}}//翻译OaPaymentOrderVOupdateHeadVO(volist.toArray(new OaPaymentOrderVO[0])); //insertlist存放执行插入的aggvoList<AggPaymentOrderVO> insertlist = new ArrayList<AggPaymentOrderVO>();//updatelist存放执行更新后的aggvoList<AggPaymentOrderVO> updatelist = new ArrayList<AggPaymentOrderVO>();//orgupdatelist存放执行更新前的aggvoList<AggPaymentOrderVO> orgupdatelist = new ArrayList<AggPaymentOrderVO>();for (OaPaymentOrderVO vo : volist) {//封装insertlist、updatelist、orgupdatelistString id = vo.getId() + vo.getSjly() + NullValueUtils.getNullStringValue(vo.getFklx());if(vomap != null && vomap.size() > 0 && vomap.containsKey(id)){ //修改AggPaymentOrderVO aggvo = vomap.get(id);AggPaymentOrderVO clone = (AggPaymentOrderVO) aggvo.clone();PaymentOrderVO headvo = clone.getParentVO();headvo.setStatus(VOStatus.UPDATED);setHeadvo(headvo, vo);updatelist.add(clone);orgupdatelist.add(aggvo);} else { //新增AggPaymentOrderVO aggvo = new AggPaymentOrderVO();PaymentOrderVO headvo = new PaymentOrderVO();headvo.setStatus(VOStatus.NEW);headvo.setPk_billtype("XS01");headvo.setTranstypecode("XS01-Cxx-01");headvo.setPk_org(vo.getPk_org());headvo.setPk_org_v(vo.getPk_org_v());headvo.setPk_group(vo.getPk_group());headvo.setPk_transtype(vo.getPk_transtype());headvo.setDbilldate(new UFDate());headvo.setVbillstatus(-1);setHeadvo(headvo, vo);aggvo.setParentVO(headvo);insertlist.add(aggvo);}}if(insertlist != null && insertlist.size() > 0){//调新增接口AggPaymentOrderVO[] insertvos = getService().insert(insertlist.toArray(new AggPaymentOrderVO[0]), insertlist.toArray(new AggPaymentOrderVO[0]));List<AggPaymentOrderVO> insertvolist = new ArrayList<AggPaymentOrderVO>();for (AggPaymentOrderVO insertvo : insertvos) {AggPaymentOrderVO clone = (AggPaymentOrderVO) insertvo.clone();PaymentOrderVO vo = clone.getParentVO();vo.setVbillstatus(1);vo.setApprovedate(new UFDateTime());vo.setApprover(vo.getCreator());insertvolist.add(clone);}getService().approve(insertvolist.toArray(new AggPaymentOrderVO[0]), insertvos);}if(updatelist != null && updatelist.size() > 0){//调更新接口getService().update(updatelist.toArray(new AggPaymentOrderVO[0]), orgupdatelist.toArray(new AggPaymentOrderVO[0]));}SqlBuilder updatesql = new SqlBuilder(); //更新中间表中已执行数据的是否执行标识updatesql.append(" update jych_zj_fkd set iszx = 'Y' where ");updatesql.append(" pk_fkd ", zjpklist.toArray(new String[0]));getDao().executeUpdate(updatesql.toString());}private void updateHeadVO(OaPaymentOrderVO[] headvos){SuperVOUtil.execFormulaWithVOs(headvos,new String[] {// 组织"pk_org->getcolvalue2(org_orgs,pk_org,code,\"05\",islastversion,\"Y\")",// 组织版本"pk_org_v->getcolvalue(org_orgs,pk_vid,pk_org,pk_org)",// 集团"pk_group->getcolvalue(org_group,pk_group,code,\"01\")",// 付款形式-原值"def1->fkxs",// 申请人"def2->lastname",// 申请人"lastname->getColValue2(bd_psndoc,pk_psndoc,name,lastname,dr,0)",// 合同号-原值"def3->htbh",// 合同编号"htbh->getColValue(view_jych_contract,pk,htbh,htbh)",// 申请部门"def4->departmentname",// 申请部门"departmentname->getColValue2(org_dept,pk_dept,name,departmentname,dr,0)",// 项目编号"def5->xmbh",// 项目编号"xmbh->getColValue2(zkch_marketpro,pk_marketpro,marketprocode,xmbh,dr,0)"});}public void setHeadvo(PaymentOrderVO headvo, OaPaymentOrderVO vo){headvo.setWxtbs(vo.getId());//申请日期headvo.setSqrq(vo.getSqrq());//所属机构headvo.setSsjg(vo.getSzjg());//申请人headvo.setSqr(vo.getLastname());//申请部门headvo.setSqbm(vo.getDepartmentname());//支付单单号headvo.setZfddh(vo.getZfddh());//项目编号headvo.setXmbh(vo.getXmbh());//合同编号headvo.setHtbh(vo.getHtbh());//付款事由headvo.setFksy(vo.getFksy());//本次付款金额headvo.setBcfkmny(vo.getBcfkjey());//本次实际支付headvo.setBcsjzf(vo.getBcsjzf());//应付金额headvo.setYingfmny(vo.getYfkje());//付款形式headvo.setFkxs(vo.getFkxs());//是否冲销预付款headvo.setIscxyfk(vo.getSfcxyfk());//摘要
//		headvo.setMarketprocode(vo.getZy());//归档时间headvo.setGddate(vo.getLastoperatedate());//出纳审批时间headvo.setCnspdate(vo.getOperatedate());//付款类型headvo.setFklx(vo.getFklx());//数据来源headvo.setSjly(vo.getSjly());headvo.setSfhjk(vo.getSfhjk());headvo.setCxje(vo.getCxje());headvo.setDef1(vo.getDef1());headvo.setDef2(vo.getDef2());headvo.setDef3(vo.getDef3());headvo.setDef4(vo.getDef4());headvo.setDef5(vo.getDef5());}private IPaymentorderMaintain service;private IPaymentorderMaintain getService() {if (service == null) {service = NCLocator.getInstance().lookup(IPaymentorderMaintain.class);}return service;}private BaseDAO dao;private BaseDAO getDao(){if(dao == null){dao = new BaseDAO();}return dao;}
}

这篇关于从中间表取数更新TW付款单数据（不含表体）的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/209022。

相关文章

MySQL 删除数据详解(最新整理)

MySQL 删除数据详解(最新整理)

《MySQL删除数据详解(最新整理)》：本文主要介绍MySQL删除数据的相关知识,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录一、前言二、mysql 中的三种删除方式1.DELETE语句✅ 基本语法： 示例：2.TRUNCATE语句✅ 基本语
阅读更多...
MyBatisPlus如何优化千万级数据的CRUD

MyBatisPlus如何优化千万级数据的CRUD

《MyBatisPlus如何优化千万级数据的CRUD》最近负责的一个项目,数据库表量级破千万,每次执行CRUD都像走钢丝,稍有不慎就引起数据库报警,本文就结合这个项目的实战经验,聊聊MyBatisPl... 目录背景一、MyBATis Plus 简介二、千万级数据的挑战三、优化 CRUD 的关键策略1. 查
阅读更多...
python实现对数据公钥加密与私钥解密

python实现对数据公钥加密与私钥解密

《python实现对数据公钥加密与私钥解密》这篇文章主要为大家详细介绍了如何使用python实现对数据公钥加密与私钥解密,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录公钥私钥的生成使用公钥加密使用私钥解密公钥私钥的生成这一部分，使用python生成公钥与私钥，然后保存在两个文
阅读更多...
mysql中的数据目录用法及说明

mysql中的数据目录用法及说明

《mysql中的数据目录用法及说明》：本文主要介绍mysql中的数据目录用法及说明,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录1、背景2、版本3、数据目录4、总结1、背景安装mysql之后，在安装目录下会有一个data目录，我们创建的数据库、创建的表、插入的
阅读更多...
MySQL追踪数据库表更新操作来源的全面指南

MySQL追踪数据库表更新操作来源的全面指南

《MySQL追踪数据库表更新操作来源的全面指南》本文将以一个具体问题为例,如何监测哪个IP来源对数据库表statistics_test进行了UPDATE操作,文内探讨了多种方法,并提供了详细的代码... 目录引言1. 为什么需要监控数据库更新操作2. 方法1：启用数据库审计日志（1）mysql/mariad
阅读更多...
Navicat数据表的数据添加,删除及使用sql完成数据的添加过程

Navicat数据表的数据添加,删除及使用sql完成数据的添加过程

《Navicat数据表的数据添加,删除及使用sql完成数据的添加过程》：本文主要介绍Navicat数据表的数据添加,删除及使用sql完成数据的添加过程,具有很好的参考价值,希望对大家有所帮助,如有... 目录Navicat数据表数据添加,删除及使用sql完成数据添加选中操作的表则出现如下界面，查看左下角从左
阅读更多...
SpringBoot中4种数据水平分片策略

SpringBoot中4种数据水平分片策略

《SpringBoot中4种数据水平分片策略》数据水平分片作为一种水平扩展策略,通过将数据分散到多个物理节点上,有效解决了存储容量和性能瓶颈问题,下面小编就来和大家分享4种数据分片策略吧... 目录一、前言二、哈希分片2.1 原理2.2 SpringBoot实现2.3 优缺点分析2.4 适用场景三、范围分片
阅读更多...
Redis分片集群、数据读写规则问题小结

Redis分片集群、数据读写规则问题小结

《Redis分片集群、数据读写规则问题小结》本文介绍了Redis分片集群的原理,通过数据分片和哈希槽机制解决单机内存限制与写瓶颈问题,实现分布式存储和高并发处理,但存在通信开销大、维护复杂及对事务支持... 目录一、分片集群解android决的问题二、分片集群图解 分片集群特征如何解决的上述问题？（与哨兵模
阅读更多...
浅析如何保证MySQL与Redis数据一致性

浅析如何保证MySQL与Redis数据一致性

《浅析如何保证MySQL与Redis数据一致性》在互联网应用中,MySQL作为持久化存储引擎,Redis作为高性能缓存层,两者的组合能有效提升系统性能,下面我们来看看如何保证两者的数据一致性吧... 目录一、数据不一致性的根源1.1 典型不一致场景1.2 关键矛盾点二、一致性保障策略2.1 基础策略：更新数
阅读更多...
Oracle 数据库数据操作如何精通 INSERT, UPDATE, DELETE

Oracle 数据库数据操作如何精通 INSERT, UPDATE, DELETE

《Oracle数据库数据操作如何精通INSERT,UPDATE,DELETE》在Oracle数据库中,对表内数据进行增加、修改和删除操作是通过数据操作语言来完成的,下面给大家介绍Oracle数... 目录思维导图一、插入数据 (INSERT)1.1 插入单行数据，指定所有列的值语法：1.2 插入单行数据，指
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2