package com.gk.firework.Controller;
|
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.gk.firework.Controller.Base.BaseController;
|
import com.gk.firework.Domain.*;
|
import com.gk.firework.Domain.Log.JsonParams;
|
import com.gk.firework.Domain.Utils.FilterObject;
|
import com.gk.firework.Domain.Utils.Msg;
|
import com.gk.firework.Domain.Utils.StringUtils;
|
import com.gk.firework.Domain.Vo.DirectionDetail;
|
import com.gk.firework.Domain.Vo.FireworkDeal;
|
import com.gk.firework.Domain.Vo.ProductVo;
|
import com.gk.firework.Service.*;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiImplicitParam;
|
import io.swagger.annotations.ApiImplicitParams;
|
import io.swagger.annotations.ApiOperation;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.*;
|
|
import java.text.DateFormat;
|
import java.text.ParseException;
|
import java.text.SimpleDateFormat;
|
import java.util.*;
|
|
import static com.gk.firework.Domain.Enum.ErrorCode.*;
|
import static com.gk.firework.Domain.Enum.ErrorCode.ERROR_10003;
|
|
/**
|
* @author : jingjy
|
* @date : 2021/4/1 10:21
|
*/
|
@Api(tags = "出库接口")
|
@RestController
|
@RequestMapping("/delivery")
|
public class DeliveryController extends BaseController {
|
@Autowired
|
private DeliveryOrderService deliveryOrderService;
|
@Autowired
|
private DeliveryDetailService deliveryDetailService;
|
@Autowired
|
private UserService userService;
|
@Autowired
|
private StockService stockService;
|
@Autowired
|
private ProductService productService;
|
@Autowired
|
private ProductLocusService productLocusService;
|
@Autowired
|
private WarnContentService warnContentService;
|
|
/**
|
* @param jsonArray 接收json数组格式为：[{"id":"用户ID","rfids":"出库流向码，以逗号进行拼接","time":"出库时间","type":"1或者2；1：正常出库；2：退货出库"}]
|
* @return msg
|
*/
|
@ApiOperation(value = "出库",notes = "接收json数组格式为：[{\"id\":\"用户ID\",\"rfids\":\"出库流向码，以逗号进行拼接\",\"time\":\"出库时间\",\"type\":\"1或者2；1：正常出库；2：退货出库\"}]")
|
@PostMapping("/out")
|
@JsonParams
|
public Msg deliveryStock(@RequestBody JSONArray jsonArray){
|
Msg msg = new Msg(true);
|
if (jsonArray.isEmpty()){
|
msg.setCode(ERROR_10001.getCode());
|
msg.setMessage(ERROR_10001.getMsg()+"：未收到出库信息！");
|
return msg;
|
}
|
|
for (int i = 0; i < jsonArray.size(); i++) {
|
JSONObject jsonObject = jsonArray.getJSONObject(i);
|
String userId = jsonObject.getString("id");
|
String directionCodeStr = jsonObject.getString("rfids");
|
String datetime = jsonObject.getString("time");
|
String type = jsonObject.getString("type");
|
String cert = jsonObject.getString("cert");
|
Date date;
|
DateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
try {
|
date = dateFormat.parse(datetime);
|
} catch (ParseException e) {
|
msg.setCode(ERROR_10003.getCode());
|
msg.setMessage(ERROR_10003.getMsg()+"：日期类型错误！");
|
return msg;
|
}
|
|
if (StringUtils.isBlank(directionCodeStr)){
|
msg.setCode(ERROR_10001.getCode());
|
msg.setMessage(ERROR_10001.getMsg()+"：流向码不能为空");
|
return msg;
|
}
|
|
boolean isUser = userService.checkUserById(userId);
|
if (!isUser){
|
msg.setCode(ERROR_50001.getCode());
|
msg.setMessage(ERROR_50001.getMsg()+"：未找到相关用户信息，不能出库！");
|
return msg;
|
}
|
UserInfo userInfo = userService.getById(userId);
|
|
List<String> directionCodes = StringUtils.toList(directionCodeStr);
|
|
//判断是否存在同时间同操作人出库记录
|
boolean exist = deliveryOrderService.isOrderExist(datetime,userInfo);
|
if (exist){
|
continue;
|
}
|
|
//出库单创建
|
DeliveryOrderInfo deliveryOrderInfo;
|
String auth = getAuth();
|
auth = StringUtils.isBlank(auth) ? "NOAUTH" : auth;
|
deliveryOrderInfo = deliveryOrderService.generateDeliveryOrder(type,date,userInfo,cert,auth);
|
List<DeliveryDetailInfo>deliveryDetailInfos = deliveryDetailService.generateDeliveryDetail(deliveryOrderInfo,userInfo,directionCodes);
|
|
deliveryOrderService.save(deliveryOrderInfo);
|
deliveryDetailService.saveBatch(deliveryDetailInfos);
|
//扣库存
|
stockService.deliveryByDetail(date,deliveryDetailInfos,userInfo);
|
}
|
return msg;
|
}
|
|
@ApiOperation(value = "快速出库",response = Msg.class)
|
@PostMapping("/deliveryQuick")
|
@JsonParams
|
public Msg deliveryQuick(@RequestBody JSONArray jsonArray){
|
Msg msg = new Msg(true);
|
if (jsonArray.size() > 0)
|
{
|
for (int i = 0; i < jsonArray.size(); i++) {
|
JSONObject jsonObject = jsonArray.getJSONObject(i);
|
String userId = jsonObject.getString("id");
|
String directionCodeFirst = jsonObject.getString("rfidfirst");
|
String directionCodeLast = jsonObject.getString("rfidlast");
|
String datetime = jsonObject.getString("time");
|
String transport = jsonObject.getString("cert");
|
//type 1.常规出库； 2.退货出库
|
String type = "1";
|
Date date;
|
DateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
try {
|
date = dateFormat.parse(datetime);
|
} catch (ParseException e) {
|
return new Msg(ERROR_10003,"出库日期类型错误");
|
}
|
if (!(FireworkDeal.is22Characters(directionCodeFirst) && FireworkDeal.is22Characters(directionCodeLast))){
|
return new Msg(ERROR_10004,"流向码首尾不符合规则，无法快速出库");
|
}
|
boolean isUser = userService.checkUserById(userId);
|
if (!isUser){
|
return new Msg(ERROR_50001,"未找到相关用户信息，不能出库");
|
}
|
UserInfo userInfo = userService.getById(userId);
|
//判断是否存在同时间同操作人入库记录
|
boolean exist = deliveryOrderService.isOrderExist(datetime,userInfo);
|
if (exist){ continue; }
|
|
String auth = getAuth();
|
auth = StringUtils.isBlank(auth) ? "NOAUTH" : auth;
|
DeliveryOrderInfo orderInfo = deliveryOrderService.generateDeliveryOrder(type,date,userInfo,transport, auth);
|
List<DeliveryDetailInfo>detailInfos = new ArrayList<>();
|
List<ProductLocusInfo>locusInfos = new ArrayList<>();
|
List<ProductVo> productVos = new ArrayList<>();
|
DirectionDetail detailFirst = FireworkDeal.dealDirectionCode(directionCodeFirst);
|
DirectionDetail detailLast = FireworkDeal.dealDirectionCode(directionCodeLast);
|
if (!detailFirst.getItemCode().equals(detailLast.getItemCode())){
|
return new Msg(ERROR_10004,"首尾商品编码不一致，无法快速出库");
|
}
|
if (Integer.parseInt(detailFirst.getSerialNo()) > Integer.parseInt(detailLast.getSerialNo())){
|
return new Msg(ERROR_10004,"首位商品序号大于末位，无法快速出库");
|
}
|
ProductVo productVo = productService.selectVoByDirection(directionCodeFirst);
|
if (productVo == null){
|
return new Msg(ERROR_50001,"未找到相关产品信息，不能出库");
|
}
|
|
Integer firstNo = Integer.parseInt(detailFirst.getSerialNo());
|
Integer lastNo = Integer.parseInt(detailLast.getSerialNo());
|
int perBoxNum = Integer.parseInt(detailFirst.getBoxNo());
|
int boxNum = ((lastNo-firstNo)/perBoxNum)+1;
|
int totalNum = 0;
|
|
for (int j=1;j<= boxNum;j++){
|
String dire = detailFirst.getItemCode()+detailFirst.getDateCode()+ String.format("%05d", firstNo)+String.format("%03d", perBoxNum);
|
DeliveryDetailInfo detailInfo = new DeliveryDetailInfo();
|
detailInfo.setDeliverycode(orderInfo.getOrdercode());
|
detailInfo.setDirectioncode(dire);
|
detailInfo.setItemcode(productVo.getItemCode());
|
detailInfo.setItemname(productVo.getName());
|
detailInfo.setCreateat(new Date());
|
detailInfo.setCreateby(userInfo.getUsername());
|
detailInfo.setNum(perBoxNum);
|
detailInfos.add(detailInfo);
|
ProductLocusInfo productLocusInfo = new ProductLocusInfo(dire,new Date(),date, userInfo.getCompany(),
|
null,ProductLocusInfo.DELIVERY_STATUS,productVo.getBoxNumber().toString());
|
locusInfos.add(productLocusInfo);
|
firstNo+=perBoxNum;
|
totalNum += perBoxNum;
|
}
|
|
FireworkDeal.getProductVos(directionCodeFirst,detailFirst,detailLast,productVos,productVo);
|
orderInfo.setBoxnum(totalNum);
|
deliveryOrderService.save(orderInfo);
|
deliveryDetailService.saveBatch(detailInfos);
|
productLocusService.insertBatch(locusInfos);
|
stockService.deliveryByDetail(date,detailInfos,userInfo);
|
}
|
}
|
return msg;
|
}
|
|
/**
|
* 退货出库
|
*/
|
@PostMapping("/entryReturn")
|
@ApiOperation(value = "退货出库", httpMethod = "POST")
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "filter.code", type = "JSONObject",
|
value = " JSONObject{\"datetime\":\"时间\",\"data\":[{\"directionCode\":\"流向码\"},{\"directionCode\":\"流向码\"}]}"),
|
})
|
@JsonParams
|
public Msg getProductListByCodes(@RequestBody JSONObject object) {
|
JSONArray jsonArray = object.getJSONArray("data");
|
String datetime = object.getString("datetime");
|
Date date;
|
DateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
try {
|
date = dateFormat.parse(datetime);
|
} catch (ParseException e) {
|
return new Msg(ERROR_10003,"日期类型错误！");
|
}
|
//生成出库单号，类型，退货出库
|
DeliveryOrderInfo deliveryOrderInfo;
|
UserInfo userInfo = userService.getById(getUser().getId());
|
String auth = getAuth();
|
auth = StringUtils.isBlank(auth) ? "NOAUTH" : auth;
|
|
deliveryOrderInfo = deliveryOrderService.generateDeliveryOrder(FireworkDeal.OTHER_DELIVERY,date,userInfo, null, auth);
|
List<DeliveryDetailInfo>deliveryDetailInfos = new ArrayList<>();
|
List<StockInfo>stockInfos = new ArrayList<>();
|
for (int i = 0; i < jsonArray.size(); i++) {
|
// 遍历 jsonArray 数组，把每一个对象转成 json 对象
|
JSONObject jsonObject = jsonArray.getJSONObject(i);
|
String directionCode = jsonObject.getString("directionCode");
|
DirectionDetail directionDetail = FireworkDeal.dealDirectionCode(directionCode);
|
ProductInfo productInfo = productService.selectByDirection(directionDetail.getItemCode());
|
|
// 生成出库详情，库存OWNER设置为空
|
DeliveryDetailInfo deliveryDetailInfo = new DeliveryDetailInfo();
|
deliveryDetailInfo.setDirectioncode(directionCode);
|
deliveryDetailInfo.setDeliverycode(deliveryOrderInfo.getOrdercode());
|
deliveryDetailInfo.setItemcode(directionDetail.getItemCode());
|
deliveryDetailInfo.setItemname(productInfo.getName());
|
deliveryDetailInfo.setCreateat(new Date());
|
deliveryDetailInfo.setCreateby(getUser().getUsername());
|
deliveryDetailInfos.add(deliveryDetailInfo);
|
StockInfo stockInfo = stockService.selectStockByDirection(directionCode);
|
if (stockInfo == null){
|
return new Msg(ERROR_50001,"库存信息未找到");
|
}
|
stockInfo.setOwner("");
|
stockInfo.setModifiedby(userInfo.getUsername());
|
stockInfo.setModifieddate(date);
|
stockInfos.add(stockInfo);
|
}
|
|
deliveryOrderService.save(deliveryOrderInfo);
|
deliveryDetailService.saveBatch(deliveryDetailInfos);
|
stockService.updateStocks(stockInfos,userInfo);
|
return success();
|
}
|
|
|
/**
|
* @Description: 出库查询
|
* @date 2021/4/15 12:05
|
*/
|
@PostMapping("/outbound-query")
|
@ApiOperation(value = "出库查询", httpMethod = "POST")
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "pageIndex", value = "当前页码", required = true),
|
@ApiImplicitParam(name = "pageSize", value = "页大小", required = true),
|
@ApiImplicitParam(name = "filter.province", value = "省"),
|
@ApiImplicitParam(name = "filter.city", value = "市"),
|
@ApiImplicitParam(name = "filter.district", value = "区"),
|
@ApiImplicitParam(name = "filter.street", value = "街道"),
|
@ApiImplicitParam(name = "filter.committee", value = "委员会"),
|
@ApiImplicitParam(name = "filter.starttime", value = "开始时间"),
|
@ApiImplicitParam(name = "filter.endtime", value = "结束时间"),
|
@ApiImplicitParam(name = "filter.transportcert", value = "运输证号码"),
|
@ApiImplicitParam(name = "filter.enterprisename", value = "入库企业名称"),
|
@ApiImplicitParam(name = "filter.safetysupervision", value = "安全监管分类"),
|
@ApiImplicitParam(name = "filter.code", value = "单号"),
|
})
|
Object getOutboundInfo(@RequestBody FilterObject jsonFilter) {
|
Integer pageIndex = jsonFilter.getPageIndex();
|
Integer pageSize = jsonFilter.getPageSize();
|
IPage page = deliveryOrderService.selectPage(new Page<>(pageIndex, pageSize), jsonFilter.getFilter(), getUser());
|
return success(page);
|
}
|
|
@PostMapping("/stock/outbound-query")
|
@ApiOperation(value = "出库查询", httpMethod = "POST")
|
Object getStockOutboundInfo(@RequestBody FilterObject jsonFilter) {
|
Integer pageIndex = jsonFilter.getPageIndex();
|
Integer pageSize = jsonFilter.getPageSize();
|
IPage page = deliveryOrderService.selectStockPage(new Page<>(pageIndex, pageSize), jsonFilter.getFilter(), getUser());
|
return success(page);
|
}
|
|
/**
|
* @Description: 出库导出
|
* @date 2021/4/19 17:24
|
*/
|
/**
|
* @Description: 出库查询
|
* @date 2021/4/15 12:05
|
*/
|
@PostMapping("/export/outbound")
|
@ApiOperation(value = "出库查询", httpMethod = "POST")
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "pageIndex", value = "当前页码", required = true),
|
@ApiImplicitParam(name = "pageSize", value = "页大小", required = true),
|
@ApiImplicitParam(name = "filter.province", value = "省"),
|
@ApiImplicitParam(name = "filter.city", value = "市"),
|
@ApiImplicitParam(name = "filter.district", value = "区"),
|
@ApiImplicitParam(name = "filter.street", value = "街道"),
|
@ApiImplicitParam(name = "filter.committee", value = "委员会"),
|
@ApiImplicitParam(name = "filter.starttime", value = "开始时间"),
|
@ApiImplicitParam(name = "filter.endtime", value = "结束时间"),
|
@ApiImplicitParam(name = "filter.transportcert", value = "运输证号码"),
|
@ApiImplicitParam(name = "filter.enterprisename", value = "入库企业名称"),
|
})
|
Object exportOutbound(@RequestBody FilterObject jsonFilter) {
|
List<DeliveryOrderInfo> list = deliveryOrderService.selectExportList(jsonFilter.getFilter(), getUser());
|
return success(list);
|
}
|
|
|
/**
|
* @Description: 根据{出库单号}查询出库明细
|
* @date 2021/4/15 12:05
|
*/
|
@PostMapping("/outbound-detail")
|
@ApiOperation(value = "出库单明细", httpMethod = "POST")
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "pageIndex", value = "当前页码", required = true),
|
@ApiImplicitParam(name = "pageSize", value = "页大小", required = true),
|
@ApiImplicitParam(name = "filter.code", value = "入库单号code"),
|
})
|
Object getOutboundDetail(@RequestBody FilterObject jsonFilter) {
|
Integer pageIndex = jsonFilter.getPageIndex();
|
Integer pageSize = jsonFilter.getPageSize();
|
IPage page = deliveryDetailService.selectDetailPage(new Page<>(pageIndex, pageSize), jsonFilter.getFilter());
|
return success(page);
|
}
|
|
/**
|
* @Description: 根据{出库单code}查询出库明细并导出
|
* @date 2021/4/15 11:09
|
*/
|
@GetMapping("/export/outbound-detail")
|
@ApiOperation(value = "出库单明细导出", httpMethod = "POST")
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "code", value = "出库单号code"),
|
})
|
Object getOutboundDetail(@RequestParam String code) {
|
List<Map> detailExport = deliveryDetailService.selectDetailExport(code);
|
return success(detailExport);
|
}
|
|
@GetMapping("/cert")
|
@ApiOperation(value = "根据运输证查询出库明细", httpMethod = "GET")
|
@ApiImplicitParams({
|
@ApiImplicitParam(name = "cert", value = "运输证号"),
|
})
|
Msg getDeliveryDetailByCert(@RequestParam String cert){
|
if (StringUtils.isBlank(cert)){
|
return new Msg(ERROR_10001.getCode(),ERROR_10001.getMsg());
|
}
|
Map<String,List>map = new HashMap<>();
|
List<DeliveryOrderInfo> deliveryOrderInfos = deliveryOrderService.getDeliveryOrderByCert(cert);
|
if (deliveryOrderInfos == null || deliveryOrderInfos.size() == 0){
|
return new Msg(ERROR_50001.getCode(),ERROR_50001.getMsg()+"：没有找到对应的出库记录！");
|
}
|
List<DeliveryDetailInfo>deliveryDetailInfoList = new ArrayList<>();
|
for (DeliveryOrderInfo deliveryOrderInfo : deliveryOrderInfos){
|
List<DeliveryDetailInfo>deliveryDetailInfos = deliveryDetailService.getDetailByCode(deliveryOrderInfo.getOrdercode());
|
deliveryDetailInfoList.addAll(deliveryDetailInfos);
|
}
|
List<ProductVo>productVos = deliveryOrderService.getProductVosByCert(cert);
|
map.put("detail",deliveryDetailInfoList);
|
map.put("product",productVos);
|
|
return success(map);
|
}
|
|
@ApiOperation(value = "批量退库")
|
@PostMapping("/returnBatch")
|
@JsonParams
|
public List<Msg> returnBatch(@RequestBody JSONArray array) {
|
List<Msg>msgList = new ArrayList<>();
|
if (array.size() < 1) {
|
return null;
|
}
|
for (int j = 0; j < array.size(); j++) {
|
// 遍历 jsonArray 数组，把每一个对象转成 json 对象
|
JSONObject object = array.getJSONObject(j);
|
JSONArray jsonArray = object.getJSONArray("data");
|
String datetime = object.getString("datetime");
|
Date date;
|
DateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
try {
|
date = dateFormat.parse(datetime);
|
} catch (ParseException e) {
|
msgList.add(new Msg(ERROR_10003, "日期类型错误！"));
|
continue;
|
}
|
//生成出库单号，类型，退货出库
|
DeliveryOrderInfo deliveryOrderInfo;
|
UserInfo userInfo = userService.getById(getUser().getId());
|
String auth = getAuth();
|
auth = StringUtils.isBlank(auth) ? "NOAUTH" : auth;
|
|
deliveryOrderInfo = deliveryOrderService.generateDeliveryOrder(FireworkDeal.OTHER_DELIVERY, date, userInfo, null, auth);
|
List<DeliveryDetailInfo> deliveryDetailInfos = new ArrayList<>();
|
List<StockInfo> stockInfos = new ArrayList<>();
|
StringBuilder stringBuilder = new StringBuilder();
|
boolean flag = false;
|
for (int i = 0; i < jsonArray.size(); i++) {
|
// 遍历 jsonArray 数组，把每一个对象转成 json 对象
|
JSONObject jsonObject = jsonArray.getJSONObject(i);
|
String directionCode = jsonObject.getString("directionCode");
|
DirectionDetail directionDetail = FireworkDeal.dealDirectionCode(directionCode);
|
ProductInfo productInfo = productService.selectByDirection(directionDetail.getItemCode());
|
|
// 生成出库详情，库存OWNER设置为空
|
DeliveryDetailInfo deliveryDetailInfo = new DeliveryDetailInfo();
|
deliveryDetailInfo.setDirectioncode(directionCode);
|
deliveryDetailInfo.setDeliverycode(deliveryOrderInfo.getOrdercode());
|
deliveryDetailInfo.setItemcode(directionDetail.getItemCode());
|
deliveryDetailInfo.setItemname(productInfo.getName());
|
deliveryDetailInfo.setCreateat(new Date());
|
deliveryDetailInfo.setCreateby(getUser().getUsername());
|
deliveryDetailInfos.add(deliveryDetailInfo);
|
StockInfo stockInfo = stockService.selectStockByDirection(directionCode);
|
if (stockInfo == null) {
|
stringBuilder.append(directionCode).append("库存信息未找到");
|
flag = true;
|
continue;
|
}
|
stockInfo.setOwner("");
|
stockInfos.add(stockInfo);
|
}
|
if (flag){
|
msgList.add(new Msg(ERROR_50001,stringBuilder.toString()));
|
continue;
|
}
|
|
deliveryOrderService.save(deliveryOrderInfo);
|
deliveryDetailService.saveBatch(deliveryDetailInfos);
|
stockService.updateStocks(stockInfos, getUser());
|
msgList.add(new Msg(SUCCESS));
|
}
|
return msgList;
|
}
|
|
}
|
