2022业务中台项目案例

package com.smallrig.oms.service; import cn.hutool.core.date.DatePattern; import cn.hutool.core.date.DateUtil; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; import com.github.pagehelper.PageHelper; import com.jcraft.jsch.SftpException; import com.smallrig.api.basics.entity.Currency; import com.smallrig.api.basics.entity.*; import com.smallrig.api.oms.entity.*; import com.smallrig.api.sku.entity.PlatformProductRelation; import com.smallrig.common.bean.PageResult; import com.smallrig.common.bean.ResponseBean; import com.smallrig.common.constant.CommonConstant; import com.smallrig.common.enums.CodeEnums; import com.smallrig.common.enums.CountryTaxEnums; import com.smallrig.common.enums.MqTypeEnums; import com.smallrig.common.exception.BusinessException; import com.smallrig.common.utils.Common; import com.smallrig.common.utils.SmallrigConstant; import com.smallrig.oms.baen.vo.*; import com.smallrig.oms.cache.MarketCache; import com.smallrig.oms.cache.OrderCache; import com.smallrig.oms.cache.OrderStatCache; import com.smallrig.oms.cache.PlatformCache; import com.smallrig.oms.common.util.SFtpUtils; import com.smallrig.oms.feign.BasicsClient; import com.smallrig.oms.feign.OrderDbClient; import com.smallrig.oms.feign.SkuClient; import com.smallrig.oms.mapper.ExternalOrderImportMapper; import com.smallrig.oms.mq.MessagesEntity; import com.smallrig.oms.request.BasicsRequest; import com.smallrig.oms.request.OrderImportRequest; import com.smallrig.oms.response.OrderImportResponse; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.time.DateUtils; import org.joda.time.DateTime; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.context.ApplicationEventPublisher; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.util.CollectionUtils; import org.springframework.web.multipart.MultipartFile; import java.io.IOException; import java.math.BigDecimal; import java.math.RoundingMode; import java.text.ParseException; import java.text.SimpleDateFormat; import java.util.*; /** * @author zhangfangming <zhangfangming@smallrig.com> * @version 1.0.0 * @date 2019/12/20 18:21 * @since 1.0 */ @Service @Slf4j public class OrderImportService { @Autowired private ExternalOrderImportMapper externalOrderImportMapper; @Autowired private BasicsClient basicsClient; @Autowired private OrderCache orderCache; @Autowired private SFtpUtils sftpHelper; @Value("${sftp.upload.file}") private String fileUploadBasePath; @Value("${sftp.config.baseUploadPath}") private String fileUploadPath; @Autowired private OrderAddressService orderAddressService; @Autowired private OrderCostService orderCostService; @Autowired private OrderItemService orderItemService; @Autowired private OrderLogService orderLogService; @Autowired private OrderBaseService orderBaseService; @Autowired private SkuClient skuClient; @Autowired private OrderSysItemService sysItemService; @Autowired private CommonService commonService; @Autowired private OrderDbClient orderDbClient; @Autowired private MarketCache marketCache; @Autowired private PlatformCache platformCache; @Autowired private OrderStatCache orderStatCache; @Autowired private ApplicationEventPublisher publisher; /** * @return void * @throws IOException * @throws SftpException * @exception @author zhangfangming <zhangfangming@smallrig.com> * @date 2019/12/20 20:46 */ @Transactional(rollbackFor = Exception.class) public String importOrderFile(MultipartFile file) throws Exception { //导入的文件上传到服务器 String fileName = file.getOriginalFilename(); String suffixName = fileName.substring(fileName.lastIndexOf(".")); String filePath = new DateTime().toString("yyyyMMdd");//文件目录 fileName = System.currentTimeMillis() + suffixName; if(!sftpHelper.uploadFile(fileUploadBasePath, filePath, fileName,file.getInputStream())){ return ""; } return filePath+"/"+fileName; } /** * 订单列表查询 * @return ResponseBean * @exception * @author zhangfangming <zhangfangming@smallrig.com> * @date 2019/12/21 17:14 */ public ResponseBean listOrder(OrderImportRequest request) { Object o=commonService.getAuthRequest(request,request.getUserName()); if(o==null){ return ResponseBean.buildSuccess(); } List<Long> ids=commonService.getAndCheckAuthWarehouse(request.getWarehouseIds(),request.getPermissionWarehouseIds(),request.getUserName()); if(CollectionUtils.isEmpty(ids)){ if(CommonConstant.ADMIN.equals(request.getUserName())){ request.setWarehouseIds(null); }else { return ResponseBean.buildSuccess(); } }else { request.setWarehouseIds(ids); } JSONObject json = new JSONObject(); String channelIdss = request.getChannelIdss(); if (!StringUtils.isEmpty(channelIdss)){ String[] channelIdSplit = channelIdss.split(","); List<Long> channelIdList=new ArrayList<>(); for (String s : channelIdSplit) { channelIdList.add(Long.parseLong(s)); } request.setChannelIdList(channelIdList); } String platformIds = request.getPlatformIds(); if (!StringUtils.isEmpty(platformIds)){ String[] platformIdsSplit = platformIds.split(","); List<Long> platformIdsList=new ArrayList<>(); for (String s : platformIdsSplit) { platformIdsList.add(Long.parseLong(s)); } request.setPlatformIdList(platformIdsList); } String warehouseIds = request.getWarehouseIdArr(); if (!StringUtils.isEmpty(warehouseIds)){ String[] warehouseIdsSplit = warehouseIds.split(","); List<Long> warehouseIdsList=new ArrayList<>(); for (String s : warehouseIdsSplit) { warehouseIdsList.add(Long.parseLong(s)); } request.setWarehouseIdList(warehouseIdsList); } PageHelper.startPage(Integer.valueOf(request.getPageNum()), Integer.valueOf(request.getPageSize())); List<ExternalOrderImport> orderImportList = externalOrderImportMapper.selectOrderImportPaging(request); PageResult<ExternalOrderImport> pageInfo = new PageResult<>(orderImportList); List<OrderImportResponse> orderImportResponseList = new ArrayList<>(100); for (ExternalOrderImport externalOrderImport : orderImportList) { //1.查询订单里面的平台名称 String platformName = getPlatform(externalOrderImport); //2.查询订单里面的仓库名称 String warehouseName = getWarehouse(externalOrderImport); //3.查询订单里面的渠道名称 String channelName = getMarketChannel(externalOrderImport); OrderImportResponse orderImportResponse = new OrderImportResponse(); orderImportResponse.setPlatformName(platformName); orderImportResponse.setWarehouseName(warehouseName); orderImportResponse.setChannelName(channelName); orderImportResponse.setRemark(externalOrderImport.getRemark()); orderImportResponse.setImportStatus(externalOrderImport.getImportStatus()); orderImportRes