两千万数据框架

.idea/workspace.xml

@@ -5,9 +5,16 @@
   </component>
   <component name="ChangeListManager">
     <list default="true" id="d7f9db40-65da-4834-b29d-bbe0bd94d010" name="更改" comment="天气预警">
+      <change afterPath="$PROJECT_DIR$/cloud-port-server/src/main/java/com/muyu/cloud/mart/controller/DataMillionController.java" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/cloud-port-server/src/main/java/com/muyu/cloud/mart/mapper/DataMillionMapper.java" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/cloud-port-server/src/main/java/com/muyu/cloud/mart/service/DataMillionService.java" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/cloud-port-server/src/main/java/com/muyu/cloud/mart/service/impl/DataMillionServiceImpl.java" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/cloud-port-server/src/main/resources/mapper/DataMillionMapper.xml" afterDir="false" />
       <change beforePath="$PROJECT_DIR$/.idea/workspace.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/logs/cloud-etl/error.log" beforeDir="false" afterPath="$PROJECT_DIR$/logs/cloud-etl/error.log" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/cloud-port-server/src/main/java/com/muyu/cloud/mart/controller/MarketController.java" beforeDir="false" afterPath="$PROJECT_DIR$/cloud-port-server/src/main/java/com/muyu/cloud/mart/controller/MarketController.java" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/logs/cloud-etl/info.log" beforeDir="false" afterPath="$PROJECT_DIR$/logs/cloud-etl/info.log" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/cloud-port-server/src/main/java/com/muyu/cloud/mart/service/MarketService.java" beforeDir="false" afterPath="$PROJECT_DIR$/cloud-port-server/src/main/java/com/muyu/cloud/mart/service/MarketService.java" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/cloud-port-server/src/main/java/com/muyu/cloud/mart/service/impl/MarketServiceImpl.java" beforeDir="false" afterPath="$PROJECT_DIR$/cloud-port-server/src/main/java/com/muyu/cloud/mart/service/impl/MarketServiceImpl.java" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/cloud-port-server/src/main/resources/mapper/MarketMappers.xml" beforeDir="false" afterPath="$PROJECT_DIR$/cloud-port-server/src/main/resources/mapper/MarketMapper.xml" afterDir="false" />
     </list>
     <option name="SHOW_DIALOG" value="false" />
     <option name="HIGHLIGHT_CONFLICTS" value="true" />
@@ -17,6 +24,7 @@
   <component name="FileTemplateManagerImpl">
     <option name="RECENT_TEMPLATES">
       <list>
+        <option value="Interface" />
         <option value="Class" />
       </list>
     </option>
@@ -139,6 +147,9 @@
       <workItem from="1725238963629" duration="8237000" />
       <workItem from="1725325573388" duration="1221000" />
       <workItem from="1725345043314" duration="1792000" />
+      <workItem from="1725350762294" duration="4960000" />
+      <workItem from="1725380326630" duration="2900000" />
+      <workItem from="1725415396368" duration="2602000" />
     </task>
     <task id="LOCAL-00001" summary="初始化">
       <option name="closed" value="true" />
@@ -372,7 +383,15 @@
       <option name="project" value="LOCAL" />
       <updated>1725244257747</updated>
     </task>
-    <option name="localTasksCounter" value="30" />
+    <task id="LOCAL-00030" summary="天气预警">
+      <option name="closed" value="true" />
+      <created>1725350926810</created>
+      <option name="number" value="00030" />
+      <option name="presentableId" value="LOCAL-00030" />
+      <option name="project" value="LOCAL" />
+      <updated>1725350926810</updated>
+    </task>
+    <option name="localTasksCounter" value="31" />
     <servers />
   </component>
   <component name="TypeScriptGeneratedFilesManager">

cloud-port-common/src/main/java/com/muyu/domain/DataMillion.java

@@ -0,0 +1,18 @@
+package com.muyu.domain;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+/**
+ * @Author：chaiyapeng
+ * @Package：com.muyu.domain
+ * @Project：cloud-port
+ * @name：DataMillion
+ * @Date：2024/9/4 12:07
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class DataMillion {
+}

cloud-port-server/src/main/java/com/muyu/cloud/mart/controller/DataMillionController.java

@@ -0,0 +1,17 @@
+package com.muyu.cloud.mart.controller;
+
+import com.muyu.common.core.web.controller.BaseController;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * @Author：chaiyapeng
+ * @Package：com.muyu.cloud.mart.controller
+ * @Project：cloud-port
+ * @name：DataMillion
+ * @Date：2024/9/4 12:02
+ */
+@RestController
+@RequestMapping("million")
+public class DataMillionController extends BaseController {
+}

cloud-port-server/src/main/java/com/muyu/cloud/mart/controller/MarketController.java

@@ -41,11 +41,7 @@ public class MarketController extends BaseController {
      * 两千万条数据查询
      * @return
      */
-    @GetMapping("findMarketList")
+
-    public Result<TableDataInfo<Market>> findMarketList(){
-        List<Market> list = marketService.findMarketList();
-        return getDataTable(list);
-    }
 
     /**
      * 手机号查询归属地

cloud-port-server/src/main/java/com/muyu/cloud/mart/mapper/DataMillionMapper.java

@@ -0,0 +1,16 @@
+package com.muyu.cloud.mart.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.muyu.domain.DataMillion;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * @Author：chaiyapeng
+ * @Package：com.muyu.cloud.mart.mapper
+ * @Project：cloud-port
+ * @name：DataMillionMapper
+ * @Date：2024/9/4 12:03
+ */
+@Mapper
+public interface DataMillionMapper extends BaseMapper<DataMillion> {
+}

cloud-port-server/src/main/java/com/muyu/cloud/mart/service/DataMillionService.java

@@ -0,0 +1,14 @@
+package com.muyu.cloud.mart.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.muyu.domain.DataMillion;
+
+/**
+ * @Author：chaiyapeng
+ * @Package：com.muyu.cloud.mart.service
+ * @Project：cloud-port
+ * @name：DataMillionService
+ * @Date：2024/9/4 12:04
+ */
+public interface DataMillionService extends IService<DataMillion> {
+}

cloud-port-server/src/main/java/com/muyu/cloud/mart/service/MarketService.java

@@ -17,7 +17,6 @@ import java.util.List;
  * @Date：2024/8/21 21:54
  */
 public interface MarketService extends IService<Market> {
-    List<Market> findMarketList();
 
     Result phonePlace(String tel);
 

cloud-port-server/src/main/java/com/muyu/cloud/mart/service/impl/DataMillionServiceImpl.java

@@ -0,0 +1,51 @@
+package com.muyu.cloud.mart.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.muyu.cloud.mart.mapper.DataMillionMapper;
+import com.muyu.cloud.mart.service.DataMillionService;
+import com.muyu.domain.DataMillion;
+import lombok.extern.log4j.Log4j2;
+import org.springframework.stereotype.Service;
+
+/**
+ * @Author：chaiyapeng
+ * @Package：com.muyu.cloud.mart.service.impl
+ * @Project：cloud-port
+ * @name：DataMillionServiceImpl
+ * @Date：2024/9/4 12:04
+ */
+@Service
+@Log4j2
+public class DataMillionServiceImpl
+        extends ServiceImpl<DataMillionMapper, DataMillion>
+        implements DataMillionService {
+}
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+

cloud-port-server/src/main/java/com/muyu/cloud/mart/service/impl/MarketServiceImpl.java

@@ -40,25 +40,7 @@ public class MarketServiceImpl extends ServiceImpl<MarketMapper, Market> impleme
     @Autowired
     private RedisTemplate<String,String>redisTemplate;
 
-    @Override
+
-    public List<Market> findMarketList() {
-        if (redisTemplate.hasKey("list")){
-            List<String> list = redisTemplate.opsForList().range("list", 0, -1);
-            ArrayList<Market> markets = new ArrayList<>();
-            for (String s : list) {
-                markets.add(JSON.parseObject(s, Market.class));
-            }
-            return markets;
-        }
-        startPage();
-//        List<Market> list = marketService.findMarketList();
-        List<Market> list = marketMapper.selectList(null);
-        for (Market market1 : list) {
-            redisTemplate.opsForList().rightPush("list", JSON.toJSONString(market1));
-        }
-        return list;
-    }
-//    public static final PhoneNumberOfflineGeocoder GEOCODER = PhoneNumberOfflineGeocoder.getInstance();
 
 
     /**

cloud-port-server/src/main/resources/mapper/DataMillionMapper.xml

@@ -0,0 +1,7 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper
+        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.muyu.cloud.mart.mapper.DataMillionMapper">
+
+</mapper>