From 86d7beb97edd7e68e388a7fdc43b1e4ee8ea4760 Mon Sep 17 00:00:00 2001 From: zhenghaoyu Date: Fri, 15 Sep 2023 13:13:46 +0800 Subject: [PATCH] =?UTF-8?q?1.=E5=AE=8C=E6=88=90=E6=AC=A7=E6=B4=BE=E5=B7=A5?= =?UTF-8?q?=E5=8E=82=E7=AD=BE=E6=94=B6=E5=9B=BE=E7=89=87=E6=95=B0=E6=8D=AE?= =?UTF-8?q?=E7=9A=84=E4=BF=9D=E5=AD=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../oupai/entity/OpSignPictureEntity.java | 38 +++++++++++++++++++ .../oupai/mapper/OpSignPictureMapper.java | 9 +++++ .../oupai/mapper/OpSignPictureMapper.xml | 5 +++ .../oupai/receiver/OpSignDataHandler.java | 28 +++++++++++--- .../oupai/service/IOpSignPictureService.java | 8 ++++ .../impl/OpSignPictureServiceImpl.java | 20 ++++++++++ 6 files changed, 102 insertions(+), 6 deletions(-) create mode 100644 blade-service-api/logpm-factory-api/src/main/java/com/logpm/factory/oupai/entity/OpSignPictureEntity.java create mode 100644 blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/mapper/OpSignPictureMapper.java create mode 100644 blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/mapper/OpSignPictureMapper.xml create mode 100644 blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/service/IOpSignPictureService.java create mode 100644 blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/service/impl/OpSignPictureServiceImpl.java diff --git a/blade-service-api/logpm-factory-api/src/main/java/com/logpm/factory/oupai/entity/OpSignPictureEntity.java b/blade-service-api/logpm-factory-api/src/main/java/com/logpm/factory/oupai/entity/OpSignPictureEntity.java new file mode 100644 index 000000000..b6104c9f7 --- /dev/null +++ b/blade-service-api/logpm-factory-api/src/main/java/com/logpm/factory/oupai/entity/OpSignPictureEntity.java @@ -0,0 +1,38 @@ +package com.logpm.factory.oupai.entity; + +import com.baomidou.mybatisplus.annotation.TableName; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; +import lombok.EqualsAndHashCode; +import org.springblade.core.mp.base.BaseEntity; + +@Data +@TableName("op_sign_picture") +@ApiModel(value = "OpSignPicture对象", description = "欧派工厂签收图片") +@EqualsAndHashCode(callSuper = true) +public class OpSignPictureEntity extends BaseEntity { + + /** 预留1 */ + @ApiModelProperty(name = "预留1",notes = "") + private String reserve1 ; + /** 预留2 */ + @ApiModelProperty(name = "预留2",notes = "") + private String reserve2 ; + /** 预留3 */ + @ApiModelProperty(name = "预留3",notes = "") + private String reserve3 ; + /** 预留4 */ + @ApiModelProperty(name = "预留4",notes = "") + private String reserve4 ; + /** 预留5 */ + @ApiModelProperty(name = "预留5",notes = "") + private String reserve5 ; + + private Long signBillId;//签收单id + private String signBillCode;//签收单号 + private String oid; + private String fileUrl;//图片地址 + + +} diff --git a/blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/mapper/OpSignPictureMapper.java b/blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/mapper/OpSignPictureMapper.java new file mode 100644 index 000000000..ad8fd29b1 --- /dev/null +++ b/blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/mapper/OpSignPictureMapper.java @@ -0,0 +1,9 @@ +package com.logpm.factory.oupai.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.logpm.factory.oupai.entity.OpSignPictureEntity; +import org.apache.ibatis.annotations.Mapper; + +@Mapper +public interface OpSignPictureMapper extends BaseMapper { +} diff --git a/blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/mapper/OpSignPictureMapper.xml b/blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/mapper/OpSignPictureMapper.xml new file mode 100644 index 000000000..658fcf0f8 --- /dev/null +++ b/blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/mapper/OpSignPictureMapper.xml @@ -0,0 +1,5 @@ + + + + + diff --git a/blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/receiver/OpSignDataHandler.java b/blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/receiver/OpSignDataHandler.java index 3eb4af360..10ba000cc 100644 --- a/blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/receiver/OpSignDataHandler.java +++ b/blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/receiver/OpSignDataHandler.java @@ -2,13 +2,11 @@ package com.logpm.factory.oupai.receiver; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; -import com.logpm.factory.oupai.entity.OpOrderStatusLogEntity; -import com.logpm.factory.oupai.entity.OpOutGoingOrderEntity; -import com.logpm.factory.oupai.entity.OpSignBillEntity; -import com.logpm.factory.oupai.entity.OpSignPackageEntity; +import com.logpm.factory.oupai.entity.*; import com.logpm.factory.oupai.service.IOpOutGoingOrderService; import com.logpm.factory.oupai.service.IOpSignBillService; import com.logpm.factory.oupai.service.IOpSignPackageService; +import com.logpm.factory.oupai.service.IOpSignPictureService; import com.rabbitmq.client.Channel; import lombok.extern.slf4j.Slf4j; import org.springblade.common.constant.RabbitConstant; @@ -41,6 +39,8 @@ public class OpSignDataHandler { private IOpSignBillService opSignBillService; @Autowired private IOpSignPackageService opSignPackageService; + @Autowired + private IOpSignPictureService opSignPictureService; @RabbitHandler @@ -66,6 +66,7 @@ public class OpSignDataHandler { String outGoingOrderCode = outGoingOrder.getString("Code"); JSONObject store = valueObject.getJSONObject("Store"); JSONArray packages = valueObject.getJSONArray("Packages"); + JSONArray signPictures = valueObject.getJSONArray("SignPictures"); String status = outGoingOrder.getString("Status"); //先查询是否已经有数据存在系统中 OpOutGoingOrderEntity opOutGoingOrderEntity = opOutGoingOrderService.getEntityByCode(outGoingOrderCode); @@ -195,9 +196,24 @@ public class OpSignDataHandler { // 保存签收图片 + for (int t = 0; t < signPictures.size(); t++) { + JSONObject signPicturesJSONObject = signPictures.getJSONObject(t); + String oid = signPicturesJSONObject.getString("Oid"); + //先判断库中是否已经存在 + OpSignPictureEntity signPictureEntity = opSignPictureService.findEntityByOid(oid); + if(Objects.isNull(signPictureEntity)){ + JSONObject data = signPicturesJSONObject.getJSONObject("Data"); + signPictureEntity = new OpSignPictureEntity(); + signPictureEntity.setSignBillId(signBillId); + signPictureEntity.setSignBillCode(signBillEntity.getCode()); + signPictureEntity.setOid(oid); + if(!Objects.isNull(data)){ + signPictureEntity.setFileUrl(data.getString("FileUrl")); + } + opSignPictureService.save(signPictureEntity); + } - - + } //存入包件数据 for (int j = 0; j < packages.size(); j++) { diff --git a/blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/service/IOpSignPictureService.java b/blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/service/IOpSignPictureService.java new file mode 100644 index 000000000..ff217ca2a --- /dev/null +++ b/blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/service/IOpSignPictureService.java @@ -0,0 +1,8 @@ +package com.logpm.factory.oupai.service; + +import com.logpm.factory.oupai.entity.OpSignPictureEntity; +import org.springblade.core.mp.base.BaseService; + +public interface IOpSignPictureService extends BaseService { + OpSignPictureEntity findEntityByOid(String oid); +} diff --git a/blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/service/impl/OpSignPictureServiceImpl.java b/blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/service/impl/OpSignPictureServiceImpl.java new file mode 100644 index 000000000..1afd6e657 --- /dev/null +++ b/blade-service/logpm-factory/src/main/java/com/logpm/factory/oupai/service/impl/OpSignPictureServiceImpl.java @@ -0,0 +1,20 @@ +package com.logpm.factory.oupai.service.impl; + +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.logpm.factory.oupai.entity.OpSignPictureEntity; +import com.logpm.factory.oupai.mapper.OpSignPictureMapper; +import com.logpm.factory.oupai.service.IOpSignPictureService; +import lombok.AllArgsConstructor; +import org.springblade.core.mp.base.BaseServiceImpl; +import org.springframework.stereotype.Service; + +@Service +@AllArgsConstructor +public class OpSignPictureServiceImpl extends BaseServiceImpl implements IOpSignPictureService { + @Override + public OpSignPictureEntity findEntityByOid(String oid) { + QueryWrapper queryWrapper = new QueryWrapper<>(); + queryWrapper.eq("oid",oid); + return baseMapper.selectOne(queryWrapper); + } +}