latest

.idea/compiler.xml

@@ -2,6 +2,7 @@
 <project version="4">
   <component name="CompilerConfiguration">
     <annotationProcessing>
+      <profile default="true" name="Default" enabled="true" />
       <profile name="Maven default annotation processors profile" enabled="true">
         <sourceOutputDir name="target/generated-sources/annotations" />
         <sourceTestOutputDir name="target/generated-test-sources/test-annotations" />

.idea/workspace.xml

@@ -9,15 +9,31 @@
     <option name="autoReloadType" value="SELECTIVE" />
   </component>
   <component name="ChangeListManager">
-    <list default="true" id="7ccd1d49-504a-4f69-8dd5-6c0dce4175ec" name="Changes" comment="" />
+    <list default="true" id="7ccd1d49-504a-4f69-8dd5-6c0dce4175ec" name="Changes" comment="新增地级市成交价抓取">
+      <change beforePath="$PROJECT_DIR$/src/main/resources/config.properties" beforeDir="false" afterPath="$PROJECT_DIR$/src/main/resources/config.properties" afterDir="false" />
+    </list>
     <option name="SHOW_DIALOG" value="false" />
     <option name="HIGHLIGHT_CONFLICTS" value="true" />
     <option name="HIGHLIGHT_NON_ACTIVE_CHANGELIST" value="false" />
     <option name="LAST_RESOLUTION" value="IGNORE" />
   </component>
+  <component name="CompilerWorkspaceConfiguration">
+    <option name="MAKE_PROJECT_ON_SAVE" value="true" />
+  </component>
+  <component name="FileTemplateManagerImpl">
+    <option name="RECENT_TEMPLATES">
+      <list>
+        <option value="Interface" />
+        <option value="Class" />
+      </list>
+    </option>
+  </component>
   <component name="Git.Settings">
     <option name="RECENT_GIT_ROOT_PATH" value="$PROJECT_DIR$" />
   </component>
+  <component name="JRebelWorkspace">
+    <option name="jrebelEnabledAutocompile" value="true" />
+  </component>
   <component name="LogFilters">
     <option name="FILTER_ERRORS" value="false" />
     <option name="FILTER_WARNINGS" value="false" />
@@ -39,31 +55,40 @@
     </option>
   </component>
   <component name="ProjectId" id="2cceqq0xhKeRZDfK3rFVmMszsYZ" />
-  <component name="ProjectLevelVcsManager" settingsEditedManually="true" />
+  <component name="ProjectLevelVcsManager" settingsEditedManually="true">
+    <ConfirmationsSetting value="1" id="Add" />
+  </component>
   <component name="ProjectViewState">
     <option name="hideEmptyMiddlePackages" value="true" />
     <option name="showLibraryContents" value="true" />
   </component>
-  <component name="PropertiesComponent"><![CDATA[{
-  "keyToString": {
-    "RunOnceActivity.OpenProjectViewOnStart": "true",
-    "RunOnceActivity.ShowReadmeOnStart": "true",
-    "WebServerToolWindowFactoryState": "false",
-    "node.js.detected.package.eslint": "true",
-    "node.js.detected.package.tslint": "true",
-    "node.js.selected.package.eslint": "(autodetect)",
-    "node.js.selected.package.tslint": "(autodetect)",
-    "project.structure.last.edited": "Artifacts",
-    "project.structure.proportion": "0.15",
-    "project.structure.side.proportion": "0.2",
-    "settings.editor.selected.configurable": "MavenSettings",
-    "spring.configuration.checksum": "d41d8cd98f00b204e9800998ecf8427e",
-    "vue.rearranger.settings.migration": "true"
+  <component name="PropertiesComponent">{
+  &quot;keyToString&quot;: {
+    &quot;RunOnceActivity.OpenProjectViewOnStart&quot;: &quot;true&quot;,
+    &quot;RunOnceActivity.ShowReadmeOnStart&quot;: &quot;true&quot;,
+    &quot;WebServerToolWindowFactoryState&quot;: &quot;false&quot;,
+    &quot;node.js.detected.package.eslint&quot;: &quot;true&quot;,
+    &quot;node.js.detected.package.tslint&quot;: &quot;true&quot;,
+    &quot;node.js.selected.package.eslint&quot;: &quot;(autodetect)&quot;,
+    &quot;node.js.selected.package.tslint&quot;: &quot;(autodetect)&quot;,
+    &quot;project.structure.last.edited&quot;: &quot;Artifacts&quot;,
+    &quot;project.structure.proportion&quot;: &quot;0.15&quot;,
+    &quot;project.structure.side.proportion&quot;: &quot;0.2&quot;,
+    &quot;settings.editor.selected.configurable&quot;: &quot;MavenSettings&quot;,
+    &quot;spring.configuration.checksum&quot;: &quot;d41d8cd98f00b204e9800998ecf8427e&quot;,
+    &quot;vue.rearranger.settings.migration&quot;: &quot;true&quot;
   }
-}]]></component>
+}</component>
   <component name="RebelAgentSelection">
     <selection>jr</selection>
   </component>
+  <component name="RunDashboard">
+    <option name="excludedTypes">
+      <set>
+        <option value="#com.intellij.j2ee.web.tomcat.TomcatRunConfigurationFactory" />
+      </set>
+    </option>
+  </component>
   <component name="RunManager">
     <configuration name="dydb-tomcat" type="#com.intellij.j2ee.web.tomcat.TomcatRunConfigurationFactory" factoryName="Local" APPLICATION_SERVER_NAME="Tomcat 8.5.40" ALTERNATIVE_JRE_ENABLED="false">
       <option name="OPEN_IN_BROWSER_URL" value="http://localhost:8080/project_dydb_war" />
@@ -196,11 +221,55 @@
       <option name="presentableId" value="Default" />
       <updated>1708415489784</updated>
       <workItem from="1708415491364" duration="6336000" />
-      <workItem from="1708476641696" duration="7056000" />
+      <workItem from="1708476641696" duration="9483000" />
+      <workItem from="1713332728308" duration="13672000" />
+      <workItem from="1713402263711" duration="24237000" />
+      <workItem from="1713487788658" duration="157000" />
+      <workItem from="1715043261528" duration="2020000" />
+      <workItem from="1715735711983" duration="2957000" />
+    </task>
+    <task id="LOCAL-00001" summary="新增地级市成交价抓取">
+      <created>1713487879954</created>
+      <option name="number" value="00001" />
+      <option name="presentableId" value="LOCAL-00001" />
+      <option name="project" value="LOCAL" />
+      <updated>1713487879954</updated>
     </task>
+    <option name="localTasksCounter" value="2" />
     <servers />
   </component>
   <component name="TypeScriptGeneratedFilesManager">
     <option name="version" value="3" />
   </component>
+  <component name="Vcs.Log.Tabs.Properties">
+    <option name="TAB_STATES">
+      <map>
+        <entry key="MAIN">
+          <value>
+            <State />
+          </value>
+        </entry>
+      </map>
+    </option>
+  </component>
+  <component name="VcsManagerConfiguration">
+    <MESSAGE value="新增地级市成交价抓取" />
+    <option name="LAST_COMMIT_MESSAGE" value="新增地级市成交价抓取" />
+  </component>
+  <component name="XDebuggerManager">
+    <breakpoint-manager>
+      <breakpoints>
+        <line-breakpoint enabled="true" type="java-line">
+          <url>file://$PROJECT_DIR$/src/main/java/com/leeroa/dydb/datasource/paimai/utils/LianjiaUpUtils.java</url>
+          <line>309</line>
+          <option name="timeStamp" value="14" />
+        </line-breakpoint>
+        <line-breakpoint enabled="true" type="java-line">
+          <url>file://$PROJECT_DIR$/src/main/java/com/leeroa/dydb/datasource/paimai/utils/LianjiaUpUtils.java</url>
+          <line>314</line>
+          <option name="timeStamp" value="15" />
+        </line-breakpoint>
+      </breakpoints>
+    </breakpoint-manager>
+  </component>
 </project>

src/main/java/com/leeroa/dydb/datasource/lianjia/bo/DataLianjiaCodeBo.java

@@ -0,0 +1,30 @@
+package com.leeroa.dydb.datasource.lianjia.bo;
+
+import com.michael.core.hibernate.criteria.BO;
+import com.michael.core.hibernate.criteria.Condition;
+import com.michael.docs.annotations.ApiField;
+import lombok.Data;
+
+
+/**
+ * 类说明：
+ *
+ * @author: wucl
+ * @since: 2024/4/17
+ * created with IntelliJ IDEA.
+ */
+@Data
+public class DataLianjiaCodeBo implements BO {
+
+    @ApiField(value = "父级id")
+    @Condition
+    private String parentId;
+
+    @ApiField(value = "名称")
+    @Condition
+    private String name;
+
+    @ApiField(value = "编码")
+    @Condition
+    private String code;
+}

src/main/java/com/leeroa/dydb/datasource/lianjia/dao/DataLianjiaCodeDao.java

@@ -0,0 +1,21 @@
+package com.leeroa.dydb.datasource.lianjia.dao;
+
+import com.leeroa.dydb.datasource.lianjia.bo.DataLianjiaCodeBo;
+import com.leeroa.dydb.datasource.lianjia.domain.DataLianjiaCode;
+
+import java.util.List;
+
+/**
+ * 类说明：
+ *
+ * @author: wucl
+ * @since: 2024/4/17
+ * created with IntelliJ IDEA.
+ */
+public interface DataLianjiaCodeDao {
+
+    List<DataLianjiaCode> getLianjiaCode(DataLianjiaCodeBo dataLianjiaCode);
+
+    String getCityNameByCode(String code);
+
+}

src/main/java/com/leeroa/dydb/datasource/lianjia/dao/impl/DataLianjiaCodeDaoImpl.java

@@ -0,0 +1,57 @@
+package com.leeroa.dydb.datasource.lianjia.dao.impl;
+
+import com.leeroa.dydb.datasource.lianjia.bo.DataLianjiaBo;
+import com.leeroa.dydb.datasource.lianjia.bo.DataLianjiaCodeBo;
+import com.leeroa.dydb.datasource.lianjia.dao.DataLianjiaCodeDao;
+import com.leeroa.dydb.datasource.lianjia.domain.DataLianjiaCode;
+import com.michael.core.hibernate.HibernateDaoHelper;
+import com.michael.core.hibernate.criteria.CriteriaUtils;
+import org.hibernate.Criteria;
+import org.springframework.stereotype.Repository;
+import org.springframework.util.Assert;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+/**
+ * 类说明：
+ *
+ * @author: wucl
+ * @since: 2024/4/17
+ * created with IntelliJ IDEA.
+ */
+@Repository("dataLianjiaCodeDao")
+public class DataLianjiaCodeDaoImpl  extends HibernateDaoHelper implements DataLianjiaCodeDao {
+
+    private static Map<String, String> cityNameCodeMap = new HashMap<>();
+    
+    @Override
+    public List<DataLianjiaCode> getLianjiaCode(DataLianjiaCodeBo bo) {
+        Criteria criteria = createCriteria(DataLianjiaCode.class);
+        initCriteria(criteria,bo);
+        List<DataLianjiaCode> list = criteria.list();
+        return list;
+    }
+
+    @Override
+    public String getCityNameByCode(String code) {
+        if (!cityNameCodeMap.isEmpty()){
+            return cityNameCodeMap.get(code);
+        }
+        DataLianjiaCodeBo bo = new DataLianjiaCodeBo();
+        bo.setParentId("0");
+        List<DataLianjiaCode> list = getLianjiaCode(bo);
+        cityNameCodeMap = list.stream().collect(Collectors.toMap(DataLianjiaCode::getCode, DataLianjiaCode::getName));
+        return getCityNameByCode(code);
+    }
+
+
+    private void initCriteria(Criteria criteria, DataLianjiaCodeBo bo) {
+        Assert.notNull(criteria, "criteria must not be null!");
+        if (bo != null) {
+            CriteriaUtils.addCondition(criteria, bo);
+        }
+    }
+}

src/main/java/com/leeroa/dydb/datasource/lianjia/domain/DataLianjiaCode.java

@@ -0,0 +1,34 @@
+package com.leeroa.dydb.datasource.lianjia.domain;
+
+import com.michael.common.CommonDomain;
+import com.michael.docs.annotations.ApiField;
+import lombok.Data;
+
+import javax.persistence.Column;
+import javax.persistence.Entity;
+import javax.persistence.Table;
+
+/**
+ * 类说明：
+ *
+ * @author: wucl
+ * @since: 2024/4/17
+ * created with IntelliJ IDEA.
+ */
+@Data
+@Entity
+@Table(name = "db_data_lianjia_code")
+public class DataLianjiaCode extends CommonDomain {
+
+    @ApiField(value = "父级id")
+    @Column(name = "parent_id")
+    private String parentId;
+
+    @ApiField(value = "名称")
+    @Column(name = "name")
+    private String name;
+
+    @ApiField(value = "编码")
+    @Column(name = "code")
+    private String code;
+}

src/main/java/com/leeroa/dydb/datasource/lianjia/service/DataLianjiaCodeService.java

@@ -0,0 +1,19 @@
+package com.leeroa.dydb.datasource.lianjia.service;
+
+import com.leeroa.dydb.datasource.lianjia.bo.DataLianjiaCodeBo;
+import com.leeroa.dydb.datasource.lianjia.domain.DataLianjiaCode;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 类说明：
+ *
+ * @author: wucl
+ * @since: 2024/4/17
+ * created with IntelliJ IDEA.
+ */
+public interface DataLianjiaCodeService {
+
+    List<DataLianjiaCode> queryCityMap(DataLianjiaCodeBo bo);
+}

src/main/java/com/leeroa/dydb/datasource/lianjia/service/impl/DataLianjiaCodeServiceImpl.java

@@ -0,0 +1,39 @@
+package com.leeroa.dydb.datasource.lianjia.service.impl;
+
+import com.leeroa.dydb.datasource.lianjia.bo.DataLianjiaCodeBo;
+import com.leeroa.dydb.datasource.lianjia.dao.DataLianjiaCodeDao;
+import com.leeroa.dydb.datasource.lianjia.dao.DataLianjiaDao;
+import com.leeroa.dydb.datasource.lianjia.domain.DataLianjiaCode;
+import com.leeroa.dydb.datasource.lianjia.service.DataLianjiaCodeService;
+import com.leeroa.dydb.datasource.lianjia.vo.DataLianjiaCodeVo;
+import com.michael.core.beans.BeanWrapCallback;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 类说明：
+ *
+ * @author: wucl
+ * @since: 2024/4/17
+ * created with IntelliJ IDEA.
+ */
+@Slf4j
+@Service("dataLianjiaCodeService")
+public class DataLianjiaCodeServiceImpl implements DataLianjiaCodeService, BeanWrapCallback<DataLianjiaCode, DataLianjiaCodeVo> {
+
+    @Resource
+    private DataLianjiaCodeDao dataLianjiaCodeDao;
+    @Override
+    public List<DataLianjiaCode> queryCityMap(DataLianjiaCodeBo bo) {
+        return dataLianjiaCodeDao.getLianjiaCode(bo);
+    }
+
+    @Override
+    public void doCallback(DataLianjiaCode dataLianjiaCode, DataLianjiaCodeVo dataLianjiaCodeVo) {
+
+    }
+}

src/main/java/com/leeroa/dydb/datasource/lianjia/vo/DataLianjiaCodeVo.java

@@ -0,0 +1,13 @@
+package com.leeroa.dydb.datasource.lianjia.vo;
+
+import com.leeroa.dydb.datasource.lianjia.domain.DataLianjiaCode;
+
+/**
+ * 类说明：
+ *
+ * @author: wucl
+ * @since: 2024/4/17
+ * created with IntelliJ IDEA.
+ */
+public class DataLianjiaCodeVo extends DataLianjiaCode {
+}

src/main/resources/config.properties

@@ -1,7 +1,7 @@
 db.driverClass=com.mysql.jdbc.Driver
 db.jdbcUrl=jdbc:mysql://localhost:3306/p_dydb
 db.user=root
-db.password=root
+db.password=914851221
 db.maxPoolSize=100
 db.minPoolSize=8
 db.maxWait=300000

src/main/resources/rebel.xml

@@ -0,0 +1,23 @@
+<?xml version="1.0" encoding="UTF-8"?>
+
+<!--
+  This is the JRebel configuration file. It maps the running application to your IDE workspace, enabling JRebel reloading for this project.
+  Refer to https://manuals.jrebel.com/jrebel/standalone/config.html for more information.
+-->
+<application generated-by="intellij" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://www.zeroturnaround.com" xsi:schemaLocation="http://www.zeroturnaround.com http://update.zeroturnaround.com/jrebel/rebel-2_3.xsd">
+
+	<id>project-dydb</id>
+
+	<classpath>
+		<dir name="F:/development/dydb/target/classes">
+		</dir>
+	</classpath>
+
+	<web>
+		<link target="/">
+			<dir name="F:/development/dydb/src/main/webapp">
+			</dir>
+		</link>
+	</web>
+
+</application>