测试代码

src/main/java/com/xynet/marketing/controller/TestController.java

@@ -0,0 +1,26 @@
+package com.xynet.marketing.controller;
+
+import com.xynet.marketing.service.factory.plus.PlusFactory;
+import com.xynet.marketing.utils.FactoryUtils;
+import com.xynet.marketing.utils.R;
+import com.xynet.marketing.utils.error.BusinessException;
+import com.xynet.marketing.utils.redis.utils.RedisService;
+import lombok.AllArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.Map;
+
+@RestController
+@RequestMapping("test")
+@AllArgsConstructor
+@Slf4j
+public class TestController {
+    private RedisService<Object> redisService;
+
+    @PostMapping("aa")
+    public R<String> aa(@RequestBody Map<String,Object> param) {
+        String v = FactoryUtils.getService(PlusFactory.class, param.get("v").toString()).save(param);
+        return R.ok(v);
+    }
+}

src/main/java/com/xynet/marketing/entity/Merc.java

@@ -0,0 +1,27 @@
+package com.xynet.marketing.entity;
+
+import cn.hutool.core.date.DateTime;
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+@Data
+@Accessors(chain = true)
+public class Merc {
+    /**
+     *
+     */
+    @TableId(type = IdType.AUTO)
+    private Integer id;
+
+    /**
+     * 设备号
+     */
+    private Integer serviceProviderId;
+
+    /**
+     * 指令版本
+     */
+    private String mercId;
+}

src/main/java/com/xynet/marketing/mapper/MercMapper.java

@@ -0,0 +1,8 @@
+package com.xynet.marketing.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.xynet.marketing.entity.Merc;
+import org.springframework.stereotype.Repository;
+
+public interface MercMapper extends BaseMapper<Merc> {
+}

src/main/java/com/xynet/marketing/service/TestService.java

@@ -0,0 +1,32 @@
+package com.xynet.marketing.service;
+
+
+import cn.hutool.core.date.DateTime;
+import cn.hutool.core.lang.Console;
+import cn.hutool.core.util.ObjectUtil;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.xynet.marketing.entity.Merc;
+import com.xynet.marketing.mapper.MercMapper;
+import org.springframework.stereotype.Service;
+
+import java.util.Map;
+
+@Service
+public class TestService extends ServiceImpl<MercMapper, Merc> {
+
+    public void add(Map<String, Object> map) {
+        Integer serviceProviderId = ObjectUtil.isNotNull(map.get("serviceProviderId")) ? Integer.valueOf(map.get("serviceProviderId").toString()) : null;
+        String mercId = ObjectUtil.isNotNull(map.get("mercId")) ? map.get("mercId").toString() : null;
+
+
+        Merc deviceLog = new Merc()
+                .setServiceProviderId(serviceProviderId)
+                .setMercId(mercId);
+        save(deviceLog);
+    }
+
+    public void obj(Integer id) {
+        Merc merc = getById(id);
+        Console.log(merc);
+    }
+}

src/main/java/com/xynet/marketing/service/factory/plus/PlusFactory.java

@@ -0,0 +1,22 @@
+package com.xynet.marketing.service.factory.plus;
+
+
+
+import com.xynet.marketing.utils.R;
+
+import java.util.Map;
+
+/**
+ * <p>
+ *
+ * </p>
+ *
+ * @author hechunping
+ * @since 2024/4/17
+ */
+public interface PlusFactory {
+    String save(Map<String,Object> param);
+
+
+
+}

src/main/java/com/xynet/marketing/service/factory/plus/impl/base/PlusFactoryBase.java

@@ -0,0 +1,15 @@
+package com.xynet.marketing.service.factory.plus.impl.base;
+
+import com.xynet.marketing.service.factory.plus.PlusFactory;
+import com.xynet.marketing.utils.R;
+import org.springframework.stereotype.Component;
+
+import java.util.Map;
+
+@Component
+public class PlusFactoryBase implements PlusFactory {
+    @Override
+    public String save(Map<String, Object> param) {
+        return "这个是基础版本！！！";
+    }
+}

src/main/java/com/xynet/marketing/service/factory/plus/impl/v2/PlusFactoryV2.java

@@ -0,0 +1,15 @@
+package com.xynet.marketing.service.factory.plus.impl.v2;
+
+import com.xynet.marketing.service.factory.plus.PlusFactory;
+import com.xynet.marketing.utils.R;
+import org.springframework.stereotype.Component;
+
+import java.util.Map;
+
+@Component
+public class PlusFactoryV2 implements PlusFactory {
+    @Override
+    public String save(Map<String, Object> param) {
+        return "这个是V2版本";
+    }
+}

src/main/resources/application-dev.properties

@@ -1,7 +1,7 @@
 spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
-spring.datasource.url=jdbc:mysql://47.119.120.128:3316/xyplatdb?useUnicode=true&characterEncoding=utf-8&serverTimezone=GMT%2B8
+spring.datasource.url=jdbc:mysql://119.96.213.127:3306/hcp_xy_temp?useUnicode=true&characterEncoding=utf-8&serverTimezone=GMT%2B8
 spring.datasource.username=root
-spring.datasource.password=xymysqlroot_2019
+spring.datasource.password=#Xynet2022
 eureka.client.service-url.defaultZone=http://eureka:eureka_xyplat@localhost:8080/eureka/
 eureka.client.enabled=false
 eureka.client.registerWithEureka=true
@@ -16,9 +16,9 @@ eureka.instance.instance-id=${spring.cloud.client.ip-address}:${server.port}
 logging.config=classpath:log4j2-dev.xml
 
 #redis
-spring.redis.host=47.119.120.128
-spring.redis.password=XY#123456@mm
-spring.redis.port=6389
+spring.redis.host=127.0.0.1
+spring.redis.password=123456
+spring.redis.port=6379
 
 # ²âÊÔ·þ±£´æµÄ·¾¶
 savePath=/data/apps/electricbox/images

src/main/resources/application.properties

@@ -30,13 +30,6 @@ spring.jackson.serialization.FAIL_ON_EMPTY_BEANS=false
 
 
 #redis
-spring.redis.database=12
+spring.redis.database=0
 spring.redis.database-session=1
-spring.redis.jedis.pool.max-idle=8
-spring.redis.jedis.pool.min-idle=1
-spring.redis.jedis.pool.max-active=100
-spring.redis.jedis.pool.max-wait=-1
-spring.redis.pool.maxTotal=8
-spring.redis.pool.maxWaitMillis=1000
-spring.redis.timeout=3000