| | |
|---|
| | | import com.moral.util.HttpUtils; |
|---|
| | | import com.moral.util.WxMappingJackson2HttpMessageConverter; |
|---|
| | | |
|---|
| | | import com.xxl.job.core.biz.model.ReturnT; |
|---|
| | | import com.xxl.job.core.handler.annotation.XxlJob; |
|---|
| | | import org.apache.commons.lang3.time.DateUtils; |
|---|
| | | import org.apache.http.HttpResponse; |
|---|
| | |
|---|
| | | @Resource |
|---|
| | | private AQIService aqiService; |
|---|
| | | @XxlJob("insertData") |
|---|
| | | public void insertData(){ |
|---|
| | | public ReturnT insertData(){ |
|---|
| | | SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); |
|---|
| | | RestTemplate restTemplate = new RestTemplate(); |
|---|
| | | restTemplate.getMessageConverters().add(new WxMappingJackson2HttpMessageConverter()); |
|---|
| | |
|---|
| | | JSONObject json = JSON.parseObject(entity); |
|---|
| | | data = (Map<String, Object>) json.get("data"); |
|---|
| | | if (!ObjectUtils.isEmpty(data)) { |
|---|
| | | values = data.values(); |
|---|
| | | pubtime = format.parse(data.get("pubtime").toString()); |
|---|
| | | } |
|---|
| | | } catch (Exception e) { |
|---|
| | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | ReturnT returnT = new ReturnT(500, "插入数据成功！"); |
|---|
| | | return returnT; |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
