wms / WMS_LZZT · Files

package com.huaheng.api.SSP.service;

import com.alibaba.fastjson.JSON;

import com.alibaba.fastjson.JSONObject;

import com.huaheng.api.SSP.domain.ConfirmHeaderModel;
import com.huaheng.api.SSP.domain.ConfirmModel;
import com.huaheng.api.SSP.domain.ConfirmTypeModel;

import com.huaheng.api.U8.domain.ICSReceiptHeader;

import com.huaheng.common.exception.service.ServiceException;
import com.huaheng.common.support.Convert;
import com.huaheng.common.utils.http.HttpUtils;
import com.huaheng.framework.web.domain.AjaxResult;
import com.huaheng.pc.general.material.domain.Material;
import com.huaheng.pc.general.material.service.IMaterialService;
import com.huaheng.pc.receipt.receiptDetail.domain.ReceiptDetail;
import com.huaheng.pc.receipt.receiptDetail.service.IReceiptDetailService;
import com.huaheng.pc.receipt.receiptHeader.domain.ReceiptHeader;
import com.huaheng.pc.receipt.receiptHeader.service.IReceiptHeaderService;
import com.huaheng.pc.shipment.shipmentDetail.domain.ShipmentDetail;
import com.huaheng.pc.shipment.shipmentDetail.service.IShipmentDetailService;
import com.huaheng.pc.shipment.shipmentHeader.domain.ShipmentHeader;
import com.huaheng.pc.shipment.shipmentHeader.service.IShipmentHeaderService;
import net.bytebuddy.implementation.bytecode.Throw;

import org.aspectj.weaver.loadtime.Aj;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;

/**   出入库单下发Service
 *
 *  1. 此Service的作用是将系统中未被钱柜扫描过的出入库单据发送给钱柜，目前考虑到系统资源，一次只能查询或发送一条单据，发送规则是根据子单内的
 * 属于钱柜的物料进行发送，发送成功后会将子单的状态改为100,若主单内的所有子单都没有发现钱柜物料，则将不进行发送，但是无论发送与否，都会对主单的扫描标识进行修改，目前钱柜
 * 的标识是1，若主单据的扫描标识的第一位为1则代表此单据被钱柜扫描过。
 *
 * 2. 目前此Service出入库单的下发逻辑是先扫描入库单据，若入库单据已全部下发成功，将自动扫描出库单据。
 *
 * 3. 目前钱柜编码写死为QG,默认为库区编码为QG的物料为钱柜的物料。
 */

@Transactional
@Service

public class OrderAssignApiService {

    @Autowired
    IReceiptHeaderService iReceiptHeaderService;

    @Autowired
    IReceiptDetailService iReceiptDetailService;

    @Autowired
    IShipmentHeaderService iShipmentHeaderService;

    @Autowired
    IShipmentDetailService iShipmentDetailService;

    @Autowired
    IMaterialService iMaterialService;

    public AjaxResult receiptAssign(String url){

        //查询出一条未被钱柜扫描过的入库单
        ReceiptHeader item =  iReceiptHeaderService.selectNosScanSSP();

        if (item==null){
            return shipmentAssign(url);
        }

        ConfirmHeaderModel cfh = new ConfirmHeaderModel();
        cfh.setOrderHeaderId(item.getId());
        cfh.setOrderCode(item.getCode());
        cfh.setOrderType("receipt");
        cfh.setWarehouseCode(item.getWarehouseCode());
        SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        cfh.setcDatetime(df.format(new Date()));
        ConfirmModel confirmModel = new ConfirmModel();

//        confirmModel.setConfirmHeaderModel(cfh);

        ReceiptDetail receiptDetail = new ReceiptDetail();
        receiptDetail.setReceiptId(item.getId());
        List<ReceiptDetail> details = iReceiptDetailService.selectListEntityByEqual(receiptDetail);
        List<ConfirmTypeModel> typeModels = new ArrayList<>();
        //遍历入库子单

        int i = 0;

        List<Integer> list = new ArrayList();

        for (ReceiptDetail ds:details){

            //查找子单中钱柜的物料

            Material material = iMaterialService.selectEntityById(ds.getMaterialId());
            if (material != null && material.getZoneCode().equals("QG")) {

                ConfirmTypeModel cft = new ConfirmTypeModel();
                cft.setOrderDetailId(ds.getId());
                cft.setCompanyCode(ds.getCompanyCode());
                cft.setContainerCode("0");
                cft.setItemCode(ds.getMaterialCode());
                cft.setItemName(material.getName());
                cft.setItemBarcode(material.getBarcode());
                cft.setItemState(ds.getInventoryStatus());
                float a = Convert.toFloat(ds.getQty());
                cft.setQty(a);
                cft.setItemUnit(material.getMasterUnit());
                typeModels.add(cft);

                list.add(ds.getId());

                i++;
            }

        }

        //若此单据无钱柜物料 则修改状态

        ReceiptHeader receiptHeaderOver = new ReceiptHeader();
        receiptHeaderOver.setId(item.getId());

        if (i < 1){

            StringBuffer str = new StringBuffer();
            str.append(item.getScanid());
            str.replace(0, 1, "1");
            receiptHeaderOver.setScanid(String.valueOf(str));

            iReceiptHeaderService.updateByModel(receiptHeaderOver);
            return AjaxResult.success("已扫描一条入单据，没有发现钱柜物料");
        }else {

            //此处将入库主单，入库子单整合成发送给钱柜的的实体
            cfh.setCubeCode("QG");
            confirmModel.setConfirmHeaderModel(cfh);

            confirmModel.setOrderItems(typeModels);
            try {

//                发送单据给钱柜IP

                String JsonParam = JSON.toJSONString(confirmModel);
                String result = HttpUtils.bodypost(url, JsonParam);
                AjaxResult ajaxResult = JSON.parseObject(result, AjaxResult.class);

                //修改已经下发的子单状态

                short statusover = 100;

                ReceiptDetail detail = new ReceiptDetail();
                for (int j = 0; j < list.size(); j++) {
                    detail.setId(list.get(j));
                    detail.setStatus(statusover);
                    iReceiptDetailService.updateByModel(detail);
                }
                StringBuffer str = new StringBuffer();
                str.append(item.getScanid());
                str.replace(0, 1, "1");
                receiptHeaderOver.setScanid(String.valueOf(str));

                if (iReceiptHeaderService.updateByModel(receiptHeaderOver) < 1) {
                    throw new ServiceException("入库订单状态更新失败!");
                }
                return ajaxResult;
            } catch (Exception e) {
                throw new ServiceException("入库订单下发发送失败!");
            }

        }
    }



    public AjaxResult shipmentAssign(String url) {

        //查询出一条未被钱柜扫描过的出库单
        ShipmentHeader item = iShipmentHeaderService.selectNosScanSSP();
        if (item==null){

            return AjaxResult.success("所有出入库单都已下发成功!");

        }
        ConfirmHeaderModel cfh = new ConfirmHeaderModel();
        cfh.setOrderHeaderId(item.getId());
        cfh.setOrderCode(item.getCode());
        cfh.setOrderType("shipment");
        cfh.setWarehouseCode(item.getWarehouseCode());
        SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        cfh.setcDatetime(df.format(new Date()));
        ConfirmModel confirmModel = new ConfirmModel();

//        confirmModel.setConfirmHeaderModel(cfh);

        ShipmentDetail shipmentDetail = new ShipmentDetail();
        shipmentDetail.setShipmentId(item.getId());
        List<ShipmentDetail> details = iShipmentDetailService.selectListEntityByEqual(shipmentDetail);
        List<ConfirmTypeModel> typeModels = new ArrayList<>();

        //遍历出库子单

        int i = 0;

        List<Integer> list = new ArrayList();

        for (ShipmentDetail ds:details){

            //查找子单中钱柜的物料
            Material material = iMaterialService.selectEntityById(ds.getId());
            if (material != null || material.getZoneCode().equals("QG")) {
                ConfirmTypeModel cft = new ConfirmTypeModel();
                cft.setOrderDetailId(ds.getId());
                cft.setCompanyCode(ds.getCompanyCode());
                cft.setContainerCode("0");
                cft.setItemCode(ds.getMaterialCode());
                cft.setItemName(material.getName());
                cft.setItemBarcode(material.getBarcode());
                cft.setItemState(ds.getInventoryStatus());
                float a = Convert.toFloat(ds.getQty());
                cft.setQty(a);
                cft.setItemUnit(material.getMasterUnit());
                typeModels.add(cft);

                list.add(ds.getId());

                i++;
            }

        }

        //若此单据无钱柜物料 则修改状态

        ShipmentHeader shipmentHeaderOver = new ShipmentHeader();
        shipmentHeaderOver.setId(item.getId());

        if (i<1){

            StringBuffer str = new StringBuffer();
            str.append(item.getScanid());
            str.replace(0, 1, "1");
            shipmentHeaderOver.setScanid(String.valueOf(str));

            iShipmentHeaderService.updateByModel(shipmentHeaderOver);
            return AjaxResult.success("已扫描一条出库单据，没有发现钱柜物料");
        }else {

            //此处将出库主单，出库子单整合成发送给钱柜的的实体
            cfh.setCubeCode("QG");
            confirmModel.setConfirmHeaderModel(cfh);

            confirmModel.setOrderItems(typeModels);
            try {
                String JsonParam = JSON.toJSONString(confirmModel);
                String result = HttpUtils.bodypost(url, JsonParam);
                AjaxResult ajaxResult = JSON.parseObject(result, AjaxResult.class);

                //修改已经下发的子单状态
                short statusover = 100;
                ShipmentDetail detail = new ShipmentDetail();
                for (int j = 0; j < list.size(); j++) {
                    detail.setId(list.get(j));
                    detail.setStatus(statusover);
                    iShipmentDetailService.updateByModel(detail);
                }
                StringBuffer str = new StringBuffer();
                str.append(item.getScanid());
                str.replace(0, 1, "1");
                shipmentHeaderOver.setScanid(String.valueOf(str));

                if (iShipmentHeaderService.updateByModel(shipmentHeaderOver)<1){
                    throw new ServiceException("出库单据状态更新失败");
                }
                return ajaxResult;
            } catch (Exception e) {
                throw new ServiceException("出库订单发送失败!");
            }
        }

    }
}