package com.yuanchu.mom.service.impl;
import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yuanchu.mom.common.GetLook;
import com.yuanchu.mom.common.PrintChina;
import com.yuanchu.mom.mapper.ProcessTotaldealMapper;
import com.yuanchu.mom.pojo.ProcessDeal;
import com.yuanchu.mom.mapper.ProcessDealMapper;
import com.yuanchu.mom.pojo.ProcessEvaluate;
import com.yuanchu.mom.pojo.ProcessTotaldeal;
import com.yuanchu.mom.service.ProcessDealService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.yuanchu.mom.utils.QueryWrappers;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.ExceptionHandler;
import javax.annotation.Resource;
import java.time.LocalDate;
import java.time.format.DateTimeFormatter;
import java.util.HashMap;
import java.util.Map;
/**
*
* 检测或校准物品的处置 服务实现类
*
*
* @author
* @since 2024-11-02 02:50:19
*/
@Service
@Transactional(rollbackFor = Exception.class)
public class ProcessDealServiceImpl extends ServiceImpl implements ProcessDealService {
@Resource
private ProcessDealMapper processDealMapper;
@Resource
GetLook getLook;
@Resource
private ProcessTotaldealMapper processTotaldealMapper;
@Override
public Map pageProcessDeal(Page page, ProcessDeal processDeal) {
Map map = new HashMap<>();
map.put("head", PrintChina.printChina(ProcessDeal.class));
Map map1 = getLook.selectPowerByMethodAndUserId("pageProcessDeal");
if (map1.get("look") == 1) processDeal.setCreateUser(map1.get("userId"));
if (ObjectUtils.isEmpty(processDeal.getTotaldealId())) {
//获取当前月份
LocalDate currentDate = LocalDate.now();
// 定义日期格式
DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM");
// 格式化当前日期
String currentMonth = currentDate.format(formatter);
//查询历史
ProcessTotaldeal processTotaldeal = processTotaldealMapper.selectOne(Wrappers.lambdaQuery().eq(ProcessTotaldeal::getMonth, currentMonth));
processDeal.setTotaldealId(processTotaldeal.getId());
}
map.put("body", processDealMapper.pageProcessDeal(page, QueryWrappers.queryWrappers(processDeal)));
return map;
}
@Override
public int addProcessDeal(ProcessDeal processDeal) {
ProcessTotaldeal processTotaldeal;
if (ObjectUtils.isEmpty(processDeal.getTotaldealId())){
LocalDate dealTime = LocalDate.now();
// 定义日期格式
DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM");
// 格式化当前日期
String currentMonth = dealTime.format(formatter);
processTotaldeal= processTotaldealMapper.selectOne(Wrappers.lambdaQuery().eq(ProcessTotaldeal::getMonth,currentMonth));
processDeal.setTotaldealId(processTotaldeal.getId());
}else {
processTotaldeal= processTotaldealMapper.selectById(processDeal.getTotaldealId());
}
processDealMapper.insert(processDeal);
processTotaldeal.setTotalNum(processDeal.getNum()+processTotaldeal.getTotalNum());
return processTotaldealMapper.updateById(processTotaldeal);
}
@Override
public int delProcessDeal(Integer id) {
ProcessDeal processDeal = processDealMapper.selectById(id);
processDealMapper.deleteById(id);
ProcessTotaldeal processTotaldeal = processTotaldealMapper.selectById(processDeal.getTotaldealId());
processTotaldeal.setTotalNum(processTotaldeal.getTotalNum()-processDeal.getNum());
return processTotaldealMapper.updateById(processTotaldeal);
}
@Override
public int doProcessDeal(ProcessDeal processDeal) {
if (ObjectUtils.isNotEmpty(processDeal.getNum())) {
ProcessDeal oldProcessDeal = processDealMapper.selectById(processDeal.getId());
ProcessTotaldeal processTotaldeal = processTotaldealMapper.selectById(processDeal.getTotaldealId());
processTotaldeal.setTotalNum(processTotaldeal.getTotalNum() - oldProcessDeal.getNum() + processDeal.getNum());
processTotaldealMapper.updateById(processTotaldeal);
}
return processDealMapper.updateById(processDeal);
}
}