package com.by4cloud.platformx.device.service.impl;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.by4cloud.platformx.device.dto.ReceivingNoteQueryDTO;
import com.by4cloud.platformx.device.entity.*;
import com.by4cloud.platformx.device.mapper.*;
import com.by4cloud.platformx.device.service.ReceivingNoteService;
import lombok.AllArgsConstructor;
import org.springframework.stereotype.Service;

import java.io.Serializable;
import java.util.List;

/**
 * 验收表
 *
 * @author pig
 * @date 2025-03-13 11:03:52
 */
@Service
@AllArgsConstructor
public class ReceivingNoteServiceImpl extends ServiceImpl<ReceivingNoteMapper, ReceivingNote> implements ReceivingNoteService {

	private final ReceivingNoteItemMapper itemMapper;
	private final DeviceInventoryMapper inventoryMapper;
	private final InventoryFlowWaterMapper inventoryFlowWaterMapper;
	private final DeviceMapper deviceMapper;
	private final ContractMapper contractMapper;

	@Override
	public IPage pageNew(Page page, ReceivingNoteQueryDTO queryDTO) {
		return baseMapper.pageNew(page,queryDTO);
	}

	@Override
	public boolean saveDeep(ReceivingNote entity) {
		baseMapper.insert(entity);
		if (entity.getNoteItemList()!=null&&entity.getNoteItemList().size()>0){
			for (ReceivingNoteItem item:entity.getNoteItemList()
				 ) {
				item.setNoteId(entity.getId());
				itemMapper.insert(item);
				//设备库存同步新增
				if (item.getSerialNos()!=null&&item.getSerialNos().size()>0){
					for (String serialNo:item.getSerialNos()
						 ) {
						Device device = deviceMapper.selectById(item.getDeviceId());
						Contract contract = contractMapper.selectById(entity.getContractId());
						if (device!=null) {
							DeviceInventory inventory = new DeviceInventory();
							inventory.setDeviceId(item.getDeviceId());
							inventory.setDeviceNumber(item.getDeviceCode());
							inventory.setName(device.getName());
							inventory.setSerialNo(serialNo);
							if (contract!=null&&(contract.getType()==1||contract.getType()==2)){
								inventory.setSource(1);
								inventory.setInventoryStatus(1);
							}
							if (contract!=null&&contract.getType()==0){
								inventory.setSource(1);
								inventory.setInventoryStatus(2);
							}
							inventoryMapper.insert(inventory);
							//设备库存流水同步新增
							InventoryFlowWater flowWater = new InventoryFlowWater();
							flowWater.setDeviceId(item.getDeviceId());
							flowWater.setSerialNo(serialNo);
							flowWater.setInventoryId(inventory.getId());
							flowWater.setClassId(device.getClassId());
							if (contract!=null&&(contract.getType()==1||contract.getType()==2)){
								flowWater.setOperateType(2);
							}
							if (contract!=null&&contract.getType()==0){
								flowWater.setOperateType(1);
							}
							inventoryFlowWaterMapper.insert(flowWater);
						}
					}

				}
			}
		}
		return Boolean.TRUE;
	}

	@Override
	public boolean updateByIdDeep(ReceivingNote entity) {
		baseMapper.updateById(entity);
		QueryWrapper<ReceivingNoteItem> queryWrapper = new QueryWrapper<>();
		queryWrapper.eq("note_id",entity.getId());
		itemMapper.delete(queryWrapper);
		if (entity.getNoteItemList()!=null&&entity.getNoteItemList().size()>0){
			for (ReceivingNoteItem item:entity.getNoteItemList()
			) {
				item.setNoteId(entity.getId());
				itemMapper.insert(item);
			}
		}
		return Boolean.TRUE;
	}

	@Override
	public ReceivingNote getByIdDeep(Long id) {
		ReceivingNote note = baseMapper.selectById(id);
		QueryWrapper<ReceivingNoteItem> queryWrapper = new QueryWrapper<>();
		queryWrapper.eq("note_id",note.getId());
		List<ReceivingNoteItem> itemList = itemMapper.selectList(queryWrapper);
		note.setNoteItemList(itemList);
		return note;
	}
}