From 3db0b46ead08fb48271d6412b0682afe5770c898 Mon Sep 17 00:00:00 2001 From: mzr Date: Tue, 15 Apr 2025 11:23:37 +0800 Subject: [PATCH] =?UTF-8?q?=E5=88=B0=E8=B4=A6=E9=80=9A=E7=9F=A5=E5=8F=91?= =?UTF-8?q?=E5=B8=83-=E6=8E=A8=E9=80=81=E6=8C=89=E9=92=AE=E5=92=8C?= =?UTF-8?q?=E6=94=B6=E7=A5=A8=E7=99=BB=E8=AE=B0-=E5=88=B0=E8=B4=A6?= =?UTF-8?q?=E9=80=9A=E7=9F=A5=E6=8E=A8=E9=80=81=E6=8C=89=E9=92=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../informer/action/myBtnClickAction.java | 431 ++++++++++++++++++ .../web/fbm/fbm/gather/action/DzButton.java | 328 +++++++++++++ 2 files changed, 759 insertions(+) create mode 100644 cmp/src/client/nccloud/web/cmp/informer/informer/action/myBtnClickAction.java create mode 100644 fbm/src/client/nccloud/web/fbm/fbm/gather/action/DzButton.java diff --git a/cmp/src/client/nccloud/web/cmp/informer/informer/action/myBtnClickAction.java b/cmp/src/client/nccloud/web/cmp/informer/informer/action/myBtnClickAction.java new file mode 100644 index 0000000..ac1fcbf --- /dev/null +++ b/cmp/src/client/nccloud/web/cmp/informer/informer/action/myBtnClickAction.java @@ -0,0 +1,431 @@ +package nccloud.web.cmp.informer.informer.action; + +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONArray; +import nc.bs.logging.Logger; +import nc.itf.uap.IUAPQueryBS; +import nc.jdbc.framework.JdbcSession; +import nc.jdbc.framework.PersistenceManager; +import nc.jdbc.framework.exception.DbException; +import nc.jdbc.framework.processor.MapListProcessor; +import nc.jdbc.framework.processor.MapProcessor; +import nccloud.framework.service.ServiceLocator; +import nccloud.framework.web.action.itf.ICommonAction; +import nccloud.framework.web.container.IRequest; +import nccloud.web.cmp.informer.action.InformerAction; +import org.apache.commons.codec.binary.Base64; + +import javax.crypto.Mac; +import javax.crypto.spec.SecretKeySpec; +import javax.net.ssl.HttpsURLConnection; +import javax.net.ssl.SSLContext; +import javax.net.ssl.TrustManager; +import javax.net.ssl.X509TrustManager; +import java.io.*; +import java.net.HttpURLConnection; +import java.net.URL; +import java.net.URLEncoder; +import java.nio.charset.StandardCharsets; +import java.security.InvalidKeyException; +import java.security.NoSuchAlgorithmException; +import java.security.SecureRandom; +import java.security.cert.X509Certificate; +import java.sql.Connection; +import java.sql.SQLException; +import java.util.*; + +public class myBtnClickAction extends InformerAction implements ICommonAction { + + @Override + public Object doAction(IRequest request) { + + + // 初始化结果映射，用于存储处理结果 + HashMap resultMap = new HashMap(); + // 读取请求中的JSON数据 + + String json = request.read(); + Map maps = JSON.parseObject(json, Map.class); + if (maps.get("pks") == null ){ + resultMap.put("result", "请选择行"); + return resultMap; + } + JSONArray jsonArray = (JSONArray) maps.get("pks"); + ArrayList pks = new ArrayList<>(Arrays.asList(jsonArray.toArray())); + +// 使用 String.join 进行字符串拼接 + String result = ""; + StringBuilder sb = new StringBuilder(); + if (pks.size() > 1) { + for (int i = 0; i < pks.size(); i++) { + sb.append("'").append(pks.get(i)).append("'"); + if (i < pks.size() - 1) { + sb.append(","); + } + } + + result = sb.toString(); + }else { + result= "'"+(String) pks.get(0)+"'"; + + } + System.out.println(result); + // 解析JSON数据为JSONObject对象 + // 从JSON对象中提取账单编号 + System.out.println(json); + String urlpath; + String appKey ; + String appSecret ; + String tenant ; + + // 如果账单编号为空，则返回失败结果 + + try { + String urlsql="select code,name from bd_defdoc where code='baseUrl'"; + String appksql="select code,name from bd_defdoc where code='appKey'"; + String uappssql="select code,name from bd_defdoc where code='appSecret'"; + String tenantsql="select code,name from bd_defdoc where code='tenant'"; + + Map urls = (Map) getQueryService().executeQuery(urlsql, new MapProcessor()); + Mapappks = (Map) getQueryService().executeQuery(appksql, new MapProcessor()); + Map appses = (Map) getQueryService().executeQuery(uappssql, new MapProcessor()); + Map tenants = (Map) getQueryService().executeQuery(tenantsql, new MapProcessor()); + + if (urls.get("code") != null) { + urlpath = (String) urls.get("name"); + } else { + resultMap.put("result", "未配置url"); + return resultMap; + } + if (appks.get("code") != null) { + appKey = (String) appks.get("name"); + } else { + resultMap.put("result", "未配置appKey"); + return resultMap; + } + if (appses.get("code") != null) { + appSecret = (String) appses.get("name"); + } else { + resultMap.put("result", "未配置appSecret"); + return resultMap; + } + if (tenants.get("code") != null) { + tenant = (String) tenants.get("name"); + } else { + resultMap.put("result", "未配置tenant"); + return resultMap; } + long timestampMillis = System.currentTimeMillis(); + System.out.println("当前时间戳（毫秒）：" + timestampMillis); + String dai = "appKey" + appKey + "timestamp" + timestampMillis; + String signature = calculateHmacSHA256(dai, appSecret); + SSLUtilities sas= new SSLUtilities() ; + sas.disableCertificateValidation(); + + String urlstr = "appKey=" + appKey + "×tamp=" + timestampMillis + "&signature="+signature; + URL url = new URL(urlpath+"/iuap-api-auth/open-auth/selfAppAuth/getAccessToken?" + urlstr); + // 打开连接 + HttpURLConnection con = (HttpURLConnection) url.openConnection(); + + // 设置请求方法为 GET + con.setRequestMethod("GET"); + + + // 获取响应代码 + BufferedReader ins = new BufferedReader(new InputStreamReader(con.getInputStream())); + String inputLine; + StringBuilder response = new StringBuilder(); + + while ((inputLine = ins.readLine()) != null) { + response.append(inputLine); + } + + System.out.println(response); + System.out.println(response); + + String jsonString = response.toString(); + Map map = JSON.parseObject(jsonString, Map.class); + System.out.println(map); + + System.out.println(url); + + // 获取当前年份 + String sql = " select bz.code as nzcode,jstype.code as pk_balatype,ban.code bancode,ban.name as banname,bankname,bank.accnum as accnum,infodate,CASE direction " + + "WHEN 'paymoney' THEN '付款' " + + "WHEN 'receivemoney' THEN '收款' " + + "ELSE '不存在' " + + "END as direction, 'CNY' as currencyCode,moneyy , bant.code as dfcode,bant.name as dfname,oppbankaccount,bankt.accnum dfaccnum " + + ",pk_oppunit,org.code as orgcode,org.name as orgname,cmp.pk_informer " + + ",cmp.memo,cmp.transerial,df.name as ksmc,df.code as ksbm,cmp.note_no,def01,cmp.oppunitname " + + "from cmp_informer cmp " + + "left join bd_bankaccbas bank on cmp.pk_bankacc=bank.pk_bankaccbas " + + "left join bd_bankdoc ban on cmp.pk_bank=ban.pk_bankdoc " + + "left join bd_bankdoc bant on cmp.pk_oppbank=bant.pk_bankdoc " + + "left join bd_bankaccbas bankt on cmp.pk_oppacc=bankt.pk_bankaccbas " + + "left join bd_cust_supplier df on cmp.pk_oppunit=df.pk_cust_sup " + + "left join org_financeorg org on cmp.pk_org = org.pk_financeorg " + + "left join bd_balatype jstype on jstype.pk_balatype =cmp.pk_balatype "+ + "left join bd_currtype bz on cmp.pk_currtype=bz.pk_currtype"+ + " where cmp.pk_informer in("+result+") "; + List> results = (List>) getQueryService().executeQuery(sql, new MapListProcessor()); + + ArrayList lists= new ArrayList(); + for (int i = 0; i < results.size(); i++) { + Map vmao = new HashMap(); + Map row = results.get(i); + String def01 = (String) row.get("def01"); + if ("已推送".equals(def01)) { + resultMap.put("flag", "false"); + resultMap.put("message", "已推送无法再次推送"); + return resultMap; + } + if ("撤回".equals(def01)){ + vmao.put("publishStatus", "再次发布"); + }else { + vmao.put("publishStatus", ""); + + } + String pjlsh; + if (row.get("transerial") != null){ + pjlsh=row.get("transerial").toString(); + }else if (row.get("note_no") != null){ + pjlsh=row.get("note_no").toString(); + }else { + resultMap.put("flag", "false"); + resultMap.put("message", "票据与流水号不可同时为空"); + return resultMap; + } + + + vmao.put("accountName", row.get("bancode")); + vmao.put("bankNum",row.get("accnum")); + vmao.put("transactionDate", row.get("infodate")); + vmao.put("paymentReceiptStatus", row.get("direction")); + vmao.put("currencyCode", row.get("nzcode") ); + vmao.put("transactionAmount", row.get("moneyy") ); + vmao.put("pendingClaimAmount",0); + vmao.put("oppAccount", row.get("oppbankaccount")); + vmao.put("oppAccountName", row.get("oppunitname")); + vmao.put("oppBank",row.get("dfcode")); + vmao.put("oppBankName",row.get("dfname")); + vmao.put("description", row.get("memo")); + vmao.put("bankTransactionNumber", pjlsh); + vmao.put("accountType","默认类型"); + vmao.put("orgCode",row.get("orgcode")); + vmao.put("billNumber",row.get("note_no")); + + if (row.get("pk_balatype") != null && row.get("pk_balatype") != "" && row.get("pk_balatype") != "~"){ + vmao.put("paymentMethod",row.get("pk_balatype")); + }else { + vmao.put("paymentMethod","10"); + } + vmao.put("sourceId",row.get("pk_informer")); + lists.add(vmao); + } + + //lists转json + String jsonString1 = JSON.toJSONString(lists); + Map access_token=(Map)map.get("data"); + String urls2=urlpath+"/iuap-api-gateway/"+tenant+"/current_yonbip_default_sys/KKAPI/paymentNotice/addBatch?access_token="+access_token.get("access_token"); + Map mapjson = httpFW(urls2,jsonString1); + Map datas= (Map) mapjson.get("data"); + JSONArray faijsonist = (JSONArray) datas.get("failData"); + + String message1= (String) mapjson.get("message"); + JSONArray jsonist = (JSONArray) datas.get("successData"); + // 将JSONArray转换为List + ArrayList successData = null; + ArrayList failData = null; + + if (jsonist != null) { + successData = (ArrayList) jsonist.toJavaList(String.class); + + } + if (faijsonist != null){ + failData = (ArrayList) faijsonist.toJavaList(String.class); + } + ArrayList sqlStr = new ArrayList<>(); + for (int i = 0; i < pks.size(); i++) { + String pk_s= (String) pks.get(i); + String sql1; + if (successData!=null&&successData.contains(pk_s)) { + sql1="update cmp_informer set def01='已推送' where pk_informer='"+pk_s+"'"; + sqlStr.add(sql1); + } else { + sql1="update cmp_informer set def01='推送失败' where pk_informer='"+pk_s+"'"; + } + sqlStr.add(sql1); + + } + + + + int succState = executeUpdate(sqlStr); + String message= datas.get("successData")+"成功" + message1+"，失败："+failData; + resultMap.put("flag", "true"); + resultMap.put("message", message); + // 调用服务工具类的deletePrcplInterest方法，尝试删除利息计划 + System.out.println("year"+mapjson); + ins.close(); + } catch (Exception ex) { + // 捕获异常，并记录错误日志 + Logger.error("123"+ex.getMessage(), ex); + resultMap.put("flag", "0"); + resultMap.put("message", ex.getMessage()); + } + + + // 返回结果映射 + return resultMap; + } + public IUAPQueryBS getQueryService() { + + return ServiceLocator.find(IUAPQueryBS.class); + } + + public static String calculateHmacSHA256(String data, String key) throws NoSuchAlgorithmException, InvalidKeyException, UnsupportedEncodingException { + String algorithm = "HmacSHA256"; + Mac hmacSHA256 = Mac.getInstance(algorithm); + SecretKeySpec secretKey = new SecretKeySpec(key.getBytes(), algorithm); + hmacSHA256.init(secretKey); + byte[] hashBytes = hmacSHA256.doFinal(data.getBytes()); + String base64Hash = Base64.encodeBase64String(hashBytes); + return URLEncoder.encode(base64Hash, StandardCharsets.UTF_8.toString()); + } + + + public static Map httpFW(String urlString, String jsonInputString) { +// String jsonInputString = "{\"key\": \"中文\"}"; // 你的 JSON 数据 +// String urlString = "http://example.com/api"; // 替换为你的 URL + System.out.println("请求值"); + System.out.println(jsonInputString); + try { + URL url = new URL(urlString); + HttpURLConnection connection = (HttpURLConnection) url.openConnection(); + + connection.setRequestMethod("POST"); + connection.setRequestProperty("Content-Type", "application/json; charset=UTF-8"); + connection.setDoOutput(true); + + // 发送请求 + try (OutputStream os = connection.getOutputStream()) { + byte[] input = jsonInputString.getBytes(StandardCharsets.UTF_8); + os.write(input, 0, input.length); + } + + // 获取响应码 + int responseCode = connection.getResponseCode(); + System.out.println("响应码: " + responseCode); + // 根据响应码读取响应 + InputStream is = (responseCode >= 200 && responseCode < 300) ? connection.getInputStream() : connection.getErrorStream(); + StringBuilder response = new StringBuilder(); + + try (BufferedReader br = new BufferedReader(new InputStreamReader(is, StandardCharsets.UTF_8))) { + String responseLine; + while ((responseLine = br.readLine()) != null) { + response.append(responseLine.trim()); + } + } + + // 输出响应 + System.out.println("返回值:"); + System.out.println(response.toString()); + //返回map + Map result= JSON.parseObject(response.toString(), HashMap.class); + return result; + + } catch (Exception e) { + e.printStackTrace(); + } + return null; + } + public class SSLUtilities { + public void disableCertificateValidation() throws Exception { + TrustManager[] trustAllCertificates = new TrustManager[]{ + new X509TrustManager() { + public X509Certificate[] getAcceptedIssuers() { + return null; + } + public void checkClientTrusted(X509Certificate[] certs, String authType) { + } + public void checkServerTrusted(X509Certificate[] certs, String authType) { + } + } + }; + + SSLContext sc = SSLContext.getInstance("TLS"); + sc.init(null, trustAllCertificates, new SecureRandom()); + HttpsURLConnection.setDefaultSSLSocketFactory(sc.getSocketFactory()); + } + } + public int executeUpdate(List updateSqls) throws DbException { + if (updateSqls == null) { + return 0; + } + + int ret = 0; + PersistenceManager manager = null; + JdbcSession session = null; + Connection connection = null; + + try { + manager = PersistenceManager.getInstance(); + session = manager.getJdbcSession(); + connection = session.getConnection(); // 获取实际的数据库连接 +// connection = ConnectionFactory.getConnection(); + // 开始事务 + connection.setAutoCommit(false); // 禁用自动提交，手动管理事务 + + // 执行批量操作 + for (String sql : updateSqls) { + session.addBatch(sql); + } + + + // 执行批处理 + ret = session.executeBatch(); + + // 提交事务 + connection.commit(); // 批处理成功后提交事务 + + } catch (DbException e) { + if (connection != null) { + try { + // 如果发生异常，回滚事务 + connection.rollback(); + } catch (SQLException rollbackEx) { + // 记录回滚异常的详细信息 + throw new DbException("Error during transaction rollback", rollbackEx) { + @Override + public boolean isDataIntegrityViolation() { + return false; + } + + @Override + public boolean isBadSQLGrammar() { + return false; + } + }; + } + } + throw e; // 将原始异常抛出 + } catch (SQLException e) { + throw new RuntimeException(e); + } finally { + if (connection != null) { + try { + // 恢复自动提交模式，确保不会影响其他操作 + connection.setAutoCommit(true); + } catch (SQLException e) { + // 忽略恢复自动提交时的异常 + } + } + if (manager != null) { + manager.release(); + } + } + + return ret; + } + +} + diff --git a/fbm/src/client/nccloud/web/fbm/fbm/gather/action/DzButton.java b/fbm/src/client/nccloud/web/fbm/fbm/gather/action/DzButton.java new file mode 100644 index 0000000..269cf93 --- /dev/null +++ b/fbm/src/client/nccloud/web/fbm/fbm/gather/action/DzButton.java @@ -0,0 +1,328 @@ +package nccloud.web.fbm.fbm.gather.action; + +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONArray; +import nc.itf.uap.IUAPQueryBS; +import nc.jdbc.framework.JdbcSession; +import nc.jdbc.framework.PersistenceManager; +import nc.jdbc.framework.exception.DbException; +import nc.jdbc.framework.processor.MapListProcessor; +import nccloud.framework.service.ServiceLocator; +import nccloud.framework.web.action.itf.ICommonAction; +import nccloud.framework.web.container.IRequest; + +import java.sql.Connection; +import java.sql.SQLException; +import java.time.LocalDateTime; +import java.time.format.DateTimeFormatter; +import java.util.*; + +public class DzButton implements ICommonAction { + + @Override + public Object doAction(IRequest request) { + // 初始化结果映射，用于存储处理结果 + HashMap resultMap = new HashMap(); + // 读取请求中的JSON数据 + + String json = request.read(); + Map maps = JSON.parseObject(json, Map.class); + if (maps.get("pks") == null ){ + resultMap.put("result", "请选择行"); + return resultMap; + } + int yg=0; + int cg=0; + int sbl=0; + + JSONArray jsonArray = (JSONArray) maps.get("pks"); + ArrayList pks = new ArrayList<>(Arrays.asList(jsonArray.toArray())); + +// 使用 String.join 进行字符串拼接 + String result = ""; + StringBuilder sb = new StringBuilder(); + if (pks.size() > 1) { + for (int i = 0; i < pks.size(); i++) { + sb.append("'").append(pks.get(i)).append("'"); + if (i < pks.size() - 1) { + sb.append(","); + } + } + + result = sb.toString(); + }else { + result= "'"+(String) pks.get(0)+"'"; + } + // 如果账单编号为空，则返回失败结果 + try { + // 获取当前年份 + String sql = "select fbm.gatherdate,bank1.pk_bankdoc as fkyh,bank2.pk_bankdoc as skyh,fbm.acceptorbank,fbm.hidereceivebankacc ,holdunit,org.name as orgname , reg.name as pjname,xxb_bon.bdcode,btype.pk_balatype,reg.code,xxe.exsystemcode,\n" + + "xxb_bon.exsysval\n" + + ",invoiceunit,fbmbilltype,fbm.fbmbillno,fbm.pk_register, paybankacc as bankaccount,fbm.payunit,cust.name as bankname,fbm.billmaker,fbm.creator,fbm.note,fbm.money,cust.custsupprop ,cust.custsuptype,fbm.pk_banktype ,fbm.pk_org ,fbm.pk_org_v,fbm.hidereceiveunit, fbm.hidepayunit,fbm.hidepaybankacc ,fbm.hidepaybank ,fbm.paybankacc ,fbm.paybank ,fbm.receiveunit,fbm.receivebankacc ,fbm.receivebank ,hidereceivebank, bankdoc.pk_bankaccbas ,fbm.pk_group \n" + + "from fbm_register fbm \n" + + "left join bd_cust_supplier cust on fbm.hidepayunit=cust.pk_cust_sup \n" + + "left join bd_bankaccbas bankdoc on fbm.receivebankacc = bankdoc.code\n" + + "left join bd_notetype reg on fbm.fbmbilltype=reg.pk_notetype\n" + + "join xx_bdcontra_b xxb_bon on xxb_bon.exsysval=reg.code\n" + + "join xx_bdcontra xxb on xxb.pk_contra=xxb_bon.pk_contra\n" + + "join xx_exsystem xxe on xxe.pk_exsystem =xxb.exsystem and xxe.exsystemcode='pkinformer'\n" + + "left join org_financeorg org on org.pk_financeorg=fbm.holdunit\n" + + "left join bd_bankdoc bank1 on fbm.paybank =bank1.name\n" + + "left join bd_bankdoc bank2 on fbm.receivebank =bank2.name\n" + + "left join bd_balatype btype on btype.code=xxb_bon.bdcode " + + + " where fbm.pk_register in("+result+") "; + List> results = (List>) getQueryService().executeQuery(sql, new MapListProcessor()); + + List sqlStr = new ArrayList(); + LocalDateTime creationTime = LocalDateTime.now(); + +// 格式化年月日 + + DateTimeFormatter dateFormatter = DateTimeFormatter.ofPattern("yyyy-MM-dd"); + String formattedDate = creationTime.format(dateFormatter); + // 格式化时分秒 + DateTimeFormatter timeFormatter = DateTimeFormatter.ofPattern("HH:mm:ss"); + String formattedTime = creationTime.format(timeFormatter); + +// 格式化时间 + DateTimeFormatter datatimes = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); + String formatteddatatime = creationTime.format(datatimes); + yg=results.size(); + for (int i = 0; i < results.size(); i++) { + + Map row = results.get(i); + String bankAccount = (String) row.get("receivebankacc"); + String gatherdate=(String) row.get("gatherdate"); + // 本方开户银行名称 + String bankName= (String) row.get("receiveunit"); + // 制单人 + String billMaker= (String) row.get("billmaker"); + // 托收协议号 + String consignAgreement="~"; + // 记录创建时间 + String sj = formatteddatatime; + // 创建人 + String creator= (String) row.get("creator"); + // 收付性质 + String direction="receivemoney"; + // （未明确用途，可根据实际情况使用） + String domain="~"; + // 制单日期 + String doOperateDate=formatteddatatime; + // 制单时间 + String doOperateTime=formattedTime; + // 标记，通常用于逻辑删除，0 表示未删除 + int dr=0; + // （未明确用途，可根据实际情况使用） + String family="~"; + // 未生成标志 + String generateFlag="hasnogenerate"; + // 到账日期 + String infoDate=gatherdate; + // 到账时间 + String infoDateTime=formattedTime; + // 备注 + String memo=(String) row.get("note"); + // 修改时间 + String modifiedTime=formatteddatatime; + // 修改人 + String modifier=(String) row.get("creator"); + // 金额 + double money=Double.parseDouble(row.get("money").toString()); + // 对方账户 + String oppBankAccount=(String) row.get("paybankacc"); + // 对方单位内外部标识 custsupprop 0=外部单位; + //1=内部单位; + + String oppInOut; + if (row.get("custsupprop")!=null&&row.get("custsupprop").toString().equals("0")){ + oppInOut="outer"; + }else{ + oppInOut="inner"; + } + // 对方名称 + String oppUnitName=(String) row.get("payunit"); + // 对方单位类别 + Object custsuptype = row.get("custsuptype"); + String oppUnitType = "cust"; // 默认值 + + if (custsuptype != null && custsuptype.toString().equals("2")) { + oppUnitType = "supp"; + } + + // 本方账户对应子户 + String pkAccSub=(String) row.get("hidereceivebankacc"); + // （未明确用途，可根据实际情况使用） + String pk_balatype= (String) row.get("pk_balatype"); + // 本方开户银行主键 + String pkBank=(String) row.get("skyh"); + // 本方银行账号主键 + String pkBankAcc=(String) row.get("pk_bankaccbas");//1 + // 记账人 + String pkBankAccer="~"; + // 本方银行类别主键 + String pkBankType=(String) row.get("pk_banktype"); + + // 对方单位 + String pk_oppunit=(String) row.get("hidepayunit"); + // 对方开户银行账号主键 + String pk_oppbank=(String)row.get("fkyh"); + //对方账户PK + String pk_oppacc= (String) row.get("hidepaybankacc"); + + + // 单据类型 + String pkBillTypeCode="36S3"; + // 单据类型主键 + String pkBillTypeId="1001Z61000000001SOPF"; + // （未明确用途，可根据实际情况使用） + String pkClaimer="~"; + // 币种 + String pkCurrType="1002Z0100000000001K1"; + // （未明确用途，可根据实际情况使用） + String pkFundType="~"; + // 所属集团 + String pkGroup=(String) row.get("pk_group"); + // （未明确用途，可根据实际情况使用主键） + String pkInformer=(String) row.get("pk_register"); + // （未明确用途，可根据实际情况使用） + String pkOrg=(String) row.get("pk_org"); + // 财务组织版本 + String pkOrgV=(String) row.get("pk_org_v"); + // 来源单据主键 + String pkSrc=null; + // 制证人 + String pkVouch=(String) row.get("billmaker"); + // 收/付款资金组织 + String recPayFundOrg="~"; + // 收/付款资金组织计划项目 + String recPayFundPlansubj="~"; + // （未明确用途，可根据实际情况使用） + String recPayInnerAcc="~"; + // （未明确用途，可根据实际情况使用） + String recPayOrg="~"; + // （未明确用途，可根据实际情况使用） + String recPayOrgPlansubj="~"; + // （未明确用途，可根据实际情况使用） + String releaseOrg="~"; + // 风格标志，A 可能表示某种风格类型 + char styleFlag='A'; + // （未明确用途，可根据实际情况使用） + String subFamily="~"; + // 系统代码 + String sysCode="sysnet"; + // 时间戳 + String ts= formatteddatatime; + // 单据号 + long timestamp = System.currentTimeMillis(); + Random random = new Random(); + int randomNumber = random.nextInt(10000); // 生成0到9999之间的随机数 + String vBillNo = "36S"+String.format("%d%04d", timestamp, randomNumber); + String note_no=(String) row.get("fbmbillno"); + //String sqlp="insert into cmp_informer(bankaccount,bankname,billmaker,consignagreement,creationtime,creator,direction,domain,doperatedate,doperatetime,dr,family,generateflag,infodate,infodatetime,memo,modifiedtime,modifier,moneyy,oppbankaccount,oppinout,oppunitname,oppunittype,pk_acc_sub,pk_balatype,pk_bank,pk_bankacc,pk_bankaccer,pk_banktype,pk_billtypecode,pk_billtypeid,pk_claimer,pk_currtype,pk_fundtype,pk_group,pk_informer,pk_org,pk_org_v,pk_src,pk_vouch,recpay_fundorg,recpay_fundplansubj,recpay_inneracc,recpay_org,recpay_orgplansubj,release_org,styleflag,subfamily,syscode,ts,vbillno) values('"+num+"','济南热电有限公司','1001A110000000003Q0I','~','"+dam+"','1001A110000000003Q0I','"+pr+"','~','"+transactionDate+"','"+dam+"','0','~','hasnogenerate','"+transactionDate+"','"+timesub+"','"+zhaiYao+"','"+dam+"','1001A110000000003Q0I',"+money+",'"+oppositeAccountNumber+"','"+opp+"','"+oppositeUserName+"','"+opptype+"','"+select[2]+"','~','"+select[0]+"','"+select[1]+"','~','"+select3[0]+"','36S3','1001Z61000000001SOPF','~','1002Z0100000000001K1','~','0001N2100000000002ZE','"+vId+"','0001N710000000001FWC','0001N710000000001FWB','1001A110000000007IWJ','~','~','~','~','~','~','~','A','~','sysnet','"+dam+"','"+fId2+"')" + // 形成sql + String sqlp="insert into cmp_informer(bankaccount,bankname,billmaker,consignagreement,creationtime,creator,direction,domain,doperatedate,doperatetime,dr,family,generateflag,infodate,infodatetime,memo,modifiedtime,modifier,moneyy,oppbankaccount,oppinout,oppunitname,oppunittype,pk_acc_sub,pk_balatype,pk_bank,pk_bankacc,pk_bankaccer,pk_banktype,pk_billtypecode,pk_billtypeid,pk_claimer,pk_currtype,pk_fundtype,pk_group,pk_informer,pk_org,pk_org_v,pk_src,pk_vouch,recpay_fundorg,recpay_fundplansubj,recpay_inneracc,recpay_org,recpay_orgplansubj,release_org,styleflag,subfamily,syscode,ts,vbillno,note_no,pk_oppunit,pk_oppbank,pk_oppacc) values('" + +bankAccount+"','"+bankName+"','"+billMaker+"','"+consignAgreement+"','"+formatteddatatime+"','"+creator+"','"+direction+"','"+domain+"','"+doOperateDate+"','"+sj+"','"+dr+"','"+family+"','"+generateFlag+"','"+infoDate+"','"+infoDateTime+"','"+memo+"','"+modifiedTime+"','"+modifier+"','"+money+"','"+oppBankAccount+"','"+oppInOut+"','"+oppUnitName+"','"+oppUnitType+"','"+pkAccSub+"','"+pk_balatype+"','"+pkBank+"','"+pkBankAcc+"','"+pkBankAccer+"','"+pkBankType+"','"+pkBillTypeCode+"','"+pkBillTypeId+"','"+pkClaimer+"','"+pkCurrType+"','"+pkFundType+"','"+pkGroup+"','"+pkInformer+"','"+pkOrg+"','"+pkOrgV+"','"+pkSrc+"','"+pkVouch+"','"+recPayFundOrg+"','"+recPayFundPlansubj+"','"+recPayInnerAcc+"','"+recPayOrg+"','"+recPayOrgPlansubj+"','"+releaseOrg+"','"+styleFlag+"','"+subFamily+"','"+sysCode+"','"+ts+"','"+vBillNo+"','"+note_no+"','"+pk_oppunit+"','"+pk_oppbank+"','"+pk_oppacc+"')"; + sqlStr.add(sqlp); + } + int succState = executeUpdate(sqlStr); + cg=succState; + sbl=yg-succState; + resultMap.put("flag", "1"); + resultMap.put("message", "插入数据成功，已插入"+succState+"条数据"); + resultMap.put("cg", String.valueOf(cg)); + resultMap.put("sbl", String.valueOf(sbl)); + resultMap.put("yg", String.valueOf(yg)); + //lists转json + } catch (Exception ex) { + // 捕获异常，并记录错误日志 + resultMap.put("cg", String.valueOf(0)); + resultMap.put("sbl", String.valueOf(yg)); + resultMap.put("yg", String.valueOf(yg)); + resultMap.put("flag", "0"); + resultMap.put("message", ex.getMessage()); + } + // 返回结果映射 + return resultMap; + } + public IUAPQueryBS getQueryService() { + return ServiceLocator.find(IUAPQueryBS.class); + } + + + public int executeUpdate(List updateSqls) throws DbException { + if (updateSqls == null) { + return 0; + } + + int ret = 0; + PersistenceManager manager = null; + JdbcSession session = null; + Connection connection = null; + + try { + manager = PersistenceManager.getInstance(); + session = manager.getJdbcSession(); + connection = session.getConnection(); // 获取实际的数据库连接 + + // 开始事务 + connection.setAutoCommit(false); // 禁用自动提交，手动管理事务 + + // 执行批量操作 + for (String sql : updateSqls) { + session.addBatch(sql); + } + + // 执行批处理 + ret = session.executeBatch(); + + // 提交事务 + connection.commit(); // 批处理成功后提交事务 + + } catch (DbException e) { + if (connection != null) { + try { + // 如果发生异常，回滚事务 + connection.rollback(); + } catch (SQLException rollbackEx) { + // 记录回滚异常的详细信息 + throw new DbException("Error during transaction rollback", rollbackEx) { + @Override + public boolean isDataIntegrityViolation() { + return false; + } + + @Override + public boolean isBadSQLGrammar() { + return false; + } + }; + } + } + throw e; // 将原始异常抛出 + } catch (SQLException e) { + throw new RuntimeException(e); + } finally { + if (connection != null) { + try { + // 恢复自动提交模式，确保不会影响其他操作 + connection.setAutoCommit(true); + } catch (SQLException e) { + // 忽略恢复自动提交时的异常 + } + } + if (manager != null) { + manager.release(); + } + } + + return ret; + } + + + + +} + +