导入测试

chengf

2026-03-18 56931dc90c4e070d279a0cbf5822af010c481812

 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("保存数据失败");