DIL-DAZHOU-WMS2/src/main/java/com/steerinfo/dil/controller/WmspOutboundResultController.java

package com.steerinfo.dil.controller;

import com.steerinfo.dil.feign.ESFeign;
import com.steerinfo.dil.mapper.CommonSeq;
import com.steerinfo.dil.mapper.WmspInboundScanResultMapper;
import com.steerinfo.dil.model.WmspOutboundResult;
import com.steerinfo.dil.model.WmspOutboundScanResult;
import com.steerinfo.dil.service.IWmspOutboundResultMaterialService;
import com.steerinfo.dil.service.impl.WmspOutboundResultServiceImpl;
import com.steerinfo.dil.service.impl.WmspOutboundScanResultServiceImpl;
import com.steerinfo.dil.util.BaseRESTfulController;
import com.steerinfo.dil.util.ColumnDataUtil;
import com.steerinfo.dil.util.PageListAdd;
import com.steerinfo.dil.vo.OutBoundDetailed;
import com.steerinfo.framework.controller.RESTfulResult;
import com.steerinfo.framework.service.pagehelper.PageHelper;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.*;

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

/**
 * WmspOutboundResult RESTful接口：
 * @author generator
 * @version 1.0-SNAPSHORT 2021-09-08 10:35
 * 类描述
 * 修订历史：
 * 日期：2021-09-08
 * 作者：generator
 * 参考：
 * 描述：WmspOutboundResult RESTful接口
 * @see null
 * @Copyright 湖南视拓信息技术股份有限公司. All rights reserved.
 */
@RestController
@RequestMapping("/${api.version}/wmspoutboundresults")
public class WmspOutboundResultController extends BaseRESTfulController {

    @Autowired
    private WmspOutboundResultServiceImpl wmspOutboundResultService;
    @Autowired
    private WmspInboundScanResultMapper wmspInboundScanResultMapper;
    @Autowired
    private IWmspOutboundResultMaterialService wmspOutboundResultMaterialService;
    @Autowired
    private WmspOutboundScanResultServiceImpl wmspOutboundScanResultService;
    @Autowired
    private CommonSeq commonSeq;
    @Autowired
    private  ESFeign esFeign;


    /**
     * 编写人：hukui
     * PC端查看钢材出库实绩
     * 参数：
     *  apiId：表头id
     *  pageSize：每页记录数
     *  pageNum：查询页数
     * 返回值：
     *  data：所有出库单实绩
     * */
    @Autowired
    ColumnDataUtil columnDataUtil;
    @ApiImplicitParams({
            @ApiImplicitParam(name = "pageNum", value = "查询页数", required = false, dataType = "Integer"),
            @ApiImplicitParam(name = "pageSize", value = "每页记录数", required = false, dataType = "Integer"),
            @ApiImplicitParam(name = "apiId", value = "96", required = false, dataType = "BigDecimal"),
    })
    @PostMapping(value = "/getWmspOutboundResult")
    public RESTfulResult getWmspOutboundResult(@RequestBody(required = false) Map<String, Object> mapval,
                                               Integer pageNum,
                                               Integer pageSize,
                                               Integer apiId,
                                               String con
    ){

        if (con != null) {
            if (!"undefined".equals(con)) {
                String index = "get_wms_outResult";//设置要查询的索引名称
                return success(esFeign.getConResult(mapval, index, apiId, pageNum, pageSize, con));//获取查询结果
            }
        }

        List<Map<String, Object>> libaryOutBoundList = null;
        if (mapval.size() == 0) {
            //将查询结果存入索引中
            libaryOutBoundList = wmspOutboundResultService.selectResultNumber(mapval);
            Map<String, Object> map1 = new HashMap<>();
            //添加索引
            map1.put("index", "get_wms_outresult");
            //添加id
            map1.put("indexId", "outBoundResultId");
            libaryOutBoundList.add(map1);
            //新建索引
            esFeign.insertIndex(libaryOutBoundList);
            //删除
            libaryOutBoundList.remove(libaryOutBoundList.size() - 1);
        }
        if (libaryOutBoundList == null) {
            libaryOutBoundList = wmspOutboundResultService.selectResultNumber(mapval);
        }
        PageHelper.startPage(pageNum, pageSize);
        List<Map<String, Object>> columnList =wmspOutboundResultService.selectResultNumber(mapval);
        PageListAdd pageList = columnDataUtil.tableColumnData(apiId, libaryOutBoundList, columnList);
        return success(pageList);
    }
    @ApiOperation("进入出库扫码页面，查询出库物资信息详情")
    @GetMapping("/getInitOutboundScanResultMaterialInfo")
    @ApiImplicitParam(name = "resultId",value = "出库实绩id",paramType = "BigDecimal",required = true)
    public RESTfulResult getInitOutboundScanResultMaterialInfo(@RequestParam(value = "resultId",required = true) BigDecimal resultId){
        OutBoundDetailed outBoundDetailed= wmspOutboundResultService.getInitOutboundScanResultMaterialInfo(resultId);
        return success(outBoundDetailed);
    }

    /**
     * 编写人：hukui
     * 通过前端扫描司机运单二维码，新增出单实绩并返回新增的出库单实绩
     * 参数：
     *   mapval（运输订单号，订单类别）
     * 返回值：
     *   list：出库单实绩
     * */
    @PostMapping(value = "/insertWmspOutBoundResult")
    public Map<String, Object> insertWmspOutBoundResult(@RequestBody(required = false) Map<String, Object> mapval){
        /**拿到前端传递的运输订单号*/
        String orderNumber = mapval.get("orderNumber").toString();
        /**根据运输订单号，查询运输订单信息，*/
        Map<String, Object> order = wmspOutboundResultService.getOrder(orderNumber);
        /**拿运输订单信息中的运输订单Id*/
        BigDecimal orderId = (BigDecimal) order.get("orderId");
        //根据该运输订单Id判断当前订单是否已经完成出厂，若完成直接返回null
        if (wmspOutboundResultService.getOutboundStatus(orderId)==0){

            Map<String,Object> map = new HashMap<>();
            map.put("orderId",orderId);
            /**根据运输订单ID和物资id查询出库单(没有逻辑删除）
             *若orderNum大于0,则不是第一次扫描，已经新增出库单,返回详情信息
             *若orderNum等于0，则是第一次扫描，需要增加出库单，再返回详情信息
             * */
            int orderNum = wmspOutboundResultService.ExistWmspOutboundResult(map);
            if(orderNum == 0){
                //创建出货单
                WmspOutboundResult wmspOutboundResult=wmspOutboundResultService.createOutboundResult(orderId,new BigDecimal(order.get("orderType").toString()));
                if (wmspOutboundResult!=null){
                    /**根据运输订单号，查询出该订单还没有装货的物资*/
                    List<Map<String,Object>> orderList = wmspOutboundResultService.getMaterial(orderId.intValue());
                    int status= wmspOutboundResultMaterialService.insertOutboundMaterial(wmspOutboundResult.getResultId(),orderList);

                }
            }
            //查询运单相关信息

            return wmspOutboundResultService.getOutBoundDetailedInfo(orderId);
        }
        return null;
    }

    /**
     * 编写人：zouzhendon
     * PDA前端装卸工拒绝扫描出的运输订单，并逻辑删除出库单
     * 参数：
     *   resultId（出库单Id）
     * 返回值：
     *   int：是否逻辑删除出库单
     * */
    @PostMapping(value = "/deletewmspOutboundResult")
    public RESTfulResult deleteWmspOutboundResult(@RequestParam Integer resultId){
        //通过出库单Id逻辑删除出库单
        int i = wmspOutboundResultService.deleteWmspOutboundResult(new BigDecimal(resultId));
        return success(i);
    }



    /**
     * 编写人：yanghaiming
     * 装卸工PDA前端扫描钢材吊牌二维码，新增出库单扫描实绩并返回已扫描并稽核成功的物资信息
     * 参数：
     *   map（resultNumber 出库单号，personnelJobNumber 装卸工工号 resultMaterial 装卸工扫描吊牌结果)
     * 返回值：
     *   list：出库单实绩
     * */
    @Transactional
    @PostMapping(value = "/insertwmspOutboundScanResult")
    public synchronized RESTfulResult insertwmspOutboundScanResult(@RequestBody(required = false) Map<String, Object> map){
        //判断物资是否满足要求,目前一下三种不做处理的判断
        //获取装卸工扫描吊牌结果   HRB400-14-21706854-9-3049-280-20211001015115-7a63cd87a4095e7f-08010103010100003-4
        String subResultMaterial = map.get("resultMaterial").toString().substring(0,map.get("resultMaterial").toString().length() - 1);
        //获取出库单号
        BigDecimal resultId = new BigDecimal(map.get("resultId").toString());
        //物资唯一编码
        String MaterialOnlyCode=subResultMaterial.split("-")[7];


        //判断物质是否已经被扫描
        int isScan = wmspOutboundResultService.ExistScanResult(subResultMaterial);
        //判断物资是否是需要出库的物资,需要出库物资数量不等于0,通过物资唯一编码和出库实绩
        Integer materialNumber = wmspOutboundResultMaterialService.isOutboundResultMaterial(MaterialOnlyCode,resultId);
        //判断物资是否数量已满
        int scanCount = wmspOutboundScanResultService.getScanCount(MaterialOnlyCode,resultId);

        //根据物资id查询相对应的入库实绩ID，并将其赋值给相对应的入库扫描实绩表,判断是否入库
        List<Map<String, Object>> list = wmspInboundScanResultMapper.getInboundResultIdByMaterial(subResultMaterial);

        if(list.size()>0&&isScan==0&&(materialNumber!=null&&materialNumber!=0)&&(materialNumber>scanCount)){
            //创建扫描实绩
            //通过装卸工工号查询装卸工Id
            BigDecimal personnelId = wmspOutboundResultService.getPersonnelIdByJobnumber(map.get("personnelJobNumber").toString());
            //默认以获取到的第一个值作为入库实绩Id
            Map<String, Object> map1 = list.get(0);
            int status= wmspOutboundResultService.createOutboundScanResult(subResultMaterial,personnelId,resultId,(BigDecimal)map1.get("inboundResultId"));
        }

        //返回值展示结果
        return failed();
    }
    /**
     * 编写人：zouzhendon
     * 装卸工PDA前端扫描钢材吊牌二维码，新增出库单扫描实绩并返回已扫描并稽核成功的物资信息
     * 参数：
     *   map（resultNumber 出库单号，personnelJobNumber 装卸工工号 resultMaterial 装卸工扫描吊牌结果)
     * 返回值：
     *   list：出库单实绩
     * */
    @Transactional
    @PostMapping(value = "/insertwmspOutboundScanResult2")
    public synchronized RESTfulResult insertwmspOutboundScanResult2(@RequestBody(required = false) Map<String, Object> map){
      ///获得前台传来得信息

       //获取装卸工扫描吊牌结果   HRB400-14-21706854-9-3049-280-20211001015115-7a63cd87a4095e7f-08010103010100003-4
        String resultMaterial = (String) map.get("resultMaterial");
        String subResultMaterial = resultMaterial.substring(0,resultMaterial.length() - 1);
        //获取出库单号
        BigDecimal resultId = new BigDecimal(map.get("resultId").toString());
        /**根据扫描结果查询扫描实绩、判断是否一件出库
         *          若scanCount大于0,则不是第一次扫描，已经新增出库扫描实绩,返回已扫描过
         *          若scanCount等于0，则是第一次扫描，需要增加出库扫描实绩，再返回已扫描并稽核成功的物资信息
         * */

        ///判断物质是否已经被扫描
        int scanCount = wmspOutboundResultService.ExistScanResult(subResultMaterial);
        ///如果没有被扫描
        if(scanCount==0){

            //wmspOutboundResultService.getOutBoundId(resultNumber);
            //获取装卸工工号
            String personnelJobNumber = (String) map.get("personnelJobNumber");
            //通过装卸工工号查询装卸工Id
            BigDecimal personnelId = wmspOutboundResultService.getPersonnelIdByJobnumber(personnelJobNumber);
            //通过出库实绩Id判断出库单已扫描的件数是否等于运输订单物资表的物资件数
                ///解析物质二维码信息
                //截取扫描结果，得到物资唯一编码
                String[] split = resultMaterial.split("-");
                //唯一编码
                String MaterialOnlyCode=split[7];
                //通过物资物资唯一编码查询钢材物资表的物资Id
                BigDecimal SteelMaterialId = wmspOutboundResultService.getSteelMaterialIdByMaterialOnlyCode(MaterialOnlyCode);
                //通过出库实绩Id查询物资Id
                BigDecimal OutboundMaterialId = wmspOutboundResultService.getOutboundMaterialByResultId(resultId);

                //初始化出库扫描实绩
                WmspOutboundScanResult wmspOutboundScanResult = new WmspOutboundScanResult();

                //使用序列号增加生成主键id
                int seq_wmspOutboundScanResult = commonSeq.getSeqNumber("seq__WMSP_OUTBOUND_SCAN_RESULT");
                //插入主键id
                wmspOutboundScanResult.setResultId(new BigDecimal(seq_wmspOutboundScanResult));
                //根据物资id查询相对应的入库实绩ID，并将其赋值给相对应的入库扫描实绩表
                List<Map<String, Object>> list= wmspInboundScanResultMapper.getInboundResultIdByMaterial(subResultMaterial);
                //默认以获取到的第一个值作为入库实绩Id
                Map<String ,Object> map1 = list.get(0);
                //如果等于0说明该物资没有录入系统
                if (list.size()==0){

                }
                wmspOutboundScanResult.setInboundResultId((BigDecimal) map1.get("inboundResultId"));
                //插入出库实绩ID
                wmspOutboundScanResult.setOutboundResultId(resultId);
                //插入装卸工Id
                wmspOutboundScanResult.setLoadId(personnelId);
                //插入装卸工扫描吊牌结果
                wmspOutboundScanResult.setResultMaterial(resultMaterial);
                //插入装卸工扫描吊牌时间
                wmspOutboundScanResult.setResultLoadTime(new Date());
                //插入出库物资数量
                wmspOutboundScanResult.setOutboundMaterialNumber(new BigDecimal(1));
                //常规字段
                wmspOutboundScanResult.setInsertUsername("admin");
                wmspOutboundScanResult.setInsertTime(new Date());
                wmspOutboundScanResult.setUpdateUsername("admin");
                wmspOutboundScanResult.setUpdateTime(new Date());
                wmspOutboundScanResult.setInsertUpdateRemark("无");
                if(SteelMaterialId.intValue()==OutboundMaterialId.intValue()){
                    int EqualMaterialsNumber = wmspOutboundResultService.EqualMaterialsNumber(resultId);
                    if(EqualMaterialsNumber==1){
                        //相等返回装货数量已够
                        wmspOutboundScanResult.setResultCheck(new BigDecimal(1));
                    }else {
                        //稽核成功,设定扫描实绩稽核结果为成功
                        wmspOutboundScanResult.setResultCheck(new BigDecimal(0));
                    }

                    //插入扫描实绩
                    wmspOutboundResultService.scanResultInsert(wmspOutboundScanResult);
                }else {
                    //稽核失败,设定扫描实绩稽核结果为失败
                    wmspOutboundScanResult.setResultCheck(new BigDecimal(1));
                    //插入扫描实绩
                    wmspOutboundResultService.scanResultInsert(wmspOutboundScanResult);
                }
                //返回已扫描并并稽核成功的物资信息
                //1、获取出库单统一信息
                //获取月台Id
                //BigDecimal platformId = wmspOutboundResultService.getPlatformIdByResultId(resultId);
                //通过月台Id获取仓库名
                //String warehouseName = wmspOutboundResultService.getWarehouseNameByPlatformId(platformId);
                //获取出库单统一部分信息
                Map<String,Object> theSameOutboundInfo = wmspOutboundResultService.theSameOutboundInfo(resultId);
                //theSameOutboundInfo.put("warehouseName",warehouseName);
                //2、获取出库扫描实绩数据
                List<Map<String,Object>> scanAuditSuccessInfo = wmspOutboundResultService.scanAuditSuccessInfo(resultId);
                //补全出库扫描实绩数据的信息,对扫描实绩进行去重


                for (Map<String, Object> stringObjectMap : scanAuditSuccessInfo) {
                    String resultMaterial1 = (String) stringObjectMap.get("resultMaterial");
                    //截取扫描结果，得到一件物资的详细信息
                    String[] split1 = resultMaterial1.split("-");
                    //规格
                    String Specification="Φ"+split1[1];
                    stringObjectMap.put("Specification",Specification);
                    //型号
                    String Model=split1[0];
                    stringObjectMap.put("Model",Model);
                    //炉号
                    String FurnaceNumber=split1[2];
                    stringObjectMap.put("FurnaceNumber",FurnaceNumber);
                    //理重
                    String TheoreticalWeight=split1[4];
                    stringObjectMap.put("TheoreticalWeight",TheoreticalWeight);
                    //唯一编码
                    String MaterialOnlyCode1=split1[7];
                    stringObjectMap.put("MaterialOnlyCode",MaterialOnlyCode1);
                    //通过唯一编码获取物资名称、计量单位、垛位
                    Map<String,Object> otherMap = wmspOutboundResultService.getOtherInfoByMaterialOnlyCode(MaterialOnlyCode1);
                    //取出再放入物资名称
                    String materialName = otherMap.get("materialName").toString();
                    stringObjectMap.put("materialName",materialName);
                    //取出再放入计量单位
                    String unitOfMeasureName = otherMap.get("unitOfMeasureName").toString();
                    stringObjectMap.put("unitOfMeasureName",unitOfMeasureName);
                    //取出再放入垛位
                    String stackingNo = otherMap.get("stackingNo").toString();
                    stringObjectMap.put("stackingNo",stackingNo);
                    //合并出库单统一信息map
                    stringObjectMap.putAll(theSameOutboundInfo);
                }
                return success(scanAuditSuccessInfo);

        }else{
            //返回已扫描并并稽核成功的物资信息
            //1、获取出库单统一信息
            //获取月台Id
            //BigDecimal platformId = wmspOutboundResultService.getPlatformIdByResultId(resultId);
            //通过月台Id获取仓库名
            //String warehouseName = wmspOutboundResultService.getWarehouseNameByPlatformId(platformId);
            //获取出库单统一部分信息
            Map<String,Object> theSameOutboundInfo = wmspOutboundResultService.theSameOutboundInfo(resultId);
            //theSameOutboundInfo.put("warehouseName",warehouseName);
            //2、获取出库扫描实绩数据
            List<Map<String,Object>> scanAuditSuccessInfo = wmspOutboundResultService.scanAuditSuccessInfo(resultId);
            //补全出库扫描实绩数据的信息
            for (Map<String, Object> stringObjectMap : scanAuditSuccessInfo) {
                String resultMaterial1 = (String) stringObjectMap.get("resultMaterial");
                //截取扫描结果，得到一件物资的详细信息
                String[] split1 = resultMaterial1.split("-");
                //规格
                String Specification = "Φ" + split1[1];
                stringObjectMap.put("Specification", Specification);
                //型号
                String Model = split1[0];
                stringObjectMap.put("Model", Model);
                //炉号
                String FurnaceNumber = split1[2];
                stringObjectMap.put("FurnaceNumber", FurnaceNumber);
                //理重
                String TheoreticalWeight = split1[4];
                stringObjectMap.put("TheoreticalWeight", TheoreticalWeight);
                //唯一编码
                String MaterialOnlyCode1 = split1[7];
                stringObjectMap.put("MaterialOnlyCode", MaterialOnlyCode1);
                //通过唯一编码获取物资名称、计量单位、垛位
                Map<String, Object> otherMap = wmspOutboundResultService.getOtherInfoByMaterialOnlyCode(MaterialOnlyCode1);
                //取出再放入物资名称
                String materialName = otherMap.get("materialName").toString();
                stringObjectMap.put("materialName", materialName);
                //取出再放入计量单位
                String unitOfMeasureName = otherMap.get("unitOfMeasureName").toString();
                stringObjectMap.put("unitOfMeasureName", unitOfMeasureName);
                //取出再放入垛位
                String stackingNo = otherMap.get("stackingNo").toString();
                stringObjectMap.put("stackingNo", stackingNo);
                //合并出库单统一信息map
                stringObjectMap.putAll(theSameOutboundInfo);
            }
            return success(scanAuditSuccessInfo);
        }
    }


    /**
     * 编写人：hujianguo
     * 装卸工PDA前端点击出库
     * 参数：
     *   resultId
     * 返回值：
     *   result：出库成功标志
     * */
    @ApiOperation(value = "出库(非0:成功,0:失败)")
    @PostMapping("/outbountResultToSuccess")
    public RESTfulResult outbountResultToSuccess(@RequestParam Integer resultId) {
        int result = wmspOutboundResultService.outbountResultToSuccess(resultId);
        if (result == 0) {
            return failed("还未扫描完，请继续！");
        }
        else {
            return success(result);
        }
    }

    /**
     * 编写人：hukui
     * 通过前端扫描司机运单二维码，新增出单实绩并返回新增的出库单实绩
     * 参数：
     *   mapval（运输订单号，订单类别）
     * 返回值：
     *   list：出库单实绩
     * */
    @PostMapping(value = "/updataResultStatus")
    public RESTfulResult updataResultStatus(@RequestBody(required = false) Integer resultId){
        // 创建一个出库单实体
        WmspOutboundResult wmspOutboundResult = new WmspOutboundResult();
        // 把前端传递的出库单主键id赋值给实体
        wmspOutboundResult.setResultId(new BigDecimal(resultId));
        // 把出库单状态改为已出库
        wmspOutboundResult.setResultStatus(new BigDecimal(1));
        int i = wmspOutboundResultService.updateByPrimaryKeySelective(wmspOutboundResult);
        return success(i);
    }
    /**
     * 司机扫描订单二维码进行倒库，首先根据运输订单号查找运输订单，
     *
     */
    @PostMapping("/insertOutBoundResult")
    public  RESTfulResult insertOutBoundResult(@RequestBody(required = false) Map<String, Object> map){
        return success();
    }

    //创建一个删除实时库的接口
    @PostMapping("/deleteGridMaterial")
    public RESTfulResult deleteGridMaterial(@RequestParam String materialOnlyCode){
        int result = wmspOutboundResultService.deleteGridMaterial(materialOnlyCode);
        if(result == -1){
            return failed("请勿重复扫码");
        }
        if(result == -2){
            return  failed("该钢材还未入库");
        }
        return success(result);
    }
}