|
@@ -7,10 +7,13 @@ import cn.hutool.json.JSONArray;
|
|
import cn.hutool.json.JSONObject;
|
|
import cn.hutool.json.JSONObject;
|
|
import cn.hutool.json.JSONUtil;
|
|
import cn.hutool.json.JSONUtil;
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
|
-import com.ruoyi.framework.websocket.WebSocketServer;
|
|
|
|
|
|
+import com.ruoyi.common.core.domain.entity.SysDept;
|
|
|
|
+import com.ruoyi.common.utils.FindsDepartsChildrenUtil;
|
|
import com.ruoyi.system.service.ISysDeptService;
|
|
import com.ruoyi.system.service.ISysDeptService;
|
|
import com.ruoyi.system.service.ISysDictTypeService;
|
|
import com.ruoyi.system.service.ISysDictTypeService;
|
|
import com.ruoyi.system.service.ISysUserService;
|
|
import com.ruoyi.system.service.ISysUserService;
|
|
|
|
+import com.ruoyi.zhdd.domain.GatewayDept;
|
|
|
|
+import com.ruoyi.zhdd.domain.GatewaySUser;
|
|
import com.ruoyi.zhdd.domain.SingleDevice;
|
|
import com.ruoyi.zhdd.domain.SingleDevice;
|
|
import com.ruoyi.zhdd.domain.bo.SingleDeviceBo;
|
|
import com.ruoyi.zhdd.domain.bo.SingleDeviceBo;
|
|
import com.ruoyi.zhdd.service.ISingleDeviceService;
|
|
import com.ruoyi.zhdd.service.ISingleDeviceService;
|
|
@@ -35,165 +38,136 @@ public class SysGatewayUserTask {
|
|
@Autowired
|
|
@Autowired
|
|
private ISysDictTypeService sysDictTypeService;
|
|
private ISysDictTypeService sysDictTypeService;
|
|
|
|
|
|
- @Autowired
|
|
|
|
- private WebSocketServer webSocketServer;
|
|
|
|
-
|
|
|
|
- /*@KafkaListener(topics = "t_uc_user")
|
|
|
|
- public void onUserMessage(String message) {
|
|
|
|
- log.info("kafka用户信息消费:{}", message);
|
|
|
|
- try {
|
|
|
|
- GatewaySUser gatewaySUser = JSONUtil.toBean(message, GatewaySUser.class);
|
|
|
|
- if (gatewaySUser != null) {
|
|
|
|
- SysUser quser = new SysUser();
|
|
|
|
- quser.setUserId(gatewaySUser.getUserId());
|
|
|
|
- List<SysUser> userList = userService.selectUserList(quser);
|
|
|
|
- if (userList.isEmpty()) {
|
|
|
|
- //插入
|
|
|
|
- SysUser user = new SysUser();
|
|
|
|
- user.setUserId(gatewaySUser.getUserId());
|
|
|
|
- *//*{
|
|
|
|
- SysDept qdept = new SysDept();
|
|
|
|
- qdept.setOtherId(gatewaySUser.getDeptId());
|
|
|
|
- List<SysDept> deptList = deptService.selectDeptList(qdept);
|
|
|
|
- if (!deptList.isEmpty()) {
|
|
|
|
- user.setDeptId(deptList.get(0).getDeptId());
|
|
|
|
- } else {
|
|
|
|
- //还未有部门暂不设置 //需要先同步部门
|
|
|
|
- }
|
|
|
|
- }*//*
|
|
|
|
- user.setPhonenumber(gatewaySUser.getMobile());
|
|
|
|
- user.setNickName(gatewaySUser.getName());
|
|
|
|
- user.setUserName(gatewaySUser.getUserName());
|
|
|
|
- user.setDeptId(gatewaySUser.getDeptId());
|
|
|
|
- user.setUserType(Convert.toStr(gatewaySUser.getUserGroupId()));
|
|
|
|
- user.setUpdateBy("kafka");
|
|
|
|
- user.setUpdateTime(new Date());
|
|
|
|
- user.setCreateBy("kafka");
|
|
|
|
- user.setCreateTime(new Date());
|
|
|
|
- user.setSex(gatewaySUser.getSex());
|
|
|
|
- user.setOrgId(gatewaySUser.getOrgId());
|
|
|
|
- user.setSuperior(gatewaySUser.getSuperior());
|
|
|
|
- user.setIdNumber(gatewaySUser.getIdNumber());
|
|
|
|
- user.setPassword(SecurityUtils.encryptPassword("tocc!suqian"));
|
|
|
|
- user.setStatus(gatewaySUser.getStatus());
|
|
|
|
- user.setDelFlag(gatewaySUser.getDelFlag());
|
|
|
|
- userService.insertUser(user);
|
|
|
|
- } else {
|
|
|
|
- //更新
|
|
|
|
- SysUser user = userList.get(0);
|
|
|
|
- *//*{
|
|
|
|
- SysDept qdept = new SysDept();
|
|
|
|
- qdept.setOtherId(gatewaySUser.getDeptId());
|
|
|
|
- List<SysDept> deptList = deptService.selectDeptList(qdept);
|
|
|
|
- if (!deptList.isEmpty()) {
|
|
|
|
- user.setDeptId(deptList.get(0).getDeptId());
|
|
|
|
- } else {
|
|
|
|
- //还未有部门暂不设置 //需要先同步部门
|
|
|
|
-
|
|
|
|
- }
|
|
|
|
- }*//*
|
|
|
|
- user.setPhonenumber(gatewaySUser.getMobile());
|
|
|
|
- user.setNickName(gatewaySUser.getName());
|
|
|
|
- user.setUserName(gatewaySUser.getUserName());
|
|
|
|
- user.setDeptId(gatewaySUser.getDeptId());
|
|
|
|
- user.setUserType(Convert.toStr(gatewaySUser.getUserGroupId()));
|
|
|
|
- user.setUpdateBy("kafka");
|
|
|
|
- user.setUpdateTime(new Date());
|
|
|
|
- user.setSex(gatewaySUser.getSex());
|
|
|
|
- user.setOrgId(gatewaySUser.getOrgId());
|
|
|
|
- user.setSuperior(gatewaySUser.getSuperior());
|
|
|
|
- user.setIdNumber(gatewaySUser.getIdNumber());
|
|
|
|
- user.setPassword(SecurityUtils.encryptPassword("tocc!suqian"));
|
|
|
|
- user.setStatus(gatewaySUser.getStatus());
|
|
|
|
- user.setDelFlag(gatewaySUser.getDelFlag());
|
|
|
|
- user.setUpdateBy("kafka");
|
|
|
|
- user.setUpdateTime(new Date());
|
|
|
|
- userService.updateUser(user);
|
|
|
|
- }
|
|
|
|
- }
|
|
|
|
- } catch (Exception e) {
|
|
|
|
- log.error("t_uc_use的kafka消费异常:{}", e.getMessage());
|
|
|
|
- }
|
|
|
|
- }*/
|
|
|
|
|
|
+// @Autowired
|
|
|
|
+// private WebSocketServer webSocketServer;
|
|
|
|
|
|
/**
|
|
/**
|
|
- * 四维组织部门数据消费
|
|
|
|
- * {"id":"f124bfe4b43c49c5b7451b11355cc499","name":"市运输服务中心","parentId":null,"parentName":null,"flag":0,"createTime":"2021-10-21 14:02:28","createUser":"admin","updateTime":"2021-10-21 14:02:28","updateUser":"admin","delFlag":"0"}
|
|
|
|
|
|
+ * kfka用户同步
|
|
*
|
|
*
|
|
* @param message
|
|
* @param message
|
|
*/
|
|
*/
|
|
-// @KafkaListener(topics = "t_uc_orgdept")
|
|
|
|
-// public void onDeptMessage(String message) {
|
|
|
|
-// log.info("kafka部门信息消费:{}", message);
|
|
|
|
-// try {
|
|
|
|
-// GatewayDept gatewayDept = JSONUtil.toBean(message, GatewayDept.class);
|
|
|
|
-// if (gatewayDept != null) {
|
|
|
|
-// SysDept qdept = new SysDept();
|
|
|
|
-// qdept.setDeptId(gatewayDept.getId());
|
|
|
|
-// List<SysDept> deptList = deptService.selectDeptList(qdept);
|
|
|
|
-// if (deptList.isEmpty()) {
|
|
|
|
|
|
+ @KafkaListener(topics = "t_uc_user")
|
|
|
|
+ public void onUserMessage(String message) {
|
|
|
|
+ log.info("kafka用户信息消费:{}", message);
|
|
|
|
+ try {
|
|
|
|
+ GatewaySUser gatewaySUser = JSONUtil.toBean(message, GatewaySUser.class);
|
|
|
|
+// if (gatewaySUser != null) {
|
|
|
|
+// SysUser quser = new SysUser();
|
|
|
|
+// quser.setUserId(gatewaySUser.getUserId());
|
|
|
|
+// List<SysUser> userList = userService.selectUserList(quser);
|
|
|
|
+// if (userList.isEmpty()) {
|
|
// //插入
|
|
// //插入
|
|
-//// SysDept dept = new SysDept();
|
|
|
|
-// /*//查询父部门
|
|
|
|
|
|
+// SysUser user = new SysUser();
|
|
|
|
+// user.setUserId(gatewaySUser.getUserId());
|
|
// {
|
|
// {
|
|
-// SysDept qdept1 = new SysDept();
|
|
|
|
-// if (gatewayDept.getParentId() == null || gatewayDept.getParentId().equals("")) {
|
|
|
|
-// qdept1.setParentId("0");
|
|
|
|
-// qdept1.setOtherId(gatewayDept.getOrgId());
|
|
|
|
|
|
+// SysDept qdept = new SysDept();
|
|
|
|
+// qdept.setOtherId(gatewaySUser.getDeptId());
|
|
|
|
+// List<SysDept> deptList = deptService.selectDeptList(qdept);
|
|
|
|
+// if (!deptList.isEmpty()) {
|
|
|
|
+// user.setDeptId(deptList.get(0).getDeptId());
|
|
// } else {
|
|
// } else {
|
|
-// qdept1.setOtherId(gatewayDept.getParentId());
|
|
|
|
|
|
+// //还未有部门暂不设置 //需要先同步部门
|
|
// }
|
|
// }
|
|
-// List<SysDept> deptList1 = deptService.selectDeptList(qdept1);
|
|
|
|
-// if (!deptList1.isEmpty()) {
|
|
|
|
-// dept.setParentId(deptList1.get(0).getDeptId());
|
|
|
|
-// } else {
|
|
|
|
-// //无父组织或部门 暂不处理吧
|
|
|
|
-// }
|
|
|
|
-// }*/
|
|
|
|
-// qdept.setParentId(StrUtil.emptyToDefault(gatewayDept.getParentId(), "0"));
|
|
|
|
-// qdept.setDeptName(gatewayDept.getName());
|
|
|
|
-// qdept.setUpdateBy(gatewayDept.getUpdateUser());
|
|
|
|
-// qdept.setUpdateTime(DateUtil.parseDateTime(gatewayDept.getUpdateTime()));
|
|
|
|
-// qdept.setCreateBy(gatewayDept.getCreateUser());
|
|
|
|
-// qdept.setCreateTime(DateUtil.parseDateTime(gatewayDept.getCreateTime()));
|
|
|
|
-// qdept.setDelFlag(gatewayDept.getDelFlag());
|
|
|
|
-// qdept.setFlag(Convert.toStr(gatewayDept.getFlag()));
|
|
|
|
-//
|
|
|
|
-// deptService.insertDept(qdept);
|
|
|
|
|
|
+// }
|
|
|
|
+// user.setPhonenumber(gatewaySUser.getMobile());
|
|
|
|
+// user.setNickName(gatewaySUser.getName());
|
|
|
|
+// user.setUserName(gatewaySUser.getUserName());
|
|
|
|
+// user.setDeptId(gatewaySUser.getDeptId());
|
|
|
|
+// user.setUserType(Convert.toStr(gatewaySUser.getUserGroupId()));
|
|
|
|
+// user.setUpdateBy("kafka");
|
|
|
|
+// user.setUpdateTime(new Date());
|
|
|
|
+// user.setCreateBy("kafka");
|
|
|
|
+// user.setCreateTime(new Date());
|
|
|
|
+// user.setSex(gatewaySUser.getSex());
|
|
|
|
+// user.setOrgId(gatewaySUser.getOrgId());
|
|
|
|
+// user.setSuperior(gatewaySUser.getSuperior());
|
|
|
|
+// user.setIdNumber(gatewaySUser.getIdNumber());
|
|
|
|
+// user.setPassword(SecurityUtils.encryptPassword("tocc!suqian"));
|
|
|
|
+// user.setStatus(gatewaySUser.getStatus());
|
|
|
|
+// user.setDelFlag(gatewaySUser.getDelFlag());
|
|
|
|
+// userService.insertUser(user);
|
|
// } else {
|
|
// } else {
|
|
// //更新
|
|
// //更新
|
|
-// qdept = deptList.get(0);
|
|
|
|
-// //查询父部门
|
|
|
|
-// /*{
|
|
|
|
-// SysDept qdept1 = new SysDept();
|
|
|
|
-// if (gatewayDept.getParentId() == null || gatewayDept.getParentId().equals("")) {
|
|
|
|
-// qdept1.setParentId("0");
|
|
|
|
-// qdept1.setOtherId(gatewayDept.getOrgId());
|
|
|
|
-// } else {
|
|
|
|
-// qdept1.setOtherId(gatewayDept.getParentId());
|
|
|
|
-// }
|
|
|
|
-// List<SysDept> deptList1 = deptService.selectDeptList(qdept1);
|
|
|
|
-// if (!deptList1.isEmpty()) {
|
|
|
|
-// dept.setParentId(deptList1.get(0).getDeptId());
|
|
|
|
|
|
+// SysUser user = userList.get(0);
|
|
|
|
+// {
|
|
|
|
+// SysDept qdept = new SysDept();
|
|
|
|
+// qdept.setOtherId(gatewaySUser.getDeptId());
|
|
|
|
+// List<SysDept> deptList = deptService.selectDeptList(qdept);
|
|
|
|
+// if (!deptList.isEmpty()) {
|
|
|
|
+// user.setDeptId(deptList.get(0).getDeptId());
|
|
// } else {
|
|
// } else {
|
|
-// //无父组织或部门 暂不处理吧
|
|
|
|
|
|
+// //还未有部门暂不设置 //需要先同步部门
|
|
|
|
+//
|
|
// }
|
|
// }
|
|
-// }*/
|
|
|
|
-// qdept.setParentId(StrUtil.emptyToDefault(gatewayDept.getParentId(), "0"));
|
|
|
|
-// qdept.setDeptName(gatewayDept.getName());
|
|
|
|
-// qdept.setUpdateBy(gatewayDept.getUpdateUser());
|
|
|
|
-// qdept.setUpdateTime(DateUtil.parseDateTime(gatewayDept.getUpdateTime()));
|
|
|
|
-// qdept.setCreateBy(gatewayDept.getCreateUser());
|
|
|
|
-// qdept.setCreateTime(DateUtil.parseDateTime(gatewayDept.getCreateTime()));
|
|
|
|
-// qdept.setDelFlag(gatewayDept.getDelFlag());
|
|
|
|
-// qdept.setFlag(Convert.toStr(gatewayDept.getFlag()));
|
|
|
|
-// deptService.updateDept(qdept);
|
|
|
|
|
|
+// }
|
|
|
|
+// user.setPhonenumber(gatewaySUser.getMobile());
|
|
|
|
+// user.setNickName(gatewaySUser.getName());
|
|
|
|
+// user.setUserName(gatewaySUser.getUserName());
|
|
|
|
+// user.setDeptId(gatewaySUser.getDeptId());
|
|
|
|
+// user.setUserType(Convert.toStr(gatewaySUser.getUserGroupId()));
|
|
|
|
+// user.setUpdateBy("kafka");
|
|
|
|
+// user.setUpdateTime(new Date());
|
|
|
|
+// user.setSex(gatewaySUser.getSex());
|
|
|
|
+// user.setOrgId(gatewaySUser.getOrgId());
|
|
|
|
+// user.setSuperior(gatewaySUser.getSuperior());
|
|
|
|
+// user.setIdNumber(gatewaySUser.getIdNumber());
|
|
|
|
+// user.setPassword(SecurityUtils.encryptPassword("tocc!suqian"));
|
|
|
|
+// user.setStatus(gatewaySUser.getStatus());
|
|
|
|
+// user.setDelFlag(gatewaySUser.getDelFlag());
|
|
|
|
+// user.setUpdateBy("kafka");
|
|
|
|
+// user.setUpdateTime(new Date());
|
|
|
|
+// userService.updateUser(user);
|
|
// }
|
|
// }
|
|
// }
|
|
// }
|
|
-// } catch (Exception e) {
|
|
|
|
-// log.error("t_uc_orgdept的kafka消费异常:{}", e.getMessage());
|
|
|
|
-// }
|
|
|
|
-// }
|
|
|
|
|
|
+ } catch (Exception e) {
|
|
|
|
+ log.error("t_uc_use的kafka消费异常:{}", e.getMessage());
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ /**
|
|
|
|
+ * 四维组织部门数据消费
|
|
|
|
+ * '{"id":"6913667dddd34c5ab8894164fb58d296","name":"华设测试","parentId":"310c4af66f1a4f9586bfee9c432e1ab2","parentName":"沭阳县交通运输局","flag":0,"createTime":"2022-09-14 11:20:07","createUser":"sqadmin1","updateTime":"2022-09-14 11:53:07","updateUser":"sqadmin1","delFlag":"0","fullName":null,"ordinal":null}'
|
|
|
|
+ *
|
|
|
|
+ * @param message
|
|
|
|
+ */
|
|
|
|
+ @KafkaListener(topics = "t_uc_orgdept")
|
|
|
|
+ public void onDeptMessage(String message) {
|
|
|
|
+ log.info("kafka部门信息消费:{}", message);
|
|
|
|
+ try {
|
|
|
|
+ GatewayDept gatewayDept = JSONUtil.toBean(message, GatewayDept.class);
|
|
|
|
+ if (gatewayDept != null) {
|
|
|
|
+ if ("2".equals(gatewayDept.getDelFlag())) {
|
|
|
|
+ // 2为删除部门
|
|
|
|
+ deptService.removeById(gatewayDept.getId());
|
|
|
|
+ return;
|
|
|
|
+ }
|
|
|
|
+ SysDept qdept = new SysDept();
|
|
|
|
+ qdept.setDeptId(gatewayDept.getId());
|
|
|
|
+ qdept.setParentId(StrUtil.emptyToDefault(gatewayDept.getParentId(), "0"));
|
|
|
|
+ qdept.setDeptName(gatewayDept.getName());
|
|
|
|
+ qdept.setUpdateBy(gatewayDept.getUpdateUser());
|
|
|
|
+ qdept.setUpdateTime(DateUtil.parseDateTime(gatewayDept.getUpdateTime()));
|
|
|
|
+ qdept.setCreateBy(gatewayDept.getCreateUser());
|
|
|
|
+ qdept.setCreateTime(DateUtil.parseDateTime(gatewayDept.getCreateTime()));
|
|
|
|
+ qdept.setDelFlag(gatewayDept.getDelFlag());
|
|
|
|
+ qdept.setFlag(Convert.toStr(gatewayDept.getFlag()));
|
|
|
|
+
|
|
|
|
+ SysDept info = deptService.getById(qdept.getParentId());
|
|
|
|
+ if (info != null) {
|
|
|
|
+ qdept.setAncestors(info.getAncestors() + "," + qdept.getParentId());
|
|
|
|
+ } else {
|
|
|
|
+ // 找不到父类
|
|
|
|
+ // 情况1:有父类,但是之前的部门缺失了
|
|
|
|
+// deptService.dealMissDept(qdept.getParentId());
|
|
|
|
+ }
|
|
|
|
+ String departFullNamePrefix = FindsDepartsChildrenUtil.departFullName(deptService.list(), qdept.getParentId());
|
|
|
|
+ qdept.setFullName(StrUtil.isBlank(departFullNamePrefix) ? qdept.getDeptName() : departFullNamePrefix + qdept.getDeptName());
|
|
|
|
+ deptService.saveOrUpdate(qdept);
|
|
|
|
+ }
|
|
|
|
+ } catch (Exception e) {
|
|
|
|
+ log.error("t_uc_orgdept的kafka消费异常:{}", e.getMessage());
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
|
|
/**
|
|
/**
|
|
* 单兵实时位置消费
|
|
* 单兵实时位置消费
|