package com.tld.service.impl;

import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.tld.mapper.ReceiveGoodsMapper;
import com.tld.model.ReceiveGoods;
import com.tld.service.ReceiveGoodsSerivce;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.*;

@Service
public class ReceiveGoodsSerivceImpl implements ReceiveGoodsSerivce {

    @Autowired
    private ReceiveGoodsMapper receiveGoodsMapper;


    @Override
    public Map<String, Object> getReceiveGoods(ReceiveGoods receiveGoods) {
        Map<String, Object> map = new HashMap<>();
        try{
            PageHelper.startPage(receiveGoods.getPage(), receiveGoods.getLimit());
            PageInfo<ReceiveGoods> pageInfo = new PageInfo<>(receiveGoodsMapper.getReceiveGoods(receiveGoods));
            map.put("data", pageInfo);
            map.put("msg", "200");
        }catch (Exception e){
            e.printStackTrace();
            map.put("msg", "500");
            map.put("errMsg", "服务器请求异常，请稍后再试");
        }
        return map;
    }

    @Override
    public Map<String, Object> getPastReceiveGoods(ReceiveGoods receiveGoods) {
        Map<String, Object> map = new HashMap<>();
        try{
            PageHelper.startPage(receiveGoods.getPage(), receiveGoods.getLimit());
            PageInfo<ReceiveGoods> pageInfo = new PageInfo<>(receiveGoodsMapper.getPastReceiveGoods(receiveGoods));
            map.put("data", pageInfo);
            map.put("msg", "200");
        }catch (Exception e){
            e.printStackTrace();
            map.put("msg", "500");
            map.put("errMsg", "服务器请求异常，请稍后再试");
        }
        return map;
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public Map<String, Object> addReceiveGoods(ReceiveGoods receiveGoods) {
        Map<String, Object> map = new HashMap<>();
        try{

            receiveGoods.setType("0");
            //存在一个采购单发送多次的情况  如果是一个采购单多次传输 则改变原数据的数量
            ReceiveGoods receiveGoods1 = new ReceiveGoods().setOrderCode(receiveGoods.getOrderCode()).setMaterialId(receiveGoods.getMaterialId());
            List<ReceiveGoods> list = receiveGoodsMapper.getReceiveGoods(receiveGoods1);
            if(list.size() != 0){
                receiveGoods.setArrivalNum(String.valueOf(Integer.parseInt(list.get(0).getArrivalNum()) + Integer.parseInt(receiveGoods.getArrivalNum())));
                receiveGoodsMapper.updateReceiveGoods(receiveGoods);
            } else {
                if(receiveGoodsMapper.getReceiveGoodsf(receiveGoods1) == 0){
                    receiveGoodsMapper.addReceiveGoodsf(receiveGoods);
                }
                receiveGoodsMapper.addReceiveGoods(receiveGoods);
            }
            //采购单日志
            receiveGoodsMapper.addReceiveGoodsLog(receiveGoods);
            map.put("msg", "200");
        } catch (Exception e) {
            e.printStackTrace();
            map.put("msg", "500");
            map.put("errMsg", "服务器请求异常，请稍后再试");
        }
        return map;
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public Map<String, Object> addReceiveGoodsConfirm(ReceiveGoods receiveGoods) {
        Map<String, Object> map = new HashMap<>();
        try{
            receiveGoods.setType("1");
            receiveGoodsMapper.updateReceiveGoods(receiveGoods);
            map.put("msg", "200");
        } catch (Exception e) {
            e.printStackTrace();
            map.put("msg", "500");
            map.put("errMsg", "服务器请求异常，请稍后再试");
        }
        return map;
    }
}