帷幄君成-富创-后端代码
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
huangjiayang
2025-04-29 d320f67a7edbe887baac890a639c16e78432f2a3 
 aps-modules/aps-job/src/main/java/com/aps/job/service/impl/ApsWorkOrderJobServiceImpl.java


@@ -1,31 +1,32 @@


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.job.domain.ApsWorkOrderJob;


import com.aps.job.domain.ApsWorkOrderJobLog;


import com.aps.job.mapper.ApsWorkOrderJobLogMapper;


import com.aps.job.mapper.ApsWorkOrderJobMapper;


import com.aps.job.param.ApsWorkOrderJobParam;


import com.aps.job.service.IApsWorkOrderJobService;


import lombok.extern.slf4j.Slf4j;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.beans.factory.annotation.Value;


import org.springframework.http.HttpEntity;


import org.springframework.http.HttpHeaders;


import org.springframework.http.MediaType;


import org.springframework.http.ResponseEntity;


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;


import org.springframework.web.client.RestTemplate;




import java.time.LocalDate;


import java.time.LocalDateTime;


import java.time.format.DateTimeFormatter;


import java.util.ArrayList;


import java.util.Arrays;


import java.util.List;




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 lombok.extern.slf4j.Slf4j;


import org.springframework.beans.factory.annotation.Value;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.http.HttpEntity;


import org.springframework.http.HttpHeaders;


import org.springframework.http.MediaType;


import org.springframework.http.ResponseEntity;


import org.springframework.stereotype.Service;


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;




/**


 * 工单同步Service业务层处理


@@ -158,7 +159,7 @@


        param.setDocState(Arrays.asList(0,1,2,4));


        param.setBeginDate(yesterdayMidnight.format(formatter));


        param.setEndDate(today.format(formatter));


        param.setPageSize(1000);


        param.setPageSize(100);


        while (continueFlag){


            param.setPageIndex(currentPage);


            continueFlag= batchSaveByPager(param);


@@ -178,6 +179,7 @@


        jobLog.setCreateTime(DateUtils.getNowDate());


        jobLog.setBizType("work_order");


        jobLogMapper.insertApsWorkOrderJobLog(jobLog);


        log.info("work_order_request：{}", JSONObject.toJSONString(jobLog));


        return requestOnePage(jobLog);


    }


    /**


@@ -292,13 +294,15 @@


                }




                ApsWorkOrderJob order = result.getObject(i, ApsWorkOrderJob.class);


                order.setId(IdUtil.getSnowflakeNextId());


                order.setOrderId(jsonObject.getString("ID"));


                order.setCreateTime(DateUtils.getNowDate());


                order.setPageIndex(i);


                order.setPageNum(pageNum);


                order.setDelFlag("0");


                order.setProcessStatus("0");




                order.setOpStatus(jsonObject.getString("OpStatus"));


                order.setNextOpName(jsonObject.getString("NextOpName"));


                jobs.add(order);


                orderIds.add(order.getOrderId());


            } catch (Exception e) {


@@ -343,4 +347,15 @@


        apsWorkOrderJobMapper.batchInsertPlatePlan();


    }






    /**


     * 同步钣金工单信息


     * */


    @Transactional


    @Override


    public void syncGasPipingData() {


        apsWorkOrderJobMapper.deleteAllGasPiping();


        apsWorkOrderJobMapper.batchInsertGasPiping();


    }




}