1111

pom.xml

@@ -43,6 +43,13 @@
             <scope>test</scope>
         </dependency>
 
+        <!--fastjson start-->
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>fastjson</artifactId>
+            <version>1.2.56</version>
+        </dependency>
+        <!--fastjson end-->
 
         <!--oss start-->
         <dependency>

src/main/java/com/example/civilizedcity/common/HttpUtils.java

@@ -0,0 +1,87 @@
+//package com.example.civilizedcity.common;
+//
+//import org.springframework.http.*;
+//import org.springframework.stereotype.Component;
+//import org.springframework.web.client.RestTemplate;
+//
+//import java.io.UnsupportedEncodingException;
+//import java.net.URLDecoder;
+//import java.util.*;
+//
+//@Component
+//public class HttpUtils {
+//    public String get(String url) throws Exception {
+//        RestTemplate restTemplate = new RestTemplate();
+//        HttpHeaders headers = new HttpHeaders();
+//        headers.setAccept(Arrays.asList(MediaType.APPLICATION_JSON));
+//        HttpEntity<String> entity = new HttpEntity<String>(headers);
+//
+//        Map<String, Object> urlAndParams = parseURL(url);
+//        String formatURL = (String) urlAndParams.get("url");
+//        Map<String, String> params = (Map<String, String>) urlAndParams.get("params");
+//
+//        ResponseEntity<String> resp = restTemplate.exchange(formatURL, HttpMethod.GET, entity, String.class, params);
+//        return resp.getBody();
+//    }
+//
+//    public String post(String url, Map<String, String> header, String body) throws Exception {
+//        RestTemplate restTemplate = new RestTemplate();
+//        HttpHeaders headers = new HttpHeaders();
+//        MediaType type = MediaType.parseMediaType("application/json; charset=UTF-8");
+//        headers.setContentType(type);
+//        headers.setAccept(Arrays.asList(MediaType.APPLICATION_JSON));
+//        headers.setAll(header);
+//        HttpEntity<String> entity = new HttpEntity<String>(body, headers);
+//
+//        Map<String, Object> urlAndParams = parseURL(url);
+//        String formatURL = (String) urlAndParams.get("url");
+//        Map<String, String> params = (Map<String, String>) urlAndParams.get("params");
+//
+//        ResponseEntity<String> resp = restTemplate.exchange(formatURL, HttpMethod.POST, entity, String.class, params);
+//        return resp.getBody();
+//    }
+//
+//    // RestTemplate 不能正常的处理 querystring, 必须按照约定的方式处理
+//    private Map<String, Object> parseURL(String url) {
+//        Map<String, Object> res = new HashMap<>();
+//
+//        String[] parts = url.split("\\?");
+//        String baseURL = parts[0];
+//
+//        if (parts.length < 2) {
+//            res.put("url", baseURL);
+//            res.put("params", new HashMap<>());
+//            return res;
+//        }
+//
+//
+//        String[] fields = parts[1].split("&");
+//        Map<String, String> params = new HashMap<>();
+//        List<String> searchList = new ArrayList<>();
+//        for (String field : fields) {
+//            String[] pairs = field.split("=");
+//            if (2 != pairs.length) {
+//                continue;
+//            }
+//
+//            try {
+//                String key = URLDecoder.decode(pairs[0].trim(), "UTF-8");
+//                String val = URLDecoder.decode(pairs[1].trim(), "UTF-8");
+//
+//                // 转化为 "foo={foo}" 这种字符串
+//                searchList.add(String.format("%s={%s}", key, key));
+//                // 把 foo 对应的值存储起来
+//                params.put(key, val);
+//            } catch (UnsupportedEncodingException e) {
+//                e.printStackTrace();
+//            }
+//        }
+//
+//        // url 格式类似 http://foo.org/bar?name={name}
+//        String formatURL = baseURL + "?" + String.join("&", searchList);
+//        res.put("url", formatURL);
+//        res.put("params", params);
+//
+//        return res;
+//    }
+//}

src/main/java/com/example/civilizedcity/common/SMSUtils.java

@@ -0,0 +1,65 @@
+//package com.example.civilizedcity.common;
+//
+//import com.alibaba.fastjson.JSONObject;
+//import lombok.Data;
+//import lombok.experimental.Accessors;
+//import lombok.extern.slf4j.Slf4j;
+//import org.springframework.beans.factory.InitializingBean;
+//import org.springframework.beans.factory.annotation.Autowired;
+//import org.springframework.beans.factory.annotation.Value;
+//import org.springframework.scheduling.annotation.EnableAsync;
+//import org.springframework.scheduling.annotation.EnableScheduling;
+//import org.springframework.stereotype.Component;
+//
+//import java.util.HashMap;
+//import java.util.Map;
+//
+//@Slf4j
+//@Component
+//@EnableScheduling //开启定时任务
+//@EnableAsync  //开启多线程
+//public class SMSUtils implements InitializingBean {
+//    @Autowired
+//    HttpUtils httpUtils;
+//    @Value("${yz.sms.api}")
+//    String smsAPI;
+//
+//    @Value("${yz.sms.appid}")
+//    String appid;
+//
+//    //    @Async
+////    @Scheduled(cron = "0 30 8 * * ?") //时隔多少秒
+//    public void SendMessage(Message message) throws Exception {
+//        long nowMills = System.currentTimeMillis();
+//        String timestamp = String.valueOf(nowMills);
+//        String secret = appid + timestamp;
+//
+//        Map<String, String> header = new HashMap<>();
+//        header.put("x-appid", appid);
+//        header.put("x-timestamp", timestamp);
+//        header.put("x-sign", EncryptUtils.md5(appid + secret, timestamp));
+//
+//        Map<String, String> body = new HashMap<>();
+//        body.put("PhoneNumbers", message.getTel());
+//        body.put("SignName", message.getSign());
+//        body.put("TemplateCode", message.getCode());
+//        body.put("TemplateParam", message.getContent());
+//
+//        httpUtils.post(smsAPI, header, JSONObject.toJSONString(body, false));
+//
+//    }
+//
+//    @Override
+//    public void afterPropertiesSet() throws Exception {
+//    }
+//
+//    @Data
+//    @Accessors(chain = true)
+//    public static class Message {
+//        String code;
+//        String tel;
+//        String sign;
+//        String content;
+//    }
+//
+//}

src/main/java/com/example/civilizedcity/service/impl/TaFeedbackServiceImpl.java

@@ -5,9 +5,9 @@ import com.example.civilizedcity.common.Constants;
 import com.example.civilizedcity.common.StringUtils;
 import com.example.civilizedcity.entity.*;
 import com.example.civilizedcity.mapper.*;
+import com.example.civilizedcity.service.TaFeedbackService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
-import com.example.civilizedcity.service.TaFeedbackService;
 import org.springframework.transaction.annotation.Transactional;
 
 import java.time.LocalDateTime;
@@ -139,6 +139,10 @@ public class TaFeedbackServiceImpl extends BaseServiceImpl<TaFeedbackMapper, TaF
             processStatus = Constants.APPLY_REJECT;
         }
 
+        if (processList.size() == 0) {
+            processList = null;
+        }
+
         return baseMapper.getPageBy(pg, personId, processList, processStatus);
     }
 }