RocketMQ的消息整改

admin

2019-11-20 8b2191df2f7d94aa299bd43dcbe97c94e5a61bbd

 fanli/src/main/java/com/yeshi/fanli/util/elme/ElmeOrderUtil.java

@@ -5,7 +5,6 @@
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;

@@ -17,6 +16,8 @@
import javax.mail.Store;

import javax.mail.internet.MimeMessage;



import org.apache.poi.hssf.usermodel.HSSFDateUtil;

import org.apache.poi.ss.usermodel.Cell;

import org.apache.poi.ss.usermodel.Row;

import org.apache.poi.xssf.usermodel.XSSFWorkbook;

import org.yeshi.utils.mail.ShowMail;

@@ -44,11 +45,24 @@
         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();

            Cell cell = row.getCell(c);

            String content = null;



            String columnName = firstRow.getCell(c).getStringCellValue().trim();

            if (cell.getCellType() == Cell.CELL_TYPE_NUMERIC) {

               if (HSSFDateUtil.isCellDateFormatted(cell)) { // 判断日期类型

                  Date date = cell.getDateCellValue();

                  content = TimeUtil.getGernalTime(date.getTime(), "yyyy-MM-dd");

               } else { // 否

                  content =  cell.getNumericCellValue() + "";

               }



            } else if (cell.getCellType() == Cell.CELL_TYPE_STRING) {

               content = (cell.getStringCellValue());

            }

            switch (columnName) {

            case "渠道号":

               order.setChannelId(content);

               order.setChannelId(new BigDecimal(content).longValue()+"");

               break;

            case "渠道名称":

               order.setChannelName(content);

@@ -57,13 +71,13 @@
               order.setTrackPid(content);

               break;

            case "rid":

               order.setRid(content);

               order.setRid(new BigDecimal(content).longValue()+"");

               break;

            case "订单日期":

               order.setOrderDate(new Date(TimeUtil.convertToTimeTemp(content, "yyyy-MM-dd")));

               break;

            case "订单号":

               order.setOrderId(content.replace("<", "").replace(">", ""));

               order.setOrderId(content.replace("&lt;", "").replace("&gt;", "").replace("<", "").replace(">", ""));

               break;

            case "支付金额":

               order.setPayMoney(new BigDecimal(content));

@@ -75,19 +89,19 @@
               order.setCouponMoney(new BigDecimal(content));

               break;

            case "是否新客首单":

               order.setNewerFirstOrder(Integer.parseInt(content));

               order.setNewerFirstOrder(new BigDecimal(content).intValue());

               break;

            case "是否新客复购单":

               order.setNewerRepayOrder(Integer.parseInt(content));

               order.setNewerRepayOrder(new BigDecimal(content).intValue());

               break;

            case "是否使用淘客红包":

               order.setTaokeHongBao(Integer.parseInt(content));

               order.setTaokeHongBao(new BigDecimal(content).intValue());

               break;

            case "是否有在会场内该门店的点击记录":

               order.setShopClick(Integer.parseInt(content));

               order.setShopClick(new BigDecimal(content).intValue());

               break;

            case "是否领券后7天内首单":

               order.setRecieveCoupon7DayFirstOrder(Integer.parseInt(content));

               order.setRecieveCoupon7DayFirstOrder(new BigDecimal(content).intValue());

               break;

            case "是否6结佣":

               if ("是".equalsIgnoreCase(content))