| | |
| | | package com.aps.job.service.impl; |
| | | |
| | | import cn.hutool.core.util.IdUtil; |
| | | import com.alibaba.fastjson.JSONArray; |
| | | import com.alibaba.fastjson.JSONObject; |
| | | import com.aps.common.core.utils.DateUtils; |
| | | import com.aps.common.core.utils.uuid.Sequence; |
| | | import com.aps.job.domain.ApsWorkOrderJob; |
| | | import com.aps.job.domain.ApsWorkOrderJobLog; |
| | | import com.aps.job.mapper.ApsWorkOrderJobLogMapper; |
| | |
| | | |
| | | @Autowired |
| | | private ApsWorkOrderJobLogMapper jobLogMapper; |
| | | |
| | | @Autowired |
| | | private Sequence sequence; |
| | | |
| | | /** |
| | | * 查询工单同步 |
| | |
| | | param.setDocState(Arrays.asList(0,1,2,4)); |
| | | param.setBeginDate(yesterdayMidnight.format(formatter)); |
| | | param.setEndDate(today.format(formatter)); |
| | | param.setPageSize(500); |
| | | param.setPageSize(100); |
| | | while (continueFlag){ |
| | | param.setPageIndex(currentPage); |
| | | continueFlag= batchSaveByPager(param); |
| | |
| | | jobLog.setCreateTime(DateUtils.getNowDate()); |
| | | jobLog.setBizType("work_order"); |
| | | jobLogMapper.insertApsWorkOrderJobLog(jobLog); |
| | | log.info("work_order_request:{}", JSONObject.toJSONString(jobLog)); |
| | | return requestOnePage(jobLog); |
| | | } |
| | | /** |
| | |
| | | } |
| | | |
| | | ApsWorkOrderJob order = result.getObject(i, ApsWorkOrderJob.class); |
| | | order.setId(sequence.nextId()); |
| | | order.setId(IdUtil.getSnowflakeNextId()); |
| | | order.setOrderId(jsonObject.getString("ID")); |
| | | order.setCreateTime(DateUtils.getNowDate()); |
| | | order.setPageIndex(i); |