bug修改,耗材字典控制是否必填,委托验收bug,新增配送产品其他一些bug问题

zhairh
anthonyywj2 3 years ago
parent 9439249026
commit 9c6364e8c2

@ -72,6 +72,9 @@ public class SpsSyncDownloadController {
logs = logs + "系统用户信息:" + baseResponse.getData().getAuthAdminList().size() + "条\n"; logs = logs + "系统用户信息:" + baseResponse.getData().getAuthAdminList().size() + "条\n";
if (CollUtil.isNotEmpty(baseResponse.getData().getDeptEntityList())) if (CollUtil.isNotEmpty(baseResponse.getData().getDeptEntityList()))
logs = logs + "部门信息:" + baseResponse.getData().getDeptEntityList().size() + "条\n"; logs = logs + "部门信息:" + baseResponse.getData().getDeptEntityList().size() + "条\n";
if (CollUtil.isNotEmpty(baseResponse.getData().getNewUploadDiEntities()))
logs = logs + "新增配送产品信息:" + baseResponse.getData().getNewUploadDiEntities().size() + "条\n";
basicExportStatusEntity.setRemark(logs); basicExportStatusEntity.setRemark(logs);
basicExportService.updateExportStatus(basicExportStatusEntity); basicExportService.updateExportStatus(basicExportStatusEntity);

@ -96,6 +96,8 @@ public class SpsSyncDownloadService {
@Resource @Resource
DeptService deptService; DeptService deptService;
@Resource
NewUploadDiService newUploadDiService;
public BaseResponse findProductInfo(SpsSyncDataRequest spsSyncDataRequest) { public BaseResponse findProductInfo(SpsSyncDataRequest spsSyncDataRequest) {
@ -226,7 +228,6 @@ public class SpsSyncDownloadService {
} }
} }
if (syncDataSetEntity.isBasicThirdCorp()) { if (syncDataSetEntity.isBasicThirdCorp()) {
//第三方往来单位 //第三方往来单位
FilterThrCorpRequest filterThrCorpRequest = new FilterThrCorpRequest(); FilterThrCorpRequest filterThrCorpRequest = new FilterThrCorpRequest();
@ -260,6 +261,14 @@ public class SpsSyncDownloadService {
syncDataResponse.setThrOrderDetailEntities(allOrderDetailEntities); syncDataResponse.setThrOrderDetailEntities(allOrderDetailEntities);
syncDataResponse.setThrOrderEntities(thrOrderEntities); syncDataResponse.setThrOrderEntities(thrOrderEntities);
} }
//新增配送产品信息
FilterNewUploadDiRequest filterNewUploadDiRequest = new FilterNewUploadDiRequest();
BeanUtils.copyProperties(spsSyncDataRequest, filterNewUploadDiRequest);
List<NewUploadDiEntity> newUploadDiEntities = newUploadDiService.filterNewUploads(filterNewUploadDiRequest);
syncDataResponse.setNewUploadDiEntities(newUploadDiEntities);
return ResultVOUtils.success(syncDataResponse); return ResultVOUtils.success(syncDataResponse);
} }

@ -190,6 +190,7 @@ public class SpsSyncExportStatusController {
|| CollUtil.isNotEmpty(spsSyncDataResponse.getThrInvWarehouseEntities()) || CollUtil.isNotEmpty(spsSyncDataResponse.getThrInvWarehouseEntities())
|| CollUtil.isNotEmpty(spsSyncDataResponse.getAuthAdminList()) || CollUtil.isNotEmpty(spsSyncDataResponse.getAuthAdminList())
|| CollUtil.isNotEmpty(spsSyncDataResponse.getDeptEntityList()) || CollUtil.isNotEmpty(spsSyncDataResponse.getDeptEntityList())
|| CollUtil.isNotEmpty(spsSyncDataResponse.getNewUploadDiEntities())
) { ) {
BasicExportStatusTimeEntity basicExportStatusTimeEntity = basicExportTimeService.findByType(ConstantStatus.SYNC_BASIC_DATA); BasicExportStatusTimeEntity basicExportStatusTimeEntity = basicExportTimeService.findByType(ConstantStatus.SYNC_BASIC_DATA);
if (basicExportStatusTimeEntity != null) { if (basicExportStatusTimeEntity != null) {

@ -503,17 +503,14 @@ public class SpsSyncUploadController {
if (temp == null) { if (temp == null) {
mapper.importOrder(orderEntity); mapper.importOrder(orderEntity);
if (CollUtil.isNotEmpty(syncDataResponse.getWarehouseEntityList())) { if (CollUtil.isNotEmpty(syncDataResponse.getWarehouseEntityList())) {
try { CodesTempDao codeMappert = batchSession.getMapper(CodesTempDao.class);
CodesTempDao codeMappert = batchSession.getMapper(CodesTempDao.class); List<WarehouseEntity> warehouseEntityList = syncDataResponse.getWarehouseEntityList();
List<WarehouseEntity> warehouseEntityList = syncDataResponse.getWarehouseEntityList(); for (WarehouseEntity warehouseEntity : warehouseEntityList) {
for (WarehouseEntity warehouseEntity : warehouseEntityList) { if (warehouseEntity.getOrderId().equals(orderEntity.getId())) {
if (warehouseEntity.getOrderId().equals(orderEntity.getId())) { codeMappert.replaceCodesTempSingle(warehouseEntity);
codeMappert.replaceCodesTempSingle(warehouseEntity);
}
} }
batchSession.commit();
} catch (Exception e) {
} }
batchSession.commit();
} }
} }

@ -21,6 +21,7 @@ import com.glxp.sale.admin.req.receipt.ProductInfoFilterRequest;
import com.glxp.sale.admin.req.thrsys.FilterThrProductsRequest; import com.glxp.sale.admin.req.thrsys.FilterThrProductsRequest;
import com.glxp.sale.admin.res.PageSimpleResponse; import com.glxp.sale.admin.res.PageSimpleResponse;
import com.glxp.sale.admin.res.basic.ErpProductsResponse; import com.glxp.sale.admin.res.basic.ErpProductsResponse;
import com.glxp.sale.admin.res.basic.UdiRelevanceResponse;
import com.glxp.sale.admin.service.basic.BasicThirdSysDetailService; import com.glxp.sale.admin.service.basic.BasicThirdSysDetailService;
import com.glxp.sale.admin.service.basic.UdiInfoService; import com.glxp.sale.admin.service.basic.UdiInfoService;
import com.glxp.sale.admin.service.basic.UdiRelevanceService; import com.glxp.sale.admin.service.basic.UdiRelevanceService;

@ -82,6 +82,8 @@ public class UdiRelevanceController {
CustomerService customerService; CustomerService customerService;
@Resource @Resource
GennerOrderUtils gennerOrderUtils; GennerOrderUtils gennerOrderUtils;
@Resource
SupplementVailUtil supplementVailUtil;
@AuthRuleAnnotation("") @AuthRuleAnnotation("")
@GetMapping("/udi/udirel/download") @GetMapping("/udi/udirel/download")
@ -266,6 +268,17 @@ public class UdiRelevanceController {
if (bindingResult.hasErrors()) { if (bindingResult.hasErrors()) {
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage()); return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage());
} }
long customerId = customerService.getCustomerId();
if (customerId != 110) {
SupplementRequest supplementRequest = new SupplementRequest();
BeanUtils.copyProperties(udiRelevanceResponse, supplementRequest);
String vailResult = supplementVailUtil.vail(supplementRequest, SupplementVailUtil.LOCAL_EIDT);
if (vailResult != null)
return ResultVOUtils.error(500, vailResult);
}
UdiRelevanceEntity udiRelevanceEntity = new UdiRelevanceEntity(); UdiRelevanceEntity udiRelevanceEntity = new UdiRelevanceEntity();
BeanUtils.copyProperties(udiRelevanceResponse, udiRelevanceEntity); BeanUtils.copyProperties(udiRelevanceResponse, udiRelevanceEntity);
udiRelevanceEntity.setId(udiRelevanceResponse.getId() + ""); udiRelevanceEntity.setId(udiRelevanceResponse.getId() + "");
@ -276,7 +289,7 @@ public class UdiRelevanceController {
udiRelevanceEntity.setIsUseDy(true); udiRelevanceEntity.setIsUseDy(true);
} else udiRelevanceEntity.setIsUseDy(false); } else udiRelevanceEntity.setIsUseDy(false);
udiRelevanceService.updateUdiRelevance(udiRelevanceEntity); udiRelevanceService.updateUdiRelevance(udiRelevanceEntity);
long customerId = customerService.getCustomerId();
if (customerId != 110) { if (customerId != 110) {
if (StrUtil.isNotEmpty(udiRelevanceEntity.getPrice())) { if (StrUtil.isNotEmpty(udiRelevanceEntity.getPrice())) {
CompanyProductRelevanceEntity companyProductRelevanceEntity = companyProductRelevanceService.findCompanyProductRelevanceByUdiRlIdFk(udiRelevanceEntity.getId(), customerId + ""); CompanyProductRelevanceEntity companyProductRelevanceEntity = companyProductRelevanceService.findCompanyProductRelevanceByUdiRlIdFk(udiRelevanceEntity.getId(), customerId + "");

@ -0,0 +1,49 @@
package com.glxp.sale.admin.controller.info;
import com.github.pagehelper.PageInfo;
import com.glxp.sale.admin.annotation.AuthRuleAnnotation;
import com.glxp.sale.admin.entity.info.BasicProductSetEntity;
import com.glxp.sale.admin.entity.info.CompanyCertEntity;
import com.glxp.sale.admin.entity.info.SetupEntity;
import com.glxp.sale.admin.req.info.CompanyRequest;
import com.glxp.sale.admin.req.info.FilterBasicProductSetrequest;
import com.glxp.sale.admin.res.PageSimpleResponse;
import com.glxp.sale.admin.service.info.BasicProductSetService;
import com.glxp.sale.common.enums.ResultEnum;
import com.glxp.sale.common.res.BaseResponse;
import com.glxp.sale.common.util.ResultVOUtils;
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 java.util.List;
@RestController
public class BasicProductSetController {
@Resource
BasicProductSetService basicProductSetService;
@AuthRuleAnnotation("")
@GetMapping("/spms/basicProduct/setup/filter")
public BaseResponse filterSetUps(FilterBasicProductSetrequest filterBasicProductSetrequest) {
List<BasicProductSetEntity> basicProductSetEntities = basicProductSetService.filterSetup(filterBasicProductSetrequest);
PageInfo<BasicProductSetEntity> pageInfo;
pageInfo = new PageInfo<>(basicProductSetEntities);
PageSimpleResponse<BasicProductSetEntity> pageSimpleResponse = new PageSimpleResponse<>();
pageSimpleResponse.setTotal(pageInfo.getTotal());
pageSimpleResponse.setList(basicProductSetEntities);
return ResultVOUtils.success(pageSimpleResponse);
}
@AuthRuleAnnotation("")
@PostMapping("/spms/basicProduct/setup/modify")
public BaseResponse modifySetup(@RequestBody BasicProductSetEntity basicProductSetEntity) {
basicProductSetService.updateSetup(basicProductSetEntity);
return ResultVOUtils.success("修改成功");
}
}

@ -92,9 +92,9 @@ public class CompanyController {
// } // }
if (StringUtils.isNotBlank(companyEntity.getNewFilePath())) { if (StringUtils.isNotBlank(companyEntity.getNewFilePath())) {
if (StringUtils.isNotBlank(companyEntity.getFilePath())) { if (StringUtils.isNotBlank(companyEntity.getFilePath())) {
String URL=filePath+"/register/file/image1/" + companyEntity.getFilePath(); String URL = filePath + "/register/file/image1/" + companyEntity.getFilePath();
File file=new File(URL); File file = new File(URL);
if(file.exists()&&file.isFile()) { if (file.exists() && file.isFile()) {
file.delete(); file.delete();
} }
} }
@ -102,9 +102,9 @@ public class CompanyController {
} }
if (StringUtils.isNotBlank(companyEntity.getNewFilePath2())) { if (StringUtils.isNotBlank(companyEntity.getNewFilePath2())) {
if (StringUtils.isNotBlank(companyEntity.getFilePath2())) { if (StringUtils.isNotBlank(companyEntity.getFilePath2())) {
String URL=filePath+"/register/file/image1/" + companyEntity.getFilePath2(); String URL = filePath + "/register/file/image1/" + companyEntity.getFilePath2();
File file=new File(URL); File file = new File(URL);
if(file.exists()&&file.isFile()) { if (file.exists() && file.isFile()) {
file.delete(); file.delete();
} }
} }
@ -112,9 +112,9 @@ public class CompanyController {
} }
if (StringUtils.isNotBlank(companyEntity.getNewFilePath3())) { if (StringUtils.isNotBlank(companyEntity.getNewFilePath3())) {
if (StringUtils.isNotBlank(companyEntity.getFilePath3())) { if (StringUtils.isNotBlank(companyEntity.getFilePath3())) {
String URL=filePath+"/register/file/image1/" + companyEntity.getFilePath3(); String URL = filePath + "/register/file/image1/" + companyEntity.getFilePath3();
File file=new File(URL); File file = new File(URL);
if(file.exists()&&file.isFile()) { if (file.exists() && file.isFile()) {
file.delete(); file.delete();
} }
} }
@ -122,9 +122,9 @@ public class CompanyController {
} }
if (StringUtils.isNotBlank(companyEntity.getNewFilePath4())) { if (StringUtils.isNotBlank(companyEntity.getNewFilePath4())) {
if (StringUtils.isNotBlank(companyEntity.getFilePath4())) { if (StringUtils.isNotBlank(companyEntity.getFilePath4())) {
String URL=filePath+"/register/file/image1/" + companyEntity.getFilePath4(); String URL = filePath + "/register/file/image1/" + companyEntity.getFilePath4();
File file=new File(URL); File file = new File(URL);
if(file.exists()&&file.isFile()) { if (file.exists() && file.isFile()) {
file.delete(); file.delete();
} }
} }
@ -158,12 +158,7 @@ public class CompanyController {
customerContactEntity.setEmail(companyEntity.getEmail()); customerContactEntity.setEmail(companyEntity.getEmail());
customerContactEntity.setContacts(companyEntity.getContacts()); customerContactEntity.setContacts(companyEntity.getContacts());
customerContactEntity.setCustomerId(companyEntity.getCustomerId()); customerContactEntity.setCustomerId(companyEntity.getCustomerId());
customerContactService.updateCustomerContact(customerContactEntity);
try {
customerContactService.updateCustomerContact(customerContactEntity);
} catch (Exception e) {
}
return ResultVOUtils.success("修改成功"); return ResultVOUtils.success("修改成功");
} }

@ -6,10 +6,13 @@ import com.glxp.sale.admin.annotation.AuthRuleAnnotation;
import com.glxp.sale.admin.controller.basic.BasicUnitMaintainController; import com.glxp.sale.admin.controller.basic.BasicUnitMaintainController;
import com.glxp.sale.admin.entity.auth.AuthAdmin; import com.glxp.sale.admin.entity.auth.AuthAdmin;
import com.glxp.sale.admin.entity.basic.BasicUnitMaintainEntity; import com.glxp.sale.admin.entity.basic.BasicUnitMaintainEntity;
import com.glxp.sale.admin.entity.info.BasicProductSetEntity;
import com.glxp.sale.admin.entity.info.CompanyEntity; import com.glxp.sale.admin.entity.info.CompanyEntity;
import com.glxp.sale.admin.entity.info.CompanyProductRelevanceEntity; import com.glxp.sale.admin.entity.info.CompanyProductRelevanceEntity;
import com.glxp.sale.admin.entity.param.SystemParamConfigEntity;
import com.glxp.sale.admin.exception.JsonException; import com.glxp.sale.admin.exception.JsonException;
import com.glxp.sale.admin.req.basic.CompanyProductRelevanceRequest; import com.glxp.sale.admin.req.basic.CompanyProductRelevanceRequest;
import com.glxp.sale.admin.req.basic.SupplementRequest;
import com.glxp.sale.admin.req.basic.UdiInfoExportRequest; import com.glxp.sale.admin.req.basic.UdiInfoExportRequest;
import com.glxp.sale.admin.req.info.CompanyRequest; import com.glxp.sale.admin.req.info.CompanyRequest;
import com.glxp.sale.admin.req.info.DeleteCompanyFileRequest; import com.glxp.sale.admin.req.info.DeleteCompanyFileRequest;
@ -18,9 +21,12 @@ import com.glxp.sale.admin.res.PageSimpleResponse;
import com.glxp.sale.admin.res.basic.CompanyProductRelevanceResponse; import com.glxp.sale.admin.res.basic.CompanyProductRelevanceResponse;
import com.glxp.sale.admin.service.auth.AuthAdminService; import com.glxp.sale.admin.service.auth.AuthAdminService;
import com.glxp.sale.admin.service.basic.BasicUnitMaintainService; import com.glxp.sale.admin.service.basic.BasicUnitMaintainService;
import com.glxp.sale.admin.service.info.BasicProductSetService;
import com.glxp.sale.admin.service.info.CompanyProductRelevanceService; import com.glxp.sale.admin.service.info.CompanyProductRelevanceService;
import com.glxp.sale.admin.service.info.CompanyService; import com.glxp.sale.admin.service.info.CompanyService;
import com.glxp.sale.admin.service.param.SystemParamConfigService;
import com.glxp.sale.admin.thread.CompanyProductsRelService; import com.glxp.sale.admin.thread.CompanyProductsRelService;
import com.glxp.sale.admin.util.SupplementVailUtil;
import com.glxp.sale.common.enums.ResultEnum; import com.glxp.sale.common.enums.ResultEnum;
import com.glxp.sale.common.res.BaseResponse; import com.glxp.sale.common.res.BaseResponse;
import com.glxp.sale.common.util.ResultVOUtils; import com.glxp.sale.common.util.ResultVOUtils;
@ -37,6 +43,7 @@ import javax.servlet.http.HttpServletRequest;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Date; import java.util.Date;
import java.util.List; import java.util.List;
import java.util.Map;
@RestController @RestController
public class CompanyProductRelevanceController { public class CompanyProductRelevanceController {
@ -165,6 +172,16 @@ public class CompanyProductRelevanceController {
return ResultVOUtils.success("成功"); return ResultVOUtils.success("成功");
} }
@Resource
BasicProductSetService basicProductSetService;
@Resource
SystemParamConfigService systemParamConfigService;
@Resource
SupplementVailUtil supplementVailUtil;
@AuthRuleAnnotation("") @AuthRuleAnnotation("")
@PostMapping("/sale/info/insertFilter") @PostMapping("/sale/info/insertFilter")
public BaseResponse insertFilter(@RequestBody UdiInfoExportRequest udiInfoExportRequest) { public BaseResponse insertFilter(@RequestBody UdiInfoExportRequest udiInfoExportRequest) {
@ -174,6 +191,9 @@ public class CompanyProductRelevanceController {
} else { } else {
udiInfoExportRequest.setUnitFk(companyEntity.getUnitIdFk()); udiInfoExportRequest.setUnitFk(companyEntity.getUnitIdFk());
} }
String vailResult = supplementVailUtil.vail(udiInfoExportRequest.getSupplementRequest(), SupplementVailUtil.SUP_SELECT);
if (vailResult != null)
return ResultVOUtils.error(500, vailResult);
companyProductsRelService.insertCompanyProducts(udiInfoExportRequest); companyProductsRelService.insertCompanyProducts(udiInfoExportRequest);
return ResultVOUtils.success("后台正在导入,请稍后刷新查看!"); return ResultVOUtils.success("后台正在导入,请稍后刷新查看!");
} }

@ -366,7 +366,9 @@ public class OrderController {
} else { } else {
if (orderEntity.getFromType().intValue() != ConstantStatus.FROM_CHANGE && orderEntity.getFromType().intValue() != ConstantStatus.FROM_PEACE_CHANGE) { if (orderEntity.getFromType().intValue() != ConstantStatus.FROM_CHANGE && orderEntity.getFromType().intValue() != ConstantStatus.FROM_PEACE_CHANGE) {
transferOrder(orderEntity, entrustReceEntity); if (StrUtil.isEmpty(entrustReceEntity.getAction())) {
transferOrder(orderEntity, entrustReceEntity);
}
} }
if (!entrustReceEntity.isFinishRece()) { if (!entrustReceEntity.isFinishRece()) {
StockOrderFilterRequest stockOrderFilterRequest = new StockOrderFilterRequest(); StockOrderFilterRequest stockOrderFilterRequest = new StockOrderFilterRequest();
@ -442,13 +444,10 @@ public class OrderController {
} }
); );
//更新数据 //更新数据
try { orderDao.insertOrder(supplementOrder);
orderDao.insertOrder(supplementOrder); orderEntity.setUllageSupNo(supplementOrder.getId());
orderEntity.setUllageSupNo(supplementOrder.getId()); orderDao.updateOrder(orderEntity);
orderDao.updateOrder(orderEntity); codesTempDao.insertCodesTemp(supplementCodes);
codesTempDao.insertCodesTemp(supplementCodes);
} catch (Exception e) {
}
} }

@ -1,20 +1,25 @@
package com.glxp.sale.admin.controller.thrsys; package com.glxp.sale.admin.controller.thrsys;
import cn.hutool.core.util.ReflectUtil;
import cn.hutool.core.util.StrUtil; import cn.hutool.core.util.StrUtil;
import com.github.pagehelper.PageInfo; import com.github.pagehelper.PageInfo;
import com.glxp.sale.admin.annotation.AuthRuleAnnotation; import com.glxp.sale.admin.annotation.AuthRuleAnnotation;
import com.glxp.sale.admin.entity.basic.BasicThirdSysEntity; import com.glxp.sale.admin.entity.basic.BasicThirdSysEntity;
import com.glxp.sale.admin.entity.basic.UdiRelevanceEntity;
import com.glxp.sale.admin.entity.thrsys.ThrProductsAddEntity; import com.glxp.sale.admin.entity.thrsys.ThrProductsAddEntity;
import com.glxp.sale.admin.entity.thrsys.ThrProductsEntity; import com.glxp.sale.admin.entity.thrsys.ThrProductsEntity;
import com.glxp.sale.admin.req.info.DeleteRequest; import com.glxp.sale.admin.req.info.DeleteRequest;
import com.glxp.sale.admin.req.thrsys.FilterThrProductsRequest; import com.glxp.sale.admin.req.thrsys.FilterThrProductsRequest;
import com.glxp.sale.admin.res.PageSimpleResponse; import com.glxp.sale.admin.res.PageSimpleResponse;
import com.glxp.sale.admin.res.basic.UdiRelevanceResponse;
import com.glxp.sale.admin.service.auth.CustomerService; import com.glxp.sale.admin.service.auth.CustomerService;
import com.glxp.sale.admin.service.basic.BasicThirdSysService; import com.glxp.sale.admin.service.basic.BasicThirdSysService;
import com.glxp.sale.admin.service.basic.UdiContrastService; import com.glxp.sale.admin.service.basic.UdiContrastService;
import com.glxp.sale.admin.service.basic.UdiRelevanceService;
import com.glxp.sale.admin.service.thrsys.ThrProductsAddService; import com.glxp.sale.admin.service.thrsys.ThrProductsAddService;
import com.glxp.sale.admin.service.thrsys.ThrProductsService; import com.glxp.sale.admin.service.thrsys.ThrProductsService;
import com.glxp.sale.admin.util.BeanUtils; import com.glxp.sale.admin.util.BeanUtils;
import com.glxp.sale.admin.util.DateUtil;
import com.glxp.sale.common.enums.ResultEnum; import com.glxp.sale.common.enums.ResultEnum;
import com.glxp.sale.common.res.BaseResponse; import com.glxp.sale.common.res.BaseResponse;
import com.glxp.sale.common.util.ResultVOUtils; import com.glxp.sale.common.util.ResultVOUtils;
@ -75,7 +80,6 @@ public class ThrProductsAddController {
} }
@AuthRuleAnnotation("") @AuthRuleAnnotation("")
@PostMapping("/udiwms/thrsys/updateThrAddProducts") @PostMapping("/udiwms/thrsys/updateThrAddProducts")
public BaseResponse updateThrAddProducts(@RequestBody ThrProductsAddEntity thrProductsAddEntity, BindingResult bindingResult) { public BaseResponse updateThrAddProducts(@RequestBody ThrProductsAddEntity thrProductsAddEntity, BindingResult bindingResult) {
@ -88,7 +92,6 @@ public class ThrProductsAddController {
if (thrProductsService.isExit(tempEntity.getCode(), tempEntity.getThirdSysFk())) { if (thrProductsService.isExit(tempEntity.getCode(), tempEntity.getThirdSysFk())) {
return ResultVOUtils.error(500, "已存在相同产品编码,无法添加!"); return ResultVOUtils.error(500, "已存在相同产品编码,无法添加!");
} }
thrProductsAddService.updateThrProducts(thrProductsAddEntity); thrProductsAddService.updateThrProducts(thrProductsAddEntity);
if (thrProductsAddEntity.getCheckStatus() == 2) { if (thrProductsAddEntity.getCheckStatus() == 2) {
ThrProductsEntity thrProductsEntity = new ThrProductsEntity(); ThrProductsEntity thrProductsEntity = new ThrProductsEntity();
@ -96,6 +99,36 @@ public class ThrProductsAddController {
BeanUtils.copyProperties(thrProductsAddEntity, thrProductsEntity); BeanUtils.copyProperties(thrProductsAddEntity, thrProductsEntity);
thrProductsEntity.setUpdateTime(new Date()); thrProductsEntity.setUpdateTime(new Date());
thrProductsService.insertThrProducts(thrProductsEntity); thrProductsService.insertThrProducts(thrProductsEntity);
if (StrUtil.isNotEmpty(tempEntity.getRelId())) {
UdiRelevanceEntity udiRelevanceEntity = udiRelevanceService.selectById(tempEntity.getRelId());
if (udiRelevanceEntity != null) {
if (tempEntity.getThirdSysFk().equals("thirdId")) {
udiRelevanceEntity.setMainId(tempEntity.getCode());
udiRelevanceEntity.setMainName(tempEntity.getName());
udiRelevanceEntity.setThirdId(tempEntity.getCode());
udiRelevanceEntity.setThirdName(tempEntity.getName());
} else if (tempEntity.getThirdSysFk().equals("thirdId1")) {
udiRelevanceEntity.setThirdId1(tempEntity.getCode());
udiRelevanceEntity.setThirdName1(tempEntity.getName());
} else if (tempEntity.getThirdSysFk().equals("thirdId2")) {
udiRelevanceEntity.setThirdId2(tempEntity.getCode());
udiRelevanceEntity.setThirdName2(tempEntity.getName());
} else if (tempEntity.getThirdSysFk().equals("thirdId3")) {
udiRelevanceEntity.setThirdId3(tempEntity.getCode());
udiRelevanceEntity.setThirdName3(tempEntity.getName());
} else if (tempEntity.getThirdSysFk().equals("thirdId4")) {
udiRelevanceEntity.setThirdId4(tempEntity.getCode());
udiRelevanceEntity.setThirdName4(tempEntity.getName());
}
}
String time = DateUtil.formatDateTime(new Date());
udiRelevanceEntity.setUpdateTime(time);
udiRelevanceEntity.setModifyTime(time);
udiRelevanceService.updateUdiRelevance(udiRelevanceEntity);
}
//审核通过后直接加到耗材字典里---todo 暂时不加到耗材字典里 //审核通过后直接加到耗材字典里---todo 暂时不加到耗材字典里
// BasicThirdSysEntity basicThirdSysEntity = basicThirdSysService.selectMainThrSys(); // BasicThirdSysEntity basicThirdSysEntity = basicThirdSysService.selectMainThrSys();
// if (basicThirdSysEntity.getThirdId().equals(thrProductsAddEntity.getThirdSysFk())) // if (basicThirdSysEntity.getThirdId().equals(thrProductsAddEntity.getThirdSysFk()))
@ -110,6 +143,9 @@ public class ThrProductsAddController {
} }
@Resource
UdiRelevanceService udiRelevanceService;
/** /**
* *
* *
@ -136,8 +172,19 @@ public class ThrProductsAddController {
if (StrUtil.isEmpty(thrProductsAddEntity.getThirdSysFk())) { if (StrUtil.isEmpty(thrProductsAddEntity.getThirdSysFk())) {
thrProductsAddEntity.setThirdSysFk("thirdId"); thrProductsAddEntity.setThirdSysFk("thirdId");
} }
if (StrUtil.isNotEmpty(thrProductsAddEntity.getRelId())) {
UdiRelevanceResponse udiRelevanceResponse = udiRelevanceService.selectGroupById(thrProductsAddEntity.getRelId());
if (udiRelevanceResponse != null) {
BeanUtils.copyProperties(udiRelevanceResponse, thrProductsAddEntity);
thrProductsAddEntity.setName(udiRelevanceResponse.getCpmctymc());
thrProductsAddEntity.setManufactory(udiRelevanceResponse.getYlqxzcrbarmc());
thrProductsAddEntity.setSpec(udiRelevanceResponse.getGgxh());
thrProductsAddEntity.setRegisterNo(udiRelevanceResponse.getZczbhhzbapzbh());
}
}
thrProductsAddEntity.setCustomerId(customerId); thrProductsAddEntity.setCustomerId(customerId);
thrProductsAddEntity.setCheckStatus(1); thrProductsAddEntity.setCheckStatus(1);
thrProductsAddEntity.setUpdateTime(new Date());
thrProductsAddService.insertThrProducts(thrProductsAddEntity); thrProductsAddService.insertThrProducts(thrProductsAddEntity);
} }

@ -2,28 +2,36 @@ package com.glxp.sale.admin.controller.thrsys;
import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.util.StrUtil;
import cn.hutool.json.JSONUtil;
import com.github.pagehelper.PageInfo; import com.github.pagehelper.PageInfo;
import com.glxp.sale.admin.annotation.AuthRuleAnnotation; import com.glxp.sale.admin.annotation.AuthRuleAnnotation;
import com.glxp.sale.admin.entity.basic.NewUploadDiEntity;
import com.glxp.sale.admin.entity.basic.UdiInfoEntity; import com.glxp.sale.admin.entity.basic.UdiInfoEntity;
import com.glxp.sale.admin.entity.basic.UdiRelevanceEntity; import com.glxp.sale.admin.entity.basic.UdiRelevanceEntity;
import com.glxp.sale.admin.entity.info.CompanyProductRelevanceEntity; import com.glxp.sale.admin.entity.info.CompanyProductRelevanceEntity;
import com.glxp.sale.admin.entity.thrsys.ThrProductsAddDiEntity; import com.glxp.sale.admin.entity.thrsys.ThrProductsAddDiEntity;
import com.glxp.sale.admin.entity.thrsys.ThrProductsEntity; import com.glxp.sale.admin.entity.thrsys.ThrProductsEntity;
import com.glxp.sale.admin.req.basic.CombineRequest; import com.glxp.sale.admin.req.basic.CombineRequest;
import com.glxp.sale.admin.req.basic.SupplementRequest;
import com.glxp.sale.admin.req.inout.DeleteRequest; import com.glxp.sale.admin.req.inout.DeleteRequest;
import com.glxp.sale.admin.req.thrsys.AddThrDiProductsRequest; import com.glxp.sale.admin.req.thrsys.AddThrDiProductsRequest;
import com.glxp.sale.admin.req.thrsys.FilterThrProductsRequest; import com.glxp.sale.admin.req.thrsys.FilterThrProductsRequest;
import com.glxp.sale.admin.res.PageSimpleResponse; import com.glxp.sale.admin.res.PageSimpleResponse;
import com.glxp.sale.admin.res.thrsys.ThrProductsAddDiResponse; import com.glxp.sale.admin.res.thrsys.ThrProductsAddDiResponse;
import com.glxp.sale.admin.service.basic.NewUploadDiService;
import com.glxp.sale.admin.service.basic.UdiContrastService; import com.glxp.sale.admin.service.basic.UdiContrastService;
import com.glxp.sale.admin.service.basic.UdiInfoService; import com.glxp.sale.admin.service.basic.UdiInfoService;
import com.glxp.sale.admin.service.basic.UdiRelevanceService; import com.glxp.sale.admin.service.basic.UdiRelevanceService;
import com.glxp.sale.admin.service.info.CompanyProductRelevanceService; import com.glxp.sale.admin.service.info.CompanyProductRelevanceService;
import com.glxp.sale.admin.service.thrsys.ThrProductsAddDiService; import com.glxp.sale.admin.service.thrsys.ThrProductsAddDiService;
import com.glxp.sale.admin.util.BeanUtils;
import com.glxp.sale.admin.util.SupplementVailUtil;
import com.glxp.sale.common.enums.ResultEnum; import com.glxp.sale.common.enums.ResultEnum;
import com.glxp.sale.common.res.BaseResponse; import com.glxp.sale.common.res.BaseResponse;
import com.glxp.sale.common.util.ResultVOUtils; import com.glxp.sale.common.util.ResultVOUtils;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.context.annotation.Bean;
import org.springframework.validation.BindingResult; import org.springframework.validation.BindingResult;
import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.PostMapping;
@ -51,6 +59,11 @@ public class ThrProductsAddDiController {
UdiRelevanceService udiRelevanceService; UdiRelevanceService udiRelevanceService;
@Resource @Resource
UdiInfoService udiInfoService; UdiInfoService udiInfoService;
@Resource
NewUploadDiService newUploadDiService;
@Resource
SupplementVailUtil supplementVailUtil;
/** /**
* DI * DI
@ -69,6 +82,8 @@ public class ThrProductsAddDiController {
return ResultVOUtils.success(pageSimpleResponse); return ResultVOUtils.success(pageSimpleResponse);
} }
/** /**
* DI * DI
* *
@ -80,6 +95,13 @@ public class ThrProductsAddDiController {
if (bindingResult.hasErrors()) { if (bindingResult.hasErrors()) {
return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL); return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL);
} }
SupplementRequest supplementRequest = new SupplementRequest();
BeanUtils.copyProperties(addThrDiProductsRequest, supplementRequest);
String vailResult = supplementVailUtil.vail(supplementRequest, SupplementVailUtil.SUP_ADD);
if (vailResult != null)
return ResultVOUtils.error(500, vailResult);
thrProductsAddDiService.addThrAddDiProducts(addThrDiProductsRequest); thrProductsAddDiService.addThrAddDiProducts(addThrDiProductsRequest);
return ResultVOUtils.success(); return ResultVOUtils.success();
} }
@ -98,6 +120,8 @@ public class ThrProductsAddDiController {
} }
thrProductsAddDiEntity.setAuditTime(new Date()); thrProductsAddDiEntity.setAuditTime(new Date());
thrProductsAddDiService.updateDiProduct(thrProductsAddDiEntity); thrProductsAddDiService.updateDiProduct(thrProductsAddDiEntity);
thrProductsAddDiEntity = thrProductsAddDiService.selecById(thrProductsAddDiEntity.getId());
ThrProductsAddDiResponse thrProductsAddDiResponse = thrProductsAddDiService.selecById(thrProductsAddDiEntity.getId()); ThrProductsAddDiResponse thrProductsAddDiResponse = thrProductsAddDiService.selecById(thrProductsAddDiEntity.getId());
if (thrProductsAddDiEntity.getStatus() == 2) { //审核通过 if (thrProductsAddDiEntity.getStatus() == 2) { //审核通过
@ -130,6 +154,21 @@ public class ThrProductsAddDiController {
companyProductRelevanceEntity.setAuditStatus("1"); companyProductRelevanceEntity.setAuditStatus("1");
companyProductRelevanceService.insertCompanyProductRelevance(companyProductRelevanceEntity); companyProductRelevanceService.insertCompanyProductRelevance(companyProductRelevanceEntity);
if (StrUtil.isNotEmpty(thrProductsAddDiEntity.getSelectThridSysStr())) {
List<String> thirdSysList = JSONUtil.toList(thrProductsAddDiEntity.getSelectThridSysStr(), String.class);
if (thirdSysList.size() > 0) {
for (String thirdSys : thirdSysList) {
NewUploadDiEntity newUploadDiEntity = new NewUploadDiEntity();
newUploadDiEntity.setRelId(udiRelIdFk + "");
newUploadDiEntity.setUpdateTime(new Date());
newUploadDiEntity.setUploadStatus(0);
newUploadDiEntity.setThirdSysFk(thirdSys);
newUploadDiService.insertNewUploadDi(newUploadDiEntity);
}
}
}
} }
@ -140,7 +179,6 @@ public class ThrProductsAddDiController {
/** /**
* DI * DI
* *
* @param id
* @return * @return
*/ */
@AuthRuleAnnotation("") @AuthRuleAnnotation("")

@ -0,0 +1,21 @@
package com.glxp.sale.admin.dao.basic;
import com.glxp.sale.admin.entity.basic.CorpImportLogEntity;
import com.glxp.sale.admin.entity.basic.NewUploadDiEntity;
import com.glxp.sale.admin.req.basic.FilterNewUploadDiRequest;
import org.apache.ibatis.annotations.Mapper;
import java.util.List;
@Mapper
public interface NewUploadDiDao {
List<NewUploadDiEntity> filterNewUploads(FilterNewUploadDiRequest filterNewUploadDiRequest);
boolean deleteById(Integer id);
boolean insertNewUploadDi(NewUploadDiEntity newUploadDiEntity);
boolean updateNewUploadDi(NewUploadDiEntity newUploadDiEntity);
}

@ -0,0 +1,16 @@
package com.glxp.sale.admin.dao.info;
import com.glxp.sale.admin.entity.info.BasicProductSetEntity;
import com.glxp.sale.admin.req.info.FilterBasicProductSetrequest;
import org.apache.ibatis.annotations.Mapper;
import java.util.List;
@Mapper
public interface BasicProductSetDao {
List<BasicProductSetEntity> filterSetup(FilterBasicProductSetrequest filterBasicProductSetrequest);
boolean updateSetup(BasicProductSetEntity basicProductSetEntity);
}

@ -0,0 +1,19 @@
package com.glxp.sale.admin.entity.basic;
import lombok.Data;
import java.util.Date;
@Data
public class NewUploadDiEntity {
private Integer id;
private String relId;
private String thirdSysFk;
private Integer uploadStatus;
private String uploadMsg;
private String uploadCode;
private String remark;
private Date updateTime;
private Date submitTime;
}

@ -0,0 +1,22 @@
package com.glxp.sale.admin.entity.info;
import lombok.Data;
@Data
public class BasicProductSetEntity {
private Integer id;
private String parmName;
private String parmKey;
private boolean enable;
private boolean supSelect;
private boolean supAdd;
private boolean localAdd;
private boolean localEdit;
private String remark;
private Integer sort;
}

@ -48,7 +48,6 @@ public class ThrProductsAddDiEntity {
private String remark; private String remark;
private String thirdSysFk; private String thirdSysFk;
private String code; private String code;
private String sptm; private String sptm;
@ -57,5 +56,16 @@ public class ThrProductsAddDiEntity {
private String manufactory; private String manufactory;
private String spmc; private String spmc;
private String cpms; private String cpms;
private String selectThridSysStr;
private String price;
private String basicPrductRemak1;
private String basicPrductRemak2;
private String basicPrductRemak3;
private String basicPrductRemak4;
private String basicPrductRemak5;
private String basicPrductRemak6;
private String basicPrductRemak7;
private String basicPrductRemak8;
} }

@ -43,4 +43,5 @@ public class ThrProductsAddEntity {
private Integer checkStatus; private Integer checkStatus;
private String customerId; private String customerId;
private String thirdSys; private String thirdSys;
private String relId;
} }

@ -38,5 +38,6 @@ public class ThrProductsEntity {
private String remark1; //备注1 private String remark1; //备注1
private String remark2; //备注2 private String remark2; //备注2
private String remark3; //备注3 private String remark3; //备注3
private String relId;
} }

@ -0,0 +1,15 @@
package com.glxp.sale.admin.req.basic;
import com.glxp.sale.admin.req.ListPageRequest;
import lombok.Data;
@Data
public class FilterNewUploadDiRequest extends ListPageRequest {
private Integer id;
private String relId;
private String thirdSysFk;
private String uploadStatus;
private String uploadCode;
private String lastUpdateTime;
}

@ -0,0 +1,25 @@
package com.glxp.sale.admin.req.basic;
import lombok.Data;
//选入产品补充信息
@Data
public class SupplementRequest {
//补充信息:
private String basicPrductRemak1;
private String basicPrductRemak2;
private String basicPrductRemak3;
private String basicPrductRemak4;
private String basicPrductRemak5;
private String basicPrductRemak6;
private String basicPrductRemak7;
private String basicPrductRemak8;
private String sptm;
private String ybbm;
private String measname;
private String manufactory;
private String spmc;
private String cpms;
private String price;
}

@ -24,4 +24,8 @@ public class UdiInfoExportRequest extends ListPageRequest {
private String thirdId3; private String thirdId3;
private String thirdId4; private String thirdId4;
private SupplementRequest supplementRequest;
} }

@ -0,0 +1,13 @@
package com.glxp.sale.admin.req.info;
import com.glxp.sale.admin.req.ListPageRequest;
import lombok.Data;
@Data
public class FilterBasicProductSetrequest extends ListPageRequest {
String parmName;
Boolean enable;
}

@ -33,6 +33,17 @@ public class AddThrDiProductsRequest {
private String manufactory; private String manufactory;
private String spmc; private String spmc;
private String cpms; private String cpms;
private List<String> selectThirdSys;
private String basicPrductRemak1;
private String basicPrductRemak2;
private String basicPrductRemak3;
private String basicPrductRemak4;
private String basicPrductRemak5;
private String basicPrductRemak6;
private String basicPrductRemak7;
private String basicPrductRemak8;
} }

@ -3,6 +3,7 @@ package com.glxp.sale.admin.res.basic;
import com.glxp.sale.admin.entity.auth.AuthAdmin; import com.glxp.sale.admin.entity.auth.AuthAdmin;
import com.glxp.sale.admin.entity.auth.DeptEntity; import com.glxp.sale.admin.entity.auth.DeptEntity;
import com.glxp.sale.admin.entity.basic.BasicUnitMaintainEntity; import com.glxp.sale.admin.entity.basic.BasicUnitMaintainEntity;
import com.glxp.sale.admin.entity.basic.NewUploadDiEntity;
import com.glxp.sale.admin.entity.basic.UdiInfoEntity; import com.glxp.sale.admin.entity.basic.UdiInfoEntity;
import com.glxp.sale.admin.entity.basic.UdiRelevanceEntity; import com.glxp.sale.admin.entity.basic.UdiRelevanceEntity;
import com.glxp.sale.admin.entity.info.CompanyProductRelevanceEntity; import com.glxp.sale.admin.entity.info.CompanyProductRelevanceEntity;
@ -48,4 +49,7 @@ public class SpsSyncDataResponse {
List<InvSubWarehouseEntity> invSubWarehouseEntities; List<InvSubWarehouseEntity> invSubWarehouseEntities;
List<InvBusUserEntity> invBusUserEntities; List<InvBusUserEntity> invBusUserEntities;
//新增配送产品信息
List<NewUploadDiEntity> newUploadDiEntities;
} }

@ -29,4 +29,14 @@ public class ThrProductsAddDiResponse extends ThrProductsAddDiEntity {
private String remark; private String remark;
private String price;
private String basicPrductRemak1;
private String basicPrductRemak2;
private String basicPrductRemak3;
private String basicPrductRemak4;
private String basicPrductRemak5;
private String basicPrductRemak6;
private String basicPrductRemak7;
private String basicPrductRemak8;
} }

@ -0,0 +1,20 @@
package com.glxp.sale.admin.service.basic;
import com.glxp.sale.admin.entity.basic.NewUploadDiEntity;
import com.glxp.sale.admin.req.basic.FilterNewUploadDiRequest;
import java.util.List;
public interface NewUploadDiService {
List<NewUploadDiEntity> filterNewUploads(FilterNewUploadDiRequest filterNewUploadDiRequest);
boolean deleteById(Integer id);
boolean insertNewUploadDi(NewUploadDiEntity newUploadDiEntity);
boolean updateNewUploadDi(NewUploadDiEntity newUploadDiEntity);
}

@ -0,0 +1,49 @@
package com.glxp.sale.admin.service.basic.impl;
import com.github.pagehelper.PageHelper;
import com.glxp.sale.admin.dao.basic.NewUploadDiDao;
import com.glxp.sale.admin.entity.basic.CorpImportLogEntity;
import com.glxp.sale.admin.entity.basic.NewUploadDiEntity;
import com.glxp.sale.admin.entity.basic.UdiInfoImportLogEntity;
import com.glxp.sale.admin.req.basic.FilterNewUploadDiRequest;
import com.glxp.sale.admin.service.basic.NewUploadDiService;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.Collections;
import java.util.List;
@Service
public class NewUploadDiServiceImpl implements NewUploadDiService {
@Resource
NewUploadDiDao newUploadDiDao;
@Override
public List<NewUploadDiEntity> filterNewUploads(FilterNewUploadDiRequest filterNewUploadDiRequest) {
if (filterNewUploadDiRequest == null) {
return Collections.emptyList();
}
if (filterNewUploadDiRequest.getPage() != null) {
int offset = (filterNewUploadDiRequest.getPage() - 1) * filterNewUploadDiRequest.getLimit();
PageHelper.offsetPage(offset, filterNewUploadDiRequest.getLimit());
}
List<NewUploadDiEntity> data = newUploadDiDao.filterNewUploads(filterNewUploadDiRequest);
return data;
}
@Override
public boolean deleteById(Integer id) {
return newUploadDiDao.deleteById(id);
}
@Override
public boolean insertNewUploadDi(NewUploadDiEntity newUploadDiEntity) {
return newUploadDiDao.insertNewUploadDi(newUploadDiEntity);
}
@Override
public boolean updateNewUploadDi(NewUploadDiEntity newUploadDiEntity) {
return newUploadDiDao.updateNewUploadDi(newUploadDiEntity);
}
}

@ -97,15 +97,12 @@ public class UdiInfoImportDetailServiceImpl implements UdiInfoImportDetailServic
//基础表导入 //基础表导入
SqlSession batchSession = sqlSessionFactory.openSession(ExecutorType.BATCH, TransactionIsolationLevel.READ_COMMITTED); SqlSession batchSession = sqlSessionFactory.openSession(ExecutorType.BATCH, TransactionIsolationLevel.READ_COMMITTED);
if (CollUtil.isNotEmpty(udiRelevanceExportJsonResponse.getUdiInfoEntities())) { if (CollUtil.isNotEmpty(udiRelevanceExportJsonResponse.getUdiInfoEntities())) {
try { List<UdiInfoEntity> corpList = udiRelevanceExportJsonResponse.getUdiInfoEntities();
List<UdiInfoEntity> corpList = udiRelevanceExportJsonResponse.getUdiInfoEntities(); UdiInfoDao mapper = batchSession.getMapper(UdiInfoDao.class);
UdiInfoDao mapper = batchSession.getMapper(UdiInfoDao.class); for (UdiInfoEntity basicUnitMaintainEntity : corpList) {
for (UdiInfoEntity basicUnitMaintainEntity : corpList) { mapper.insertUdiInfo(basicUnitMaintainEntity);
mapper.insertUdiInfo(basicUnitMaintainEntity);
}
batchSession.commit();
} catch (Exception e) {
} }
batchSession.commit();
} }
batchSession.close(); batchSession.close();
} }
@ -113,15 +110,12 @@ public class UdiInfoImportDetailServiceImpl implements UdiInfoImportDetailServic
//关联表导入 //关联表导入
if (CollUtil.isNotEmpty(udiRelevanceExportJsonResponse.getUdiRelevanceEntities())) { if (CollUtil.isNotEmpty(udiRelevanceExportJsonResponse.getUdiRelevanceEntities())) {
SqlSession batchSession = sqlSessionFactory.openSession(ExecutorType.BATCH, TransactionIsolationLevel.READ_COMMITTED); SqlSession batchSession = sqlSessionFactory.openSession(ExecutorType.BATCH, TransactionIsolationLevel.READ_COMMITTED);
try { List<UdiRelevanceEntity> corpList = udiRelevanceExportJsonResponse.getUdiRelevanceEntities();
List<UdiRelevanceEntity> corpList = udiRelevanceExportJsonResponse.getUdiRelevanceEntities(); UdiRelevanceDao mapper = batchSession.getMapper(UdiRelevanceDao.class);
UdiRelevanceDao mapper = batchSession.getMapper(UdiRelevanceDao.class); for (UdiRelevanceEntity basicUnitMaintainEntity : corpList) {
for (UdiRelevanceEntity basicUnitMaintainEntity : corpList) { mapper.insertUdiRelevance(basicUnitMaintainEntity);
mapper.insertUdiRelevance(basicUnitMaintainEntity);
}
batchSession.commit();
} catch (Exception e) {
} }
batchSession.commit();
batchSession.close(); batchSession.close();
} }
@ -129,15 +123,12 @@ public class UdiInfoImportDetailServiceImpl implements UdiInfoImportDetailServic
if (CollUtil.isNotEmpty(udiRelevanceExportJsonResponse.getThrProductsEntities())) { if (CollUtil.isNotEmpty(udiRelevanceExportJsonResponse.getThrProductsEntities())) {
SqlSession batchSession = sqlSessionFactory.openSession(ExecutorType.BATCH, TransactionIsolationLevel.READ_COMMITTED); SqlSession batchSession = sqlSessionFactory.openSession(ExecutorType.BATCH, TransactionIsolationLevel.READ_COMMITTED);
try { List<ThrProductsEntity> corpList = udiRelevanceExportJsonResponse.getThrProductsEntities();
List<ThrProductsEntity> corpList = udiRelevanceExportJsonResponse.getThrProductsEntities(); ThrProductsDao mapper = batchSession.getMapper(ThrProductsDao.class);
ThrProductsDao mapper = batchSession.getMapper(ThrProductsDao.class); for (ThrProductsEntity basicUnitMaintainEntity : corpList) {
for (ThrProductsEntity basicUnitMaintainEntity : corpList) { mapper.insertThrProducts(basicUnitMaintainEntity);
mapper.insertThrProducts(basicUnitMaintainEntity);
}
batchSession.commit();
} catch (Exception e) {
} }
batchSession.commit();
batchSession.close(); batchSession.close();
} }

@ -0,0 +1,18 @@
package com.glxp.sale.admin.service.info;
import com.glxp.sale.admin.entity.info.BasicProductSetEntity;
import com.glxp.sale.admin.req.info.FilterBasicProductSetrequest;
import java.util.List;
import java.util.Map;
public interface BasicProductSetService {
List<BasicProductSetEntity> filterSetup(FilterBasicProductSetrequest filterBasicProductSetrequest);
Map<String, BasicProductSetEntity> filterAllEnable();
boolean updateSetup(BasicProductSetEntity basicProductSetEntity);
}

@ -0,0 +1,58 @@
package com.glxp.sale.admin.service.info.impl;
import cn.hutool.core.collection.CollUtil;
import com.github.pagehelper.PageHelper;
import com.glxp.sale.admin.dao.info.BasicProductSetDao;
import com.glxp.sale.admin.entity.info.BasicProductSetEntity;
import com.glxp.sale.admin.req.info.FilterBasicProductSetrequest;
import com.glxp.sale.admin.service.info.BasicProductSetService;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.Collections;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@Service
public class BasicProductSetServiceImpl implements BasicProductSetService {
@Resource
BasicProductSetDao basicProductSetDao;
@Override
public List<BasicProductSetEntity> filterSetup(FilterBasicProductSetrequest filterBasicProductSetrequest) {
if (filterBasicProductSetrequest == null) {
return Collections.emptyList();
}
if (filterBasicProductSetrequest.getPage() != null) {
int offset = (filterBasicProductSetrequest.getPage() - 1) * filterBasicProductSetrequest.getLimit();
PageHelper.offsetPage(offset, filterBasicProductSetrequest.getLimit());
}
return basicProductSetDao.filterSetup(filterBasicProductSetrequest);
}
@Override
public Map<String, BasicProductSetEntity> filterAllEnable() {
FilterBasicProductSetrequest filterBasicProductSetrequest = new FilterBasicProductSetrequest();
filterBasicProductSetrequest.setEnable(true);
List<BasicProductSetEntity> basicProductSetEntities = basicProductSetDao.filterSetup(filterBasicProductSetrequest);
Map<String, BasicProductSetEntity> basicProductSetEntityMap = new HashMap<>();
if (CollUtil.isNotEmpty(basicProductSetEntities)) {
for (BasicProductSetEntity basicProductSetEntity : basicProductSetEntities) {
basicProductSetEntityMap.put(basicProductSetEntity.getParmKey(), basicProductSetEntity);
}
}
return basicProductSetEntityMap;
}
@Override
public boolean updateSetup(BasicProductSetEntity basicProductSetEntity) {
return basicProductSetDao.updateSetup(basicProductSetEntity);
}
}

@ -5,6 +5,7 @@ import com.glxp.sale.admin.req.param.SystemParamConfigRequest;
import com.glxp.sale.admin.req.param.SystemParamConfigSaveRequest; import com.glxp.sale.admin.req.param.SystemParamConfigSaveRequest;
import java.util.List; import java.util.List;
import java.util.Map;
public interface SystemParamConfigService { public interface SystemParamConfigService {
@ -21,11 +22,13 @@ public interface SystemParamConfigService {
SystemParamConfigEntity selectByParamKey(String key); SystemParamConfigEntity selectByParamKey(String key);
String selectValueByParamKey(String key); String selectValueByParamKey(String key);
boolean updateById(SystemParamConfigSaveRequest systemParamConfigSaveRequest); boolean updateById(SystemParamConfigSaveRequest systemParamConfigSaveRequest);
boolean updateParentId(SystemParamConfigSaveRequest systemParamConfigSaveRequest); boolean updateParentId(SystemParamConfigSaveRequest systemParamConfigSaveRequest);
boolean insert(SystemParamConfigEntity systemParamConfigEntity); boolean insert(SystemParamConfigEntity systemParamConfigEntity);
Map<String, SystemParamConfigEntity> findBasicAll();
} }

@ -1,5 +1,6 @@
package com.glxp.sale.admin.service.param.impl; package com.glxp.sale.admin.service.param.impl;
import cn.hutool.core.collection.CollUtil;
import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageHelper;
import com.glxp.sale.admin.dao.param.SystemParamConfigDao; import com.glxp.sale.admin.dao.param.SystemParamConfigDao;
import com.glxp.sale.admin.entity.param.SystemParamConfigEntity; import com.glxp.sale.admin.entity.param.SystemParamConfigEntity;
@ -9,7 +10,9 @@ import com.glxp.sale.admin.service.param.SystemParamConfigService;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import javax.annotation.Resource; import javax.annotation.Resource;
import java.util.HashMap;
import java.util.List; import java.util.List;
import java.util.Map;
@Service @Service
public class SystemParamConfigServiceImpl implements SystemParamConfigService { public class SystemParamConfigServiceImpl implements SystemParamConfigService {
@ -79,4 +82,24 @@ public class SystemParamConfigServiceImpl implements SystemParamConfigService {
public boolean insert(SystemParamConfigEntity systemParamConfigEntity) { public boolean insert(SystemParamConfigEntity systemParamConfigEntity) {
return systemParamConfigDao.insert(systemParamConfigEntity); return systemParamConfigDao.insert(systemParamConfigEntity);
} }
@Override
public Map<String, SystemParamConfigEntity> findBasicAll() {
SystemParamConfigRequest systemParamConfigRequest = new SystemParamConfigRequest();
systemParamConfigRequest.setParamType(2);
systemParamConfigRequest.setParamStatus(1);
List<SystemParamConfigEntity> systemParamConfigEntities = queryPage(systemParamConfigRequest);
Map<String, SystemParamConfigEntity> systemParamConfigEntityMap = new HashMap<>();
if (CollUtil.isNotEmpty(systemParamConfigEntities)) {
for (SystemParamConfigEntity systemParamConfigEntity : systemParamConfigEntities) {
systemParamConfigEntityMap.put(systemParamConfigEntity.getParamKey(), systemParamConfigEntity);
}
}
return systemParamConfigEntityMap;
}
} }

@ -75,14 +75,11 @@ public class ThrCorpServiceImpl implements ThrCorpService {
public void importJsonData(List<ThrCorpEntity> thrCorpEntities) { public void importJsonData(List<ThrCorpEntity> thrCorpEntities) {
SqlSession batchSession = sqlSessionFactory.openSession(ExecutorType.BATCH, TransactionIsolationLevel.READ_COMMITTED); SqlSession batchSession = sqlSessionFactory.openSession(ExecutorType.BATCH, TransactionIsolationLevel.READ_COMMITTED);
if (CollUtil.isNotEmpty(thrCorpEntities)) { if (CollUtil.isNotEmpty(thrCorpEntities)) {
try { ThrCorpDao mapper = batchSession.getMapper(ThrCorpDao.class);
ThrCorpDao mapper = batchSession.getMapper(ThrCorpDao.class); thrCorpEntities.forEach(thrCorpEntity -> {
thrCorpEntities.forEach(thrCorpEntity -> { mapper.insertThrCorps(thrCorpEntity);
mapper.insertThrCorps(thrCorpEntity); });
}); batchSession.commit();
batchSession.commit();
} catch (Exception e) {
}
} }
batchSession.close(); batchSession.close();
} }

@ -1,6 +1,7 @@
package com.glxp.sale.admin.service.thrsys.impl; package com.glxp.sale.admin.service.thrsys.impl;
import cn.hutool.core.collection.CollUtil; import cn.hutool.core.collection.CollUtil;
import cn.hutool.json.JSONUtil;
import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageHelper;
import com.glxp.sale.admin.dao.thrsys.ThrProductsAddDiDao; import com.glxp.sale.admin.dao.thrsys.ThrProductsAddDiDao;
import com.glxp.sale.admin.entity.basic.UdiInfoEntity; import com.glxp.sale.admin.entity.basic.UdiInfoEntity;
@ -71,6 +72,7 @@ public class ThrProductsAddDiServiceImpl implements ThrProductsAddDiService {
thrProductsAddDiEntity.setUuid(uuid); thrProductsAddDiEntity.setUuid(uuid);
thrProductsAddDiEntity.setCreateTime(date); thrProductsAddDiEntity.setCreateTime(date);
thrProductsAddDiEntity.setStatus(1); //未审核 thrProductsAddDiEntity.setStatus(1); //未审核
thrProductsAddDiEntity.setSelectThridSysStr(JSONUtil.toJsonStr(thrDiProductsRequest.getSelectThirdSys()));
list.add(thrProductsAddDiEntity); list.add(thrProductsAddDiEntity);
} }
return thrProductsAddDiDao.insertThrDiProducts(list); return thrProductsAddDiDao.insertThrDiProducts(list);

@ -1,11 +1,16 @@
package com.glxp.sale.admin.thread; package com.glxp.sale.admin.thread;
import cn.hutool.core.util.StrUtil; import cn.hutool.core.util.StrUtil;
import com.glxp.sale.admin.entity.basic.UdiInfoEntity;
import com.glxp.sale.admin.entity.basic.UdiRelevanceEntity; import com.glxp.sale.admin.entity.basic.UdiRelevanceEntity;
import com.glxp.sale.admin.entity.info.CompanyProductRelevanceEntity; import com.glxp.sale.admin.entity.info.CompanyProductRelevanceEntity;
import com.glxp.sale.admin.req.basic.SupplementRequest;
import com.glxp.sale.admin.req.basic.UdiInfoExportRequest; import com.glxp.sale.admin.req.basic.UdiInfoExportRequest;
import com.glxp.sale.admin.service.basic.UdiInfoService;
import com.glxp.sale.admin.service.basic.UdiRelevanceService; import com.glxp.sale.admin.service.basic.UdiRelevanceService;
import com.glxp.sale.admin.service.info.CompanyProductRelevanceService; import com.glxp.sale.admin.service.info.CompanyProductRelevanceService;
import com.glxp.sale.admin.util.BeanUtils;
import org.springframework.context.annotation.Bean;
import org.springframework.scheduling.annotation.Async; import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
@ -20,6 +25,8 @@ public class CompanyProductsRelService {
private CompanyProductRelevanceService companyProductRelevanceService; private CompanyProductRelevanceService companyProductRelevanceService;
@Resource @Resource
UdiRelevanceService udiRelevanceService; UdiRelevanceService udiRelevanceService;
@Resource
UdiInfoService udiInfoService;
@Async @Async
public void insertCompanyProducts(UdiInfoExportRequest udiInfoExportRequest) { public void insertCompanyProducts(UdiInfoExportRequest udiInfoExportRequest) {
@ -33,6 +40,12 @@ public class CompanyProductsRelService {
if (udiRelevanceEntity != null && StrUtil.isNotBlank(udiRelevanceEntity.getPrice())) { if (udiRelevanceEntity != null && StrUtil.isNotBlank(udiRelevanceEntity.getPrice())) {
companyProductRelevanceEntity.setPrice(new BigDecimal(udiRelevanceEntity.getPrice())); companyProductRelevanceEntity.setPrice(new BigDecimal(udiRelevanceEntity.getPrice()));
} }
UdiInfoEntity udiInfoEntity = udiInfoService.findByUuid(udiRelevanceEntity.getUuid());
SupplementRequest supplementRequest = udiInfoExportRequest.getSupplementRequest();
BeanUtils.copyProperties(udiInfoExportRequest.getSupplementRequest(), udiInfoEntity);
BeanUtils.copyProperties(supplementRequest, udiRelevanceEntity);
udiRelevanceService.updateUdiRelevance(udiRelevanceEntity);
udiInfoService.updateUdiInfo(udiInfoEntity);
companyProductRelevanceEntity.setCreate_time(new Date()); companyProductRelevanceEntity.setCreate_time(new Date());
companyProductRelevanceEntity.setUpdate_time(new Date()); companyProductRelevanceEntity.setUpdate_time(new Date());
companyProductRelevanceEntity.setAuditStatus("3"); companyProductRelevanceEntity.setAuditStatus("3");
@ -40,6 +53,8 @@ public class CompanyProductsRelService {
companyProductRelevanceEntity.setUdiRlIdFk(Integer.parseInt(uuid)); companyProductRelevanceEntity.setUdiRlIdFk(Integer.parseInt(uuid));
companyProductRelevanceEntity.setCustomerId(udiInfoExportRequest.getCustomerId()); companyProductRelevanceEntity.setCustomerId(udiInfoExportRequest.getCustomerId());
boolean b = companyProductRelevanceService.insertCompanyProductRelevance(companyProductRelevanceEntity); boolean b = companyProductRelevanceService.insertCompanyProductRelevance(companyProductRelevanceEntity);
} }
} else {//一键导出 //todo暂时去掉 } else {//一键导出 //todo暂时去掉

@ -111,15 +111,12 @@ public class ThrOrderImportService {
} }
if (CollUtil.isNotEmpty(importData.getThrOrderDetailEntities())) { if (CollUtil.isNotEmpty(importData.getThrOrderDetailEntities())) {
try { List<ThrOrderDetailEntity> thrOrderDetailEntities = importData.getThrOrderDetailEntities();
List<ThrOrderDetailEntity> thrOrderDetailEntities = importData.getThrOrderDetailEntities(); ThrOrderDetailDao mapper = batchSession.getMapper(ThrOrderDetailDao.class);
ThrOrderDetailDao mapper = batchSession.getMapper(ThrOrderDetailDao.class); thrOrderDetailEntities.forEach(thrOrderDetailEntity -> {
thrOrderDetailEntities.forEach(thrOrderDetailEntity -> { mapper.insertThrOrderDetail(thrOrderDetailEntity);
mapper.insertThrOrderDetail(thrOrderDetailEntity); });
}); batchSession.commit();
batchSession.commit();
} catch (Exception e) {
}
} }
batchSession.close(); batchSession.close();
} }

@ -78,14 +78,11 @@ public class ThrProductsImportService {
SqlSession batchSession = sqlSessionFactory.openSession(ExecutorType.BATCH, TransactionIsolationLevel.READ_COMMITTED); SqlSession batchSession = sqlSessionFactory.openSession(ExecutorType.BATCH, TransactionIsolationLevel.READ_COMMITTED);
if (CollUtil.isNotEmpty(thrProductsEntities)) { if (CollUtil.isNotEmpty(thrProductsEntities)) {
try { ThrProductsDao mapper = batchSession.getMapper(ThrProductsDao.class);
ThrProductsDao mapper = batchSession.getMapper(ThrProductsDao.class); thrProductsEntities.forEach(thrCorpEntity -> {
thrProductsEntities.forEach(thrCorpEntity -> { mapper.insertThrProducts(thrCorpEntity);
mapper.insertThrProducts(thrCorpEntity); });
}); batchSession.commit();
batchSession.commit();
} catch (Exception e) {
}
} }
batchSession.close(); batchSession.close();
} }

@ -0,0 +1,177 @@
package com.glxp.sale.admin.util;
import cn.hutool.core.util.StrUtil;
import com.glxp.sale.admin.entity.info.BasicProductSetEntity;
import com.glxp.sale.admin.entity.param.SystemParamConfigEntity;
import com.glxp.sale.admin.req.basic.SupplementRequest;
import com.glxp.sale.admin.service.info.BasicProductSetService;
import com.glxp.sale.admin.service.param.SystemParamConfigService;
import com.glxp.sale.common.res.BaseResponse;
import com.glxp.sale.common.util.ResultVOUtils;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.Map;
@Service
public class SupplementVailUtil {
@Resource
BasicProductSetService basicProductSetService;
@Resource
SystemParamConfigService systemParamConfigService;
public static final int SUP_SELECT = 1;
public static final int SUP_ADD = 2;
public static final int LOCAL_ADD = 3;
public static final int LOCAL_EIDT = 4;
public String vail(SupplementRequest supplementRequest, int type) {
//验证产品信息是否必填
Map<String, BasicProductSetEntity> basicProductSetEntityMap = basicProductSetService.filterAllEnable();
Map<String, SystemParamConfigEntity> systemParamConfigEntityMap = systemParamConfigService.findBasicAll();
if (basicProductSetEntityMap.size() > 0) {
BasicProductSetEntity basicProductSetEntity = null;
basicProductSetEntity = basicProductSetEntityMap.get("sptm");
if (isMustFill(type, basicProductSetEntity)) {
if (StrUtil.isEmpty(supplementRequest.getSptm())) {
return "商品条码不能为空";
}
}
basicProductSetEntity = basicProductSetEntityMap.get("ybbm");
if (isMustFill(type, basicProductSetEntity)) {
if (StrUtil.isEmpty(supplementRequest.getYbbm())) {
return "医保编码不能为空";
}
}
basicProductSetEntity = basicProductSetEntityMap.get("measname");
if (isMustFill(type, basicProductSetEntity)) {
if (StrUtil.isEmpty(supplementRequest.getMeasname())) {
return "计量单位不能为空";
}
}
basicProductSetEntity = basicProductSetEntityMap.get("manufactory");
if (isMustFill(type, basicProductSetEntity)) {
if (StrUtil.isEmpty(supplementRequest.getManufactory())) {
return "生产企业不能为空";
}
}
basicProductSetEntity = basicProductSetEntityMap.get("spmc");
if (isMustFill(type, basicProductSetEntity)) {
if (StrUtil.isEmpty(supplementRequest.getSpmc())) {
return "商品名称不能为空";
}
}
basicProductSetEntity = basicProductSetEntityMap.get("cpms");
if (isMustFill(type, basicProductSetEntity)) {
if (StrUtil.isEmpty(supplementRequest.getCpms())) {
return "产品描述不能为空";
}
}
basicProductSetEntity = basicProductSetEntityMap.get("price");
if (isMustFill(type, basicProductSetEntity)) {
if (StrUtil.isEmpty(supplementRequest.getPrice())) {
return "产品价格不能为空";
}
}
basicProductSetEntity = basicProductSetEntityMap.get("basicPrductRemak1");
if (isMustFill(type, basicProductSetEntity)) {
if (StrUtil.isEmpty(supplementRequest.getBasicPrductRemak1())) {
SystemParamConfigEntity systemParamConfigEntity = systemParamConfigEntityMap.get("basicPrductRemak1");
if (!systemParamConfigEntity.getParamValue().equals("0")) {
return systemParamConfigEntity.getParamValue() + "不能为空";
}
}
}
basicProductSetEntity = basicProductSetEntityMap.get("basicPrductRemak2");
if (isMustFill(type, basicProductSetEntity)) {
if (StrUtil.isEmpty(supplementRequest.getBasicPrductRemak2())) {
SystemParamConfigEntity systemParamConfigEntity = systemParamConfigEntityMap.get("basicPrductRemak2");
if (!systemParamConfigEntity.getParamValue().equals("0")) {
return systemParamConfigEntity.getParamValue() + "不能为空";
}
}
}
basicProductSetEntity = basicProductSetEntityMap.get("basicPrductRemak3");
if (isMustFill(type, basicProductSetEntity)) {
if (StrUtil.isEmpty(supplementRequest.getBasicPrductRemak3())) {
SystemParamConfigEntity systemParamConfigEntity = systemParamConfigEntityMap.get("basicPrductRemak3");
if (!systemParamConfigEntity.getParamValue().equals("0")) {
return systemParamConfigEntity.getParamValue() + "不能为空";
}
}
}
basicProductSetEntity = basicProductSetEntityMap.get("basicPrductRemak4");
if (isMustFill(type, basicProductSetEntity)) {
if (StrUtil.isEmpty(supplementRequest.getBasicPrductRemak4())) {
SystemParamConfigEntity systemParamConfigEntity = systemParamConfigEntityMap.get("basicPrductRemak4");
if (!systemParamConfigEntity.getParamValue().equals("0")) {
return systemParamConfigEntity.getParamValue() + "不能为空";
}
}
}
basicProductSetEntity = basicProductSetEntityMap.get("basicPrductRemak5");
if (isMustFill(type, basicProductSetEntity)) {
if (StrUtil.isEmpty(supplementRequest.getBasicPrductRemak5())) {
SystemParamConfigEntity systemParamConfigEntity = systemParamConfigEntityMap.get("basicPrductRemak5");
if (!systemParamConfigEntity.getParamValue().equals("0")) {
return systemParamConfigEntity.getParamValue() + "不能为空";
}
}
}
basicProductSetEntity = basicProductSetEntityMap.get("basicPrductRemak6");
if (isMustFill(type, basicProductSetEntity)) {
if (StrUtil.isEmpty(supplementRequest.getBasicPrductRemak6())) {
SystemParamConfigEntity systemParamConfigEntity = systemParamConfigEntityMap.get("basicPrductRemak6");
if (!systemParamConfigEntity.getParamValue().equals("0")) {
return systemParamConfigEntity.getParamValue() + "不能为空";
}
}
}
basicProductSetEntity = basicProductSetEntityMap.get("basicPrductRemak7");
if (isMustFill(type, basicProductSetEntity)) {
if (StrUtil.isEmpty(supplementRequest.getBasicPrductRemak7())) {
SystemParamConfigEntity systemParamConfigEntity = systemParamConfigEntityMap.get("basicPrductRemak7");
if (!systemParamConfigEntity.getParamValue().equals("0")) {
return systemParamConfigEntity.getParamValue() + "不能为空";
}
}
}
basicProductSetEntity = basicProductSetEntityMap.get("basicPrductRemak8");
if (isMustFill(type, basicProductSetEntity)) {
if (StrUtil.isEmpty(supplementRequest.getBasicPrductRemak8())) {
SystemParamConfigEntity systemParamConfigEntity = systemParamConfigEntityMap.get("basicPrductRemak8");
if (!systemParamConfigEntity.getParamValue().equals("0")) {
return systemParamConfigEntity.getParamValue() + "不能为空";
}
}
}
}
return null;
}
public boolean isMustFill(int type, BasicProductSetEntity basicProductSetEntity) {
if (basicProductSetEntity == null)
return false;
if (type == SUP_SELECT && basicProductSetEntity.isSupSelect()) {
return true;
} else if (type == SUP_ADD && basicProductSetEntity.isSupAdd()) {
return true;
} else if (type == LOCAL_ADD && basicProductSetEntity.isLocalAdd()) {
return true;
} else if (type == LOCAL_EIDT && basicProductSetEntity.isLocalEdit()) {
return true;
}
return false;
}
}

@ -0,0 +1,65 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="com.glxp.sale.admin.dao.basic.NewUploadDiDao">
<select id="filterNewUploads" parameterType="com.glxp.sale.admin.req.basic.FilterNewUploadDiRequest"
resultType="com.glxp.sale.admin.entity.basic.NewUploadDiEntity">
SELECT * FROM basic_new_udi_upload
<where>
<if test="id != '' and id != null">
AND id = #{id}
</if>
<if test="relId != '' and relId != null">
AND relId = #{relId}
</if>
<if test="thirdSysFk != '' and thirdSysFk != null">
AND thirdSysFk = #{thirdSysFk}
</if>
<if test="uploadStatus != '' and uploadStatus != null">
AND uploadStatus = #{uploadStatus}
</if>
<if test="uploadCode != '' and uploadCode != null">
AND uploadCode = #{uploadCode}
</if>
<if test="lastUpdateTime!=null and lastUpdateTime!=''">
<![CDATA[ and DATE_FORMAT(updateTime, '%Y-%m-%d %H:%i:%S')>= DATE_FORMAT(#{lastUpdateTime}, '%Y-%m-%d %H:%i:%S') ]]>
</if>
</where>
ORDER BY updateTime DESC
</select>
<insert id="insertNewUploadDi" keyProperty="id" parameterType="com.glxp.sale.admin.entity.basic.NewUploadDiEntity">
insert INTO basic_new_udi_upload
(relId, thirdSysFk, uploadStatus, uploadMsg, uploadCode, remark, updateTime, submitTime)
values (#{relId},
#{thirdSysFk},
#{uploadStatus},
#{uploadMsg}, #{uploadCode}, #{remark}, #{updateTime}, #{submitTime})
</insert>
<delete id="deleteById" parameterType="Map">
DELETE
FROM basic_new_udi_upload
WHERE id = #{id}
</delete>
<update id="updateNewUploadDi" parameterType="com.glxp.sale.admin.entity.basic.NewUploadDiEntity">
UPDATE basic_new_udi_upload
<set>
<if test="relId != null">relId=#{relId},</if>
<if test="thirdSysFk != null">thirdSysFk=#{thirdSysFk},</if>
<if test="updateTime != null">updateTime=#{updateTime},</if>
<if test="uploadStatus != null">uploadStatus=#{uploadStatus},</if>
<if test="uploadMsg != null">uploadMsg=#{uploadMsg},</if>
<if test="uploadCode != null">uploadCode=#{uploadCode},</if>
<if test="remark != null">remark=#{remark},</if>
<if test="updateTime != null">updateTime=#{updateTime},</if>
<if test="submitTime != null">submitTime=#{submitTime},</if>
</set>
WHERE id = #{id}
</update>
</mapper>

@ -0,0 +1,42 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="com.glxp.sale.admin.dao.info.BasicProductSetDao">
<select id="filterSetup"
parameterType="com.glxp.sale.admin.req.info.FilterBasicProductSetrequest"
resultType="com.glxp.sale.admin.entity.info.BasicProductSetEntity">
SELECT *
FROM basic_product_set
<where>
<if test="parmName != '' and parmName!=null">
and udiRlIdFk = #{udiRlIdFk}
</if>
<if test="enable != null ">
and enable = #{enable}
</if>
</where>
ORDER BY sort
</select>
<insert id="updateSetup" parameterType="com.glxp.sale.admin.entity.info.BasicProductSetEntity">
replace
INTO basic_product_set(parmName,
parmKey,enable,supSelect,supAdd,localAdd,remark,sort,localEdit) values
(
#{parmName},
#{parmKey},
#{enable} ,
#{supSelect},
#{supAdd},
#{localAdd},
#{remark},
#{sort},
#{localEdit}
)
</insert>
</mapper>

@ -102,7 +102,7 @@
( (
code,`name`,measname,spec,registerNo,manufactory, code,`name`,measname,spec,registerNo,manufactory,
cplb,flbm,qxlb,ybbm,sptm,tyshxydm,zczbhhzbapzbh,ylqxzcrbarmc,ylqxzcrbarywmc,cpms, cplb,flbm,qxlb,ybbm,sptm,tyshxydm,zczbhhzbapzbh,ylqxzcrbarmc,ylqxzcrbarywmc,cpms,
thirdSysFk,updateTime,supName,checkStatus,customerId thirdSysFk,updateTime,supName,checkStatus,customerId,relId
) )
values values
( (
@ -126,7 +126,7 @@
#{updateTime}, #{updateTime},
#{supName}, #{supName},
#{checkStatus}, #{checkStatus},
#{customerId} #{customerId},#{relId}
) )
</insert> </insert>
@ -135,7 +135,7 @@
( (
code,name,measname,spec,registerNo,manufactory, code,name,measname,spec,registerNo,manufactory,
cplb,flbm,qxlb,ybbm,sptm,tyshxydm,zczbhhzbapzbh,ylqxzcrbarmc,ylqxzcrbarywmc,cpms, cplb,flbm,qxlb,ybbm,sptm,tyshxydm,zczbhhzbapzbh,ylqxzcrbarmc,ylqxzcrbarywmc,cpms,
thirdSysFk,updateTime,supName,checkStatus,customerId thirdSysFk,updateTime,supName,checkStatus,customerId,relId
) )
values values
@ -150,7 +150,7 @@
#{item.manufactory}, #{item.manufactory},
#{item.cplb}, #{item.flbm}, #{item.qxlb}, #{item.ybbm},#{item.sptm}, #{item.cplb}, #{item.flbm}, #{item.qxlb}, #{item.ybbm},#{item.sptm},
#{item.tyshxydm}, #{item.zczbhhzbapzbh}, #{item.ylqxzcrbarmc}, #{item.ylqxzcrbarywmc},#{item.cpms}, #{item.tyshxydm}, #{item.zczbhhzbapzbh}, #{item.ylqxzcrbarmc}, #{item.ylqxzcrbarywmc},#{item.cpms},
#{item.thirdSysFk},#{item.updateTime},#{item.supName}, #{tem.checkStatus}, #{tem.customerId} #{item.thirdSysFk},#{item.updateTime},#{item.supName}, #{tem.checkStatus}, #{tem.customerId},#{item.relId}
) )
</foreach> </foreach>
</insert> </insert>

@ -5,7 +5,9 @@
<insert id="insertThrDiProducts" keyProperty="id" parameterType="java.util.List"> <insert id="insertThrDiProducts" keyProperty="id" parameterType="java.util.List">
insert into thr_products_add_di (uuid, customerId, createTime, auditTime, remark, auditUser, `status` insert into thr_products_add_di (uuid, customerId, createTime, auditTime, remark, auditUser, `status`
, thirdSysFk, code, sptm, ybbm, measname,manufactory,spmc,cpms , thirdSysFk, code, sptm, ybbm, measname,manufactory,spmc,cpms,selectThridSysStr,price,
basicPrductRemak1,basicPrductRemak2,basicPrductRemak3,basicPrductRemak4,
basicPrductRemak5,basicPrductRemak6,basicPrductRemak7,basicPrductRemak8
) )
values values
<foreach collection="list" index="index" item="item" separator=","> <foreach collection="list" index="index" item="item" separator=",">
@ -23,7 +25,10 @@
#{item.measname}, #{item.measname},
#{item.manufactory}, #{item.manufactory},
#{item.spmc}, #{item.spmc},
#{item.cpms}) #{item.cpms},#{item.selectThridSysStr},#{item.price}
,#{item.basicPrductRemak1},#{item.basicPrductRemak2},#{item.basicPrductRemak3},#{item.basicPrductRemak4}
,#{item.basicPrductRemak5},#{item.basicPrductRemak6},#{item.basicPrductRemak7},#{item.basicPrductRemak8}
)
</foreach> </foreach>
</insert> </insert>
@ -45,6 +50,16 @@
<if test="spmc != null">`spmc`=#{spmc},</if> <if test="spmc != null">`spmc`=#{spmc},</if>
<if test="cpms != null">`cpms`=#{cpms},</if> <if test="cpms != null">`cpms`=#{cpms},</if>
<if test="status != null">`status`=#{status},</if> <if test="status != null">`status`=#{status},</if>
<if test="price != null">`price`=#{price},</if>
<if test="basicPrductRemak1 != null">`basicPrductRemak1`=#{basicPrductRemak1},</if>
<if test="basicPrductRemak2 != null">`basicPrductRemak2`=#{basicPrductRemak2},</if>
<if test="basicPrductRemak3 != null">`basicPrductRemak3`=#{basicPrductRemak3},</if>
<if test="basicPrductRemak4 != null">`basicPrductRemak4`=#{basicPrductRemak4},</if>
<if test="basicPrductRemak5 != null">`basicPrductRemak5`=#{basicPrductRemak5},</if>
<if test="basicPrductRemak6 != null">`basicPrductRemak6`=#{basicPrductRemak6},</if>
<if test="basicPrductRemak7 != null">`basicPrductRemak7`=#{basicPrductRemak7},</if>
<if test="basicPrductRemak8 != null">`basicPrductRemak8`=#{basicPrductRemak8},</if>
<if test="selectThridSysStr != null">`selectThridSysStr`=#{selectThridSysStr},</if>
</trim> </trim>
WHERE id = #{id} WHERE id = #{id}
@ -58,16 +73,12 @@
<select id="filterThrProductsList" parameterType="com.glxp.sale.admin.req.thrsys.FilterThrProductsRequest" <select id="filterThrProductsList" parameterType="com.glxp.sale.admin.req.thrsys.FilterThrProductsRequest"
resultType="com.glxp.sale.admin.res.thrsys.ThrProductsAddDiResponse"> resultType="com.glxp.sale.admin.res.thrsys.ThrProductsAddDiResponse">
SELECT tdi.id, SELECT tdi.*,
tdi.status,
tdi.uuid,
tdi.customerId,
tdi.remark,
p.nameCode, p.nameCode,
p.cpmctymc, p.cpmctymc,
p.ggxh, p.ggxh,
p.ylqxzcrbarmc, p.ylqxzcrbarmc,
p.zczbhhzbapzbh p.zczbhhzbapzbh,tdi.selectThridSysStr
FROM thr_products_add_di tdi FROM thr_products_add_di tdi
LEFT JOIN productinfo p ON tdi.uuid = p.uuid LEFT JOIN productinfo p ON tdi.uuid = p.uuid
<where> <where>

Loading…
Cancel
Save