diff --git a/kn-service-api/biz-vordm-api/src/main/java/com/kening/vordm/entity/DataUpload.java b/kn-service-api/biz-vordm-api/src/main/java/com/kening/vordm/entity/DataUpload.java index 3097873..1744fad 100644 --- a/kn-service-api/biz-vordm-api/src/main/java/com/kening/vordm/entity/DataUpload.java +++ b/kn-service-api/biz-vordm-api/src/main/java/com/kening/vordm/entity/DataUpload.java @@ -35,4 +35,6 @@ public class DataUpload extends EntityData{ private String account; private String password; + + private String sourceLink; } diff --git a/kn-service-api/biz-vordm-api/src/main/java/com/kening/vordm/entity/EntityData.java b/kn-service-api/biz-vordm-api/src/main/java/com/kening/vordm/entity/EntityData.java index c74e972..e663025 100644 --- a/kn-service-api/biz-vordm-api/src/main/java/com/kening/vordm/entity/EntityData.java +++ b/kn-service-api/biz-vordm-api/src/main/java/com/kening/vordm/entity/EntityData.java @@ -126,6 +126,42 @@ public class EntityData implements Serializable { //来源路径 方便查看信息来源 private String sourceLink; + /** + * 1-Optical satellite, 2-Night light satellite, 3-Video satellite, 4-Hyperspectral satellite, 5-Radar satellite + */ + private Integer satelliteTypeSelect; + + /** + * 卫星代号 + */ + private String satelliteCode; + + /** + * 产品序列号 + */ + private String productSerialNum; + + /** + * 产品分辨率 + */ + private Double productResolution; + + /** + * 云层覆盖量 + */ + private Integer cloudCover; + + /** + * 生产时间 + */ + private Date productTime; + + /** + * 产品波段树 + */ + private String productBandsNum; + + /** * 上传人姓名 */ @@ -168,6 +204,18 @@ public class EntityData implements Serializable { @TableField(exist = false) private String disasterType; + /** + * 拒绝理由 + */ + @TableField(exist = false) + private String reason; + + /** + * 上传用户邮箱 + */ + @TableField(exist = false) + private String email; + @TableField(exist = false) private static final long serialVersionUID = 1L; diff --git a/kn-service-api/biz-vordm-api/src/main/java/com/kening/vordm/vo/EntityDataUserVo.java b/kn-service-api/biz-vordm-api/src/main/java/com/kening/vordm/vo/EntityDataUserVo.java index 21f01d3..69a8180 100644 --- a/kn-service-api/biz-vordm-api/src/main/java/com/kening/vordm/vo/EntityDataUserVo.java +++ b/kn-service-api/biz-vordm-api/src/main/java/com/kening/vordm/vo/EntityDataUserVo.java @@ -192,8 +192,18 @@ public class EntityDataUserVo { */ private Integer satelliteTypeSelect; + /** + * 产品序列号 + */ + private String productSerialNum; + /** * 文件信息 */ private List filesArray; + + /** + * 网络连接 + */ + private String sourceLink; } diff --git a/kn-service/biz-vordm/src/main/java/com/kening/vordm/controller/DataUploadController.java b/kn-service/biz-vordm/src/main/java/com/kening/vordm/controller/DataUploadController.java index 46ba49d..a3d87eb 100644 --- a/kn-service/biz-vordm/src/main/java/com/kening/vordm/controller/DataUploadController.java +++ b/kn-service/biz-vordm/src/main/java/com/kening/vordm/controller/DataUploadController.java @@ -2,8 +2,10 @@ package com.kening.vordm.controller; import com.baomidou.mybatisplus.core.metadata.IPage; import com.kening.vordm.entity.DataUpload; +import com.kening.vordm.entity.Email; import com.kening.vordm.entity.EntityData; import com.kening.vordm.service.DataUploadService; +import com.kening.vordm.service.EmailService; import lombok.AllArgsConstructor; import org.springblade.core.mp.support.Condition; import org.springblade.core.mp.support.Query; @@ -14,6 +16,7 @@ import org.springframework.web.bind.annotation.*; import java.util.Date; import java.util.List; import java.util.Map; +import java.util.stream.Collectors; /** * 后端管理系统-数据上传界面 @@ -53,6 +56,7 @@ public class DataUploadController { public R> pagesAdmin(Query query, @RequestParam Map params){ return R.data(service.queryPage(Condition.getPage(query),params)); } + private final EmailService emailService; /** * 批量审批 @@ -64,6 +68,23 @@ public class DataUploadController { data.setManagerId(AuthUtil.getUserId()); data.setReviewTime(new Date()); }); + + if (dataUploadList.get(0).getStatus() == 2){ + String emailList = dataUploadList.stream().map(EntityData::getEmail).collect(Collectors.joining(",")); + //发送邮件 + Email email = new Email(); + email.setSubject("The resource you uploaded did not pass"); + + email.setText(dataUploadList.get(0).getReason()); + String[] to = new String[]{emailList}; + email.setTos(to); + email.setHtmlText(false); + try { + emailService.sendMimeMessage(email); + } catch (Exception e) { + return R.fail("Sending failed, please check if the email is correct!"); + } + } return R.status(service.updateBatchById(dataUploadList)); } diff --git a/kn-service/biz-vordm/src/main/java/com/kening/vordm/controller/DisasterInfoController.java b/kn-service/biz-vordm/src/main/java/com/kening/vordm/controller/DisasterInfoController.java index 175b8c5..3ea8841 100644 --- a/kn-service/biz-vordm/src/main/java/com/kening/vordm/controller/DisasterInfoController.java +++ b/kn-service/biz-vordm/src/main/java/com/kening/vordm/controller/DisasterInfoController.java @@ -486,8 +486,12 @@ public class DisasterInfoController { } @GetMapping("/statisticsByUser") - public R statisticsByUser(String year,Long userId,String email) { - return R.data(disasterInfoService.statisticsByUser(year,userId,email)); + public R statisticsByUser(String year,Long userId,String email,Long roleId) { + if (roleId.compareTo(Long.parseLong("1123598816738675203"))==0){ + return R.data(disasterInfoService.statisticsByUserNew(year,userId,email)); + }else { + return R.data(disasterInfoService.statisticsByUser(year,userId,email)); + } } /** diff --git a/kn-service/biz-vordm/src/main/java/com/kening/vordm/controller/RemoteSensingSourceDataController.java b/kn-service/biz-vordm/src/main/java/com/kening/vordm/controller/RemoteSensingSourceDataController.java index d54393b..c26f8e8 100644 --- a/kn-service/biz-vordm/src/main/java/com/kening/vordm/controller/RemoteSensingSourceDataController.java +++ b/kn-service/biz-vordm/src/main/java/com/kening/vordm/controller/RemoteSensingSourceDataController.java @@ -70,6 +70,7 @@ public class RemoteSensingSourceDataController { return R.data(remoteSensingSourceDataService.getRemoteSensingSourceDataByCondition(Condition.getPage(query), remoteSensingSourceData)); } + @GetMapping("/ConditionNew") public R> getRemoteSensingSourceDataByConditionNew(RemoteSensingSourceData remoteSensingSourceData, Query query) { return R.data(remoteSensingSourceDataService.getRemoteSensingSourceDataByConditionNew(Condition.getPage(query), remoteSensingSourceData)); diff --git a/kn-service/biz-vordm/src/main/java/com/kening/vordm/mapper/DataUploadMapper.xml b/kn-service/biz-vordm/src/main/java/com/kening/vordm/mapper/DataUploadMapper.xml index aa254ba..8459d2a 100644 --- a/kn-service/biz-vordm/src/main/java/com/kening/vordm/mapper/DataUploadMapper.xml +++ b/kn-service/biz-vordm/src/main/java/com/kening/vordm/mapper/DataUploadMapper.xml @@ -45,6 +45,7 @@ ed.is_download, ed.account, ed.password, + ed.source_link, bu.name as uploaderName, bu.email as uploaderEmail from entity_data ed diff --git a/kn-service/biz-vordm/src/main/java/com/kening/vordm/mapper/DisasterInfoMapper.java b/kn-service/biz-vordm/src/main/java/com/kening/vordm/mapper/DisasterInfoMapper.java index d54ced4..38d3a2e 100644 --- a/kn-service/biz-vordm/src/main/java/com/kening/vordm/mapper/DisasterInfoMapper.java +++ b/kn-service/biz-vordm/src/main/java/com/kening/vordm/mapper/DisasterInfoMapper.java @@ -105,4 +105,7 @@ public interface DisasterInfoMapper extends BaseMapper { IPage getUserDisasterInfoListNDRNew(IPage page,@Param("userId") String userId,@Param("respondStatus") String respondStatus); List> disasterInfoType(@Param("year") String year); + + List> initiateAndResponseDataByUserNew(@Param("year") String year,@Param("userId") Long userId,@Param("email") String email); + } diff --git a/kn-service/biz-vordm/src/main/java/com/kening/vordm/mapper/DisasterInfoMapper.xml b/kn-service/biz-vordm/src/main/java/com/kening/vordm/mapper/DisasterInfoMapper.xml index 5254f34..a91c19d 100644 --- a/kn-service/biz-vordm/src/main/java/com/kening/vordm/mapper/DisasterInfoMapper.xml +++ b/kn-service/biz-vordm/src/main/java/com/kening/vordm/mapper/DisasterInfoMapper.xml @@ -1422,4 +1422,250 @@ GROUP BY d.`key` ORDER BY d.`key` + + diff --git a/kn-service/biz-vordm/src/main/java/com/kening/vordm/mapper/EntityDataMapper.xml b/kn-service/biz-vordm/src/main/java/com/kening/vordm/mapper/EntityDataMapper.xml index ac6bf50..6320b15 100644 --- a/kn-service/biz-vordm/src/main/java/com/kening/vordm/mapper/EntityDataMapper.xml +++ b/kn-service/biz-vordm/src/main/java/com/kening/vordm/mapper/EntityDataMapper.xml @@ -28,6 +28,13 @@ + + + + + + + @@ -39,7 +46,10 @@ ed.status,ed.uploader_id,ed.manager_id, ed.review_time, ed.source_organization, ed.upload_type, ed.is_deleted, ed.is_publish, - ed.is_download, ed.account, ed.password, ed.source_link + ed.is_download, ed.account, ed.password, ed.source_link, + ed.satellite_type_select, ed.satellite_code, ed.product_serial_num, + ed.product_resolution, ed.cloud_cover, ed.product_time, + ed.product_bands_num