| | |
| | | import com.alibaba.fastjson.JSONArray; |
| | | import com.alibaba.fastjson.JSONObject; |
| | | import com.aps.common.core.utils.DateUtils; |
| | | import com.aps.job.domain.ApsWorkOrderJobLog; |
| | | import com.aps.job.mapper.ApsWorkOrderJobLogMapper; |
| | | import com.aps.job.param.ApsWorkOrderJobParam; |
| | | import org.springframework.beans.factory.annotation.Value; |
| | |
| | | Integer PageSize = 500; |
| | | Boolean continueFlag = true; |
| | | /* while (continueFlag){*/ |
| | | |
| | | ApsWorkOrderJobLog log = new ApsWorkOrderJobLog(); |
| | | |
| | | String requestString = JSONObject.toJSONString(param); |
| | | HttpEntity<String> request = new HttpEntity<>(requestString, headers); |
| | | ResponseEntity<String> response = restTemplate.postForEntity(getWorkOrderUrl, request, String.class); |
| | | log.setRequestData(requestString); |
| | | log.setResponseData(response.getBody()); |
| | | log.setPageNum(Long.valueOf(PageIndex)); |
| | | log.setPageCount(Long.valueOf(PageSize)); |
| | | log.setCreateTime(); |
| | | jobLogMapper.insertApsWorkOrderJobLog(log) |
| | | if (response.getStatusCode().is2xxSuccessful()) { |
| | | JSONObject responseBodyJson = JSONObject.parseObject(response.getBody()); |
| | | if ("200".equals(responseBodyJson.getString("status"))) { |
| | |
| | | } |
| | | apsWorkOrderJobMapper.batchInsertApsWorkOrderJob(jobs); |
| | | } |
| | | |
| | | } |
| | | |
| | | } |
| | | |
| | | } |
| | | } |