package com.java110.user.cmd.owner; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.java110.core.annotation.Java110Cmd; import com.java110.core.annotation.Java110Transactional; import com.java110.core.context.CmdContextUtils; 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.AuthenticationFactory; import com.java110.core.factory.GenerateCodeFactory; import com.java110.core.factory.SendSmsFactory; import com.java110.core.smo.IPhotoSMO; import com.java110.doc.annotation.*; import com.java110.dto.community.CommunityDto; import com.java110.dto.msg.SmsDto; import com.java110.dto.owner.OwnerDto; import com.java110.intf.common.IFileInnerServiceSMO; import com.java110.intf.common.IFileRelInnerServiceSMO; import com.java110.intf.common.ISmsInnerServiceSMO; import com.java110.intf.community.ICommunityInnerServiceSMO; import com.java110.intf.community.ICommunityV1InnerServiceSMO; import com.java110.intf.user.*; import com.java110.po.owner.OwnerAppUserPo; import com.java110.po.owner.OwnerAttrPo; import com.java110.po.owner.OwnerPo; import com.java110.po.user.UserPo; import com.java110.user.bmo.owner.IGeneratorOwnerUserBMO; import com.java110.utils.cache.MappingCache; import com.java110.utils.constant.MappingConstant; import com.java110.utils.constant.UserLevelConstant; import com.java110.utils.exception.CmdException; import com.java110.utils.util.Assert; import com.java110.utils.util.BeanConvertUtil; import com.java110.utils.util.ListUtil; import com.java110.utils.util.StringUtil; import org.springframework.beans.factory.annotation.Autowired; import java.text.ParseException; import java.util.List; @Java110CmdDoc(title = "添加业主", description = "第三方系统，比如招商系统同步业主信息", httpMethod = "post", url = "http://{ip}:{port}/app/owner.saveOwnerMember", resource = "userDoc", author = "吴学文", serviceCode = "owner.saveOwnerMember", seq = 10 ) @Java110ParamsDoc(params = { @Java110ParamDoc(name = "communityId", length = 30, remark = "小区ID"), @Java110ParamDoc(name = "name", length = 64, remark = "业主名称"), @Java110ParamDoc(name = "roomName", length = 64, remark = "房屋 楼栋-单元-房屋"), @Java110ParamDoc(name = "link", length = 11, remark = "业主手机号"), @Java110ParamDoc(name = "idCard", length = 30, remark = "业主身份证号"), @Java110ParamDoc(name = "address", length = 512, remark = "地址"), @Java110ParamDoc(name = "sex", length = 12, remark = "性别 男 1 女 0"), @Java110ParamDoc(name = "ownerTypeCd", length = 12, remark = "业主类型 1001 业主 2002 家庭成员 家庭成员 需要传业主的ownerId"), @Java110ParamDoc(name = "remark", length = 512, remark = "备注"), @Java110ParamDoc(name = "ownerId", length = 30, remark = "业主 时 填写-1 家庭成员时填写业主ID"), @Java110ParamDoc(name = "ownerPhoto", length = -1, remark = "业主人脸 用于同步门禁 人脸开门"), }) @Java110ResponseDoc( params = { @Java110ParamDoc(name = "code", type = "int", length = 11, defaultValue = "0", remark = "返回编号，0 成功 其他失败"), @Java110ParamDoc(name = "msg", type = "String", length = 250, defaultValue = "成功", remark = "描述"), } ) @Java110ExampleDoc( reqBody = "{\n" + "\t\"name\": \"王王\",\n" + "\t\"roomName\": \"1-1-1001\",\n" + "\t\"age\": \"\",\n" + "\t\"link\": \"18909718888\",\n" + "\t\"address\": \"张三\",\n" + "\t\"sex\": \"0\",\n" + "\t\"ownerTypeCd\": \"1001\",\n" + "\t\"remark\": \"\",\n" + "\t\"ownerId\": -1,\n" + "\t\"ownerPhoto\": \"\",\n" + "\t\"idCard\": \"\",\n" + "\t\"communityId\": \"2022121921870161\"\n" + "}", resBody = "{\"code\":0,\"msg\":\"成功\"}" ) /** * 添加家庭成员 */ @Java110Cmd(serviceCode = "owner.saveOwnerMember") public class SaveOwnerMemberCmd extends Cmd { @Autowired private IOwnerInnerServiceSMO ownerInnerServiceSMOImpl; @Autowired private ISmsInnerServiceSMO smsInnerServiceSMOImpl; @Autowired private IFileRelInnerServiceSMO fileRelInnerServiceSMOImpl; @Autowired private IFileInnerServiceSMO fileInnerServiceSMOImpl; @Autowired private IOwnerV1InnerServiceSMO ownerV1InnerServiceSMOImpl; @Autowired private IOwnerAttrInnerServiceSMO ownerAttrInnerServiceSMOImpl; @Autowired private ICommunityV1InnerServiceSMO communityV1InnerServiceSMOImpl; @Autowired private IPhotoSMO photoSMOImpl; @Autowired private IGeneratorOwnerUserBMO generatorOwnerUserBMOImpl; @Override public void validate(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException, ParseException { Assert.jsonObjectHaveKey(reqJson, "name", "请求报文中未包含name"); Assert.jsonObjectHaveKey(reqJson, "link", "请求报文中未包含link"); Assert.jsonObjectHaveKey(reqJson, "sex", "请求报文中未包含sex"); Assert.jsonObjectHaveKey(reqJson, "ownerId", "请求报文中未包含业主"); Assert.jsonObjectHaveKey(reqJson, "communityId", "请求报文中未包含communityId"); if (reqJson.containsKey("ownerPhotoUrl")) { String ownerPhotoUrl = reqJson.getString("ownerPhotoUrl"); if (!StringUtil.isEmpty(ownerPhotoUrl) && ownerPhotoUrl.length() > 500) { throw new CmdException("图片地址太长"); } } //todo 验证吗校验 if (reqJson.containsKey("msgCode")) { SmsDto smsDto = new SmsDto(); smsDto.setTel(reqJson.getString("link")); smsDto.setCode(reqJson.getString("msgCode")); smsDto = smsInnerServiceSMOImpl.validateCode(smsDto); if (!smsDto.isSuccess() && "ON".equals(MappingCache.getValue(MappingConstant.SMS_DOMAIN, SendSmsFactory.SMS_SEND_SWITCH))) { throw new IllegalArgumentException(smsDto.getMsg()); } } //todo 校验手机号重复 String userValidate = MappingCache.getValue("USER_VALIDATE"); if ("ON".equals(userValidate)) { String link = reqJson.getString("link"); OwnerDto ownerDto = new OwnerDto(); ownerDto.setLink(link); ownerDto.setCommunityId(reqJson.getString("communityId")); List ownerDtos = ownerInnerServiceSMOImpl.queryAllOwners(ownerDto); Assert.listIsNull(ownerDtos, "手机号重复，请重新输入"); } //todo 属性校验 Assert.judgeAttrValue(reqJson); } @Override @Java110Transactional public void doCmd(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException, ParseException { String userId = CmdContextUtils.getUserId(context); //todo 生成memberId String memberId = GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_ownerId); reqJson.put("memberId", memberId); OwnerPo ownerPo = BeanConvertUtil.covertBean(reqJson, OwnerPo.class); String ownerPhotoUrl = reqJson.getString("ownerPhotoUrl"); ownerPo.setFaceUrl(ownerPhotoUrl); ownerPo.setAge("0"); ownerPo.setUserId(userId); ownerPo.setState(OwnerDto.STATE_FINISH); ownerPo.setPersonType(OwnerDto.PERSON_TYPE_PERSON); ownerPo.setOwnerTypeCd(OwnerDto.OWNER_TYPE_CD_MEMBER); int flag = ownerV1InnerServiceSMOImpl.saveOwner(ownerPo); if (flag < 1) { throw new CmdException("保存业主失败"); } //todo 保存属性 dealOwnerAttr(reqJson, context); //todo 生成登录账号 generatorOwnerUserBMOImpl.generator(ownerPo); } private void dealOwnerAttr(JSONObject paramObj, ICmdDataFlowContext cmdDataFlowContext) { if (!paramObj.containsKey("attrs")) { return; } JSONArray attrs = paramObj.getJSONArray("attrs"); if (attrs.size() < 1) { return; } int flag = 0; JSONObject attr = null; for (int attrIndex = 0; attrIndex < attrs.size(); attrIndex++) { attr = attrs.getJSONObject(attrIndex); attr.put("communityId", paramObj.getString("communityId")); attr.put("memberId", paramObj.getString("memberId")); attr.put("attrId", GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_attrId)); OwnerAttrPo ownerAttrPo = BeanConvertUtil.covertBean(attr, OwnerAttrPo.class); flag = ownerAttrInnerServiceSMOImpl.saveOwnerAttr(ownerAttrPo); if (flag < 1) { throw new CmdException("保存业主房屋关系失败"); } } } }