根据户号获取户名

zhsw-common/src/main/java/com/rongwei/zhsw/system/dao/SwUserManagementDao.java

@@ -37,6 +37,8 @@ public interface SwUserManagementDao extends BaseMapper<SwUserManagementDo> {
 
     void batchUpdateUserBalances(@Param("list") List<TransferAccountDo.UpdateUserBalance> list);
 
+    SwUserManagementVo getDataByAccountName(@Param("huHao") String huHao, @Param("waterCompanyId") String waterCompanyId);
+
 }
 
 

zhsw-common/src/main/java/com/rongwei/zhsw/system/wechat/AccountService.java

@@ -25,4 +25,6 @@ public interface AccountService {
     R updateReadStatus(ReadStatusVo readStatusVo);
 
     R updateReadStatusAll(ReadStatusVo readStatusVo);
+
+    R getHuMing(String huHao, String waterCompanyId);
 }

zhsw-common/src/main/java/com/rongwei/zhsw/system/wechat/impl/AccountServiceImpl.java

@@ -269,4 +269,24 @@ public class AccountServiceImpl implements AccountService {
         return R.ok("更新成功");
     }
 
+    /**
+     * 根据户号和水司ID获取户名
+     * @param huHao 户号
+     * @param waterCompanyId 水司ID
+     * @return 用户名信息
+     */
+    @Override
+    public R getHuMing(String huHao, String waterCompanyId) {
+        log.info("开始查询户名，户号：{}，水司ID：{}", huHao, waterCompanyId);
+        WeChatUtils.checkWater(waterCompanyId);
+
+        SwUserManagementVo userInfo = swUserManagementService.getBaseMapper().getDataByAccountName(huHao, waterCompanyId);
+
+        if (userInfo == null) {
+            log.error("未找到户号{}对应的用户信息", huHao);
+            return R.error("未找到用户");
+        }
+        return R.ok(userInfo.getUsername());
+    }
+
 }

zhsw-common/src/main/resources/mybatis/zhsw/SwUserManagementDao.xml

@@ -10,6 +10,12 @@
         where ID = #{id}
     </update>
 
+    <select id="getDataByAccountName" resultType="com.rongwe.zhsw.system.vo.SwUserManagementVo">
+        select a.ID, a.USERNUMBER, a.USERNAME, a.DELETED
+        from ${waterCompanyId}.sw_user_management a
+        where a.DELETED = '0'
+          and a.USERNUMBER = #{huHao}
+    </select>
 
     <update id="batchUpdateUserBalances">
         <foreach collection="list" item="item" separator=";">

zhsw-server/src/main/java/com/rongwei/zhsw/system/controller/weChat/AccountController.java

@@ -71,11 +71,20 @@ public class AccountController {
 
     /**
      * 户号设置默认方法
-
      */
     @PostMapping("/setDefaultAccount")
     private R setDefaultAccount(@RequestBody AccountUnbindVo accountUnbindVo) {
         return accountService.setDefaultAccount(accountUnbindVo);
     }
 
+    /**
+     * 根据户号和水司ID获取户名
+     * @param huHao 户号
+     * @param waterCompanyId 水司ID
+     */
+    @GetMapping("/getHuMing")
+    private R getHuMing(@RequestParam("huHao") String huHao, @RequestParam("waterCompanyId") String waterCompanyId) {
+
+        return accountService.getHuMing(huHao, waterCompanyId);
+    }
 }

zhsw-server/src/main/resources/bootstrap-dev.yml

@@ -11,3 +11,4 @@ spring:
         server-addr: 127.0.0.1:8848
         namespace: cd047569-9470-4dfb-8663-b113d01cd30f
         #cd047569-9470-4dfb-8663-b113d01cd30f
+        #9caed6dc-3784-4d73-bd4c-a8e8153bc358