| | |
| | | package com.aps.job.service.impl; |
| | | |
| | | import cn.hutool.core.util.IdUtil; |
| | | import com.alibaba.fastjson.JSON; |
| | | import com.alibaba.fastjson.JSONArray; |
| | | import com.alibaba.fastjson.JSONObject; |
| | | import com.aps.common.core.utils.DateUtils; |
| | |
| | | import com.aps.job.mapper.ApsMaterialStorageManagementJobMapper; |
| | | import com.aps.job.mapper.ApsWorkOrderJobLogMapper; |
| | | import com.aps.job.service.IApsMaterialStorageManagementJobService; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.beans.factory.annotation.Value; |
| | | import org.springframework.http.HttpEntity; |
| | |
| | | * @date 2025-05-08 |
| | | */ |
| | | @Service |
| | | @Slf4j |
| | | public class ApsMaterialStorageManagementJobServiceImpl implements IApsMaterialStorageManagementJobService |
| | | { |
| | | @Autowired |
| | |
| | | jobLog.setResult("storage:"+storageList.size()); |
| | | jobLog.setCreateBy(batchNum); |
| | | jobLogMapper.insertApsWorkOrderJobLog(jobLog); |
| | | log.info("物料同步:"+ JSON.toJSONString(jobLog)); |
| | | pageIndex++; |
| | | }else{ |
| | | break; |
| | |
| | | jobLog.setResult("error"); |
| | | jobLog.setCreateBy(batchNum); |
| | | jobLogMapper.insertApsWorkOrderJobLog(jobLog); |
| | | log.info("物料同步异常:"+ JSON.toJSONString(jobLog)); |
| | | break; |
| | | } |
| | | } |
| | |
| | | jobLog.setResult("error"); |
| | | jobLog.setCreateBy(batchNum); |
| | | jobLogMapper.insertApsWorkOrderJobLog(jobLog); |
| | | log.info("物料同步异常:"+ JSON.toJSONString(jobLog)); |
| | | return false; |
| | | } |
| | | return true; |
| | |
| | | @Override |
| | | public boolean syncApsMaterialStorageDataJob(int pageIndex, int pageSize, String orgCode, String itemCodeList) { |
| | | try { |
| | | log.info("开始同步库存数据"); |
| | | log.info("delete ApsMaterialStorageJob"); |
| | | apsMaterialStorageManagementJobMapper.deleteApsMaterialStorageJob(); |
| | | log.info("sync ApsMaterialStorageData"); |
| | | boolean res = syncApsMaterialStorageData(pageIndex, pageSize, orgCode, itemCodeList); |
| | | if(!res){ |
| | | return false; |
| | | } |
| | | log.info("delete ApsMaterialStorage"); |
| | | apsMaterialStorageManagementJobMapper.deleteApsMaterialStorage(); |
| | | log.info("insertInto ApsMaterialStorage "); |
| | | apsMaterialStorageManagementJobMapper.insertIntoApsMaterialStorage(); |
| | | return true; |
| | | } catch (Exception e) { |