2020-11-19

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

@@ -3,7 +3,9 @@ package com.uas.eis.serviceImpl;
 
 import com.taobao.api.DefaultTaobaoClient;
 import com.taobao.api.TaobaoClient;
+import com.taobao.api.domain.Order;
 import com.taobao.api.domain.Trade;
+import com.taobao.api.internal.util.StringUtils;
 import com.uas.eis.dao.BaseDao;
 import com.uas.eis.service.InsertService;
 import net.sf.json.JSON;
@@ -13,10 +15,7 @@ import org.apache.log4j.Logger;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Timer;
-import java.util.TimerTask;
+import java.util.*;
 
 import com.taobao.api.request.TradesSoldGetRequest;
 import com.taobao.api.response.TradesSoldGetResponse;
@@ -31,7 +30,7 @@ public class InsertServiceImpl implements InsertService {
     // private static final String serverUrl = "http://gw.api.tbsandbox.com/router/rest";
     public static final String appKey = "31921866"; // 可替换为您的沙箱环境应用的appKey         /* 待修改 */
     public static final String appSecret = "7121c52d4c9970ba08bf09e2f525acd0"; // 可替换为您的沙箱环境应用的appSecret   /* 待修改 */
-    public static final String sessionKey = "31921866"; // 必须替换为沙箱账号授权得到的真实有效sessionKey    /* 待修改 */
+    public static final String sessionKey = "61024291979328cd09f0ba138f79236d66bd313f3364cf148715824"; // 必须替换为沙箱账号授权得到的真实有效sessionKey    /* 待修改 */
     public static Logger logger = Logger.getLogger(InsertServiceImpl.class);
 
     @Autowired
@@ -58,65 +57,92 @@ public class InsertServiceImpl implements InsertService {
 
     @Override
     public void getAllDate(){
-        TaobaoClient client1 = new DefaultTaobaoClient("http://auth.open.taobao.com/?appkey=31921866", "31921866", "7121c52d4c9970ba08bf09e2f525acd0");
+//        TaobaoClient client1 = new DefaultTaobaoClient("http://auth.open.taobao.com/?appkey=31921866", "31921866", "7121c52d4c9970ba08bf09e2f525acd0");
 
-
-        TaobaoClient client = new DefaultTaobaoClient("http://gw.api.taobao.com/router/rest=31921866", "31921866", "7121c52d4c9970ba08bf09e2f525acd0");
-//        TaobaoClient client2 = new DefaultTaobaoClient("http://container.open.taobao.com/container?authcode={授权码}", "31921866", "7121c52d4c9970ba08bf09e2f525acd0");
-//
-//        ((DefaultTaobaoClient) client).getRequestUrl("http://auth.open.taobao.com/?appkey=31921866")
-        //  查询卖家已卖出的交易数据
         TradesSoldGetRequest req = new TradesSoldGetRequest();
 
 
 
 
 //                    OpenTradesSoldGetRequest req = new OpenTradesSoldGetRequest();
-        req.setFields("tid,type,status,payment,orders,rx_audit_status");
-
-        //String sysdate = DateUtil.getCurrentDate();
-        //req.setStartCreated(StringUtils.parseDateTime(sysdate));
-        //req.setStartCreated(StringUtils.parseDateTime("2000-01-01 00:00:00"));
-        //req.setEndCreated(StringUtils.parseDateTime("2000-01-01 23:59:59"));
-        //交易成功
-        req.setStatus("TRADE_FINISHED");
+//        req.setFields("tid,type,status,payment,orders,rx_audit_status");
+//
+//        //String sysdate = DateUtil.getCurrentDate();
+//        //req.setStartCreated(StringUtils.parseDateTime(sysdate));
+//        //req.setStartCreated(StringUtils.parseDateTime("2000-01-01 00:00:00"));
+//        //req.setEndCreated(StringUtils.parseDateTime("2000-01-01 23:59:59"));
+//        //交易成功
+//        req.setStatus("TRADE_FINISHED");
 //            req.setBuyerNick("zhangsan");
-//            req.setType("game_equipment");
-        req.setExtType("service");
-//            req.setRateStatus("RATE_UNBUYER");
-//            req.setTag("time_card");
-//            req.setPageNo(1L);
-//            req.setPageSize(40L);
-        req.setUseHasNext(true);
-        req.setBuyerOpenId("AAHm5d-EAAeGwJedwSHpg8bT");
-//                    OpenTradesSoldGetResponse rsp = client.execute(req, sessionKey);
+////            req.setType("game_equipment");
+//        req.setExtType("service");
+////            req.setRateStatus("RATE_UNBUYER");
+////            req.setTag("time_card");
+////            req.setPageNo(1L);
+////            req.setPageSize(40L);
+//        req.setUseHasNext(true);
+//        req.setBuyerOpenId("AAHm5d-EAAeGwJedwSHpg8bT");
+////                    OpenTradesSoldGetResponse rsp = client.execute(req, sessionKey);
+        TaobaoClient client = new DefaultTaobaoClient("http://gw.api.taobao.com/router/rest", "31921866", "7121c52d4c9970ba08bf09e2f525acd0");
+////        TaobaoClient client2 = new DefaultTaobaoClient("http://container.open.taobao.com/container?authcode={授权码}", "31921866", "7121c52d4c9970ba08bf09e2f525acd0");
+////
+////        ((DefaultTaobaoClient) client).getRequestUrl("http://auth.open.taobao.com/?appkey=31921866")
+//        //  查询卖家已卖出的交易数据
+//
+
+        req.setFields("tid,type,status,payment,orders,rx_audit_status,trades");
+//        req.setStartCreated(StringUtils.parseDateTime("2000-01-01 00:00:00"));
+//        req.setEndCreated(StringUtils.parseDateTime("2020-12-01 23:59:59"));
+//        req.setStatus("ALL_WAIT_PAY");
+//        req.setBuyerNick("");
+//        req.setType("game_equipment");
+//        req.setExtType("service");
+//        req.setRateStatus("RATE_UNBUYER");
+//        req.setTag("time_card");
+//        req.setPageNo(1L);
+//        req.setPageSize(40L);
+//        req.setUseHasNext(true);
+//        req.setBuyerOpenId("AAHm5d-EAAeGwJedwSHpg8bT");
 
         try {
 
-            TradesSoldGetResponse rsp = client.execute(req, sessionKey);
+            TradesSoldGetResponse rsp = client.execute(req, "61024291979328cd09f0ba138f79236d66bd313f3364cf148715824");
             System.out.println(rsp.getBody());
             List<String> insertSqlsList = new ArrayList<String>();
             //这里解析返回的数据
 
+//            List<Map<String, Object>>  trades = rsp.getTrades();
+//            List<Map<String, Object>> resultList = new ArrayList<Map<String,Object>>();
+//            List<Map<String, Object>> resultList =rsp.getTrades();
             List<Trade> trades = rsp.getTrades();
 
+            //receiver_name
+//            Object  sss = trades.get(1).getReceiverName();
+
+
+
+
+
+
+
 
 //                    //解析第一层---对象
             //JSONObject jObject1 = new JSONObject(rsp.getBody());
             //解析第二层----数组
-            JSONArray jsonArray2 = JSONArray.fromObject(trades);
+//            JSONArray jsonArray2 = JSONArray.fromObject(trades);
             //JSONArray jsonArray2 = jObject1.getJSONArray();
             //遍历数组获取元素----对象
-            if (jsonArray2.size() == 0) {
+            if (trades.size() == 0) {
                 logger.info(this.getClass() + " 未录入淘宝订单");
             } else {
-                for (int i = 0; i < jsonArray2.size(); i++) {
+                for (int i = 0; i < 1; i++) {    //trades.size()
                     //解析第三层----对象
-                    JSONObject jObject3 = jsonArray2.getJSONObject(i);
+//                    JSONObject jObject3 = jsonArray2.getJSONObject(i);
+
                     /*  插入淘宝订单ID  sa_tradeid 字段 alter table sale  add sa_tradeid number; */
-                    Long sa_tradeid = baseDao.queryForObject("select sa_tradeid from sale where sa_tradeid =" + jObject3.getInt("tid"), Long.class);
+                    Long sa_tradeid = baseDao.queryForObject("select sa_tradeid from sale where sa_tradeid =" + trades.get(i).getTid(), Long.class);
                     /*  存在未 插入的淘宝订单 时 执行 插入操作  */
-                    while (sa_tradeid == null) {
+//                    while (sa_tradeid == null) {
                         Long said = baseDao.queryForObject("select sale_seq.nextval from dual", Long.class);
 
 
@@ -127,19 +153,28 @@ public class InsertServiceImpl implements InsertService {
                                 ",sa_transport,sa_seller,sa_updatedate" +
                                 ",sa_enddate,sa_statuscode,sa_status,sa_fare,sa_total" +
                                 ",sa_recamount,sa_plandelivery,sa_printstatuscode)" +
-                                "values(" + said + "," + jObject3.getInt("tid") + "," + sa_code + "+to_date(" + jObject3.getString("start_created") + ",'yyyy-MM-dd hh:mm:ss'),sysdate" + jObject3.getString("receiver_name") + ",'rmb','1',"
-                                + jObject3.getString("receiver_name") + "," + jObject3.getString("receiver_name") + "," + jObject3.getString("receiver_address") + ","
-                                + jObject3.getString("shipping_type") + "," + jObject3.getString("o2o_guide_name") + "," + jObject3.getString("modified")
-                                + "," + jObject3.getString("end_time") + ",'entering','在录入'," + jObject3.getInt("post_fee") + "," + jObject3.getInt("payment") + ","
-                                + jObject3.getInt("total_fee") + "," + jObject3.getString("consign_time") + ",'unprint')";
+                                "  values(" + said + "," + trades.get(i).getTid() + "," + sa_code + ",sysdate,sysdate," + trades.get(i).getReceiverName()+ ",'rmb','1',"
+                                + trades.get(i).getReceiverName() + "," + trades.get(i).getReceiverName()+ "," + 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')";
                         insertSqlsList.add(INSERTSALESql);
-                        String INSERTSALEDETAILSql = "insert into saledetail(sd_said,sd_detno,sd_qty,sd_delivery,sd_price,sd_total,sd_taxrate,sd_costprice" +
-                                ",sd_taxtotal,sd_description,sd_statuscode,sd_status,sd_enddate,sd_senddate,sd_discount)" +
-                                "values (" + said + ",?," + jObject3.getInt("num") + "," + jObject3.getInt("price") + " ," + jObject3.getInt("total_fee") + " ,?," + jObject3.getInt("price") + " /(1+" + jObject3.getInt("sd_taxrate") + " /100)" +
-                                ",price/(1+" + jObject3.getInt("total_fee") + "/100),customization,'entering','在录入',end_time,consign_time," + jObject3.getInt("discount_fee") + "  )";
-                        insertSqlsList.add(INSERTSALEDETAILSql);
-                    }
+
+                        List<Order> orders = trades.get(i).getOrders();
+                        for (int j= 0; j < 1; j++) {   //orders.size()
+                                    int k=j+1;
+                            //sd_enddate  ,sd_senddate ,to_date('  "+orders.get(j).getEndTime()+ "','yyyy-MM-dd hh24:mi:ss'),to_date('" +orders.get(j).getConsignTime()+"','yyyy-MM-dd hh24:mi:ss'),
+                            //
+                            Long sdid = baseDao.queryForObject("select saledetail_seq.nextval from dual", Long.class);
+                            String INSERTSALEDETAILSql = "insert into saledetail(sd_id,sd_said,sd_detno,sd_qty,sd_price,sd_total" +
+                                    ",sd_statuscode,sd_status,sd_discount)" +
+                                    "  values ( "+sdid+" ,"  + said + ","+k+"," + orders.get(j).getNum() + "," + orders.get(j).getPrice() + " ," + orders.get(j).getTotalFee() +
+                                    ",'entering','已审核',"+ orders.get(j).getDiscountFee() + "  )";
+                            insertSqlsList.add(INSERTSALEDETAILSql);
+                        }
+
                 }
+                System.out.println(insertSqlsList);
                 baseDao.execute(insertSqlsList);
                 logger.info(this.getClass() + "插入销售明细成功");
             }