Skip to content

X
xzxt-app-report
Commit df151826 by wang_jiaxing
Options

增加位置信息的相关接口，修改消息中心使用mysql库

parent 1e19d2c7
Showing with 813 additions and 422 deletions
src/main/java/org/springblade/founder/qgccj/service/impl/TbXwZbfzxyrServiceQgccjImpl.java
......@@ -15,6 +15,7 @@ import org.springblade.founder.qgccj.service.TbStRyService;
import org.springblade.founder.qgccj.service.TbXwZbfzxyrQgccjService;
import org.springblade.founder.qgccj.util.BeanCopyUtil;
import org.springblade.founder.socketio.entity.TbFwXxdl;
import org.springblade.founder.socketio.entity.TbXxfwXxdl;
import org.springblade.founder.socketio.service.IMessageService;
import org.springblade.founder.utils.SysXxzjbhService;
import org.springblade.modules.system.entity.XzxtUser;
......@@ -125,9 +126,9 @@ public class TbXwZbfzxyrServiceQgccjImpl implements TbXwZbfzxyrQgccjService {
if (StringUtils.isNotEmpty(thisObj.getZhfzxyrCyzjZjhm())) {
try {
TbFwXxdl xxdl = getXyrLbfXxdl(thisObj.getZhfzxyrXm(), thisObj.getZhfzxyrCyzjZjhm(), thisObj.getAsjbh());
TbXxfwXxdl xxdl = getXyrLbfXxdl(thisObj.getZhfzxyrXm(), thisObj.getZhfzxyrCyzjZjhm(), thisObj.getAsjbh());
if (xxdl != null) {
messageService.sendMessage(xxdl);
messageService.saveMessage(xxdl);
}
} catch (Exception e) {
e.printStackTrace();
......@@ -136,22 +137,21 @@ public class TbXwZbfzxyrServiceQgccjImpl implements TbXwZbfzxyrQgccjService {
return xxzjbh;
}
private TbFwXxdl getXyrLbfXxdl(String xm, String sfzh, String asjbh) {
private TbXxfwXxdl getXyrLbfXxdl(String xm, String sfzh, String asjbh) {
List<String> hnAsjbhList = hnJbAsjXsMapper.getAsjbhListZjhm(sfzh);
List<String> qgAsjbhList = qgJbAsjXsMapper.getAsjbhListZjhm(sfzh, hnAsjbhList);
hnAsjbhList.remove(asjbh);
qgAsjbhList.remove(asjbh);
if (hnAsjbhList.size() == 0 && qgAsjbhList.size() == 0) {
return null;
}
TbFwXxdl tbFwXxdl = new TbFwXxdl();
tbFwXxdl.setXxbt("新增嫌疑人录比反消息提醒");
tbFwXxdl.setXxlx("010000"); //录比反消息提醒
tbFwXxdl.setXxname("新增嫌疑人录比反消息提醒");
tbFwXxdl.setFsrName("系统");
tbFwXxdl.setSfydPdbz("0");
// if (hnAsjbhList.size() == 0 && qgAsjbhList.size() == 0) {
// return null;
// }
TbXxfwXxdl tbFwXxdl = new TbXxfwXxdl();
XzxtUser xzxtUser = SecureUtil.getUserXzxt();
tbFwXxdl.setJsrZjhm(xzxtUser.getIdentitycard());
tbFwXxdl.setXxbt("新增嫌疑人录比反消息提醒");
tbFwXxdl.setXxlx("010201"); //录比反消息提醒
tbFwXxdl.setLrridentitycard(xzxtUser.getIdentitycard());
tbFwXxdl.setGlxxid(asjbh);
tbFwXxdl.setXxyhidentitycard(xzxtUser.getIdentitycard());
String xxnr = "您在案件：" + asjbh + "中添加的嫌疑人：" + xm + "(" + sfzh + ")在全省还涉及" +
(hnAsjbhList.size()) + "起案件，" + "在全国还涉及" + (qgAsjbhList.size()) + "起案件。";
tbFwXxdl.setXxnr(xxnr);
......
src/main/java/org/springblade/founder/socketio/controller/MessageController.java
......@@ -2,7 +2,7 @@ package org.springblade.founder.socketio.controller;
import lombok.extern.slf4j.Slf4j;
import org.springblade.core.secure.utils.SecureUtil;
import org.springblade.founder.socketio.entity.TbFwXxdl;
import org.springblade.founder.socketio.entity.TbXxfwXxdl;
import org.springblade.founder.socketio.service.IMessageService;
import org.springblade.founder.utils.R;
import org.springblade.modules.system.entity.XzxtUser;
......@@ -26,35 +26,37 @@ public class MessageController {
private IMessageService messageService;
@RequestMapping("/sendMessage")
@ResponseBody
public String sendMessage(TbFwXxdl tbFwXxdl){
return messageService.sendMessage(tbFwXxdl);
}
@RequestMapping("/sendMassage")
@ResponseBody
public R sendMassage(TbXxfwXxdl tbXxfwXxdl){
try {
String result=messageService.saveMessage(tbXxfwXxdl);
return R.ok().data("result",result);
} catch (Exception e) {
e.printStackTrace();
return R.error(e.getMessage());
}
}
/**
* 获取最新30天内未读消息
* @param tbFwXxdl
* 获取消息列表
* @param tbXxfwXxdl
* @return
*/
@RequestMapping("/getXxList")
@ResponseBody
public R getXxList(TbFwXxdl tbFwXxdl){
public R getXxList(TbXxfwXxdl tbXxfwXxdl){
XzxtUser user = SecureUtil.getUserXzxt();
String page = tbFwXxdl.getPage();
String rows = tbFwXxdl.getRows();
// 开始行数
int begin = Integer.parseInt(rows) * (Integer.parseInt(page) - 1);
// 取几行
int end = Integer.parseInt(rows) * Integer.parseInt(page);
tbFwXxdl.setBegin(begin);
tbFwXxdl.setEnd(end);
tbFwXxdl.setJsrZjhm(user.getIdentitycard());
Integer page = tbXxfwXxdl.getPage();
Integer rows = tbXxfwXxdl.getRows();
page = (page - 1) * rows;
tbXxfwXxdl.setPage(page);
tbXxfwXxdl.setXxyhidentitycard(user.getIdentitycard());
// 获取最新消息30天内容 未读
List<TbFwXxdl> tbFwXxdls = messageService.getZxXxWdList(tbFwXxdl);
int count=messageService.getZxXxWdTotalCount(tbFwXxdl);
return R.ok().data("rows",tbFwXxdls).data("total",count);
List<TbXxfwXxdl> tbXxfwXxdls = messageService.getXxList(tbXxfwXxdl);
int count=messageService.getXxCount(tbXxfwXxdl);
return R.ok().data("rows",tbXxfwXxdls).data("total",count);
}
@RequestMapping("/updateXxzt")
......@@ -62,7 +64,7 @@ public class MessageController {
public R updateXxzt(String xxid){
try {
messageService.updateXxzt(xxid);
return R.ok().data("xxbh",xxid);
return R.ok().data("xxid",xxid);
} catch (Exception e) {
e.printStackTrace();
log.error("错误日志", e);
......@@ -72,11 +74,11 @@ public class MessageController {
@RequestMapping("/updateXxztAll")
@ResponseBody
public R updateXxztAll(TbFwXxdl tbFwXxdl){
public R updateXxztAll(TbXxfwXxdl tbXxfwXxdl){
try {
XzxtUser user = SecureUtil.getUserXzxt();
tbFwXxdl.setJsrZjhm(user.getIdentitycard());
int count = messageService.updateXxztAll(tbFwXxdl);
tbXxfwXxdl.setXxyhidentitycard(user.getIdentitycard());
int count = messageService.updateXxztAll(tbXxfwXxdl);
return R.ok().data("count",count);
} catch (Exception e) {
e.printStackTrace();
......
src/main/java/org/springblade/founder/socketio/dao/MessgeMapper.java 0 → 100644
package org.springblade.founder.socketio.dao;
import com.baomidou.dynamic.datasource.annotation.DS;
import org.apache.ibatis.annotations.Mapper;
import org.springblade.founder.socketio.entity.TbXxfwXxdl;
import org.springblade.modules.system.entity.SysNewUser;
import org.springframework.stereotype.Component;
import java.util.List;
@Component
@Mapper
public interface MessgeMapper {
@DS("xzxt_hn")
List<SysNewUser> getUsers(SysNewUser param);
@DS("db1")
int messageInsert(TbXxfwXxdl tbXxfwXxdl);
@DS("db1")
int getXxWdTotalCount(TbXxfwXxdl tbXxfwXxdl);
@DS("db1")
List<TbXxfwXxdl> getXxWdlList(TbXxfwXxdl tbXxfwXxdl);
@DS("db1")
int updateXxztById(String xxid);
@DS("db1")
int updateXxztAll(TbXxfwXxdl tbXxfwXxdl);
}
src/main/java/org/springblade/founder/socketio/dao/MessgeMapper.xml 0 → 100644
<?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="org.springblade.founder.socketio.dao.MessgeMapper">
<insert id="messageInsert">
insert into tb_xxfw_xxdl ( xxid
, asjbh
, fwbsh
, zjhm
, clpzh
, lxdh
, scbz
, lrr
, lrsj
, lrdwdm
, lrdwmc
, gxsj
, ip
, xxnr
, xxlx
, sfyd
, xxyhid
, xxyhjh
, xxyhdwdm
, xxyhdwmc
, xxbt
, glxxid
, xxxl
, lrridentitycard
, xxyhidentitycard
, xxyhxm
, gxr
, xxbh)
values ( #{ xxid , jdbcType=VARCHAR }
, #{ asjbh , jdbcType=VARCHAR }
, #{ fwbsh , jdbcType=VARCHAR }
, #{ zjhm , jdbcType=VARCHAR }
, #{ clpzh , jdbcType=VARCHAR }
, #{ lxdh , jdbcType=VARCHAR }
, '0'
, #{ lrr , jdbcType=VARCHAR }
, now()
, #{ lrdwdm , jdbcType=VARCHAR }
, #{ lrdwmc , jdbcType=VARCHAR }
, now()
, #{ ip , jdbcType=VARCHAR }
, #{ xxnr , jdbcType=VARCHAR }
, #{ xxlx , jdbcType=VARCHAR }
, #{ sfyd , jdbcType=VARCHAR }
, #{ xxyhid , jdbcType=VARCHAR }
, #{ xxyhjh , jdbcType=VARCHAR }
, #{ xxyhdwdm , jdbcType=VARCHAR }
, #{ xxyhdwmc , jdbcType=VARCHAR }
, #{ xxbt , jdbcType=VARCHAR }
, #{ glxxid , jdbcType=VARCHAR }
, #{ xxxl , jdbcType=VARCHAR }
, #{ lrridentitycard , jdbcType=VARCHAR }
, #{ xxyhidentitycard , jdbcType=VARCHAR }
, #{ xxyhxm , jdbcType=VARCHAR }
, #{ gxr , jdbcType=VARCHAR }
, #{ xxbh , jdbcType=VARCHAR })
</insert>
<update id="updateXxztById">
update tb_xxfw_xxdl
set sfyd = '1',
gxsj = now(),
gxr = xxyhxm
where xxid = #{xxid}
</update>
<update id="updateXxztAll">
update tb_xxfw_xxdl
set sfyd = '1',
gxsj = now(),
gxr = xxyhxm
where xxyhidentitycard = #{xxyhidentitycard}
and sfyd = '0'
</update>
<select id="getUsers" resultType="org.springblade.modules.system.entity.SysNewUser">
select
ID as id,
UNITCODE as unitcode,
USERNAME as username,
PASSWORD as password,
TRUE_NAME as trueName,
OPEN_FLAG as openFlag,
LRR as lrr,
LRSJ as lrsj,
GXR as gxr,
GXSJ as gxsj,
LRDWDM as lrdwdm,
LRDWMC as lrdwmc,
IDENTITYCARD as identitycard,
SEX as sex,
BIRTHDAY as birthday,
TELEPHONE as telephone,
UNITNAME as unitname,
SCBZ as scbz,
IP as ip,
GRADE as grade,
POLICEMANID as policemanid
from sys_user
where SCBZ = '0'
<if test="id != null and id != ''">AND ID = #{id , jdbcType=VARCHAR }</if>
<if test="unitcode != null and unitcode != ''">AND UNITCODE = #{unitcode , jdbcType=VARCHAR }</if>
<if test="username != null and username != ''">AND USERNAME = #{username , jdbcType=VARCHAR }</if>
<if test="password != null and password != ''">AND PASSWORD = #{password , jdbcType=VARCHAR }</if>
<if test="trueName != null and trueName != ''">AND TRUE_NAME = #{trueName , jdbcType=VARCHAR }</if>
<if test="identitycard != null and identitycard != ''">AND IDENTITYCARD = #{identitycard , jdbcType=VARCHAR }
</if>
<if test="sex != null and sex != ''">AND SEX = #{sex , jdbcType=VARCHAR }</if>
<if test="grade != null and grade != ''">AND GRADE = #{grade , jdbcType=VARCHAR }</if>
<if test="policemanid != null and policemanid != ''">AND POLICEMANID = #{policemanid , jdbcType=VARCHAR }</if>
</select>
<select id="getXxWdlList" resultType="org.springblade.founder.socketio.entity.TbXxfwXxdl">
select scbz,
lrr,
lrsj,
lrdwdm,
lrdwmc,
gxsj,
ip,
xxid,
xxnr,
(select name from sys_dictitem where groupid = 'CODE_XXLXXL' and code = xxlx) as xxlx,
sfyd,
xxyhid,
xxyhjh,
xxyhdwdm,
xxyhdwmc,
ydsj,
xxbt,
glxxid,
xxxl,
lrridentitycard,
xxyhidentitycard,
xxyhxm,
gxr,
xxbh,
asjbh,
fwbsh,
zjhm,
clpzh,
lxdh
from tb_xxfw_xxdl
where scbz = '0'
<if test="xxyhidentitycard != null and xxyhidentitycard != ''">
and xxyhidentitycard = #{xxyhidentitycard}
</if>
<if test="sfyd != null and sfyd != ''">
and sfyd = #{sfyd}
</if>
ORDER BY sfyd, lrsj DESC
limit #{page}, #{rows}
</select>
<select id="getXxWdTotalCount" resultType="java.lang.Integer">
select count(1) from tb_xxfw_xxdl
where scbz = '0'
<if test="xxyhidentitycard != null and xxyhidentitycard != ''">
and xxyhidentitycard = #{xxyhidentitycard}
</if>
<if test="sfyd != null and sfyd != ''">
and sfyd = #{sfyd}
</if>
</select>
</mapper>
src/main/java/org/springblade/founder/socketio/dao/NewsDao.java deleted 100644 → 0
package org.springblade.founder.socketio.dao;
import org.apache.ibatis.annotations.Mapper;
import org.springblade.founder.socketio.entity.TbFwXxdl;
import org.springblade.modules.system.entity.XzxtUser;
import org.springframework.stereotype.Component;
import java.util.List;
/**
*
* @author wangyang
* @date 2019/4/17
*/
@Component
@Mapper
public interface NewsDao {
//根据单位代码获取单位用户列表
List<XzxtUser> getUserListByUnitCode(String receiveUnitCode);
//消息入库
int insertNews(TbFwXxdl tbFwXxdl);
//获取最新30天内未读消息总条数
int getZxXxWdTotalCount(TbFwXxdl tbFwXxdl);
// 获取所有未读消息
List<TbFwXxdl> getXxWdlList(TbFwXxdl tbFwXxdl);
// 最新消息30天内所有未读消息
List<TbFwXxdl> getZxXxWdlList(TbFwXxdl tbFwXxdl);
// 根据消息id更新消息状态
int updateXxztById(String xxid);
// 更新全部未读消息
int updateXxztAll(TbFwXxdl tbFwXxdl);
}
src/main/java/org/springblade/founder/socketio/dao/UserDao.java deleted 100644 → 0
package org.springblade.founder.socketio.dao;
import org.apache.ibatis.annotations.Mapper;
import org.springblade.modules.system.entity.XzxtUser;
import org.springframework.stereotype.Repository;
@Mapper
@Repository
public interface UserDao {
XzxtUser queryUserBySfz(String fsrZjhm);
}
src/main/java/org/springblade/founder/socketio/dao/UserDao.xml deleted 100644 → 0
<?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="org.springblade.founder.socketio.dao.UserDao">
<select id="queryUserBySfz" resultType="org.springblade.modules.system.entity.XzxtUser">
select UNITCODE as unitcode,
TRUE_NAME as truename,
IDENTITYCARD as identitycard
from SYS_USER
where IDENTITYCARD = #{fsrZjhm}
and scbz = 0
</select>
</mapper>
src/main/java/org/springblade/founder/socketio/dao/newsDao.xml deleted 100644 → 0
<?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="org.springblade.founder.socketio.dao.NewsDao">
<!-- 根据单位代码查询本单位用户列表 -->
<select id="getUserListByUnitCode" parameterType="java.lang.String" resultType="org.springblade.modules.system.entity.XzxtUser">
SELECT * FROM SYS_USER WHERE unitcode=#{value} AND SCBZ='0' AND IDENTITYCARD IS NOT NULL
</select>
<!-- 新增 -->
<insert id="insertNews" parameterType="org.springblade.founder.socketio.entity.TbFwXxdl">
INSERT INTO TB_FW_XXDL (
XXID
,YWDX
,XXBT
,XXNR
,XXLX
,JSR_ZJHM
,FSR_ZJHM
,FSR_NAME
,FSSJ
,SFYD_PDBZ
,YDSJ
,SCSJ
,XXSC_PDBZ
,XXBH
,JSDW_DM
)
VALUES(
#{ xxid , jdbcType=VARCHAR }
,#{ ywdx , jdbcType=VARCHAR }
,#{ xxbt , jdbcType=VARCHAR }
,#{ xxnr , jdbcType=VARCHAR }
,#{ xxlx , jdbcType=VARCHAR }
,#{ jsrZjhm , jdbcType=VARCHAR }
,#{ fsrZjhm , jdbcType=VARCHAR }
,#{ fsrName , jdbcType=VARCHAR }
,sysdate
,'0'
,null
,null
,'0'
,#{ xxbh , jdbcType=VARCHAR }
,#{ jsdwDm , jdbcType=VARCHAR }
)
</insert>
<!-- 获取最新消息的列表（30天内未读消息） -->
<select id="getZxXxWdlList" parameterType="org.springblade.founder.socketio.entity.TbFwXxdl"
resultType="org.springblade.founder.socketio.entity.TbFwXxdl">
SELECT
*
FROM
(
SELECT
news.*, ROWNUM rn
FROM
(
SELECT
XXID as xxid,
ywdx as ywdx,
xxbt as xxbt,
xxnr as xxnr,
xxlx as xxlx,
(select name from SYS_DICTITEM where GROUPID='CODE_XXLXXL' and scbz = '0' and length(code)=6 and code=xxlx) as xxname,
jsr_zjhm as jsrZjhm,
fsr_zjhm as fsrZjhm,
fsr_name as fsrName,
to_char(fssj,'yyyy-MM-dd hh24:mi') as fssj,
sfyd_pdbz as sfydPdbz,
ydsj as ydsj,
xxbh as xxbh
from TB_FW_XXDL
where xxsc_pdbz = '0' and length(xxlx)=6
AND to_char(fssj,'YY/MM/DD') <![CDATA[>=]]> to_char(SYSDATE - 30,'YY/MM/DD')
AND sfyd_pdbz = '0'
<if test="jsrZjhm != null and jsrZjhm != ''">
and jsr_zjhm = #{jsrZjhm}
</if>
ORDER BY sfyd_pdbz , fssj DESC
) news
where ROWNUM <![CDATA[<=]]>
#{end}
) where rn > #{begin}
</select>
<!-- 获取最新消息的列表 ，根据消息类型 -->
<select id="getXxWdlList" parameterType="org.springblade.founder.socketio.entity.TbFwXxdl"
resultType="org.springblade.founder.socketio.entity.TbFwXxdl">
SELECT
*
FROM
(
SELECT
news.*, ROWNUM rn
FROM
(
select
XXID as xxid,
ywdx as ywdx,
xxbt as xxbt,
xxnr as xxnr,
xxlx as xxlx,
jsr_zjhm as jsrZjhm,
(select name from SYS_DICTITEM where GROUPID='CODE_XXLXXL' and scbz = '0' and length(code)=6 and code=xxlx) as xxname,
fsr_zjhm as fsrZjhm,
fsr_name as fsrName,
to_char(fssj,'yyyy-MM-dd hh24:mi') as fssj,
sfyd_pdbz as sfydPdbz,
ydsj as ydsj,
xxbh as xxbh
from TB_FW_XXDL
where xxsc_pdbz = '0' and length(xxlx)=6
<if test="qryType != null and qryType == '0'.toString()">
AND xxlx like '0801%'
</if>
<if test="qryType != null and qryType == '1'.toString()">
AND xxlx like '0802%'
</if>
<if test="qryType != null and qryType == '2'.toString()">
AND xxlx like '0803%'
</if>
<if test="jsrZjhm != null and jsrZjhm != ''">
and jsr_zjhm = #{jsrZjhm}
</if>
<if test="sfydPdbz != null and sfydPdbz != ''">
and sfyd_pdbz = #{sfydPdbz}
</if>
ORDER BY fssj DESC
) news
where ROWNUM <![CDATA[<=]]>
#{end}
) where rn > #{begin}
</select>
<!-- 获取最新30天内消息未读数 -->
<select id="getZxXxWdTotalCount" parameterType="org.springblade.founder.socketio.entity.TbFwXxdl"
resultType="java.lang.Integer">
select count(*)
from TB_FW_XXDL t
where xxsc_pdbz = '0' and
length(xxlx)=6
<if test="jsrZjhm != null and jsrZjhm != ''">
AND jsr_zjhm = #{jsrZjhm}
</if>
<if test="sfydPdbz != null and sfydPdbz != ''">
and sfyd_pdbz = #{sfydPdbz}
</if>
</select>
<update id="updateXxztById">
update TB_FW_XXDL set SFYD_PDBZ = '1' where XXID = #{xxid ,jdbcType=VARCHAR}
</update>
<update id="updateXxztAll">
update TB_FW_XXDL set SFYD_PDBZ = '1'
where xxsc_pdbz = '0' and
length(xxlx)=6
<if test="jsrZjhm != null and jsrZjhm != ''">
AND jsr_zjhm = #{jsrZjhm}
</if>
AND sfyd_pdbz = '0'
</update>
</mapper>
src/main/java/org/springblade/founder/socketio/entity/TbXxfwXxdl.java 0 → 100644
package org.springblade.founder.socketio.entity;
import lombok.Data;
import java.io.Serializable;
import java.util.Date;
@Data
public class TbXxfwXxdl implements Serializable {
//案事件编号
private String asjbh;
//录比反服务标识号
private String fwbsh;
//录比反人员证件号码
private String zjhm;
//录比反车辆牌照号码
private String clpzh;
//录比反物品联系电话
private String lxdh;
//删除标志
private String scbz;
//录入人
private String lrr;
//录入时间
private Date lrsj;
//录入单位代码
private String lrdwdm;
//录入单位名称
private String lrdwmc;
//改写时间
private Date gxsj;
//ip地址
private String ip;
//消息ID
private String xxid;
//消息内容
private String xxnr;
//消息类型(预警消息、工作提示消息、采比反消息等)
private String xxlx;
//是否已读(0:未读1:已读)
private String sfyd;
//消息用户ID
private String xxyhid;
//消息用户警号
private String xxyhjh;
//消息用户单位代码
private String xxyhdwdm;
//消息单位单位名称
private String xxyhdwmc;
//已读时间
private Date ydsj;
//信息标题(采比反信息存案件编号)
private String xxbt;
//消息由案件产生，则添加对应的案件编号，如果消息由人员产生，则添加对应的人员编号.
private String glxxid;
//消息细类，用以区分消息详细内容，采用code码
private String xxxl;
//录入人身份证号码
private String lrridentitycard;
//消息用户身份证号码
private String xxyhidentitycard;
//消息用户姓名
private String xxyhxm;
//更新人
private String gxr;
//消息编号（同一次录入的消息）
private String xxbh;
//消息类型名称
private String xxlxstr;
private Integer page = 1;
private Integer rows = 5;
}
src/main/java/org/springblade/founder/socketio/service/IMessageService.java
package org.springblade.founder.socketio.service;
import org.springblade.founder.socketio.entity.TbFwXxdl;
import org.springblade.founder.socketio.entity.TbXxfwXxdl;
import org.springblade.founder.socketio.entity.TbXxfwXxdl;
import java.util.List;
......@@ -11,18 +12,16 @@ import java.util.List;
* @date 2019/4/20
*/
public interface IMessageService {
//写消息到消息队列
String sendMessage(TbFwXxdl tbFwXxdl);
//消息队列信息最新消息未读数 1、查询最新消息未读数 2、查询最新消息未读数(案件编号)
int getZxXxWdTotalCount(TbFwXxdl tbFwXxdl);
//获取最新未读消息信息列表
List<TbFwXxdl> getZxXxWdList(TbFwXxdl tbFwXxdl);
//获取消息信息列表
List<TbXxfwXxdl> getXxList(TbXxfwXxdl tbXxfwXxdl);
//更新消息
int updateXxzt(String xxid);
int updateXxztAll(TbFwXxdl tbFwXxdl);
int updateXxztAll(TbXxfwXxdl tbXxfwXxdl);
int getWdxxCount();
void addMessage(String xxbt, String xxlx, String xxnr, String jsdwdm, String jsrZjhm);
String saveMessage(TbXxfwXxdl tbXxfwXxdl) throws Exception;
int getXxCount(TbXxfwXxdl tbXxfwXxdl);
}
src/main/java/org/springblade/founder/socketio/service/impl/MessageServiceImpl.java
package org.springblade.founder.socketio.service.impl;
import com.alibaba.druid.util.StringUtils;
import com.baomidou.dynamic.datasource.annotation.DS;
import org.springblade.core.secure.utils.SecureUtil;
import org.springblade.founder.socketio.dao.NewsDao;
import org.springblade.founder.socketio.dao.UserDao;
import org.springblade.founder.socketio.entity.TbFwXxdl;
import org.springblade.founder.socketio.dao.MessgeMapper;
import org.springblade.founder.socketio.entity.TbXxfwXxdl;
import org.springblade.founder.socketio.service.IMessageService;
import org.springblade.founder.utils.SysXxzjbhService;
import org.springblade.modules.system.entity.SysNewUser;
import org.springblade.modules.system.entity.XzxtUser;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.Arrays;
import java.util.HashSet;
import java.util.List;
import java.util.UUID;
import java.util.*;
/**
......@@ -22,167 +20,129 @@ import java.util.UUID;
* @date 2019/4/20
*/
@Service
@DS("db1")
public class MessageServiceImpl implements IMessageService {
@Autowired
private NewsDao newsDao;
@Autowired
private UserDao userDao;
@Override
public String sendMessage(TbFwXxdl tbFwXxdl) {
if (!StringUtils.isEmpty(tbFwXxdl.getJsdwDm()) && !StringUtils.isEmpty(tbFwXxdl.getJsrZjhm()) ){
return "发送消息失败，接收人、接收单位不能同时存在！";
}
if (StringUtils.isEmpty(tbFwXxdl.getFsrZjhm()) && StringUtils.isEmpty(tbFwXxdl.getFsrName())){
return "发送消息失败，发送人信息不能为空！";
}
if (StringUtils.isEmpty(tbFwXxdl.getXxbt())){
return "发送消息失败，消息标题不能为空！";
}
if (StringUtils.isEmpty(tbFwXxdl.getXxlx())){
return "发送消息失败，消息类型不能为空！";
}
if (StringUtils.isEmpty(tbFwXxdl.getXxnr())){
return "发送消息失败，消息内容不能为空！";
}
if (StringUtils.isEmpty(tbFwXxdl.getJsrZjhm())&& StringUtils.isEmpty(tbFwXxdl.getJsdwDm())){
return "发送消息失败，接收者信息不能为空！";
}
//消息编号
tbFwXxdl.setXxbh(UUID.randomUUID().toString().replace("-", ""));
// 存放接收者身份证号
HashSet<String> idCadeList = new HashSet<String>();
if (tbFwXxdl.getJsrZjhm() != null){
String idCard =tbFwXxdl.getJsrZjhm();
if(idCard.contains(",")){
idCadeList.addAll(Arrays.asList(idCard.split(",")));
}else {
idCadeList.add(idCard);
}
}
// 接收单位
String receiveUnitCode = tbFwXxdl.getJsdwDm();
// 消息发送给指定单位 接收单位处理start
if (!"".equals(receiveUnitCode) && receiveUnitCode != null) {
// 根据单位代码获取单位用户列表
List<XzxtUser> unitUsers = newsDao.getUserListByUnitCode(receiveUnitCode);
if (unitUsers != null && unitUsers.size() > 0) {
for (XzxtUser u : unitUsers) {
if (!idCadeList.contains(u.getIdentitycard())) {
// 指定单位下所有用户也放入list
idCadeList.add(u.getIdentitycard());
}
}
}
}
// 消息接收单位处理end
XzxtUser user = null;
String fsrZjhm = tbFwXxdl.getFsrZjhm();
String fsrName = tbFwXxdl.getFsrName();
// 通过消息发送人身份证号码获取发送人信息
if (fsrName == null || "".equals(fsrName)) {
user = userDao.queryUserBySfz(fsrZjhm);
if (user == null) {
return "发送消息失败，发送人信息不存在！";
}
//发送人姓名
fsrName = user.getRealname() == null ? user.getRealname() : user.getRealname().trim();
}
String result = "";
if (idCadeList != null && idCadeList.size() > 0) {
for (String idCade : idCadeList) {
TbFwXxdl insertNews = new TbFwXxdl();
insertNews.setJsrZjhm(idCade);
//消息编号
insertNews.setXxbh(tbFwXxdl.getXxbh());
//发送人姓名
insertNews.setFsrName(fsrName);
//接收单位代码
if (tbFwXxdl.getJsdwDm()!=null){
insertNews.setJsdwDm(tbFwXxdl.getJsdwDm());
}
//发送人证件号码
insertNews.setFsrZjhm(tbFwXxdl.getFsrZjhm());
insertNews.setXxbt(tbFwXxdl.getXxbt());
insertNews.setXxlx(tbFwXxdl.getXxlx());
insertNews.setXxname(tbFwXxdl.getXxname());
insertNews.setXxnr(tbFwXxdl.getXxnr());
insertNews.setYwdx(tbFwXxdl.getYwdx());
insertNews.setSfydPdbz("0");
//设置消息ID
insertNews.setXxid(UUID.randomUUID().toString().replace("-", ""));
// 根据身份证号码获取用户信息
XzxtUser jsr = userDao.queryUserBySfz(insertNews.getJsrZjhm());
if (jsr != null) {
int flag = newsDao.insertNews(insertNews);
if (flag == 1) {
/* insertNews.setXxbt("您有一条新消息！");
// 推送消息
Socketio.sendMessage(insertNews);*/
} else {
return "发送消息失败，消息队列信息新增出错";
}
} else {
return "发送消息失败，接收人信息不存在！";
}
}
result = tbFwXxdl.getXxbh();
}
return result;
}
@Override
public int getZxXxWdTotalCount(TbFwXxdl tbFwXxdl) {
return newsDao.getZxXxWdTotalCount(tbFwXxdl);
}
@Override
public List<TbFwXxdl> getZxXxWdList(TbFwXxdl tbFwXxdl) {
return newsDao.getXxWdlList(tbFwXxdl);
}
@Autowired
private MessgeMapper messgeMapper;
@Autowired
private SysXxzjbhService xxzjbhService;
@Override
public int updateXxzt(String xxid) {
return newsDao.updateXxztById(xxid);
return messgeMapper.updateXxztById(xxid);
}
@Override
public int updateXxztAll(TbFwXxdl tbFwXxdl) {
return newsDao.updateXxztAll(tbFwXxdl);
public int updateXxztAll(TbXxfwXxdl tbXxfwXxdl) {
return messgeMapper.updateXxztAll(tbXxfwXxdl);
}
@Override
public List<TbXxfwXxdl> getXxList(TbXxfwXxdl tbXxfwXxdl) {
return messgeMapper.getXxWdlList(tbXxfwXxdl);
}
@Override
public int getWdxxCount() {
TbFwXxdl tbFwXxdl = new TbFwXxdl();
TbXxfwXxdl tbXxfwXxdl = new TbXxfwXxdl();
XzxtUser user = SecureUtil.getUserXzxt();
tbFwXxdl.setJsrZjhm(user.getIdentitycard());
tbFwXxdl.setSfydPdbz("0");
return newsDao.getZxXxWdTotalCount(tbFwXxdl);
tbXxfwXxdl.setXxyhidentitycard(user.getIdentitycard());
tbXxfwXxdl.setSfyd("0");
return messgeMapper.getXxWdTotalCount(tbXxfwXxdl);
}
@Override
public void addMessage(String xxbt, String xxlx, String xxnr, String jsdwdm, String jsrZjhm) {
@Override
public String saveMessage(TbXxfwXxdl tbXxfwXxdl) throws Exception {
String result = "";
String jsrZjhm = tbXxfwXxdl.getXxyhidentitycard();
String jsrDwdm = tbXxfwXxdl.getXxyhdwdm();
String lrrZjhm = tbXxfwXxdl.getLrridentitycard();
SysNewUser user = null;
Date date = new Date();
Set<String> userIdList=new HashSet<>();
// 将指定的接收方插入消息队列
userIdList.add(jsrZjhm);
// 消息发送给指定单位 接收单位处理start
if (!"".equals(jsrDwdm) && jsrDwdm != null) {// 接收单位
// 根据单位代码获取单位用户列表
SysNewUser param=new SysNewUser();
param.setUnitcode(jsrDwdm);
List<SysNewUser> unitUsers = messgeMapper.getUsers(param);
if (unitUsers != null && unitUsers.size() > 0) {
for (SysNewUser u : unitUsers) {
if (!userIdList.contains(u.getIdentitycard())) {
userIdList.add(u.getIdentitycard());// 指定单位下所有用户也放入list
// 去重处理
}
}
}
}
// 消息接收单位处理end
// 通过录入人身份证号码获取录入人信息
if (lrrZjhm != null && !"".equals(lrrZjhm)) {
SysNewUser param=new SysNewUser();
param.setIdentitycard(lrrZjhm);
List<SysNewUser> list = messgeMapper.getUsers(param);
if(list != null && list.size() > 0 ){
user=list.get(0);
}
else{
throw new Exception("发送消息失败，录入人信息不存在！");
}
}else{
throw new Exception("发送消息失败，录入人信息不能为空！");
}
// ① 处理过后的用户结果集跟指定接收人比较 若包含 则将结果集用户依次存入消息对象tbXxfwXxdl中
int flag = -1;
if (userIdList != null && userIdList.size() > 0 && user != null) {
String lrrxm = user.getTrueName() == null ? user.getTrueName() : user.getTrueName().trim();
String lrdwdm = user.getUnitcode() == null ? user.getUnitcode() : user.getUnitcode().trim();
String lrdwmc = user.getUnitname() == null ? user.getUnitname() : user.getUnitname().trim();
String lrrIdentitycard = user.getIdentitycard() == null ? user.getIdentitycard() : user.getIdentitycard().trim();
// 消息编号，每次录入消息多条消息对应一个消息编号
String xxbh = xxzjbhService.getZcxwYwbh(lrdwdm,null,"TB_XXFW_XXDL","X");
tbXxfwXxdl.setLrr(lrrxm);// 录入人人姓名
tbXxfwXxdl.setLrdwdm(lrdwdm);// 录入人单位
tbXxfwXxdl.setLrdwmc(lrdwmc);// 录入人单位名称
tbXxfwXxdl.setLrridentitycard(lrrIdentitycard);// 录入人身份证号码
tbXxfwXxdl.setSfyd("0");
try {
for (String idCade : userIdList) {
// 根据身份证号码获取用户信息
SysNewUser param=new SysNewUser();
param.setIdentitycard(idCade);
List<SysNewUser> jsrs = messgeMapper.getUsers(param);
SysNewUser jsr = null;
if(jsrs!=null&&jsrs.size()>0){
jsr=jsrs.get(0);
}
if (jsr != null) {
// 消息主键
tbXxfwXxdl.setXxid(xxzjbhService.getZcxwYwbh(lrdwdm,null,"tb_xxfw_xxdl","X"));// 消息ID，主键
tbXxfwXxdl.setXxyhjh(jsr.getPolicemanid());// 接收人警号
tbXxfwXxdl.setXxyhdwdm(jsr.getUnitcode());// 接收单位代码
tbXxfwXxdl.setXxyhxm(jsr.getTrueName());// 接收人姓名
tbXxfwXxdl.setXxyhdwmc(jsr.getUnitname());// 接收单位名称
tbXxfwXxdl.setXxyhidentitycard(idCade);// 身份证号码
tbXxfwXxdl.setXxbh(xxbh);// 消息编号
flag = messgeMapper.messageInsert(tbXxfwXxdl);//返回消息id
} else {
throw new Exception("发送消息失败，接收人信息不存在！");
}
}
result = xxbh;
} catch (Exception e) {
e.printStackTrace();
throw new Exception("系统异常，发送消息失败！");
}
}
return result;
}
@Override
public int getXxCount(TbXxfwXxdl tbXxfwXxdl) {
XzxtUser user = SecureUtil.getUserXzxt();
String fsrName = user.getRealname();
String fsrZjhm = user.getIdentitycard();
TbFwXxdl tbFwXxdl = new TbFwXxdl();
tbFwXxdl.setXxbt(xxbt);
tbFwXxdl.setXxlx(xxlx);
tbFwXxdl.setXxname(xxbt);
tbFwXxdl.setXxnr(xxnr);
tbFwXxdl.setYwdx("xs");
tbFwXxdl.setFsrName(fsrName);
tbFwXxdl.setFsrZjhm(fsrZjhm);
tbFwXxdl.setSfydPdbz("0");
tbFwXxdl.setJsdwDm(jsdwdm);
tbFwXxdl.setJsrZjhm(jsrZjhm);
sendMessage(tbFwXxdl);
}
tbXxfwXxdl.setXxyhidentitycard(user.getIdentitycard());
return messgeMapper.getXxWdTotalCount(tbXxfwXxdl);
}
}
src/main/java/org/springblade/founder/xcxx/controller/TbStAppWzxxController.java 0 → 100644
package org.springblade.founder.xcxx.controller;
import org.springblade.founder.utils.R;
import org.springblade.founder.xcxx.entity.TbStAppWzxx;
import org.springblade.founder.xcxx.service.TbStAppWzxxService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.Map;
@RestController
@RequestMapping("/wzxx")
public class TbStAppWzxxController {
@Autowired
private TbStAppWzxxService tbStAppWzxxService;
@PostMapping("/saveNewWzxx")
public R saveNewWzxx(TbStAppWzxx wzxx){
try {
String xxzjbh = tbStAppWzxxService.saveNewWzxx(wzxx);
return R.ok().data("xxzjbh", xxzjbh);
} catch (Exception e){
e.printStackTrace();
return R.error(e.getMessage());
}
}
@PostMapping("/updateWzxx")
public R updateWzxx(TbStAppWzxx wzxx){
try {
String xxzjbh = tbStAppWzxxService.updateWzxx(wzxx);
return R.ok().data("xxzjbh", xxzjbh);
} catch (Exception e){
e.printStackTrace();
return R.error(e.getMessage());
}
}
@PostMapping("/deleteWzxx")
public R deleteWzxx(String xxzjbh){
try {
tbStAppWzxxService.deleteWzxx(xxzjbh);
return R.ok().data("xxzjbh", xxzjbh);
} catch (Exception e){
e.printStackTrace();
return R.error(e.getMessage());
}
}
@PostMapping("/selectList")
public R selectList(TbStAppWzxx wzxx){
try {
Map<String, Object> resultMap = tbStAppWzxxService.selectList(wzxx);
return R.ok().data(resultMap);
} catch (Exception e){
e.printStackTrace();
return R.error(e.getMessage());
}
}
}
src/main/java/org/springblade/founder/xcxx/entity/TbStAppWzxx.java 0 → 100644
package org.springblade.founder.xcxx.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
import lombok.EqualsAndHashCode;
import org.springblade.founder.entity.BaseModel;
import org.springframework.format.annotation.DateTimeFormat;
import java.util.Date;
@Data
@EqualsAndHashCode(callSuper = true)
@TableName("TB_ST_APP_WZXX")
public class TbStAppWzxx extends BaseModel {
@TableId(type = IdType.INPUT)
private String xxzjbh;
//位置类型 CODE_WZLXDM
private String wzlx;
@TableField(exist = false)
private String wzlxStr;
//位置经度
private Double wzjd;
@TableField(exist = false)
private Double wzjdStart;
@TableField(exist = false)
private Double wzjdEnd;
//位置纬度
private Double wzwd;
@TableField(exist = false)
private Double wzwdStart;
@TableField(exist = false)
private Double wzwdEnd;
//位置描述
private String wzms;
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date xxrbksj;
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date xxrsksj;
private String xxrskPdbz;
private String xxrbkPdbz;
}
src/main/java/org/springblade/founder/xcxx/mapper/TbStAppWzxxMapper.java 0 → 100644
package org.springblade.founder.xcxx.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
import org.springblade.founder.xcxx.entity.TbStAppWzxx;
import org.springframework.stereotype.Repository;
import java.util.List;
@Mapper
@Repository
public interface TbStAppWzxxMapper extends BaseMapper<TbStAppWzxx> {
List<TbStAppWzxx> selectListByParam(TbStAppWzxx wzxx);
Integer selectCountByParam(TbStAppWzxx wzxx);
}
src/main/java/org/springblade/founder/xcxx/mapper/TbStAppWzxxMapper.xml 0 → 100644
<?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="org.springblade.founder.xcxx.mapper.TbStAppWzxxMapper">
<select id="selectListByParam" resultType="org.springblade.founder.xcxx.entity.TbStAppWzxx">
select *
from (select rownum r, t.*
from (
SELECT
<include refid="selectField"/>
FROM TB_ST_APP_WZXX
where XXSC_PDBZ = '0'
<include refid="selectParam"/>
order by djsj desc
) t
where rownum <![CDATA[ <= ]]> #{end})
where r <![CDATA[ > ]]> #{begin}
</select>
<select id="selectCountByParam" resultType="java.lang.Integer">
select count(1)
from TB_ST_APP_WZXX
where XXSC_PDBZ = '0'
<include refid="selectParam"/>
</select>
<sql id="selectField">
XXZJBH,
WZLX,
(select name from SYS_DICTITEM where GROUPID = 'CODE_WZLXDM' and code = WZLX) as wzlxStr,
WZJD,
WZWD,
WZMS,
XXSC_PDBZ,
XXRBK_PDBZ,
XXRSK_PDBZ,
XXRBKSJ,
XXRSKSJ,
XXLYMS,
GXSJ,
XXCZRY_GMSFHM,
XXCZRY_XM,
XXCZDW_GAJGMC,
XXCZDW_GAJGJGDM,
XXDJRY_LXDH,
XXDJRY_GMSFHM,
XXDJRY_XM,
XXDJDW_GAJGMC,
XXDJDW_GAJGJGDM,
DJSJ
</sql>
<sql id="selectParam">
<if test="xxzjbh != null and xxzjbh != ''">
AND XXZJBH = #{xxzjbh , jdbcType=VARCHAR }
</if>
<if test="wzlx != null and wzlx != ''">
AND WZLX = #{wzlx , jdbcType=VARCHAR }
</if>
<if test="wzjdStart != null">
AND WZJD <![CDATA[ >= ]]> #{wzjdStart , jdbcType=INTEGER }
</if>
<if test="wzjdEnd != null">
AND WZJD <![CDATA[ <= ]]> #{wzjdEnd , jdbcType=INTEGER }
</if>
<if test="wzwdStart != null">
AND WZWD <![CDATA[ >= ]]> #{wzwdStart , jdbcType=INTEGER }
</if>
<if test="wzwdEnd != null">
AND WZWD <![CDATA[ <= ]]> #{wzwdEnd , jdbcType=INTEGER }
</if>
<if test="wzms != null and wzms != ''">
AND WZMS = #{wzms , jdbcType=VARCHAR }
</if>
<if test="xxscPdbz != null and xxscPdbz != ''">
AND XXSC_PDBZ = #{xxscPdbz , jdbcType=VARCHAR }
</if>
<if test="xxrbkPdbz != null and xxrbkPdbz != ''">
AND XXRBK_PDBZ = #{xxrbkPdbz , jdbcType=VARCHAR }
</if>
<if test="xxrskPdbz != null and xxrskPdbz != ''">
AND XXRSK_PDBZ = #{xxrskPdbz , jdbcType=VARCHAR }
</if>
<if test="xxrbksj != null">
AND XXRBKSJ = #{xxrbksj , jdbcType=TIMESTAMP }
</if>
<if test="xxrsksj != null">
AND XXRSKSJ = #{xxrsksj , jdbcType=TIMESTAMP }
</if>
<if test="xxlyms != null and xxlyms != ''">
AND XXLYMS = #{xxlyms , jdbcType=VARCHAR }
</if>
<if test="gxsj != null">
AND GXSJ = #{gxsj , jdbcType=TIMESTAMP }
</if>
<if test="xxczryGmsfhm != null and xxczryGmsfhm != ''">
AND XXCZRY_GMSFHM = #{xxczryGmsfhm , jdbcType=VARCHAR }
</if>
<if test="xxczryXm != null and xxczryXm != ''">
AND XXCZRY_XM = #{xxczryXm , jdbcType=VARCHAR }
</if>
<if test="xxczdwGajgmc != null and xxczdwGajgmc != ''">
AND XXCZDW_GAJGMC = #{xxczdwGajgmc , jdbcType=VARCHAR }
</if>
<if test="xxczdwGajgjgdm != null and xxczdwGajgjgdm != ''">
AND XXCZDW_GAJGJGDM = #{xxczdwGajgjgdm , jdbcType=VARCHAR }
</if>
<if test="xxdjryLxdh != null and xxdjryLxdh != ''">
AND XXDJRY_LXDH = #{xxdjryLxdh , jdbcType=VARCHAR }
</if>
<if test="xxdjryGmsfhm != null and xxdjryGmsfhm != ''">
AND XXDJRY_GMSFHM = #{xxdjryGmsfhm , jdbcType=VARCHAR }
</if>
<if test="xxdjryXm != null and xxdjryXm != ''">
AND XXDJRY_XM = #{xxdjryXm , jdbcType=VARCHAR }
</if>
<if test="xxdjdwGajgmc != null and xxdjdwGajgmc != ''">
AND XXDJDW_GAJGMC = #{xxdjdwGajgmc , jdbcType=VARCHAR }
</if>
<if test="xxdjdwGajgjgdm != null and xxdjdwGajgjgdm != ''">
AND XXDJDW_GAJGJGDM = #{xxdjdwGajgjgdm , jdbcType=VARCHAR }
</if>
<if test="djsj != null">
AND DJSJ = #{djsj , jdbcType=TIMESTAMP }
</if>
</sql>
</mapper>
src/main/java/org/springblade/founder/xcxx/service/TbStAppWzxxService.java 0 → 100644
package org.springblade.founder.xcxx.service;
import org.springblade.founder.xcxx.entity.TbStAppWzxx;
import java.util.Map;
public interface TbStAppWzxxService {
/**
* saveNewWzxx 新增位置信息
* @return java.lang.String
* @author lystar
* 2021/12/2 14:38
*/
String saveNewWzxx(TbStAppWzxx wzxx);
/**
* deleteWzxx 删除位置信息
* @param xxzjbh: 信息主键编号
* @author lystar
* 2021/12/2 14:56
*/
void deleteWzxx(String xxzjbh);
/**
* selectList 查询列表
* @return java.util.Map<java.lang.String,java.lang.Object>
* @author lystar
* 2021/12/2 15:00
*/
Map<String, Object> selectList(TbStAppWzxx wzxx);
/**
* updateWzxx 修改位置信息
* @return java.lang.String
* @author lystar
* 2021/12/2 15:44
*/
String updateWzxx(TbStAppWzxx wzxx);
}
src/main/java/org/springblade/founder/xcxx/service/impl/TbStAppWzxxServiceImpl.java 0 → 100644
package org.springblade.founder.xcxx.service.impl;
import com.baomidou.dynamic.datasource.annotation.DS;
import org.springblade.core.secure.utils.SecureUtil;
import org.springblade.founder.utils.SysXxzjbhService;
import org.springblade.founder.utils.Utils;
import org.springblade.founder.xcxx.entity.TbStAppWzxx;
import org.springblade.founder.xcxx.mapper.TbStAppWzxxMapper;
import org.springblade.founder.xcxx.service.TbStAppWzxxService;
import org.springblade.modules.system.entity.XzxtUser;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@Service
@DS("xzxt_hn")
public class TbStAppWzxxServiceImpl implements TbStAppWzxxService {
@Autowired
private TbStAppWzxxMapper tbStAppWzxxMapper;
@Autowired
private SysXxzjbhService xxzjbhService;
@Override
public String saveNewWzxx(TbStAppWzxx wzxx) {
XzxtUser xzxtUser = SecureUtil.getUserXzxt();
String xxzjbh = xxzjbhService.getXxzjbh(xzxtUser.getUnitcode());
wzxx.setXxzjbh(xxzjbh);
Utils.setUserDjxxAndCzxx(wzxx);
tbStAppWzxxMapper.insert(wzxx);
return xxzjbh;
}
@Override
public void deleteWzxx(String xxzjbh) {
TbStAppWzxx wzxx = new TbStAppWzxx();
wzxx.setXxzjbh(xxzjbh);
wzxx.setXxscPdbz("1");
Utils.setUserCzxx(wzxx);
tbStAppWzxxMapper.updateById(wzxx);
}
@Override
public Map<String, Object> selectList(TbStAppWzxx wzxx) {
Utils.setPageParams(wzxx);
List<TbStAppWzxx> rows = tbStAppWzxxMapper.selectListByParam(wzxx);
Integer total = tbStAppWzxxMapper.selectCountByParam(wzxx);
HashMap<String, Object> resultMap = new HashMap<>();
resultMap.put("rows", rows);
resultMap.put("total", total);
return resultMap;
}
@Override
public String updateWzxx(TbStAppWzxx wzxx) {
Utils.setUserCzxx(wzxx);
tbStAppWzxxMapper.updateById(wzxx);
return wzxx.getXxzjbh();
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment