个贷数据库接口

biz-base/src/main/java/com/dayou/controller/PersonalTargetController.java

@@ -1,7 +1,9 @@
 package com.dayou.controller;
 
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
+import com.dayou.annotation.IgnoreAuth;
 import com.dayou.common.BaseEntity;
+import com.dayou.dto.PersonalTargetEvaData;
 import com.dayou.dto.TaskRecordDTO;
 import com.dayou.vo.*;
 import com.dayou.workflow.annotation.FinishTask;
@@ -171,5 +173,17 @@ public class PersonalTargetController extends BaseController {
         return RestResponse.data(result);
     }
 
+    /**
+     * 房产数据库同步数据接口
+     * @param evaData
+     * @return
+     */
+    @IgnoreAuth
+    @PostMapping("/evaData")
+    public RestResponse<List<PersonalTargetEvaData>> queryPersonalTargetEvaData(@RequestBody PersonalTargetEvaData evaData){
+        List<PersonalTargetEvaData> ret = personalTargetService.queryPersonalTargetEvaData(evaData);
+        return RestResponse.data(ret);
+    }
+
 }
 

dao/src/main/java/com/dayou/mapper/PersonalTargetMapper.java

@@ -1,10 +1,12 @@
 package com.dayou.mapper;
 
+import com.dayou.dto.PersonalTargetEvaData;
 import com.dayou.entity.PersonalTarget;
 import com.dayou.dao.CustomBaseMapper;
 import com.dayou.vo.ProdValidateVO;
 import org.apache.ibatis.annotations.Param;
 
+import java.util.Date;
 import java.util.List;
 
 /**
@@ -20,4 +22,6 @@ public interface PersonalTargetMapper extends CustomBaseMapper<PersonalTarget> {
     ProdValidateVO validateProd(@Param("id") Long id);
 
     List<String> fuzzyBackgroundList(@Param("location") String location);
+
+    List<PersonalTargetEvaData> queryPersonalTargetEvaData(@Param("startDate") String startDate);
 }

dao/src/main/resources/mapper/MajorProductionMapper.xml

@@ -688,7 +688,6 @@
             mp.name AS productionName,
             mp.report_no AS productionNo ,
             mp.client_name as bailor,
-            DATE_FORMAT(mp.production_time,'%Y-%m-%d') as productionTime,
             mp.value_timing
         FROM
             major_production mp

dao/src/main/resources/mapper/PersonalTargetMapper.xml

@@ -37,22 +37,7 @@
             p.order_id AS productionNo,
             p.bailorA,
             p.bailorB,
-            DATE_FORMAT((
-                SELECT
-                    created
-                FROM
-                    work_flow_log
-                WHERE
-                    state= 'PASS'
-                  AND business_type = 'PERSONAL_BUSINESS'
-                  AND instance_id = ( SELECT id FROM work_flow_node_instance WHERE business_type = 'PERSONAL_BUSINESS' AND business_id = p.id AND deleted = 0 AND node_id = 100 AND state='FINISHED' ORDER BY created DESC LIMIT 1 )
-		ORDER BY
-			created DESC
-			LIMIT 1
-			),
-		'%Y-%m-%d'
-	) AS valueTiming,
-            DATE_FORMAT(( SELECT production_time FROM personal_production WHERE target_id = pt.id AND production_time IS NOT NULL AND deleted = 0 ORDER BY production_time ASC LIMIT 1 ), '%Y-%m-%d' ) AS production_time
+            DATE_FORMAT(JSON_UNQUOTE(JSON_EXTRACT(selling_ability,'$.sceneDateD')),'%Y-%m-%d') AS valueTiming
         FROM
             personal_target pt
                 LEFT JOIN personal p ON p.id = pt.personal_id
@@ -73,4 +58,23 @@
           AND JSON_EXTRACT( background_info, '$.location' ) LIKE concat ('%',#{location},'%')
         order by id desc
     </select>
+
+    <select id="queryPersonalTargetEvaData" parameterType="java.lang.String" resultType="com.dayou.dto.PersonalTargetEvaData">
+        SELECT
+            p.order_id as orderId,
+            p.order_id as orderNO,
+            JSON_UNQUOTE(JSON_EXTRACT(pt.entity_info,'$.communityName')) as houseName,
+            pt.location as address,
+            JSON_UNQUOTE(JSON_EXTRACT(pt.entity_info,'$.allFloor')) as totalFloor,
+            JSON_UNQUOTE(JSON_EXTRACT(pt.entity_info,'$.buildingAge')) as buildYear,
+            DATE_FORMAT(JSON_UNQUOTE(JSON_EXTRACT(selling_ability,'$.sceneDateD')),'%Y-%m-%d %H:%i:%s') AS priceDate,
+            pt.acreage as area,
+            pt.amount as money,
+            pt.price as price,
+            pt.modified as modifyTime
+        FROM
+            personal_target pt
+                LEFT JOIN personal p ON p.id = pt.personal_id
+        where p.created>='2025-01-01 00:00:00' and pt.modified &gt;#{startDate}
+    </select>
 </mapper>

domain/src/main/java/com/dayou/dto/PersonalTargetEvaData.java

@@ -0,0 +1,34 @@
+package com.dayou.dto;
+
+import lombok.Data;
+
+import java.util.Date;
+
+@Data
+public class PersonalTargetEvaData {
+
+    private String orderId;
+
+    private String orderNO;
+
+    private String houseName;
+
+    private String address;
+
+    private String totalFloor;
+
+    private String buildYear;
+
+    private Date priceDate;
+
+    private String area;
+
+    private Double money;
+
+    private Double price;
+
+    private Date modifyTime;
+
+    private String startTime;
+
+}

service/src/main/java/com/dayou/service/IPersonalTargetService.java

@@ -1,4 +1,5 @@
 package com.dayou.service;
+import com.dayou.dto.PersonalTargetEvaData;
 import com.dayou.dto.TaskRecordDTO;
 import com.dayou.entity.PersonalTarget;
 import com.baomidou.mybatisplus.extension.service.IService;
@@ -46,4 +47,7 @@ public interface IPersonalTargetService extends IService<PersonalTarget> {
     Boolean doFeedback(TaskRecordDTO<PersonalTarget> taskRecordDTO);
 
     List<PersonalBackgroundInfo> fuzzyBackgroundList(String location);
+
+    List<PersonalTargetEvaData> queryPersonalTargetEvaData(PersonalTargetEvaData evaData);
+
 }

service/src/main/java/com/dayou/service/impl/PersonalTargetServiceImpl.java

@@ -6,6 +6,7 @@ import cn.hutool.core.util.StrUtil;
 import com.alibaba.fastjson.JSON;
 import com.baomidou.dynamic.datasource.annotation.DS;
 import com.dayou.common.BaseEntity;
+import com.dayou.dto.PersonalTargetEvaData;
 import com.dayou.dto.TaskRecordDTO;
 import com.dayou.entity.Personal;
 import com.dayou.entity.PersonalTarget;
@@ -14,6 +15,7 @@ import com.dayou.mapper.PersonalTargetMapper;
 import com.dayou.service.IPersonalService;
 import com.dayou.service.IPersonalTargetService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.dayou.utils.DateUtils;
 import com.dayou.vo.*;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -35,6 +37,7 @@ import org.springframework.web.multipart.MultipartFile;
 
 import java.sql.Struct;
 import java.util.Collections;
+import java.util.Date;
 import java.util.List;
 import java.util.ArrayList;
 import java.util.stream.Collectors;
@@ -203,4 +206,9 @@ public class PersonalTargetServiceImpl extends ServiceImpl<PersonalTargetMapper,
         }).collect(Collectors.toList());
         return result;
     }
+
+    @Override
+    public List<PersonalTargetEvaData> queryPersonalTargetEvaData(PersonalTargetEvaData evaData) {
+        return personalTargetMapper.queryPersonalTargetEvaData(evaData.getStartTime());
+    }
 }