adm/src/main/java/com/minpay/shouhuo/invCardManageAction.java

package com.minpay.shouhuo;

import com.minpay.common.bean.User;
import com.minpay.common.format.IFormatService;
import com.minpay.common.service.ILogService;
import com.minpay.common.util.CommonUtil;
import com.minpay.common.util.DateUtil;
import com.minpay.db.table.mapper.VmOrderInfMapper;
import com.minpay.db.table.model.VmOrderInf;
import com.minpay.db.table.own.mapper.OrderManageMapper;
import com.startup.minpay.frame.business.IMINAction;
import com.startup.minpay.frame.business.res.MINActionResult;
import com.startup.minpay.frame.constant.IMINBusinessConstant;
import com.startup.minpay.frame.data.format.MINCopyFormat;
import com.startup.minpay.frame.jdbc.MINRowBounds;
import com.startup.minpay.frame.service.base.IMINDataBaseService;
import com.startup.minpay.frame.service.base.Service;
import com.startup.minpay.frame.session.MINSession;
import com.startup.minpay.frame.target.MINAction;
import com.startup.minpay.frame.target.MINComponent;
import com.startup.minpay.frame.target.MINParam;
import org.apache.commons.lang.StringUtils;

import java.math.BigDecimal;
import java.text.SimpleDateFormat;
import java.util.*;

/**
 * 财务管理
 * 
 * @author wlm
 */
@MINComponent
public class invCardManageAction implements IMINAction {

	/**查询订单详情**/
	public final static String SELECT_ORDER_DETAIL = "selectOrderDetail";

	/**取货、作废**/
	public final static String UPDATE_ORDER_STT = "updateOrderStt";

	/**查询取货记录**/
	public final static String SELECT_PICKUP_RECORD = "selectPickupRecord";

	/**  收入统计 **/
	public final static String SELECT_INCOME_STATISTICS = "selectIncomeStatistics";

	/**  收入统计 **/
	public final static String SELECT_ALL_INCOME = "selectAllIncome";

	/**  销售数据 **/
	public final static String SELECT_SALES_DATA = "selectSalesData";
	/**  销售数据2 **/
	public final static String SELECT_ALL_SALE = "selectAllSale";

	/**  时间轴查询销售金额、预估利润 **/
	public final static String SELECT_INCOME_BYDATE = "selectIncomeBydate";

	/**
	 * 时间轴查询销售金额、预估利润
	 * @param session
	 * @return
	 * @throws Exception
	 */
	@MINAction(value = SELECT_INCOME_BYDATE)
	public MINActionResult selectIncomeBydate (
			@MINParam(key = "dateFlag") String dateFlag,
			MINSession session) throws Exception {
		MINActionResult res = new MINActionResult();
		User user = session.getUser();
		//获取当前时间
		Date currentTime = new Date();
		String nowDate = DateUtil.format(currentTime,"yyyyMMdd");
		Map<String, String> m = new HashMap<String, String>();
		//昨天
		String yesDate = DateUtil.getDifferentDate(-1).substring(0,8);
		//本周第一天
		Calendar cal=Calendar.getInstance();
		cal.add(Calendar.WEEK_OF_MONTH, 0);
		cal.set(Calendar.DAY_OF_WEEK, 2);
		Date weekFristDate = cal.getTime();
		String weekDate = DateUtil.format(weekFristDate,"yyyyMMdd");
		//按时间查询
		String time = null;
		if("0".equals(dateFlag)) {
			m.put("nowDate", nowDate);
			Date  parse = new SimpleDateFormat("yyyyMMdd").parse(nowDate);
			String  dateString = new SimpleDateFormat("yyyy-MM-dd").format(parse);
			time = dateString;
		}else if("1".equals(dateFlag)) {
			m.put("yesDate", yesDate);
			Date  parse = new SimpleDateFormat("yyyyMMdd").parse(yesDate);
			String  dateString = new SimpleDateFormat("yyyy-MM-dd").format(parse);
			time = dateString;
		}else if("2".equals(dateFlag)) {
			m.put("weekDate", weekDate);
			Date  parse = new SimpleDateFormat("yyyyMMdd").parse(weekDate);
			String  dateString = new SimpleDateFormat("yyyy-MM-dd").format(parse);
			Date  parseb = new SimpleDateFormat("yyyyMMdd").parse(nowDate);
			String  dateStringb = new SimpleDateFormat("yyyy-MM-dd").format(parseb);
			 time = dateString.concat(" 至 ").concat(dateStringb);
		}
		//查询累计收入
		String countIncome = Service.lookup(IMINDataBaseService.class)
				.getMybatisMapper(OrderManageMapper.class).selectCountIncome(m);
		//查询预估利润
		String predictIncome = Service.lookup(IMINDataBaseService.class)
				.getMybatisMapper(OrderManageMapper.class).selectPredictIncome(m);

		//查询累计收入
		List<Map<String, String>> mapList = Service.lookup(IMINDataBaseService.class)
														.getMybatisMapper(OrderManageMapper.class).selectCountIncomeb(m);

		String  wxzfbAmout = "0";
		String  czAmout = "0";
		for (int i = 0; i < mapList.size(); i++) {
			Map<String, String> map = mapList.get(i);
			String transType = map.get("transType");
			if(transType.equals("00")){ //充值金额
				 czAmout =  String.valueOf(map.get("amout"));
			}
			if(transType.equals("10")){ //支付金额
				wxzfbAmout =   String.valueOf(map.get("amout"));
			}
		}

		predictIncome = CommonUtil.subtract(countIncome,predictIncome);
		String zsrAmout = CommonUtil.add(czAmout,wxzfbAmout);
		//返回数据
		res.set("countIncome", countIncome);
		res.set("predictIncome", predictIncome);
		res.set("czAmout", czAmout);
		res.set("zsrAmout", zsrAmout);
		res.set("time", time);
		return res;
	}

	/**
	 * 总销售数量
	 * @param session
	 * @return
	 * @throws Exception
	 */
	@MINAction(value = SELECT_ALL_SALE)
	public MINActionResult selectAllSale (
			MINSession session) throws Exception {
		MINActionResult res = new MINActionResult();
		User user = session.getUser();
		//总实际金额
		String allSale = Service.lookup(IMINDataBaseService.class)
				.getMybatisMapper(OrderManageMapper.class).selectAllSale();
		//总商品成本
		String allCost = Service.lookup(IMINDataBaseService.class)
				.getMybatisMapper(OrderManageMapper.class).selectAllCost();
		BigDecimal num1 = new BigDecimal(allSale);
		BigDecimal num2 = new BigDecimal(allCost);
		BigDecimal  allProfit = num1.subtract(num2);
		//返回数据
		res.set("allSale", allSale);
		res.set("allCost", allCost);
		res.set("allProfit", allProfit);

		return res;
	}
	/**
	 * 销售数据
	 * @param page
	 * @param limit
	 * @param session
	 * @return
	 * @throws Exception
	 */
	@MINAction(value = SELECT_SALES_DATA)
	public MINActionResult selectSalesData (
			@MINParam(key = "page", defaultValue = "1") int page,
			@MINParam(key = "limit", defaultValue = "7") int limit,
			@MINParam(key = "proName") String proName,
			MINSession session) throws Exception {
		MINActionResult res = new MINActionResult();
		User user = session.getUser();
		Map<String, String> m = new HashMap<String, String>();
		m.put("proName", proName);

		MINRowBounds rows = new MINRowBounds(page, limit);
		List<Map<String, String>> detailList = Service.lookup(IMINDataBaseService.class)
				.getMybatisMapper(OrderManageMapper.class).selectProductInfo(rows, m);

		detailList = Service.lookup(IFormatService.class).formatCurrency(detailList, "amount", "proNums");

		//返回数据
		res.set(IMINBusinessConstant.F_PAGING_LAY, detailList);
		res.set(IMINBusinessConstant.F_PAGING_COUNT, rows.getCount());
		return res;
	}

	/**
	 * 总收入统计
	 * @param session
	 * @return
	 * @throws Exception
	 */
//	@MINAction(value = SELECT_ALL_INCOME)
//	public MINActionResult selectAllIncome (
//			MINSession session) throws Exception {
//		MINActionResult res = new MINActionResult();
//		User user = session.getUser();
//		//查询订单数
//		String orderNum = Service.lookup(IMINDataBaseService.class)
//				.getMybatisMapper(OrderManageMapper.class).selectCountOrderNum();
//		//查询累计收入
//		String countIncome = Service.lookup(IMINDataBaseService.class)
//				.getMybatisMapper(OrderManageMapper.class).selectCountIncome();
//		//查询总机台数
//		String countDevice = Service.lookup(IMINDataBaseService.class)
//				.getMybatisMapper(OrderManageMapper.class).selectCountDevice();
//		//返回数据
//		res.set("orderNum", orderNum);
//		res.set("countIncome", countIncome);
//		res.set("countDevice", countDevice);
//		return res;
//	}

	/**
	 * 收入统计
	 * @param page
	 * @param limit
	 * @param session
	 * @return
	 * @throws Exception
	 */
	@MINAction(value = SELECT_INCOME_STATISTICS)
	public MINActionResult selectIncomeStatistics (
			@MINParam(key = "page", defaultValue = "1") int page,
			@MINParam(key = "limit", defaultValue = "10") int limit,
			@MINParam(key = "equNum") String equNum,
			@MINParam(key = "datesTime") String datesTime,

			MINSession session) throws Exception {
		MINActionResult res = new MINActionResult();
		User user = session.getUser();
		String branchId = user.getBranchId();
		MINRowBounds rows = new MINRowBounds(page, limit);
		//获取当前时间
 		Date currentTime = new Date();
		String nowDate = DateUtil.format(currentTime,"yyyyMMdd");
		Map<String, String> m = new HashMap<String, String>();
		m.put("equNum", equNum);
		m.put("datesTime", datesTime);
		m.put("nowDate", nowDate);
		if(!"88888888".equals(branchId)) {
			m.put("branchId", branchId);
		}
		List<Map<String, String>> detailList = Service.lookup(IMINDataBaseService.class)
				.getMybatisMapper(OrderManageMapper.class).selectIncomeDetail(rows, m);

		detailList = Service.lookup(IFormatService.class).formatDate(detailList, "sellTime");
		detailList = Service.lookup(IFormatService.class).formatCurrency(detailList, "sellWxSum", "sellZfSum", "" +
				"sellMfSum", "allSell");
		//返回数据
		res.set(IMINBusinessConstant.F_PAGING_LAY, detailList);
		res.set(IMINBusinessConstant.F_PAGING_COUNT, rows.getCount());
		return res;
	}

	/**
	 * 取货记录
	 * @param machineNo
	 * @param orderNo
	 * @param pickUpDates
	 * @param page
	 * @param limit
	 * @param session
	 * @return
	 * @throws Exception
	 */
	@MINAction(value = SELECT_PICKUP_RECORD)
	public MINActionResult selectPickupRecord (
			@MINParam(key = "machineNo") String machineNo,
			@MINParam(key = "orderNo") String orderNo,
			@MINParam(key = "pickUpDates") String pickUpDates,
			@MINParam(key = "equrelId") String equrelId,
			@MINParam(key = "vciId") String vciId,
			@MINParam(key = "pickupNo") String pickupNo,
			@MINParam(key = "page", defaultValue = "1") int page,
			@MINParam(key = "limit", defaultValue = "3") int limit,
			MINSession session) throws Exception {
		MINActionResult res = new MINActionResult();
		User user = session.getUser();
		String branchId = user.getBranchId();
		Map<String, String> m = new HashMap<String, String>();
		m.put("machineNo", machineNo);
		m.put("orderNo", orderNo);
		m.put("pickUpDates", pickUpDates);
		m.put("equrelId", equrelId);
		m.put("vciId", vciId);
		m.put("pickupNo", pickupNo);
		m.put("branchId", branchId);
		MINRowBounds rows = new MINRowBounds(page, limit);
		List<Map<String, String>> detailList = Service.lookup(IMINDataBaseService.class)
				.getMybatisMapper(OrderManageMapper.class).selectPickupRecord(m,rows);
		detailList = new MINCopyFormat("{stt:'sttDesc'}").format(detailList);
		detailList = Service.lookup(IFormatService.class).formatEnum(detailList,"{sttDesc:'PICKUP_STT'}");
		//返回数据
		res.set(IMINBusinessConstant.F_PAGING_LAY, detailList);
		res.set(IMINBusinessConstant.F_PAGING_COUNT, rows.getCount());
		return res;
	}

	/**
	 * 查询订单详情
	 * @param machineNo
	 * @param pickUpCode
	 * @param creatdDtes
	 * @param pickUpDates
	 * @param pickUpState
	 * @param page
	 * @param limit
	 * @param session
	 * @return
	 * @throws Exception
	 */
	@MINAction(value = SELECT_ORDER_DETAIL)
	public MINActionResult selectOrderDetail (
			@MINParam(key = "machineNo") String machineNo,
			@MINParam(key = "pickUpCode") String pickUpCode,
			@MINParam(key = "equrelId") String equrelId,
			@MINParam(key = "creatdDtes") String creatdDtes,
			@MINParam(key = "pickUpDates") String pickUpDates,
			@MINParam(key = "pickUpState") String pickUpState,
			@MINParam(key = "page", defaultValue = "1") int page,
			@MINParam(key = "limit", defaultValue = "3") int limit,
			MINSession session) throws Exception {
		MINActionResult res = new MINActionResult();
		User user = session.getUser();
		String branchId = user.getBranchId();
		Map<String, String> m = new HashMap<String, String>();
		m.put("machineNo", machineNo);
		m.put("pickUpCode", pickUpCode);
		m.put("equrelId", equrelId);
		m.put("creatdDtes", creatdDtes);
		m.put("pickUpDates", pickUpDates);
		m.put("pickUpState", pickUpState);
		if(!"88888888".equals(branchId)) {
			m.put("branchId", branchId);
		}
		MINRowBounds rows = new MINRowBounds(page, limit);
		List<Map<String, String>> detailList = Service.lookup(IMINDataBaseService.class)
				.getMybatisMapper(OrderManageMapper.class).selectOrderDetail(m,rows);
		// 格式化数据
		detailList = Service.lookup(IFormatService.class).formatDateTime(detailList, "pickUpTime");
		detailList = Service.lookup(IFormatService.class).formatDateTime(detailList, "createTime");
		detailList = new MINCopyFormat("{stt:'sttDesc'}").format(detailList);
		detailList = Service.lookup(IFormatService.class).formatEnum(detailList,"{sttDesc:'ORDER_PICKUP_STT'}");
		//返回数据
		res.set(IMINBusinessConstant.F_PAGING_LAY, detailList);
		res.set(IMINBusinessConstant.F_PAGING_COUNT, rows.getMaxRows());
		return res;
	}


	/**
	 *卡卷管理、取货、作废
	 * @param orderNo
	 * @param temp	操作0：作废，1：取货
	 * @param session
	 * @return
	 * @throws Exception
	 */
	@MINAction(value = UPDATE_ORDER_STT)
	public MINActionResult updateOrderStt(
			@MINParam ( key = "orderNo")String orderNo,
			@MINParam ( key = "temp")String temp,
			MINSession session) throws Exception{
		MINActionResult res = new MINActionResult();
		User user = session.getUser();
		String info = "";
		//更新订单状态
		VmOrderInf vd = new VmOrderInf();
		vd.setId(orderNo);
		if ("0".equals(temp)) {
			vd.setPickupStt("02");
			info = "废止";
		}else if("1".equals(temp)) {
			vd.setPickupStt("01");
			info = "发货";
		}
		Service.lookup(IMINDataBaseService.class)
				.updateByPrimaryKeySelective(VmOrderInfMapper.class, vd);
		//日志
		String logInfo = user.getName()+"-更新订单状态:" +info+ ",订单号"+orderNo;
		Service.lookup(ILogService.class).logging(session, logInfo);
		return res;
	}

}