JiuShengServer/src/dsb/com/cnd3b/restcontroller/customer/wechatapplet/wechatapplet.java

package com.cnd3b.restcontroller.customer.wechatapplet;

import com.alibaba.fastjson.JSONObject;
import com.cnd3b.common.Controller;
import com.cnd3b.common.data.Row;
import com.cnd3b.common.data.Rows;
import com.cnd3b.common.data.RowsMap;
import com.cnd3b.common.data.SQLFactory;
import com.cnd3b.common.parameter.parameter;
import com.cnd3b.utility.WebRequest;
import com.cnd3b.utility.wechatdock.WechatDock_Enterprise;

import java.text.SimpleDateFormat;
import java.util.Calendar;

public class wechatapplet extends Controller {
    /**
     * 构造函数
     *
     * @param content
     */
    public wechatapplet(JSONObject content) {
        super(content);
    }

    public String wechatappletLogin() {
        String code = content.getString("code");
        String url = "https://qyapi.weixin.qq.com/cgi-bin/user/getuserinfo?access_token=" + WechatDock_Enterprise.getAccessToken2() + "&code=" + code;
//        System.err.println(url);
        String response = new WebRequest().doGet(url);
        JSONObject object = JSONObject.parseObject(response);
//        System.err.println(object);
        int errcode = object.getIntValue("errcode");
        String errmsg = object.getString("errmsg");
        if (errcode != 0) {
            return getErrReturnObject().setErrMsg(errmsg).toString();
        }
        String userid = object.getString("UserId");
        SQLFactory sqlFactory = new SQLFactory(this, "查询账号");
        sqlFactory.addParameter("wechat_userid", userid);
        Rows rows = dbConnect.runSqlQuery(sqlFactory.getSQL());
        for (Row row : rows) {
            row.put("logintime", new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(Calendar.getInstance().getTime()));
        }
        if (rows.isEmpty()) {
            return getErrReturnObject().setErrMsg("未找到用户信息").toString();
        }

        return getSucReturnObject().setData(rows).toString();
    }

    /**
     * 获取培训学习列表
     *
     * @return
     */
    public String getCoursewareList() {

        String ttypedetailid = content.getString("ttypedetailid");

        SQLFactory sqlFactory = new SQLFactory(this, "查询课件列表", pageSize, pageNumber, " t1.createdate desc");
        sqlFactory.addParameter("ttypedetailid", ttypedetailid);
        Rows rows = dbConnect.runSqlQuery(sqlFactory.getSQL());
        RowsMap rowsMap = getAttachmentUrl("tarchives_sc", rows.toArrayList("tarchives_scid"));
        //查询封面
        RowsMap rowsMapCover = getAttachmentUrl("tarchives_sc", rows.toArrayList("tarchives_scid"), "cover");
        for (Row row : rows) {
            row.put("attinfos", rowsMap.get(row.getString("tarchives_scid")));
            Rows coverRows = rowsMapCover.get(row.getString("tarchives_scid"));
            if (!coverRows.isEmpty()) {
                row.put("cover", coverRows.get(0).getString("fobsurl"));
            }

        }
        return getSucReturnObject().setDataByPaging(rows).preloading(1).toString();
    }

}