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<String, Object> getseletCustomer(Integer pageNum, Integer pageSize, Customer customer) {
|
Integer offset = (pageNum - 1) * pageSize;
|
|
Map<String, Object> map = new HashMap<>();
|
map.put("data", customerMapper.getseletCustomer(offset, pageSize, customer));
|
map.put("total", customerMapper.getseletCustomerPageTotal(offset, pageSize, customer));
|
return map;
|
}
|
|
|
public Boolean insertCustomer(Map<String,Object> 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<String,Object> 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;
|
|
}
|
|
|
}
|
