定时任务-调用接口传参是fastjson

一时失言乱红尘 2021-09-29 09:30 372阅读 0赞

@Scheduled(cron = “0 \*/30 \* \* \* ?”)  
//@Scheduled(cron = “0 0 2 \* \* ?”)  
public void getChannelInfoFromYiDian() \{  
String url = “”;  
HttpClient httpclient = null;  
PostMethod post = null;  
String page\_size = “1000”;  
String page\_no = “1”;  
String tokenID=“7E77B2680CD33FD7CB3BD731D2151534”;  
try \{  
//创建连接  
httpclient = new HttpClient();  
post = new PostMethod(url);  
// 设置编码方式  
post.getParams().setParameter(HttpMethodParams.HTTP\_CONTENT\_CHARSET, “UTF-8”);  
// 添加参数  
Map<String,Object> map=new HashMap<>();  
map.put(“tokenID”,tokenID);  
map.put(“page\_size”,page\_size);  
map.put(“page\_no”,page\_no);  
JSONObject jsonObject= new JSONObject(map);  
RequestEntity requestEntity=new StringRequestEntity(jsonObject.toString(),“application/json”,“UTF-8”);  
post.setRequestEntity(requestEntity);  
post.setRequestHeader(“Content-Type”,“application/json”);  
post.getParams().setParameter(HttpMethodParams.SO\_TIMEOUT, 5000);//设置超时时间  
/*post.addParameter(“tokenID”, tokenID);  
post.addParameter(“page\_size”, page\_size);  
post.addParameter(“page\_no”, page\_no);*/  
// 执行请求  
httpclient.executeMethod(post);  
// 接口返回信息  
String info = new String(post.getResponseBody(), “UTF-8”);  
System.out.println(“频道信息”+info);  
JSONObject jsonObject2=JSONObject.parseObject(info);  
JSONObject jsonObject1=jsonObject2.getJSONObject(“data”);  
JSONArray jsonArray=jsonObject1.getJSONArray(“records”);  
if(null==jsonArray)\{  
Map<String,Object> channels=new HashMap<>();  
channels.put(“6”,“记者”);  
channels.put(“1”,“看点”);  
channels.put(“03”,“头条”);  
channels.put(“04”,“情报”);  
channels.put(“2”,“本地新闻”);  
channels.put(“5”,“推荐”);  
channels.put(“36”,“味道”);  
channels.put(“37”,“房产”);  
channels.put(“38”,“精读”);  
channels.put(“40”,“旅游”);  
channels.put(“89”,“汽车”);  
channels.put(“90”,“财经”);

AdDeliveryServiceImpl.channels=channels;
    
            }else{
                Map<String,Object> maps =new HashMap<>();
                for(int i=0; i<jsonArray.size();i++){
                    JSONObject jsonObject3=jsonArray.getJSONObject(i);
                    String inner_id=jsonObject3.getString("inner_id");
                    String channel_name=jsonObject3.getString("channel_name");
                    maps.put(inner_id,channel_name);
                }
                maps.put("03","头条");
                maps.put("04","情报");
                AdDeliveryServiceImpl.channels=maps;
                //logger.info("aaaaaaaaaaaaaaaaaaaaaa"+maps.toString());
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            // 关闭连接，释放资源
            post.releaseConnection();
            ((SimpleHttpConnectionManager) httpclient.getHttpConnectionManager()).shutdown();
        }
    
    }