package com.glxp.api.controller.sync; import cn.hutool.core.collection.CollUtil; import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.lang.Dict; import cn.hutool.core.util.StrUtil; import cn.hutool.json.JSONObject; import cn.hutool.json.JSONUtil; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.glxp.api.annotation.AuthRuleAnnotation; 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.constant.BasicExportStatusEnum; import com.glxp.api.constant.BasicExportTypeEnum; import com.glxp.api.constant.BasicProcessStatus; import com.glxp.api.constant.ConstantStatus; import com.glxp.api.dao.auth.*; import com.glxp.api.dao.basic.*; import com.glxp.api.dao.inout.*; import com.glxp.api.dao.purchase.*; import com.glxp.api.dao.schedule.SystemParamConfigDao; import com.glxp.api.dao.system.*; import com.glxp.api.dao.thrsys.*; import com.glxp.api.entity.auth.*; import com.glxp.api.entity.basic.*; import com.glxp.api.entity.inout.*; import com.glxp.api.entity.purchase.*; import com.glxp.api.entity.sync.BasicDownloadStatusEntity; import com.glxp.api.entity.sync.BasicExportStatusEntity; import com.glxp.api.entity.system.*; import com.glxp.api.entity.thrsys.*; import com.glxp.api.req.sync.SpsSyncDataRequest; import com.glxp.api.req.sync.SyncUpLoadRequest; import com.glxp.api.res.sync.*; import com.glxp.api.service.inout.IoAddInoutService; import com.glxp.api.service.inout.IoCheckInoutService; import com.glxp.api.service.inout.IoOrderService; import com.glxp.api.service.purchase.PurOrderDetailService; import com.glxp.api.service.purchase.PurOrderService; import com.glxp.api.service.sync.BasicDownloadService; import com.glxp.api.service.sync.BasicExportService; import com.glxp.api.service.sync.SpsSyncDownloadService; import com.glxp.api.util.CustomUtil; import com.glxp.api.util.JsonUtils; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import lombok.RequiredArgsConstructor; import org.apache.ibatis.session.ExecutorType; import org.apache.ibatis.session.SqlSession; import org.apache.ibatis.session.SqlSessionFactory; import org.apache.ibatis.session.TransactionIsolationLevel; import org.springframework.beans.BeanUtils; 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.io.FileNotFoundException; import java.io.FileReader; import java.io.IOException; import java.util.Date; import java.util.List; @RestController @Api(tags = "同步下载相关") @RequiredArgsConstructor public class SpsSyncDownloadController { @Resource SpsSyncDownloadService spsSyncDownloadService; @Resource BasicExportService basicExportService; @Resource BasicDownloadService basicDownloadService; @Resource SqlSessionFactory sqlSessionFactory; @Resource IoOrderService orderService; @Resource PurOrderService purOrderService; @Resource IoAddInoutService addInoutService; @Resource IoCheckInoutService ioCheckInoutService; @Resource PurOrderDetailService purOrderDetailService; @Resource AuthAdminDao authAdminDao; @Resource InvBusUserDao invBusUserDao; @Resource DeptDao deptDao; @Resource DeptUserDao deptUserDao; @Resource InvWarehouseDao invWarehouseDao; @Resource WarehouseBussinessTypeDao warehouseBussinessTypeDao; @Resource WarehouseUserDao warehouseUserDao; private final InvSpaceDao invSpaceDao; // 下发单据接口 ，供给中继服务，UDI管理系统下载 @AuthRuleAnnotation("") @GetMapping("sps/sync/order") public BaseResponse getOrder(SpsSyncDataRequest spsSyncDataRequest) { BaseResponse baseResponse = spsSyncDownloadService.findOrder(spsSyncDataRequest); BasicExportStatusEntity basicExportStatusEntity = basicExportService.findByData(ConstantStatus.SYNC_SCAN_ORDER, 0); String logs = ""; if (basicExportStatusEntity != null) { logs = logs + "单据：" + baseResponse.getData().getOrderEntities().size() + "条\n"; if (CollUtil.isNotEmpty(baseResponse.getData().getOrderDetailBizEntities())) logs = logs + "单据详情：" + baseResponse.getData().getOrderDetailBizEntities().size() + "条\n"; if (CollUtil.isNotEmpty(baseResponse.getData().getCodeEntities())) logs = logs + "单据条码信息：" + baseResponse.getData().getCodeEntities().size() + "条\n"; basicExportStatusEntity.setRemark(logs); basicExportService.updateExportStatus(basicExportStatusEntity); SpsSyncOrderResponse spsSyncOrderResponse = baseResponse.getData(); spsSyncOrderResponse.setTaskId(basicExportStatusEntity.getId()); baseResponse.setData(spsSyncOrderResponse); } return baseResponse; } // 下发国家库DI数据，供给中继服务，UDI管理系统下载 @AuthRuleAnnotation("") @GetMapping("sps/sync/syncUdis") public BaseResponse getDiProducts(SpsSyncDataRequest spsSyncDataRequest) { BaseResponse baseResponse = spsSyncDownloadService.syncUdi(spsSyncDataRequest); BasicExportStatusEntity basicExportStatusEntity = basicExportService.findByData(ConstantStatus.SYNC_DI_PRODUCTS, 0); String logs = ""; if (basicExportStatusEntity != null) { if (CollUtil.isNotEmpty(baseResponse.getData().getProductInfoEntityList())) logs = logs + "DI信息：" + baseResponse.getData().getProductInfoEntityList().size() + "条\n"; if (CollUtil.isNotEmpty(baseResponse.getData().getUdiCompanyEntities())) logs = logs + "医疗器械注册人：" + baseResponse.getData().getUdiCompanyEntities().size() + "条\n"; basicExportStatusEntity.setRemark(logs); basicExportService.updateExportStatus(basicExportStatusEntity); SpSyncUdiResponse spSyncUdiResponse = baseResponse.getData(); spSyncUdiResponse.setTaskId(basicExportStatusEntity.getId()); baseResponse.setData(spSyncUdiResponse); } return baseResponse; } // 下发基础数据 ，供给中继服务，UDI管理系统下载 @AuthRuleAnnotation("") @GetMapping("sps/sync/data") @ApiOperation("拉取同步任务数据") public BaseResponse data(BasicExportTypeEnum exportType) { BaseResponse baseResponse = new BaseResponse<>(); BasicExportStatusEntity one = basicExportService.getOne(Wrappers.lambdaQuery(BasicExportStatusEntity.class) .eq(BasicExportStatusEntity::getType, exportType.getRemark()) .orderByDesc(BasicExportStatusEntity::getStartTime) .last("limit 1") ); RelaySyncResponse relaySyncResponse = null; if (one != null) { if (BasicExportStatusEnum.WAIT_TRIGGERED.getCode().equals(one.getStatus())) { basicExportService.update(Wrappers.lambdaUpdate(BasicExportStatusEntity.class) .set(BasicExportStatusEntity::getStatus, BasicExportStatusEnum.WAIT_BUILT.getCode()) .set(BasicExportStatusEntity::getUpdateTime, new Date()) .eq(BasicExportStatusEntity::getStatus, BasicExportStatusEnum.WAIT_TRIGGERED.getCode()) .eq(BasicExportStatusEntity::getId, one.getId()) ); } else if (BasicExportStatusEnum.WAIT_SYNC.getCode().equals(one.getStatus())) { if (StrUtil.isBlank(one.getCacheFilePath())) { throw new RuntimeException("系统异常，文件名为空"); } relaySyncResponse = RelaySyncResponse.builder() .taskId(one.getId()) .filePath(one.getCacheFilePath()) .fileContent(this.readDataFile(one.getCacheFilePath())) .build(); } } baseResponse.setCode(ResultEnum.SUCCESS.getCode()); baseResponse.setData(relaySyncResponse); return baseResponse; } private String readDataFile(String fileFullPath) { // 读取文件数据 try { if (StrUtil.isBlank(fileFullPath)) { throw new RuntimeException("系统异常，文件名为空"); } FileReader reader = new FileReader(fileFullPath); StringBuilder str = new StringBuilder(); int data; while ((data = reader.read()) != -1) { str.append((char) data); } reader.close(); return str.toString(); } catch (FileNotFoundException e) { throw new RuntimeException("系统异常，未找到对应数据文件"); } catch (IOException e) { throw new RuntimeException(e); } } // 下发基础数据 ，供给中继服务，UDI管理系统下载 @AuthRuleAnnotation("") @GetMapping("sps/sync/basicData") public BaseResponse getBasicData() { BaseResponse baseResponse = new BaseResponse<>(); SpsSyncBasicDataResponse spsSyncBasicDataResponse = null; BasicExportStatusEntity one = basicExportService.getOne(Wrappers.lambdaQuery(BasicExportStatusEntity.class) .eq(BasicExportStatusEntity::getType, BasicExportTypeEnum.BASIC_DATA.getRemark()) .orderByDesc(BasicExportStatusEntity::getStartTime) .last("limit 1") ); if (one != null) { if (BasicExportStatusEnum.WAIT_TRIGGERED.getCode().equals(one.getStatus())) { basicExportService.update(Wrappers.lambdaUpdate(BasicExportStatusEntity.class) .set(BasicExportStatusEntity::getStatus, BasicExportStatusEnum.WAIT_BUILT.getCode()) .set(BasicExportStatusEntity::getUpdateTime, new Date()) .eq(BasicExportStatusEntity::getStatus, BasicExportStatusEnum.WAIT_TRIGGERED.getCode()) .eq(BasicExportStatusEntity::getId, one.getId()) ); } else if (BasicExportStatusEnum.WAIT_SYNC.getCode().equals(one.getStatus())) { // 读取文件数据 try { FileReader reader = new FileReader(one.getCacheFilePath()); StringBuilder str = new StringBuilder(); int data; while ((data = reader.read()) != -1) { str.append((char) data); } reader.close(); Dict map = JsonUtils.parseMap(str.toString()); spsSyncBasicDataResponse = new SpsSyncBasicDataResponse(); // 组装返回数据 spsSyncBasicDataResponse.setTaskId(one.getId()); spsSyncBasicDataResponse.setHospTypeList((List) map.get(BasicHospTypeEntity.class.getSimpleName())); spsSyncBasicDataResponse.setUdiRelevanceList((List) map.get(UdiRelevanceEntity.class.getSimpleName())); spsSyncBasicDataResponse.setProductsList((List) map.get(BasicProductsEntity.class.getSimpleName())); spsSyncBasicDataResponse.setRelevanceList((List) map.get(CompanyProductRelevanceEntity.class.getSimpleName())); spsSyncBasicDataResponse.setCorpList((List) map.get(BasicCorpEntity.class.getSimpleName())); spsSyncBasicDataResponse.setSupCertList((List) map.get(SupCertEntity.class.getSimpleName())); spsSyncBasicDataResponse.setSupCertSetList((List) map.get(SupCertSetEntity.class.getSimpleName())); spsSyncBasicDataResponse.setSupCompanyList((List) map.get(SupCompanyEntity.class.getSimpleName())); spsSyncBasicDataResponse.setSupManufacturerList((List) map.get(SupManufacturerEntity.class.getSimpleName())); spsSyncBasicDataResponse.setSupProductList((List) map.get(SupProductEntity.class.getSimpleName())); } catch (FileNotFoundException e) { throw new RuntimeException("系统异常，未找到对应数据文件"); } catch (IOException e) { throw new RuntimeException(e); } // 修改任务状态 // basicExportService.update(Wrappers.lambdaUpdate(BasicExportStatusEntity.class) // .set(BasicExportStatusEntity::getStatus, BasicExportStatusEnum.COMPLETED.getCode()) // .set(BasicExportStatusEntity::getUpdateTime, new Date()) // .set(BasicExportStatusEntity::getEndTime, new Date()) // .eq(BasicExportStatusEntity::getStatus, BasicExportStatusEnum.WAIT_SYNC.getCode()) // .eq(BasicExportStatusEntity::getId, one.getId()) // ); } } baseResponse.setCode(ResultVOUtils.success().getCode()); baseResponse.setData(spsSyncBasicDataResponse); return baseResponse; } // 下发基础数据 ，供给中继服务，UDI管理系统下载 @AuthRuleAnnotation("") @GetMapping("sps/sync/otherData") public BaseResponse getOtherData() { BaseResponse baseResponse = new BaseResponse<>(); SpsSyncOtherDataResponse spsSyncOtherDataResponse = null; BasicExportStatusEntity one = basicExportService.getOne(Wrappers.lambdaQuery(BasicExportStatusEntity.class) .eq(BasicExportStatusEntity::getType, BasicExportTypeEnum.OTHER_DATA.getRemark()) .orderByDesc(BasicExportStatusEntity::getStartTime) .last("limit 1") ); if (one != null) { if (BasicExportStatusEnum.WAIT_TRIGGERED.getCode().equals(one.getStatus())) { basicExportService.update(Wrappers.lambdaUpdate(BasicExportStatusEntity.class) .set(BasicExportStatusEntity::getStatus, BasicExportStatusEnum.WAIT_BUILT.getCode()) .set(BasicExportStatusEntity::getUpdateTime, new Date()) .eq(BasicExportStatusEntity::getStatus, BasicExportStatusEnum.WAIT_TRIGGERED.getCode()) .eq(BasicExportStatusEntity::getId, one.getId()) ); } else if (BasicExportStatusEnum.WAIT_SYNC.getCode().equals(one.getStatus())) { // 读取文件数据 try { FileReader reader = new FileReader(one.getCacheFilePath()); StringBuilder str = new StringBuilder(); int data; while ((data = reader.read()) != -1) { str.append((char) data); } reader.close(); Dict map = JsonUtils.parseMap(str.toString()); spsSyncOtherDataResponse = new SpsSyncOtherDataResponse(); // 组装返回数据 spsSyncOtherDataResponse.setTaskId(one.getId()); spsSyncOtherDataResponse.setIoCodeLostList((List) map.get(IoCodeLostEntity.class.getSimpleName())); spsSyncOtherDataResponse.setIoCodeRelList((List) map.get(IoCodeRelEntity.class.getSimpleName())); } catch (FileNotFoundException e) { throw new RuntimeException("系统异常，未找到对应数据文件"); } catch (IOException e) { throw new RuntimeException(e); } } } baseResponse.setCode(ResultVOUtils.success().getCode()); baseResponse.setData(spsSyncOtherDataResponse); return baseResponse; } @ApiOperation("上传同步数据") @PostMapping("sps/sync/upload/data") public Object uploadData(@RequestBody SyncUpLoadRequest upLoadRequest) { try { JSONObject obj = JSONUtil.parseObj(upLoadRequest.getData()); switch (upLoadRequest.getExportType()) { case BASIC_DATA: saveUploadBasicData(JSONUtil.toBean(obj, SpsSyncBasicDataResponse.class)); break; case OTHER_DATA: saveUploadOtherData(JSONUtil.toBean(obj, SpsSyncOtherDataResponse.class)); break; case DOCUMENT_TYPE_DATA: saveUploadDocumentTypeData(JSONUtil.toBean(obj, SpsSyncBusResponse.class)); break; case USER_DATA: saveUploadUserData(JSONUtil.toBean(obj, SpsSyncDataResponse.class)); break; case THIRD_DATA: saveUploadThrData(JSONUtil.toBean(obj, SpsSyncThrDataResponse.class)); break; case COUNTRY_DI_DATA: } String taskId = obj.getStr("taskId"); BasicDownloadStatusEntity downloadStatus = BasicDownloadStatusEntity.builder() .id(taskId) .taskId(taskId) .startTime(new Date()) .endTime(new Date()) .updateTime(new Date()) .type(upLoadRequest.getExportType().getRemark()) .idDatas(upLoadRequest.getExportType().getKey()) .scheduleType(1) .build(); basicDownloadService.insertDownloadStatus(downloadStatus); return ResultVOUtils.success(); } catch (Exception e) { e.printStackTrace(); return ResultVOUtils.error(ResultEnum.NOT_NETWORK, e.getMessage()); } } private final ThrDeptDao thrDeptDao; private final ThrInvWarehouseDao thrInvWarehouseDao; private final ThrProductsDao thrProductsDao; private final ThrCorpDao thrCorpDao; private void saveUploadThrData(SpsSyncThrDataResponse bean) { if (CollectionUtil.isNotEmpty(bean.getDeptEntities())) { thrDeptDao.insertOrUpdateBatch(bean.getDeptEntities()); } if (CollectionUtil.isNotEmpty(bean.getInvWarehouseEntities())) { thrInvWarehouseDao.insertOrUpdateBatch(bean.getInvWarehouseEntities()); } if (CollectionUtil.isNotEmpty(bean.getProductsEntityList())) { thrProductsDao.insertOrUpdateBatch(bean.getProductsEntityList()); } if (CollectionUtil.isNotEmpty(bean.getCorpEntities())) { thrCorpDao.insertOrUpdateBatch(bean.getCorpEntities()); } } private void saveUploadUserData(SpsSyncDataResponse bean) { if (CollectionUtil.isNotEmpty(bean.getAuthAdminList())) { authAdminDao.insertOrUpdateBatch(bean.getAuthAdminList()); } if (CollectionUtil.isNotEmpty(bean.getDeptEntityList())) { deptDao.insertOrUpdateBatch(bean.getDeptEntityList()); } if (CollectionUtil.isNotEmpty(bean.getDeptUserEntities())) { deptUserDao.insertOrUpdateBatch(bean.getDeptUserEntities()); } if (CollectionUtil.isNotEmpty(bean.getInvWarehouseEntities())) { invWarehouseDao.insertOrUpdateBatch(bean.getInvWarehouseEntities()); } if (CollectionUtil.isNotEmpty(bean.getWarehouseUserEntities())) { warehouseUserDao.insertOrUpdateBatch(bean.getWarehouseUserEntities()); } if (CollectionUtil.isNotEmpty(bean.getWarehouseBussinessTypeEntities())) { warehouseBussinessTypeDao.insertOrUpdateBatch(bean.getWarehouseBussinessTypeEntities()); } if (CollectionUtil.isNotEmpty(bean.getInvSpaces())) { invSpaceDao.insertOrUpdateBatch(bean.getInvSpaces()); } if (CollectionUtil.isNotEmpty(bean.getInvBusUserEntities())) { invBusUserDao.insertOrUpdateBatch(bean.getInvBusUserEntities()); } } private final BasicBussinessTypeDao basicBussinessTypeDao; private final BasicBusTypeChangeDao busTypeChangeDao; private final ThrBusTypeOriginDao thrBusTypeOriginDao; /** * 保存上传的单据类型数据 * * @param bean */ private void saveUploadDocumentTypeData(SpsSyncBusResponse bean) { if (CollectionUtil.isNotEmpty(bean.getBussinessTypeEntities())) { basicBussinessTypeDao.insertOrUpdateBatch(bean.getBussinessTypeEntities()); } if (CollectionUtil.isNotEmpty(bean.getBusTypeChangeEntities())) { busTypeChangeDao.insertOrUpdateBatch(bean.getBusTypeChangeEntities()); } if (CollectionUtil.isNotEmpty(bean.getThrBusTypeOriginEntities())) { thrBusTypeOriginDao.insertOrUpdateBatch(bean.getThrBusTypeOriginEntities()); } } private final IoCodeLostMapper ioCodeLostMapper; private final IoCodeRelMapper ioCodeRelMapper; /** * 保存上传的其他数据 * * @param bean */ private void saveUploadOtherData(SpsSyncOtherDataResponse bean) { if (CollectionUtil.isNotEmpty(bean.getIoCodeLostList())) { ioCodeLostMapper.insertOrUpdateBatch(bean.getIoCodeLostList()); } if (CollectionUtil.isNotEmpty(bean.getIoCodeRelList())) { ioCodeRelMapper.insertOrUpdateBatch(bean.getIoCodeRelList()); } } private final BasicHospTypeDao basicHospTypeDao; private final UdiRelevanceDao udiRelevanceDao; private final BasicProductsDao basicProductsDao; private final CompanyProductRelevanceDao relevanceDao; private final BasicCorpDao corpDao; private final SupCertDao supCertDao; private final SupCertSetDao supCertSetDao; private final SupCompanyDao supCompanyDao; private final SupManufacturerDao supManufacturerDao; private final SupProductDao supProductDao; /** * 保存上传的基础数据 * * @param bean */ private void saveUploadBasicData(SpsSyncBasicDataResponse bean) { if (CollectionUtil.isNotEmpty(bean.getHospTypeList())) { basicHospTypeDao.insertOrUpdateBatch(bean.getHospTypeList()); } if (CollectionUtil.isNotEmpty(bean.getUdiRelevanceList())) { udiRelevanceDao.insertOrUpdateBatch(bean.getUdiRelevanceList()); } if (CollectionUtil.isNotEmpty(bean.getProductsList())) { basicProductsDao.insertOrUpdateBatch(bean.getProductsList()); } if (CollectionUtil.isNotEmpty(bean.getRelevanceList())) { relevanceDao.insertOrUpdateBatch(bean.getRelevanceList()); } if (CollectionUtil.isNotEmpty(bean.getCorpList())) { corpDao.insertOrUpdateBatch(bean.getCorpList()); } if (CollectionUtil.isNotEmpty(bean.getSupCertList())) { supCertDao.insertOrUpdateBatch(bean.getSupCertList()); } if (CollectionUtil.isNotEmpty(bean.getSupCertSetList())) { supCertSetDao.insertOrUpdateBatch(bean.getSupCertSetList()); } if (CollectionUtil.isNotEmpty(bean.getSupCompanyList())) { supCompanyDao.insertOrUpdateBatch(bean.getSupCompanyList()); } if (CollectionUtil.isNotEmpty(bean.getSupManufacturerList())) { supManufacturerDao.insertOrUpdateBatch(bean.getSupManufacturerList()); } if (CollectionUtil.isNotEmpty(bean.getSupProductList())) { supProductDao.insertOrUpdateBatch(bean.getSupProductList()); } } //接收中继服务、UDI管理系统上传单据 @AuthRuleAnnotation("sps/sync/order/upload") @PostMapping("/sps/sync/order/upload") public BaseResponse uploadOrder(@RequestBody @Valid SpsSyncOrderResponse syncDataResponse) { BasicDownloadStatusEntity basicDownloadStatusEntity = new BasicDownloadStatusEntity(); basicDownloadStatusEntity.setId(CustomUtil.getId()); basicDownloadStatusEntity.setTaskId(syncDataResponse.getTaskId()); basicDownloadStatusEntity.setStartTime(new Date()); basicDownloadStatusEntity.setIdDatas(ConstantStatus.SYNC_DOWNLOAD_SCAN_ORDER); basicDownloadStatusEntity.setStatus(ConstantStatus.SYNC_STATUS_WAIT); //下载中 basicDownloadStatusEntity.setType(BasicProcessStatus.NEW_ALL_ORDER); basicDownloadStatusEntity.setScheduleType(1); basicDownloadService.insertDownloadStatus(basicDownloadStatusEntity); StringBuffer remark = new StringBuffer(); SqlSession batchSession = sqlSessionFactory.openSession(ExecutorType.BATCH, TransactionIsolationLevel.READ_COMMITTED); if (CollUtil.isNotEmpty(syncDataResponse.getOrderEntities())) { try { List orderEntities = syncDataResponse.getOrderEntities(); IoOrderDao mapper = batchSession.getMapper(IoOrderDao.class); for (IoOrderEntity orderEntity : orderEntities) { orderEntity.setUpdateTime(null); orderEntity.setFromType(ConstantStatus.FROM_UDISP); orderEntity.setStatus(ConstantStatus.ORDER_STATUS_PROCESS); IoOrderEntity temp = orderService.findById(orderEntity.getBillNo()); if (temp == null) { orderEntity.setId(null); mapper.insert(orderEntity); //更新码详情 if (CollUtil.isNotEmpty(syncDataResponse.getOrderDetailCodeEntities())) { IoCodeTempDao codeMappert = batchSession.getMapper(IoCodeTempDao.class); List warehouseEntityList = syncDataResponse.getCodeEntities(); for (IoCodeEntity warehouseEntity : warehouseEntityList) { if (warehouseEntity.getOrderId().equals(orderEntity.getBillNo())) { IoCodeTempEntity codeTempEntity = new IoCodeTempEntity(); BeanUtils.copyProperties(warehouseEntity, codeTempEntity); codeTempEntity.setId(null); codeMappert.insert(codeTempEntity); } } } //更新业务详情 if (CollUtil.isNotEmpty(syncDataResponse.getOrderDetailBizEntities())) { IoOrderDetailBizDao orderDetailBizDao = batchSession.getMapper(IoOrderDetailBizDao.class); List orderDetailBizEntities = syncDataResponse.getOrderDetailBizEntities(); for (IoOrderDetailBizEntity bizEntity : orderDetailBizEntities) { if (bizEntity.getOrderIdFk().equals(orderEntity.getBillNo())) { orderDetailBizDao.insert(bizEntity); } } } //更新码详情 if (CollUtil.isNotEmpty(syncDataResponse.getOrderDetailCodeEntities())) { IoOrderDetailCodeDao orderDetailCodeDao = batchSession.getMapper(IoOrderDetailCodeDao.class); List orderDetailCodeEntities = syncDataResponse.getOrderDetailCodeEntities(); for (IoOrderDetailCodeEntity codeEntity : orderDetailCodeEntities) { if (codeEntity.getOrderIdFk().equals(orderEntity.getBillNo())) { orderDetailCodeDao.insert(codeEntity); } } } //更新结果详情 if (CollUtil.isNotEmpty(syncDataResponse.getOrderDetailResultEntities())) { IoOrderDetailResultDao orderDetailResultDao = batchSession.getMapper(IoOrderDetailResultDao.class); List orderDetailResultEntities = syncDataResponse.getOrderDetailResultEntities(); for (IoOrderDetailResultEntity detailResultEntity : orderDetailResultEntities) { if (detailResultEntity.getOrderIdFk().equals(orderEntity.getBillNo())) { orderDetailResultDao.insert(detailResultEntity); } } } //更新发票信息 if (CollUtil.isNotEmpty(syncDataResponse.getOrderInvoiceEntities())) { IoOrderInvoiceMapper orderInvoiceMapper = batchSession.getMapper(IoOrderInvoiceMapper.class); List orderInvoiceEntities = syncDataResponse.getOrderInvoiceEntities(); for (IoOrderInvoiceEntity orderInvoiceEntity : orderInvoiceEntities) { if (orderInvoiceEntity.getOrderIdFk().equals(orderEntity.getBillNo())) { orderInvoiceMapper.insert(orderInvoiceEntity); } } } batchSession.commit(); orderEntity = orderService.findByBillNo(orderEntity.getBillNo()); addInoutService.dealProcess(orderEntity); orderEntity = orderService.findByBillNo(orderEntity.getBillNo()); if (orderEntity.getStatus() != ConstantStatus.ORDER_STATS_ERROR && !ioCheckInoutService.checkManual(orderEntity.getBillNo())) { ioCheckInoutService.check(orderEntity.getBillNo()); } } } batchSession.commit(); String logs = ""; if (CollUtil.isNotEmpty(syncDataResponse.getOrderEntities())) logs = logs + "单据：" + syncDataResponse.getOrderEntities().size() + "条\n"; if (CollUtil.isNotEmpty(syncDataResponse.getOrderDetailBizEntities())) logs = logs + "业务详情：" + syncDataResponse.getOrderDetailBizEntities().size() + "条\n"; if (CollUtil.isNotEmpty(syncDataResponse.getOrderDetailCodeEntities())) logs = logs + "单据扫码详情：" + syncDataResponse.getOrderDetailCodeEntities().size() + "条\n"; if (CollUtil.isNotEmpty(syncDataResponse.getOrderDetailResultEntities())) logs = logs + "单据结果详情：" + syncDataResponse.getOrderDetailResultEntities().size() + "条\n"; if (CollUtil.isNotEmpty(syncDataResponse.getCodeEntities())) logs = logs + "单据条码信息：" + syncDataResponse.getCodeEntities().size() + "条\n"; remark.append(logs); } catch (Exception e) { e.printStackTrace(); } } batchSession.close(); basicDownloadStatusEntity.setUpdateTime(new Date()); basicDownloadStatusEntity.setEndTime(new Date()); basicDownloadStatusEntity.setRemark(remark.toString()); basicDownloadStatusEntity.setStatus(ConstantStatus.SYNC_STATUS_SUCCESS); basicDownloadService.updateDownloadStatus(basicDownloadStatusEntity); return ResultVOUtils.success("上传成功！"); } //接收中级服务，UDI管理系统上传业务单据 @AuthRuleAnnotation("/sps/sync/busOrder/upload") @PostMapping("/sps/sync/busOrder/upload") public BaseResponse uploadBusOrder(@RequestBody @Valid SpsSyncBusOrderResponse spsSyncBusOrderResponse) { BasicDownloadStatusEntity basicDownloadStatusEntity = new BasicDownloadStatusEntity(); basicDownloadStatusEntity.setId(CustomUtil.getId()); basicDownloadStatusEntity.setTaskId(spsSyncBusOrderResponse.getTaskId()); basicDownloadStatusEntity.setStartTime(new Date()); basicDownloadStatusEntity.setIdDatas(ConstantStatus.SYNC_DOWNLOAD_SCAN_ORDER); basicDownloadStatusEntity.setStatus(ConstantStatus.SYNC_STATUS_WAIT); //下载中 basicDownloadStatusEntity.setType(BasicProcessStatus.NEW_ALL_BUS_ORDER); basicDownloadStatusEntity.setScheduleType(1); basicDownloadService.insertDownloadStatus(basicDownloadStatusEntity); StringBuffer remark = new StringBuffer(); if (CollUtil.isNotEmpty(spsSyncBusOrderResponse.getPurOrderEntities())) { try { List orderEntities = spsSyncBusOrderResponse.getPurOrderEntities(); for (PurOrderEntity orderEntity : orderEntities) { orderEntity.setUpdateTime(null); PurOrderEntity temp = purOrderService.selectByBillNo(orderEntity.getBillNo()); if (temp == null) { orderEntity.setId(null); purOrderService.insert(orderEntity); if (CollUtil.isNotEmpty(spsSyncBusOrderResponse.getPurOrderDetailEntities())) { List purOrderDetailEntities = spsSyncBusOrderResponse.getPurOrderDetailEntities(); for (PurOrderDetailEntity purOrderDetailEntity : purOrderDetailEntities) { PurOrderDetailEntity codeTempEntity = new PurOrderDetailEntity(); BeanUtils.copyProperties(purOrderDetailEntity, codeTempEntity); codeTempEntity.setId(null); codeTempEntity.setOrderIdFk(orderEntity.getId() + ""); purOrderDetailService.insert(codeTempEntity); } } } } String logs = ""; if (CollUtil.isNotEmpty(spsSyncBusOrderResponse.getPurOrderEntities())) logs = logs + "单据：" + spsSyncBusOrderResponse.getPurOrderEntities().size() + "条\n"; if (CollUtil.isNotEmpty(spsSyncBusOrderResponse.getPurOrderDetailEntities())) logs = logs + "单据详情：" + spsSyncBusOrderResponse.getPurOrderDetailEntities().size() + "条\n"; remark.append(logs); } catch (Exception e) { e.printStackTrace(); } } basicDownloadStatusEntity.setUpdateTime(new Date()); basicDownloadStatusEntity.setEndTime(new Date()); basicDownloadStatusEntity.setRemark(remark.toString()); basicDownloadStatusEntity.setStatus(ConstantStatus.SYNC_STATUS_SUCCESS); basicDownloadService.updateDownloadStatus(basicDownloadStatusEntity); return ResultVOUtils.success("上传成功！"); } //接收中继服务、UDI管理系统上传单据类型 @AuthRuleAnnotation("") @PostMapping("sps/sync/busType/upload") public BaseResponse uploadBusType(@RequestBody SpsSyncBusResponse syncDataResponse) { if (syncDataResponse != null) { SqlSession batchSession = sqlSessionFactory.openSession(ExecutorType.BATCH, TransactionIsolationLevel.READ_COMMITTED); BasicDownloadStatusEntity basicDownloadStatusEntity = new BasicDownloadStatusEntity(); basicDownloadStatusEntity.setId(CustomUtil.getId()); basicDownloadStatusEntity.setTaskId(syncDataResponse.getTaskId()); basicDownloadStatusEntity.setStartTime(new Date()); basicDownloadStatusEntity.setIdDatas(ConstantStatus.SYNC_BUS_TYPE); basicDownloadStatusEntity.setStatus(0); basicDownloadStatusEntity.setType(BasicProcessStatus.NEW_ALL_BUS); basicDownloadStatusEntity.setScheduleType(1); basicDownloadService.insertDownloadStatus(basicDownloadStatusEntity); StringBuffer remark = new StringBuffer(); // 扫码单据类型 if (CollUtil.isNotEmpty(syncDataResponse.getBussinessTypeEntities())) { try { List bussinessTypeEntities = syncDataResponse.getBussinessTypeEntities(); BasicBussinessTypeDao mapper = batchSession.getMapper(BasicBussinessTypeDao.class); for (BasicBussinessTypeEntity bussinessTypeEntity : bussinessTypeEntities) { mapper.insertOrUpdate(bussinessTypeEntity); } batchSession.commit(); remark.append("扫码单据类型：").append(syncDataResponse.getBussinessTypeEntities().size()).append("条\n"); } catch (Exception e) { e.printStackTrace(); } } //业务单据 if (CollUtil.isNotEmpty(syncDataResponse.getBusTypeChangeEntities())) { try { List busTypeChangeEntities = syncDataResponse.getBusTypeChangeEntities(); BasicBusTypeChangeDao mapper = batchSession.getMapper(BasicBusTypeChangeDao.class); busTypeChangeEntities.forEach(busTypeChangeEntity -> { mapper.insertOrUpdate(busTypeChangeEntity); }); batchSession.commit(); remark.append("业务单据类型：").append(syncDataResponse.getBussinessTypeEntities().size()).append("条\n"); } catch (Exception e) { e.printStackTrace(); } } //原始单据 if (CollUtil.isNotEmpty(syncDataResponse.getThrBusTypeOriginEntities())) { try { List bussinessTypeEntities = syncDataResponse.getThrBusTypeOriginEntities(); ThrBusTypeOriginDao mapper = batchSession.getMapper(ThrBusTypeOriginDao.class); for (ThrBusTypeOriginEntity bussinessTypeEntity : bussinessTypeEntities) { mapper.insertOrUpdate(bussinessTypeEntity); } batchSession.commit(); remark.append("第三方单据类型：").append(syncDataResponse.getBussinessTypeEntities().size()).append("条\n"); } catch (Exception e) { e.printStackTrace(); } } batchSession.close(); basicDownloadStatusEntity.setStatus(1); basicDownloadStatusEntity.setUpdateTime(new Date()); basicDownloadStatusEntity.setEndTime(new Date()); basicDownloadStatusEntity.setRemark(remark.toString()); basicDownloadService.updateDownloadStatus(basicDownloadStatusEntity); } return ResultVOUtils.success("上传成功！"); } //接收中继服务、UDI管理系统上传用户数据 @AuthRuleAnnotation("") @PostMapping("sps/sync/userData/upload") public BaseResponse uploadUserData(@RequestBody SpsSyncDataResponse syncDataResponse) { if (syncDataResponse != null) { SqlSession batchSession = sqlSessionFactory.openSession(ExecutorType.BATCH, TransactionIsolationLevel.READ_COMMITTED); BasicDownloadStatusEntity basicDownloadStatusEntity = new BasicDownloadStatusEntity(); basicDownloadStatusEntity.setId(CustomUtil.getId()); basicDownloadStatusEntity.setTaskId(syncDataResponse.getTaskId()); basicDownloadStatusEntity.setStartTime(new Date()); basicDownloadStatusEntity.setIdDatas(ConstantStatus.SYNC_BASIC_DATA); basicDownloadStatusEntity.setStatus(0); basicDownloadStatusEntity.setType(BasicProcessStatus.NEW_ALL_DATA); basicDownloadStatusEntity.setScheduleType(1); basicDownloadService.insertDownloadStatus(basicDownloadStatusEntity); StringBuffer remark = new StringBuffer(); //用户表 if (CollUtil.isNotEmpty(syncDataResponse.getAuthAdminList())) { for (AuthAdmin authAdmin : syncDataResponse.getAuthAdminList()) { authAdmin.setId(null); authAdminDao.insertOrUpdate(authAdmin); remark.append("用户信息：").append(syncDataResponse.getAuthAdminList().size()).append("条\n"); } } //用户对应单据类型 if (CollUtil.isNotEmpty(syncDataResponse.getInvBusUserEntities())) { for (InvBusUserEntity invBusUserEntity : syncDataResponse.getInvBusUserEntities()) { invBusUserDao.insertOrUpdate(invBusUserEntity); } } // 部门信息 if (CollUtil.isNotEmpty(syncDataResponse.getDeptEntityList())) { for (DeptEntity deptEntity : syncDataResponse.getDeptEntityList()) { deptDao.insertOrUpdate(deptEntity); } } // 部门信息关联用户信息 if (CollUtil.isNotEmpty(syncDataResponse.getDeptUserEntities())) { for (DeptUserEntity deptUserEntity : syncDataResponse.getDeptUserEntities()) { deptUserDao.insertOrUpdate(deptUserEntity); } } //仓库字典导入 if (CollUtil.isNotEmpty(syncDataResponse.getInvWarehouseEntities())) { for (InvWarehouseEntity invWarehouseEntity : syncDataResponse.getInvWarehouseEntities()) { invWarehouseDao.insertOrUpdate(invWarehouseEntity); } remark.append("仓库字典：").append(syncDataResponse.getInvWarehouseEntities().size()).append("条\n"); } //仓库用户表 if (CollUtil.isNotEmpty(syncDataResponse.getWarehouseUserEntities())) { for (WarehouseUserEntity warehouseUserEntity : syncDataResponse.getWarehouseUserEntities()) { warehouseUserDao.insertOrUpdateEntity(warehouseUserEntity); } remark.append("仓库用户信息：").append(syncDataResponse.getWarehouseUserEntities().size()).append("条\n"); } //仓库单据类型表 if (CollUtil.isNotEmpty(syncDataResponse.getWarehouseBussinessTypeEntities())) { for (WarehouseBussinessTypeEntity warehouseUserEntity : syncDataResponse.getWarehouseBussinessTypeEntities()) { warehouseBussinessTypeDao.insertOrUpdate(warehouseUserEntity); } remark.append("仓库所属单据类型：").append(syncDataResponse.getWarehouseBussinessTypeEntities().size()).append("条\n"); } batchSession.close(); basicDownloadStatusEntity.setStatus(1); basicDownloadStatusEntity.setUpdateTime(new Date()); basicDownloadStatusEntity.setEndTime(new Date()); basicDownloadStatusEntity.setRemark(remark.toString()); basicDownloadService.updateDownloadStatus(basicDownloadStatusEntity); } return ResultVOUtils.success("上传成功！"); } //接收中继服务、UDI管理系统上传基础信息 //@AuthRuleAnnotation("") @PostMapping("/sps/sync/thrData/upload") public BaseResponse uploadThrData(@RequestBody @Valid SpsSyncThrDataResponse spsSyncThrDataResponse) { if (spsSyncThrDataResponse != null) { SqlSession sqlSession = sqlSessionFactory.openSession(ExecutorType.BATCH, TransactionIsolationLevel.READ_COMMITTED); BasicDownloadStatusEntity basicDownloadStatusEntity = new BasicDownloadStatusEntity(); basicDownloadStatusEntity.setId(CustomUtil.getId()); basicDownloadStatusEntity.setTaskId(spsSyncThrDataResponse.getTaskId()); basicDownloadStatusEntity.setStartTime(new Date()); basicDownloadStatusEntity.setIdDatas(ConstantStatus.SYNC_THR_DATA); basicDownloadStatusEntity.setStatus(0); basicDownloadStatusEntity.setType(BasicProcessStatus.NEW_ALL_THR_DATA); basicDownloadStatusEntity.setScheduleType(1); basicDownloadService.insertDownloadStatus(basicDownloadStatusEntity); StringBuilder remark = new StringBuilder(); //第三方部门信息 if (CollUtil.isNotEmpty(spsSyncThrDataResponse.getDeptEntities())) { List deptEntities = spsSyncThrDataResponse.getDeptEntities(); ThrDeptDao mapper = sqlSession.getMapper(ThrDeptDao.class); deptEntities.forEach(mapper::insertOrUpdateEntity); } sqlSession.commit(); remark.append("第三方部门信息：").append(spsSyncThrDataResponse.getDeptEntities().size()).append("条\n"); //第三方仓库信息 if (CollUtil.isNotEmpty(spsSyncThrDataResponse.getInvWarehouseEntities())) { List invWarehouseEntities = spsSyncThrDataResponse.getInvWarehouseEntities(); ThrInvWarehouseDao mapper = sqlSession.getMapper(ThrInvWarehouseDao.class); invWarehouseEntities.forEach(mapper::insertOrUpdateEntity); } sqlSession.commit(); remark.append("第三方仓库信息：").append(spsSyncThrDataResponse.getInvWarehouseEntities().size()).append("条\n"); //第三方往来单位信息 if (CollUtil.isNotEmpty(spsSyncThrDataResponse.getCorpEntities())) { List corpEntities = spsSyncThrDataResponse.getCorpEntities(); ThrCorpDao mapper = sqlSession.getMapper(ThrCorpDao.class); corpEntities.forEach(mapper::insertOrUpdateEntity); } sqlSession.commit(); remark.append("第三方往来单位信息：").append(spsSyncThrDataResponse.getCorpEntities().size()).append("条\n"); sqlSession.close(); basicDownloadStatusEntity.setStatus(1); basicDownloadStatusEntity.setUpdateTime(new Date()); basicDownloadStatusEntity.setEndTime(new Date()); basicDownloadStatusEntity.setRemark(remark.toString()); basicDownloadService.updateDownloadStatus(basicDownloadStatusEntity); } return ResultVOUtils.success("上传成功"); } //接收中继服务、UDI管理系统上传系统设置 //@AuthRuleAnnotation("") @PostMapping("/sps/sync/sys/setting") public BaseResponse uploadSysSetting(@RequestBody @Valid SpsSyncSysSettingResponse spsSyncSysSettingResponse) { if (spsSyncSysSettingResponse != null) { SqlSession sqlSession = sqlSessionFactory.openSession(ExecutorType.BATCH, TransactionIsolationLevel.READ_COMMITTED); BasicDownloadStatusEntity basicDownloadStatusEntity = new BasicDownloadStatusEntity(); basicDownloadStatusEntity.setId(CustomUtil.getId()); basicDownloadStatusEntity.setTaskId(spsSyncSysSettingResponse.getTaskId()); basicDownloadStatusEntity.setStartTime(new Date()); basicDownloadStatusEntity.setIdDatas(ConstantStatus.SYNC_SYS_SETTING); basicDownloadStatusEntity.setStatus(0); basicDownloadStatusEntity.setType(BasicProcessStatus.NEW_ALL_SYS_SETTING); basicDownloadStatusEntity.setScheduleType(1); basicDownloadService.insertDownloadStatus(basicDownloadStatusEntity); StringBuilder remark = new StringBuilder(); //系统运行参数 if (CollUtil.isNotEmpty(spsSyncSysSettingResponse.getSystemParamConfigEntities())) { List systemParamConfigEntities = spsSyncSysSettingResponse.getSystemParamConfigEntities(); SystemParamConfigDao mapper = sqlSession.getMapper(SystemParamConfigDao.class); systemParamConfigEntities.forEach(mapper::insertOrUpdate); } sqlSession.commit(); remark.append("系统运行参数：").append(spsSyncSysSettingResponse.getSystemParamConfigEntities().size()).append("条\n"); //委托验收设置 if (CollUtil.isNotEmpty(spsSyncSysSettingResponse.getEntrustReceEntities())) { List entrustReceEntities = spsSyncSysSettingResponse.getEntrustReceEntities(); EntrustReceDao mapper = sqlSession.getMapper(EntrustReceDao.class); entrustReceEntities.forEach(mapper::insertOrUpdate); } sqlSession.commit(); remark.append("委托验收设置：").append(spsSyncSysSettingResponse.getEntrustReceEntities().size()).append("条\n"); //打印模块 if (CollUtil.isNotEmpty(spsSyncSysSettingResponse.getSystemPDFModuleEntities())) { List systemPDFModuleEntities = spsSyncSysSettingResponse.getSystemPDFModuleEntities(); SystemPDFModuleDao mapper = sqlSession.getMapper(SystemPDFModuleDao.class); systemPDFModuleEntities.forEach(mapper::insertOrUpdate); } sqlSession.commit(); remark.append("打印模块：").append(spsSyncSysSettingResponse.getSystemPDFModuleEntities().size()).append("条\n"); //打印模板 if (CollUtil.isNotEmpty(spsSyncSysSettingResponse.getSystemPDFTemplateEntities())) { List systemPDFTemplateEntities = spsSyncSysSettingResponse.getSystemPDFTemplateEntities(); SystemPDFTemplateDao mapper = sqlSession.getMapper(SystemPDFTemplateDao.class); systemPDFTemplateEntities.forEach(mapper::insertOrUpdate); } sqlSession.commit(); remark.append("打印模板：").append(spsSyncSysSettingResponse.getSystemPDFTemplateEntities().size()).append("条\n"); //扫码单据关联表 if (CollUtil.isNotEmpty(spsSyncSysSettingResponse.getSysPdfTemplateRelevanceCodeEntities())) { List sysPdfTemplateRelevanceCodeEntities = spsSyncSysSettingResponse.getSysPdfTemplateRelevanceCodeEntities(); SysPdfTemplateRelevanceCodeDao mapper = sqlSession.getMapper(SysPdfTemplateRelevanceCodeDao.class); sysPdfTemplateRelevanceCodeEntities.forEach(mapper::insertOrUpdate); } sqlSession.commit(); remark.append("扫码单据关联表：").append(spsSyncSysSettingResponse.getSysPdfTemplateRelevanceCodeEntities().size()).append("条\n"); //业务单据关联表 if (CollUtil.isNotEmpty(spsSyncSysSettingResponse.getSysPdfTemplateRelevanceBizEntities())) { List sysPdfTemplateRelevanceBizEntities = spsSyncSysSettingResponse.getSysPdfTemplateRelevanceBizEntities(); SysPdfTemplateRelevanceBizDao mapper = sqlSession.getMapper(SysPdfTemplateRelevanceBizDao.class); sysPdfTemplateRelevanceBizEntities.forEach(mapper::insertOrUpdate); } sqlSession.commit(); remark.append("业务单据关联表：").append(spsSyncSysSettingResponse.getSysPdfTemplateRelevanceBizEntities().size()).append("条\n"); //内部码打印关联表 if (CollUtil.isNotEmpty(spsSyncSysSettingResponse.getSysPdfTemplateRelevanceLabelEntities())) { List sysPdfTemplateRelevanceLabelEntities = spsSyncSysSettingResponse.getSysPdfTemplateRelevanceLabelEntities(); SysPdfTemplateRelevanceLabelDao mapper = sqlSession.getMapper(SysPdfTemplateRelevanceLabelDao.class); sysPdfTemplateRelevanceLabelEntities.forEach(mapper::insertOrUpdate); } sqlSession.commit(); remark.append("内部码打印关联表：").append(spsSyncSysSettingResponse.getSystemParamConfigEntities().size()).append("条\n"); //资质证书打印关联表 if (CollUtil.isNotEmpty(spsSyncSysSettingResponse.getSysPdfTemplateRelevanceStatemenEntities())) { List sysPdfTemplateRelevanceStatemenEntities = spsSyncSysSettingResponse.getSysPdfTemplateRelevanceStatemenEntities(); SysPdfTemplateRelevanceStatemenDao mapper = sqlSession.getMapper(SysPdfTemplateRelevanceStatemenDao.class); sysPdfTemplateRelevanceStatemenEntities.forEach(mapper::insertOrUpdate); } sqlSession.commit(); remark.append("资质证书打印关联表：").append(spsSyncSysSettingResponse.getSysPdfTemplateRelevanceStatemenEntities().size()).append("条\n"); //自动建出入库单设置 if (CollUtil.isNotEmpty(spsSyncSysSettingResponse.getBasicBusTypePreEntities())) { List basicBusTypePreEntities = spsSyncSysSettingResponse.getBasicBusTypePreEntities(); BasicBusTypePreDao mapper = sqlSession.getMapper(BasicBusTypePreDao.class); basicBusTypePreEntities.forEach(mapper::insertOrUpdate); } sqlSession.commit(); remark.append("自动建出入库单设置：").append(spsSyncSysSettingResponse.getBasicBusTypePreEntities().size()).append("条\n"); //自动建业务单设置 if (CollUtil.isNotEmpty(spsSyncSysSettingResponse.getBasicBusTypeChangeEntities())) { List basicBusTypeChangeEntities = spsSyncSysSettingResponse.getBasicBusTypeChangeEntities(); BasicBusTypeChangeDao mapper = sqlSession.getMapper(BasicBusTypeChangeDao.class); basicBusTypeChangeEntities.forEach(mapper::insertOrUpdate); } sqlSession.commit(); remark.append("自动建业务单设置：").append(spsSyncSysSettingResponse.getBasicBusTypeChangeEntities().size()).append("条\n"); sqlSession.close(); basicDownloadStatusEntity.setStatus(1); basicDownloadStatusEntity.setUpdateTime(new Date()); basicDownloadStatusEntity.setEndTime(new Date()); basicDownloadStatusEntity.setRemark(remark.toString()); basicDownloadService.updateDownloadStatus(basicDownloadStatusEntity); } return ResultVOUtils.success("上传成功"); } //接收中继服务、UDI管理系统上传第三方产品信息 //@AuthRuleAnnotation("") @PostMapping("/sps/sync/thrData/products/upload") public BaseResponse uploadThrProducts(@RequestBody @Valid SpsSyncThrProductsResponse spsSyncThrProductsResponse) { if (spsSyncThrProductsResponse != null) { SqlSession sqlSession = sqlSessionFactory.openSession(ExecutorType.BATCH, TransactionIsolationLevel.READ_COMMITTED); BasicDownloadStatusEntity basicDownloadStatusEntity = new BasicDownloadStatusEntity(); basicDownloadStatusEntity.setId(CustomUtil.getId()); basicDownloadStatusEntity.setTaskId(spsSyncThrProductsResponse.getTaskId()); basicDownloadStatusEntity.setStartTime(new Date()); basicDownloadStatusEntity.setIdDatas(ConstantStatus.SYNC_THR_PRODUCTS); basicDownloadStatusEntity.setStatus(0); basicDownloadStatusEntity.setType(BasicProcessStatus.NEW_ALL_THR_PRODUCTS); basicDownloadStatusEntity.setScheduleType(1); basicDownloadService.insertDownloadStatus(basicDownloadStatusEntity); StringBuilder remark = new StringBuilder(); //第三方产品信息 if (CollUtil.isNotEmpty(spsSyncThrProductsResponse.getProductsEntities())) { List productsEntities = spsSyncThrProductsResponse.getProductsEntities(); ThrProductsDao mapper = sqlSession.getMapper(ThrProductsDao.class); productsEntities.forEach(mapper::insertOrUpdateEntity); } sqlSession.commit(); remark.append("第三方产品信息：").append(spsSyncThrProductsResponse.getProductsEntities().size()).append("条\n"); sqlSession.close(); basicDownloadStatusEntity.setStatus(1); basicDownloadStatusEntity.setUpdateTime(new Date()); basicDownloadStatusEntity.setEndTime(new Date()); basicDownloadStatusEntity.setRemark(remark.toString()); basicDownloadService.updateDownloadStatus(basicDownloadStatusEntity); } return ResultVOUtils.success("上传成功"); } }