diff --git a/yxt_supervise/supervise-crm/supervise-crm-biz/src/main/java/com/yxt/supervise/crm/biz/userproject/UserProjectMapper.java b/yxt_supervise/supervise-crm/supervise-crm-biz/src/main/java/com/yxt/supervise/crm/biz/userproject/UserProjectMapper.java index 5a5d62da..c089948d 100644 --- a/yxt_supervise/supervise-crm/supervise-crm-biz/src/main/java/com/yxt/supervise/crm/biz/userproject/UserProjectMapper.java +++ b/yxt_supervise/supervise-crm/supervise-crm-biz/src/main/java/com/yxt/supervise/crm/biz/userproject/UserProjectMapper.java @@ -18,7 +18,7 @@ import java.util.List; @Mapper public interface UserProjectMapper extends BaseMapper { IPage selectPageVo(IPage page, @Param(Constants.WRAPPER) Wrapper qw); - List typeList(); - UserProjectVo getProjectTypeBySid( @Param("sid") String sid); + List userProjectList(); + UserProjectVo getUserProjectBySid( @Param("projectSid") String projectSid,@Param("userType")String userType); } diff --git a/yxt_supervise/supervise-crm/supervise-crm-biz/src/main/java/com/yxt/supervise/crm/biz/userproject/UserProjectMapper.xml b/yxt_supervise/supervise-crm/supervise-crm-biz/src/main/java/com/yxt/supervise/crm/biz/userproject/UserProjectMapper.xml index f478d15d..ec7bc4ff 100644 --- a/yxt_supervise/supervise-crm/supervise-crm-biz/src/main/java/com/yxt/supervise/crm/biz/userproject/UserProjectMapper.xml +++ b/yxt_supervise/supervise-crm/supervise-crm-biz/src/main/java/com/yxt/supervise/crm/biz/userproject/UserProjectMapper.xml @@ -12,13 +12,11 @@ ${ew.sqlSegment} - SELECT * FROM user_project - + SELECT * FROM user_project WHERE projectSid=#{projectSid} and userType=#{userType} \ No newline at end of file diff --git a/yxt_supervise/supervise-crm/supervise-crm-biz/src/main/java/com/yxt/supervise/crm/biz/userproject/UserProjectRest.java b/yxt_supervise/supervise-crm/supervise-crm-biz/src/main/java/com/yxt/supervise/crm/biz/userproject/UserProjectRest.java index f73cc028..42dbea90 100644 --- a/yxt_supervise/supervise-crm/supervise-crm-biz/src/main/java/com/yxt/supervise/crm/biz/userproject/UserProjectRest.java +++ b/yxt_supervise/supervise-crm/supervise-crm-biz/src/main/java/com/yxt/supervise/crm/biz/userproject/UserProjectRest.java @@ -36,7 +36,7 @@ public class UserProjectRest { @PostMapping("/list") public ResultBean> listPage() { ResultBean rb = ResultBean.fireFail(); - List pv = UserProjectService.typeList(); + List pv = UserProjectService.userProjectList(); return rb.success().setData(pv); } @ApiOperation("保存") @@ -50,12 +50,16 @@ public class UserProjectRest { return UserProjectService.update(dto); } @ApiOperation("根据sid查询") - @GetMapping("/getProjTypeBySid/{sid}") - public ResultBean getWarehouse(@PathVariable String sid){ + @GetMapping("/getUserProjectBySid/{projectSid}/{userType}") + public ResultBean getWarehouse(@PathVariable String projectSid,@PathVariable String userType){ ResultBean rb = ResultBean.fireFail(); - UserProjectVo UserProjectVo=UserProjectService.getProjectTypeBySid(sid); + UserProjectVo UserProjectVo=UserProjectService.getUserProjectBySid(projectSid,userType); return rb.success().setData(UserProjectVo); } + //获取银行 +// public ResultBean getAllUser(String userType){ +// +// } @ApiOperation("删除") @DeleteMapping("/delete/{sid}") public ResultBean delete(@PathVariable String sid) { diff --git a/yxt_supervise/supervise-crm/supervise-crm-biz/src/main/java/com/yxt/supervise/crm/biz/userproject/UserProjectService.java b/yxt_supervise/supervise-crm/supervise-crm-biz/src/main/java/com/yxt/supervise/crm/biz/userproject/UserProjectService.java index a0afb15e..673ec5f3 100644 --- a/yxt_supervise/supervise-crm/supervise-crm-biz/src/main/java/com/yxt/supervise/crm/biz/userproject/UserProjectService.java +++ b/yxt_supervise/supervise-crm/supervise-crm-biz/src/main/java/com/yxt/supervise/crm/biz/userproject/UserProjectService.java @@ -33,8 +33,8 @@ public class UserProjectService extends MybatisBaseService p = PagerUtil.pageToVo(pagging, null); return p; } - public List typeList() { - List pagging = baseMapper.typeList(); + public List userProjectList() { + List pagging = baseMapper.userProjectList(); return pagging; } public ResultBean save(UserProjectDto dto) { @@ -54,8 +54,8 @@ public class UserProjectService extends MybatisBaseService { - @Select("select * from message_push_log l left join message_openid o on o.messageSid=l.sid where o.openId=#{openid}") - MessagePushLogVo getAllByUserSid(@Param("openid") String openid); + @Select("select count(o.id) from message_push_log l left join message_openid o on o.messageSid=l.sid where o.openId=#{openid} and o.state=#{state}") + int getAllByUserSid(@Param("openid") String openid,@Param("state")String state); IPage selectPageVo(IPage page, @Param(Constants.WRAPPER) Wrapper qw); } diff --git a/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/messagepushlog/MessagePushLogRest.java b/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/messagepushlog/MessagePushLogRest.java index 062bd22c..ce2799af 100644 --- a/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/messagepushlog/MessagePushLogRest.java +++ b/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/messagepushlog/MessagePushLogRest.java @@ -41,6 +41,18 @@ public class MessagePushLogRest { PagerVo pv = messagePushLogService.listPage(pq); return rb.success().setData(pv); } + + /** + * 查询待阅 已阅消息数量 + * @param userSid + * @param state + * @return + */ + @GetMapping("/numberOfJobs/{userSid}/{state}") + public ResultBean numberOfJobs(@PathVariable("userSid")String userSid,@PathVariable("state") String state){ + return messagePushLogService.numberOfJobs(userSid,state); + } + @PostMapping("/changeState") public ResultBean changeState(@RequestBody PagerQuery pq){ ResultBean rb = ResultBean.fireFail(); diff --git a/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/messagepushlog/MessagePushLogService.java b/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/messagepushlog/MessagePushLogService.java index 39276f4d..96a86152 100644 --- a/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/messagepushlog/MessagePushLogService.java +++ b/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/messagepushlog/MessagePushLogService.java @@ -6,6 +6,7 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.yxt.common.base.service.MybatisBaseService; import com.yxt.common.base.utils.PagerUtil; +import com.yxt.common.base.utils.StringUtils; import com.yxt.common.core.query.PagerQuery; import com.yxt.common.core.result.ResultBean; import com.yxt.common.core.vo.PagerVo; @@ -23,7 +24,6 @@ import com.yxt.supervise.report.api.reportsalesdaytobaccostore.ReportSalesDayTob import com.yxt.supervise.report.biz.messageopenid.MessageOpenidService; import com.yxt.supervise.system.dicttype.DictType; import com.yxt.supervise.system.dicttype.DictTypeVo; -import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; @@ -65,10 +65,26 @@ public class MessagePushLogService extends MybatisBaseService page = PagerUtil.queryToPage(pq); QueryWrapper qw = new QueryWrapper<>(); qw.eq("o.openId",openid); + if(StringUtils.isNotNull(query.getState())){ + if(query.getState().equals("0")){} + else if(query.getState().equals("1")){ + qw.eq("o.state",0); + }else if(query.getState().equals("2")){ + qw.eq("o.state",1); + } + } IPage pagging = baseMapper.selectPageVo(page, qw); PagerVo p = PagerUtil.pageToVo(pagging, null); return p; } + public ResultBean numberOfJobs(String userSid,String state){ + ResultBean rb =new ResultBean(); + String openid=systemMapper.getAppletOpenidByUsersid(userSid); + int count=baseMapper.getAllByUserSid(openid,state); + return rb.success().setData(count); + } + + public PagerVo changeState(PagerQuery pq) { ResultBean rb=new ResultBean(); MessagePushLogQuery query = pq.getParams();