|
@@ -5,6 +5,7 @@ import cn.hutool.core.collection.CollUtil;
|
|
|
import cn.hutool.core.date.DateTime;
|
|
import cn.hutool.core.date.DateTime;
|
|
|
import cn.hutool.core.date.DateUtil;
|
|
import cn.hutool.core.date.DateUtil;
|
|
|
import cn.hutool.core.util.NumberUtil;
|
|
import cn.hutool.core.util.NumberUtil;
|
|
|
|
|
+import cn.hutool.core.util.StrUtil;
|
|
|
import com.alibaba.fastjson2.JSON;
|
|
import com.alibaba.fastjson2.JSON;
|
|
|
import com.alibaba.fastjson2.JSONObject;
|
|
import com.alibaba.fastjson2.JSONObject;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
@@ -34,15 +35,17 @@ import com.sckw.core.web.response.HttpResult;
|
|
|
import com.sckw.manage.api.RemoteManageService;
|
|
import com.sckw.manage.api.RemoteManageService;
|
|
|
import com.sckw.manage.api.model.dto.res.FindEntCooperateResVo;
|
|
import com.sckw.manage.api.model.dto.res.FindEntCooperateResVo;
|
|
|
import com.sckw.mongo.model.SckwTradeOrder;
|
|
import com.sckw.mongo.model.SckwTradeOrder;
|
|
|
-import com.sckw.order.api.model.OrderSaleVo;
|
|
|
|
|
-import com.sckw.order.api.model.TradeOrderCountStatisticsDTO;
|
|
|
|
|
-import com.sckw.order.api.model.TradeOrderSettlePara;
|
|
|
|
|
|
|
+import com.sckw.order.api.model.*;
|
|
|
import com.sckw.order.dao.KwoTradeOrderMapper;
|
|
import com.sckw.order.dao.KwoTradeOrderMapper;
|
|
|
import com.sckw.order.enums.ContractStatusEnum;
|
|
import com.sckw.order.enums.ContractStatusEnum;
|
|
|
import com.sckw.order.enums.*;
|
|
import com.sckw.order.enums.*;
|
|
|
import com.sckw.order.model.*;
|
|
import com.sckw.order.model.*;
|
|
|
import com.sckw.order.model.dto.*;
|
|
import com.sckw.order.model.dto.*;
|
|
|
|
|
+import com.sckw.order.model.vo.req.ContractInfo;
|
|
|
import com.sckw.order.model.vo.req.*;
|
|
import com.sckw.order.model.vo.req.*;
|
|
|
|
|
+import com.sckw.order.model.vo.res.GoodsInfoDetailRes;
|
|
|
|
|
+import com.sckw.order.model.vo.res.OrderDetailRes;
|
|
|
|
|
+import com.sckw.order.model.vo.res.UnitInfoDetailRes;
|
|
|
import com.sckw.order.model.vo.res.*;
|
|
import com.sckw.order.model.vo.res.*;
|
|
|
import com.sckw.payment.api.dubbo.PayCenterDubboService;
|
|
import com.sckw.payment.api.dubbo.PayCenterDubboService;
|
|
|
import com.sckw.payment.api.dubbo.PaymentDubboService;
|
|
import com.sckw.payment.api.dubbo.PaymentDubboService;
|
|
@@ -77,7 +80,6 @@ import org.springframework.transaction.annotation.Transactional;
|
|
|
|
|
|
|
|
import java.math.BigDecimal;
|
|
import java.math.BigDecimal;
|
|
|
import java.math.RoundingMode;
|
|
import java.math.RoundingMode;
|
|
|
-import java.time.LocalDate;
|
|
|
|
|
import java.time.LocalDateTime;
|
|
import java.time.LocalDateTime;
|
|
|
import java.util.*;
|
|
import java.util.*;
|
|
|
import java.util.concurrent.atomic.AtomicInteger;
|
|
import java.util.concurrent.atomic.AtomicInteger;
|
|
@@ -147,12 +149,7 @@ public class KwoTradeOrderService {
|
|
|
*/
|
|
*/
|
|
|
public void addPurchaseOrderDraft(PurchaseOrderDraftParam param) {
|
|
public void addPurchaseOrderDraft(PurchaseOrderDraftParam param) {
|
|
|
KwoTradeOrder order = BeanUtil.copyProperties(param, KwoTradeOrder.class);
|
|
KwoTradeOrder order = BeanUtil.copyProperties(param, KwoTradeOrder.class);
|
|
|
- order.setEntId(LoginUserHolder.getEntId())
|
|
|
|
|
- .setTOrderNo(getOrderNo())
|
|
|
|
|
- .setStartTime(DateUtils.localDateToDateStart(param.getStartTime()))
|
|
|
|
|
- .setEndTime(DateUtils.localDateToDateEnd(param.getEndTime()))
|
|
|
|
|
- .setUnit(Objects.nonNull(param.getGoodsInfo()) ? param.getGoodsInfo().getUnit() : null)
|
|
|
|
|
- .setSource(OrderSourceEnum.PURCHASE.getType()).setStatus(OrderStatusEnum.SAVED.getCode());
|
|
|
|
|
|
|
+ order.setEntId(LoginUserHolder.getEntId()).setTOrderNo(getOrderNo()).setStartTime(DateUtils.localDateToDateStart(param.getStartTime())).setEndTime(DateUtils.localDateToDateEnd(param.getEndTime())).setUnit(Objects.nonNull(param.getGoodsInfo()) ? param.getGoodsInfo().getUnit() : null).setSource(OrderSourceEnum.PURCHASE.getType()).setStatus(OrderStatusEnum.SAVED.getCode());
|
|
|
kwoTradeOrderMapper.insert(order);
|
|
kwoTradeOrderMapper.insert(order);
|
|
|
addOtherOrderInfo(order, BeanUtil.copyProperties(param, ValetOrderParam.class), false, true);
|
|
addOtherOrderInfo(order, BeanUtil.copyProperties(param, ValetOrderParam.class), false, true);
|
|
|
}
|
|
}
|
|
@@ -170,15 +167,7 @@ public class KwoTradeOrderService {
|
|
|
Long id = tradeOrder.getId();
|
|
Long id = tradeOrder.getId();
|
|
|
String tOrderNo = tradeOrder.getTOrderNo();
|
|
String tOrderNo = tradeOrder.getTOrderNo();
|
|
|
SckwTradeOrder order = new SckwTradeOrder();
|
|
SckwTradeOrder order = new SckwTradeOrder();
|
|
|
- order.setFirmName(LoginUserHolder.getEntName())
|
|
|
|
|
- .setCreateByName(LoginUserHolder.getUserName())
|
|
|
|
|
- .setUpdateByName(LoginUserHolder.getUserName())
|
|
|
|
|
- .setTOrderId(id)
|
|
|
|
|
- .setAssociateStatement(0)
|
|
|
|
|
- .setPrice(Objects.isNull(tradeOrder.getPrice()) ? null : tradeOrder.getPrice().doubleValue())
|
|
|
|
|
- .setAmount(Objects.isNull(tradeOrder.getAmount()) ? null : tradeOrder.getAmount().doubleValue())
|
|
|
|
|
- .setEntrustAmount(Objects.isNull(tradeOrder.getEntrustAmount()) ? null : tradeOrder.getEntrustAmount().doubleValue())
|
|
|
|
|
- .setActualAmount(Objects.isNull(tradeOrder.getActualAmount()) ? null : tradeOrder.getActualAmount().doubleValue());
|
|
|
|
|
|
|
+ order.setFirmName(LoginUserHolder.getEntName()).setCreateByName(LoginUserHolder.getUserName()).setUpdateByName(LoginUserHolder.getUserName()).setTOrderId(id).setAssociateStatement(0).setPrice(Objects.isNull(tradeOrder.getPrice()) ? null : tradeOrder.getPrice().doubleValue()).setAmount(Objects.isNull(tradeOrder.getAmount()) ? null : tradeOrder.getAmount().doubleValue()).setEntrustAmount(Objects.isNull(tradeOrder.getEntrustAmount()) ? null : tradeOrder.getEntrustAmount().doubleValue()).setActualAmount(Objects.isNull(tradeOrder.getActualAmount()) ? null : tradeOrder.getActualAmount().doubleValue());
|
|
|
|
|
|
|
|
BeanUtil.copyProperties(tradeOrder, order);
|
|
BeanUtil.copyProperties(tradeOrder, order);
|
|
|
|
|
|
|
@@ -188,9 +177,7 @@ public class KwoTradeOrderService {
|
|
|
KwoTradeOrderGoods goods = BeanUtil.copyProperties(goodsInfo, KwoTradeOrderGoods.class);
|
|
KwoTradeOrderGoods goods = BeanUtil.copyProperties(goodsInfo, KwoTradeOrderGoods.class);
|
|
|
if (Objects.nonNull(goods) && Objects.nonNull(goods.getGoodsId())) {
|
|
if (Objects.nonNull(goods) && Objects.nonNull(goods.getGoodsId())) {
|
|
|
GoodsDetail goodsDetail = goodsInfoService.getDetailById(goods.getGoodsId());
|
|
GoodsDetail goodsDetail = goodsInfoService.getDetailById(goods.getGoodsId());
|
|
|
- if (Objects.isNull(goodsDetail)
|
|
|
|
|
- || !Objects.equals(goodsDetail.getStatus(), 1)
|
|
|
|
|
- || Objects.equals(goodsDetail.getDelFlag(), Global.YES)) {
|
|
|
|
|
|
|
+ if (Objects.isNull(goodsDetail) || !Objects.equals(goodsDetail.getStatus(), 1) || Objects.equals(goodsDetail.getDelFlag(), Global.YES)) {
|
|
|
throw new BusinessException("商品不存在或已下架!");
|
|
throw new BusinessException("商品不存在或已下架!");
|
|
|
}
|
|
}
|
|
|
goods.setTOrderId(id).setTOrderNo(tOrderNo).setGoodsType(goodsDetail.getGoodsType());
|
|
goods.setTOrderId(id).setTOrderNo(tOrderNo).setGoodsType(goodsDetail.getGoodsType());
|
|
@@ -212,9 +199,7 @@ public class KwoTradeOrderService {
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
//订单关联商品信息
|
|
//订单关联商品信息
|
|
|
- order.setGoodsId(goodsDetail.getId()).setUnit(goodsDetail.getUnit()).setUnitPrice(goods.getUnitPrice().doubleValue())
|
|
|
|
|
- .setGoodsName(goodsDetail.getName()).setGoodsType(goodsDetail.getGoodsType()).setGoodsCode(goodsDetail.getCode())
|
|
|
|
|
- .setGoodsTaxRate(goodsDetail.getTaxRate()).setGoodsSpec(goodsDetail.getSpec()).setGoodsThumb(goodsDetail.getThumb());
|
|
|
|
|
|
|
+ order.setGoodsId(goodsDetail.getId()).setUnit(goodsDetail.getUnit()).setUnitPrice(goods.getUnitPrice().doubleValue()).setGoodsName(goodsDetail.getName()).setGoodsType(goodsDetail.getGoodsType()).setGoodsCode(goodsDetail.getCode()).setGoodsTaxRate(goodsDetail.getTaxRate()).setGoodsSpec(goodsDetail.getSpec()).setGoodsThumb(goodsDetail.getThumb());
|
|
|
}
|
|
}
|
|
|
if (Objects.isNull(order.getUnitPrice())) {
|
|
if (Objects.isNull(order.getUnitPrice())) {
|
|
|
order.setUnitPrice(BigDecimal.ZERO.doubleValue());
|
|
order.setUnitPrice(BigDecimal.ZERO.doubleValue());
|
|
@@ -236,11 +221,9 @@ public class KwoTradeOrderService {
|
|
|
unit.setTOrderId(id).setTOrderNo(tOrderNo).setTopEntId(ent.getId());
|
|
unit.setTOrderId(id).setTOrderNo(tOrderNo).setTopEntId(ent.getId());
|
|
|
list.add(unit);
|
|
list.add(unit);
|
|
|
if (Objects.equals(e.getUnitType(), OrderUnitTypeEnum.PURCHASE.getType())) {
|
|
if (Objects.equals(e.getUnitType(), OrderUnitTypeEnum.PURCHASE.getType())) {
|
|
|
- order.setProcureEntId(e.getEntId()).setProcureTopEntId(unit.getTopEntId()).setProcureFirmName(e.getFirmName())
|
|
|
|
|
- .setProcureContacts(e.getContacts()).setProcurePhone(e.getPhone()).setProcureContactsId(e.getContactsId());
|
|
|
|
|
|
|
+ order.setProcureEntId(e.getEntId()).setProcureTopEntId(unit.getTopEntId()).setProcureFirmName(e.getFirmName()).setProcureContacts(e.getContacts()).setProcurePhone(e.getPhone()).setProcureContactsId(e.getContactsId());
|
|
|
} else {
|
|
} else {
|
|
|
- order.setSupplyEntId(e.getEntId()).setSupplyTopEntId(unit.getTopEntId()).setSupplyFirmName(e.getFirmName())
|
|
|
|
|
- .setSupplyContacts(e.getContacts()).setSupplyPhone(e.getPhone()).setSupplyContactsId(e.getContactsId());
|
|
|
|
|
|
|
+ order.setSupplyEntId(e.getEntId()).setSupplyTopEntId(unit.getTopEntId()).setSupplyFirmName(e.getFirmName()).setSupplyContacts(e.getContacts()).setSupplyPhone(e.getPhone()).setSupplyContactsId(e.getContactsId());
|
|
|
}
|
|
}
|
|
|
});
|
|
});
|
|
|
kwoTradeOrderUnitService.insertBatch(list);
|
|
kwoTradeOrderUnitService.insertBatch(list);
|
|
@@ -291,21 +274,16 @@ public class KwoTradeOrderService {
|
|
|
//todo MongoDB如何存多个地址信息?
|
|
//todo MongoDB如何存多个地址信息?
|
|
|
if (Objects.equals(address.getAddressType(), OrderAddressTypeEnum.LOAD.getType())) {
|
|
if (Objects.equals(address.getAddressType(), OrderAddressTypeEnum.LOAD.getType())) {
|
|
|
address.setSort(loadSort.getAndIncrement());
|
|
address.setSort(loadSort.getAndIncrement());
|
|
|
- order.setLoadName(e.getName()).setLoadType(e.getType()).setLoadContacts(e.getContacts())
|
|
|
|
|
- .setLoadPhone(e.getPhone()).setLoadCityCode(String.valueOf(e.getCityCode())).setLoadCityName(e.getCityName())
|
|
|
|
|
- .setLoadDetailAddress(e.getDetailAddress()).setLoadLat(e.getLat()).setLoadLng(e.getLng());
|
|
|
|
|
|
|
+ order.setLoadName(e.getName()).setLoadType(e.getType()).setLoadContacts(e.getContacts()).setLoadPhone(e.getPhone()).setLoadCityCode(String.valueOf(e.getCityCode())).setLoadCityName(e.getCityName()).setLoadDetailAddress(e.getDetailAddress()).setLoadLat(e.getLat()).setLoadLng(e.getLng());
|
|
|
} else {
|
|
} else {
|
|
|
address.setSort(unloadSort.getAndIncrement());
|
|
address.setSort(unloadSort.getAndIncrement());
|
|
|
- order.setUnloadName(e.getName()).setUnloadType(e.getType()).setUnloadContacts(e.getContacts())
|
|
|
|
|
- .setUnloadPhone(e.getPhone()).setUnloadCityCode(String.valueOf(e.getCityCode())).setUnloadCityName(e.getCityName())
|
|
|
|
|
- .setUnloadDetailAddress(e.getDetailAddress()).setUnloadLat(e.getLat()).setUnloadLng(e.getLng());
|
|
|
|
|
|
|
+ order.setUnloadName(e.getName()).setUnloadType(e.getType()).setUnloadContacts(e.getContacts()).setUnloadPhone(e.getPhone()).setUnloadCityCode(String.valueOf(e.getCityCode())).setUnloadCityName(e.getCityName()).setUnloadDetailAddress(e.getDetailAddress()).setUnloadLat(e.getLat()).setUnloadLng(e.getLng());
|
|
|
}
|
|
}
|
|
|
//地址信息
|
|
//地址信息
|
|
|
Long addressId = kwoTradeOrderAddressService.add(address);
|
|
Long addressId = kwoTradeOrderAddressService.add(address);
|
|
|
//分配量信息
|
|
//分配量信息
|
|
|
KwoTradeOrderAmount orderAmount = new KwoTradeOrderAmount();
|
|
KwoTradeOrderAmount orderAmount = new KwoTradeOrderAmount();
|
|
|
- orderAmount.setTOrderId(id).setAmount(e.getAmount())
|
|
|
|
|
- .setTAddressId(addressId);
|
|
|
|
|
|
|
+ orderAmount.setTOrderId(id).setAmount(e.getAmount()).setTAddressId(addressId);
|
|
|
tradeOrderAmountService.add(orderAmount);
|
|
tradeOrderAmountService.add(orderAmount);
|
|
|
});
|
|
});
|
|
|
}
|
|
}
|
|
@@ -357,12 +335,7 @@ public class KwoTradeOrderService {
|
|
|
*/
|
|
*/
|
|
|
public void addValetOrderDraft(ValetOrderDraftParam param) {
|
|
public void addValetOrderDraft(ValetOrderDraftParam param) {
|
|
|
KwoTradeOrder order = BeanUtil.copyProperties(param, KwoTradeOrder.class);
|
|
KwoTradeOrder order = BeanUtil.copyProperties(param, KwoTradeOrder.class);
|
|
|
- order.setEntId(LoginUserHolder.getEntId())
|
|
|
|
|
- .setTOrderNo(getOrderNo())
|
|
|
|
|
- .setStartTime(DateUtils.localDateToDateStart(param.getStartTime()))
|
|
|
|
|
- .setEndTime(DateUtils.localDateToDateEnd(param.getEndTime()))
|
|
|
|
|
- .setUnit(Objects.nonNull(param.getGoodsInfo()) ? param.getGoodsInfo().getUnit() : null)
|
|
|
|
|
- .setSource(OrderSourceEnum.SALE.getType()).setStatus(OrderStatusEnum.SAVED.getCode());
|
|
|
|
|
|
|
+ order.setEntId(LoginUserHolder.getEntId()).setTOrderNo(getOrderNo()).setStartTime(DateUtils.localDateToDateStart(param.getStartTime())).setEndTime(DateUtils.localDateToDateEnd(param.getEndTime())).setUnit(Objects.nonNull(param.getGoodsInfo()) ? param.getGoodsInfo().getUnit() : null).setSource(OrderSourceEnum.SALE.getType()).setStatus(OrderStatusEnum.SAVED.getCode());
|
|
|
kwoTradeOrderMapper.insert(order);
|
|
kwoTradeOrderMapper.insert(order);
|
|
|
addOtherOrderInfo(order, BeanUtil.copyProperties(param, ValetOrderParam.class), false, true);
|
|
addOtherOrderInfo(order, BeanUtil.copyProperties(param, ValetOrderParam.class), false, true);
|
|
|
}
|
|
}
|
|
@@ -381,17 +354,10 @@ public class KwoTradeOrderService {
|
|
|
}
|
|
}
|
|
|
OrderCheckDTO orderCheck = BeanUtil.copyProperties(param, OrderCheckDTO.class);
|
|
OrderCheckDTO orderCheck = BeanUtil.copyProperties(param, OrderCheckDTO.class);
|
|
|
getTopEnt(orderCheck, param.getUnitInfo());
|
|
getTopEnt(orderCheck, param.getUnitInfo());
|
|
|
- orderCheck.setGoodsId(goodsInfo.getGoodsId()).setUnitPrice(goodsInfo.getUnitPrice())
|
|
|
|
|
- .setOrderSource(OrderSourceEnum.PURCHASE.getType());
|
|
|
|
|
|
|
+ orderCheck.setGoodsId(goodsInfo.getGoodsId()).setUnitPrice(goodsInfo.getUnitPrice()).setOrderSource(OrderSourceEnum.PURCHASE.getType());
|
|
|
orderCheck(orderCheck, false);
|
|
orderCheck(orderCheck, false);
|
|
|
KwoTradeOrder order = BeanUtil.copyProperties(param, KwoTradeOrder.class);
|
|
KwoTradeOrder order = BeanUtil.copyProperties(param, KwoTradeOrder.class);
|
|
|
- order.setEntId(LoginUserHolder.getEntId())
|
|
|
|
|
- .setTOrderNo(getOrderNo())
|
|
|
|
|
- .setStartTime(DateUtils.localDateToDateStart(param.getStartTime()))
|
|
|
|
|
- .setEndTime(DateUtils.localDateToDateEnd(param.getEndTime()))
|
|
|
|
|
- .setUnit(param.getGoodsInfo().getUnit())
|
|
|
|
|
- .setSource(OrderSourceEnum.PURCHASE.getType())
|
|
|
|
|
- .setStatus(OrderStatusEnum.WAIT_ACCEPTED.getCode());
|
|
|
|
|
|
|
+ order.setEntId(LoginUserHolder.getEntId()).setTOrderNo(getOrderNo()).setStartTime(DateUtils.localDateToDateStart(param.getStartTime())).setEndTime(DateUtils.localDateToDateEnd(param.getEndTime())).setUnit(param.getGoodsInfo().getUnit()).setSource(OrderSourceEnum.PURCHASE.getType()).setStatus(OrderStatusEnum.WAIT_ACCEPTED.getCode());
|
|
|
kwoTradeOrderMapper.insert(order);
|
|
kwoTradeOrderMapper.insert(order);
|
|
|
//扣减库存
|
|
//扣减库存
|
|
|
HttpResult updateResult = goodsInfoService.updateGoodsAmount(param.getGoodsInfo().getGoodsId(), param.getAmount());
|
|
HttpResult updateResult = goodsInfoService.updateGoodsAmount(param.getGoodsInfo().getGoodsId(), param.getAmount());
|
|
@@ -466,10 +432,7 @@ public class KwoTradeOrderService {
|
|
|
urls.put(ClientTypeEnum.pc.getValue(), pcUrl);
|
|
urls.put(ClientTypeEnum.pc.getValue(), pcUrl);
|
|
|
urls.put(ClientTypeEnum.app.getValue(), appUrl);
|
|
urls.put(ClientTypeEnum.app.getValue(), appUrl);
|
|
|
SckwMessage msg = new SckwMessage(msgEnum);
|
|
SckwMessage msg = new SckwMessage(msgEnum);
|
|
|
- msg.setParams(params)
|
|
|
|
|
- .setMsgUrls(urls)
|
|
|
|
|
- .setUserInfos(userInfos)
|
|
|
|
|
- .setCreateBy(LoginUserHolder.getUserId());
|
|
|
|
|
|
|
+ msg.setParams(params).setMsgUrls(urls).setUserInfos(userInfos).setCreateBy(LoginUserHolder.getUserId());
|
|
|
log.info("有新的提醒消息:{}", JSON.toJSONString(msg));
|
|
log.info("有新的提醒消息:{}", JSON.toJSONString(msg));
|
|
|
streamBridge.send("sckw-message", JSON.toJSONString(msg));
|
|
streamBridge.send("sckw-message", JSON.toJSONString(msg));
|
|
|
}
|
|
}
|
|
@@ -532,11 +495,9 @@ public class KwoTradeOrderService {
|
|
|
}
|
|
}
|
|
|
List<FindEntCooperateResVo> entCooperate;
|
|
List<FindEntCooperateResVo> entCooperate;
|
|
|
if (OrderSourceEnum.PURCHASE.getType().equals(param.getOrderSource())) {
|
|
if (OrderSourceEnum.PURCHASE.getType().equals(param.getOrderSource())) {
|
|
|
- entCooperate = remoteManageService.findEntCooperate(param.getProcureEntId()
|
|
|
|
|
- , param.getSupplyEntId(), CooperateTypeEnum.SUPPLIER.getCode());
|
|
|
|
|
|
|
+ entCooperate = remoteManageService.findEntCooperate(param.getProcureEntId(), param.getSupplyEntId(), CooperateTypeEnum.SUPPLIER.getCode());
|
|
|
} else {
|
|
} else {
|
|
|
- entCooperate = remoteManageService.findEntCooperate(param.getSupplyEntId()
|
|
|
|
|
- , param.getProcureEntId(), CooperateTypeEnum.PURCHASER.getCode());
|
|
|
|
|
|
|
+ entCooperate = remoteManageService.findEntCooperate(param.getSupplyEntId(), param.getProcureEntId(), CooperateTypeEnum.PURCHASER.getCode());
|
|
|
}
|
|
}
|
|
|
if (CollectionUtils.isEmpty(entCooperate)) {
|
|
if (CollectionUtils.isEmpty(entCooperate)) {
|
|
|
throw new BusinessException("供采双方企业无合作关系!");
|
|
throw new BusinessException("供采双方企业无合作关系!");
|
|
@@ -578,19 +539,13 @@ public class KwoTradeOrderService {
|
|
|
public void addValetOrderSubmit(ValetOrderParam param) {
|
|
public void addValetOrderSubmit(ValetOrderParam param) {
|
|
|
OrderCheckDTO orderCheck = BeanUtil.copyProperties(param, OrderCheckDTO.class);
|
|
OrderCheckDTO orderCheck = BeanUtil.copyProperties(param, OrderCheckDTO.class);
|
|
|
getTopEnt(orderCheck, param.getUnitInfo());
|
|
getTopEnt(orderCheck, param.getUnitInfo());
|
|
|
- orderCheck.setGoodsId(param.getGoodsInfo().getGoodsId()).setUnitPrice(param.getGoodsInfo().getUnitPrice())
|
|
|
|
|
- .setOrderSource(OrderSourceEnum.SALE.getType());
|
|
|
|
|
|
|
+ orderCheck.setGoodsId(param.getGoodsInfo().getGoodsId()).setUnitPrice(param.getGoodsInfo().getUnitPrice()).setOrderSource(OrderSourceEnum.SALE.getType());
|
|
|
orderCheck(orderCheck, false);
|
|
orderCheck(orderCheck, false);
|
|
|
ContractInfo contract = param.getContractInfo();
|
|
ContractInfo contract = param.getContractInfo();
|
|
|
contractCheck(contract);
|
|
contractCheck(contract);
|
|
|
param.setContractInfo(contract);
|
|
param.setContractInfo(contract);
|
|
|
KwoTradeOrder order = BeanUtil.copyProperties(param, KwoTradeOrder.class);
|
|
KwoTradeOrder order = BeanUtil.copyProperties(param, KwoTradeOrder.class);
|
|
|
- order.setEntId(LoginUserHolder.getEntId())
|
|
|
|
|
- .setTOrderNo(getOrderNo())
|
|
|
|
|
- .setStartTime(DateUtils.localDateToDateStart(param.getStartTime()))
|
|
|
|
|
- .setEndTime(DateUtils.localDateToDateEnd(param.getEndTime()))
|
|
|
|
|
- .setUnit(param.getGoodsInfo().getUnit())
|
|
|
|
|
- .setSource(OrderSourceEnum.SALE.getType());
|
|
|
|
|
|
|
+ order.setEntId(LoginUserHolder.getEntId()).setTOrderNo(getOrderNo()).setStartTime(DateUtils.localDateToDateStart(param.getStartTime())).setEndTime(DateUtils.localDateToDateEnd(param.getEndTime())).setUnit(param.getGoodsInfo().getUnit()).setSource(OrderSourceEnum.SALE.getType());
|
|
|
String contractStatus = contract.getContractStatus();
|
|
String contractStatus = contract.getContractStatus();
|
|
|
if (Objects.equals(contractStatus, ContractStatusEnum.WAIT_SIGNED.getCode())) {
|
|
if (Objects.equals(contractStatus, ContractStatusEnum.WAIT_SIGNED.getCode())) {
|
|
|
order.setStatus(OrderStatusEnum.WAIT_SIGNED.getCode());
|
|
order.setStatus(OrderStatusEnum.WAIT_SIGNED.getCode());
|
|
@@ -607,8 +562,7 @@ public class KwoTradeOrderService {
|
|
|
}
|
|
}
|
|
|
//冻结金额
|
|
//冻结金额
|
|
|
if (param.getTrading().startsWith("1")) {
|
|
if (param.getTrading().startsWith("1")) {
|
|
|
- HttpResult freezeResult = paymentDubboService.freezeMoney(orderCheck.getProcureTopEntId(),
|
|
|
|
|
- ChannelEnum.getByTrading(param.getTrading()), orderCheck.getSupplyTopEntId(), param.getPrice(), order.getId());
|
|
|
|
|
|
|
+ HttpResult freezeResult = paymentDubboService.freezeMoney(orderCheck.getProcureTopEntId(), ChannelEnum.getByTrading(param.getTrading()), orderCheck.getSupplyTopEntId(), param.getPrice(), order.getId());
|
|
|
if (!Objects.equals(HttpStatus.SUCCESS_CODE, freezeResult.getCode())) {
|
|
if (!Objects.equals(HttpStatus.SUCCESS_CODE, freezeResult.getCode())) {
|
|
|
throw new BusinessException(freezeResult.getMsg());
|
|
throw new BusinessException(freezeResult.getMsg());
|
|
|
}
|
|
}
|
|
@@ -714,11 +668,7 @@ public class KwoTradeOrderService {
|
|
|
if (Objects.isNull(order)) {
|
|
if (Objects.isNull(order)) {
|
|
|
throw new BusinessException("不存在该订单!");
|
|
throw new BusinessException("不存在该订单!");
|
|
|
}
|
|
}
|
|
|
- Map<String, Map<String, String>> dict = remoteSystemService.queryDictByType(
|
|
|
|
|
- List.of(DictTypeEnum.TRADE_TYPE.getType(), DictTypeEnum.PICKUP_TYPE.getType(),
|
|
|
|
|
- DictTypeEnum.DELIVERY_TYPE.getType(), DictTypeEnum.TORDER_SOURCE.getType(), DictTypeEnum.TORDER_STATUS.getType(),
|
|
|
|
|
- DictTypeEnum.PRODUCT_NAME_TYPE.getType(), DictTypeEnum.UNIT_TYPE.getType(), DictTypeEnum.TAX_RATE.getType(),
|
|
|
|
|
- DictTypeEnum.TORDER_UNIT_TYPE.getType(), DictTypeEnum.TORDER_ADDRESS_TYPE.getType(), DictTypeEnum.ADDRESS_TYPE.getType(), DictTypeEnum.CONSIGNMENT_WAY.getType(), DictTypeEnum.CHARGING_TYPE.getType()));
|
|
|
|
|
|
|
+ Map<String, Map<String, String>> dict = remoteSystemService.queryDictByType(List.of(DictTypeEnum.TRADE_TYPE.getType(), DictTypeEnum.PICKUP_TYPE.getType(), DictTypeEnum.DELIVERY_TYPE.getType(), DictTypeEnum.TORDER_SOURCE.getType(), DictTypeEnum.TORDER_STATUS.getType(), DictTypeEnum.PRODUCT_NAME_TYPE.getType(), DictTypeEnum.UNIT_TYPE.getType(), DictTypeEnum.TAX_RATE.getType(), DictTypeEnum.TORDER_UNIT_TYPE.getType(), DictTypeEnum.TORDER_ADDRESS_TYPE.getType(), DictTypeEnum.ADDRESS_TYPE.getType(), DictTypeEnum.CONSIGNMENT_WAY.getType(), DictTypeEnum.CHARGING_TYPE.getType()));
|
|
|
Map<String, String> tradeMap = new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
Map<String, String> tradeMap = new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
|
Map<String, String> pickupMap = new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
Map<String, String> pickupMap = new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
|
Map<String, String> deleveryMap = new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
Map<String, String> deleveryMap = new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
@@ -732,7 +682,7 @@ public class KwoTradeOrderService {
|
|
|
Map<String, String> orderUnitMap, orderAddressMap, addressMap;
|
|
Map<String, String> orderUnitMap, orderAddressMap, addressMap;
|
|
|
if (CollUtil.isNotEmpty(dict)) {
|
|
if (CollUtil.isNotEmpty(dict)) {
|
|
|
tradeMap = dict.get(DictTypeEnum.TRADE_TYPE.getType());
|
|
tradeMap = dict.get(DictTypeEnum.TRADE_TYPE.getType());
|
|
|
- pickupMap = dict.get(DictTypeEnum.PICKUP_TYPE.getType());
|
|
|
|
|
|
|
+ pickupMap = dict.get(DictTypeEnum.CONSIGNMENT_WAY.getType());
|
|
|
deleveryMap = dict.get(DictTypeEnum.DELIVERY_TYPE.getType());
|
|
deleveryMap = dict.get(DictTypeEnum.DELIVERY_TYPE.getType());
|
|
|
sourceMap = dict.get(DictTypeEnum.TORDER_SOURCE.getType());
|
|
sourceMap = dict.get(DictTypeEnum.TORDER_SOURCE.getType());
|
|
|
statusMap = dict.get(DictTypeEnum.TORDER_STATUS.getType());
|
|
statusMap = dict.get(DictTypeEnum.TORDER_STATUS.getType());
|
|
@@ -753,16 +703,7 @@ public class KwoTradeOrderService {
|
|
|
OrderDetailRes detail = BeanUtil.copyProperties(order, OrderDetailRes.class);
|
|
OrderDetailRes detail = BeanUtil.copyProperties(order, OrderDetailRes.class);
|
|
|
UserCacheResDto createUser = remoteSystemService.queryUserCacheById(detail.getCreateBy());
|
|
UserCacheResDto createUser = remoteSystemService.queryUserCacheById(detail.getCreateBy());
|
|
|
EntCacheResDto ent = remoteSystemService.queryEntCacheById(detail.getEntId());
|
|
EntCacheResDto ent = remoteSystemService.queryEntCacheById(detail.getEntId());
|
|
|
- detail.setFirmName(Objects.isNull(ent) ? null : ent.getFirmName())
|
|
|
|
|
- .setCreateByName(Objects.isNull(createUser) ? null : createUser.getName())
|
|
|
|
|
- .setTradingLabel(CollUtil.isNotEmpty(tradeMap) ? tradeMap.get(detail.getTrading()) : null)
|
|
|
|
|
- .setPickupTypeLabel(CollUtil.isNotEmpty(pickupMap) ? pickupMap.get(detail.getPickupType()) : null)
|
|
|
|
|
- .setDeliveryTypeLabel(CollUtil.isNotEmpty(deleveryMap) ? deleveryMap.get(detail.getDeliveryType()) : null)
|
|
|
|
|
- .setSourceLabel(CollUtil.isNotEmpty(sourceMap) ? sourceMap.get(detail.getSource()) : null)
|
|
|
|
|
- .setStatusLabel(CollUtil.isNotEmpty(statusMap) ? statusMap.get(String.valueOf(detail.getStatus())) : null)
|
|
|
|
|
- .setChargeTypeLabel(CollUtil.isNotEmpty(chargeTypeMap) ? chargeTypeMap.get(String.valueOf(detail.getChargeType())) : null)
|
|
|
|
|
- .setConsignmentWayLabel(CollUtil.isNotEmpty(consignmentWayMap) ? consignmentWayMap.get(String.valueOf(detail.getConsignmentWay())) : null)
|
|
|
|
|
- ;
|
|
|
|
|
|
|
+ detail.setFirmName(Objects.isNull(ent) ? null : ent.getFirmName()).setCreateByName(Objects.isNull(createUser) ? null : createUser.getName()).setTradingLabel(CollUtil.isNotEmpty(tradeMap) ? tradeMap.get(detail.getTrading()) : null).setPickupTypeLabel(CollUtil.isNotEmpty(pickupMap) ? pickupMap.get(detail.getPickupType()) : null).setDeliveryTypeLabel(CollUtil.isNotEmpty(deleveryMap) ? deleveryMap.get(detail.getDeliveryType()) : null).setSourceLabel(CollUtil.isNotEmpty(sourceMap) ? sourceMap.get(detail.getSource()) : null).setStatusLabel(CollUtil.isNotEmpty(statusMap) ? statusMap.get(String.valueOf(detail.getStatus())) : null).setChargeTypeLabel(CollUtil.isNotEmpty(chargeTypeMap) ? chargeTypeMap.get(String.valueOf(detail.getChargeType())) : null).setConsignmentWayLabel(CollUtil.isNotEmpty(consignmentWayMap) ? consignmentWayMap.get(String.valueOf(detail.getConsignmentWay())) : null);
|
|
|
if (Objects.equals(detail.getChargeType(), 1)) {//按装货量
|
|
if (Objects.equals(detail.getChargeType(), 1)) {//按装货量
|
|
|
detail.setDealAmount(detail.getLoadAmount());
|
|
detail.setDealAmount(detail.getLoadAmount());
|
|
|
} else {
|
|
} else {
|
|
@@ -775,16 +716,7 @@ public class KwoTradeOrderService {
|
|
|
if (Objects.nonNull(goods)) {
|
|
if (Objects.nonNull(goods)) {
|
|
|
EntCacheResDto entCache = remoteSystemService.queryEntCacheById(goods.getEntId());
|
|
EntCacheResDto entCache = remoteSystemService.queryEntCacheById(goods.getEntId());
|
|
|
GoodsInfoDetailRes goodsDetail = new GoodsInfoDetailRes();
|
|
GoodsInfoDetailRes goodsDetail = new GoodsInfoDetailRes();
|
|
|
- goodsDetail.setGoodsTypeLabel(CollUtil.isNotEmpty(prodcutNameMap) ? prodcutNameMap.get(goods.getGoodsType()) : null)
|
|
|
|
|
- .setUnitLabel(CollUtil.isNotEmpty(unitMap) ? unitMap.get(goods.getUnit()) : null)
|
|
|
|
|
- .setTaxRateLabel(CollUtil.isNotEmpty(taxRateMap) ? taxRateMap.get(goods.getTaxRate()) : null)
|
|
|
|
|
- .setGoodsAmount(goods.getAmount())
|
|
|
|
|
- .setGoodsId(goods.getId()).setCode(goods.getCode()).setName(goods.getName())
|
|
|
|
|
- .setGoodsType(goods.getGoodsType()).setTaxRate(goods.getTaxRate()).setSpec(goods.getSpec())
|
|
|
|
|
- .setUnit(goods.getUnit()).setPriceRangeId(orderGoods.getPriceRangeId()).setUnitPrice(orderGoods.getUnitPrice())
|
|
|
|
|
- .setSkuId(orderGoods.getSkuId()).setCollectionUnitId(goods.getEntId()).setGoodsThumb(goods.getThumb())
|
|
|
|
|
- .setPrepaidLimit(goods.getPrepaidLimit()).setAdvancePrice(goods.getAdvancePrice())
|
|
|
|
|
- .setCollectionUnit(Objects.isNull(entCache) ? null : entCache.getFirmName());
|
|
|
|
|
|
|
+ goodsDetail.setGoodsTypeLabel(CollUtil.isNotEmpty(prodcutNameMap) ? prodcutNameMap.get(goods.getGoodsType()) : null).setUnitLabel(CollUtil.isNotEmpty(unitMap) ? unitMap.get(goods.getUnit()) : null).setTaxRateLabel(CollUtil.isNotEmpty(taxRateMap) ? taxRateMap.get(goods.getTaxRate()) : null).setGoodsAmount(goods.getAmount()).setGoodsId(goods.getId()).setCode(goods.getCode()).setName(goods.getName()).setGoodsType(goods.getGoodsType()).setTaxRate(goods.getTaxRate()).setSpec(goods.getSpec()).setUnit(goods.getUnit()).setPriceRangeId(orderGoods.getPriceRangeId()).setUnitPrice(orderGoods.getUnitPrice()).setSkuId(orderGoods.getSkuId()).setCollectionUnitId(goods.getEntId()).setGoodsThumb(goods.getThumb()).setPrepaidLimit(goods.getPrepaidLimit()).setAdvancePrice(goods.getAdvancePrice()).setCollectionUnit(Objects.isNull(entCache) ? null : entCache.getFirmName());
|
|
|
detail.setGoodsInfo(goodsDetail);
|
|
detail.setGoodsInfo(goodsDetail);
|
|
|
if (Objects.equals(detail.getChargeType(), 1)) {//按装货量
|
|
if (Objects.equals(detail.getChargeType(), 1)) {//按装货量
|
|
|
detail.setDealMoney(NumberUtil.mul(orderGoods.getUnitPrice(), detail.getLoadAmount()));
|
|
detail.setDealMoney(NumberUtil.mul(orderGoods.getUnitPrice(), detail.getLoadAmount()));
|
|
@@ -858,11 +790,10 @@ public class KwoTradeOrderService {
|
|
|
contractInfo.setContractId(d.getContractId());
|
|
contractInfo.setContractId(d.getContractId());
|
|
|
contractInfo.setContractNo(d.getContractNo());
|
|
contractInfo.setContractNo(d.getContractNo());
|
|
|
Optional.ofNullable(contractMap.get(d.getContractId())).ifPresent(c -> {
|
|
Optional.ofNullable(contractMap.get(d.getContractId())).ifPresent(c -> {
|
|
|
- contractInfo.setContractName(c.getContactName());
|
|
|
|
|
- contractInfo.setContractSigningWay(c.getSigningWayName());
|
|
|
|
|
- contractInfo.setContractStatus(c.getStatusName());
|
|
|
|
|
- }
|
|
|
|
|
- );
|
|
|
|
|
|
|
+ contractInfo.setContractName(c.getContactName());
|
|
|
|
|
+ contractInfo.setContractSigningWay(c.getSigningWayName());
|
|
|
|
|
+ contractInfo.setContractStatus(c.getStatusName());
|
|
|
|
|
+ });
|
|
|
return contractInfo;
|
|
return contractInfo;
|
|
|
}).collect(Collectors.toList());
|
|
}).collect(Collectors.toList());
|
|
|
detail.setContractInfoList(collect);
|
|
detail.setContractInfoList(collect);
|
|
@@ -899,15 +830,13 @@ public class KwoTradeOrderService {
|
|
|
}
|
|
}
|
|
|
String source = order.getSource();
|
|
String source = order.getSource();
|
|
|
Integer status = order.getStatus();
|
|
Integer status = order.getStatus();
|
|
|
- if ((!Objects.equals(status, OrderStatusEnum.SAVED.getCode()) && !Objects.equals(status, OrderStatusEnum.RETURNED.getCode()))
|
|
|
|
|
- && Objects.equals(source, OrderSourceEnum.PURCHASE.getType())) {
|
|
|
|
|
|
|
+ if ((!Objects.equals(status, OrderStatusEnum.SAVED.getCode()) && !Objects.equals(status, OrderStatusEnum.RETURNED.getCode())) && Objects.equals(source, OrderSourceEnum.PURCHASE.getType())) {
|
|
|
throw new BusinessException("采购下单只能修改已保存及已退回状态的订单!");
|
|
throw new BusinessException("采购下单只能修改已保存及已退回状态的订单!");
|
|
|
}
|
|
}
|
|
|
if (Objects.equals(source, OrderSourceEnum.SALE.getType()) && !Objects.equals(status, OrderStatusEnum.SAVED.getCode())) {
|
|
if (Objects.equals(source, OrderSourceEnum.SALE.getType()) && !Objects.equals(status, OrderStatusEnum.SAVED.getCode())) {
|
|
|
throw new BusinessException("代客下单只能修改已保存状态的订单!");
|
|
throw new BusinessException("代客下单只能修改已保存状态的订单!");
|
|
|
}
|
|
}
|
|
|
- if (!Objects.equals(0, order.getStatus())
|
|
|
|
|
- && kwoTradeOrderUnitService.entMatch(param.getId(), LoginUserHolder.getEntId(), source)) {
|
|
|
|
|
|
|
+ if (!Objects.equals(0, order.getStatus()) && kwoTradeOrderUnitService.entMatch(param.getId(), LoginUserHolder.getEntId(), source)) {
|
|
|
throw new BusinessException("无权限修改此订单!");
|
|
throw new BusinessException("无权限修改此订单!");
|
|
|
}
|
|
}
|
|
|
OrderCheckDTO orderCheck = new OrderCheckDTO();
|
|
OrderCheckDTO orderCheck = new OrderCheckDTO();
|
|
@@ -930,8 +859,7 @@ public class KwoTradeOrderService {
|
|
|
}
|
|
}
|
|
|
orderCheck = BeanUtil.copyProperties(param, OrderCheckDTO.class);
|
|
orderCheck = BeanUtil.copyProperties(param, OrderCheckDTO.class);
|
|
|
getTopEnt(orderCheck, param.getUnitInfo());
|
|
getTopEnt(orderCheck, param.getUnitInfo());
|
|
|
- orderCheck.setGoodsId(param.getGoodsInfo().getGoodsId()).setUnitPrice(param.getGoodsInfo().getUnitPrice())
|
|
|
|
|
- .setOrderSource(source);
|
|
|
|
|
|
|
+ orderCheck.setGoodsId(param.getGoodsInfo().getGoodsId()).setUnitPrice(param.getGoodsInfo().getUnitPrice()).setOrderSource(source);
|
|
|
orderCheck(orderCheck, false);
|
|
orderCheck(orderCheck, false);
|
|
|
//扣减库存
|
|
//扣减库存
|
|
|
HttpResult updateResult = goodsInfoService.updateGoodsAmount(param.getGoodsInfo().getGoodsId(), param.getAmount());
|
|
HttpResult updateResult = goodsInfoService.updateGoodsAmount(param.getGoodsInfo().getGoodsId(), param.getAmount());
|
|
@@ -940,31 +868,15 @@ public class KwoTradeOrderService {
|
|
|
}
|
|
}
|
|
|
//代客下单冻结金额
|
|
//代客下单冻结金额
|
|
|
if (Objects.equals(source, OrderSourceEnum.SALE.getType()) && param.getTrading().startsWith("1")) {
|
|
if (Objects.equals(source, OrderSourceEnum.SALE.getType()) && param.getTrading().startsWith("1")) {
|
|
|
- HttpResult freezeResult = paymentDubboService.freezeMoney(orderCheck.getProcureTopEntId(),
|
|
|
|
|
- ChannelEnum.getByTrading(param.getTrading()), orderCheck.getSupplyTopEntId(), param.getPrice(), order.getId());
|
|
|
|
|
|
|
+ HttpResult freezeResult = paymentDubboService.freezeMoney(orderCheck.getProcureTopEntId(), ChannelEnum.getByTrading(param.getTrading()), orderCheck.getSupplyTopEntId(), param.getPrice(), order.getId());
|
|
|
if (!Objects.equals(HttpStatus.SUCCESS_CODE, freezeResult.getCode())) {
|
|
if (!Objects.equals(HttpStatus.SUCCESS_CODE, freezeResult.getCode())) {
|
|
|
throw new BusinessException(freezeResult.getMsg());
|
|
throw new BusinessException(freezeResult.getMsg());
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
- order.setAmount(param.getAmount()).setUnit(Objects.isNull(param.getGoodsInfo()) ? null : param.getGoodsInfo().getUnit())
|
|
|
|
|
- .setPrice(param.getPrice()).setTrading(param.getTrading()).setPickupType(param.getPickupType())
|
|
|
|
|
- .setDeliveryType(param.getDeliveryType())
|
|
|
|
|
- .setStartTime(DateUtils.localDateToDateStart(param.getStartTime()))
|
|
|
|
|
- .setEndTime(DateUtils.localDateToDateEnd(param.getEndTime()))
|
|
|
|
|
- .setRemark(param.getRemark());
|
|
|
|
|
|
|
+ order.setAmount(param.getAmount()).setUnit(Objects.isNull(param.getGoodsInfo()) ? null : param.getGoodsInfo().getUnit()).setPrice(param.getPrice()).setTrading(param.getTrading()).setPickupType(param.getPickupType()).setDeliveryType(param.getDeliveryType()).setStartTime(DateUtils.localDateToDateStart(param.getStartTime())).setEndTime(DateUtils.localDateToDateEnd(param.getEndTime())).setRemark(param.getRemark());
|
|
|
LambdaUpdateWrapper<KwoTradeOrder> wrapper = new LambdaUpdateWrapper<>();
|
|
LambdaUpdateWrapper<KwoTradeOrder> wrapper = new LambdaUpdateWrapper<>();
|
|
|
- wrapper.set(KwoTradeOrder::getAmount, order.getAmount())
|
|
|
|
|
- .set(KwoTradeOrder::getUnit, order.getUnit())
|
|
|
|
|
- .set(KwoTradeOrder::getPrice, order.getPrice())
|
|
|
|
|
- .set(KwoTradeOrder::getTrading, order.getTrading())
|
|
|
|
|
- .set(KwoTradeOrder::getPickupType, order.getPickupType())
|
|
|
|
|
- .set(KwoTradeOrder::getDeliveryType, order.getDeliveryType())
|
|
|
|
|
- .set(KwoTradeOrder::getStartTime, order.getStartTime())
|
|
|
|
|
- .set(KwoTradeOrder::getEndTime, order.getEndTime())
|
|
|
|
|
- .set(KwoTradeOrder::getRemark, order.getRemark())
|
|
|
|
|
- .set(KwoTradeOrder::getStatus, order.getStatus())
|
|
|
|
|
- .eq(KwoTradeOrder::getId, order.getId());
|
|
|
|
|
|
|
+ wrapper.set(KwoTradeOrder::getAmount, order.getAmount()).set(KwoTradeOrder::getUnit, order.getUnit()).set(KwoTradeOrder::getPrice, order.getPrice()).set(KwoTradeOrder::getTrading, order.getTrading()).set(KwoTradeOrder::getPickupType, order.getPickupType()).set(KwoTradeOrder::getDeliveryType, order.getDeliveryType()).set(KwoTradeOrder::getStartTime, order.getStartTime()).set(KwoTradeOrder::getEndTime, order.getEndTime()).set(KwoTradeOrder::getRemark, order.getRemark()).set(KwoTradeOrder::getStatus, order.getStatus()).eq(KwoTradeOrder::getId, order.getId());
|
|
|
kwoTradeOrderMapper.update(null, wrapper);
|
|
kwoTradeOrderMapper.update(null, wrapper);
|
|
|
ValetOrderParam valetOrderParam = BeanUtil.copyProperties(param, ValetOrderParam.class);
|
|
ValetOrderParam valetOrderParam = BeanUtil.copyProperties(param, ValetOrderParam.class);
|
|
|
|
|
|
|
@@ -1097,8 +1009,7 @@ public class KwoTradeOrderService {
|
|
|
public void acceptanceOrder(AcceptanceOrderParam param) {
|
|
public void acceptanceOrder(AcceptanceOrderParam param) {
|
|
|
BigDecimal amount = param.getAmount();
|
|
BigDecimal amount = param.getAmount();
|
|
|
List<UpdateAddressAmountParam> addressAmountParams = param.getAddressAmountParams();
|
|
List<UpdateAddressAmountParam> addressAmountParams = param.getAddressAmountParams();
|
|
|
- BigDecimal totalLoadAmount = addressAmountParams.stream()
|
|
|
|
|
- .map(UpdateAddressAmountParam::getAmount).reduce(BigDecimal.ZERO, BigDecimal::add);
|
|
|
|
|
|
|
+ BigDecimal totalLoadAmount = addressAmountParams.stream().map(UpdateAddressAmountParam::getAmount).reduce(BigDecimal.ZERO, BigDecimal::add);
|
|
|
if (amount.compareTo(totalLoadAmount) != 0) {
|
|
if (amount.compareTo(totalLoadAmount) != 0) {
|
|
|
throw new BusinessException("分配卸货量总量与订单总量不相符!");
|
|
throw new BusinessException("分配卸货量总量与订单总量不相符!");
|
|
|
}
|
|
}
|
|
@@ -1107,8 +1018,7 @@ public class KwoTradeOrderService {
|
|
|
if (unloadCount > 0) {
|
|
if (unloadCount > 0) {
|
|
|
throw new BusinessException("装货地址类型信息有误!");
|
|
throw new BusinessException("装货地址类型信息有误!");
|
|
|
}
|
|
}
|
|
|
- BigDecimal totalUnLoadAmount = loadAddressInfoDto.stream()
|
|
|
|
|
- .map(AddressInfoDto::getAmount).reduce(BigDecimal.ZERO, BigDecimal::add);
|
|
|
|
|
|
|
+ BigDecimal totalUnLoadAmount = loadAddressInfoDto.stream().map(AddressInfoDto::getAmount).reduce(BigDecimal.ZERO, BigDecimal::add);
|
|
|
if (amount.compareTo(totalUnLoadAmount) != 0) {
|
|
if (amount.compareTo(totalUnLoadAmount) != 0) {
|
|
|
throw new BusinessException("分配装货量总量与订单总量不相符!");
|
|
throw new BusinessException("分配装货量总量与订单总量不相符!");
|
|
|
}
|
|
}
|
|
@@ -1131,8 +1041,7 @@ public class KwoTradeOrderService {
|
|
|
}
|
|
}
|
|
|
List<KwoTradeOrderUnit> units = kwoTradeOrderUnitService.getByOrderId(order.getId());
|
|
List<KwoTradeOrderUnit> units = kwoTradeOrderUnitService.getByOrderId(order.getId());
|
|
|
Long saleUnitId = param.getSaleUnitParam().getId();
|
|
Long saleUnitId = param.getSaleUnitParam().getId();
|
|
|
- KwoTradeOrderUnit saleUnit = units.stream().filter(e -> Objects.equals(e.getId(), saleUnitId) &&
|
|
|
|
|
- Objects.equals(e.getUnitType(), OrderUnitTypeEnum.SALE.getType())).findFirst().orElse(null);
|
|
|
|
|
|
|
+ KwoTradeOrderUnit saleUnit = units.stream().filter(e -> Objects.equals(e.getId(), saleUnitId) && Objects.equals(e.getUnitType(), OrderUnitTypeEnum.SALE.getType())).findFirst().orElse(null);
|
|
|
if (Objects.isNull(saleUnit)) {
|
|
if (Objects.isNull(saleUnit)) {
|
|
|
throw new BusinessException("我方单位信息异常!");
|
|
throw new BusinessException("我方单位信息异常!");
|
|
|
}
|
|
}
|
|
@@ -1157,8 +1066,7 @@ public class KwoTradeOrderService {
|
|
|
orderCheck(orderCheck, true);
|
|
orderCheck(orderCheck, true);
|
|
|
//冻结金额
|
|
//冻结金额
|
|
|
if (param.getTrading().startsWith("1")) {
|
|
if (param.getTrading().startsWith("1")) {
|
|
|
- HttpResult freezeResult = paymentDubboService.freezeMoney(orderCheck.getProcureTopEntId(),
|
|
|
|
|
- ChannelEnum.getByTrading(param.getTrading()), orderCheck.getSupplyTopEntId(), param.getPrice(), order.getId());
|
|
|
|
|
|
|
+ HttpResult freezeResult = paymentDubboService.freezeMoney(orderCheck.getProcureTopEntId(), ChannelEnum.getByTrading(param.getTrading()), orderCheck.getSupplyTopEntId(), param.getPrice(), order.getId());
|
|
|
if (!Objects.equals(HttpStatus.SUCCESS_CODE, freezeResult.getCode())) {
|
|
if (!Objects.equals(HttpStatus.SUCCESS_CODE, freezeResult.getCode())) {
|
|
|
throw new BusinessException(freezeResult.getMsg());
|
|
throw new BusinessException(freezeResult.getMsg());
|
|
|
}
|
|
}
|
|
@@ -1175,8 +1083,7 @@ public class KwoTradeOrderService {
|
|
|
} else {
|
|
} else {
|
|
|
throw new BusinessException("Invalid contract status");
|
|
throw new BusinessException("Invalid contract status");
|
|
|
}
|
|
}
|
|
|
- order.setStartTime(DateUtils.localDateToDateStart(param.getStartTime()))
|
|
|
|
|
- .setEndTime(DateUtils.localDateToDateEnd(param.getEndTime()));
|
|
|
|
|
|
|
+ order.setStartTime(DateUtils.localDateToDateStart(param.getStartTime())).setEndTime(DateUtils.localDateToDateEnd(param.getEndTime()));
|
|
|
kwoTradeOrderMapper.updateById(order);
|
|
kwoTradeOrderMapper.updateById(order);
|
|
|
//更新商品价格
|
|
//更新商品价格
|
|
|
kwoTradeOrderGoodsService.updateUnitPrice(param.getId(), param.getUnitPrice());
|
|
kwoTradeOrderGoodsService.updateUnitPrice(param.getId(), param.getUnitPrice());
|
|
@@ -1185,8 +1092,7 @@ public class KwoTradeOrderService {
|
|
|
kwoTradeOrderUnitService.updateById(saleUnit);
|
|
kwoTradeOrderUnitService.updateById(saleUnit);
|
|
|
}
|
|
}
|
|
|
//更新装货地址信息
|
|
//更新装货地址信息
|
|
|
- List<Long> oldLoadAddressIds = kwoTradeOrderAddressService.getByOrderIdAndType(param.getId(), OrderAddressTypeEnum.LOAD.getType())
|
|
|
|
|
- .stream().map(KwoTradeOrderAddress::getId).toList();
|
|
|
|
|
|
|
+ List<Long> oldLoadAddressIds = kwoTradeOrderAddressService.getByOrderIdAndType(param.getId(), OrderAddressTypeEnum.LOAD.getType()).stream().map(KwoTradeOrderAddress::getId).toList();
|
|
|
if (CollUtil.isNotEmpty(oldLoadAddressIds)) {
|
|
if (CollUtil.isNotEmpty(oldLoadAddressIds)) {
|
|
|
kwoTradeOrderAddressService.delByIds(oldLoadAddressIds);
|
|
kwoTradeOrderAddressService.delByIds(oldLoadAddressIds);
|
|
|
tradeOrderAmountService.delByOrderIdAndAddressIds(param.getId(), oldLoadAddressIds);
|
|
tradeOrderAmountService.delByOrderIdAndAddressIds(param.getId(), oldLoadAddressIds);
|
|
@@ -1194,14 +1100,12 @@ public class KwoTradeOrderService {
|
|
|
AtomicInteger loadSort = new AtomicInteger(0);
|
|
AtomicInteger loadSort = new AtomicInteger(0);
|
|
|
loadAddressInfoDto.forEach(e -> {
|
|
loadAddressInfoDto.forEach(e -> {
|
|
|
KwoTradeOrderAddress address = BeanUtil.copyProperties(e, KwoTradeOrderAddress.class);
|
|
KwoTradeOrderAddress address = BeanUtil.copyProperties(e, KwoTradeOrderAddress.class);
|
|
|
- address.setTOrderId(param.getId()).setTOrderNo(order.getTOrderNo())
|
|
|
|
|
- .setSort(loadSort.getAndIncrement());
|
|
|
|
|
|
|
+ address.setTOrderId(param.getId()).setTOrderNo(order.getTOrderNo()).setSort(loadSort.getAndIncrement());
|
|
|
//地址信息
|
|
//地址信息
|
|
|
Long addressId = kwoTradeOrderAddressService.add(address);
|
|
Long addressId = kwoTradeOrderAddressService.add(address);
|
|
|
//分配量信息
|
|
//分配量信息
|
|
|
KwoTradeOrderAmount orderAmount = new KwoTradeOrderAmount();
|
|
KwoTradeOrderAmount orderAmount = new KwoTradeOrderAmount();
|
|
|
- orderAmount.setTOrderId(param.getId()).setAmount(e.getAmount())
|
|
|
|
|
- .setTAddressId(addressId);
|
|
|
|
|
|
|
+ orderAmount.setTOrderId(param.getId()).setAmount(e.getAmount()).setTAddressId(addressId);
|
|
|
tradeOrderAmountService.add(orderAmount);
|
|
tradeOrderAmountService.add(orderAmount);
|
|
|
});
|
|
});
|
|
|
//更新卸货地址分配量信息
|
|
//更新卸货地址分配量信息
|
|
@@ -1223,20 +1127,7 @@ public class KwoTradeOrderService {
|
|
|
}
|
|
}
|
|
|
//更新mongodb
|
|
//更新mongodb
|
|
|
SckwTradeOrder updateParam = BeanUtil.copyProperties(param, SckwTradeOrder.class);
|
|
SckwTradeOrder updateParam = BeanUtil.copyProperties(param, SckwTradeOrder.class);
|
|
|
- updateParam.setTOrderId(param.getId())
|
|
|
|
|
- .setStatus(order.getStatus())
|
|
|
|
|
- .setStartTime(DateUtils.localDateToDateStart(param.getStartTime()))
|
|
|
|
|
- .setEndTime(DateUtils.localDateToDateEnd(param.getEndTime()))
|
|
|
|
|
- .setPrice(order.getPrice().doubleValue())
|
|
|
|
|
- .setAmount(order.getAmount().doubleValue())
|
|
|
|
|
- .setUnitPrice(param.getUnitPrice().doubleValue())
|
|
|
|
|
- .setContractId(contractInfo.getContractId())
|
|
|
|
|
- .setContractNo(contractInfo.getContractNo())
|
|
|
|
|
- .setContractName(contractInfo.getContractName())
|
|
|
|
|
- .setContractSigningWay(contractInfo.getContractSigningWay())
|
|
|
|
|
- .setUpdateBy(LoginUserHolder.getUserId())
|
|
|
|
|
- .setUpdateByName(LoginUserHolder.getUserName())
|
|
|
|
|
- .setUpdateTime(new Date());
|
|
|
|
|
|
|
+ updateParam.setTOrderId(param.getId()).setStatus(order.getStatus()).setStartTime(DateUtils.localDateToDateStart(param.getStartTime())).setEndTime(DateUtils.localDateToDateEnd(param.getEndTime())).setPrice(order.getPrice().doubleValue()).setAmount(order.getAmount().doubleValue()).setUnitPrice(param.getUnitPrice().doubleValue()).setContractId(contractInfo.getContractId()).setContractNo(contractInfo.getContractNo()).setContractName(contractInfo.getContractName()).setContractSigningWay(contractInfo.getContractSigningWay()).setUpdateBy(LoginUserHolder.getUserId()).setUpdateByName(LoginUserHolder.getUserName()).setUpdateTime(new Date());
|
|
|
saveMongoDb(3, updateParam);
|
|
saveMongoDb(3, updateParam);
|
|
|
|
|
|
|
|
}
|
|
}
|
|
@@ -1273,8 +1164,7 @@ public class KwoTradeOrderService {
|
|
|
}
|
|
}
|
|
|
//mongodb更新订单状态
|
|
//mongodb更新订单状态
|
|
|
SckwTradeOrder updateParam = new SckwTradeOrder();
|
|
SckwTradeOrder updateParam = new SckwTradeOrder();
|
|
|
- updateParam.setTOrderId(order.getId()).setStatus(order.getStatus()).setUpdateBy(LoginUserHolder.getUserId())
|
|
|
|
|
- .setUpdateByName(LoginUserHolder.getUserName()).setUpdateTime(new Date());
|
|
|
|
|
|
|
+ updateParam.setTOrderId(order.getId()).setStatus(order.getStatus()).setUpdateBy(LoginUserHolder.getUserId()).setUpdateByName(LoginUserHolder.getUserName()).setUpdateTime(new Date());
|
|
|
saveMongoDb(3, updateParam);
|
|
saveMongoDb(3, updateParam);
|
|
|
//发送提醒消息
|
|
//发送提醒消息
|
|
|
List<KwoTradeOrderUnit> units = kwoTradeOrderUnitService.getByOrderId(order.getId());
|
|
List<KwoTradeOrderUnit> units = kwoTradeOrderUnitService.getByOrderId(order.getId());
|
|
@@ -1292,8 +1182,7 @@ public class KwoTradeOrderService {
|
|
|
private void rejectOrderSendMsg(List<KwoTradeOrderUnit> units, KwoTradeOrder order) {
|
|
private void rejectOrderSendMsg(List<KwoTradeOrderUnit> units, KwoTradeOrder order) {
|
|
|
Map<String, Object> map = CollectionUtils.createHashMap();
|
|
Map<String, Object> map = CollectionUtils.createHashMap();
|
|
|
map.put("orderNo", order.getTOrderNo());
|
|
map.put("orderNo", order.getTOrderNo());
|
|
|
- Map<String, KwoTradeOrderUnit> unitMap = units.stream().collect
|
|
|
|
|
- (Collectors.toMap(KwoTradeOrderUnit::getUnitType, Function.identity()));
|
|
|
|
|
|
|
+ Map<String, KwoTradeOrderUnit> unitMap = units.stream().collect(Collectors.toMap(KwoTradeOrderUnit::getUnitType, Function.identity()));
|
|
|
KwoTradeOrderUnit purchase = unitMap.get(OrderUnitTypeEnum.PURCHASE.getType());
|
|
KwoTradeOrderUnit purchase = unitMap.get(OrderUnitTypeEnum.PURCHASE.getType());
|
|
|
KwoTradeOrderUnit supply = unitMap.get(OrderUnitTypeEnum.SALE.getType());
|
|
KwoTradeOrderUnit supply = unitMap.get(OrderUnitTypeEnum.SALE.getType());
|
|
|
//给供应企业联系人发消息
|
|
//给供应企业联系人发消息
|
|
@@ -1389,8 +1278,7 @@ public class KwoTradeOrderService {
|
|
|
remoteContractService.updatePerformed(contract.getContractId(), actualAmount);
|
|
remoteContractService.updatePerformed(contract.getContractId(), actualAmount);
|
|
|
//mongodb更新订单状态
|
|
//mongodb更新订单状态
|
|
|
SckwTradeOrder updateParam = new SckwTradeOrder();
|
|
SckwTradeOrder updateParam = new SckwTradeOrder();
|
|
|
- updateParam.setTOrderId(order.getId()).setActualAmount(order.getActualAmount().doubleValue()).setStatus(order.getStatus())
|
|
|
|
|
- .setUpdateBy(LoginUserHolder.getUserId()).setUpdateByName(LoginUserHolder.getUserName()).setUpdateTime(new Date());
|
|
|
|
|
|
|
+ updateParam.setTOrderId(order.getId()).setActualAmount(order.getActualAmount().doubleValue()).setStatus(order.getStatus()).setUpdateBy(LoginUserHolder.getUserId()).setUpdateByName(LoginUserHolder.getUserName()).setUpdateTime(new Date());
|
|
|
saveMongoDb(3, updateParam);
|
|
saveMongoDb(3, updateParam);
|
|
|
} finally {
|
|
} finally {
|
|
|
RedissonUtils.unlock(lockKey);
|
|
RedissonUtils.unlock(lockKey);
|
|
@@ -1416,8 +1304,7 @@ public class KwoTradeOrderService {
|
|
|
}
|
|
}
|
|
|
//排除草稿状态权限匹配
|
|
//排除草稿状态权限匹配
|
|
|
List<Long> filterIds = list.stream().filter(e -> !(Objects.equals(e.getStatus(), 0))).map(KwoTradeOrder::getId).toList();
|
|
List<Long> filterIds = list.stream().filter(e -> !(Objects.equals(e.getStatus(), 0))).map(KwoTradeOrder::getId).toList();
|
|
|
- if (CollUtil.isNotEmpty(filterIds) &&
|
|
|
|
|
- kwoTradeOrderUnitService.entBatchMatch(filterIds, LoginUserHolder.getEntId(), String.valueOf(param.getOrderType()))) {
|
|
|
|
|
|
|
+ if (CollUtil.isNotEmpty(filterIds) && kwoTradeOrderUnitService.entBatchMatch(filterIds, LoginUserHolder.getEntId(), String.valueOf(param.getOrderType()))) {
|
|
|
throw new BusinessException("无订单操作权限!");
|
|
throw new BusinessException("无订单操作权限!");
|
|
|
}
|
|
}
|
|
|
LambdaUpdateWrapper<KwoTradeOrder> updateWrapper = new LambdaUpdateWrapper<>();
|
|
LambdaUpdateWrapper<KwoTradeOrder> updateWrapper = new LambdaUpdateWrapper<>();
|
|
@@ -1431,8 +1318,7 @@ public class KwoTradeOrderService {
|
|
|
//更新mongodb
|
|
//更新mongodb
|
|
|
ids.forEach(id -> {
|
|
ids.forEach(id -> {
|
|
|
SckwTradeOrder updateParam = new SckwTradeOrder();
|
|
SckwTradeOrder updateParam = new SckwTradeOrder();
|
|
|
- updateParam.setTOrderId(id).setDelFlag(Global.YES).setUpdateBy(LoginUserHolder.getUserId())
|
|
|
|
|
- .setUpdateByName(LoginUserHolder.getUserName()).setUpdateTime(new Date());
|
|
|
|
|
|
|
+ updateParam.setTOrderId(id).setDelFlag(Global.YES).setUpdateBy(LoginUserHolder.getUserId()).setUpdateByName(LoginUserHolder.getUserName()).setUpdateTime(new Date());
|
|
|
saveMongoDb(3, updateParam);
|
|
saveMongoDb(3, updateParam);
|
|
|
});
|
|
});
|
|
|
|
|
|
|
@@ -1473,8 +1359,7 @@ public class KwoTradeOrderService {
|
|
|
*/
|
|
*/
|
|
|
public List<KwoTradeOrder> getWaitSignByIds(List<Long> tOrderIds) {
|
|
public List<KwoTradeOrder> getWaitSignByIds(List<Long> tOrderIds) {
|
|
|
LambdaQueryWrapper<KwoTradeOrder> wrapper = new LambdaQueryWrapper<>();
|
|
LambdaQueryWrapper<KwoTradeOrder> wrapper = new LambdaQueryWrapper<>();
|
|
|
- wrapper.eq(KwoTradeOrder::getStatus, OrderStatusEnum.WAIT_SIGNED.getCode())
|
|
|
|
|
- .in(KwoTradeOrder::getId, tOrderIds).eq(KwoTradeOrder::getDelFlag, Global.NO);
|
|
|
|
|
|
|
+ wrapper.eq(KwoTradeOrder::getStatus, OrderStatusEnum.WAIT_SIGNED.getCode()).in(KwoTradeOrder::getId, tOrderIds).eq(KwoTradeOrder::getDelFlag, Global.NO);
|
|
|
List<KwoTradeOrder> list = kwoTradeOrderMapper.selectList(wrapper);
|
|
List<KwoTradeOrder> list = kwoTradeOrderMapper.selectList(wrapper);
|
|
|
return CollUtil.emptyIfNull(list);
|
|
return CollUtil.emptyIfNull(list);
|
|
|
}
|
|
}
|
|
@@ -1489,9 +1374,7 @@ public class KwoTradeOrderService {
|
|
|
*/
|
|
*/
|
|
|
public void contractCompletedUpdate(List<Long> tOrderIds, Long updateBy) {
|
|
public void contractCompletedUpdate(List<Long> tOrderIds, Long updateBy) {
|
|
|
LambdaUpdateWrapper<KwoTradeOrder> wrapper = new LambdaUpdateWrapper<>();
|
|
LambdaUpdateWrapper<KwoTradeOrder> wrapper = new LambdaUpdateWrapper<>();
|
|
|
- wrapper.in(KwoTradeOrder::getId, tOrderIds).eq(KwoTradeOrder::getStatus, OrderStatusEnum.WAIT_SIGNED.getCode())
|
|
|
|
|
- .eq(KwoTradeOrder::getDelFlag, Global.NO).set(KwoTradeOrder::getUpdateBy, updateBy)
|
|
|
|
|
- .set(KwoTradeOrder::getStatus, OrderStatusEnum.EXECUTING.getCode());
|
|
|
|
|
|
|
+ wrapper.in(KwoTradeOrder::getId, tOrderIds).eq(KwoTradeOrder::getStatus, OrderStatusEnum.WAIT_SIGNED.getCode()).eq(KwoTradeOrder::getDelFlag, Global.NO).set(KwoTradeOrder::getUpdateBy, updateBy).set(KwoTradeOrder::getStatus, OrderStatusEnum.EXECUTING.getCode());
|
|
|
kwoTradeOrderMapper.update(null, wrapper);
|
|
kwoTradeOrderMapper.update(null, wrapper);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -1516,8 +1399,7 @@ public class KwoTradeOrderService {
|
|
|
return res;
|
|
return res;
|
|
|
}
|
|
}
|
|
|
//装卸货地址类型分组获取装卸货cityCodes
|
|
//装卸货地址类型分组获取装卸货cityCodes
|
|
|
- Map<String, List<Integer>> map = addressList.stream().collect(Collectors.
|
|
|
|
|
- groupingBy(KwoTradeOrderAddress::getAddressType, Collectors.mapping(KwoTradeOrderAddress::getCityCode, Collectors.toList())));
|
|
|
|
|
|
|
+ Map<String, List<Integer>> map = addressList.stream().collect(Collectors.groupingBy(KwoTradeOrderAddress::getAddressType, Collectors.mapping(KwoTradeOrderAddress::getCityCode, Collectors.toList())));
|
|
|
//装货地址下拉列表树
|
|
//装货地址下拉列表树
|
|
|
List<AreaTreeFrontResDto> loadTree = remoteSystemService.queryAreaTreeFrontByCodeList(map.get(OrderAddressTypeEnum.LOAD.getType()));
|
|
List<AreaTreeFrontResDto> loadTree = remoteSystemService.queryAreaTreeFrontByCodeList(map.get(OrderAddressTypeEnum.LOAD.getType()));
|
|
|
//卸货地址下拉列表树
|
|
//卸货地址下拉列表树
|
|
@@ -1535,8 +1417,7 @@ public class KwoTradeOrderService {
|
|
|
*/
|
|
*/
|
|
|
public List<KwoTradeOrder> associateEnt(Collection<Long> tOrderIds) {
|
|
public List<KwoTradeOrder> associateEnt(Collection<Long> tOrderIds) {
|
|
|
LambdaQueryWrapper<KwoTradeOrder> wrapper = new LambdaQueryWrapper<>();
|
|
LambdaQueryWrapper<KwoTradeOrder> wrapper = new LambdaQueryWrapper<>();
|
|
|
- wrapper.in(KwoTradeOrder::getId, tOrderIds).eq(KwoTradeOrder::getDelFlag, Global.NO)
|
|
|
|
|
- .in(KwoTradeOrder::getStatus, 1, 2, 3, 4);
|
|
|
|
|
|
|
+ wrapper.in(KwoTradeOrder::getId, tOrderIds).eq(KwoTradeOrder::getDelFlag, Global.NO).in(KwoTradeOrder::getStatus, 1, 2, 3, 4);
|
|
|
List<KwoTradeOrder> list = kwoTradeOrderMapper.selectList(wrapper);
|
|
List<KwoTradeOrder> list = kwoTradeOrderMapper.selectList(wrapper);
|
|
|
return CollUtil.emptyIfNull(list);
|
|
return CollUtil.emptyIfNull(list);
|
|
|
}
|
|
}
|
|
@@ -1646,10 +1527,7 @@ public class KwoTradeOrderService {
|
|
|
unloadDetailAddressList.add(e.getCityName() + e.getDetailAddress());
|
|
unloadDetailAddressList.add(e.getCityName() + e.getDetailAddress());
|
|
|
}
|
|
}
|
|
|
});
|
|
});
|
|
|
- res.setLoadNameList(loadNameList)
|
|
|
|
|
- .setLoadDetailAddressList(loadDetailAddressList)
|
|
|
|
|
- .setUnloadNameList(unloadNameList)
|
|
|
|
|
- .setUnloadDetailAddressList(unloadDetailAddressList);
|
|
|
|
|
|
|
+ res.setLoadNameList(loadNameList).setLoadDetailAddressList(loadDetailAddressList).setUnloadNameList(unloadNameList).setUnloadDetailAddressList(unloadDetailAddressList);
|
|
|
return res;
|
|
return res;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -1692,24 +1570,15 @@ public class KwoTradeOrderService {
|
|
|
Map<Long, UserCacheResDto> userMap = remoteSystemService.queryUserCacheMapByIds(createByIds);
|
|
Map<Long, UserCacheResDto> userMap = remoteSystemService.queryUserCacheMapByIds(createByIds);
|
|
|
Map<Long, KwpGoods> goodsMap = goodsInfoService.getGoodsByIds(goodIdList);
|
|
Map<Long, KwpGoods> goodsMap = goodsInfoService.getGoodsByIds(goodIdList);
|
|
|
Map<Long, ContractCommonInfoResDto> contractMap = remoteContractService.queryContractBaseInfo(contracIdList);
|
|
Map<Long, ContractCommonInfoResDto> contractMap = remoteContractService.queryContractBaseInfo(contracIdList);
|
|
|
- Map<String, Map<String, String>> dict = remoteSystemService.queryDictByType(List.of(
|
|
|
|
|
- DictTypeEnum.TORDER_STATUS.getType(), DictTypeEnum.TRADE_TYPE.getType(), DictTypeEnum.DELIVERY_TYPE.getType(),
|
|
|
|
|
- DictTypeEnum.PICKUP_TYPE.getType(), DictTypeEnum.TORDER_SOURCE.getType()));
|
|
|
|
|
|
|
+ Map<String, Map<String, String>> dict = remoteSystemService.queryDictByType(List.of(DictTypeEnum.TORDER_STATUS.getType(), DictTypeEnum.TRADE_TYPE.getType(), DictTypeEnum.SETTLEMENT_WAY.getType(), DictTypeEnum.CONSIGNMENT_WAY.getType(), DictTypeEnum.TORDER_SOURCE.getType()));
|
|
|
Map<String, SysDictResDto> unitType = remoteSystemService.queryDictMapByType(DictTypeEnum.UNIT_TYPE.getType());
|
|
Map<String, SysDictResDto> unitType = remoteSystemService.queryDictMapByType(DictTypeEnum.UNIT_TYPE.getType());
|
|
|
- Map<String, String> statusMap, tradeMap, deliveryMap, pickupMap, sourceMap;
|
|
|
|
|
|
|
+ Map<String, String> tradeMap, deliveryMap, pickupMap, sourceMap;
|
|
|
if (CollUtil.isNotEmpty(dict)) {
|
|
if (CollUtil.isNotEmpty(dict)) {
|
|
|
- statusMap = CollUtil.isNotEmpty(dict.get(DictTypeEnum.TORDER_STATUS.getType())) ?
|
|
|
|
|
- dict.get(DictTypeEnum.TORDER_STATUS.getType()) : new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
|
|
|
- tradeMap = CollUtil.isNotEmpty(dict.get(DictTypeEnum.TRADE_TYPE.getType())) ?
|
|
|
|
|
- dict.get(DictTypeEnum.TRADE_TYPE.getType()) : new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
|
|
|
- deliveryMap = CollUtil.isNotEmpty(dict.get(DictTypeEnum.DELIVERY_TYPE.getType())) ?
|
|
|
|
|
- dict.get(DictTypeEnum.DELIVERY_TYPE.getType()) : new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
|
|
|
- pickupMap = CollUtil.isNotEmpty(dict.get(DictTypeEnum.PICKUP_TYPE.getType())) ?
|
|
|
|
|
- dict.get(DictTypeEnum.PICKUP_TYPE.getType()) : new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
|
|
|
- sourceMap = CollUtil.isNotEmpty(dict.get(DictTypeEnum.TORDER_SOURCE.getType())) ?
|
|
|
|
|
- dict.get(DictTypeEnum.TORDER_SOURCE.getType()) : new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
|
|
|
|
|
+ tradeMap = CollUtil.isNotEmpty(dict.get(DictTypeEnum.TRADE_TYPE.getType())) ? dict.get(DictTypeEnum.TRADE_TYPE.getType()) : new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
|
|
|
+ deliveryMap = CollUtil.isNotEmpty(dict.get(DictTypeEnum.SETTLEMENT_WAY.getType())) ? dict.get(DictTypeEnum.SETTLEMENT_WAY.getType()) : new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
|
|
|
+ pickupMap = CollUtil.isNotEmpty(dict.get(DictTypeEnum.CONSIGNMENT_WAY.getType())) ? dict.get(DictTypeEnum.CONSIGNMENT_WAY.getType()) : new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
|
|
|
+ sourceMap = CollUtil.isNotEmpty(dict.get(DictTypeEnum.TORDER_SOURCE.getType())) ? dict.get(DictTypeEnum.TORDER_SOURCE.getType()) : new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
|
} else {
|
|
} else {
|
|
|
- statusMap = new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
|
|
|
tradeMap = new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
tradeMap = new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
|
deliveryMap = new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
deliveryMap = new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
|
pickupMap = new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
pickupMap = new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
@@ -1721,14 +1590,9 @@ public class KwoTradeOrderService {
|
|
|
List<KwoTradeOrderAddress> loadAddresses = kwoTradeOrderAddressService.findByAddress(e.getTOrderId(), AddressTypeEnum.SHIPMENT.getCode());
|
|
List<KwoTradeOrderAddress> loadAddresses = kwoTradeOrderAddressService.findByAddress(e.getTOrderId(), AddressTypeEnum.SHIPMENT.getCode());
|
|
|
//卸货地址
|
|
//卸货地址
|
|
|
List<KwoTradeOrderAddress> unloadAddresses = kwoTradeOrderAddressService.findByAddress(e.getTOrderId(), AddressTypeEnum.TAKE.getCode());
|
|
List<KwoTradeOrderAddress> unloadAddresses = kwoTradeOrderAddressService.findByAddress(e.getTOrderId(), AddressTypeEnum.TAKE.getCode());
|
|
|
- //装货地点名称
|
|
|
|
|
- List<String> loadName = loadAddresses.stream().map(KwoTradeOrderAddress::getName).toList();
|
|
|
|
|
- //装货地点
|
|
|
|
|
- List<String> loadAddress = loadAddresses.stream().map(item -> item.getCityName() + " " + item.getDetailAddress()).toList();
|
|
|
|
|
|
|
+ Optional<KwoTradeOrderAddress> loadAddress = loadAddresses.stream().findFirst();
|
|
|
//卸货地点点名称
|
|
//卸货地点点名称
|
|
|
- List<String> unloadName = unloadAddresses.stream().map(KwoTradeOrderAddress::getName).toList();
|
|
|
|
|
- //卸货地点
|
|
|
|
|
- List<String> unloadAddress = unloadAddresses.stream().map(item -> item.getCityName() + " " + item.getDetailAddress()).toList();
|
|
|
|
|
|
|
+ Optional<KwoTradeOrderAddress> unloadAddress = unloadAddresses.stream().findFirst();
|
|
|
|
|
|
|
|
BigDecimal actualAmount = Objects.isNull(e.getActualAmount()) ? BigDecimal.ZERO : e.getActualAmount();
|
|
BigDecimal actualAmount = Objects.isNull(e.getActualAmount()) ? BigDecimal.ZERO : e.getActualAmount();
|
|
|
BigDecimal unitPrice = Objects.isNull(e.getUnitPrice()) ? BigDecimal.ZERO : e.getUnitPrice();
|
|
BigDecimal unitPrice = Objects.isNull(e.getUnitPrice()) ? BigDecimal.ZERO : e.getUnitPrice();
|
|
@@ -1737,7 +1601,7 @@ public class KwoTradeOrderService {
|
|
|
UserCacheResDto userCache = userMap.get(e.getCreateBy());
|
|
UserCacheResDto userCache = userMap.get(e.getCreateBy());
|
|
|
|
|
|
|
|
OrderListResVO vo = BeanUtil.copyProperties(e, OrderListResVO.class);
|
|
OrderListResVO vo = BeanUtil.copyProperties(e, OrderListResVO.class);
|
|
|
- vo.setStatusLabel(statusMap.get(String.valueOf(e.getStatus())))
|
|
|
|
|
|
|
+ vo.setStatusLabel(TradeOrderStatusEnum.getMsg(e.getStatus()))
|
|
|
.setTradingLabel(tradeMap.get(e.getTrading()))
|
|
.setTradingLabel(tradeMap.get(e.getTrading()))
|
|
|
.setTrading(tradeMap.get(e.getTrading()))
|
|
.setTrading(tradeMap.get(e.getTrading()))
|
|
|
.setDeliveryTypeLabel(deliveryMap.get(e.getDeliveryType()))
|
|
.setDeliveryTypeLabel(deliveryMap.get(e.getDeliveryType()))
|
|
@@ -1761,10 +1625,18 @@ public class KwoTradeOrderService {
|
|
|
.setEntrustAmount(setScale(e.getEntrustAmount()))
|
|
.setEntrustAmount(setScale(e.getEntrustAmount()))
|
|
|
.setActualAmount(setScale(e.getActualAmount()))
|
|
.setActualAmount(setScale(e.getActualAmount()))
|
|
|
.setCreateByName(Objects.isNull(userCache) ? null : userCache.getName())
|
|
.setCreateByName(Objects.isNull(userCache) ? null : userCache.getName())
|
|
|
- .setLoadName(loadName)
|
|
|
|
|
- .setLoadAddress(loadAddress)
|
|
|
|
|
- .setUnloadName(unloadName)
|
|
|
|
|
- .setUnloadAddress(unloadAddress);
|
|
|
|
|
|
|
+ ;
|
|
|
|
|
+ loadAddress.ifPresent(d -> {
|
|
|
|
|
+ vo.setLoadName(d.getName());
|
|
|
|
|
+ vo.setLoadAddress(d.getCityName() + " " + d.getDetailAddress());
|
|
|
|
|
+
|
|
|
|
|
+ });
|
|
|
|
|
+ unloadAddress.ifPresent(d -> {
|
|
|
|
|
+ vo.setUnloadName(d.getName());
|
|
|
|
|
+ vo.setUnloadAddress(d.getCityName() + " " + d.getDetailAddress());
|
|
|
|
|
+ vo.setUnloadContact(d.getContacts());
|
|
|
|
|
+ vo.setUnloadContactPhone(d.getPhone());
|
|
|
|
|
+ });
|
|
|
result.add(vo);
|
|
result.add(vo);
|
|
|
});
|
|
});
|
|
|
return PageHelperUtil.getPageResult(new PageInfo<>(result), list, pageSize);
|
|
return PageHelperUtil.getPageResult(new PageInfo<>(result), list, pageSize);
|
|
@@ -1779,27 +1651,26 @@ public class KwoTradeOrderService {
|
|
|
*/
|
|
*/
|
|
|
public TradeOrderListSelectDTO buildSelectParam(TradeOrderListStatisticParam params) {
|
|
public TradeOrderListSelectDTO buildSelectParam(TradeOrderListStatisticParam params) {
|
|
|
TradeOrderListSelectDTO dto = BeanUtil.copyProperties(params, TradeOrderListSelectDTO.class);
|
|
TradeOrderListSelectDTO dto = BeanUtil.copyProperties(params, TradeOrderListSelectDTO.class);
|
|
|
|
|
+ EntTypeResDto entTypeResDto = remoteSystemService.queryEntTypeById(LoginUserHolder.getEntId());
|
|
|
dto.setEntId(LoginUserHolder.getEntId())
|
|
dto.setEntId(LoginUserHolder.getEntId())
|
|
|
- .setUserId(LoginUserHolder.getUserId())
|
|
|
|
|
|
|
+ .setManager(LoginUserHolder.isManager())
|
|
|
|
|
+ .setEntType(Objects.nonNull(entTypeResDto) ? entTypeResDto.getType() : null)
|
|
|
|
|
+ .setEntList(LoginUserHolder.getChildEntList())
|
|
|
.setIsMain(LoginUserHolder.getIsMain());
|
|
.setIsMain(LoginUserHolder.getIsMain());
|
|
|
//装卸货地址
|
|
//装卸货地址
|
|
|
String loadCode = params.getShippingAddressCode();
|
|
String loadCode = params.getShippingAddressCode();
|
|
|
if (StringUtils.isNotBlank(loadCode) && Objects.nonNull(params.getShippingAddressLevel())) {
|
|
if (StringUtils.isNotBlank(loadCode) && Objects.nonNull(params.getShippingAddressLevel())) {
|
|
|
switch (params.getShippingAddressLevel()) {
|
|
switch (params.getShippingAddressLevel()) {
|
|
|
- case 1 -> dto.setLoadAddressCode(
|
|
|
|
|
- loadCode.substring(0, 2).trim());
|
|
|
|
|
- case 2 -> dto.setLoadAddressCode(
|
|
|
|
|
- loadCode.substring(0, 4).trim());
|
|
|
|
|
|
|
+ case 1 -> dto.setLoadAddressCode(loadCode.substring(0, 2).trim());
|
|
|
|
|
+ case 2 -> dto.setLoadAddressCode(loadCode.substring(0, 4).trim());
|
|
|
case 3 -> dto.setLoadAddressCode(loadCode);
|
|
case 3 -> dto.setLoadAddressCode(loadCode);
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
String unloadCode = params.getUnloadingAddressCode();
|
|
String unloadCode = params.getUnloadingAddressCode();
|
|
|
if (StringUtils.isNotBlank(unloadCode) && Objects.nonNull(params.getUnloadingAddressLevel())) {
|
|
if (StringUtils.isNotBlank(unloadCode) && Objects.nonNull(params.getUnloadingAddressLevel())) {
|
|
|
switch (params.getUnloadingAddressLevel()) {
|
|
switch (params.getUnloadingAddressLevel()) {
|
|
|
- case 1 -> dto.setUnloadAddressCode(
|
|
|
|
|
- unloadCode.substring(0, 2).trim());
|
|
|
|
|
- case 2 -> dto.setUnloadAddressCode(
|
|
|
|
|
- unloadCode.substring(0, 4).trim());
|
|
|
|
|
|
|
+ case 1 -> dto.setUnloadAddressCode(unloadCode.substring(0, 2).trim());
|
|
|
|
|
+ case 2 -> dto.setUnloadAddressCode(unloadCode.substring(0, 4).trim());
|
|
|
case 3 -> dto.setUnloadAddressCode(unloadCode);
|
|
case 3 -> dto.setUnloadAddressCode(unloadCode);
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
@@ -1851,19 +1722,18 @@ public class KwoTradeOrderService {
|
|
|
* @author yzc
|
|
* @author yzc
|
|
|
* @date 2024/3/15 8:52
|
|
* @date 2024/3/15 8:52
|
|
|
*/
|
|
*/
|
|
|
- public TableStatisticRes tradeOrderStatistic(TradeOrderListStatisticParam params) {
|
|
|
|
|
|
|
+ public TableStatisticRes tradeOrderStatistic(TradeOrderListSelectParam params) {
|
|
|
TableStatisticRes res = new TableStatisticRes();
|
|
TableStatisticRes res = new TableStatisticRes();
|
|
|
TradeOrderListSelectDTO dto = buildSelectParam(params);
|
|
TradeOrderListSelectDTO dto = buildSelectParam(params);
|
|
|
dto.setStatus(null);
|
|
dto.setStatus(null);
|
|
|
List<TableTop> tableTops = kwoTradeOrderMapper.tradeOrderStatistic(dto, dto.getGoodIds(), LoginUserHolder.getAuthUserIdList());
|
|
List<TableTop> tableTops = kwoTradeOrderMapper.tradeOrderStatistic(dto, dto.getGoodIds(), LoginUserHolder.getAuthUserIdList());
|
|
|
Map<Integer, Integer> map = new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
Map<Integer, Integer> map = new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
|
if (CollUtil.isNotEmpty(tableTops)) {
|
|
if (CollUtil.isNotEmpty(tableTops)) {
|
|
|
- map = tableTops.stream().collect(Collectors.toMap
|
|
|
|
|
- (TableTop::getValue, TableTop::getTotal, (k1, k2) -> k2));
|
|
|
|
|
|
|
+ map = tableTops.stream().collect(Collectors.toMap(TableTop::getValue, TableTop::getTotal, (k1, k2) -> k2));
|
|
|
}
|
|
}
|
|
|
List<TableTop> list = new ArrayList<>();
|
|
List<TableTop> list = new ArrayList<>();
|
|
|
int count = 0;
|
|
int count = 0;
|
|
|
- for (OrderStatusEnum e : OrderStatusEnum.getSortList()) {
|
|
|
|
|
|
|
+ for (TradeOrderStatusEnum e : TradeOrderStatusEnum.getSortList()) {
|
|
|
Integer value = e.getCode();
|
|
Integer value = e.getCode();
|
|
|
int total = Objects.isNull(map.get(value)) ? 0 : map.get(value);
|
|
int total = Objects.isNull(map.get(value)) ? 0 : map.get(value);
|
|
|
TableTop tableTop = new TableTop();
|
|
TableTop tableTop = new TableTop();
|
|
@@ -1889,16 +1759,13 @@ public class KwoTradeOrderService {
|
|
|
*/
|
|
*/
|
|
|
public List<TradeOrderAppStatisticVO> appStatistic(TradeOrderAppStatisticParam params) {
|
|
public List<TradeOrderAppStatisticVO> appStatistic(TradeOrderAppStatisticParam params) {
|
|
|
TradeOrderAppStatisticParamDTO dto = new TradeOrderAppStatisticParamDTO();
|
|
TradeOrderAppStatisticParamDTO dto = new TradeOrderAppStatisticParamDTO();
|
|
|
- dto.setOrderType(params.getOrderType())
|
|
|
|
|
- .setIsMain(LoginUserHolder.getIsMain())
|
|
|
|
|
- .setEntId(LoginUserHolder.getEntId());
|
|
|
|
|
|
|
+ dto.setOrderType(params.getOrderType()).setIsMain(LoginUserHolder.getIsMain()).setEntId(LoginUserHolder.getEntId());
|
|
|
List<Integer> statuses = Arrays.asList(1, 4, 5, 7);
|
|
List<Integer> statuses = Arrays.asList(1, 4, 5, 7);
|
|
|
List<Long> authUserIds = LoginUserHolder.getAuthUserIdList();
|
|
List<Long> authUserIds = LoginUserHolder.getAuthUserIdList();
|
|
|
List<TradeOrderAppStatisticVO> tableTops = kwoTradeOrderMapper.appStatistic(dto, statuses, authUserIds);
|
|
List<TradeOrderAppStatisticVO> tableTops = kwoTradeOrderMapper.appStatistic(dto, statuses, authUserIds);
|
|
|
Map<Integer, Integer> map = new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
Map<Integer, Integer> map = new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
|
if (CollUtil.isNotEmpty(tableTops)) {
|
|
if (CollUtil.isNotEmpty(tableTops)) {
|
|
|
- map = tableTops.stream().collect(Collectors.toMap
|
|
|
|
|
- (TradeOrderAppStatisticVO::getValue, TradeOrderAppStatisticVO::getTotal, (k1, k2) -> k2));
|
|
|
|
|
|
|
+ map = tableTops.stream().collect(Collectors.toMap(TradeOrderAppStatisticVO::getValue, TradeOrderAppStatisticVO::getTotal, (k1, k2) -> k2));
|
|
|
}
|
|
}
|
|
|
List<TradeOrderAppStatisticVO> statistics = new ArrayList<>();
|
|
List<TradeOrderAppStatisticVO> statistics = new ArrayList<>();
|
|
|
for (Integer e : statuses) {
|
|
for (Integer e : statuses) {
|
|
@@ -1930,21 +1797,14 @@ public class KwoTradeOrderService {
|
|
|
if (CollUtil.isEmpty(orders)) {
|
|
if (CollUtil.isEmpty(orders)) {
|
|
|
return Collections.emptyList();
|
|
return Collections.emptyList();
|
|
|
}
|
|
}
|
|
|
- Map<String, Map<String, String>> dict = remoteSystemService.queryDictByType(List.of(
|
|
|
|
|
- DictTypeEnum.TORDER_STATUS.getType(), DictTypeEnum.PICKUP_TYPE.getType(), DictTypeEnum.DELIVERY_TYPE.getType(),
|
|
|
|
|
- DictTypeEnum.TORDER_SOURCE.getType(), DictTypeEnum.TRADE_TYPE.getType()));
|
|
|
|
|
|
|
+ Map<String, Map<String, String>> dict = remoteSystemService.queryDictByType(List.of(DictTypeEnum.TORDER_STATUS.getType(), DictTypeEnum.PICKUP_TYPE.getType(), DictTypeEnum.DELIVERY_TYPE.getType(), DictTypeEnum.TORDER_SOURCE.getType(), DictTypeEnum.TRADE_TYPE.getType()));
|
|
|
Map<String, String> statusMap, pickupMap, deliveryMap, sourceMap, tradeMap;
|
|
Map<String, String> statusMap, pickupMap, deliveryMap, sourceMap, tradeMap;
|
|
|
if (CollUtil.isNotEmpty(dict)) {
|
|
if (CollUtil.isNotEmpty(dict)) {
|
|
|
- statusMap = CollUtil.isNotEmpty(dict.get(DictTypeEnum.TORDER_STATUS.getType())) ?
|
|
|
|
|
- dict.get(DictTypeEnum.TORDER_STATUS.getType()) : new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
|
|
|
- pickupMap = CollUtil.isNotEmpty(dict.get(DictTypeEnum.PICKUP_TYPE.getType())) ?
|
|
|
|
|
- dict.get(DictTypeEnum.PICKUP_TYPE.getType()) : new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
|
|
|
- deliveryMap = CollUtil.isNotEmpty(dict.get(DictTypeEnum.DELIVERY_TYPE.getType())) ?
|
|
|
|
|
- dict.get(DictTypeEnum.DELIVERY_TYPE.getType()) : new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
|
|
|
- sourceMap = CollUtil.isNotEmpty(dict.get(DictTypeEnum.TORDER_SOURCE.getType())) ?
|
|
|
|
|
- dict.get(DictTypeEnum.TORDER_SOURCE.getType()) : new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
|
|
|
- tradeMap = CollUtil.isNotEmpty(dict.get(DictTypeEnum.TRADE_TYPE.getType())) ?
|
|
|
|
|
- dict.get(DictTypeEnum.TRADE_TYPE.getType()) : new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
|
|
|
|
|
+ statusMap = CollUtil.isNotEmpty(dict.get(DictTypeEnum.TORDER_STATUS.getType())) ? dict.get(DictTypeEnum.TORDER_STATUS.getType()) : new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
|
|
|
+ pickupMap = CollUtil.isNotEmpty(dict.get(DictTypeEnum.PICKUP_TYPE.getType())) ? dict.get(DictTypeEnum.PICKUP_TYPE.getType()) : new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
|
|
|
+ deliveryMap = CollUtil.isNotEmpty(dict.get(DictTypeEnum.DELIVERY_TYPE.getType())) ? dict.get(DictTypeEnum.DELIVERY_TYPE.getType()) : new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
|
|
|
+ sourceMap = CollUtil.isNotEmpty(dict.get(DictTypeEnum.TORDER_SOURCE.getType())) ? dict.get(DictTypeEnum.TORDER_SOURCE.getType()) : new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
|
|
|
+ tradeMap = CollUtil.isNotEmpty(dict.get(DictTypeEnum.TRADE_TYPE.getType())) ? dict.get(DictTypeEnum.TRADE_TYPE.getType()) : new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
|
} else {
|
|
} else {
|
|
|
statusMap = new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
statusMap = new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
|
pickupMap = new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
pickupMap = new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
@@ -2002,25 +1862,7 @@ public class KwoTradeOrderService {
|
|
|
ContractCommonInfoResDto contract = contractMap.get(e.getContractId());
|
|
ContractCommonInfoResDto contract = contractMap.get(e.getContractId());
|
|
|
UserCacheResDto userCache = userMap.get(e.getCreateBy());
|
|
UserCacheResDto userCache = userMap.get(e.getCreateBy());
|
|
|
BigDecimal waitEntrustAmount = getWaitEntrustAmount(e.getAmount(), e.getEntrustAmount());
|
|
BigDecimal waitEntrustAmount = getWaitEntrustAmount(e.getAmount(), e.getEntrustAmount());
|
|
|
- vo.setStatus(statusMap.get(String.valueOf(vo.getStatus())))
|
|
|
|
|
- .setGoodsName(Objects.isNull(goods) ? null : goods.getName())
|
|
|
|
|
- .setGoodsSpec(Objects.isNull(goods) ? null : goods.getSpec())
|
|
|
|
|
- .setUnitPrice(String.valueOf(setScale(e.getUnitPrice())))
|
|
|
|
|
- .setAmount(String.valueOf(setScale(e.getAmount())))
|
|
|
|
|
- .setPrice(String.valueOf(setScale(e.getPrice())))
|
|
|
|
|
- .setGoodsTaxRate(Objects.isNull(goods) ? null : goods.getTaxRate())
|
|
|
|
|
- .setEntrustAmount(String.valueOf(setScale(e.getEntrustAmount())))
|
|
|
|
|
- .setActualAmount(String.valueOf(setScale(e.getActualAmount())))
|
|
|
|
|
- .setWaitEntrustAmount(String.valueOf(setScale(waitEntrustAmount)))
|
|
|
|
|
- .setPickupType(pickupMap.get(e.getPickupType()))
|
|
|
|
|
- .setDeliveryType(deliveryMap.get(e.getDeliveryType()))
|
|
|
|
|
- .setSource(sourceMap.get(e.getSource()))
|
|
|
|
|
- .setTrading(tradeMap.get(e.getTrading()))
|
|
|
|
|
- .setStartTime(Objects.isNull(e.getStartTime()) ? null : e.getStartTime().toString())
|
|
|
|
|
- .setEndTime(Objects.isNull(e.getEndTime()) ? null : e.getEndTime().toString())
|
|
|
|
|
- .setContractSigningWay(Objects.isNull(contract) ? null : contract.getSigningWayName())
|
|
|
|
|
- .setCreateByName(Objects.isNull(userCache) ? null : userCache.getName())
|
|
|
|
|
- .setCreateTime(com.sckw.excel.utils.DateUtil.getDateTime(e.getCreateTime()));
|
|
|
|
|
|
|
+ vo.setStatus(statusMap.get(String.valueOf(vo.getStatus()))).setGoodsName(Objects.isNull(goods) ? null : goods.getName()).setGoodsSpec(Objects.isNull(goods) ? null : goods.getSpec()).setUnitPrice(String.valueOf(setScale(e.getUnitPrice()))).setAmount(String.valueOf(setScale(e.getAmount()))).setPrice(String.valueOf(setScale(e.getPrice()))).setGoodsTaxRate(Objects.isNull(goods) ? null : goods.getTaxRate()).setEntrustAmount(String.valueOf(setScale(e.getEntrustAmount()))).setActualAmount(String.valueOf(setScale(e.getActualAmount()))).setWaitEntrustAmount(String.valueOf(setScale(waitEntrustAmount))).setPickupType(pickupMap.get(e.getPickupType())).setDeliveryType(deliveryMap.get(e.getDeliveryType())).setSource(sourceMap.get(e.getSource())).setTrading(tradeMap.get(e.getTrading())).setStartTime(Objects.isNull(e.getStartTime()) ? null : e.getStartTime().toString()).setEndTime(Objects.isNull(e.getEndTime()) ? null : e.getEndTime().toString()).setContractSigningWay(Objects.isNull(contract) ? null : contract.getSigningWayName()).setCreateByName(Objects.isNull(userCache) ? null : userCache.getName()).setCreateTime(com.sckw.excel.utils.DateUtil.getDateTime(e.getCreateTime()));
|
|
|
list.add(vo);
|
|
list.add(vo);
|
|
|
});
|
|
});
|
|
|
return list;
|
|
return list;
|
|
@@ -2197,9 +2039,8 @@ public class KwoTradeOrderService {
|
|
|
KwoTradeOrderUnit unit = BeanUtil.copyProperties(e, KwoTradeOrderUnit.class);
|
|
KwoTradeOrderUnit unit = BeanUtil.copyProperties(e, KwoTradeOrderUnit.class);
|
|
|
unit.setId(new IdWorker(1).nextId());
|
|
unit.setId(new IdWorker(1).nextId());
|
|
|
unit.setTOrderId(order.getId())
|
|
unit.setTOrderId(order.getId())
|
|
|
- .setUnitType(e.getUnitType())
|
|
|
|
|
- .setTOrderNo(order.getTOrderNo())
|
|
|
|
|
- .setTopEntId(e.getEntId());
|
|
|
|
|
|
|
+ .setTOrderNo(order.getTOrderNo()).setTopEntId(e.getEntId());
|
|
|
|
|
+ unit.setUnitType(StrUtil.equals(e.getUnitType(), "1") ? "2" : "1");//贸易合同和订单的单位类型相反
|
|
|
list.add(unit);
|
|
list.add(unit);
|
|
|
});
|
|
});
|
|
|
kwoTradeOrderUnitService.insertBatch(list);
|
|
kwoTradeOrderUnitService.insertBatch(list);
|
|
@@ -2239,14 +2080,7 @@ public class KwoTradeOrderService {
|
|
|
order.setAssociateStatement(0);
|
|
order.setAssociateStatement(0);
|
|
|
order.setChargeType(tradeContractResDto.getUnloadWay());
|
|
order.setChargeType(tradeContractResDto.getUnloadWay());
|
|
|
order.setConsignmentWay(tradeContractResDto.getConsignment());
|
|
order.setConsignmentWay(tradeContractResDto.getConsignment());
|
|
|
- order.setEntId(LoginUserHolder.getEntId())
|
|
|
|
|
- .setTOrderNo(getOrderNo())
|
|
|
|
|
- .setAmount(tradeOrderParam.getAmount())
|
|
|
|
|
- .setStartTime(DateUtils.localDateToDateStart(tradeOrderParam.getStartTime()))
|
|
|
|
|
- .setEndTime(DateUtils.localDateToDateEnd(tradeOrderParam.getEndTime()))
|
|
|
|
|
- .setSource(OrderSourceEnum.PURCHASE.getType())
|
|
|
|
|
- .setStatus(TradeOrderStatusEnum.AUDIT.getCode())
|
|
|
|
|
- .setRemark(tradeOrderParam.getRemark());
|
|
|
|
|
|
|
+ order.setEntId(LoginUserHolder.getEntId()).setTOrderNo(getOrderNo()).setAmount(tradeOrderParam.getAmount()).setStartTime(DateUtils.localDateToDateStart(tradeOrderParam.getStartTime())).setEndTime(DateUtils.localDateToDateEnd(tradeOrderParam.getEndTime())).setSource(OrderSourceEnum.PURCHASE.getType()).setStatus(TradeOrderStatusEnum.AUDIT.getCode()).setRemark(tradeOrderParam.getRemark());
|
|
|
return tradeContractResDto;
|
|
return tradeContractResDto;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -2352,15 +2186,12 @@ public class KwoTradeOrderService {
|
|
|
logisticInfo.setAcceptCompany("");
|
|
logisticInfo.setAcceptCompany("");
|
|
|
logisticInfo.setPrice(d.getTransportPrice());
|
|
logisticInfo.setPrice(d.getTransportPrice());
|
|
|
logisticInfo.setPriceType(0L);
|
|
logisticInfo.setPriceType(0L);
|
|
|
- logisticInfo.setEndTime(LocalDate.now());
|
|
|
|
|
- logisticInfo.setStartTime(LocalDate.now());
|
|
|
|
|
logisticInfo.setAmount(new BigDecimal("0"));
|
|
logisticInfo.setAmount(new BigDecimal("0"));
|
|
|
logisticInfo.setAmountUnit("");
|
|
logisticInfo.setAmountUnit("");
|
|
|
logisticInfo.setLoss(new BigDecimal("0"));
|
|
logisticInfo.setLoss(new BigDecimal("0"));
|
|
|
logisticInfo.setPayment(0L);
|
|
logisticInfo.setPayment(0L);
|
|
|
logisticInfo.setSigningWay(0);
|
|
logisticInfo.setSigningWay(0);
|
|
|
logisticInfo.setLossUnit("");
|
|
logisticInfo.setLossUnit("");
|
|
|
- logisticInfo.setBillingMode("");
|
|
|
|
|
logisticInfo.setRemark("");
|
|
logisticInfo.setRemark("");
|
|
|
logisticInfo.setType(0);
|
|
logisticInfo.setType(0);
|
|
|
|
|
|
|
@@ -2372,40 +2203,39 @@ public class KwoTradeOrderService {
|
|
|
if (CollUtil.isNotEmpty(list)) {
|
|
if (CollUtil.isNotEmpty(list)) {
|
|
|
//Map<Long, ContractCommonInfoResDto> contractMap = remoteContractService.queryContractBaseInfo(list.stream().map(KwoTradeOrderTransport::getContractId).collect(Collectors.toList()));
|
|
//Map<Long, ContractCommonInfoResDto> contractMap = remoteContractService.queryContractBaseInfo(list.stream().map(KwoTradeOrderTransport::getContractId).collect(Collectors.toList()));
|
|
|
List<LogisticInfo> collect = list.stream().map(d -> {
|
|
List<LogisticInfo> collect = list.stream().map(d -> {
|
|
|
- LogisticInfo logisticInfo = new LogisticInfo();
|
|
|
|
|
- logisticInfo.setContractId(d.getContractId());
|
|
|
|
|
- logisticInfo.setContractNo(d.getContractNo());
|
|
|
|
|
- logisticInfo.setContractName("");
|
|
|
|
|
- logisticInfo.setAcceptCompanyId(d.getEntId());
|
|
|
|
|
- logisticInfo.setAcceptContactPhone(d.getPhone());
|
|
|
|
|
- logisticInfo.setAcceptContacts(d.getContacts());
|
|
|
|
|
- logisticInfo.setAcceptContactsId(d.getContactsId());
|
|
|
|
|
- logisticInfo.setAcceptCompany(d.getFirmName());
|
|
|
|
|
- logisticInfo.setPrice(d.getTransportPrice());
|
|
|
|
|
- logisticInfo.setPriceType(0L);
|
|
|
|
|
- logisticInfo.setEndTime(LocalDate.now());
|
|
|
|
|
- logisticInfo.setStartTime(LocalDate.now());
|
|
|
|
|
- logisticInfo.setAmount(new BigDecimal("0"));
|
|
|
|
|
- logisticInfo.setAmountUnit("");
|
|
|
|
|
- logisticInfo.setLoss(new BigDecimal("0"));
|
|
|
|
|
- logisticInfo.setPayment(0L);
|
|
|
|
|
- logisticInfo.setSigningWay(0);
|
|
|
|
|
- logisticInfo.setLossUnit("");
|
|
|
|
|
- logisticInfo.setBillingMode("");
|
|
|
|
|
- logisticInfo.setRemark("");
|
|
|
|
|
- logisticInfo.setType(0);
|
|
|
|
|
-
|
|
|
|
|
- return logisticInfo;
|
|
|
|
|
- }
|
|
|
|
|
- ).collect(Collectors.toList());
|
|
|
|
|
|
|
+ LogisticInfo logisticInfo = new LogisticInfo();
|
|
|
|
|
+ logisticInfo.setContractId(d.getContractId());
|
|
|
|
|
+ logisticInfo.setContractNo(d.getContractNo());
|
|
|
|
|
+ logisticInfo.setContractName("");
|
|
|
|
|
+ logisticInfo.setAcceptCompanyId(d.getEntId());
|
|
|
|
|
+ logisticInfo.setAcceptContactPhone(d.getPhone());
|
|
|
|
|
+ logisticInfo.setAcceptContacts(d.getContacts());
|
|
|
|
|
+ logisticInfo.setAcceptContactsId(d.getContactsId());
|
|
|
|
|
+ logisticInfo.setAcceptCompany(d.getFirmName());
|
|
|
|
|
+ logisticInfo.setPrice(d.getTransportPrice());
|
|
|
|
|
+ logisticInfo.setPriceType(0L);
|
|
|
|
|
+ logisticInfo.setAmount(new BigDecimal("0"));
|
|
|
|
|
+ logisticInfo.setAmountUnit("");
|
|
|
|
|
+ logisticInfo.setLoss(new BigDecimal("0"));
|
|
|
|
|
+ logisticInfo.setPayment(0L);
|
|
|
|
|
+ logisticInfo.setSigningWay(0);
|
|
|
|
|
+ logisticInfo.setLossUnit("");
|
|
|
|
|
+ logisticInfo.setRemark("");
|
|
|
|
|
+ logisticInfo.setType(0);
|
|
|
|
|
+
|
|
|
|
|
+ return logisticInfo;
|
|
|
|
|
+ }).collect(Collectors.toList());
|
|
|
addLogisticOrderParam.setLogisticInfo(collect);
|
|
addLogisticOrderParam.setLogisticInfo(collect);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
}
|
|
}
|
|
|
addLogisticOrderParam.setTradeOrderId(kwoTradeOrder.getId());
|
|
addLogisticOrderParam.setTradeOrderId(kwoTradeOrder.getId());
|
|
|
addLogisticOrderParam.setTradeOrderNo(kwoTradeOrder.getTOrderNo());
|
|
addLogisticOrderParam.setTradeOrderNo(kwoTradeOrder.getTOrderNo());
|
|
|
|
|
+ addLogisticOrderParam.setBillingMode(String.valueOf(kwoTradeOrder.getChargeType()));
|
|
|
|
|
+ addLogisticOrderParam.setStartTime(DateUtils.dateToLocalDate(kwoTradeOrder.getStartTime()));
|
|
|
|
|
+ addLogisticOrderParam.setEndTime(DateUtils.dateToLocalDate(kwoTradeOrder.getEndTime()));
|
|
|
if (Objects.equals(tradeContractResDto.getConsignment(), 1)) {//买方托运
|
|
if (Objects.equals(tradeContractResDto.getConsignment(), 1)) {//买方托运
|
|
|
- KwoTradeOrderUnit kwoTradeOrderUnit = unitMap.get("1");//采购
|
|
|
|
|
|
|
+ KwoTradeOrderUnit kwoTradeOrderUnit = unitMap.get("1");//买方
|
|
|
if (Objects.nonNull(kwoTradeOrderUnit)) {
|
|
if (Objects.nonNull(kwoTradeOrderUnit)) {
|
|
|
addLogisticOrderParam.setConsignCompany(kwoTradeOrderUnit.getFirmName());
|
|
addLogisticOrderParam.setConsignCompany(kwoTradeOrderUnit.getFirmName());
|
|
|
addLogisticOrderParam.setConsignCompanyId(kwoTradeOrderUnit.getEntId());
|
|
addLogisticOrderParam.setConsignCompanyId(kwoTradeOrderUnit.getEntId());
|
|
@@ -2413,9 +2243,17 @@ public class KwoTradeOrderService {
|
|
|
addLogisticOrderParam.setConsignContacts(kwoTradeOrderUnit.getContacts());
|
|
addLogisticOrderParam.setConsignContacts(kwoTradeOrderUnit.getContacts());
|
|
|
addLogisticOrderParam.setConsignContactsId(kwoTradeOrderUnit.getContactsId());
|
|
addLogisticOrderParam.setConsignContactsId(kwoTradeOrderUnit.getContactsId());
|
|
|
}
|
|
}
|
|
|
|
|
+ KwoTradeOrderUnit kwoTradeOrderUnit2 = unitMap.get("2");//卖方
|
|
|
|
|
+ if (Objects.nonNull(kwoTradeOrderUnit2)) {
|
|
|
|
|
+ addLogisticOrderParam.setNonConsignCompany(kwoTradeOrderUnit2.getFirmName());
|
|
|
|
|
+ addLogisticOrderParam.setNonConsignCompanyId(kwoTradeOrderUnit2.getEntId());
|
|
|
|
|
+ addLogisticOrderParam.setNonConsignContactPhone(kwoTradeOrderUnit2.getPhone());
|
|
|
|
|
+ addLogisticOrderParam.setNonConsignContacts(kwoTradeOrderUnit2.getContacts());
|
|
|
|
|
+ addLogisticOrderParam.setNonConsignContactsId(kwoTradeOrderUnit2.getContactsId());
|
|
|
|
|
+ }
|
|
|
|
|
|
|
|
} else {
|
|
} else {
|
|
|
- KwoTradeOrderUnit kwoTradeOrderUnit = unitMap.get("2");//采购
|
|
|
|
|
|
|
+ KwoTradeOrderUnit kwoTradeOrderUnit = unitMap.get("2");//卖方
|
|
|
if (Objects.nonNull(kwoTradeOrderUnit)) {
|
|
if (Objects.nonNull(kwoTradeOrderUnit)) {
|
|
|
addLogisticOrderParam.setConsignCompany(kwoTradeOrderUnit.getFirmName());
|
|
addLogisticOrderParam.setConsignCompany(kwoTradeOrderUnit.getFirmName());
|
|
|
addLogisticOrderParam.setConsignCompanyId(kwoTradeOrderUnit.getEntId());
|
|
addLogisticOrderParam.setConsignCompanyId(kwoTradeOrderUnit.getEntId());
|
|
@@ -2423,6 +2261,14 @@ public class KwoTradeOrderService {
|
|
|
addLogisticOrderParam.setConsignContacts(kwoTradeOrderUnit.getContacts());
|
|
addLogisticOrderParam.setConsignContacts(kwoTradeOrderUnit.getContacts());
|
|
|
addLogisticOrderParam.setConsignContactsId(kwoTradeOrderUnit.getContactsId());
|
|
addLogisticOrderParam.setConsignContactsId(kwoTradeOrderUnit.getContactsId());
|
|
|
}
|
|
}
|
|
|
|
|
+ KwoTradeOrderUnit kwoTradeOrderUnit2 = unitMap.get("1");//买方
|
|
|
|
|
+ if (Objects.nonNull(kwoTradeOrderUnit2)) {
|
|
|
|
|
+ addLogisticOrderParam.setNonConsignCompany(kwoTradeOrderUnit2.getFirmName());
|
|
|
|
|
+ addLogisticOrderParam.setNonConsignCompanyId(kwoTradeOrderUnit2.getEntId());
|
|
|
|
|
+ addLogisticOrderParam.setNonConsignContactPhone(kwoTradeOrderUnit2.getPhone());
|
|
|
|
|
+ addLogisticOrderParam.setNonConsignContacts(kwoTradeOrderUnit2.getContacts());
|
|
|
|
|
+ addLogisticOrderParam.setNonConsignContactsId(kwoTradeOrderUnit2.getContactsId());
|
|
|
|
|
+ }
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
addLogisticOrderParam.setGoodsId(byOrderId.getGoodsId());
|
|
addLogisticOrderParam.setGoodsId(byOrderId.getGoodsId());
|
|
@@ -2443,7 +2289,7 @@ public class KwoTradeOrderService {
|
|
|
addLogisticOrderParam.setLoadLng(kwoTradeOrderAddress.getLng());
|
|
addLogisticOrderParam.setLoadLng(kwoTradeOrderAddress.getLng());
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- List<KwoTradeOrderAddress> kwoTradeOrderAddresses2 = addressMap.get(String.valueOf(AddressTypeEnum.SHIPMENT.getCode()));
|
|
|
|
|
|
|
+ List<KwoTradeOrderAddress> kwoTradeOrderAddresses2 = addressMap.get(String.valueOf(AddressTypeEnum.TAKE.getCode()));
|
|
|
KwoTradeOrderAddress unloadAddress = kwoTradeOrderAddresses2.get(0);
|
|
KwoTradeOrderAddress unloadAddress = kwoTradeOrderAddresses2.get(0);
|
|
|
if (Objects.nonNull(unloadAddress)) {
|
|
if (Objects.nonNull(unloadAddress)) {
|
|
|
addLogisticOrderParam.setUnloadId(unloadAddress.getId());
|
|
addLogisticOrderParam.setUnloadId(unloadAddress.getId());
|
|
@@ -2506,4 +2352,31 @@ public class KwoTradeOrderService {
|
|
|
|
|
|
|
|
kwoTradeOrderMapper.updateById(kwoTradeOrder1);
|
|
kwoTradeOrderMapper.updateById(kwoTradeOrder1);
|
|
|
}
|
|
}
|
|
|
|
|
+
|
|
|
|
|
+ public List<TradeOrderVo> queryOrder(TradeOrderPara tradeOrderPara) {
|
|
|
|
|
+ List<TradeOrderVo> tradeOrderVos = kwoTradeOrderMapper.selectData(tradeOrderPara);
|
|
|
|
|
+ if (CollUtil.isNotEmpty(tradeOrderVos)) {
|
|
|
|
|
+ Map<String, Map<String, String>> dict = remoteSystemService.queryDictByType(List.of(DictTypeEnum.PRODUCT_NAME_TYPE.getType(), DictTypeEnum.UNIT_TYPE.getType(), DictTypeEnum.CHARGING_TYPE.getType()));
|
|
|
|
|
+ Map<String, String> statusMap, productNameMap, unitMap, chargeTypeMap;
|
|
|
|
|
+ if (CollUtil.isNotEmpty(dict)) {
|
|
|
|
|
+ statusMap = CollUtil.isNotEmpty(dict.get(DictTypeEnum.TORDER_STATUS.getType())) ? dict.get(DictTypeEnum.TORDER_STATUS.getType()) : new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
|
|
|
+ productNameMap = CollUtil.isNotEmpty(dict.get(DictTypeEnum.PRODUCT_NAME_TYPE.getType())) ? dict.get(DictTypeEnum.PRODUCT_NAME_TYPE.getType()) : new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
|
|
|
+ unitMap = CollUtil.isNotEmpty(dict.get(DictTypeEnum.UNIT_TYPE.getType())) ? dict.get(DictTypeEnum.UNIT_TYPE.getType()) : new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
|
|
|
+ chargeTypeMap = CollUtil.isNotEmpty(dict.get(DictTypeEnum.CHARGING_TYPE.getType())) ? dict.get(DictTypeEnum.CHARGING_TYPE.getType()) : new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
|
|
|
+ } else {
|
|
|
|
|
+ statusMap = new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
|
|
|
+ productNameMap = new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
|
|
|
+ unitMap = new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
|
|
|
+ chargeTypeMap = new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
|
|
|
+ }
|
|
|
|
|
+ tradeOrderVos.forEach(d -> {
|
|
|
|
|
+ d.setStatusLabel(statusMap.get(String.valueOf(d.getStatus())));
|
|
|
|
|
+ d.setGoodsTypeLabel(productNameMap.get(d.getGoodsType()));
|
|
|
|
|
+ d.setChargeTypeLabel(chargeTypeMap.get(String.valueOf(d.getChargeType())));
|
|
|
|
|
+ d.setUnitLabel(unitMap.get(String.valueOf(d.getUnit())));
|
|
|
|
|
+ });
|
|
|
|
|
+ return tradeOrderVos;
|
|
|
|
|
+ }
|
|
|
|
|
+ return new ArrayList<>();
|
|
|
|
|
+ }
|
|
|
}
|
|
}
|