package com.example.erp.service.mm;
|
|
import cn.hutool.core.util.StrUtil;
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.alibaba.fastjson.TypeReference;
|
import com.baomidou.dynamic.datasource.annotation.DS;
|
import com.example.erp.entity.mm.*;
|
import com.example.erp.entity.sd.*;
|
import com.example.erp.entity.userInfo.Log;
|
import com.example.erp.entity.userInfo.SysError;
|
import com.example.erp.mapper.mm.BasicWarehouseTypeMapper;
|
import com.example.erp.mapper.mm.FinishedGlassShelfMapper;
|
import com.example.erp.mapper.mm.MaterialInventoryMapper;
|
import com.example.erp.mapper.mm.MaterialStoreMapper;
|
import com.example.erp.service.userInfo.LogService;
|
import com.example.erp.service.userInfo.SysErrorService;
|
import com.fasterxml.jackson.core.JsonProcessingException;
|
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.math.BigDecimal;
|
import java.math.RoundingMode;
|
import java.text.DecimalFormat;
|
import java.text.SimpleDateFormat;
|
import java.time.LocalDate;
|
import java.util.*;
|
import java.util.concurrent.atomic.AtomicReference;
|
import java.util.stream.Collectors;
|
|
@Service
|
@DS("mm")
|
@Transactional(rollbackFor = Exception.class)
|
public class FinishedGlassShelfService {
|
@Autowired
|
FinishedGlassShelfMapper finishedGlassShelfMapper;
|
@Autowired
|
SysErrorService sysErrorService;
|
@Autowired
|
LogService logService;
|
|
public String saveFinishedGlassShelf(Map<String,Object> object) {
|
String saveState = "true";
|
//设置回滚点
|
Object savePoint = TransactionAspectSupport.currentTransactionStatus().createSavepoint();
|
try {
|
Log log = new Log();
|
log.setOperatorId(object.get("userId").toString());
|
log.setOperator(object.get("userName").toString());
|
log.setContent(object.toString());
|
|
String userName = "";
|
if (object.get("userName") != null) {
|
userName = object.get("userName").toString();
|
}
|
|
FinishedGlassShelfInformation finishedGlassShelfInformation =
|
JSONObject.parseObject(JSONObject.toJSONString(object.get("title")), FinishedGlassShelfInformation.class);
|
finishedGlassShelfInformation.setMoney(finishedGlassShelfInformation.getPrice()*finishedGlassShelfInformation.getTotalQuantity());
|
|
List<FinishedGlassShelfInformation> finishedGlassShelfInformationList=finishedGlassShelfMapper
|
.getSelectFinishedGlassShelfInformation(finishedGlassShelfInformation);
|
|
if(finishedGlassShelfInformation.getId()>0){
|
finishedGlassShelfMapper.updateFinishedGlassShelfInformation(finishedGlassShelfInformation,finishedGlassShelfInformation.getId());
|
log.setFunction("saveFinishedGlassShelf修改1");
|
}else{
|
if(finishedGlassShelfInformationList.size()==0){
|
finishedGlassShelfMapper.insetFinishedGlassShelfInformation(finishedGlassShelfInformation);
|
log.setFunction("saveFinishedGlassShelf新增");
|
}else if(finishedGlassShelfInformationList.size()==1){
|
finishedGlassShelfMapper.updateFinishedGlassShelfInformationQuantity(finishedGlassShelfInformation.getTotalQuantity(),finishedGlassShelfInformationList.get(0).getId());
|
log.setFunction("saveFinishedGlassShelf修改2");
|
}else{
|
saveState = "false";
|
}
|
|
if(saveState.equals("true")){
|
finishedGlassShelfMapper.insetFinishedGlassShelfLog(finishedGlassShelfInformation);
|
}
|
}
|
|
|
|
|
|
logService.saveLog(log);
|
|
} catch (Exception e) {
|
TransactionAspectSupport.currentTransactionStatus().rollbackToSavepoint(savePoint);
|
//将异常传入数据库
|
SysError sysError = new SysError();
|
sysError.setError(e+Arrays.toString(e.getStackTrace()));
|
sysError.setFunc("saveFinishedGlassShelf");
|
sysErrorService.insert(sysError);
|
saveState = "false";
|
|
}
|
return saveState;
|
|
}
|
|
public Map<String, Object> getSelectFinishedGlassShelfInformation(Integer pageNum, Integer pageSize) {
|
Integer offset = (pageNum - 1) * pageSize;
|
Map<String, Object> map = new HashMap<>();
|
map.put("data", finishedGlassShelfMapper.getSelectFinishedGlassShelfInformationDate(offset, pageSize));
|
map.put("total", finishedGlassShelfMapper.getSelectFinishedGlassShelfInformationDatePageTotal(offset, pageSize));
|
return map;
|
}
|
|
public Map<String, Object> getSelectFinishedGlassShelfInformationById(Long id) {
|
Map<String, Object> map = new HashMap<>();
|
map.put("data", finishedGlassShelfMapper.getSelectFinishedGlassShelfInformationById(id));
|
return map;
|
}
|
|
|
public String deleteFinishedGlassShelfInformationById(Map<String,Object> object) {
|
String saveState = "true";
|
//设置回滚点
|
Object savePoint = TransactionAspectSupport.currentTransactionStatus().createSavepoint();
|
try {
|
Long id = 0l;
|
if (object.get("id") != null) {
|
id = Long.valueOf(object.get("id").toString());
|
}
|
|
finishedGlassShelfMapper.deleteFinishedGlassShelfInformationById(id);
|
|
Log log = new Log();
|
log.setOperatorId(object.get("userId").toString());
|
log.setOperator(object.get("userName").toString());
|
log.setContent(object.toString());
|
log.setFunction("deleteFinishedGlassShelfInformationById删除："+id);
|
logService.saveLog(log);
|
|
|
|
} catch (Exception e) {
|
TransactionAspectSupport.currentTransactionStatus().rollbackToSavepoint(savePoint);
|
//将异常传入数据库
|
SysError sysError = new SysError();
|
sysError.setError(e+Arrays.toString(e.getStackTrace()));
|
sysError.setFunc("eleteFinishedGlassShelfInformationById");
|
sysErrorService.insert(sysError);
|
saveState = "false";
|
|
}
|
return saveState;
|
|
}
|
|
public Map<String, Object> getSelectFinishedGlassShelfInformationDetails(Integer pageNum, Integer pageSize, String ids) {
|
if (ids.startsWith("\"") && ids.endsWith("\"")) {
|
ids = ids.substring(1, ids.length() - 1); // 去除首尾引号
|
}
|
List<Long> id=new ArrayList<>();;
|
if(ids!=null && !ids.isEmpty()){
|
List<String> result = StrUtil.split(ids, '|');
|
id=result.stream().map(Long::valueOf).collect(Collectors.toList());
|
}
|
Map<String, Object> map = new HashMap<>();
|
map.put("data", finishedGlassShelfMapper.getSelectFinishedGlassShelfInformationInId(id));
|
return map;
|
}
|
|
public Map<String, Object> getSelectFinishedGlassShelfEmitDetails(Integer pageNum, Integer pageSize, String emitId) {
|
if (emitId.startsWith("\"") && emitId.endsWith("\"")) {
|
emitId = emitId.substring(1, emitId.length() - 1); // 去除首尾引号
|
}
|
Map<String, Object> map = new HashMap<>();
|
map.put("emit", finishedGlassShelfMapper.getSelectFinishedGlassShelfEmitByemitId(emitId));
|
map.put("data", finishedGlassShelfMapper.getSelectFinishedGlassShelfEmitDetailsByemitId(emitId));
|
return map;
|
}
|
|
|
public String insertFinishedGlassShelfEmit(Map<String,Object> object) {
|
|
String saveState = "true";
|
//设置回滚点
|
Object savePoint = TransactionAspectSupport.currentTransactionStatus().createSavepoint();
|
|
try {
|
String emitId="";
|
String oddNumber = null;
|
if (object.get("emitId") != null) {
|
emitId = object.get("emitId").toString();
|
} else {
|
emitId = "";
|
}
|
FinishedGlassShelfEmit finishedGlassShelfEmit = JSONObject.parseObject(JSONObject.toJSONString(object.get("title")), FinishedGlassShelfEmit.class);
|
List<FinishedGlassShelfEmitDetails> finishedGlassShelfEmitDetailsList = JSONArray.parseArray(JSONObject.toJSONString(object.get("emitDetails")), FinishedGlassShelfEmitDetails.class);
|
//查询出库单是否存在
|
FinishedGlassShelfEmit finishedGlassShelfEmit2 = finishedGlassShelfMapper.getSelectFinishedGlassShelfEmitByemitId(emitId);
|
|
Log log = new Log();
|
log.setOperator(object.get("userName").toString());
|
log.setOperatorId(object.get("userId").toString());
|
log.setContent(object.toString());
|
|
if (finishedGlassShelfEmit2 != null) {
|
//编辑还原数据
|
List<FinishedGlassShelfEmitDetails> finishedGlassShelfEmitDetailsList2 = finishedGlassShelfMapper.getSelectFinishedGlassShelfEmitDetailsByemitId1(emitId);
|
if (!finishedGlassShelfEmitDetailsList2.isEmpty()) {
|
for (FinishedGlassShelfEmitDetails finishedGlassShelfEmitDetails : finishedGlassShelfEmitDetailsList2) {
|
finishedGlassShelfMapper.updateInformationAvailableQuantityInt(finishedGlassShelfEmitDetails);
|
finishedGlassShelfMapper.deleteFinishedGlassShelfEmitDetails(emitId);
|
finishedGlassShelfMapper.updateFinishedGlassShelfEmitDetailsLog(emitId);
|
}
|
}
|
|
oddNumber = emitId;
|
finishedGlassShelfMapper.updateFinishedGlassShelfEmit(finishedGlassShelfEmit, oddNumber);
|
log.setFunction("insertDelivery修改:"+oddNumber);
|
} else {
|
//获取单号
|
oddNumber = orderNumberSetting("出库");
|
//新增出库数据
|
finishedGlassShelfMapper.insertFinishedGlassShelfEmit(finishedGlassShelfEmit, oddNumber);
|
log.setFunction("insertFinishedGlassShelfEmit新增:"+oddNumber);
|
}
|
|
//获取对象集合循环进行新增修改
|
if (finishedGlassShelfEmitDetailsList.size()>0) {
|
int index=1;
|
for (FinishedGlassShelfEmitDetails finishedGlassShelfEmitDetails:finishedGlassShelfEmitDetailsList){
|
finishedGlassShelfEmitDetails.setMoney(finishedGlassShelfEmitDetails.getPrice()*finishedGlassShelfEmitDetails.getQuantity());
|
finishedGlassShelfMapper.updateInformationAvailableQuantityOut(finishedGlassShelfEmitDetails);
|
finishedGlassShelfMapper.insertFinishedGlassShelfEmitDetails(oddNumber,index,finishedGlassShelfEmitDetails);
|
finishedGlassShelfMapper.insertFinishedGlassShelfEmitDetailsLog(oddNumber,index,finishedGlassShelfEmitDetails);
|
index++;
|
}
|
logService.saveLog(log);
|
} else {
|
return "false3";
|
}
|
}catch (Exception e) {
|
TransactionAspectSupport.currentTransactionStatus().rollbackToSavepoint(savePoint);
|
//将异常传入数据库
|
SysError sysError = new SysError();
|
sysError.setError(e+Arrays.toString(e.getStackTrace()));
|
sysError.setFunc("insertDelivery");
|
sysErrorService.insert(sysError);
|
saveState = "false4";
|
|
}
|
|
return saveState;
|
}
|
|
|
public Map<String, Object> getSelectFinishedGlassShelfEmit(Integer pageNum, Integer pageSize,List<String> selectDate,
|
FinishedGlassShelfEmit finishedGlassShelfEmit) throws JsonProcessingException {
|
Integer offset = (pageNum - 1) * pageSize;
|
String endDate = LocalDate.now().toString();
|
String startDate = LocalDate.now().minusDays(15).toString();
|
if(selectDate !=null && selectDate.size()==2){
|
if(!selectDate.get(0).isEmpty()){
|
startDate = selectDate.get(0);
|
}
|
if(!selectDate.get(1).isEmpty()){
|
endDate = selectDate.get(1);
|
}
|
}
|
Map<String, Object> map = new HashMap<>();
|
map.put("data", finishedGlassShelfMapper.getSelectFinishedGlassShelfEmit(offset, pageSize,startDate,endDate, finishedGlassShelfEmit));
|
map.put("total", finishedGlassShelfMapper.getSelectFinishedGlassShelfEmitPageTotal(offset, pageSize,startDate,endDate, finishedGlassShelfEmit));
|
List<String> list = new ArrayList<>();
|
list.add(startDate);
|
list.add(endDate);
|
map.put("selectDate",list);
|
return map;
|
}
|
|
|
public String deleteFinishedGlassShelfEmit(Map<String,Object> object) {
|
String saveState = "true";
|
//设置回滚点
|
Object savePoint = TransactionAspectSupport.currentTransactionStatus().createSavepoint();
|
try {
|
String emitId = "";
|
if (object.get("emitId") != null) {
|
emitId = object.get("emitId").toString();
|
}
|
FinishedGlassShelfEmit finishedGlassShelfEmit2 = finishedGlassShelfMapper.getSelectFinishedGlassShelfEmitByemitId(emitId);
|
|
if (finishedGlassShelfEmit2 != null) {
|
//编辑还原数据
|
List<FinishedGlassShelfEmitDetails> finishedGlassShelfEmitDetailsList2 = finishedGlassShelfMapper.getSelectFinishedGlassShelfEmitDetailsByemitId1(emitId);
|
if (!finishedGlassShelfEmitDetailsList2.isEmpty()) {
|
for (FinishedGlassShelfEmitDetails finishedGlassShelfEmitDetails : finishedGlassShelfEmitDetailsList2) {
|
finishedGlassShelfMapper.updateInformationAvailableQuantityInt(finishedGlassShelfEmitDetails);
|
finishedGlassShelfMapper.deleteFinishedGlassShelfEmitDetailsLog(emitId);
|
}
|
}
|
|
}
|
finishedGlassShelfMapper.deleteFinishedGlassShelfEmitDetails(emitId);
|
finishedGlassShelfMapper.deleteFinishedGlassShelfEmit(emitId);
|
|
|
Log log = new Log();
|
log.setOperatorId(object.get("userId").toString());
|
log.setOperator(object.get("userName").toString());
|
log.setContent(object.toString());
|
log.setFunction("deleteFinishedGlassShelfEmit删除:"+emitId);
|
logService.saveLog(log);
|
|
return "true";
|
}catch (Exception e) {
|
TransactionAspectSupport.currentTransactionStatus().rollbackToSavepoint(savePoint);
|
//将异常传入数据库
|
SysError sysError = new SysError();
|
sysError.setError(e+Arrays.toString(e.getStackTrace()));
|
sysError.setFunc("deleteFinishedGlassShelfEmit");
|
sysErrorService.insert(sysError);
|
saveState = "false";
|
|
}
|
return saveState;
|
|
}
|
|
|
|
|
|
public String orderNumberSetting(String type) {
|
//根据类型自动生成不同的操作单号
|
String alias="";
|
Integer maximum=0;
|
if(Objects.equals(type, "入库")){
|
alias="RK";
|
maximum=finishedGlassShelfMapper.getmaximumWithdraw();
|
}else if(Objects.equals(type, "出库")){
|
alias="CK";
|
maximum=finishedGlassShelfMapper.getmaximumEmit();
|
}
|
//设置两位不够补0
|
String formattedNumber = String.format("%02d", maximum+1);
|
//格式化当前日期
|
Date currentDate = new Date();
|
SimpleDateFormat dateFormat = new SimpleDateFormat("yyMMdd");
|
String formattedDate = dateFormat.format(currentDate);
|
String oddNumbers = alias+formattedDate+formattedNumber;
|
return oddNumbers;
|
}
|
|
|
}
|
