2020-11-24

1.增加  淘宝订单 ID ,去重处理。 SA_TAOBAOID   alter   table  SALE add SA_TAOBAOID NUMBER;
2.增量备份
3.开启每小时执行一次定时任务
4.输出日志文件

src/main/java/com/uas/eis/UasEisApplication.java

@@ -12,7 +12,7 @@ import com.uas.eis.core.support.TokenPropertiesListener;
 @SpringBootApplication
 @EnableCaching
 //开启定时任务
-//@EnableScheduling
+@EnableScheduling
 @Import({DynamicDataSourceRegister.class})
 public class UasEisApplication {
 	public static void main(String[] args) {

src/main/java/com/uas/eis/serviceImpl/InsertServiceImpl.java

@@ -16,6 +16,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Service;
 
+import java.text.SimpleDateFormat;
 import java.util.*;
 
 import com.taobao.api.request.TradesSoldGetRequest;
@@ -62,7 +63,7 @@ public class InsertServiceImpl implements InsertService {
 
 
     @Autowired
-//  @Scheduled(cron = "0 0 0/1 * * ?")
+  @Scheduled(cron = "0 0 0/1 * * ?")
     public void getAllDate() {
 
 //        1.无淘宝自动抓取的 订单 ，则正常备份历史订单
@@ -90,7 +91,8 @@ public class InsertServiceImpl implements InsertService {
                 TradesSoldGetResponse rsp = client.execute(req, session_Key);
                 trades = rsp.getTrades();
             } catch (Exception e) {
-                logger.info(this.getClass() + "淘宝未响应并返回订单数据");
+
+                logger.info(  new SimpleDateFormat("YYYY-MM-DD hh24:mi:ss").format(new Date())+ this.getClass() + "淘宝未响应并返回订单数据");
             }
 
         } else {
@@ -139,17 +141,17 @@ public class InsertServiceImpl implements InsertService {
                 said = said + i ;
                 String sa_code = baseDao.sGetMaxNumber("Sale", 2);
 
-                String INSERTSALESql = "insert into sale(SA_TAOBAOID,sa_payments,sa_custname,sa_kind,sa_wwh_user,sa_need15,sa_id,sa_tradeid,sa_code,sa_date,sa_recorder,sa_recorddate,sa_currency,sa_rate" +
+                String INSERTSALESql = "insert into sale( sa_custcode,sa_paymentscode,SA_TAOBAOID,sa_payments,sa_custname,sa_kind,sa_wwh_user,sa_need15,sa_id,sa_tradeid,sa_code,sa_date,sa_recorder,sa_recorddate,sa_currency,sa_rate" +
                         ",sa_apcustname,sa_shcustname,sa_toplace" +
                         ",sa_transport,sa_seller,sa_updatedate" +
                         ",sa_enddate,sa_statuscode,sa_status,sa_fare,sa_total" +
                         ",sa_recamount,sa_plandelivery,sa_printstatuscode,sa_remark)" +
-                        "  SELECT "+ trades.get(i).getTid() + " , '现结','HLK淘宝','国内标准销售订单'," + trades.get(i).getReceiverName() + "," + trades.get(i).getReceiverPhone() + "," + said + "," + trades.get(i).getTid() + "," + sa_code
+                        "  SELECT  'GN0008358','P001', "   + trades.get(i).getTid() + " , '现结','HLK淘宝','国内标准销售订单', " + trades.get(i).getReceiverName() + "  , " + trades.get(i).getReceiverPhone() + "," + said + "," + trades.get(i).getTid() + "," + sa_code
                         + " ," + trades.get(i).getCreated() + "," + trades.get(i).getBuyerNick() + ",sysdate,'RMB','1',"
                         + trades.get(i).getReceiverName() + "," + trades.get(i).getBuyerNick() + "," + trades.get(i).getReceiverState() + " || " + trades.get(i).getReceiverAddress() + ","
                         + trades.get(i).getShippingType() + "," + trades.get(i).getO2oGuideName() + "," + trades.get(i).getModified()
-                        + "," + trades.get(i).getEndTime() + ",'entering','已审核'," + trades.get(i).getPostFee() + "," + trades.get(i).getPayment() + ","
-                        + trades.get(i).getTotalFee() + "," + trades.get(i).getConsignTime() + ",'unprint','淘宝自动抓取'  FROM DUAL  " +
+                        + "," + trades.get(i).getEndTime() + ",'entering','在录入'," + trades.get(i).getPostFee() + "," + trades.get(i).getPayment() + ","
+                        + trades.get(i).getTotalFee() + "," + trades.get(i).getConsignTime() + ",'unprint', '淘宝自动抓取'   FROM DUAL  " +
                         " WHERE NOT EXISTS ( select sa_id from sale WHERE SA_iD=" + said +  " )    AND  NOT EXISTS ( select SA_TAOBAOID from sale WHERE SA_TAOBAOID=" + trades.get(i).getTid() + "   )  ";
                 insertSqlsList.add(INSERTSALESql);
 
@@ -161,12 +163,12 @@ public class InsertServiceImpl implements InsertService {
                     //
                     Long sdid = baseDao.queryForObject("select saledetail_seq.nextval from dual", Long.class);
                     sdid = sdid +L;
-                    String INSERTSALEDETAILSql = "insert into saledetail(sd_id,sd_said,sd_code,sd_detno,sd_prodcode,sd_qty,sd_price,sd_total" +
+                    String INSERTSALEDETAILSql = "insert into saledetail(sd_remark,sd_id,sd_said,sd_code,sd_detno,sd_prodcode,sd_qty,sd_price,sd_total" +
                             ",sd_statuscode,sd_status,sd_discount)" +
-                            "  SELECT  " + sdid + " ," + said + "  ,' " +  sdid + " '," + k + "," + orders.get(j).getNumIid() + "," + orders.get(j).getNum() + "," + orders.get(j).getPrice() + " ," + orders.get(j).getTotalFee() +
-                            ",'entering','已审核'," + orders.get(j).getDiscountFee() + " FROM DUAL   WHERE NOT EXISTS ( select sd_id from saledetail " +
+                            "  SELECT  ' " + orders.get(j).getTitle() + " ' , "  + sdid + " ," + said + "  ,' " +  sdid + " '," + k + "," + orders.get(j).getNumIid() + "," + orders.get(j).getNum() + "," + orders.get(j).getPrice() + " ," + orders.get(j).getTotalFee() +
+                            ",'entering','在录入'," + orders.get(j).getDiscountFee() + " FROM DUAL   WHERE NOT EXISTS ( select sd_id from saledetail " +
                             "WHERE sd_id=" + sdid + "  )  AND  NOT EXISTS ( select sd_id from  sale left join  saledetail on sa_id=sd_said " +
-                            "WHERE SA_TAOBAOID = " + trades.get(i).getTid() +  "  and sd_detno = "  + orders.get(j).getNumIid() +" )  ";
+                            "WHERE SA_TAOBAOID = " + trades.get(i).getTid() +  "  and sd_detno = "  + k +" )  ";
                     insertSqlsList.add(INSERTSALEDETAILSql);
                 }
 

src/main/resources/application.yml

@@ -17,6 +17,12 @@ server:
         uri_encoding: UTF-8
     context-path:
         /EIS
+logging:
+  level:
+    org:
+      hibernate:
+        type: trace
+  config: classpath:logback-prod.xml
 
 action:
     api_action: /EIS/api