em数据

src/main/java/com/qlm/job/MyJob.java

@@ -46,6 +46,7 @@ public class MyJob  implements Job {
 			throws JobExecutionException {
 		logger.info("定时任务执行..." + new Date());
 		UploadService.update();
+		UploadService.updateEm();
 //		updDayCount();
 	}
 

src/main/java/com/qlm/service/UploadService.java

@@ -208,6 +208,92 @@ public class UploadService {
 		
 	}
 	
+	
+static boolean  isEmRunning = false;
+	
+	//同步订单到我们自己的库
+	public static void updateEm(){
+		if(isEmRunning){
+			return;
+		}
+		isEmRunning = true;
+		int pageSize = 1000;
+		try{
+		for (int pageNumber = 1; pageNumber <100000000; pageNumber++) {
+			int pageStart = (pageNumber - 1) * pageSize + 1;
+			int pageEnd = pageSize*pageNumber;
+			
+			String udfSqlString = "SELECT * FROM (SELECT a.*, ROWNUM rnum FROM (SELECT * FROM WMS_PROD.V_YMSO_RETURN_H) a WHERE ROWNUM <= ?) WHERE rnum > ?";
+			List<Record> find = Db.use("oracle").find(udfSqlString,pageEnd,pageStart);
+			if(find.isEmpty()){
+				break;
+			}
+			
+			List<Record> list = new ArrayList<Record>();
+			for (Record record : find) {
+				String orderNo = record.getStr("ORDERNO");//发货单号
+				
+				String OUTWAREHOUSE = record.getStr("OUTWAREHOUSE");//工厂名称
+				
+				
+				String WAREHOUSEID = record.getStr("WAREHOUSEID");//工厂ID
+				
+				
+				Date Deliverytime = record.getDate("DELIVERYTIME");//出库时间
+				
+				String caseCode = record.getStr("CASECODE");//箱码
+				
+				String palletCode = record.getStr("PALLETCODE");//垛码
+				
+				
+				String PRODUCTNAME = record.getStr("PRODUCTNAME");//产品名称
+				
+				
+				
+				String CUSTOMERNAME = record.getStr("CUSTOMERNAME");//客户姓名
+			
+				String SKUNAME = record.getStr("SKUNAME");//SKU名称
+				
+				String LICENSEPLATE = record.getStr("LICENSEPLATE");//车牌号
+				
+				String OUTWAREHOUSENO = record.getStr("OUTWAREHOUSENO");//工厂编号
+				
+				String SKUNO = record.getStr("SKUNO");//sku编号
+				
+				String OPERATEUSER = record.getStr("OPERATEUSER");//操作人
+				
+				String PRODUCTNO = record.getStr("PRODUCTNO");//产品编号
+				
+				String CUSTOMERNO = record.getStr("CUSTOMERNO");//客户编号
+				
+				Record info = new Record();
+				
+				info.set("OrderNo", orderNo).set("OutWarehouse", OUTWAREHOUSE).set("WarehouseID", WAREHOUSEID)
+				
+				.set("DeliveryTime", Deliverytime).set("CaseCode", caseCode).set("PalletCode", palletCode)
+				
+				.set("ProductName", PRODUCTNAME).set("CustomerName", CUSTOMERNAME).set("SKUName", SKUNAME)
+				
+				
+				.set("LicensePlate", LICENSEPLATE).set("OutWarehouseNo", OUTWAREHOUSENO).set("SKUNo", SKUNO)
+				
+				.set("OperateUser", OPERATEUSER).set("ProductNo", PRODUCTNO).set("CustomerNo", CUSTOMERNO);
+				
+				
+				list.add(info);
+				
+			}
+			WxUtil.batchSaveIgnore("deliveryorders", list, "");
+		}
+		Log.info("执行同步数据em:完成");
+		}catch(Exception e){
+			e.printStackTrace();
+		}finally{
+			isEmRunning = false;
+		}
+		
+		
+	}
 	private static String key = "wYG(nx%Xlc7vb%Ss1=2L#JZ*gSk^WXuV";
 
 	private boolean checksign(String code, String time, String sign) {