other_project/jlzx
7
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

计量中心项目

Browse Source
This commit is contained in:
dimengzhe
2022-07-25 11:09:12 +08:00
parent 5911f42537
commit c8bb34e6cb
2143 changed files with 306192 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

100
jlzx-single/yxt-single-messagecenter/yxt-single-messagecenter-biz/pom.xml Normal file
View File

@@ -0,0 +1,100 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>com.yxt</groupId>
<artifactId>yxt-parent</artifactId>
<version>0.0.1</version>
<relativePath/>
</parent>
<groupId>com.yxt.messagecenter</groupId>
<artifactId>yxt-single-messagecenter-biz</artifactId>
<version>0.0.1</version>
<dependencies>
<dependency>
<groupId>com.yxt.messagecenter</groupId>
<artifactId>yxt-single-messagecenter-api</artifactId>
<version>0.0.1</version>
</dependency>
<dependency>
<groupId>com.yxt.jlzx</groupId>
<artifactId>jlzx-single-oa-api</artifactId>
<version>0.0.1</version>
</dependency>
<dependency>
<groupId>com.yxt.jlzx</groupId>
<artifactId>jlzx-single-jlcyry-api</artifactId>
<version>0.0.1</version>
</dependency>
<dependency>
<groupId>com.yxt.jlzx</groupId>
<artifactId>jlzx-single-system-api</artifactId>
<version>0.0.1</version>
</dependency>
<dependency>
<groupId>com.yxt.workflow</groupId>
<artifactId>yxt-single-workflow-api</artifactId>
<version>0.0.1</version>
</dependency>
<dependency>
<groupId>com.yxt</groupId>
<artifactId>yxt-common-base</artifactId>
<version>0.0.1</version>
</dependency>
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
</dependency>
<dependency>
<groupId>com.github.xiaoymin</groupId>
<artifactId>knife4j-spring-boot-starter</artifactId>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
<executions>
<execution>
<goals>
<goal>repackage</goal>
</goals>
</execution>
</executions>
</plugin>
</plugins>
<resources>
<resource>
<directory>src/main/java</directory>
<includes>
<include>**/*Mapper.xml</include>
</includes>
</resource>
<resource>
<directory>src/main/resources</directory>
<includes>
<include>**/*.yml</include>
</includes>
<filtering>false</filtering>
</resource>
</resources>
</build>
</project>

28
jlzx-single/yxt-single-messagecenter/yxt-single-messagecenter-biz/src/main/java/com/yxt/messagecenter/MessageCenterApplication.java Normal file
View File

@@ -0,0 +1,28 @@
package com.yxt.messagecenter;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.openfeign.EnableFeignClients;
/**
* @author yxt_mtl
* @date 2020/10/09 17:54
* @description
*/
@EnableDiscoveryClient
@SpringBootApplication(scanBasePackages = {
"com.yxt.common.base.config",
"com.yxt.messagecenter"
})
@EnableFeignClients(basePackages = {"com.yxt.jlzx.jlcyry","com.yxt.jlzx.system","com.yxt.oa","com.yxt.workflow"})
public class MessageCenterApplication
{
public static void main( String[] args )
{
SpringApplication.run(MessageCenterApplication.class, args);
}
}

283
jlzx-single/yxt-single-messagecenter/yxt-single-messagecenter-biz/src/main/java/com/yxt/messagecenter/biz/message/MessageApiImpl.java Normal file
View File

@@ -0,0 +1,283 @@
package com.yxt.messagecenter.biz.message;
import java.util.Date;
import java.util.List;
import javax.validation.Valid;
import com.yxt.jlzx.system.api.user.UserInfoVo;
import com.yxt.messagecenter.api.message.*;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.yxt.common.base.utils.PagerUtil;
import com.yxt.common.core.query.PagerQuery;
import com.yxt.common.core.result.ResultBean;
import com.yxt.common.core.vo.PagerVo;
import com.yxt.jlzx.jlcyry.api.staffinfo.StaffBasicDetailsVo;
import com.yxt.jlzx.jlcyry.api.staffinfo.StaffInfoApi;
import com.yxt.jlzx.system.api.department.DepartmentApi;
import com.yxt.jlzx.system.api.department.QrCodeVo;
import com.yxt.jlzx.system.api.user.UserApi;
import com.yxt.messagecenter.api.messagelist.Messagelist;
import com.yxt.messagecenter.api.messagelist.MessagelistQuery;
import com.yxt.messagecenter.api.messagelist.MessagelistVo;
import com.yxt.messagecenter.biz.messagelist.MessagelistService;
import io.swagger.annotations.Api;
/**
* @author hanweijia
* @date 2020/9/29 13:30
* @description 角色信息
*/
@Controller
@RequestMapping("v1/messages")
@Api(tags = "消息列表")
public class MessageApiImpl implements MessageApi{
@Autowired
private MessageService messageService;
@Autowired
private MessagelistService messagelistService;
@Autowired
private UserApi userApi;
@Autowired
private StaffInfoApi staffInofApi;
@Autowired
private DepartmentApi departmentApi;
@Override
public ResultBean<List<MessageVo>> list(@Valid MessageQuery query) {
return null;
}
@Override
public ResultBean<PagerVo<MessageVo>> pageList(@Valid PagerQuery<MessageQuery> pagerQuery) {
ResultBean<PagerVo<MessageVo>> rb = ResultBean.fireFail();
IPage<MessageVo> page = messageService.pageList(pagerQuery);
//把Ipage转换为PageVo
PagerVo<MessageVo> pv_result = PagerUtil.pageToVo(page, null);
return rb.success().setData(pv_result);
}
@Override
public ResultBean<List<MessagelistVo>> selectByMsgSid(String msgSid) {
ResultBean<List<MessagelistVo>> rb = ResultBean.fireFail();
List<MessagelistVo> listVo= messagelistService.selectByMsgSid(msgSid);
return rb.success().setData(listVo);
}
@Override
public ResultBean<PagerVo<MessagelistVo>> reveicepageList(@Valid PagerQuery<MessagelistQuery> pagerQuery) {
ResultBean<PagerVo<MessagelistVo>> rb = ResultBean.fireFail();
IPage<MessagelistVo> page = messagelistService.pageList(pagerQuery);
//把Ipage转换为PageVo
PagerVo<MessagelistVo> pv_result = PagerUtil.pageToVo(page, null);
return rb.success().setData(pv_result);
}
@Override
public ResultBean save(@Valid MessageDto dto) {
Message message=new Message();
dto.fillEntity(message);
if(dto.getCreateBySid()!=null) {
ResultBean<UserInfoVo> bean=userApi.selectBysid(dto.getCreateBySid());
UserInfoVo user=null;
if(bean.getSuccess()) {
user=bean.getData();
}
if(user!=null&&StringUtils.isNoneBlank(user.getStaffSid())) {
StaffBasicDetailsVo staffinfo= staffInofApi.staffBasicDetails(user.getStaffSid()).getData();
if(staffinfo!=null){
message.setCreaterName(staffinfo.getName());
}
QrCodeVo qrCodeVo=departmentApi.queryByStaffSid(user.getStaffSid()).getData();
if(qrCodeVo!=null) {
message.setCreateDeptName(qrCodeVo.getDepartmentName());
message.setCreateDeptSid(qrCodeVo.getSid());
}
}
}
if(dto.getReceiveSids()!=null&&dto.getReceiveSids().size()>0) {
for(int i=0;dto.getReceiveSids().size()>i;i++) {
Messagelist messagelist=new Messagelist();
ResultBean<UserInfoVo> bean=userApi.selectBysid(dto.getReceiveSids().get(i).getUserSid());
UserInfoVo user=null;
if(bean.getSuccess()) {
user=bean.getData();
}
if(user!=null&&StringUtils.isNoneBlank(user.getStaffSid())) {
StaffBasicDetailsVo staffinfo= staffInofApi.staffBasicDetails(user.getStaffSid()).getData();
if(staffinfo!=null){
messagelist.setReceiverName(staffinfo.getName());
}
QrCodeVo qrCodeVo=departmentApi.queryByStaffSid(user.getStaffSid()).getData();
if(qrCodeVo!=null) {
messagelist. setReceiverDeptSid(qrCodeVo.getSid());
messagelist.setReceiverDeptName(qrCodeVo.getDepartmentName());
}
}
messagelist.setReceiverId(dto.getReceiveSids().get(i).getUserSid());
messagelist.setState(0);//未读状态
messagelist.setCreateTime(message.getCreateTime());
messagelist.setMsgSid(message.getSid());
messagelistService.save(messagelist);
}
}else {
return ResultBean.fireSuccess().setMsg("保存失败，请选择人员");
}
if(!messageService.save(message)){
return ResultBean.fireFail();
}
return ResultBean.fireSuccess().setData(message.getSid());
}
@Override
public ResultBean update(@Valid MessageDto dto, String sid) throws Exception {
return new ResultBean().setMsg("接口暂未使用");
}
@Override
public ResultBean delete(String sid) {
Message t = messageService.fetchBySid(sid);
if (null == t){
return ResultBean.fireFail().setMsg("该记录不存在");
}
t.setIsDelete(1);
Boolean b= messageService.updateById(t);
if(b) {
List<Messagelist> list=messagelistService.fetchByMsgSid(sid);
for (int i = 0; i < list.size(); i++) {
Messagelist Message=list.get(i);
Message.setSDelStatus(1);
messagelistService.updateById(Message);
}
}else {
return ResultBean.fireSuccess().setSuccess(b).setMsg("删除失败");
}
return ResultBean.fireSuccess().setSuccess(b).setData(t.getSid()).setMsg("删除成功");
}
@Override
public ResultBean delSend(String sid) {
Messagelist t=messagelistService.fetchBySid(sid);
if (null == t){
return ResultBean.fireFail().setMsg("该记录不存在");
}
t.setSDelStatus(1);
Boolean b= messagelistService.updateById(t);
if (!b){
return ResultBean.fireSuccess().setSuccess(b).setMsg("删除失败");
}
return ResultBean.fireSuccess().setSuccess(b).setData(t.getSid()).setMsg("删除成功");
}
@Override
public ResultBean delReceive(String sid) {
Messagelist t=messagelistService.fetchBySid(sid);
if (null == t){
return ResultBean.fireFail().setMsg("该记录不存在");
}
t.setRDelStatus(1);
Boolean b= messagelistService.updateById(t);
if (!b){
return ResultBean.fireSuccess().setSuccess(b).setMsg("删除失败");
}
return ResultBean.fireSuccess().setSuccess(b).setData(t.getSid()).setMsg("删除成功");
}
@Override
public ResultBean<MessageVo> getVo(String sid) {
return null;
}
@Override
public ResultBean<MessagelistVo> msgListDtail(String sid) {
Messagelist t=messagelistService.fetchBySid(sid);
MessagelistVo messagelistVo=messagelistService.selectBySid(sid);
if(t.getState()!=1) {
t.setModifyTime(new Date());//修改已阅时间
t.setState(1);//点击详情 为已阅
messagelistService.updateById(t);
}
return new ResultBean<MessagelistVo>().success().setData(messagelistVo);
}
@Override
public ResultBean<PagerVo<MessageOneVo>> doingreads(@Valid PagerQuery<MessagelistQuery> query) {
ResultBean<PagerVo<MessageOneVo>> rb = ResultBean.fireFail();
IPage<MessageOneVo> page = messagelistService.doingreadspageList(query);
//把Ipage转换为PageVo
PagerVo<MessageOneVo> pv_result = PagerUtil.pageToVo(page, null);
return rb.success().setData(pv_result);
}
@Override
public ResultBean<PagerVo<MessageOneVo>> didreads(@Valid PagerQuery<MessagelistQuery> query) {
ResultBean<PagerVo<MessageOneVo>> rb = ResultBean.fireFail();
IPage<MessageOneVo> page = messagelistService.doingreadspageList(query);
//把Ipage转换为PageVo
PagerVo<MessageOneVo> pv_result = PagerUtil.pageToVo(page, null);
return rb.success().setData(pv_result);
}
@Override
public ResultBean cxjlSave(MessageDtoOne dtoOne) {
try {
System.out.println("djaskdjklas");
Messagelist messagelist = new Messagelist();
messagelist.setReceiverId(dtoOne.getReceiverId());
messagelist.setReceiverName(dtoOne.getReceiverName());
messagelist.setCreateTime(new Date());
Message message = new Message();
message.setMsgTitle("诚信计量，企业消息");
message.setMsgContent(dtoOne.getMsgContent());
messageService.save(message);
messagelist.setMsgSid(message.getSid());
messagelistService.save(messagelist);
} catch (Exception e ){
return ResultBean.fireSuccess().setMsg("添加失败");
}
return ResultBean.fireFail().setMsg("添加成功");
}
@Override
public ResultBean cxjlSelect(String orgSid) {
List<MessageVoOne> messageVoOneList = messagelistService.cxjlSelect(orgSid);
return new ResultBean().setData(messageVoOneList).success();
}
}

24
jlzx-single/yxt-single-messagecenter/yxt-single-messagecenter-biz/src/main/java/com/yxt/messagecenter/biz/message/MessageMaper.java Normal file
View File

@@ -0,0 +1,24 @@
package com.yxt.messagecenter.biz.message;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import com.baomidou.mybatisplus.core.conditions.Wrapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Constants;
import com.yxt.messagecenter.api.message.Message;
import com.yxt.messagecenter.api.message.MessageQuery;
import com.yxt.messagecenter.api.message.MessageVo;
/**
* @author hwj
* @date 2020/10/14 14:29
* @description
*/
@Mapper
public interface MessageMaper extends BaseMapper<Message> {
IPage<MessageVo> pageList(IPage<MessageQuery> page, @Param(Constants.WRAPPER) Wrapper<MessageVo> qw);
}

9
jlzx-single/yxt-single-messagecenter/yxt-single-messagecenter-biz/src/main/java/com/yxt/messagecenter/biz/message/MessageMapper.xml Normal file
View File

@@ -0,0 +1,9 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.yxt.messagecenter.biz.message.MessageMapper">
<select id="pageList" resultType="com.yxt.messagecenter.api.message.MessageVo">
select * from message
${ew.customSqlSegment}
</select>
</mapper>

52
jlzx-single/yxt-single-messagecenter/yxt-single-messagecenter-biz/src/main/java/com/yxt/messagecenter/biz/message/MessageService.java Normal file
View File

@@ -0,0 +1,52 @@
package com.yxt.messagecenter.biz.message;
import org.apache.commons.lang3.StringUtils;
import org.springframework.stereotype.Service;
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.core.query.PagerQuery;
import com.yxt.messagecenter.api.message.Message;
import com.yxt.messagecenter.api.message.MessageQuery;
import com.yxt.messagecenter.api.message.MessageVo;
/**
* @author dimengzhe
* @date 2020/10/14 14:29
* @description
*/
@Service
public class MessageService extends MybatisBaseService<MessageMaper, Message> {
// 分页列表
public IPage<MessageVo> pageList(PagerQuery<MessageQuery> pagerQuery) {
IPage<MessageQuery> page = PagerUtil.queryToPage(pagerQuery);
QueryWrapper<MessageVo> qw = buildQueryWrapper(pagerQuery.getParams());
return baseMapper.pageList(page, qw);
}
/**
* 解析和组装查询条件，封装在qw中,虚方法，需要在子类中定义具体实现
* @param pagerQuery
* @return
*/
private QueryWrapper<MessageVo> buildQueryWrapper(MessageQuery pagerQuery){
QueryWrapper<MessageVo> qw = new QueryWrapper<MessageVo>();
if (pagerQuery != null) {
if( StringUtils.isNoneBlank(pagerQuery.getCreateBySid())) {
qw.eq("createBySid", pagerQuery.getCreateBySid()) ;
}
qw.eq("isDelete","0");
qw.orderByDesc("createTime");
}
return qw;
}
}

40
jlzx-single/yxt-single-messagecenter/yxt-single-messagecenter-biz/src/main/java/com/yxt/messagecenter/biz/messagelist/MessagelistMapper.java Normal file
View File

@@ -0,0 +1,40 @@
package com.yxt.messagecenter.biz.messagelist;
import java.util.List;
import com.yxt.messagecenter.api.message.MessageVoOne;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import com.baomidou.mybatisplus.core.conditions.Wrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Constants;
import com.yxt.messagecenter.api.message.MessageOneVo;
import com.yxt.messagecenter.api.messagelist.Messagelist;
import com.yxt.messagecenter.api.messagelist.MessagelistQuery;
import com.yxt.messagecenter.api.messagelist.MessagelistVo;
/**
* @author yxt_mtl
* @date 2020/10/12 11:14
* @description
*/
@Mapper
public interface MessagelistMapper extends BaseMapper<Messagelist>{
//分页列表
IPage<MessagelistVo> pageList(IPage<MessagelistQuery> page,@Param(Constants.WRAPPER) Wrapper<MessagelistVo> qw);
MessagelistVo selectBySid(String msgSid);
List<MessagelistVo> selectByMsgSid(String msgSid);
List<Messagelist> fetchByMsgSid(String msgSid);
IPage<MessageOneVo> doingreadspageList(IPage<MessagelistQuery> page,@Param(Constants.WRAPPER) Wrapper<MessageOneVo> qw );
IPage<MessageOneVo> didreadspageList(IPage<MessagelistQuery> page, @Param(Constants.WRAPPER) Wrapper<MessageOneVo> qw);
List<MessageVoOne> cxjlSelect(@Param("orgSid") String orgSid);
}

56
jlzx-single/yxt-single-messagecenter/yxt-single-messagecenter-biz/src/main/java/com/yxt/messagecenter/biz/messagelist/MessagelistMapper.xml Normal file
View File

@@ -0,0 +1,56 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.yxt.messagecenter.biz.messagelist.MessagelistMapper">
<select id="pageList" resultType="com.yxt.messagecenter.api.messagelist.MessagelistVo">
select (select msgTitle from message where sid=r.msgSid)msgTitle,
(select createrName from message where sid=r.msgSid) sendName,r.receiverId,r.receiverName,
r.receiverDeptSid,r.receiverDeptName,
DATE_FORMAT(r.modifyTime, '%Y-%m-%d %H:%m:%s') AS modifyTime ,r.sid, case when r.state=1 then "已阅" else "未阅" end from messagelist r
${ew.customSqlSegment}
</select>
<select id="doingreadspageList" resultType="com.yxt.messagecenter.api.message.MessageOneVo">
select (select msgTitle from message where sid=r.msgSid)msgTitle,
(select createrName from message where sid=r.msgSid) sendName,r.receiverId,r.receiverName,
r.receiverDeptSid,r.receiverDeptName,
DATE_FORMAT(r.modifyTime, '%Y-%m-%d %H:%m:%s') AS modifyTime from messagelist r
${ew.customSqlSegment}
</select>
<select id="didreadspageList" resultType="com.yxt.messagecenter.api.message.MessageOneVo">
select (select msgTitle from message where sid=r.msgSid)msgTitle,
(select createrName from message where sid=r.msgSid) sendName,r.receiverId,r.receiverName,
r.receiverDeptSid,r.receiverDeptName,
DATE_FORMAT(r.modifyTime, '%Y-%m-%d %H:%m:%s') AS modifyTime from messagelist r
${ew.customSqlSegment}
</select>
<select id="selectBySid" resultType="com.yxt.messagecenter.api.messagelist.MessagelistVo">
select (select msgTitle from message where sid=r.msgSid)msgTitle,
(select createrName from message where sid=r.msgSid) sendName,r.receiverId,r.receiverName,
r.receiverDeptSid,r.receiverDeptName,
DATE_FORMAT(r.modifyTime, '%Y-%m-%d %H:%m:%s') AS modifyTime ,r.sid, case when r.state=1 then "已阅" else "未阅" end from messagelist r
where sid=#{sid}
</select>
<select id="fetchByMsgSid" resultType="com.yxt.messagecenter.api.messagelist.Messagelist">
select * from messagelist
where msgSid=#{msgSid}
</select>
<select id="selectByMsgSid" resultType="com.yxt.messagecenter.api.messagelist.MessagelistVo">
select (select msgTitle from message where sid=r.msgSid)msgTitle,
(select createrName from message where sid=r.msgSid) sendName,r.receiverId,r.receiverName,
r.receiverDeptSid,r.receiverDeptName,
DATE_FORMAT(r.modifyTime, '%Y-%m-%d %H:%m:%s') AS modifyTime ,r.sid, case when r.state=1 then "已阅" else "未阅" end from messagelist r
where msgSid=#{msgSid}
</select>
<select id="cxjlSelect" resultType="com.yxt.messagecenter.api.message.MessageVoOne">
SELECT * from messagelist f INNER JOIN message m on m.sid = f.msgSid WHERE receiverId = #{orgSid}
</select>
</mapper>

135
jlzx-single/yxt-single-messagecenter/yxt-single-messagecenter-biz/src/main/java/com/yxt/messagecenter/biz/messagelist/MessagelistService.java Normal file
View File

@@ -0,0 +1,135 @@
package com.yxt.messagecenter.biz.messagelist;
import java.util.List;
import javax.validation.Valid;
import com.yxt.messagecenter.api.message.MessageVoOne;
import org.springframework.stereotype.Service;
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.core.query.PagerQuery;
import com.yxt.messagecenter.api.message.MessageOneVo;
import com.yxt.messagecenter.api.message.MessageQuery;
import com.yxt.messagecenter.api.message.MessageVo;
import com.yxt.messagecenter.api.messagelist.Messagelist;
import com.yxt.messagecenter.api.messagelist.MessagelistQuery;
import com.yxt.messagecenter.api.messagelist.MessagelistVo;
/**
* @author yxt_mtl
* @date 2020/10/12 11:12
* @description
*/
@Service
public class MessagelistService extends MybatisBaseService<MessagelistMapper, Messagelist> {
// 分页列表
public IPage<MessagelistVo> pageList(PagerQuery<MessagelistQuery> pagerQuery) {
IPage<MessagelistQuery> page = PagerUtil.queryToPage(pagerQuery);
QueryWrapper<MessagelistVo> qw = buildQueryWrapper(pagerQuery.getParams());
return baseMapper.pageList(page, qw);
}
/**
* 解析和组装查询条件，封装在qw中
*
* @param pagerQuery
* @return
*/
private QueryWrapper<MessagelistVo> buildQueryWrapper(MessagelistQuery pagerQuery) {
QueryWrapper<MessagelistVo> qw = new QueryWrapper<>();
if (pagerQuery != null) {
// if (org.apache.commons.lang3.StringUtils.isNotBlank(pagerQuery.getTitle()))
// qw.like("title", pagerQuery.getTitle());
//
// if (org.apache.commons.lang3.StringUtils.isNotBlank(pagerQuery.getSenderName()))
// qw.like("senderName", pagerQuery.getSenderName());
//
// if (null!=pagerQuery.getStartDate() && org.apache.commons.lang3.StringUtils.isNotBlank(pagerQuery
// .getStartDate().toString()))
// qw.ge("sendTime", pagerQuery.getStartDate());
//
// if (null!=pagerQuery.getEndDate() && org.apache.commons.lang3.StringUtils.isNotBlank(pagerQuery
// .getEndDate().toString()))
// qw.le("sendTime", pagerQuery.getEndDate());
if (org.apache.commons.lang3.StringUtils.isNotBlank(pagerQuery.getReceiverSid()))
qw.eq("receiverId", pagerQuery.getReceiverSid());
qw.orderByDesc("createTime");
}
return qw;
}
//待阅
public IPage<MessageOneVo> doingreadspageList(@Valid PagerQuery<MessagelistQuery> query) {
// TODO Auto-generated method stub
query.getParams().setState(0);
IPage<MessagelistQuery> page = PagerUtil.queryToPage(query);
QueryWrapper<MessageOneVo> qw = buildQueryWrapper1(query.getParams());
return baseMapper.doingreadspageList(page, qw);
}
//已阅
public IPage<MessageOneVo> didreadspageList(@Valid PagerQuery<MessagelistQuery> query) {
// TODO Auto-generated method stub
query.getParams().setState(1);
IPage<MessagelistQuery> page = PagerUtil.queryToPage(query);
QueryWrapper<MessageOneVo> qw = buildQueryWrapper1(query.getParams());
return baseMapper.didreadspageList(page, qw);
}
private QueryWrapper<MessageOneVo> buildQueryWrapper1(MessagelistQuery pagerQuery) {
QueryWrapper<MessageOneVo> qw = new QueryWrapper<>();
if (pagerQuery != null) {
if (org.apache.commons.lang3.StringUtils.isNotBlank(pagerQuery.getReceiverSid()))
qw.eq("r.receiverId", pagerQuery.getReceiverSid());
if (org.apache.commons.lang3.StringUtils.isNotBlank(pagerQuery.getMsgTitle()))
qw.like("m.msgTile", pagerQuery.getMsgTitle());
if (org.apache.commons.lang3.StringUtils.isNotBlank(pagerQuery.getMsgType()))
qw.eq("m.msgType", pagerQuery.getMsgType());
qw.eq("r.state", pagerQuery.getState());
qw.eq("rDelStatus","0");
qw.orderByDesc("createTime");
}
return qw;
}
public List<Messagelist> fetchByMsgSid(String msgSid) {
// TODO Auto-generated method stub
return baseMapper.fetchByMsgSid(msgSid);
}
public List<MessagelistVo> selectByMsgSid(String msgSid) {
// TODO Auto-generated method stub
return baseMapper.selectByMsgSid(msgSid);
}
public MessagelistVo selectBySid(String msgSid) {
// TODO Auto-generated method stub
return baseMapper.selectBySid(msgSid);
}
public List<MessageVoOne> cxjlSelect(String orgSid) {
return baseMapper.cxjlSelect(orgSid);
}
}

70
jlzx-single/yxt-single-messagecenter/yxt-single-messagecenter-biz/src/main/java/com/yxt/messagecenter/conf/Swagger2Config.java Normal file
View File

@@ -0,0 +1,70 @@
/*********************************************************
*********************************************************
******************** *******************
************* ************
******* _oo0oo_ *******
*** o8888888o ***
* 88" . "88 *
* (| -_- |) *
* 0\ = /0 *
* ___/`---'\___ *
* .' \\| |// '. *
* / \\||| : |||// \ *
* / _||||| -:- |||||- \ *
* | | \\\ - /// | | *
* | \_| ''\---/'' |_/ | *
* \ .-\__ '-' ___/-. / *
* ___'. .' /--.--\ `. .'___ *
* ."" '< `.___\_<|>_/___.' >' "". *
* | | : `- \`.;`\ _ /`;.`/ - ` : | | *
* \ \ `_. \_ __\ /__ _/ .-` / / *
* =====`-.____`.___ \_____/___.-`___.-'===== *
* `=---=' *
* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ *
*********__佛祖保佑__永无BUG__验收通过__钞票多多__*********
*********************************************************/
package com.yxt.messagecenter.conf;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import springfox.documentation.builders.ApiInfoBuilder;
import springfox.documentation.builders.PathSelectors;
import springfox.documentation.builders.RequestHandlerSelectors;
import springfox.documentation.service.ApiInfo;
import springfox.documentation.spi.DocumentationType;
import springfox.documentation.spring.web.plugins.Docket;
import springfox.documentation.swagger2.annotations.EnableSwagger2;
import com.github.xiaoymin.knife4j.spring.annotations.EnableKnife4j;
/**
* Project: jlcyry <br/>
* File: Swagger2Config.java <br/>
* Class: com.yxt.jlzx.jlcyry.conf.Swagger2Config <br/>
* Description: <描述类的功能>. <br/>
* Copyright: Copyright (c) 2011 <br/>
* Company: https://gitee.com/liuzp315 <br/>
* Makedate: 2020/8/25 23:27 <br/>
*
* @author liupopo
* @version 1.0
* @since 1.0
*/
@Configuration
@EnableSwagger2
@EnableKnife4j
public class Swagger2Config {
@Bean
public Docket createRestApi() {
return new Docket(DocumentationType.SWAGGER_2)
.apiInfo(apiInfo()).select()
.apis(RequestHandlerSelectors.basePackage("com.yxt"))
.paths(PathSelectors.any()).build();
}
private ApiInfo apiInfo() {
return new ApiInfoBuilder().title("计量中心/消息中心").description("计量中心消息中心").version("1.0")
.build();
}
}

40
jlzx-single/yxt-single-messagecenter/yxt-single-messagecenter-biz/src/main/resources/application-dev.yml Normal file
View File

@@ -0,0 +1,40 @@
spring:
datasource:
driver-class-name: com.mysql.cj.jdbc.Driver
url: jdbc:mysql://127.0.0.1:3306/jlzx_messagecenter?useUnicode=true&characterEncoding=UTF-8&useSSL=false&autoReconnect=true&serverTimezone=GMT%2B8&failOverReadOnly=false
username: root
password: root
redis:
database: 6 # Redis数据库索引（默认为0）
host: 127.0.0.1
jedis:
pool:
max-active: -1 #连接池最大连接数（使用负值表示没有限制）
max-idle: 8 #连接池中的最大空闲连接
max-wait: -1 # 连接池最大阻塞等待时间（使用负值表示没有限制）
min-idle: 0 # 连接池中的最小空闲连接
password:
port: 6379
timeout: 0 # 连接超时时间（毫秒）
nacos:
discovery:
server-addr: 127.0.0.1:8848
# 日志配置
logging:
level:
com.yxt: debug
org.mybatis: debug
org.springframework: warn
image:
upload:
#path: /Users/popo/works/projects/hbuilderx/gg815/gg_admin/target/classes/static/upload/
#path: D:\\works\\projects\\hbuilderx\\gg815\\gg_admin\\target\\classes\\static\\upload\\
#path: /home/lzh/webapps/hbhx_kzdapi/BOOT-INF/classes/static/img/
path: D:\\jlzx\\upload\\
url:
prefix: http://127.0.0.1:8111/upload/
#prefix: http://211.90.39.140:8008/
#prefix: http://b92.bwyljy.com/img/
#prefix: http://192.168.0.119:8089/lv-qggz-state-ww/img/

34
jlzx-single/yxt-single-messagecenter/yxt-single-messagecenter-biz/src/main/resources/application-pro.yml Normal file
View File

@@ -0,0 +1,34 @@
spring:
datasource:
driver-class-name: com.mysql.cj.jdbc.Driver
url: jdbc:mysql://39.104.142.92:3306/jlzx_messagecenter?useUnicode=true&characterEncoding=UTF-8&useSSL=false&autoReconnect=true&serverTimezone=GMT%2B8&failOverReadOnly=false
username: root
password: 123456
nacos:
discovery:
server-addr: 39.104.100.138:8848
redis:
database: 2 # Redis数据库索引（默认为0）
host: 39.104.100.138
jedis:
pool:
max-active: -1 #连接池最大连接数（使用负值表示没有限制）
max-idle: 8 #连接池中的最大空闲连接
max-wait: -1 # 连接池最大阻塞等待时间（使用负值表示没有限制）
min-idle: 0 # 连接池中的最小空闲连接
password: 123456
port: 6379
timeout: 0 # 连接超时时间（毫秒）
# 日志配置
logging:
level:
com.yxt: debug
org.mybatis: debug
org.springframework: warn
image:
upload:
path: D:\\jlzx\\upload\\
url:
prefix: http://39.104.100.138:8111/upload/

36
jlzx-single/yxt-single-messagecenter/yxt-single-messagecenter-biz/src/main/resources/application-pro2.yml Normal file
View File

@@ -0,0 +1,36 @@
spring:
datasource:
driver-class-name: com.mysql.cj.jdbc.Driver
url: jdbc:mysql://192.168.103.6:3306/jlzx_messagecenter?useUnicode=true&characterEncoding=UTF-8&useSSL=false&autoReconnect=true&serverTimezone=GMT%2B8&failOverReadOnly=false
username: root
password: yxt_@jlzx_root
cloud:
nacos:
discovery:
server-addr: 192.168.103.6:8848
redis:
database: 2 # Redis数据库索引（默认为0）
host: 192.168.103.6
jedis:
pool:
max-active: -1 #连接池最大连接数（使用负值表示没有限制）
max-idle: 8 #连接池中的最大空闲连接
max-wait: -1 # 连接池最大阻塞等待时间（使用负值表示没有限制）
min-idle: 0 # 连接池中的最小空闲连接
password: 123456
port: 6379
timeout: 0 # 连接超时时间（毫秒）
# 日志配置
logging:
level:
com.yxt: debug
org.mybatis: debug
org.springframework: warn
image:
upload:
path: E:\jlzx\upload\
url:
# prefix: http://192.168.103.6:8111/upload/
prefix: http://jlyw1.hebjlzy.com:8111/upload/

36
jlzx-single/yxt-single-messagecenter/yxt-single-messagecenter-biz/src/main/resources/application-pro3.yml Normal file
View File

@@ -0,0 +1,36 @@
spring:
datasource:
driver-class-name: com.mysql.cj.jdbc.Driver
url: jdbc:mysql://192.168.103.5:3306/jlzx_messagecenter?useUnicode=true&characterEncoding=UTF-8&useSSL=false&autoReconnect=true&serverTimezone=GMT%2B8&failOverReadOnly=false
username: root
password: 1LAiGz$t1*Iw
cloud:
nacos:
discovery:
server-addr: 127.0.0.1:8848
redis:
database: 2 # Redis数据库索引（默认为0）
host: 127.0.0.1
jedis:
pool:
max-active: -1 #连接池最大连接数（使用负值表示没有限制）
max-idle: 8 #连接池中的最大空闲连接
max-wait: -1 # 连接池最大阻塞等待时间（使用负值表示没有限制）
min-idle: 0 # 连接池中的最小空闲连接
password:
port: 6379
timeout: 0 # 连接超时时间（毫秒）
# 日志配置
logging:
level:
com.yxt: debug
org.mybatis: debug
org.springframework: warn
image:
upload:
path: D:\jlzx\upload\
url:
# prefix: http://192.168.103.6:8111/upload/
prefix: http://218.11.12.36:8111/upload/

24
jlzx-single/yxt-single-messagecenter/yxt-single-messagecenter-biz/src/main/resources/application-test.yml Normal file
View File

@@ -0,0 +1,24 @@
spring:
datasource:
driver-class-name: com.mysql.cj.jdbc.Driver
url: jdbc:mysql://127.0.0.1:3306/jlzx_messagecenter?useUnicode=true&characterEncoding=UTF-8&useSSL=false&autoReconnect=true&serverTimezone=GMT%2B8&failOverReadOnly=false
username: root
password: root
# 日志配置
logging:
level:
com.yxt: debug
org.mybatis: debug
org.springframework: warn
image:
upload:
#path: /Users/popo/works/projects/hbuilderx/gg815/gg_admin/target/classes/static/upload/
path: D:\\works\\projects\\hbuilderx\\gg815\\gg_admin\\target\\classes\\static\\upload\\
#path: /home/lzh/webapps/hbhx_kzdapi/BOOT-INF/classes/static/img/
url:
prefix: http://192.168.56.1:8108/upload/
#prefix: http://211.90.39.140:8008/
#prefix: http://b92.bwyljy.com/img/
#prefix: http://192.168.0.119:8089/lv-qggz-state-ww/img/

48
jlzx-single/yxt-single-messagecenter/yxt-single-messagecenter-biz/src/main/resources/application.yml Normal file
View File

@@ -0,0 +1,48 @@
spring:
application:
name: yxt-messagecenter
profiles:
active: dev
# 资源信息
messages:
# 国际化资源文件路径
basename: i18n/messages
servlet:
multipart:
max-file-size: 50MB
max-request-size: 100MB
output:
ansi:
enabled: ALWAYS
server:
port: 8107
#mybatis
mybatis-plus:
mapper-locations: classpath*:**Mapper.xml
global-config:
refresh: true
db-config:
id-type: 0
db-type: mysql
configuration:
map-underscore-to-camel-case: false
cache-enabled: true
call-setters-on-nulls: true
log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
#hystrix的超时时间
hystrix:
command:
default:
execution:
timeout:
enabled: true
isolation:
thread:
timeoutInMilliseconds: 30000
#ribbon的超时时间
ribbon:
ReadTimeout: 30000
ConnectTimeout: 30000

49
jlzx-single/yxt-single-messagecenter/yxt-single-messagecenter-biz/src/main/resources/logback-spring.xml Normal file
View File

@@ -0,0 +1,49 @@
<?xml version="1.0" encoding="UTF-8"?>
<configuration>
<property name="log.base" value="logs/yxt_messagecenter" />
<appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
<encoder>
<!--格式化输出：%d表示日期，%thread表示线程名，%-5level：级别从左显示5个字符宽度%msg：日志消息，%n是换行符 ：
|%blue(%thread) 线程 如 ：DiscoveryClient-CacheRefreshExecutor-0-->
<!--<pattern>%d{HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>-->
<pattern>%yellow(%date{yyyy-MM-dd HH:mm:ss}) |%highlight(%-5level) |%green(%logger:%line) |%black(%msg%n)</pattern>
<!--<charset>UTF-8</charset> -->
</encoder>
</appender>
<!-- 彩色日志 -->
<!-- 彩色日志依赖的渲染类 -->
<conversionRule conversionWord="clr" converterClass="org.springframework.boot.logging.logback.ColorConverter" />
<conversionRule conversionWord="wex" converterClass="org.springframework.boot.logging.logback.WhitespaceThrowableProxyConverter" />
<conversionRule conversionWord="wEx" converterClass="org.springframework.boot.logging.logback.ExtendedWhitespaceThrowableProxyConverter" />
<!-- 彩色日志格式 -->
<property name="CONSOLE_LOG_PATTERN" value="${CONSOLE_LOG_PATTERN:-%clr(%d{yyyy-MM-dd HH:mm:ss.SSS}){faint} %clr(${LOG_LEVEL_PATTERN:-%5p}) %clr(${PID:- }){magenta} %clr(---){faint} %clr([%15.15t]){faint} %clr(%-40.40logger{39}){cyan} %clr(:){faint} %m%n${LOG_EXCEPTION_CONVERSION_WORD:-%wEx}}"/>
<appender name="FILEOUT"
class="ch.qos.logback.core.rolling.RollingFileAppender">
<file>${log.base}.log</file>
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<fileNamePattern>${log.base}.%d{yyyyMMdd}.%i.log.zip
</fileNamePattern>
<!-- 当文件大小超过10MB时触发滚动 -->
<timeBasedFileNamingAndTriggeringPolicy
class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP">
<maxFileSize>1MB</maxFileSize>
</timeBasedFileNamingAndTriggeringPolicy>
</rollingPolicy>
<encoder>
<!--<pattern>%date [%thread] %-5level %logger{35} - %msg%n</pattern>-->
<Pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36}
-%msg%n</Pattern>
<!--<charset>UTF-8</charset> -->
</encoder>
</appender>
<root level="INFO">
<appender-ref ref="STDOUT" />
<appender-ref ref="FILEOUT" />
</root>
</configuration>