attiya/ebike-plus
SHA256
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Compare commits

base: attiya:f7ff856202495eafc3ac1936563358e2194fbea6bc73c02a631ae0bf99c5555d
Branches Tags
attiya:main
attiya:dev
..
compare: attiya:9e951fb8d08db721a805dc2fb07204f46ae4713227717ee00500e1c28b791f77
Branches Tags
attiya:main
attiya:dev

No commits in common. "f7ff856202495eafc3ac1936563358e2194fbea6bc73c02a631ae0bf99c5555d" and "9e951fb8d08db721a805dc2fb07204f46ae4713227717ee00500e1c28b791f77" have entirely different histories.
f7ff856202 ... 9e951fb8d0

3 changed files with 2 additions and 9 deletions
Show Stats Expand all files Collapse all files

1
ebike-gather/src/main/java/org/cdzy/gather/kafka/KafkaConsumer.java
View File

@ -3,6 +3,7 @@ package org.cdzy.gather.kafka;
import com.cdzy.common.model.CMDMsg; import com.cdzy.common.model.CMDMsg;
import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper; import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.node.ObjectNode;
import io.netty.handler.codec.mqtt.MqttQoS; import io.netty.handler.codec.mqtt.MqttQoS;
import org.apache.kafka.clients.consumer.ConsumerRecord; import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.cdzy.gather.mqtt.MqttPoolClient; import org.cdzy.gather.mqtt.MqttPoolClient;

8
ebike-operations/src/main/java/com/cdzy/operations/model/entity/EbikeSite.java
View File

@ -1,10 +1,5 @@
package com.cdzy.operations.model.entity; package com.cdzy.operations.model.entity;
import com.cdzy.operations.handler.PGpolygonDeserializer;
import com.cdzy.operations.handler.PGpolygonSerializer;
import com.cdzy.operations.handler.PGpolygonTypeHandler;
import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
import com.fasterxml.jackson.databind.annotation.JsonSerialize;
import com.mybatisflex.annotation.Column; import com.mybatisflex.annotation.Column;
import com.mybatisflex.annotation.Id; import com.mybatisflex.annotation.Id;
import com.mybatisflex.annotation.Table; import com.mybatisflex.annotation.Table;
@ -58,9 +53,6 @@ public class EbikeSite implements Serializable {
/** /**
* 站点区域 * 站点区域
*/ */
@Column(typeHandler = PGpolygonTypeHandler.class)
@JsonSerialize(using = PGpolygonSerializer.class)
@JsonDeserialize(using = PGpolygonDeserializer.class)
private PGpolygon sitePolygon; private PGpolygon sitePolygon;
/** /**