apsbackend.git - Gitblit

			@@ -1,6 +1,7 @@
			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;
			@@ -11,6 +12,7 @@
			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;
			@@ -31,6 +33,7 @@
			* @date 2025-05-08
			*/
			@Service
			@Slf4j
			public class ApsMaterialStorageManagementJobServiceImpl implements IApsMaterialStorageManagementJobService
			{
			@Autowired
			@@ -174,6 +177,7 @@
			jobLog.setResult("storage:"+storageList.size());
			jobLog.setCreateBy(batchNum);
			jobLogMapper.insertApsWorkOrderJobLog(jobLog);
			log.info("物料同步："+ JSON.toJSONString(jobLog));
			pageIndex++;
			}else{
			break;
			@@ -188,6 +192,7 @@
			jobLog.setResult("error");
			jobLog.setCreateBy(batchNum);
			jobLogMapper.insertApsWorkOrderJobLog(jobLog);
			log.info("物料同步异常："+ JSON.toJSONString(jobLog));
			break;
			}
			}
			@@ -202,6 +207,7 @@
			jobLog.setResult("error");
			jobLog.setCreateBy(batchNum);
			jobLogMapper.insertApsWorkOrderJobLog(jobLog);
			log.info("物料同步异常："+ JSON.toJSONString(jobLog));
			return false;
			}
			return true;
			@@ -211,12 +217,17 @@
			@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) {