Kaynağa Gözat

[bug-2353]培训通知定时任务改成接口调用

szjbdgzl 1 yıl önce
ebeveyn
işleme
080ae71b86

+ 16 - 1
ibps-provider-root/modules/provider-business/src/main/java/com/lc/ibps/business/service/impl/AuditServiceImpl.java

@@ -111,12 +111,27 @@ public class AuditServiceImpl implements AuditService {
                     newsPo.setUserId(userId);
                     newsPo.setUserName(userName);
                     newsPo.setType(didian);
-                    newsMgrService.save(newsPo);
+                    newsPo.setKey(id);
+                    saveNews(newsPo);
                 }
             }
         }
     }
 
+    public void saveNews(NewsPo newsPo){
+        String sql = "select id_ from ibps_news where key_='%s'";
+        sql = String.format(sql,newsPo.getKey());
+        Map<String,Object> map = commonDao.queryOne(sql);
+        if (BeanUtils.isEmpty(map)){
+            newsMgrService.save(newsPo);
+        }else {
+            String updSQL= "update ibps_news set title_='%s',USER_NAME_='%s',USER_ID_='%s',PUBLIC_DATE_=now()," +
+                    "AUTHOR_='%s',DEP_NAME_='%s',DEP_ID_='%s',TYPE_=now() where key_='%s'";
+            updSQL = String.format(updSQL,newsPo.getTitle(),newsPo.getUserName(),newsPo.getUserId(),newsPo.getAuthor(),newsPo.getDepName(),newsPo.getDepId(),newsPo.getKey());
+            commonDao.execute(updSQL);
+        }
+    }
+
     public String deduplication(String nameIds){
         String[] idsArray = nameIds.split(",");
         Set<String> uniqueIds = new HashSet<>();