| | |
| | | import com.alibaba.fastjson.JSONObject; |
| | | import com.ks.tool.bkz.dto.FirstOrderSubParseResult; |
| | | import com.ks.tool.bkz.entity.FirstOrderSubInfo; |
| | | import com.ks.tool.bkz.exception.TBCookieException; |
| | | import com.ks.tool.bkz.service.FirstOrderSubInfoService; |
| | | import com.ks.tool.bkz.service.manager.RedisManager; |
| | | import com.ks.tool.bkz.util.FirstOrderSubDataUtil; |
| | | import com.ks.tool.bkz.util.JsonUtil; |
| | | import com.ks.tool.bkz.util.UrlUtil; |
| | | import com.ks.tool.bkz.util.*; |
| | | import org.omg.CORBA.PUBLIC_MEMBER; |
| | | import org.springframework.stereotype.Controller; |
| | | import org.springframework.web.bind.annotation.RequestMapping; |
| | |
| | | @Controller |
| | | @RequestMapping("parse") |
| | | public class ParseController { |
| | | String cookie = null; |
| | | @Resource |
| | | private RedisManager redisManager; |
| | | |
| | | @Resource |
| | | private FirstOrderSubInfoService firstOrderSubInfoService; |
| | | |
| | | private String getCookieKey(String tbUid) { |
| | | return "tbcookie-" + tbUid; |
| | | } |
| | | |
| | | @RequestMapping("getRequestUrl") |
| | | @ResponseBody |
| | | public String getRequestUrl(String baseUrl) { |
| | | public String getRequestUrl(String baseUrl, String tbUid) { |
| | | String host = UrlUtil.getHost(baseUrl); |
| | | Map<String, String> params = UrlUtil.getParamsMap(baseUrl); |
| | | params.put("t", System.currentTimeMillis() + ""); |
| | | cookie = redisManager.get("cookie"); |
| | | |
| | | String cookie = redisManager.get(getCookieKey(tbUid)); |
| | | String token = FirstOrderSubDataUtil.getTokenFromCookie(cookie); |
| | | String data = params.get("data"); |
| | | try { |
| | |
| | | @RequestMapping("uploadCookies") |
| | | @ResponseBody |
| | | public String uploadCookie(String cookies) { |
| | | this.cookie = cookies; |
| | | redisManager.save("cookie", cookies, 60 * 60); |
| | | return cookies; |
| | | String tbUid = TBCookieUtil.getTBUid(cookies); |
| | | if (!StringUtil.isNullOrEmpty(tbUid)) { |
| | | redisManager.save(getCookieKey(tbUid), cookies, 60 * 60); |
| | | } |
| | | return ""; |
| | | } |
| | | |
| | | @RequestMapping("getLoginUrl") |
| | |
| | | @RequestMapping("uploadContent") |
| | | @ResponseBody |
| | | public String uploadContent(String content) { |
| | | FirstOrderSubParseResult result = FirstOrderSubDataUtil.parseOrderSubData(content); |
| | | if (result != null && result.isHasNextPage()) { |
| | | if (result.getGoodsList() != null) |
| | | for (FirstOrderSubInfo info : result.getGoodsList()) { |
| | | firstOrderSubInfoService.add(info); |
| | | System.out.println(info.getId() + "-" + info.getTitle()); |
| | | } |
| | | System.out.println("----------------------------"); |
| | | return JsonUtil.loadTrueResult(null); |
| | | } else { |
| | | return JsonUtil.loadFalseResult(1, "无更多数据"); |
| | | try { |
| | | FirstOrderSubParseResult result = FirstOrderSubDataUtil.parseOrderSubData(content); |
| | | if (result != null && result.isHasNextPage()) { |
| | | if (result.getGoodsList() != null) |
| | | for (FirstOrderSubInfo info : result.getGoodsList()) { |
| | | firstOrderSubInfoService.add(info); |
| | | System.out.println(info.getId() + "-" + info.getTitle()); |
| | | } |
| | | System.out.println("----------------------------"); |
| | | return JsonUtil.loadTrueResult(null); |
| | | } else { |
| | | return JsonUtil.loadFalseResult(1, "无更多数据"); |
| | | } |
| | | } catch (TBCookieException e) { |
| | | return JsonUtil.loadFalseResult(1001, "淘宝授权出错"); |
| | | } |
| | | } |
| | | |