Browse Source

数据中心文件归档处理;多文件归档

zhouy 5 years ago
parent
commit
619b794381

+ 3 - 0
src/main/java/com/uas/eis/serviceImpl/DataDealServiceImpl.java

@@ -73,7 +73,10 @@ public class DataDealServiceImpl  implements DataDealService {
                 itemCols.add("ITEM"+(j+1));
             }
             List<String> sqls =new ArrayList<String>();
+            sqls.add("DELETE FROM DATACENTER$CHIP_DATAMAIN WHERE CHIPCODE_='"+dataChip.getChipcode_()+"'");
             sqls.add("BEGIN "+mainBuffer.toString()+"  END;");
+            sqls.add("DELETE FROM "+TableName+"@SHENAI_EDCDATA  WHERE CHIPCODE='"+dataChip.getChipcode_()+"'");
+
             int allRow = st.getLastRowNum()-23;//总行数
             //分批3000行处理
             int a = allRow / 3000;

+ 1 - 1
src/main/java/com/uas/eis/task/DataDealTask.java

@@ -47,7 +47,7 @@ public class DataDealTask {
                 e.printStackTrace();
             }
         }
-        logger.info("Data文件解析执行结束:用时"+((date.getTime()-new Date().getTime())/1000));
+        logger.info("Data文件解析执行结束:用时"+((new Date().getTime()-date.getTime())/1000));
     }
 
 }

+ 5 - 0
src/test/java/com/uas/eis/UasEisApplicationTests.java

@@ -7,6 +7,8 @@ import com.uas.eis.service.SaleReturnService;
 import com.uas.eis.service.SaleService;
 import org.junit.Test;
 import org.junit.runner.RunWith;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.jdbc.core.BeanPropertyRowMapper;
@@ -22,6 +24,7 @@ import java.util.stream.Collectors;
 @RunWith(SpringRunner.class)
 @SpringBootTest(classes = {UasEisApplication.class})
 public class UasEisApplicationTests {
+	private final Logger logger = LoggerFactory.getLogger(this.getClass());
 
 	@Autowired
 	private DataDealService dataDealService;
@@ -29,6 +32,7 @@ public class UasEisApplicationTests {
 	private BaseDao baseDao;
 	@Test
 	public void contextLoads() {
+		Date date = new Date();
 		List<DataChip> dataChips = baseDao.getJdbcTemplate().query("select id_,chipcode_,counterpath_,datapath_,testdate_ from (select id_,chipcode_,counterpath_,datapath_,testdate_ from datacenter$chip where chipcode_='F20025075#04' and  nvl(readstatus_,0)=0 and testdate_ is  not null order by testdate_  desc) where rownum<=50",
 				new BeanPropertyRowMapper<DataChip>(DataChip.class));
 		if(dataChips.size()>0){
@@ -44,6 +48,7 @@ public class UasEisApplicationTests {
 				e.printStackTrace();
 			}
 		}
+		logger.info("Data文件解析执行结束:用时"+((new Date().getTime()-date.getTime())/1000));
 	}