DAL-DAZHOU-TMSSHIP-API/src/main/java/com/steerinfo/dil/service/impl/TmsshipUnloadShipResultServiceImpl.java

package com.steerinfo.dil.service.impl;

import com.steerinfo.dil.feign.WmshboundFeign;
import com.steerinfo.dil.mapper.OmsshipInstructionsCapacityMapper;
import com.steerinfo.dil.mapper.TmsshipLoadShipResultMapper;
import com.steerinfo.dil.mapper.TmsshipTotalResultMapper;
import com.steerinfo.dil.model.OmsshipInstructionsCapacity;
import com.steerinfo.dil.model.TmsshipLoadShipResult;
import com.steerinfo.dil.model.TmsshipTotalResult;
import com.steerinfo.dil.model.TmsshipUnloadShipResult;
import com.steerinfo.dil.mapper.TmsshipUnloadShipResultMapper;
import com.steerinfo.dil.service.ITmsshipUnloadShipResultService;
import com.steerinfo.dil.util.DataChange;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.math.BigDecimal;
import java.time.LocalDate;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * TmsshipUnloadShipResult服务实现：
 * @author generator
 * @version 1.0-SNAPSHORT 2021-08-19 08:57
 * 类描述
 * 修订历史：
 * 日期：2021-08-19
 * 作者：generator
 * 参考：
 * 描述：TmsshipUnloadShipResult服务实现
 * @see null
 * @Copyright 湖南视拓信息技术股份有限公司. All rights reserved.
 */
@Service(value = "tmsshipUnloadShipResultService")
public class TmsshipUnloadShipResultServiceImpl implements ITmsshipUnloadShipResultService {

    @Autowired
    TmsshipUnloadShipResultMapper tmsshipUnloadShipResultMapper;
    @Autowired
    TmsshipTotalResultServiceImpl tmsshipTotalResultService;
    @Autowired
    TmsshipLoadShipResultMapper tmsshipLoadShipResultMapper;
    @Autowired
    WmshboundFeign wmshboundFeign;
    @Autowired
    TmsshipTotalResultMapper tmsshipTotalResultMapper;
    @Autowired
    OmsshipInstructionsCapacityMapper omsshipInstructionsCapacityMapper;


    /**
     * 得到最大id
     * @return
     */
    @Override
    public BigDecimal selectMaxId() {
        return tmsshipUnloadShipResultMapper.selectUnloadId();
    }

    /**
     * 新增卸船实绩
     * @param map
     * @return
     */
    @Override
    @Transactional
    public int insertUnloadShip(Map<String, Object> map) {
        Map<String,Object> mapVal = (Map<String, Object>) map.get("mapVal");
        Map<String,Object> unloadMap = (Map<String, Object>) map.get("unloadMap");
        BigDecimal downSwimPortId= DataChange.dataToBigDecimal(unloadMap.get("downSwimPortId"));
        BigDecimal portId= DataChange.dataToBigDecimal(unloadMap.get("portId"));
        TmsshipUnloadShipResult tmsshipUnloadShipResult = new TmsshipUnloadShipResult();
        BigDecimal resultId = selectMaxId();
        BigDecimal orderId = new BigDecimal((Integer) unloadMap.get("orderId"));
        BigDecimal totalResultId = tmsshipTotalResultService.getResultTotalId(orderId);
        //修改船舶状态
        TmsshipTotalResult tmsshipTotalResult=new TmsshipTotalResult();
        tmsshipTotalResult.setResultId(totalResultId);
        tmsshipTotalResult.setShipStatus(new BigDecimal(1));
        tmsshipTotalResultMapper.updateByPrimaryKeySelective(tmsshipTotalResult);
        if(mapVal.get("resultArrivalDate") != null && !"null".equals(mapVal.get("resultArrivalDate"))){
            Date resultArrivalDate = new Date((Long) mapVal.get("resultArrivalDate"));
            tmsshipUnloadShipResult.setResultArrivalDate(resultArrivalDate);
        }
        if(mapVal.get("resultStartTime") != null && !"null".equals(mapVal.get("resultStartTime"))){
            Date resultStartTime = new Date((Long) mapVal.get("resultStartTime"));
            tmsshipUnloadShipResult.setResultStartTime(resultStartTime);
        }
        if(mapVal.get("resultEndTime") != null && !"null".equals(mapVal.get("resultEndTime"))){
            Date resultEndTime = new Date((Long) mapVal.get("resultEndTime"));
            tmsshipUnloadShipResult.setResultEndTime(resultEndTime);
        }
        String resultStatus = (String) mapVal.get("resultStatus");
        // 设置属性值
        tmsshipUnloadShipResult.setResultId(resultId);
        tmsshipUnloadShipResult.setTotalResultId(totalResultId);
        tmsshipUnloadShipResult.setResultStatus(resultStatus);
        // 设置常规字段
        tmsshipUnloadShipResult.setInsertTime(new Date());
        tmsshipUnloadShipResult.setUpdateTime(new Date());
        tmsshipUnloadShipResult.setInsertUsername("admin");
        tmsshipUnloadShipResult.setUpdateUsername("admin");
        tmsshipUnloadShipResult.setInsertUpdateRemark("无");
        //锁定船只
        OmsshipInstructionsCapacity omsshipInstructionsCapacity=new OmsshipInstructionsCapacity();
        omsshipInstructionsCapacity.setInstructionsCapacityId(DataChange.dataToBigDecimal(unloadMap.get("instructionsCapacityId")));
        //锁定
        omsshipInstructionsCapacity.setDeleted(new BigDecimal(3));
        omsshipInstructionsCapacityMapper.updateByPrimaryKeySelective(omsshipInstructionsCapacity);
        // 新增出库实绩
        Map<String,Object> totalId = new HashMap<>();
        totalId.put("totalResultId",totalResultId);
        List<Map<String,Object>> tmsshipLoadShipResults = tmsshipLoadShipResultMapper.getBatchIdForOut(totalId);
        Map<String,Object> tmsshipLoadShipResult = tmsshipLoadShipResults.get(0);
        Map<String,Object> mapValue = new HashMap<>();
        mapValue.put("batchId",tmsshipLoadShipResult.get("batchId"));
        mapValue.put("portId",portId);
        mapValue.put("resultMaterialNumber",tmsshipLoadShipResult.get("resultMaterialNumber"));
        wmshboundFeign.addWarehousingResult(mapValue);

        return tmsshipUnloadShipResultMapper.insert(tmsshipUnloadShipResult);
    }

    /**
     * 通过主键删除卸船实绩
     * @param resultId
     * @return
     */
    @Override
    public int deleteUnloadShip(BigDecimal resultId) {
        TmsshipUnloadShipResult tmsshipUnloadShipResult = selectUnloadShip(resultId);
        tmsshipUnloadShipResult.setDeleted(new BigDecimal(1));
        return tmsshipUnloadShipResultMapper.updateByPrimaryKeySelective(tmsshipUnloadShipResult);
    }

    /**
     * 通过主键查询卸船
     * @param resultId
     * @return
     */
    @Override
    public TmsshipUnloadShipResult selectUnloadShip(BigDecimal resultId) {
        return tmsshipUnloadShipResultMapper.selectByPrimaryKey(resultId);
    }

    /**
     * 修改卸船信息
     * @param tmsshipUnloadShipResult
     * @return
     */
    @Override
    public int updateUnloadShip(TmsshipUnloadShipResult tmsshipUnloadShipResult) {
        if(tmsshipUnloadShipResult.getResultEndTime() != null && !"null".equals(tmsshipUnloadShipResult.getResultEndTime())){
            //Map<String,Object> totalId = new HashMap<>();
            //totalId.put("totalResultId",totalResultId);
            //List<TmsshipLoadShipResult> tmsshipLoadShipResults = tmsshipLoadShipResultMapper.selectByParameters(totalId);
            //TmsshipLoadShipResult tmsshipLoadShipResult = tmsshipLoadShipResults.get(0);
            //Map<String,Object> mapValue = new HashMap<>();
            //mapValue.put("batchId",tmsshipLoadShipResult.getBatchId());
            //mapValue.put("downSwimPortId",downSwimPortId);
            //mapValue.put("resultMaterialNumber",tmsshipLoadShipResult.getResultActualInstallations());
            //wmshboundFeign.addWarehousingResult(mapValue);
        }
        tmsshipUnloadShipResult.setUpdateTime(new Date());
        return tmsshipUnloadShipResultMapper.updateByPrimaryKeySelective(tmsshipUnloadShipResult);
    }

    /**
     * 查询所有卸船实绩信息
     * @param mapVal
     * @return
     */
    @Override
    public List<Map<String, Object>> selectUnloadShipList(Map<String, Object> mapVal) {
        return tmsshipUnloadShipResultMapper.selectUnloadShipList(mapVal);
    }

    /**
     * 得到卸船作业表单
     * @param resultId
     * @return
     */
    @Override
    public List<Map<String, Object>> getUnloadShip(BigDecimal resultId) {
        return tmsshipUnloadShipResultMapper.selectUnloadShip(resultId);
    }
}