From 81da61b828e29b7745e1382dfbbaeb685dc083ef Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期二, 23 一月 2024 17:17:55 +0800
Subject: [PATCH] 抖音转链修改
---
fanli/src/main/java/com/yeshi/fanli/controller/admin/UserRankingsAdminController.java | 1821 +++++++++++++++++++++++++++++-----------------------------
1 files changed, 911 insertions(+), 910 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/controller/admin/UserRankingsAdminController.java b/fanli/src/main/java/com/yeshi/fanli/controller/admin/UserRankingsAdminController.java
index 93207ca..7a7c32a 100644
--- a/fanli/src/main/java/com/yeshi/fanli/controller/admin/UserRankingsAdminController.java
+++ b/fanli/src/main/java/com/yeshi/fanli/controller/admin/UserRankingsAdminController.java
@@ -1,910 +1,911 @@
-package com.yeshi.fanli.controller.admin;
-
-import java.io.BufferedWriter;
-import java.io.ByteArrayOutputStream;
-import java.io.DataInputStream;
-import java.io.File;
-import java.io.FileOutputStream;
-import java.io.FileWriter;
-import java.io.IOException;
-import java.io.PrintWriter;
-import java.net.MalformedURLException;
-import java.net.URL;
-import java.util.ArrayList;
-import java.util.Date;
-import java.util.List;
-
-import javax.annotation.Resource;
-import javax.servlet.http.HttpServletRequest;
-
-import net.sf.json.JSONObject;
-
-import org.springframework.core.task.TaskExecutor;
-import org.springframework.stereotype.Controller;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RequestParam;
-import org.springframework.web.multipart.MultipartFile;
-import org.springframework.web.multipart.MultipartHttpServletRequest;
-import org.springframework.web.multipart.commons.CommonsMultipartFile;
-import org.yeshi.utils.JsonUtil;
-
-import com.google.gson.Gson;
-import com.google.gson.GsonBuilder;
-import com.google.gson.reflect.TypeToken;
-import com.yeshi.fanli.entity.bus.user.ShamUser;
-import com.yeshi.fanli.entity.bus.user.UserRankings;
-import com.yeshi.fanli.exception.UserRankingsException;
-import com.yeshi.fanli.service.inter.user.ShamUserService;
-import com.yeshi.fanli.service.inter.user.UserRankingsService;
-import com.yeshi.fanli.tag.PageEntity;
-import com.yeshi.fanli.util.Constant;
-import com.yeshi.fanli.util.StringUtil;
-
-@Controller
-@RequestMapping("admin/new/api/v1/rankings")
-public class UserRankingsAdminController {
-
- @Resource
- private UserRankingsService userRankingsService;
- @Resource
- private ShamUserService shamUserService;
- @Resource(name = "taskExecutor")
- private TaskExecutor executor;
-
-
-
- @RequestMapping(value = "saveAdd")
- public void saveAdd(String callback, UserRankings userRankings, HttpServletRequest request, PrintWriter out) {
-
-
- try {
-
- String nickName = userRankings.getNickName();
-
- if (StringUtil.isNullOrEmpty(nickName)) {
- JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鐢ㄦ埛鍚嶇О涓嶈兘涓虹┖"));
- return;
- }
-
- // 鏌ヨ鏄电О鏄惁宸插瓨鍦�
- List<UserRankings> listRankings = userRankingsService.selectByNickName(nickName.trim());
-
- if (listRankings != null && listRankings.size() > 0) {
- JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("["+ nickName +"] 姝ゆ樀绉板凡瀛樺湪"));
- return;
- }
-
- if (request instanceof MultipartHttpServletRequest) {
-
- List<MultipartFile> files = ((MultipartHttpServletRequest) request).getFiles("file");
-
- if (files != null && files.size() > 0) {
- userRankingsService.insertAndUploadFile(userRankings, files.get(0));
- } else {
- userRankingsService.insertAndUploadFile(userRankings, null);
- }
-
- } else {
- userRankingsService.insertAndUploadFile(userRankings, null);
- }
-
- JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("娣诲姞鎴愬姛"));
-
- } catch (Exception e) {
-
- JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("娣诲姞澶辫触"));
- e.printStackTrace();
- }
-
- }
-
-
- @RequestMapping(value = "saveModify")
- public void saveModify(String callback, UserRankings userRankings, PrintWriter out) {
-
- try {
- Long id = userRankings.getId();
- if (id == null) {
- JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("璇蜂紶閫掓纭弬鏁�"));
- return;
- }
-
- UserRankings resultObj = userRankingsService.selectByPrimaryKey(id);
- if (resultObj == null) {
- JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鏁版嵁涓嶅瓨鍦ㄦ垨宸茶鍒犻櫎"));
- return;
- }
-
- String nickName = userRankings.getNickName();
- if (!StringUtil.isNullOrEmpty(nickName)) {
- // 鏌ヨ鏄电О鏄惁宸插瓨鍦�
- List<UserRankings> listRankings = userRankingsService.selectByNickName(nickName.trim());
-
- if (listRankings != null && listRankings.size() > 0) {
- boolean proess = false;
- for (UserRankings userRanking: listRankings) {
- Long objid = userRanking.getId();
- if (id.equals(objid)){
- proess = true;
- }
- }
-
- if (!proess){
- JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("["+ nickName +"] 姝ゆ樀绉板凡瀛樺湪"));
- return;
- }
- }
- }
-
- Integer shareState = userRankings.getShareState();
- if (shareState != null && (shareState.equals(1) || shareState == 1)){
- userRankings.setShareTime(new Date());
- }
-
- Integer tradeState = userRankings.getTradeState();
- if (tradeState != null && (tradeState.equals(1) || tradeState == 1)){
- userRankings.setTradeTime(new Date());
- }
-
- userRankingsService.updateByPrimaryKeySelective(userRankings);
- JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("淇敼鎴愬姛"));
-
- } catch (UserRankingsException e) {
- JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("淇敼澶辫触"));
- e.printStackTrace();
- }
-
- }
-
-
- @RequestMapping(value = "deleteBatch")
- public void deleteBatch(String callback, String idArray, PrintWriter out) {
-
- try {
-
- if (StringUtil.isNullOrEmpty(idArray)) {
- JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("璇烽�夋嫨鍒犻櫎鐨勬暟鎹�"));
- return;
- }
-
- Gson gson = new Gson();
- List<Long> arrayID = gson.fromJson(idArray, new TypeToken<ArrayList<Long>>() {}.getType());
- if (arrayID == null || arrayID.size() == 0) {
- JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鏈娴嬪埌鍒犻櫎鐨勬暟鎹�"));
- return;
- }
-
- userRankingsService.deleteBatchByPrimaryKey(arrayID);
-
- out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult("鍒犻櫎鎴愬姛")));
-
- } catch (UserRankingsException e) {
- JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鍒犻櫎澶辫触"));
- e.printStackTrace();
- }
- }
-
-
- @RequestMapping(value = "uploadPicture")
- public void uploadImg(String callback, Long id, @RequestParam("file") CommonsMultipartFile file,
- PrintWriter out) {
- try {
-
- if (file == null) {
- JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("涓婁紶鏂囦欢涓嶈兘涓虹┖"));
- return;
- }
-
- if (id == null) {
- JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("璇蜂紶閫掓纭弬鏁�"));
- return;
- }
-
- UserRankings resultObj = userRankingsService.selectByPrimaryKey(id);
- if (resultObj == null) {
- JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鏁版嵁涓嶅瓨鍦ㄦ垨宸茶鍒犻櫎"));
- return;
- }
-
- userRankingsService.uploadPicture(file, resultObj);
-
- JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("鍥剧墖涓婁紶鎴愬姛"));
-
- } catch (Exception e) {
- JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鍥剧墖涓婁紶澶辫触"));
- e.printStackTrace();
- }
- }
-
-
-
-
- @RequestMapping(value = "removePicture")
- public void uploadImg(String callback, Long id, PrintWriter out) {
-
- try {
-
- if (id == null) {
- JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("璇蜂紶閫掓纭弬鏁�"));
- return;
- }
-
- UserRankings resultObj = userRankingsService.selectByPrimaryKey(id);
- if (resultObj == null) {
- JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鏁版嵁涓嶅瓨鍦ㄦ垨宸茶鍒犻櫎"));
- return;
- }
-
- userRankingsService.removePicture(resultObj);
-
- JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("鍥剧墖鍒犻櫎鎴愬姛"));
-
- } catch (Exception e) {
- JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鍥剧墖鍒犻櫎澶辫触"));
- e.printStackTrace();
- }
- }
-
-
-
-
- /**
- * 鏌ユ壘鎵�鏈夋爣绛�
- *
- * @param callback
- * @param pageIndex
- * @param key
- * @param startTime
- * @param endTime
- * @param out
- */
- @RequestMapping(value = "query")
- public void query(String callback, Integer pageIndex, Integer pageSize, String key,
- Integer tradeState, Integer shareState, Integer sort, PrintWriter out) {
-
- try {
-
- if (pageIndex == null || pageIndex < 1)
- pageIndex = 1;
-
- if (pageSize == null || pageSize < 1)
- pageSize = Constant.PAGE_SIZE;
-
- if (sort == null || sort < 1 || sort >8)
- sort = 1;
-
-
- List<UserRankings> userRankingsList = userRankingsService.query((pageIndex - 1) * pageSize,
- pageSize, key, tradeState, shareState, sort);
-
- if (userRankingsList == null || userRankingsList.size() == 0) {
- out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("鏆傛棤鐩稿叧鏁版嵁")));
- return;
- }
-
- long count = userRankingsService.queryCount(key, tradeState, shareState);
- int totalPage = (int) (count % pageSize == 0 ? count / pageSize : count / pageSize + 1);
- PageEntity pe = new PageEntity(pageIndex, pageSize, count, totalPage);
-
-
- GsonBuilder gsonBuilder = new GsonBuilder();
- gsonBuilder.serializeNulls();
- Gson gson = gsonBuilder.setDateFormat("yyyy/MM/dd HH:mm:ss").create();
-
- JSONObject data = new JSONObject();
- data.put("pe", pe);
- data.put("result_list", gson.toJson(userRankingsList));
-
- JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data));
-
- } catch (Exception e) {
- JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鏌ヨ澶辫触"));
- e.printStackTrace();
- }
- }
-
- /**
- * 锛堥殢鏈烘潈濂栭噾锛�
- * @param callback
- * @param request
- * @param out @param 澶у��
- * @param 灏忓��
- */
- @RequestMapping(value = "setRewardtBatch")
- public void setRewardtBatch(String callback,String ids, Integer type, Double reward,
- Double startReward, Double endReward, HttpServletRequest request, PrintWriter out) {
-
- try {
-
- if (StringUtil.isNullOrEmpty(ids)) {
- JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鏈�夋嫨闇�鎿嶄綔鐨勭敤鎴�"));
- return;
- }
-
- // type : 1 鑷喘 2 鍒嗕韩
- if (type == null || type <1 || type >2) {
- JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("璇烽�夋嫨姝ｇ‘鐨勭被鍨�"));
- return;
- }
-
-
- Gson gson = new Gson();
- List<Long> idList = gson.fromJson(ids, new TypeToken<ArrayList<Long>>() {}.getType());
-
- if (idList == null || idList.size() == 0) {
- JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("璇烽�夋嫨闇�鎿嶄綔鐨勭敤鎴�"));
- return;
- }
-
- userRankingsService.setRewardtBatch(idList, type, reward, startReward, endReward);
-
- JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("鎿嶄綔鎴愬姛"));
-
- } catch ( Exception e) {
- JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鎿嶄綔澶辫触"));
- e.printStackTrace();
- }
-
- }
-
-
- /**
- * 锛堥殢鏈烘潈濂栭噾锛�
- * @param callback
- * @param request
- * @param out @param 澶у��
- * @param 灏忓��
- */
- @RequestMapping(value = "setStateBatch")
- public void setStateBatch(String callback, String ids, Integer type, Integer state, PrintWriter out) {
-
- try {
-
- if (StringUtil.isNullOrEmpty(ids)) {
- JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鏈�夋嫨闇�鎿嶄綔鐨勭敤鎴�"));
- return;
- }
-
- // type : 1 鑷喘 2 鍒嗕韩
- if (type == null || type <1 || type >2) {
- JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("璇烽�夋嫨姝ｇ‘鐨勭被鍨�"));
- return;
- }
-
-
- Gson gson = new Gson();
- List<Long> idList = gson.fromJson(ids, new TypeToken<ArrayList<Long>>() {}.getType());
-
- if (idList == null || idList.size() == 0) {
- JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("璇烽�夋嫨闇�鎿嶄綔鐨勭敤鎴�"));
- return;
- }
-
- userRankingsService.setStateBatch(idList, type, state);
-
- JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("鎿嶄綔鎴愬姛"));
-
- } catch ( Exception e) {
- JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鎿嶄綔澶辫触"));
- e.printStackTrace();
- }
- }
-
- @RequestMapping(value = "batchUpFile")
- public void batchUpFile(PrintWriter out) {
-
- try {
-
- File file = new File("E:\\test");// 闇�瑕佹煡鎵剧殑鏂囦欢澶�
-
- userRankingsService.uploadFile(file);
-
- JsonUtil.printMode(out, null, JsonUtil.loadTrueResult("鍥剧墖涓婁紶鎴愬姛"));
-
- } catch (Exception e) {
-
- JsonUtil.printMode(out, null, JsonUtil.loadFalseResult("鍥剧墖涓婁紶澶辫触"));
- e.printStackTrace();
- }
- }
-
-
- @RequestMapping(value = "batchUpShowID")
- public void batchUpShowID(PrintWriter out) {
-
- try {
-
- File file = new File("E:\\idtest\\IDS.txt");//Text鏂囦欢
-
- userRankingsService.updateShowID(file);
-
- JsonUtil.printMode(out, null, JsonUtil.loadTrueResult("涓婁紶鎴愬姛"));
-
- } catch (Exception e) {
-
- JsonUtil.printMode(out, null, JsonUtil.loadFalseResult("鍥剧墖涓婁紶澶辫触"));
- e.printStackTrace();
- }
- }
-
- @RequestMapping(value = "batchUpNickName")
- public void batchUpNickName(PrintWriter out) {
-
- try {
-
- File file = new File("E:\\idtest\\Names.txt");//Text鏂囦欢
-
- userRankingsService.batchUpNickName(file);
-
- JsonUtil.printMode(out, null, JsonUtil.loadTrueResult("涓婁紶鎴愬姛"));
-
- } catch (Exception e) {
-
- JsonUtil.printMode(out, null, JsonUtil.loadFalseResult("鍥剧墖涓婁紶澶辫触"));
- e.printStackTrace();
- }
- }
-
-
-
- @RequestMapping(value = "downPic")
- public void downPic(PrintWriter out) {
-
- try {
-
- List<ShamUser> list = shamUserService.findShamUserList(100000);
-
- executor.execute(new Runnable() {
- @Override
- public void run() {
- try {
- /* 璇诲叆TXT鏂囦欢 */
- String pathname = "E:\\name.txt"; // 缁濆璺緞鎴栫浉瀵硅矾寰勯兘鍙互锛岃繖閲屾槸缁濆璺緞锛屽啓鍏ユ枃浠舵椂婕旂ず鐩稿璺緞
- File writename = new File(pathname); // 瑕佽鍙栦互涓婅矾寰勭殑input銆倀xt鏂囦欢
-
- BufferedWriter outWriter;
-
- outWriter = new BufferedWriter(new FileWriter(writename));
-
- /* 璇诲叆TXT鏂囦欢 */
- String pathID = "E:\\id.txt"; // 缁濆璺緞鎴栫浉瀵硅矾寰勯兘鍙互锛岃繖閲屾槸缁濆璺緞锛屽啓鍏ユ枃浠舵椂婕旂ず鐩稿璺緞
- File writeID = new File(pathID); // 瑕佽鍙栦互涓婅矾寰勭殑input銆倀xt鏂囦欢
-
- BufferedWriter outID = new BufferedWriter(new FileWriter(writeID));
- List<ShamUser> subList = list.subList(0, 10000);
- for (ShamUser shamUser : subList) {
- String picUrl = shamUser.getPicUrl();
- if (!StringUtil.isNullOrEmpty(picUrl)) {
- long id = shamUser.getId();
- String path = "E:/test/" + id + ".jpg";
- // 涓嬭浇鍥剧墖
- downloadPicture(picUrl, path);
- // 涓嬭浇鏂囧瓧
- outID.write(id + "\r\n");
- outWriter.write(shamUser.getName() + "\r\n");
- }
- }
- outID.flush();// 鎶婄紦瀛樺尯鍐呭鍘嬪叆鏂囦欢
- outID.close(); // 鏈�鍚庤寰楀叧闂枃浠�
-
- outWriter.flush(); // 鎶婄紦瀛樺尯鍐呭鍘嬪叆鏂囦欢
- outWriter.close(); // 鏈�鍚庤寰楀叧闂枃浠�
- } catch (Exception e) {
- e.printStackTrace();
- }
- }
- });
-
- executor.execute(new Runnable() {
- @Override
- public void run() {
- try {
- /* 璇诲叆TXT鏂囦欢 */
- String pathname = "E:\\name.txt"; // 缁濆璺緞鎴栫浉瀵硅矾寰勯兘鍙互锛岃繖閲屾槸缁濆璺緞锛屽啓鍏ユ枃浠舵椂婕旂ず鐩稿璺緞
- File writename = new File(pathname); // 瑕佽鍙栦互涓婅矾寰勭殑input銆倀xt鏂囦欢
-
- BufferedWriter outWriter;
-
- outWriter = new BufferedWriter(new FileWriter(writename));
-
- /* 璇诲叆TXT鏂囦欢 */
- String pathID = "E:\\id.txt"; // 缁濆璺緞鎴栫浉瀵硅矾寰勯兘鍙互锛岃繖閲屾槸缁濆璺緞锛屽啓鍏ユ枃浠舵椂婕旂ず鐩稿璺緞
- File writeID = new File(pathID); // 瑕佽鍙栦互涓婅矾寰勭殑input銆倀xt鏂囦欢
-
- BufferedWriter outID = new BufferedWriter(new FileWriter(writeID));
- List<ShamUser> subList = list.subList(10000, 20000);
- for (ShamUser shamUser : subList) {
- String picUrl = shamUser.getPicUrl();
- if (!StringUtil.isNullOrEmpty(picUrl)) {
- long id = shamUser.getId();
- String path = "E:/test/" + id + ".jpg";
- // 涓嬭浇鍥剧墖
- downloadPicture(picUrl, path);
- // 涓嬭浇鏂囧瓧
- outID.write(id + "\r\n");
- outWriter.write(shamUser.getName() + "\r\n");
- }
- }
- outID.flush();// 鎶婄紦瀛樺尯鍐呭鍘嬪叆鏂囦欢
- outID.close(); // 鏈�鍚庤寰楀叧闂枃浠�
-
- outWriter.flush(); // 鎶婄紦瀛樺尯鍐呭鍘嬪叆鏂囦欢
- outWriter.close(); // 鏈�鍚庤寰楀叧闂枃浠�
- } catch (Exception e) {
- e.printStackTrace();
- }
- }
- });
-
- executor.execute(new Runnable() {
- @Override
- public void run() {
- try {
- /* 璇诲叆TXT鏂囦欢 */
- String pathname = "E:\\name.txt"; // 缁濆璺緞鎴栫浉瀵硅矾寰勯兘鍙互锛岃繖閲屾槸缁濆璺緞锛屽啓鍏ユ枃浠舵椂婕旂ず鐩稿璺緞
- File writename = new File(pathname); // 瑕佽鍙栦互涓婅矾寰勭殑input銆倀xt鏂囦欢
-
- BufferedWriter outWriter;
-
- outWriter = new BufferedWriter(new FileWriter(writename));
-
- /* 璇诲叆TXT鏂囦欢 */
- String pathID = "E:\\id.txt"; // 缁濆璺緞鎴栫浉瀵硅矾寰勯兘鍙互锛岃繖閲屾槸缁濆璺緞锛屽啓鍏ユ枃浠舵椂婕旂ず鐩稿璺緞
- File writeID = new File(pathID); // 瑕佽鍙栦互涓婅矾寰勭殑input銆倀xt鏂囦欢
-
- BufferedWriter outID = new BufferedWriter(new FileWriter(writeID));
- List<ShamUser> subList = list.subList(20000, 30000);
- for (ShamUser shamUser : subList) {
- String picUrl = shamUser.getPicUrl();
- if (!StringUtil.isNullOrEmpty(picUrl)) {
- long id = shamUser.getId();
- String path = "E:/test/" + id + ".jpg";
- // 涓嬭浇鍥剧墖
- downloadPicture(picUrl, path);
- // 涓嬭浇鏂囧瓧
- outID.write(id + "\r\n");
- outWriter.write(shamUser.getName() + "\r\n");
- }
- }
- outID.flush();// 鎶婄紦瀛樺尯鍐呭鍘嬪叆鏂囦欢
- outID.close(); // 鏈�鍚庤寰楀叧闂枃浠�
-
- outWriter.flush(); // 鎶婄紦瀛樺尯鍐呭鍘嬪叆鏂囦欢
- outWriter.close(); // 鏈�鍚庤寰楀叧闂枃浠�
- } catch (Exception e) {
- e.printStackTrace();
- }
- }
- });
-
- executor.execute(new Runnable() {
- @Override
- public void run() {
- try {
- /* 璇诲叆TXT鏂囦欢 */
- String pathname = "E:\\name.txt"; // 缁濆璺緞鎴栫浉瀵硅矾寰勯兘鍙互锛岃繖閲屾槸缁濆璺緞锛屽啓鍏ユ枃浠舵椂婕旂ず鐩稿璺緞
- File writename = new File(pathname); // 瑕佽鍙栦互涓婅矾寰勭殑input銆倀xt鏂囦欢
-
- BufferedWriter outWriter;
-
- outWriter = new BufferedWriter(new FileWriter(writename));
-
- /* 璇诲叆TXT鏂囦欢 */
- String pathID = "E:\\id.txt"; // 缁濆璺緞鎴栫浉瀵硅矾寰勯兘鍙互锛岃繖閲屾槸缁濆璺緞锛屽啓鍏ユ枃浠舵椂婕旂ず鐩稿璺緞
- File writeID = new File(pathID); // 瑕佽鍙栦互涓婅矾寰勭殑input銆倀xt鏂囦欢
-
- BufferedWriter outID = new BufferedWriter(new FileWriter(writeID));
- List<ShamUser> subList = list.subList(30000, 40000);
- for (ShamUser shamUser : subList) {
- String picUrl = shamUser.getPicUrl();
- if (!StringUtil.isNullOrEmpty(picUrl)) {
- long id = shamUser.getId();
- String path = "E:/test/" + id + ".jpg";
- // 涓嬭浇鍥剧墖
- downloadPicture(picUrl, path);
- // 涓嬭浇鏂囧瓧
- outID.write(id + "\r\n");
- outWriter.write(shamUser.getName() + "\r\n");
- }
- }
- outID.flush();// 鎶婄紦瀛樺尯鍐呭鍘嬪叆鏂囦欢
- outID.close(); // 鏈�鍚庤寰楀叧闂枃浠�
-
- outWriter.flush(); // 鎶婄紦瀛樺尯鍐呭鍘嬪叆鏂囦欢
- outWriter.close(); // 鏈�鍚庤寰楀叧闂枃浠�
- } catch (Exception e) {
- e.printStackTrace();
- }
-
- }
- });
-
-
- executor.execute(new Runnable() {
- @Override
- public void run() {
- try {
- /* 璇诲叆TXT鏂囦欢 */
- String pathname = "E:\\name.txt"; // 缁濆璺緞鎴栫浉瀵硅矾寰勯兘鍙互锛岃繖閲屾槸缁濆璺緞锛屽啓鍏ユ枃浠舵椂婕旂ず鐩稿璺緞
- File writename = new File(pathname); // 瑕佽鍙栦互涓婅矾寰勭殑input銆倀xt鏂囦欢
-
- BufferedWriter outWriter;
-
- outWriter = new BufferedWriter(new FileWriter(writename));
-
- /* 璇诲叆TXT鏂囦欢 */
- String pathID = "E:\\id.txt"; // 缁濆璺緞鎴栫浉瀵硅矾寰勯兘鍙互锛岃繖閲屾槸缁濆璺緞锛屽啓鍏ユ枃浠舵椂婕旂ず鐩稿璺緞
- File writeID = new File(pathID); // 瑕佽鍙栦互涓婅矾寰勭殑input銆倀xt鏂囦欢
-
- BufferedWriter outID = new BufferedWriter(new FileWriter(writeID));
- List<ShamUser> subList = list.subList(40000, 50000);
- for (ShamUser shamUser : subList) {
- String picUrl = shamUser.getPicUrl();
- if (!StringUtil.isNullOrEmpty(picUrl)) {
- long id = shamUser.getId();
- String path = "E:/test/" + id + ".jpg";
- // 涓嬭浇鍥剧墖
- downloadPicture(picUrl, path);
- // 涓嬭浇鏂囧瓧
- outID.write(id + "\r\n");
- outWriter.write(shamUser.getName() + "\r\n");
- }
- }
- outID.flush();// 鎶婄紦瀛樺尯鍐呭鍘嬪叆鏂囦欢
- outID.close(); // 鏈�鍚庤寰楀叧闂枃浠�
-
- outWriter.flush(); // 鎶婄紦瀛樺尯鍐呭鍘嬪叆鏂囦欢
- outWriter.close(); // 鏈�鍚庤寰楀叧闂枃浠�
- } catch (Exception e) {
- e.printStackTrace();
- }
-
- }
- });
-
- executor.execute(new Runnable() {
- @Override
- public void run() {
- try {
- /* 璇诲叆TXT鏂囦欢 */
- String pathname = "E:\\name.txt"; // 缁濆璺緞鎴栫浉瀵硅矾寰勯兘鍙互锛岃繖閲屾槸缁濆璺緞锛屽啓鍏ユ枃浠舵椂婕旂ず鐩稿璺緞
- File writename = new File(pathname); // 瑕佽鍙栦互涓婅矾寰勭殑input銆倀xt鏂囦欢
-
- BufferedWriter outWriter;
-
- outWriter = new BufferedWriter(new FileWriter(writename));
-
- /* 璇诲叆TXT鏂囦欢 */
- String pathID = "E:\\id.txt"; // 缁濆璺緞鎴栫浉瀵硅矾寰勯兘鍙互锛岃繖閲屾槸缁濆璺緞锛屽啓鍏ユ枃浠舵椂婕旂ず鐩稿璺緞
- File writeID = new File(pathID); // 瑕佽鍙栦互涓婅矾寰勭殑input銆倀xt鏂囦欢
-
- BufferedWriter outID = new BufferedWriter(new FileWriter(writeID));
- List<ShamUser> subList = list.subList(50000, 60000);
- for (ShamUser shamUser : subList) {
- String picUrl = shamUser.getPicUrl();
- if (!StringUtil.isNullOrEmpty(picUrl)) {
- long id = shamUser.getId();
- String path = "E:/test/" + id + ".jpg";
- // 涓嬭浇鍥剧墖
- downloadPicture(picUrl, path);
- // 涓嬭浇鏂囧瓧
- outID.write(id + "\r\n");
- outWriter.write(shamUser.getName() + "\r\n");
- }
- }
- outID.flush();// 鎶婄紦瀛樺尯鍐呭鍘嬪叆鏂囦欢
- outID.close(); // 鏈�鍚庤寰楀叧闂枃浠�
-
- outWriter.flush(); // 鎶婄紦瀛樺尯鍐呭鍘嬪叆鏂囦欢
- outWriter.close(); // 鏈�鍚庤寰楀叧闂枃浠�
- } catch (Exception e) {
- e.printStackTrace();
- }
-
- }
- });
-
-
- executor.execute(new Runnable() {
- @Override
- public void run() {
- try {
- /* 璇诲叆TXT鏂囦欢 */
- String pathname = "E:\\name.txt"; // 缁濆璺緞鎴栫浉瀵硅矾寰勯兘鍙互锛岃繖閲屾槸缁濆璺緞锛屽啓鍏ユ枃浠舵椂婕旂ず鐩稿璺緞
- File writename = new File(pathname); // 瑕佽鍙栦互涓婅矾寰勭殑input銆倀xt鏂囦欢
-
- BufferedWriter outWriter;
-
- outWriter = new BufferedWriter(new FileWriter(writename));
-
- /* 璇诲叆TXT鏂囦欢 */
- String pathID = "E:\\id.txt"; // 缁濆璺緞鎴栫浉瀵硅矾寰勯兘鍙互锛岃繖閲屾槸缁濆璺緞锛屽啓鍏ユ枃浠舵椂婕旂ず鐩稿璺緞
- File writeID = new File(pathID); // 瑕佽鍙栦互涓婅矾寰勭殑input銆倀xt鏂囦欢
-
- BufferedWriter outID = new BufferedWriter(new FileWriter(writeID));
- List<ShamUser> subList = list.subList(60000, 70000);
- for (ShamUser shamUser : subList) {
- String picUrl = shamUser.getPicUrl();
- if (!StringUtil.isNullOrEmpty(picUrl)) {
- long id = shamUser.getId();
- String path = "E:/test/" + id + ".jpg";
- // 涓嬭浇鍥剧墖
- downloadPicture(picUrl, path);
- // 涓嬭浇鏂囧瓧
- outID.write(id + "\r\n");
- outWriter.write(shamUser.getName() + "\r\n");
- }
- }
- outID.flush();// 鎶婄紦瀛樺尯鍐呭鍘嬪叆鏂囦欢
- outID.close(); // 鏈�鍚庤寰楀叧闂枃浠�
-
- outWriter.flush(); // 鎶婄紦瀛樺尯鍐呭鍘嬪叆鏂囦欢
- outWriter.close(); // 鏈�鍚庤寰楀叧闂枃浠�
- } catch (Exception e) {
- e.printStackTrace();
- }
-
- }
- });
- executor.execute(new Runnable() {
- @Override
- public void run() {
- try {
- /* 璇诲叆TXT鏂囦欢 */
- String pathname = "E:\\name.txt"; // 缁濆璺緞鎴栫浉瀵硅矾寰勯兘鍙互锛岃繖閲屾槸缁濆璺緞锛屽啓鍏ユ枃浠舵椂婕旂ず鐩稿璺緞
- File writename = new File(pathname); // 瑕佽鍙栦互涓婅矾寰勭殑input銆倀xt鏂囦欢
-
- BufferedWriter outWriter;
-
- outWriter = new BufferedWriter(new FileWriter(writename));
-
- /* 璇诲叆TXT鏂囦欢 */
- String pathID = "E:\\id.txt"; // 缁濆璺緞鎴栫浉瀵硅矾寰勯兘鍙互锛岃繖閲屾槸缁濆璺緞锛屽啓鍏ユ枃浠舵椂婕旂ず鐩稿璺緞
- File writeID = new File(pathID); // 瑕佽鍙栦互涓婅矾寰勭殑input銆倀xt鏂囦欢
-
- BufferedWriter outID = new BufferedWriter(new FileWriter(writeID));
- List<ShamUser> subList = list.subList(70000, 80000);
- for (ShamUser shamUser : subList) {
- String picUrl = shamUser.getPicUrl();
- if (!StringUtil.isNullOrEmpty(picUrl)) {
- long id = shamUser.getId();
- String path = "E:/test/" + id + ".jpg";
- // 涓嬭浇鍥剧墖
- downloadPicture(picUrl, path);
- // 涓嬭浇鏂囧瓧
- outID.write(id + "\r\n");
- outWriter.write(shamUser.getName() + "\r\n");
- }
- }
- outID.flush();// 鎶婄紦瀛樺尯鍐呭鍘嬪叆鏂囦欢
- outID.close(); // 鏈�鍚庤寰楀叧闂枃浠�
-
- outWriter.flush(); // 鎶婄紦瀛樺尯鍐呭鍘嬪叆鏂囦欢
- outWriter.close(); // 鏈�鍚庤寰楀叧闂枃浠�
- } catch (Exception e) {
- e.printStackTrace();
- }
-
- }
- });
-
- executor.execute(new Runnable() {
- @Override
- public void run() {
- try {
- /* 璇诲叆TXT鏂囦欢 */
- String pathname = "E:\\name.txt"; // 缁濆璺緞鎴栫浉瀵硅矾寰勯兘鍙互锛岃繖閲屾槸缁濆璺緞锛屽啓鍏ユ枃浠舵椂婕旂ず鐩稿璺緞
- File writename = new File(pathname); // 瑕佽鍙栦互涓婅矾寰勭殑input銆倀xt鏂囦欢
-
- BufferedWriter outWriter;
-
- outWriter = new BufferedWriter(new FileWriter(writename));
-
- /* 璇诲叆TXT鏂囦欢 */
- String pathID = "E:\\id.txt"; // 缁濆璺緞鎴栫浉瀵硅矾寰勯兘鍙互锛岃繖閲屾槸缁濆璺緞锛屽啓鍏ユ枃浠舵椂婕旂ず鐩稿璺緞
- File writeID = new File(pathID); // 瑕佽鍙栦互涓婅矾寰勭殑input銆倀xt鏂囦欢
-
- BufferedWriter outID = new BufferedWriter(new FileWriter(writeID));
- List<ShamUser> subList = list.subList(80000, 90000);
- for (ShamUser shamUser : subList) {
- String picUrl = shamUser.getPicUrl();
- if (!StringUtil.isNullOrEmpty(picUrl)) {
- long id = shamUser.getId();
- String path = "E:/test/" + id + ".jpg";
- // 涓嬭浇鍥剧墖
- downloadPicture(picUrl, path);
- // 涓嬭浇鏂囧瓧
- outID.write(id + "\r\n");
- outWriter.write(shamUser.getName() + "\r\n");
- }
- }
- outID.flush();// 鎶婄紦瀛樺尯鍐呭鍘嬪叆鏂囦欢
- outID.close(); // 鏈�鍚庤寰楀叧闂枃浠�
-
- outWriter.flush(); // 鎶婄紦瀛樺尯鍐呭鍘嬪叆鏂囦欢
- outWriter.close(); // 鏈�鍚庤寰楀叧闂枃浠�
- } catch (Exception e) {
- e.printStackTrace();
- }
-
- }
- });
- executor.execute(new Runnable() {
- @Override
- public void run() {
- try {
- /* 璇诲叆TXT鏂囦欢 */
- String pathname = "E:\\name.txt"; // 缁濆璺緞鎴栫浉瀵硅矾寰勯兘鍙互锛岃繖閲屾槸缁濆璺緞锛屽啓鍏ユ枃浠舵椂婕旂ず鐩稿璺緞
- File writename = new File(pathname); // 瑕佽鍙栦互涓婅矾寰勭殑input銆倀xt鏂囦欢
-
- BufferedWriter outWriter;
-
- outWriter = new BufferedWriter(new FileWriter(writename));
-
- /* 璇诲叆TXT鏂囦欢 */
- String pathID = "E:\\id.txt"; // 缁濆璺緞鎴栫浉瀵硅矾寰勯兘鍙互锛岃繖閲屾槸缁濆璺緞锛屽啓鍏ユ枃浠舵椂婕旂ず鐩稿璺緞
- File writeID = new File(pathID); // 瑕佽鍙栦互涓婅矾寰勭殑input銆倀xt鏂囦欢
-
- BufferedWriter outID = new BufferedWriter(new FileWriter(writeID));
- List<ShamUser> subList = list.subList(90000, 100000);
- for (ShamUser shamUser : subList) {
- String picUrl = shamUser.getPicUrl();
- if (!StringUtil.isNullOrEmpty(picUrl)) {
- long id = shamUser.getId();
- String path = "E:/test/" + id + ".jpg";
- // 涓嬭浇鍥剧墖
- downloadPicture(picUrl, path);
- // 涓嬭浇鏂囧瓧
- outID.write(id + "\r\n");
- outWriter.write(shamUser.getName() + "\r\n");
- }
- }
- outID.flush();// 鎶婄紦瀛樺尯鍐呭鍘嬪叆鏂囦欢
- outID.close(); // 鏈�鍚庤寰楀叧闂枃浠�
-
- outWriter.flush(); // 鎶婄紦瀛樺尯鍐呭鍘嬪叆鏂囦欢
- outWriter.close(); // 鏈�鍚庤寰楀叧闂枃浠�
- } catch (Exception e) {
- e.printStackTrace();
- }
-
- }
- });
-
-
- JsonUtil.printMode(out, null, JsonUtil.loadTrueResult("涓嬭浇鎴愬姛"));
-
- } catch (Exception e) {
- e.printStackTrace();
- }
- }
-
- //閾炬帴url涓嬭浇鍥剧墖
- private void downloadPicture(String picUrl,String path) {
- URL url = null;
- try {
- url = new URL(picUrl);
-
- DataInputStream dataInputStream = new DataInputStream(url.openStream());
-
- FileOutputStream fileOutputStream = new FileOutputStream(new File(path));
- ByteArrayOutputStream output = new ByteArrayOutputStream();
-
- byte[] buffer = new byte[1024];
- int length;
-
- while ((length = dataInputStream.read(buffer)) > 0) {
- output.write(buffer, 0, length);
- }
- fileOutputStream.write(output.toByteArray());
- dataInputStream.close();
- fileOutputStream.close();
-
- } catch (MalformedURLException e) {
- e.printStackTrace();
- } catch (IOException e) {
- e.printStackTrace();
- }
- }
-
-}
+package com.yeshi.fanli.controller.admin;
+
+import java.io.BufferedWriter;
+import java.io.ByteArrayOutputStream;
+import java.io.DataInputStream;
+import java.io.File;
+import java.io.FileOutputStream;
+import java.io.FileWriter;
+import java.io.IOException;
+import java.io.PrintWriter;
+import java.net.MalformedURLException;
+import java.net.URL;
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+
+import javax.annotation.Resource;
+import javax.servlet.http.HttpServletRequest;
+
+import com.yeshi.fanli.entity.accept.AdminAcceptData;
+import net.sf.json.JSONObject;
+
+import org.springframework.core.task.TaskExecutor;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.multipart.MultipartFile;
+import org.springframework.web.multipart.MultipartHttpServletRequest;
+import org.springframework.web.multipart.commons.CommonsMultipartFile;
+import org.yeshi.utils.JsonUtil;
+
+import com.google.gson.Gson;
+import com.google.gson.GsonBuilder;
+import com.google.gson.reflect.TypeToken;
+import com.yeshi.fanli.entity.bus.user.ShamUser;
+import com.yeshi.fanli.entity.bus.user.UserRankings;
+import com.yeshi.fanli.exception.user.UserRankingsException;
+import com.yeshi.fanli.service.inter.user.ShamUserService;
+import com.yeshi.fanli.service.inter.user.UserRankingsService;
+import com.yeshi.common.entity.PageEntity;
+import com.yeshi.fanli.util.Constant;
+import com.yeshi.fanli.util.StringUtil;
+
+@Controller
+@RequestMapping("admin/new/api/v1/rankings")
+public class UserRankingsAdminController {
+
+ @Resource
+ private UserRankingsService userRankingsService;
+ @Resource
+ private ShamUserService shamUserService;
+ @Resource(name = "taskExecutor")
+ private TaskExecutor executor;
+
+
+
+ @RequestMapping(value = "saveAdd")
+ public void saveAdd(AdminAcceptData acceptData, String callback, UserRankings userRankings, HttpServletRequest request, PrintWriter out) {
+
+
+ try {
+
+ String nickName = userRankings.getNickName();
+
+ if (StringUtil.isNullOrEmpty(nickName)) {
+ JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鐢ㄦ埛鍚嶇О涓嶈兘涓虹┖"));
+ return;
+ }
+
+ // 鏌ヨ鏄电О鏄惁宸插瓨鍦�
+ List<UserRankings> listRankings = userRankingsService.selectByNickName(nickName.trim());
+
+ if (listRankings != null && listRankings.size() > 0) {
+ JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("["+ nickName +"] 姝ゆ樀绉板凡瀛樺湪"));
+ return;
+ }
+
+ if (request instanceof MultipartHttpServletRequest) {
+
+ List<MultipartFile> files = ((MultipartHttpServletRequest) request).getFiles("file");
+
+ if (files != null && files.size() > 0) {
+ userRankingsService.insertAndUploadFile(userRankings, files.get(0));
+ } else {
+ userRankingsService.insertAndUploadFile(userRankings, null);
+ }
+
+ } else {
+ userRankingsService.insertAndUploadFile(userRankings, null);
+ }
+
+ JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("娣诲姞鎴愬姛"));
+
+ } catch (Exception e) {
+
+ JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("娣诲姞澶辫触"));
+ e.printStackTrace();
+ }
+
+ }
+
+
+ @RequestMapping(value = "saveModify")
+ public void saveModify(AdminAcceptData acceptData,String callback, UserRankings userRankings, PrintWriter out) {
+
+ try {
+ Long id = userRankings.getId();
+ if (id == null) {
+ JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("璇蜂紶閫掓纭弬鏁�"));
+ return;
+ }
+
+ UserRankings resultObj = userRankingsService.selectByPrimaryKey(id);
+ if (resultObj == null) {
+ JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鏁版嵁涓嶅瓨鍦ㄦ垨宸茶鍒犻櫎"));
+ return;
+ }
+
+ String nickName = userRankings.getNickName();
+ if (!StringUtil.isNullOrEmpty(nickName)) {
+ // 鏌ヨ鏄电О鏄惁宸插瓨鍦�
+ List<UserRankings> listRankings = userRankingsService.selectByNickName(nickName.trim());
+
+ if (listRankings != null && listRankings.size() > 0) {
+ boolean proess = false;
+ for (UserRankings userRanking: listRankings) {
+ Long objid = userRanking.getId();
+ if (id.equals(objid)){
+ proess = true;
+ }
+ }
+
+ if (!proess){
+ JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("["+ nickName +"] 姝ゆ樀绉板凡瀛樺湪"));
+ return;
+ }
+ }
+ }
+
+ Integer shareState = userRankings.getShareState();
+ if (shareState != null && (shareState.equals(1) || shareState == 1)){
+ userRankings.setShareTime(new Date());
+ }
+
+ Integer tradeState = userRankings.getTradeState();
+ if (tradeState != null && (tradeState.equals(1) || tradeState == 1)){
+ userRankings.setTradeTime(new Date());
+ }
+
+ userRankingsService.updateByPrimaryKeySelective(userRankings);
+ JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("淇敼鎴愬姛"));
+
+ } catch (UserRankingsException e) {
+ JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("淇敼澶辫触"));
+ e.printStackTrace();
+ }
+
+ }
+
+
+ @RequestMapping(value = "deleteBatch")
+ public void deleteBatch(AdminAcceptData acceptData,String callback, String idArray, PrintWriter out) {
+
+ try {
+
+ if (StringUtil.isNullOrEmpty(idArray)) {
+ JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("璇烽�夋嫨鍒犻櫎鐨勬暟鎹�"));
+ return;
+ }
+
+ Gson gson = new Gson();
+ List<Long> arrayID = gson.fromJson(idArray, new TypeToken<ArrayList<Long>>() {}.getType());
+ if (arrayID == null || arrayID.size() == 0) {
+ JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鏈娴嬪埌鍒犻櫎鐨勬暟鎹�"));
+ return;
+ }
+
+ userRankingsService.deleteBatchByPrimaryKey(arrayID);
+
+ out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult("鍒犻櫎鎴愬姛")));
+
+ } catch (UserRankingsException e) {
+ JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鍒犻櫎澶辫触"));
+ e.printStackTrace();
+ }
+ }
+
+
+ @RequestMapping(value = "uploadPicture")
+ public void uploadImg(AdminAcceptData acceptData,String callback, Long id, @RequestParam("file") CommonsMultipartFile file,
+ PrintWriter out) {
+ try {
+
+ if (file == null) {
+ JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("涓婁紶鏂囦欢涓嶈兘涓虹┖"));
+ return;
+ }
+
+ if (id == null) {
+ JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("璇蜂紶閫掓纭弬鏁�"));
+ return;
+ }
+
+ UserRankings resultObj = userRankingsService.selectByPrimaryKey(id);
+ if (resultObj == null) {
+ JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鏁版嵁涓嶅瓨鍦ㄦ垨宸茶鍒犻櫎"));
+ return;
+ }
+
+ userRankingsService.uploadPicture(file, resultObj);
+
+ JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("鍥剧墖涓婁紶鎴愬姛"));
+
+ } catch (Exception e) {
+ JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鍥剧墖涓婁紶澶辫触"));
+ e.printStackTrace();
+ }
+ }
+
+
+
+
+ @RequestMapping(value = "removePicture")
+ public void uploadImg(AdminAcceptData acceptData,String callback, Long id, PrintWriter out) {
+
+ try {
+
+ if (id == null) {
+ JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("璇蜂紶閫掓纭弬鏁�"));
+ return;
+ }
+
+ UserRankings resultObj = userRankingsService.selectByPrimaryKey(id);
+ if (resultObj == null) {
+ JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鏁版嵁涓嶅瓨鍦ㄦ垨宸茶鍒犻櫎"));
+ return;
+ }
+
+ userRankingsService.removePicture(resultObj);
+
+ JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("鍥剧墖鍒犻櫎鎴愬姛"));
+
+ } catch (Exception e) {
+ JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鍥剧墖鍒犻櫎澶辫触"));
+ e.printStackTrace();
+ }
+ }
+
+
+
+
+ /**
+ * 鏌ユ壘鎵�鏈夋爣绛�
+ *
+ * @param callback
+ * @param pageIndex
+ * @param key
+ * @param startTime
+ * @param endTime
+ * @param out
+ */
+ @RequestMapping(value = "query")
+ public void query(AdminAcceptData acceptData,String callback, Integer pageIndex, Integer pageSize, String key,
+ Integer tradeState, Integer shareState, Integer sort, PrintWriter out) {
+
+ try {
+
+ if (pageIndex == null || pageIndex < 1)
+ pageIndex = 1;
+
+ if (pageSize == null || pageSize < 1)
+ pageSize = Constant.PAGE_SIZE;
+
+ if (sort == null || sort < 1 || sort >8)
+ sort = 1;
+
+
+ List<UserRankings> userRankingsList = userRankingsService.query((pageIndex - 1) * pageSize,
+ pageSize, key, tradeState, shareState, sort);
+
+ if (userRankingsList == null || userRankingsList.size() == 0) {
+ out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("鏆傛棤鐩稿叧鏁版嵁")));
+ return;
+ }
+
+ long count = userRankingsService.queryCount(key, tradeState, shareState);
+ int totalPage = (int) (count % pageSize == 0 ? count / pageSize : count / pageSize + 1);
+ PageEntity pe = new PageEntity(pageIndex, pageSize, count, totalPage);
+
+
+ GsonBuilder gsonBuilder = new GsonBuilder();
+ gsonBuilder.serializeNulls();
+ Gson gson = gsonBuilder.setDateFormat("yyyy/MM/dd HH:mm:ss").create();
+
+ JSONObject data = new JSONObject();
+ data.put("pe", pe);
+ data.put("result_list", gson.toJson(userRankingsList));
+
+ JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data));
+
+ } catch (Exception e) {
+ JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鏌ヨ澶辫触"));
+ e.printStackTrace();
+ }
+ }
+
+ /**
+ * 锛堥殢鏈烘潈濂栭噾锛�
+ * @param callback
+ * @param request
+ * @param out @param 澶у��
+ * @param 灏忓��
+ */
+ @RequestMapping(value = "setRewardtBatch")
+ public void setRewardtBatch(AdminAcceptData acceptData,String callback,String ids, Integer type, Double reward,
+ Double startReward, Double endReward, HttpServletRequest request, PrintWriter out) {
+
+ try {
+
+ if (StringUtil.isNullOrEmpty(ids)) {
+ JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鏈�夋嫨闇�鎿嶄綔鐨勭敤鎴�"));
+ return;
+ }
+
+ // type : 1 鑷喘 2 鍒嗕韩
+ if (type == null || type <1 || type >2) {
+ JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("璇烽�夋嫨姝ｇ‘鐨勭被鍨�"));
+ return;
+ }
+
+
+ Gson gson = new Gson();
+ List<Long> idList = gson.fromJson(ids, new TypeToken<ArrayList<Long>>() {}.getType());
+
+ if (idList == null || idList.size() == 0) {
+ JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("璇烽�夋嫨闇�鎿嶄綔鐨勭敤鎴�"));
+ return;
+ }
+
+ userRankingsService.setRewardtBatch(idList, type, reward, startReward, endReward);
+
+ JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("鎿嶄綔鎴愬姛"));
+
+ } catch ( Exception e) {
+ JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鎿嶄綔澶辫触"));
+ e.printStackTrace();
+ }
+
+ }
+
+
+ /**
+ * 锛堥殢鏈烘潈濂栭噾锛�
+ * @param callback
+ * @param request
+ * @param out @param 澶у��
+ * @param 灏忓��
+ */
+ @RequestMapping(value = "setStateBatch")
+ public void setStateBatch(AdminAcceptData acceptData,String callback, String ids, Integer type, Integer state, PrintWriter out) {
+
+ try {
+
+ if (StringUtil.isNullOrEmpty(ids)) {
+ JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鏈�夋嫨闇�鎿嶄綔鐨勭敤鎴�"));
+ return;
+ }
+
+ // type : 1 鑷喘 2 鍒嗕韩
+ if (type == null || type <1 || type >2) {
+ JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("璇烽�夋嫨姝ｇ‘鐨勭被鍨�"));
+ return;
+ }
+
+
+ Gson gson = new Gson();
+ List<Long> idList = gson.fromJson(ids, new TypeToken<ArrayList<Long>>() {}.getType());
+
+ if (idList == null || idList.size() == 0) {
+ JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("璇烽�夋嫨闇�鎿嶄綔鐨勭敤鎴�"));
+ return;
+ }
+
+ userRankingsService.setStateBatch(idList, type, state);
+
+ JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("鎿嶄綔鎴愬姛"));
+
+ } catch ( Exception e) {
+ JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鎿嶄綔澶辫触"));
+ e.printStackTrace();
+ }
+ }
+
+ @RequestMapping(value = "batchUpFile")
+ public void batchUpFile(AdminAcceptData acceptData,PrintWriter out) {
+
+ try {
+
+ File file = new File("E:\\test");// 闇�瑕佹煡鎵剧殑鏂囦欢澶�
+
+ userRankingsService.uploadFile(file);
+
+ JsonUtil.printMode(out, null, JsonUtil.loadTrueResult("鍥剧墖涓婁紶鎴愬姛"));
+
+ } catch (Exception e) {
+
+ JsonUtil.printMode(out, null, JsonUtil.loadFalseResult("鍥剧墖涓婁紶澶辫触"));
+ e.printStackTrace();
+ }
+ }
+
+
+ @RequestMapping(value = "batchUpShowID")
+ public void batchUpShowID(AdminAcceptData acceptData,PrintWriter out) {
+
+ try {
+
+ File file = new File("E:\\idtest\\IDS.txt");//Text鏂囦欢
+
+ userRankingsService.updateShowID(file);
+
+ JsonUtil.printMode(out, null, JsonUtil.loadTrueResult("涓婁紶鎴愬姛"));
+
+ } catch (Exception e) {
+
+ JsonUtil.printMode(out, null, JsonUtil.loadFalseResult("鍥剧墖涓婁紶澶辫触"));
+ e.printStackTrace();
+ }
+ }
+
+ @RequestMapping(value = "batchUpNickName")
+ public void batchUpNickName(AdminAcceptData acceptData,PrintWriter out) {
+
+ try {
+
+ File file = new File("E:\\idtest\\Names.txt");//Text鏂囦欢
+
+ userRankingsService.batchUpNickName(file);
+
+ JsonUtil.printMode(out, null, JsonUtil.loadTrueResult("涓婁紶鎴愬姛"));
+
+ } catch (Exception e) {
+
+ JsonUtil.printMode(out, null, JsonUtil.loadFalseResult("鍥剧墖涓婁紶澶辫触"));
+ e.printStackTrace();
+ }
+ }
+
+
+
+ @RequestMapping(value = "downPic")
+ public void downPic(AdminAcceptData acceptData,PrintWriter out) {
+
+ try {
+
+ List<ShamUser> list = shamUserService.findShamUserList(100000);
+
+ executor.execute(new Runnable() {
+ @Override
+ public void run() {
+ try {
+ /* 璇诲叆TXT鏂囦欢 */
+ String pathname = "E:\\name.txt"; // 缁濆璺緞鎴栫浉瀵硅矾寰勯兘鍙互锛岃繖閲屾槸缁濆璺緞锛屽啓鍏ユ枃浠舵椂婕旂ず鐩稿璺緞
+ File writename = new File(pathname); // 瑕佽鍙栦互涓婅矾寰勭殑input銆倀xt鏂囦欢
+
+ BufferedWriter outWriter;
+
+ outWriter = new BufferedWriter(new FileWriter(writename));
+
+ /* 璇诲叆TXT鏂囦欢 */
+ String pathID = "E:\\id.txt"; // 缁濆璺緞鎴栫浉瀵硅矾寰勯兘鍙互锛岃繖閲屾槸缁濆璺緞锛屽啓鍏ユ枃浠舵椂婕旂ず鐩稿璺緞
+ File writeID = new File(pathID); // 瑕佽鍙栦互涓婅矾寰勭殑input銆倀xt鏂囦欢
+
+ BufferedWriter outID = new BufferedWriter(new FileWriter(writeID));
+ List<ShamUser> subList = list.subList(0, 10000);
+ for (ShamUser shamUser : subList) {
+ String picUrl = shamUser.getPicUrl();
+ if (!StringUtil.isNullOrEmpty(picUrl)) {
+ long id = shamUser.getId();
+ String path = "E:/test/" + id + ".jpg";
+ // 涓嬭浇鍥剧墖
+ downloadPicture(picUrl, path);
+ // 涓嬭浇鏂囧瓧
+ outID.write(id + "\r\n");
+ outWriter.write(shamUser.getName() + "\r\n");
+ }
+ }
+ outID.flush();// 鎶婄紦瀛樺尯鍐呭鍘嬪叆鏂囦欢
+ outID.close(); // 鏈�鍚庤寰楀叧闂枃浠�
+
+ outWriter.flush(); // 鎶婄紦瀛樺尯鍐呭鍘嬪叆鏂囦欢
+ outWriter.close(); // 鏈�鍚庤寰楀叧闂枃浠�
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+ });
+
+ executor.execute(new Runnable() {
+ @Override
+ public void run() {
+ try {
+ /* 璇诲叆TXT鏂囦欢 */
+ String pathname = "E:\\name.txt"; // 缁濆璺緞鎴栫浉瀵硅矾寰勯兘鍙互锛岃繖閲屾槸缁濆璺緞锛屽啓鍏ユ枃浠舵椂婕旂ず鐩稿璺緞
+ File writename = new File(pathname); // 瑕佽鍙栦互涓婅矾寰勭殑input銆倀xt鏂囦欢
+
+ BufferedWriter outWriter;
+
+ outWriter = new BufferedWriter(new FileWriter(writename));
+
+ /* 璇诲叆TXT鏂囦欢 */
+ String pathID = "E:\\id.txt"; // 缁濆璺緞鎴栫浉瀵硅矾寰勯兘鍙互锛岃繖閲屾槸缁濆璺緞锛屽啓鍏ユ枃浠舵椂婕旂ず鐩稿璺緞
+ File writeID = new File(pathID); // 瑕佽鍙栦互涓婅矾寰勭殑input銆倀xt鏂囦欢
+
+ BufferedWriter outID = new BufferedWriter(new FileWriter(writeID));
+ List<ShamUser> subList = list.subList(10000, 20000);
+ for (ShamUser shamUser : subList) {
+ String picUrl = shamUser.getPicUrl();
+ if (!StringUtil.isNullOrEmpty(picUrl)) {
+ long id = shamUser.getId();
+ String path = "E:/test/" + id + ".jpg";
+ // 涓嬭浇鍥剧墖
+ downloadPicture(picUrl, path);
+ // 涓嬭浇鏂囧瓧
+ outID.write(id + "\r\n");
+ outWriter.write(shamUser.getName() + "\r\n");
+ }
+ }
+ outID.flush();// 鎶婄紦瀛樺尯鍐呭鍘嬪叆鏂囦欢
+ outID.close(); // 鏈�鍚庤寰楀叧闂枃浠�
+
+ outWriter.flush(); // 鎶婄紦瀛樺尯鍐呭鍘嬪叆鏂囦欢
+ outWriter.close(); // 鏈�鍚庤寰楀叧闂枃浠�
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+ });
+
+ executor.execute(new Runnable() {
+ @Override
+ public void run() {
+ try {
+ /* 璇诲叆TXT鏂囦欢 */
+ String pathname = "E:\\name.txt"; // 缁濆璺緞鎴栫浉瀵硅矾寰勯兘鍙互锛岃繖閲屾槸缁濆璺緞锛屽啓鍏ユ枃浠舵椂婕旂ず鐩稿璺緞
+ File writename = new File(pathname); // 瑕佽鍙栦互涓婅矾寰勭殑input銆倀xt鏂囦欢
+
+ BufferedWriter outWriter;
+
+ outWriter = new BufferedWriter(new FileWriter(writename));
+
+ /* 璇诲叆TXT鏂囦欢 */
+ String pathID = "E:\\id.txt"; // 缁濆璺緞鎴栫浉瀵硅矾寰勯兘鍙互锛岃繖閲屾槸缁濆璺緞锛屽啓鍏ユ枃浠舵椂婕旂ず鐩稿璺緞
+ File writeID = new File(pathID); // 瑕佽鍙栦互涓婅矾寰勭殑input銆倀xt鏂囦欢
+
+ BufferedWriter outID = new BufferedWriter(new FileWriter(writeID));
+ List<ShamUser> subList = list.subList(20000, 30000);
+ for (ShamUser shamUser : subList) {
+ String picUrl = shamUser.getPicUrl();
+ if (!StringUtil.isNullOrEmpty(picUrl)) {
+ long id = shamUser.getId();
+ String path = "E:/test/" + id + ".jpg";
+ // 涓嬭浇鍥剧墖
+ downloadPicture(picUrl, path);
+ // 涓嬭浇鏂囧瓧
+ outID.write(id + "\r\n");
+ outWriter.write(shamUser.getName() + "\r\n");
+ }
+ }
+ outID.flush();// 鎶婄紦瀛樺尯鍐呭鍘嬪叆鏂囦欢
+ outID.close(); // 鏈�鍚庤寰楀叧闂枃浠�
+
+ outWriter.flush(); // 鎶婄紦瀛樺尯鍐呭鍘嬪叆鏂囦欢
+ outWriter.close(); // 鏈�鍚庤寰楀叧闂枃浠�
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+ });
+
+ executor.execute(new Runnable() {
+ @Override
+ public void run() {
+ try {
+ /* 璇诲叆TXT鏂囦欢 */
+ String pathname = "E:\\name.txt"; // 缁濆璺緞鎴栫浉瀵硅矾寰勯兘鍙互锛岃繖閲屾槸缁濆璺緞锛屽啓鍏ユ枃浠舵椂婕旂ず鐩稿璺緞
+ File writename = new File(pathname); // 瑕佽鍙栦互涓婅矾寰勭殑input銆倀xt鏂囦欢
+
+ BufferedWriter outWriter;
+
+ outWriter = new BufferedWriter(new FileWriter(writename));
+
+ /* 璇诲叆TXT鏂囦欢 */
+ String pathID = "E:\\id.txt"; // 缁濆璺緞鎴栫浉瀵硅矾寰勯兘鍙互锛岃繖閲屾槸缁濆璺緞锛屽啓鍏ユ枃浠舵椂婕旂ず鐩稿璺緞
+ File writeID = new File(pathID); // 瑕佽鍙栦互涓婅矾寰勭殑input銆倀xt鏂囦欢
+
+ BufferedWriter outID = new BufferedWriter(new FileWriter(writeID));
+ List<ShamUser> subList = list.subList(30000, 40000);
+ for (ShamUser shamUser : subList) {
+ String picUrl = shamUser.getPicUrl();
+ if (!StringUtil.isNullOrEmpty(picUrl)) {
+ long id = shamUser.getId();
+ String path = "E:/test/" + id + ".jpg";
+ // 涓嬭浇鍥剧墖
+ downloadPicture(picUrl, path);
+ // 涓嬭浇鏂囧瓧
+ outID.write(id + "\r\n");
+ outWriter.write(shamUser.getName() + "\r\n");
+ }
+ }
+ outID.flush();// 鎶婄紦瀛樺尯鍐呭鍘嬪叆鏂囦欢
+ outID.close(); // 鏈�鍚庤寰楀叧闂枃浠�
+
+ outWriter.flush(); // 鎶婄紦瀛樺尯鍐呭鍘嬪叆鏂囦欢
+ outWriter.close(); // 鏈�鍚庤寰楀叧闂枃浠�
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+
+ }
+ });
+
+
+ executor.execute(new Runnable() {
+ @Override
+ public void run() {
+ try {
+ /* 璇诲叆TXT鏂囦欢 */
+ String pathname = "E:\\name.txt"; // 缁濆璺緞鎴栫浉瀵硅矾寰勯兘鍙互锛岃繖閲屾槸缁濆璺緞锛屽啓鍏ユ枃浠舵椂婕旂ず鐩稿璺緞
+ File writename = new File(pathname); // 瑕佽鍙栦互涓婅矾寰勭殑input銆倀xt鏂囦欢
+
+ BufferedWriter outWriter;
+
+ outWriter = new BufferedWriter(new FileWriter(writename));
+
+ /* 璇诲叆TXT鏂囦欢 */
+ String pathID = "E:\\id.txt"; // 缁濆璺緞鎴栫浉瀵硅矾寰勯兘鍙互锛岃繖閲屾槸缁濆璺緞锛屽啓鍏ユ枃浠舵椂婕旂ず鐩稿璺緞
+ File writeID = new File(pathID); // 瑕佽鍙栦互涓婅矾寰勭殑input銆倀xt鏂囦欢
+
+ BufferedWriter outID = new BufferedWriter(new FileWriter(writeID));
+ List<ShamUser> subList = list.subList(40000, 50000);
+ for (ShamUser shamUser : subList) {
+ String picUrl = shamUser.getPicUrl();
+ if (!StringUtil.isNullOrEmpty(picUrl)) {
+ long id = shamUser.getId();
+ String path = "E:/test/" + id + ".jpg";
+ // 涓嬭浇鍥剧墖
+ downloadPicture(picUrl, path);
+ // 涓嬭浇鏂囧瓧
+ outID.write(id + "\r\n");
+ outWriter.write(shamUser.getName() + "\r\n");
+ }
+ }
+ outID.flush();// 鎶婄紦瀛樺尯鍐呭鍘嬪叆鏂囦欢
+ outID.close(); // 鏈�鍚庤寰楀叧闂枃浠�
+
+ outWriter.flush(); // 鎶婄紦瀛樺尯鍐呭鍘嬪叆鏂囦欢
+ outWriter.close(); // 鏈�鍚庤寰楀叧闂枃浠�
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+
+ }
+ });
+
+ executor.execute(new Runnable() {
+ @Override
+ public void run() {
+ try {
+ /* 璇诲叆TXT鏂囦欢 */
+ String pathname = "E:\\name.txt"; // 缁濆璺緞鎴栫浉瀵硅矾寰勯兘鍙互锛岃繖閲屾槸缁濆璺緞锛屽啓鍏ユ枃浠舵椂婕旂ず鐩稿璺緞
+ File writename = new File(pathname); // 瑕佽鍙栦互涓婅矾寰勭殑input銆倀xt鏂囦欢
+
+ BufferedWriter outWriter;
+
+ outWriter = new BufferedWriter(new FileWriter(writename));
+
+ /* 璇诲叆TXT鏂囦欢 */
+ String pathID = "E:\\id.txt"; // 缁濆璺緞鎴栫浉瀵硅矾寰勯兘鍙互锛岃繖閲屾槸缁濆璺緞锛屽啓鍏ユ枃浠舵椂婕旂ず鐩稿璺緞
+ File writeID = new File(pathID); // 瑕佽鍙栦互涓婅矾寰勭殑input銆倀xt鏂囦欢
+
+ BufferedWriter outID = new BufferedWriter(new FileWriter(writeID));
+ List<ShamUser> subList = list.subList(50000, 60000);
+ for (ShamUser shamUser : subList) {
+ String picUrl = shamUser.getPicUrl();
+ if (!StringUtil.isNullOrEmpty(picUrl)) {
+ long id = shamUser.getId();
+ String path = "E:/test/" + id + ".jpg";
+ // 涓嬭浇鍥剧墖
+ downloadPicture(picUrl, path);
+ // 涓嬭浇鏂囧瓧
+ outID.write(id + "\r\n");
+ outWriter.write(shamUser.getName() + "\r\n");
+ }
+ }
+ outID.flush();// 鎶婄紦瀛樺尯鍐呭鍘嬪叆鏂囦欢
+ outID.close(); // 鏈�鍚庤寰楀叧闂枃浠�
+
+ outWriter.flush(); // 鎶婄紦瀛樺尯鍐呭鍘嬪叆鏂囦欢
+ outWriter.close(); // 鏈�鍚庤寰楀叧闂枃浠�
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+
+ }
+ });
+
+
+ executor.execute(new Runnable() {
+ @Override
+ public void run() {
+ try {
+ /* 璇诲叆TXT鏂囦欢 */
+ String pathname = "E:\\name.txt"; // 缁濆璺緞鎴栫浉瀵硅矾寰勯兘鍙互锛岃繖閲屾槸缁濆璺緞锛屽啓鍏ユ枃浠舵椂婕旂ず鐩稿璺緞
+ File writename = new File(pathname); // 瑕佽鍙栦互涓婅矾寰勭殑input銆倀xt鏂囦欢
+
+ BufferedWriter outWriter;
+
+ outWriter = new BufferedWriter(new FileWriter(writename));
+
+ /* 璇诲叆TXT鏂囦欢 */
+ String pathID = "E:\\id.txt"; // 缁濆璺緞鎴栫浉瀵硅矾寰勯兘鍙互锛岃繖閲屾槸缁濆璺緞锛屽啓鍏ユ枃浠舵椂婕旂ず鐩稿璺緞
+ File writeID = new File(pathID); // 瑕佽鍙栦互涓婅矾寰勭殑input銆倀xt鏂囦欢
+
+ BufferedWriter outID = new BufferedWriter(new FileWriter(writeID));
+ List<ShamUser> subList = list.subList(60000, 70000);
+ for (ShamUser shamUser : subList) {
+ String picUrl = shamUser.getPicUrl();
+ if (!StringUtil.isNullOrEmpty(picUrl)) {
+ long id = shamUser.getId();
+ String path = "E:/test/" + id + ".jpg";
+ // 涓嬭浇鍥剧墖
+ downloadPicture(picUrl, path);
+ // 涓嬭浇鏂囧瓧
+ outID.write(id + "\r\n");
+ outWriter.write(shamUser.getName() + "\r\n");
+ }
+ }
+ outID.flush();// 鎶婄紦瀛樺尯鍐呭鍘嬪叆鏂囦欢
+ outID.close(); // 鏈�鍚庤寰楀叧闂枃浠�
+
+ outWriter.flush(); // 鎶婄紦瀛樺尯鍐呭鍘嬪叆鏂囦欢
+ outWriter.close(); // 鏈�鍚庤寰楀叧闂枃浠�
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+
+ }
+ });
+ executor.execute(new Runnable() {
+ @Override
+ public void run() {
+ try {
+ /* 璇诲叆TXT鏂囦欢 */
+ String pathname = "E:\\name.txt"; // 缁濆璺緞鎴栫浉瀵硅矾寰勯兘鍙互锛岃繖閲屾槸缁濆璺緞锛屽啓鍏ユ枃浠舵椂婕旂ず鐩稿璺緞
+ File writename = new File(pathname); // 瑕佽鍙栦互涓婅矾寰勭殑input銆倀xt鏂囦欢
+
+ BufferedWriter outWriter;
+
+ outWriter = new BufferedWriter(new FileWriter(writename));
+
+ /* 璇诲叆TXT鏂囦欢 */
+ String pathID = "E:\\id.txt"; // 缁濆璺緞鎴栫浉瀵硅矾寰勯兘鍙互锛岃繖閲屾槸缁濆璺緞锛屽啓鍏ユ枃浠舵椂婕旂ず鐩稿璺緞
+ File writeID = new File(pathID); // 瑕佽鍙栦互涓婅矾寰勭殑input銆倀xt鏂囦欢
+
+ BufferedWriter outID = new BufferedWriter(new FileWriter(writeID));
+ List<ShamUser> subList = list.subList(70000, 80000);
+ for (ShamUser shamUser : subList) {
+ String picUrl = shamUser.getPicUrl();
+ if (!StringUtil.isNullOrEmpty(picUrl)) {
+ long id = shamUser.getId();
+ String path = "E:/test/" + id + ".jpg";
+ // 涓嬭浇鍥剧墖
+ downloadPicture(picUrl, path);
+ // 涓嬭浇鏂囧瓧
+ outID.write(id + "\r\n");
+ outWriter.write(shamUser.getName() + "\r\n");
+ }
+ }
+ outID.flush();// 鎶婄紦瀛樺尯鍐呭鍘嬪叆鏂囦欢
+ outID.close(); // 鏈�鍚庤寰楀叧闂枃浠�
+
+ outWriter.flush(); // 鎶婄紦瀛樺尯鍐呭鍘嬪叆鏂囦欢
+ outWriter.close(); // 鏈�鍚庤寰楀叧闂枃浠�
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+
+ }
+ });
+
+ executor.execute(new Runnable() {
+ @Override
+ public void run() {
+ try {
+ /* 璇诲叆TXT鏂囦欢 */
+ String pathname = "E:\\name.txt"; // 缁濆璺緞鎴栫浉瀵硅矾寰勯兘鍙互锛岃繖閲屾槸缁濆璺緞锛屽啓鍏ユ枃浠舵椂婕旂ず鐩稿璺緞
+ File writename = new File(pathname); // 瑕佽鍙栦互涓婅矾寰勭殑input銆倀xt鏂囦欢
+
+ BufferedWriter outWriter;
+
+ outWriter = new BufferedWriter(new FileWriter(writename));
+
+ /* 璇诲叆TXT鏂囦欢 */
+ String pathID = "E:\\id.txt"; // 缁濆璺緞鎴栫浉瀵硅矾寰勯兘鍙互锛岃繖閲屾槸缁濆璺緞锛屽啓鍏ユ枃浠舵椂婕旂ず鐩稿璺緞
+ File writeID = new File(pathID); // 瑕佽鍙栦互涓婅矾寰勭殑input銆倀xt鏂囦欢
+
+ BufferedWriter outID = new BufferedWriter(new FileWriter(writeID));
+ List<ShamUser> subList = list.subList(80000, 90000);
+ for (ShamUser shamUser : subList) {
+ String picUrl = shamUser.getPicUrl();
+ if (!StringUtil.isNullOrEmpty(picUrl)) {
+ long id = shamUser.getId();
+ String path = "E:/test/" + id + ".jpg";
+ // 涓嬭浇鍥剧墖
+ downloadPicture(picUrl, path);
+ // 涓嬭浇鏂囧瓧
+ outID.write(id + "\r\n");
+ outWriter.write(shamUser.getName() + "\r\n");
+ }
+ }
+ outID.flush();// 鎶婄紦瀛樺尯鍐呭鍘嬪叆鏂囦欢
+ outID.close(); // 鏈�鍚庤寰楀叧闂枃浠�
+
+ outWriter.flush(); // 鎶婄紦瀛樺尯鍐呭鍘嬪叆鏂囦欢
+ outWriter.close(); // 鏈�鍚庤寰楀叧闂枃浠�
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+
+ }
+ });
+ executor.execute(new Runnable() {
+ @Override
+ public void run() {
+ try {
+ /* 璇诲叆TXT鏂囦欢 */
+ String pathname = "E:\\name.txt"; // 缁濆璺緞鎴栫浉瀵硅矾寰勯兘鍙互锛岃繖閲屾槸缁濆璺緞锛屽啓鍏ユ枃浠舵椂婕旂ず鐩稿璺緞
+ File writename = new File(pathname); // 瑕佽鍙栦互涓婅矾寰勭殑input銆倀xt鏂囦欢
+
+ BufferedWriter outWriter;
+
+ outWriter = new BufferedWriter(new FileWriter(writename));
+
+ /* 璇诲叆TXT鏂囦欢 */
+ String pathID = "E:\\id.txt"; // 缁濆璺緞鎴栫浉瀵硅矾寰勯兘鍙互锛岃繖閲屾槸缁濆璺緞锛屽啓鍏ユ枃浠舵椂婕旂ず鐩稿璺緞
+ File writeID = new File(pathID); // 瑕佽鍙栦互涓婅矾寰勭殑input銆倀xt鏂囦欢
+
+ BufferedWriter outID = new BufferedWriter(new FileWriter(writeID));
+ List<ShamUser> subList = list.subList(90000, 100000);
+ for (ShamUser shamUser : subList) {
+ String picUrl = shamUser.getPicUrl();
+ if (!StringUtil.isNullOrEmpty(picUrl)) {
+ long id = shamUser.getId();
+ String path = "E:/test/" + id + ".jpg";
+ // 涓嬭浇鍥剧墖
+ downloadPicture(picUrl, path);
+ // 涓嬭浇鏂囧瓧
+ outID.write(id + "\r\n");
+ outWriter.write(shamUser.getName() + "\r\n");
+ }
+ }
+ outID.flush();// 鎶婄紦瀛樺尯鍐呭鍘嬪叆鏂囦欢
+ outID.close(); // 鏈�鍚庤寰楀叧闂枃浠�
+
+ outWriter.flush(); // 鎶婄紦瀛樺尯鍐呭鍘嬪叆鏂囦欢
+ outWriter.close(); // 鏈�鍚庤寰楀叧闂枃浠�
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+
+ }
+ });
+
+
+ JsonUtil.printMode(out, null, JsonUtil.loadTrueResult("涓嬭浇鎴愬姛"));
+
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+
+ //閾炬帴url涓嬭浇鍥剧墖
+ private void downloadPicture(String picUrl,String path) {
+ URL url = null;
+ try {
+ url = new URL(picUrl);
+
+ DataInputStream dataInputStream = new DataInputStream(url.openStream());
+
+ FileOutputStream fileOutputStream = new FileOutputStream(new File(path));
+ ByteArrayOutputStream output = new ByteArrayOutputStream();
+
+ byte[] buffer = new byte[1024];
+ int length;
+
+ while ((length = dataInputStream.read(buffer)) > 0) {
+ output.write(buffer, 0, length);
+ }
+ fileOutputStream.write(output.toByteArray());
+ dataInputStream.close();
+ fileOutputStream.close();
+
+ } catch (MalformedURLException e) {
+ e.printStackTrace();
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ }
+
+}
--
Gitblit v1.8.0