| | |
|---|
| | |
|
|---|
| | | import java.io.Serializable;
|
|---|
| | | import java.math.BigDecimal;
|
|---|
| | | import java.text.SimpleDateFormat;
|
|---|
| | | import java.util.ArrayList;
|
|---|
| | | import java.util.Date;
|
|---|
| | | import java.util.HashMap;
|
|---|
| | | import java.util.List;
|
|---|
| | | import java.util.Map;
|
|---|
| | |
|
|---|
| | | import javax.annotation.Resource;
|
|---|
| | | import javax.servlet.http.HttpServletRequest;
|
|---|
| | |
|
|---|
| | | import net.sf.json.JSONObject;
|
|---|
| | |
|
|---|
| | | import org.hibernate.HibernateException;
|
|---|
| | | import org.hibernate.Query;
|
|---|
| | |
|---|
| | | import org.springframework.transaction.annotation.Transactional;
|
|---|
| | | import org.springframework.web.context.request.RequestContextHolder;
|
|---|
| | | import org.springframework.web.context.request.ServletRequestAttributes;
|
|---|
| | | import org.yeshi.utils.DateUtil;
|
|---|
| | |
|
|---|
| | | import com.yeshi.fanli.dao.hongbao.HongBaoDao;
|
|---|
| | | import com.yeshi.fanli.dao.mybatis.AccountDetailsMapper;
|
|---|
| | |
|---|
| | | import com.yeshi.fanli.util.push.XiaoMiPushUtil;
|
|---|
| | | import com.yeshi.fanli.util.taobao.TaoBaoOrderUtil;
|
|---|
| | | import com.yeshi.fanli.util.taobao.TaoBaoUtil;
|
|---|
| | |
|
|---|
| | | import net.sf.json.JSONObject;
|
|---|
| | |
|
|---|
| | | @Service
|
|---|
| | | public class HongBaoServiceImpl implements HongBaoService {
|
|---|
| | |
|---|
| | | System.out.println("订单:" + order);
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @Transactional
|
|---|
| | | @Override
|
|---|
| | | public void addHongBao(Order order, TaoBaoOrder taoBaoOrder, Long orderItemId) {
|
|---|
| | | OrderItem orderItem = orderItemMapper.selectByPrimaryKey(orderItemId);
|
|---|
| | | // 订单返利比例
|
|---|
| | | BigDecimal proportion = hongBaoManageService.getFanLiRate();
|
|---|
| | | BigDecimal baseRate = proportion.divide(new BigDecimal(100));
|
|---|
| | |
|
|---|
| | | // 创建红包
|
|---|
| | | JSONObject data = new JSONObject();
|
|---|
| | | HongBao hongBao = null;
|
|---|
| | | if (taoBaoOrder.getOrderState().equalsIgnoreCase("订单结算"))
|
|---|
| | | // 订单结算应该取结算金额与预估收入
|
|---|
| | | hongBao = HongBaoFactory.createHongBao(MoneyBigDecimalUtil.mul(baseRate, taoBaoOrder.geteIncome()),
|
|---|
| | | data.toString(), order.getId(), null, order.getUserInfo(), 1, taoBaoOrder.getSettlement(),
|
|---|
| | | taoBaoOrder.getAuctionId());
|
|---|
| | | else
|
|---|
| | | hongBao = HongBaoFactory.createHongBao(MoneyBigDecimalUtil.mul(baseRate, taoBaoOrder.getEstimate()),
|
|---|
| | | data.toString(), order.getId(), null, order.getUserInfo(), 1, taoBaoOrder.getPayment(),
|
|---|
| | | taoBaoOrder.getAuctionId());
|
|---|
| | |
|
|---|
| | | hongBao.setOrderId(taoBaoOrder.getOrderId());
|
|---|
| | | hongBao.setOrderItemId(orderItem.getId());
|
|---|
| | | hongBao.setPreGettime(0L);
|
|---|
| | | if (taoBaoOrder.getOrderState().equalsIgnoreCase("订单结算")
|
|---|
| | | && !StringUtil.isNullOrEmpty(taoBaoOrder.getSettlementTime()))
|
|---|
| | | hongBao.setBalanceTime(
|
|---|
| | | new Date(TimeUtil.convertToTimeTemp(taoBaoOrder.getSettlementTime(), "yyyy-MM-dd HH:mm:ss")));
|
|---|
| | |
|
|---|
| | | UserInfo boss = threeSaleMapper.selectBoss(order.getUserInfo().getId());
|
|---|
| | |
|
|---|
| | | if (boss != null) {
|
|---|
| | | hongBao.setHasChild(true);
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | // 如果失效就判定已经失效
|
|---|
| | | if (taoBaoOrder.getOrderState().equalsIgnoreCase("订单失效"))
|
|---|
| | | hongBao.setState(HongBao.STATE_SHIXIAO);
|
|---|
| | |
|
|---|
| | | hongBaoMapper.insertSelective(hongBao);
|
|---|
| | | // 通知用户订单被统计
|
|---|
| | | if (!taoBaoOrder.getOrderState().equalsIgnoreCase("订单失效")) {
|
|---|
| | | try {
|
|---|
| | | userNotificationService.orderFanliStatisticed(hongBao.getUserInfo().getId(), order.getOrderId());
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | // 提成订单不处理失效订单
|
|---|
| | | if (taoBaoOrder.getOrderState().equalsIgnoreCase("订单失效"))
|
|---|
| | | return;
|
|---|
| | | if (boss != null) {
|
|---|
| | | // 计算上级返利金额
|
|---|
| | | HongBaoManage hbm = hongBaoManageMapper
|
|---|
| | | .selectByKey("sale_6_" + (boss.getRank() == null ? 0 : boss.getRank()));
|
|---|
| | | BigDecimal rate = null;
|
|---|
| | | if (hbm == null)
|
|---|
| | | rate = new BigDecimal(0);
|
|---|
| | | else
|
|---|
| | | rate = new BigDecimal(hbm.getValue()).divide(new BigDecimal(100));
|
|---|
| | | if (rate.compareTo(new BigDecimal(0)) > 0) {
|
|---|
| | | HongBao hongBao2 = null;
|
|---|
| | | if (taoBaoOrder.getOrderState().equalsIgnoreCase("订单结算")) {
|
|---|
| | | // 订单结算应该取结算金额与预估收入
|
|---|
| | | hongBao2 = HongBaoFactory.createHongBao(
|
|---|
| | | MoneyBigDecimalUtil.mul(rate, MoneyBigDecimalUtil.mul(taoBaoOrder.geteIncome(), baseRate)),
|
|---|
| | | null, hongBao, boss, Constant.ONESALE);
|
|---|
| | | } else {
|
|---|
| | | hongBao2 = HongBaoFactory.createHongBao(
|
|---|
| | | MoneyBigDecimalUtil.mul(rate, MoneyBigDecimalUtil.mul(taoBaoOrder.getEstimate(), baseRate)),
|
|---|
| | | null, hongBao, boss, Constant.ONESALE);
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | HongBaoFactory.createHongBao(
|
|---|
| | | MoneyBigDecimalUtil.mul(rate, MoneyBigDecimalUtil.mul(taoBaoOrder.getEstimate(), baseRate)),
|
|---|
| | | null, hongBao, boss, Constant.ONESALE);
|
|---|
| | | // 设置订单号
|
|---|
| | | hongBao2.setOrderId(taoBaoOrder.getOrderId());
|
|---|
| | |
|
|---|
| | | hongBaoMapper.insertSelective(hongBao2);
|
|---|
| | |
|
|---|
| | | try {
|
|---|
| | | // 通知提成订单被统计
|
|---|
| | | userNotificationService.tiChengStatisticed(hongBao2.getUserInfo().getId(), hongBao2.getOrderId(),
|
|---|
| | | hongBao2.getMoney());
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | UserInfo boss2 = threeSaleMapper.selectBoss(boss.getId());
|
|---|
| | | // 计算上上级返利
|
|---|
| | | if (boss2 != null) {
|
|---|
| | | hbm = hongBaoManageMapper.selectByKey("sale_7_" + (boss.getRank() == null ? 0 : boss.getRank()));
|
|---|
| | | if (hbm == null)
|
|---|
| | | rate = new BigDecimal(0);
|
|---|
| | | else
|
|---|
| | | rate = new BigDecimal(hbm.getValue()).divide(new BigDecimal(100));
|
|---|
| | | if (rate.compareTo(new BigDecimal(0)) > 0) {
|
|---|
| | | // 订单结算应该取结算金额与预估收入
|
|---|
| | | HongBao hongBao3 = null;
|
|---|
| | | if (taoBaoOrder.getOrderState().equalsIgnoreCase("订单结算"))
|
|---|
| | | hongBao3 = HongBaoFactory.createHongBao(
|
|---|
| | | MoneyBigDecimalUtil.mul(rate,
|
|---|
| | | MoneyBigDecimalUtil.mul(taoBaoOrder.geteIncome(), baseRate)),
|
|---|
| | | null, hongBao, boss2, Constant.TWOSALE);
|
|---|
| | | else
|
|---|
| | | hongBao3 = HongBaoFactory.createHongBao(
|
|---|
| | | MoneyBigDecimalUtil.mul(rate,
|
|---|
| | | MoneyBigDecimalUtil.mul(taoBaoOrder.getEstimate(), baseRate)),
|
|---|
| | | null, hongBao, boss2, Constant.TWOSALE);
|
|---|
| | | // 设置返利订单号
|
|---|
| | | hongBao3.setOrderId(taoBaoOrder.getOrderId());
|
|---|
| | | hongBaoMapper.insertSelective(hongBao3);
|
|---|
| | |
|
|---|
| | | try {
|
|---|
| | | // 通知提成订单被统计
|
|---|
| | | userNotificationService.tiChengStatisticed(hongBao3.getUserInfo().getId(),
|
|---|
| | | hongBao3.getOrderId(), hongBao3.getMoney());
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | | public BigDecimal getTotalTiChengMoney(Long uid) {
|
|---|
| | |
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | | public int getTotalTiChengCount(Long uid) {
|
|---|
| | |
|
|---|
| | | return hongBaoMapper.getTotalTiChengCount(uid);
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | |
|---|
| | | @Override
|
|---|
| | | public List<Map<String, Object>> count24HOderByChannel(String channel, Integer type, String years,
|
|---|
| | | String startTime, String endTime) throws Exception{
|
|---|
| | | return hongBaoMapper.count24HOderByChannel(channel, type, years, startTime, endTime);
|
|---|
| | | }
|
|---|
| | | |
|---|
| | | @Override
|
|---|
| | | public List<Map<String, Object>> countHistoryOderByChannel(String channel, Integer type, String years,
|
|---|
| | | String startTime, String endTime) throws Exception{
|
|---|
| | | |
|---|
| | | return hongBaoMapper.countHistoryOderByChannel(channel, type, years, |
|---|
| | | startTime, endTime);
|
|---|
| | | }
|
|---|
| | | |
|---|
| | | |
|---|
| | | public List<Object> dayFactory(String startTime, String endTime, List<Map<String, Object>> list) throws Exception {
|
|---|
| | | |
|---|
| | | List<Object> listObject = new ArrayList<Object>();
|
|---|
| | | |
|---|
| | | if (startTime.equals(endTime)) {
|
|---|
| | | |
|---|
| | | Map<String, Object> map = list.get(0);
|
|---|
| | | Object payMoney = map.get("payMoney");
|
|---|
| | | Object countOrder = map.get("countOrder");
|
|---|
| | | Object commision = map.get("commision");
|
|---|
| | | |
|---|
| | | if (payMoney == null) {
|
|---|
| | | map.put("payMoney", 0);
|
|---|
| | | }
|
|---|
| | | if (countOrder == null) {
|
|---|
| | | map.put("countOrder", 0);
|
|---|
| | | }
|
|---|
| | | if (commision == null) {
|
|---|
| | | map.put("commision", 0);
|
|---|
| | | }
|
|---|
| | | listObject.add(map);
|
|---|
| | | return listObject;
|
|---|
| | | }
|
|---|
| | | |
|---|
| | | |
|---|
| | | String plusDay = "";
|
|---|
| | | for (int i = 0; i < 1000 ; i++) {
|
|---|
| | | if (i == 0) {
|
|---|
| | | plusDay = startTime;
|
|---|
| | | } else {
|
|---|
| | | plusDay = DateUtil.plusDay(i, startTime);
|
|---|
| | | }
|
|---|
| | | |
|---|
| | | Map<String, Object> mapObject = new HashMap<String, Object>();
|
|---|
| | | Object payMoney = null;
|
|---|
| | | Object countOrder = null;
|
|---|
| | | Object commision = null; |
|---|
| | | |
|---|
| | | for (int j = 0; j < list.size(); j++) {
|
|---|
| | | Map<String, Object> map = list.get(j);
|
|---|
| | | Object createDate = map.get("showDate");
|
|---|
| | | String month = createDate.toString();
|
|---|
| | | if (plusDay.equalsIgnoreCase(month)) {
|
|---|
| | | payMoney = map.get("payMoney");
|
|---|
| | | countOrder = map.get("countOrder");
|
|---|
| | | commision = map.get("commision");
|
|---|
| | | break;
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | |
|---|
| | | if (payMoney == null) {
|
|---|
| | | payMoney = 0;
|
|---|
| | | }
|
|---|
| | | mapObject.put("payMoney", payMoney);
|
|---|
| | | |
|---|
| | | if (countOrder == null) {
|
|---|
| | | countOrder = 0;
|
|---|
| | | }
|
|---|
| | | mapObject.put("countOrder", countOrder);
|
|---|
| | | |
|---|
| | | if (commision == null) {
|
|---|
| | | commision = 0;
|
|---|
| | | }
|
|---|
| | | mapObject.put("commision", commision);
|
|---|
| | | |
|---|
| | | SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
|
|---|
| | | SimpleDateFormat sdf2 = new SimpleDateFormat("yyyy/MM/dd");
|
|---|
| | | Date parseDate = sdf.parse(plusDay.toString());
|
|---|
| | | |
|---|
| | | mapObject.put("showDate", sdf2.format(parseDate));
|
|---|
| | | |
|---|
| | | listObject.add(mapObject);
|
|---|
| | | |
|---|
| | | if (plusDay.equals(endTime)) {
|
|---|
| | | break; // 时间结束
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | |
|---|
| | | return listObject;
|
|---|
| | | }
|
|---|
| | | |
|---|
| | | |
|---|
| | | public List<Object> monthFactory(List<Map<String, Object>> list) {
|
|---|
| | | |
|---|
| | | List<Object> listObject = new ArrayList<Object>();
|
|---|
| | | // 12 个月处理
|
|---|
| | | for (int i = 1; i <= 12; i++) {
|
|---|
| | | Map<String, Object> mapObject = new HashMap<String, Object>();
|
|---|
| | | Object payMoney = null;
|
|---|
| | | Object countOrder = null;
|
|---|
| | | Object commision = null; |
|---|
| | | |
|---|
| | | for (int j = 0; j < list.size(); j++) {
|
|---|
| | | Map<String, Object> map = list.get(j);
|
|---|
| | | Object createDate = map.get("showDate");
|
|---|
| | | String month = createDate.toString();
|
|---|
| | | if ((i+"").equalsIgnoreCase(month) || i == Integer.parseInt(month)) {
|
|---|
| | | payMoney = map.get("payMoney");
|
|---|
| | | countOrder = map.get("countOrder");
|
|---|
| | | commision = map.get("commision");
|
|---|
| | | break;
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | |
|---|
| | | if (payMoney == null) {
|
|---|
| | | payMoney = 0;
|
|---|
| | | }
|
|---|
| | | mapObject.put("payMoney", payMoney);
|
|---|
| | | |
|---|
| | | if (countOrder == null) {
|
|---|
| | | countOrder = 0;
|
|---|
| | | }
|
|---|
| | | mapObject.put("countOrder", countOrder);
|
|---|
| | | |
|---|
| | | if (commision == null) {
|
|---|
| | | commision = 0;
|
|---|
| | | }
|
|---|
| | | mapObject.put("commision", commision);
|
|---|
| | | |
|---|
| | | mapObject.put("showDate", i + "月");
|
|---|
| | | |
|---|
| | | listObject.add(mapObject);
|
|---|
| | | }
|
|---|
| | | return listObject;
|
|---|
| | | }
|
|---|
| | | |
|---|
| | | public List<Object> yearFactory(List<Map<String, Object>> list) {
|
|---|
| | | |
|---|
| | | List<Object> listObject = new ArrayList<Object>();
|
|---|
| | | |
|---|
| | | for (int i = 0; i < list.size(); i++) {
|
|---|
| | | Map<String, Object> map = list.get(i);
|
|---|
| | | Object payMoney = map.get("payMoney");
|
|---|
| | | Object countOrder = map.get("countOrder");
|
|---|
| | | Object commision = map.get("commision"); |
|---|
| | | |
|---|
| | | if (payMoney == null) {
|
|---|
| | | payMoney = 0;
|
|---|
| | | }
|
|---|
| | | map.put("payMoney", payMoney);
|
|---|
| | | |
|---|
| | | if (countOrder == null) {
|
|---|
| | | countOrder = 0;
|
|---|
| | | }
|
|---|
| | | map.put("countOrder", countOrder);
|
|---|
| | | |
|---|
| | | if (commision == null) {
|
|---|
| | | commision = 0;
|
|---|
| | | }
|
|---|
| | | map.put("commision", commision);
|
|---|
| | | |
|---|
| | | listObject.add(map);
|
|---|
| | | }
|
|---|
| | | |
|---|
| | | return listObject;
|
|---|
| | | }
|
|---|
| | | }
|
|---|
