From 95fda41de3f8c229cedafab091f5dbe33eeac7fc Mon Sep 17 00:00:00 2001 From: xyh <18782104331@139.com> Date: 星期一, 28 六月 2021 15:19:00 +0800 Subject: [PATCH] 修改 --- springcloud_k8s_panzhihuazhihuishequ/service_grid/src/main/java/com/panzhihua/service_grid/service/impl/EventVisitingTasksServiceImpl.java | 95 +++++++++++++++++++++++++++-------------------- 1 files changed, 55 insertions(+), 40 deletions(-) diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_grid/src/main/java/com/panzhihua/service_grid/service/impl/EventVisitingTasksServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_grid/src/main/java/com/panzhihua/service_grid/service/impl/EventVisitingTasksServiceImpl.java index 409a429..051eb33 100644 --- a/springcloud_k8s_panzhihuazhihuishequ/service_grid/src/main/java/com/panzhihua/service_grid/service/impl/EventVisitingTasksServiceImpl.java +++ b/springcloud_k8s_panzhihuazhihuishequ/service_grid/src/main/java/com/panzhihua/service_grid/service/impl/EventVisitingTasksServiceImpl.java @@ -1,5 +1,7 @@ package com.panzhihua.service_grid.service.impl; +import cn.hutool.core.date.DatePattern; +import cn.hutool.core.date.DateUtil; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; @@ -8,16 +10,13 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.panzhihua.common.enums.EventTasksStatusEnum; import com.panzhihua.common.enums.PopulPoliticalOutlookEnum; -import com.panzhihua.common.model.dtos.grid.EventVisitingTasksAddDTO; -import com.panzhihua.common.model.dtos.grid.EventVisitingTasksDeleteDTO; -import com.panzhihua.common.model.dtos.grid.EventVisitingTasksEditDTO; -import com.panzhihua.common.model.dtos.grid.PageEventVisitingTasksDTO; +import com.panzhihua.common.model.dtos.EventResourceDTO; import com.panzhihua.common.model.dtos.grid.*; +import com.panzhihua.common.model.dtos.visit.EventVisitCompleteDTO; import com.panzhihua.common.model.helper.AESUtil; import com.panzhihua.common.model.query.visit.EventTasksQuery; import com.panzhihua.common.model.query.visit.EventVisitListQuery; import com.panzhihua.common.model.vos.R; -import com.panzhihua.common.model.vos.grid.EventDetailsVO; import com.panzhihua.common.model.vos.grid.EventResourceVO; import com.panzhihua.common.model.vos.visit.*; import com.panzhihua.common.utlis.CopyUtil; @@ -36,11 +35,6 @@ import org.springframework.util.CollectionUtils; import javax.annotation.Resource; -import javax.crypto.BadPaddingException; -import javax.crypto.IllegalBlockSizeException; -import javax.crypto.NoSuchPaddingException; -import java.security.InvalidKeyException; -import java.security.NoSuchAlgorithmException; import java.util.*; import java.util.ArrayList; import java.util.Date; @@ -163,14 +157,19 @@ if(eventVisitingTasksVO.getNationCode() != null){ eventVisitingTasksVO.setNation(PopulPoliticalOutlookEnum.getCnDescByName(eventVisitingTasksVO.getNationCode())); } - if(eventVisitingTasksVO.getVisiterTele() != null){ - - } - eventVisitingTasksVO.setVisiterTele(AESUtil.decrypt128(eventVisitingTasksVO.getVisiterTele(), aesKey)); } - page.getRecords().forEach(e->{ + return R.ok(page); + } - }); + @Override + public R appTaskList(EventTasksQuery query) throws Exception{ + + IPage<EventVisitingTasksVO> page = eventVisitingTasksMapper.appFindListByPage(new Page(query.getPageNum(),query.getPageSize()),query); + for(EventVisitingTasksVO eventVisitingTasksVO:page.getRecords()){ + if(eventVisitingTasksVO.getNationCode() != null){ + eventVisitingTasksVO.setNation(PopulPoliticalOutlookEnum.getCnDescByName(eventVisitingTasksVO.getNationCode())); + } + } return R.ok(page); } @@ -194,6 +193,13 @@ @Override public R visitorList(EventVisitListQuery query) { IPage<EventVisitListVO> page = eventVisitingTasksMapper.visitorList(new Page(query.getPageNum(),query.getPageSize()),query); + page.getRecords().stream().forEach(e->{ + List<EventVisitingTasksDO> list = eventVisitingTasksMapper.selectList(new QueryWrapper<EventVisitingTasksDO>().eq("visiter_id",e.getId()).orderByDesc("id")); + if(!CollectionUtils.isEmpty(list)){ + e.setCreateAt(list.get(0).getCreateAt()); + e.setEventStatus(list.get(0).getEventStatus()); + } + }); return R.ok(page); } @@ -209,7 +215,6 @@ if(eventVisitingTasksDO!=null) { EventVisitingTasksDetailsVO eventVisitingTasksDetailsVO = new EventVisitingTasksDetailsVO(); BeanUtils.copyProperties(eventVisitingTasksDO, eventVisitingTasksDetailsVO); - eventVisitingTasksDetailsVO.setVisiterTele(AESUtil.decrypt128(eventVisitingTasksDO.getVisiterTele(), aesKey)); eventVisitingTasksDetailsVO.setTableContentJson(JSONObject.parseObject(eventVisitingTasksDO.getTableContentJson())); return R.ok(eventVisitingTasksDetailsVO); } @@ -261,16 +266,14 @@ visitingTasksDO.setVisiterId(Long.valueOf(map.get("id").toString())); visitingTasksDO.setVisiterName(map.get("name").toString()); visitingTasksDO.setVisiterSex(Integer.valueOf(map.get("sex").toString())); - if(map.get("phone") != null){ - visitingTasksDO.setVisiterTele(AESUtil.decrypt128(map.get("phone").toString(),aesKey)); - } + visitingTasksDO.setVisiterTele(map.get("phone") == null ?null:map.get("phone").toString()); StringBuilder sb = new StringBuilder(); sb.append(map.get("address")).append(map.get("road")).append(map.get("door_no")).append(map.get("floor")).append("栋").append(map.get("unit_no")).append("单元").append(map.get("house_no")).append("号"); visitingTasksDO.setVisiterAddress(sb.toString()); visitingTasksDO.setVisiterType(0); visitingTasksDO.setActOpara(0); if(map.get("lat") != null && map.get("lng") != null){ - visitingTasksDO.setHappentLatLng(map.get("lat")+"-"+map.get("lng")); + visitingTasksDO.setHappentLatLng(map.get("lat")+","+map.get("lng")); } visitingTasksDO.setEventStatus(EventTasksStatusEnum.DZF.getCode()); visitingTasksDO.setReporting(0); @@ -378,40 +381,61 @@ @Override public R complete(EventVisitCompleteDTO taskCompleteDTO) { EventVisitingTasksDO eventVisitingTasksDO = eventVisitingTasksMapper.selectById(taskCompleteDTO.getId()); - if(eventVisitingTasksDO == null || eventVisitingTasksDO.getEventStatus() != EventTasksStatusEnum.JXZ.getCode()){ + if(eventVisitingTasksDO == null || eventVisitingTasksDO.getEventStatus() != EventTasksStatusEnum.DZF.getCode()){ return R.fail("当前状态不可完成走访"); } + EventVisitingTasksDO complete = new EventVisitingTasksDO(); + BeanUtils.copyProperties(taskCompleteDTO,complete); if(taskCompleteDTO.getException().intValue() == 0){ - taskCompleteDTO.setEventStatus(EventTasksStatusEnum.ZJJJ.getCode()); + complete.setEventStatus(EventTasksStatusEnum.ZJJJ.getCode()); }else{ - taskCompleteDTO.setEventStatus(EventTasksStatusEnum.YC.getCode()); + complete.setEventStatus(EventTasksStatusEnum.YC.getCode()); } - + complete.setSubmitDate(DateUtil.parse(taskCompleteDTO.getSubmitDate(), DatePattern.NORM_DATETIME_FORMAT)); JSONObject json = JSONObject.parseObject(eventVisitingTasksDO.getTableContentJson()); json.put("check",taskCompleteDTO.getOption()); - taskCompleteDTO.setOption(json.toJSONString()); + complete.setTableContentJson(json.toJSONString()); - if(!CollectionUtils.isEmpty(taskCompleteDTO.getImgList())){ + if(!StringUtils.isEmpty(taskCompleteDTO.getImgList())){ taskCompleteDTO.getImgList().forEach(e->{ - createResource(eventVisitingTasksDO.getId(),eventVisitingTasksDO.getDellUserId(),2,1,e); + createResource(eventVisitingTasksDO.getId(),taskCompleteDTO.getUserId(),2,1,e); }); } if(!CollectionUtils.isEmpty(taskCompleteDTO.getVosList())){ taskCompleteDTO.getVosList().forEach(e->{ - createResource(eventVisitingTasksDO.getId(),eventVisitingTasksDO.getDellUserId(),2,2,e); + createResource(eventVisitingTasksDO.getId(),taskCompleteDTO.getUserId(),2,2,e); }); } if(!CollectionUtils.isEmpty(taskCompleteDTO.getVideoList())){ taskCompleteDTO.getVosList().forEach(e->{ - createResource(eventVisitingTasksDO.getId(),eventVisitingTasksDO.getDellUserId(),2,3,e); + createResource(eventVisitingTasksDO.getId(),taskCompleteDTO.getUserId(),2,3,e); }); } - int rt = eventVisitingTasksMapper.complete(taskCompleteDTO); + Map<String,Object> map = eventVisitingTasksMapper.findUserById(taskCompleteDTO.getUserId()); + complete.setGridMemberStreet(Long.valueOf(map.get("street_id").toString())); + complete.setGridMemberCommunity(Long.valueOf(map.get("community_id").toString())); + complete.setGridMember(Long.valueOf(map.get("user_id").toString())); + complete.setGridMemberName(map.get("name").toString()); + complete.setGridMenberTele(map.get("phone") ==null?"":map.get("phone").toString()); + + int rt = eventVisitingTasksMapper.complete(complete); if(rt > 0){ return R.ok(); } return R.fail(); + } + + + private void createResource(Long id, Long dellUserId, int classification, int type, EventResourceDTO resourceDTO) { + EventResourceDO eventResourceDO = new EventResourceDO(); + eventResourceDO.setRefId(id); + eventResourceDO.setClassification(classification); + eventResourceDO.setType(type); + eventResourceDO.setCreateBy(dellUserId); + eventResourceDO.setUrl(resourceDTO.getUrl()); + eventResourceDO.setResourceTime(resourceDTO.getResourceTime()); + eventResourceMapper.insert(eventResourceDO); } @Override @@ -476,14 +500,5 @@ return false; } - private void createResource(Long id, Long dellUserId, int classification, int type, String url) { - EventResourceDO eventResourceDO = new EventResourceDO(); - eventResourceDO.setRefId(id); - eventResourceDO.setClassification(classification); - eventResourceDO.setType(type); - eventResourceDO.setCreateBy(dellUserId); - eventResourceDO.setUrl(url); - eventResourceMapper.insert(eventResourceDO); - } } -- Gitblit v1.7.1