NmmsImportServiceImpl.java 2.2 KB
package com.tianbo.analysis.service.imp;

import com.tianbo.analysis.dao.ORIGINMANIFESTMASTERMapper;
import com.tianbo.analysis.dao.OriginmanifestsecondaryMapper;
import com.tianbo.analysis.model.ORIGINMANIFESTMASTER;
import com.tianbo.analysis.model.Originmanifestsecondary;
import com.tianbo.analysis.service.NmmsImportService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;

/**
 * @author shenhl
 * <p>
 * 2022/2/15/15:14
 */
@Service
@Slf4j
public class NmmsImportServiceImpl implements NmmsImportService{

    @Autowired
    OriginmanifestsecondaryMapper originmanifestsecondaryMapper;

    @Autowired
    ORIGINMANIFESTMASTERMapper originmanifestmasterMapper;

    @Override
    public int mountAwbh(ORIGINMANIFESTMASTER master) {

        int w = 0;
        try {
            String awba = "";
            List<String> awbhIds = master.getAwbhIds();
            // 查询该分单绑定的主单id
            for (int i=0; i< awbhIds.size(); i++){
                Originmanifestsecondary originmanifestsecondary = originmanifestsecondaryMapper.findAwba(awbhIds.get(i));
                log.info("查询的主单id:{}", originmanifestsecondary);
                if (originmanifestsecondary != null){
                    awba = originmanifestsecondary.getWaybillnomaster();
                    // 查询需要挂载的主单id
                    ORIGINMANIFESTMASTER originmanifestmaster = originmanifestmasterMapper.findAwba(awba, master.getFlightno(), master.getFlightDate());
                    // 修改分单表 所绑定的主单id
                    if (originmanifestmaster!=null){
                        log.info("挂载主单的id:{}", originmanifestmaster);
                        log.info("修改分单数据参数:{}", awbhIds, originmanifestmaster.getAutoid());
                        w = originmanifestsecondaryMapper.updateMasterAutoId(awbhIds.get(i), originmanifestmaster.getAutoid());
                        log.info("修改后的状态:{}", w);
                    }
                }
            }
            return w;
        }catch (Exception e){
            e.printStackTrace();
            return w;
        }
    }
}