DAL-DAZHOU-AMS-API/src/main/java/com/steerinfo/dil/service/impl/AmsSaleOrderMaterialServiceImpl.java

package com.steerinfo.dil.service.impl;

import com.steerinfo.dil.controller.AmsSaleTrucknoMaterialController;
import com.steerinfo.dil.feign.IMFeign;
import com.steerinfo.dil.feign.TmsTruckFeign;
import com.steerinfo.dil.mapper.*;
import com.steerinfo.dil.model.*;
import com.steerinfo.dil.service.IAmsSaleOrderMaterialService;
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.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.*;

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

    @Autowired
    private AmsSaleOrderMaterialMapper amsSaleOrderMaterialMapper;
    @Autowired
    AmsSaleTrucknoMaterialMapper amsSaleTrucknoMaterialMapper;
    @Autowired
    AmsDispatchSaleOrderMapper amsDispatchSaleOrderMapper;
    @Autowired
    OmstruckOrderMapper omstruckOrderMapper;
    @Autowired
    OmstruckOrderMaterialMapper omstruckOrderMaterialMapper;
    @Autowired
    IMFeign imFeign;
    @Autowired
    TmsTruckFeign tmsTruckFeign;
    @Autowired
    AmsSaleOrderMapper amsSaleOrderMapper;

    @Override
    public int addAmsSaleOrderMaterial(AmsSaleOrderMaterial amsSaleOrderMaterial) {
        long id;
        if(amsSaleOrderMaterialMapper.selectMaxId()==null){
            id = 1;
        }else {
            id = amsSaleOrderMaterialMapper.selectMaxId().longValue()+1;
        }
        //生成主键id
        amsSaleOrderMaterial.setSaleOrderMaterialId(new BigDecimal(id));
        //生成车序号
        amsSaleOrderMaterial.setSaleOrderMaterialTruckNo(new BigDecimal(id));
        //常规字段
        amsSaleOrderMaterial.setInsertUsername("admin");
        amsSaleOrderMaterial.setInsertTime(new Date());
        amsSaleOrderMaterial.setUpdateUsername("admin");
        amsSaleOrderMaterial.setUpdateTime(new Date());
        amsSaleOrderMaterial.setInsertUpdateRemark("无");
        amsSaleOrderMaterial.setDeleted(new BigDecimal(0));
        amsSaleOrderMaterial.setUpdated(new BigDecimal(0));
        return amsSaleOrderMaterialMapper.insert(amsSaleOrderMaterial);
    }

    @Override
    public List<Map<String, Object>> selectBySaleOrderMaterialId(BigDecimal saleOrderMaterialId) {
        return amsSaleOrderMaterialMapper.selectBySaleOrderMaterialId(saleOrderMaterialId);
    }

    @Override
    public int updateAmsSaleOrderMaterial(AmsSaleOrderMaterial amsSaleOrderMaterial) {
        amsSaleOrderMaterial.setUpdateTime(new Date());
        return amsSaleOrderMaterialMapper.updateByPrimaryKeySelective(amsSaleOrderMaterial);
    }

    @Override
    public int deleteAmsSaleOrderMaterialBySaleOrderMaterialId(BigDecimal saleOrderMaterialId) {
        AmsSaleOrderMaterial amsSaleOrderMaterial = amsSaleOrderMaterialMapper.selectByPrimaryKey(saleOrderMaterialId);
        amsSaleOrderMaterial.setDeleted(new BigDecimal(1));
        return amsSaleOrderMaterialMapper.updateByPrimaryKey(amsSaleOrderMaterial);
    }

    @Override
    public String getAddress(BigDecimal saleOrderMaterialId) {
        return amsSaleOrderMaterialMapper.getAddress(saleOrderMaterialId);
    }

    @Override
    public int updateAddress(Map<String, Object> map) {
        String saleOrderMaterialId = map.get("saleOrderMaterialId").toString();
        //查询收货地址表中是否有该地址，无则新增，有则取收货地址Id
        String saleShippingAddress = (String) map.get("saleShippingAddress");
        BigDecimal addressId = amsSaleOrderMaterialMapper.getReceiveAddressId(saleShippingAddress);
        //获得原车次表信息
        AmsSaleOrderMaterial amsSaleOrderMaterial1 = amsSaleOrderMaterialMapper.selectByPrimaryKey(new BigDecimal(saleOrderMaterialId));
        if(addressId!=null){
            long id;
            if(amsSaleOrderMaterialMapper.selectMaxId()==null){
                id = 1;
            }else {
                id = amsSaleOrderMaterialMapper.selectMaxId().longValue()+1;
            }
            //生成主键id
            amsSaleOrderMaterial1.setSaleOrderMaterialId(new BigDecimal(id));
            amsSaleOrderMaterial1.setSaleShippingAddressId(addressId);
            //新增修改了地址的数据
            amsSaleOrderMaterialMapper.insert(amsSaleOrderMaterial1);
        }else {
            //新增收货地址，取得收货地址的Id
            Map<String,Object> mapReceive = new HashMap<>();
            long id;
            if(amsSaleOrderMaterialMapper.selectMaxIdReceive()==null){
                id = 1;
            }else {
                id = amsSaleOrderMaterialMapper.selectMaxIdReceive().longValue()+1;
            }
            mapReceive.put("addressId",new BigDecimal(id));
            mapReceive.put("addressDeliveryAddress",saleShippingAddress);
            amsSaleOrderMaterialMapper.insertReceiveAddress(mapReceive);
            //新增修改了地址的数据
            long id1;
            if(amsSaleOrderMaterialMapper.selectMaxId()==null){
                id1 = 1;
            }else {
                id1 = amsSaleOrderMaterialMapper.selectMaxId().longValue()+1;
            }
            //生成主键id
            amsSaleOrderMaterial1.setSaleOrderMaterialId(new BigDecimal(id1));
            amsSaleOrderMaterial1.setSaleShippingAddressId(new BigDecimal(id));
            //新增修改了地址的数据
            amsSaleOrderMaterialMapper.insert(amsSaleOrderMaterial1);

        }
        //修改原地址记录状态
        AmsSaleOrderMaterial amsSaleOrderMaterial2 = amsSaleOrderMaterialMapper.selectByPrimaryKey(new BigDecimal(saleOrderMaterialId));
        amsSaleOrderMaterial2.setUpdated(new BigDecimal(1));
        return amsSaleOrderMaterialMapper.updateByPrimaryKeySelective(amsSaleOrderMaterial2);
    }

    @Override
    public List<Map<String, Object>> getAddressDeliveryAddress() {
        return amsSaleOrderMaterialMapper.getAddressDeliveryAddress();
    }

    public List<Map<String, Object>> getSaleMaterial(Map<String, Object> mapValue) {
        return amsSaleOrderMaterialMapper.getSaleMaterial(mapValue);
    }


    public Integer selectById(BigDecimal saleOrderMaterialId) {
        return amsSaleOrderMaterialMapper.selectById(saleOrderMaterialId);
    }

    public Integer selectByCxh(Map<String, Object> m) {
        return amsSaleOrderMaterialMapper.selectByCxh(m);
    }

    /**
     * 展示车序号信息
     * @param mapValue
     * @return
     */
    @Override
    public List<Map<String, Object>> getTruckNoList(Map<String, Object> mapValue) {
        List<Map<String,Object>> mapList = amsSaleOrderMaterialMapper.getTruckNoList(mapValue);
        return mapList;
    }

    /**
     * 添加车序号与物资
     * @param mapList
     * @return
     */
    @Transactional
    @Override
    public int addTruckNo(List<Map<String, Object>> mapList) {
        int result = 0;
        for (Map<String, Object> map : mapList) {
            // 销售订单id
            BigDecimal saleOrderId = DataChange.dataToBigDecimal(map.get("saleOrderId"));
            // 车序号
            BigDecimal truckNo = DataChange.dataToBigDecimal(map.get("truckNo"));
            AmsSaleOrderMaterial amsSaleOrderMaterial;
            Map<String,Object> saleMap = new HashMap<>();
            saleMap.put("saleOrderId",saleOrderId);
            saleMap.put("saleOrderMaterialTruckNo",truckNo);
            // 检测销售订单下的车序号是否已存在
            List<AmsSaleOrderMaterial> amsSaleOrderMaterials = amsSaleOrderMaterialMapper.selectByParameters(saleMap);
            // 如果已存在则不处理
            if (amsSaleOrderMaterials != null && amsSaleOrderMaterials.size() != 0) {
                amsSaleOrderMaterial = amsSaleOrderMaterials.get(0);
            }
            // 如果不存在则新增车序号
            else {
                // 收货地址id
                BigDecimal shippingAddressId = DataChange.dataToBigDecimal(map.get("shippingAddressId"));
                // 截止日期
                String dateOfReceiptStr = (String) map.get("dateOfReceipt");
                SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
                Date dateOfReceipt = null;
                try {
                    dateOfReceipt = sdf.parse(dateOfReceiptStr);
                } catch (ParseException e) {
                    e.printStackTrace();
                }
                // 收货方姓名
                String orderConsignee = (String) map.get("orderConsignee");
                // 收货方联系方式
                Object orderConsigneeTel = map.get("orderConsigneeTel");
                amsSaleOrderMaterial = new AmsSaleOrderMaterial();
                BigDecimal saleOrderMaterialId = amsSaleOrderMaterialMapper.selectMaxId();
                amsSaleOrderMaterial.setSaleOrderMaterialId(saleOrderMaterialId);
                amsSaleOrderMaterial.setSaleOrderId(saleOrderId);
                amsSaleOrderMaterial.setSaleOrderMaterialTruckNo(truckNo);
                amsSaleOrderMaterial.setSaleShippingAddressId(shippingAddressId);
                // 钢材收货日期
                amsSaleOrderMaterial.setSaleDateOfReceipt(dateOfReceipt);
                amsSaleOrderMaterial.setSaleOrderConsignee(orderConsignee);
                if (orderConsignee != null) {
                    amsSaleOrderMaterial.setSaleOrderConsigneeTel(orderConsigneeTel.toString());
                }
                amsSaleOrderMaterial.setInsertTime(new Date());
                amsSaleOrderMaterial.setInsertUsername("admin");
                amsSaleOrderMaterial.setDeleted(new BigDecimal(0));
                amsSaleOrderMaterial.setInsertUpdateRemark("无");
                amsSaleOrderMaterial.setUpdated(new BigDecimal(0));
                amsSaleOrderMaterial.setIssueStatus(new BigDecimal(0));
                result += amsSaleOrderMaterialMapper.insertSelective(amsSaleOrderMaterial);
            }
            // 新增车序号与物资中间表
            AmsSaleTrucknoMaterial amsSaleTrucknoMaterial = new AmsSaleTrucknoMaterial();
            // 物资id
            BigDecimal materialId = DataChange.dataToBigDecimal(map.get("saleMaterialId"));
            // 物资数量
            BigDecimal materialNumber = DataChange.dataToBigDecimal(map.get("materialNumber"));
            BigDecimal saleTrucknoMaterialId = amsSaleTrucknoMaterialMapper.selectMaxId();
            amsSaleTrucknoMaterial.setTrucknoMaterialId(saleTrucknoMaterialId);
            amsSaleTrucknoMaterial.setMaterialId(materialId);
            amsSaleTrucknoMaterial.setSaleOrderMaterialId(amsSaleOrderMaterial.getSaleOrderMaterialId());
            amsSaleTrucknoMaterial.setSaleOrderMaterialNumber(materialNumber);
            amsSaleTrucknoMaterial.setInsertTime(new Date());
            amsSaleTrucknoMaterial.setInsertUsername("admin");
            amsSaleTrucknoMaterial.setInsertUpdateRemark("无");
            result += amsSaleTrucknoMaterialMapper.insertSelective(amsSaleTrucknoMaterial);
        }
        return result;
    }

    /**
     * 下发车序号
     * @param mapList
     * @return
     */
    @Override
    public int issueTruckNo(List<Map<String, Object>> mapList) {
        int result = 0;
        for (Map<String, Object> map : mapList) {
            BigDecimal saleOrderMaterialId = DataChange.dataToBigDecimal(map.get("saleOrderMaterialId"));
            AmsSaleOrderMaterial amsSaleOrderMaterial = new AmsSaleOrderMaterial();
            amsSaleOrderMaterial.setSaleOrderMaterialId(saleOrderMaterialId);
            amsSaleOrderMaterial.setIssueStatus(new BigDecimal(1));
            result += amsSaleOrderMaterialMapper.updateByPrimaryKeySelective(amsSaleOrderMaterial);
        }
        return result;
    }

    /**
     * 展示车序号下的物资详情
     * @param saleOrderMaterialId
     * @return
     */
    @Override
    public List<Map<String, Object>> getTruckNoMaterialList(BigDecimal saleOrderMaterialId) {
        List<Map<String, Object>> mapList = amsSaleOrderMaterialMapper.getTruckNoMaterialList(saleOrderMaterialId);
        return mapList;
    }

    /**
     * 销售订单下的物资
     * @param saleOrderId
     * @return
     */
    @Override
    public List<Map<String, Object>> getSaleMaterialList(BigDecimal saleOrderId) {
        List<Map<String, Object>> saleMaterialList = amsSaleOrderMaterialMapper.getSaleMaterialList(saleOrderId);
        return saleMaterialList;
    }

    /**
     * 销售直接派发销售订单
     * @param mapValue
     * @return
     */
    @Transactional
    @Override
    public int dispatchTruckOrderBySale(Map<String, Object> mapValue) {
        int result = 0;
        // 得到列内容
        List<Map<String,Object>> mapList = (List<Map<String, Object>>) mapValue.get("mapList");
        // 销售订单主键
        BigDecimal saleOrderId = DataChange.dataToBigDecimal(mapValue.get("saleOrderId"));
        // 车序号计数
        int count = 1;
        // 遍历每一个列
        for (Map<String, Object> map : mapList) {
            // 销售订单-物资中间表id
            BigDecimal saleMaterialId = DataChange.dataToBigDecimal(map.get("saleMaterialId"));
            // 物资id
            BigDecimal materialId = DataChange.dataToBigDecimal(map.get("materialId"));
            // 收货地址id
            BigDecimal saleShippingAddressId = DataChange.dataToBigDecimal(map.get("saleShippingAddressId"));
            if (saleShippingAddressId.intValue() == 0) {
                saleShippingAddressId = null;
            }
            // 承运商id
            BigDecimal carrierId = DataChange.dataToBigDecimal(map.get("carrierId"));
            // 运输线路id
            BigDecimal lineId = DataChange.dataToBigDecimal(map.get("lineId"));
            // 通过线路id判断是否是钢材
            BigDecimal isSteel = amsSaleOrderMaterialMapper.getIsSteel(lineId);
            // 物资重量
            BigDecimal materialNumber = DataChange.dataToBigDecimal(map.get("orderPlanWeight"));
            // 车牌号
            String capacityNumber = (String) map.get("capacityNumber");
            // 得到运力id
            BigDecimal capacityId = amsSaleOrderMaterialMapper.getCapacityId(capacityNumber);
            // 收货方姓名
            String consigneeName = String.valueOf(map.get("saleOrderConsignee"));
            // 收货方电话
            String consigneeTel = String.valueOf(map.get("saleOrderConsigneeTel"));
            // 截止日期
            String dateOfReceiptStr = String.valueOf(map.get("saleDateOfReceipt"));
            Date dateOfReceipt = null;
            if (!"null".equals(dateOfReceiptStr) && !"undefined".equals(dateOfReceiptStr)) {
                dateOfReceipt = new Date(Long.valueOf(dateOfReceiptStr));
            }
            /*
             车序号表
             */
            AmsSaleOrderMaterial amsSaleOrderMaterial = new AmsSaleOrderMaterial();
            // 主键
            BigDecimal saleOrderMaterialId = amsSaleOrderMaterialMapper.selectMaxId();
            amsSaleOrderMaterial.setSaleOrderMaterialId(saleOrderMaterialId);
            // 销售订单主键
            amsSaleOrderMaterial.setSaleOrderId(saleOrderId);
            // 车序号
            amsSaleOrderMaterial.setSaleOrderMaterialTruckNo(new BigDecimal(count));
            // 收货地址
            amsSaleOrderMaterial.setSaleShippingAddressId(saleShippingAddressId);
            // 截止日期
            amsSaleOrderMaterial.setSaleDateOfReceipt(dateOfReceipt);
            // 收货方姓名
            if (!consigneeName.equals("null") && !consigneeName.equals("undefined")) {
                amsSaleOrderMaterial.setSaleOrderConsignee(consigneeName);
            }
            // 收货方联系方式
            if (!consigneeTel.equals("null") && !consigneeTel.equals("undefined")) {
                amsSaleOrderMaterial.setSaleOrderConsigneeTel(consigneeTel);
            }
            // 下发状态
            amsSaleOrderMaterial.setIssueStatus(new BigDecimal(2));
            /*
             车序号与物资子表
             */
            AmsSaleTrucknoMaterial amsSaleTrucknoMaterial = new AmsSaleTrucknoMaterial();
            // 主键
            BigDecimal truckNoMaterialId = amsSaleTrucknoMaterialMapper.selectMaxId();
            amsSaleTrucknoMaterial.setTrucknoMaterialId(truckNoMaterialId);
            // 销售订单-物资中间表id
            amsSaleTrucknoMaterial.setMaterialId(saleMaterialId);
            // 车序号主键
            amsSaleTrucknoMaterial.setSaleOrderMaterialId(saleOrderMaterialId);
            // 物资重量
            amsSaleTrucknoMaterial.setSaleOrderMaterialNumber(materialNumber);
            /*
             定向派单表
             */
            AmsDispatchSaleOrder amsDispatchSaleOrder = new AmsDispatchSaleOrder();
            // 主键
            BigDecimal dispatchId = amsDispatchSaleOrderMapper.selectOtherId();
            amsDispatchSaleOrder.setDispatchId(dispatchId);
            // 车序号表id
            amsDispatchSaleOrder.setSaleOrderMaterialId(saleOrderMaterialId);
            // 承运商id
            amsDispatchSaleOrder.setCarrierId(carrierId);
            // 派单时间和成交时间
            amsDispatchSaleOrder.setDispatchTime(new Date());
            amsDispatchSaleOrder.setDispatchDealTime(new Date());
            // 成交类型
            amsDispatchSaleOrder.setDispatchType(new BigDecimal(0));
            // 车序号状态
            amsDispatchSaleOrder.setDispatchStatus(new BigDecimal(2));
            /*
             运输订单
             */
            OmstruckOrder omstruckOrder = new OmstruckOrder();
            // 运输订单主键
            BigDecimal orderId = omstruckOrderMapper.selectMaxId();
            omstruckOrder.setOrderId(orderId);
            // 车序号主键
            omstruckOrder.setOrderPlanId(saleOrderMaterialId);
            // 运输订单号
            omstruckOrder.setOrderNumber(DataChange.generateEightDigitsNumber("WYSDD",orderId.intValue()));
            // 运力id
            omstruckOrder.setCapacityId(capacityId);
            // 下发时间
            omstruckOrder.setOrderIssueTime(new Date());
            // 运单状态
            omstruckOrder.setOrderStatus(new BigDecimal(4));
            BigDecimal status;
            // 非钢材（危化品和焦炭）
            if (isSteel != null && (isSteel.intValue() == 3 || isSteel.intValue() == 4)) {
                status = new BigDecimal(2);
            }
            // 钢材
            else {
                status = new BigDecimal(1);
            }
            // 订单类型
            omstruckOrder.setOrderType(status);
            // 运输线路id
            omstruckOrder.setLineId(lineId);
            /*
             运输订单子表
             */
            OmstruckOrderMaterial omstruckOrderMaterial = new OmstruckOrderMaterial();
            // 主键
            BigDecimal orderMaterialId = omstruckOrderMaterialMapper.selectMaxId();
            omstruckOrderMaterial.setOrderMaterialId(orderMaterialId);
            // 运输订单id
            omstruckOrderMaterial.setOrderId(orderId);
            // 物资id
            omstruckOrderMaterial.setMaterialId(materialId);
            // 物资重量
            omstruckOrderMaterial.setOrderMaterialWeight(materialNumber);
            // 新增车序号表
            result += amsSaleOrderMaterialMapper.insertSelective(amsSaleOrderMaterial);
            // 新增车序号-物资中间表
            result += amsSaleTrucknoMaterialMapper.insertSelective(amsSaleTrucknoMaterial);
            // 新增定向派单表
            result += amsDispatchSaleOrderMapper.insertSelective(amsDispatchSaleOrder);
            // 新增运输订单
            result += omstruckOrderMapper.insertSelective(omstruckOrder);
            // 新增运输订单子表
            result += omstruckOrderMaterialMapper.insertSelective(omstruckOrderMaterial);
            // 调用websocket
            Map<String,Object> orderIdMap = new HashMap<>();
            orderIdMap.put("orderId",orderId);
            pushMesToWebsocket(orderIdMap);
            // 生成运输执行总实绩
            result += tmsTruckFeign.addTotalResult(orderIdMap);
            // 车序号累加
            count++;
        }
        // 得到销售订单中的总重量和销售订单下的总净重
        BigDecimal saleMaterialWeight = amsSaleOrderMaterialMapper.getMaterialWeightByOrderId(saleOrderId);
        BigDecimal saleMaterialNetWeight = amsSaleOrderMaterialMapper.getMaterialNetWeightBySaleId(saleOrderId);
        if (saleMaterialNetWeight == null) {
            saleMaterialNetWeight = new BigDecimal(0);
        }
        // 计算净重所占销售订单中的比例
        Double percent = saleMaterialNetWeight.doubleValue()/saleMaterialWeight.doubleValue();
        if (percent >= 0.97) {
            result = -1;
        }
        return result;
    }

    /**
     * 承运商直接派发销售订单
     * @param mapValue
     * @return
     */
    @Override
    public int dispatchTruckOrderByCarrier(Map<String, Object> mapValue) {
        int result = 0;
        // 得到列内容
        List<Map<String,Object>> mapList = (List<Map<String, Object>>) mapValue.get("mapList");
        // 销售订单主键
        BigDecimal saleOrderId = DataChange.dataToBigDecimal(mapValue.get("saleOrderId"));
        // 得到最大的车序号
        BigDecimal count = DataChange.dataToBigDecimal(mapValue.get("truckNo"));
        // 车序号计数
        if (count.intValue() == 0) {
            count = new BigDecimal(1);
        }
        // 遍历每一个列
        for (Map<String, Object> map : mapList) {
            // 销售订单-物资中间表id
            BigDecimal saleMaterialId = DataChange.dataToBigDecimal(map.get("saleMaterialId"));
            // 物资id
            BigDecimal materialId = DataChange.dataToBigDecimal(map.get("materialId"));
            // 收货地址id
            BigDecimal saleShippingAddressId = DataChange.dataToBigDecimal(map.get("saleShippingAddressId"));
            if (saleShippingAddressId.intValue() == 0) {
                saleShippingAddressId = null;
            }
            // 承运商id
            BigDecimal carrierId = DataChange.dataToBigDecimal(map.get("carrierId"));
            // 运输线路id
            BigDecimal lineId = DataChange.dataToBigDecimal(map.get("lineId"));
            // 通过线路id判断是否是钢材
            BigDecimal isSteel = amsSaleOrderMaterialMapper.getIsSteel(lineId);
            // 物资重量
            BigDecimal materialNumber = DataChange.dataToBigDecimal(map.get("orderPlanWeight"));
            // 车牌号
            String capacityNumber = (String) map.get("capacityNumber");
            // 得到运力id
            BigDecimal capacityId = amsSaleOrderMaterialMapper.getCapacityId(capacityNumber);
            // 收货方姓名
            String consigneeName = String.valueOf(map.get("saleOrderConsignee"));
            // 收货方电话
            String consigneeTel = String.valueOf(map.get("saleOrderConsigneeTel"));
            // 截止日期
            String dateOfReceiptStr = "4102415999000";
            Date dateOfReceipt = new Date(Long.valueOf(dateOfReceiptStr));
            /*
             车序号表
             */
            AmsSaleOrderMaterial amsSaleOrderMaterial = new AmsSaleOrderMaterial();
            // 主键
            BigDecimal saleOrderMaterialId = amsSaleOrderMaterialMapper.selectMaxId();
            amsSaleOrderMaterial.setSaleOrderMaterialId(saleOrderMaterialId);
            // 销售订单主键
            amsSaleOrderMaterial.setSaleOrderId(saleOrderId);
            // 车序号
            amsSaleOrderMaterial.setSaleOrderMaterialTruckNo(count);
            // 收货地址
            amsSaleOrderMaterial.setSaleShippingAddressId(saleShippingAddressId);
            // 截止日期
            amsSaleOrderMaterial.setSaleDateOfReceipt(dateOfReceipt);
            // 收货方姓名
            if (!consigneeName.equals("null") && !consigneeName.equals("undefined")) {
                amsSaleOrderMaterial.setSaleOrderConsignee(consigneeName);
            }
            // 收货方联系方式
            if (!consigneeTel.equals("null") && !consigneeTel.equals("undefined")) {
                amsSaleOrderMaterial.setSaleOrderConsigneeTel(consigneeTel);
            }
            // 下发状态
            amsSaleOrderMaterial.setIssueStatus(new BigDecimal(2));
            /*
             车序号与物资子表
             */
            AmsSaleTrucknoMaterial amsSaleTrucknoMaterial = new AmsSaleTrucknoMaterial();
            // 主键
            BigDecimal truckNoMaterialId = amsSaleTrucknoMaterialMapper.selectMaxId();
            amsSaleTrucknoMaterial.setTrucknoMaterialId(truckNoMaterialId);
            // 销售订单-物资中间表id
            amsSaleTrucknoMaterial.setMaterialId(saleMaterialId);
            // 车序号主键
            amsSaleTrucknoMaterial.setSaleOrderMaterialId(saleOrderMaterialId);
            // 物资重量
            amsSaleTrucknoMaterial.setSaleOrderMaterialNumber(materialNumber);
            /*
             定向派单表
             */
            AmsDispatchSaleOrder amsDispatchSaleOrder = new AmsDispatchSaleOrder();
            // 主键
            BigDecimal dispatchId = amsDispatchSaleOrderMapper.selectOtherId();
            amsDispatchSaleOrder.setDispatchId(dispatchId);
            // 车序号表id
            amsDispatchSaleOrder.setSaleOrderMaterialId(saleOrderMaterialId);
            // 承运商id
            amsDispatchSaleOrder.setCarrierId(carrierId);
            // 派单时间和成交时间
            amsDispatchSaleOrder.setDispatchTime(new Date());
            amsDispatchSaleOrder.setDispatchDealTime(new Date());
            // 成交类型
            amsDispatchSaleOrder.setDispatchType(new BigDecimal(0));
            // 车序号状态
            amsDispatchSaleOrder.setDispatchStatus(new BigDecimal(2));
            /*
             运输订单
             */
            OmstruckOrder omstruckOrder = new OmstruckOrder();
            // 运输订单主键
            BigDecimal orderId = omstruckOrderMapper.selectMaxId();
            omstruckOrder.setOrderId(orderId);
            // 车序号主键
            omstruckOrder.setOrderPlanId(saleOrderMaterialId);
            // 运输订单号
            omstruckOrder.setOrderNumber(DataChange.generateEightDigitsNumber("WYSDD",orderId.intValue()));
            // 运力id
            omstruckOrder.setCapacityId(capacityId);
            // 下发时间
            omstruckOrder.setOrderIssueTime(new Date());
            // 运单状态
            omstruckOrder.setOrderStatus(new BigDecimal(4));
            BigDecimal status;
            // 非钢材（危化品和焦炭）
            if (isSteel != null && (isSteel.intValue() == 3 || isSteel.intValue() == 4)) {
                status = new BigDecimal(2);
            }
            // 钢材
            else {
                status = new BigDecimal(1);
            }
            // 订单类型
            omstruckOrder.setOrderType(status);
            // 运输线路id
            omstruckOrder.setLineId(lineId);
            /*
             运输订单子表
             */
            OmstruckOrderMaterial omstruckOrderMaterial = new OmstruckOrderMaterial();
            // 主键
            BigDecimal orderMaterialId = omstruckOrderMaterialMapper.selectMaxId();
            omstruckOrderMaterial.setOrderMaterialId(orderMaterialId);
            // 运输订单id
            omstruckOrderMaterial.setOrderId(orderId);
            // 物资id
            omstruckOrderMaterial.setMaterialId(materialId);
            // 物资重量
            omstruckOrderMaterial.setOrderMaterialWeight(materialNumber);
            // 新增车序号表
            result += amsSaleOrderMaterialMapper.insertSelective(amsSaleOrderMaterial);
            // 新增车序号-物资中间表
            result += amsSaleTrucknoMaterialMapper.insertSelective(amsSaleTrucknoMaterial);
            // 新增定向派单表
            result += amsDispatchSaleOrderMapper.insertSelective(amsDispatchSaleOrder);
            // 新增运输订单
            result += omstruckOrderMapper.insertSelective(omstruckOrder);
            // 新增运输订单子表
            result += omstruckOrderMaterialMapper.insertSelective(omstruckOrderMaterial);
            // 调用websocket
            Map<String,Object> orderIdMap = new HashMap<>();
            orderIdMap.put("orderId",orderId);
            pushMesToWebsocket(orderIdMap);
            // 生成运输执行总实绩
            result += tmsTruckFeign.addTotalResult(orderIdMap);
            // 车序号累加
            count = new BigDecimal(count.intValue() + 1);
        }
        // 修改状态为开启状态
        AmsSaleOrder amsSaleOrder = new AmsSaleOrder();
        amsSaleOrder.setSaleOrderId(saleOrderId);
        amsSaleOrder.setCloseStatus(new BigDecimal(0));
        result += amsSaleOrderMapper.updateByPrimaryKeySelective(amsSaleOrder);
        return result;
    }

    /**
     * 关闭销售订单
     * @param saleOrderId
     * @return
     */
    @Override
    public int closeSaleOrder(BigDecimal saleOrderId) {
        AmsSaleOrder amsSaleOrder = new AmsSaleOrder();
        amsSaleOrder.setSaleOrderId(saleOrderId);
        amsSaleOrder.setCloseStatus(new BigDecimal(1));
        int result = amsSaleOrderMapper.updateByPrimaryKeySelective(amsSaleOrder);
        return result;
    }

    /**
     * 发送消息到 websocket 推送消息
     * orderId  订单Id
     * @return
     */
    public String pushMesToWebsocket(Map<String, Object> map) {
        Map<String, Object> mesMap = omstruckOrderMapper.pushMesToWebsocket(map);
        //添加消息实体
        HashMap<Object, Object> mapp = new HashMap<>();
        mapp.put("messageType", 3);
        mapp.put("sendPerson", "system");
        mapp.put("receivePerson", mesMap.get("capacityNumber"));
        mapp.put("messageContent",(String) mesMap.get("orderNumber") + new Date());
        mapp.put("createTime", new Date());
        ArrayList<Object> list = new ArrayList<>();
        list.add(mapp);
        //调用websocket接口推送
        HashMap<Object, Object> sendMap = new HashMap<>();
        //将消息实体放入list中存到map中
        sendMap.put("messages", list);
        String s = imFeign.sendToUser(sendMap);
        System.out.println(s);
        return s;
    }
}