package com.product.contract.service;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.product.contract.config.CmnConst;
import com.product.contract.service.ide.IProjectBusinessService;
import com.product.core.dao.BaseDao;
import com.product.core.entity.DataTableEntity;
import com.product.core.entity.FieldSetEntity;
import com.product.core.service.support.AbstractBaseService;
import com.product.core.transfer.Transactional;
import com.product.util.BaseUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
public class ProjectBusinessService extends AbstractBaseService implements IProjectBusinessService {

	@Autowired
	public BaseDao baseDao;

	@Override
	public JSONObject findProject(FieldSetEntity fse) {
		FieldSetEntity fsData = baseDao.getFieldSet(CmnConst.PRODUCT_PROJECT_BUSINESS, fse.getUUID(), false);
		//计算整体项目进度
		String sql ="SELECT CONCAT(sum(REPLACE(a.task_rate, '%', ''))/COUNT(*),'%') task_rate FROM `product_project_schedule_weekly_sub` a\n" +
				"LEFT JOIN  product_project_schedule_weekly b on a.main_uuid=b.uuid\n" +
				"where a.project_uuid=? and b.flow_flag =2 GROUP BY project_uuid";
		FieldSetEntity task_rate_fs = baseDao.getFieldSetEntityBySQL(sql, new String[]{fse.getUUID()}, false);
		if (!FieldSetEntity.isEmpty(task_rate_fs)){
			fsData.setValue("schedule",task_rate_fs.getString("task_rate"));
		}
		//封装项目计划数据接口
		JSONObject json = new JSONObject();
		DataTableEntity planData=baseDao.listTable(CmnConst.PRODUCT_PROJECT_BUSINESS_PLAN,"project_uuid=?",new String[]{fse.getUUID()});
		for (int i = 0; i <planData.getRows() ; i++) {
			FieldSetEntity fs = planData.getFieldSetEntity(i);
			JSONObject jsonObject = BaseUtil.fieldSetEntityToJson(fs);
			JSONArray projectTask = json.getJSONArray(fs.getString("project_task"));
			if (projectTask==null){
				JSONArray objects = new JSONArray();
				objects.add(jsonObject);
				json.put(fs.getString("project_task"),objects);
			}else {
				projectTask.add(jsonObject);
			}
		}
		JSONObject rejson=BaseUtil.fieldSetEntityToJson(fsData);
		rejson.put(CmnConst.PRODUCT_PROJECT_BUSINESS_PLAN,json);
		//封装项目进度数据结构
		DataTableEntity scheduleDt =baseDao.listTable("select  project_task_sub,a.*  from product_project_schedule a\n" +
				"LEFT JOIN product_project_business_plan b  on a.business_sub_uuid =b.uuid\n" +
				"where b.project_uuid=? order by a.business_sub_uuid,a.reporting_time",new String[]{fse.getUUID()});
		baseDao.loadPromptData(scheduleDt);
		rejson.put(CmnConst.PRODUCT_PROJECT_SCHEDULE,BaseUtil.dataTableEntityToJson(scheduleDt));
        //封装资料数据结构
		DataTableEntity dataList = baseDao.listTable(CmnConst.PRODUCT_PROJECT_MANAGER_DATA_LIST, "project_type=?", new String[]{fsData.getString("project_type")});
		rejson.put(CmnConst.PRODUCT_PROJECT_MANAGER_DATA_LIST,BaseUtil.dataTableEntityToJson(dataList));
		return rejson;
	}
	@Override
	public JSONObject findTranslate(FieldSetEntity fse) {
		FieldSetEntity fsData = baseDao.getFieldSetBySQL("SELECT project_type,date FROM product_project_business_translate where project_type=?", new String[]{fse.getString("project_type")}, false);
		JSONObject rejson=BaseUtil.fieldSetEntityToJson(fsData);
		DataTableEntity projectType = baseDao.listTable(CmnConst.PRODUCT_PROJECT_BUSINESS_TRANSLATE, "project_type=? ORDER BY project_task", new String[]{fse.getString("project_type")});
		JSONObject json = new JSONObject();
		for (int i = 0; i < projectType.getRows(); i++) {
			FieldSetEntity fs = projectType.getFieldSetEntity(i);
			fs.remove("uuid");
			if (json.getJSONArray(fs.getString("project_task"))==null){
				JSONArray objects = new JSONArray();
				objects.add(BaseUtil.fieldSetEntityToJson(fs));
				json.put(fs.getString("project_task"),objects);

			}else {
				JSONArray projectTask = json.getJSONArray(fs.getString("project_task"));
				projectTask.add(BaseUtil.fieldSetEntityToJson(fs));
			}
		}
		rejson.put(CmnConst.PRODUCT_PROJECT_BUSINESS_TRANSLATE,json);
		
		
		return rejson;
	}
	@Transactional
	@Override
	public boolean saveTranslate(FieldSetEntity fs) {
		DataTableEntity dt = fs.getSubDataTable(CmnConst.PRODUCT_PROJECT_BUSINESS_TRANSLATE);
		boolean a=true;
		for (int i = 0; i < dt.getRows(); i++) {
			FieldSetEntity fse = dt.getFieldSetEntity(i);
			fse.setValue("project_type",fs.getString("project_type"));
			fse.setValue("date",fs.getString("date"));
			BaseUtil.createCreatorAndCreationTime(fse);
			if (fse.getUUID()==null){
				String uuid= baseDao.add(fse);
				if (uuid==null) a= false;
			}else if (fse.getString("~type~")!=null&&fse.getString("~type~").equals("del")){
				boolean delete = baseDao.delete(CmnConst.PRODUCT_PROJECT_BUSINESS_TRANSLATE, "uuid=?", new String[]{fse.getUUID()});
				if (!delete) a= false;
			}else {
				boolean update = baseDao.update(fse);
				if (!update) a= false;
			}
		}
		return a;
	}
	@Transactional
	@Override
	public boolean saveProject(FieldSetEntity fse) {
		if (fse.getString("del").equals("2")){
			baseDao.delete(CmnConst.PRODUCT_PROJECT_BUSINESS_PLAN,"project_uuid=?",new String[]{fse.getUUID()});
		}
		return baseDao.saveFieldSetEntity(BaseUtil.createCreatorAndCreationTime(fse));
	}
}