|
|
@@ -103,21 +103,23 @@ public class AddNoFlowDataJob extends BaseJob2 {
|
|
|
int error = 0;
|
|
|
logger.warn("添加无流程快照数据总数:{}, 业务表名=={}", boList.size(), prefix +":"+tableName);
|
|
|
for (Map<String, Object> boMap : boList){
|
|
|
- boMap.put("bo_code_", tableName);
|
|
|
- boMap.put("proc_def_name_", prefix);
|
|
|
- boMap.put("bao_biao_lu_jing_", url);
|
|
|
- boMap.put("id_", UniqueIdUtil.getId());
|
|
|
- boMap.put("end_time_", new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format((BeanUtils.isEmpty(boMap.get("update_time_"))?boMap.get("create_time_"):boMap.get("update_time_"))));
|
|
|
- boMap.put("create_time_", new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
|
|
|
- boMap.put("update_time_", new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
|
|
|
-
|
|
|
- try{
|
|
|
- commonDao.execute(this.buildInsertSql(boMap,"t_bckzsjb"));
|
|
|
- }catch (Exception e){
|
|
|
- error = error + 1;
|
|
|
- logger.error("无流程快照数据插入异常:{}",boMap);
|
|
|
- e.printStackTrace();
|
|
|
- continue;
|
|
|
+ if (BeanUtils.isNotEmpty(boMap.get("position_id_")) && BeanUtils.isNotEmpty(boMap.get("org_id_"))){
|
|
|
+ boMap.put("bo_code_", tableName);
|
|
|
+ boMap.put("proc_def_name_", prefix);
|
|
|
+ boMap.put("bao_biao_lu_jing_", url);
|
|
|
+ boMap.put("id_", UniqueIdUtil.getId());
|
|
|
+ boMap.put("end_time_", new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format((BeanUtils.isEmpty(boMap.get("update_time_"))?boMap.get("create_time_"):boMap.get("update_time_"))));
|
|
|
+ boMap.put("create_time_", new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
|
|
|
+ boMap.put("update_time_", new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
|
|
|
+
|
|
|
+ try{
|
|
|
+ commonDao.execute(this.buildInsertSql(boMap,"t_bckzsjb"));
|
|
|
+ }catch (Exception e){
|
|
|
+ error = error + 1;
|
|
|
+ logger.error("无流程快照数据插入异常:{}",boMap);
|
|
|
+ e.printStackTrace();
|
|
|
+ continue;
|
|
|
+ }
|
|
|
}
|
|
|
}
|
|
|
String msg = "无流程快照数据添加f_gen_snapshot表异常数:"+error;
|