zhcy-api/eladmin-system/src/main/java/me/zhengjie/modules/thirdparty/v1/OpenApiController.java

package me.zhengjie.modules.thirdparty.v1;

import com.alibaba.fastjson.JSONObject;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.RequiredArgsConstructor;
import me.zhengjie.annotation.AnonymousAccess;
import me.zhengjie.annotation.Log;
import me.zhengjie.annotation.rest.AnonymousGetMapping;
import me.zhengjie.annotation.rest.AnonymousPostMapping;
import me.zhengjie.base.BaseResponse;
import me.zhengjie.base.QueryPageParams;
import me.zhengjie.config.rabbitmq.test.SendTemplate;
import me.zhengjie.domain.LocalStorage;
import me.zhengjie.exception.BadRequestException;
import me.zhengjie.modules.dm.daypc.domain.DmDayPc;
import me.zhengjie.modules.dm.daypc.service.DmDayPcService;
import me.zhengjie.modules.dm.daypc.service.dto.DmDayPcQueryCriteria;
import me.zhengjie.modules.dm.foodCate.repository.DmFoodCateRepository;
import me.zhengjie.modules.dm.foodPj.domain.DmFoodPj;
import me.zhengjie.modules.dm.foodPj.service.DmFoodPjService;
import me.zhengjie.modules.dm.order.domain.DmOrderItem;
import me.zhengjie.modules.dm.order.domain.DmOrderRecord;
import me.zhengjie.modules.dm.order.repository.DmOrderItemRepository;
import me.zhengjie.modules.dm.order.repository.DmOrderRecordRepository;
import me.zhengjie.modules.dm.service.domain.DmServicePj;
import me.zhengjie.modules.dm.service.repository.DmServicePjRepository;
import me.zhengjie.modules.dm.service.service.DmServicePjService;
import me.zhengjie.modules.dmApp.domain.AppFoodPj;
import me.zhengjie.modules.dmApp.service.AppFoodPjService;
import me.zhengjie.modules.dmApp.service.dto.AppFoodPjDto;
import me.zhengjie.service.LocalStorageService;
import me.zhengjie.utils.FileUtil;
import me.zhengjie.utils.SecurityUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Pageable;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;

import java.math.BigDecimal;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

@RestController
@RequiredArgsConstructor
@Api(tags = "用户接口")
@RequestMapping("/api/thirdparty/v1/open")
public class OpenApiController {
    private final DmDayPcService dmDayPcService;
    private final DmServicePjService dmServicePjService;
    private final AppFoodPjService appFoodPjService;
    private final DmFoodPjService dmFoodPjService;
    private final LocalStorageService localStorageService;
    private final DmOrderRecordRepository dmOrderRecordRepository;
    private final DmOrderItemRepository orderItemRepository;
    private final DmFoodCateRepository dmFoodCateRepository;
    private final DmServicePjRepository dmServicePjRepository;

    @Log("获取今日菜品-App")
    @ApiOperation("获取今日菜品-App")
    @AnonymousPostMapping(value = "/foodRepository")
    public BaseResponse<Object> foodRepository(@RequestBody QueryPageParams<DmDayPcQueryCriteria> criteria){
        SecurityUtils.CheckApiAuth(criteria);
//        dmDayPcService.foodRepository();
        return new BaseResponse<>(dmFoodCateRepository.foodApp());
    }

    @AnonymousPostMapping(value = "/createApp")
    @Log("新增服务评价")
    @ApiOperation("新增服务评价")
    public BaseResponse<Object> createApp(@RequestBody QueryPageParams<DmServicePj> resources){
        SecurityUtils.CheckApiAuth(resources);
        int count = dmServicePjService.servicePjApp(resources.getQuery().getUserCode());
        if (count >= 1){
            throw new BadRequestException("该用户已评价，今日不可评价！");
        }else {
            dmServicePjService.createApp(resources.getQuery());
        }
        return new BaseResponse<>(count);
    }

    @AnonymousPostMapping(value = "/appFoodPj")
    @Log("App菜品评价")
    @ApiOperation("App菜品评价")
    public BaseResponse<Object> appFoodPj(@RequestBody QueryPageParams<String> cardid) {
        SecurityUtils.CheckApiAuth(cardid);
        List<AppFoodPj> list = appFoodPjService.selectAppFoodPj(cardid.getQuery());
        return new BaseResponse<>(list);
    }

    @AnonymousPostMapping(value = "/createFoodPj")
    @Log("新增菜品评价")
    @ApiOperation("新增菜品评价")
    public BaseResponse<Object> createFoodPj(@RequestBody QueryPageParams<DmFoodPj> resources){
        SecurityUtils.CheckApiAuth(resources);
        return new BaseResponse<>(dmFoodPjService.createApp(resources.getQuery()));
    }

    @AnonymousPostMapping(value = "/pictures")
    @Log("上传图片")
    @ApiOperation("上传图片")
    public BaseResponse<Object> upload(@RequestParam String timestamp, @RequestParam String nonce, @RequestParam String name, @RequestParam("file") MultipartFile file){
        QueryPageParams params = new QueryPageParams();
        params.setNonce(nonce);
        params.setTimestamp(timestamp);
        SecurityUtils.CheckApiAuth(params);
        // 判断文件是否为图片
        String suffix = FileUtil.getExtensionName(file.getOriginalFilename());
        if(!FileUtil.IMAGE.equals(FileUtil.getFileType(suffix))){
            throw new BadRequestException("只能上传图片");
        }
        LocalStorage localStorage = localStorageService.create(name, file);
        return new BaseResponse<>(localStorage);
    }

    @AnonymousAccess
    @GetMapping(value = "/countOrderAmt")
    @Log("pc端运营食堂营业额")
    @ApiOperation("pc端运营食堂营业额")
    public ResponseEntity<Object> countOrderAmt(){
        return new ResponseEntity<>(dmOrderRecordRepository.countOrderAmt(),HttpStatus.OK);
    }

    @AnonymousAccess
    @GetMapping(value = "/hyFood")
    @Log("pc端运营最受欢迎菜品")
    @ApiOperation("pc端运营最受欢迎菜品")
    public ResponseEntity<Object> hyFood(){
        return new ResponseEntity<>(orderItemRepository.hyFood(),HttpStatus.OK);
    }

    @AnonymousPostMapping(value = "/countOrderAmtApp")
    @Log("App端运营食堂营业额")
    @ApiOperation("App端运营食堂营业额")
    public BaseResponse<Object> countOrderAmtApp(@RequestBody QueryPageParams<DmOrderRecord> criteria){
        SecurityUtils.CheckApiAuth(criteria);
        return new BaseResponse<>(dmOrderRecordRepository.countOrderAmt());
    }

    @AnonymousPostMapping(value = "/hyFoodApp")
    @Log("App端运营最受欢迎菜品")
    @ApiOperation("App端运营最受欢迎菜品")
    public BaseResponse<Object> hyFoodApp(@RequestBody QueryPageParams<DmOrderItem> criteria){
        SecurityUtils.CheckApiAuth(criteria);
        return new BaseResponse<>(orderItemRepository.hyFood());
    }

    @AnonymousPostMapping(value = "/enableApp")
    @Log("pc端控制整体评价是否可见")
    @ApiOperation("pc端控制整体评价是否可见")
    public BaseResponse<Object> enableApp(@RequestBody QueryPageParams<DmOrderItem> criteria){
        SecurityUtils.CheckApiAuth(criteria);
        return new BaseResponse<>(dmServicePjService.enableApp());
    }

    @AnonymousPostMapping(value = "/findDmServicePjByUserCodeAndPjTime")
    @Log("用户服务评价详情")
    @ApiOperation("用户服务评价详情")
    public BaseResponse<Object> findDmServicePjByUserCodeAndPjTime(@RequestBody QueryPageParams<DmServicePj> criteria){
        SecurityUtils.CheckApiAuth(criteria);
        return new BaseResponse<>(dmServicePjService.getDmServicePjByUserCodeAndPjTime(criteria.getQuery().getUserCode()));
    }

    @AnonymousPostMapping(value = "/AppCountData")
    @Log("统计数据")
    @ApiOperation("App端统计数据")
    public BaseResponse<Object> appCountData(@RequestBody QueryPageParams<String> criteria){
        SecurityUtils.CheckApiAuth(criteria);

        /**
         * 查询今日购餐总额(元)
         */
        BigDecimal bigDecimal =  dmOrderRecordRepository.countOrderAmtByNow();
        /**
         * 查询今日用餐人数(人次)
         */
        Integer person = dmOrderRecordRepository.countOrderPersonByNow();
        /**
         * 查询服务评价
         */
         List<DmServicePj> dmServicePjContentByNow = dmServicePjRepository.getDmServicePjContentByNow();
        /**
         * 统计综合服务评分
         */
        Map<String, Object> dmServicePjByNow = dmServicePjRepository.getDmServicePjByNow();
        dmServicePjByNow.put("dmServicePjContentByNow",dmServicePjContentByNow);
        dmServicePjByNow.put("person",person);
        dmServicePjByNow.put("money",bigDecimal.toString());
        return new BaseResponse<>(dmServicePjByNow);
    }

    @AnonymousPostMapping(value = "/AppDayFoodData")
    @Log("今日菜品清单")
    @ApiOperation("App今日菜品清单")
    public BaseResponse<Object> AppDayFoodData(@RequestBody QueryPageParams<String> criteria){
        SecurityUtils.CheckApiAuth(criteria);

        /**
         * 查询今日菜品清单
         * data { 菜品名称,菜品单价,供应数量 }
         */
         List<Map<String, Object>> maps = dmFoodCateRepository.foodApp();

        /**
         * 声明一个json对象用来存储菜品统计信息
         */
        JSONObject jsonObject = new JSONObject();

        /**
         * 使用forEach之后 里面的变量必须要用原子类
         */
        maps.forEach(item->{
//            item.get("")

         });

        return new BaseResponse<>(maps);
    }


}