预警检测修改逻辑

src/main/java/com/zhiwei/manage/handle/MainThread.java

@@ -220,8 +220,8 @@ public class MainThread extends Thread {
 					}
 				}
 				Set<String> keys = allTmp.keySet();
-				List<Message> needRemoveWm = new ArrayList<>();
-				List<Message> needRemovePm = new ArrayList<>();
+				List<String> needRemoveWm = new ArrayList<>();
+				List<String> needRemovePm = new ArrayList<>();
 				for (Iterator<String> it = keys.iterator(); it.hasNext();) {
 					String key = it.next();
 					Template tmp = allTmp.get(key);
@@ -253,18 +253,30 @@ public class MainThread extends Thread {
 									Message msg = messageService.findMsg(tmp.getTempName(), null);
 									if (msg != null) {
 										if (msg.getPt().equals("网媒")) {
-											needRemoveWm.add(msg);
+											needRemoveWm.add(msg.getMessageId());
 										} else {
-											needRemovePm.add(msg);
+											needRemovePm.add(msg.getMessageId());
 										}
 									}
 								}
+							} else {
+								Message msg = messageService.findMsg(tmp.getTempName(), null);
+								if (msg != null) {
+									if (msg.getPt().equals("网媒")) {
+										needRemoveWm.add(msg.getMessageId());
+									} else {
+										needRemovePm.add(msg.getMessageId());
+									}
+								}
 							}
 						} catch (Exception e) {
 							log.error(tmp.getTempName() + "入库出错，错误信息{}", e);
 						}
 					}
 				}
+				// 有数据了，移除错误信息
+				messageService.delete(needRemovePm, "平媒");
+				messageService.delete(needRemoveWm, "网媒");
 			} catch (Exception e) {
 				e.printStackTrace();
 			}

src/main/java/com/zhiwei/manage/servlet/ServerController.java

@@ -104,21 +104,18 @@ public class ServerController {
 		return JSON.toJSONString(result);
 	}
 
-	// /**
-	// * 更改平台
-	// *
-	// * @param map
-	// * @return
-	// */
-	// @RequestMapping(value = "/changePt", produces =
-	// "application/json;charset=utf-8")
-	// @ResponseBody
-	// public String changePt(@RequestBody Map<String, Object> map) {
-	// String pt = (String) map.get("pt");
-	// ss.findPt(pt);
-	// JsonResult result = new JsonResult(true, 200, "源改变成功");
-	// return JSON.toJSONString(result);
-	// }
+	/**
+	 * 更改平台
+	 *
+	 * @param map
+	 * @return
+	 */
+	@RequestMapping(value = "/changePt", produces = "application/json;charset=utf-8")
+	@ResponseBody
+	public String changePt(@RequestBody Map<String, Object> map) {
+		JsonResult result = new JsonResult(true, 200, "源改变成功");
+		return JSON.toJSONString(result);
+	}
 
 	/**
 	 * 插入渠道信息