| | |
| | | import com.baomidou.mybatisplus.extension.plugins.pagination.Page; |
| | | import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
| | | import com.ruoyi.common.core.domain.AjaxResult; |
| | | import com.ruoyi.common.core.domain.entity.EsModel; |
| | | import com.ruoyi.common.core.domain.entity.SysUser; |
| | | import com.ruoyi.common.utils.MapUtils; |
| | | import com.ruoyi.common.utils.SecurityUtils; |
| | |
| | | |
| | | import com.ruoyi.domain.ZfClean; |
| | | import com.ruoyi.mapper.ZfCleanMapper; |
| | | import com.ruoyi.service.ZAuthorityService; |
| | | import com.ruoyi.service.ZInfoUserService; |
| | | import com.ruoyi.service.ZfCleanService; |
| | | import com.ruoyi.service.*; |
| | | |
| | | import com.ruoyi.util.ArraysUtil; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.elasticsearch.action.delete.DeleteRequest; |
| | | import org.elasticsearch.action.update.UpdateRequest; |
| | | import org.elasticsearch.client.RequestOptions; |
| | | import org.elasticsearch.client.RestHighLevelClient; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | | import org.springframework.web.multipart.MultipartFile; |
| | | |
| | | import javax.annotation.Resource; |
| | | import java.util.ArrayList; |
| | | import java.util.Arrays; |
| | | import java.util.HashMap; |
| | | import java.util.List; |
| | | import java.io.IOException; |
| | | import java.time.LocalDateTime; |
| | | import java.util.*; |
| | | import java.util.stream.Collectors; |
| | | |
| | | import static com.ruoyi.constant.MenuAuthority.*; |
| | |
| | | |
| | | @Resource |
| | | ZAuthorityService zAuthorityService; |
| | | |
| | | @Resource |
| | | ZfLogService zfLogService; |
| | | |
| | | @Resource |
| | | EsService esService; |
| | | |
| | | @Resource |
| | | RestHighLevelClient restHighLevelClient; |
| | | |
| | | private LambdaQueryWrapper<ZfClean> buildCondition(ZfClean zfClean,List<Long> familyIdList) { |
| | | LambdaQueryWrapper<ZfClean> lqw = new LambdaQueryWrapper<>(); |
| | |
| | | bean.setOwnData(0); |
| | | } |
| | | } |
| | | ).collect(Collectors.toList()); |
| | | ).sorted((a,b)-> b.getOwnData()-a.getOwnData()).collect(Collectors.toList()); |
| | | } |
| | | |
| | | @Override |
| | |
| | | } |
| | | |
| | | if (save(zfClean)) { |
| | | EsModel esModel = new EsModel(); |
| | | Integer inte = zfClean.getId().intValue(); |
| | | String uuid = UUID.randomUUID().toString().replace("-",""); |
| | | esModel.setId(uuid); |
| | | esModel.setCtId(Long.valueOf(inte)); |
| | | esModel.setCtTableName("保洁与收纳"); |
| | | esModel.setBy1(zfClean.getType()); |
| | | esModel.setBy2(zfClean.getMethod()); |
| | | esModel.setBy3(zfClean.getPlace()); |
| | | esModel.setBy4(zfClean.getSuitable()); |
| | | esModel.setBy5("/family/zfClean"); |
| | | esModel.setRemark(zfClean.getRemark()); |
| | | esModel.setFid(familyId); |
| | | //这里存储查询详情的路径 |
| | | esService.insertTable(esModel); |
| | | |
| | | |
| | | return AjaxResult.success(); |
| | | } else { |
| | | return AjaxResult.error(); |
| | |
| | | throw new RuntimeException("你没有权限操作此家庭的数据"); |
| | | } |
| | | |
| | | //操作后加入日志 |
| | | ZfLog zfLog = new ZfLog(); |
| | | zfLog.setUpdateTime(LocalDateTime.now()); |
| | | zfLog.setModule("保洁收纳"); |
| | | zfLog.setUpdater(zInfoUserService.getMyself().getNickName()); |
| | | zfLogService.save(zfLog); |
| | | |
| | | |
| | | if(updateById(zfClean)){ |
| | | |
| | | //到数据库中查询对应的数据 |
| | | ZfClean dataById = getById(zfClean.getId()); |
| | | |
| | | //先到es中查询到对应那条数据在es的id |
| | | EsModel esResult = esService.findByCtId(dataById.getId().intValue(), "保洁与收纳"); |
| | | |
| | | //操作es修改数据 |
| | | EsModel newModel = new EsModel(); |
| | | if(zfClean.getType()!=null){ |
| | | newModel.setBy1(zfClean.getType()); |
| | | }else { |
| | | newModel.setBy1(dataById.getType()); |
| | | } |
| | | |
| | | if(zfClean.getMethod()!=null){ |
| | | newModel.setBy2(zfClean.getMethod()); |
| | | }else { |
| | | newModel.setBy2(dataById.getMethod()); |
| | | } |
| | | |
| | | if(zfClean.getPlace()!=null){ |
| | | newModel.setBy3(zfClean.getPlace()); |
| | | }else { |
| | | newModel.setBy3(dataById.getPlace()); |
| | | } |
| | | |
| | | if(zfClean.getSuitable()!=null){ |
| | | newModel.setBy4(zfClean.getSuitable()); |
| | | }else { |
| | | newModel.setBy4(dataById.getSuitable()); |
| | | } |
| | | |
| | | if(zfClean.getRemark()!=null){ |
| | | newModel.setRemark(zfClean.getRemark()); |
| | | }else { |
| | | newModel.setRemark(dataById.getRemark()); |
| | | } |
| | | |
| | | |
| | | UpdateRequest updateRequest = new UpdateRequest("allsearchdata", esResult.getId()); |
| | | updateRequest.doc( |
| | | "by1",newModel.getBy1(), |
| | | "by2",newModel.getBy2(), |
| | | "by3",newModel.getBy3(), |
| | | "by4",newModel.getBy4(), |
| | | "remark",newModel.getRemark() |
| | | ); |
| | | |
| | | try { |
| | | restHighLevelClient.update(updateRequest, RequestOptions.DEFAULT); |
| | | } catch (IOException e) { |
| | | throw new RuntimeException(e); |
| | | } |
| | | return AjaxResult.success(); |
| | | }else { |
| | | return AjaxResult.error(); |
| | |
| | | } |
| | | } |
| | | |
| | | List<ZfClean> zfCleans = listByIds(Arrays.asList(ids)); |
| | | |
| | | if (zfCleanService.removeByIds(Arrays.asList(ids))) { |
| | | |
| | | //删除es中的数据 |
| | | zfCleans.stream().forEach(zfClean -> { |
| | | EsModel esModel = esService.findByCtId(zfClean.getId().intValue(), "保洁与收纳"); |
| | | DeleteRequest deleteRequest = new DeleteRequest("allsearchdata", esModel.getId()); |
| | | try { |
| | | restHighLevelClient.delete(deleteRequest,RequestOptions.DEFAULT); |
| | | } catch (IOException e) { |
| | | throw new RuntimeException(e); |
| | | } |
| | | }); |
| | | return AjaxResult.success(); |
| | | }else { |
| | | return AjaxResult.error(); |