Commit 2bdb4253 by shentao

Merge branch 'feature' into 'release'

2024/12/03 分支版本恢复

See merge request !149
parents 89800b93 e83d7d49
...@@ -11,7 +11,7 @@ ...@@ -11,7 +11,7 @@
</parent> </parent>
<artifactId>middleware-automatic-center-client</artifactId> <artifactId>middleware-automatic-center-client</artifactId>
<version>1.0.0.7-SNAPSHOT</version> <version>${automatic.version}</version>
<properties> <properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
......
package com.zhiwei.middleware.automatic.server.pojo; package com.zhiwei.middleware.automatic.server.pojo;
public class CidRecord { public class CidRecordData {
private String id; private String id;
private Long c4; private Long c4;
...@@ -101,20 +100,4 @@ public class CidRecord { ...@@ -101,20 +100,4 @@ public class CidRecord {
public void setCid(Long cid) { public void setCid(Long cid) {
this.cid = cid; this.cid = cid;
} }
@Override
public String toString() {
return "CidRecord{" +
"id='" + id + '\'' +
", c4=" + c4 +
", c5=" + c5 +
", foreign=" + foreign +
", url='" + url + '\'' +
", time=" + time +
", ctime=" + ctime +
", stime=" + stime +
", esId='" + esId + '\'' +
", cid=" + cid +
",version=20241201}";
}
} }
package com.zhiwei.middleware.automatic.son.pojo; package com.zhiwei.middleware.automatic.server.pojo;
public class CidRecord { public class CidRecordInfo {
private String id; private String id;
...@@ -101,20 +101,4 @@ public class CidRecord { ...@@ -101,20 +101,4 @@ public class CidRecord {
public void setCid(Long cid) { public void setCid(Long cid) {
this.cid = cid; this.cid = cid;
} }
@Override
public String toString() {
return "CidRecord{" +
"id='" + id + '\'' +
", c4=" + c4 +
", c5=" + c5 +
", foreign=" + foreign +
", url='" + url + '\'' +
", time=" + time +
", ctime=" + ctime +
", stime=" + stime +
", esId='" + esId + '\'' +
", cid=" + cid +
'}';
}
} }
...@@ -28,7 +28,6 @@ ...@@ -28,7 +28,6 @@
<filter.version>1.1.6-SNAPSHOT</filter.version> <filter.version>1.1.6-SNAPSHOT</filter.version>
<nlp-aggree.version>0.0.5-SNAPSHOT</nlp-aggree.version> <nlp-aggree.version>0.0.5-SNAPSHOT</nlp-aggree.version>
<dubbo-server.version>2.7.4.1</dubbo-server.version> <dubbo-server.version>2.7.4.1</dubbo-server.version>
<automatic.client.version>1.0.0.7-SNAPSHOT</automatic.client.version>
</properties> </properties>
......
package com.zhiwei.middleware.automatic.son.dao; package com.zhiwei.middleware.automatic.son.dao;
import com.zhiwei.middleware.automatic.son.pojo.CidRecord; import com.zhiwei.middleware.automatic.server.pojo.CidRecordData;
public interface CidRecordDao { public interface CidRecordDao {
void insert(CidRecord cidRecord); void insert(CidRecordData cidRecord);
} }
package com.zhiwei.middleware.automatic.son.dao.impl; package com.zhiwei.middleware.automatic.son.dao.impl;
import com.zhiwei.middleware.automatic.son.pojo.CidRecord; import com.zhiwei.middleware.automatic.server.pojo.CidRecordData;
import com.zhiwei.middleware.automatic.son.dao.CidRecordDao; import com.zhiwei.middleware.automatic.son.dao.CidRecordDao;
import com.zhiwei.middleware.automatic.son.util.Tools; import com.zhiwei.middleware.automatic.son.util.Tools;
import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.beans.factory.annotation.Qualifier;
...@@ -19,7 +19,7 @@ public class CidRecordDaoImpl implements CidRecordDao { ...@@ -19,7 +19,7 @@ public class CidRecordDaoImpl implements CidRecordDao {
} }
@Override @Override
public void insert(CidRecord cidRecord) { public void insert(CidRecordData cidRecord) {
mongoTemplate.insert(cidRecord, COLLECTION_NAME + Tools.TIME_FORMAT_COMMON.format(cidRecord.getStime())); mongoTemplate.insert(cidRecord, COLLECTION_NAME + Tools.TIME_FORMAT_COMMON.format(cidRecord.getStime()));
} }
} }
...@@ -3,10 +3,10 @@ package com.zhiwei.middleware.automatic.son.task.service; ...@@ -3,10 +3,10 @@ package com.zhiwei.middleware.automatic.son.task.service;
import com.alibaba.excel.util.CollectionUtils; import com.alibaba.excel.util.CollectionUtils;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.zhiwei.middleware.automatic.server.pojo.AutoTask; import com.zhiwei.middleware.automatic.server.pojo.AutoTask;
import com.zhiwei.middleware.automatic.server.pojo.CidRecordData;
import com.zhiwei.middleware.automatic.server.pojo.enums.TaskType; import com.zhiwei.middleware.automatic.server.pojo.enums.TaskType;
import com.zhiwei.middleware.automatic.server.util.RedissonUtil; import com.zhiwei.middleware.automatic.server.util.RedissonUtil;
import com.zhiwei.middleware.automatic.son.dao.CidRecordDao; import com.zhiwei.middleware.automatic.son.dao.CidRecordDao;
import com.zhiwei.middleware.automatic.son.pojo.CidRecord;
import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.LogManager;
import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor; import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
...@@ -41,11 +41,10 @@ public class TaskServiceCidRecord extends AbstractTaskService { ...@@ -41,11 +41,10 @@ public class TaskServiceCidRecord extends AbstractTaskService {
} }
for (String s : data) { for (String s : data) {
try { try {
CidRecord cidRecord = JSONObject.parseObject(s, CidRecord.class); CidRecordData cidRecord = JSONObject.parseObject(s, CidRecordData.class);
if (!test) { if (!test) {
test = true; test = true;
com.zhiwei.middleware.automatic.server.pojo.CidRecord record = JSONObject.parseObject(s, com.zhiwei.middleware.automatic.server.pojo.CidRecord.class); log.info("日志打印,源数据:{},实体:{}", s, JSONObject.toJSONString(cidRecord));
log.info("日志打印,源数据:{},实体:{},version:{}", s, JSONObject.toJSONString(record), record.toString());
} }
cidRecordDao.insert(cidRecord); cidRecordDao.insert(cidRecord);
} catch (Exception e) { } catch (Exception e) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment