|
|
package com.glxp.api.service.collect;
|
|
|
|
|
|
import cn.hutool.core.collection.CollUtil;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
|
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
|
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
|
import com.github.pagehelper.PageHelper;
|
|
|
import com.glxp.api.dao.collect.IoCollectOrderMapper;
|
|
|
import com.glxp.api.entity.auth.SysWorkplace;
|
|
|
import com.glxp.api.entity.basic.BasicCollectBustypeEntity;
|
|
|
import com.glxp.api.entity.basic.BasicSkPrescribeEntity;
|
|
|
import com.glxp.api.entity.basic.BasicSkPrescribeItemEntity;
|
|
|
import com.glxp.api.entity.collect.IoCollectOrder;
|
|
|
import com.glxp.api.entity.collect.IoCollectOrderBiz;
|
|
|
import com.glxp.api.entity.collect.IoCollectOrderCodeMan;
|
|
|
import com.glxp.api.entity.inout.IoOrderDetailBizEntity;
|
|
|
import com.glxp.api.entity.inout.IoOrderEntity;
|
|
|
import com.glxp.api.exception.JsonException;
|
|
|
import com.glxp.api.req.collect.CollectOrderRequest;
|
|
|
import com.glxp.api.req.inout.DeleteTageCodeRequest;
|
|
|
import com.glxp.api.req.inout.FilterOrderRequest;
|
|
|
import com.glxp.api.res.basic.UdiRelevanceResponse;
|
|
|
import com.glxp.api.res.collect.IoCollectOrderResponse;
|
|
|
import com.glxp.api.res.inout.IoOrderResponse;
|
|
|
import com.glxp.api.service.auth.SysWorkplaceService;
|
|
|
import com.glxp.api.service.basic.*;
|
|
|
import com.glxp.api.service.inout.IoCodeTempService;
|
|
|
import com.glxp.api.service.inout.IoOrderDetailBizService;
|
|
|
import com.glxp.api.service.inout.IoOrderService;
|
|
|
import com.glxp.api.service.inout.impl.IoCodeService;
|
|
|
import com.glxp.api.util.IntUtil;
|
|
|
import com.glxp.api.util.MsDateUtil;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
|
|
|
|
import javax.annotation.Resource;
|
|
|
import java.util.*;
|
|
|
|
|
|
@Service
|
|
|
public class IoCollectOrderService extends ServiceImpl<IoCollectOrderMapper, IoCollectOrder> {
|
|
|
|
|
|
@Resource
|
|
|
IoCollectOrderMapper collectOrderMapper;
|
|
|
@Resource
|
|
|
IoCollectOrderCodeManService ioCollectOrderCodeManService;
|
|
|
|
|
|
public IoCollectOrder getByBillNo(String billNo) {
|
|
|
return collectOrderMapper.selectOne(new LambdaQueryWrapper<IoCollectOrder>().eq(IoCollectOrder::getBillNo, billNo).last("limit 1"));
|
|
|
}
|
|
|
|
|
|
public int updateByBillNo(IoCollectOrder collectOrder) {
|
|
|
return collectOrderMapper.update(collectOrder, new UpdateWrapper<IoCollectOrder>().eq("billNo", collectOrder.getBillNo()));
|
|
|
}
|
|
|
|
|
|
|
|
|
public List<IoCollectOrderResponse> filterList(CollectOrderRequest collectOrderRequest) {
|
|
|
if (collectOrderRequest == null) {
|
|
|
return Collections.emptyList();
|
|
|
}
|
|
|
if (collectOrderRequest.getPage() != null) {
|
|
|
int offset = (collectOrderRequest.getPage() - 1) * collectOrderRequest.getLimit();
|
|
|
PageHelper.offsetPage(offset, collectOrderRequest.getLimit());
|
|
|
}
|
|
|
List<IoCollectOrderResponse> data = collectOrderMapper.filterList(collectOrderRequest);
|
|
|
return data;
|
|
|
}
|
|
|
|
|
|
|
|
|
@Resource
|
|
|
IoOrderService orderService;
|
|
|
@Resource
|
|
|
IoOrderDetailBizService orderDetailBizService;
|
|
|
@Resource
|
|
|
BasicCollectBustypeService collectBustypeService;
|
|
|
@Resource
|
|
|
IoCollectOrderBizService collectOrderBizService;
|
|
|
@Resource
|
|
|
UdiRelevanceService udiRelevanceService;
|
|
|
@Resource
|
|
|
BasicSkPrescribeService basicSkPrescribeService;
|
|
|
@Resource
|
|
|
BasicSkPrescirbeDetailService basicSkPrescirbeDetailService;
|
|
|
|
|
|
/**
|
|
|
* 导入内部数据
|
|
|
*/
|
|
|
public void importOrder() {
|
|
|
importUdi();
|
|
|
importPrescribe();
|
|
|
}
|
|
|
|
|
|
|
|
|
@Resource
|
|
|
IoOrderDetailBizService orderDetailCodeService;
|
|
|
@Resource
|
|
|
IoCodeTempService codeTempService;
|
|
|
@Resource
|
|
|
IoCodeService codeService;
|
|
|
|
|
|
public void clearOrder() {
|
|
|
collectOrderMapper.clearOrder();
|
|
|
|
|
|
|
|
|
List<IoOrderEntity> orderEntities = new ArrayList<>();
|
|
|
|
|
|
|
|
|
List<IoOrderEntity> orderEntities1 = orderService.findAllByAction("SC72197936495755");
|
|
|
List<IoOrderEntity> orderEntities2 = orderService.findAllByAction("SC72249388338364");
|
|
|
orderEntities.addAll(orderEntities1);
|
|
|
orderEntities.addAll(orderEntities2);
|
|
|
orderEntities.parallelStream().forEach(item ->
|
|
|
{
|
|
|
List<String> delBillNos = new ArrayList<>();
|
|
|
delBillNos.add(item.getBillNo());
|
|
|
orderService.deleteInvByBillNo(delBillNos);
|
|
|
for (String billNo : delBillNos) {
|
|
|
orderService.deleteByBillNo(billNo);
|
|
|
orderDetailBizService.deleteByOrderId(billNo);
|
|
|
orderDetailCodeService.deleteByOrderId(billNo);
|
|
|
codeTempService.deleteByBillNo(billNo);
|
|
|
codeService.deleteCodeByOrderId(billNo);
|
|
|
}
|
|
|
}
|
|
|
);
|
|
|
}
|
|
|
|
|
|
@Resource
|
|
|
SysWorkplaceService sysWorkplaceService;
|
|
|
|
|
|
@Resource
|
|
|
SysWorkplaceDocumentService sysWorkplaceDocumentService;
|
|
|
|
|
|
|
|
|
public void importUdi() {
|
|
|
//下载UDI内部单据
|
|
|
FilterOrderRequest filterOrderRequest = new FilterOrderRequest();
|
|
|
// filterOrderRequest.setPage(1);
|
|
|
// filterOrderRequest.setLimit(1000);
|
|
|
filterOrderRequest.setStatus(7);
|
|
|
filterOrderRequest.setProductType(null);
|
|
|
List<IoOrderResponse> list = orderService.filterList(filterOrderRequest);
|
|
|
List<IoCollectOrder> collectOrderList = new ArrayList<>();
|
|
|
for (IoOrderResponse ioOrderEntity : list) {
|
|
|
|
|
|
if (collectOrderMapper.exists(new LambdaQueryWrapper<IoCollectOrder>().eq(IoCollectOrder::getBillNo, ioOrderEntity.getBillNo()))) {
|
|
|
continue;
|
|
|
}
|
|
|
BasicCollectBustypeEntity collectBustypeEntity = collectBustypeService.findByAddr(ioOrderEntity.getAction());
|
|
|
if (collectBustypeEntity == null)
|
|
|
continue;
|
|
|
List<SysWorkplace> sysWorkplaces = sysWorkplaceService.getAllByBusType(collectBustypeEntity.getCode());
|
|
|
|
|
|
|
|
|
//自动分配工位
|
|
|
final Long[] defaultWorkplace = {null};
|
|
|
if (CollUtil.isNotEmpty(sysWorkplaces)) {
|
|
|
if (sysWorkplaces.size() == 1) {
|
|
|
defaultWorkplace[0] = sysWorkplaces.get(0).getWorkplaceId();
|
|
|
} else {
|
|
|
List<SysWorkplace> addWorkplace = new ArrayList<>();
|
|
|
for (SysWorkplace sysWorkplace : sysWorkplaces) {
|
|
|
//获取是否有正在处理的工位
|
|
|
List<IoCollectOrder> collectOrderList1 = collectOrderMapper.selectList(new LambdaQueryWrapper<IoCollectOrder>()
|
|
|
.eq(IoCollectOrder::getWorkPlaceCode, sysWorkplace.getWorkplaceId()).in(IoCollectOrder::getTagStatus, -1, 1, 2));
|
|
|
sysWorkplace.setOrderCount(collectOrderList1.size());
|
|
|
if (IntUtil.value(sysWorkplace.getOrderCount()) > 0) {
|
|
|
addWorkplace.add(sysWorkplace);
|
|
|
}
|
|
|
}
|
|
|
if (addWorkplace.size() > 0) {
|
|
|
Optional<SysWorkplace> minCountObject = addWorkplace.stream()
|
|
|
.min((o1, o2) -> Integer.compare(o1.getOrderCount(), o2.getOrderCount()));
|
|
|
minCountObject.ifPresent(sysWorkplace -> defaultWorkplace[0] = sysWorkplace.getWorkplaceId());
|
|
|
} else {
|
|
|
defaultWorkplace[0] = sysWorkplaces.get(0).getWorkplaceId();
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
IoCollectOrder collectOrder = IoCollectOrder.builder()
|
|
|
.billNo(ioOrderEntity.getBillNo())
|
|
|
.busType(collectBustypeEntity.getCode())
|
|
|
.fromType(collectBustypeEntity.getFromType())
|
|
|
.fromCorp(ioOrderEntity.getFromName())
|
|
|
.workPlaceCode(defaultWorkplace[0])
|
|
|
.billTime(ioOrderEntity.getCreateTime())
|
|
|
.createTime(ioOrderEntity.getCreateTime())
|
|
|
.createUser(ioOrderEntity.getCreateUser())
|
|
|
.updateTime(new Date())
|
|
|
.splitStatus(0)
|
|
|
.tagStatus(0)
|
|
|
.build();
|
|
|
if (collectOrder.getWorkPlaceCode() != null) {
|
|
|
collectOrder.setTagStatus(1);
|
|
|
}
|
|
|
collectOrderList.add(collectOrder);
|
|
|
List<IoOrderDetailBizEntity> orderDetailBizEntities = orderDetailBizService.findByOrderId(ioOrderEntity.getBillNo());
|
|
|
|
|
|
List<IoCollectOrderBiz> collectOrderBizs = new ArrayList<>();
|
|
|
for (IoOrderDetailBizEntity bizEntity : orderDetailBizEntities) {
|
|
|
UdiRelevanceResponse udiRelevanceResponse = udiRelevanceService.selectByRelId(bizEntity.getBindRlFk() + "");
|
|
|
IoCollectOrderBiz collectOrderBiz = IoCollectOrderBiz.builder().orderIdFk(collectOrder.getBillNo())
|
|
|
.relId(bizEntity.getBindRlFk())
|
|
|
.thrCode(udiRelevanceResponse.getMainId())
|
|
|
.ybbm(udiRelevanceResponse.getYbbm())
|
|
|
.payFeeCode(udiRelevanceResponse.getPayFeeCode())
|
|
|
.cpmctymc(bizEntity.getCoName())
|
|
|
.nameCode(bizEntity.getNameCode())
|
|
|
.ggxh(bizEntity.getSpec())
|
|
|
.batchNo(bizEntity.getBatchNo())
|
|
|
.productDate(bizEntity.getProductDate())
|
|
|
.expireDate(bizEntity.getExpireDate())
|
|
|
.count(bizEntity.getCount())
|
|
|
.measureUnit(bizEntity.getMeasname())
|
|
|
.tagStatus(1)
|
|
|
.unTagCount(bizEntity.getCount()).build();
|
|
|
|
|
|
if (IntUtil.value(udiRelevanceResponse.getProductsType()) == 2) {
|
|
|
collectOrderBiz.setGgxh(udiRelevanceResponse.getBzgg());
|
|
|
collectOrderBiz.setMeasureUnit(udiRelevanceResponse.getPrepnUnit());
|
|
|
}
|
|
|
collectOrderBizs.add(collectOrderBiz);
|
|
|
}
|
|
|
if (CollUtil.isNotEmpty(collectOrderBizs))
|
|
|
collectOrderBizService.saveBatch(collectOrderBizs);
|
|
|
}
|
|
|
if (CollUtil.isNotEmpty(collectOrderList)) {
|
|
|
saveBatch(collectOrderList);
|
|
|
}
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
public void importPrescribe() {
|
|
|
//下载处方
|
|
|
List<BasicSkPrescribeEntity> basicSkPrescribeEntities = basicSkPrescribeService.list();
|
|
|
|
|
|
List<IoCollectOrder> collectOrderList = new ArrayList<>();
|
|
|
for (BasicSkPrescribeEntity basicSkPrescribeEntity : basicSkPrescribeEntities) {
|
|
|
BasicCollectBustypeEntity collectBustypeEntity = collectBustypeService.findByAddr(String.valueOf(basicSkPrescribeEntity.getAddr()));
|
|
|
|
|
|
|
|
|
if (collectBustypeEntity == null)
|
|
|
continue;
|
|
|
if (collectOrderMapper.exists(new LambdaQueryWrapper<IoCollectOrder>().eq(IoCollectOrder::getBillNo, basicSkPrescribeEntity.getCode()))) {
|
|
|
continue;
|
|
|
}
|
|
|
//自动分配工位
|
|
|
final Long[] defaultWorkplace = {null};
|
|
|
List<SysWorkplace> sysWorkplaces = sysWorkplaceService.getAllByBusType(collectBustypeEntity.getCode());
|
|
|
if (CollUtil.isNotEmpty(sysWorkplaces)) {
|
|
|
if (sysWorkplaces.size() == 1) {
|
|
|
defaultWorkplace[0] = sysWorkplaces.get(0).getWorkplaceId();
|
|
|
} else {
|
|
|
List<SysWorkplace> addWorkplace = new ArrayList<>();
|
|
|
for (SysWorkplace sysWorkplace : sysWorkplaces) {
|
|
|
//获取是否有正在处理的工位
|
|
|
List<IoCollectOrder> collectOrderList1 = collectOrderMapper.selectList(new LambdaQueryWrapper<IoCollectOrder>()
|
|
|
.eq(IoCollectOrder::getWorkPlaceCode, sysWorkplace.getWorkplaceId()).in(IoCollectOrder::getTagStatus, -1, 1, 2));
|
|
|
sysWorkplace.setOrderCount(collectOrderList1.size());
|
|
|
if (IntUtil.value(sysWorkplace.getOrderCount()) > 0) {
|
|
|
addWorkplace.add(sysWorkplace);
|
|
|
}
|
|
|
}
|
|
|
if (addWorkplace.size() > 0) {
|
|
|
Optional<SysWorkplace> minCountObject = addWorkplace.stream()
|
|
|
.min((o1, o2) -> Integer.compare(o1.getOrderCount(), o2.getOrderCount()));
|
|
|
minCountObject.ifPresent(sysWorkplace -> defaultWorkplace[0] = sysWorkplace.getWorkplaceId());
|
|
|
} else {
|
|
|
defaultWorkplace[0] = sysWorkplaces.get(0).getWorkplaceId();
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
|
|
|
|
|
|
IoCollectOrder collectOrder = IoCollectOrder.builder()
|
|
|
.billNo(basicSkPrescribeEntity.getCode())
|
|
|
.busType(collectBustypeEntity.getCode())
|
|
|
.fromType(collectBustypeEntity.getFromType())
|
|
|
.fromCorp(basicSkPrescribeEntity.getSickerCode())
|
|
|
.workPlaceCode(defaultWorkplace[0])
|
|
|
.billTime(MsDateUtil.localToDate(basicSkPrescribeEntity.getCreateTime()))
|
|
|
.createTime(new Date())
|
|
|
.createUser(basicSkPrescribeEntity.getCreateUser())
|
|
|
.updateTime(new Date())
|
|
|
.splitStatus(0)
|
|
|
.tagStatus(0)
|
|
|
.build();
|
|
|
if (collectOrder.getWorkPlaceCode() != null) {
|
|
|
collectOrder.setTagStatus(1);
|
|
|
}
|
|
|
collectOrderList.add(collectOrder);
|
|
|
List<BasicSkPrescribeItemEntity> basicSkPrescribeItemEntities = basicSkPrescirbeDetailService.findByPrescribeNum(basicSkPrescribeEntity.getCode());
|
|
|
|
|
|
List<IoCollectOrderBiz> collectOrderBizs = new ArrayList<>();
|
|
|
for (BasicSkPrescribeItemEntity bizEntity : basicSkPrescribeItemEntities) {
|
|
|
UdiRelevanceResponse udiRelevanceResponse = udiRelevanceService.selectByRelId(bizEntity.getRelId() + "");
|
|
|
IoCollectOrderBiz collectOrderBiz = IoCollectOrderBiz.builder().orderIdFk(collectOrder.getBillNo())
|
|
|
.relId(bizEntity.getRelId())
|
|
|
.thrCode(bizEntity.getItemCode())
|
|
|
.ybbm(udiRelevanceResponse.getYbbm())
|
|
|
.payFeeCode(udiRelevanceResponse.getPayFeeCode())
|
|
|
.cpmctymc(bizEntity.getItemName())
|
|
|
.nameCode(udiRelevanceResponse.getNameCode())
|
|
|
.ggxh(bizEntity.getGgxh())
|
|
|
.batchNo(bizEntity.getBatchNo())
|
|
|
.count(IntUtil.value(bizEntity.getMeasureCount()))
|
|
|
.measureUnit(bizEntity.getMeasureUnit())
|
|
|
.tagStatus(1)
|
|
|
.unTagCount(bizEntity.getCount()).build();
|
|
|
|
|
|
if (IntUtil.value(udiRelevanceResponse.getProductsType()) == 2) {
|
|
|
collectOrderBiz.setGgxh(udiRelevanceResponse.getBzgg());
|
|
|
collectOrderBiz.setMeasureUnit(udiRelevanceResponse.getPrepnUnit());
|
|
|
}
|
|
|
collectOrderBizs.add(collectOrderBiz);
|
|
|
}
|
|
|
if (CollUtil.isNotEmpty(collectOrderBizs))
|
|
|
collectOrderBizService.saveBatch(collectOrderBizs);
|
|
|
}
|
|
|
if (CollUtil.isNotEmpty(collectOrderList)) {
|
|
|
saveBatch(collectOrderList);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
|
public void removeCode(DeleteTageCodeRequest deleteTageCodeRequest) {
|
|
|
Integer delType = deleteTageCodeRequest.getDelType();
|
|
|
Long codeManId = deleteTageCodeRequest.getCodeManId();
|
|
|
IoCollectOrderCodeMan ioCollectOrderCodeMan = ioCollectOrderCodeManService.getById(codeManId);
|
|
|
if (ioCollectOrderCodeMan == null) throw new JsonException("码明细id有误");
|
|
|
Long bizIdFk = ioCollectOrderCodeMan.getBizIdFk();
|
|
|
Integer scanCount = ioCollectOrderCodeMan.getScanCount();
|
|
|
Integer delCount = 0;
|
|
|
if (delType == 1) {//1.减一，，，IoCollectOrderCodeMan-1 IoCollectOrderBiz-1
|
|
|
Integer newCount = scanCount - 1;
|
|
|
delCount = 1;
|
|
|
if (newCount == 0) {
|
|
|
ioCollectOrderCodeManService.removeById(codeManId);
|
|
|
} else {
|
|
|
ioCollectOrderCodeMan.setScanCount(newCount);
|
|
|
ioCollectOrderCodeManService.updateById(ioCollectOrderCodeMan);
|
|
|
}
|
|
|
} else if (delType == 2) {//2.删除 IoCollectOrderCodeMan-删除 IoCollectOrderBiz-数量
|
|
|
delCount = scanCount;
|
|
|
ioCollectOrderCodeManService.removeById(codeManId);
|
|
|
}
|
|
|
|
|
|
if (delCount > 0) {
|
|
|
IoCollectOrderBiz bizServiceOne = collectOrderBizService.getOne(new LambdaQueryWrapper<IoCollectOrderBiz>()
|
|
|
.eq(IoCollectOrderBiz::getId, bizIdFk));
|
|
|
if (bizServiceOne == null) throw new JsonException("扫码详情未查找到");
|
|
|
Integer oneScanCount = bizServiceOne.getScanCount();
|
|
|
Integer newCount = oneScanCount - delCount;
|
|
|
bizServiceOne.setScanCount(newCount);
|
|
|
collectOrderBizService.updateById(bizServiceOne);
|
|
|
}
|
|
|
|
|
|
}
|
|
|
}
|
