序列号获取修改

This commit is contained in:
yjf 2022-03-31 10:01:51 +08:00
parent f7b43baa5e
commit 69e89acda9

View File

@ -192,27 +192,29 @@ public class FlowUtil {
String querySql = DataOperatorUtil.getQuerySql(searchCondtion);
BizObjectQuery bqDest = tNumberManager.createQuery(querySql);
for (String key : searchCondtion.keySet()) {
bqDest.setParameter(key, searchCondtion.get(key).toString());
bqDest.setParameter(key, searchCondtion.get(key));
}
BizObject serialNumber = null;
serialNumber = bqDest.getSingleResult(true);// 目标JBO需要做更新操作
serialNumber = bqDest.getSingleResult();// Ä¿±êJBO£¬ÐèÒª×ö¸üвÙ×÷
if(null==serialNumber){
serialNumber = tNumberManager.newObject();
if(null != queryYear)
{
if (null != queryYear) {
currentYear = queryYear;
}
serialNumber.setAttributeValue("year_",currentYear);
serialNumber.setAttributeValue("type_",type);
serialNumber.setAttributeValue("order_number_", "0");
serialNumber.setAttributeValue("order_number_", "1");
tNumberManager.saveObject(serialNumber);
} else {
Transaction sqlCa = Transaction.createTransaction(tx);
SqlObject sqlObject = new SqlObject("update T_SERIAL_NUMBER set order_number_ = order_number_+1 where " + querySql);
for (String key : searchCondtion.keySet()) {
sqlObject.setParameter(key, searchCondtion.get(key));
}
sqlCa.executeSQL(sqlObject);
serialNumber = bqDest.getSingleResult();
}
int maxOrderNumber = Integer.valueOf(serialNumber.getAttribute("order_number_").getInt()) + 1;
serialNumber.setAttributeValue("order_number_",maxOrderNumber);
tNumberManager.saveObject(serialNumber);
return maxOrderNumber;
return serialNumber.getAttribute("order_number_").getInt();
}
//考虑并发情况必须采用同步机制
@SuppressWarnings("unchecked")