diff --git a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarInstitution/service/ITsInstitutionService.java b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarInstitution/service/ITsInstitutionService.java index 2bd56f28..688cc318 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarInstitution/service/ITsInstitutionService.java +++ b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarInstitution/service/ITsInstitutionService.java @@ -20,7 +20,7 @@ public interface ITsInstitutionService extends IService { */ List getInstitution(); - List getInstitutionAndUser(); + List getInstitutionAndUser(String userName); /** * 批量插入机构 @@ -29,4 +29,17 @@ public interface ITsInstitutionService extends IService { void batchInsert(List tsInstitutions); public void parseInstitution() throws Exception; + + /** + * 通过部门id获取他的子一级部门和人员 + * @param institutionId + * @return + */ + public List getNext(String institutionId); + + /** + * 获得第一级的部门 + * @return + */ + public List getFirst(); } diff --git a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarPersonalCenter/service/impl/SarUserStarServiceImpl.java b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarPersonalCenter/service/impl/SarUserStarServiceImpl.java index 890d219d..d6cdc8c5 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarPersonalCenter/service/impl/SarUserStarServiceImpl.java +++ b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarPersonalCenter/service/impl/SarUserStarServiceImpl.java @@ -51,6 +51,29 @@ public class SarUserStarServiceImpl extends ServiceImpl> getUserStarList(PersonCollectEO personCollectEO) { +// if (personCollectEO.getUserId() == null) { +// return Result.error("userId不能为空"); +// } else { +// +// QueryWrapper wrapper = new QueryWrapper<>(); +// wrapper.eq("user_id", personCollectEO.getUserId()); +// if(personCollectEO.getCollectType()!=null)wrapper.like("COLLECT_TYPE",personCollectEO.getCollectType()); +// if(personCollectEO.getCollectTitle()!=null)wrapper.like("name",personCollectEO.getCollectTitle()); +// if(sarUserStarEO.getModular()!=null)wrapper.like("modular",sarUserStarEO.getModular()); +// if(sarUserStarEO.getInfo()!=null)wrapper.like("info",sarUserStarEO.getInfo()); +// if(sarUserStarEO.getUrl()!=null)wrapper.like("url",sarUserStarEO.getUrl()); +// IPage page = iSarUserStarService.page(new Page<>(sarUserStarEO.getCurrent(), sarUserStarEO.getSize()), wrapper); +// while (page.getRecords().remove(null)) ; +// return Result.success(page); +// } +// } + + + + + @Override public ResponseMessage> deleteList(@RequestBody SarUserStarEO sarUserStars) { if (sarUserStars.getUserId() == null) { diff --git a/adc-da-sys/src/main/java/com/adc/da/person/controller/PersonCollectEOController.java b/adc-da-sys/src/main/java/com/adc/da/person/controller/PersonCollectEOController.java index 1d3054c2..c720ea6e 100644 --- a/adc-da-sys/src/main/java/com/adc/da/person/controller/PersonCollectEOController.java +++ b/adc-da-sys/src/main/java/com/adc/da/person/controller/PersonCollectEOController.java @@ -1,23 +1,21 @@ package com.adc.da.person.controller; import com.adc.da.base.web.BaseController; -import com.adc.da.http.PageInfo; import com.adc.da.http.ResponseMessage; import com.adc.da.http.Result; -import com.adc.da.person.entity.PersonCollectEO; +import com.adc.da.person.entity.TsPersonCollect; import com.adc.da.person.page.PersonCollectEOPage; import com.adc.da.person.service.IPersonCollectEOService; import com.adc.da.util.LoginUserUtil; import com.adc.da.util.UUIDUtils; +import com.baomidou.mybatisplus.core.metadata.IPage; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; -import org.apache.commons.lang3.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; -import java.util.ArrayList; import java.util.Arrays; import java.util.Date; import java.util.List; @@ -28,7 +26,7 @@ import static org.springframework.http.MediaType.APPLICATION_JSON_UTF8_VALUE; @RestController @RequestMapping("/${restPath}/person/personCollect") @Api(description = "|PersonCollectEO|") -public class PersonCollectEOController extends BaseController { +public class PersonCollectEOController extends BaseController { private static final Logger logger = LoggerFactory.getLogger(PersonCollectEOController.class); @@ -45,45 +43,10 @@ public class PersonCollectEOController extends BaseController { **/ @ApiOperation(value = "|PersonCollectEO|分页查询") @GetMapping("/page") - public ResponseMessage> page(Integer pageNo, Integer pageSize, String modeType, String collectTitle) throws Exception { - PersonCollectEOPage page = new PersonCollectEOPage(); - if (StringUtils.isNotEmpty(modeType)) { - List collectTypes = new ArrayList<>(); - switch (modeType) { - case "STAND": - collectTypes.add("INLAND_STAND"); - collectTypes.add("FOREIGN_STAND"); - collectTypes.add("BUSINESS_STAND"); - break; - case "LAWS": - collectTypes.add("INLAND_LAWS"); - collectTypes.add("FOREIGN_LAWS"); - break; - case "MSG": - collectTypes.add("INLAND_MSG"); - collectTypes.add("FOREIGN_MSG"); - collectTypes.add("RESOURCE_MSG"); - break; - default:break; - } - page.setCollectTypeList(collectTypes); - } - if (pageNo != null) { - page.setPage(pageNo); - }else{ - page.setPage(1); - } - if (pageSize != null) { - page.setPageSize(pageSize); - }else{ - page.setPageSize(10); - } - if (StringUtils.isNotEmpty(collectTitle)) { - page.setCollectTitle(collectTitle); - } - page.setUserId(LoginUserUtil.getUserId()); - List rows = personCollectEOService.queryByPersonCollectPage(page); - return Result.success(getPageInfo(page.getPager(), rows)); + public ResponseMessage> page(Integer pageNo, Integer pageSize, String collectTitle, String userId) throws Exception { + + + return personCollectEOService.queryCollectByWrapper(pageNo, pageSize,collectTitle,userId); } @@ -91,7 +54,7 @@ public class PersonCollectEOController extends BaseController { @ApiOperation(value = "|PersonCollectEO|查询") @GetMapping("") // @RequiresPermissions("person:personCollect:list") - public ResponseMessage> list(PersonCollectEOPage page) throws Exception { + public ResponseMessage> list(PersonCollectEOPage page) throws Exception { return Result.success(personCollectEOService.queryByList(page)); } @@ -99,39 +62,44 @@ public class PersonCollectEOController extends BaseController { @ApiOperation(value = "|PersonCollectEO|详情") @GetMapping("/{id}") // @RequiresPermissions("person:personCollect:get") - public ResponseMessage find(@PathVariable String id) throws Exception { + public ResponseMessage find(@PathVariable String id) throws Exception { return Result.success(personCollectEOService.getById(id)); } /** * 刘寅楠 - * @param personCollectEO + * 收藏国内标准法规 + * @param tsPersonCollect * @return com.adc.da.person.entity.PersonCollectEO * @throws Exception */ @ApiOperation(value = "|PersonCollectEO|新增") @PostMapping(consumes = APPLICATION_JSON_UTF8_VALUE) // @RequiresPermissions("person:personCollect:create") - public ResponseMessage create(@RequestBody PersonCollectEO personCollectEO) throws Exception { - String userId = LoginUserUtil.getUserId(); - personCollectEO.setId(UUIDUtils.randomUUID20()); - personCollectEO.setUserId(userId); - personCollectEO.setValidFlag(0); - personCollectEO.setCreationTime(new Date()); - personCollectEO.setModifyTime(new Date()); - personCollectEOService.save(personCollectEO); - return Result.success("0","收藏成功,请到'我的收藏'中查看相关信息。",personCollectEO); + public ResponseMessage create(@RequestBody TsPersonCollect tsPersonCollect,String userId) throws Exception { + // String userId = LoginUserUtil.getUserId(); + + tsPersonCollect.setId(UUIDUtils.randomUUID20()); + tsPersonCollect.setUserId(userId); + tsPersonCollect.setValidFlag(0); + tsPersonCollect.setCreationTime(new Date()); + tsPersonCollect.setModifyTime(new Date()); + + + personCollectEOService.save(tsPersonCollect); + + return Result.success("0","收藏成功,请到'我的收藏'中查看相关信息。", tsPersonCollect); } @ApiOperation(value = "|PersonCollectEO|修改") @PutMapping(consumes = APPLICATION_JSON_UTF8_VALUE) // @RequiresPermissions("person:personCollect:update") - public ResponseMessage update(@RequestBody PersonCollectEO personCollectEO) throws Exception { - personCollectEO.setModifyTime(new Date()); - personCollectEOService.updateById(personCollectEO); - return Result.success(personCollectEO); + public ResponseMessage update(@RequestBody TsPersonCollect tsPersonCollect) throws Exception { + tsPersonCollect.setModifyTime(new Date()); + personCollectEOService.updateById(tsPersonCollect); + return Result.success(tsPersonCollect); } @@ -158,13 +126,13 @@ public class PersonCollectEOController extends BaseController { @ApiOperation(value = "取消收藏") @PutMapping("/updateByUserId") // @RequiresPermissions("person:personCollect:updateByUserId") PersonCollectEO - public ResponseMessage updateByUserId(PersonCollectEO personCollectEO) throws Exception { - personCollectEO.setValidFlag(1); - int result = personCollectEOService.updateByPrimaryKeySelective(personCollectEO); + public ResponseMessage updateByUserId(TsPersonCollect tsPersonCollect) throws Exception { + tsPersonCollect.setValidFlag(1); + int result = personCollectEOService.updateByPrimaryKeySelective(tsPersonCollect); if(result == 1){ - return Result.success("0","取消成功",personCollectEO); + return Result.success("0","取消成功", tsPersonCollect); } else { - return Result.error("0","取消失败",personCollectEO); + return Result.error("0","取消失败", tsPersonCollect); } } diff --git a/adc-da-sys/src/main/java/com/adc/da/person/dao/PersonCollectEODao.java b/adc-da-sys/src/main/java/com/adc/da/person/dao/PersonCollectEODao.java index 26c07001..59ddd12e 100644 --- a/adc-da-sys/src/main/java/com/adc/da/person/dao/PersonCollectEODao.java +++ b/adc-da-sys/src/main/java/com/adc/da/person/dao/PersonCollectEODao.java @@ -1,7 +1,7 @@ package com.adc.da.person.dao; import com.adc.da.base.page.BasePage; -import com.adc.da.person.entity.PersonCollectEO; +import com.adc.da.person.entity.TsPersonCollect; import com.adc.da.person.page.PersonCollectEOPage; import com.baomidou.mybatisplus.core.mapper.BaseMapper; import org.apache.ibatis.annotations.Param; @@ -16,15 +16,15 @@ import java.util.List; * 日期: 2018-09-03
* 版权所有:版权归北京卡达克数据技术中心所有。
*/ -public interface PersonCollectEODao extends BaseMapper { +public interface PersonCollectEODao extends BaseMapper { - public List queryByList(BasePage page); + public List queryByList(BasePage page); public int queryByCount(BasePage var1); - public List queryByPage(BasePage page); + public List queryByPage(BasePage page); - public List queryByPersonCollectPage(PersonCollectEOPage page); + public List queryByPersonCollectPage(PersonCollectEOPage page); public int queryByPersonCollectPageCount(PersonCollectEOPage page); @@ -34,6 +34,6 @@ public interface PersonCollectEODao extends BaseMapper { int deleteByResIdList(@Param("idList") List idList); - int updateByPrimaryKeySelective(PersonCollectEO personCollectEO); + int updateByPrimaryKeySelective(TsPersonCollect tsPersonCollect); } diff --git a/adc-da-sys/src/main/java/com/adc/da/person/entity/PersonCollectEO.java b/adc-da-sys/src/main/java/com/adc/da/person/entity/TsPersonCollect.java similarity index 94% rename from adc-da-sys/src/main/java/com/adc/da/person/entity/PersonCollectEO.java rename to adc-da-sys/src/main/java/com/adc/da/person/entity/TsPersonCollect.java index c7200d51..8a62e5c2 100644 --- a/adc-da-sys/src/main/java/com/adc/da/person/entity/PersonCollectEO.java +++ b/adc-da-sys/src/main/java/com/adc/da/person/entity/TsPersonCollect.java @@ -1,6 +1,9 @@ package com.adc.da.person.entity; import com.adc.da.base.entity.BaseEntity; +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableLogic; import com.fasterxml.jackson.annotation.JsonFormat; import java.util.ArrayList; @@ -13,24 +16,32 @@ import java.util.List; * 日期: 2018-09-03
* 版权所有:版权归北京卡达克数据技术中心所有。
*/ -public class PersonCollectEO extends BaseEntity { - +public class TsPersonCollect extends BaseEntity { + @TableField //@org.springframework.format.annotation.DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss") @JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss") private Date modifyTime; //@org.springframework.format.annotation.DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss") @JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss") - + @TableField private Date creationTime; + @TableLogic private Integer validFlag; + @TableField private String collectResId; + @TableField private String collectInfoUri; + @TableField private String collectTitle; + @TableField private String collectType; + @TableField private String userId; + @TableId private String id; //追加字段 + @TableField(exist = false) private List noteList = new ArrayList<>(); @@ -94,7 +105,7 @@ public class PersonCollectEO extends BaseEntity { default: return null; } } - + /** **/ public Date getModifyTime() { return this.modifyTime; diff --git a/adc-da-sys/src/main/java/com/adc/da/person/service/IPersonCollectEOService.java b/adc-da-sys/src/main/java/com/adc/da/person/service/IPersonCollectEOService.java index e275d28a..b21e938f 100644 --- a/adc-da-sys/src/main/java/com/adc/da/person/service/IPersonCollectEOService.java +++ b/adc-da-sys/src/main/java/com/adc/da/person/service/IPersonCollectEOService.java @@ -1,18 +1,20 @@ package com.adc.da.person.service; -import com.adc.da.person.entity.PersonCollectEO; +import com.adc.da.http.ResponseMessage; +import com.adc.da.person.entity.TsPersonCollect; import com.adc.da.person.page.PersonCollectEOPage; +import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.service.IService; import java.util.List; -public interface IPersonCollectEOService extends IService { +public interface IPersonCollectEOService extends IService { - public List queryByPage(PersonCollectEOPage page); + public List queryByPage(PersonCollectEOPage page); - public List queryByList(PersonCollectEOPage page); + public List queryByList(PersonCollectEOPage page); - public List queryByPersonCollectPage(PersonCollectEOPage page); + public List queryByPersonCollectPage(PersonCollectEOPage page); public String queryCollectByUserAndId(String collectResId); @@ -20,6 +22,8 @@ public interface IPersonCollectEOService extends IService { public int deleteByResId(String resId); - int updateByPrimaryKeySelective(PersonCollectEO personCollectEO) throws Exception; + int updateByPrimaryKeySelective(TsPersonCollect tsPersonCollect) throws Exception; + + public ResponseMessage> queryCollectByWrapper(Integer pageNo, Integer pageSize, String modeType, String collectTitle); } diff --git a/adc-da-sys/src/main/java/com/adc/da/person/service/impl/PersonCollectEOServiceImpl.java b/adc-da-sys/src/main/java/com/adc/da/person/service/impl/PersonCollectEOServiceImpl.java index 9035db87..fc781203 100644 --- a/adc-da-sys/src/main/java/com/adc/da/person/service/impl/PersonCollectEOServiceImpl.java +++ b/adc-da-sys/src/main/java/com/adc/da/person/service/impl/PersonCollectEOServiceImpl.java @@ -1,14 +1,18 @@ package com.adc.da.person.service.impl; import com.adc.da.base.page.BasePage; +import com.adc.da.http.ResponseMessage; +import com.adc.da.http.Result; import com.adc.da.person.dao.PersonCollectEODao; -import com.adc.da.person.dao.PersonConfEODao; import com.adc.da.person.dao.PersonNoteEODao; -import com.adc.da.person.entity.PersonCollectEO; +import com.adc.da.person.entity.TsPersonCollect; import com.adc.da.person.entity.PersonNoteEO; import com.adc.da.person.page.PersonCollectEOPage; import com.adc.da.person.service.IPersonCollectEOService; import com.adc.da.util.LoginUserUtil; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; @@ -28,7 +32,7 @@ import java.util.List; */ @Service("personCollectEOService") @Transactional(value = "transactionManager", readOnly = false, propagation = Propagation.REQUIRED, rollbackFor = Throwable.class) -public class PersonCollectEOServiceImpl extends ServiceImpl implements IPersonCollectEOService { +public class PersonCollectEOServiceImpl extends ServiceImpl implements IPersonCollectEOService { @@ -38,8 +42,9 @@ public class PersonCollectEOServiceImpl extends ServiceImpl queryByPage(PersonCollectEOPage page) { + public List queryByPage(PersonCollectEOPage page) { Integer rowCount = this.queryByCount(page); page.getPager().setRowCount(rowCount); return this.baseMapper.queryByPage(page); @@ -50,15 +55,15 @@ public class PersonCollectEOServiceImpl extends ServiceImpl queryByList(PersonCollectEOPage page) { + public List queryByList(PersonCollectEOPage page) { return this.baseMapper.queryByList(page); } - public List queryByPersonCollectPage(PersonCollectEOPage page){ + public List queryByPersonCollectPage(PersonCollectEOPage page){ page.setValidFlag("0"); int ire = this.baseMapper.queryByPersonCollectPageCount(page); page.getPager().setRowCount(ire); - List list = this.baseMapper.queryByPersonCollectPage(page); + List list = this.baseMapper.queryByPersonCollectPage(page); for(int i =0;i getCollects = this.baseMapper.queryByList(page); + List getCollects = this.baseMapper.queryByList(page); String collectId = ""; if(getCollects != null){ if(getCollects.size()>0){ @@ -101,7 +106,35 @@ public class PersonCollectEOServiceImpl extends ServiceImpl> queryCollectByWrapper(Integer pageNo, Integer pageSize, String collectTitle, String userId) { + BasePage basePage = new BasePage(); + QueryWrapper wrapper = new QueryWrapper<>(); + wrapper.eq("user_id",userId); + if (collectTitle != null && !collectTitle.equals("")){ + wrapper.like("collect_title",collectTitle); + + } + + if (pageNo != null) { + basePage.setPage(pageNo); + }else{ + basePage.setPage(1); + } + if (pageSize != null) { + basePage.setPageSize(pageSize); + }else{ + basePage.setPageSize(10); + } + + + IPage page = this.page(new Page<>(basePage.getPage(), basePage.getPageSize()), wrapper); + return Result.success(page); + } + } diff --git a/adc-da-sys/src/main/resources/mybatis/mapper/person/PersonCollectEOMapper.xml b/adc-da-sys/src/main/resources/mybatis/mapper/person/PersonCollectEOMapper.xml index 68378140..230c587c 100644 --- a/adc-da-sys/src/main/resources/mybatis/mapper/person/PersonCollectEOMapper.xml +++ b/adc-da-sys/src/main/resources/mybatis/mapper/person/PersonCollectEOMapper.xml @@ -2,7 +2,7 @@ - + @@ -153,7 +153,7 @@ - + @@ -164,7 +164,7 @@ - + @@ -194,7 +194,7 @@ - + update TS_PERSON_COLLECT set modify_time = #{modifyTime}, creation_time = #{creationTime}, @@ -208,7 +208,7 @@ - + update TS_PERSON_COLLECT @@ -332,7 +332,7 @@ ${pager.orderCondition} order by TS_PERSON_COLLECT.creation_time desc - ) tmp_tb where rownum <= ${pager.endIndex}) + ) as tmp_tb where rownum <= ${pager.endIndex}) where rn >= ${pager.startIndex} @@ -391,4 +391,10 @@ + +