|
|
|
|
@ -2,34 +2,33 @@ package com.glxp.api.controller.sync;
|
|
|
|
|
|
|
|
|
|
import cn.hutool.core.collection.CollUtil;
|
|
|
|
|
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.BasicProcessStatus;
|
|
|
|
|
import com.glxp.api.constant.Constant;
|
|
|
|
|
import com.glxp.api.constant.ConstantStatus;
|
|
|
|
|
import com.glxp.api.controller.purchase.PurOrderController;
|
|
|
|
|
import com.glxp.api.dao.auth.*;
|
|
|
|
|
import com.glxp.api.dao.basic.*;
|
|
|
|
|
import com.glxp.api.dao.basic.BasicBusTypeChangeDao;
|
|
|
|
|
import com.glxp.api.dao.basic.BasicBusTypePreDao;
|
|
|
|
|
import com.glxp.api.dao.basic.BasicBussinessTypeDao;
|
|
|
|
|
import com.glxp.api.dao.basic.EntrustReceDao;
|
|
|
|
|
import com.glxp.api.dao.inout.*;
|
|
|
|
|
import com.glxp.api.dao.purchase.PurOrderDao;
|
|
|
|
|
import com.glxp.api.dao.purchase.PurOrderDetailDao;
|
|
|
|
|
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.basic.BasicBusTypeChangeEntity;
|
|
|
|
|
import com.glxp.api.entity.basic.BasicBusTypePreEntity;
|
|
|
|
|
import com.glxp.api.entity.basic.BasicBussinessTypeEntity;
|
|
|
|
|
import com.glxp.api.entity.basic.EntrustReceEntity;
|
|
|
|
|
import com.glxp.api.entity.inout.*;
|
|
|
|
|
import com.glxp.api.entity.purchase.PurOrderDetailEntity;
|
|
|
|
|
import com.glxp.api.entity.purchase.PurOrderEntity;
|
|
|
|
|
import com.glxp.api.entity.sync.BasicDownloadStatusEntity;
|
|
|
|
|
import com.glxp.api.entity.sync.BasicExportStatusEntity;
|
|
|
|
|
import com.glxp.api.entity.sync.SyncDataBustypeEntity;
|
|
|
|
|
import com.glxp.api.entity.sync.SyncDataSetEntity;
|
|
|
|
|
import com.glxp.api.entity.system.*;
|
|
|
|
|
import com.glxp.api.entity.thrsys.*;
|
|
|
|
|
import com.glxp.api.req.basic.UdiInfoRequest;
|
|
|
|
|
import com.glxp.api.req.sync.SpsSyncDataRequest;
|
|
|
|
|
import com.glxp.api.res.sync.*;
|
|
|
|
|
import com.glxp.api.res.system.SyncDataSetResponse;
|
|
|
|
|
import com.glxp.api.service.auth.AuthAdminService;
|
|
|
|
|
import com.glxp.api.service.inout.IoAddInoutService;
|
|
|
|
|
import com.glxp.api.service.inout.IoCheckInoutService;
|
|
|
|
|
import com.glxp.api.service.inout.IoOrderService;
|
|
|
|
|
@ -39,7 +38,6 @@ 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.DateUtil;
|
|
|
|
|
import org.apache.ibatis.session.ExecutorType;
|
|
|
|
|
import org.apache.ibatis.session.SqlSession;
|
|
|
|
|
import org.apache.ibatis.session.SqlSessionFactory;
|
|
|
|
|
@ -52,7 +50,6 @@ import org.springframework.web.bind.annotation.RestController;
|
|
|
|
|
|
|
|
|
|
import javax.annotation.Resource;
|
|
|
|
|
import javax.validation.Valid;
|
|
|
|
|
import java.util.ArrayList;
|
|
|
|
|
import java.util.Date;
|
|
|
|
|
import java.util.List;
|
|
|
|
|
|
|
|
|
|
@ -433,7 +430,7 @@ public class SpsSyncDownloadController {
|
|
|
|
|
// 部门信息
|
|
|
|
|
if (CollUtil.isNotEmpty(syncDataResponse.getDeptEntityList())) {
|
|
|
|
|
for (DeptEntity deptEntity : syncDataResponse.getDeptEntityList()) {
|
|
|
|
|
deptDao.insertInvWarehouse(deptEntity);
|
|
|
|
|
deptDao.insertOrUpdate(deptEntity);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
// 部门信息关联用户信息
|
|
|
|
|
@ -483,13 +480,218 @@ public class SpsSyncDownloadController {
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
//接收中继服务、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<ThrDeptEntity> deptEntities = spsSyncThrDataResponse.getDeptEntities();
|
|
|
|
|
ThrDeptDao mapper = sqlSession.getMapper(ThrDeptDao.class);
|
|
|
|
|
deptEntities.forEach(mapper::insertOrUpdate);
|
|
|
|
|
}
|
|
|
|
|
sqlSession.commit();
|
|
|
|
|
remark.append("第三方部门信息：").append(spsSyncThrDataResponse.getDeptEntities().size()).append("条\n");
|
|
|
|
|
|
|
|
|
|
//第三方仓库信息
|
|
|
|
|
if (CollUtil.isNotEmpty(spsSyncThrDataResponse.getInvWarehouseEntities())) {
|
|
|
|
|
List<ThrInvWarehouseEntity> invWarehouseEntities = spsSyncThrDataResponse.getInvWarehouseEntities();
|
|
|
|
|
ThrInvWarehouseDao mapper = sqlSession.getMapper(ThrInvWarehouseDao.class);
|
|
|
|
|
invWarehouseEntities.forEach(mapper::insertOrUpdate);
|
|
|
|
|
}
|
|
|
|
|
sqlSession.commit();
|
|
|
|
|
remark.append("第三方仓库信息：").append(spsSyncThrDataResponse.getInvWarehouseEntities().size()).append("条\n");
|
|
|
|
|
|
|
|
|
|
//第三方往来单位信息
|
|
|
|
|
if (CollUtil.isNotEmpty(spsSyncThrDataResponse.getCorpEntities())) {
|
|
|
|
|
List<ThrCorpEntity> corpEntities = spsSyncThrDataResponse.getCorpEntities();
|
|
|
|
|
ThrCorpDao mapper = sqlSession.getMapper(ThrCorpDao.class);
|
|
|
|
|
corpEntities.forEach(mapper::insertOrUpdate);
|
|
|
|
|
}
|
|
|
|
|
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<SystemParamConfigEntity> 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<EntrustReceEntity> 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<SystemPDFModuleEntity> 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<SystemPDFTemplateEntity> 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<SysPdfTemplateRelevanceCodeEntity> 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<SysPdfTemplateRelevanceBizEntity> 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<SysPdfTemplateRelevanceLabelEntity> 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<SysPdfTemplateRelevanceStatemenEntity> 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<BasicBusTypePreEntity> 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<BasicBusTypeChangeEntity> 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<ThrProductsEntity> productsEntities = spsSyncThrProductsResponse.getProductsEntities();
|
|
|
|
|
ThrProductsDao mapper = sqlSession.getMapper(ThrProductsDao.class);
|
|
|
|
|
productsEntities.forEach(mapper::insertOrUpdate);
|
|
|
|
|
}
|
|
|
|
|
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("上传成功");
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
chengqf
2 years ago