| | |
| | | import com.aps.job.mapper.ApsWorkOrderJobMapper; |
| | | import com.aps.job.domain.ApsWorkOrderJob; |
| | | import com.aps.job.service.IApsWorkOrderJobService; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | | import org.springframework.web.client.RestTemplate; |
| | | |
| | | /** |
| | |
| | | } |
| | | |
| | | |
| | | @Transactional |
| | | @Override |
| | | public void batchInsertApsWorkOrderJob(ApsWorkOrderJobParam param) { |
| | | |
| | | HttpHeaders headers = new HttpHeaders(); |
| | | headers.setContentType(MediaType.APPLICATION_JSON); |
| | | Integer PageIndex = 1; |
| | | Integer PageSize = 500; |
| | | Integer PageIndex = 3; |
| | | Integer PageSize = 600; |
| | | Boolean continueFlag = true; |
| | | /* while (continueFlag){*/ |
| | | |
| | |
| | | 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) |
| | | log.setCreateTime(DateUtils.getNowDate()); |
| | | jobLogMapper.insertApsWorkOrderJobLog(log); |
| | | if (response.getStatusCode().is2xxSuccessful()) { |
| | | JSONObject responseBodyJson = JSONObject.parseObject(response.getBody()); |
| | | if ("200".equals(responseBodyJson.getString("status"))) { |
| | |
| | | } |
| | | apsWorkOrderJobMapper.batchInsertApsWorkOrderJob(jobs); |
| | | } |
| | | log.setResult("success"); |
| | | }else{ |
| | | log.setResponseData(response.getBody()); |
| | | } |
| | | } |
| | | else { |
| | | log.setResponseData(response.getBody()); |
| | | log.setResult("request fail"); |
| | | } |
| | | jobLogMapper.updateApsWorkOrderJobLog(log); |
| | | } |
| | | } |