木兰湾是用于管理个人消费、锻炼、音乐、阅读、健康、饮食、人生经历等各个衣食住行信息的系统

package cn.mulanbay.pms.web.controller; import cn.mulanbay.ai.nlp.processor.NLPProcessor; import cn.mulanbay.common.exception.ApplicationException; import cn.mulanbay.common.util.*; import cn.mulanbay.persistent.query.NullType; import cn.mulanbay.persistent.query.PageRequest; import cn.mulanbay.persistent.query.PageResult; import cn.mulanbay.persistent.query.Sort; import cn.mulanbay.pms.common.ConfigKey; import cn.mulanbay.pms.common.PmsErrorCode; import cn.mulanbay.pms.handler.BudgetHandler; import cn.mulanbay.pms.handler.ConsumeHandler; import cn.mulanbay.pms.handler.SystemConfigHandler; import cn.mulanbay.pms.handler.bean.BuyRecordMatchBean; import cn.mulanbay.pms.persistent.domain.*; import cn.mulanbay.pms.persistent.dto.*; import cn.mulanbay.pms.persistent.enums.*; import cn.mulanbay.pms.persistent.service.*; import cn.mulanbay.pms.util.ChartUtil; import cn.mulanbay.pms.util.TreeBeanUtil; import cn.mulanbay.pms.web.bean.request.CommonBeanDeleteRequest; import cn.mulanbay.pms.web.bean.request.CommonBeanGetRequest; import cn.mulanbay.pms.web.bean.request.GroupType; import cn.mulanbay.pms.web.bean.request.buy.*; import cn.mulanbay.pms.web.bean.response.TreeBean; import cn.mulanbay.pms.web.bean.response.buy.BuyRecordCostStatVo; import cn.mulanbay.pms.web.bean.response.buy.ChartRadarGroupVo; import cn.mulanbay.pms.web.bean.response.chart.*; import cn.mulanbay.web.bean.response.ResultBean; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; import org.springframework.web.bind.annotation.RestController; import javax.validation.Valid; import java.math.BigDecimal; import java.util.*; /** * 购买记录 * * @author fenghong * @create 2017-07-10 21:44 */ @RestController @RequestMapping("/buyRecord") public class BuyRecordController extends BaseController { private static final Logger logger = LoggerFactory.getLogger(BuyRecordController.class); private static Class<BuyRecord> beanClass = BuyRecord.class; @Autowired BuyRecordService buyRecordService; @Autowired LifeExperienceService lifeExperienceService; @Autowired AuthService authService; @Autowired BudgetHandler budgetHandler; @Autowired IncomeService incomeService; @Autowired NLPProcessor nlpProcessor; @Autowired ConsumeHandler consumeHandler; @Autowired SystemConfigHandler systemConfigHandler; @Autowired DataService dataService; // # 购买记录统计中是否启用商品类型里的可统计字段 @Value("${system.buyRecord.stat.useStatable}") boolean useStatable; /** * 关键字列表 * * @return */ @RequestMapping(value = "/getKeywordsTree") public ResultBean getKeywordsTree(BuyRecordKeywordsSearch sf) { List<TreeBean> list = new ArrayList<TreeBean>(); if(sf.getStartDate()==null&&sf.getEndDate()==null){ Date[] range = this.getTagsDateRange(); sf.setStartDate(range[0]); sf.setEndDate(range[1]); } List<String> keywordsList = buyRecordService.getKeywordsList(sf); //去重 Set<String> keywordsSet = TreeBeanUtil.deleteDuplicate(keywordsList); for (String s : keywordsSet) { TreeBean tb = new TreeBean(); tb.setId(s); tb.setText(s); list.add(tb); } return callback(TreeBeanUtil.addRoot(list, sf.getNeedRoot())); } /** * 获取标签的时间段 * @return */ private Date[] getTagsDateRange(){ Date[] ds = systemConfigHandler.getDateRange(null,"buyRecord.tags.days"); return ds; } /** * 获取列表数据 * * @return */ @RequestMapping(value = "/getData", method = RequestMethod.GET) public ResultBean getData(BuyRecordSearch sf) { PageRequest pr = sf.buildQuery(); if (StringUtil.isEmpty(sf.getSortField())) { Sort s = new Sort("buyDate", Sort.DESC); pr.addSort(s); } else { Sort s = new Sort(sf.getSortField(), sf.getSortType()); pr.addSort(s); } pr.setBeanClass(beanClass); PageResult<BuyRecord> qr = baseService.getBeanResult(pr); return callbackDataGrid(qr); } /** * 总的概要统计 * 这里的出售已经不准了，因为售出的时间应该用deleteDate查询了 * * @return */ @RequestMapping(value = "/stat", method = RequestMethod.GET) public ResultBean stat(BuyRecordSearch sf) { sf.setMoneyFlow(MoneyFlow.BUY); BuyRecordStat buyData = buyRecordService.getBuyRecordStat(sf); sf.setMoneyFlow(MoneyFlow.SALE); BuyRecordStat saleData = buyRecordService.getBuyRecordStat(sf); List<BuyRecordStat> list = new ArrayList<>(); list.add(buyData); list.add(saleData); return callback(list); } /** * 统计消费金额，包含看病费用 * * @return */ @RequestMapping(value = "/statWithTreat", method = RequestMethod.GET) public ResultBean statWithTreat(BuyRecordAnalyseStatSearch sf) { sf.setType(GroupType.TOTALPRICE); sf.setGroupField("goods_type_id"); List<BuyRecordRealTimeStat> list = buyRecordService.getAnalyseStat(sf); return callback(this.createAnalyseStatPieData(list, sf)); } /** * 创建 * * @return */ @RequestMapping(value = "/create", method = RequestMethod.POST) public ResultBean create(@RequestBody @Valid BuyRecordFormRequest formRequest) { BuyRecord buyRecord = new BuyRecord(); changeFormToBean(formRequest, buyRecord); buyRecord.setCreatedTime(new Date()); buyRecordService.saveBuyRecord(buyRecord); updateIncome(buyRecord); consumeHandler.addToCache(buyRecord); return callback(buyRecord); } /** * 转换 * @param formRequest * @param buyRecord */ private void changeFormToBean(BuyRecordFormRequest formRequest, BuyRecord buyRecord) { BeanCopy.copyProperties(formRequest, buyRecord, true); buyRecord.setTotalPrice(buyRecord.getPrice() * buyRecord.getAmount() + buyRecord.getShipment()); //不判断会导致保存异常。当不选择商品子类型时，spring mvc会初始化一个空的GoodsType对象（id=null） if (formRequest.getSubGoodsTypeId() != null) { GoodsType subGoodsType = this.getUserEntity(GoodsType.class, formRequest.getSubGoodsTypeId(), formRequest.getUserId()); buyRecord.setSubGoodsType(subGoodsType); } else { buyRecord.setSubGoodsType(null); } BuyType buyType = this.getUserEntity(BuyType.class, formRequest.getBuyTypeId(), formRequest.getUserId()); buyRecord.setBuyType(buyType); GoodsType goodsType = this.getUserEntity(GoodsType.class, formRequest.getGoodsTypeId(), formRequest.getUserId()); buyRecord.setGoodsType(goodsType); //消费日期默认为购买日期 if (buyRecord.getConsumeDate() == null) { buyRecord.setConsumeDate(buyRecord.getBuyDate()); } //设置总价 BigDecimal totalPrice = new BigDecimal(0); totalPrice = totalPrice.add(new BigDecimal(formRequest.getPrice()).multiply(new BigDecimal(formRequest.getAmount()))); totalPrice = totalPrice.add(new BigDecimal(formRequest.getShipment())); buyRecord.setTotalPrice(totalPrice.doubleValue()); //设置使用时长 if(buyRecord.getDeleteDate()!=null){ long usedTime = buyRecord.getDeleteDate().getTime()-buyRecord.getBuyDate().getTime();