From bec2ef3f7b137304e2188683cc3239716a597e79 Mon Sep 17 00:00:00 2001
From: wuxw <928255095@qq.com>
Date: 星期四, 09 一月 2020 11:59:49 +0800
Subject: [PATCH] Merge branch 'master' of https://github.com/java110/MicroCommunity
---
AppFrontService/src/main/java/com/java110/app/smo/complaint/impl/SaveComplaintSMOImpl.java | 48 +++++++++++++++++++++++++++++++++++++++++++++---
1 files changed, 45 insertions(+), 3 deletions(-)
diff --git a/AppFrontService/src/main/java/com/java110/app/smo/complaint/impl/SaveComplaintSMOImpl.java b/AppFrontService/src/main/java/com/java110/app/smo/complaint/impl/SaveComplaintSMOImpl.java
index 72d5124..d466ebc 100644
--- a/AppFrontService/src/main/java/com/java110/app/smo/complaint/impl/SaveComplaintSMOImpl.java
+++ b/AppFrontService/src/main/java/com/java110/app/smo/complaint/impl/SaveComplaintSMOImpl.java
@@ -1,26 +1,68 @@
package com.java110.app.smo.complaint.impl;
+import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.java110.app.smo.AppAbstractComponentSMO;
import com.java110.app.smo.complaint.ISaveComplaintSMO;
+import com.java110.app.smo.wxLogin.impl.WxLoginSMOImpl;
import com.java110.core.context.IPageData;
+import com.java110.utils.constant.ServiceConstant;
+import com.java110.utils.util.Assert;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpMethod;
+import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Service;
+import org.springframework.web.client.RestTemplate;
import java.io.IOException;
+import java.util.HashMap;
+import java.util.Map;
+@Service("saveComplaintSMOImpl")
public class SaveComplaintSMOImpl extends AppAbstractComponentSMO implements ISaveComplaintSMO {
+ private final static Logger logger = LoggerFactory.getLogger(SaveComplaintSMOImpl.class);
+
+ @Autowired
+ private RestTemplate restTemplate;
+
@Override
public ResponseEntity<String> save(IPageData pd) {
- return null;
+ return businessProcess(pd);
}
@Override
protected void validate(IPageData pd, JSONObject paramIn) {
-
+ Assert.hasKeyAndValue(paramIn, "communityId", "璇锋眰鎶ユ枃涓湭鍖呭惈灏忓尯淇℃伅");
}
@Override
protected ResponseEntity<String> doBusinessProcess(IPageData pd, JSONObject paramIn) throws IOException {
- return null;
+
+ //鏌ヨ鐢ㄦ埛ID
+ paramIn.put("userId", pd.getUserId());
+ //鏌ヨ鍟嗘埛ID
+ Map paramObj = new HashMap();
+ paramObj.put("communityId", paramIn.getString("communityId"));
+ paramObj.put("auditStatusCd", "1100");
+ paramObj.put("memberTypeCd", "390001200002");
+ paramObj.put("page", 1);
+ paramObj.put("row", 1);
+ String url = ServiceConstant.SERVICE_API_URL + "/api/store.listStoresByCommunity" + mapToUrlParam(paramObj);
+ ResponseEntity<String> responseEntity = super.callCenterService(restTemplate, pd, "", url, HttpMethod.GET);
+ if (responseEntity.getStatusCode() != HttpStatus.OK) {
+ return responseEntity;
+ }
+
+ JSONObject storeObj = JSONObject.parseObject(responseEntity.getBody());
+ JSONArray stores = storeObj.getJSONArray("stores");
+ String storeId = stores.getJSONObject(0).getString("storeId");
+ paramIn.put("storeId", storeId);
+ url = ServiceConstant.SERVICE_API_URL + "/api/complaint.saveComplaint";
+ responseEntity = super.callCenterService(restTemplate, pd, paramIn.toJSONString(), url, HttpMethod.POST);
+
+ return responseEntity;
}
}
--
Gitblit v1.8.0