From f51054ea40fba7b8486770901238f7a7dcb8708f Mon Sep 17 00:00:00 2001 From: anthonywj Date: Fri, 2 Jun 2023 09:40:00 +0800 Subject: [PATCH 1/5] =?UTF-8?q?=E7=AC=AC=E4=B8=89=E6=96=B9=E5=8D=95?= =?UTF-8?q?=E6=8D=AE=E4=B8=8A=E4=BC=A0=E7=B1=BB=E5=9E=8B=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../thrsys/ThirdUploadSetController.java | 16 +------ .../thrsys/ThrOrderUploadBustypesMapper.java | 9 ++++ .../thrsys/ThrOrderUploadBustypesEntity.java | 47 ++++++++++--------- .../com/glxp/api/http/ErpBasicClient.java | 1 - .../thrsys/ThrOrderUploadBustypesService.java | 10 ++++ .../thrsys/ThrOrderUploadBustypesMapper.xml | 4 ++ 6 files changed, 51 insertions(+), 36 deletions(-) create mode 100644 src/main/java/com/glxp/api/dao/thrsys/ThrOrderUploadBustypesMapper.java create mode 100644 src/main/java/com/glxp/api/service/thrsys/ThrOrderUploadBustypesService.java create mode 100644 src/main/resources/mybatis/mapper/thrsys/ThrOrderUploadBustypesMapper.xml diff --git a/src/main/java/com/glxp/api/controller/thrsys/ThirdUploadSetController.java b/src/main/java/com/glxp/api/controller/thrsys/ThirdUploadSetController.java index 62414e60a..545b85e80 100644 --- a/src/main/java/com/glxp/api/controller/thrsys/ThirdUploadSetController.java +++ b/src/main/java/com/glxp/api/controller/thrsys/ThirdUploadSetController.java @@ -1,14 +1,11 @@ package com.glxp.api.controller.thrsys; -import cn.hutool.core.collection.CollUtil; import com.glxp.api.annotation.AuthRuleAnnotation; -import com.glxp.api.entity.system.SyncDataBustypeEntity; -import com.glxp.api.entity.system.SyncUploadDataSetEntity; -import com.glxp.api.service.system.SyncUploadDataBustypeService; -import com.glxp.api.service.system.SyncUploadDataSetService; import com.glxp.api.common.enums.ResultEnum; import com.glxp.api.common.res.BaseResponse; import com.glxp.api.common.util.ResultVOUtils; +import com.glxp.api.entity.system.SyncUploadDataSetEntity; +import com.glxp.api.service.system.SyncUploadDataSetService; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestBody; @@ -16,19 +13,15 @@ import org.springframework.web.bind.annotation.RestController; import javax.annotation.Resource; import javax.validation.Valid; -import java.util.List; @RestController public class ThirdUploadSetController { @Resource SyncUploadDataSetService syncUploadDataSetService; - @Resource - SyncUploadDataBustypeService syncUploadDataBustypeService; @AuthRuleAnnotation("system/third/syncData/config") @GetMapping("/system/third/syncData/config") public BaseResponse list() { - SyncUploadDataSetEntity syncDataSetResponse = syncUploadDataSetService.selectSet(); return ResultVOUtils.success(syncDataSetResponse); } @@ -37,11 +30,6 @@ public class ThirdUploadSetController { @PostMapping("/system/third/syncData/save") public BaseResponse save(@RequestBody @Valid SyncUploadDataSetEntity syncUploadDataSetEntity ) { - List busTypes = syncUploadDataSetEntity.getBusTypes(); - syncUploadDataBustypeService.deleteAll(); - if (CollUtil.isNotEmpty(busTypes)) - syncUploadDataBustypeService.inserts(busTypes); - syncUploadDataSetEntity.setBusTypes(null); boolean b = syncUploadDataSetService.insert(syncUploadDataSetEntity); if (!b) { return ResultVOUtils.error(ResultEnum.NOT_NETWORK); diff --git a/src/main/java/com/glxp/api/dao/thrsys/ThrOrderUploadBustypesMapper.java b/src/main/java/com/glxp/api/dao/thrsys/ThrOrderUploadBustypesMapper.java new file mode 100644 index 000000000..42a62e1eb --- /dev/null +++ b/src/main/java/com/glxp/api/dao/thrsys/ThrOrderUploadBustypesMapper.java @@ -0,0 +1,9 @@ +package com.glxp.api.dao.thrsys; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.glxp.api.entity.thrsys.ThrOrderUploadBustypesEntity; +import org.apache.ibatis.annotations.Mapper; + +@Mapper +public interface ThrOrderUploadBustypesMapper extends BaseMapper { +} diff --git a/src/main/java/com/glxp/api/entity/thrsys/ThrOrderUploadBustypesEntity.java b/src/main/java/com/glxp/api/entity/thrsys/ThrOrderUploadBustypesEntity.java index 783fb3b8b..0165f4833 100644 --- a/src/main/java/com/glxp/api/entity/thrsys/ThrOrderUploadBustypesEntity.java +++ b/src/main/java/com/glxp/api/entity/thrsys/ThrOrderUploadBustypesEntity.java @@ -4,62 +4,67 @@ import com.baomidou.mybatisplus.annotation.IdType; import com.baomidou.mybatisplus.annotation.TableField; import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableName; -import lombok.Data; +import java.io.Serializable; import java.util.Date; +import com.baomidou.mybatisplus.extension.handlers.FastjsonTypeHandler; +import lombok.Data; -/** - *

- * - *

- * - * @author 作者 - * @since 2023-01-13 - */ @Data -@TableName("thr_order_upload_bustypes") -public class ThrOrderUploadBustypesEntity { +@TableName(value = "thr_order_upload_bustypes") +public class ThrOrderUploadBustypesEntity implements Serializable { - @TableId(value = "id", type = IdType.AUTO) + @TableId(value = "id", type = IdType.INPUT) private Integer id; - @TableField("action") + @TableField(value = "`action`") private String action; - @TableField("name") + @TableField(value = "`name`") private String name; + /** + * 单据类型状态: 1:未审核;2:已审核;3:已确认 + */ + @TableField(value = "orderStatus") + private Integer orderStatus; + + /** + * 单据来源(数组) + */ + @TableField(value = "orderSource", typeHandler = FastjsonTypeHandler.class) + private String orderSource; + /** * 创建人 */ - @TableField("createUser") + @TableField(value = "`createUser`") private String createUser; /** * 创建时间 */ - @TableField("createTime") + @TableField(value = "createTime") private Date createTime; /** * 更新人 */ - @TableField("updateUser") + @TableField(value = "updateUser") private String updateUser; /** * 更新时间 */ - @TableField("updateTime") + @TableField(value = "updateTime") private Date updateTime; /** * 备注 */ - @TableField("remark") + @TableField(value = "remark") private String remark; - - + private static final long serialVersionUID = 1L; } diff --git a/src/main/java/com/glxp/api/http/ErpBasicClient.java b/src/main/java/com/glxp/api/http/ErpBasicClient.java index bbd0a1c27..c862eb87b 100644 --- a/src/main/java/com/glxp/api/http/ErpBasicClient.java +++ b/src/main/java/com/glxp/api/http/ErpBasicClient.java @@ -154,7 +154,6 @@ public class ErpBasicClient { /** * 上传文件到第三方接口服务，解析第三方系统产品信息并获取回调结果 * - * @param files * @param thirdSys * @return */ diff --git a/src/main/java/com/glxp/api/service/thrsys/ThrOrderUploadBustypesService.java b/src/main/java/com/glxp/api/service/thrsys/ThrOrderUploadBustypesService.java new file mode 100644 index 000000000..dd94da9e8 --- /dev/null +++ b/src/main/java/com/glxp/api/service/thrsys/ThrOrderUploadBustypesService.java @@ -0,0 +1,10 @@ +package com.glxp.api.service.thrsys; + +import org.springframework.stereotype.Service; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.glxp.api.dao.thrsys.ThrOrderUploadBustypesMapper; +import com.glxp.api.entity.thrsys.ThrOrderUploadBustypesEntity; +@Service +public class ThrOrderUploadBustypesService extends ServiceImpl { + +} diff --git a/src/main/resources/mybatis/mapper/thrsys/ThrOrderUploadBustypesMapper.xml b/src/main/resources/mybatis/mapper/thrsys/ThrOrderUploadBustypesMapper.xml new file mode 100644 index 000000000..6583cc3be --- /dev/null +++ b/src/main/resources/mybatis/mapper/thrsys/ThrOrderUploadBustypesMapper.xml @@ -0,0 +1,4 @@ + + + + From 1b0c8638b923a84bf68ccca0f3e62b7b03107e88 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=83=91=E6=98=8E=E6=A2=81?= <2429105222@qq.com> Date: Fri, 2 Jun 2023 10:52:01 +0800 Subject: [PATCH 2/5] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E7=BB=9F=E8=AE=A1?= =?UTF-8?q?=E6=B1=87=E6=80=BB=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../glxp/api/service/inout/impl/IoStatDayServiceImpl.java | 8 +++++--- .../api/service/inout/impl/IoStatMonthServiceImpl.java | 5 +++-- 2 files changed, 8 insertions(+), 5 deletions(-) diff --git a/src/main/java/com/glxp/api/service/inout/impl/IoStatDayServiceImpl.java b/src/main/java/com/glxp/api/service/inout/impl/IoStatDayServiceImpl.java index 22c8ba1da..dce76b334 100644 --- a/src/main/java/com/glxp/api/service/inout/impl/IoStatDayServiceImpl.java +++ b/src/main/java/com/glxp/api/service/inout/impl/IoStatDayServiceImpl.java @@ -96,7 +96,7 @@ public class IoStatDayServiceImpl implements IoStatDayService { ew.eq("month", twoDay.monthBaseOne()); ew.eq("day", twoDay.dayOfMonth()); List ioStatDayEntityList=statDayDao.selectList(ew); - List newOrOldDate=getNewOrOldDate(dataList,ioStatDayEntityList); + List newOrOldDate=getNewOrOldDate(dataList,ioStatDayEntityList,yesterday); dataList.addAll(newOrOldDate); //插入汇总记录 saveData(yesterday, dataList); @@ -229,7 +229,7 @@ public class IoStatDayServiceImpl implements IoStatDayService { private static QueryWrapper buildQueryWrapper(IoOrderDetailResultEntity orderDetailResultEntity, DateTime yesterday) { QueryWrapper wrapper = new QueryWrapper<>(); - DateTime dateTime = DateUtil.offsetDay(yesterday, -1); //取前天的时间 + DateTime dateTime =DateUtil.offsetDay(yesterday, -1); //取前天的时间 wrapper.eq("year", dateTime.year()) .eq("month", dateTime.monthBaseOne()) .eq("day", dateTime.dayOfMonth()) //取前天的数据 @@ -239,7 +239,7 @@ public class IoStatDayServiceImpl implements IoStatDayService { return wrapper; } - private List getNewOrOldDate(List newIoStatDayEntity, List oldIoStatDayEntity){ + private List getNewOrOldDate(List newIoStatDayEntity, List oldIoStatDayEntity,DateTime yesterday){ // 计算出两个集合之间产品批次号组成的差异 List IoStatDayEntityList = oldIoStatDayEntity.stream() @@ -252,10 +252,12 @@ public class IoStatDayServiceImpl implements IoStatDayService { }).collect(Collectors.toList()); for (IoStatDayEntity ioStatDayEntity : IoStatDayEntityList) { + DateTime twoDay = DateUtil.offsetDay(new Date(), -2); ioStatDayEntity.setId(null); ioStatDayEntity.setBeginCount(ioStatDayEntity.getBalanceCount()); ioStatDayEntity.setBalanceAmount(ioStatDayEntity.getBalanceAmount()); ioStatDayEntity.setBeginPrice(ioStatDayEntity.getBalancePrice()); + ioStatDayEntity.setDay(yesterday.dayOfMonth()); ioStatDayEntity.setInCount(0); ioStatDayEntity.setOutCount(0); } diff --git a/src/main/java/com/glxp/api/service/inout/impl/IoStatMonthServiceImpl.java b/src/main/java/com/glxp/api/service/inout/impl/IoStatMonthServiceImpl.java index 7b358c58e..1b5b02dac 100644 --- a/src/main/java/com/glxp/api/service/inout/impl/IoStatMonthServiceImpl.java +++ b/src/main/java/com/glxp/api/service/inout/impl/IoStatMonthServiceImpl.java @@ -101,7 +101,7 @@ public class IoStatMonthServiceImpl implements IoStatMonthService { ew.eq("quarter", twoDay.quarter()); ew.eq("month", twoDay.monthBaseOne()-2); List ioStatMonthEntityList=statMonthDao.selectList(ew); - List newOrOldDate=getNewOrOldDate(dataList,ioStatMonthEntityList); + List newOrOldDate=getNewOrOldDate(dataList,ioStatMonthEntityList,lastMonth); dataList.addAll(newOrOldDate); //插入汇总记录 @@ -257,7 +257,7 @@ public class IoStatMonthServiceImpl implements IoStatMonthService { return wrapper; } - private List getNewOrOldDate(List newIoStatDayEntity, List oldIoStatDayEntity) { + private List getNewOrOldDate(List newIoStatDayEntity, List oldIoStatDayEntity, DateTime lastMonth) { // 计算出两个集合之间产品批次号组成的差异 // List ioStatMonthEntityList = oldIoStatDayEntity.stream().filter(notComment -> { @@ -278,6 +278,7 @@ public class IoStatMonthServiceImpl implements IoStatMonthService { for (IoStatMonthEntity ioStatDayEntity : ioStatMonthEntityList) { ioStatDayEntity.setId(null); ioStatDayEntity.setBeginCount(ioStatDayEntity.getBalanceCount()); + ioStatDayEntity.setMonth(lastMonth.monthBaseOne()); ioStatDayEntity.setBalanceAmount(ioStatDayEntity.getBalanceAmount()); ioStatDayEntity.setBeginPrice(ioStatDayEntity.getBalancePrice()); ioStatDayEntity.setInCount(0); From 70c07845843efec81c0a529b40b97cfff4c0874d Mon Sep 17 00:00:00 2001 From: anthonywj Date: Sat, 3 Jun 2023 18:30:37 +0800 Subject: [PATCH 3/5] =?UTF-8?q?=E7=94=B3=E8=B4=AD=EF=BC=8C=E7=9B=B8?= =?UTF-8?q?=E5=85=B3=E6=9F=A5=E8=AF=A2=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../inout/IoOrderDetailBizController.java | 10 +- .../basic/CompanyProductRelevanceRequest.java | 2 +- .../FilterCompanyProductRelevanceRequest.java | 1 + .../service/basic/UdiRelevanceService.java | 3 +- .../basic/impl/UdiRelevanceServiceImpl.java | 12 +- .../glxp/api/service/sync/HeartService.java | 76 +++-- .../java/com/glxp/api/task/SyncHeartTask.java | 4 +- .../mybatis/mapper/basic/UdiRlSupDao.xml | 262 +++++++++--------- 8 files changed, 188 insertions(+), 182 deletions(-) diff --git a/src/main/java/com/glxp/api/controller/inout/IoOrderDetailBizController.java b/src/main/java/com/glxp/api/controller/inout/IoOrderDetailBizController.java index 89dc47d1b..3d96ab344 100644 --- a/src/main/java/com/glxp/api/controller/inout/IoOrderDetailBizController.java +++ b/src/main/java/com/glxp/api/controller/inout/IoOrderDetailBizController.java @@ -33,6 +33,7 @@ import com.glxp.api.req.inv.FilterInvoiceRequest; import com.glxp.api.req.system.DeleteRequest; import com.glxp.api.res.PageSimpleResponse; import com.glxp.api.res.basic.UdiRelevanceResponse; +import com.glxp.api.res.basic.UdiRlSupResponse; import com.glxp.api.res.inout.IoOrderDetailBizResponse; import com.glxp.api.res.inout.IoOrderDetailCodeResponse; import com.glxp.api.res.inout.IoOrderInvoiceResponse; @@ -291,9 +292,9 @@ public class IoOrderDetailBizController extends BaseController { for (ThrOrderDetailEntity thrOrderDetailEntity : thrOrderDetailEntities) { thrOrderDetailEntity.getProductId(); - List udiRelevanceEntities = udiRelevanceService.selectListByThirdId(thrOrderDetailEntity.getProductId(), thrOrderEntity.getThirdSysFk()); + List udiRelevanceEntities = udiRelevanceService.selectListByThirdId(thrOrderDetailEntity.getProductId(), thrOrderEntity.getThirdSysFk()); IoOrderDetailBizEntity ioOrderDetailBizEntity = new IoOrderDetailBizEntity(); - UdiRelevanceResponse udiRelevanceResponse = null; + UdiRlSupResponse udiRelevanceResponse = null; if (udiRelevanceEntities.size() == 1) { udiRelevanceResponse = udiRelevanceEntities.get(0); ioOrderDetailBizEntity.setBindRlFk(udiRelevanceResponse.getId()); @@ -305,7 +306,8 @@ public class IoOrderDetailBizController extends BaseController { ioOrderDetailBizEntity.setManufacturer(udiRelevanceResponse.getManufactory()); ioOrderDetailBizEntity.setMeasname(udiRelevanceResponse.getMeasname()); ioOrderDetailBizEntity.setSpec(udiRelevanceResponse.getGgxh()); - ioOrderDetailBizEntity.setPrice(udiRelevanceResponse.getPrice()); + ioOrderDetailBizEntity.setPrice(BigDecimal.valueOf(Double.valueOf(udiRelevanceResponse.getPrice()))); + ioOrderDetailBizEntity.setSupId(udiRelevanceResponse.getCustomerId() + ""); } else { ioOrderDetailBizEntity.setCoName(thrOrderDetailEntity.getCorpName()); ioOrderDetailBizEntity.setCertCode(thrOrderDetailEntity.getZczbhhzbapzbh()); @@ -316,7 +318,7 @@ public class IoOrderDetailBizController extends BaseController { if (udiRelevanceEntities.size() > 1) { String bindRlIds = ""; - for (UdiRelevanceResponse temp : udiRelevanceEntities) { + for (UdiRlSupResponse temp : udiRelevanceEntities) { bindRlIds = bindRlIds + "," + temp.getId(); } ioOrderDetailBizEntity.setBindRlIds(bindRlIds.substring(1)); diff --git a/src/main/java/com/glxp/api/req/basic/CompanyProductRelevanceRequest.java b/src/main/java/com/glxp/api/req/basic/CompanyProductRelevanceRequest.java index 660258bb8..af69a4e51 100644 --- a/src/main/java/com/glxp/api/req/basic/CompanyProductRelevanceRequest.java +++ b/src/main/java/com/glxp/api/req/basic/CompanyProductRelevanceRequest.java @@ -35,7 +35,6 @@ public class CompanyProductRelevanceRequest extends ListPageRequest { private String thrPiId; - private Boolean isCheck; private Integer filterType; //0:全部，1.对照完成，2.未对照DI，3.未对照产品编码，4.未对照其他产品编码 @@ -52,5 +51,6 @@ public class CompanyProductRelevanceRequest extends ListPageRequest { private String corpId; private String billType; + private String flbm; private List uuids; } diff --git a/src/main/java/com/glxp/api/req/basic/FilterCompanyProductRelevanceRequest.java b/src/main/java/com/glxp/api/req/basic/FilterCompanyProductRelevanceRequest.java index 31467b965..3a93d2df0 100644 --- a/src/main/java/com/glxp/api/req/basic/FilterCompanyProductRelevanceRequest.java +++ b/src/main/java/com/glxp/api/req/basic/FilterCompanyProductRelevanceRequest.java @@ -13,4 +13,5 @@ public class FilterCompanyProductRelevanceRequest extends ListPageRequest { private String unitFk; private String lastUpdateTime; private String key; + private String flbm; } diff --git a/src/main/java/com/glxp/api/service/basic/UdiRelevanceService.java b/src/main/java/com/glxp/api/service/basic/UdiRelevanceService.java index decf0ac92..24980fd0e 100644 --- a/src/main/java/com/glxp/api/service/basic/UdiRelevanceService.java +++ b/src/main/java/com/glxp/api/service/basic/UdiRelevanceService.java @@ -5,6 +5,7 @@ import com.baomidou.mybatisplus.extension.service.IService; import com.glxp.api.entity.basic.UdiRelevanceEntity; import com.glxp.api.req.basic.FilterUdiRelRequest; import com.glxp.api.res.basic.UdiRelevanceResponse; +import com.glxp.api.res.basic.UdiRlSupResponse; import java.util.List; @@ -71,7 +72,7 @@ public interface UdiRelevanceService extends IService { UdiRelevanceEntity selectByThirdId(String thirdId, String thirdSys); - List selectListByThirdId(String thirdId, String thirdSys); + List selectListByThirdId(String thirdId, String thirdSys); boolean insertUdiRelevance(UdiRelevanceEntity udiRelevanceEntity); diff --git a/src/main/java/com/glxp/api/service/basic/impl/UdiRelevanceServiceImpl.java b/src/main/java/com/glxp/api/service/basic/impl/UdiRelevanceServiceImpl.java index 0fc11ca77..8ab21f504 100644 --- a/src/main/java/com/glxp/api/service/basic/impl/UdiRelevanceServiceImpl.java +++ b/src/main/java/com/glxp/api/service/basic/impl/UdiRelevanceServiceImpl.java @@ -9,9 +9,12 @@ import com.glxp.api.dao.basic.UdiRelevanceDao; import com.glxp.api.entity.basic.UdiEntity; import com.glxp.api.entity.basic.UdiRelevanceEntity; import com.glxp.api.entity.thrsys.ThrSystemEntity; +import com.glxp.api.req.basic.CompanyProductRelevanceRequest; import com.glxp.api.req.basic.FilterUdiRelRequest; import com.glxp.api.res.basic.UdiRelevanceResponse; +import com.glxp.api.res.basic.UdiRlSupResponse; import com.glxp.api.service.basic.UdiRelevanceService; +import com.glxp.api.service.basic.UdiRlSupService; import com.glxp.api.service.thrsys.ThrSystemService; import com.glxp.api.util.udi.FilterUdiUtils; import org.springframework.stereotype.Service; @@ -27,6 +30,8 @@ public class UdiRelevanceServiceImpl extends ServiceImpl selectListByThirdId(String thirdId, String thirdSys) { + public List selectListByThirdId(String thirdId, String thirdSys) { if (StrUtil.isEmpty(thirdId) || StrUtil.isEmpty(thirdSys)) { return null; } - FilterUdiRelRequest filterUdiRelRequest = new FilterUdiRelRequest(); + CompanyProductRelevanceRequest filterUdiRelRequest = new CompanyProductRelevanceRequest(); if ("thirdId".equals(thirdSys)) { filterUdiRelRequest.setThirdId(thirdId); } else if ("thirdId1".equals(thirdSys)) { @@ -337,7 +342,8 @@ public class UdiRelevanceServiceImpl extends ServiceImpl data = udiRelevanceDao.filterUdiGp(filterUdiRelRequest); + filterUdiRelRequest.setDiType(1); + List data = udiRlSupService.filterUdiGp(filterUdiRelRequest); return data; } diff --git a/src/main/java/com/glxp/api/service/sync/HeartService.java b/src/main/java/com/glxp/api/service/sync/HeartService.java index 20bf45edc..c910cc422 100644 --- a/src/main/java/com/glxp/api/service/sync/HeartService.java +++ b/src/main/java/com/glxp/api/service/sync/HeartService.java @@ -1327,7 +1327,6 @@ public class HeartService { }); if (response.getCode() == 20000 && response.getData() != null) { - JSONArray fileJson = JSONUtil.parseObj(response.getData()).getJSONArray("syncFiles"); SpsSyncOrderResponse syncDataResponse = JSONObject.parseObject(response.getData(), new TypeReference() { }); @@ -1342,54 +1341,47 @@ public class HeartService { basicDownloadStatusEntity.setRemark(syncDataResponse.getSyncRemark()); basicDownloadStatusEntity.setScheduleType(1); basicDownloadService.insertDownloadStatus(basicDownloadStatusEntity); - if (CollUtil.isNotEmpty(syncDataResponse.getOrderEntities())) { - try { - List orderEntities = syncDataResponse.getOrderEntities(); - for (IoOrderEntity orderEntity : orderEntities) { - SyncDataBustypeEntity syncDataBustypeEntity = syncDataBustypeService.findByAction(orderEntity.getAction(), 2); - orderEntity.setUpdateTime(null); - orderEntity.setFromType(ConstantStatus.FROM_UDISP); - orderEntity.setProcessStatus(ConstantStatus.ORDER_DEAL_POST); - orderEntity.setOrderType(ConstantStatus.ORDER_TYPE_SCAN); - orderEntity.setStatus(ConstantStatus.ORDER_STATUS_PROCESS); - if (syncDataBustypeEntity != null) { - if (syncDataBustypeEntity.getSyncStatus() != null && syncDataBustypeEntity.getSyncStatus().compareTo(1) == 0) { - orderEntity.setProcessStatus(ConstantStatus.ORDER_DEAL_DRAFT); - orderEntity.setStatus(ConstantStatus.ORDER_STATUS_TEMP_SAVE); - } - if (syncDataBustypeEntity.isSyncChange()) { - orderEntity.setOutChangeEnable(syncDataBustypeEntity.isSyncChange()); - } + List orderEntities = syncDataResponse.getOrderEntities(); + for (IoOrderEntity orderEntity : orderEntities) { + SyncDataBustypeEntity syncDataBustypeEntity = syncDataBustypeService.findByAction(orderEntity.getAction(), 2); + orderEntity.setUpdateTime(null); + orderEntity.setFromType(ConstantStatus.FROM_UDISP); + orderEntity.setProcessStatus(ConstantStatus.ORDER_DEAL_POST); + orderEntity.setOrderType(ConstantStatus.ORDER_TYPE_SCAN); + orderEntity.setStatus(ConstantStatus.ORDER_STATUS_PROCESS); + if (syncDataBustypeEntity != null) { + if (syncDataBustypeEntity.getSyncStatus() != null && syncDataBustypeEntity.getSyncStatus().compareTo(1) == 0) { + orderEntity.setProcessStatus(ConstantStatus.ORDER_DEAL_DRAFT); + orderEntity.setStatus(ConstantStatus.ORDER_STATUS_TEMP_SAVE); + } + if (syncDataBustypeEntity.isSyncChange()) { + orderEntity.setOutChangeEnable(syncDataBustypeEntity.isSyncChange()); } - IoOrderEntity temp = orderService.findByBillNo(orderEntity.getBillNo()); - if (temp == null) { - orderEntity.setId(null); - orderService.insertOrder(orderEntity); - insetOrderDb(syncDataResponse, orderEntity); + } + IoOrderEntity temp = orderService.findByBillNo(orderEntity.getBillNo()); + if (temp == null) { + orderEntity.setId(null); + orderService.insertOrder(orderEntity); + insetOrderDb(syncDataResponse, orderEntity); + orderEntity = orderService.findByBillNo(orderEntity.getBillNo()); + if (orderEntity.getStatus() != ConstantStatus.ORDER_STATUS_TEMP_SAVE) { + addInoutService.dealProcess(orderEntity); orderEntity = orderService.findByBillNo(orderEntity.getBillNo()); - if (orderEntity.getStatus() != ConstantStatus.ORDER_STATUS_TEMP_SAVE) { - addInoutService.dealProcess(orderEntity); - orderEntity = orderService.findByBillNo(orderEntity.getBillNo()); - if (orderEntity.getStatus() != ConstantStatus.ORDER_STATS_ERROR && !ioCheckInoutService.checkManual(orderEntity.getBillNo())) { - ioCheckInoutService.check(orderEntity.getBillNo()); - } + if (orderEntity.getStatus() != ConstantStatus.ORDER_STATS_ERROR && !ioCheckInoutService.checkManual(orderEntity.getBillNo())) { + ioCheckInoutService.check(orderEntity.getBillNo()); } - } else { - updateOrderDb(syncDataResponse, orderEntity); } + } else { + updateOrderDb(syncDataResponse, orderEntity); } - if (fileJson != null && fileJson.size() > 0) { - List syncFiles = fileJson.toList(String.class); - if (CollUtil.isNotEmpty(syncFiles)) { - idcService.batchDownloadFile(spGetHttp.getIpUrl(), syncFiles.toArray(new String[syncFiles.size()])); - } + } + if (fileJson != null && fileJson.size() > 0) { + List syncFiles = fileJson.toList(String.class); + if (CollUtil.isNotEmpty(syncFiles)) { + idcService.batchDownloadFile(spGetHttp.getIpUrl(), syncFiles.toArray(new String[syncFiles.size()])); } - } catch (Exception e) { - e.printStackTrace(); } - - } spGetHttp.finishTask(basicExportStatusEntity.getId()); basicDownloadStatusEntity.setUpdateTime(new Date()); @@ -1867,7 +1859,7 @@ public class HeartService { List orderInvoiceEntities = syncDataResponse.getOrderInvoiceEntities(); for (IoOrderInvoiceEntity orderInvoiceEntity : orderInvoiceEntities) { if (orderInvoiceEntity.getOrderIdFk().equals(orderEntity.getBillNo())) { - orderInvoiceService.insertInvoice(orderInvoiceEntity); + ioOrderInvoiceMapper.insertOrUpdate(orderInvoiceEntity); } } } diff --git a/src/main/java/com/glxp/api/task/SyncHeartTask.java b/src/main/java/com/glxp/api/task/SyncHeartTask.java index 221619653..3c288962a 100644 --- a/src/main/java/com/glxp/api/task/SyncHeartTask.java +++ b/src/main/java/com/glxp/api/task/SyncHeartTask.java @@ -20,8 +20,8 @@ import javax.annotation.Resource; import java.util.Arrays; -//@Component -//@EnableScheduling +@Component +@EnableScheduling public class SyncHeartTask implements SchedulingConfigurer { final Logger logger = LoggerFactory.getLogger(SyncHeartTask.class); diff --git a/src/main/resources/mybatis/mapper/basic/UdiRlSupDao.xml b/src/main/resources/mybatis/mapper/basic/UdiRlSupDao.xml index 7d42be1e4..f4a92c765 100644 --- a/src/main/resources/mybatis/mapper/basic/UdiRlSupDao.xml +++ b/src/main/resources/mybatis/mapper/basic/UdiRlSupDao.xml @@ -30,88 +30,88 @@ @@ -239,7 +243,7 @@ SELECT * FROM company_product_relevance where udiRlIdFk = #{udiRlIdFk} - and customerId = #{customerId} + and customerId = #{customerId} @@ -289,45 +293,45 @@ replace - INTO company_product_relevance(id,customerId, productId, enterpriseId, registrationId, - createTime, updateTime, auditStatus, productUuid, udiRlIdFk, unitFk, - price, createUser, updateUser) - values (#{id},#{customerId}, - #{productId}, - #{enterpriseId}, - #{registrationId}, - #{createTime}, - #{updateTime}, - #{auditStatus}, - #{productUuid}, - #{udiRlIdFk}, - #{unitFk}, - #{price}, - #{createUser}, - #{updateUser}) + INTO company_product_relevance(id, customerId, productId, enterpriseId, registrationId, + createTime, updateTime, auditStatus, productUuid, udiRlIdFk, unitFk, + price, createUser, updateUser) + values (#{id}, #{customerId}, + #{productId}, + #{enterpriseId}, + #{registrationId}, + #{createTime}, + #{updateTime}, + #{auditStatus}, + #{productUuid}, + #{udiRlIdFk}, + #{unitFk}, + #{price}, + #{createUser}, + #{updateUser}) replace - INTO company_product_relevance(id, customerId, productId, enterpriseId, registrationId, - createTime, updateTime, auditStatus, productUuid, udiRlIdFk, unitFk, - price, createUser, updateUser) + INTO company_product_relevance(id, customerId, productId, enterpriseId, registrationId, + createTime, updateTime, auditStatus, productUuid, udiRlIdFk, unitFk, + price, createUser, updateUser) values (#{id}, - #{customerId}, - #{productId}, - #{enterpriseId}, - #{registrationId}, - #{createTime}, - #{updateTime}, - #{auditStatus}, - #{productUuid}, - #{udiRlIdFk}, - #{unitFk}, - #{price}, - #{createUser}, - #{updateUser}) + #{customerId}, + #{productId}, + #{enterpriseId}, + #{registrationId}, + #{createTime}, + #{updateTime}, + #{auditStatus}, + #{productUuid}, + #{udiRlIdFk}, + #{unitFk}, + #{price}, + #{createUser}, + #{updateUser}) @@ -358,9 +362,9 @@