修改了institutionAndUser(String userName)接口,当userName有值事搜索出此用户以及它所在的机构,userName为null时搜索全部
添加getNext(String institutionId)接口,通过机构id返回此部门下的第一级部门和人员 添加getFirstInstitution()接口,返回机构第一级目录
This commit is contained in:
+14
-1
@@ -20,7 +20,7 @@ public interface ITsInstitutionService extends IService<TsInstitution> {
|
|||||||
*/
|
*/
|
||||||
List<TsInstitution> getInstitution();
|
List<TsInstitution> getInstitution();
|
||||||
|
|
||||||
List<TsInstitution> getInstitutionAndUser();
|
List<TsInstitution> getInstitutionAndUser(String userName);
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 批量插入机构
|
* 批量插入机构
|
||||||
@@ -29,4 +29,17 @@ public interface ITsInstitutionService extends IService<TsInstitution> {
|
|||||||
void batchInsert(List<TsInstitution> tsInstitutions);
|
void batchInsert(List<TsInstitution> tsInstitutions);
|
||||||
|
|
||||||
public void parseInstitution() throws Exception;
|
public void parseInstitution() throws Exception;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 通过部门id获取他的子一级部门和人员
|
||||||
|
* @param institutionId
|
||||||
|
* @return
|
||||||
|
*/
|
||||||
|
public List<TsInstitution> getNext(String institutionId);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 获得第一级的部门
|
||||||
|
* @return
|
||||||
|
*/
|
||||||
|
public List<TsInstitution> getFirst();
|
||||||
}
|
}
|
||||||
|
|||||||
+23
@@ -51,6 +51,29 @@ public class SarUserStarServiceImpl extends ServiceImpl<SarUserStarDao, SarUserS
|
|||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
// @Override
|
||||||
|
// public ResponseMessage<IPage<SarUserStar>> getUserStarList(PersonCollectEO personCollectEO) {
|
||||||
|
// if (personCollectEO.getUserId() == null) {
|
||||||
|
// return Result.error("userId不能为空");
|
||||||
|
// } else {
|
||||||
|
//
|
||||||
|
// QueryWrapper<SarUserStar> 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<SarUserStar> page = iSarUserStarService.page(new Page<>(sarUserStarEO.getCurrent(), sarUserStarEO.getSize()), wrapper);
|
||||||
|
// while (page.getRecords().remove(null)) ;
|
||||||
|
// return Result.success(page);
|
||||||
|
// }
|
||||||
|
// }
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public ResponseMessage<IPage<SarUserStar>> deleteList(@RequestBody SarUserStarEO sarUserStars) {
|
public ResponseMessage<IPage<SarUserStar>> deleteList(@RequestBody SarUserStarEO sarUserStars) {
|
||||||
if (sarUserStars.getUserId() == null) {
|
if (sarUserStars.getUserId() == null) {
|
||||||
|
|||||||
+33
-65
@@ -1,23 +1,21 @@
|
|||||||
package com.adc.da.person.controller;
|
package com.adc.da.person.controller;
|
||||||
|
|
||||||
import com.adc.da.base.web.BaseController;
|
import com.adc.da.base.web.BaseController;
|
||||||
import com.adc.da.http.PageInfo;
|
|
||||||
import com.adc.da.http.ResponseMessage;
|
import com.adc.da.http.ResponseMessage;
|
||||||
import com.adc.da.http.Result;
|
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.page.PersonCollectEOPage;
|
||||||
import com.adc.da.person.service.IPersonCollectEOService;
|
import com.adc.da.person.service.IPersonCollectEOService;
|
||||||
import com.adc.da.util.LoginUserUtil;
|
import com.adc.da.util.LoginUserUtil;
|
||||||
import com.adc.da.util.UUIDUtils;
|
import com.adc.da.util.UUIDUtils;
|
||||||
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
||||||
import io.swagger.annotations.Api;
|
import io.swagger.annotations.Api;
|
||||||
import io.swagger.annotations.ApiOperation;
|
import io.swagger.annotations.ApiOperation;
|
||||||
import org.apache.commons.lang3.StringUtils;
|
|
||||||
import org.slf4j.Logger;
|
import org.slf4j.Logger;
|
||||||
import org.slf4j.LoggerFactory;
|
import org.slf4j.LoggerFactory;
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Autowired;
|
||||||
import org.springframework.web.bind.annotation.*;
|
import org.springframework.web.bind.annotation.*;
|
||||||
|
|
||||||
import java.util.ArrayList;
|
|
||||||
import java.util.Arrays;
|
import java.util.Arrays;
|
||||||
import java.util.Date;
|
import java.util.Date;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
@@ -28,7 +26,7 @@ import static org.springframework.http.MediaType.APPLICATION_JSON_UTF8_VALUE;
|
|||||||
@RestController
|
@RestController
|
||||||
@RequestMapping("/${restPath}/person/personCollect")
|
@RequestMapping("/${restPath}/person/personCollect")
|
||||||
@Api(description = "|PersonCollectEO|")
|
@Api(description = "|PersonCollectEO|")
|
||||||
public class PersonCollectEOController extends BaseController<PersonCollectEO> {
|
public class PersonCollectEOController extends BaseController<TsPersonCollect> {
|
||||||
|
|
||||||
private static final Logger logger = LoggerFactory.getLogger(PersonCollectEOController.class);
|
private static final Logger logger = LoggerFactory.getLogger(PersonCollectEOController.class);
|
||||||
|
|
||||||
@@ -45,45 +43,10 @@ public class PersonCollectEOController extends BaseController<PersonCollectEO> {
|
|||||||
**/
|
**/
|
||||||
@ApiOperation(value = "|PersonCollectEO|分页查询")
|
@ApiOperation(value = "|PersonCollectEO|分页查询")
|
||||||
@GetMapping("/page")
|
@GetMapping("/page")
|
||||||
public ResponseMessage<PageInfo<PersonCollectEO>> page(Integer pageNo, Integer pageSize, String modeType, String collectTitle) throws Exception {
|
public ResponseMessage<IPage<TsPersonCollect>> page(Integer pageNo, Integer pageSize, String collectTitle, String userId) throws Exception {
|
||||||
PersonCollectEOPage page = new PersonCollectEOPage();
|
|
||||||
if (StringUtils.isNotEmpty(modeType)) {
|
|
||||||
List<String> collectTypes = new ArrayList<>();
|
return personCollectEOService.queryCollectByWrapper(pageNo, pageSize,collectTitle,userId);
|
||||||
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<PersonCollectEO> rows = personCollectEOService.queryByPersonCollectPage(page);
|
|
||||||
return Result.success(getPageInfo(page.getPager(), rows));
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -91,7 +54,7 @@ public class PersonCollectEOController extends BaseController<PersonCollectEO> {
|
|||||||
@ApiOperation(value = "|PersonCollectEO|查询")
|
@ApiOperation(value = "|PersonCollectEO|查询")
|
||||||
@GetMapping("")
|
@GetMapping("")
|
||||||
// @RequiresPermissions("person:personCollect:list")
|
// @RequiresPermissions("person:personCollect:list")
|
||||||
public ResponseMessage<List<PersonCollectEO>> list(PersonCollectEOPage page) throws Exception {
|
public ResponseMessage<List<TsPersonCollect>> list(PersonCollectEOPage page) throws Exception {
|
||||||
return Result.success(personCollectEOService.queryByList(page));
|
return Result.success(personCollectEOService.queryByList(page));
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -99,39 +62,44 @@ public class PersonCollectEOController extends BaseController<PersonCollectEO> {
|
|||||||
@ApiOperation(value = "|PersonCollectEO|详情")
|
@ApiOperation(value = "|PersonCollectEO|详情")
|
||||||
@GetMapping("/{id}")
|
@GetMapping("/{id}")
|
||||||
// @RequiresPermissions("person:personCollect:get")
|
// @RequiresPermissions("person:personCollect:get")
|
||||||
public ResponseMessage<PersonCollectEO> find(@PathVariable String id) throws Exception {
|
public ResponseMessage<TsPersonCollect> find(@PathVariable String id) throws Exception {
|
||||||
return Result.success(personCollectEOService.getById(id));
|
return Result.success(personCollectEOService.getById(id));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 刘寅楠
|
* 刘寅楠
|
||||||
* @param personCollectEO
|
* 收藏国内标准法规
|
||||||
|
* @param tsPersonCollect
|
||||||
* @return com.adc.da.person.entity.PersonCollectEO
|
* @return com.adc.da.person.entity.PersonCollectEO
|
||||||
* @throws Exception
|
* @throws Exception
|
||||||
*/
|
*/
|
||||||
@ApiOperation(value = "|PersonCollectEO|新增")
|
@ApiOperation(value = "|PersonCollectEO|新增")
|
||||||
@PostMapping(consumes = APPLICATION_JSON_UTF8_VALUE)
|
@PostMapping(consumes = APPLICATION_JSON_UTF8_VALUE)
|
||||||
// @RequiresPermissions("person:personCollect:create")
|
// @RequiresPermissions("person:personCollect:create")
|
||||||
public ResponseMessage<PersonCollectEO> create(@RequestBody PersonCollectEO personCollectEO) throws Exception {
|
public ResponseMessage<TsPersonCollect> create(@RequestBody TsPersonCollect tsPersonCollect,String userId) throws Exception {
|
||||||
String userId = LoginUserUtil.getUserId();
|
// String userId = LoginUserUtil.getUserId();
|
||||||
personCollectEO.setId(UUIDUtils.randomUUID20());
|
|
||||||
personCollectEO.setUserId(userId);
|
tsPersonCollect.setId(UUIDUtils.randomUUID20());
|
||||||
personCollectEO.setValidFlag(0);
|
tsPersonCollect.setUserId(userId);
|
||||||
personCollectEO.setCreationTime(new Date());
|
tsPersonCollect.setValidFlag(0);
|
||||||
personCollectEO.setModifyTime(new Date());
|
tsPersonCollect.setCreationTime(new Date());
|
||||||
personCollectEOService.save(personCollectEO);
|
tsPersonCollect.setModifyTime(new Date());
|
||||||
return Result.success("0","收藏成功,请到'我的收藏'中查看相关信息。",personCollectEO);
|
|
||||||
|
|
||||||
|
personCollectEOService.save(tsPersonCollect);
|
||||||
|
|
||||||
|
return Result.success("0","收藏成功,请到'我的收藏'中查看相关信息。", tsPersonCollect);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
@ApiOperation(value = "|PersonCollectEO|修改")
|
@ApiOperation(value = "|PersonCollectEO|修改")
|
||||||
@PutMapping(consumes = APPLICATION_JSON_UTF8_VALUE)
|
@PutMapping(consumes = APPLICATION_JSON_UTF8_VALUE)
|
||||||
// @RequiresPermissions("person:personCollect:update")
|
// @RequiresPermissions("person:personCollect:update")
|
||||||
public ResponseMessage<PersonCollectEO> update(@RequestBody PersonCollectEO personCollectEO) throws Exception {
|
public ResponseMessage<TsPersonCollect> update(@RequestBody TsPersonCollect tsPersonCollect) throws Exception {
|
||||||
personCollectEO.setModifyTime(new Date());
|
tsPersonCollect.setModifyTime(new Date());
|
||||||
personCollectEOService.updateById(personCollectEO);
|
personCollectEOService.updateById(tsPersonCollect);
|
||||||
return Result.success(personCollectEO);
|
return Result.success(tsPersonCollect);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
@@ -158,13 +126,13 @@ public class PersonCollectEOController extends BaseController<PersonCollectEO> {
|
|||||||
@ApiOperation(value = "取消收藏")
|
@ApiOperation(value = "取消收藏")
|
||||||
@PutMapping("/updateByUserId")
|
@PutMapping("/updateByUserId")
|
||||||
// @RequiresPermissions("person:personCollect:updateByUserId") PersonCollectEO
|
// @RequiresPermissions("person:personCollect:updateByUserId") PersonCollectEO
|
||||||
public ResponseMessage<PersonCollectEO> updateByUserId(PersonCollectEO personCollectEO) throws Exception {
|
public ResponseMessage<TsPersonCollect> updateByUserId(TsPersonCollect tsPersonCollect) throws Exception {
|
||||||
personCollectEO.setValidFlag(1);
|
tsPersonCollect.setValidFlag(1);
|
||||||
int result = personCollectEOService.updateByPrimaryKeySelective(personCollectEO);
|
int result = personCollectEOService.updateByPrimaryKeySelective(tsPersonCollect);
|
||||||
if(result == 1){
|
if(result == 1){
|
||||||
return Result.success("0","取消成功",personCollectEO);
|
return Result.success("0","取消成功", tsPersonCollect);
|
||||||
} else {
|
} else {
|
||||||
return Result.error("0","取消失败",personCollectEO);
|
return Result.error("0","取消失败", tsPersonCollect);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -1,7 +1,7 @@
|
|||||||
package com.adc.da.person.dao;
|
package com.adc.da.person.dao;
|
||||||
|
|
||||||
import com.adc.da.base.page.BasePage;
|
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.adc.da.person.page.PersonCollectEOPage;
|
||||||
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
||||||
import org.apache.ibatis.annotations.Param;
|
import org.apache.ibatis.annotations.Param;
|
||||||
@@ -16,15 +16,15 @@ import java.util.List;
|
|||||||
* <b>日期:</b> 2018-09-03 <br>
|
* <b>日期:</b> 2018-09-03 <br>
|
||||||
* <b>版权所有:<b>版权归北京卡达克数据技术中心所有。<br>
|
* <b>版权所有:<b>版权归北京卡达克数据技术中心所有。<br>
|
||||||
*/
|
*/
|
||||||
public interface PersonCollectEODao extends BaseMapper<PersonCollectEO> {
|
public interface PersonCollectEODao extends BaseMapper<TsPersonCollect> {
|
||||||
|
|
||||||
public List<PersonCollectEO> queryByList(BasePage page);
|
public List<TsPersonCollect> queryByList(BasePage page);
|
||||||
|
|
||||||
public int queryByCount(BasePage var1);
|
public int queryByCount(BasePage var1);
|
||||||
|
|
||||||
public List<PersonCollectEO> queryByPage(BasePage page);
|
public List<TsPersonCollect> queryByPage(BasePage page);
|
||||||
|
|
||||||
public List<PersonCollectEO> queryByPersonCollectPage(PersonCollectEOPage page);
|
public List<TsPersonCollect> queryByPersonCollectPage(PersonCollectEOPage page);
|
||||||
|
|
||||||
public int queryByPersonCollectPageCount(PersonCollectEOPage page);
|
public int queryByPersonCollectPageCount(PersonCollectEOPage page);
|
||||||
|
|
||||||
@@ -34,6 +34,6 @@ public interface PersonCollectEODao extends BaseMapper<PersonCollectEO> {
|
|||||||
|
|
||||||
int deleteByResIdList(@Param("idList") List<String> idList);
|
int deleteByResIdList(@Param("idList") List<String> idList);
|
||||||
|
|
||||||
int updateByPrimaryKeySelective(PersonCollectEO personCollectEO);
|
int updateByPrimaryKeySelective(TsPersonCollect tsPersonCollect);
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
+15
-4
@@ -1,6 +1,9 @@
|
|||||||
package com.adc.da.person.entity;
|
package com.adc.da.person.entity;
|
||||||
|
|
||||||
import com.adc.da.base.entity.BaseEntity;
|
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 com.fasterxml.jackson.annotation.JsonFormat;
|
||||||
|
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
@@ -13,24 +16,32 @@ import java.util.List;
|
|||||||
* <b>日期:</b> 2018-09-03 <br>
|
* <b>日期:</b> 2018-09-03 <br>
|
||||||
* <b>版权所有:<b>版权归北京卡达克数据技术中心所有。<br>
|
* <b>版权所有:<b>版权归北京卡达克数据技术中心所有。<br>
|
||||||
*/
|
*/
|
||||||
public class PersonCollectEO extends BaseEntity {
|
public class TsPersonCollect extends BaseEntity {
|
||||||
|
@TableField
|
||||||
//@org.springframework.format.annotation.DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss")
|
//@org.springframework.format.annotation.DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss")
|
||||||
@JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
|
@JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
|
||||||
private Date modifyTime;
|
private Date modifyTime;
|
||||||
//@org.springframework.format.annotation.DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss")
|
//@org.springframework.format.annotation.DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss")
|
||||||
@JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
|
@JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
|
||||||
|
@TableField
|
||||||
private Date creationTime;
|
private Date creationTime;
|
||||||
|
@TableLogic
|
||||||
private Integer validFlag;
|
private Integer validFlag;
|
||||||
|
@TableField
|
||||||
private String collectResId;
|
private String collectResId;
|
||||||
|
@TableField
|
||||||
private String collectInfoUri;
|
private String collectInfoUri;
|
||||||
|
@TableField
|
||||||
private String collectTitle;
|
private String collectTitle;
|
||||||
|
@TableField
|
||||||
private String collectType;
|
private String collectType;
|
||||||
|
@TableField
|
||||||
private String userId;
|
private String userId;
|
||||||
|
@TableId
|
||||||
private String id;
|
private String id;
|
||||||
|
|
||||||
//追加字段
|
//追加字段
|
||||||
|
@TableField(exist = false)
|
||||||
private List<PersonNoteEO> noteList = new ArrayList<>();
|
private List<PersonNoteEO> noteList = new ArrayList<>();
|
||||||
|
|
||||||
|
|
||||||
@@ -94,7 +105,7 @@ public class PersonCollectEO extends BaseEntity {
|
|||||||
default: return null;
|
default: return null;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/** **/
|
/** **/
|
||||||
public Date getModifyTime() {
|
public Date getModifyTime() {
|
||||||
return this.modifyTime;
|
return this.modifyTime;
|
||||||
@@ -1,18 +1,20 @@
|
|||||||
package com.adc.da.person.service;
|
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.adc.da.person.page.PersonCollectEOPage;
|
||||||
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
||||||
import com.baomidou.mybatisplus.extension.service.IService;
|
import com.baomidou.mybatisplus.extension.service.IService;
|
||||||
|
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
|
||||||
public interface IPersonCollectEOService extends IService<PersonCollectEO> {
|
public interface IPersonCollectEOService extends IService<TsPersonCollect> {
|
||||||
|
|
||||||
public List<PersonCollectEO> queryByPage(PersonCollectEOPage page);
|
public List<TsPersonCollect> queryByPage(PersonCollectEOPage page);
|
||||||
|
|
||||||
public List<PersonCollectEO> queryByList(PersonCollectEOPage page);
|
public List<TsPersonCollect> queryByList(PersonCollectEOPage page);
|
||||||
|
|
||||||
public List<PersonCollectEO> queryByPersonCollectPage(PersonCollectEOPage page);
|
public List<TsPersonCollect> queryByPersonCollectPage(PersonCollectEOPage page);
|
||||||
|
|
||||||
public String queryCollectByUserAndId(String collectResId);
|
public String queryCollectByUserAndId(String collectResId);
|
||||||
|
|
||||||
@@ -20,6 +22,8 @@ public interface IPersonCollectEOService extends IService<PersonCollectEO> {
|
|||||||
|
|
||||||
public int deleteByResId(String resId);
|
public int deleteByResId(String resId);
|
||||||
|
|
||||||
int updateByPrimaryKeySelective(PersonCollectEO personCollectEO) throws Exception;
|
int updateByPrimaryKeySelective(TsPersonCollect tsPersonCollect) throws Exception;
|
||||||
|
|
||||||
|
public ResponseMessage<IPage<TsPersonCollect>> queryCollectByWrapper(Integer pageNo, Integer pageSize, String modeType, String collectTitle);
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
+43
-10
@@ -1,14 +1,18 @@
|
|||||||
package com.adc.da.person.service.impl;
|
package com.adc.da.person.service.impl;
|
||||||
|
|
||||||
import com.adc.da.base.page.BasePage;
|
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.PersonCollectEODao;
|
||||||
import com.adc.da.person.dao.PersonConfEODao;
|
|
||||||
import com.adc.da.person.dao.PersonNoteEODao;
|
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.entity.PersonNoteEO;
|
||||||
import com.adc.da.person.page.PersonCollectEOPage;
|
import com.adc.da.person.page.PersonCollectEOPage;
|
||||||
import com.adc.da.person.service.IPersonCollectEOService;
|
import com.adc.da.person.service.IPersonCollectEOService;
|
||||||
import com.adc.da.util.LoginUserUtil;
|
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 com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Autowired;
|
||||||
import org.springframework.stereotype.Service;
|
import org.springframework.stereotype.Service;
|
||||||
@@ -28,7 +32,7 @@ import java.util.List;
|
|||||||
*/
|
*/
|
||||||
@Service("personCollectEOService")
|
@Service("personCollectEOService")
|
||||||
@Transactional(value = "transactionManager", readOnly = false, propagation = Propagation.REQUIRED, rollbackFor = Throwable.class)
|
@Transactional(value = "transactionManager", readOnly = false, propagation = Propagation.REQUIRED, rollbackFor = Throwable.class)
|
||||||
public class PersonCollectEOServiceImpl extends ServiceImpl<PersonCollectEODao, PersonCollectEO> implements IPersonCollectEOService {
|
public class PersonCollectEOServiceImpl extends ServiceImpl<PersonCollectEODao, TsPersonCollect> implements IPersonCollectEOService {
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
@@ -38,8 +42,9 @@ public class PersonCollectEOServiceImpl extends ServiceImpl<PersonCollectEODao,
|
|||||||
private PersonCollectEODao personCollectEODao;
|
private PersonCollectEODao personCollectEODao;
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public List<PersonCollectEO> queryByPage(PersonCollectEOPage page) {
|
public List<TsPersonCollect> queryByPage(PersonCollectEOPage page) {
|
||||||
Integer rowCount = this.queryByCount(page);
|
Integer rowCount = this.queryByCount(page);
|
||||||
page.getPager().setRowCount(rowCount);
|
page.getPager().setRowCount(rowCount);
|
||||||
return this.baseMapper.queryByPage(page);
|
return this.baseMapper.queryByPage(page);
|
||||||
@@ -50,15 +55,15 @@ public class PersonCollectEOServiceImpl extends ServiceImpl<PersonCollectEODao,
|
|||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public List<PersonCollectEO> queryByList(PersonCollectEOPage page) {
|
public List<TsPersonCollect> queryByList(PersonCollectEOPage page) {
|
||||||
return this.baseMapper.queryByList(page);
|
return this.baseMapper.queryByList(page);
|
||||||
}
|
}
|
||||||
|
|
||||||
public List<PersonCollectEO> queryByPersonCollectPage(PersonCollectEOPage page){
|
public List<TsPersonCollect> queryByPersonCollectPage(PersonCollectEOPage page){
|
||||||
page.setValidFlag("0");
|
page.setValidFlag("0");
|
||||||
int ire = this.baseMapper.queryByPersonCollectPageCount(page);
|
int ire = this.baseMapper.queryByPersonCollectPageCount(page);
|
||||||
page.getPager().setRowCount(ire);
|
page.getPager().setRowCount(ire);
|
||||||
List<PersonCollectEO> list = this.baseMapper.queryByPersonCollectPage(page);
|
List<TsPersonCollect> list = this.baseMapper.queryByPersonCollectPage(page);
|
||||||
for(int i =0;i<list.size();i++){
|
for(int i =0;i<list.size();i++){
|
||||||
PersonNoteEO personNoteEO = new PersonNoteEO();
|
PersonNoteEO personNoteEO = new PersonNoteEO();
|
||||||
personNoteEO.setCollectId(list.get(i).getId());
|
personNoteEO.setCollectId(list.get(i).getId());
|
||||||
@@ -81,7 +86,7 @@ public class PersonCollectEOServiceImpl extends ServiceImpl<PersonCollectEODao,
|
|||||||
page.setCollectResId(collectResId);
|
page.setCollectResId(collectResId);
|
||||||
page.setUserId(userId);
|
page.setUserId(userId);
|
||||||
page.setValidFlag("0");
|
page.setValidFlag("0");
|
||||||
List<PersonCollectEO> getCollects = this.baseMapper.queryByList(page);
|
List<TsPersonCollect> getCollects = this.baseMapper.queryByList(page);
|
||||||
String collectId = "";
|
String collectId = "";
|
||||||
if(getCollects != null){
|
if(getCollects != null){
|
||||||
if(getCollects.size()>0){
|
if(getCollects.size()>0){
|
||||||
@@ -101,7 +106,35 @@ public class PersonCollectEOServiceImpl extends ServiceImpl<PersonCollectEODao,
|
|||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public int updateByPrimaryKeySelective(PersonCollectEO personCollectEO) throws Exception{
|
public int updateByPrimaryKeySelective(TsPersonCollect tsPersonCollect) throws Exception{
|
||||||
return personCollectEODao.updateByPrimaryKeySelective(personCollectEO);
|
return personCollectEODao.updateByPrimaryKeySelective(tsPersonCollect);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public ResponseMessage<IPage<TsPersonCollect>> queryCollectByWrapper(Integer pageNo, Integer pageSize, String collectTitle, String userId) {
|
||||||
|
BasePage basePage = new BasePage();
|
||||||
|
QueryWrapper<TsPersonCollect> 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<TsPersonCollect> page = this.page(new Page<>(basePage.getPage(), basePage.getPageSize()), wrapper);
|
||||||
|
return Result.success(page);
|
||||||
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -2,7 +2,7 @@
|
|||||||
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
|
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
|
||||||
<mapper namespace="com.adc.da.person.dao.PersonCollectEODao">
|
<mapper namespace="com.adc.da.person.dao.PersonCollectEODao">
|
||||||
<!-- Result Map-->
|
<!-- Result Map-->
|
||||||
<resultMap id="BaseResultMap" type="com.adc.da.person.entity.PersonCollectEO">
|
<resultMap id="BaseResultMap" type="com.adc.da.person.entity.TsPersonCollect">
|
||||||
<id column="id" property="id"/>
|
<id column="id" property="id"/>
|
||||||
<result column="modify_time" property="modifyTime"/>
|
<result column="modify_time" property="modifyTime"/>
|
||||||
<result column="creation_time" property="creationTime"/>
|
<result column="creation_time" property="creationTime"/>
|
||||||
@@ -153,7 +153,7 @@
|
|||||||
</sql>
|
</sql>
|
||||||
|
|
||||||
<!-- 插入记录 -->
|
<!-- 插入记录 -->
|
||||||
<insert id="insert" parameterType="com.adc.da.person.entity.PersonCollectEO">
|
<insert id="insert" parameterType="com.adc.da.person.entity.TsPersonCollect">
|
||||||
<!-- <selectKey resultType="java.lang.String" order="BEFORE" keyProperty="id">
|
<!-- <selectKey resultType="java.lang.String" order="BEFORE" keyProperty="id">
|
||||||
SELECT SEQ_TS_PERSON_COLLECT.NEXTVAL FROM DUAL
|
SELECT SEQ_TS_PERSON_COLLECT.NEXTVAL FROM DUAL
|
||||||
</selectKey> -->
|
</selectKey> -->
|
||||||
@@ -164,7 +164,7 @@
|
|||||||
</insert>
|
</insert>
|
||||||
|
|
||||||
<!-- 动态插入记录 主键是序列 -->
|
<!-- 动态插入记录 主键是序列 -->
|
||||||
<insert id="insertSelective" parameterType="com.adc.da.person.entity.PersonCollectEO">
|
<insert id="insertSelective" parameterType="com.adc.da.person.entity.TsPersonCollect">
|
||||||
<!-- <selectKey resultType="java.lang.String" order="BEFORE" keyProperty="id">
|
<!-- <selectKey resultType="java.lang.String" order="BEFORE" keyProperty="id">
|
||||||
SELECT SEQ_TS_PERSON_COLLECT.NEXTVAL FROM DUAL
|
SELECT SEQ_TS_PERSON_COLLECT.NEXTVAL FROM DUAL
|
||||||
</selectKey> -->
|
</selectKey> -->
|
||||||
@@ -194,7 +194,7 @@
|
|||||||
</insert>
|
</insert>
|
||||||
|
|
||||||
<!-- 根据pk,修改记录-->
|
<!-- 根据pk,修改记录-->
|
||||||
<update id="updateByPrimaryKey" parameterType="com.adc.da.person.entity.PersonCollectEO">
|
<update id="updateByPrimaryKey" parameterType="com.adc.da.person.entity.TsPersonCollect">
|
||||||
update TS_PERSON_COLLECT
|
update TS_PERSON_COLLECT
|
||||||
set modify_time = #{modifyTime},
|
set modify_time = #{modifyTime},
|
||||||
creation_time = #{creationTime},
|
creation_time = #{creationTime},
|
||||||
@@ -208,7 +208,7 @@
|
|||||||
</update>
|
</update>
|
||||||
|
|
||||||
<!-- 修改记录,只修改只不为空的字段 -->
|
<!-- 修改记录,只修改只不为空的字段 -->
|
||||||
<update id="updateByPrimaryKeySelective" parameterType="com.adc.da.person.entity.PersonCollectEO">
|
<update id="updateByPrimaryKeySelective" parameterType="com.adc.da.person.entity.TsPersonCollect">
|
||||||
update TS_PERSON_COLLECT
|
update TS_PERSON_COLLECT
|
||||||
<set>
|
<set>
|
||||||
<if test="modifyTime != null">
|
<if test="modifyTime != null">
|
||||||
@@ -332,7 +332,7 @@
|
|||||||
${pager.orderCondition}
|
${pager.orderCondition}
|
||||||
</if>
|
</if>
|
||||||
order by TS_PERSON_COLLECT.creation_time desc
|
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}
|
where rn >= ${pager.startIndex}
|
||||||
</select>
|
</select>
|
||||||
|
|
||||||
@@ -391,4 +391,10 @@
|
|||||||
</where>
|
</where>
|
||||||
</update>
|
</update>
|
||||||
|
|
||||||
|
|
||||||
|
<select id="selectPageCollect" resultMap="BaseResultMap" parameterType="java.util.Map">
|
||||||
|
select *
|
||||||
|
from ts_pserson_collect
|
||||||
|
where collect_type=#{c}
|
||||||
|
</select>
|
||||||
</mapper>
|
</mapper>
|
||||||
|
|||||||
Reference in New Issue
Block a user