From 56931dc90c4e070d279a0cbf5822af010c481812 Mon Sep 17 00:00:00 2001
From: chengf <cgf12138@163.com>
Date: 星期三, 18 三月 2026 15:36:42 +0800
Subject: [PATCH] 导入测试
---
service-job/src/main/java/com/java110/job/importData/adapt/ImportPhoneBillFeeV2QueueDataAdapt.java | 10 ++++++----
1 files changed, 6 insertions(+), 4 deletions(-)
diff --git a/service-job/src/main/java/com/java110/job/importData/adapt/ImportPhoneBillFeeV2QueueDataAdapt.java b/service-job/src/main/java/com/java110/job/importData/adapt/ImportPhoneBillFeeV2QueueDataAdapt.java
index 2b26fff..2ac7d23 100644
--- a/service-job/src/main/java/com/java110/job/importData/adapt/ImportPhoneBillFeeV2QueueDataAdapt.java
+++ b/service-job/src/main/java/com/java110/job/importData/adapt/ImportPhoneBillFeeV2QueueDataAdapt.java
@@ -128,10 +128,10 @@
payFeePo.setUserId("-1");;
String id = po.getId();
po.setId(null);
- Object o = ((HashMap) sqlSessionTemplate.selectList("phoneBillFlowServiceDaoImpl.queryPhoneBillFlowsCount", BeanConvertUtil.beanCovertMap(po)).get(0)).get("count");
- if (Integer.parseInt(Vtil.defaultValue(o, "1")) != 0) {
- throw new IllegalArgumentException("閲嶅鐨勮瘽璐�");
- }
+// Object o = ((HashMap) sqlSessionTemplate.selectList("phoneBillFlowServiceDaoImpl.queryPhoneBillFlowsCount", BeanConvertUtil.beanCovertMap(po)).get(0)).get("count");
+// if (Integer.parseInt(Vtil.defaultValue(o, "1")) != 0) {
+// throw new IllegalArgumentException("閲嶅鐨勮瘽璐�");
+// }
po.setId(id);
// reqJson.put("feeId", payFeePo.getFeeId());
// String id = payFeePo.getFeeId();
@@ -141,7 +141,9 @@
// throw new IllegalArgumentException("閲嶅鐨勮瘽璐�");
// }
// payFeePo.setFeeId(id);
+
sqlSessionTemplate.insert("phoneBillFlowServiceDaoImpl.savePhoneBillFlowInfo", BeanConvertUtil.beanCovertMap(po));
+ payFeePo.setTest("瀵煎叆鍐呭锛屽厛涓嶅仛绂绘暎");
int flag = payFeeV1InnerServiceSMOImpl.savePayFee(payFeePo);
if (flag < 1) {
throw new CmdException("淇濆瓨鏁版嵁澶辫触");
--
Gitblit v1.8.0