x

src/main/java/com/egolm/pds/schedule/PriceTask.java

@@ -4,7 +4,8 @@ import java.util.Date;
 import java.util.HashMap;
 import java.util.Map;
 
-import org.springframework.beans.factory.annotation.Autowired;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
@@ -14,14 +15,12 @@ import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.egolm.common.DateUtil;
 import com.egolm.pds.config.HttpUtil;
-import com.egolm.pds.schedule.service.PdsService;
 
 @Component
 public class PriceTask {
-
-	@Autowired
-	private PdsService pdsService;
 	
+	private static final Log log = LogFactory.getLog(PriceTask.class);
+
 	@Value("${pds.auth_key}")
 	private String authKey;
 	
@@ -31,13 +30,9 @@ public class PriceTask {
 	@Value("${pds.url_query}")
 	private String urlQuery;
 	
-	@Value("${pds.cron.products_download}")
-	private String cron;
-	
-	
-	@Scheduled(cron="${pds.cron.products_download}")
+	@Scheduled(cron="${pds.cron.price_download}")
 	public void execute() {
-		System.out.println(DateUtil.format(new Date()) + " PdsProductsUpdateTask RUN " + cron);
+		log.debug(DateUtil.format(new Date()) + " PdsProductsUpdateTask RUN");
 		boolean boo = true;
 		int loopCount = 0;
 		while(boo) {
@@ -53,60 +48,28 @@ public class PriceTask {
 		JSONArray jsonArray = jsonObject.getJSONArray("data");
 		if(jsonArray != null) {
 			for(int i = 0; i < jsonArray.size(); i++) {
-				JSONObject productJsonObject = jsonArray.getJSONObject(i);
-				String article_description = productJsonObject.getString("article_description");
-				String article_group_no = productJsonObject.getString("article_group_no");
-				String article_short_description = productJsonObject.getString("article_short_description");
-				String article_type = productJsonObject.getString("article_type");
-				String barcode = productJsonObject.getString("barcode");
-				String buying_price = productJsonObject.getString("buying_price");
-				String buying_price_with_tax = productJsonObject.getString("buying_price_with_tax");
-				Integer case_qty = productJsonObject.getInteger("case_qty");
-				String deduction = productJsonObject.getString("deduction");
-				String made_in = productJsonObject.getString("made_in");
-				String order_way = productJsonObject.getString("order_way");
-				String pack_unit = productJsonObject.getString("pack_unit");
-				String selling_price = productJsonObject.getString("selling_price");
-				String specification = productJsonObject.getString("specification");
-				String stores = productJsonObject.getString("stores");
-				String supplier_article_no = productJsonObject.getString("supplier_article_no");
-				String supplier_no = productJsonObject.getString("supplier_no");
-				String tax_rate = productJsonObject.getString("tax_rate");
-				String trade_mode = productJsonObject.getString("trade_mode");
-				String weight_article = productJsonObject.getString("weight_article");
-				Object transactionId = productJsonObject.get("transaction_id");
-				
-				Map<String, Object> productMap = new HashMap<String, Object>();
-				productMap.put("article_description", article_description);
-				productMap.put("article_group_no", article_group_no);
-				productMap.put("article_short_description", article_short_description);
-				productMap.put("article_type", article_type);
-				productMap.put("barcode", barcode);
-				productMap.put("buying_price", buying_price);
-				productMap.put("buying_price_with_tax", buying_price_with_tax);
-				productMap.put("case_qty", case_qty);
-				productMap.put("deduction", deduction);
-				productMap.put("made_in", made_in);
-				productMap.put("order_way", order_way);
-				productMap.put("pack_unit", pack_unit);
-				productMap.put("selling_price", selling_price);
-				productMap.put("specification", specification);
-				productMap.put("stores", stores);
-				productMap.put("supplier_article_no", supplier_article_no);
-				productMap.put("supplier_no", supplier_no);
-				productMap.put("tax_rate", tax_rate);
-				productMap.put("trade_mode", trade_mode);
-				productMap.put("weight_article", weight_article);
-				productMap.put("dLastUpdateTime", new Date());
-				pdsService.savePdsProduct(transactionId, productMap);;
+				JSONObject priceObject = jsonArray.getJSONObject(i);
+				String barcode = priceObject.getString("barcode");
+				Integer contract_id = priceObject.getInteger("contract_id");
+				String effective_date = priceObject.getString("effective_date");
+				String effective_end_date = priceObject.getString("effective_end_date");
+				String new_buying_price_with_tax = priceObject.getString("new_buying_price_with_tax");
+				String new_selling_price_with_tax = priceObject.getString("new_selling_price_with_tax");
+				String price_change_type = priceObject.getString("price_change_type");
+
+				Map<String, Object> map = new HashMap<String, Object>();
+				map.put("barcode", barcode);
+				map.put("contract_id", contract_id);
+				map.put("effective_date", effective_date);
+				map.put("effective_end_date", effective_end_date);
+				map.put("new_buying_price_with_tax", new_buying_price_with_tax);
+				map.put("new_selling_price_with_tax", new_selling_price_with_tax);
+				map.put("price_change_type", price_change_type);
+				log.debug(JSON.toJSONString(map));
 			}
 		}
 		
 		return jsonArray == null ? 0 : jsonArray.size();
 	}
 	
-	public static void main(String[] args) {
-		Date date = new Date(1568079001765L);
-		System.out.println(DateUtil.format(date));
-	}
 }

src/main/java/com/egolm/pds/schedule/ProductsTask.java

@@ -31,13 +31,9 @@ public class ProductsTask {
 	@Value("${pds.products.url_query}")
 	private String urlQuery;
 	
-	@Value("${pds.cron.products_download}")
-	private String cron;
-	
-	
 	@Scheduled(cron="${pds.cron.products_download}")
 	public void execute() {
-		System.out.println(DateUtil.format(new Date()) + " PdsProductsUpdateTask RUN " + cron);
+		System.out.println(DateUtil.format(new Date()) + " PdsProductsUpdateTask RUN");
 		boolean boo = true;
 		int loopCount = 0;
 		while(boo) {

src/main/resources/application-dev.yml

@@ -20,6 +20,7 @@ spring:
 pds:
   cron:
     products_download: 0 0 3 * * ?
+    price_download: 0 0 4 * * ?
   auth_key: x-api-key
   auth_value: gPmsTNthxi5krwOTnaM9y5AhXlHrc6Ve5ik2GzQg
   products:

src/main/resources/application-pro.yml

@@ -20,6 +20,7 @@ spring:
 pds:
   cron:
     products_download: 0 0 3 * * ?
+    price_download: 0 0 4 * * ?
   auth_key: x-api-key
   auth_value: gPmsTNthxi5krwOTnaM9y5AhXlHrc6Ve5ik2GzQg
   products:

src/main/resources/logback.xml

@@ -12,7 +12,7 @@
 			<appender name="rollingFileAppender"
 				class="ch.qos.logback.core.rolling.RollingFileAppender">
 				<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
-					<FileNamePattern>/data/logs/pds/${context}-%d{yyyy-MM-dd}.log</FileNamePattern>
+					<FileNamePattern>logs/${context}-%d{yyyy-MM-dd}.log</FileNamePattern>
 					<MaxHistory>30</MaxHistory>
 				</rollingPolicy>
 				<encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">
@@ -38,14 +38,6 @@
 		</root>
 	</springProfile>
 	
-	<logger name="com.microsoft"   level="INFO" />
-	<logger name="com.alibaba"   level="INFO" />
-	<logger name="springfox" level="ERROR" />
-	<logger name="javax" level="ERROR" />
-	<logger name="java"  level="ERROR" />
-	<logger name="net"   level="ERROR" />
-	<logger name="org"   level="INFO" />
-	<logger name="io"   level="INFO" />
 	<logger name="com.egolm" level="DEBUG" />
 
 </configuration>
\ No newline at end of file