| | |
|---|
| | | package com.yeshi.fanli.util.elme;
|
|---|
| | |
|
|---|
| | | import java.io.IOException;
|
|---|
| | | import java.io.InputStream;
|
|---|
| | | import java.math.BigDecimal;
|
|---|
| | | import java.util.ArrayList;
|
|---|
| | | import java.util.Arrays;
|
|---|
| | | import java.util.Collections;
|
|---|
| | | import java.util.Date;
|
|---|
| | | import java.util.List;
|
|---|
| | | import java.util.Properties;
|
|---|
| | |
|
|---|
| | | import javax.mail.Folder;
|
|---|
| | | import javax.mail.Message;
|
|---|
| | | import javax.mail.Part;
|
|---|
| | | import javax.mail.Session;
|
|---|
| | | import javax.mail.Store;
|
|---|
| | | import javax.mail.internet.MimeMessage;
|
|---|
| | |
|
|---|
| | | import org.apache.poi.ss.usermodel.Row;
|
|---|
| | | import org.apache.poi.xssf.usermodel.XSSFWorkbook;
|
|---|
| | | import org.yeshi.utils.mail.ShowMail;
|
|---|
| | |
|
|---|
| | | import com.yeshi.fanli.entity.elme.ElmeOrder;
|
|---|
| | | import com.yeshi.fanli.util.MoneyBigDecimalUtil;
|
|---|
| | | import com.yeshi.fanli.util.TimeUtil;
|
|---|
| | |
|
|---|
| | | public class ElmeOrderUtil {
|
|---|
| | |
|
|---|
| | | public static List<ElmeOrder> parseOrder(InputStream is) {
|
|---|
| | | List<ElmeOrder> list = new ArrayList<>();
|
|---|
| | |
|
|---|
| | | org.apache.poi.ss.usermodel.Workbook wb = null;
|
|---|
| | | try {
|
|---|
| | | wb = new XSSFWorkbook(is);
|
|---|
| | | } catch (IOException e) {
|
|---|
| | | e.printStackTrace();
|
|---|
| | | }
|
|---|
| | | // 开始解析
|
|---|
| | | org.apache.poi.ss.usermodel.Sheet sheet = wb.getSheetAt(0);
|
|---|
| | |
|
|---|
| | | Row firstRow = sheet.getRow(0);
|
|---|
| | | for (int r = 1; r <= sheet.getLastRowNum(); r++) {
|
|---|
| | | ElmeOrder order = new ElmeOrder();
|
|---|
| | | Row row = sheet.getRow(r);
|
|---|
| | | for (int c = row.getFirstCellNum(); c < row.getLastCellNum(); c++) {
|
|---|
| | | String content = row.getCell(c).toString().trim();
|
|---|
| | | String columnName = firstRow.getCell(c).getStringCellValue().trim();
|
|---|
| | | switch (columnName) {
|
|---|
| | | case "渠道号":
|
|---|
| | | order.setChannelId(content);
|
|---|
| | | break;
|
|---|
| | | case "渠道名称":
|
|---|
| | | order.setChannelName(content);
|
|---|
| | | break;
|
|---|
| | | case "track_pid":
|
|---|
| | | order.setTrackPid(content);
|
|---|
| | | break;
|
|---|
| | | case "rid":
|
|---|
| | | order.setRid(content);
|
|---|
| | | break;
|
|---|
| | | case "订单日期":
|
|---|
| | | order.setOrderDate(new Date(TimeUtil.convertToTimeTemp(content, "yyyy-MM-dd")));
|
|---|
| | | break;
|
|---|
| | | case "订单号":
|
|---|
| | | order.setOrderId(content.replace("<", "").replace(">", ""));
|
|---|
| | | break;
|
|---|
| | | case "支付金额":
|
|---|
| | | order.setPayMoney(new BigDecimal(content));
|
|---|
| | | break;
|
|---|
| | | case "下单城市":
|
|---|
| | | order.setCity(content);
|
|---|
| | | break;
|
|---|
| | | case "用券金额":
|
|---|
| | | order.setCouponMoney(new BigDecimal(content));
|
|---|
| | | break;
|
|---|
| | | case "是否新客首单":
|
|---|
| | | order.setNewerFirstOrder(Integer.parseInt(content));
|
|---|
| | | break;
|
|---|
| | | case "是否新客复购单":
|
|---|
| | | order.setNewerRepayOrder(Integer.parseInt(content));
|
|---|
| | | break;
|
|---|
| | | case "是否使用淘客红包":
|
|---|
| | | order.setTaokeHongBao(Integer.parseInt(content));
|
|---|
| | | break;
|
|---|
| | | case "是否有在会场内该门店的点击记录":
|
|---|
| | | order.setShopClick(Integer.parseInt(content));
|
|---|
| | | break;
|
|---|
| | | case "是否领券后7天内首单":
|
|---|
| | | order.setRecieveCoupon7DayFirstOrder(Integer.parseInt(content));
|
|---|
| | | break;
|
|---|
| | | case "是否6结佣":
|
|---|
| | | if ("是".equalsIgnoreCase(content))
|
|---|
| | | order.setIsSettle(true);
|
|---|
| | | else
|
|---|
| | | order.setIsSettle(false);
|
|---|
| | | break;
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | list.add(order);
|
|---|
| | | }
|
|---|
| | | return list;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | public static BigDecimal getCommission(BigDecimal payMoney) {
|
|---|
| | | return MoneyBigDecimalUtil.mul(payMoney, new BigDecimal("0.06"));
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | public static List<ElmeOrder> pullLatest5DayOrder() {
|
|---|
| | | List<ElmeOrder> totalOrderList = new ArrayList<>();
|
|---|
| | | String host = "pop.qq.com";
|
|---|
| | | String username = "2780501319@qq.com";
|
|---|
| | | String password = "dbltidaeknumdgfd";
|
|---|
| | | Properties props = new Properties();
|
|---|
| | | Session session = Session.getDefaultInstance(props, null);
|
|---|
| | | try {
|
|---|
| | | Store store = session.getStore("pop3");
|
|---|
| | | store.connect(host, username, password);
|
|---|
| | | Folder folder = store.getFolder("INBOX");
|
|---|
| | | folder.open(Folder.READ_ONLY);
|
|---|
| | | Message message[] = folder.getMessages();
|
|---|
| | | List<Message> list = Arrays.asList(message);
|
|---|
| | | int count = 0;
|
|---|
| | | for (int i = list.size() - 1; i >= 0; i--) {
|
|---|
| | | ShowMail showMail = new ShowMail((MimeMessage) list.get(i));
|
|---|
| | | if ("qiuming.wu<qiuming.wu@ele.me>".equalsIgnoreCase(showMail.getFrom())) {
|
|---|
| | | if (count++ > 4)
|
|---|
| | | break;
|
|---|
| | | boolean attch = showMail.isContainAttach((Part) list.get(i));
|
|---|
| | | if (attch) {
|
|---|
| | | List<InputStream> attchList = showMail.saveAttachMent((Part) list.get(i));
|
|---|
| | | if (attchList.size() > 0) {
|
|---|
| | | List<ElmeOrder> orderList = ElmeOrderUtil.parseOrder(attchList.get(0));
|
|---|
| | | if (orderList != null && orderList.size() > 0)
|
|---|
| | | totalOrderList.addAll(orderList);
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | e.printStackTrace();
|
|---|
| | | }
|
|---|
| | | return totalOrderList;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | }
|
|---|
