package com.taoke.autopay.controller.admin.js2;

import com.google.gson.Gson;
import com.google.gson.GsonBuilder;
import com.google.gson.TypeAdapter;
import com.google.gson.stream.JsonReader;
import com.google.gson.stream.JsonWriter;
import com.taoke.autopay.dao.ClientInfoMapper;
import com.taoke.autopay.entity.ClientAdditionalInfo;
import com.taoke.autopay.entity.ClientInfo;
import com.taoke.autopay.service.ClientAdditionalInfoService;
import com.taoke.autopay.service.ClientInfoService;
import com.taoke.autopay.utils.Constant;
import com.taoke.autopay.utils.TimeUtil;
import com.taoke.autopay.utils.encrypt.AESUtil;
import com.taoke.autopay.vo.admin.AdminOrderClientInfoVO;
import net.sf.json.JSONObject;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import org.yeshi.utils.JsonUtil;
import org.yeshi.utils.StringUtil;

import javax.annotation.Resource;
import java.io.IOException;
import java.util.*;

/**
 * 下单设备管理
 */
@Controller
@RequestMapping("/admin/api/clientinfo/js2")
public class AdminClientInfoJS2Controller {

    @Resource
    private ClientInfoService clientInfoService;

    @Resource
    private ClientAdditionalInfoService clientAdditionalInfoService;

    private final Gson gson = new GsonBuilder().registerTypeAdapter(Date.class, new TypeAdapter<Date>() {
        @Override
        public void write(JsonWriter out, Date value) throws IOException {
            String desc = "";
            if (value != null) {
                // 判断是否是同一天
                desc = TimeUtil.getGernalTime(value.getTime(), "yyyy-MM-dd HH:mm:ss");
                out.value(desc);
            } else {
                out.value("");
            }
        }

        @Override
        public Date read(JsonReader in) throws IOException {
            return new Date();
        }
    }).create();

    @ResponseBody
    @RequestMapping("list")
    public String list(String account, int page,int limit){

        ClientInfoMapper.DaoQuery query=new   ClientInfoMapper.DaoQuery();
        if(!StringUtil.isNullOrEmpty(account)) {
            query.account = account;
        }
        query.start = (long) (page - 1) *limit;
        query.count = limit;
        query.clientType = ClientInfo.CLIENT_TYPE_ORDER;
        query.sortList= Arrays.asList(new String[]{"create_time desc"});
        JSONObject data=new JSONObject();
        List<ClientInfo> list = clientInfoService.list(query);
        Map<Long, ClientAdditionalInfo> map;
        if(!list.isEmpty()){
            List<Long> idList=new ArrayList<>();
            for(ClientInfo info:list){
                idList.add(info.getId());
            }
            map = clientAdditionalInfoService.getClientAdditionalInfoMap(idList);
        } else {
            map = new HashMap<>();
        }
        List<AdminOrderClientInfoVO> results = new ArrayList<>();
        list.forEach(info->{
            ClientAdditionalInfo additionalInfo = map.get(info.getId());
            results.add(AdminOrderClientInfoVO.builder()
                    .client(info)
                    .additionalInfo(additionalInfo)
                    .build());
        });

        data.put("list", gson.toJson(results));
        data.put("count",  clientInfoService.count(query));
        return JsonUtil.loadTrueResult(data);
    }


    @ResponseBody
    @RequestMapping("setpwd")
    public String setPwd(Long id, String pwd) {
        if(id==null||pwd==null||pwd.length()<6){
            return JsonUtil.loadFalseResult("数据不完整");
        }
        clientInfoService.setPwd(id,StringUtil.Md5( pwd));
        return JsonUtil.loadTrueResult("");
    }

    @ResponseBody
    @RequestMapping("add")
    public String addClient(String pwd, int count) {
        if(count>100){
            return JsonUtil.loadFalseResult("单次创建最多100个");
        }
        for(int i=0;i<count;i++){
              ClientInfo info=ClientInfo.builder()
                      .pwd(StringUtil.Md5(pwd))
                      .clientType(ClientInfo.CLIENT_TYPE_ORDER)
                      .build();
              clientInfoService.add(info);
              if(info!=null){
                  clientAdditionalInfoService.addClientAdditionalInfo(ClientAdditionalInfo.builder()
                                  .id(info.getId())
                                  .createTime(new Date())
                          .build());
              }
        }
        return JsonUtil.loadTrueResult("");
    }

    @ResponseBody
    @RequestMapping("update")
    public String updateClientInfo(ClientAdditionalInfo info) {
        if(info==null||info.getId()==null) {
            return JsonUtil.loadFalseResult("数据不完整");
        }
        if(!StringUtil.isNullOrEmpty(info.getAlipayPassword())){
            info.setAlipayPassword(AESUtil.encrypt(info.getAlipayPassword(), Constant.AES_KEY));
        }else{
            ClientAdditionalInfo old =  clientAdditionalInfoService.getClientAdditionalInfoByClientId(info.getId());
            if(StringUtil.isNullOrEmpty(old.getAlipayPassword())){
                return JsonUtil.loadFalseResult("尚未设置支付宝密码");
            }
        }
        clientAdditionalInfoService.updateClientAdditionalInfo(info);
        return JsonUtil.loadTrueResult("");
    }

    @ResponseBody
    @RequestMapping("getAdditionalInfo")
    public String getAdditionalInfo(Long id) {
        if(id==null) {
            return JsonUtil.loadFalseResult("数据不完整");
        }
        ClientAdditionalInfo additionalInfo =  clientAdditionalInfoService.getClientAdditionalInfoByClientId(id);
        additionalInfo.setAlipayPassword("");
        return JsonUtil.loadTrueResult(gson.toJson(additionalInfo));
    }

}