单据完成后自动上传

dev_unify
yewj 7 months ago
parent 71c198668f
commit a987057b46

@ -341,7 +341,7 @@ public class IoCollectOrderCodeManController extends BaseController {
@PostMapping("/udiwms/basic/collect/IoCollectOrderCodeMan/checkCode") @PostMapping("/udiwms/basic/collect/IoCollectOrderCodeMan/checkCode")
public BaseResponse checkCollectOrderManCode(@RequestBody CollectOrderCodeManRequest request){ public BaseResponse checkCollectOrderManCode(@RequestBody CollectOrderCodeManRequest request) {
ExecutorService executor = Executors.newSingleThreadExecutor(); ExecutorService executor = Executors.newSingleThreadExecutor();
Future<BaseResponse> future = executor.submit(() -> collectOrderCodeManService.CheckCode(request)); Future<BaseResponse> future = executor.submit(() -> collectOrderCodeManService.CheckCode(request));
BaseResponse response = null; BaseResponse response = null;

@ -192,13 +192,13 @@ public class IoCollectOrderBackupService extends ServiceImpl<IoCollectOrderBacku
if (IntUtil.value(sysWorkplaceDocumentEntity.getCorpType()) == 2) { if (IntUtil.value(sysWorkplaceDocumentEntity.getCorpType()) == 2) {
orderEntity.setInvCode(collectOrder.getShipper() + ""); orderEntity.setInvCode(collectOrder.getShipper() + "");
orderEntity.setFromCorp(collectOrder.getFromCorp()); orderEntity.setFromCorp(collectOrder.getFromCorp());
InvWarehouseEntity invWarehouseEntity = invWarehouseService.findByInvSubByCode(collectOrder.getShipper() + ""); InvWarehouseEntity invWarehouseEntity = invWarehouseService.findByInvSubByCode(orderEntity.getInvCode() + "");
if (invWarehouseEntity != null) if (invWarehouseEntity != null)
orderEntity.setDeptCode(invWarehouseEntity.getParentId()); orderEntity.setDeptCode(invWarehouseEntity.getParentId());
} else { } else {
orderEntity.setInvCode(collectOrder.getFromCorp() + ""); orderEntity.setInvCode(collectOrder.getFromCorp() + "");
orderEntity.setFromCorp(collectOrder.getShipper()); orderEntity.setFromCorp(collectOrder.getShipper());
InvWarehouseEntity invWarehouseEntity = invWarehouseService.findByInvSubByCode(collectOrder.getShipper() + ""); InvWarehouseEntity invWarehouseEntity = invWarehouseService.findByInvSubByCode(orderEntity.getInvCode() + "");
if (invWarehouseEntity != null) if (invWarehouseEntity != null)
orderEntity.setDeptCode(invWarehouseEntity.getParentId()); orderEntity.setDeptCode(invWarehouseEntity.getParentId());
} }
@ -231,10 +231,10 @@ public class IoCollectOrderBackupService extends ServiceImpl<IoCollectOrderBacku
Map<Long, List<IoCodeTempEntity>> groupedMap = lossCodesList.stream() Map<Long, List<IoCodeTempEntity>> groupedMap = lossCodesList.stream()
.collect(Collectors.groupingBy(IoCodeTempEntity::getRelId)); .collect(Collectors.groupingBy(IoCodeTempEntity::getRelId));
groupedMap.forEach((key, value) -> { groupedMap.forEach((key, value) -> {
companyProductRelevanceService.insertOrReadId(key, collectOrder.getFromCorp()); companyProductRelevanceService.insertOrReadId(key, collectOrder.getShipper());
}); });
for (IoCodeTempEntity codeTempEntity : lossCodesList) { for (IoCodeTempEntity codeTempEntity : lossCodesList) {
codeTempEntity.setSupId(collectOrder.getFromCorp()); codeTempEntity.setSupId(collectOrder.getShipper());
} }
} }
orderService.insertOrder(orderEntity); orderService.insertOrder(orderEntity);
@ -267,9 +267,9 @@ public class IoCollectOrderBackupService extends ServiceImpl<IoCollectOrderBacku
} }
} }
if (sysWorkplaceDocumentEntity != null){ if (sysWorkplaceDocumentEntity != null) {
Integer uploadYb = sysWorkplaceDocumentEntity.getUploadYb(); Integer uploadYb = sysWorkplaceDocumentEntity.getUploadYb();
if (uploadYb == 1){ if (uploadYb == 1) {
uploadThrid(collectOrder); uploadThrid(collectOrder);
} }
} }

@ -872,21 +872,24 @@ public class IoCollectOrderService extends ServiceImpl<IoCollectOrderMapper, IoC
ioCollectOrderBackup.setCheckCodeStatus(0); ioCollectOrderBackup.setCheckCodeStatus(0);
ioCollectOrderBackup.setCheckCodeConfirm(0); ioCollectOrderBackup.setCheckCodeConfirm(0);
ioCollectOrderBackupService.save(ioCollectOrderBackup); ioCollectOrderBackupService.save(ioCollectOrderBackup);
//todo 备份码表 //todo 备份码表
IoCollectOrder finalCollectOrder = collectOrder; IoCollectOrder finalCollectOrder = collectOrder;
ThreadUtil.execAsync(() -> { ThreadUtil.execAsync(() -> {
//插入到码表 //插入到码表
collectCodeService.insertCodesByBill(collectOrderRequest.getBillNo()); collectCodeService.insertCodesByBill(collectOrderRequest.getBillNo());
//删除原来单据 //删除原来单据
removeOrderByBillNo(finalCollectOrder); removeOrderByBillNo(finalCollectOrder);
//更新数据至第三方系统 //更新数据至第三方系统
//单据更新 //单据更新
ioCollectOrderBackupService.generateOrder(finalCollectOrder.getBillNo(), authAdmin); // ioCollectOrderBackupService.generateOrder(finalCollectOrder.getBillNo(), authAdmin);
// spGetHttpClient.updateCheckStatus(orderEntity,collectOrder.getCreateUser()); IoCollectSet ioCollectSet = collectSetService.getSet();
}); Boolean autoUploadOrder = ioCollectSet.getAutoUploadOrder();
if (autoUploadOrder) {
ioCollectOrderBackupService.orderUpload(collectOrderRequest.getBillNo(), null);
}
}
);
} }
public void busGenOrder(CollectOrderRequest collectOrderRequest) { public void busGenOrder(CollectOrderRequest collectOrderRequest) {

Loading…
Cancel
Save