package com.java110.community.cmd.unit; import com.alibaba.fastjson.JSONObject; import com.java110.core.annotation.Java110Cmd; import com.java110.core.annotation.Java110Transactional; import com.java110.core.context.ICmdDataFlowContext; import com.java110.core.event.cmd.Cmd; import com.java110.core.event.cmd.CmdEvent; import com.java110.doc.annotation.*; import com.java110.dto.floor.FloorDto; import com.java110.dto.unit.UnitDto; import com.java110.intf.community.IFloorInnerServiceSMO; import com.java110.intf.community.IUnitInnerServiceSMO; import com.java110.intf.community.IUnitV1InnerServiceSMO; import com.java110.po.unit.UnitPo; import com.java110.utils.exception.CmdException; import com.java110.utils.util.Assert; import com.java110.utils.util.BeanConvertUtil; import com.java110.vo.ResultVo; import org.springframework.beans.factory.annotation.Autowired; @Java110CmdDoc(title = "修改单元", description = "用于外系统修改单元信息功能", httpMethod = "post", url = "http://{ip}:{port}/app/unit.updateUnit", resource = "communityDoc", author = "吴学文", serviceCode = "unit.updateUnit", seq = 10 ) @Java110ParamsDoc(params = { @Java110ParamDoc(name = "communityId", length = 30, remark = "小区ID"), @Java110ParamDoc(name = "floorId", length = 30, remark = "楼栋ID"), @Java110ParamDoc(name = "unitId", length = 30, remark = "单元ID"), @Java110ParamDoc(name = "unitNum", length = 30, remark = "单元"), @Java110ParamDoc(name = "layerCount", length = 30, remark = "楼层"), @Java110ParamDoc(name = "lift", length = 30, remark = "1010 有电梯 2020 无电梯"), @Java110ParamDoc(name = "unitArea", length = 30, 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="{\"floorId\":\"732022081690440002\",\"unitId\":\"123123\",\"unitNum\":\"2\",\"layerCount\":\"2\",\"lift\":\"1010\",\"remark\":\"2\",\"communityId\":\"2022081539020475\",\"unitArea\":\"2\"}", resBody="{'code':0,'msg':'成功'}" ) @Java110Cmd(serviceCode = "unit.updateUnit") public class UpdateUnitCmd extends Cmd { @Autowired private IFloorInnerServiceSMO floorInnerServiceSMOImpl; @Autowired private IUnitInnerServiceSMO unitInnerServiceSMOImpl; @Autowired private IUnitV1InnerServiceSMO unitV1InnerServiceSMOImpl; @Override public void validate(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) { Assert.jsonObjectHaveKey(reqJson, "communityId", "请求报文中未包含communityId节点"); Assert.jsonObjectHaveKey(reqJson, "floorId", "请求报文中未包含floorId节点"); Assert.jsonObjectHaveKey(reqJson, "unitId", "请求报文中未包含unitId节点"); Assert.jsonObjectHaveKey(reqJson, "unitNum", "请求报文中未包含unitNum节点"); Assert.jsonObjectHaveKey(reqJson, "layerCount", "请求报文中未包含layerCount节点"); Assert.jsonObjectHaveKey(reqJson, "lift", "请求报文中未包含lift节点"); Assert.isInteger(reqJson.getString("layerCount"), "单元总层数据不是有效数字"); if (!"1010".equals(reqJson.getString("lift")) && !"2020".equals(reqJson.getString("lift"))) { throw new IllegalArgumentException("是否有电梯 传入数据错误"); } FloorDto floorDto = new FloorDto(); floorDto.setCommunityId(reqJson.getString("communityId")); floorDto.setFloorId(reqJson.getString("floorId")); //校验小区楼ID和小区是否有对应关系 int total = floorInnerServiceSMOImpl.queryFloorsCount(floorDto); if (total < 1) { throw new IllegalArgumentException("传入小区楼ID不是该小区的楼"); } //校验 小区楼ID 和单元ID是否有关系 UnitDto unitDto = new UnitDto(); unitDto.setFloorId(reqJson.getString("floorId")); unitDto.setUnitId(reqJson.getString("unitId")); total = unitInnerServiceSMOImpl.queryUnitsCount(unitDto); if (total < 1) { throw new IllegalArgumentException("传入单元不是该小区的楼的单元"); } } @Override @Java110Transactional public void doCmd(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException { JSONObject businessUnit = new JSONObject(); businessUnit.put("floorId", reqJson.getString("floorId")); businessUnit.put("layerCount", reqJson.getString("layerCount")); businessUnit.put("unitId", reqJson.getString("unitId")); businessUnit.put("unitNum", reqJson.getString("unitNum")); businessUnit.put("unitName", reqJson.getString("unitName")); businessUnit.put("lift", reqJson.getString("lift")); businessUnit.put("remark", reqJson.getString("remark")); businessUnit.put("unitArea", reqJson.getString("unitArea")); businessUnit.put("userId", reqJson.getString("userId")); UnitPo unitPo = BeanConvertUtil.covertBean(businessUnit, UnitPo.class); int flag = unitV1InnerServiceSMOImpl.updateUnit(unitPo); if (flag < 1) { throw new CmdException("修改单元失败"); } cmdDataFlowContext.setResponseEntity(ResultVo.success()); } }