|
|
|
@ -1634,8 +1634,16 @@ public class YxfyyyClient extends CommonHttpClient {
|
|
|
|
|
*/
|
|
|
|
|
private BaseResponse covertSellOrder(UdiwmsBasicSkPrescribeRequest udiwmsBasicSkPrescribeRequest, IPage<VInsurNationGoodsPhysic> page) {
|
|
|
|
|
List<VInsurNationGoodsPhysic> presInfoEntities = page.getRecords();
|
|
|
|
|
List<VInsurNationGoodsPhysic> vInsurNationGoodsPhysics = new ArrayList<>();
|
|
|
|
|
if (CollUtil.isNotEmpty(presInfoEntities)) {
|
|
|
|
|
Map<String, List<VInsurNationGoodsPhysic>> groupedByPrescribeNumber = presInfoEntities.stream()
|
|
|
|
|
List<String> collect = presInfoEntities.stream().map(VInsurNationGoodsPhysic::getRXNO).collect(Collectors.toList());
|
|
|
|
|
LambdaQueryWrapper<VInsurNationGoodsPhysic> wrapper1 = new LambdaQueryWrapper<>();
|
|
|
|
|
wrapper1.in(VInsurNationGoodsPhysic::getRXNO,collect);
|
|
|
|
|
vInsurNationGoodsPhysics = goodsPhysicMapper.selectList(wrapper1);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (CollUtil.isNotEmpty(vInsurNationGoodsPhysics)) {
|
|
|
|
|
Map<String, List<VInsurNationGoodsPhysic>> groupedByPrescribeNumber = vInsurNationGoodsPhysics.stream()
|
|
|
|
|
.collect(Collectors.groupingBy(VInsurNationGoodsPhysic::getRXNO));
|
|
|
|
|
List<IoCollectOrder> ioCollectOrders = new ArrayList<>();
|
|
|
|
|
groupedByPrescribeNumber.forEach((key, value) -> {
|
|
|
|
@ -1652,6 +1660,9 @@ public class YxfyyyClient extends CommonHttpClient {
|
|
|
|
|
ioCollectOrder.setCreateTime(new Date());
|
|
|
|
|
ioCollectOrder.setCreateUser(udiwmsBasicSkPrescribeRequest.getCreateUser());
|
|
|
|
|
ioCollectOrder.setBackupOrderRemark1(presInfoEntity.getSTOOUT_NO());
|
|
|
|
|
ioCollectOrder.setBackupOrderRemark2(presInfoEntity.getSICK_ID());
|
|
|
|
|
ioCollectOrder.setBackupOrderRemark3(presInfoEntity.getPSN_NAME());
|
|
|
|
|
ioCollectOrder.setBackupOrderRemark4(presInfoEntity.getPSN_NO());
|
|
|
|
|
ioCollectOrder.setUpdateTime(new Date());
|
|
|
|
|
ioCollectOrder.setSplitStatus(0);
|
|
|
|
|
ioCollectOrder.setTagStatus(0);
|
|
|
|
@ -1665,8 +1676,10 @@ public class YxfyyyClient extends CommonHttpClient {
|
|
|
|
|
errorMsg.append(entity.getFIXMEDINS_HILIST_NAME()).append("字典未对照").append(";");
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
VYpzsPresInfo vYpzsPresInfo = vYpzsPresInfoMapper.selectOne(new LambdaQueryWrapper<VYpzsPresInfo>().eq(VYpzsPresInfo::getPRESCRIBE_NUMBER, entity.getRXNO()).eq(VYpzsPresInfo::getPHYSIC_CODE, entity.getFIXMEDINS_HILIST_ID()));
|
|
|
|
|
if (vYpzsPresInfo != null) {
|
|
|
|
|
List<VYpzsPresInfo> vYpzsPresInfos = vYpzsPresInfoMapper.selectList(new LambdaQueryWrapper<VYpzsPresInfo>().eq(VYpzsPresInfo::getPRESCRIBE_NUMBER, entity.getRXNO()).eq(VYpzsPresInfo::getPHYSIC_CODE, entity.getFIXMEDINS_HILIST_ID()));
|
|
|
|
|
|
|
|
|
|
if (CollUtil.isNotEmpty(vYpzsPresInfos)) {
|
|
|
|
|
VYpzsPresInfo vYpzsPresInfo = vYpzsPresInfos.get(0);
|
|
|
|
|
collectOrderBiz.setGgxh(vYpzsPresInfo.getPACK_SPEC());
|
|
|
|
|
collectOrderBiz.setMeasureUnit(vYpzsPresInfo.getPHYSIC_UNIT());
|
|
|
|
|
}
|
|
|
|
@ -1699,8 +1712,16 @@ public class YxfyyyClient extends CommonHttpClient {
|
|
|
|
|
|
|
|
|
|
private BaseResponse covertReturnOrder(UdiwmsBasicSkPrescribeRequest udiwmsBasicSkPrescribeRequest, IPage<VInsurNationGoodsReturn> page) {
|
|
|
|
|
List<VInsurNationGoodsReturn> presInfoEntities = page.getRecords();
|
|
|
|
|
List<VInsurNationGoodsReturn> vInsurNationGoodsReturns = new ArrayList<>();
|
|
|
|
|
if (CollUtil.isNotEmpty(presInfoEntities)) {
|
|
|
|
|
Map<String, List<VInsurNationGoodsReturn>> groupedByPrescribeNumber = presInfoEntities.stream()
|
|
|
|
|
List<String> collect = presInfoEntities.stream().map(VInsurNationGoodsReturn::getAPPLY_NO).collect(Collectors.toList());
|
|
|
|
|
LambdaQueryWrapper<VInsurNationGoodsReturn> wrapper1 = new LambdaQueryWrapper<>();
|
|
|
|
|
wrapper1.in(VInsurNationGoodsReturn::getAPPLY_NO, collect);
|
|
|
|
|
vInsurNationGoodsReturns = vInsurNationGoodsReturnMapper.selectList(wrapper1);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (CollUtil.isNotEmpty(vInsurNationGoodsReturns)) {
|
|
|
|
|
Map<String, List<VInsurNationGoodsReturn>> groupedByPrescribeNumber = vInsurNationGoodsReturns.stream()
|
|
|
|
|
.collect(Collectors.groupingBy(VInsurNationGoodsReturn::getAPPLY_NO));
|
|
|
|
|
List<IoCollectOrder> ioCollectOrders = new ArrayList<>();
|
|
|
|
|
groupedByPrescribeNumber.forEach((key, value) -> {
|
|
|
|
@ -1728,8 +1749,10 @@ public class YxfyyyClient extends CommonHttpClient {
|
|
|
|
|
} else {
|
|
|
|
|
errorMsg.append(entity.getFIXMEDINS_HILIST_NAME()).append("字典未对照").append(";");
|
|
|
|
|
}
|
|
|
|
|
VYpzsPresInfoReturn vYpzsPresInfo = vYpzsPresInfoReturnMapper.selectOne(new LambdaQueryWrapper<VYpzsPresInfoReturn>().eq(VYpzsPresInfoReturn::getAPPLY_NO, entity.getAPPLY_NO()).eq(VYpzsPresInfoReturn::getPHYSIC_CODE, entity.getFIXMEDINS_HILIST_ID()));
|
|
|
|
|
if (vYpzsPresInfo != null) {
|
|
|
|
|
List<VYpzsPresInfoReturn> vYpzsPresInfoReturns = vYpzsPresInfoReturnMapper.selectList(new LambdaQueryWrapper<VYpzsPresInfoReturn>().eq(VYpzsPresInfoReturn::getAPPLY_NO, entity.getAPPLY_NO()).eq(VYpzsPresInfoReturn::getPHYSIC_CODE, entity.getFIXMEDINS_HILIST_ID()));
|
|
|
|
|
|
|
|
|
|
if (CollUtil.isNotEmpty(vYpzsPresInfoReturns)) {
|
|
|
|
|
VYpzsPresInfoReturn vYpzsPresInfo = vYpzsPresInfoReturns.get(0);
|
|
|
|
|
collectOrderBiz.setGgxh(vYpzsPresInfo.getPHYSIC_SPEC());
|
|
|
|
|
collectOrderBiz.setMeasureUnit(vYpzsPresInfo.getPHYSIC_UNIT());
|
|
|
|
|
}
|
|
|
|
|