1.单位人员增加账户表

amos-boot-module/amos-boot-module-api/amos-boot-module-common-api/src/main/java/com/yeejoin/amos/boot/module/common/api/service/IOrgUsrAgencyUserService.java

 package com.yeejoin.amos.boot.module.common.api.service;
 
 
+import com.alibaba.fastjson.JSONObject;
+import com.yeejoin.amos.boot.module.common.api.entity.OrgUsrAgencyUser;
+
 /**
  * 单位人员平台人员关系表接口类
  *
@@ -9,4 +12,7 @@ package com.yeejoin.amos.boot.module.common.api.service;
  */
 public interface IOrgUsrAgencyUserService {
 
+    OrgUsrAgencyUser getAccountDetail(String orgUsrId);
+
+    void synOrgUser(JSONObject jsonObject);
 }

amos-boot-module/amos-boot-module-biz/amos-boot-module-common-biz/src/main/java/com/yeejoin/amos/boot/module/common/biz/controller/OrgUsrAgencyUserController.java

+package com.yeejoin.amos.boot.module.common.biz.controller;
+
+import com.yeejoin.amos.boot.biz.common.controller.BaseController;
+import com.yeejoin.amos.boot.module.common.api.entity.OrgUsrAgencyUser;
+import com.yeejoin.amos.boot.module.common.api.service.IOrgUsrAgencyUserService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RestController;
+import org.typroject.tyboot.core.foundation.enumeration.UserType;
+import org.typroject.tyboot.core.restful.doc.TycloudOperation;
+import org.typroject.tyboot.core.restful.utils.ResponseHelper;
+import org.typroject.tyboot.core.restful.utils.ResponseModel;
+
+/**
+ * 部门信息修改
+ *
+ * @author tb
+ * @date 2021-06-18
+ */
+@RestController
+@Api(tags = "人员amos账号信息Api")
+@RequestMapping(value = "/org-usr-agency")
+public class OrgUsrAgencyUserController extends BaseController {
+
+    @Autowired
+    IOrgUsrAgencyUserService orgUsrAgencyUserService;
+
+
+    /**
+     * 查询关联的amos账号信息
+     *
+     * @return OrgUsrAgencyUser
+     */
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
+    @RequestMapping(value = "/{orgUsrId}/detail", method = RequestMethod.GET)
+    @ApiOperation(httpMethod = "POST", value = "查询关联的amos账号信息", notes = "查询关联的amos账号信息")
+    public ResponseModel<OrgUsrAgencyUser> getAccountDetail(@PathVariable String orgUsrId) {
+        OrgUsrAgencyUser agencyUser = orgUsrAgencyUserService.getAccountDetail(orgUsrId);
+        return ResponseHelper.buildResponse(agencyUser);
+    }
+}
\ No newline at end of file

amos-boot-module/amos-boot-module-biz/amos-boot-module-common-biz/src/main/java/com/yeejoin/amos/boot/module/common/biz/listener/AmosMqttListener.java

+package com.yeejoin.amos.boot.module.common.biz.listener;
+
+import com.alibaba.fastjson.JSONObject;
+import com.yeejoin.amos.boot.module.common.api.service.IOrgUsrAgencyUserService;
+import org.eclipse.paho.client.mqttv3.MqttMessage;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import org.typroject.tyboot.component.emq.EmqxListener;
+
+import java.nio.charset.StandardCharsets;
+
+/**
+ * @author Administrator
+ */
+@Component
+public class AmosMqttListener extends EmqxListener {
+
+    @Autowired
+    IOrgUsrAgencyUserService orgUsrAgencyUserService;
+
+    @Override
+    public void processMessage(String topic, MqttMessage mqttMessage) throws Exception {
+        byte[] payload = mqttMessage.getPayload();
+        String str = new String(payload, StandardCharsets.UTF_8);
+        JSONObject jsonObject = JSONObject.parseObject(str);
+        JSONObject result = jsonObject.getJSONObject("result");
+        String path = result.getString("path");
+        if (path.contains("agencyuser")) {
+            orgUsrAgencyUserService.synOrgUser(jsonObject);
+        }
+    }
+}

amos-boot-module/amos-boot-module-biz/amos-boot-module-common-biz/src/main/java/com/yeejoin/amos/boot/module/common/biz/service/impl/ApplicationRunnerImpl.java

+package com.yeejoin.amos.boot.module.common.biz.service.impl;
+
+import com.yeejoin.amos.boot.module.common.biz.listener.AmosMqttListener;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.ApplicationArguments;
+import org.springframework.boot.ApplicationRunner;
+import org.typroject.tyboot.component.emq.EmqKeeper;
+
+/**
+ * @author Administrator
+ */
+public class ApplicationRunnerImpl implements ApplicationRunner {
+
+    @Autowired
+    EmqKeeper emqKeeper;
+
+    @Autowired
+    AmosMqttListener amosMqttListener;
+
+
+    @Override
+    public void run(ApplicationArguments args) throws Exception {
+        emqKeeper.subscript("/amos/operation/log", 2, amosMqttListener);
+    }
+}

amos-boot-module/amos-boot-module-biz/amos-boot-module-common-biz/src/main/java/com/yeejoin/amos/boot/module/common/biz/service/impl/OrgUsrAgencyUserServiceImpl.java

 package com.yeejoin.amos.boot.module.common.biz.service.impl;
 
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.yeejoin.amos.boot.module.common.api.dto.OrgUsrAgencyUserDto;
 import com.yeejoin.amos.boot.module.common.api.entity.OrgUsrAgencyUser;
 import com.yeejoin.amos.boot.module.common.api.mapper.OrgUsrAgencyUserMapper;
 import com.yeejoin.amos.boot.module.common.api.service.IOrgUsrAgencyUserService;
-import com.yeejoin.amos.boot.module.common.api.dto.OrgUsrAgencyUserDto;
-import org.typroject.tyboot.core.rdbms.service.BaseService;
 import org.springframework.stereotype.Service;
-import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import org.typroject.tyboot.core.rdbms.service.BaseService;
+
 import java.util.List;
+import java.util.stream.Collectors;
 
 /**
  * 单位人员平台人员关系表服务实现类
@@ -16,18 +20,32 @@ import java.util.List;
  * @date 2022-09-13
  */
 @Service
-public class OrgUsrAgencyUserServiceImpl extends BaseService<OrgUsrAgencyUserDto,OrgUsrAgencyUser,OrgUsrAgencyUserMapper> implements IOrgUsrAgencyUserService {
-    /**
-     * 分页查询
-     */
-    public Page<OrgUsrAgencyUserDto> queryForOrgUsrAgencyUserPage(Page<OrgUsrAgencyUserDto> page)   {
-        return this.queryForPage(page, null, false);
+public class OrgUsrAgencyUserServiceImpl extends BaseService<OrgUsrAgencyUserDto, OrgUsrAgencyUser, OrgUsrAgencyUserMapper> implements IOrgUsrAgencyUserService {
+
+
+    @Override
+    public OrgUsrAgencyUser getAccountDetail(String orgUsrId) {
+        return this.getOne(new LambdaQueryWrapper<OrgUsrAgencyUser>().eq(OrgUsrAgencyUser::getOrgUsrId, orgUsrId));
     }
 
-    /**
-     * 列表查询 示例
-     */
-    public List<OrgUsrAgencyUserDto> queryForOrgUsrAgencyUserList()   {
-        return this.queryForList("" , false);
+    @Override
+    public void synOrgUser(JSONObject jsonObject) {
+        JSONObject result = jsonObject.getJSONObject("result");
+        String methodName = jsonObject.getString("methodName");
+        String userId = jsonObject.getString("userId");
+        // 平台添加用户
+        if ("update".equals(methodName)) {
+            // 更新cb_org_usr_agency_user、cb_org_usr、cb_firefighters
+            JSONObject object = result.getJSONObject("result");
+//            person.setId(object.getLong("sequenceNbr"));
+//            person.setAccountName(object.getString("userName"));
+//            person.setUserId(object.getLong("userId"));
+//            person.setName(object.getString("realName"));
+//            person.setPhone(object.getString("mobile"));
+        } else if ("multDeleteUser".equals(methodName)) {
+            JSONArray array = result.getJSONArray("result");
+            List<Object> userIds = array.stream().collect(Collectors.toList());
+            // 删除cb_org_usr_agency_user、cb_org_usr与用户有关字段、cb_firefighters和用户有关字段
+        }
     }
 }
\ No newline at end of file