udi-wms-java/src/main/java/com/glxp/api/controller/inout/IoOrderMutiController.java

package com.glxp.api.controller.inout;

import cn.hutool.core.util.IdUtil;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.github.pagehelper.PageInfo;
import com.glxp.api.common.res.BaseResponse;
import com.glxp.api.common.util.ResultVOUtils;
import com.glxp.api.constant.Constant;
import com.glxp.api.entity.basic.UdiEntity;
import com.glxp.api.entity.basic.UdiProductEntity;
import com.glxp.api.entity.inout.IoOrderMutiEntity;
import com.glxp.api.entity.inout.IoOrderMutiSetEntity;
import com.glxp.api.entity.inout.IoOrderMutiUseEntity;
import com.glxp.api.req.inout.IoOrderMutiRequest;
import com.glxp.api.res.inout.IoOrderMutiResponse;
import com.glxp.api.res.inout.IoOrderMutiSetResponse;
import com.glxp.api.service.auth.CustomerService;
import com.glxp.api.service.basic.UdiProductService;
import com.glxp.api.service.inout.IoOrderMutiService;
import com.glxp.api.service.inout.IoOrderMutiUseService;
import com.glxp.api.util.GennerOrderUtils;
import com.glxp.api.util.OrderNoTypeBean;
import com.glxp.api.util.RedisUtil;
import com.glxp.api.util.udi.FilterUdiUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;
import java.lang.reflect.InvocationTargetException;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

@RestController
public class IoOrderMutiController {

    @Resource
    private IoOrderMutiService ioOrderMutiService;
    @Resource
    private UdiProductService udiProductService;
    @Resource
    private IoOrderMutiUseService ioOrderMutiUseService;
    @Resource
    RedisUtil redisUtil;
    @Resource
    CustomerService customerService;
    @Resource
    GennerOrderUtils gennerOrderUtils;


    @PostMapping("/udiwms/inout/order/muti/checkUdi")
    public BaseResponse checkUdi(@RequestBody IoOrderMutiEntity ioOrderMutiEntity) {

        if (StrUtil.isNotBlank(ioOrderMutiEntity.getUdiCode())) {
            //查询码是否包含序列号
            UdiEntity udiEntity = FilterUdiUtils.getUdi(ioOrderMutiEntity.getUdiCode());
            if (StrUtil.isNotBlank(udiEntity.getSerialNo())) {
                //包含
                QueryWrapper<IoOrderMutiEntity> ew = new QueryWrapper<>();
                ew.eq("udiCode", ioOrderMutiEntity.getUdiCode());
                IoOrderMutiEntity ioOrderMutiEntityOne = ioOrderMutiService.getOne(ew);
                //查询是否被使用过
                if (ioOrderMutiEntityOne != null) {
                    if (ioOrderMutiEntityOne.getReCount() == 0) {
                        return ResultVOUtils.error(999, "该产品库存不足！");
                    }
                    return ResultVOUtils.success(ioOrderMutiEntityOne.getId());
                } else {
                    //查询物资信息
                    UdiProductEntity udiProductEntity = udiProductService.findByNameCode(udiEntity.getUdi());
                    ioOrderMutiEntityOne = new IoOrderMutiEntity();
                    ioOrderMutiEntityOne.setId(IdUtil.getSnowflakeNextId());
                    ioOrderMutiEntityOne.setUdiCode(ioOrderMutiEntity.getUdiCode());
                    ioOrderMutiEntityOne.setBatchNo(udiProductEntity.getBatchNo());
                    ioOrderMutiEntityOne.setExpireDate(udiProductEntity.getExpireDate());
                    ioOrderMutiEntityOne.setProduceDate(udiProductEntity.getProduceDate());
                    ioOrderMutiEntityOne.setTotalCount(20);
                    ioOrderMutiEntityOne.setStatus(0);
                    ioOrderMutiEntityOne.setCreateUser(customerService.getUserId() + "");
                    ioOrderMutiEntityOne.setUseCount(0);
                    ioOrderMutiEntityOne.setReCount(20);
                    ioOrderMutiEntityOne.setCreateTime(new Date());
                    ioOrderMutiEntityOne.setUpdateTime(new Date());
                    ioOrderMutiEntityOne.setNameCode(udiProductEntity.getNameCode());
                    ioOrderMutiEntityOne.setSerialNo(udiProductEntity.getSerialNo());
                    ioOrderMutiEntityOne.setSupId(udiProductEntity.getSupId());
                    ioOrderMutiService.save(ioOrderMutiEntityOne);
                    return ResultVOUtils.success(ioOrderMutiEntityOne.getId());
                }
            } else {
                //不包含
                return ResultVOUtils.error(888, "");
            }
        } else {
            return ResultVOUtils.error(999, "请选填写UDI码！");
        }
    }


    @GetMapping("/udiwms/inout/order/muti/filterMutiList")
    public BaseResponse filterMutiList(IoOrderMutiEntity ioOrderMutiEntity) {

        ioOrderMutiEntity = ioOrderMutiService.getById(ioOrderMutiEntity.getId());
        UdiProductEntity udiProductEntity = udiProductService.findByNameCode(ioOrderMutiEntity.getNameCode());
        IoOrderMutiResponse ioOrderMutiResponse = new IoOrderMutiResponse();
        BeanUtils.copyProperties(ioOrderMutiEntity, ioOrderMutiResponse);
        ioOrderMutiResponse.setCpmctymc(udiProductEntity.getCpmctymc());
        ioOrderMutiResponse.setGgxh(udiProductEntity.getGgxh());
        QueryWrapper<IoOrderMutiUseEntity> ew = new QueryWrapper<>();
        ew.eq("mutiIdFk", ioOrderMutiEntity.getId());
        ew.select("io_order_muti_use.*,(SELECT userName FROM auth_user WHERE auth_user.id=io_order_muti_use.useUser) as createUserName");
        List<IoOrderMutiUseEntity> ioOrderMutiUseEntityList = ioOrderMutiUseService.list(ew);
        Map<String, Object> map = new HashMap<>();
        map.put("data", ioOrderMutiResponse);
        map.put("detailList", ioOrderMutiUseEntityList);
        return ResultVOUtils.success(map);

    }


    @PostMapping("/udiwms/inout/order/muti/addOrderMuti")
    public BaseResponse addOrderMuti(@RequestBody IoOrderMutiEntity ioOrderMutiEntity) {

        if (StrUtil.isNotBlank(ioOrderMutiEntity.getUdiCode())) {
            UdiEntity udiEntity = FilterUdiUtils.getUdi(ioOrderMutiEntity.getUdiCode());
            //查询物资信息
            UdiProductEntity udiProductEntity = udiProductService.findByNameCode(udiEntity.getUdi());

            IoOrderMutiEntity ioOrderMutiEntity1 = new IoOrderMutiEntity();
            ioOrderMutiEntity1.setId(IdUtil.getSnowflakeNextId());
            ioOrderMutiEntity1.setUdiCode(ioOrderMutiEntity.getUdiCode());
            ioOrderMutiEntity1.setBatchNo(udiProductEntity.getBatchNo());
            ioOrderMutiEntity1.setExpireDate(udiProductEntity.getExpireDate());
            ioOrderMutiEntity1.setProduceDate(udiProductEntity.getProduceDate());
            ioOrderMutiEntity1.setTotalCount(20);
            ioOrderMutiEntity1.setStatus(0);
            ioOrderMutiEntity1.setUseCount(0);
            ioOrderMutiEntity1.setReCount(20);
            ioOrderMutiEntity1.setCreateUser(customerService.getUserId() + "");
            ioOrderMutiEntity1.setCreateTime(new Date());
            ioOrderMutiEntity1.setUpdateTime(new Date());
            ioOrderMutiEntity1.setNameCode(udiProductEntity.getNameCode());
            ioOrderMutiEntity1.setSerialNo(udiProductEntity.getSerialNo());
            ioOrderMutiEntity1.setSupId(udiProductEntity.getSupId());
            ioOrderMutiService.save(ioOrderMutiEntity1);
            return ResultVOUtils.success(ioOrderMutiEntity1.getId());
        } else {
            return ResultVOUtils.error(999, "请选填写UDI码！");
        }
    }

    @PostMapping("/udiwms/inout/order/muti/updateOrderMuti")
    public BaseResponse updateOrderMuti(@RequestBody IoOrderMutiEntity ioOrderMutiEntity) {
        ioOrderMutiEntity.setReCount(ioOrderMutiEntity.getTotalCount() - ioOrderMutiEntity.getUseCount());
        ioOrderMutiEntity.setCreateTime(new Date());
        ioOrderMutiEntity.setCreateUser(customerService.getUserId() + "");
        ioOrderMutiEntity.setUpdateTime(new Date());
        ioOrderMutiEntity.setUpdateUser(customerService.getUserId() + "");
        boolean falg = ioOrderMutiService.updateById(ioOrderMutiEntity);


        QueryWrapper<IoOrderMutiUseEntity> ew = new QueryWrapper<>();
        ew.eq("mutiIdFk", ioOrderMutiEntity.getId());
        List<IoOrderMutiUseEntity> ioOrderMutiUseEntityList = ioOrderMutiUseService.list(ew);
        for (IoOrderMutiUseEntity ioOrderMutiUseEntity : ioOrderMutiUseEntityList) {
            ioOrderMutiUseEntity.setStatus(1);
        }
        ioOrderMutiUseService.updateBatchById(ioOrderMutiUseEntityList);

        if (falg) {
            return ResultVOUtils.success();
        } else {
            return ResultVOUtils.error(999, "更新失败");
        }
    }


    @PostMapping("/udiwms/inout/order/muti/filterMutiDetailList")
    public BaseResponse filterMutiDetailList(@RequestBody IoOrderMutiRequest ioOrderMutiRequest) {

        ioOrderMutiRequest.setStatus(0);
        List<IoOrderMutiResponse> ioOrderMutiEntityList = ioOrderMutiService.filterList(ioOrderMutiRequest);
        return ResultVOUtils.success(ioOrderMutiEntityList);
    }

    @PostMapping("/udiwms/inout/order/muti/selectMutiDetailList")
    public BaseResponse selectMutiDetailList(@RequestBody IoOrderMutiUseEntity ioOrderMutiUseEntity) {

        QueryWrapper<IoOrderMutiUseEntity> ew = new QueryWrapper<>();
        ew.eq("mutiIdFk", ioOrderMutiUseEntity.getMutiIdFk());
        ew.select("io_order_muti_use.*,(SELECT userName FROM auth_user WHERE auth_user.id=io_order_muti_use.useUser) as createUserName");
        List<IoOrderMutiUseEntity> ioOrderMutiEntityList = ioOrderMutiUseService.list(ew);
        return ResultVOUtils.success(ioOrderMutiEntityList);
    }


    @PostMapping("/udiwms/inout/order/muti/selectMutiList")
    public BaseResponse selectMutiList(@RequestBody IoOrderMutiRequest ioOrderMutiRequest) {
        List<IoOrderMutiResponse> list = ioOrderMutiService.filterList(ioOrderMutiRequest);
        PageInfo<IoOrderMutiResponse> pageInfo = new PageInfo<>(list);
        return ResultVOUtils.page(pageInfo);
    }


    @PostMapping("/udiwms/inout/order/muti/addMutiDetail")
    public BaseResponse addMutiDetail(@RequestBody IoOrderMutiUseEntity ioOrderMutiUseEntity) {
        int sum = 0;
        QueryWrapper<IoOrderMutiUseEntity> ew = new QueryWrapper<>();
        ew.eq("mutiIdFk", ioOrderMutiUseEntity.getMutiIdFk());
        Long count = ioOrderMutiUseService.count(ew);
        if (count == null) {
            sum = 0;
        } else {
            sum = count.intValue();
        }
        IoOrderMutiEntity ioOrderMutiEntity = ioOrderMutiService.getById(ioOrderMutiUseEntity.getMutiIdFk());
        if (ioOrderMutiEntity.getTotalCount() - count == 0) {
            return ResultVOUtils.error(999, "该产品数量不足！");
        }
        ioOrderMutiUseEntity.setId(IdUtil.getSnowflakeNextId());
        ioOrderMutiUseEntity.setCurIndex(sum + 1);
        ioOrderMutiUseEntity.setUseUser(customerService.getUserId() + "");
        ioOrderMutiUseEntity.setUseTime(new Date());
        ioOrderMutiUseService.save(ioOrderMutiUseEntity);
        return ResultVOUtils.success();
    }

    @GetMapping("/udiwms/inout/order/muti/getMark")
    public BaseResponse getMark() {
        String recordId = gennerOrderUtils.createOrderMark(new OrderNoTypeBean("yyMMdd"));
        return ResultVOUtils.success(recordId);
    }

    @PostMapping("/udiwms/inout/order/muti/delectMutiDelect")
    public BaseResponse delectMutiDelect(@RequestBody IoOrderMutiUseEntity ioOrderMutiUseEntity) {
        ioOrderMutiUseService.removeById(ioOrderMutiUseEntity);
        return ResultVOUtils.success();
    }

    @PostMapping("/udiwms/inout/order/muti/delectMuti")
    public BaseResponse delectMuti(@RequestBody IoOrderMutiEntity ioOrderMutiEntity) {

        Boolean falg=ioOrderMutiService.removeById(ioOrderMutiEntity);
        if(falg){
            return  ResultVOUtils.success();
        }else{
            return ResultVOUtils.error(999,"删除失败");
        }
    }
}