|
|
@@ -0,0 +1,110 @@
|
|
|
+package com.java110.web.components.floor;
|
|
|
+
|
|
|
+import com.alibaba.fastjson.JSONObject;
|
|
|
+import com.java110.common.util.Assert;
|
|
|
+import com.java110.core.context.IPageData;
|
|
|
+import com.java110.core.context.PageData;
|
|
|
+import com.java110.web.smo.IFloorServiceSMO;
|
|
|
+import com.java110.web.smo.impl.FloorServiceSMOImpl;
|
|
|
+import org.slf4j.Logger;
|
|
|
+import org.slf4j.LoggerFactory;
|
|
|
+import org.springframework.beans.factory.annotation.Autowired;
|
|
|
+import org.springframework.http.HttpStatus;
|
|
|
+import org.springframework.http.ResponseEntity;
|
|
|
+import org.springframework.stereotype.Component;
|
|
|
+
|
|
|
+/**
|
|
|
+ * 添加小区楼组件
|
|
|
+ */
|
|
|
+@Component("batchAddFloor")
|
|
|
+public class BatchAddFloorComponent {
|
|
|
+
|
|
|
+ private static Logger logger = LoggerFactory.getLogger(BatchAddFloorComponent.class);
|
|
|
+
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private IFloorServiceSMO floorServiceSMOImpl;
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 查询小区楼信息
|
|
|
+ *
|
|
|
+ * @param pd 页面封装对象 包含页面请求数据
|
|
|
+ * @return ResponseEntity对象返回给页面
|
|
|
+ */
|
|
|
+ public ResponseEntity<String> saveFloor(IPageData pd) {
|
|
|
+
|
|
|
+ JSONObject floors = JSONObject.parseObject(pd.getReqData());
|
|
|
+
|
|
|
+ Assert.hasKeyAndValue(floors, "startFloorNum", "请求报文中未包含startFloorNum 节点");
|
|
|
+ Assert.hasKeyAndValue(floors, "endFloorNum", "请求报文中未包含startFloorNum 节点");
|
|
|
+ Assert.hasKeyAndValue(floors, "communityId", "请求报文中未包含communityId 节点");
|
|
|
+
|
|
|
+ Assert.isInteger(floors.getString("startFloorNum"), "开始楼栋编号不是数字");
|
|
|
+ Assert.isInteger(floors.getString("endFloorNum"), "结束楼栋编号不是数字");
|
|
|
+
|
|
|
+ int startFloorNum = floors.getInteger("startFloorNum");
|
|
|
+ int endFloorNum = floors.getInteger("endFloorNum");
|
|
|
+
|
|
|
+ if (endFloorNum <= startFloorNum) {
|
|
|
+ throw new IllegalArgumentException("结束楼栋编号不能小于等于开始楼栋编号");
|
|
|
+ }
|
|
|
+
|
|
|
+ if (endFloorNum - startFloorNum > 50) {
|
|
|
+ throw new IllegalArgumentException("一次批量生成不能超过50栋楼");
|
|
|
+ }
|
|
|
+
|
|
|
+ int successFloorCount = 0;
|
|
|
+ int failFloorCount = 0;
|
|
|
+
|
|
|
+ IPageData newPd = null;
|
|
|
+
|
|
|
+ /**
|
|
|
+ * "communityId", "未包含
|
|
|
+ * "name", "未包含小区楼名称")
|
|
|
+ * "floorNum", "未包含小区楼
|
|
|
+ * "remark", "未包含小区楼备注
|
|
|
+ */
|
|
|
+ JSONObject needReqParam = null;
|
|
|
+ ResponseEntity<String> floorEntity = null;
|
|
|
+ for (int floorIndex = startFloorNum; floorIndex <= endFloorNum; floorIndex++) {
|
|
|
+ try {
|
|
|
+ needReqParam = new JSONObject();
|
|
|
+ needReqParam.put("communityId", floors.getString("communityId"));
|
|
|
+ needReqParam.put("floorNum", floorIndex);
|
|
|
+ needReqParam.put("name", floorIndex + "号楼");
|
|
|
+ needReqParam.put("remark", floors.containsKey("remark") ? floors.getString("remark") : "");
|
|
|
+ newPd = PageData.newInstance().builder(pd.getUserId(),
|
|
|
+ pd.getToken(),
|
|
|
+ needReqParam.toJSONString(),
|
|
|
+ pd.getComponentCode(),
|
|
|
+ pd.getComponentMethod(), "", pd.getSessionId());
|
|
|
+ floorEntity = floorServiceSMOImpl.saveFloor(newPd);
|
|
|
+
|
|
|
+ if(floorEntity.getStatusCode() == HttpStatus.OK){
|
|
|
+ successFloorCount ++;
|
|
|
+ }else{
|
|
|
+ failFloorCount ++;
|
|
|
+ }
|
|
|
+ }catch (Exception e){
|
|
|
+ logger.error("批量生成楼栋失败",e);
|
|
|
+ failFloorCount ++;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ JSONObject outParam = new JSONObject();
|
|
|
+ outParam.put("successFloorCount",successFloorCount);
|
|
|
+ outParam.put("failFloorCount",failFloorCount);
|
|
|
+
|
|
|
+
|
|
|
+ return new ResponseEntity<String>(outParam.toJSONString(), HttpStatus.OK);
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ public IFloorServiceSMO getFloorServiceSMOImpl() {
|
|
|
+ return floorServiceSMOImpl;
|
|
|
+ }
|
|
|
+
|
|
|
+ public void setFloorServiceSMOImpl(IFloorServiceSMO floorServiceSMOImpl) {
|
|
|
+ this.floorServiceSMOImpl = floorServiceSMOImpl;
|
|
|
+ }
|
|
|
+}
|