thmodel/src/main/java/com/thmodel/service/impl/ModelInfoServiceImpl.java

package com.thmodel.service.impl;

import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import com.thmodel.constants.Constants;
import com.thmodel.constants.Recursion;
import com.thmodel.dao.DataTypeInfoDao;
import com.thmodel.dao.MemberinfoDao;
import com.thmodel.dao.ModelInfoDao;
import com.thmodel.dao.impl.DataTypeInfoDaoImpl;
import com.thmodel.dao.impl.MemberinfoDaoImpl;
import com.thmodel.dao.impl.ModelInfoDaoImpl;
import com.thmodel.dbconnection.DbConnection;
import com.thmodel.entity.ChatRecord;
import com.thmodel.entity.HonorInfo;
import com.thmodel.entity.ModelAct;
import com.thmodel.entity.ModelInfo;
import com.thmodel.entity.ModelPhoto;
import com.thmodel.entity.ModelPrice;
import com.thmodel.entity.ModelPrivate;
import com.thmodel.entity.ModelPrivateDiscuss;
import com.thmodel.entity.ModelPrivateItem;
import com.thmodel.entity.ReportInfo;
import com.thmodel.nimserver.Nimserver;
import com.thmodel.service.ModelInfoService;
import com.thmodel.util.CommentUtils;
import com.thmodel.util.MyDateUtil;

import net.sf.json.JSONArray;
import net.sf.json.JSONObject;

import com.thmodel.page.Page;
import org.jooq.DSLContext;
import org.jooq.Record;
import org.jooq.Result;
import org.jooq.impl.DSL;

import static com.thmodel.jooq.Tables.MODELFAN;

public class ModelInfoServiceImpl implements ModelInfoService {

    private static ModelInfoDao modelinfodao = new ModelInfoDaoImpl();

    private static MemberinfoDao memberinfoDao = new MemberinfoDaoImpl();

    private static DataTypeInfoDao dataTypeInfoDao = new DataTypeInfoDaoImpl();

    private static NimserverServiceImpl nimserverService = new NimserverServiceImpl();

    @Override
    public Map<String, Object> dogetmodel(int memberpk, String area, int index, int size) {

        return modelinfodao.getmodel(memberpk, area, index, size);

    }

    @Override
    public Map<String, Object> getmodelfan(int pk, int index, int size) {

        if (pk > 0) {
            return modelinfodao.getmodelfan(pk, index, size);
        } else {
            Map<String, Object> map = new HashMap<>();
            map.put("data", new ArrayList<>());
            map.put("count", 0);
            return map;
        }

    }

    @Override
    public Map<String, Object> getmodelstar(int memberpk, int star, int index, int size) {
        if (star >= 0) {
            return modelinfodao.modelstar(memberpk, star, index, size);
        } else {
            return null;
        }
    }

    @Override
    public List<ModelAct> geart(int ModelPK) {
        if (ModelPK > 0) {
            return modelinfodao.getModelActListByModelPK(ModelPK);
        } else {
            return null;
        }
    }

    @Override
    public List<Map<String, Object>> getfan(int ModelPK) {
        if (ModelPK > 0) {
            return modelinfodao.getfan(ModelPK);
        } else {
            return null;
        }
    }

    @Override
    public List<ModelPrice> getprice(int ModelPK) {
        if (ModelPK > 0) {
            return modelinfodao.getprice(ModelPK);
        } else {
            return null;

        }
    }

    @Override
    public List<ChatRecord> getchat(int ModelPK, Integer PK) {

        if (ModelPK > 0) {
            return modelinfodao.findChatRecordByModelPkAndMemberPK(ModelPK, PK);
        } else {
            return null;
        }

    }

    @Override
    public boolean putchat(String CDate, String ModelPK, String MemberPK, String chat, String CType) {
        int pk = modelinfodao.insertChatRecord(CDate, ModelPK, MemberPK, chat, CType);
        if (pk > 0) {
            return true;
        } else {
            return false;
        }
    }

    @Override
    public List<HonorInfo> getHonor(int ModelPK) {
        if (ModelPK > 0) {
            List<HonorInfo> list = modelinfodao.findHonorInfoByModelPk(ModelPK);
            return list;
        } else {
            return null;
        }
    }

    @Override
    public List<String> getHonorName(int ModelPK) {
        List<String> resultList = new ArrayList<String>();
        if (ModelPK > 0) {
            List<HonorInfo> list = modelinfodao.findHonorInfoByModelPk(ModelPK);
            for (HonorInfo honorInfo : list) {
                resultList.add(honorInfo.getHonor());
            }
            return resultList;
        } else {
            return null;
        }
    }

    @Override
    public boolean addHonor(int ModelPK, String Honors) {
        boolean flag = false;
        if (ModelPK > 0 && CommentUtils.isNull(Honors)) {

            //解析Honors
            //格式		"[{\"honor\":\"这是我的荣誉我\"}, {\"honor\":\"这是我的荣誉\"}, {\"honor\": \"honor3\"}]"
            List<String> honorList = new ArrayList<String>();
            JSONArray JsonArr = JSONArray.fromObject(Honors);
            JSONObject tmpJson;
            for (int i = 0; i < JsonArr.size(); i++) {
                tmpJson = (JSONObject) JsonArr.get(i);
                String value = tmpJson.getString("honor");
                if (value != null && !value.equals("")) {
                    honorList.add(value);
                }
            }

            if (honorList.size() > 0) {

                //删除这个模特的所有荣誉
                modelinfodao.deleteHonorInfo(ModelPK);

                int pk = modelinfodao.insertHonorInfo(ModelPK, honorList);
                if (pk > 0) {
                    flag = true;
                }
            }
        }
        return flag;
    }

    @Override
    public Map<String, Object> getBroke(int BrokePK) {
        if (BrokePK > 0) {
            Map<String, Object> resultMap = modelinfodao.findBrokeInforByPk(BrokePK);// 查询经纪人信息
            return resultMap;
        } else {
            return null;
        }
    }

    @Override
    public Map<String, Object> qryBroke(String LikeName, int index, int size) {

        return modelinfodao.findBrokeInforLikeName(LikeName, index, size);

    }

    @Override
    public boolean appBroke(int ModelPK, int BrokePK, int MemberPK) {
        boolean flag = false;
        if (ModelPK > 0 && BrokePK > 0 && MemberPK > 0) {
            int rows = modelinfodao.updateModelInfoSetBrokeByPk(ModelPK, BrokePK, MemberPK);
            if (rows > 0) {
                flag = true;
            }
        }
        return flag;
    }

    @Override
    public Map<String, Object> qryModel(int memberpk, int brokePk, int index, int size) {
        if (brokePk > 0) {
            return modelinfodao.findModelByBrokePk(memberpk, brokePk, index, size);
        } else {
            return null;
        }
    }

    @Override
    public Map<String, Object> getQueryModel(int memberpk, String likeName, int index, int size, String area) {
        return modelinfodao.findModelInfoByName(memberpk, likeName, index, size, area);
    }

    @Override
    public Page<List<Map<String, Object>>> getPrivate(int modelPk, int memberpk, int index, int size) {

        Page<List<Map<String, Object>>> resultPage = new Page<List<Map<String, Object>>>();

        //data
        List<Map<String, Object>> resultMapList = new ArrayList<Map<String, Object>>();
        if (modelPk > 0) {
            Page<List<ModelPrivate>> page = modelinfodao.findModelPrivateByModelPk(modelPk, memberpk, index, size);
            int count = page.getCount();

            List<ModelPrivate> privateList = page.getData();// 空间动态

            List<ModelPrivateItem> privateItemList = null;// 空间明细（图片）
            List<ModelPrivateDiscuss> privateInfoList = null;// 点赞列表
            List<ModelPrivateDiscuss> privateDiscussList = null;// 空间评论

            Date pdatePrev = null;// 记录上一个的时间

            if (index > 1) {
                //不是第一页
                int prev_index = index - 1;

                StringBuffer sql = new StringBuffer();
                sql.append("select * from (");
                sql.append("	select * from (");
                sql.append("		select pdate from modelprivate where modelpk = 2 order by pdate desc");
                sql.append("	)t0_  limit " + ((prev_index - 1) * size) + ", " + size);
                sql.append(")t1_ order by pdate limit 1");

                pdatePrev = new DbConnection().queryOneDate(sql.toString());

            }
            for (ModelPrivate modelPrivate : privateList) {
                int privatePk = modelPrivate.getPk();
                privateItemList = modelinfodao.findModelPrivateItemByPrivatePk(privatePk);

                privateInfoList = modelinfodao.getPraiseByPrivatePk(privatePk);

                privateDiscussList = modelinfodao.findModelPrivateDiscussByPrivatePk(privatePk);

                Map<String, Object> resultMap = new HashMap<String, Object>();
                resultMap.put("privatepk", privatePk);
                resultMap.put("islikes", modelPrivate.getIslikes());
                resultMap.put("pdate", MyDateUtil.format(modelPrivate.getPdate(), MyDateUtil.DATE_FORMAT_1));
                resultMap.put("intro", modelPrivate.getIntro());

                // 判断是否跟上一个相同
                boolean isDay = MyDateUtil.isSameDay(pdatePrev, modelPrivate.getPdate());
                pdatePrev = modelPrivate.getPdate();
                resultMap.put("isditto", isDay ? 1 : 0);

                List<Map<String, Object>> result_iteminfoList = new ArrayList<Map<String, Object>>();
                for (ModelPrivateItem mpi : privateItemList) {
                    Map<String, Object> map = new HashMap<String, Object>();
                    map.put("iteminfopk", mpi.getPk());
                    map.put("url", mpi.getUrl());
                    map.put("ftype", mpi.getFtype());
                    result_iteminfoList.add(map);
                }

                List<Map<String, Object>> result_privateInfoList = new ArrayList<Map<String, Object>>();
                for (ModelPrivateDiscuss mpd : privateInfoList) {
                    Map<String, Object> map = new HashMap<String, Object>();
                    map.put("memberpk", mpd.getMemberpk());
                    map.put("idate", MyDateUtil.format(mpd.getIdate(), MyDateUtil.DATE_FORMAT_1));
                    result_privateInfoList.add(map);
                }

                List<Map<String, Object>> result_recordInfoList = Recursion.getRecordInfo(privateDiscussList);

                resultMap.put("iteminfo", result_iteminfoList);
                resultMap.put("privateinfo", result_privateInfoList);
                resultMap.put("recordinfo", result_recordInfoList);

                resultMapList.add(resultMap);
            }
            resultPage.setData(resultMapList);
            resultPage.setCount(count);
            return resultPage;
        } else {
            return null;
        }
    }

    @Override
    public int addPrivate(int modelPk, String intro) {
        int pk = 0;
        if (modelPk > 0) {
            pk = modelinfodao.insertModelPrivate(modelPk, intro);
        }
        return pk;
    }

    @Override
    public boolean addPrivateItem(int privatePk, String url, String fType) {
        boolean flag = false;
        if (privatePk > 0) {
            int pk = modelinfodao.insertModelPrivateItem(privatePk, url, fType);
            if (pk > 0) {
                flag = true;
            }
        }
        return flag;
    }

    @Override
    public boolean praisePrivate(int privatePk, int memberPk) {
        boolean flag = false;
        if (privatePk > 0 && memberPk > 0) {

            //判断是否点赞
            // 先判断有没有点赞 false 没有点赞
            boolean isLikes = modelinfodao.findLikes(memberPk, privatePk);
            if (!isLikes) {
                int pk = modelinfodao.praisePrivate(privatePk, memberPk);
                if (pk > 0) {
                    flag = true;
                }
            } else {
                flag = true;
            }
        }
        return flag;
    }

    @Override
    public boolean addPrivateRecord(int privatePk, int memberPk, int RecordInfoPK, String intro) {
        boolean flag = false;
        if (privatePk > 0 && memberPk > 0) {
            int pk = modelinfodao.insertModelPrivateDiscuss(privatePk, memberPk, RecordInfoPK, intro);
            if (pk > 0) {
                flag = true;
            }
        }
        return flag;
    }

    @Override
    public Map<String, Object> getModelFigure(int modelPk) {
        Map<String, Object> resultMap = new HashMap<String, Object>();
        if (modelPk > 0) {

            // 获取自评
            List<Map<String, Object>> selfFigureList = modelinfodao.findSelfFigure(modelPk);

            // 获取用户印象
            List<Map<String, Object>> customImageList = modelinfodao.findCustomImage(modelPk);

            // 用户评价（不是自评就是用户评价）
            List<Map<String, Object>> customFigureList = modelinfodao.findCustomFigure(modelPk);

            resultMap.put("selffigure", selfFigureList);
            resultMap.put("customimage", customImageList);
            resultMap.put("customfigure", customFigureList);
        }
        return resultMap;
    }

    @Override
    public List<Map<String, Object>> getFigures() {
        return dataTypeInfoDao.findDataTypeInfoByTypeName(Constants.data_type_4);// 形象标签
    }

    @Override
    public Map<String, Object> queryFigureModel(int memberpk, String figurePks, int index, int size) {
        if (figurePks.length() > 0) {
            // 如果首字母是逗号，去除
            figurePks = figurePks.substring(0, 1).equals(",") ? figurePks.substring(1, figurePks.length()) : figurePks;
            // 如果最后一个字母是逗号，去除
            figurePks = figurePks.substring(figurePks.length() - 1, figurePks.length()).equals(",")
                    ? figurePks.substring(0, figurePks.length() - 1)
                    : figurePks;

            return modelinfodao.findModelByFigurePks(memberpk, figurePks, index, size);
        } else {
            return null;
        }

    }

    @Override
    public List<Map<String, Object>> queryMyFigure(int memberPk, int modelPk) {

        if (memberPk > 0 && modelPk > 0) {
            return modelinfodao.findModelFigureByModelPkAndMemberPk(memberPk, modelPk);
        } else {
            return null;
        }

    }

    @Override
    public boolean setModelFigure(int memberPk, int modelPk, String figurePks, int isSelf) {
        boolean flag = false;
        if (memberPk > 0 && modelPk > 0 && figurePks.length() > 0 && (isSelf == 0 || isSelf == 1)) {
            // 如果首字母是逗号，去除
            figurePks = figurePks.substring(0, 1).equals(",") ? figurePks.substring(1, figurePks.length()) : figurePks;
            // 如果最后一个字母是逗号，去除
            figurePks = figurePks.substring(figurePks.length() - 1, figurePks.length()).equals(",")
                    ? figurePks.substring(0, figurePks.length() - 1)
                    : figurePks;
            int rows = modelinfodao.insertModelFigure(memberPk, modelPk, figurePks, isSelf);
            if (rows > 0) {
                flag = true;
            }
        }
        return flag;
    }

    @Override
    public Map<String, Object> modelInfoByPk(int memberpk, int modelPk) {
        if (modelPk > 0) {
            return modelinfodao.findModelInfoByPk(memberpk, modelPk);
        } else {
            return null;
        }

    }

    @Override
    public Map<String, Object> queryPrivateRecord(int privatePk) {
        Map<String, Object> resultMap = new HashMap<String, Object>();
        if (privatePk > 0) {

            List<ModelPrivateDiscuss> privateInfoList = modelinfodao.getPraiseByPrivatePk(privatePk);// 点赞列表
            List<ModelPrivateDiscuss> privateDiscussList = modelinfodao.findModelPrivateDiscussByPrivatePk(privatePk);// 评论列表

            List<Map<String, Object>> privateInfoMapList = new ArrayList<Map<String, Object>>();
            List<Map<String, Object>> recordInfoMapList = Recursion.getRecordInfo(privateDiscussList);

            for (ModelPrivateDiscuss mpd : privateInfoList) {
                Map<String, Object> map = new HashMap<String, Object>();
                map.put("memberpk", mpd.getMemberpk());
                map.put("idate", MyDateUtil.format(mpd.getIdate(), MyDateUtil.DATE_FORMAT_1));
                privateInfoMapList.add(map);
            }
            resultMap.put("privateinfo", privateInfoMapList);
            resultMap.put("recordinfo", recordInfoMapList);
            return resultMap;
        } else {
            return null;
        }

    }

    @Override
    public List<Map<String, Object>> querySkillFigure() {
        List<Map<String, Object>> list = dataTypeInfoDao.findDataTypeInfoByTypeName(Constants.data_type_5);// "技能标签"
        return list;
    }

    @Override
    public Map<String, Object> querySkillModel(int memberpk, String skillPks, int index, int size, String area) {
        if (skillPks.length() > 0) {
            // 如果首字母是逗号，去除
            skillPks = skillPks.substring(0, 1).equals(",") ? skillPks.substring(1, skillPks.length()) : skillPks;
            // 如果最后一个字母是逗号，去除
            skillPks = skillPks.substring(skillPks.length() - 1, skillPks.length()).equals(",")
                    ? skillPks.substring(0, skillPks.length() - 1)
                    : skillPks;

            return modelinfodao.findDataTypeInfoByPkOrTypeName(memberpk, skillPks, Constants.data_type_5, area, index, size);
        } else {
            return null;
        }
    }

    @Override
    public Page<List<Map<String, Object>>> findModelPrivateLimit(int privatePk, int index, int size) {
        if (privatePk > 0) {
            return modelinfodao.findModelPrivateLimit(privatePk, index, size);
        } else {
            return null;
        }
    }

    @Override
    public Page<List> findmodel(int memberPk, int index, int size) {

        if (memberPk >= 0) {
            return modelinfodao.findModelInfoAndPhotoInfoList(memberPk, index, size);
        } else {
            Page<List> page = new Page<>();
            page.setCount(0);
            page.setData(new ArrayList());
            return page;
        }

    }

    @Override
    public boolean likes(int memberPk, int privatePk, int type) {
        boolean flag = false;

        // type 1点赞/2取消点赞
        if (type == 1) {
            // 先判断有没有点赞 false 没有点赞
            boolean isLikes = modelinfodao.findLikes(memberPk, privatePk);
            if (!isLikes) {
                int pk = modelinfodao.praisePrivate(privatePk, memberPk);
                if (pk > 0) {
                    flag = true;
                }
            } else {
                flag = true;
            }

        } else if (type == 2) {
            // 先判断有没有点赞 true 已经点赞
            boolean isLikes = modelinfodao.findLikes(memberPk, privatePk);
            if (isLikes) {
                int rows = modelinfodao.notPraisePrivate(privatePk, memberPk);
                if (rows > 0) {
                    flag = true;
                }
            } else {
                // 没有点赞 但也给返回成功
                flag = true;
            }
        }
        return flag;
    }

    @Override
    public boolean attention(int memberPk, int modelPk, int type) {
        boolean flag = false;

        // type 1关注/2取消关注
        if (type == 1) {
            // 先判断有没有关注 false 没有关注
            boolean isLikes = modelinfodao.findAttention(memberPk, modelPk);
            if (!isLikes) {
                int pk = modelinfodao.insertModelFan(memberPk, modelPk);
                modelinfodao.updateModelFanSetFCount(modelPk);
                if (pk > 0) {
                    flag = true;
                }
            } else {
                flag = true;
            }

        } else if (type == 2) {
            // 先判断有没有关注 true 已经关注
            boolean isLikes = modelinfodao.findAttention(memberPk, modelPk);
            if (isLikes) {
                int rows = modelinfodao.deleteModelFan(memberPk, modelPk);
                modelinfodao.updateModelFanSetFCount(modelPk);
                if (rows > 0) {
                    flag = true;
                }
            } else {
                // 没有关注 但也给返回成功
                flag = true;
            }
        }
        return flag;
    }

    @Override
    public List getSkillData(int modelPk) {
        if (modelPk > 0) {
            List<Map<String, Object>> list = modelinfodao.getSkillData(modelPk);
            return list;
        } else {
            return null;
        }
    }

    @Override
    public boolean addSkill(int skillpk, int modelpk, String skillphoto, double price, String unit, int orderid) {
        boolean flag = false;
        if (skillpk > 0 && price > 0) {
            int rows = modelinfodao.insertModelPrice(skillpk, modelpk, skillphoto, price, unit, orderid);
            if (rows > 0) {
                flag = true;
            }
        }
        return flag;
    }

    @Override
    public boolean updateSkill(int pk, int modelpk, String skillpk, String skillphoto, String price, String unit,
                               String orderid) {
        boolean flag = false;
        if (pk > 0 && modelpk > 0) {
            int rows = modelinfodao.updateModelPrice(pk, modelpk, skillpk, skillphoto, price, unit, orderid);
            if (rows > 0) {
                flag = true;
            }
        }
        return flag;
    }

    @Override
    public Map<String, Object> dologin(String username, String pwd) {
        // 登录
        if (username != null || pwd != null) {

            //登录刷新token
            Map<String, Object> loginInfo = modelinfodao.login(username, pwd);
            if (loginInfo != null) {
                int pk = (int) loginInfo.get("pk");
                String pet = (String) loginInfo.get("pet");
                nimserverService.refreshOrCreateToken(pk, pet);
                return modelinfodao.login(username, pwd);
            } else {
                return null;
            }

        } else {
            return null;
        }

    }

    @Override
    public List<Map<String, Object>> getModelStyle(int modelpk) {
        if (modelpk > 0) {
            List<Map<String, Object>> list = modelinfodao.findSelfFigure(modelpk);
            return list;
        } else {
            return null;
        }
    }

    @Override
    public boolean setModelStyle(int modelpk, String stylepks) {
        boolean flag = false;
        if (modelpk > 0 && stylepks.length() > 0) {
            // 分割成String数组
            String[] stylepkArr = stylepks.split(",");
            if (stylepkArr.length > 0) {

                int[] stylepkArrInt = new int[stylepkArr.length];

                // 转换成int数组
                for (int i = 0; i < stylepkArr.length; i++) {
                    stylepkArrInt[i] = Integer.parseInt(stylepkArr[i]);
                }

                // 删除人才的所有风格标签
                modelinfodao.deleteModelStyleAll(modelpk);

                // 添加人才的所有标签
                int rows = modelinfodao.insertModelStyle(modelpk, stylepkArrInt);
                if (rows > 0) {
                    flag = true;
                }
            }

        }
        return flag;
    }

    @Override
    public boolean removeModelSkill(int modelpk, int skillpk) {
        boolean flag = false;
        if (modelpk > 0 && skillpk > 0) {
            int rows = modelinfodao.deleteModelPrice(modelpk, skillpk);
            if (rows > 0) {
                flag = true;
            }
        }
        return flag;
    }

    @Override
    public int doModelRegister(int memberpk, String name, int BrokePK, int BMemberPK) {
        int modelpk = modelinfodao.insertModelInfo(memberpk, name, BrokePK, BMemberPK);
        return modelpk;
    }

    @Override
    public List getModelPhoto(int modelpk) {
        if (modelpk > 0) {
            List<ModelPhoto> list = modelinfodao.findModelPhotoByModelPk(modelpk);
            return list;
        } else {
            return null;
        }
    }

    @Override
    public boolean addModelPhoto(int modelpk, String photo, int ordid) {
        boolean flag = false;
        if (modelpk > 0 && photo != null && !photo.equals("")) {

            String[] photos = photo.split(",");
            int pk = modelinfodao.insertModelPhoto(modelpk, photos, ordid);
            if (pk > 0) {
                flag = true;
            }
        }
        return flag;
    }

    @Override
    public boolean deleteModelPhoto(String modelphotopks, int modelpk) {
        boolean flag = false;
        if (modelphotopks.length() > 0 && modelpk > 0) {
            int rows = modelinfodao.deleteModelPhoto(modelphotopks, modelpk);
            if (rows > 0) {
                flag = true;
            }
        }
        return flag;
    }

    @Override
    public List getModelData(int modelpk) {
        if (modelpk > 0) {
            List list = modelinfodao.getModelData(modelpk);
            return list;
        } else {
            return null;
        }
    }

    @Override
    public boolean verifyModelPhone(String phone) {
        if (phone != null && !phone.equals("")) {
            return modelinfodao.verifyModelPhone(phone) > 0;
        }
        return false;
    }

    @Override
    public int findModelPrivateCount(int privatePk) {
        //获取订单 总数量

        if (privatePk > 0) {
            return modelinfodao.findModelPrivateCount(privatePk);
        } else {
            return 0;
        }

    }

    @Override
    public Map<String, Object> getModelLoginInfo(int modelpk) {
        if (modelpk > 0) {
            return modelinfodao.getModelLoginInfo(modelpk);
        } else {
            return null;
        }
    }

    @Override
    public Page<List> findModelLikesLimit(int privatePk, int index, int size) {
        if (privatePk > 0) {
            return modelinfodao.findModelLikesLimit(privatePk, index, size);
        } else {
            return null;
        }
    }

    @Override
    public boolean putOnline(int modelpk, int online) {
        boolean flag = false;
        if (modelpk > 0) {
            int rows = modelinfodao.updateModelOnlineByModelpk(modelpk, online);
            if (rows >= 0) {
                flag = true;
            }
        }
        return flag;
    }

    @Override
    public boolean removeModelPrivate(int privatepk) {
        boolean flag = false;
        if (privatepk > 0) {
            int rows = modelinfodao.deleteModelPrivateByPk(privatepk);
            if (rows > 0) {
                modelinfodao.deleteModelPrivateItemByPrivatepk(privatepk);
                modelinfodao.deleteModelPrivateDiscussByPrivatepk(privatepk);
                flag = true;
            }
        }
        return flag;
    }

    @Override
    public Map<String, Object> getModelVPrice(int memberpk) {
        Map<String, Object> resultMap = new HashMap<String, Object>();

        String msg = "";
        double vprice = 0;
        int is_a = 0;
        int modelpk = modelinfodao.getModelpkByMemberpk(memberpk);
        if (modelpk > 0) {
            msg = Constants.success;
            ModelInfo model = modelinfodao.findModelByPk(modelpk);
            vprice = model.getVprice();
            is_a = model.getIs_a();
        } else {
            msg = Constants.fail;
        }
        resultMap.put("msg", msg);
        resultMap.put("vprice", vprice);
        resultMap.put("modelpk", modelpk);
        resultMap.put("is_a", is_a);
        return resultMap;
    }

    @Override
    public boolean setModelHasRed(int modelpk, int hasred) {
        boolean flag = false;
        if (modelpk > 0 && (hasred == 1 || hasred == 0)) {
            int rows = modelinfodao.updateModelSetHasRedByModel(modelpk, hasred);
            if (rows > 0) {
                flag = true;
            }
        }
        return flag;
    }

    @Override
    public boolean isModel(int memberpk) {
        boolean flag = false;
        if (memberpk > 0) {
            int count = memberinfoDao.findMemberIsModel(memberpk);
            if (count > 0) {
                flag = true;
            }
        }
        return flag;
    }

    @Override
    public String getNewMemQrCode() {
        return memberinfoDao.getNewMemQrCode();
    }

    @Override
    public boolean doAddReport(ReportInfo reportInfo) {
        boolean flag = false;
        if (reportInfo != null && reportInfo.getAccuserpk() > 0 && reportInfo.getAppelleepk() > 0) {
            reportInfo.setReason(reportInfo.getReason() == null ? "" : reportInfo.getReason());
            int rows = memberinfoDao.insertReportInfo(reportInfo);
            if (rows > 0) {
                flag = true;
            }
        }
        return flag;
    }

    @Override
    public boolean removeComments(int privatepk, int modelprivatediscusspk) {
        boolean flag = false;
        if (privatepk > 0 && modelprivatediscusspk > 0) {
            int i = memberinfoDao.deleteModelPrivateDiscuss(modelprivatediscusspk, privatepk);
            if (i > 0) {
                flag = true;
            }
        }
        return flag;
    }

    @Override
    public boolean setOnline(int modelpk, int state) {
        return modelinfodao.setOnline(modelpk, state);
    }

    @Override
    public Map<String, Object> rank(int memberpk, int day) {
        return modelinfodao.queryRankList(memberpk, day);
    }

    @Override
    public boolean recommendApply(int modelpk) {
        return modelinfodao.applyRecommend(modelpk);
    }

    @Override
    public int findModelPKByMemberPK(int memberPK) {
        return modelinfodao.findModelPKByMemberPK(memberPK);
    }

    @Override
    public List<JSONObject> fans(int modelPK, int page, int size) {
        return modelinfodao.fans(modelPK, page, size);
    }

    @Override
    public int fansCount(int modelPK) {
        return modelinfodao.fansCount(modelPK);
    }

    @Override
    public String sendMsgToFans(int modelpk, String msg) {
        DSLContext ctx = DSL.using(DbConnection.getPara("MySQLURL"));

        Result<Record> result = ctx.select().from(MODELFAN).where(MODELFAN.MODELPK.equal(modelpk)).fetch();
        JSONArray toAccids = new JSONArray();
        for (Record record : result) {
            toAccids.add(record.get(MODELFAN.MEMBERPK));
        }
        Nimserver nimserver = new Nimserver();
        JSONObject body = new JSONObject();
        body.put("msg", msg);
        nimserver.sendBatchMsg("system", toAccids.toString(), "0", body.toString(), new HashMap<>());

        ctx.close();
        return "success";
    }
}