import { Inject, Provide } from '@midwayjs/decorator';
import { BaseService, ICoolCache, } from '@cool-midway/core';
import * as _ from 'lodash';
import { MysqlUtil } from '../../utils/mysqlutil';
import { DateUtil } from '../../utils/dateutil';
import { AxiosUtil } from '../../utils/axiosutil';

// 引入读写核心模块


/**
 * 系统用户
 */
@Provide()
export class RpcService extends BaseService {

    @Inject('cool:cache')
    coolCache: ICoolCache;

    @Inject()
    mysqlUtil: MysqlUtil;

    rpc_url: "http://192.168.1.4:5000/api";

    @Inject()
    dateUtil: DateUtil;

    @Inject()
    axios: AxiosUtil;

    /**
   * 远程调用设备，启动任务执行
   * @param query
   */
    async remoteCall(url, query) {
        if (url == null) {
            url = this.rpc_url;
        }
        let stattime = this.dateUtil.getCurretTimeStr()
        console.log('---------------------------------------------send msg  to device-----------------------------------------')
        console.log(query)
        // let res = await this.axios.httpPostBuffer(url, query)
        console.log('---------------------------------------receive the reply msg from device-----------------------------------')
        this.axios.httpPostBuffer(url, query).then(res => {
            console.log(res)
            const bidsql = `insert into t_config_interface_record (interface_direct,start_time,end_time,request_type,createTime,remark,status,params,result) 
                values ('${url}','${stattime}','${this.dateUtil.getCurretTimeStr()}','post',now(),'ok',200,'${JSON.stringify(query)}','${res}') `;
            this.nativeQuery(bidsql);
            return res
        }).catch((error) => {
            console.log(error)
            return error
        })

    }


    /**
     * 分页查询
     * @param query
     */
    async getData(query) {
        // const { keyWord, status, departmentIds = [] } = query;
        // const permsDepartmentArr = await this.baseSysPermsService.departmentIds(
        //   this.ctx.admin.userId
        // ); // 部门权限
        const bidsql = `select * from t_sys_business_config where id_='${query.bid}' limit 0,1`;
        const bid_obj_ = await this.nativeQuery(bidsql);
        console.log(bid_obj_)
        let sqlObj = this.mysqlUtil.create_sql(bid_obj_[0], query?.pageindex || null, query?.pagesize || null, query);
        if (sqlObj?.status == 0) {
            return sqlObj?.msg;
        }
        return this.nativeQuery(sqlObj?.sql, query);
    }


    /**
     * 分页查询
     * @param query
     */
    async getDataByNative(query) {
        // const { keyWord, status, departmentIds = [] } = query;
        // const permsDepartmentArr = await this.baseSysPermsService.departmentIds(
        //   this.ctx.admin.userId
        // ); // 部门权限
        const bidsql = `select * from t_sys_business_config where id_='${query.bid}' limit 0,1`;
        const bid_obj_ = await this.nativeQuery(bidsql);
        console.log(bid_obj_)
        let sqlObj = this.mysqlUtil.create_sql(bid_obj_[0], query?.pageindex || null, query?.pagesize || null, query);
        if (sqlObj?.status == 0) {
            return sqlObj?.msg;
        }
        return this.nativeQuery(sqlObj?.sql)
    }

    /**
     * 分页查询
     * @param query
     */
    async updateData(query) {
        // const { keyWord, status, departmentIds = [] } = query;
        // const permsDepartmentArr = await this.baseSysPermsService.departmentIds(
        //   this.ctx.admin.userId
        // ); // 部门权限
        const bidsql = `select * from t_sys_business_config where id_='${query.bid}' limit 0,1`;
        const bid_obj_ = await this.nativeQuery(bidsql);
        let sqlObj = this.mysqlUtil.create_sql(bid_obj_[0], query?.pageindex || null, query?.pagesize || null, query);
        if (sqlObj?.status == 0) {
            return sqlObj?.msg;
        }
        return this.sqlRenderPage(sqlObj?.sql, query);
    }

}