feat: 缓存同步

fs-service-system/src/main/java/com/fs/store/domain/FsStoreProductAttr.java

@@ -2,15 +2,19 @@ package com.fs.store.domain;
 
 import com.fs.common.annotation.Excel;
 import com.fs.common.core.domain.BaseEntity;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
 import org.apache.commons.lang3.builder.ToStringBuilder;
 import org.apache.commons.lang3.builder.ToStringStyle;
 
 /**
  * 商品属性对象 fs_store_product_attr
- * 
+ *
  * @author fs
  * @date 2022-03-15
  */
+@EqualsAndHashCode(callSuper = true)
+@Data
 public class FsStoreProductAttr extends BaseEntity
 {
     private static final long serialVersionUID = 1L;
@@ -29,51 +33,4 @@ public class FsStoreProductAttr extends BaseEntity
     /** 属性值 */
     @Excel(name = "属性值")
     private String attrValues;
-
-    public void setId(Long id) 
-    {
-        this.id = id;
-    }
-
-    public Long getId() 
-    {
-        return id;
-    }
-    public void setProductId(Long productId) 
-    {
-        this.productId = productId;
-    }
-
-    public Long getProductId() 
-    {
-        return productId;
-    }
-    public void setAttrName(String attrName) 
-    {
-        this.attrName = attrName;
-    }
-
-    public String getAttrName() 
-    {
-        return attrName;
-    }
-    public void setAttrValues(String attrValues) 
-    {
-        this.attrValues = attrValues;
-    }
-
-    public String getAttrValues() 
-    {
-        return attrValues;
-    }
-
-    @Override
-    public String toString() {
-        return new ToStringBuilder(this,ToStringStyle.MULTI_LINE_STYLE)
-            .append("id", getId())
-            .append("productId", getProductId())
-            .append("attrName", getAttrName())
-            .append("attrValues", getAttrValues())
-            .toString();
-    }
 }

fs-service-system/src/main/java/com/fs/store/domain/FsUserAddress.java

@@ -2,15 +2,19 @@ package com.fs.store.domain;
 
 import com.fs.common.annotation.Excel;
 import com.fs.common.core.domain.BaseEntity;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
 import org.apache.commons.lang3.builder.ToStringBuilder;
 import org.apache.commons.lang3.builder.ToStringStyle;
 
 /**
  * 用户地址对象 fs_user_address
- * 
+ *
  * @author fs
  * @date 2022-03-15
  */
+@EqualsAndHashCode(callSuper = true)
+@Data
 public class FsUserAddress extends BaseEntity
 {
     private static final long serialVersionUID = 1L;
@@ -70,152 +74,4 @@ public class FsUserAddress extends BaseEntity
     @Excel(name = "是否删除")
     private Integer isDel;
 
-    public void setId(Long id) 
-    {
-        this.id = id;
-    }
-
-    public Long getId() 
-    {
-        return id;
-    }
-    public void setUserId(Long userId) 
-    {
-        this.userId = userId;
-    }
-
-    public Long getUserId() 
-    {
-        return userId;
-    }
-    public void setRealName(String realName) 
-    {
-        this.realName = realName.trim();
-    }
-
-    public String getRealName() 
-    {
-        return realName;
-    }
-    public void setPhone(String phone) 
-    {
-        this.phone = phone.trim();
-    }
-
-    public String getPhone() 
-    {
-        return phone;
-    }
-    public void setProvince(String province) 
-    {
-        this.province = province;
-    }
-
-    public String getProvince() 
-    {
-        return province;
-    }
-    public void setCity(String city) 
-    {
-        this.city = city;
-    }
-
-    public String getCity() 
-    {
-        return city;
-    }
-    public void setCityId(Long cityId) 
-    {
-        this.cityId = cityId;
-    }
-
-    public Long getCityId() 
-    {
-        return cityId;
-    }
-    public void setDistrict(String district) 
-    {
-        this.district = district;
-    }
-
-    public String getDistrict() 
-    {
-        return district;
-    }
-    public void setDetail(String detail) 
-    {
-        this.detail = detail.trim();
-    }
-
-    public String getDetail() 
-    {
-        return detail;
-    }
-    public void setPostCode(String postCode) 
-    {
-        this.postCode = postCode;
-    }
-
-    public String getPostCode() 
-    {
-        return postCode;
-    }
-    public void setLongitude(String longitude) 
-    {
-        this.longitude = longitude;
-    }
-
-    public String getLongitude() 
-    {
-        return longitude;
-    }
-    public void setLatitude(String latitude) 
-    {
-        this.latitude = latitude;
-    }
-
-    public String getLatitude() 
-    {
-        return latitude;
-    }
-    public void setIsDefault(Integer isDefault) 
-    {
-        this.isDefault = isDefault;
-    }
-
-    public Integer getIsDefault() 
-    {
-        return isDefault;
-    }
-    public void setIsDel(Integer isDel) 
-    {
-        this.isDel = isDel;
-    }
-
-    public Integer getIsDel() 
-    {
-        return isDel;
-    }
-
-    @Override
-    public String toString() {
-        return new ToStringBuilder(this,ToStringStyle.MULTI_LINE_STYLE)
-            .append("id", getId())
-            .append("userId", getUserId())
-            .append("realName", getRealName())
-            .append("phone", getPhone())
-            .append("province", getProvince())
-            .append("city", getCity())
-            .append("cityId", getCityId())
-            .append("district", getDistrict())
-            .append("detail", getDetail())
-            .append("postCode", getPostCode())
-            .append("longitude", getLongitude())
-            .append("latitude", getLatitude())
-            .append("isDefault", getIsDefault())
-            .append("isDel", getIsDel())
-            .append("createTime", getCreateTime())
-            .append("updateTime", getUpdateTime())
-            .toString();
-    }
 }

fs-sync/src/main/java/com/fs/fssync/listener/MySqlEventListener.java

@@ -40,7 +40,7 @@ public class MySqlEventListener implements CommandLineRunner {
     private FlinkConfig flinkConfig;
 
     private static final String JOB_ID = "1a2b3c4d5e6f7a8b9c0d1e2f3a4b5c6d";
-    private static final String CHECKPOINT_DIR = "file:///d:/data/flink/checkpoints";
+    private static final String CHECKPOINT_DIR = "file:///home/software/fs-sync/data/flink/checkpoints";
 
     @Override
     public void run(String... args) throws Exception {

fs-sync/src/main/java/com/fs/fssync/sink/impl/FsStoreProductAttrSinkStrategy.java

@@ -0,0 +1,33 @@
+package com.fs.fssync.sink.impl;
+
+import com.fs.fssync.sink.AbstractCdcSinkStrategy;
+import com.fs.store.domain.FsStoreProductAttr;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+import java.io.Serializable;
+
+@Slf4j
+@Component
+public class FsStoreProductAttrSinkStrategy extends AbstractCdcSinkStrategy<FsStoreProductAttr> implements Serializable {
+
+    @Override
+    public boolean canHandle(String table) {
+        return "fs_store_product_attr".equals(table);
+    }
+
+    @Override
+    public Class<FsStoreProductAttr> getEntityClass() {
+        return FsStoreProductAttr.class;
+    }
+
+    @Override
+    public String getKeyPrefix() {
+        return "fs:store:product:attr:";
+    }
+
+    @Override
+    protected String getIdField() {
+        return "id";
+    }
+}

fs-sync/src/main/java/com/fs/fssync/sink/impl/FsUserAddressSinkStrategy.java

@@ -0,0 +1,33 @@
+package com.fs.fssync.sink.impl;
+
+import com.fs.fssync.sink.AbstractCdcSinkStrategy;
+import com.fs.store.domain.FsUserAddress;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+import java.io.Serializable;
+
+@Slf4j
+@Component
+public class FsUserAddressSinkStrategy extends AbstractCdcSinkStrategy<FsUserAddress> implements Serializable {
+
+    @Override
+    public boolean canHandle(String table) {
+        return "fs_user_address".equals(table);
+    }
+
+    @Override
+    public Class<FsUserAddress> getEntityClass() {
+        return FsUserAddress.class;
+    }
+
+    @Override
+    public String getKeyPrefix() {
+        return "fs:user:address:";
+    }
+
+    @Override
+    protected String getIdField() {
+        return "id";
+    }
+}

fs-sync/src/main/java/com/fs/fssync/sink/impl/FsWarehousesSinkStrategy.java

@@ -0,0 +1,33 @@
+package com.fs.fssync.sink.impl;
+
+import com.fs.fssync.sink.AbstractCdcSinkStrategy;
+import com.fs.store.domain.FsWarehouses;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+import java.io.Serializable;
+
+@Slf4j
+@Component
+public class FsWarehousesSinkStrategy extends AbstractCdcSinkStrategy<FsWarehouses> implements Serializable {
+
+    @Override
+    public boolean canHandle(String table) {
+        return "fs_warehouses".equals(table);
+    }
+
+    @Override
+    public Class<FsWarehouses> getEntityClass() {
+        return FsWarehouses.class;
+    }
+
+    @Override
+    public String getKeyPrefix() {
+        return "fs:warehouses:";
+    }
+
+    @Override
+    protected String getIdField() {
+        return "id";
+    }
+}