Skip to content

H
haoban-manage3.0
Commit 8b7808a8 by huangZW
Options

Merge branch 'developer' of http://115.159.76.241/haoban3.0/haoban-manage3.0.git into developer

parents 645d583d 391771a9
Showing with 2 additions and 2 deletions
haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/task/KafkaMessageServiceImpl.java
...@@ -50,9 +50,9 @@ public class KafkaMessageServiceImpl implements MessageListener<String, GicRecor ...@@ -50,9 +50,9 @@ public class KafkaMessageServiceImpl implements MessageListener<String, GicRecor
private BinlogBasePojo binlogChange(GicRecord record) { private BinlogBasePojo binlogChange(GicRecord record) {
ClerkSyncPojo pojo=new ClerkSyncPojo(); ClerkSyncPojo pojo=new ClerkSyncPojo();
pojo.setRecordType(record.getRecordType().value()); pojo.setRecordType(record.getRecordType().value());
if(record.getDbName().equals(CLERK)) { if(record.getTableName().equals(CLERK)) {
return binlogMap(record.getFieldList(),record.getRecordType(),ClerkSyncPojo.class); return binlogMap(record.getFieldList(),record.getRecordType(),ClerkSyncPojo.class);
}else if (record.getDbName().equals(STORE)) { }else if (record.getTableName().equals(STORE)) {
return binlogMap(record.getFieldList(),record.getRecordType(),ClerkSyncPojo.class); return binlogMap(record.getFieldList(),record.getRecordType(),ClerkSyncPojo.class);
}else{ }else{
return null; return null;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment