Commit ba587c0d by liuyu

2024/12/03 pom版本恢复

parent 299de565
...@@ -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 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 +
",version=20241201}";
}
} }
...@@ -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.CidRecordInfo;
public interface CidRecordDao { public interface CidRecordDao {
void insert(CidRecord cidRecord); void insert(CidRecordInfo 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.CidRecordInfo;
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(CidRecordInfo 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()));
} }
} }
package com.zhiwei.middleware.automatic.son.pojo;
public class CidRecord {
private String id;
private Long c4;
private Long c5;
private int foreign;
private String url;
private Long time;
private Long ctime;
private Long stime;
private String esId;
private Long cid;
public Long getC5() {
return c5;
}
public void setC5(Long c5) {
this.c5 = c5;
}
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public Long getC4() {
return c4;
}
public void setC4(Long c4) {
this.c4 = c4;
}
public int getForeign() {
return foreign;
}
public void setForeign(int foreign) {
this.foreign = foreign;
}
public String getUrl() {
return url;
}
public void setUrl(String url) {
this.url = url;
}
public Long getTime() {
return time;
}
public void setTime(Long time) {
this.time = time;
}
public Long getCtime() {
return ctime;
}
public void setCtime(Long ctime) {
this.ctime = ctime;
}
public Long getStime() {
return stime;
}
public void setStime(Long stime) {
this.stime = stime;
}
public String getEsId() {
return esId;
}
public void setEsId(String esId) {
this.esId = esId;
}
public Long getCid() {
return cid;
}
public void setCid(Long 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 +
'}';
}
}
...@@ -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.CidRecordInfo;
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); CidRecordInfo cidRecord = JSONObject.parseObject(s, CidRecordInfo.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