/* 淘宝订单抓取测试 author by shenl 2020-07-16 */

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

@@ -252,33 +252,40 @@ public class QueryServiceImpl implements QueryService {
             req.setBuyerOpenId("AAHm5d-EAAeGwJedwSHpg8bT");
             TradesSoldGetResponse rsp = client.execute(req, sessionKey);
             System.out.println(rsp.getBody());
+            List<String> insertSqlsList = new ArrayList<String>();
             //这里解析返回的数据
             //解析第一层---对象
             JSONObject jObject1 = new JSONObject(rsp.getBody());
             //解析第二层----数组
             JSONArray jsonArray2 = jObject1.getJSONArray("trades");
             //遍历数组获取元素----对象
-            for (int i = 0; i < jsonArray2.length(); i++) {
+
+
+            for (int i = 0; i < jsonArray2.size(); i++) {
                 //解析第三层----对象
                 JSONObject jObject3 = jsonArray2.getJSONObject(i);
                 Long said = baseDao.queryForObject("select sale_seq.nextval from dual", Long.class);
 
-                String INSERTSALESql = "insert into sale(sa_id,sa_date,sa_custname,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)" +
-                        "values(said,to_date(" + jObject3.getString("start_created") + ",'yyyy-MM-dd hh:mm:ss'),receiver_name,'rmb','1',receiver_name,receiver_name,receiver_address,shipping_type" +
-                        ",o2o_guide_name,modified,end_time,'entering','在录入',post_fee,payment,total_fee,consign_time,'unprint')";
-
+                String INSERTSALESql = "insert into sale(sa_id,sa_date,sa_custname,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)" +
+                        "values("+said+",to_date(" + jObject3.getString("start_created") + ",'yyyy-MM-dd hh:mm:ss'),"+ 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')";
+                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 (sd_said,?,num,price,total_fee,?,price/(1+sd_taxrate/100)" +
-                        ",price/(1+total_fee/100),customization,'entering','在录入',end_time,consign_time,discount_fee )";
-                baseDao.execute(INSERTSALESql);
-                baseDao.execute(INSERTSALEDETAILSql);
+                        "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);
 
             }
-
-
-            return "插入每日销售明细成功";
+            baseDao.execute(insertSqlsList);
+            return "插入销售明细成功";
         } catch (Exception e) {
             return e.getMessage();
         }