diff --git a/api-admin/src/main/java/com/glxp/api/admin/controller/inout/WareHouseController.java b/api-admin/src/main/java/com/glxp/api/admin/controller/inout/WareHouseController.java index 598b3c3e..48b7d325 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/controller/inout/WareHouseController.java +++ b/api-admin/src/main/java/com/glxp/api/admin/controller/inout/WareHouseController.java @@ -220,7 +220,7 @@ public class WareHouseController { BussinessTypeEntity bussinessTypeEntity = bussinessTypeService.findBTByAction(addOrderRequest.getAction()); orderSaveRequest.setMainAction(bussinessTypeEntity.getMainAction()); - + orderSaveRequest.setLocStorageCode(addOrderRequest.getLocStorageCode()); orderSaveRequest.setAction(addOrderRequest.getAction()); orderSaveRequest.setActor(addOrderRequest.getActor()); orderSaveRequest.setCorpOrderId(addOrderRequest.getCorpOrderId()); @@ -261,6 +261,7 @@ public class WareHouseController { warehouseEntity.setBatchNo(udiEntity.getBatchNo()); warehouseEntity.setProduceDate(udiEntity.getProduceDate()); warehouseEntity.setExpireDate(udiEntity.getExpireDate()); + warehouseEntity.setLocStorageCode(addOrderRequest.getLocStorageCode()); warehouseEntity.setSerialNo(udiEntity.getSerialNo()); warehouseEntity.setCount(1); List warehouseEntityList = new ArrayList<>(); diff --git a/api-admin/src/main/java/com/glxp/api/admin/controller/inventory/InvWarehouseController.java b/api-admin/src/main/java/com/glxp/api/admin/controller/inventory/InvWarehouseController.java new file mode 100644 index 00000000..97de9dd7 --- /dev/null +++ b/api-admin/src/main/java/com/glxp/api/admin/controller/inventory/InvWarehouseController.java @@ -0,0 +1,116 @@ +package com.glxp.api.admin.controller.inventory; + +import com.glxp.api.admin.entity.inventory.InvWarehouseEntity; +import com.glxp.api.admin.req.inout.DeleteRequest; +import com.glxp.api.admin.req.inventory.FilterInvWarehouseRequest; +import com.glxp.api.admin.res.inventory.InvWarehouseResponse; +import com.glxp.api.admin.service.inventory.InvWarehouseService; +import com.glxp.api.common.enums.ResultEnum; +import com.glxp.api.common.res.BaseResponse; +import com.glxp.api.common.util.ResultVOUtils; +import org.springframework.beans.BeanUtils; +import org.springframework.validation.BindingResult; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RestController; + +import javax.annotation.Resource; +import javax.validation.Valid; +import java.util.ArrayList; +import java.util.HashMap; +import java.util.List; +import java.util.Map; + +@RestController +public class InvWarehouseController { + + @Resource + InvWarehouseService invWarehouseService; + + @GetMapping("spms/inv/warehouse/filter") + public BaseResponse filterInvWarehouse(FilterInvWarehouseRequest filterInvWarehouseRequest) { + List invWarehouseEntities = invWarehouseService.filterInvWarehouse(filterInvWarehouseRequest); + List merge = merge(invWarehouseEntities, 0); + + Map restMap = new HashMap<>(); + restMap.put("list", merge); + return ResultVOUtils.success(restMap); + } + + @GetMapping("spms/inv/warehouse/filterAll") + public BaseResponse filterAllInvWarehouse(FilterInvWarehouseRequest filterInvWarehouseRequest) { + filterInvWarehouseRequest.setPid(0); + List invWarehouseEntities = invWarehouseService.filterInvWarehouse(filterInvWarehouseRequest); + return ResultVOUtils.success(invWarehouseEntities); + } + + public List merge(List invWarehouseEntities, + Integer pid) { + List invWarehouseResponses = new ArrayList<>(); + for (InvWarehouseEntity invWarehouseEntity : invWarehouseEntities) { + InvWarehouseResponse invWarehouseResponse = new InvWarehouseResponse(); + BeanUtils.copyProperties(invWarehouseEntity, invWarehouseResponse); + if (pid.equals(invWarehouseEntity.getPid())) { + invWarehouseResponse.setChildren(merge(invWarehouseEntities, invWarehouseEntity.getId())); + invWarehouseResponses.add(invWarehouseResponse); + } + } + return invWarehouseResponses; + } + + + @PostMapping("/spms/inv/warehouse/save") + public BaseResponse save(@RequestBody @Valid InvWarehouseEntity invWarehouseEntity, + BindingResult bindingResult) { + + if (bindingResult.hasErrors()) { + return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage()); + } + + if (invWarehouseEntity.getPid() == null) { + invWarehouseEntity.setPid(0); // 默认设置 + } + + boolean b = invWarehouseService.insertInvWarehouse(invWarehouseEntity); + if (!b) { + return ResultVOUtils.error(ResultEnum.NOT_NETWORK); + } + + return ResultVOUtils.success("添加成功!"); + } + + @PostMapping("/spms/inv/warehouse/edit") + public BaseResponse edit(@RequestBody @Valid InvWarehouseEntity invWarehouseEntity, + BindingResult bindingResult) { + + if (bindingResult.hasErrors()) { + return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage()); + } + if (invWarehouseEntity.getId() == null) { + return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL); + } + invWarehouseEntity.setPid(null); // 不能修改父级 pid + boolean b = invWarehouseService.updateInvWarehouse(invWarehouseEntity); + if (!b) { + return ResultVOUtils.error(ResultEnum.NOT_NETWORK); + } + + return ResultVOUtils.success(); + } + + @PostMapping("/spms/inv/warehouse/delete") + public BaseResponse delete(@RequestBody DeleteRequest deleteRequest) { + + if (deleteRequest.getId() == null) { + return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL); + } + boolean b = invWarehouseService.deleteById(deleteRequest.getId()); + if (!b) { + return ResultVOUtils.error(ResultEnum.NOT_NETWORK); + } + return ResultVOUtils.success(); + } + + +} diff --git a/api-admin/src/main/java/com/glxp/api/admin/dao/inventory/InvWarehouseDao.java b/api-admin/src/main/java/com/glxp/api/admin/dao/inventory/InvWarehouseDao.java new file mode 100644 index 00000000..9a25d5b8 --- /dev/null +++ b/api-admin/src/main/java/com/glxp/api/admin/dao/inventory/InvWarehouseDao.java @@ -0,0 +1,23 @@ +package com.glxp.api.admin.dao.inventory; + +import com.glxp.api.admin.entity.inventory.InvWarehouseEntity; +import com.glxp.api.admin.req.inventory.FilterInvWarehouseRequest; +import org.apache.ibatis.annotations.Param; + +import java.util.List; + +public interface InvWarehouseDao { + + List filterInvWarehouse(FilterInvWarehouseRequest filterInvWarehouseRequest); + + List filterGroupInvWarehouse(FilterInvWarehouseRequest filterInvWarehouseRequest); + + boolean insertInvWarehouse(InvWarehouseEntity InvWarehouseEntity); + + boolean updateInvWarehouse(InvWarehouseEntity InvWarehouseEntity); + + InvWarehouseEntity selectById(@Param("id") String id); + + boolean deleteById(@Param("id") String id); + +} diff --git a/api-admin/src/main/java/com/glxp/api/admin/entity/basic/BussinessLocalTypeEntity.java b/api-admin/src/main/java/com/glxp/api/admin/entity/basic/BussinessLocalTypeEntity.java index 83a2c1fd..61934499 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/entity/basic/BussinessLocalTypeEntity.java +++ b/api-admin/src/main/java/com/glxp/api/admin/entity/basic/BussinessLocalTypeEntity.java @@ -15,4 +15,6 @@ public class BussinessLocalTypeEntity { private Boolean checkEnable; private Boolean advanceType; private Boolean changeEnable; + private int corpType; + private boolean genUnit; } diff --git a/api-admin/src/main/java/com/glxp/api/admin/entity/basic/BussinessTypeEntity.java b/api-admin/src/main/java/com/glxp/api/admin/entity/basic/BussinessTypeEntity.java index 6814a9f7..82d3c091 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/entity/basic/BussinessTypeEntity.java +++ b/api-admin/src/main/java/com/glxp/api/admin/entity/basic/BussinessTypeEntity.java @@ -37,4 +37,6 @@ public class BussinessTypeEntity { private boolean secCheckSp; private Integer index; + + private int corpType; } diff --git a/api-admin/src/main/java/com/glxp/api/admin/entity/business/StockOrderEntity.java b/api-admin/src/main/java/com/glxp/api/admin/entity/business/StockOrderEntity.java index a95a86d3..cff535ce 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/entity/business/StockOrderEntity.java +++ b/api-admin/src/main/java/com/glxp/api/admin/entity/business/StockOrderEntity.java @@ -27,4 +27,5 @@ public class StockOrderEntity { private String thirdOrderFk; private String orderIdFk; private BigDecimal totalPrice; + private String locStorageCode; } diff --git a/api-admin/src/main/java/com/glxp/api/admin/entity/business/StockOrderPrintEntity.java b/api-admin/src/main/java/com/glxp/api/admin/entity/business/StockOrderPrintEntity.java index 7b12eb64..a4a14cf8 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/entity/business/StockOrderPrintEntity.java +++ b/api-admin/src/main/java/com/glxp/api/admin/entity/business/StockOrderPrintEntity.java @@ -20,4 +20,5 @@ public class StockOrderPrintEntity extends StockOrderDetailEntity { private String printStatus; private String unitIdFk; private String customerId; + private String locStorageCode; } diff --git a/api-admin/src/main/java/com/glxp/api/admin/entity/inout/OrderEntity.java b/api-admin/src/main/java/com/glxp/api/admin/entity/inout/OrderEntity.java index 4d45583d..fcbc72bf 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/entity/inout/OrderEntity.java +++ b/api-admin/src/main/java/com/glxp/api/admin/entity/inout/OrderEntity.java @@ -21,4 +21,5 @@ public class OrderEntity { private Integer signStatus; private String stockCheckFk; private String remark; + private String locStorageCode; } diff --git a/api-admin/src/main/java/com/glxp/api/admin/entity/inout/WarehouseEntity.java b/api-admin/src/main/java/com/glxp/api/admin/entity/inout/WarehouseEntity.java index ce0b21e4..c8928c9b 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/entity/inout/WarehouseEntity.java +++ b/api-admin/src/main/java/com/glxp/api/admin/entity/inout/WarehouseEntity.java @@ -26,4 +26,5 @@ public class WarehouseEntity { private String relId; private Integer status; private String supId; + private String locStorageCode; } diff --git a/api-admin/src/main/java/com/glxp/api/admin/entity/inventory/InvWarehouseEntity.java b/api-admin/src/main/java/com/glxp/api/admin/entity/inventory/InvWarehouseEntity.java new file mode 100644 index 00000000..5fac13d0 --- /dev/null +++ b/api-admin/src/main/java/com/glxp/api/admin/entity/inventory/InvWarehouseEntity.java @@ -0,0 +1,22 @@ +package com.glxp.api.admin.entity.inventory; + +import lombok.Data; + +import java.util.Date; + +@Data +public class InvWarehouseEntity { + + + private Integer id; + private Integer pid; + private String code; + private String name; + private Boolean advanceType; + private Boolean isDefault; + private Integer status; + private Date updateTime; + private String remark; + + +} diff --git a/api-admin/src/main/java/com/glxp/api/admin/req/basic/BasicUnitMaintainFilterRequest.java b/api-admin/src/main/java/com/glxp/api/admin/req/basic/BasicUnitMaintainFilterRequest.java index c53e9c7b..5d4929d5 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/req/basic/BasicUnitMaintainFilterRequest.java +++ b/api-admin/src/main/java/com/glxp/api/admin/req/basic/BasicUnitMaintainFilterRequest.java @@ -24,7 +24,7 @@ public class BasicUnitMaintainFilterRequest extends ListPageRequest { private Boolean isDownThrSys; List thrCorpEntities; - private int corpType; + private Integer corpType; private String unitId; diff --git a/api-admin/src/main/java/com/glxp/api/admin/req/inout/AddOrderRequest.java b/api-admin/src/main/java/com/glxp/api/admin/req/inout/AddOrderRequest.java index 8d9f70d2..1089f5c9 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/req/inout/AddOrderRequest.java +++ b/api-admin/src/main/java/com/glxp/api/admin/req/inout/AddOrderRequest.java @@ -14,7 +14,7 @@ public class AddOrderRequest { private String fromType; private String actDate; private String billType; - + private String locStorageCode; private String orderId; private String customerId; } diff --git a/api-admin/src/main/java/com/glxp/api/admin/req/inout/WarehouseQueryRequest.java b/api-admin/src/main/java/com/glxp/api/admin/req/inout/WarehouseQueryRequest.java index e2c6951e..becdc367 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/req/inout/WarehouseQueryRequest.java +++ b/api-admin/src/main/java/com/glxp/api/admin/req/inout/WarehouseQueryRequest.java @@ -13,4 +13,5 @@ public class WarehouseQueryRequest extends ListPageRequest { private String orderId; private String nameCode; private String supId; + private String locStorageCode; } diff --git a/api-admin/src/main/java/com/glxp/api/admin/req/inout/WarehouseSaveRequest.java b/api-admin/src/main/java/com/glxp/api/admin/req/inout/WarehouseSaveRequest.java index 04e50a5c..5788576e 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/req/inout/WarehouseSaveRequest.java +++ b/api-admin/src/main/java/com/glxp/api/admin/req/inout/WarehouseSaveRequest.java @@ -16,4 +16,5 @@ public class WarehouseSaveRequest { private String fromCorpId; private long id; private String fromCorp; + private String locStorageCode; } diff --git a/api-admin/src/main/java/com/glxp/api/admin/req/inventory/FilterInvWarehouseRequest.java b/api-admin/src/main/java/com/glxp/api/admin/req/inventory/FilterInvWarehouseRequest.java new file mode 100644 index 00000000..cf6d9da4 --- /dev/null +++ b/api-admin/src/main/java/com/glxp/api/admin/req/inventory/FilterInvWarehouseRequest.java @@ -0,0 +1,19 @@ +package com.glxp.api.admin.req.inventory; + +import com.glxp.api.admin.req.ListPageRequest; +import lombok.Data; + +import java.util.Date; + +@Data +public class FilterInvWarehouseRequest extends ListPageRequest { + + private Integer id; + private Integer pid; + private String code; + private String name; + private Boolean advanceType; + private Boolean isDefault; + private Date updateTime; + private String key; +} diff --git a/api-admin/src/main/java/com/glxp/api/admin/res/inventory/InvWarehouseResponse.java b/api-admin/src/main/java/com/glxp/api/admin/res/inventory/InvWarehouseResponse.java new file mode 100644 index 00000000..44089f13 --- /dev/null +++ b/api-admin/src/main/java/com/glxp/api/admin/res/inventory/InvWarehouseResponse.java @@ -0,0 +1,24 @@ +package com.glxp.api.admin.res.inventory; + +import lombok.Data; + +import java.util.Date; +import java.util.List; + +@Data +public class InvWarehouseResponse { + + + private Integer id; + private Integer pid; + private String code; + private String name; + private Boolean advanceType; + private Boolean isDefault; + private Integer status; + private Date updateTime; + private String remark; + + private List children; + +} diff --git a/api-admin/src/main/java/com/glxp/api/admin/service/inventory/InvWarehouseService.java b/api-admin/src/main/java/com/glxp/api/admin/service/inventory/InvWarehouseService.java new file mode 100644 index 00000000..dfe8dd28 --- /dev/null +++ b/api-admin/src/main/java/com/glxp/api/admin/service/inventory/InvWarehouseService.java @@ -0,0 +1,28 @@ +package com.glxp.api.admin.service.inventory; + + +import com.glxp.api.admin.entity.inventory.InvWarehouseEntity; +import com.glxp.api.admin.req.inventory.FilterInvWarehouseRequest; + +import java.util.List; + +public interface InvWarehouseService { + + + InvWarehouseEntity findDefault(Boolean advaceType, Boolean isDefault); + + List filterInvWarehouse(FilterInvWarehouseRequest filterInvWarehouseRequest); + + List filterGroupInvWarehouse(FilterInvWarehouseRequest filterInvWarehouseRequest); + + boolean insertInvWarehouse(InvWarehouseEntity invWarehouseEntity); + + boolean updateInvWarehouse(InvWarehouseEntity invWarehouseEntity); + + InvWarehouseEntity selectById(String id); + + InvWarehouseEntity selectByCode(String code); + + boolean deleteById(String id); + +} diff --git a/api-admin/src/main/java/com/glxp/api/admin/service/inventory/impl/InvWarehouseServiceImpl.java b/api-admin/src/main/java/com/glxp/api/admin/service/inventory/impl/InvWarehouseServiceImpl.java new file mode 100644 index 00000000..02c984a8 --- /dev/null +++ b/api-admin/src/main/java/com/glxp/api/admin/service/inventory/impl/InvWarehouseServiceImpl.java @@ -0,0 +1,88 @@ +package com.glxp.api.admin.service.inventory.impl; + +import com.github.pagehelper.PageHelper; +import com.glxp.api.admin.dao.inventory.InvWarehouseDao; +import com.glxp.api.admin.entity.inventory.InvWarehouseEntity; +import com.glxp.api.admin.req.inventory.FilterInvWarehouseRequest; +import com.glxp.api.admin.service.inventory.InvWarehouseService; +import org.springframework.stereotype.Service; + +import javax.annotation.Resource; +import java.util.Collections; +import java.util.List; + +@Service +public class InvWarehouseServiceImpl implements InvWarehouseService { + + + @Resource + InvWarehouseDao invWarehouseDao; + + @Override + public InvWarehouseEntity findDefault(Boolean advaceType, Boolean isDefault) { + + FilterInvWarehouseRequest filterInvWarehouseRequest = new FilterInvWarehouseRequest(); + filterInvWarehouseRequest.setIsDefault(isDefault); + filterInvWarehouseRequest.setAdvanceType(advaceType); + List invWarehouseEntities = invWarehouseDao.filterInvWarehouse(filterInvWarehouseRequest); + if (invWarehouseEntities != null && invWarehouseEntities.size() > 0) + return invWarehouseEntities.get(0); + return null; + } + + @Override + public List filterInvWarehouse(FilterInvWarehouseRequest filterInvWarehouseRequest) { + if (filterInvWarehouseRequest == null) { + return Collections.emptyList(); + } + if (filterInvWarehouseRequest.getPage() != null) { + int offset = (filterInvWarehouseRequest.getPage() - 1) * filterInvWarehouseRequest.getLimit(); + PageHelper.offsetPage(offset, filterInvWarehouseRequest.getLimit()); + } + List data = invWarehouseDao.filterInvWarehouse(filterInvWarehouseRequest); + return data; + } + + @Override + public List filterGroupInvWarehouse(FilterInvWarehouseRequest filterInvWarehouseRequest) { + if (filterInvWarehouseRequest == null) { + return Collections.emptyList(); + } + if (filterInvWarehouseRequest.getPage() != null) { + int offset = (filterInvWarehouseRequest.getPage() - 1) * filterInvWarehouseRequest.getLimit(); + PageHelper.offsetPage(offset, filterInvWarehouseRequest.getLimit()); + } + List data = invWarehouseDao.filterGroupInvWarehouse(filterInvWarehouseRequest); + return data; + } + + @Override + public boolean insertInvWarehouse(InvWarehouseEntity invWarehouseEntity) { + return invWarehouseDao.insertInvWarehouse(invWarehouseEntity); + } + + @Override + public boolean updateInvWarehouse(InvWarehouseEntity invWarehouseEntity) { + return invWarehouseDao.updateInvWarehouse(invWarehouseEntity); + } + + @Override + public InvWarehouseEntity selectById(String id) { + return invWarehouseDao.selectById(id); + } + + @Override + public InvWarehouseEntity selectByCode(String code) { + FilterInvWarehouseRequest filterInvWarehouseRequest = new FilterInvWarehouseRequest(); + filterInvWarehouseRequest.setCode(code); + List invWarehouseEntities = invWarehouseDao.filterInvWarehouse(filterInvWarehouseRequest); + if (invWarehouseEntities != null && invWarehouseEntities.size() > 0) + return invWarehouseEntities.get(0); + return null; + } + + @Override + public boolean deleteById(String id) { + return invWarehouseDao.deleteById(id); + } +} diff --git a/api-admin/src/main/java/com/glxp/api/admin/thread/BasicGenExcelService.java b/api-admin/src/main/java/com/glxp/api/admin/thread/BasicGenExcelService.java index f0de2e7b..7e2b58e3 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/thread/BasicGenExcelService.java +++ b/api-admin/src/main/java/com/glxp/api/admin/thread/BasicGenExcelService.java @@ -18,6 +18,7 @@ import com.glxp.api.admin.util.HttpClient; import com.glxp.api.common.res.BaseResponse; import com.glxp.api.common.util.ResultVOUtils; import org.springframework.beans.BeanUtils; +import org.springframework.beans.factory.annotation.Value; import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Service; @@ -29,6 +30,10 @@ import java.util.List; @Service public class BasicGenExcelService { + + @Value("${SPSYNC_IP}") + private String spsSyncUrl; + @Resource CorpExportLogService corpExportLogService; @Resource @@ -146,20 +151,20 @@ public class BasicGenExcelService { } //todo 上传SMP - SystemParamConfigEntity systemParamConfigEntity = systemParamConfigService.selectByParamKey("smp_service_ip"); - if (systemParamConfigEntity != null) { - String response = HttpClient.uCloudPost(systemParamConfigEntity.getParamValue() + "/udiwms/basic/corps/upload", postCorpsRequest); - BaseResponse baseResponse = JSONObject.parseObject(response, new TypeReference() { - }); - if (baseResponse.getCode() == 20000) { - corpExportLogEntity.setStatus(BasicProcessStatus.UDIINFO_IMPORT_SUCCESS); - } else { - corpExportLogEntity.setStatus(BasicProcessStatus.UDIINFO_IMPORT_FAIL); - } +// SystemParamConfigEntity systemParamConfigEntity = systemParamConfigService.selectByParamKey("smp_service_ip"); +// if (systemParamConfigEntity != null) { + String response = HttpClient.uCloudPost(spsSyncUrl + "/udiwms/basic/corps/upload", postCorpsRequest); + BaseResponse baseResponse = JSONObject.parseObject(response, new TypeReference() { + }); + if (baseResponse.getCode() == 20000) { + corpExportLogEntity.setStatus(BasicProcessStatus.UDIINFO_IMPORT_SUCCESS); } else { - corpExportLogEntity.setRemark("SMP服务IP地址未定义!"); corpExportLogEntity.setStatus(BasicProcessStatus.UDIINFO_IMPORT_FAIL); } +// } else { +// corpExportLogEntity.setRemark("SMP服务IP地址未定义!"); +// corpExportLogEntity.setStatus(BasicProcessStatus.UDIINFO_IMPORT_FAIL); +// } corpExportLogService.updateCorpExportLog(corpExportLogEntity); @@ -242,21 +247,21 @@ public class BasicGenExcelService { postUdiInfoRequest.setDatas(genDatas); } //todo 上传SMP - SystemParamConfigEntity systemParamConfigEntity = systemParamConfigService.selectByParamKey("smp_service_ip"); - if (systemParamConfigEntity != null) { - String response = HttpClient.uCloudPost(systemParamConfigEntity.getParamValue() + "/udiwms/basic/products/upload", postUdiInfoRequest); - BaseResponse baseResponse = JSONObject.parseObject(response, new TypeReference() { - }); - if (baseResponse.getCode() == 20000) { - udiInfoExportLogEntity.setStatus(BasicProcessStatus.UDIINFO_IMPORT_SUCCESS); - } else { - udiInfoExportLogEntity.setRemark(baseResponse.getMessage()); - udiInfoExportLogEntity.setStatus(BasicProcessStatus.UDIINFO_IMPORT_FAIL); - } +// SystemParamConfigEntity systemParamConfigEntity = systemParamConfigService.selectByParamKey("smp_service_ip"); +// if (systemParamConfigEntity != null) { + String response = HttpClient.uCloudPost(spsSyncUrl + "/udiwms/basic/products/upload", postUdiInfoRequest); + BaseResponse baseResponse = JSONObject.parseObject(response, new TypeReference() { + }); + if (baseResponse.getCode() == 20000) { + udiInfoExportLogEntity.setStatus(BasicProcessStatus.UDIINFO_IMPORT_SUCCESS); } else { - udiInfoExportLogEntity.setRemark("SMP服务IP地址未定义!"); + udiInfoExportLogEntity.setRemark(baseResponse.getMessage()); udiInfoExportLogEntity.setStatus(BasicProcessStatus.UDIINFO_IMPORT_FAIL); } +// } else { +// udiInfoExportLogEntity.setRemark("SMP服务IP地址未定义!"); +// udiInfoExportLogEntity.setStatus(BasicProcessStatus.UDIINFO_IMPORT_FAIL); +// } udiInfoExportLogService.updateUdiInfoExportLog(udiInfoExportLogEntity); } diff --git a/api-admin/src/main/java/com/glxp/api/admin/thread/BasicUdiInfoImportService.java b/api-admin/src/main/java/com/glxp/api/admin/thread/BasicUdiInfoImportService.java index db3d484b..338109b0 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/thread/BasicUdiInfoImportService.java +++ b/api-admin/src/main/java/com/glxp/api/admin/thread/BasicUdiInfoImportService.java @@ -163,7 +163,14 @@ public class BasicUdiInfoImportService { udiRelevanceService.updateUdiRelevance(temp); } else { UdiRelevanceEntity mTemp = udiRelevanceService.selectUpdateByThirdId(mainId); + boolean isThird = false; if (mTemp != null) { + UdiInfoEntity udiInfoEntity1 = udiInfoService.findByUuid(mTemp.getUuid()); + if (udiInfoEntity1 != null && udiInfoEntity1.getProductType() != null && udiInfoEntity1.getProductType() == 1) { + isThird = true; + } + } + if (mTemp != null && !isThird) { udiInfoImportDetailEntity.setStatus(BasicProcessStatus.UDIINFO_IMPORT_CODE_FAIL); udiInfoImportDetailEntity.setRemark("产品编码已存在关联不能重复插入!"); udiInfoImportLogEntity.setStatus(BasicProcessStatus.UDIINFO_IMPORT_FAIL); @@ -211,7 +218,7 @@ public class BasicUdiInfoImportService { if (udiInfoImportDetailEntity.getSptm() != null && !udiInfoImportDetailEntity.getSptm().trim().equals("")) { udiRelevanceEntity.setSptm(udiInfoImportDetailEntity.getSptm()); } - if (udiInfoImportDetailEntity.getIsUseDy() != null && udiInfoImportDetailEntity.getIsUseDy().trim().equals("")) { + if (udiInfoImportDetailEntity.getIsUseDy() != null && !udiInfoImportDetailEntity.getIsUseDy().trim().equals("")) { if (udiInfoImportDetailEntity.getIsUseDy().equals("是")) { udiRelevanceEntity.setIsUseDy(true); } else { diff --git a/api-admin/src/main/java/com/glxp/api/admin/thread/ThrOrdersDlService.java b/api-admin/src/main/java/com/glxp/api/admin/thread/ThrOrdersDlService.java index edf48637..ec1d11fe 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/thread/ThrOrdersDlService.java +++ b/api-admin/src/main/java/com/glxp/api/admin/thread/ThrOrdersDlService.java @@ -30,6 +30,7 @@ import com.glxp.api.admin.util.HttpClient; import com.glxp.api.admin.util.RedisUtil; import com.glxp.api.common.res.BaseResponse; import org.springframework.beans.BeanUtils; +import org.springframework.beans.factory.annotation.Value; import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Service; @@ -40,6 +41,9 @@ import java.util.List; @Service public class ThrOrdersDlService { + + @Value("${SPSYNC_IP}") + private String spsSyncUrl; @Resource ThrOrderService thrOrderService; @Resource @@ -285,20 +289,20 @@ public class ThrOrdersDlService { //toDo 上傳SMP postThrOrderRequest.setGenKey(genKey); postThrOrderRequest.setThirdSys(thrOrderExportRequest.getThirdSysFk()); - SystemParamConfigEntity systemParamConfigEntity = systemParamConfigService.selectByParamKey("smp_service_ip"); - if (systemParamConfigEntity != null) { - String response = HttpClient.uCloudPost(systemParamConfigEntity.getParamValue() + "/udiwms/thrsys/postOrderDetail", postThrOrderRequest); - BaseResponse baseResponse = JSONObject.parseObject(response, new TypeReference() { - }); - if (baseResponse.getCode() == 20000) { - thrOrderExportLogEntity.setStatus(BasicProcessStatus.UDIINFO_IMPORT_SUCCESS); - } else { - thrOrderExportLogEntity.setStatus(BasicProcessStatus.UDIINFO_IMPORT_FAIL); - } +// SystemParamConfigEntity systemParamConfigEntity = systemParamConfigService.selectByParamKey("smp_service_ip"); +// if (systemParamConfigEntity != null) { + String response = HttpClient.uCloudPost(spsSyncUrl + "/udiwms/thrsys/postOrderDetail", postThrOrderRequest); + BaseResponse baseResponse = JSONObject.parseObject(response, new TypeReference() { + }); + if (baseResponse.getCode() == 20000) { + thrOrderExportLogEntity.setStatus(BasicProcessStatus.UDIINFO_IMPORT_SUCCESS); } else { - thrOrderExportLogEntity.setRemark("SMP服务IP地址未定义!"); thrOrderExportLogEntity.setStatus(BasicProcessStatus.UDIINFO_IMPORT_FAIL); } +// } else { +// thrOrderExportLogEntity.setRemark("SMP服务IP地址未定义!"); +// thrOrderExportLogEntity.setStatus(BasicProcessStatus.UDIINFO_IMPORT_FAIL); +// } thrOrderExportLogEntity.setStatus(BasicProcessStatus.UDIINFO_IMPORT_SUCCESS); thrOrderExportLogService.updateThrOrderExportLog(thrOrderExportLogEntity); diff --git a/api-admin/src/main/java/com/glxp/api/admin/thread/ThrProductsDlService.java b/api-admin/src/main/java/com/glxp/api/admin/thread/ThrProductsDlService.java index ae7eb4be..70d5e7e6 100644 --- a/api-admin/src/main/java/com/glxp/api/admin/thread/ThrProductsDlService.java +++ b/api-admin/src/main/java/com/glxp/api/admin/thread/ThrProductsDlService.java @@ -24,6 +24,7 @@ import com.glxp.api.admin.service.thrsys.ThrProductsService; import com.glxp.api.admin.util.*; import com.glxp.api.common.res.BaseResponse; import org.springframework.beans.BeanUtils; +import org.springframework.beans.factory.annotation.Value; import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Service; @@ -35,6 +36,10 @@ import java.util.stream.Collectors; @Service public class ThrProductsDlService { + + @Value("${SPSYNC_IP}") + private String spsSyncUrl; + @Resource ThrProductsService thrProductsService; @Resource @@ -258,20 +263,20 @@ public class ThrProductsDlService { } //Todo 接口上传SMP - SystemParamConfigEntity systemParamConfigEntity = systemParamConfigService.selectByParamKey("smp_service_ip"); - if (systemParamConfigEntity != null) { - String response = HttpClient.uCloudPost(systemParamConfigEntity.getParamValue() + "/udiwms/thrsys/postThrProducts", postThrProductsRequest); - BaseResponse baseResponse = JSONObject.parseObject(response, new TypeReference() { - }); - if (baseResponse.getCode() == 20000) { - thrProductsExportLogEntity.setStatus(BasicProcessStatus.UDIINFO_IMPORT_SUCCESS); - } else { - thrProductsExportLogEntity.setStatus(BasicProcessStatus.UDIINFO_IMPORT_FAIL); - } +// SystemParamConfigEntity systemParamConfigEntity = systemParamConfigService.selectByParamKey("smp_service_ip"); +// if (systemParamConfigEntity != null) { + String response = HttpClient.uCloudPost(spsSyncUrl + "/udiwms/thrsys/postThrProducts", postThrProductsRequest); + BaseResponse baseResponse = JSONObject.parseObject(response, new TypeReference() { + }); + if (baseResponse.getCode() == 20000) { + thrProductsExportLogEntity.setStatus(BasicProcessStatus.UDIINFO_IMPORT_SUCCESS); } else { - thrProductsExportLogEntity.setRemark("SMP服务IP地址未定义!"); thrProductsExportLogEntity.setStatus(BasicProcessStatus.UDIINFO_IMPORT_FAIL); } +// } else { +// thrProductsExportLogEntity.setRemark("SMP服务IP地址未定义!"); +// thrProductsExportLogEntity.setStatus(BasicProcessStatus.UDIINFO_IMPORT_FAIL); +// } thrProductsExportLogEntity.setStatus(BasicProcessStatus.UDIINFO_IMPORT_SUCCESS); thrProductsExportLogService.updateThrProductsExportLog(thrProductsExportLogEntity); diff --git a/api-admin/src/main/resources/application-pro.properties b/api-admin/src/main/resources/application-pro.properties index 728f6adb..302597a4 100644 --- a/api-admin/src/main/resources/application-pro.properties +++ b/api-admin/src/main/resources/application-pro.properties @@ -18,13 +18,16 @@ logging.level.com.glxp.api.admin.erp.second=debug #logback配置 logging.path=output/logs # 不指定的情况下默认生成在项目根目录,按照配置生成所需的日志名称 -logging.file=D:/udi.log +#logging.file=D:/udi.log + file_path=D:/1s/udiwms/udiwmsfile/ #file_path=/home/glxp/udiwms #UDI数据下载 +UDI_KEY=6b137c66-6286-46c6-8efa-c2f5dd9237df UDI_SERVER_URL=https://www.udims.com/UDI_DL_Server_test #中转服务IP地址 SPSYNC_IP=http://127.0.0.1:9989 +#SPSYNC_IP=http://192.168.0.109:8080/SP_SYNC_SERVER #UDI_SERVER_URL=http://127.0.0.1:9995 ##端口号 # Redis数据库索引(默认为0) diff --git a/api-admin/src/main/resources/mybatis/mapper/basic/BasicUnitMaintainDao.xml b/api-admin/src/main/resources/mybatis/mapper/basic/BasicUnitMaintainDao.xml index 2948763e..b2c37297 100644 --- a/api-admin/src/main/resources/mybatis/mapper/basic/BasicUnitMaintainDao.xml +++ b/api-admin/src/main/resources/mybatis/mapper/basic/BasicUnitMaintainDao.xml @@ -92,7 +92,8 @@ #{thirdName2}, #{thirdName3}, #{thirdName4}, - #{updateTime},#{corpType} + #{updateTime}, + #{corpType} ) @@ -100,7 +101,7 @@ insert INTO basic_corp(thirdId, erpId, name, spell, addr, status, type, creditNo, contact, mobile, thirdId1, thirdId2, thirdId3, thirdId4, - thirdName, thirdName1, thirdName2, thirdName3, thirdName4, updateTime,corpType) + thirdName, thirdName1, thirdName2, thirdName3, thirdName4, updateTime, corpType) values (#{thirdId}, #{erpId}, #{name}, @@ -112,7 +113,7 @@ #{contact}, #{mobile}, #{thirdId1}, #{thirdId2}, #{thirdId3}, #{thirdId4}, - #{thirdName}, #{thirdName1}, #{thirdName2}, #{thirdName3}, #{thirdName4}, #{updateTime},#{corpType}) + #{thirdName}, #{thirdName1}, #{thirdName2}, #{thirdName3}, #{thirdName4}, #{updateTime}, #{corpType}) diff --git a/api-admin/src/main/resources/mybatis/mapper/basic/BussinessLocalTypeDao.xml b/api-admin/src/main/resources/mybatis/mapper/basic/BussinessLocalTypeDao.xml index 53d83b1f..e2a83d27 100644 --- a/api-admin/src/main/resources/mybatis/mapper/basic/BussinessLocalTypeDao.xml +++ b/api-admin/src/main/resources/mybatis/mapper/basic/BussinessLocalTypeDao.xml @@ -26,9 +26,9 @@ - + diff --git a/api-admin/src/main/resources/mybatis/mapper/business/StockOrderDao.xml b/api-admin/src/main/resources/mybatis/mapper/business/StockOrderDao.xml index 7a03b508..32c3b40b 100644 --- a/api-admin/src/main/resources/mybatis/mapper/business/StockOrderDao.xml +++ b/api-admin/src/main/resources/mybatis/mapper/business/StockOrderDao.xml @@ -24,7 +24,7 @@ parameterType="com.glxp.api.admin.entity.business.StockOrderEntity"> insert INTO stock_order(id, billNo, billdate, corpId, corpName, billType, billFlag, thirdSysFk, status, statusInfo, type, sourceType, - printStatus, unitIdFk, customerId, thirdOrderFk, orderIdFk, totalPrice) + printStatus, unitIdFk, customerId, thirdOrderFk, orderIdFk, totalPrice,locStorageCode) values (#{id}, #{billNo}, #{billdate}, @@ -37,7 +37,8 @@ #{statusInfo}, #{type}, #{sourceType}, - #{printStatus}, #{unitIdFk}, #{customerId}, #{thirdOrderFk}, #{orderIdFk}, #{totalPrice}) + #{printStatus}, #{unitIdFk}, #{customerId}, + #{thirdOrderFk}, #{orderIdFk}, #{totalPrice},#{locStorageCode}) UPDATE stock_order @@ -59,7 +60,7 @@ thirdOrderFk=#{thirdOrderFk}, orderIdFk=#{orderIdFk}, totalPrice=#{totalPrice}, - + locStorageCode=#{locStorageCode}, WHERE id = #{id} diff --git a/api-admin/src/main/resources/mybatis/mapper/inout/CodesDao.xml b/api-admin/src/main/resources/mybatis/mapper/inout/CodesDao.xml index 63e9aef3..7ce3b28c 100644 --- a/api-admin/src/main/resources/mybatis/mapper/inout/CodesDao.xml +++ b/api-admin/src/main/resources/mybatis/mapper/inout/CodesDao.xml @@ -36,7 +36,7 @@ INSERT INTO io_codes(action, mainAction, code, corpOrderId, actor, actDate, upperCorpOrderId, fromCorpId, - fromCorp, nameCode, relId,status,supId) + fromCorp, nameCode, relId,status,supId,locStorageCode) values (#{action}, #{mainAction}, #{code}, @@ -44,7 +44,7 @@ #{actor}, #{actDate}, #{fromCorpId}, - #{fromCorp}, #{orderId}, #{nameCode}, #{relId},#{status},#{supId}) + #{fromCorp}, #{orderId}, #{nameCode}, #{relId},#{status},#{supId},#{locStorageCode}) @@ -56,7 +56,7 @@ actor, actDate, fromCorpId,fromCorp,orderId,batchNo,produceDate,expireDate, - serialNo,count,packageLevel,warehouseCode,nameCode,relId,status,supId) + serialNo,count,packageLevel,warehouseCode,nameCode,relId,status,supId,locStorageCode) VALUES @@ -76,7 +76,7 @@ ,#{item.serialNo} ,#{item.count} ,#{item.packageLevel} ,#{item.warehouseCode},#{item.nameCode},#{item.relId},#{item.status} - ,#{item.supId}) + ,#{item.supId},#{item.locStorageCode}) @@ -136,7 +136,7 @@ sCount=#{sCount}, status=#{status}, supId=#{supId}, - + locStorageCode=#{locStorageCode}, WHERE id=#{id} diff --git a/api-admin/src/main/resources/mybatis/mapper/inout/CodesTempDao.xml b/api-admin/src/main/resources/mybatis/mapper/inout/CodesTempDao.xml index 7bbb69bf..47f65d52 100644 --- a/api-admin/src/main/resources/mybatis/mapper/inout/CodesTempDao.xml +++ b/api-admin/src/main/resources/mybatis/mapper/inout/CodesTempDao.xml @@ -7,7 +7,8 @@ INSERT INTO io_codes_temp (action, mainAction,code, corpOrderId, actor,actDate, - fromCorpId, fromCorp, orderId,batchNo,produceDate,expireDate,serialNo,count,nameCode,relId,status,supId) + fromCorpId, fromCorp, orderId,batchNo,produceDate,expireDate,serialNo, + count,nameCode,relId,status,supId,locStorageCode) VALUES @@ -26,7 +27,7 @@ ,#{item.expireDate} ,#{item.serialNo} ,#{item.count},#{item.nameCode} - , #{item.relId},#{item.status},#{item.supId}) + , #{item.relId},#{item.status},#{item.supId},#{item.locStorageCode}) @@ -34,7 +35,7 @@ INSERT INTO io_codes_temp(action, mainAction, code, corpOrderId, actor, actDate, fromCorpId, fromCorp, orderId, batchNo, produceDate, expireDate, serialNo, count, - nameCode, relId, status, supId) + nameCode, relId, status, supId,locStorageCode) values (#{action}, #{mainAction}, #{code}, @@ -48,7 +49,7 @@ #{produceDate}, #{expireDate}, #{serialNo}, - #{count}, #{nameCode}, #{relId}, #{status}, #{supId}) + #{count}, #{nameCode}, #{relId}, #{status}, #{supId},#{locStorageCode}) + SELECT * FROM inv_warehouse + + + AND id = #{id} + + + AND pid = #{pid} + + + AND code = #{code} + + + AND name = #{name} + + + AND advanceType = #{advanceType} + + + AND isDefault = #{isDefault} + + + and code like concat('%',#{key},'%') or `name` like concat('%',#{key},'%') + + + + + + + + + + + insert INTO inv_warehouse + (pid, code, name, advanceType, isDefault, + status, updateTime, remark) + values (#{pid}, #{code}, + #{name}, #{advanceType}, #{isDefault}, + #{status}, #{updateTime}, + #{remark}) + + + + + DELETE + FROM inv_warehouse + WHERE id = #{id} + + + + UPDATE inv_warehouse + + pid=#{pid}, + name=#{name}, + code=#{code}, + advanceType=#{advanceType}, + isDefault=#{isDefault}, + status=#{status}, + updateTime=#{updateTime}, + remark=#{remark}, + + WHERE id = #{id} + + + \ No newline at end of file diff --git a/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrProductsDao.xml b/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrProductsDao.xml index a4550081..efc0b46c 100644 --- a/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrProductsDao.xml +++ b/api-admin/src/main/resources/mybatis/mapper/thrsys/ThrProductsDao.xml @@ -29,7 +29,8 @@ AND spec LIKE concat('%',#{spec},'%') - or code LIKE concat('%',#{unionCode},'%') or sptm LIKE concat('%',#{unionCode},'%') or ybbm LIKE concat('%',#{unionCode},'%') + or code LIKE concat('%',#{unionCode},'%') or sptm LIKE concat('%',#{unionCode},'%') or ybbm LIKE + concat('%',#{unionCode},'%') AND thirdSysFk = #{thirdSysFk} @@ -39,14 +40,18 @@ - ORDER BY updateTime DESC + + - replace INTO thr_products + replace + INTO thr_products ( code,name,measname,spec,registerNo,manufactory, cplb,flbm,qxlb,ybbm,sptm,tyshxydm,zczbhhzbapzbh,ylqxzcrbarmc,ylqxzcrbarywmc,cpms, @@ -54,16 +59,26 @@ ) values ( - #{code}, - #{name}, - #{measname}, - #{spec}, - #{registerNo}, - #{manufactory}, - #{cplb}, #{flbm}, #{qxlb}, #{ybbm},#{sptm}, - #{tyshxydm}, #{zczbhhzbapzbh}, #{ylqxzcrbarmc}, #{ylqxzcrbarywmc},#{cpms} - #{thirdSysFk},#{updateTime},#{supName} - ) + #{code}, + #{name}, + #{measname}, + #{spec}, + #{registerNo}, + #{manufactory}, + #{cplb}, + #{flbm}, + #{qxlb}, + #{ybbm}, + #{sptm}, + #{tyshxydm}, + #{zczbhhzbapzbh}, + #{ylqxzcrbarmc}, + #{ylqxzcrbarywmc}, + #{cpms} + #{thirdSysFk}, + #{updateTime}, + #{supName} + ) @@ -92,7 +107,9 @@ - DELETE FROM thr_products WHERE id = #{id} + DELETE + FROM thr_products + WHERE id = #{id} @@ -123,6 +140,7 @@ - DELETE FROM thr_products + DELETE + FROM thr_products \ No newline at end of file