package com.iamberry.app.service; import java.util.ArrayList; import java.util.Calendar; import java.util.Date; import java.util.IdentityHashMap; import java.util.LinkedHashMap; import java.util.LinkedList; import java.util.List; import java.util.Map; import org.apache.commons.lang3.math.NumberUtils; import org.springframework.stereotype.Service; import com.iamberry.app.config.Constants; import com.iamberry.app.core.dto.MilkInfoDTO; import com.iamberry.app.core.dto.RecordCountInfoDTO; import com.iamberry.app.core.dto.RecordDTO; import com.iamberry.app.core.entity.MilkImages; import com.iamberry.app.core.entity.MilkMakingRecord; import com.iamberry.app.core.entity.MilkPowderInfo; import com.iamberry.app.core.entity.User; import com.iamberry.app.face.MilkService; import com.iamberry.app.ulitity.Utility; /** * MilkService * * @author Moon Cheng * @date 2016年3月23日 上午11:33:10 */ @Service public class MilkServiceImpl extends BaseService implements MilkService { /** * setMilkMakingRecord * @param makingRecord * @param token * @param recordId * @return */ public MilkMakingRecord setMilkMakingRecord(MilkMakingRecord makingRecord, String token) { User userInfo = validateUserToken(token); if (userInfo == null) { return null; } makingRecord.setUser(userInfo.getId()); makingRecord.setTimestamp_(new Date()); milkMapper.insertMilkMakingRecord(makingRecord); return makingRecord; } /** * searchUserRecordsBytime * * @author Moon Cheng * @param userId * @param startTime * @param endTime * @return Milk Making Record List */ public Map> searchUserRecordsByTime(Long userId, String dateStatus, String chosenDate, String machineMac) { Map> recordInfos = new LinkedHashMap>(); String dateType = null, formatter = null; Calendar calendar = Calendar.getInstance(); if (chosenDate != null) { // calendar.setTime(Utility.formatStringToDate("yyyy-MM-dd // HH:mm:ss", chosenDate)); // 防止无数据时显示分钟错误 chosenDate = chosenDate.substring(0, chosenDate.length() - 6) + ":00:00"; calendar.setTime(Utility.formatStringToDate("yyyy-MM-dd HH:mm:ss", chosenDate)); } else { calendar.setTime(new Date()); } Date start = null, end = null; switch (dateStatus) { case "day": dateType = "days"; formatter = "%Y%m%d%H"; calendar.set(calendar.get(Calendar.YEAR), calendar.get(Calendar.MONDAY), calendar.get(Calendar.DATE), 0, 0, 0); start = calendar.getTime(); calendar.set(calendar.get(Calendar.YEAR), calendar.get(Calendar.MONDAY), calendar.get(Calendar.DATE), 23, 59, 59); end = calendar.getTime(); recordInfos.put("app", Utility.convertMap( milkMapper.selectMilkMakingRecords(start, end, "app", dateType, formatter, userId, machineMac), dateType)); recordInfos.put("machine", Utility.convertMap( milkMapper.selectMachineMilkMakingRecords(start, end, "machine", dateType, formatter, machineMac), dateType)); break; case "week": dateType = "weeks"; formatter = "%Y%m%d"; calendar.set(calendar.get(Calendar.YEAR), calendar.get(Calendar.MONDAY), calendar.get(Calendar.DATE), 0, 0, 0); calendar.set(Calendar.DAY_OF_WEEK, Calendar.MONDAY); start = calendar.getTime(); calendar.set(calendar.get(Calendar.YEAR), calendar.get(Calendar.MONDAY), calendar.get(Calendar.DATE), 23, 59, 59); if (Calendar.SUNDAY < Calendar.MONDAY) { calendar.add(Calendar.DATE, 7); } calendar.set(Calendar.DAY_OF_WEEK, Calendar.SUNDAY); end = calendar.getTime(); recordInfos.put("app", Utility.convertMap( milkMapper.selectMilkMakingRecords(start, end, "app", dateType, formatter, userId, machineMac), dateType)); recordInfos.put("machine", Utility.convertMap( milkMapper.selectMachineMilkMakingRecords(start, end, "machine", dateType, formatter, machineMac), dateType)); break; case "year": dateType = "years"; formatter = "%Y%m"; calendar.set(calendar.get(Calendar.YEAR), 0, 1, 0, 0, 0); start = calendar.getTime(); calendar.set(calendar.get(Calendar.YEAR), 11, 31, 23, 59, 59); end = calendar.getTime(); recordInfos.put("app", Utility.convertMap( milkMapper.selectMilkMakingRecords(start, end, "app", dateType, formatter, userId, machineMac), dateType)); recordInfos.put("machine", Utility.convertMap( milkMapper.selectMachineMilkMakingRecords(start, end, "machine", dateType, formatter, machineMac), dateType)); break; } return Utility.fillAppMachineRecordWithZero(Utility.synAppMachineRecord(recordInfos), dateType, chosenDate); } /** * searchUserRecordById * * @author Moon Cheng * @param recordId * @return Milk Making Record Information */ public MilkMakingRecord searchUserRecordById(Long recordId) { MilkMakingRecord makingRecord = milkMapper.selectMilkMakingRecord(recordId); return makingRecord; } /** * 根据用户,获取冲奶记录的-->总量和次数 * * @author Moon Cheng * @param userId * @return */ public RecordCountInfoDTO getTotalMilkVolumeMadeByUser(Long userId) { RecordCountInfoDTO recordcount = milkMapper.getMilkPowderSumByUser(userId); return recordcount; } /** * setMilkPowderInfo * * @author Moon Cheng * @param entity * @param token * @return Milk Powder Information */ public MilkPowderInfo setMilkPowderInfo(MilkPowderInfo entity, String token) { User userInfo = validateUserToken(token); if (userInfo == null) { return null; } // change status as user's phone number entity.setStatus_( userInfo.getUsername().length() > 11 ? Constants.MILK_POWDER_NOT_APPROVED : userInfo.getUsername()); entity.setCreated_on(new Date()); milkMapper.insertMilkPowderInfo(entity); return entity; } /** * searchMilkPowderInfoByBarCode * * @author Moon Cheng * @param barcode * @return Milk Powder Information */ public MilkPowderInfo searchMilkPowderInfoByBarCode(String barcode) { MilkPowderInfo milkPowderInfo = milkMapper.selectMilkPowderInfo(barcode); return milkPowderInfo; } /** * * 通过品牌名获取奶粉信息 * @author Moon Cheng, Yin * @param brand * @return Milk Powder List */ public Map> searchMilkPowderInfosByBrand(String brand) { brand = "%" + brand.trim() + "%"; Map> infos = new IdentityHashMap>(); List milkInfo = milkMapper.selectMilkInfoBybrand(brand); for (int i = 0; i < milkInfo.size(); i++) { List list = new LinkedList(); list.add(milkInfo.get(i).getLevel() + ":" + milkInfo.get(i).getType() + ":" + milkInfo.get(i).getPowder_ratio() + ":" + milkInfo.get(i).getId() + ":" + milkInfo.get(i).getWeight_per_spoon()); infos.put(milkInfo.get(i).getSeries(),list); } return infos; } /** * searchMilkPowderBrand * * @return Brand List */ public List searchMilkPowderBrand() { List milkPowderInfos = milkMapper.selectMilkPowderBrand(); List result = new ArrayList<>(); milkPowderInfos.forEach(milk -> { if (NumberUtils.isNumber(milk) && milk.contains(".")) { milk = milk.substring(0, milk.indexOf(".")); } result.add(milk); }); return result; } /** * searchMilkInfoByBrandSeriesLevel * * @param brand * @param series * @param level * @return */ public MilkPowderInfo searchMilkInfoByBrandSeriesLevel(String brand, String series, String level) { return milkMapper.selectMilkInfoByBrandSeriesLevel(brand, series, level); } // =====================================TuyaHistoryData====================================== /** * getLastRecordDate * * @return */ public Date getLastRecordDate() { Date lastDate = milkMapper.selectLastRecordDate(); return lastDate == null ? new Date() : lastDate; } /** * addRecordData * @param devId * @param value * @param time */ public void addRecordData(String devId, String value, Long time, Long userId) { MilkMakingRecord milkMakingRecord = new MilkMakingRecord(); milkMakingRecord.setVolume(Integer.parseInt(value)); milkMakingRecord.setMachine(devId); milkMakingRecord.setTimestamp_(new Date(time)); milkMakingRecord.setUser(userId); milkMapper.insertRecordData(milkMakingRecord); } @Override public void setMilkImages(MilkImages images) { // TODO Auto-generated method stub milkMapper.insertMilkImages(images); } }