diff --git a/blade-biz-common/src/main/java/org/springblade/common/constant/CommonConstant.java b/blade-biz-common/src/main/java/org/springblade/common/constant/CommonConstant.java index 460e6949a..17ead5cf3 100644 --- a/blade-biz-common/src/main/java/org/springblade/common/constant/CommonConstant.java +++ b/blade-biz-common/src/main/java/org/springblade/common/constant/CommonConstant.java @@ -53,14 +53,14 @@ public interface CommonConstant { // /** // * 默认缓存文件地址 // */ - String SYSTEMFILEPATH ="/home/java_works/logpm_temp_file/"; +// String SYSTEMFILEPATH ="/home/java_works/logpm_temp_file/"; /** * 默认缓存文件地址 */ -// String SYSTEMFILEPATH ="C:\\Users\\0.0\\Desktop\\汇通\\"; + String SYSTEMFILEPATH ="F:/logs/"; diff --git a/blade-biz-common/src/main/java/org/springblade/common/constant/ModuleNameConstant.java b/blade-biz-common/src/main/java/org/springblade/common/constant/ModuleNameConstant.java index 301dcc0d5..1e2dbc087 100644 --- a/blade-biz-common/src/main/java/org/springblade/common/constant/ModuleNameConstant.java +++ b/blade-biz-common/src/main/java/org/springblade/common/constant/ModuleNameConstant.java @@ -8,7 +8,7 @@ public interface ModuleNameConstant { /** * 如果不需要 "" */ - public static final String DEVAUTH =""; + public static final String DEVAUTH ="-pref"; /** * 工厂对接服务名称 diff --git a/blade-biz-common/src/main/java/org/springblade/common/utils/FileLogsUtil.java b/blade-biz-common/src/main/java/org/springblade/common/utils/FileLogsUtil.java new file mode 100644 index 000000000..c7453f07e --- /dev/null +++ b/blade-biz-common/src/main/java/org/springblade/common/utils/FileLogsUtil.java @@ -0,0 +1,84 @@ +package org.springblade.common.utils; + + +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springblade.common.constant.CommonConstant; + +import java.io.File; +import java.io.FileWriter; +import java.io.IOException; +import java.io.Writer; +import java.util.Calendar; +import java.util.Date; + +/** + * 根据日志文件生成本地文件 + */ +public class FileLogsUtil { + private static final Logger log = LoggerFactory.getLogger(FileLogsUtil.class); + + + // 根基传入的String 日志响应内容 保存到本地磁盘,返回本次保存的磁盘路径 + public static String saveFileLogs(String logs) { + + Date date = new Date(); + // 获取当前系统时间 + Long startdate = date.getTime(); + + String dataString = makeDateString(date); + + + String imgPath = CommonConstant.SYSTEMFILEPATH + "logs/"; + //根据当前时间 按照 年/月/日 创建一个文件 + imgPath = imgPath + dataString; + + // 判断文件夹是否存在 + File imgPathFile = new File(imgPath); + if (!imgPathFile.exists()) { + imgPathFile.mkdirs(); + } + // 按照年-月-日 创建一个字符串 + String fileName = System.currentTimeMillis() + ".log"; + + Writer writer = null; + try { + writer = new FileWriter(imgPath + fileName); + writer.write(logs); + writer.flush(); + + } catch (IOException e) { + throw new RuntimeException(e); + } finally { + if (writer != null) { + try { + writer.close(); + } catch (IOException e) { + throw new RuntimeException(e); + } + } + } + Long endDate = new Date().getTime(); + + log.info("保存消耗时间:" + (endDate - startdate) + "毫秒"); + + return imgPath + fileName; + } + + private static String makeDateString(Date date) { + + StringBuilder stringBuffer = new StringBuilder(); + Calendar calendar = Calendar.getInstance(); + calendar.setTime(date); //放入Date类型数据 + //获取年份 + stringBuffer.append(calendar.get(Calendar.YEAR)).append("/"); + //获取月份 + stringBuffer.append(calendar.get(Calendar.MONTH) + 1).append("/"); + //获取日份 + stringBuffer.append(calendar.get(Calendar.DATE)).append("/"); + return stringBuffer.toString(); + + + } + +} diff --git a/blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/feign/IDistributionParcelListClient.java b/blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/feign/IDistributionParcelListClient.java index d558ff578..f6fae33d5 100644 --- a/blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/feign/IDistributionParcelListClient.java +++ b/blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/feign/IDistributionParcelListClient.java @@ -67,7 +67,7 @@ public interface IDistributionParcelListClient { List findEntityListByOrderCode(@RequestParam String orderCode); @GetMapping(API_PREFIX+"/findALLNoUpShelfPackageByOrderCode") - List findALLNoUpShelfPackageByOrderCode(@RequestParam String orderCode); + List findALLNoUpShelfPackageByOrderCode(@RequestParam String orderCode,@RequestParam Long warehouseId); @GetMapping(API_PREFIX+"/updatePackageGroundingStatus") void updatePackageGroundingStatus(@RequestParam String orderPackageCode, @RequestParam String groundingStatus); diff --git a/blade-service-api/logpm-factory-api/src/main/java/com/logpm/factory/oupai/entity/OpOrderStatusLogEntity.java b/blade-service-api/logpm-factory-api/src/main/java/com/logpm/factory/oupai/entity/OpOrderStatusLogEntity.java index 724b55950..ee13f169e 100644 --- a/blade-service-api/logpm-factory-api/src/main/java/com/logpm/factory/oupai/entity/OpOrderStatusLogEntity.java +++ b/blade-service-api/logpm-factory-api/src/main/java/com/logpm/factory/oupai/entity/OpOrderStatusLogEntity.java @@ -1,5 +1,6 @@ package com.logpm.factory.oupai.entity; +import com.baomidou.mybatisplus.annotation.TableField; import com.baomidou.mybatisplus.annotation.TableName; import io.swagger.annotations.ApiModel; import lombok.Data; @@ -12,8 +13,16 @@ import org.springblade.core.mp.base.BaseEntity; @EqualsAndHashCode(callSuper = true) public class OpOrderStatusLogEntity extends BaseEntity { + /** + * 请求参数 + */ private String args; + /** + * 响应文件资源 + */ + private String responseUrl; + /** * 数据用途 1. 发车数据 */ @@ -26,4 +35,7 @@ public class OpOrderStatusLogEntity extends BaseEntity { */ private Integer dataStatus; + @TableField(exist = false) + private String responseBody; + } diff --git a/blade-service-api/logpm-factory-api/src/main/java/com/logpm/factory/oupai/vo/OpOrderStatusLogVO.java b/blade-service-api/logpm-factory-api/src/main/java/com/logpm/factory/oupai/vo/OpOrderStatusLogVO.java new file mode 100644 index 000000000..26e562806 --- /dev/null +++ b/blade-service-api/logpm-factory-api/src/main/java/com/logpm/factory/oupai/vo/OpOrderStatusLogVO.java @@ -0,0 +1,16 @@ +package com.logpm.factory.oupai.vo; + +import com.logpm.factory.oupai.entity.OpOrderStatusLogEntity; +import lombok.Data; +import lombok.EqualsAndHashCode; + +@Data +@EqualsAndHashCode(callSuper = true) +public class OpOrderStatusLogVO extends OpOrderStatusLogEntity { + + /** + * 响应内容 + */ + private String reponseBody; + +} diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/feign/DistributionParcelListClient.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/feign/DistributionParcelListClient.java index 102c0b02f..c56c191d4 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/feign/DistributionParcelListClient.java +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/feign/DistributionParcelListClient.java @@ -89,12 +89,12 @@ public class DistributionParcelListClient implements IDistributionParcelListClie } @Override - public List findALLNoUpShelfPackageByOrderCode(String orderCode) { + public List findALLNoUpShelfPackageByOrderCode(String orderCode,Long warehouseId) { // QueryWrapper queryWrapper = new QueryWrapper<>(); // queryWrapper.eq("order_code",orderCode) // .eq("is_deleted",0) // .eq("order_package_grounding_status",10); - return distributionParcelListService.findALLNoUpShelfPackageByOrderCode(orderCode); + return distributionParcelListService.findALLNoUpShelfPackageByOrderCode(orderCode,warehouseId); } @Override diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionParcelListMapper.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionParcelListMapper.java index 26e74dd4a..5692ff324 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionParcelListMapper.java +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionParcelListMapper.java @@ -90,7 +90,7 @@ public interface DistributionParcelListMapper extends BaseMapper selectOrderInfoSelfList(@Param("reservationId") Long reservationId,@Param("stockupId") Long stockupId, @Param("stockArticleId")Long stockArticleId); - List findALLNoUpShelfPackageByOrderCode(@Param("orderCode") String orderCode); + List findALLNoUpShelfPackageByOrderCode(@Param("orderCode") String orderCode,@Param("orderCode") Long warehouseId); IPage pageOweList(IPage page,@Param("param") DistributionParcelListDTO parcelListEntity); } diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionParcelListMapper.xml b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionParcelListMapper.xml index a165abc97..5c8401b20 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionParcelListMapper.xml +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionParcelListMapper.xml @@ -318,6 +318,7 @@ left join logpm_warehouse_updown_goods lwug on lwug.association_value = ldpl.order_package_code where 1=1 and ldpl.order_code = #{orderCode} + and ldpl.warehouse_id = #{warehouseId} and lwtg.id is null and lwug.id is null diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionStockArticleMapper.xml b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionStockArticleMapper.xml index 4cc1a4f4e..11b49a0b9 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionStockArticleMapper.xml +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionStockArticleMapper.xml @@ -300,11 +300,12 @@