| | |
| | | import cn.hutool.core.util.IdUtil; |
| | | import com.alibaba.fastjson.JSONArray; |
| | | import com.alibaba.fastjson.JSONObject; |
| | | import com.alibaba.fastjson2.JSON; |
| | | import com.aps.common.core.utils.DateUtils; |
| | | import com.aps.common.core.utils.StringUtils; |
| | | import com.aps.common.core.utils.uuid.IdUtils; |
| | |
| | | import com.aps.job.mapper.ApsMaterialManagementJobMapper; |
| | | import com.aps.job.mapper.ApsWorkOrderJobLogMapper; |
| | | import com.aps.job.service.IApsMaterialManagementJobService; |
| | | 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-10 |
| | | */ |
| | | @Service |
| | | @Slf4j |
| | | public class ApsMaterialManagementJobServiceImpl implements IApsMaterialManagementJobService |
| | | { |
| | | @Autowired |
| | |
| | | jobLog.setResult("material:"+materialList.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 syncApsMaterialDataJob(int pageIndex, int pageSize, String orgCode, String itemCodeList) { |
| | | try { |
| | | log.info("开始清除物料中间表aps_material_management_job"); |
| | | apsMaterialManagementJobMapper.deleteApsMaterialJob(); |
| | | log.info("开始同步物料信息"); |
| | | boolean res = syncApsMaterialData(pageIndex, pageSize, orgCode, itemCodeList); |
| | | if(!res){ |
| | | return false; |
| | | } |
| | | log.info("开始清除物料表 aps_material_management"); |
| | | apsMaterialManagementJobMapper.deleteApsMaterial(); |
| | | log.info("插入数据到 aps_material_management"); |
| | | apsMaterialManagementJobMapper.insertIntoApsMaterialManagement(); |
| | | return true; |
| | | } catch (Exception e) { |