ErpServiceImpl.java 2.58 KB
package com.huaheng.api.erp.service;

import com.huaheng.api.erp.domain.ErpMaterialSync;
import com.huaheng.common.constant.QuantityConstant;
import com.huaheng.framework.web.domain.AjaxResult;
import com.huaheng.pc.config.material.domain.Material;
import com.huaheng.pc.config.material.service.MaterialService;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.Date;
import java.util.List;


@Service
public class ErpServiceImpl implements ErpService {

    @Resource
    private MaterialService materialService;

    @Override
    public AjaxResult materialSync(List<ErpMaterialSync> masterDataList) {
        for (ErpMaterialSync erpMaterial : masterDataList) {
            AjaxResult ajaxResult = syncSingleMaterial(erpMaterial);
            if (ajaxResult.hasErr()) {
                return ajaxResult;
            }
        }
        return AjaxResult.success("物料信息同步成功");
    }

    private AjaxResult syncSingleMaterial(ErpMaterialSync erpMaterial) {
        String warehouseCode = QuantityConstant.DEFAULT_WAREHOUSE;
        String companyCode = QuantityConstant.COMPANYCODE;
        Material material = materialService.getMaterialByCode(erpMaterial.getSku(), warehouseCode);
        if (material != null) {
            material.setName(erpMaterial.getSkuName());
            material.setUnit(erpMaterial.getUom());
            material.setSpec(erpMaterial.getSkuSpec());
            material.setLastUpdated(new Date());
            material.setLastUpdatedBy("ERP");
            if (!materialService.updateById(material)) {
                return AjaxResult.error("更新物料失败,物料编码:" + erpMaterial.getSku());
            }
        } else {
            material = new Material();
            material.setCode(erpMaterial.getSku());
            material.setName(erpMaterial.getSkuName());
            material.setUnit(erpMaterial.getUom());
            material.setSpec(erpMaterial.getSkuSpec());
            material.setWarehouseCode(warehouseCode);
            material.setCompanyCode(companyCode);
            material.setEnable(true);
            material.setDeleted(false);
            material.setCreated(new Date());
            material.setCreatedBy("ERP");
            material.setLastUpdated(new Date());
            material.setLastUpdatedBy("ERP");
            if (!materialService.save(material)) {
                return AjaxResult.error("新增物料失败,物料编码:" + erpMaterial.getSku());
            }
        }
        return AjaxResult.success("物料同步成功,物料编码:" + erpMaterial.getSku());
    }
}