package com.example.erp.service.sd; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.baomidou.dynamic.datasource.annotation.DS; import com.example.erp.entity.sd.*; import com.example.erp.entity.userInfo.SysError; import com.example.erp.mapper.mm.FinishedGoodsInventoryMapper; import com.example.erp.mapper.sd.*; import com.example.erp.service.userInfo.SysErrorService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.interceptor.TransactionAspectSupport; import java.text.SimpleDateFormat; import java.time.LocalDate; import java.util.*; @Service @DS("sd") @Transactional(rollbackFor = Exception.class) public class CustomerService { @Autowired CustomerMapper customerMapper; @Autowired SysErrorService sysErrorService; public Map getSelectCustomer(Integer pageNum, Integer pageSize, Customer customer) { Integer offset = (pageNum - 1) * pageSize; Map map = new HashMap<>(); map.put("data", customerMapper.getSelectCustomer(offset, pageSize, customer)); map.put("total", customerMapper.getSelectCustomerPageTotal(offset, pageSize, customer)); return map; } public Boolean insertCustomer(Map object) { boolean saveState = true; //设置回滚点 Object savePoint = TransactionAspectSupport.currentTransactionStatus().createSavepoint(); try { Customer customer = JSONObject.parseObject(JSONObject.toJSONString(object.get("customer")), Customer.class); if(customer!=null){ if (customer.getId()!=null && customer.getId()!=0){ System.out.println(111); customerMapper.updateCustomer(customer); }else{ System.out.println(222); customerMapper.insertCustomer(customer); } } } catch (Exception e) { TransactionAspectSupport.currentTransactionStatus().rollbackToSavepoint(savePoint); //将异常传入数据库 SysError sysError = new SysError(); sysError.setError(e.toString()); sysError.setFunc("saveOrder"); sysErrorService.insert(sysError); saveState = false; } return saveState; } public Boolean deleteCustomer(Map object) { boolean saveState = true; //设置回滚点 Object savePoint = TransactionAspectSupport.currentTransactionStatus().createSavepoint(); try { Customer customer = JSONObject.parseObject(JSONObject.toJSONString(object.get("customer")), Customer.class); if(customer!=null){ if (customer.getId()!=null){ customerMapper.deleteCustomer(customer); } } } catch (Exception e) { TransactionAspectSupport.currentTransactionStatus().rollbackToSavepoint(savePoint); //将异常传入数据库 SysError sysError = new SysError(); sysError.setError(e.toString()); sysError.setFunc("saveOrder"); sysErrorService.insert(sysError); saveState = false; } return saveState; } }