bug修改。

This commit is contained in:
Renpc-kilig 2022-02-22 15:13:02 +08:00
parent 63cbab59ca
commit 40bb96cfdd
2 changed files with 3 additions and 2 deletions

View File

@ -63,6 +63,7 @@ public class FullSyncC0012 implements ApplicationEventPublisherAware {
@KafkaListener(topics = "C0012") @KafkaListener(topics = "C0012")
public void messageMsg(ConsumerRecord<?, ?> record) { public void messageMsg(ConsumerRecord<?, ?> record) {
System.out.println("收到全量同步命令");
JSONObject jsonObject = JSONObject.parseObject(record.value().toString()); JSONObject jsonObject = JSONObject.parseObject(record.value().toString());
Map<String, Object> params = new HashMap<>(); Map<String, Object> params = new HashMap<>();
if(!"delete".equals(jsonObject.getString("action"))) { if(!"delete".equals(jsonObject.getString("action"))) {

View File

@ -931,8 +931,8 @@
initBaseSysInfoData(); initBaseSysInfoData();
setFileZZ(); /*setFileZZ();
/*testDat(); testDat();
getkeyplace(); getkeyplace();
getkeyarea(); getkeyarea();
setFileKey(); setFileKey();