静态二维码开发中

service-user/src/main/java/com/java110/user/cmd/owner/GetQrcodeOwnerCmd.java

@@ -0,0 +1,137 @@
+package com.java110.user.cmd.owner;
+
+import com.alibaba.fastjson.JSONObject;
+import com.java110.core.annotation.Java110Cmd;
+import com.java110.core.context.ICmdDataFlowContext;
+import com.java110.core.event.cmd.Cmd;
+import com.java110.core.event.cmd.CmdEvent;
+import com.java110.core.factory.SendSmsFactory;
+import com.java110.dto.owner.OwnerDto;
+import com.java110.dto.payFeeQrcode.PayFeeQrcodeDto;
+import com.java110.dto.room.RoomDto;
+import com.java110.intf.community.IRoomV1InnerServiceSMO;
+import com.java110.intf.fee.IPayFeeQrcodeV1InnerServiceSMO;
+import com.java110.intf.user.IOwnerInnerServiceSMO;
+import com.java110.intf.user.IOwnerV1InnerServiceSMO;
+import com.java110.utils.cache.CommonCache;
+import com.java110.utils.exception.CmdException;
+import com.java110.utils.util.Assert;
+import com.java110.utils.util.ValidatorUtil;
+import com.java110.vo.ResultVo;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import java.text.ParseException;
+import java.util.List;
+
+/**
+ * 二维码 查询业主
+ */
+@Java110Cmd(serviceCode = "owner.getQrcodeOwner")
+public class GetQrcodeOwnerCmd extends Cmd {
+
+
+    @Autowired
+    private IOwnerV1InnerServiceSMO ownerV1InnerServiceSMOImpl;
+
+    @Autowired
+    private IRoomV1InnerServiceSMO roomV1InnerServiceSMOImpl;
+
+    @Autowired
+    private IOwnerInnerServiceSMO ownerInnerServiceSMOImpl;
+
+    @Autowired
+    private IPayFeeQrcodeV1InnerServiceSMO payFeeQrcodeV1InnerServiceSMOImpl;
+
+    @Override
+    public void validate(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException, ParseException {
+        Assert.hasKeyAndValue(reqJson, "queryWay", "未包含查询方式");
+        Assert.hasKeyAndValue(reqJson, "communityId", "未包含小区");
+        Assert.hasKeyAndValue(reqJson, "pfqId", "未包含二维码信息");
+
+        if ("room".equals(reqJson.getString("queryWay"))) {
+            Assert.hasKeyAndValue(reqJson, "roomNum", "未包含房屋信息");
+        } else {
+            Assert.hasKeyAndValue(reqJson, "link", "未包含手机号");
+            if (!ValidatorUtil.isMobile(reqJson.getString("link"))) {
+                throw new IllegalArgumentException("手机号格式错误");
+            }
+        }
+
+
+        PayFeeQrcodeDto payFeeQrcodeDto = new PayFeeQrcodeDto();
+        payFeeQrcodeDto.setPfqId(reqJson.getString("pfqId"));
+        payFeeQrcodeDto.setCommunityId(reqJson.getString("communityId"));
+        List<PayFeeQrcodeDto> payFeeQrcodeDtos = payFeeQrcodeV1InnerServiceSMOImpl.queryPayFeeQrcodes(payFeeQrcodeDto);
+
+        Assert.listOnlyOne(payFeeQrcodeDtos, "二维码不存在");
+
+        //todo 不校验验证码
+        if (!"ON".equals(payFeeQrcodeDtos.get(0).getSmsValidate())) {
+            return;
+        }
+        Assert.hasKeyAndValue(reqJson, "msgCode", "未包含验证码信息");
+
+        OwnerDto ownerDto = computeOwner(reqJson);
+        String smsCode = CommonCache.getValue(reqJson.getString(ownerDto.getLink()) + SendSmsFactory.VALIDATE_CODE);
+
+        if (!reqJson.getString("msgCode").equals(smsCode)) {
+            throw new CmdException("验证码错误");
+        }
+
+    }
+
+    @Override
+    public void doCmd(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException, ParseException {
+
+        OwnerDto ownerDto = computeOwner(reqJson);
+
+        context.setResponseEntity(ResultVo.createResponseEntity(ownerDto.getOwnerId()));
+    }
+
+    /**
+     * 计算业主手机号
+     *
+     * @param reqJson
+     * @return
+     */
+    private OwnerDto computeOwner(JSONObject reqJson) {
+
+        if ("phone".equals(reqJson.getString("queryWay"))) {
+            OwnerDto ownerDto = new OwnerDto();
+            ownerDto.setLink(reqJson.getString("link"));
+            ownerDto.setCommunityId(reqJson.getString("communityId"));
+            ownerDto.setOwnerTypeCd(OwnerDto.OWNER_TYPE_CD_OWNER);
+            List<OwnerDto> ownerDtos = ownerV1InnerServiceSMOImpl.queryOwners(ownerDto);
+            if (ownerDtos == null || ownerDtos.size() < 1) {
+                throw new CmdException("业主不存在");
+            }
+            return ownerDtos.get(0);
+        }
+        String roomNumStr = reqJson.getString("roomNum");
+        String[] roomNums = roomNumStr.split("-", 3);
+        if (roomNums == null || roomNums.length != 3) {
+            throw new CmdException("业主不存在");
+        }
+
+        RoomDto roomDto = new RoomDto();
+        roomDto.setFloorNum(roomNums[0]);
+        roomDto.setUnitNum(roomNums[1]);
+        roomDto.setRoomNum(roomNums[2]);
+        roomDto.setCommunityId(reqJson.getString("communityId"));
+        List<RoomDto> roomDtos = roomV1InnerServiceSMOImpl.queryRooms(roomDto);
+
+        Assert.listOnlyOne(roomDtos, "房屋不存在");
+
+
+        OwnerDto ownerDto = new OwnerDto();
+        ownerDto.setRoomId(roomDtos.get(0).getRoomId());
+        ownerDto.setCommunityId(reqJson.getString("communityId"));
+        ownerDto.setOwnerTypeCd(OwnerDto.OWNER_TYPE_CD_OWNER);
+        List<OwnerDto> ownerDtos = ownerInnerServiceSMOImpl.queryOwners(ownerDto);
+        if (ownerDtos == null || ownerDtos.size() < 1) {
+            throw new CmdException("业主不存在");
+        }
+
+        return ownerDtos.get(0);
+    }
+}

service-user/src/main/java/com/java110/user/cmd/user/OwnerSendSmsCmd.java

@@ -72,6 +72,7 @@ public class OwnerSendSmsCmd extends Cmd {
 
 //super.validatePageInfo(reqJson);
         Assert.hasKeyAndValue(reqJson, "queryWay", "未包含查询方式");
+        Assert.hasKeyAndValue(reqJson, "communityId", "未包含小区");
 
         if ("room".equals(reqJson.getString("queryWay"))) {
             Assert.hasKeyAndValue(reqJson, "roomNum", "未包含房屋信息");

springboot/src/main/java/com/java110/boot/configuration/ServiceConfiguration.java

@@ -111,6 +111,9 @@ public class ServiceConfiguration {
         // todo 静态二维码支付 相关接口放开
         exclusions.append("/app/payFeeQrcode.getQrcodeConfig,");// 放开接口登录
         exclusions.append("/app/user.ownerSendSms,");// 向业主发送验证码
+        exclusions.append("/app/owner.getQrcodeOwner,");// 根据二维码查询业主信息
+
+
 
 
         exclusions.append("/app/reportInfoAnswer/queryReportInfoAnswerByOpenId");