zhanghl
2025-05-22 93e554de49b2b87c337df71ea9ece51dd4e1d31d
aps-modules/aps-job/src/main/java/com/aps/job/service/impl/ApsWorkOrderJobServiceImpl.java
@@ -1,9 +1,9 @@
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;
@@ -27,8 +27,6 @@
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import static com.aps.common.core.utils.uuid.IdUtils.getId;
/**
 * 工单同步Service业务层处理
@@ -161,7 +159,7 @@
        param.setDocState(Arrays.asList(0,1,2,4));
        param.setBeginDate(yesterdayMidnight.format(formatter));
        param.setEndDate(today.format(formatter));
        param.setPageSize(100);
        param.setPageSize(500);
        while (continueFlag){
            param.setPageIndex(currentPage);
            continueFlag= batchSaveByPager(param);
@@ -296,7 +294,7 @@
                }
                ApsWorkOrderJob order = result.getObject(i, ApsWorkOrderJob.class);
                order.setId(getId());
                order.setId(IdUtil.getSnowflakeNextId());
                order.setOrderId(jsonObject.getString("ID"));
                order.setCreateTime(DateUtils.getNowDate());
                order.setPageIndex(i);
@@ -305,6 +303,10 @@
                order.setProcessStatus("0");
                order.setOpStatus(jsonObject.getString("OpStatus"));
                order.setNextOpName(jsonObject.getString("NextOpName"));
                order.setLowOrderCode(jsonObject.getString("LowLevelCode"));
                order.setOrderCreateTime(jsonObject.getDate("CreatedOn"));
                order.setApproveOn(jsonObject.getDate("ApproveOn"));
                order.setStartWorkDate(jsonObject.getDate("StartDatetime"));
                jobs.add(order);
                orderIds.add(order.getOrderId());
            } catch (Exception e) {
@@ -360,4 +362,9 @@
        apsWorkOrderJobMapper.batchInsertGasPiping();
    }
    @Override
    public void deleteAllWorkOrderJob(){
         apsWorkOrderJobMapper.deleteAllWorkOrderJob();
    }
}