优化代码

service-community/src/main/java/com/java110/community/api/CommunitySettingApi.java

@@ -35,17 +35,17 @@ public class CommunitySettingApi {
      * @serviceCode /communitySetting/saveCommunitySetting
      * @path /app/communitySetting/saveCommunitySetting
      */
-    @RequestMapping(value = "/saveCommunitySetting", method = RequestMethod.POST)
-    public ResponseEntity<String> saveCommunitySetting(@RequestBody JSONObject reqJson) {
-
-        Assert.hasKeyAndValue(reqJson, "communityId", "请求报文中未包含communityId");
-        Assert.hasKeyAndValue(reqJson, "settingType", "请求报文中未包含settingType");
-        Assert.hasKeyAndValue(reqJson, "settingKey", "请求报文中未包含settingKey");
-
-
-        CommunitySettingPo communitySettingPo = BeanConvertUtil.covertBean(reqJson, CommunitySettingPo.class);
-        return saveCommunitySettingBMOImpl.save(communitySettingPo);
-    }
+//    @RequestMapping(value = "/saveCommunitySetting", method = RequestMethod.POST)
+//    public ResponseEntity<String> saveCommunitySetting(@RequestBody JSONObject reqJson) {
+//
+//        Assert.hasKeyAndValue(reqJson, "communityId", "请求报文中未包含communityId");
+//        Assert.hasKeyAndValue(reqJson, "settingType", "请求报文中未包含settingType");
+//        Assert.hasKeyAndValue(reqJson, "settingKey", "请求报文中未包含settingKey");
+//
+//
+//        CommunitySettingPo communitySettingPo = BeanConvertUtil.covertBean(reqJson, CommunitySettingPo.class);
+//        return saveCommunitySettingBMOImpl.save(communitySettingPo);
+//    }
 
     /**
      * 微信修改消息模板

service-community/src/main/java/com/java110/community/cmd/community/SaveCommunitySettingCmd.java

@@ -0,0 +1,90 @@
+package com.java110.community.cmd.community;
+
+import com.alibaba.fastjson.JSONArray;
+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.CommunitySettingFactory;
+import com.java110.core.factory.GenerateCodeFactory;
+import com.java110.dto.community.CommunitySettingDto;
+import com.java110.intf.community.ICommunitySettingInnerServiceSMO;
+import com.java110.po.community.CommunitySettingPo;
+import com.java110.utils.exception.CmdException;
+import com.java110.utils.util.Assert;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import java.text.ParseException;
+import java.util.List;
+
+@Java110Cmd(serviceCode = "community.saveCommunitySetting")
+public class SaveCommunitySettingCmd extends Cmd {
+
+    @Autowired
+    private ICommunitySettingInnerServiceSMO communitySettingInnerServiceSMOImpl;
+
+    @Override
+    public void validate(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException, ParseException {
+        Assert.hasKeyAndValue(reqJson, "communityId", "未包含小区");
+        Assert.hasKeyAndValue(reqJson, "settingType", "未包含类型");
+
+        if (!reqJson.containsKey("keys")) {
+            throw new CmdException("未包内容");
+        }
+
+        JSONArray keys = reqJson.getJSONArray("keys");
+        if (keys == null || keys.size() < 1) {
+            throw new CmdException("未包内容");
+        }
+
+        JSONObject keyObj = null;
+        for (int keyIndex = 0; keyIndex < keys.size(); keyIndex++) {
+            keyObj = keys.getJSONObject(keyIndex);
+            Assert.hasKeyAndValue(keyObj, "settingValue", "未包含值");
+            Assert.hasKeyAndValue(keyObj, "settingKey", "未包含键");
+        }
+    }
+
+    @Override
+    public void doCmd(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException, ParseException {
+
+        JSONArray keys = reqJson.getJSONArray("keys");
+
+        JSONObject keyObj = null;
+        List<CommunitySettingDto> settings = null;
+        CommunitySettingPo communitySettingPo = null;
+        for (int keyIndex = 0; keyIndex < keys.size(); keyIndex++) {
+            keyObj = keys.getJSONObject(keyIndex);
+
+            CommunitySettingDto communitySettingDto = new CommunitySettingDto();
+            communitySettingDto.setSettingKey(keyObj.getString("settingKey"));
+            communitySettingDto.setSettingType(reqJson.getString("settingType"));
+            communitySettingDto.setCommunityId(reqJson.getString("communityId"));
+            settings = communitySettingInnerServiceSMOImpl.queryCommunitySettings(communitySettingDto);
+            communitySettingPo = new CommunitySettingPo();
+            communitySettingPo.setSettingValue(reqJson.getString("settingType"));
+            communitySettingPo.setCommunityId(reqJson.getString("communityId"));
+            communitySettingPo.setSettingKey(keyObj.getString("settingKey"));
+            communitySettingPo.setSettingName(keyObj.getString("settingName"));
+            communitySettingPo.setRemark(keyObj.getString("remark"));
+
+            if (settings == null || settings.size() < 1) {
+                communitySettingPo.setCsId(GenerateCodeFactory.getGeneratorId("11"));
+
+                communitySettingInnerServiceSMOImpl.saveCommunitySetting(communitySettingPo);
+                continue;
+            }
+
+            communitySettingPo.setCsId(settings.get(0).getCsId());
+            communitySettingInnerServiceSMOImpl.updateCommunitySetting(communitySettingPo);
+
+            //将结果写入缓存
+            CommunitySettingFactory.getCommunitySettingFromDb(communitySettingPo.getCommunityId(), communitySettingPo.getSettingKey());
+
+        }
+
+
+
+    }
+}