/*
 *      Copyright (c) 2018-2028, Chill Zhuang All rights reserved.
 *
 *  Redistribution and use in source and binary forms, with or without
 *  modification, are permitted provided that the following conditions are met:
 *
 *  Redistributions of source code must retain the above copyright notice,
 *  this list of conditions and the following disclaimer.
 *  Redistributions in binary form must reproduce the above copyright
 *  notice, this list of conditions and the following disclaimer in the
 *  documentation and/or other materials provided with the distribution.
 *  Neither the name of the dreamlu.net developer nor the names of its
 *  contributors may be used to endorse or promote products derived from
 *  this software without specific prior written permission.
 *  Author: Chill 庄骞 (smallchill@163.com)
 */
package org.springblade.modules.processInv.service.impl;

import org.springblade.modules.processInv.entity.ProcessInv;
import org.springblade.modules.processInv.mapper.ProcessInvMapper;
import org.springblade.modules.processInv.service.IProcessInvService;
import org.springblade.modules.processInv.vo.ProcessInvVO;
import org.springblade.core.mp.base.BaseServiceImpl;
import org.springframework.stereotype.Service;
import com.baomidou.mybatisplus.core.metadata.IPage;

import java.util.Date;

/**
 * 加工库存表 服务实现类
 *
 * @author BladeX
 * @since 2022-08-01
 */
@Service
public class ProcessInvServiceImpl extends BaseServiceImpl<ProcessInvMapper, ProcessInv> implements IProcessInvService {

	@Override
	public IPage<ProcessInvVO> selectProcessInvPage(IPage<ProcessInvVO> page, ProcessInvVO processInv) {
		return page.setRecords(baseMapper.selectProcessInvPage(page, processInv));
	}

	@Override
	public Boolean insertOrUpdate(ProcessInv processInv) {
		//通过strainId和productId查询对应数据
		ProcessInv processInv1 = baseMapper.selectBy2Id(processInv.getStrainId(),processInv.getProductId());
		if (processInv1 != null){
			//当存在该数据时，修改
			processInv1.setProductInventoryNum(processInv1.getProductInventoryNum()+processInv.getProductInventoryNum());
			processInv1.setUpdateTime(new Date());
			processInv1.setUpdateUser(processInv.getUpdateUser());
			return baseMapper.updateById(processInv1)>0;
		}else {
			//不存在该数据时添加
			return baseMapper.add(processInv);
		}
	}

	@Override
	public boolean stockCompare(Double saleNum, String proid) {
		return baseMapper.stockCompare(saleNum,proid);
	}

	@Override
	public Boolean stockReduce(Double saleNum, String proid) {
		return baseMapper.stockReduce(saleNum,proid);
	}

	@Override
	public ProcessInv selectBy2Id(String strainId, String processId) {
		return baseMapper.selectBy2Id(Long.parseLong(strainId),Long.parseLong(processId));
	}

	@Override
	public Boolean del(Long id) {
		return baseMapper.del(id);
	}

}