From f8270f19b831500bf088495dd7401039b4726689 Mon Sep 17 00:00:00 2001 From: calyrex <2213354201@qq.com> Date: Mon, 6 Jan 2025 14:03:24 +0800 Subject: [PATCH] 4 files update --- .../workflow/action/BY_EnterToJhrwMx.java | 3 + .../workflow/action/BuQianKaAction.java | 60 +++++++++++++------ .../workflow/action/CustomTeAction.java | 12 +--- .../workflow/action/DoTheActionNew.java | 2 +- .../action/SCFAndEASApplyUserSyncAction.java | 2 +- .../ZOA_SD_CREDIT_HANDLE_APPROVALAction.java | 34 ++++++++--- 6 files changed, 75 insertions(+), 38 deletions(-) diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/BY_EnterToJhrwMx.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/BY_EnterToJhrwMx.java index 3da79ac..7f60b8d 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/BY_EnterToJhrwMx.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/BY_EnterToJhrwMx.java @@ -69,6 +69,9 @@ public class BY_EnterToJhrwMx implements Action, EsbServerlessRpcRemoteInterface TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源*/ long generate = IdGenerator.generate(); rs.executeSql(sql, poolname,generate); + + + // 写入流程提醒记录 String sql4 = "insert into e10_common.dbo.jhrwmxlog(id,mainid,rwbh,lcbid,zkjh,gzrw,zrr,jxzb,ts,ksrq,jsrq,yqrq,phr,ddr,qrr,csr,pid,glid,mxid,isdr,rwzt,requestid,request,rwbh2,lxsj,tdsj,rwlx,xmkp,yhry,rwjb,shr,jtyq,tbr,rbbm,ssgs,rwsm,fj,yfjd,xmbh,FtriggerFlag) (select id,mainid,rwbh,lcbid,zkjh,gzrw,zrr,jxzb,ts,ksrq,jsrq,yqrq,phr,ddr,qrr,csr,pid,glid,mxid,isdr,rwzt,0 as requestid,requestid as request,rwbh2,lxsj,tdsj,rwlx,xmkp,yhry,rwjb,shr,jtyq,tbr,rbbm,ssgs,rwsm,fj,yfjd,xmbh,0 as FtriggerFlag from jhrwmx where mxid<>0 and ISDR=0 AND cast(glid as varchar) = '" + glid + "') order by rwbh "; logger_b053f378.info("sql4:" + sql4); diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/BuQianKaAction.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/BuQianKaAction.java index f52c246..1ab2d9e 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/BuQianKaAction.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/BuQianKaAction.java @@ -119,13 +119,21 @@ public class BuQianKaAction extends BaseBean implements Action, EsbServerlessRpc Punchreason = Util.null2String((String) mainTableDataMap.get("yyy2")); TimeCardTime = TimeCardTime + " " + time; Punchtype1 = Punchtype + "_2"; - String sql = "insert into e10_common.dbo.buka_log(requestid,gh,punchreason,punchtype,TimeCardDate,TimeCardTime,createrId,BKRQ) values" + "(" + requestid + ",'" + GH + "','" + Punchreason + "','" + Punchtype1 + "','" + TimeCardDate + "','" + TimeCardTime + "','" + createrId + "','" + BKRQ + "')"; +// String sql = "insert into e10_common.dbo.buka_log(requestid,gh,punchreason,punchtype,TimeCardDate,TimeCardTime,createrId,BKRQ) values" + "(" + requestid + ",'" + GH + "','" + Punchreason + "','" + Punchtype1 + "','" + TimeCardDate + "','" + TimeCardTime + "','" + createrId + "','" + BKRQ + "')"; +// logger_f1f35583.info(String.valueOf("sql2:" + sql)); +// String poolname_ae = CONN_TYPE.ebuilder.getType(); +// /* *TODO 检测到insert语句 -> E9插入sql迁移到E10需要特殊处理请参考文档进行调整 https://www.e-cology.com.cn/sp/doc/docShare/1027709301045985331?tenantKey=t7akvdnf84 +// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源*/ +// long generate = IdGenerator.generate(); +// rs.executeSql(sql, poolname_ae,generate); + Long uf_CustomFlow_formId1 = commonDevUtil.getObjId("buka_log"); + logger_f1f35583.info("uf_CustomFlow_formId = " + uf_CustomFlow_formId1); + SimpleEmployee currentEmployee = HrmContextUtil.getCurrentUser(); + Long recodId = ebFormDataDubboService.addEmptyData(uf_CustomFlow_formId1, currentEmployee); + String sql = "update e10_common.dbo.buka_log set requestid = " + requestid + ",gh = '" + GH + "',punchreason='" + Punchreason + "',punchtype='" + Punchtype1 + "',TimeCardDate='" + TimeCardDate + "',TimeCardTime='" + TimeCardTime + "',createrId='" + createrId + "',BKRQ='" + BKRQ + "' where id = " + recodId+ " and delete_type = 0 "; + boolean b1 = rs.executeSql(sql, poolname); logger_f1f35583.info(String.valueOf("sql2:" + sql)); - String poolname_ae = CONN_TYPE.ebuilder.getType(); - /* *TODO 检测到insert语句 -> E9插入sql迁移到E10需要特殊处理请参考文档进行调整 https://www.e-cology.com.cn/sp/doc/docShare/1027709301045985331?tenantKey=t7akvdnf84 - TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源*/ - long generate = IdGenerator.generate(); - rs.executeSql(sql, poolname_ae,generate); + logger_f1f35583.info(String.valueOf("b1:" + b1)); } } logger_f1f35583.info(String.valueOf("sikz:" + mainTableDataMap.get("sikz"))); @@ -138,13 +146,21 @@ public class BuQianKaAction extends BaseBean implements Action, EsbServerlessRpc Punchreason = Util.null2String((String) mainTableDataMap.get("yyy" + (2 + i))); TimeCardTime = TimeCardTime + " " + time; Punchtype1 = Punchtype + "_" + i; - String sql = "insert into e10_common.dbo.buka_log(requestid,gh,punchreason,punchtype,TimeCardDate,TimeCardTime,createrId,BKRQ) values" + "(" + requestid + ",'" + GH + "','" + Punchreason + "','" + Punchtype1 + "','" + TimeCardDate + "','" + TimeCardTime + "','" + createrId + "','" + BKRQ + "')"; +// String sql = "insert into e10_common.dbo.buka_log(requestid,gh,punchreason,punchtype,TimeCardDate,TimeCardTime,createrId,BKRQ) values" + "(" + requestid + ",'" + GH + "','" + Punchreason + "','" + Punchtype1 + "','" + TimeCardDate + "','" + TimeCardTime + "','" + createrId + "','" + BKRQ + "')"; +// logger_f1f35583.info(String.valueOf("sql3:" + sql)); +// String poolname_oa = CONN_TYPE.ebuilder.getType(); +// /* *TODO 检测到insert语句 -> E9插入sql迁移到E10需要特殊处理请参考文档进行调整 https://www.e-cology.com.cn/sp/doc/docShare/1027709301045985331?tenantKey=t7akvdnf84 +// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源*/ +// long generate = IdGenerator.generate(); +// rs.executeSql(sql, poolname_oa,generate); + Long uf_CustomFlow_formId2 = commonDevUtil.getObjId("buka_log"); + logger_f1f35583.info("uf_CustomFlow_formId = " + uf_CustomFlow_formId2); + SimpleEmployee currentEmployee = HrmContextUtil.getCurrentUser(); + Long recodId = ebFormDataDubboService.addEmptyData(uf_CustomFlow_formId2, currentEmployee); + String sql = "update e10_common.dbo.buka_log set requestid = " + requestid + ",gh = '" + GH + "',punchreason='" + Punchreason + "',punchtype='" + Punchtype1 + "',TimeCardDate='" + TimeCardDate + "',TimeCardTime='" + TimeCardTime + "',createrId='" + createrId + "',BKRQ='" + BKRQ + "' where id = " + recodId+ " and delete_type = 0 "; + boolean b1 = rs.executeSql(sql, poolname); logger_f1f35583.info(String.valueOf("sql3:" + sql)); - String poolname_oa = CONN_TYPE.ebuilder.getType(); - /* *TODO 检测到insert语句 -> E9插入sql迁移到E10需要特殊处理请参考文档进行调整 https://www.e-cology.com.cn/sp/doc/docShare/1027709301045985331?tenantKey=t7akvdnf84 - TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源*/ - long generate = IdGenerator.generate(); - rs.executeSql(sql, poolname_oa,generate); + logger_f1f35583.info(String.valueOf("b1:" + b1)); } } } @@ -158,13 +174,21 @@ public class BuQianKaAction extends BaseBean implements Action, EsbServerlessRpc Punchreason = Util.null2String((String) mainTableDataMap.get("yyy" + (6 + i))); TimeCardTime = TimeCardTime + " " + time; Punchtype1 = Punchtype + "_" + i; - String sql = "insert into e10_common.dbo.buka_log(requestid,gh,punchreason,punchtype,TimeCardDate,TimeCardTime,createrId,BKRQ) values" + "(" + requestid + ",'" + GH + "','" + Punchreason + "','" + Punchtype1 + "','" + TimeCardDate + "','" + TimeCardTime + "','" + createrId + "','" + BKRQ + "')"; +// String sql = "insert into e10_common.dbo.buka_log(requestid,gh,punchreason,punchtype,TimeCardDate,TimeCardTime,createrId,BKRQ) values" + "(" + requestid + ",'" + GH + "','" + Punchreason + "','" + Punchtype1 + "','" + TimeCardDate + "','" + TimeCardTime + "','" + createrId + "','" + BKRQ + "')"; +// logger_f1f35583.info(String.valueOf("sql4:" + sql)); +// String poolname_31 = CONN_TYPE.ebuilder.getType(); +// /* *TODO 检测到insert语句 -> E9插入sql迁移到E10需要特殊处理请参考文档进行调整 https://www.e-cology.com.cn/sp/doc/docShare/1027709301045985331?tenantKey=t7akvdnf84 +// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源*/ +// long generate = IdGenerator.generate(); +// rs.executeSql(sql, poolname_31,generate); + Long uf_CustomFlow_formId3 = commonDevUtil.getObjId("buka_log"); + logger_f1f35583.info("uf_CustomFlow_formId = " + uf_CustomFlow_formId3); + SimpleEmployee currentEmployee = HrmContextUtil.getCurrentUser(); + Long recodId = ebFormDataDubboService.addEmptyData(uf_CustomFlow_formId3, currentEmployee); + String sql = "update e10_common.dbo.buka_log set requestid = " + requestid + ",gh = '" + GH + "',punchreason='" + Punchreason + "',punchtype='" + Punchtype1 + "',TimeCardDate='" + TimeCardDate + "',TimeCardTime='" + TimeCardTime + "',createrId='" + createrId + "',BKRQ='" + BKRQ + "' where id = " + recodId+ " and delete_type = 0 "; + boolean b1 = rs.executeSql(sql, poolname); logger_f1f35583.info(String.valueOf("sql4:" + sql)); - String poolname_31 = CONN_TYPE.ebuilder.getType(); - /* *TODO 检测到insert语句 -> E9插入sql迁移到E10需要特殊处理请参考文档进行调整 https://www.e-cology.com.cn/sp/doc/docShare/1027709301045985331?tenantKey=t7akvdnf84 - TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源*/ - long generate = IdGenerator.generate(); - rs.executeSql(sql, poolname_31,generate); + logger_f1f35583.info(String.valueOf("b1:" + b1)); } } } diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/CustomTeAction.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/CustomTeAction.java index ac6c59e..7e9d28f 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/CustomTeAction.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/CustomTeAction.java @@ -1,15 +1,12 @@ package com.weaver.seconddev.interfaces.workflow.action; import com.alibaba.fastjson.JSON; -import com.weaver.authority.api.req.role.BatchAuthRoleReq; import com.weaver.authority.api.rest.RemoteAuthorityRoleService; import com.weaver.common.base.entity.result.WeaResult; import com.weaver.common.hrm.util.HrmContextUtil; import com.weaver.common.i18n.tool.util.I18nContextUtil; -import com.weaver.custom.configcenter.htsysjcmtConfig; import com.weaver.ebuilder.form.client.ebform.data.EbFormDataDubboService; import com.weaver.esb.api.rpc.EsbServerlessRpcRemoteInterface; -import com.weaver.framework.client.annotation.WeaverConfigCenter; import com.weaver.framework.rpc.annotation.RpcReference; import com.weaver.seconddev.interfaces.prop.ConfigProp; import com.weaver.seconddev.interfaces.workflow.util.CommonDevUtil; @@ -17,22 +14,15 @@ import com.weaver.teams.domain.user.SimpleEmployee; import com.weaver.verupgrade.conn.CONN_TYPE; import com.weaver.verupgrade.conn.RecordSet; import com.weaver.verupgrade.general.BaseBean; -import com.weaver.verupgrade.general.Util; import com.weaver.verupgrade.interfaces.workflow.action.Action; import com.weaver.verupgrade.soa.workflow.request.RequestInfo; import com.weaver.verupgrade.workflow.request.RequestManager; -import lombok.Data; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; -import org.springframework.cloud.context.config.annotation.RefreshScope; -import org.springframework.context.annotation.Configuration; -import org.springframework.core.env.Environment; import org.springframework.stereotype.Service; -import java.util.ArrayList; import java.util.HashMap; -import java.util.List; import java.util.Map; @@ -64,7 +54,7 @@ public class CustomTeAction extends BaseBean implements Action, EsbServerlessRpc @Override public WeaResult> execute(Map params) { logger.error("start CustomTeAction"); - logger.error("lplysl_url == " + configProp.getLplysl_url()); +// logger.error("lplysl_url == " + configProp.getLplysl_url()); logger.error("basePackage == " + basePackage); logger.error("params = " + JSON.toJSONString(params)); diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/DoTheActionNew.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/DoTheActionNew.java index 0a2cdda..7829da5 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/DoTheActionNew.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/DoTheActionNew.java @@ -91,7 +91,6 @@ public class DoTheActionNew { String csr = (String) mainMap.get("csr"); String ddr = (String) mainMap.get("ddr"); String qrr = (String) mainMap.get("qrr"); - String sql = "insert into dbo.uf_zqjhrqfkxx (requestId,fksm,fj,fkrq,pid,zrr,ddr,csr,phr,qrr,formmodeid,modedatacreater) values (?,?,?,?,?,?,?,?,?,?,97,?)"; Object[] array = new Object[11]; array[0] = requestId; array[1] = sm; @@ -106,6 +105,7 @@ public class DoTheActionNew { array[10] = tbr; // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 String poolname =""; + String sql = "insert into dbo.uf_zqjhrqfkxx (requestId,fksm,fj,fkrq,pid,zrr,ddr,csr,phr,qrr,formmodeid,modedatacreater) values (?,?,?,?,?,?,?,?,?,?,97,?)"; rs.executeSql(sql, false, poolname, array); String sql2 = "select * from uf_zqjhrqfkxx where pid = " + mxid; RecordSet rs3 = I18nContextUtil.getBean(RecordSet.class); diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/SCFAndEASApplyUserSyncAction.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/SCFAndEASApplyUserSyncAction.java index 75f2ae7..3a59c3c 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/SCFAndEASApplyUserSyncAction.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/SCFAndEASApplyUserSyncAction.java @@ -199,7 +199,7 @@ public class SCFAndEASApplyUserSyncAction extends BaseBean implements Action, Es rs.executeSql("insert into uf_applyUser(companycode,formmodeid,modedatacreater,modedatacreatertype,modedatacreatedate,modedatacreatetime," + "lclx,oafqr,oafqrgh,easfqr,easfqrgh,modeuuid) " + "values('" + companyCode + "'," + "'139'," + sqr + "," + "'0'," + "'" + currentdate + "'," + "'" + currenttime + "'," + list.get(i).get("lclx") + "," + list.get(i).get("oafqr") + ",'" + list.get(i).get("oafqrgh") + "'," + list.get(i).get("oafqr") + ",'" + list.get(i).get("oafqrgh") + "','" + uuid + // DiscountedInvoiceApplicationImpl 使用eas发起人 "')", poolname_2n,generate); } - // rs.execute("insert into uf_applyUser(companycode,lclx,oafqr,oafqrgh,easfqr,easfqrgh) values('"+companyCode+"',"+list.get(i).get("lclx")+","+list.get(i).get("oafqr")+",'"+list.get(i).get("oafqrgh")+"',"+list.get(i).get("easfqr")+",'"+list.get(i).get("easfqrgh")+"')"); + // rs.execute("F"); } } } diff --git a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOA_SD_CREDIT_HANDLE_APPROVALAction.java b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOA_SD_CREDIT_HANDLE_APPROVALAction.java index ae6a682..b61554e 100644 --- a/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOA_SD_CREDIT_HANDLE_APPROVALAction.java +++ b/secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOA_SD_CREDIT_HANDLE_APPROVALAction.java @@ -1,10 +1,15 @@ package com.weaver.seconddev.interfaces.workflow.action; import com.weaver.common.distribution.genid.IdGenerator; +import com.weaver.common.hrm.util.HrmContextUtil; +import com.weaver.ebuilder.form.client.ebform.data.EbFormDataDubboService; +import com.weaver.framework.rpc.annotation.RpcReference; import com.weaver.seconddev.interfaces.crmoa.CRM_SyncUnFreezeTimesStub; import com.weaver.seconddev.interfaces.crmoa.CRM_syncUnFreezeTimes; import com.weaver.seconddev.interfaces.swfa.BillFieldUtil; import com.weaver.common.i18n.tool.util.I18nContextUtil; +import com.weaver.seconddev.interfaces.workflow.util.CommonDevUtil; +import com.weaver.teams.domain.user.SimpleEmployee; import com.weaver.verupgrade.conn.CONN_TYPE; import java.lang.*; import java.util.*; @@ -34,6 +39,12 @@ public class ZOA_SD_CREDIT_HANDLE_APPROVALAction extends BaseBean implements Act @Autowired private RequestInfo requestInfoTemp; + @Autowired + private CommonDevUtil commonDevUtil; + + @RpcReference(group = "ebuilderform") + private EbFormDataDubboService ebFormDataDubboService; + @Autowired private CRM_syncUnFreezeTimes freezeTimes ; @@ -150,13 +161,22 @@ public class ZOA_SD_CREDIT_HANDLE_APPROVALAction extends BaseBean implements Act logger_d591fda6.info(String.valueOf("------------[state : " + result[0] + "][message : " + result[1] + "] ----------")); logger_d591fda6.info(String.valueOf("------------do webservice CRM_syncUnFreezeTimes fail ----------")); // 把数据写入中间表 - String sql = "insert into HT_CRM_JDCS (REQUESTID,KHBM,XSZZ,SQRGH,SQRQ,CREATEDATE ) VALUES ('" + requestId + "','" + khbm + "','" + xszz + "','" + sqrgh + "','" + sqrq + "',GETDATE())"; - logger_d591fda6.info(String.valueOf("写入中间表sql : " + sql)); - String poolname_jj = CONN_TYPE.workflow.getType(); - /* *TODO 检测到insert语句 -> E9插入sql迁移到E10需要特殊处理请参考文档进行调整 https://www.e-cology.com.cn/sp/doc/docShare/1027709301045985331?tenantKey=t7akvdnf84 - TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源*/ - long generate = IdGenerator.generate(); - rs.executeSql(sql, poolname_jj,generate); +// String sql = "insert into HT_CRM_JDCS (REQUESTID,KHBM,XSZZ,SQRGH,SQRQ,CREATEDATE ) VALUES ('" + requestId + "','" + khbm + "','" + xszz + "','" + sqrgh + "','" + sqrq + "',GETDATE())"; +// logger_d591fda6.info(String.valueOf("写入中间表sql : " + sql)); +// String poolname_jj = CONN_TYPE.workflow.getType(); +// /* *TODO 检测到insert语句 -> E9插入sql迁移到E10需要特殊处理请参考文档进行调整 https://www.e-cology.com.cn/sp/doc/docShare/1027709301045985331?tenantKey=t7akvdnf84 +// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源*/ +// long generate = IdGenerator.generate(); +// rs.executeSql(sql, poolname_jj,generate); + + Long uf_CustomFlow_formId = commonDevUtil.getObjId("HT_CRM_JDCS"); + logger_d591fda6.info("uf_CustomFlow_formId = " + uf_CustomFlow_formId); + SimpleEmployee currentEmployee = HrmContextUtil.getCurrentUser(); + Long recodId = ebFormDataDubboService.addEmptyData(uf_CustomFlow_formId, currentEmployee);// 获取插入的空的建模id + String sql3 = "update e10_common.dbo.HT_CRM_JDCS set REQUESTID = '" + requestId + "',KHBM='" + khbm + "',XSZZ='" + xszz + "',SQRGH='" + sqrgh + "',SQRQ='" + sqrq + "',CREATEDATE=GETDATE() where id = " + recodId + " and delete_type = 0 "; + boolean b1 = rs.executeSql(sql3, poolname); + logger_d591fda6.info("sql3 = " + sql3); + logger_d591fda6.info("添加 = " + b1); logger_d591fda6.info(String.valueOf("------------写入中间表 success ----------")); } else { // 成功