帷幄君成-富创-后端代码
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
sfd
2025-05-22 e5a96bc789ca0252e31fd2e01bec5e471a02c0d6 
 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(500);


        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);


    }


    /**


@@ -291,14 +293,20 @@


                    continue; // 跳过无效数据


                }




                ApsWorkOrderJob order = new ApsWorkOrderJob();


                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"));


                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) {


@@ -333,4 +341,30 @@


        apsWorkOrderJobMapper.batchInsertPartPlan();


    }




    /**


     * 同步钣金工单信息


     * */


    @Transactional


    @Override


    public void syncPlateOrderData() {


        apsWorkOrderJobMapper.deleteAllPlatePlan();


        apsWorkOrderJobMapper.batchInsertPlatePlan();


    }






    /**


     * 同步钣金工单信息


     * */


    @Transactional


    @Override


    public void syncGasPipingData() {


        apsWorkOrderJobMapper.deleteAllGasPiping();


        apsWorkOrderJobMapper.batchInsertGasPiping();


    }




    @Override


    public void deleteAllWorkOrderJob(){


         apsWorkOrderJobMapper.deleteAllWorkOrderJob();


    }




}