4cdb9f1a6255cc1c51a3ea4479ef5326d35921bc.svn-base 1.5 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647
  1. package com.chinacreator.process;
  2. import java.util.HashMap;
  3. import java.util.List;
  4. import java.util.Map;
  5. import com.chinacreator.process.util.JsonUtil;
  6. import com.chinacreator.process.util.ReadUtil;
  7. import com.chinacreator.process.util.URLUtil;
  8. public class RepeatMain {
  9. private final static String FILENAME = "f:444.txt";
  10. public static void main(String[] args) {
  11. List<Map<?,?>> list = ReadUtil.readTxt(FILENAME, "utf-8");
  12. for (Map<?, ?> txtmap : list) {
  13. Map<String, String> map = new HashMap<String, String>();
  14. map.put("userid", (String)txtmap.get("userid"));
  15. map.put("cpid",(String)txtmap.get("cpid"));
  16. map.put("spid", (String)txtmap.get("spid"));
  17. map.put("province", (String)txtmap.get("province"));
  18. map.put("area", (String)txtmap.get("area"));
  19. String orderType = (String)txtmap.get("orderType");
  20. map.put("status", orderType);
  21. if(orderType.equals("0")){
  22. map.put("ordertime", (String)txtmap.get("updateTime"));
  23. map.put("canceltime", "");
  24. map.put("orderchannel", (String)txtmap.get("channel"));
  25. map.put("cancelchannel", "");
  26. }else{
  27. map.put("canceltime", (String)txtmap.get("updateTime"));
  28. map.put("ordertime", "");
  29. map.put("orderchannel","");
  30. map.put("cancelchannel", (String)txtmap.get("channel"));
  31. }
  32. map.put("header", "order");
  33. map.put("type", "order");
  34. try {
  35. System.out.println(JsonUtil.objectToJson(map));
  36. System.out.println(URLUtil.post("http://127.0.0.136:8041/mq-service/recive.do", JsonUtil.objectToJson(map)));
  37. } catch (Exception e) {
  38. e.printStackTrace();
  39. }
  40. }
  41. }
  42. }