生成快照BUG修复

ibps-provider-root/modules/provider-platform/src/main/java/com/lc/ibps/mq/consumer/rabbit/RabbitSnapshotMessageQueueConsumer.java

@@ -93,7 +93,8 @@ public class RabbitSnapshotMessageQueueConsumer   {
                 "where liu_cheng_xuan_ze = '" + hisMap.get("PROC_DEF_KEY_") + "' AND gui_dang_lei_xing = 'process'");
             APIResult<AttachmentPo> result = new APIResult<>();
 
-            if (BeanUtils.isNotEmpty(kzMap.get("ti_jiao_kuai_zhao")) && "是".equals(kzMap.get("ti_jiao_kuai_zhao"))) {
+            if (BeanUtils.isNotEmpty(kzMap) && kzMap.containsKey("ti_jiao_kuai_zhao") &&
+                    BeanUtils.isNotEmpty(kzMap.get("ti_jiao_kuai_zhao")) && "是".equals(kzMap.get("ti_jiao_kuai_zhao")) ) {
                 PartyEmployeePo employeePo = partyEmployeeRepository.get(userId);
                 String position = employeePo.getPositions().split(",")[0];
                 PartyEntityPo entityPo = partyEntityRepository.get(position);
@@ -115,9 +116,11 @@ public class RabbitSnapshotMessageQueueConsumer   {
                 result = uploadFile.runQianUpload(url , name , StringPool.FileType.Office.PDF );
 
             }
-            StringBuilder sql = new StringBuilder();
-            if (BeanUtils.isNotEmpty(kzMap)) {
-                sql.append("update t_").append(kzMap.get("tablekey_")).append(" set shi_fou_guo_shen_ = '已完成' ");
+
+            Map<String, Object> defMap = commonDao.queryOne("select BO_CODE_ from ibps_bpm_def where DEF_KEY_ = '" + hisMap.get("PROC_DEF_KEY_") + "' ");
+            if (BeanUtils.isNotEmpty(defMap)) {
+                StringBuilder sql = new StringBuilder();
+                sql.append("update t_").append(defMap.get("BO_CODE_")).append(" set shi_fou_guo_shen_ = '已完成' ");
                 if (result.getState() == 200 && BeanUtils.isNotEmpty(result.getData())) {
                     sql.append(" , kuai_zhao_ = '").append(result.getData().getId()).append("' ");
                     LOGGER.warn("Generated Snapshot ID=" + result.getData().getId());