|
|
@@ -168,53 +168,71 @@ public class AdminUserServiceImpl implements AdminUserService {
|
|
|
@Override
|
|
|
public String test(String param) throws Exception {
|
|
|
|
|
|
- Wrapper wrapper = new EntityWrapper();
|
|
|
-// wrapper.ne("order_status_name","卖家已发货");
|
|
|
- wrapper.eq("dang_order_status","未发货");
|
|
|
- List<ShopOrder> list = shopOrderMapper.selectList(wrapper);
|
|
|
- for (ShopOrder shopOrder: list
|
|
|
+ List<ShopAccount> listAccount = shopAccountMapper.selectList(new EntityWrapper<ShopAccount>().eq("delete_flag",0));
|
|
|
+ for (ShopAccount shopAccount:listAccount
|
|
|
) {
|
|
|
- ShopAccount shopAccount = shopAccountMapper.selectById(shopOrder.getAccountId());
|
|
|
flushCookie(shopAccount);
|
|
|
CloseableHttpClient httpClient = HttpClientBuilder.create().build();
|
|
|
- HttpGet get = new HttpGet("https://shop.kongfz.com/buyer/order/getOrderInfo/?orderId="+shopOrder.getOrderId());
|
|
|
+ HttpGet get = new HttpGet("https://shop.kongfz.com/buyer/order/index/?pageCurr=1&pageShow=9999&orderStatus=ShippedToReceipt");
|
|
|
+ //这里可以设置请求参数，token等
|
|
|
+ get.addHeader("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/58.0.3029.81 Safari/537.36");
|
|
|
+ get.addHeader("cookie",shopAccount.getFuziCookie());
|
|
|
+
|
|
|
+ CloseableHttpResponse response = httpClient.execute(get);//执行获取响应
|
|
|
try{
|
|
|
- //这里可以设置请求参数，token等
|
|
|
- get.addHeader("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/58.0.3029.81 Safari/537.36");
|
|
|
- get.addHeader("cookie",shopAccount.getFuziCookie());
|
|
|
- HttpResponse response = httpClient.execute(get);//执行获取响应
|
|
|
+
|
|
|
if (response.getStatusLine().getStatusCode() == HttpStatus.SC_OK){//根据状态码处理
|
|
|
+ String strTmp= EntityUtils.toString(response.getEntity(),"UTF-8");
|
|
|
//返回字符串
|
|
|
- String res = unicodeToString(EntityUtils.toString(response.getEntity(),"UTF-8"));
|
|
|
- System.out.println(res);
|
|
|
+ String res = unicodeToString(strTmp);
|
|
|
JSONObject datas = JSONObject.parseObject(res);//转换成JSON格式
|
|
|
Boolean status = (Boolean) datas.get("status");//获取返回数据状态，get获取的字段需要根据提供的返回值去获取
|
|
|
- ShopOrder data = JSONObject.parseObject(datas.get("data").toString(),ShopOrder.class);//"data"是根据返回值设定
|
|
|
- ShopOrder tmp = new ShopOrder();
|
|
|
- tmp.setOrderId(data.getOrderId());
|
|
|
- tmp = shopOrderMapper.selectOne(tmp);
|
|
|
- data.setAccountId(shopAccount.getId());
|
|
|
- if(tmp == null){
|
|
|
- data.setDangOrder(shopOrder.getDangOrder());
|
|
|
- data.setGmtCreate(new Date());
|
|
|
- data.setGmtUpdate(new Date());
|
|
|
- shopOrderMapper.insert(data);
|
|
|
- }
|
|
|
- else{
|
|
|
- data.setDangOrder(shopOrder.getDangOrder());
|
|
|
- data.setOrderStatusName(shopOrder.getOrderStatusName());
|
|
|
- data.setGmtUpdate(new Date());
|
|
|
- shopOrderMapper.update(data,new EntityWrapper<ShopOrder>().eq("order_id",tmp.getOrderId()));
|
|
|
+ List<ShopOrder> data = JSONArray.parseArray(datas.get("data").toString(),ShopOrder.class);//"data"是根据返回值设定
|
|
|
+ for (ShopOrder tmp: data
|
|
|
+ ) {
|
|
|
+ //正则表达式，用于匹配非数字串，+号用于匹配出多个非数字串
|
|
|
+ String regEx="[^0-9]+";
|
|
|
+ Pattern pattern = Pattern.compile(regEx);
|
|
|
+ //用定义好的正则表达式拆分字符串，把字符串中的数字留出来
|
|
|
+ String[] cs = pattern.split(tmp.getRemarkText());
|
|
|
+ String dangOrder = "";
|
|
|
+ for (String str:cs
|
|
|
+ ) {
|
|
|
+ dangOrder += str;
|
|
|
+ }
|
|
|
+ tmp.setDangOrder(dangOrder);
|
|
|
+ tmp.setAccountId(shopAccount.getId());
|
|
|
+ Long time = Long.parseLong(tmp.getShippingTime());
|
|
|
+ SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
|
|
+ sdf.setTimeZone(TimeZone.getTimeZone("GMT"));
|
|
|
+ String time1 = sdf.format(new Date(time * 1000));
|
|
|
+ tmp.setShippingTime(time1);
|
|
|
+ tmp.setDeleteFlag(0);
|
|
|
+ tmp.setGmtUpdate(new Date());
|
|
|
+ tmp.setGmtCreate(new Date());
|
|
|
+ ShopOrder tt = new ShopOrder();
|
|
|
+ tt.setOrderId(tmp.getOrderId());
|
|
|
+ tt = shopOrderMapper.selectOne(tt);
|
|
|
+ if(tt == null){
|
|
|
+ shopOrderMapper.insert(tmp);
|
|
|
+ }
|
|
|
}
|
|
|
+
|
|
|
}
|
|
|
|
|
|
+
|
|
|
} catch (IOException e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
|
+ finally {
|
|
|
+ response.close();
|
|
|
+ httpClient.close();
|
|
|
+ }
|
|
|
}
|
|
|
Wrapper wrapper1 = new EntityWrapper();
|
|
|
wrapper1.eq("order_status_name","卖家已发货");
|
|
|
wrapper1.eq("dang_order_status","未发货");
|
|
|
+ wrapper1.orderBy("gmt_update",false);
|
|
|
List<ShopOrder> list1 = shopOrderMapper.selectList(wrapper1);
|
|
|
for (ShopOrder shopOrder: list1
|
|
|
) {
|
