|
@@ -1,5 +1,6 @@
|
|
|
package com.siwei.apply.service.third.impl;
|
|
package com.siwei.apply.service.third.impl;
|
|
|
|
|
|
|
|
|
|
+import com.alibaba.fastjson2.JSON;
|
|
|
import com.siwei.apply.domain.NodeAttachment;
|
|
import com.siwei.apply.domain.NodeAttachment;
|
|
|
import com.siwei.apply.domain.ProjectImmobileCode;
|
|
import com.siwei.apply.domain.ProjectImmobileCode;
|
|
|
import com.siwei.apply.domain.ProjectWorkflow;
|
|
import com.siwei.apply.domain.ProjectWorkflow;
|
|
@@ -164,6 +165,8 @@ public class OfferDataServiceImpl implements OfferDataService {
|
|
|
throw new ServiceException("业务号为空");
|
|
throw new ServiceException("业务号为空");
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
+ log.info("登簿数据校验通过开始入库: {}" , JSON.toJSONString(body));
|
|
|
|
|
+
|
|
|
String id="";
|
|
String id="";
|
|
|
String tbztFlag;
|
|
String tbztFlag;
|
|
|
// 入库:以 yfbdcdyh 或 ywh 及 ywlx 判重,已存在则按主键覆盖更新,避免重复插入
|
|
// 入库:以 yfbdcdyh 或 ywh 及 ywlx 判重,已存在则按主键覆盖更新,避免重复插入
|
|
@@ -179,7 +182,8 @@ public class OfferDataServiceImpl implements OfferDataService {
|
|
|
thirdRecordStatusMapper.insert(body);
|
|
thirdRecordStatusMapper.insert(body);
|
|
|
tbztFlag = "0";
|
|
tbztFlag = "0";
|
|
|
}
|
|
}
|
|
|
-
|
|
|
|
|
|
|
+ log.info("登簿数据入库成功: {}" , id);
|
|
|
|
|
+ tbztFlag = "1"; //todo 这里暂时不同步数据
|
|
|
if("0".equals(tbztFlag)) {
|
|
if("0".equals(tbztFlag)) {
|
|
|
//todo 需要进行数据的抓取,并且需要异步处理,否则下载文件会阻塞接口的返回,导致超时。
|
|
//todo 需要进行数据的抓取,并且需要异步处理,否则下载文件会阻塞接口的返回,导致超时。
|
|
|
CompletableFuture.supplyAsync(()-> {
|
|
CompletableFuture.supplyAsync(()-> {
|