yonyou
/
taikai2312
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(ims): 高压IMS-调整sql-防止引号中有引号

This commit is contained in:
mzr 2025-11-20 16:45:23 +08:00
parent 747e94d84d
commit da7e4a19fb
3 changed files with 23 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
uapbd/src/private/nc/bs/uapbd/task/ims/ErpIaI2billFromGyImsPlugin.java
View File

@ -9,6 +9,7 @@ import nc.bs.pub.pa.PreAlertObject;
import nc.bs.pub.taskcenter.BgWorkingContext; import nc.bs.pub.taskcenter.BgWorkingContext;
import nc.bs.pub.taskcenter.IBackgroundWorkPlugin; import nc.bs.pub.taskcenter.IBackgroundWorkPlugin;
import nc.bs.uapbd.util.MyHelper; import nc.bs.uapbd.util.MyHelper;
import nc.jdbc.framework.SQLParameter;
import nc.jdbc.framework.processor.MapListProcessor; import nc.jdbc.framework.processor.MapListProcessor;
import nc.jdbc.framework.processor.MapProcessor; import nc.jdbc.framework.processor.MapProcessor;
import nc.vo.ic.m45.entity.PurchaseInVO; import nc.vo.ic.m45.entity.PurchaseInVO;
@ -162,10 +163,11 @@ public class ErpIaI2billFromGyImsPlugin implements IBackgroundWorkPlugin {
getImsDao().executeUpdate(updateSql); getImsDao().executeUpdate(updateSql);
} catch (BusinessException e) { } catch (BusinessException e) {
logger.error("ErpIaI2billFromGyImsPlugin Error: " + e.getMessage(), e); logger.error("ErpIaI2billFromGyImsPlugin Error: " + e.getMessage(), e);
String updateSql = "update BIPInputMainTab set err_msg = '[err_msg]' where cgeneralhid = '[cgeneralhid]'"; String updateSql = "update BIPInputMainTab set err_msg = ? where cgeneralhid = ?";
updateSql = updateSql.replace("[err_msg]", e.getMessage()); SQLParameter parameter = new SQLParameter();
updateSql = updateSql.replace("[cgeneralhid]", cgeneralhid); parameter.addParam(e.getMessage());
int rows = getImsDao().executeUpdate(updateSql); parameter.addParam(cgeneralhid);
int rows = getImsDao().executeUpdate(updateSql, parameter);
} }
} }
return null; return null;

19
uapbd/src/private/nc/bs/uapbd/task/ims/MaterialOutGyImsPlugin.java
View File

@ -9,6 +9,7 @@ import nc.bs.pub.taskcenter.IBackgroundWorkPlugin;
import nc.bs.uapbd.util.MyHelper; import nc.bs.uapbd.util.MyHelper;
import nc.itf.mmpac.pickm.IPickmQueryService; import nc.itf.mmpac.pickm.IPickmQueryService;
import nc.itf.uap.pf.busiflow.PfButtonClickContext; import nc.itf.uap.pf.busiflow.PfButtonClickContext;
import nc.jdbc.framework.SQLParameter;
import nc.jdbc.framework.processor.ColumnProcessor; import nc.jdbc.framework.processor.ColumnProcessor;
import nc.jdbc.framework.processor.MapListProcessor; import nc.jdbc.framework.processor.MapListProcessor;
import nc.pubitf.ic.m4d.api.IMaterialOutMaintainAPI; import nc.pubitf.ic.m4d.api.IMaterialOutMaintainAPI;
@ -29,7 +30,9 @@ import nc.vo.scmpub.res.billtype.MMBillType;
import java.math.BigDecimal; import java.math.BigDecimal;
import java.sql.Timestamp; import java.sql.Timestamp;
import java.text.SimpleDateFormat; import java.text.SimpleDateFormat;
import java.util.*; import java.util.HashMap;
import java.util.List;
import java.util.Map;
/** /**
* 定时同步高压加工车间IMS的材料出库 * 定时同步高压加工车间IMS的材料出库
@ -98,8 +101,8 @@ public class MaterialOutGyImsPlugin implements IBackgroundWorkPlugin {
MaterialOutHeadVO hvo = vo.getHead(); MaterialOutHeadVO hvo = vo.getHead();
MaterialOutBodyVO[] bodys = vo.getBodys(); MaterialOutBodyVO[] bodys = vo.getBodys();
hvo.setVbillcode(mainMap.get("vbillcode") + ""); hvo.setVbillcode(mainMap.get("vbillcode") + "");
hvo.setCreator(MyHelper.getUserId((String) mainMap.get("creator")) ); hvo.setCreator(MyHelper.getUserId((String) mainMap.get("creator")));
hvo.setBillmaker(MyHelper.getUserId((String) mainMap.get("billmaker")) ); hvo.setBillmaker(MyHelper.getUserId((String) mainMap.get("billmaker")));
hvo.setVtrantypecode("4D-01"); hvo.setVtrantypecode("4D-01");
if (MMValueCheck.isEmpty(mainMap.get("cwarehouseid"))) { if (MMValueCheck.isEmpty(mainMap.get("cwarehouseid"))) {
continue; continue;
@ -166,11 +169,11 @@ public class MaterialOutGyImsPlugin implements IBackgroundWorkPlugin {
getImsDao().executeUpdate(updateSql); getImsDao().executeUpdate(updateSql);
} catch (BusinessException e) { } catch (BusinessException e) {
logger.error("MaterialOutGyImsPlugin Error: ", e); logger.error("MaterialOutGyImsPlugin Error: ", e);
String updateSql = "update BIPOutMainTab set err_msg = '[err_msg]' where cgeneralhid = '[cgeneralhid]'"; String updateSql = "update BIPOutMainTab set err_msg = ? where cgeneralhid = ?";
updateSql = updateSql.replace("[err_msg]", e.getMessage()); SQLParameter parameter = new SQLParameter();
updateSql = updateSql.replace("[cgeneralhid]", cgeneralhid); parameter.addParam(e.getMessage());
// NCCForUAPLogger.debug("updateSql-fail = " + updateSql); parameter.addParam(cgeneralhid);
getImsDao().executeUpdate(updateSql); int rows = getImsDao().executeUpdate(updateSql, parameter);
} }
} }
logger.error("---end----高压IMS-材料出库-任务结束运行--"); logger.error("---end----高压IMS-材料出库-任务结束运行--");

10
uapbd/src/private/nc/bs/uapbd/task/ims/ProductReportGyImsPlugin.java
View File

@ -10,6 +10,7 @@ import nc.bs.uapbd.util.MyHelper;
import nc.itf.mmpac.pmo.pac0002.IPMOQueryService; import nc.itf.mmpac.pmo.pac0002.IPMOQueryService;
import nc.itf.mmpac.wr.IWrMaintainService; import nc.itf.mmpac.wr.IWrMaintainService;
import nc.itf.uap.pf.busiflow.PfButtonClickContext; import nc.itf.uap.pf.busiflow.PfButtonClickContext;
import nc.jdbc.framework.SQLParameter;
import nc.jdbc.framework.processor.ColumnProcessor; import nc.jdbc.framework.processor.ColumnProcessor;
import nc.jdbc.framework.processor.MapListProcessor; import nc.jdbc.framework.processor.MapListProcessor;
import nc.util.mmf.busi.service.PFPubService; import nc.util.mmf.busi.service.PFPubService;
@ -170,10 +171,11 @@ public class ProductReportGyImsPlugin implements IBackgroundWorkPlugin {
getImsDao().executeUpdate(updateSql); getImsDao().executeUpdate(updateSql);
} catch (BusinessException e) { } catch (BusinessException e) {
logger.error("ProductReportGyImsPlugin Error: " + e.getMessage(), e); logger.error("ProductReportGyImsPlugin Error: " + e.getMessage(), e);
String updateSql = "update BIPReportMainTab set err_msg = '[err_msg]' where pk_wr = '[pkWr]'"; String updateSql = "update BIPReportMainTab set err_msg = ? where pk_wr = ?";
updateSql = updateSql.replace("[err_msg]", e.getMessage()); SQLParameter parameter = new SQLParameter();
updateSql = updateSql.replace("[pkWr]", pkWr); parameter.addParam(e.getMessage());
getImsDao().executeUpdate(updateSql); parameter.addParam(pkWr);
int rows = getImsDao().executeUpdate(updateSql, parameter);
} }
} }
logger.error("---end----高压IMS-生产报告-任务结束运行--"); logger.error("---end----高压IMS-生产报告-任务结束运行--");