fanli-server.git

package com.yeshi.fanli.controller.admin.user.cloud; 
 
import java.io.PrintWriter; 
import java.util.List; 
 
import javax.annotation.Resource; 
 
import org.springframework.stereotype.Controller; 
import org.springframework.web.bind.annotation.RequestMapping; 
import org.yeshi.utils.JsonUtil; 
 
import com.google.gson.Gson; 
import com.google.gson.GsonBuilder; 
import com.yeshi.fanli.entity.bus.user.UserInfo; 
import com.yeshi.fanli.entity.bus.user.cloud.UserCloud; 
import com.yeshi.fanli.entity.bus.user.cloud.UserCloudGoods; 
import com.yeshi.fanli.entity.bus.user.cloud.UserCloudGroup; 
import com.yeshi.fanli.entity.bus.user.cloud.UserCloudOrder; 
import com.yeshi.fanli.entity.bus.user.cloud.UserCloudSendContent; 
import com.yeshi.fanli.entity.bus.user.cloud.UserCloudSendRecord; 
import com.yeshi.fanli.log.LogHelper; 
import com.yeshi.fanli.service.inter.dynamic.GoodsEvaluateService; 
import com.yeshi.fanli.service.inter.user.UserInfoService; 
import com.yeshi.fanli.service.inter.user.cloud.UserCloudGoodsService; 
import com.yeshi.fanli.service.inter.user.cloud.UserCloudGroupService; 
import com.yeshi.fanli.service.inter.user.cloud.UserCloudManageService; 
import com.yeshi.fanli.service.inter.user.cloud.UserCloudOrderService; 
import com.yeshi.fanli.service.inter.user.cloud.UserCloudSendContentService; 
import com.yeshi.fanli.service.inter.user.cloud.UserCloudSendRecordService; 
import com.yeshi.fanli.service.inter.user.cloud.UserCloudService; 
import com.yeshi.fanli.service.manger.alipay.UserCloudAlipayManager; 
import com.yeshi.fanli.tag.PageEntity; 
import com.yeshi.fanli.util.Constant; 
 
import net.sf.json.JSONObject; 
 
@Controller 
@RequestMapping("admin/new/api/v1/cloud") 
public class  UserCloudAdminController { 
 
    @Resource 
    private UserCloudService userCloudService; 
 
    @Resource 
    private UserCloudOrderService userCloudOrderService; 
 
    @Resource 
    private UserCloudGroupService userCloudGroupService; 
 
    @Resource 
    private UserCloudGoodsService userCloudGoodsService; 
 
    @Resource 
    private UserInfoService userInfoService; 
 
    @Resource 
    private UserCloudSendRecordService userCloudSendRecordService; 
 
    @Resource 
    private UserCloudManageService userCloudManageService; 
 
    @Resource 
    private UserCloudAlipayManager userCloudAlipayManager; 
     
    @Resource 
    private GoodsEvaluateService goodsEvaluateService; 
     
    @Resource 
    private UserCloudSendContentService userCloudSendContentService; 
     
     
     
    /** 
     * 订单信息查询 
     * @param callback 
     * @param pageIndex 
     * @param key 
     * @param state 
     * @param out 
     */ 
    @RequestMapping(value = "queryOrder") 
    public void queryOrder(String callback, Integer pageIndex, Integer pageSize, String key, Integer state, PrintWriter out) { 
        try { 
            if (pageIndex == null) 
                pageIndex = 1; 
            if (pageSize == null) 
                pageSize = Constant.PAGE_SIZE; 
            List<UserCloudOrder> list = userCloudOrderService.query(pageIndex, pageSize, key, state); 
            if (list == null || list.size() == 0) { 
                out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("暂无数据"))); 
                return; 
            } 
             
            for (UserCloudOrder cloudOrder: list) { 
                UserInfo userInfo = userInfoService.getUserByIdWithMybatis(cloudOrder.getUid()); 
                if (userInfo == null) 
                    continue; 
                 
                cloudOrder.setNickName(userInfo.getNickName()); 
                cloudOrder.setPortrait(userInfo.getPortrait()); 
            } 
             
            GsonBuilder gsonBuilder = new GsonBuilder(); 
            gsonBuilder.serializeNulls(); // 重点 
            Gson gson = gsonBuilder.setDateFormat("yyyy/MM/dd HH:mm:ss").create(); 
 
            long count = userCloudOrderService.count(key, state); 
            int totalPage = (int) (count % pageSize == 0 ? count / pageSize : count / pageSize + 1); 
            PageEntity pe = new PageEntity(pageIndex, pageSize, count, totalPage); 
             
            JSONObject data = new JSONObject(); 
            data.put("pe", pe); 
            data.put("list", gson.toJson(list)); 
            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult(data))); 
        } catch (Exception e) { 
            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("操作异常"))); 
            e.printStackTrace(); 
            LogHelper.errorDetailInfo(e); 
        } 
    } 
  
     
    /** 
     * 开通成功记录 
     * @param callback 
     * @param pageIndex 
     * @param key 
     * @param state 
     * @param out 
     */ 
    @RequestMapping(value = "queryCloud") 
    public void queryCloud(String callback, Integer pageIndex, Integer pageSize, String key, Integer state, PrintWriter out) { 
        try { 
            if (pageIndex == null) 
                pageIndex = 1; 
            if (pageSize == null) 
                pageSize = Constant.PAGE_SIZE; 
            List<UserCloud> list = userCloudService.query(pageIndex, pageSize, key, state); 
            if (list == null || list.size() == 0) { 
                out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("暂无数据"))); 
                return; 
            } 
             
            for (UserCloud userCloud: list) { 
                UserInfo userInfo = userInfoService.getUserByIdWithMybatis(userCloud.getUid()); 
                if (userInfo == null) 
                    continue; 
                 
                userCloud.setNickName(userInfo.getNickName()); 
                userCloud.setPortrait(userInfo.getPortrait()); 
            } 
             
            GsonBuilder gsonBuilder = new GsonBuilder(); 
            gsonBuilder.serializeNulls(); // 重点 
            Gson gson = gsonBuilder.setDateFormat("yyyy/MM/dd HH:mm:ss").create(); 
 
            long count = userCloudService.count(key, state); 
            int totalPage = (int) (count % pageSize == 0 ? count / pageSize : count / pageSize + 1); 
            PageEntity pe = new PageEntity(pageIndex, pageSize, count, totalPage); 
             
            JSONObject data = new JSONObject(); 
            data.put("pe", pe); 
            data.put("list", gson.toJson(list)); 
            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult(data))); 
        } catch (Exception e) { 
            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("操作异常"))); 
            e.printStackTrace(); 
            LogHelper.errorDetailInfo(e); 
        } 
    } 
     
     
    /** 
     * 查询发送记录 
     * @param callback 
     * @param pageIndex 
     * @param pageSize 
     * @param key 
     * @param origin 
     * @param out 
     */ 
    @RequestMapping(value = "querySendRecord") 
    public void querySendRecord(String callback, Integer pageIndex, Integer pageSize, String key, Integer origin, PrintWriter out) { 
        try { 
            if (pageIndex == null) 
                pageIndex = 1; 
            if (pageSize == null) 
                pageSize = Constant.PAGE_SIZE; 
            List<UserCloudSendRecord> list = userCloudSendRecordService.query(pageIndex, pageSize, key, origin); 
            if (list == null || list.size() == 0) { 
                out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("暂无数据"))); 
                return; 
            } 
             
            for (UserCloudSendRecord userCloud: list) { 
                UserInfo userInfo = userInfoService.getUserByIdWithMybatis(userCloud.getUid()); 
                if (userInfo == null) 
                    continue; 
                 
                userCloud.setNickName(userInfo.getNickName()); 
                userCloud.setPortrait(userInfo.getPortrait()); 
            } 
             
            GsonBuilder gsonBuilder = new GsonBuilder(); 
            gsonBuilder.serializeNulls(); // 重点 
            Gson gson = gsonBuilder.setDateFormat("yyyy/MM/dd HH:mm:ss").create(); 
 
            long count = userCloudSendRecordService.count(key, origin); 
            int totalPage = (int) (count % pageSize == 0 ? count / pageSize : count / pageSize + 1); 
            PageEntity pe = new PageEntity(pageIndex, pageSize, count, totalPage); 
             
            JSONObject data = new JSONObject(); 
            data.put("pe", pe); 
            data.put("list", gson.toJson(list)); 
            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult(data))); 
        } catch (Exception e) { 
            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("操作异常"))); 
            e.printStackTrace(); 
            LogHelper.errorDetailInfo(e); 
        } 
    } 
     
    /** 
     * 查询发送内容 
     * @param callback 
     * @param pid 
     * @param origin 
     * @param out 
     */ 
    @RequestMapping(value = "getSendContent") 
    public void getSendContent(String callback, String pid, Integer origin, PrintWriter out) { 
        try { 
            List<UserCloudSendContent> list = userCloudSendContentService.getByPid(pid); 
            if (list == null || list.size() == 0) { 
                out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("暂无数据"))); 
                return; 
            } 
             
            GsonBuilder gsonBuilder = new GsonBuilder(); 
            gsonBuilder.serializeNulls(); // 重点 
            Gson gson = gsonBuilder.setDateFormat("yyyy/MM/dd HH:mm:ss").create(); 
 
            long count = list.size(); 
            int totalPage = (int) (count % 20 == 0 ? count / 20 : count / 20 + 1); 
            PageEntity pe = new PageEntity(1, 20, count, totalPage); 
             
            JSONObject data = new JSONObject(); 
            data.put("pe", pe); 
            data.put("list", gson.toJson(list)); 
            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult(data))); 
        } catch (Exception e) { 
            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("操作异常"))); 
            e.printStackTrace(); 
            LogHelper.errorDetailInfo(e); 
        } 
    } 
     
    /** 
     * 查询用户群信息 
     * @param callback 
     * @param uid 
     * @param out 
     */ 
    @RequestMapping(value = "getUserGroups") 
    public void getUserGroups(String callback, Long uid, PrintWriter out) { 
        try { 
            List<UserCloudGroup> list = userCloudGroupService.listByUid(uid); 
            if (list == null || list.size() == 0) { 
                out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("暂无数据"))); 
                return; 
            } 
             
            GsonBuilder gsonBuilder = new GsonBuilder(); 
            gsonBuilder.serializeNulls(); // 重点 
            Gson gson = gsonBuilder.setDateFormat("yyyy/MM/dd HH:mm:ss").create(); 
 
            long count = list.size(); 
            int totalPage = (int) (count % 20 == 0 ? count / 20 : count / 20 + 1); 
            PageEntity pe = new PageEntity(1, 20, count, totalPage); 
             
            JSONObject data = new JSONObject(); 
            data.put("pe", pe); 
            data.put("list", gson.toJson(list)); 
            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult(data))); 
        } catch (Exception e) { 
            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("操作异常"))); 
            e.printStackTrace(); 
            LogHelper.errorDetailInfo(e); 
        } 
    } 
     
     
    /** 
     * 开通成功记录 
     * @param callback 
     * @param pageIndex 
     * @param key 
     * @param state 
     * @param out 
     */ 
    @RequestMapping(value = "queryGoodsList") 
    public void queryGoodsList(String callback, Integer pageIndex, Integer pageSize, String key, PrintWriter out) { 
        try { 
            if (pageIndex == null) 
                pageIndex = 1; 
            if (pageSize == null) 
                pageSize = Constant.PAGE_SIZE; 
             
            List<UserCloudGoods> list = userCloudGoodsService.query(pageIndex, pageSize, key); 
            if (list == null || list.size() == 0) { 
                out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("暂无数据"))); 
                return; 
            } 
             
            for (UserCloudGoods userCloud: list) { 
                UserInfo userInfo = userInfoService.getUserByIdWithMybatis(userCloud.getUid()); 
                if (userInfo == null) 
                    continue; 
                 
                userCloud.setNickName(userInfo.getNickName()); 
                userCloud.setPortrait(userInfo.getPortrait()); 
            } 
             
            GsonBuilder gsonBuilder = new GsonBuilder(); 
            gsonBuilder.serializeNulls(); // 重点 
            Gson gson = gsonBuilder.setDateFormat("yyyy/MM/dd HH:mm:ss").create(); 
 
            long count = userCloudGoodsService.count(key); 
            int totalPage = (int) (count % pageSize == 0 ? count / pageSize : count / pageSize + 1); 
            PageEntity pe = new PageEntity(pageIndex, pageSize, count, totalPage); 
             
            JSONObject data = new JSONObject(); 
            data.put("pe", pe); 
            data.put("list", gson.toJson(list)); 
            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult(data))); 
        } catch (Exception e) { 
            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("操作异常"))); 
            e.printStackTrace(); 
            LogHelper.errorDetailInfo(e); 
        } 
    } 
     
     
}