2020-11-27

循环抓取多店铺的sessionkey.

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

@@ -79,7 +79,12 @@ public class InsertServiceImpl implements InsertService {
 //          有淘宝自动抓取的 订单 ，则调用增量备份
         List<Trade> trades = new ArrayList<Trade>();
         String sa_remark = baseDao.queryForObject("select distinct sa_remark from sale where sa_remark ='淘宝自动抓取' ", String.class);
-        String session_Key = baseDao.queryForObject(" select  tb_code from ( select  row_number() over( order by tb_date desc ) xuhao , tb_code from tbauthorization ) where xuhao=1 ", String.class);
+
+        //String session_Key = baseDao.queryForObject(" select  tb_code from ( select  row_number() over(partition  by TB_OPENUID order by tb_date desc ) xuhao , tb_code from tbauthorization ) where xuhao=1 ", String.class);
+        List<Map<String,Object>> list = baseDao.queryForList(" select  tb_code from ( select  row_number() over(partition  by TB_OPENUID order by tb_date desc ) xuhao , tb_code from tbauthorization ) where xuhao=1");
+        for (int z = 0; z < list.size(); z++) {
+            String session_Key = list.get(z).get("tb_code").toString();
+
         if (sa_remark == null || sa_remark == "") {
             TaobaoClient client = new DefaultTaobaoClient("http://39.98.201.114:30001/router/rest", "31921866", "7121c52d4c9970ba08bf09e2f525acd0");
             TradesSoldGetRequest req = new TradesSoldGetRequest();  //正常备份接口
@@ -235,7 +240,7 @@ public class InsertServiceImpl implements InsertService {
                 logger.info( e.getMessage() );
             }
 
-
+        }
 
 
             logger.info(this.getClass() + "插入销售明细成功");