parent
687bf7277c
commit
555c2d16b7
|
@ -68,7 +68,7 @@ public class BankSaveOP extends AbstractOperationServicePlugIn {
|
|||
List<String> ids = Arrays.stream(dataEntities) // 将数组转换为 Stream
|
||||
.map(entity -> (String) entity.get("billno")) // 提取每个元素的 id
|
||||
.collect(Collectors.toList()); // 收集到 List 中
|
||||
logger.info("入参:" + ids);
|
||||
logger.info("入参编号:" + ids);
|
||||
if (dataEntities != null && dataEntities.length != 0) {
|
||||
|
||||
for (int i = 0; i < dataEntities.length; i++) {
|
||||
|
@ -76,50 +76,60 @@ public class BankSaveOP extends AbstractOperationServicePlugIn {
|
|||
DynamicObject dynamicObject = dataEntities[i];
|
||||
try {
|
||||
String description = dynamicObject.getString("description");
|
||||
logger.info("description"+description);
|
||||
if (qFilter != null) {
|
||||
String sql = qFilter.toString();
|
||||
String replaced = sql.replace("description", "'" + description + "'");
|
||||
String selsql = " /*dialect*/ select 1 where " + replaced;
|
||||
DataSet res = DB.queryDataSet(this.getClass().getSimpleName(), DBRoute.of("fi"), selsql);//财务云
|
||||
DynamicObjectCollection srcCollection = ORM.create().toPlainDynamicObjectCollection(res.copy());
|
||||
System.out.println("单据编号" + dynamicObject.getString("billno") +"size:"+srcCollection.size());
|
||||
if (srcCollection.size() != 0) {
|
||||
dynamicObject.set("kdretflag", null); //数据赋值
|
||||
logger.info("单据编号" + dynamicObject.getString("billno") + "进入banksavef方法直接赋值成功");
|
||||
}
|
||||
}else {
|
||||
dynamicObject.set("kdretflag", null); //数据赋值
|
||||
logger.info("单据编号" + dynamicObject.getString("billno") + "进入banksavef方法直接赋值成功");
|
||||
}
|
||||
} catch (Exception ex) {
|
||||
logger.info("单据编号" + dynamicObject.getString("billno") + "进入banksavef方法直接赋值失败");
|
||||
}
|
||||
|
||||
if (dynamicObject != null) {
|
||||
//通过基础资料或单据标识 的id 获取数据
|
||||
QFilter newqFilter = new QFilter("billno", QCP.equals, dynamicObject.getString("billno"));
|
||||
DynamicObject dynamicObject1 = BusinessDataServiceHelper.loadSingle("bei_transdetail", "id,billno,description,kdretflag", newqFilter.toArray());
|
||||
if (dynamicObject1 != null) {
|
||||
logger.info("已找到单据编号:" + dynamicObject.getString("billno") + "对应的交易明细");
|
||||
} else {
|
||||
logger.info("未找到单据编号:" + dynamicObject.getString("billno") + "对应的交易明细");
|
||||
}
|
||||
if (qFilter != null) {
|
||||
qFilter = qFilter.and(newqFilter);
|
||||
} else {
|
||||
qFilter = newqFilter;
|
||||
}
|
||||
DynamicObject bei_transdetail = BusinessDataServiceHelper.loadSingle("bei_transdetail", "id,billno,description,kdretflag", qFilter.toArray());
|
||||
DynamicObject bei_transdetail_cas = BusinessDataServiceHelper.loadSingle(dynamicObject.getDynamicObjectType().toString(), "id,billno,description,kdretflag", qFilter.toArray());
|
||||
if (bei_transdetail != null) {
|
||||
|
||||
bei_transdetail.set("kdretflag", null); //数据赋值
|
||||
SaveServiceHelper.save(new DynamicObject[]{bei_transdetail});
|
||||
logger.info("bei_transdetail:" + dynamicObject + "赋值成功");
|
||||
} else {
|
||||
logger.info("dynamicObject:" + dynamicObject + "未找到");
|
||||
}
|
||||
if (bei_transdetail_cas != null) {
|
||||
bei_transdetail_cas.set("kdretflag", null); //数据赋值
|
||||
SaveServiceHelper.save(new DynamicObject[]{bei_transdetail_cas});
|
||||
}
|
||||
}
|
||||
// if (dynamicObject != null) {
|
||||
// //通过基础资料或单据标识 的id 获取数据
|
||||
// QFilter newqFilter = new QFilter("billno", QCP.equals, dynamicObject.getString("billno"));
|
||||
// DynamicObject dynamicObject1 = BusinessDataServiceHelper.loadSingle("bei_transdetail", "id,billno,description,kdretflag", newqFilter.toArray());
|
||||
// if (dynamicObject1 != null) {
|
||||
// logger.info("已找到单据编号:" + dynamicObject.getString("billno") + "对应的交易明细");
|
||||
// } else {
|
||||
// logger.info("未找到单据编号:" + dynamicObject.getString("billno") + "对应的交易明细");
|
||||
// }
|
||||
// QFilter qFilter1;
|
||||
// if (qFilter != null) {
|
||||
// qFilter1 = qFilter.copy().and(newqFilter);
|
||||
// } else {
|
||||
// qFilter1 = newqFilter;
|
||||
// }
|
||||
// DynamicObject bei_transdetail = BusinessDataServiceHelper.loadSingle("bei_transdetail", "id,billno,description,kdretflag", qFilter1.toArray());
|
||||
// DynamicObject bei_transdetail_cas = BusinessDataServiceHelper.loadSingle(dynamicObject.getDynamicObjectType().toString(), "id,billno,description,kdretflag", qFilter1.toArray());
|
||||
// if (bei_transdetail != null) {
|
||||
//
|
||||
// bei_transdetail.set("kdretflag", null); //数据赋值
|
||||
// SaveServiceHelper.save(new DynamicObject[]{bei_transdetail});
|
||||
// logger.info("bei_transdetail:" + dynamicObject.getString("billno") + "赋值成功");
|
||||
// } else {
|
||||
// logger.info("bei_transdetail:" + dynamicObject.getString("billno") + "未找到");
|
||||
// }
|
||||
//
|
||||
// if (bei_transdetail_cas != null) {
|
||||
// bei_transdetail_cas.set("kdretflag", null); //数据赋值
|
||||
// SaveServiceHelper.save(new DynamicObject[]{bei_transdetail_cas});
|
||||
// logger.info("单据标识:"+dynamicObject.getDynamicObjectType().toString()+" 编号:"+dynamicObject.getString("billno")+"赋值成功");
|
||||
// }else {
|
||||
// logger.info("单据标识:"+dynamicObject.getDynamicObjectType().toString()+" 编号:"+dynamicObject.getString("billno")+"未找到");
|
||||
// }
|
||||
// }
|
||||
dataEntities[i] = dynamicObject;
|
||||
}
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue