|
@@ -44,6 +44,7 @@ import org.springblade.system.entity.Dict;
|
|
|
import org.springblade.system.feign.IDictClient;
|
|
|
import org.springblade.system.user.entity.User;
|
|
|
import org.springblade.system.user.feign.IUserClient;
|
|
|
+import org.springframework.context.annotation.Bean;
|
|
|
import org.springframework.jdbc.core.BeanPropertyRowMapper;
|
|
|
import org.springframework.jdbc.core.JdbcTemplate;
|
|
|
import org.springframework.scheduling.annotation.Async;
|
|
@@ -229,9 +230,37 @@ public class TrialSelfInspectionRecordServiceImpl extends BaseServiceImpl<TrialS
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
- public List<SampleAncillaryDocumentsVO> selfAncillaryDocumentsList(String id) {
|
|
|
- //获取材料附件信息
|
|
|
- List<SampleAncillaryDocumentsVO> result = new ArrayList<>();
|
|
|
+ public List<TrialRecordAncillaryDocumentsVO> selfAncillaryDocumentsList(String id, String type) {
|
|
|
+ //关联取样附件
|
|
|
+ List<TrialRecordAncillaryDocumentsVO> resultData = new ArrayList<>();
|
|
|
+ this.getRecordAncillaryDocumentList(resultData, id, type);
|
|
|
+
|
|
|
+ //其他上传附件
|
|
|
+ List<TrialSelfInspectionRecordFileVO> queryFileVos = jdbcTemplate.query("select id,self_id,url,type from u_trial_self_inspection_record_file where self_id = " + id + " and type = " + type, new BeanPropertyRowMapper<>(TrialSelfInspectionRecordFileVO.class));
|
|
|
+ for (TrialSelfInspectionRecordFileVO fileVO : queryFileVos) {
|
|
|
+ TrialRecordAncillaryDocumentsVO obj = new TrialRecordAncillaryDocumentsVO();
|
|
|
+ obj.setIsDel(1); //其他可以删除
|
|
|
+ obj.setId(fileVO.getId());
|
|
|
+ obj.setUrl(fileVO.getUrl());
|
|
|
+ resultData.add(obj);
|
|
|
+ }
|
|
|
+
|
|
|
+ Map<String, Attach> maps = jdbcTemplate.query("select link,original_name from blade_attach", new BeanPropertyRowMapper<>(Attach.class)).stream().collect(Collectors.toMap(Attach::getLink, Attach -> Attach, (obj1, obj2) -> obj1));
|
|
|
+ for (TrialRecordAncillaryDocumentsVO vo : resultData) {
|
|
|
+ Attach att = maps.get(vo.getUrl());
|
|
|
+ if (att != null) {
|
|
|
+ //文件名
|
|
|
+ vo.setFileName(ObjectUtil.isNotEmpty(att.getOriginalName()) ? att.getOriginalName() : "没有找到对应的上传文件名称");
|
|
|
+ }
|
|
|
+ if (ObjectUtil.isEmpty(vo.getFileName())) {
|
|
|
+ String name = vo.getUrl().split("//upload/")[1].split("/")[1];
|
|
|
+ vo.setFileName(name);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return resultData;
|
|
|
+ }
|
|
|
+
|
|
|
+ private void getRecordAncillaryDocumentList(List<TrialRecordAncillaryDocumentsVO> result, String id, String type) {
|
|
|
//获取样品ids
|
|
|
List<String> sampleIds = baseMapper.selectSelfSampleRecord(id);
|
|
|
if (sampleIds.size() > 0) {
|
|
@@ -246,62 +275,31 @@ public class TrialSelfInspectionRecordServiceImpl extends BaseServiceImpl<TrialS
|
|
|
if (mobilizationIds.size() > 0) {
|
|
|
List<TrialMaterialMobilization> trialMaterialMobilizations = trialMaterialMobilizationMapper.selectBatchIds(mobilizationIds);
|
|
|
for (TrialMaterialMobilization trialMaterialMobilization : trialMaterialMobilizations) {
|
|
|
- SampleAncillaryDocumentsVO obj = new SampleAncillaryDocumentsVO();
|
|
|
+ TrialRecordAncillaryDocumentsVO obj = new TrialRecordAncillaryDocumentsVO();
|
|
|
obj.setId(trialMaterialMobilization.getId());
|
|
|
- obj.setName(trialMaterialMobilization.getMaterialName());
|
|
|
- obj.setOtherAccessories(trialMaterialMobilization.getOtherAccessories());
|
|
|
- obj.setProductionCertificate(trialMaterialMobilization.getProductionCertificate());
|
|
|
- obj.setQualityInspectionReport(trialMaterialMobilization.getQualityInspectionReport());
|
|
|
+ if ("1".equals(type)) {
|
|
|
+ obj.setUrl(trialMaterialMobilization.getProductionCertificate());
|
|
|
+ } else if ("2".equals(type)) {
|
|
|
+ obj.setUrl(trialMaterialMobilization.getQualityInspectionReport());
|
|
|
+ } else if ("3".equals(type)) {
|
|
|
+ obj.setUrl(trialMaterialMobilization.getOtherAccessories());
|
|
|
+ }
|
|
|
+ obj.setIsDel(0); //关联的取样文件不能删除
|
|
|
result.add(obj);
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
-
|
|
|
- String sql = "select link,original_name from blade_attach";
|
|
|
- List<Attach> query = jdbcTemplate.query(sql, new BeanPropertyRowMapper<>(Attach.class));
|
|
|
- for (SampleAncillaryDocumentsVO sampleAncillaryDocumentsVO : result) {
|
|
|
- for (Attach attach : query) {
|
|
|
- if (StringUtils.isNotEmpty(sampleAncillaryDocumentsVO.getOtherAccessories()) && sampleAncillaryDocumentsVO.getOtherAccessories().equals(attach.getLink())) {
|
|
|
- sampleAncillaryDocumentsVO.setOtherAccessoriesName(attach.getOriginalName());
|
|
|
- } else if (StringUtils.isNotEmpty(sampleAncillaryDocumentsVO.getOtherAccessories()) && !sampleAncillaryDocumentsVO.getOtherAccessories().equals(attach.getLink())) {
|
|
|
- sampleAncillaryDocumentsVO.setOtherAccessoriesName(sampleAncillaryDocumentsVO.getOtherAccessories());
|
|
|
- }
|
|
|
-
|
|
|
- if (StringUtils.isNotEmpty(sampleAncillaryDocumentsVO.getProductionCertificate()) && sampleAncillaryDocumentsVO.getProductionCertificate().equals(attach.getLink())) {
|
|
|
- sampleAncillaryDocumentsVO.setProductionCertificateName(attach.getOriginalName());
|
|
|
- } else if (StringUtils.isNotEmpty(sampleAncillaryDocumentsVO.getProductionCertificate()) && !sampleAncillaryDocumentsVO.getProductionCertificate().equals(attach.getLink())) {
|
|
|
- sampleAncillaryDocumentsVO.setProductionCertificateName(sampleAncillaryDocumentsVO.getProductionCertificate());
|
|
|
- }
|
|
|
-
|
|
|
- if (StringUtils.isNotEmpty(sampleAncillaryDocumentsVO.getQualityInspectionReport()) && sampleAncillaryDocumentsVO.getQualityInspectionReport().equals(attach.getLink())) {
|
|
|
- sampleAncillaryDocumentsVO.setQualityInspectionReportName(attach.getOriginalName());
|
|
|
- } else if (StringUtils.isNotEmpty(sampleAncillaryDocumentsVO.getQualityInspectionReport()) && !sampleAncillaryDocumentsVO.getQualityInspectionReport().equals(attach.getLink())) {
|
|
|
- sampleAncillaryDocumentsVO.setQualityInspectionReportName(sampleAncillaryDocumentsVO.getQualityInspectionReport());
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- return result;
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
- @Transactional(rollbackFor = Exception.class)
|
|
|
- public boolean selfUpdateAncillaryDocuments(SampleAncillaryDocumentsVO vo) {
|
|
|
- TrialMaterialMobilization trialMaterialMobilization = trialMaterialMobilizationMapper.selectById(vo.getId());
|
|
|
- if (ObjectUtil.isEmpty(trialMaterialMobilization)) {
|
|
|
- throw new ServiceException("未获取到对应材料信息,修改失败");
|
|
|
- }
|
|
|
- if (StringUtils.isNotEmpty(vo.getQualityInspectionReport())) {
|
|
|
- trialMaterialMobilization.setQualityInspectionReport(vo.getQualityInspectionReport());
|
|
|
- }
|
|
|
- if (StringUtils.isNotEmpty(vo.getOtherAccessories())) {
|
|
|
- trialMaterialMobilization.setOtherAccessories(vo.getOtherAccessories());
|
|
|
- }
|
|
|
- if (StringUtils.isNotEmpty(vo.getProductionCertificate())) {
|
|
|
- trialMaterialMobilization.setProductionCertificate(vo.getProductionCertificate());
|
|
|
- }
|
|
|
- trialMaterialMobilizationMapper.updateById(trialMaterialMobilization);
|
|
|
+ public boolean selfUpdateAncillaryDocuments(TrialSelfInspectionRecordFileVO vo) {
|
|
|
+ jdbcTemplate.execute("insert into u_trial_self_inspection_record_file (id,self_id,url,type) values (" + SnowFlakeUtil.getId() + "," + vo.getSelfId() + ",'" + vo.getUrl() + "'," + vo.getType() + ")");
|
|
|
+ return true;
|
|
|
+ }
|
|
|
|
|
|
+ @Override
|
|
|
+ public boolean selfRemoveAncillaryDocuments(String id) {
|
|
|
+ jdbcTemplate.execute("delete from u_trial_self_inspection_record_file where id = " + id);
|
|
|
return true;
|
|
|
}
|
|
|
|