【ADD】1.新增同步物料库存数据任务 2.增加刷新BOM数据功能代码

huangjiayang

2025-05-09 86637e6a48cc4511e34fe426d5a617e3ee018dfa

 aps-modules/aps-job/src/main/java/com/aps/job/service/impl/ApsBomHeaderJobServiceImpl.java

@@ -19,6 +19,7 @@
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.util.ArrayList;
@@ -39,9 +40,6 @@
    @Autowired
    private ApsBomLineJobMapper apsBomLineJobMapper;

    /**
     * 获取订单接口
     * */
    @Value("${u9.bomJobUrl}")
    private String getBomUrl;

@@ -223,4 +221,33 @@
        }
        return true;
    }

    /**
     * 全量同步BOM数据定时任务
     * @param pageIndex
     * @param pageSize
     * @param orgCode
     * @param itemCodeList
     * @return
     */
    @Transactional(rollbackFor = Exception.class)
    @Override
    public boolean syncBomDataJob(Integer pageIndex, Integer pageSize, String orgCode, String itemCodeList){
        try {
            apsBomHeaderJobMapper.deleteApsBomHeaderJob();
            apsBomLineJobMapper.deleteApsBomLineJob();
            boolean res = syncBomData(pageIndex, pageSize, orgCode, itemCodeList);
            if(!res){
                return false;
            }
            apsBomHeaderJobMapper.deleteApsBomHeader();
            apsBomLineJobMapper.deleteApsBomLine();
            apsBomHeaderJobMapper.insertIntoApsBomHeader();
            apsBomLineJobMapper.insertIntoApsBomLine();
        } catch (Exception e) {
            e.printStackTrace();
            throw new RuntimeException(e);
        }
        return true;
    }
}