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

package com.steerinfo.dil.controller;

import com.steerinfo.dil.feign.ESFeign;
import com.steerinfo.dil.mapper.WmspGridMaterialMapper;
import com.steerinfo.dil.model.*;
import com.steerinfo.dil.service.ICommonService;
import com.steerinfo.dil.service.IWmspInboundDistributeService;
import com.steerinfo.dil.service.impl.*;
import com.steerinfo.dil.util.*;
import com.steerinfo.framework.controller.RESTfulResult;
import com.steerinfo.framework.service.pagehelper.PageHelper;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import io.swagger.models.auth.In;
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.*;
//import java.util.*;
/**
 * @author luobang
 * @create 2021-09-06 18:13
 */
@Api("入库实绩")
@RestController
@RequestMapping("${api.version}/inboundResult")
public class WmsInboundResultController extends BaseRESTfulController {

    @Autowired
    ColumnDataUtil columnDataUtil;

    @Autowired
    ESFeign esFeign;

    @Autowired
    WmsInboundResultServiceImpl wmsInboundResultServiceImpl;

    @Autowired
    WmsInboundScanResultServiceImpl wmsInboundScanResultServiceImpl;

    @Autowired
    WmsInboundDrivingResultServiceImpl wmsInboundDrivingResultServiceImpl;

    @Autowired
    RmsStackingServiceImpl rmsStackingService;

    @Autowired
    RmsPwarehouseGridServiceImpl rmsPwarehouseGridService;

    @Autowired
    WmspGridMaterialServiceImpl wmspGridMaterialService;

    @Autowired
    WmspGridMaterialMapper wmspGridMaterialMapper;

    @Autowired
    WmsInboundStackResultServiceImpl wmsInboundStackResultServiceImpl;

    @Autowired
    WmspInboundDistributeServiceImpl wmspInboundDistributeService;

    @Autowired
    ICommonService commonService;


    /**
     * 展示入库实绩
     * @param mapValue
     * @param apiId
     * @param pageNum
     * @param pageSize
     * @return
     */
    @PostMapping("/getWmsInboundResult2")
    @ApiOperation(value = "展示入库实绩信息")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "apiId", value = "90", required = false, dataType = "BigDecimal"),
    })
    public RESTfulResult getWmsInboundResult(@RequestBody(required = false) Map<String, Object> mapValue,
                                             Integer apiId,
                                             Integer pageNum,
                                             Integer pageSize,
                                             String con) {
        if(con != null){
            if(!"undefined".equals(con)){
                String index = "get_wms_inboundresult";
                return success(esFeign.getConResult(mapValue,index,apiId,pageNum,pageSize,con));
            }
        }
        List<Map<String,Object>>inboundResultList = null;
        if(mapValue.size() == 0){
            //将查询结果存入索引中
            inboundResultList = wmsInboundResultServiceImpl.getInboundResult(mapValue);
            Map<String, Object> inboundResultMap = new HashMap<>();
            //添加索引
            inboundResultMap.put("index","get_wms_inboundresultse");
            //添加ID
            inboundResultMap.put("indexId","inboundresultId");
            inboundResultList.add(inboundResultMap);
            //新建索引
            esFeign.insertIndex(inboundResultList);
            //删除
            inboundResultList.remove(inboundResultList.size() -1);
        }
        if(inboundResultList == null) {
            inboundResultList = wmsInboundResultServiceImpl.getInboundResult(mapValue);
        }
        /*分页*/
        PageHelper.startPage(pageNum, pageSize);
        List<Map<String,Object>> columnList = wmsInboundResultServiceImpl.getInboundResult(mapValue);
        PageListAdd pageList = columnDataUtil.tableColumnData(apiId,inboundResultList,columnList);
        return success(pageList);
    }


    /**
     * 新增入库实绩
     *
     * @param
     * @return
     */
    @ApiOperation("新增入库实绩")
    @PostMapping("/insertInboundResult")
    @Transactional
    public  RESTfulResult addInvoice(@RequestParam("userName") String userName,@RequestParam("groupId") BigDecimal groupId,@RequestParam("personnelWorkshopid") BigDecimal personnelWorkshopid, @RequestBody(required = false) List<Map<String, Object>> mapList) {
        //首先做的判断处理
        //由于钢材是分批次、一批四件的（有特殊情况不是一批四件）
        //所以需要设置他们批次不能跨越一个应该是相连的,如果批次跨过两个说明有一个多按了一次，或者是有了一个人少按了一次,所以需要少下发的和多下发的对齐。
        //使两个人批次相同

        //查询当前分组下次最新的一次下发、
        // 第一、判断库状态是否是下发中的
        // 第二、判断自己上一组是否完成，如果上一组已经完成则开始下一组、没有完成给一点提示
        //查询当前组最新得一条入库实绩、判断是否是自己创建得、状态是否是带下发状态
        Map<String,Object> conditionMap=wmsInboundResultServiceImpl.selectInboundResultByGroupId(groupId);
        //如果最新的一条是自己的并且
        //遗留 查询批次、以及状态
        int batch=0;
        //此条件成了说明他提交之后、另外一个还没提交交
        if ((conditionMap!=null&&conditionMap.get("userName").toString().equals(userName)&&conditionMap.get("resultStatus").toString().equals("1"))){
            return success("请勿重复提交");
        }
        //此条件成了说明第二个人开始提交了
        if (conditionMap!=null&&!conditionMap.get("userName").toString().equals(userName)&&conditionMap.get("resultStatus").toString().equals("1")){
                //获得第一个人的批次
            //将下面的订单都录入这个批次里面
            for (int i=0;i<mapList.size();i++){
                Map<String,Object> item=mapList.get(i);
                //二、获得同一批的第i个的网格  解释：目前还没有设计出来网格的结构 没有做默认为 第一库、第一月台、第一垛位、第一行、第一列 \推送信息给行车工、让他们抢单代码备注了
                BigDecimal houseGrid = wmsInboundResultServiceImpl.getGrid(conditionMap.get("distributeId").toString(), i+1);
                //如果差不多、说明上一个人少扫了一次
                if (houseGrid==null){
                    houseGrid = rmsPwarehouseGridService.selectGrid(mapList.size()-1, personnelWorkshopid);
                    //创建实时库存
                    wmspGridMaterialService.initInsertWmspGridMaterial(item,houseGrid);
                }
                //遗留 批次、网格
                //三、创建一个入库作业实绩
                WmspInboundResult wmspInboundResult = wmsInboundResultServiceImpl.initAndWmspInboundResult(i+1,personnelWorkshopid,groupId,userName,new BigDecimal(conditionMap.get("distributeId").toString()),houseGrid,item);
                //改变扫码实绩里面的状态
                int status= wmsInboundScanResultServiceImpl.updateInboundScanStatus(new BigDecimal(item.get("resultId").toString()),wmspInboundResult.getInboundId());
                //当都完成的时候就要去改变这一批的状态改为下发状态
                if(mapList.size()==i+1){
                    int status2= wmsInboundResultServiceImpl.updateInboundStatus(new BigDecimal(conditionMap.get("distributeId").toString()));
                }
            }
                return success();
        //第n批第一次提交
        }else{
            //需要判断是否已经提交过了 通过resultId判断物质是否已经下发过了跳出、多次下发的结果
            Integer resultStatus= wmsInboundScanResultServiceImpl.getResultStatusByResultId(mapList.get(0).get("resultId").toString());
           if(resultStatus==1){
               return success("请勿重复下发");
           }
            //第一、创建批次
            WmspInboundDistribute  wmspInboundDistribute=wmspInboundDistributeService.initAndCreateInboundDistribute(personnelWorkshopid,groupId,userName,batch);

           //将下面的订单都录入这个批次里面
            for (int i=0;i<mapList.size();i++){
                Map<String,Object> item=mapList.get(i);
                //二、智能的设置好这批钢材的位置、网格图
                //二、查询一个默认的网格  解释：目前还没有设计出来网格的结构 没有做默认为 第一库、第一月台、第一垛位、第一行、第一列 \推送信息给行车工、让他们抢单代码备注了
                BigDecimal houseGrid = rmsPwarehouseGridService.selectGrid(mapList.size()-1, personnelWorkshopid);
                //遗留 批次、网格
                //三、创建一个入库作业实绩
                WmspInboundResult wmspInboundResult = wmsInboundResultServiceImpl.initAndWmspInboundResult(i+1,personnelWorkshopid,groupId,userName,wmspInboundDistribute.getDistributeId(),houseGrid,item);
                //改变扫码实绩里面的状态
                int status= wmsInboundScanResultServiceImpl.updateInboundScanStatus(new BigDecimal(item.get("resultId").toString()),wmspInboundResult.getInboundId());

                //创建实时库存
                wmspGridMaterialService.initInsertWmspGridMaterial(item,houseGrid);
            }
            return success(null);
        }

    }
    /**
     * 新增入库实绩
     *
     * @param
     * @return
     */
    @ApiOperation("新增入库实绩")
    @PostMapping("/insertInboundResult2")
    @Transactional
    public RESTfulResult addInvoice( @RequestBody(required = false) List<Map<String, Object>> mapList) {


        //获取前方传来的仓库ID进行入库
        BigDecimal warehouseId = new BigDecimal((Integer)mapList.get(0).get("personnelWorkshopid"));

        String inboundValue = null;
        BigDecimal ST = null;
        if(warehouseId.intValue() == 3){
             inboundValue = wmsInboundResultServiceImpl.selectWarehouseName(new BigDecimal(3));
        }
        //!!!默认该仓库的所有行车工都能看到
        //!!!待添加，查询该仓库所有在班的行车工
        String personnelJobNumber = "000417";
        if(warehouseId.intValue() != 3){
            //查询入库垛位信息
            Map<String,Object> stackingMap = rmsStackingService.getStackingToUpdate(mapList.size(),warehouseId,personnelJobNumber);
            //获取入库垛位ID
            ST = (BigDecimal) stackingMap.get("stackingId");
            inboundValue = stackingMap.get("stackingNo").toString();
        }
        for (Map<String,Object> map:mapList
             ) {
            WmspInboundResult wmspInboundResult = new WmspInboundResult();
            wmspInboundResult.setInboundId(new BigDecimal(wmsInboundResultServiceImpl.count() + 1));
            /*
            设置入库类型为生产入库
             */
            wmspInboundResult.setInboundType(new BigDecimal(0));
            /*
            设置入库单编号
             */
            String number=Liushuih.generateNextNumber("WRKD-", "yyyyMMdd-", 8, 12);
            wmspInboundResult.setInboundNumber(number);
             /*
            设置逻辑删除字段
             */
            wmspInboundResult.setResultDeleted(new BigDecimal(0));
            /*
            设置常规字段
            */
            wmspInboundResult.setInsertUsername("admin");
            wmspInboundResult.setInsertTime(new Date());
            wmspInboundResult.setUpdateUsername("admin");
            wmspInboundResult.setUpdateTime(new Date());
            wmspInboundResult.setInsertUpdateRemark("无");
            /*
            设置入库日期
             */
            wmspInboundResult.setInboundTime(new Date());
              /*
            设置入库单状态为已下发
             */
            wmspInboundResult.setResultStatus(new BigDecimal(1));
            
            /*
            设置入库状态，当异常值为0时，入库状态设为未完成；当异常值为1时，入库状态设为完成
             */
            Integer K = 1;
            if(warehouseId.intValue() != 3){
                System.out.println(map.containsKey("abnormalis"));
                System.out.println(map.get("abnormalis"));
                 K =  (map.containsKey("abnormalis")&&map.get("abnormalis").toString().isEmpty())?Integer.valueOf(map.get("abnormalis").toString()):0;
            }
            if (K==0){
                wmspInboundResult.setResultStatus(new BigDecimal(0));
                wmspInboundResult.setInboundIscomplete(new BigDecimal(0));
            }
            else{
                wmspInboundResult.setResultStatus(new BigDecimal(1));
                wmspInboundResult.setInboundIscomplete(new BigDecimal(1));
            }
            Integer MN = null ;
            Integer CC = null ;
            Integer CX = null ;
            if(warehouseId.intValue() != 3){
                //根据垛位ID查询物资数，确定层次层序，即网格ID
                HashMap<String, Object> map1 = new HashMap<>();
                map1.put("stackingId",ST);
                //获取物资数
                 MN=rmsStackingService.selectMaterialNumber(map1);
                //计算层次号
                 CC=(MN)/24+1;
                //计算层序号
                 CX=(MN)%24+1;
                //更新垛位表
               rmsStackingService.updateStack(ST);
            }
            //根据仓库id、垛位ID，层次号，层序号查找仓储网格
            HashMap<String, Object> map3 = new HashMap<>();
            map3.put("warehouseId",warehouseId);
            map3.put("stackingID",ST);
            map3.put("gradationNumber",CC);
            map3.put("sequenceNumber",CX);
            BigDecimal gridId=rmsPwarehouseGridService.getGridId(map3);
            //设置入库实绩里面的网格ID
            wmspInboundResult.setGridId(gridId);
            /*
            插入一条网格物资中间表
             */
            WmspGridMaterial wmspGridMaterial = new WmspGridMaterial();
            //设置主键ID
            wmspGridMaterial.setGmId(wmspGridMaterialMapper.getCount());
            wmspGridMaterial.setGridId(gridId);
            wmspGridMaterial.setGmNumber(new BigDecimal(1));
            wmspGridMaterial.setStandardDataId(new BigDecimal(1));
            //设置网格物资表里面的物资ID
            BigDecimal materialId= DataChange.dataToBigDecimal(map.get("materialId"));
            wmspInboundResult.setMaterialId(materialId);
            wmspGridMaterial.setMaterialId(materialId);
            //设置逻辑删除字段
            wmspGridMaterial.setDeleted(new BigDecimal(0));
            //设置常规字段
            wmspGridMaterial.setInsertUsername("admin");
            wmspGridMaterial.setInsertTime(new Date());
            wmspGridMaterial.setUpdateUsername("admin");
            wmspGridMaterial.setUpdateTime(new Date());
            wmspGridMaterial.setInsertUpdateRemark("无");
            wmspGridMaterial.setStatus(new BigDecimal(2));
            wmspGridMaterialService.insertWmspGridMaterial(wmspGridMaterial);
            /*
            新增入库实绩主表
             */
            wmsInboundResultServiceImpl.insertWmsInboundResult(wmspInboundResult);
            /*
            新增天车司机接收实绩
             */
            WmspInboundDrivingResult wmspInboundDrivingResult = new WmspInboundDrivingResult();
            wmspInboundDrivingResult.setDrivingId(new BigDecimal(wmsInboundDrivingResultServiceImpl.count()+1));
            wmspInboundDrivingResult.setDriverId(new BigDecimal(9));
            wmspInboundDrivingResult.setDrivingReceiveTime(new Date());
            wmspInboundDrivingResult.setInboundResultId(wmspInboundResult.getInboundId());
            wmspInboundDrivingResult.setInsertUsername("admin");
            wmspInboundDrivingResult.setInsertTime(new Date());
            wmspInboundDrivingResult.setUpdateUsername("admin");
            wmspInboundDrivingResult.setResultDeleted(new BigDecimal(1));
            wmsInboundDrivingResultServiceImpl.insertWmspInboundDrivingResult(wmspInboundDrivingResult);
            /*
            新增选择垛位实绩
             */
            WmspInboundStackResult wmspInboundStackResult = new WmspInboundStackResult();
            wmspInboundStackResult.setResultId(new BigDecimal(wmsInboundStackResultServiceImpl.count()+1));
            wmspInboundStackResult.setInboundResultId(wmspInboundResult.getInboundId());
            wmspInboundStackResult.setStackingId(ST);
            wmspInboundStackResult.setResultDeleted(new BigDecimal(1));
            //设置常规字段
            wmspInboundStackResult.setInsertUsername("admin");
            wmspInboundStackResult.setInsertTime(new Date());
            wmspInboundStackResult.setUpdateUsername("admin");
            wmspInboundStackResult.setUpdateTime(new Date());
            wmspInboundStackResult.setInsertUpdateRemark("无");
            wmspInboundStackResult.setStackingStatus(new BigDecimal(0));
            wmsInboundStackResultServiceImpl.insertWmsInboundStackResult(wmspInboundStackResult);
            System.out.println(map.get("LOADA"));
            System.out.println(map.get("LOADB"));
            //判断物资是否为线材
            BigDecimal count = wmsInboundScanResultServiceImpl.selectMaterialTypeByMaterialId(materialId);

            BigDecimal resultId= new BigDecimal((Integer)map.get("resultId")) ;
//            BigDecimal RESULTBID= new BigDecimal((Integer)map.get("RESULTBID")) ;
            BigDecimal InbounId=wmspInboundResult.getInboundId();
            if(count!=null){
                /*
            编辑扫描实绩-根据前台返回的扫描实绩ID修改扫描实绩
            */
                HashMap<String, Object> map5 = new HashMap<>();
                Map<String,Object> otherLoadMap = new HashMap<>();
                otherLoadMap.put("personnelWorkshopid",map.get("personnelWorkshopid"));
                otherLoadMap.put("personnelShifts",map.get("personnelShifts"));
                otherLoadMap.put("personnelTeam",map.get("personnelTeam"));
                otherLoadMap.put("resultId",resultId);
                //获取同一班次班组车间扫描次数扫描实绩
                List<Map<String,Object>> otherResultIds = wmsInboundScanResultServiceImpl.getOntherLoadId(otherLoadMap);
                //根据物资id查询是否该物资为线材
                //设置另一个扫描实绩id为空
                BigDecimal otherResultId = null;
                //遍历查询出的同一班次班组车间扫描次数所有扫描实绩
                for (Map<String,Object> otherMap : otherResultIds) {
                    //判断，查询出来的扫描实绩id是否于点击下发的扫描实绩的id相同
                    //如果不同，将获取到的扫描实绩主键id赋予otherResultId
                    if (((BigDecimal) otherMap.get("resultId")).intValue() != resultId.intValue()) {
                        otherResultId = (BigDecimal) otherMap.get("resultId");
                    }
                }
                //更新扫描实绩
                map5.put("resultId",resultId);
                map5.put("InbounId",InbounId);
                wmsInboundScanResultServiceImpl.updateWmsInboundScanById(map5);
                map5.remove("resultId");
                map5.put("resultId",otherResultId);
                wmsInboundScanResultServiceImpl.updateWmsInboundScanById(map5);
            }
            //更新扫描实绩状态
            Map<String,Object> map7=new HashMap<>();
            map7.put("resultId",resultId);
            map7.put("InbounId",InbounId);
            wmsInboundScanResultServiceImpl.updateWmsInboundScanById(map7);
        }
        return success(inboundValue);
    }

    //根据入库实绩id查找扫描实绩
    @PostMapping("/selectScanResultByIboundResultId")
    @ApiOperation(value = "根据入库实绩id获得扫描实绩数据")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "apiId", value = "", required = false, dataType = "BigDecimal"),
    })
    public RESTfulResult selectScanResultByIboundResultId(@RequestBody(required = false) Map<String, Object> mapValue,
                                                          Integer apiId,
                                                          Integer pageNum,
                                                          Integer pageSize,
                                                          String con
    ) {
        if(con != null){
            if(!"undefined".equals(con)){
                String index = "get_wms_inboundScanResult";
                return success(esFeign.getConResult(mapValue,index,apiId,pageNum,pageSize,con));
            }
        }
        List<Map<String,Object>>inboundScanResultList = null;
        if(mapValue.size() == 0){
            //将查询结果存入索引中
            inboundScanResultList = wmsInboundResultServiceImpl.selectScanResultByIboundResultId(mapValue);
            Map<String, Object> inboundScanResultMap = new HashMap<>();
            //添加索引
            inboundScanResultMap.put("index","get_wms_inboundScanResult");
            //添加ID
            inboundScanResultMap.put("indexId","inboundScanResultId");
            inboundScanResultList.add(inboundScanResultMap);
            //新建索引
            esFeign.insertIndex(inboundScanResultList);
            //删除
            inboundScanResultList.remove(inboundScanResultList.size() -1);
        }
        if(inboundScanResultList == null) {
            inboundScanResultList = wmsInboundResultServiceImpl.selectScanResultByIboundResultId(mapValue);
        }
        /*分页*/
        PageHelper.startPage(pageNum, pageSize);
        List<Map<String,Object>> columnList = wmsInboundResultServiceImpl.selectScanResultByIboundResultId(mapValue);
        PageListAdd pageList = columnDataUtil.tableColumnData(apiId,inboundScanResultList,columnList);
        return success(pageList);

    }
}