package com.product.data.center.controller;

import com.product.common.enums.IEnum;
import com.product.core.config.CoreConst;
import com.product.core.controller.support.AbstractBaseController;
import com.product.core.entity.FieldSetEntity;
import com.product.core.entity.RequestParameterEntity;
import com.product.core.exception.BaseException;
import com.product.core.spring.context.SpringMVCContextHolder;
import com.product.data.center.config.ErrorCode;
import com.product.data.center.service.DataSyncService;
import com.product.data.center.utils.RSAUtil;
import com.product.module.sys.version.ApiVersion;
import com.product.quartz.config.SystemCode;
import com.product.quartz.service.ISysJobService;
import com.product.quartz.service.impl.SysJobService;
import com.product.util.BaseUtil;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;

/**
 * @Author cheng
 * @Date 2022/11/14 14:36
 * @Desc
 */
@RestController
@RequestMapping("/api/mes/sync-data/")
public class SyncDataController extends AbstractBaseController {


    @Resource
    DataSyncService dataSyncService;
    @Resource
    SysJobService jobService;

    @RequestMapping(value = "/runTask/{version}", method = RequestMethod.POST)
    @ApiVersion(1)
    public String runTask(HttpServletResponse response,HttpServletRequest request,HttpSession session)
    {
        try {
            Object bean = request.getAttribute(CoreConst.API_POST_REQUEST_DATA);
            RequestParameterEntity reqp = (RequestParameterEntity) bean;
            String jobUuid = (String)reqp.getFormData().getValue("uuid");//表uuid
            //数据操作的权限验证
//            if(!permissionService.validDataPermission(CmnConst.PRODUCT_SYS_TIMED_TASK,jobUuid, CoreConst.DATA_PERMISSION_VALID_TYPE_USER)) {
//                SpringMVCContextHolder.getSystemLogger().error(SystemErrorCode.SYSTEM_NOT_OPER_PERMISSION.getValue(),
//                        SystemErrorCode.SYSTEM_NOT_OPER_PERMISSION.getText());
//                return this.error(SystemErrorCode.SYSTEM_NOT_OPER_PERMISSION.getValue(), SystemErrorCode.SYSTEM_NOT_OPER_PERMISSION.getText());
//            }
//			 if(!Global.getPropertyToBoolean("org.quartz.task.isEnable", "true").booleanValue()){
//				 throw new BaseException(SystemCode.SYSTEM_TIME_TASK_CLOSE);
//			 }
            Object proxyInstance = getProxyInstance(jobService);

            ISysJobService service=(ISysJobService)proxyInstance;
            service.run(jobUuid);
        } catch (BaseException e) {
            SpringMVCContextHolder.getSystemLogger().error(e);
            return this.error(e.getCode(), e.getMessageInfo());
        }
//        catch (SchedulerException e) {
//            SpringMVCContextHolder.getSystemLogger().error(e);
//            return error(SystemCode.SYSTEM_QUARTZ_RUN_FAIL.getValue(),SystemCode.SYSTEM_QUARTZ_RUN_FAIL.getText());
//        }
        catch (Exception e) {
            e.printStackTrace();
            SpringMVCContextHolder.getSystemLogger().error(e);
            return error(SystemCode.SYSTEM_QUARTZ_RUN_FAIL.getValue(),
                    SystemCode.SYSTEM_QUARTZ_RUN_FAIL.getText());
        }
        return OK();
    }

    @PostMapping("/{version}")
    @ApiVersion(1)
    public String syncData(HttpServletRequest request) {
        try {
            FieldSetEntity fieldSetEntity = BaseUtil.getFieldSetEntity(request);
            String syncInfo = fieldSetEntity.getString("syncInfo");
            String encodedData = RSAUtil.publicEncrypt(syncInfo, RSAUtil.getPublicKey(dataSyncService.cryptPublicKey));
//            dataSyncService.dataSync(encodedData);
            return OK();
        } catch (Exception e) {
            e.printStackTrace();
            return error(ErrorCode.DATA_SYNC_FAIL.getValue(), getErrorMessage(ErrorCode.DATA_SYNC_FAIL, e));
        }
    }


    public String getErrorMessage(IEnum iEnum, Throwable throwable) {
        String message = iEnum.getText();
        if (throwable.getMessage() != null) {
            message += "," + throwable.getMessage();
        }
        return message;
    }
}