|
|
@@ -0,0 +1,325 @@
|
|
|
+package com.sckw.transport.service;
|
|
|
+
|
|
|
+import com.github.pagehelper.PageHelper;
|
|
|
+import com.github.pagehelper.PageInfo;
|
|
|
+import com.sckw.core.common.enums.NumberConstant;
|
|
|
+import com.sckw.core.common.enums.enums.DictTypeEnum;
|
|
|
+import com.sckw.core.model.constant.Global;
|
|
|
+import com.sckw.core.model.enums.LogisticsOrderEnum;
|
|
|
+import com.sckw.core.model.page.PageRes;
|
|
|
+import com.sckw.core.utils.CollectionUtils;
|
|
|
+import com.sckw.core.utils.StringUtils;
|
|
|
+import com.sckw.core.web.context.LoginUserHolder;
|
|
|
+import com.sckw.core.web.response.HttpResult;
|
|
|
+import com.sckw.mongo.model.TableTops;
|
|
|
+import com.sckw.order.api.dubbo.TradeOrderInfoService;
|
|
|
+import com.sckw.order.api.model.OrderDetailRes;
|
|
|
+import com.sckw.order.api.model.UnitInfoDetailRes;
|
|
|
+import com.sckw.system.api.RemoteSystemService;
|
|
|
+import com.sckw.system.api.model.dto.res.UserCacheResDto;
|
|
|
+import com.sckw.transport.dao.KwtLogisticsOrderMapper;
|
|
|
+import com.sckw.transport.model.param.ManagementLogisticsOrderQuery;
|
|
|
+import com.sckw.transport.model.vo.ManagementLogsiticsOrderVO;
|
|
|
+import com.sckw.transport.model.vo.execlVo.ManagementLogisticsOrderExcelVo;
|
|
|
+import lombok.extern.slf4j.Slf4j;
|
|
|
+import org.apache.dubbo.config.annotation.DubboReference;
|
|
|
+import org.springframework.beans.BeanUtils;
|
|
|
+import org.springframework.beans.factory.annotation.Autowired;
|
|
|
+import org.springframework.stereotype.Service;
|
|
|
+
|
|
|
+import java.math.BigDecimal;
|
|
|
+import java.text.DecimalFormat;
|
|
|
+import java.util.*;
|
|
|
+import java.util.stream.Collectors;
|
|
|
+
|
|
|
+/**
|
|
|
+ * @author lfdc
|
|
|
+ * @description 运营管理端service
|
|
|
+ * @date 2023-09-11 09:09:09
|
|
|
+ */
|
|
|
+@Slf4j
|
|
|
+@Service
|
|
|
+public class ManagementLogisticsOrderService {
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ CommonService commonService;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ KwtLogisticsOrderMapper logisticsOrderMapper;
|
|
|
+
|
|
|
+ @DubboReference(version = "1.0.0", group = "design", check = false, timeout = 6000)
|
|
|
+ RemoteSystemService remoteSystemService;
|
|
|
+ @DubboReference(version = "1.0.0", group = "design", check = false, timeout = 6000)
|
|
|
+ TradeOrderInfoService tradeOrderInfoService;
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @param query
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ public PageRes selectLogisticsOrder(ManagementLogisticsOrderQuery query) {
|
|
|
+ Long entId = LoginUserHolder.getEntId();
|
|
|
+ PageHelper.startPage(query.getPage(), query.getPageSize());
|
|
|
+ List<Integer> orderList = new ArrayList<>();
|
|
|
+ if (StringUtils.isNotBlank(query.getStatus())) {
|
|
|
+ if (String.valueOf(NumberConstant.SEVEN).equals(query.getStatus())) {
|
|
|
+ orderList.add(LogisticsOrderEnum.REJECT_ORDER.getCode());
|
|
|
+ orderList.add(LogisticsOrderEnum.CANCEL_ORDER.getCode());
|
|
|
+ } else {
|
|
|
+ orderList.add(Integer.valueOf(query.getStatus()));
|
|
|
+ }
|
|
|
+ }
|
|
|
+ //装卸货地址
|
|
|
+ String loadCode = query.getLoadAddressCode();
|
|
|
+ if (StringUtils.isNotBlank(loadCode)) {
|
|
|
+ switch (query.getLoadAddressLevel()) {
|
|
|
+ case 1 -> query.setLoadAddressCode(
|
|
|
+ loadCode.substring(0, 2).trim());
|
|
|
+ case 2 -> query.setLoadAddressCode(
|
|
|
+ loadCode.substring(0, 4).trim());
|
|
|
+ case 3 -> query.setLoadAddressCode(loadCode);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ String unloadCode = query.getUnloadAddressCode();
|
|
|
+ if (StringUtils.isNotBlank(unloadCode)) {
|
|
|
+ switch (query.getUnloadAddressLevel()) {
|
|
|
+ case 1 -> query.setUnloadAddressCode(
|
|
|
+ loadCode.substring(0, 2).trim());
|
|
|
+ case 2 -> query.setUnloadAddressCode(
|
|
|
+ loadCode.substring(0, 4).trim());
|
|
|
+ case 3 -> query.setUnloadAddressCode(loadCode);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ List<Long> longs = LoginUserHolder.getAuthUserIdList();
|
|
|
+ longs.add(LoginUserHolder.getUserId());
|
|
|
+ List<Long> longList = longs.stream().distinct().collect(Collectors.toList());
|
|
|
+// LoginUserHolder.getIsMain()
|
|
|
+ List<ManagementLogsiticsOrderVO> list = logisticsOrderMapper.selectManagementLogisticsOrderList(query, orderList, entId, longList, longList);
|
|
|
+ PageInfo<ManagementLogsiticsOrderVO> pageInfo = new PageInfo<>(list);
|
|
|
+ if (CollectionUtils.isEmpty(list)) {
|
|
|
+ return PageRes.build(pageInfo, list);
|
|
|
+ }
|
|
|
+// List<AcceptCarriageOrderVO> detailRes = new ArrayList<>();
|
|
|
+ /**计量单位*/
|
|
|
+ Map<String, String> unitTypeDictData = commonService.getDictData(DictTypeEnum.UNIT_TYPE.getType());
|
|
|
+ /**运价方式*/
|
|
|
+ Map<String, String> priceDictData = commonService.getDictData(DictTypeEnum.PRICE_TYPE.getType());
|
|
|
+ /**计费方式*/
|
|
|
+ Map<String, String> chargingDictData = commonService.getDictData(DictTypeEnum.CHARGING_TYPE.getType());
|
|
|
+ /**结算周期*/
|
|
|
+ Map<String, String> settlementDictData = commonService.getDictData(DictTypeEnum.SETTLEMENT_CYCLE.getType());
|
|
|
+ /**签约方式*/
|
|
|
+ Map<String, String> signingWay = commonService.getDictData(DictTypeEnum.SIGNING_TYPE.getType());
|
|
|
+ /**合理损耗*/
|
|
|
+// Map<String, String> taxRateTypeDictData = getDictData(DictTypeEnum.TAX_RATE_TYPE.getType());
|
|
|
+ Map<Long, UserCacheResDto> longUserMap = new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
|
+ if (CollectionUtils.isNotEmpty(list)) {
|
|
|
+ List<Long> collect = list.stream().map(ManagementLogsiticsOrderVO::getCreateBy).collect(Collectors.toList());
|
|
|
+ if (CollectionUtils.isNotEmpty(collect)) {
|
|
|
+ longUserMap = remoteSystemService.queryUserCacheMapByIds(collect);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ for (ManagementLogsiticsOrderVO vo : list) {
|
|
|
+ vo.setAccountsCycleLabel(settlementDictData.get(vo.getAccountsCycle()));
|
|
|
+ vo.setAppointor(longUserMap.get(vo.getCreateBy()) == null ? null : longUserMap.get(vo.getCreateBy()).getName());
|
|
|
+ vo.setBillingModeLabel(chargingDictData.get(vo.getBillingMode()));
|
|
|
+ vo.setSigningLabel(signingWay.get(vo.getSigning()));
|
|
|
+ vo.setStatusLabel(LogisticsOrderEnum.getName(vo.getStatus()));
|
|
|
+ vo.setLoadAddress(vo.getLoadCityName() + vo.getLoadAddress());
|
|
|
+ vo.setUnloadAddress(vo.getUnloadCityName() + vo.getUnloadAddress());
|
|
|
+ if (vo.getTOrderId() != null) {
|
|
|
+ OrderDetailRes orderDetailRes = tradeOrderInfoService.getOrderDetailById(Long.valueOf(vo.getTOrderId()));
|
|
|
+ if (orderDetailRes != null) {
|
|
|
+ List<UnitInfoDetailRes> unitInfo = orderDetailRes.getUnitInfo();
|
|
|
+ for (UnitInfoDetailRes detailRes : unitInfo) {
|
|
|
+ if (String.valueOf(NumberConstant.ONE).equals(detailRes.getUnitType())) {
|
|
|
+ vo.setShipmentsUnitEntId(String.valueOf(detailRes.getEntId()));
|
|
|
+ vo.setShipmentsUnit(detailRes.getFirmName());
|
|
|
+ } else {
|
|
|
+ vo.setReceiveGoodsUnitEntId(String.valueOf(detailRes.getEntId()));
|
|
|
+ vo.setReceiveGoodsUnit(detailRes.getFirmName());
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ vo.setWaitDistributionAmount(vo.getCarryingCapacity().subtract(vo.getSubcontractAmount()).subtract(vo.getEntrustAmount()));
|
|
|
+ String tOrderId = vo.getTOrderId();
|
|
|
+ if (StringUtils.isNotBlank(tOrderId)) {
|
|
|
+ OrderDetailRes orderDetailById = tradeOrderInfoService.getOrderDetailById(Long.parseLong(tOrderId));
|
|
|
+ if (orderDetailById != null) {
|
|
|
+ List<UnitInfoDetailRes> unitInfo = orderDetailById.getUnitInfo();
|
|
|
+ if (CollectionUtils.isNotEmpty(unitInfo)) {
|
|
|
+ for (UnitInfoDetailRes detailRes : unitInfo) {
|
|
|
+ if ("1".equals(detailRes.getUnitType())) {
|
|
|
+ vo.setReceiveGoodsUnit(detailRes.getFirmName());
|
|
|
+ vo.setReceiveGoodsUnitEntId(detailRes.getEntId() == null ? null : detailRes.getEntId().toString());
|
|
|
+ }
|
|
|
+ if ("2".equals(detailRes.getUnitType())) {
|
|
|
+ vo.setShipmentsUnit(detailRes.getFirmName());
|
|
|
+ vo.setShipmentsUnitEntId(detailRes.getEntId() == null ? null : detailRes.getEntId().toString());
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+ return PageRes.build(pageInfo, list);
|
|
|
+ }
|
|
|
+
|
|
|
+ public HttpResult statisticsLogisticsOrder(ManagementLogisticsOrderQuery query) {
|
|
|
+ Long entId = LoginUserHolder.getEntId();
|
|
|
+ List<Integer> orderList = new ArrayList<>();
|
|
|
+ if (StringUtils.isNotBlank(query.getStatus())) {
|
|
|
+ if (String.valueOf(NumberConstant.EIGHT).equals(query.getStatus())) {
|
|
|
+ orderList.add(LogisticsOrderEnum.REJECT_ORDER.getCode());
|
|
|
+ orderList.add(LogisticsOrderEnum.CANCEL_ORDER.getCode());
|
|
|
+ } else {
|
|
|
+ orderList.add(Integer.valueOf(query.getStatus()));
|
|
|
+ }
|
|
|
+ }
|
|
|
+ //装卸货地址
|
|
|
+ String loadCode = query.getLoadAddressCode();
|
|
|
+ if (StringUtils.isNotBlank(loadCode)) {
|
|
|
+ switch (query.getLoadAddressLevel()) {
|
|
|
+ case 1 -> query.setLoadAddressCode(
|
|
|
+ loadCode.substring(0, 2).trim());
|
|
|
+ case 2 -> query.setLoadAddressCode(
|
|
|
+ loadCode.substring(0, 4).trim());
|
|
|
+ case 3 -> query.setLoadAddressCode(loadCode);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ String unloadCode = query.getUnloadAddressCode();
|
|
|
+ if (StringUtils.isNotBlank(unloadCode)) {
|
|
|
+ switch (query.getUnloadAddressLevel()) {
|
|
|
+ case 1 -> query.setUnloadAddressCode(
|
|
|
+ loadCode.substring(0, 2).trim());
|
|
|
+ case 2 -> query.setUnloadAddressCode(
|
|
|
+ loadCode.substring(0, 4).trim());
|
|
|
+ case 3 -> query.setUnloadAddressCode(loadCode);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ List<Long> longs = LoginUserHolder.getAuthUserIdList();
|
|
|
+ longs.add(LoginUserHolder.getUserId());
|
|
|
+ List<Long> longList = longs.stream().distinct().collect(Collectors.toList());
|
|
|
+ List<TableTops> list = logisticsOrderMapper.countManagementLogisticsOrderListByStatus(query, orderList, entId, longList, longList);
|
|
|
+ List<TableTops> arrayList = new ArrayList<>();
|
|
|
+ arrayList.addAll(list);
|
|
|
+ /**补全数据状态不齐的情况*/
|
|
|
+ arrayList = commonService.packageReturnStatistics(list, arrayList);
|
|
|
+ // 查询结果
|
|
|
+ Map<String, Object> map = new HashMap<>(NumberConstant.SIXTEEN);
|
|
|
+ map.put("tableTop", arrayList);
|
|
|
+ // 查询结果
|
|
|
+ return HttpResult.ok(map);
|
|
|
+ }
|
|
|
+
|
|
|
+ public List<ManagementLogisticsOrderExcelVo> exportLogisticsOrder(ManagementLogisticsOrderQuery query) {
|
|
|
+ Long entId = LoginUserHolder.getEntId();
|
|
|
+// PageHelper.startPage(query.getPage(), query.getPageSize());
|
|
|
+ List<Integer> orderList = new ArrayList<>();
|
|
|
+ if (StringUtils.isNotBlank(query.getStatus())) {
|
|
|
+ if (String.valueOf(NumberConstant.SEVEN).equals(query.getStatus())) {
|
|
|
+ orderList.add(LogisticsOrderEnum.REJECT_ORDER.getCode());
|
|
|
+ orderList.add(LogisticsOrderEnum.CANCEL_ORDER.getCode());
|
|
|
+ } else {
|
|
|
+ orderList.add(Integer.valueOf(query.getStatus()));
|
|
|
+ }
|
|
|
+ }
|
|
|
+ //装卸货地址
|
|
|
+ String loadCode = query.getLoadAddressCode();
|
|
|
+ if (StringUtils.isNotBlank(loadCode)) {
|
|
|
+ switch (query.getLoadAddressLevel()) {
|
|
|
+ case 1 -> query.setLoadAddressCode(
|
|
|
+ loadCode.substring(0, 2).trim());
|
|
|
+ case 2 -> query.setLoadAddressCode(
|
|
|
+ loadCode.substring(0, 4).trim());
|
|
|
+ case 3 -> query.setLoadAddressCode(loadCode);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ String unloadCode = query.getUnloadAddressCode();
|
|
|
+ if (StringUtils.isNotBlank(unloadCode)) {
|
|
|
+ switch (query.getUnloadAddressLevel()) {
|
|
|
+ case 1 -> query.setUnloadAddressCode(
|
|
|
+ loadCode.substring(0, 2).trim());
|
|
|
+ case 2 -> query.setUnloadAddressCode(
|
|
|
+ loadCode.substring(0, 4).trim());
|
|
|
+ case 3 -> query.setUnloadAddressCode(loadCode);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ List<Long> longs = LoginUserHolder.getAuthUserIdList();
|
|
|
+ longs.add(LoginUserHolder.getUserId());
|
|
|
+ List<Long> longList = longs.stream().distinct().collect(Collectors.toList());
|
|
|
+ List<ManagementLogsiticsOrderVO> list = logisticsOrderMapper.selectManagementLogisticsOrderList(query, orderList, entId, longList, longList);
|
|
|
+ /**计费方式*/
|
|
|
+ Map<String, String> chargingDictData = commonService.getDictData(DictTypeEnum.CHARGING_TYPE.getType());
|
|
|
+ /**结算周期*/
|
|
|
+ Map<String, String> settlementDictData = commonService.getDictData(DictTypeEnum.SETTLEMENT_CYCLE.getType());
|
|
|
+ /**签约方式*/
|
|
|
+ Map<String, String> signingWay = commonService.getDictData(DictTypeEnum.SIGNING_TYPE.getType());
|
|
|
+ /**合理损耗单位*/
|
|
|
+ Map<String, String> taxRate = commonService.getDictData(DictTypeEnum.TAX_RATE_TYPE.getType());
|
|
|
+ /**运价方式*/
|
|
|
+ Map<String, String> priceType = commonService.getDictData(DictTypeEnum.PRICE_TYPE.getType());
|
|
|
+ Map<Long, UserCacheResDto> longUserMap = new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
|
+ if (CollectionUtils.isNotEmpty(list)) {
|
|
|
+ List<Long> collect = list.stream().map(ManagementLogsiticsOrderVO::getCreateBy).collect(Collectors.toList());
|
|
|
+ if (CollectionUtils.isNotEmpty(collect)) {
|
|
|
+ longUserMap = remoteSystemService.queryUserCacheMapByIds(collect);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ List<ManagementLogisticsOrderExcelVo> exportList = new ArrayList<>();
|
|
|
+ for (ManagementLogsiticsOrderVO vo : list) {
|
|
|
+ ManagementLogisticsOrderExcelVo managementLogisticsOrderExcelVo = new ManagementLogisticsOrderExcelVo();
|
|
|
+ BeanUtils.copyProperties(vo, managementLogisticsOrderExcelVo);
|
|
|
+ managementLogisticsOrderExcelVo.setPriceLabel(vo.getPrice() == null ? null : vo.getPrice().toString() + priceType.get(vo.getPriceType()));
|
|
|
+ managementLogisticsOrderExcelVo.setLossUnitLabel(vo.getLoss() == null ? null : vo.getLoss().toString() + taxRate.get(vo.getLossUnit()));
|
|
|
+ managementLogisticsOrderExcelVo.setGoodsPriceLabel(vo.getGoodsPrice() == null ? null : vo.getGoodsPrice().toString() + priceType.get(vo.getGoodsPriceUnit()));
|
|
|
+ managementLogisticsOrderExcelVo.setAccountsCycleLabel(settlementDictData.get(vo.getAccountsCycle()));
|
|
|
+ managementLogisticsOrderExcelVo.setAppointor(longUserMap.get(vo.getCreateBy()) == null ? null : longUserMap.get(vo.getCreateBy()).getName());
|
|
|
+ managementLogisticsOrderExcelVo.setBillingModeLabel(chargingDictData.get(vo.getBillingMode()));
|
|
|
+ managementLogisticsOrderExcelVo.setSigningLabel(signingWay.get(vo.getSigning()));
|
|
|
+ managementLogisticsOrderExcelVo.setStatusLabel(LogisticsOrderEnum.getName(vo.getStatus()));
|
|
|
+ managementLogisticsOrderExcelVo.setLoadAddress(vo.getLoadCityName() + vo.getLoadAddress());
|
|
|
+ managementLogisticsOrderExcelVo.setUnloadAddress(vo.getUnloadCityName() + vo.getUnloadAddress());
|
|
|
+ if (vo.getTOrderId() != null) {
|
|
|
+ OrderDetailRes orderDetailRes = tradeOrderInfoService.getOrderDetailById(Long.valueOf(vo.getTOrderId()));
|
|
|
+ if (orderDetailRes != null) {
|
|
|
+ List<UnitInfoDetailRes> unitInfo = orderDetailRes.getUnitInfo();
|
|
|
+ for (UnitInfoDetailRes detailRes : unitInfo) {
|
|
|
+ if (String.valueOf(NumberConstant.ONE).equals(detailRes.getUnitType())) {
|
|
|
+ managementLogisticsOrderExcelVo.setShipmentsUnit(detailRes.getFirmName());
|
|
|
+ } else {
|
|
|
+ managementLogisticsOrderExcelVo.setReceiveGoodsUnit(detailRes.getFirmName());
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ BigDecimal subtract = vo.getCarryingCapacity().subtract(vo.getSubcontractAmount()).subtract(vo.getEntrustAmount());
|
|
|
+ DecimalFormat df = new DecimalFormat("0.00");
|
|
|
+ managementLogisticsOrderExcelVo.setWaitDistributionAmount(subtract == null ? null : df.format(subtract));
|
|
|
+ String tOrderId = vo.getTOrderId();
|
|
|
+ if (StringUtils.isNotBlank(tOrderId)) {
|
|
|
+ OrderDetailRes orderDetailById = tradeOrderInfoService.getOrderDetailById(Long.parseLong(tOrderId));
|
|
|
+ if (orderDetailById != null) {
|
|
|
+ List<UnitInfoDetailRes> unitInfo = orderDetailById.getUnitInfo();
|
|
|
+ if (CollectionUtils.isNotEmpty(unitInfo)) {
|
|
|
+ for (UnitInfoDetailRes detailRes : unitInfo) {
|
|
|
+ if ("1".equals(detailRes.getUnitType())) {
|
|
|
+ managementLogisticsOrderExcelVo.setReceiveGoodsUnit(detailRes.getFirmName());
|
|
|
+ }
|
|
|
+ if ("2".equals(detailRes.getUnitType())) {
|
|
|
+ managementLogisticsOrderExcelVo.setShipmentsUnit(detailRes.getFirmName());
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ managementLogisticsOrderExcelVo.setSubcontractAmount(Objects.isNull(vo.getSubcontractAmount()) ? null : df.format(vo.getSubcontractAmount()) + priceType.get(vo.getPriceType()));
|
|
|
+ managementLogisticsOrderExcelVo.setEntrustAmount(Objects.isNull(vo.getEntrustAmount()) ? null : df.format(vo.getEntrustAmount()) + priceType.get(vo.getPriceType()));
|
|
|
+ managementLogisticsOrderExcelVo.setLoadAmount(Objects.isNull(vo.getLoadAmount()) ? null : df.format(vo.getLoadAmount()) + priceType.get(vo.getPriceType()));
|
|
|
+ managementLogisticsOrderExcelVo.setUnloadAmount(Objects.isNull(vo.getUnloadAmount()) ? null : df.format(vo.getUnloadAmount()) + priceType.get(vo.getPriceType()));
|
|
|
+ exportList.add(managementLogisticsOrderExcelVo);
|
|
|
+ }
|
|
|
+ return exportList;
|
|
|
+ }
|
|
|
+}
|